--[[
|
编码: WMS-100-01
|
名称: HostToAgv-TaskCallBack
|
作者：HAN
|
入口函数： TaskStatusCallback
|
这段代码基本不需要改,各项目都是差不多的。
|
|
功能说明:
|
这个是一个 给 外部系统调用的 可编程接口，是AGV调度把车辆的状态发给 WMS 系统的接口
|
发送过来的数据是一个Json包，格式如下：
|
{"State":"%d","No":"%s","Ext1":"%s","Ext2":"%s","Ext3":"%s","ForkliftNo":"%d","ErrCode":"%d","ExtData":"%d"}
|
State -- 车辆动作 具体见每个项目的车辆动作码定义
|
No -- Task 编码
|
ForkliftNo -- 车辆编码
|
|
处理以下这几件事情：
|
1）解析外部输入的车辆状态信息 {"State":"%d","No":"%s","Ext1":"%s","Ext2":"%s","Ext3":"%s","ForkliftNo":"%d","ErrCode":"%d","ExtData":"%d"}
|
2）根据 ForkliftNo 获取车辆所属工厂标识
|
3）判断动作码在动作里是否存在，已经存在返回
|
3）把动作码写入 MQ_EQAction 队列
|
|
变更记录:
|
V1.1
|
+ mq_eq_action.task_code = agv_action.No
|
V3.0
|
HAN 2023-6-16
|
V3.1 HAN 2023-7-2
|
WMS_CreateDataObj 改成 m3.CreateDataObj
|
V4.1 HAN 2023-8-9 wms相关接口调整
|
V6.0 HAN 2023/9/6 -- lua.Error/lua.Debug 函数变化
|
--]]
|
wms_eq = require( "wms_equipment" )
|
|
function TaskStatusCallback ( strLuaDEID )
|
local nRet, strRetInfo, strDataJson, strErr
|
|
-- step1 获取接口中的Data
|
nRet, agv_action = m3.GetSysDataJson( strLuaDEID )
|
if ( nRet ~=0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "TaskStatusCallback 无法获取数据包!") end
|
|
-- 获取车辆编码
|
local strForkliftNo = agv_action.ForkliftNo
|
if ( strForkliftNo == '' ) then lua.Error( strLuaDEID, debug.getinfo(1), "ForkliftNo为空!") end
|
|
-- step2 获取车辆基本信息
|
local eq
|
nRet, eq = wms_eq.Equipment_GetInfo( strLuaDEID, strForkliftNo )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), eq ) end
|
-- 如果车辆没定义工厂标识返回错误
|
if ( eq.factory == '') then
|
strErr = "设备编号='"..strForkliftNo.."' 没定义工厂标识!"
|
lua.Error( strLuaDEID, debug.getinfo(1), strErr )
|
end
|
|
-- step3 判断当前车辆的动作码是否已经在队列中（MQ_EQAction）
|
local mq_eq_action = m3.AllocObject(strLuaDEID,"MQ_EQAction")
|
mq_eq_action.task_code = agv_action.No
|
mq_eq_action.eq_code = strForkliftNo
|
mq_eq_action.action_code = agv_action.State
|
nRet, strRetInfo = wms_eq.MQ_EQAction_Exist( strLuaDEID, mq_eq_action )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo ) end
|
-- 如果该车辆编码的动作已经在队列，返回，不做处理
|
if ( strRetInfo == "yes" ) then return end
|
|
-- step4 把车辆动作写入队列
|
mq_eq_action.factory = eq.factory
|
mq_eq_action.eq_type = eq.type
|
mq_eq_action.eq_type_name = eq.name
|
mq_eq_action.data = lua.table2str(agv_action)
|
nRet, strRetInfo = m3.CreateDataObj( strLuaDEID, mq_eq_action )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo ) end
|
end
|
