--[[
|
版本： Version 2.1
|
创建日期： 2024-7-26
|
创建人： HAN
|
|
WMS-Basis-Model-Version: V15.5
|
|
功能：
|
所以和入库相关的函数
|
|
更改说明：
|
|
--]]
|
|
wms_base = require ("wms_base")
|
wms_wh = require ("wms_wh")
|
|
local wms_in = {_version = "0.2.1"}
|
|
--[[
|
预分配容器取消
|
-- 组盘【Pre_Alloc_Container】状态设置为 6/取消 同时
|
-- 组盘明细【Pre_Alloc_CNTR_Detail】状态改为 3
|
-- 来源业务数据中的取消数量+ 组盘明细中的数量
|
--]]
|
function wms_in.Pre_Alloc_CNTR_Cancel( strLuaDEID, pac_obj )
|
local n, nRet, strRetInfo
|
-- 组盘已经完成或取消状态不需要再做 取消
|
if ( pac_obj.b_state > 1 ) then return 0 end
|
|
-- 6 表示'取消'
|
local strUpdateSql = "N_B_STATE = 6"
|
local strCondition = "S_PAC_NO = '"..pac_obj.pac_no.."'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Pre_Alloc_Container", strCondition, strUpdateSql )
|
if ( nRet ~= 0 ) then return 1, "更新【预分配容器】信息失败!"..strRetInfo end
|
-- 更新 Pre_Alloc_CNTR_Detail 中的状态
|
strUpdateSql = "N_B_STATE = 3"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Pre_Alloc_CNTR_Detail", strCondition, strUpdateSql )
|
if ( nRet ~= 0 ) then return 1, "更新【预分配容器明细】信息失败!"..strRetInfo end
|
|
-- 查询组盘明细
|
local data_objects
|
nRet, data_objects = m3.QueryDataObject(strLuaDEID, "Pre_Alloc_CNTR_Detail", strCondition, "N_BS_ROW_NO" )
|
if (nRet ~= 0) then return 2, "QueryDataObject失败!"..data_objects end
|
if ( data_objects == '') then return 0 end
|
|
local obj_attrs
|
local strSetAttr
|
for n = 1, #data_objects do
|
obj_attrs = m3.KeyValueAttrsToObjAttr(data_objects[n].attrs)
|
|
-- 根据业务来源加 F_ACC_I_QTY/累计入库数量
|
if ( obj_attrs.S_BS_TYPE == "Inbound_Order" ) then
|
if ( obj_attrs.S_BS_NO ~= nil and obj_attrs.S_BS_NO ~= '' ) then
|
strCondition = "S_IO_NO = '"..obj_attrs.S_BS_NO.."' AND S_ITEM_CODE = '"..obj_attrs.S_ITEM_CODE.."'"
|
strSetAttr = "F_ACC_C_QTY = F_ACC_C_QTY + "..obj_attrs.F_QTY
|
nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "Inbound_Detail", strCondition, strSetAttr )
|
if (nRet ~= 0) then return 1, "设置【Inbound_Detail】累计入库数量失败!"..strRetInfo end
|
end
|
elseif ( obj_attrs.S_BS_TYPE == 'Inbound_Wave' ) then
|
if ( obj_attrs.S_BS_NO ~= nil and obj_attrs.S_BS_NO ~= '' ) then
|
strCondition = "S_WAVE_NO = '"..obj_attrs.S_BS_NO.."' AND S_ITEM_CODE = '"..obj_attrs.S_ITEM_CODE.."'"
|
strSetAttr = "F_ACC_C_QTY = F_ACC_C_QTY + "..obj_attrs.F_QTY
|
nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "IW_Detail", strCondition, strSetAttr )
|
if (nRet ~= 0) then return 1, "设置【IW_Detail】累计入库数量失败!"..strRetInfo end
|
end
|
end
|
end
|
return 0
|
end
|
|
-- 获取收货单明细和存储量有关的信息
|
local function get_inventory_info( strLuaDEID, receipt_obj )
|
local inventory_info = '{"wh_code": "'..receipt_obj.wh_code..'",'
|
inventory_info = inventory_info..'"area_code": "'..receipt_obj.area_code..'",'
|
inventory_info = inventory_info..'"item_code": "'..receipt_obj.item_code..'",'
|
inventory_info = inventory_info..'"item_name": "'..lua.FormatJsonString(receipt_obj.item_name)..'",'
|
inventory_info = inventory_info..'"item_state": "'..receipt_obj.item_state..'",'
|
inventory_info = inventory_info..'"item_route": "'..receipt_obj.item_route..'",'
|
inventory_info = inventory_info..'"qty": "'..receipt_obj.qty..'"}'
|
return inventory_info
|
end
|
|
-- 通过收货单创建检验单及验单明细，并且加仓库
|
-- receipt_obj 收货单数对象
|
-- inspection_area 检验区
|
function wms_in.CreateInspectionOrder( strLuaDEID, receipt_obj, inspection_area )
|
local strCondition, nRet, strRetInfo
|
|
-- step1 创建检验单
|
local inspection = m3.AllocObject(strLuaDEID,"Inspect_Order")
|
local ret_obj
|
local n, area_items
|
|
inspection.wms_op_no = receipt_obj.no
|
inspection.inspect_type = 1 -- 收货检
|
inspection.factory = receipt_obj.factory
|
inspection.bs_type = receipt_obj.bs_type
|
inspection.bs_no = receipt_obj.bs_no
|
inspection.wh_code = receipt_obj.wh_code
|
|
-- 获取检验区
|
-- 获取仓库检验区可以看成是逻辑上的检验区)
|
local inspection_area = ''
|
n,area_items = wms_wh.GetArea( strLuaDEID, wh_code, 3 )
|
if ( n == 1 ) then
|
inspection_area = lua.trim_quotation_mark( area_items )
|
elseif ( n > 1 ) then
|
end
|
inspection.area_code = inspection_area
|
|
nRet, ret_obj = m3.CreateDataObj( strLuaDEID, inspection )
|
if ( nRet ~= 0 ) then return 1, "创建【检验单】失败! "..ret_obj end
|
local strNo = ret_obj.no
|
if ( strNo == nil or strNo == '' ) then return 1, "创建【检验单】后获取的验单号为空或 nil! " end
|
|
-- step2: 获取收货单明细生成验单明细
|
local strOrder = 'N_ROW_NO'
|
strCondition = "S_RECEIPT_NO = '"..receipt_obj.no.."'"
|
nRet, strRetInfo = mobox.queryDataObjAttr( strLuaDEID, "Receipt_Detail", strCondition, strOrder, "S_ITEM_CODE", "S_ITEM_NAME","S_ITEM_SPEC","N_ITEM_STATE",
|
"S_BATCH_NO", "S_SERIAL_NO", "F_QTY", "S_UOM", "S_BATCH_NO", "S_SERIAL_NO" )
|
if ( nRet ~= 0 ) then return 1, "获取【收货单明细】失败! "..strRetInfo end
|
|
local retObjs = json.decode( strRetInfo )
|
local nObjs = #retObjs
|
local n, nMaxAttr
|
local attrs
|
local receipt_detail
|
local inventory_change = ''
|
|
for n = 1, nObjs do
|
attrs = retObjs[n].attrs
|
nMaxAttr = #attrs
|
nRet, receipt_detail = m3.ObjAttrStrToLuaObj( "Receipt_Detail", lua.table2str(attrs) )
|
if ( nRet ~= 0 ) then return 1, "m3.ObjAttrStrToLuaObj(Receipt_Detail) 失败! "..receipt_detail end
|
|
attrs[nMaxAttr+1] = lua.KeyValueObj( "S_INSPECT_NO", strNo )
|
nRet, strRetInfo = mobox.createDataObj( strLuaDEID, "Inspect_Detail", lua.table2str(attrs) )
|
if ( nRet ~= 0 ) then return 1, "创建【检验单明细】失败! "..strRetInfo end
|
|
-- 生成仓库量变化输入参
|
inventory_change = inventory_change .. get_inventory_info( strLuaDEID, receipt_detail )..","
|
end
|
inventory_change = lua.trim_laster_char( inventory_change )
|
if ( inventory_change ~= '' ) then
|
nRet, strRetInfo = wms.wms_AddWHInventoryChange(strLuaDEID, 5, '['..inventory_change..']')
|
if ( nRet ~= 0 ) then return 1, "wms_AddWHInventoryChange 失败! "..strRetInfo end
|
end
|
|
return 0
|
end
|
|
|
return wms_in
|
