--[[
|
版本： Version 2.1
|
创建日期： 2025-1-28
|
创建人： HAN
|
|
WMS-Basis-Model-Version: V15.5
|
|
功能：
|
WMS 过程中一些常用功能封装
|
|
-- Get_sConst 获取常量返回字符串类型
|
-- Get_nConst 获取常量返回数值类型
|
-- GetDictItemName 获取字典项的附加值,输入的 nItemValue 必须是数值
|
-- Warning 创建一条WMS警告信息
|
-- GetFuncArea 获取功能区定义列表
|
|
--]]
|
|
require ("wms_const")
|
wms = require ("OILua_WMS")
|
|
local wms_base = {_version = "0.2.1 "}
|
--//////////////////////////////////////////////////////常量相关///////////////////////////////////////////////////////////
|
-- 获取常量返回字符串类型 （建议用这个函数）
|
function wms_base.Get_sConst2( 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( 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( 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
|
|
-- 获取字典项的附加值,输入的 nItemValue 必须是数值
|
function wms_base.GetDictItemName2( strLuaDEID, strDictName, nItemValue )
|
local str_item_name = ''
|
local nRet
|
|
if ( nItemValue == nil ) then
|
return 1, "wms_base.GetDictItemName 的输入参数 nItemValue 必须有值！请检查 wms_base.GetDictItemName 函数的输入参数!"
|
end
|
if ( type(nItemValue) ~= "number" ) then
|
return 1, "wms_base.GetDictItemName 的输入参数 nItemValue 必须要是一个数值类型！"
|
end
|
|
nRet, str_item_name = wms.wms_GetDictTypeName( strDictName, nItemValue )
|
if ( nRet ~= 0 ) then
|
return 2, strDictName.."不存在或者字典定义中不存在值 = "..nItemValue.." 的字典项!"
|
end
|
return 0, 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
|
|
|
--[[
|
入库波次完成后需要把 入库波次明细中的入库数量批分 到入库明细中的 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( ret_value.mac )
|
if ( nRet ~= 0 ) then
|
return 1, "系统无法获取常量'"..ret_value.mac.."'"
|
end
|
end
|
end
|
|
return 0, ret_value
|
|
end
|
|
--[[
|
料箱预分配配置参数检查
|
输入参数 :
|
pac_cfg = {
|
wh_code, area_code 仓库，库区编码
|
station 站台
|
bs_type 来源类型：入库单、入库波次
|
bs_no 来源单号
|
}
|
返回:
|
1--结果 true/flase
|
2--错误信息
|
]]
|
function wms_base.PreAllocCntr_CFG_Check( pac_cfg )
|
local nRet, strRetInfo
|
|
if ( pac_cfg == nil or type( pac_cfg ) ~= "table" ) then
|
return false, "料箱预分配配置参数 pac_cfg 必须有值，必须是 table 类型!"
|
end
|
if ( lua.StrIsEmpty( pac_cfg.wh_code ) ) then
|
return false, "料箱预分配配置参数 pac_cfg 中的 wh_cod 必须有值!"
|
end
|
if ( lua.StrIsEmpty( pac_cfg.bs_type ) ) then
|
return false, "料箱预分配配置参数 pac_cfg 中的 bs_type 必须有值!"
|
end
|
if ( lua.StrIsEmpty( pac_cfg.bs_no ) ) then
|
return false, "料箱预分配配置参数 pac_cfg 中的 bs_no e必须有值!"
|
end
|
return true
|
end
|
|
--[[
|
生成查询 INV_Detail 的和 SKU 相关的查询条件
|
match_rule -- 匹配规则，如果为空只是查询 S_ITEM_CODE, S_ITEM_STATE, S_STORER
|
--]]
|
function wms_base.Get_INV_Detail_MatchSql( item, match_rule )
|
local item_sql = " a.S_ITEM_CODE = '"..item.S_ITEM_CODE.."' AND a.S_ITEM_STATE = '"..item.S_ITEM_STATE.."' AND a.S_STORER = '"..item.S_STORER.."' "
|
|
if match_rule == '' then
|
return item_sql
|
end
|
|
local seg_attrs = lua.split( match_rule, ';' )
|
for _, attr in ipairs( seg_attrs ) do
|
item_sql = item_sql.." AND a."..attr.." = '"..item[attr].."' "
|
end
|
return item_sql
|
end
|
|
--[[
|
根据分拣规则生成 查询 INV_Detail 时的 order
|
picking_rule -- 拣货规则
|
FIFO -- 先进先出，查询的是 S_WMS_BN 入库批次号
|
FILO -- 先进后出，查询的是 S_WMS_BN 入库批次号
|
FMFO -- 生产日期优先, 生产日期小的先出，查询属性 D_PRD_DATE
|
FEFO -- 有效期优先， 有效期小的先出，查询属性 D_EXP_DATE
|
SMALL_QTY -- 数量小的优先 查询 F_QTY_VALID
|
BIG_QTY -- 数量大的优先，查询 F_QTY_VALID
|
--]]
|
function wms_base.Get_INV_Detail_QueryOrder( picking_rule )
|
local order = ''
|
|
if picking_rule == '' then
|
return ""
|
end
|
|
local seg_rules = lua.split( picking_rule, ';' )
|
for _, rule in ipairs( seg_rules ) do
|
if rule == "FIFO" then
|
order = order.."a.S_WMS_BN,"
|
elseif rule == "FILO" then
|
order = order.."a.S_WMS_BN Desc,"
|
elseif rule == "FMFO" then
|
order = order.."a.D_PRD_DATE,"
|
elseif rule == "FEFO" then
|
order = order.."a.D_EXP_DATE,"
|
elseif rule == "SMALL_QTY" then
|
order = order.."a.F_QTY_VALID,"
|
elseif rule == "BIG_QTY" then
|
order = order.."a.F_QTY_VALID Desc,"
|
end
|
end
|
|
return lua.trim_laster_char( order )
|
end
|
|
function wms_base.Get_LoadingLimit( item_code, sku_grid_parm, ctd_code, cell_type )
|
if item_code == nil or item_code == '' then
|
return 1, "wms_base.Get_LoadingLimit 函数中 参数 item_code 为空!"
|
end
|
if lua.isTableEmpty( sku_grid_parm ) then
|
return 1, "SKU '"..item_code.."'中没定义料格参数或参数不合规!"
|
end
|
for _, grid_parm in ipairs( sku_grid_parm ) do
|
if grid_parm.ctd_code == ctd_code then
|
for _, cell_def in ipairs( grid_parm.cell_def ) do
|
if cell_def.cell_type == cell_type then
|
loading_limit = cell_def.loading_limit or 0
|
if loading_limit <= 0 then
|
return 1, "SKU '"..item_code.."'中没定义容器类型='"..ctd_code.."' 料格类型 = '"..cell_type.."' 的装载上限设置错误!"
|
end
|
return 0, loading_limit
|
end
|
end
|
end
|
end
|
return 1, "SKU '"..item_code.."'中没定义容器类型='"..ctd_code.."' 料格类型 = '"..cell_type.."' 的装载上限设置!"
|
end
|
|
--[[
|
获取SKU在cell_type料格中最大装载数量
|
--]]
|
function wms_base.GetSKU_LoadingLimit( sku, ctd_code, cell_type )
|
if sku == nil or cell_type == nil or ctd_code == nil or ctd_code == '' then
|
return 1, "wms_base.GetSKU_LoadingLimit 输入参数不合规!"
|
end
|
local nRet, loading_limit
|
nRet, loading_limit = wms_base.Get_LoadingLimit( sku.S_ITEM_CODE, sku.sku_grid_parm, ctd_code, cell_type )
|
|
return nRet, loading_limit
|
end
|
|
function wms_base.GetOpDefInfo( factory, op_def_name )
|
local nRet, strRetInfo
|
|
if lua.StrIsEmpty( factory ) then
|
return 1, "输入参数 factory 不能为空!"
|
end
|
if lua.StrIsEmpty( op_def_name ) then
|
return 1, "输入参数 op_def_name 不能为空!"
|
end
|
nRet, strRetInfo = wms.wms_GetOpDefInfo( factory, op_def_name )
|
if nRet ~= 0 then
|
return 2, strRetInfo
|
end
|
local op_def = json.decode( strRetInfo )
|
if op_def.hand_proc == nil then
|
op_def.hand_proc = ''
|
end
|
if op_def.putaway_rule == nil then
|
op_def.putaway_rule = ''
|
end
|
return 0, op_def
|
end
|
|
-- 获取当前登录人员所属单位标识/编码
|
function wms_base.GetMyFactory( strLuaDEID )
|
local strUserLogin, strUserName, nRet
|
nRet, strUserLogin, strUserName = mobox.getCurUserInfo( strLuaDEID )
|
if ( nRet ~= 0 ) then
|
return 2, "获取当前操作人员信息失败! "..strUserLogin
|
end
|
-- 获取当前操作人员的单位编码，作为工厂标识
|
nRet, strRetInfo = mobox.getUserSectionUnit( strUserLogin )
|
if ( nRet ~= 0 ) then
|
return 2, "获取当前操作人员所属单位失败! "..strRetInfo
|
end
|
local factory = ''
|
if ( strRetInfo ~= '' ) then
|
local orgInfo = json.decode( strRetInfo )
|
factory = orgInfo.company_code
|
end
|
if factory == '' then
|
nRet, factory = wms_base.Get_sConst2( "WMS_Default_Factory")
|
if ( nRet ~= 0 ) then
|
return 2, "系统无法获取常量'WMS_Default_Factory'"
|
end
|
end
|
return 0, factory
|
end
|
|
function wms_base.GetStrategyInfo( strategy_type, strategy_code )
|
local nRet, strRetInfo
|
local strategy = {}
|
|
nRet, strRetInfo = wms.wms_GetStrategyInfo( strategy_type, strategy_code )
|
if nRet ~= 0 then
|
return 1, "在获取'"..strategy_type.."'策略时失败! "..strRetInfo
|
end
|
local success
|
success, strategy = pcall( json.decode, strRetInfo )
|
if ( success == false ) then
|
return 200, "解析 wms_GetStrategyInfo 返回的字符串错误: --> "..strategy
|
end
|
|
return 0, strategy
|
end
|
|
-- 定义一个函数用于判断字符串末尾是否包含指定子字符串
|
local function string_end_with( str, ending )
|
-- 获取原字符串的长度
|
local strLen = #str
|
-- 获取目标子字符串的长度
|
local endingLen = #ending
|
-- 如果原字符串长度小于目标子字符串长度，直接返回 false
|
if strLen < endingLen then
|
return false
|
end
|
-- 提取原字符串末尾与目标子字符串长度相同的部分
|
local endPart = string.sub(str, -endingLen)
|
-- 比较提取的部分与目标子字符串是否相等
|
return endPart == ending
|
end
|
|
--[[
|
根据策略（上架策略/空料箱呼出策略）获取仓库，库区，巷道 等存储区域
|
输入参数
|
strategy -- 策略
|
{
|
no = "", name = "",
|
enable = 1/0,
|
detail_list = {
|
{
|
title = "xx"，
|
priority = 1， enable = 1/0,
|
match_attr = {...}
|
wh_code = ""
|
area_code = ""
|
aisle_code = ""
|
loc_set = {"A","B",...}
|
}
|
}
|
}
|
input_data_attr --{"S_BATCH_NO" = "",S_UDF01="xx",...}
|
返回: 存储库区
|
storage_list = {
|
{wh_code,area_code, aisle_no, colume, layer, loc}
|
}
|
--]]
|
function wms_base.Get_Storage_Area_By_Strategy( strategy, input_data_attr )
|
local nRet, strRetInfo
|
|
if strategy == nil or type( strategy ) ~= "table" then
|
return 1, "wms_base.Get_Storage_Area_By_Strategy 函数中参数 strategy 不合规! "
|
end
|
if strategy.detail_list == nil or type( strategy.detail_list ) ~= "table" then
|
return 1, "wms_base.Get_Storage_Area_By_Strategy 函数中参数 strategy.detail_list 不合规! "
|
end
|
|
if input_data_attr == nil or type( input_data_attr ) ~= "table" then
|
return 1, "wms_base.Get_Storage_Area_By_Strategy 函数中参数 input_data_attr 不合规! "
|
end
|
|
if not strategy.enable then
|
return 1, "策略'"..strategy.no.."'没有启用!"
|
end
|
|
local match
|
local str_value, n_data_attr_value, str_data_attr_value
|
local storage_list = {}
|
|
for _, strategy_detail in ipairs( strategy.detail_list ) do
|
if strategy_detail.enable then
|
match = true
|
if strategy_detail.match_attr ~= nil and not lua.isTableEmpty( strategy_detail.match_attr ) then
|
for _, match_attr in ipairs( strategy_detail.match_attr ) do
|
str_data_attr_value = input_data_attr[match_attr.attr] or ''
|
if match_attr.type == "string" then
|
str_value = match_attr.value or ''
|
-- 等于
|
if match_attr.op == CONDITION_SYMBOL.Equals then
|
if str_value ~= str_data_attr_value then
|
match = false
|
break
|
end
|
-- 不等于
|
elseif match_attr.op == CONDITION_SYMBOL.NotEquals then
|
if str_value == str_data_attr_value then
|
match = false
|
break
|
end
|
-- 为空
|
elseif match_attr.op == CONDITION_SYMBOL.IsEmpty then
|
if str_data_attr_value ~= '' then
|
match = false
|
break
|
end
|
-- 不为空
|
elseif match_attr.op == CONDITION_SYMBOL.NotEmpty then
|
if str_data_attr_value == '' then
|
match = false
|
break
|
end
|
-- 包含
|
elseif match_attr.op == CONDITION_SYMBOL.Include then
|
if not string.find( str_data_attr_value, str_value ) then
|
match = false
|
break
|
end
|
-- 不包含
|
elseif match_attr.op == CONDITION_SYMBOL.NotInclude then
|
if string.find( str_data_attr_value, str_value ) then
|
match = false
|
break
|
end
|
-- 前面有
|
elseif match_attr.op == CONDITION_SYMBOL.FrontInclude then
|
if string.sub( str_data_attr_value, 1, #str_value ) ~= str_value then
|
match = false
|
break
|
end
|
-- 后面有
|
elseif match_attr.op == CONDITION_SYMBOL.BehindInclude then
|
if not string_end_with( str_data_attr_value, str_value ) then
|
match = false
|
break
|
end
|
end
|
elseif match_attr.type == "number" then
|
n_value = lua.Get_NumAttrValue( str_value )
|
n_data_attr_value = lua.Get_NumAttrValue( str_data_attr_value )
|
-- 等于
|
if match_attr.op == CONDITION_SYMBOL.Equals then
|
if not lua.equation( n_data_attr_value, n_value ) then
|
match = false
|
break
|
end
|
-- 不等于
|
elseif match_attr.op == CONDITION_SYMBOL.NotEquals then
|
if lua.equation( n_data_attr_value, n_value ) then
|
match = false
|
break
|
end
|
-- 大于
|
elseif match_attr.op == CONDITION_SYMBOL.Greater then
|
if n_data_attr_value <= n_value then
|
match = false
|
break
|
end
|
-- 大于等于
|
elseif match_attr.op == CONDITION_SYMBOL.GreaterOrEquals then
|
if n_data_attr_value < n_value then
|
match = false
|
break
|
end
|
-- 小于
|
elseif match_attr.op == CONDITION_SYMBOL.Less then
|
if n_data_attr_value >= n_value then
|
match = false
|
break
|
end
|
-- 小于等于
|
elseif match_attr.op == CONDITION_SYMBOL.LessOrEquals then
|
if n_data_attr_value > n_value then
|
match = false
|
break
|
end
|
end
|
elseif match_attr.type == "date" then
|
-- 等于
|
if match_attr.op == CONDITION_SYMBOL.Equals then
|
if str_data_attr_value ~= str_value then
|
match = false
|
break
|
end
|
-- 不等于
|
elseif match_attr.op == CONDITION_SYMBOL.NotEquals then
|
if str_data_attr_value == str_value then
|
match = false
|
break
|
end
|
-- 大于
|
elseif match_attr.op == CONDITION_SYMBOL.Greater then
|
if str_data_attr_value <= str_value then
|
match = false
|
break
|
end
|
-- 大于等于
|
elseif match_attr.op == CONDITION_SYMBOL.GreaterOrEquals then
|
if str_data_attr_value < str_value then
|
match = false
|
break
|
end
|
-- 小于
|
elseif match_attr.op == CONDITION_SYMBOL.Less then
|
if str_data_attr_value >= str_value then
|
match = false
|
break
|
end
|
-- 小于等于
|
elseif match_attr.op == CONDITION_SYMBOL.LessOrEquals then
|
if str_data_attr_value > str_value then
|
match = false
|
break
|
end
|
end
|
end
|
end
|
end
|
|
if match then
|
local storage = {
|
wh_code = strategy_detail.wh_code,
|
area_code = strategy_detail.area_code,
|
aisle_no = strategy_detail.aisle_code,
|
colume = strategy_detail.col_set,
|
layer = strategy_detail.layer_set,
|
location = strategy_detail.loc_set,
|
priority = strategy_detail.priority
|
}
|
table.insert( storage_list, storage)
|
end
|
end
|
end
|
|
return 0, storage_list
|
end
|
|
return wms_base
|
