--[[ 编码: GT-100-14 名称: AGV任务回报 作者: LZH 入口函数：TaskStatus 功能说明: 接收AGV的任务返回状态 输入数据： { "taskNum": "任务号", "taskStatus": 订单状态：1 开始执行，2 任务完成 ，3 开始取货，4 取货完成，5 开始放货，6 放货完成 ,7 任务取消，8 强制完成 } 处理逻辑 -- step1 解析接口传递的 datajson 参数 -- step2 校验必传字段是否为空，为空则报错 -- step3 反馈类型 2 设置任务完成 4 容器货品解绑 6 容器货品绑定 变更历史: V1.1 LZH 20250506 立库出库和粉料出库AGV取货完成之后直接回传GTWMS --]] require("WMS-Equipment") wms_cntr = require("wms_container") wms_wh = require("wms_wh") require("GT-Base") wms_task = require("wms_task") function AGVTaskStatus(strLuaDEID) local nRet, in_date, strRetInfo -- step1 获取接口数据 nRet, in_date = m3.GetSysDataJson(strLuaDEID) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "WCStoreCallback 无法获取数据包!" .. in_date) end lua.Debug(strLuaDEID, debug.getinfo(1), 'AGV任务回报参数:', in_date) -- step2 判断 必填项 是否都有值？没值报错返回 local task_no = in_date.taskNum if (task_no == nil or task_no == '') then lua.Error(strLuaDEID, debug.getinfo(1), "任务号不能为空!") end local feed_type = tonumber(in_date.taskStatus) if (feed_type == nil) then lua.Error(strLuaDEID, debug.getinfo(1), "反馈类型不能为空!") end -- 获取任务信息 local task, operation nRet, task = wms_task.GetInfo(strLuaDEID, task_no) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), task) end -- 获取作业信息 local condition = "S_CODE = '" .. task.op_code .. "'" nRet, operation = m3.GetDataObjByCondition(strLuaDEID, "Operation", condition) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), operation) end -- 反馈类型 2 设置任务完成 4 容器货品解绑 6 容器货品绑定 if (feed_type == 2) then -- 设置任务完成 nRet, strRetInfo = wms.wms_TaskFinish(strLuaDEID, task_no) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "任务编码='" .. task_no .. "'的任务设置完成失败!" .. strRetInfo) end -- 增加 任务动作 对象 local task_action = m3.AllocObject(strLuaDEID, "Task_Action") task_action.task_code = task_no task_action.action_code = 2 task_action.action = "AGV搬运完成" task_action.eq_code = "system" task_action.eq_type_name = '完成' nRet, strRetInfo = m3.CreateDataObj(strLuaDEID, task_action) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '创建【任务动作】对象失败!' .. strRetInfo) end elseif (feed_type == 4) then -- V1.1 LZH 20250506 立库出库和粉料出库AGV取货完成之后直接回传GTWMS -- 立库出库的二段AGV任务是托盘离开货位则扣除库存 if (task.op_name == '立库出库' or task.op_name == '粉料出库') then if (task.op_name == '粉料出库') then nRet, strRetInfo = wms_wh.Loc_Container_Unbinding(strLuaDEID, task.start_loc_code, operation.cntr_code, "绑定解绑方法-系统", "完成") if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '货位容器解绑失败!' .. strRetInfo) end end -- 获取扩展数据参数 local ext_data = json.decode(operation.ext_data) local delivery_no = ext_data.delivery_no -- 业务单号为 出库单号 --获取出库单信息 local stock_out condition = "S_DO_NO = '" .. delivery_no .. "'" nRet, stock_out = m3.GetDataObjByCondition(strLuaDEID, "GT_Stock_Out", condition) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), stock_out) end -- 获取容器货品明细 local cg_detail condition = "S_CNTR_CODE = '" .. operation.cntr_code .. "'" nRet, cg_detail = m3.GetDataObjByCondition(strLuaDEID, "CG_Detail", condition) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), cg_detail) end -- 获取入库单据行信息 local label_crad local strCondition = "S_SERIAL_NO = '" .. cg_detail.serial_no .. "'" if (tonumber(cg_detail.is_tl) == 1) then nRet, label_crad = m3.GetDataObjByCondition(strLuaDEID, "GT_ROM", strCondition, "T_CREATE DESC") if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1),"获取流水号信息失败!" .. label_crad) end else nRet, label_crad = m3.GetDataObjByCondition(strLuaDEID, "GT_Label_Crad", strCondition, "T_CREATE DESC") if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1),"获取流水号信息失败!" .. label_crad) end end -- 获取入库单据头信息 local incoming_Info condition = "S_DELIVERY_NO = '" .. label_crad.delivery_no .. "' AND N_DELIVERY_ROW_NO = '" .. label_crad.delivery_row_no .. "'" nRet, incoming_Info = m3.GetDataObjByCondition(strLuaDEID, "GT_Incoming_Info", condition, "T_CREATE DESC") if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "获取入库单据头信息失败!" .. incoming_Info) end -- if (stock_out.type == '人工录入') then -- -- 创建【GTWMS同步记录】 -- local sys_record = m3.AllocObject(strLuaDEID, "GTWMS_SYNC_RECORD") -- sys_record.delivery_no = incoming_Info.delivery_no -- sys_record.delivery_row_no = incoming_Info.delivery_row_no -- sys_record.task_no = delivery_no -- sys_record.lpn = cg_detail.serial_no -- sys_record.rfid = operation.cntr_code -- sys_record.lpnweight = cg_detail.qty -- sys_record.sku = cg_detail.item_code -- sys_record.batch_no = cg_detail.batch_no -- sys_record.grade = incoming_Info.level -- sys_record.type = "出库回传" -- lua.Debug(strLuaDEID, debug.getinfo(1), 'sys_record', sys_record) -- nRet, sys_record = m3.CreateDataObj(strLuaDEID, sys_record) -- if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), 'mobox 创建【GTWMS同步记录】对象失败!' .. sys_record) end -- else -- 出库结果回传 local data local source = "GTWMS出库回传" nRet, data = StorageResult(strLuaDEID, operation.code, source) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "出库结果回传失败!" .. data) end lua.Debug(strLuaDEID, debug.getinfo(1), 'data', data) -- 调用GT-WMS的回传接口 local url = wms_base.Get_sConst(strLuaDEID, "GTWMS-url") local strurl = url local strHeader = "" local strBody = { application = "GITI", code = "WCS_SO_WMS", data = data } nRet, strRetInfo = CreateInterfaceExc(strLuaDEID, strurl, strHeader, strBody, "GTWMS", source) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "调用接口失败!" .. strRetInfo) end -- end end elseif (feed_type == 6) then if (task.op_name == '粉料入库') then nRet, strRetInfo = wms_wh.Loc_Container_Binding(strLuaDEID, task.end_loc_code, operation.cntr_code, "绑定解绑方法-系统", "完成") if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '货位容器解绑失败!' .. strRetInfo) end end elseif (feed_type == 7) then end end