--[[
|
编码: GT-100-23
|
名称: NotifyDeviceSignal
|
作者: LZH
|
入口函数：NotifyDeviceSignal
|
功能说明: 004-设备信号反馈,当WCS异常时调用，下发一段agv任务拉到异常区
|
变更历史:
|
--]]
|
wms_task = require("wms_task")
|
require("WMS-Equipment")
|
wms_cntr = require("wms_container")
|
wms_wh = require("wms_wh")
|
require("GT-Base")
|
require("GT_InAndOutboundPolicies")
|
function notifyDeviceSignal(strLuaDEID)
|
local nRet, in_date, strRetInfo
|
-- step1 获取接口数据
|
nRet, in_date = m3.GetSysDataJson(strLuaDEID)
|
if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "无法获取数据包!" .. in_date) end
|
lua.Debug(strLuaDEID, debug.getinfo(1), '004-设备信号反馈参数:', in_date)
|
|
-- step2 判断 必填项 是否都有值？没值报错返回
|
local loc_code = in_date.loc -- 货位
|
local cntr_code = in_date.cntr_code -- 容器
|
-- local extData = in_date.extData
|
-- if (type(extData) ~= 'table') then
|
-- lua.Error(strLuaDEID, debug.getinfo(1), "扩展参数不是列表!")
|
-- end
|
local signalType = lua.StrToNumber(in_date.signalType) -- 1:下线请求，2：叫料请求 3：读码请求，4:下线记录，5：异常申请（固定传3）
|
if (loc_code == nil or loc_code == '') then lua.Error(strLuaDEID, debug.getinfo(1), "站点不能为空!") end
|
if (cntr_code == nil or cntr_code == '') then lua.Error(strLuaDEID, debug.getinfo(1), "FRID不能为空!") end
|
if (signalType == nil) then lua.Error(strLuaDEID, debug.getinfo(1), "类型不能为空!") end
|
local flag = lua.StrToNumber(in_date.extData) -- 扩展参数 0正常 1异常
|
if (flag == nil) then lua.Error(strLuaDEID, debug.getinfo(1), "扩展参数不能为空!") end
|
|
if (signalType ~= 3) then
|
lua.Error(strLuaDEID, debug.getinfo(1), signalType .. "未启用的请求类型!")
|
end
|
lua.Debug(strLuaDEID, debug.getinfo(1), '111:', 111)
|
|
-- 判断WCS反馈正常还是异常
|
if (tonumber(flag) == 1) then
|
lua.Debug(strLuaDEID, debug.getinfo(1), '222:', 222)
|
-- 任务异常则下发agv任务拉到异常区
|
local strCode
|
local strHeader = 'TA' .. os.date("%y%m%d") .. '-'
|
nRet, strCode = mobox.getSerialNumber("任务", strHeader, 5)
|
if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '申请【任务】编码失败!' .. strCode) end
|
-- 获取站台起点
|
loc_code = wms_base.Get_sConst(strLuaDEID, loc_code)
|
local start_loc
|
nRet, start_loc = wms_wh.GetLocInfo(loc_code)
|
if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), 'WMS_GetLocInfo失败!' .. start_loc) end
|
|
-- 根据起点站台获取对应的异常库区
|
-- 异常库区 TWO-BGYCKQ,TWO-QGYCKQ,THREE-BGYCKQ,THREE-QGYCKQ
|
local area_info
|
local strCondition = "S_CODE = '" .. start_loc.area_code .. "'"
|
nRet, area_info = m3.GetDataObjByCondition(strLuaDEID, "Area", strCondition)
|
if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "获取库区信息失败!" .. area_info) end
|
lua.Debug(strLuaDEID, debug.getinfo(1), 'area_info:', area_info)
|
|
local yc_area = ''
|
if (tonumber(area_info.floor) == 2) then
|
lua.Debug(strLuaDEID, debug.getinfo(1), "333!", 3333)
|
if (area_info.note == '半钢') then
|
yc_area = "TWO-BGYCKQ"
|
elseif (area_info.note == '全钢') then
|
yc_area = "TWO-QGYCKQ"
|
else
|
lua.Error(strLuaDEID, debug.getinfo(1), "未定义该站点的库区描述是属于半钢还是全钢!")
|
end
|
elseif (tonumber(area_info.floor) == 3) then
|
if (area_info.note == '半钢') then
|
yc_area = "THREE-BGYCKQ"
|
elseif (area_info.note == '全钢') then
|
yc_area = "THREE-QGYCKQ"
|
else
|
lua.Error(strLuaDEID, debug.getinfo(1), "未定义该站点的库区描述是属于半钢还是全钢!")
|
end
|
else
|
lua.Error(strLuaDEID, debug.getinfo(1), "该楼层未定义异常库区!")
|
end
|
lua.Debug(strLuaDEID, debug.getinfo(1), 'yc_area:', yc_area)
|
|
-- 获取异常区终点
|
local end_loc
|
nRet, end_loc = wms_base.GetAreaAvaliableLoc(strLuaDEID, yc_area)
|
if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "wms_base.GetAreaAvaliableLoc 失败! " .. end_loc) end
|
nRet, end_loc = wms_wh.GetLocInfo(end_loc)
|
if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), 'WMS_GetLocInfo失败!' .. end_loc) end
|
lua.Debug(strLuaDEID, debug.getinfo(1), 'end_loc:', end_loc)
|
-- 创建作业
|
local operation = m3.AllocObject(strLuaDEID, "Operation")
|
operation.start_wh_code = start_loc.wh_code
|
operation.start_area_code = start_loc.area_code
|
operation.start_loc_code = start_loc.code
|
|
-- 终点信息
|
operation.end_wh_code = end_loc.wh_code
|
operation.end_area_code = end_loc.area_code
|
operation.end_loc_code = end_loc.code
|
|
operation.op_type = wms_base.Get_nConst(strLuaDEID, "作业类型-入库")
|
local ext_table = {
|
task_no = strCode
|
}
|
operation.op_def_name = "AGV库内搬运"
|
operation.cntr_code = cntr_code
|
operation.ext_data = lua.table2str(ext_table)
|
|
nRet, operation = m3.CreateDataObj(strLuaDEID, operation)
|
if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '创建【作业】失败!' .. operation) end
|
lua.Debug(strLuaDEID, debug.getinfo(1), "作业创建后信息", operation)
|
end
|
end
|
