--[[
|
编码: JX-110-02
|
名称: 调度系统-输送线-任务推送
|
作者：HAN
|
日期: 2025-1-29
|
入口函数： Push
|
|
功能说明:
|
推送搬运任务到输送线
|
{
|
"requestPk": "pk2022120614242376",
|
"contNo": "60001",
|
"contType": "D",
|
"trkPrty": "5",
|
"trkType": "02",
|
"frmPos": "HW-01K010101",
|
"toPos": "2F_OUT_ST21",
|
"trkSt": 0,
|
"clientCode": "wms",
|
"reqTime": "2022-11-11 11:32:08"
|
}
|
变更记录:
|
|
--]]
|
|
wms_task = require( "wms_task" )
|
wms_op = require( "wms_operation" )
|
|
function Push( strLuaDEID )
|
local nRet, strRetInfo, strObjJson
|
local task
|
-- step1： 获取需要推送的任务对象
|
nRet, task = m3.GetSysCurEditDataObj( strLuaDEID, "Task" )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "m3.GetSysCurEditDataObj 失败!"..task ) end
|
|
-- step2： 调用NDC接口
|
-- 如果任务的类型 = 搬运
|
local strXml = ''
|
local state_wait = wms_base.Get_nConst( strLuaDEID, "任务状态-等待" )
|
-- 如果任务状态 不等于 "等待" 状态就返回，不需要推送
|
if (task.bs_state ~= state_wait ) then return end
|
|
local wcs_url
|
nRet, wcs_url = wms_base.Get_sConst2( strLuaDEID, "WCS服务地址")
|
if ( nRet ~= 0 ) then
|
lua.Stop( strLuaDEID, "系统无法获取常量'WCS服务地址'")
|
return
|
end
|
|
local trkType = "" -- 任务类型
|
local trkPrty = tostring( task.priority )
|
if ( task.type == wms_base.Get_nConst( strLuaDEID, "任务类型-输送线入库搬运" ) or
|
task.type == wms_base.Get_nConst( strLuaDEID, "任务类型-堆垛机入库搬运" ) ) then
|
trkType = "1"
|
elseif ( task.type == wms_base.Get_nConst( strLuaDEID, "任务类型-输送线出库搬运" ) or
|
task.type == wms_base.Get_nConst( strLuaDEID, "任务类型-堆垛机出库搬运" ) or
|
task.type == wms_base.Get_nConst( strLuaDEID, "任务类型-立库出库搬运" ) ) then
|
trkType = "2"
|
else
|
mobox.stopProgram( strLuaDEID, "任务类型值 = "..task.type..", 不能推送给输送线!")
|
return
|
end
|
--巨沃的料箱需要给WCS传来源系统的值
|
local curTime = os.date("%Y-%m-%d %H:%M:%S")
|
local strurl = wcs_url..'/wcs-admin/api/receive'
|
local body = {
|
requestPk = task.code,
|
contNo = task.cntr_code,
|
trkType = trkType,
|
trkPrty = trkPrty,
|
frmPos = task.start_loc_code,
|
toPos = task.end_loc_code,
|
clientCode = "wms",
|
reqTime = curTime,
|
souRce = task.source_sys --来源系统
|
}
|
lua.Debug( strLuaDEID, debug.getinfo(1), "调WCS接口-->", strurl )
|
lua.Debug( strLuaDEID, debug.getinfo(1), "body", body )
|
|
--[[
|
nRet, strRetInfo = mobox.sendHttpRequest( strurl, "",lua.table2str(body) )
|
if ( nRet ~= 0 or strRetInfo == '' ) then
|
lua.Error( strLuaDEID, debug.getinfo(1), "调用WCS /wcs-admin/api/receive 接口失败! "..strRetInfo )
|
end
|
local ret_info = json.decode( strRetInfo )
|
]]
|
local ret_info = {}
|
ret_info.code = "0"
|
|
-- step3 设置任务状态=已推送
|
if ( ret_info.code == "0" ) then
|
nRet, strRetInfo = wms_task.SetStateByCode( strLuaDEID, task.code, "任务状态-已推送" )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo ) end
|
-- 1 表示任务已经推送到设备
|
nRet, strRetInfo = wms_op.SetTaskState( strLuaDEID, task.op_code, 1 )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo ) end
|
|
local task_action = m3.AllocObject(strLuaDEID,"Task_Action")
|
task_action.task_code = task_code
|
task_action.action_code = 0
|
task_action.action = "任务推送"
|
task_action.eq_code = "XXX"
|
task_action.eq_type_name = "XXX"
|
m3.CreateDataObj( strLuaDEID, task_action )
|
|
else
|
lua.Debug( strLuaDEID, debug.getinfo(1), "调用WCS /wcs-admin/api/receive 接口失败", ret_info.msg )
|
end
|
end
|
