--[[
|
编码: WMS-100-04
|
名称: EQAction
|
作者：HAN
|
日期：2025-1-29
|
|
入口函数： EQActionProcess
|
处理和输送线相关的【MQ_EQAction】设备动作码
|
|
功能说明:
|
当入库线，出库线出口的线体有 10 动作码时标记输送线线体任务完成
|
|
变更记录:
|
--]]
|
wms_task = require( "wms_task" )
|
|
function EQActionProcess ( strLuaDEID )
|
local nRet, strRetInfo
|
|
-- step1 获取设备动作队列 MQ_EQAction
|
local mq_eq_action
|
nRet, mq_eq_action = m3.GetSysCurEditDataObj( strLuaDEID, "MQ_EQAction ")
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), mq_eq_action ) end
|
|
lua.Debug( strLuaDEID, debug.getinfo(1), "mq_eq_action", lua.table2str(mq_eq_action))
|
-- step2:
|
-- 获取任务信息，如果有任务编码检查一下任务是否存在
|
-- 检查任务的状态是否=完成，已经完成的任务也不能继续接收 action
|
local task = {}
|
if ( mq_eq_action.task_code ~= '') then
|
nRet, task = wms_task.GetInfo( strLuaDEID, mq_eq_action.task_code )
|
-- 如果任务不存在或出错， 返回
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), task ) end
|
else
|
task = nil
|
end
|
if ( task == nil ) then lua.Error( strLuaDEID, debug.getinfo(1), "监听程序无法定位任务信息, 请检查任务编号是否存在! " ) end
|
|
-- 任务已经完成
|
if ( task.bs_state == wms_base.Get_nConst(strLuaDEID, "任务状态-完成") ) then return end
|
|
-- step3 根据设备的动作码进行处理
|
-- 以下这些动作要判断一下任务里是否已经有，有返回
|
if ( mq_eq_action.action_code == wms_base.Get_nConst(strLuaDEID, "输送线-出库口到货") or
|
mq_eq_action.action_code == wms_base.Get_nConst(strLuaDEID, "输送线-入库口到货") ) then
|
|
nRet, strRetInfo = wms_task.Action_Exist( strLuaDEID, task.code, mq_eq_action.action_code )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "任务动作检查时出错! "..strRetInfo ) end
|
-- 如果这些动作码的任务动作已经存在就返回
|
if ( strRetInfo == "yes" ) then return end
|
|
-- 设置任务完成
|
nRet, strRetInfo = wms.wms_TaskFinish( strLuaDEID, task.code )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "任务编码='"..task.code.."'的任务设置完成失败!"..strRetInfo ) end
|
end
|
|
-- 增加 任务动作 对象
|
local task_action = m3.AllocObject(strLuaDEID,"Task_Action")
|
|
task_action.task_code = mq_eq_action.task_code
|
task_action.action_code = mq_eq_action.action_code
|
task_action.action = mq_eq_action.action
|
task_action.eq_code = mq_eq_action.eq_code
|
task_action.eq_type_name = mq_eq_action.eq_type_name
|
task_action.data = lua.FormatJsonString( mq_eq_action.data )
|
nRet, strRetInfo = m3.CreateDataObj( strLuaDEID, task_action )
|
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), '创建【任务动作】对象失败!'..strRetInfo ) end
|
end
|
