--[[
|
版本： Version 1.0
|
创建日期： 2023-6-16
|
创建人： HAN
|
|
功能：
|
和盘点相关的一些标准函数
|
|
-- Create_CountOrder_ByCountPlan 根据盘点计划创建盘点单
|
-- Count_PostProcess 盘点后处理
|
|
更改说明：
|
--]]
|
wms_base = require ("wms_base")
|
|
local wms_count = {_version = "0.1.1"}
|
|
local COUNT_PLAN_TYPE_GOODS = 1 -- 货品盘点
|
local COUNT_PLAN_TYPE_LOCATION = 2 -- 货位盘点
|
|
|
--[[
|
根据盘点计划 count_plan 创建一个盘点单数据对象，触发 num 个【】计划盘点容器进行"生成盘点货品明细",
|
-- method 盘点方法 1 -- 人工到货位盘点 2 -- 自动设备搬运到站台
|
-- station 如果method = 2 必须有值
|
]]
|
function wms_count.Create_CountOrder_ByCountPlan( strLuaDEID, count_plan, method, station, num )
|
local nRet, strRetInfo, n
|
|
-- step1：输入参数合法性检查
|
if ( count_plan == nil or count_plan == '') then return 1, "count_plan 必须有值!" end
|
if ( method == nil or type(method) ~= "number" ) then method = 2 end
|
if ( method == 2 ) then
|
if ( station == nil or station == '') then return 1, "station 必须有值!" end
|
end
|
if ( num == nil ) then num = 0 end
|
|
-- 获取常量 盘点差异需要审核 = Y
|
local diff_need_review = wms_base.Get_sConst( strLuaDEID, "盘点差异需要审核", 1 )
|
local diff_hand_method = 0
|
-- 1 表示有差异需要审核后才能变
|
if ( diff_need_review == "Y" ) then diff_hand_method = 1 end
|
|
-- step2：创建盘点单
|
local count_order = m3.AllocObject(strLuaDEID,"Count_Order")
|
count_order.cp_no = count_plan.cp_no
|
count_order.wh_code = count_plan.wh_code
|
count_order.area_code = count_plan.area_code
|
count_order.method = method -- 1 表示是人工盘点，这是新兴项目的要求
|
count_order.num = num
|
count_order.station = station
|
count_order.count_type = count_plan.type
|
count_order.diff_hand_method = diff_hand_method
|
nRet, count_order = m3.CreateDataObj( strLuaDEID, count_order )
|
if (nRet ~= 0) then return 1, "创建【盘点单】失败!"..count_order end
|
|
|
-- step3：查询盘点计划中没有盘点单的【计划盘点容器】
|
-- 特别注意需要 多页查询
|
local strCondition = "S_CP_NO = '"..count_plan.cp_no.."' AND N_B_STATE = 0"
|
nRet, strRetInfo = mobox.queryDataObjAttr2( strLuaDEID, "CP_Count_Container", strCondition, strOrder, 100 )
|
if ( nRet ~= 0 ) then return 1, "queryDataObjAttr2: "..strRetInfo end
|
if ( strRetInfo == '' ) then return 1, "盘点计划'".. count_plan.cp_no.."'中没有待盘点的容器!" end
|
|
local success
|
local queryInfo
|
success, queryInfo = pcall( json.decode, strRetInfo )
|
if ( success == false ) then return 1, "queryDataObjAttr2 返回结果啊非法的JSON格式!" end
|
|
local queryID = queryInfo.queryID
|
local nPageCount = queryInfo.pageCount
|
local nPage = 1
|
local dataSet = queryInfo.dataSet -- 查询出来的数据集
|
local datajson = {
|
count_type = count_plan.type, -- 盘点类型，这个在WFP的脚本里有用
|
count_order_no = count_order.count_no, -- 盘点单号
|
count_method = method, -- 盘点方法
|
diff_hand_method = diff_hand_method, -- 盘点有差异处理方法
|
station = station -- 盘点站台
|
}
|
|
local count = 1
|
while (nPage <= nPageCount) do
|
|
for n = 1, #dataSet do
|
-- step3.1: 后台触发【计划盘点容器】的 Create_Count_CG_Detail
|
-- 考虑到生成盘点货品明细的时间会较长用 WFP 来进行处理
|
local add_wfp = {
|
wfp_type = 1, -- 触发数据对象事件（指定数据对象标识）
|
datajson = datajson,
|
cls = "CP_Count_Container",
|
obj_id = dataSet[n].id,
|
trigger_event = "Create_Count_CG_Detail"
|
}
|
nRet, strRetInfo = m3.AddSysWFP( strLuaDEID, add_wfp )
|
if ( nRet ~= 0 ) then return 1, strRetInfo end
|
if ( num > 0 ) then
|
-- 如果num=0 就触发所有容器
|
if ( count == num ) then goto finish_step end
|
end
|
count = count + 1
|
end
|
|
nPage = nPage + 1
|
if ( nPage <= nPageCount ) then
|
-- 取下一页
|
nRet, strRetInfo = mobox.queryDataObjAttr2( queryID, nPage)
|
if ( nRet ~= 0 ) then
|
return 1, "queryDataObjAttr2失败! nPage="..nPage.." "..strRetInfo
|
end
|
queryInfo = json.decode(strRetInfo)
|
dataSet = queryInfo.dataSet
|
end
|
end
|
|
-- step4：更新盘点单中盘点容器数量,
|
if ( count < num or num == 0 ) then
|
-- 更新盘点单盘点容器数量
|
strCondition = "S_COUNT_NO = '"..count_order.count_no.."'"
|
local strSetSQL = "N_COUNT_NUM = "..count
|
nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "Count_Order", strCondition, strSetSQL)
|
if (nRet ~= 0) then return 1, "设置【盘点单】信息失败!"..strRetInfo end
|
end
|
|
::finish_step::
|
-- step5：更新盘点计划中的 进行盘点容器数量
|
strCondition = "S_CP_NO = '"..count_plan.cp_no.."'"
|
nRet, strRetInfo = mobox.incDataObjAccQty( strLuaDEID, "Count_Plan", strCondition, "N_PLAN_TOTAL", "N_ACC_COUNT", count )
|
if ( nRet ~= 0 ) then return 1, "incDataObjAccQty(Count_Plan)失败! "..strRetInfo end
|
if ( strRetInfo ~= '') then
|
return 1, "盘点计划号'"..count_order.count_no.."'的累计盘点容器数量异常，无法增加!"
|
end
|
|
return 0
|
end
|
|
--[[
|
根据[CP_Count_Container]cp_cntr 查询【Count_CG_Detail】如果有差异就生成【Count_Diff】
|
]]
|
function wms_count.Count_PostProcess( strLuaDEID, cp_cntr )
|
local nRet, strRetInfo
|
local strCondition = "S_CC_NO = '"..cp_cntr.cc_no.."'"
|
|
-- 判断盘点计划类型是否是货物盘点，如果是，需要更新货品盘点的结果 【CP_Good_List】
|
local cp_no = lua.Get_StrAttrValue( cp_cntr.cp_no )
|
local first_cc_no = lua.Get_StrAttrValue( cp_cntr.first_cc_no ) -- 复盘会有这个属性，表示对什么进行复盘
|
|
local is_good_count = false -- 是货品盘点
|
if ( '' ~= cp_no ) then
|
local count_plan
|
nRet, count_plan = m3.GetDataObjectByKey( strLuaDEID, "Count_Plan", "S_CP_NO", cp_cntr.cp_no )
|
if ( nRet ~= 0 ) then return 1, "GetDataObjectByKey失败"..count_plan end
|
if ( count_plan.type == COUNT_PLAN_TYPE_GOODS ) then
|
is_good_count = true
|
end
|
end
|
|
nRet, data_objs = m3.QueryDataObject(strLuaDEID, "Count_CG_Detail", strCondition )
|
if (nRet ~= 0) then return 1, "QueryDataObject失败!"..data_objs end
|
if ( data_objs == '' ) then return 0 end
|
|
local n
|
local have_diff = false
|
local obj_attrs
|
local count_diff
|
local strCondition, strUpdateSql
|
|
-- 遍历【Count_CG_Detail】
|
for n = 1, #data_objs do
|
obj_attrs = m3.KeyValueAttrsToObjAttr(data_objs[n].attrs)
|
qty = lua.StrToNumber( obj_attrs.F_QTY )
|
act_qty = lua.StrToNumber( obj_attrs.F_ACT_QTY ) -- 盘点数量
|
if ( is_good_count ) then
|
strCondition = "S_ITEM_CODE = '"..obj_attrs.S_ITEM_CODE.."' AND S_CP_NO = '"..cp_no.."'"
|
strUpdateSql = "F_ACT_QTY = F_ACT_QTY + "..act_qty
|
nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "CP_Good_List", strCondition, strUpdateSql)
|
if (nRet ~= 0) then return 1, "更新【计划盘点货品】 实际数量失败!"..strRetInfo end
|
end
|
|
if ( qty ~= act_qty ) then
|
if ( first_cc_no == '' ) then
|
count_diff = m3.AllocObject(strLuaDEID,"Count_Diff")
|
count_diff.cc_no = cp_cntr.cc_no
|
count_diff.cp_no = cp_no
|
count_diff.cntr_code = cp_cntr.cntr_code
|
count_diff.count_no = cp_cntr.count_no
|
count_diff.cg_detail_id = obj_attrs.S_CG_DETAIL_ID
|
|
count_diff.wh_code = cp_cntr.wh_code
|
count_diff.area_code = cp_cntr.area_code
|
|
count_diff.qty = qty
|
count_diff.act_qty = act_qty
|
|
count_diff.cell_no = obj_attrs.S_CELL_NO
|
count_diff.item_code = obj_attrs.S_ITEM_CODE
|
count_diff.item_name = obj_attrs.S_ITEM_NAME
|
|
count_diff.item_state = lua.StrToNumber( obj_attrs.N_ITEM_STATE )
|
count_diff.batch_no = obj_attrs.S_BATCH_NO
|
count_diff.serial_no = obj_attrs.S_SERIAL_NO
|
count_diff.erp_wh_code = obj_attrs.S_ERP_WH_CODE
|
count_diff.end_user = obj_attrs.S_END_USER
|
count_diff.owner = obj_attrs.S_OWNER
|
count_diff.supplier = obj_attrs.S_SUPPLIER_NO
|
|
count_diff.uom = obj_attrs.S_UOM
|
count_diff.ext_attr1 = obj_attrs.S_EXT_ATTR1
|
count_diff.ext_attr2 = obj_attrs.S_EXT_ATTR2
|
count_diff.ext_attr3 = obj_attrs.S_EXT_ATTR3
|
count_diff.ext_attr4 = obj_attrs.S_EXT_ATTR4
|
count_diff.ext_attr5 = obj_attrs.S_EXT_ATTR5
|
|
nRet, count_diff = m3.CreateDataObj( strLuaDEID, count_diff )
|
if ( nRet ~= 0 ) then
|
return 1, 'mobox 创建【盘点差异表】对象失败!'..count_diff
|
end
|
have_diff = true
|
else
|
-- 复盘处理差异，首先获取原先最早盘点容器流水号中的差异
|
strCondition = "S_CC_NO = '"..first_cc_no.."' AND S_CG_DETAIL_ID = '"..obj_attrs.S_CG_DETAIL_ID.."'"
|
nRet, count_diff = m3.GetDataObjByCondition( strLuaDEID, "Count_Diff", strCondition )
|
if ( nRet ~= 0 ) then return 1, "获取【盘点差异表】信息失败!"..count_diff end
|
-- 判断盘点次数, 如果已经是二盘
|
strUpdateSql = "N_B_STATE = 1, F_ACTUAL_QTY = "..act_qty
|
if ( count_diff.count_time == 2 ) then
|
-- 不允许再复盘
|
strUpdateSql = strUpdateSql..", N_COUNT_TIME = 3, C_RECOUNT = 'Y'"
|
else
|
strUpdateSql = strUpdateSql..", N_COUNT_TIME = 2 "
|
end
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Count_Diff", strCondition, strUpdateSql )
|
if ( nRet ~= 0 ) then return 1, "更新【Count_Diff】信息失败!"..strRetInfo end
|
have_diff = true
|
end
|
end
|
end
|
|
-- 盘点单｛累计盘点数量｝+1
|
strCondition = "S_COUNT_NO = '"..cp_cntr.count_no.."'"
|
nRet, strRetInfo = mobox.incDataObjAccQty ( strLuaDEID, "Count_Order", strCondition, "N_COUNT_NUM", "N_ACC_FINISH", 1 )
|
if ( nRet ~= 0 or strRetInfo ~= '') then
|
return 1, '在增加【盘点单】中的累计盘点数量时失败!'..strRetInfo
|
end
|
|
-- 更新计划盘点容器中的 C_HAVE_DIFF = 'Y' 表示这个容器盘点有差异
|
if ( have_diff ) then
|
strCondition = "S_ID = '"..cp_cntr.id.."'"
|
local strSetAttr = "C_HAVE_DIFF = 'Y'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "CP_Count_Container", strCondition, strSetAttr )
|
if ( nRet ~= 0 ) then return 1, "更新【CP_Count_Container】信息失败!"..strRetInfo end
|
end
|
return 0
|
end
|
|
return wms_count
|
