--[[
|
编码: WMS-57-11
|
名称: 预分配容器-入库后处理
|
作者：HAN
|
日期：2025-1-29
|
|
级别：项目
|
|
函数： PostProcess
|
|
功能:
|
-- 检查业务来源【入库波次】中的货品是否有全部入库完成
|
-- 如果已经全部完成，触发【入库单】完工回报
|
更改记录:
|
|
--]]
|
wms_base = require ("wms_base")
|
|
function PostProcess ( strLuaDEID )
|
local nRet, strRetInfo
|
local pa_cntr = {}
|
nRet, pa_cntr = m3.GetSysCurEditDataObj( strLuaDEID, "Pre_Alloc_Container" )
|
if (nRet ~= 0) then
|
lua.Stop( strLuaDEID, "获取【预分配容器】对象属性失败!"..pa_cntr )
|
return
|
end
|
|
-- 只有对已经完成入库/5的或取消入库/6 预分配容器 进行后处理
|
if ( pa_cntr.b_state ~= 5 and pa_cntr.b_state ~= 6 ) then return end
|
|
-- 判断来源业务（入库波次）是否可以完工
|
local strCondition
|
if ( pa_cntr.bs_type == "Inbound_Wave" ) then
|
strCondition = "F_QTY > (F_ACC_I_QTY + F_ACC_C_QTY) AND S_WAVE_NO = '"..pa_cntr.bs_no.."'"
|
|
nRet, strRetInfo = mobox.getDataObjCount( strLuaDEID, "IW_Detail", strCondition )
|
if ( nRet ~= 0 ) then
|
lua.Stop( strLuaDEID, "getDataObjCount失败!"..strRetInfo )
|
return
|
end
|
local nCount = lua.StrToNumber( strRetInfo )
|
|
if ( nCount == 0 ) then
|
-- 入库波次可以完工
|
-- N_B_STATE = 3 入库完成
|
strSetAttr = "N_B_STATE = 3"
|
strCondition = "S_WAVE_NO = '"..pa_cntr.bs_no.."'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Inbound_Wave", strCondition, strSetAttr )
|
if ( nRet ~= 0 ) then
|
lua.Stop( strLuaDEID, "更新【入库波次】状态息失败!"..strRetInfo )
|
return
|
end
|
-- 设置 N_B_STATE = 3 入库单完成
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Inbound_Order", strCondition, strSetAttr )
|
if ( nRet ~= 0 ) then
|
lua.Stop( strLuaDEID, "更新【入库单】状态息失败!"..strRetInfo )
|
return
|
end
|
|
nRet, strRetInfo = wms_base.InboundWave_Finish_PostProce( strLuaDEID, pa_cntr.bs_no )
|
if ( nRet ~= 0 ) then
|
lua.Stop( strLuaDEID, "WMS_InboundWave_Finish_PostProce失败!"..strRetInfo )
|
return
|
end
|
|
-- 触发入库波次里的【入库单】报完工 WFP
|
strCondition = "S_NO IN ( Select S_WEO_NO From TN_IW_Compose with (NOLOCK) Where S_WAVE_NO = '"..pa_cntr.bs_no.."')"
|
-- 找出入库波次组成的入库单
|
local data_objs
|
nRet, data_objs = m3.QueryDataObject(strLuaDEID, "Inbound_Order", strCondition, "S_NO" )
|
if (nRet ~= 0) then
|
lua.Stop( strLuaDEID, "QueryDataObject失败!"..data_objs )
|
return
|
end
|
if ( data_objs == '' ) then return end
|
|
local n
|
local obj_attrs
|
local add_wfp = {}
|
for n = 1, #data_objs do
|
obj_attrs = m3.KeyValueAttrsToObjAttr(data_objs[n].attrs)
|
-- 增加一个后台进程进行入库单完工回报
|
add_wfp = {
|
wfp_type = 1, -- 触发数据对象事件（指定数据对象标识）
|
cls = "入库单",
|
obj_id = data_objs[n].id,
|
obj_name = "入库单号'"..obj_attrs.S_NO.."'-->完工回报",
|
trigger_event = "完工回报"
|
}
|
nRet, strRetInfo = m3.AddSysWFP( strLuaDEID, add_wfp )
|
if ( nRet ~= 0 ) then
|
lua.Stop( strLuaDEID, "AddSysWFP失败!"..strRetInfo )
|
return
|
end
|
end
|
end
|
elseif ( pa_cntr.bs_type == "Inbound_Order" ) then
|
strCondition = "F_QTY > (F_ACC_I_QTY + F_ACC_C_QTY) AND S_IO_NO = '"..pa_cntr.bs_no.."'"
|
nRet, strRetInfo = mobox.getDataObjCount( strLuaDEID, "Inbound_Detail", strCondition )
|
if ( nRet ~= 0 ) then
|
lua.Stop( strLuaDEID, "getDataObjCount失败!"..strRetInfo )
|
return
|
end
|
local nCount = lua.StrToNumber( strRetInfo )
|
|
if ( nCount == 0 ) then
|
-- 入库单可以完工
|
-- N_B_STATE = 3 入库完成
|
strSetAttr = "N_B_STATE = 3"
|
strCondition = "S_IO_NO = '"..pa_cntr.bs_no.."'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Inbound_Order", strCondition, strSetAttr )
|
if ( nRet ~= 0 ) then
|
lua.Stop( strLuaDEID, "更新【入库单】状态失败!"..strRetInfo )
|
return
|
end
|
|
local inbound_order
|
nRet, inbound_order = m3.GetDataObjectByKey( strLuaDEID, "Inbound_Order", "S_IO_NO", pa_cntr.bs_no )
|
if ( nRet ~= 0 ) then
|
lua.Stop( strLuaDEID, "获取【入库单】信息失败!"..inbound_order )
|
return
|
end
|
-- 触发【入库单】报完工 WFP
|
-- 增加一个后台进程进行入库单完工回报
|
local add_wfp = {
|
wfp_type = 1, -- 触发数据对象事件（指定数据对象标识）
|
cls = "入库单",
|
obj_id = inbound_order.id,
|
obj_name = "入库单号'"..pa_cntr.bs_no.."'-->完工回报",
|
trigger_event = "完工回报"
|
}
|
nRet, strRetInfo = m3.AddSysWFP( strLuaDEID, add_wfp )
|
if ( nRet ~= 0 ) then
|
lua.Stop( strLuaDEID, "AddSysWFP失败!"..strRetInfo )
|
return
|
end
|
end
|
end
|
end
|
