--[[
|
编码: JX-40-29
|
名称: 作业-待启动前作业处理
|
作者：HAN
|
日期：2025-1-29
|
|
版本: V1.0
|
|
场景：查询业务状态=8的作业，判断一下作业的终点位置的任务作业数量，如果大于一定值就不设置为 待启动
|
|
|
函数： ProStartOperation
|
|
功能:
|
|
|
更改记录：
|
|
--]]
|
wms_op = require( "wms_operation" )
|
wms_cntr = require( "wms_container" )
|
wms_wh = require( "wms_wh" )
|
|
local STATION_MAX_TASK_NUM = 15 --站台最大任务数量
|
|
local function get_end_loc_task_num( loc_code, end_loc_task_set )
|
local n
|
for n = 1, #end_loc_task_set do
|
if ( end_loc_task_set[n].loc_code == loc_code ) then
|
return true, end_loc_task_set[n].task_num
|
end
|
end
|
return false, 0
|
end
|
|
local function set_end_loc_task_num( loc_code, end_loc_task_set, task_num )
|
local n
|
for n = 1, #end_loc_task_set do
|
if ( end_loc_task_set[n].loc_code == loc_code ) then
|
end_loc_task_set[n].task_num = task_num
|
return
|
end
|
end
|
|
end
|
|
function ProStartOperation ( strLuaDEID )
|
local nRet, strRetInfo, data_objs
|
-- 对待启动前的出库作业
|
local strCondition = "N_B_STATE = 8 AND N_TYPE = "..wms_base.Get_nConst(strLuaDEID, "作业类型-出库")
|
|
nRet, data_objs = m3.QueryDataObject(strLuaDEID, "Operation", strCondition, "S_CODE" )
|
if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), '查询【作业】失败!'..data_objs ) end
|
if ( data_objs == '' ) then return end
|
|
local n, data_attrs
|
local find, task_num, can_usedin_op
|
local end_loc_task_set = {}
|
local strUpdateSql
|
local cntr_loc_code, cntr_loc
|
local container
|
|
for n = 1, #data_objs do
|
data_attrs = m3.KeyValueAttrsToObjAttr(data_objs[n].attrs)
|
|
-- 如果该容器还有在作业中，不能设置为待启动
|
nRet, can_usedin_op = wms_cntr.CanUsedInOperation( strLuaDEID, data_attrs.S_CNTR_CODE )
|
if ( nRet ~= 0 ) then
|
lua.Stop( strLuaDEID, can_usedin_op )
|
return
|
end
|
if ( can_usedin_op == false ) then goto continue end
|
|
-- 判断容器所在的货位是否是存储类型，如果不是存储类型也不能设置为待启动
|
nRet, container = wms_cntr.GetInfo( strLuaDEID, data_attrs.S_CNTR_CODE )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "wms_cntr.GetInfo 失败!"..container ) end
|
cntr_loc_code = lua.Get_StrAttrValue( container.position )
|
if ( cntr_loc_code == '' ) then goto continue end
|
nRet, cntr_loc = wms_wh.GetLocInfo( cntr_loc_code )
|
if ( nRet ~= 0 ) then
|
lua.Stop( strLuaDEID, "GetLocInfo 失败!"..cntr_loc )
|
return
|
end
|
-- 如果货位的用途不是存储，说明该容器还没回库 purpose = 1 说明是存储用途
|
if ( cntr_loc.purpose ~= 1 ) then goto continue end
|
|
find, task_num = get_end_loc_task_num( data_attrs.S_END_LOC, end_loc_task_set )
|
if ( find ) then
|
if ( task_num >= STATION_MAX_TASK_NUM ) then goto continue end
|
else
|
strCondition = "S_END_LOC = '"..data_attrs.S_END_LOC.."' AND N_B_STATE IN (0,1,5,6)"
|
nRet, strRetInfo = mobox.getDataObjCount( strLuaDEID, "Operation", strCondition )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "getDataObjCount失败!"..strRetInfo ) end
|
task_num = lua.StrToNumber( strRetInfo )
|
local end_loc_task = {
|
loc_code = data_attrs.S_END_LOC, task_num = task_num
|
}
|
table.insert( end_loc_task_set, end_loc_task )
|
if ( task_num >= STATION_MAX_TASK_NUM ) then goto continue end
|
end
|
|
task_num = task_num + 1
|
set_end_loc_task_num( data_attrs.S_END_LOC, end_loc_task_set, task_num )
|
-- 设置作业状态为 0/待启动
|
strUpdateSql = "N_B_STATE = 0"
|
strCondition = "S_CODE = '"..data_attrs.S_CODE.."'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Operation", strCondition, strUpdateSql )
|
if ( nRet ~= 0 ) then
|
lua.Error( strLuaDEID, debug.getinfo(1), "更新【作业】信息失败!"..strRetInfo )
|
end
|
::continue::
|
end
|
end
|
