--[[ 版本： Version 2.1 创建日期： 2025-1-28 创建人： HAN WMS-Basis-Model-Version: V15.5 功能： WMS 过程中一些常用功能封装 -- Get_sConst 获取常量返回字符串类型 -- Get_nConst 获取常量返回数值类型 -- GetDictItemName 获取字典项的附加值,输入的 nItemValue 必须是数值 -- Warning 创建一条WMS警告信息 -- GetFuncArea 获取功能区定义列表 -- GetWHCGLocByRule 得到仓库中指定货品或空托的货位 -- Add_WHAreaQty_ByCGDetail 通过CG_Detail增加仓库量表 -- Add_WHAreaQty_By_PAC_Detail 通过 Pre_Alloc_CNTR_Detail 增加仓库量表 --]] json = require ("json") mobox = require ("OILua_JavelinExt") wms = require ("OILua_WMS") lua = require ("oi_base_func") m3 = require ("oi_base_mobox") local wms_base = {_version = "0.2.1"} -- 容器类型 WMS_CNTR_TYPE_NAME = { ["Pallet"] = "托盘", ["Normal"] = "常规", ["Cell_Box"] = "料格", ["Picking_Box"] = "拣料箱" } WMS_CNTR_TYPE = { ["托盘"] = "Pallet", ["常规"] = "Normal", ["料格"] = "Cell_Box", ["P拣料箱"] = "icking_Box" } --//////////////////////////////////////////////////////常量相关/////////////////////////////////////////////////////////// -- 获取常量返回字符串类型 （建议用这个函数） function wms_base.Get_sConst2( strLuaDEID, strConstName ) local nRet, strValue if ( strConstName == nil or strConstName == '' ) then return 1, "Get_sConst 参数必须有2个,并且第二个参数不能为空字符串!" end strConstName = lua.trim(strConstName) nRet, strValue = wms.wms_GetConst(strConstName) if (nRet ~= 0 ) then return 2, strValue end return 0, strValue end -- 如果没有返回一个巨大的值（不建议使用） function wms_base.Get_nConst( strLuaDEID, strConstName ) local nRet, strValue if ( strConstName == nil or strConstName == '' ) then return 2^53 end strConstName = lua.trim(strConstName) nRet, strValue = wms.wms_GetConst(strConstName) if (nRet ~= 0 ) then return 2^53 end return lua.StrToNumber( strValue ) end -- 获取常量返回数值类型 function wms_base.Get_nConst2( strLuaDEID, strConstName ) local nRet, strValue if ( strConstName == nil or strConstName == '' ) then return 1, "Get_nConst 参数必须有2个,并且第二个参数不能为空字符串!" end strConstName = lua.trim(strConstName) nRet, strValue = wms.wms_GetConst(strConstName) if (nRet ~= 0 ) then return 2, strValue end return 0, lua.StrToNumber( strValue ) end -- 获取常量返回bool类型 function wms_base.Get_bConst2( strLuaDEID, strConstName ) local nRet, strValue if ( strConstName == nil or strConstName == '' ) then return 1, "Get_nConst 参数必须有2个,并且第二个参数不能为空字符串!" end strConstName = lua.trim(strConstName) nRet, strValue = wms.wms_GetConst(strConstName) if (nRet ~= 0 ) then return 2, strValue end if ( strValue == '1' or strValue == 'Y' or strValue == 'y' ) then return 0, true end return 0, false end -- 获取字典项的附加值,输入的 nItemValue 必须是数值 function wms_base.GetDictItemName( strLuaDEID, strDictName, nItemValue ) local str_item_name = '' local nRet if ( nItemValue == nil ) then lua.Error( strLuaDEID, 0, "wms_base.GetDictItemName 的输入参数 nItemValue 必须有值！请检查 wms_base.GetDictItemName 函数的输入参数!" ) end if ( type(nItemValue) ~= "number" ) then lua.Warning( strLuaDEID, 0, "wms_base.GetDictItemName 的输入参数 nItemValue 必须要是一个数值类型！" ) return "" end nRet, str_item_name = wms.wms_GetDictTypeName( strDictName, nItemValue ) if ( nRet ~= 0 ) then lua.Warning( strLuaDEID, 0, strDictName.."不存在或者字典定义中不存在值 = "..nItemValue.." 的字典项!" ) return "" end return str_item_name end --[[ Warning 是未来方便使用者了解系统执行情况的 nErrCode -- 错误码 strInfo -- 错误信息 factory -- 工厂 strFrom -- 来源 nLvl -- 错误等级 strExtData -- 扩展数据 strNote -- 备注 --]] function wms_base.Warning( strLuaDEID, nLvl, nErrCode, strMsg, strExtData, strNote, strFrom, factory ) local nRet, strRetInfo, strErr if ( factory == nil or factory == "") then factory = "0000" end if ( strFrom == nil or strFrom == "") then strFrom = "Unkonw" end if ( strExtData == nil ) then strExtData = "" end if ( strNote == nil ) then strNote = "" end local warning = m3.AllocObject(strLuaDEID,"WMS_Warning") warning.factory = factory warning.msg = strMsg warning.from = strFrom warning.lvl = nLvl warning.err_code = nErrCode warning.ext_data = strExtData warning.note = strNote -- 获取创建容器时需要的属性 nRet, warning = m3.CreateDataObj( strLuaDEID, warning ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "创建 wms_base.Warning 失败! "..warning ) end end --[[ 仓库货品数量变化处理 -- strChangeOp 库存变化动作 -- strItemInfo 货品信息 --]] function wms_base.InventoryChangeAction( strLuaDEID, strChangeOp, strItemInfo ) local nRet, strRetInfo, change_op if ( type(strChangeOp) == "string" ) then change_op = wms_base.Get_nConst(strLuaDEID, strChangeOp) else change_op = strChangeOp end nRet, strRetInfo = wms.wms_AddWHInventoryChange(strLuaDEID, change_op, strItemInfo ) if ( nRet ~= 0 ) then return 2, "wms_AddWHInventoryChange 失败! "..strRetInfo end return 0 end --[[ 获取位置（Postion）相关的功能区定义列表,这里的位置是一个比较宽泛的范围，库区，货位，仓库，逻辑库区 参数： strPosClsID 位置类型：Area、Zone、Warehouse、Location strPosCode 位置编码 strFuncType 功能类型 返回 -- nRet 非零失败 -- func_pos 功能区/位列表对象，是一个table类型 [{"type":0~2, "class":"Zone", "code":"xxx"}] --]] function wms_base.GetFuncArea( strLuaDEID, strPosClsID, strPosCode, strFuncType ) local nRet, strRetInfo, nFuncType if ( type(strFuncType) == "string") then nFuncType = wms_base.Get_nConst(strLuaDEID, strFuncType) else nFuncType = strFuncType end nRet, strRetInfo = wms.wms_GetFuncArea( strPosClsID, strPosCode, nFuncType ) if (nRet ~= 0) then return 1, "wms_GetFuncArea 失败!"..strRetInfo end if ( strRetInfo == '' ) then return 1, strPosClsID.."编码 = '"..strPosCode.."' 没有定义类型值 = "..nFuncType.."名称 = '"..strFuncType.."'的功能区" end local success, ret_pos success, ret_pos = pcall( json.decode, strRetInfo ) if ( success == false ) then return 1, "wms_GetFuncArea返回值为非法的JSON格式!"..ret_pos end return 0, ret_pos end function wms_base.Get_Warehouse_FuncArea( strLuaDEID, strWHCode, strFuncType ) local nRet, strRetInfo nRet, strRetInfo = wms_base.GetFuncArea( strLuaDEID, "Warehouse", strWHCode, strFuncType ) if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), "wms_base.GetFuncArea 失败!"..strRetInfo ) end return strRetInfo end function wms_base.Get_Area_FuncArea( strLuaDEID, strAreaCode, strFuncType ) local nRet, strRetInfo nRet, strRetInfo = wms_base.GetFuncArea( strLuaDEID, "Area", strAreaCode, strFuncType ) if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), "wms_base.GetFuncArea 失败!"..strRetInfo ) end return strRetInfo end function wms_base.Get_Zone_FuncArea( strLuaDEID, strZoneCode, strFuncType ) local nRet, strRetInfo nRet, strRetInfo = wms_base.GetFuncArea( strLuaDEID, "Zone", strZoneCode, strFuncType ) if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), "wms_base.GetFuncArea 失败!"..strRetInfo ) end return strRetInfo end function wms_base.Get_Loc_FuncArea( strLuaDEID, strLocCode, strFuncType ) local nRet, strRetInfo nRet, strRetInfo = wms_base.GetFuncArea( strLuaDEID, "Location", strLocCode, strFuncType ) if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), "wms_base.GetFuncArea 失败!"..strRetInfo ) end return strRetInfo end --[[ 获取逻辑库区中可用的货位 参数： strZoneCode 返回 -- nRet 0 成功 -- location 货位对象，是一个table类型 {"wh_code":"XXX", "area_code":"XXX", "loc_code":"XX", "agv_site":"XXX", "agv_site_layer": X } --]] function wms_base.GetZoneAvaliableLoc( strLuaDEID, strZoneCode, strExtInfo ) local nRet, strRetInfo if (strExtInfo == nil) then strExtInfo = '' end nRet, strRetInfo = wms.wms_GetZoneAvaliableLoc( strLuaDEID, strZoneCode, strExtInfo ) if (nRet ~= 0) then return 1, "wms_GetZoneAvaliableLoc 失败!"..strRetInfo end if ( strRetInfo == '' ) then return 0, "" end local success, ret_info success, ret_info = pcall( json.decode, strRetInfo ) if ( success == false ) then return 1, "wms_GetZoneAvaliableLoc 返回值为非法的JSON格式!"..ret_info end return 0, ret_info end --[[ 获取库区中可用的货位 参数： strAreaCode --]] function wms_base.GetAreaAvaliableLoc( strLuaDEID, strAreaCode, strExtInfo ) local nRet, strRetInfo if (strExtInfo == nil) then strExtInfo = '' end nRet, strRetInfo = wms.wms_GetAreaAvaliableLoc( strLuaDEID, strAreaCode, strExtInfo ) if (nRet ~= 0) then return 1, "wms_GetAreaAvaliableLoc 失败! 物理库区:'"..strAreaCode.."' "..strRetInfo end if ( strRetInfo == '' ) then return 0, "" end local success, ret_info success, ret_info = pcall( json.decode, strRetInfo ) if ( success == false ) then return 1, "wms_GetAreaAvaliableLoc 返回值为非法的JSON格式!"..ret_info end return 0, ret_info end --[[ 得到仓库中指定货品或空托的货位对象 --]] function wms_base.GetWHCGLocByRule( strLuaDEID, strWHCode, strPolicyName, strExtInfo, bIsEmptyCntr ) local nRet, strRetInfo if ( bIsEmptyCntr == nil ) then bIsEmptyCntr = 0 end nRet, strRetInfo = wms.wms_GetWHCGLocByRule( strLuaDEID, strWHCode, strPolicyName, strExtInfo, bIsEmptyCntr ) if ( nRet ~= 0 ) then return nRet, "wms_GetWHCGLocByRule 失败!"..strRetInfo end if ( strRetInfo == '' ) then return 0, "" end local success, ret_info success, ret_info = pcall( json.decode, strRetInfo ) if ( success == false ) then return 1, "wms_GetWHCGLocByRule 返回值为非法的JSON格式!"..ret_info end return 0, ret_info end --[[ 得到仓库库区中指定货品或空托的货位 --]] function wms_base.GetAreaCGLoc( strLuaDEID, strAreaCode, strExtInfo, bIsEmptyCntr ) local nRet, strRetInfo if ( bIsEmptyCntr == nil ) then bIsEmptyCntr = 0 end nRet, strRetInfo = wms.wms_GetAreaCGLoc( strLuaDEID, strAreaCode, strExtInfo, bIsEmptyCntr ) if ( nRet ~= 0 ) then return nRet, "wms_base.GetAreaCGLoc 失败!"..strRetInfo end if ( strRetInfo == '' ) then return 0, "" end local success, ret_info success, ret_info = pcall( json.decode, strRetInfo ) if ( success == false ) then return 1, "WGetAreaCGLoc 返回值为非法的JSON格式!"..ret_info end return 0, ret_info end -- 根据CG_Detail生成量表变化信息 local function get_inventorychg_bycgdetail( strLuaDEID, wh_code, area_code, cntr_code ) local nRet, strRetInfo if ( cntr_code == nil or cntr_code == '' ) then return 1, "get_inventorychg_bycgdetail 函数中容器编码必须有值!" end if ( wh_code == '' or wh_code == nil ) then return 1, "get_inventorychg_bycgdetail 函数中仓库编码必须有值!" end if ( area_code == nil ) then area_code = '' end -- 获取 CG_Detail local strOrder = '' local strCondition = "S_CNTR_CODE = '"..cntr_code.."'" nRet, strRetInfo = mobox.queryDataObjAttr( strLuaDEID, "CG_Detail", strCondition, strOrder ) if ( nRet ~= 0 ) then return 1, "获取【容器货品明细】失败! "..strRetInfo end if ( strRetInfo == '' ) then return 0, "" end local retObjs = json.decode( strRetInfo ) local nObjs = #retObjs local n local cg_detail = {} local inventory_list = {} for n = 1, nObjs do nRet, cg_detail = m3.ObjAttrStrToLuaObj( "CG_Detail", lua.table2str(retObjs[n].attrs) ) if ( nRet ~= 0 ) then return 1, "m3.ObjAttrStrToLuaObj(CG_Detail) 失败! "..cg_detail end -- 生成仓库量变化输入参数 --[[ inventory_info = '{"item_code": "'..cg_detail.item_code..'",' inventory_info = inventory_info..'"item_name": "'..lua.FormatJsonString(cg_detail.item_name)..'",' inventory_info = inventory_info..'"qty": "'..cg_detail.qty..'"'..chg_target..'}' inventory_change = inventory_change .. inventory_info.."," ]] local inventory = { item_code = cg_detail.item_code, item_name = cg_detail.item_name, qty = cg_detail.qty, wh_code = wh_code, area_code = area_code } table.insert( inventory_list, inventory ) end return 0, lua.table2str(inventory_list) end -- 根据CG_Detail生成量表变化信息 local function create_on_shelves_by_cgdetail( strLuaDEID, wh_code, area_code, cntr_code, loc_code ) local nRet, strRetInfo if ( cntr_code == nil or cntr_code == '' ) then return 1, "create_on_shelves_by_cgdetail 函数中容器编码必须有值!" end if ( loc_code == nil ) then loc_code = '' end if ( wh_code == '' or wh_code == nil ) then return 1, "create_on_shelves_by_cgdetail 函数中仓库编码必须有值!" end if ( area_code == nil ) then area_code = '' end -- 获取 CG_Detail local strOrder = '' local strCondition = "S_CNTR_CODE = '"..cntr_code.."'" nRet, strRetInfo = mobox.queryDataObjAttr( strLuaDEID, "CG_Detail", strCondition, strOrder ) if ( nRet ~= 0 ) then return 1, "获取【容器货品明细】失败! "..strRetInfo end if ( strRetInfo == '' ) then return 0, "" end local retObjs = json.decode( strRetInfo ) local nObjs = #retObjs local n local cg_detail = {} local days = os.date("%Y%m%d") local inventory_list = {} for n = 1, nObjs do nRet, cg_detail = m3.ObjAttrStrToLuaObj( "CG_Detail", lua.table2str(retObjs[n].attrs) ) if ( nRet ~= 0 ) then return 1, "m3.ObjAttrStrToLuaObj(CG_Detail) 失败! "..cg_detail end -- 生成仓库量变化输入参数 --[[ inventory_info = '{"item_code": "'..cg_detail.item_code..'",' inventory_info = inventory_info..'"item_name": "'..lua.FormatJsonString(cg_detail.item_name)..'",' inventory_info = inventory_info..'"qty": "'..cg_detail.qty..'"'..chg_target..'}' inventory_change = inventory_change .. inventory_info.."," ]] local inventory = { item_code = cg_detail.item_code, item_name = cg_detail.item_name, qty = cg_detail.qty, wh_code = wh_code, area_code = area_code } table.insert( inventory_list, inventory ) if ( loc_code ~= '' ) then -- 生成上架记录【OnOff_Shelves】 onoff_shelves = m3.AllocObject(strLuaDEID,"OnOff_Shelves") onoff_shelves.action = "+" onoff_shelves.d_action = days onoff_shelves.wh_code = wh_code onoff_shelves.area_code = area_code onoff_shelves.loc_code = loc_code onoff_shelves.item_code = cg_detail.item_code onoff_shelves.item_name = cg_detail.item_name onoff_shelves.batch_no = cg_detail.batch_no onoff_shelves.serial_no = cg_detail.serial_no onoff_shelves.item_spec = cg_detail.item_spec onoff_shelves.item_state_name = cg_detail.item_state_name onoff_shelves.item_state = cg_detail.item_state onoff_shelves.end_user = cg_detail.end_user onoff_shelves.owner = cg_detail.owner onoff_shelves.supplier = cg_detail.supplier onoff_shelves.supplier_name = cg_detail.supplier_name onoff_shelves.cntr_code = cg_detail.cntr_code onoff_shelves.cell_no = cg_detail.cell_no onoff_shelves.qty = cg_detail.qty onoff_shelves.uom = cg_detail.uom onoff_shelves.bs_no = cg_detail.bs_no onoff_shelves.bs_type = cg_detail.bs_type nRet, onoff_shelves = m3.CreateDataObj( strLuaDEID, onoff_shelves ) if ( nRet ~= 0 ) then return 1, 'mobox 创建【上下架记录】对象失败!'..onoff_shelves end -- 根据业务来源加 F_ACC_I_QTY/累计入库数量 if ( cg_detail.bs_type == "Inbound_Order" ) then if ( cg_detail.bs_no ~= nil and cg_detail.bs_no ~= '' ) then strCondition = "S_IO_NO = '"..cg_detail.bs_no.."' AND S_ITEM_CODE = '"..cg_detail.item_code.."'" local strSetAttr = "F_ACC_I_QTY = F_ACC_I_QTY +"..cg_detail.qty nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "Inbound_Detail", strCondition, strSetAttr ) if (nRet ~= 0) then return 1, "设置【Inbound_Detail】累计入库数量失败!"..strRetInfo end end end if ( cg_detail.bs_type == 'Inbound_Wave' ) then if ( cg_detail.bs_no ~= nil and cg_detail.bs_no ~= '' ) then strCondition = "S_WAVE_NO = '"..cg_detail.bs_no.."' AND S_ITEM_CODE = '"..cg_detail.item_code.."'" local strSetAttr = "F_ACC_I_QTY = F_ACC_I_QTY +"..cg_detail.qty nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "IW_Detail", strCondition, strSetAttr ) if (nRet ~= 0) then return 1, "设置【IW_Detail】累计入库数量失败!"..strRetInfo end end end end end return 0, lua.table2str( inventory_list ) end --[[ 通过CG_Detail增加仓库/库区量表 ]] function wms_base.Add_WHAreaQty_ByCGDetail( strLuaDEID, wh_code, area_code, cntr_code, loc_code ) local nRet, strRetInfo, inventory_change nRet, inventory_change = create_on_shelves_by_cgdetail( strLuaDEID, wh_code, area_code, cntr_code, loc_code ) if ( nRet ~= 0 ) then return 1, inventory_change end if ( loc_code ~= nil and loc_code ~= '' ) then -- 创建上架记录 end if ( inventory_change ~= '' ) then if ( wh_code ~= '' and wh_code ~= nil ) then -- 5 仓库量表-仓库加存储量 nRet, strRetInfo = wms.wms_AddWHInventoryChange(strLuaDEID, 5, inventory_change ) if ( nRet ~= 0 ) then return 1, "wms_AddWHInventoryChange 失败! "..strRetInfo end end if ( area_code ~= '' and area_code ~= nil ) then -- 6 仓库量表-库区加存储量 nRet, strRetInfo = wms.wms_AddWHInventoryChange(strLuaDEID, 6, inventory_change) if ( nRet ~= 0 ) then return 1, "wms_AddWHInventoryChange 失败! "..strRetInfo end end end return 0 end -- 从【Pre_Alloc_CNTR_Detail】获取存储量新增参数并且创建 上下架记录 -- pac_no 组盘号 local function create_on_shelves_by_pac( strLuaDEID, wh_code, area_code, loc_code, pac_no ) local nRet, strRetInfo if ( pac_no == nil or pac_no == '' ) then return 1, "get_Inventory_chg_by_orgc 函数中 pac_no 必须有值!" end local chg_target = '' -- 量表变化对象 if ( wh_code == '' or wh_code == nil ) then return 1, "get_Inventory_chg_by_orgc 函数中仓库编码必须有值!" end if ( area_code == nil ) then area_code = '' end if ( loc_code == nil ) then loc_code = '' end -- 获取 Pre_Alloc_CNTR_Detail local strOrder = '' local strCondition = "S_PAC_NO = '"..pac_no.."'" nRet, strRetInfo = mobox.queryDataObjAttr( strLuaDEID, "Pre_Alloc_CNTR_Detail", strCondition, strOrder ) if ( nRet ~= 0 ) then return 1, "获取【组盘明细】失败! "..strRetInfo end if ( strRetInfo == '' ) then lua.Warning( strLuaDEID, debug.getinfo(1), "create_on_shelves_by_pac 存在异常 组盘号'"..pac_no.."'的明细为空!" ) return 0, "" end local retObjs = json.decode( strRetInfo ) local n local inventory_change = {} local pac_detail = {} local onoff_shelves = {} -- 上下架记录 local days = os.date("%Y%m%d") for n = 1, #retObjs do nRet, pac_detail = m3.ObjAttrStrToLuaObj( "Pre_Alloc_CNTR_Detail", lua.table2str(retObjs[n].attrs) ) if ( nRet ~= 0 ) then return 1, "m3.ObjAttrStrToLuaObj(Pre_Alloc_CNTR_Detail) 失败! "..pac_detail end if ( pac_detail.act_qty > 0 ) then -- 生成仓库量变化输入参数 local inventory_info = { item_code = pac_detail.item_code, item_name = pac_detail.item_name, qty = pac_detail.act_qty, wh_code = wh_code, area_code = area_code } table.insert( inventory_change, inventory_info ) -- 生成上架记录【OnOff_Shelves】 onoff_shelves = m3.AllocObject(strLuaDEID,"OnOff_Shelves") onoff_shelves.action = "+" onoff_shelves.d_action = days onoff_shelves.wh_code = wh_code onoff_shelves.area_code = area_code onoff_shelves.loc_code = loc_code onoff_shelves.item_code = pac_detail.item_code onoff_shelves.item_name = pac_detail.item_name onoff_shelves.batch_no = pac_detail.batch_no onoff_shelves.serial_no = pac_detail.serial_no onoff_shelves.item_spec = pac_detail.item_spec onoff_shelves.item_state_name = pac_detail.item_state_name onoff_shelves.item_state = pac_detail.item_state onoff_shelves.end_user = pac_detail.end_user onoff_shelves.owner = pac_detail.owner onoff_shelves.supplier = pac_detail.supplier onoff_shelves.supplier_name = pac_detail.supplier_name onoff_shelves.cntr_code = pac_detail.cntr_code onoff_shelves.cell_no = pac_detail.cell_no onoff_shelves.qty = pac_detail.act_qty onoff_shelves.uom = pac_detail.uom onoff_shelves.bs_no = pac_detail.bs_no onoff_shelves.bs_type = pac_detail.bs_type nRet, onoff_shelves = m3.CreateDataObj( strLuaDEID, onoff_shelves ) if ( nRet ~= 0 ) then return 1, 'mobox 创建【上下架记录】对象失败!'..onoff_shelves end end -- 根据业务来源加 F_ACC_I_QTY/累计入库数量 if ( pac_detail.bs_type == "Inbound_Order" ) then if ( pac_detail.bs_no ~= nil and pac_detail.bs_no ~= '' ) then strCondition = "S_IO_NO = '"..pac_detail.bs_no.."' AND S_ITEM_CODE = '"..pac_detail.item_code.."'" local strSetAttr = "F_ACC_I_QTY = F_ACC_I_QTY +"..pac_detail.act_qty if ( lua.equation( 0, pac_detail.cancel_qty ) == false ) then strSetAttr = strSetAttr..", F_ACC_C_QTY = F_ACC_C_QTY + "..pac_detail.cancel_qty end nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "Inbound_Detail", strCondition, strSetAttr ) if (nRet ~= 0) then return 1, "设置【Inbound_Detail】累计入库数量失败!"..strRetInfo end end end if ( pac_detail.bs_type == 'Inbound_Wave' ) then if ( pac_detail.bs_no ~= nil and pac_detail.bs_no ~= '' ) then strCondition = "S_WAVE_NO = '"..pac_detail.bs_no.."' AND S_ITEM_CODE = '"..pac_detail.item_code.."'" local strSetAttr = "F_ACC_I_QTY = F_ACC_I_QTY +"..pac_detail.act_qty if ( lua.equation( 0, pac_detail.cancel_qty ) == false ) then strSetAttr = strSetAttr..", F_ACC_C_QTY = F_ACC_C_QTY + "..pac_detail.cancel_qty end nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "IW_Detail", strCondition, strSetAttr ) if (nRet ~= 0) then return 1, "设置【IW_Detail】累计入库数量失败!"..strRetInfo end end end end return 0, inventory_change end --[[ 通过 Pre_Alloc_CNTR_Detail 增加仓库/库区量表 pac_no -- 组盘号 ]] function wms_base.Add_WHAreaQty_By_PAC_Detail( strLuaDEID, wh_code, area_code, loc_code, pac_no ) local nRet, strRetInfo, inventory_change nRet, inventory_change = create_on_shelves_by_pac( strLuaDEID, wh_code, area_code, loc_code, pac_no ) if ( nRet ~= 0 ) then return nRet, inventory_change end --[[ if ( #inventory_change > 0 ) then local str_inventory_change = lua.table2str(inventory_change) if ( wh_code ~= '' and wh_code ~= nil ) then -- 5 仓库量表-仓库加存储量 nRet, strRetInfo = wms.wms_AddWHInventoryChange(strLuaDEID, 5, str_inventory_change ) if ( nRet ~= 0 ) then return 1, "wms_AddWHInventoryChange 失败! "..strRetInfo end end if ( area_code ~= '' and area_code ~= nil ) then -- 6 仓库量表-库区加存储量 nRet, strRetInfo = wms.wms_AddWHInventoryChange(strLuaDEID, 6, str_inventory_change ) if ( nRet ~= 0 ) then return 1, "wms_AddWHInventoryChange 失败! "..strRetInfo end end end ]] return 0 end function wms_base.Reduce_WHAreaQty_ByCGDetail( strLuaDEID, wh_code, area_code, cntr_code ) local nRet, strRetInfo, inventory_change nRet, inventory_change = get_inventorychg_bycgdetail( strLuaDEID, wh_code, area_code, cntr_code ) if ( nRet ~= 0 ) then return nRet, inventory_change end if ( inventory_change ~= '' ) then if ( wh_code ~= '' and wh_code ~= nil ) then nRet, strRetInfo = wms.wms_AddWHInventoryChange(strLuaDEID, 8, inventory_change) if ( nRet ~= 0 ) then return 1, "wms_AddWHInventoryChange 失败! "..strRetInfo end end if ( area_code ~= '' and area_code ~= nil ) then nRet, strRetInfo = wms.wms_AddWHInventoryChange(strLuaDEID, 9, inventory_change) if ( nRet ~= 0 ) then return 1, "wms_AddWHInventoryChange 失败! "..strRetInfo end end end return 0 end --[[只对一个货品计算分配量，仓库量表\库区量表加分配量 ]] function wms_base.IPA_Star( wh_code, area_code, strItemInfo, strAddKey, bForceSorting ) local nRet, strRetInfo local nForceSorting = 0 if ( wh_code == nil or wh_code == '' ) then return 1, "wms_base.IPA_Star 函数中 wh_code 必须有值!" end if ( area_code == nil or area_code == '' ) then return 1, "wms_base.IPA_Star 函数中 area_code 必须有值!" end if (bForceSorting) then nForceSorting = 1 end nRet, strRetInfo = wms.wms_IPA_Start( wh_code, area_code, "", strItemInfo, strAddKey, nForceSorting ) if ( nRet ~= 0 ) then return nRet, "wms_IPA_Start失败! "..strRetInfo end local success, ret_info success, ret_info = pcall( json.decode, strRetInfo ) if ( success == false ) then return 1, "wms_IPA_Start 返回值为非法的JSON格式!"..ret_info end return 0, ret_info end ----IPA_Star2 内部调用函数------------------------------------------------------------------------------------------ local function get_oos_info( item_info, oos_info_set ) local n for n = 1, #oos_info_set do if ( item_info.N_ROW_NO == oos_info_set[n].N_ROW_NO and item_info.S_ITEM_CODE == oos_info_set[n].S_ITEM_CODE ) then return oos_info_set[n].F_OOS_QTY end end return 0 end -- 把 from中的信息复制到 target local function copy_item_info( target, from ) target.N_ROW_NO = from.N_ROW_NO target.S_ITEM_CODE = from.S_ITEM_CODE target.S_ITEM_NAME = from.S_ITEM_NAME target.F_QTY = from.F_QTY end --[[ 和IPA_Star不同这个是对多个货品进行分配 仓库量表\库区量表加分配量 对一个 item_set 的物料进行批分，根据 wms_IPA_Start 的结果休整 root_item_set 的分配量 wh_code 仓库编码 area_code 库区编码 item_set 本次物料领用的全部明细 strItemInfo 等待分配存储量的物料 返回： nRet ret_result { "trans_id":"" "outbound_items":[{"item_code":"qty":"","item_name":"xx"},...] -- 在area_code 匹配到的物料，这些物料可以出库 "to_be_alloc_items": [{"item_code":"qty":"","item_name":"xx"},...] -- 等待后面再继续进行分配的物料 } --]] function wms_base.IPA_Star2( strLuaDEID, wh_code, area_code, item_set, strItemInfo ) local nRet, strRetInfo local nForceSorting = 0 if ( wh_code == nil or wh_code == '' ) then return 1, "wms_base.IPA_Star2 函数中 wh_code 必须有值!" end if ( area_code == nil or area_code == '' ) then return 1, "wms_base.IPA_Star2 函数中 area_code 必须有值!" end if ( item_set == nil or type(item_set) ~= "table" ) then return 1, "wms_base.IPA_Star2 函数中 item_set 必须是一个table对象!" end nRet, strRetInfo = wms.wms_IPA_Start( wh_code, area_code, "", strItemInfo, "", 1 ) if ( nRet ~= 0 ) then return nRet, "wms_IPA_Start失败! "..strRetInfo end local success, ret_info success, ret_info = pcall( json.decode, strRetInfo ) if ( success == false ) then return 1, "wms_IPA_Start 返回值为非法的JSON格式!"..ret_info end local alloc_item_set = json.decode( strItemInfo ) -- 待分配的物料 local ret_result = {} local n local oos_qty -- 缺件数量 local n_outbound = 1 local n_to_be_alloc = 1 ret_result.trans_id = ret_info.trans_id ret_result.outbound_items_set = {} ret_result.to_be_alloc_items = {} if ( ret_info.oos_info == nil ) then -- 表示没有缺件 ret_result.outbound_items_set = alloc_item_set else -- 判断哪个item_code缺件，缺多少 for n = 1, #alloc_item_set do qty = alloc_item_set[n].F_QTY oos_qty = get_oos_info( alloc_item_set[n], ret_info.oos_info ) if ( oos_qty == 0 ) then -- 没有缺件 local items_out = {} copy_item_info( items_out, alloc_item_set[n] ) ret_result.outbound_items_set[n_outbound] = items_out n_outbound = n_outbound + 1 else -- 有缺件 if (oos_qty < alloc_item_set[n].F_QTY) then local items_out = {} copy_item_info( items_out, alloc_item_set[n] ) items_out.F_QTY = items_out.F_QTY - oos_qty ret_result.outbound_items_set[n_outbound] = items_out n_outbound = n_outbound + 1 local items_to_be_alloc = {} copy_item_info( items_to_be_alloc, alloc_item_set[n] ) items_to_be_alloc.F_QTY = oos_qty ret_result.to_be_alloc_items[n_to_be_alloc] = items_to_be_alloc n_to_be_alloc = n_to_be_alloc + 1 else local items_to_be_alloc = {} copy_item_info( items_to_be_alloc, alloc_item_set[n] ) ret_result.to_be_alloc_items[n_to_be_alloc] = items_to_be_alloc n_to_be_alloc = n_to_be_alloc + 1 end end end end -- 更新item_set 中的已分配量 if (#ret_result.outbound_items_set > 0) then for n = 1, #ret_result.outbound_items_set do local i for i = 1, #item_set do if (item_set[i].N_ROW_NO == ret_result.outbound_items_set[n].N_ROW_NO and item_set[i].S_ITEM_CODE == ret_result.outbound_items_set[n].S_ITEM_CODE ) then item_set[i].F_ALLOC_QTY = item_set[i].F_ALLOC_QTY + ret_result.outbound_items_set[n].F_QTY end end end end return 0, ret_result end -- 获取某物料的仓库量表 -- 返回 nRet, qty, alloc_qty function wms_base.GetWHInventory( strLuaDEID, wh_code, item_code ) local nRet, strRetInfo local parameter if ( wh_code == nil or wh_code == '' ) then return 1, "GetWHInventory 函数中 wh_code 必须有值!" end if ( item_code == nil or item_code == '' ) then return 1, "WGetWHInventory 函数中 item_code 必须有值!" end parameter = {} parameter.wh_code = wh_code parameter.item_list = {} local item = {} item.item_code = item_code parameter.item_list[1] = item nRet, strRetInfo = wms.wms_GetWHInventory( lua.table2str(parameter) ) if (nRet == 0) then local ret_info = json.decode( strRetInfo ) qty = ret_info[1].qty_storage alloc_qty = ret_info[1].qty_alloc return 0, qty, alloc_qty end return 1, "获取物料仓库存储量失败!"..strRetInfo end -- 获取某物料的库区量表 取消 -- 返回 nRet, qty, alloc_qty -- 获取某物料的库区量表 -- 返回 nRet, qty, alloc_qty function wms_base.GetAreaInventory( strLuaDEID, area_code, item_code, item_state, item_route ) local nRet, strRetInfo local parameter if ( area_code == nil or area_code == '' ) then return 1, "wms_base.GetAreaInventory 函数中 area_code 必须有值!" end if ( item_code == nil or item_code == '' ) then return 1, "wms_base.GetAreaInventory 函数中 item_code 必须有值!" end parameter = {} parameter.area_code = area_code parameter.item_list = {} local item = {} item.item_code = item_code parameter.item_list[1] = item nRet, strRetInfo = wms.wms_GetAreaInventory( lua.table2str(parameter) ) if (nRet == 0) then local ret_info = json.decode( strRetInfo ) qty = ret_info[1].qty_storage alloc_qty = ret_info[1].qty_alloc return 0, qty, alloc_qty end return 1, "获取物料库区存储量失败!"..strRetInfo end --[[ 入库波次完成后需要把 入库波次明细中的入库数量批分 到入库明细中的 F_ACC_I_QTY，F_ACC_C_QTY 否则以入库单进行回报时会没有入库数量 输入参数: wave_no 波次号 ]] function wms_base.InboundWave_Finish_PostProce( strLuaDEID, wave_no ) local nRet, strRetInfo, n, m --lua.Debug( strLuaDEID, debug.getinfo(1), "wms_base.InboundWave_Finish_PostProce --> begin ", wave_no ) if ( lua.StrIsEmpty( wave_no ) ) then return 1, "wms_base.InboundWave_Finish_PostProce 函数中 wave_no 不能为空!" end local iw_detail_objs local strCondition = "S_WAVE_NO = '"..wave_no.."'" nRet, iw_detail_objs = m3.QueryDataObject(strLuaDEID, "IW_Detail", strCondition, "N_ROW_NO" ) if ( nRet ~= 0 ) then return 1,"QueryDataObject失败!"..iw_detail_objs end --lua.Debug( strLuaDEID, debug.getinfo(1), "2 iw_detail_objs ", iw_detail_objs ) if ( iw_detail_objs == '' ) then return 0 end -- 获取入库单明细里的数量 local inbound_order_objs nRet, inbound_order_objs = m3.QueryDataObject(strLuaDEID, "Inbound_Order", strCondition, "S_NO" ) if ( nRet ~= 0 ) then return 1,"QueryDataObject失败!"..inbound_order_objs end --lua.Debug( strLuaDEID, debug.getinfo(1), "3 inbound_order_objs ", inbound_order_objs ) if ( inbound_order_objs == '' ) then return 0 end local io_no_set = {} -- 入库单号 local obj_attrs for n = 1, #inbound_order_objs do obj_attrs = m3.KeyValueAttrsToObjAttr(inbound_order_objs[n].attrs) table.insert( io_no_set, obj_attrs.S_NO ) end --lua.Debug( strLuaDEID, debug.getinfo(1), "4 io_no_set ", io_no_set ) local io_detail_objs strCondition = "S_IO_NO IN ("..lua.strArray2string( io_no_set )..")" nRet, io_detail_objs = m3.QueryDataObject(strLuaDEID, "Inbound_Detail", strCondition, "S_ITEM_CODE" ) if ( nRet ~= 0 ) then return 1,"QueryDataObject失败!"..io_detail_objs end --lua.Debug( strLuaDEID, debug.getinfo(1), "5 io_detail_objs ", io_detail_objs ) if ( io_detail_objs == '' ) then return 0 end local nCount = #io_detail_objs local io_detail_list = {} for n = 1, nCount do obj_attrs = m3.KeyValueAttrsToObjAttr(io_detail_objs[n].attrs) local io_detail = { id = io_detail_objs[n].id, item_code = obj_attrs.S_ITEM_CODE, qty = lua.Get_NumAttrValue( obj_attrs.F_QTY ), in_qty = 0, cancel_qty = 0, ok = false } table.insert( io_detail_list, io_detail ) end --lua.Debug( strLuaDEID, debug.getinfo(1), "6 io_detail_list ", io_detail_list ) local cancel_qty, in_qty for n = 1, #iw_detail_objs do obj_attrs = m3.KeyValueAttrsToObjAttr(iw_detail_objs[n].attrs) -- 入库数量 in_qty = lua.Get_NumAttrValue( obj_attrs.F_ACC_I_QTY ) -- 取消数量 cancel_qty = lua.Get_NumAttrValue( obj_attrs.F_ACC_C_QTY ) -- 把 in_qty, cancel_qty 批分到 Inbound_Detail for m = 1, nCount do if ( io_detail_list[m].ok == false ) then if ( io_detail_list[m].item_code == obj_attrs.S_ITEM_CODE ) then -- 批分入库数量 if ( in_qty > 0 ) then x_value = io_detail_list[m].qty - io_detail_list[m].in_qty - io_detail_list[m].cancel_qty -- 可以批分的入库数量 if ( in_qty > x_value ) then qty = x_value else qty = in_qty end in_qty = in_qty - qty io_detail_list[m].in_qty = io_detail_list[m].in_qty + qty end -- 批分取消数量 if ( cancel_qty > 0 ) then x_value = io_detail_list[m].qty - io_detail_list[m].in_qty - io_detail_list[m].cancel_qty -- 可以批分的取消数量 if ( cancel_qty > x_value ) then qty = x_value else qty = cancel_qty end cancel_qty = cancel_qty - qty io_detail_list[m].cancel_qty = io_detail_list[m].cancel_qty + qty end if ( io_detail_list[m].qty == (io_detail_list[m].in_qty+io_detail_list[m].cancel_qty) ) then io_detail_list[m].ok = true end end end if ( in_qty == 0 and cancel_qty == 0 ) then break end end end --lua.Debug( strLuaDEID, debug.getinfo(1), "7 io_detail_list ", io_detail_list ) -- 更新入库单明细中的入库数量，取消数量 local strSetAttr for n = 1, nCount do strCondition = "S_ID = '"..io_detail_list[n].id.."'" strSetAttr = "F_ACC_I_QTY = "..io_detail_list[n].in_qty..", F_ACC_C_QTY = "..io_detail_list[n].cancel_qty nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Inbound_Detail", strCondition, strSetAttr ) if ( nRet ~= 0 ) then return 1, "updateDataAttrByCondition(Inbound_Detail)失败"..strRetInfo end end return 0 end --[[ 出库波次完成后需要把 出库波次明细中的出库数量批分 到出库明细中的 F_ACC_O_QTY，F_ACC_C_QTY 否则以入库单进行回报时会没有入库数量 输入参数: wave_no 波次号 ]] function wms_base.OutboundWave_Finish_PostProce( strLuaDEID, wave_no ) local nRet, strRetInfo, n, m --lua.Debug( strLuaDEID, debug.getinfo(1), "wms_base.OutboundWave_Finish_PostProce --> begin ", wave_no ) if ( lua.StrIsEmpty( wave_no ) ) then return 1, "WMS_OuboundWave_Finish_PostProce 函数中 wave_no 不能为空!" end local ow_detail_objs local strCondition = "S_WAVE_NO = '"..wave_no.."'" nRet, ow_detail_objs = m3.QueryDataObject(strLuaDEID, "OW_Detail", strCondition, "N_ROW_NO" ) if ( nRet ~= 0 ) then return 1,"QueryDataObject失败!"..ow_detail_objs end --lua.Debug( strLuaDEID, debug.getinfo(1), "2 ow_detail_objs ", ow_detail_objs ) if ( ow_detail_objs == '' ) then return 0 end -- 获取出库单明细里的数量 local outbound_order_objs nRet, outbound_order_objs = m3.QueryDataObject(strLuaDEID, "Inbound_Order", strCondition, "S_NO" ) if ( nRet ~= 0 ) then return 1,"QueryDataObject失败!"..outbound_order_objs end --lua.Debug( strLuaDEID, debug.getinfo(1), "3 outbound_order_objs ", outbound_order_objs ) if ( outbound_order_objs == '' ) then return 0 end local oo_no_set = {} -- 出库单号 local obj_attrs for n = 1, #outbound_order_objs do obj_attrs = m3.KeyValueAttrsToObjAttr(outbound_order_objs[n].attrs) table.insert( oo_no_set, obj_attrs.S_NO ) end --lua.Debug( strLuaDEID, debug.getinfo(1), "4 oo_no_set ", oo_no_set ) local oo_detail_objs strCondition = "S_IO_NO IN ("..lua.strArray2string( io_no_set )..")" nRet, oo_detail_objs = m3.QueryDataObject(strLuaDEID, "Outbound_Detail", strCondition, "S_ITEM_CODE" ) if ( nRet ~= 0 ) then return 1,"QueryDataObject失败!"..oo_detail_objs end --lua.Debug( strLuaDEID, debug.getinfo(1), "5 oo_detail_objs ", oo_detail_objs ) if ( oo_detail_objs == '' ) then return 0 end local nCount = #oo_detail_objs local oo_detail_list = {} for n = 1, nCount do obj_attrs = m3.KeyValueAttrsToObjAttr(oo_detail_objs[n].attrs) local oo_detail = { id = oo_detail_objs[n].id, item_code = obj_attrs.S_ITEM_CODE, qty = lua.Get_NumAttrValue( obj_attrs.F_QTY ), out_qty = 0, cancel_qty = 0, ok = false } table.insert( oo_detail_list, oo_detail ) end --lua.Debug( strLuaDEID, debug.getinfo(1), "6 oo_detail_list ", oo_detail_list ) local cancel_qty, out_qty for n = 1, #ow_detail_objs do obj_attrs = m3.KeyValueAttrsToObjAttr(ow_detail_objs[n].attrs) -- 出库数量 out_qty = lua.Get_NumAttrValue( obj_attrs.F_ACC_O_QTY ) -- 取消数量 cancel_qty = lua.Get_NumAttrValue( obj_attrs.F_ACC_C_QTY ) -- 把 out_qty, cancel_qty 批分到 Outbound_Detail for m = 1, nCount do if ( oo_detail_list[m].ok == false ) then if ( oo_detail_list[m].item_code == obj_attrs.S_ITEM_CODE ) then -- 批分出库数量 if ( out_qty > 0 ) then x_value = oo_detail_list[m].qty - oo_detail_list[m].out_qty - oo_detail_list[m].cancel_qty -- 可以批分的出库数量 if ( out_qty > x_value ) then qty = x_value else qty = out_qty end out_qty = out_qty - qty oo_detail_list[m].out_qty = io_detail_list[m].out_qty + qty end -- 批分取消数量 if ( cancel_qty > 0 ) then x_value = oo_detail_list[m].qty - oo_detail_list[m].out_qty - oo_detail_list[m].cancel_qty -- 可以批分的取消数量 if ( cancel_qty > x_value ) then qty = x_value else qty = cancel_qty end cancel_qty = cancel_qty - qty oo_detail_list[m].cancel_qty = oo_detail_list[m].cancel_qty + qty end if ( oo_detail_list[m].qty == (oo_detail_list[m].out_qty+oo_detail_list[m].cancel_qty) ) then oo_detail_list[m].ok = true end end end if ( out_qty == 0 and cancel_qty == 0 ) then break end end end --lua.Debug( strLuaDEID, debug.getinfo(1), "7 oo_detail_list ", oo_detail_list ) -- 更新入库单明细中得入库数量，取消数量 local strSetAttr for n = 1, nCount do strCondition = "S_ID = '"..oo_detail_list[n].id.."'" strSetAttr = "F_ACC_O_QTY = "..oo_detail_list[n].out_qty..", F_ACC_C_QTY = "..oo_detail_list[n].cancel_qty nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Outbound_Detail", strCondition, strSetAttr ) if ( nRet ~= 0 ) then return 1, "updateDataAttrByCondition(Outbound_Detail)失败"..strRetInfo end end return 0 end --[[ 得到当前登录人员的账号信息，并且获取登录人员的PC MAC地址，根据这个地址获取绑定的站台 返回一个json table nRet, ret_value { login, user_name, mac, station } ]] function wms_base.Get_CurLoginUserInfo( strLuaDEID ) local nRet, strRetInfo local ret_value = {} local strUserLogin, strUserName nRet, strUserLogin, strUserName = mobox.getCurUserInfo( strLuaDEID ) if ( nRet ~= 0 ) then return 2, "获取当前操作人员信息失败! "..strUserLogin end ret_value.login = strUserLogin ret_value.user_name = strUserName ret_value.mac = "" ret_value.station = "" -- 获取当前登录账号的电脑MAC地址（如果在MBC上登录是可以获取的） nRet, strRetInfo = mobox.getCacheValue( strUserLogin, "__user_terminal__" ) if ( nRet == 0 ) then local user_terminal = json.decode( strRetInfo ) ret_value.mac = lua.Get_StrAttrValue( user_terminal.mac ) -- 根据 MAC-站台 绑定常量获取 站台 if ( ret_value.mac ~= '' ) then nRet, ret_value.station = wms_base.Get_sConst2( strLuaDEID, ret_value.mac ) if ( nRet ~= 0 ) then return 1, "系统无法获取常量'"..ret_value.mac.."'" end end end return 0, ret_value end return wms_base