--[[ 版本： Version 1.0 创建日期： 2023-6-16 创建人： HAN 功能： 和盘点相关的一些标准函数 -- Create_CountOrder_ByCountPlan 根据盘点计划创建盘点单 -- CountCntr_PostProcess 盘点容器盘点完成后处理 更改说明： --]] wms_cntr = require ("wms_container") wms_wh = require ("wms_wh") wms_inv = require ("wms_inventory") local wms_count = {_version = "0.1.1"} local COUNT_PLAN_TYPE_GOODS = 1 -- 货品盘点 local COUNT_PLAN_TYPE_LOCATION = 2 -- 货位盘点 --[[ 根据盘点计划 count_plan 创建【盘点单】数据对象，触发 num 个【计划盘点容器】执行"Create_Count_CG_Detail”,脚本 -- method 盘点方法 1 -- 人工到货位盘点 2 -- 自动设备搬运到站台 -- station 如果 method = 2 必须有值 -- num 盘点容器数量 如果没有输入就是多所有容器进行盘点 -- reject_emptybox true 表示排斥空料箱盘点，可以不输入默认 true ]] function wms_count.Create_CountOrder_ByCountPlan( strLuaDEID, count_plan, method, station, num, reject_emptybox ) 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 if ( reject_emptybox == nil ) then reject_emptybox = true end -- 获取常量 盘点差异需要审核 = Y local diff_need_review nRet, diff_need_review = wms_base.Get_sConst2( "盘点差异需要审核") if ( nRet ~= 0 ) then return 1, "系统无法获取常量'盘点差异需要审核'" end 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 = { reject_emptybox = reject_emptybox, -- 是否拒绝空料箱出库盘点 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 -- 过滤掉空料箱，一般用在整盘操作中，有些料箱已经是空料箱，不需要进行盘点 -- count_plan_no 盘点计划 function wms_count.Filter_Out_Empty_Bins(strLuaDEID, count_plan_no ) local nRet, strRetInfo -- 要联表查询的表 local strTable = "TN_CP_Count_Container a LEFT JOIN TN_Container b ON a.S_CNTR_CODE = b.S_CODE" -- 要查询的属性 local strAttrs = "a.S_CC_NO" -- 从盘点容器表中查找还没盘点，并且容器是空箱 local strCondition = "a.S_CP_NO = '"..count_plan_no.."' AND a.N_B_STATE = 0 AND b.N_EMPTY_FULL = 0" local strOrder = "" nRet, strRetInfo = mobox.queryMultiTable2(strLuaDEID, strAttrs, strTable, 100, strCondition, strOrder ) if ( nRet ~= 0 ) then return 1, "queryMultiTable2: "..strRetInfo end if ( strRetInfo == '' ) then return 0 end local success local queryInfo success, queryInfo = pcall( json.decode, strRetInfo ) if ( success == false ) then return 1, "queryMultiTable2 返回结果是非法的JSON格式!" end local nPageCount = queryInfo.page_count local nPage = 1 local data_list = queryInfo.data_list -- 查询出来的数据集 local strUpdateSql, cc_no while (nPage <= nPageCount) do for n = 1, #data_list do -- 设置盘点容器的状态=[5]取消 cc_no = lua.Get_StrAttrValue( data_list[n][1] ) -- 计划盘点容器流水号 strUpdateSql = "N_B_STATE = 5, S_NOTE = '空料箱'" strCondition = "S_CC_NO = '"..cc_no.."'" nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "CP_Count_Container", strCondition, strUpdateSql ) if ( nRet ~= 0 ) then return 1, "更新【计划盘点容器】信息失败!"..strRetInfo end end nPage = nPage + 1 if ( nPage <= nPageCount ) then -- 取下一页 nRet, strRetInfo = mobox.queryMultiTable2( strLuaDEID, nPage) if ( nRet ~= 0 ) then return 1, "queryMultiTable2 失败! nPage="..nPage.." "..strRetInfo end queryInfo = json.decode(strRetInfo) data_list = queryInfo.data_list end end return 0 end --[[ 盘点容器盘点完成后的处理逻辑 根据cp_cntr中的盘点容器流水号 查询【Count_CG_Detail】如果有差异就生成【Count_Diff】 V2.0 HAN 2025-1-10 如果不是第一盘点是复盘操作，数量相等也要进行特别的处理 V3.0 HAN 2025-2-13 有盘点差异会设置盘点单对象中的C_HAVE_DIFF字段 ]] function wms_count.CountCntr_PostProcess( strLuaDEID, cp_cntr ) local nRet, strRetInfo local strCondition -- 获取盘点计划编码 local cp_no = lua.Get_StrAttrValue( cp_cntr.cp_no ) -- 判断盘点单的盘点类型是否是货物盘点，如果是，需要更新货品盘点的结果 【CP_Good_List】 local count_no = lua.Get_StrAttrValue( cp_cntr.count_no ) if ( count_no == '' ) then return 1, "CountCntr_PostProcess 函数输入参数有问题，盘点容器里没有盘点单号!" end local is_good_count = false -- 是货品盘点 local count_order nRet, count_order = m3.GetDataObjectByKey( strLuaDEID, "Count_Order", "S_COUNT_NO", count_no ) if ( nRet ~= 0 ) then return 1, "GetDataObjectByKey失败"..count_order end if ( cp_no ~= '' and count_order.count_type == COUNT_PLAN_TYPE_GOODS ) then is_good_count = true end strCondition = "S_CC_NO = '"..cp_cntr.cc_no.."'" 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, act_qty, qty, last_act_qty, q local have_diff = false local obj_attrs local count_diff local strCondition, strUpdateSql local add_diff -- 遍历【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 ) -- 本次盘点数量 -- 如果是复盘的下面这个属性有值 count_diff_id = lua.Get_StrAttrValue( obj_attrs.G_COUNT_DIFF_ID ) add_diff = false -- 判断是否是复盘 if ( count_diff_id == '' ) then -- 不是复盘，是第一次盘点 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 add_diff = true end else -- 复盘处理差异，首先获取原先最早盘点容器流水号中的差异，判断是否存在差异 strCondition = "S_ID = '"..count_diff_id.."'" nRet, count_diff = m3.GetDataObjByCondition( strLuaDEID, "Count_Diff", strCondition ) if ( nRet ~= 0 ) then return 1, "获取【盘点差异表】信息失败!"..count_diff end -- 如果是货品盘点，要调整货品盘点里的实际数量 if ( is_good_count ) then -- 上一次的盘点数量 last_act_qty = lua.Get_NumAttrValue( count_diff.act_qty ) if ( act_qty ~= last_act_qty ) then strCondition = "S_ITEM_CODE = '"..obj_attrs.S_ITEM_CODE.."' AND S_CP_NO = '"..cp_no.."'" if ( last_act_qty > act_qty ) then q = last_act_qty - act_qty strUpdateSql = "F_ACT_QTY = F_ACT_QTY - "..q else q = act_qty - last_act_qty strUpdateSql = "F_ACT_QTY = F_ACT_QTY + "..q end nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "CP_Good_List", strCondition, strUpdateSql) if (nRet ~= 0) then return 1, "更新【计划盘点货品】 实际数量失败!"..strRetInfo end end 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 = 'N'" 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 if ( add_diff ) 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 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 --V3.0 盘点单也设置 C_HAVE_DIFF = Y strCondition = "S_COUNT_NO = '"..cp_cntr.count_no.."'" nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Count_Order", strCondition, strSetAttr ) if ( nRet ~= 0 ) then return 1, "更新【Count_Order】信息失败!"..strRetInfo end end -- 增加一个后台进程对盘点单进行处理，检查盘点单是否可以完成 local add_wfp = { wfp_type = 1, cls = "Count_Order", obj_id = count_order.id, obj_name = "盘点单'"..count_order.count_no.."'-->检查是否可以完成", trigger_event = "ResetCountOrderState" } nRet, strRetInfo = m3.AddSysWFP( strLuaDEID, add_wfp ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "AddSysWFP失败!"..strRetInfo ) end return 0 end --[[ 获取新增 盘点计划 的查询面板中的查询条件, 注意这和定义的查询页面中的控件有关系，这个是标准功能里的面板获取查询条件的代码 isSetQueryCondition = true 的情况下 容器查询 需要返回 base64 返回 nRet, ret_condition_type, strCondition nRet = 0 成功， nRet = 1 条件不满足 nRet = 2 错误 ret_condition_type = 0 返回的字符串是 纯SQL ]] function wms_count.Get_CountPlan_QueryPanel_Condition( strLuaDEID, isSetQueryCondition ) local nRet, strRetInfo local wh_code local attrs = {} local ret_condition_type = 0 -- 非base64 -- step1 获取当前查询输入面板中的 仓库编码/库区/物料编码/物料名称 nRet, attrs = m3.GetSysInputParameter( strLuaDEID ) if ( nRet ~= 0 ) then return 2, 0, "获取当前查询面板里的输入属性时失败! "..attrs end local obj_attrs = m3.KeyValueAttrsToObjAttr(attrs) if (obj_attrs == nil) then return 2, 0, "询面板里的输入属性为空" end -- "N_TYPE","S_WH_CODE","Area","ItemCode", "ItemName" local check_type = tonumber(obj_attrs.N_TYPE) -- 盘点类型 local wh_code = obj_attrs.S_WH_CODE -- 仓库编码 local area_code = obj_attrs.S_AREA_CODE -- 库区编码 if ( area_code == nil ) then area_code = '' end local strCondition = '' local strOrder = '' if ( check_type == 0 ) then return 1, 0, "必须选择一种盘点类型" end if ( wh_code == '' ) then return 1, 0, "必须选择一个仓库" end if ( check_type == wms_base.Get_nConst(strLuaDEID, "盘点类型-货品盘点")) then local item_code = obj_attrs.ItemCode -- 物料编码 local item_name = obj_attrs.ItemName -- 物料名称 local item_condition = '' if ( item_code ~= '' and item_code ~= nil ) then item_condition = " AND S_ITEM_CODE like '%%"..item_code.."%%'" end if ( item_name ~= '' and item_name ~= nil ) then item_condition = item_condition.." AND S_ITEM_NAME like '%%"..item_name.."%%' " end strOrder = 'S_ITEM_CODE' -- 如果是货物盘点 if ( area_code == '') then -- 没有输入库区就直接查仓库量表 strCondition = "F_QTY > 0 AND S_WH_CODE = '"..wh_code.."' "..item_condition else -- 有库区查库区量表 strCondition = "F_QTY > 0 AND S_WH_CODE = '"..wh_code.."' AND S_AREA_CODE = '"..area_code.."' "..item_condition end else strCondition = "S_WH_CODE = '"..wh_code.."'" if ( area_code ~= '') then strCondition = strCondition .. " AND S_AREA_CODE = '"..area_code.."' " end -- V2.0 if ( check_type == wms_base.Get_nConst(strLuaDEID, "盘点类型-货位盘点")) then -- 如果是货位盘点 local aisle = lua.StrToNumber(obj_attrs.Roadway) -- 巷道 local row = lua.StrToNumber(obj_attrs.Row) -- 排 local col = lua.StrToNumber(obj_attrs.Col) -- 列 local layer = lua.StrToNumber(obj_attrs.layer) -- 层 if ( aisle ~= 0 ) then strCondition = strCondition .. " AND N_AISLE = "..aisle end if ( row ~= 0 ) then strCondition = strCondition .. " AND N_ROW = "..row end if ( col ~= 0 ) then strCondition = strCondition .. " AND N_COL = "..col end if ( layer ~= 0 ) then strCondition = strCondition .. " AND N_LAYER = "..layer end strCondition = strCondition.." AND N_CURRENT_NUM > 0" elseif ( check_type == wms_base.Get_nConst(strLuaDEID, "盘点类型-容器盘点")) then -- 容器盘点 local cntr_code = lua.Get_StrAttrValue(obj_attrs.cntr_code) -- 料箱号 local str_wharea_condition = strCondition -- 这里的查询条件带 In 不能用简单模式 if ( isSetQueryCondition ) then local sql_condition = { { { field = "C_ENABLE", -- 容器是启用状态 value = "Y", op = "=" } }, { { field = "N_LOCK_STATE", -- 容器没被锁 value = "0", op = "=" } }, { { field = "S_CODE", value = "(select S_CNTR_CODE from TN_Loc_Container with (NOLOCK) where S_LOC_CODE in (select S_CODE from TN_Location with (NOLOCK) where "..str_wharea_condition.."))", op = "in" } } } -- 如果有输入容器料箱编码直接查料箱编码 if ( cntr_code ~= '') then local sql_item = { { field = "S_CODE", value = cntr_code, op = "=" } } table.insert( sql_condition, sql_item ) end nRet, strCondition = mobox.strToBase64( lua.table2str(sql_condition) ) if ( nRet ~= 0 ) then return 2, 0, "strToBase64 失败: "..strCondition end ret_condition_type = 1 else strCondition = "C_ENABLE = 'Y' AND N_LOCK_STATE = 0 " if ( cntr_code ~= '' ) then strCondition = strCondition.." AND S_CODE = '"..cntr_code.."'" end strCondition = strCondition.." AND S_CODE in (select S_CNTR_CODE from TN_Loc_Container with (NOLOCK) where S_LOC_CODE in (select S_CODE from TN_Location with (NOLOCK) where "..str_wharea_condition.."))" end else return 1, 0, "盘点类型不合法!" end end return 0, ret_condition_type, strCondition end --[[ 盘点差异进行复盘 -- 检查一下盘点差异是否能继续进行复盘 -- 可以复盘的创建盘点单，并且创建作业进行盘点出库 -- 容器加盘点锁 参数: station -- 复盘站点 count_diff_ids -- 需要复盘的【盘点差异】对象标识数组 ]] function wms_count.Count_Diff_RepeatCount( strLuaDEID, station, count_diff_ids ) local nRet, strRetInfo local count_diff local count_cntr_list = {} -- 需要盘点的容器 local find, id, n, m if ( lua.StrIsEmpty(station) ) then return 1, "站台必须有值!" end -- 注意: 选中的盘点差异必须是一个盘点单里的差异 local count_no = '' for n = 1, #count_diff_ids do -- 获取盘点差异对象属性 id = lua.trim_guid_str( count_diff_ids[n] ) nRet, count_diff = m3.GetDataObject( strLuaDEID, "Count_Diff", id ) if ( nRet ~= 0 ) then return 2, '获取【盘点差异】对象失败!'..count_diff end -- 盘点是否允许复盘(recount == 'Y') , 状态b_state不能是在盘点中... -- diff_move == 'N' 盘点差异没转移 if ( count_diff.recount == 'Y' and count_diff.b_state == 1 and count_diff.diff_move == 'N') then find = false -- 判断盘点差异的盘点单是否一样 if ( count_no == '' ) then count_no = count_diff.count_no else if ( count_no ~= count_diff.count_no ) then mobox.stopProgram( strLuaDEID, "复盘的盘点差异中其盘点单号必须相同!") return end end local count_item = { id = id, item_code = count_diff.item_code, item_name = count_diff.item_name, qty = count_diff.qty, cell_no = count_diff.cell_no, item_state = count_diff.item_state, batch_no = count_diff.batch_no, serial_no = count_diff.serial_no, erp_wh_code = count_diff.erp_wh_code, end_user = count_diff.end_user, supplier = count_diff.supplier, ext_attr1 = count_diff.ext_attr1, ext_attr2 = count_diff.ext_attr2, ext_attr3 = count_diff.ext_attr3, ext_attr4 = count_diff.ext_attr4, ext_attr5 = count_diff.ext_attr5, cg_detail_id = count_diff.cg_detail_id, item_spec = count_diff.item_spec, uom = count_diff.uom } for m = 1, #count_cntr_list do if ( count_cntr_list[m].cntr_code == count_diff.cntr_code ) then table.insert( count_cntr_list[m].count_item_list, count_item ) find = true break end end if ( find == false ) then local count_cntr = { cntr_code = count_diff.cntr_code, count_item_list = {} } table.insert( count_cntr.count_item_list, count_item ) table.insert( count_cntr_list, count_cntr ) end end end local strUpdateSql, strCondition nCount = #count_cntr_list if ( nCount == 0 or count_no == '') then mobox.setInfo( strLuaDEID, "复盘数量为0, 请检查一下需要复盘的容器是否可以进行复盘!") return 0 end -- 获取要复盘的差异所属的盘点单，盘点计划 local first_count_order nRet, first_count_order = m3.GetDataObjectByKey(strLuaDEID, "Count_Order", "S_COUNT_NO", count_no ) if (nRet ~= 0 ) then mobox.setInfo( strLuaDEID, "盘点单'"..count_no.."'不存在!" ) return 0 end -- 创建盘点单 local count_order = m3.AllocObject(strLuaDEID,"Count_Order") count_order.method = first_count_order.method count_order.num = nCount count_order.station = station count_order.count_type = first_count_order.count_type count_order.cp_no = first_count_order.cp_no count_order.recheck = 'Y' count_order.first_count_no = count_no count_order.diff_hand_method = 1 -- 1 不自动差异转移 nRet, count_order = m3.CreateDataObj( strLuaDEID, count_order ) if (nRet ~= 0) then return 2, "创建【盘点单】失败!"..count_order end -- 创建【计划盘点容器】 local count_cg_detail, count_item local cp_count_container_list = {} local loc, loc_code for n = 1, nCount do -- 获取容器所在货位 nRet, loc_code = wms_cntr.Get_Container_Loc( strLuaDEID, count_cntr_list[n].cntr_code ) if ( nRet ~= 0 ) then return 1, loc_code end if ( loc_code == '' ) then return 1, "容器'"..count_cntr_list[n].cntr_code.."'不在货位上" end nRet, loc = wms_wh.GetLocInfo( loc_code ) if ( nRet ~= 0 ) then return 1, '获取货位信息失败! '..loc_code end local cp_count_container = m3.AllocObject(strLuaDEID,"CP_Count_Container") cp_count_container.method = 2 cp_count_container.station = station cp_count_container.loc_code = loc_code cp_count_container.wh_code = loc.wh_code cp_count_container.area_code = loc.area_code cp_count_container.cp_no = first_count_order.cp_no cp_count_container.count_no = count_order.count_no cp_count_container.cntr_code = count_cntr_list[n].cntr_code --cp_count_container.first_cc_no = count_cntr_list[n].first_cc_no nRet, cp_count_container = m3.CreateDataObj( strLuaDEID, cp_count_container ) if (nRet ~= 0) then return 2, debug.getinfo(1), cp_count_container end table.insert( cp_count_container_list, cp_count_container ) -- 创建【盘点容器货品明细】Count_CG_Detail for m = 1, #count_cntr_list[n].count_item_list do count_cg_detail = m3.AllocObject(strLuaDEID,"Count_CG_Detail") count_item = count_cntr_list[n].count_item_list[m] count_cg_detail.cg_detail_id = count_item.cg_detail_id count_cg_detail.cc_no = cp_count_container.cc_no count_cg_detail.count_no = count_order.count_no count_cg_detail.station = station count_cg_detail.cntr_code = cp_count_container.cntr_code count_cg_detail.cell_no = count_item.cell_no count_cg_detail.serial_no = count_item.serial_no count_cg_detail.item_code = count_item.item_code count_cg_detail.item_name = count_item.item_name count_cg_detail.batch_no = count_item.batch_no count_cg_detail.item_spec = count_item.item_spec count_cg_detail.item_state = count_item.item_state count_cg_detail.end_user = count_item.end_user count_cg_detail.owner = count_item.owner count_cg_detail.supplier = count_item.supplier count_cg_detail.erp_wh_code = count_item.erp_wh_code count_cg_detail.ext_attr1 = count_item.ext_attr1 count_cg_detail.ext_attr2 = count_item.ext_attr2 count_cg_detail.ext_attr3 = count_item.ext_attr3 count_cg_detail.ext_attr4 = count_item.ext_attr4 count_cg_detail.ext_attr5 = count_item.ext_attr5 count_cg_detail.qty = count_item.qty count_cg_detail.uom = count_item.uom -- 复盘时要用到，和根据这个ID 更新新的盘点结果 count_cg_detail.count_diff_id = count_item.id nRet, count_cg_detail = m3.CreateDataObj( strLuaDEID, count_cg_detail ) if (nRet ~= 0) then return 2, "创建【Count_CG_Detail】失败!"..count_cg_detail end -- 设置【盘点差异】表记录的状态=2/复盘 local strUpdateSql = "N_B_STATE = 2" strCondition = "S_ID = '"..count_item.id.."'" nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Count_Diff", strCondition, strUpdateSql ) if ( nRet ~= 0 ) then return 2, "更新【盘点差异表】信息失败!"..strRetInfo end end end -- 盘点容器生成作业 local add_wfp for n = 1, #cp_count_container_list do -- 增加一个后台进程进行入库单完工回报 add_wfp = { wfp_type = 1, -- 触发数据对象事件（指定数据对象标识） cls = "CP_Count_Container", obj_id = cp_count_container_list[n].id, obj_name = "Container No '"..cp_count_container_list[n].cntr_code.."'-->Create stocktaking outbound operation", trigger_event = "CreateStocktakingOutOperation" } nRet, strRetInfo = m3.AddSysWFP( strLuaDEID, add_wfp ) if ( nRet ~= 0 ) then wms.wms_AbortCntrLockTrans( count_order.count_no ) return 2, "AddSysWFP失败!"..strRetInfo end -- step6: 给容器加盘点锁 4 -- 盘点锁 nRet, strRetInfo = wms.wms_LockCntr( cp_count_container_list[n].cntr_code, 4, count_order.count_no ) if ( nRet ~= 0 ) then wms.wms_AbortCntrLockTrans( count_order.count_no ) return 2, "给容器'"..cp_count_container_list[n].cntr_code.."'加盘点锁失败!" end end wms.wms_CommitCntrLockTrans( count_order.count_no ) return 0 end --[[ 盘点差异转移处理，适用不需要和上游进行回报操作，可以对单条盘点差异进行转移（改库存量）的业务场景 比较时候 WMS 系统内部盘点，你涉及第3方系统 输入参数: -- 【盘点差异】count_diff_objs 盘点差异数据对象 --]] function wms_count.CountDiff_Transfter ( strLuaDEID, count_diff_objs ) local nRet, strRetInfo if ( count_diff_objs == nil or type( count_diff_objs ) ~= "table" ) then return 1, "wms_count.CountDiff_Transfter 函数的输入参数 count_diff_objs 不合法,必须有值,必须是table类型!" end local nCount = #count_diff_objs if (nCount == 0) then return 0 end local count_diff local cntr_code_set = {} local dec_inventory_change = {} -- 减库存 local inc_inventory_change = {} -- 加库存 local qty local inventory_loss local strSetSQL, cntr_code, cg_detail_id, diff_moved local wh_code = '' local area_code = '' local days = os.date("%Y%m%d") for n = 1, nCount do nRet, count_diff = m3.ObjAttrStrToLuaObj( "Count_Diff", lua.table2str(count_diff_objs[n].attrs) ) if ( nRet ~= 0 ) then return 2, "m3.ObjAttrStrToLuaObj(Count_Diff) 失败! "..count_diff end diff_moved = lua.Get_StrAttrValue( count_diff.diff_move ) if ( diff_move == '' ) then return 1, "盘点差异显示表格中必须带'是否差异移库'列" end if ( diff_moved == 'N') then cntr_code = count_diff.cntr_code if ( cntr_code == nil or cntr_code == '') then return 1, "盘点差异显示表格中必须带'容器号'列" end if ( cntr_code == nil or cntr_code == '') then return 1, "盘点差异显示表格中必须带'容器号'列" end wh_code = lua.Get_StrAttrValue( count_diff.wh_code ) if ( wh_code == '') then return 1, "盘点差异显示表格中必须带'仓库'列" end area_code = lua.Get_StrAttrValue( count_diff.area_code ) -- 生成量表变化数据 inventory_loss = nil if ( count_diff.qty > count_diff.act_qty ) then -- 盘亏 inventory_loss = true qty = count_diff.qty - count_diff.act_qty elseif ( count_diff.qty < count_diff.act_qty ) then -- 盘盈 inventory_loss = false qty = count_diff.act_qty - count_diff.qty end cg_detail_id = count_diff.cg_detail_id if inventory_loss ~= nil then if ( cg_detail_id == nil or cg_detail_id == '') then -- V2.0 -- 需要把差异数据批分到CG_Detail 中有相同货品的Item中 strCondition = "S_CNTR_CODE = '"..count_diff.cntr_code.."' AND S_ITEM_CODE = '"..count_diff.item_code.."'" if ( inventory_loss ) then -- 盘亏 --strOrder = "F_QTY" strOrder = "T_CREATE" -- 考虑把先创建的 CG_Detial 扣减 nRet, strRetInfo = wms_inv.Reduce_INV_Detail_Qty( strLuaDEID, count_diff.cntr_code, strCondition, strOrder, qty ) else -- 盘盈 的情况把 qty 加到其中一条 INV_Detail 即可 strOrder = "T_CREATE" nRet, strRetInfo = wms_inv.Add_INV_Detail_Qty( strLuaDEID, count_diff.cntr_code, strCondition, strOrder, qty ) end if (nRet ~= 0) then return 2, "设置【容器货品明细】 数量失败!"..strRetInfo end else -- INV_Detail 更新数量 strSetSQL = "F_QTY = ".. count_diff.act_qty strCondition = "S_ID = '"..cg_detail_id.."'" nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "INV_Detail", strCondition, strSetSQL) if (nRet ~= 0) then return 2, "设置【容器货品明细】 数量失败!"..strRetInfo end end end -- Count_Diff 更新数据差异转移状态 strSetSQL = "C_DIFF_MOVE = 'Y'" strCondition = "S_ID = '"..lua.trim_guid_str( count_diff_objs[n].id ).."'" nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "Count_Diff", strCondition, strSetSQL) if (nRet ~= 0) then return 2, "设置【盘点差异表】 数量失败!"..strRetInfo end if ( lua.IsInTable(cntr_code, cntr_code_set) == false ) then table.insert( cntr_code_set, cntr_code ) end -- 生成仓库量变化输入参数 local inventory_info = { item_code = count_diff.item_code, item_name = count_diff.item_name, qty = qty, wh_code = wh_code, area_code = area_code } -- 创建上下架记录 -- 生成上架记录【OnOff_Shelves】 local onoff_shelves = m3.AllocObject(strLuaDEID,"OnOff_Shelves") if ( inventory_loss ) then table.insert( dec_inventory_change, inventory_info ) onoff_shelves.action = "-" else table.insert( inc_inventory_change, inventory_info ) onoff_shelves.action = "+" end onoff_shelves.d_action = days onoff_shelves.wh_code = wh_code onoff_shelves.area_code = area_code onoff_shelves.loc_code = "" onoff_shelves.note = "盘点单: "..count_diff.count_no onoff_shelves.item_code = count_diff.item_code onoff_shelves.item_name = count_diff.item_name onoff_shelves.batch_no = count_diff.batch_no onoff_shelves.serial_no = count_diff.serial_no onoff_shelves.item_spec = count_diff.item_spec onoff_shelves.item_state_name = count_diff.item_state_name onoff_shelves.item_state = count_diff.item_state onoff_shelves.end_user = count_diff.end_user onoff_shelves.owner = count_diff.owner onoff_shelves.supplier = count_diff.supplier onoff_shelves.supplier_name = count_diff.supplier_name onoff_shelves.cntr_code = count_diff.cntr_code onoff_shelves.cell_no = count_diff.cell_no onoff_shelves.qty = qty onoff_shelves.uom = count_diff.uom onoff_shelves.bs_no = count_diff.count_no onoff_shelves.bs_type = "Count_Order" nRet, onoff_shelves = m3.CreateDataObj( strLuaDEID, onoff_shelves ) if (nRet ~= 0) then return 2, "创建【上下架表】对象失败!"..onoff_shelves end end end -- 存储量处理 if ( #dec_inventory_change > 0 ) then -- 减存储量 local str_inventory_change = lua.table2str( dec_inventory_change ) -- 8 减仓库存储量 nRet, strRetInfo = wms.wms_AddWHInventoryChange(strLuaDEID, 8, str_inventory_change ) if ( nRet ~= 0 ) then return 2, "wms_AddWHInventoryChange 8 失败! "..strRetInfo end -- 9 减库区存储量 nRet, strRetInfo = wms.wms_AddWHInventoryChange(strLuaDEID, 9, str_inventory_change ) if ( nRet ~= 0 ) then return 2, "wms_AddWHInventoryChange 9 失败! "..strRetInfo end end if ( #inc_inventory_change > 0 ) then -- 加存储量 local str_inventory_change = lua.table2str( inc_inventory_change ) -- 5 加仓库存储量 nRet, strRetInfo = wms.wms_AddWHInventoryChange(strLuaDEID, 5, str_inventory_change ) if ( nRet ~= 0 ) then return 2, "wms_AddWHInventoryChange 5 失败! "..strRetInfo end -- 6 加库区存储量 nRet, strRetInfo = wms.wms_AddWHInventoryChange(strLuaDEID, 6, str_inventory_change ) if ( nRet ~= 0 ) then return 2, "wms_AddWHInventoryChange 6 失败! "..strRetInfo end end -- 对容器进行 差异转移后处理 程序，（设置容器为可用） local container for n = 1, #cntr_code_set do nRet, container = wms_cntr.GetInfo( strLuaDEID, cntr_code_set[n] ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), container ) end local add_wfp = { wfp_type = 1, cls = "Container", obj_id = container.id, obj_name = "容器'"..cntr_code_set[n].."'-->盘点差异转移后重置", trigger_event = "CountDiffPostProcess" } nRet, strRetInfo = m3.AddSysWFP( strLuaDEID, add_wfp ) if ( nRet ~= 0 ) then return 2, "AddSysWFP失败!"..strRetInfo end end return 0 end --[[ 盘点单-差异转移处理 输入参数: -- 【盘点单】count_order 盘点差异数据对象 --]] function wms_count.CountOrder_Transfter ( strLuaDEID, count_order ) local nRet, strRetInfo if ( count_order == nil or type( count_order ) ~= "table" ) then return 1, "CountOrder_Transfter 输入参数 count_order 不合法!" end local count_diff_objects local strCondition = "S_COUNT_NO = '"..count_order.count_no.."' AND C_DIFF_MOVE = 'N'" nRet, count_diff_objects = m3.QueryDataObject(strLuaDEID, "Count_Diff", strCondition ) if (nRet ~= 0) then return 2, "QueryDataObject失败!"..count_diff_objects end if ( count_diff_objects == '' ) then return 1, "盘点单'"..count_order.count_no.."'没可以转移的盘点差异!" end nRet, strRetInfo = wms_count.CountDiff_Transfter ( strLuaDEID, count_diff_objs ) if ( nRet ~= 0 ) then return nRet, strRetInfo end strCondition = "S_COUNT_NO = '"..count_order.count_no.."'" local strSetAttr = "C_DIFF_TRANS = 'Y'" nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Count_Order", strCondition, strSetAttr ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "更新【盘点单】信息失败!"..strRetInfo ) end return 0 end return wms_count