-- 四舍五入函数 local function round(number, precision) precision = precision or 0 local mult = 10 ^ (precision or 0) return math.floor(number * mult + 0.5) / mult end -- 定义函数用于拆分字符串并转换为数字集合 local function splitAndCollectNumbers(str) local numbers = {} for num in string.gmatch(str, "%d+") do numbers[tonumber(num)] = true end return numbers end -- 定义函数用于找出两个集合中重合的数字并拼接成字符串 local function findCommonNumbers(strA, strB) local setA = splitAndCollectNumbers(strA) local setB = splitAndCollectNumbers(strB) local commonNumbers = {} for num in pairs(setA) do if setB[num] then table.insert(commonNumbers, tostring(num)) end end return table.concat(commonNumbers, ",") end --[ -- PackWorkGeneralOperation 装箱工单入库单入库通用操作 -- 1、获取目视卡信息 -- 2、新增容器货品绑定 -- 3、新增装箱记录 -- 4、更新装箱工单数量 -- 5、更新入库单数量 -- 6、判断装箱工单、入库单是否关闭 -- param: -- serial_no 条码 -- cntr_code 容器编码 -- pack_no 装箱工单号 -- order_no 入库单号 --] local function PackWorkGeneralOperation(strLuaDEID, serial_no, cntr_code, pack_no, order_no, dispersoid) local nRet, strRetInfo, label_card, strCondition --step1 获取目视卡中的信息，用这个卡中的信息创建 CG_Detail strCondition = "S_SERIAL_NO = '" .. serial_no .. "'" nRet, label_card = m3.GetDataObjByCondition(strLuaDEID, "GT_Label_Crad", strCondition) if (nRet ~= 0) then return 2, "m3.GetDataObjByCondition 失败!" .. label_card end -- 目视卡基本属性判断 if (label_card.qty <= 0) then return 1, "目视卡'" .. serial_no .. "'的数量必须有值不能是负数!" end nRet, strRetInfo = wms_cntr.EmptyContainer_Verify(strLuaDEID, cntr_code) if (nRet ~= 0) then return 2, "容器验证失败!" .. strRetInfo end --step2 新增容器货物绑定 local cg_detail = m3.AllocObject(strLuaDEID, "CG_Detail") cg_detail.cntr_code = cntr_code cg_detail.batch_no = label_card.batch_no cg_detail.item_code = label_card.item_code cg_detail.item_name = label_card.item_name cg_detail.qty = label_card.qty cg_detail.uom = 'kg' cg_detail.serial_no = label_card.serial_no lua.Debug(strLuaDEID, debug.getinfo(1), 'cg_detail', cg_detail) nRet, cg_detail = m3.CreateDataObj(strLuaDEID, cg_detail) if (nRet ~= 0) then return 2, 'mobox 创建【容器货品明细】对象失败!' .. cg_detail end --step3 新增【装箱记录】 local packing_record = m3.AllocObject(strLuaDEID, "GT_Packing_Rec") packing_record.pack_no = pack_no packing_record.qty = label_card.qty packing_record.cntr_code = cntr_code packing_record.serial_no = label_card.serial_no nRet, packing_record = m3.CreateDataObj(strLuaDEID, packing_record) if (nRet ~= 0) then return 2, '创建【装箱记录】失败!' .. packing_record end --step4 更新【装箱工单】中的累计装箱数量 -- 装箱工单表的累计数量+1 strCondition = "S_PACK_NO = '" .. pack_no .. "'" local strSetSQL_update = " N_ACC_QTY = N_ACC_QTY + 1 " nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "GT_Packing_Order", strCondition, strSetSQL_update) if (nRet ~= 0) then return 2, "updateDataAttrByCondition 失败! " .. strRetInfo end -- 如果是散装胶则单独判断入库单据行生成的总重量是否满足入库单据头的批次号总重,满足则关闭入库单和装箱工单 if (dispersoid == 'Y') then -- 获取入库单据头 local incoming_Info strCondition = "S_ORDER_NO = '" .. label_card.order_no .. "'" nRet, incoming_Info = m3.GetDataObjByCondition(strLuaDEID, "GT_Incoming_Info", strCondition) if (nRet ~= 0) then return 2, "m3.GetDataObjByCondition 失败!" .. incoming_Info end -- 获取自己生成的散装胶的数量总和 strCondition = "S_SERIAL_NO LIKE 'S%' AND S_ORDER_NO = '" .. incoming_Info.order_no .. "'" local sumQty nRet, sumQty = mobox.getDataObjAttrSum(strLuaDEID, "GT_Label_Crad", strCondition, "F_QTY") if (nRet ~= 0) then return 2, "获取已入库散装胶总数失败! " .. sumQty end lua.Debug(strLuaDEID, debug.getinfo(1), 'sumQty', sumQty) sumQty = json.decode(sumQty) if (sumQty[1] == nil or sumQty[1] == '') then sumQty = 0 else sumQty = tonumber(sumQty[1]) end -- 判断已入库数量是否达到 GTWMS下发的入库单据头的批次号总重,达到了则设置装箱工单和入库单状态为完成 if (tonumber(sumQty) >= tonumber(incoming_Info.actual_qty)) then strCondition = "S_ORDER_NO = '" .. label_card.order_no .. "'" local strSetSQL = "S_STATE = '完成'" nRet, strRetInfo = mobox.updateTableAttrByCondition(strLuaDEID, "TN_GT_Incoming_Info", strCondition, strSetSQL) if (nRet ~= 0) then return 2, strRetInfo end strCondition = "S_ORDER_NO = '" .. label_card.order_no .. "'" strSetSQL = "S_STATE = '完成'" nRet, strRetInfo = mobox.updateTableAttrByCondition(strLuaDEID, "TN_GT_Packing_Order", strCondition, strSetSQL) end else --step5 更新【入库单】中的累计装箱数量 strCondition = "S_ORDER_NO = '" .. order_no .. "'" strSetSQL_update = " N_ACC_PACK_QTY = N_ACC_PACK_QTY + 1 " nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "GT_Incoming_Info", strCondition, strSetSQL_update) if (nRet ~= 0) then return 2, "updateDataAttrByCondition 失败! " .. strRetInfo end --step6 判断装箱工单、入库单是否关闭 -- 1、判断装箱工单是否有装箱件数，如果有判断装箱工单是否完成 -- 2、判断该装箱工单上游的入库单的累计数量和托盘数量是否相同，相同则设置入库单状态以及入库单下所有启动状态的装箱工单 状态为完成 local obj_display_name = packing_record.pack_no local wfp_list_show_name = "'" .. packing_record.pack_no .. "'新增【装箱记录】后处理程序" nRet, strRetInfo = mobox.addSysWFP(strLuaDEID, 1, "", packing_record.cls, packing_record.id, obj_display_name, 0, "", "判断状态是否完成", wfp_list_show_name, "接口 WCStoreCallback", 0) if (nRet ~= 0) then return 2, "addSysWFP 失败!" .. strRetInfo end end return 0, label_card end --[ -- ManualBindGeneralOperation 人工绑定入库单入库通用操作 -- 1、验证容器货物绑定 -- 2、获取入库单号 -- 3、更新入库单状态、数量 -- 4、判断入库单是否关闭 -- param: -- cntr_code 容器编码 --] local function ManualBindGeneralOperation(strLuaDEID, cntr_code) local nRet, strRetInfo, cg_detail, strCondition --step1 验证容器货物绑定 nRet, cg_detail = wms_cntr.Get_Container_Goods(strLuaDEID, cntr_code) if (cg_detail == nil or cg_detail == '' or #cg_detail == 0) then return 1, "未进行码盘操作!" end cg_detail = cg_detail[1].attrs cg_detail = m3.KeyValueAttrsToObjAttr(cg_detail) --step2 通过流水号获取入库单号 strCondition = "S_SERIAL_NO = '" .. cg_detail.S_SERIAL_NO .. "'" local label_card nRet, label_card = m3.GetDataObjByCondition(strLuaDEID, "GT_Label_Crad", strCondition) if (nRet ~= 0) then return 2, "m3.GetDataObjByCondition 失败!" .. label_card end -- CG_Detail里面的字段 N_IS_FJ 为复检标识,如果该数据是复检则不需要更新入库单的状态 if (tonumber(cg_detail.N_IS_FJ) == 1) then return 0, label_card end --step3 更新入库单状态、数量 strCondition = "S_ORDER_NO = '" .. label_card.order_no .. "'" nRet, strRetInfo = mobox.queryOneDataObjAttr(strLuaDEID, "GT_Incoming_Info", strCondition) if (nRet ~= 0) then return 2, "queryOneDataObjAttr 失败!" .. strRetInfo end strRetInfo = json.decode(strRetInfo) local strSetSQL_update = " N_ACC_PACK_QTY = N_ACC_PACK_QTY + 1 " if (strRetInfo.state == '新建') then strSetSQL_update = strSetSQL_update .. " ,S_STATE = '启用'" end nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "GT_Incoming_Info", strCondition, strSetSQL_update) if (nRet ~= 0) then return 2, "updateDataAttrByCondition 失败! " .. strRetInfo end --step4 判断入库单是否关闭 --判断入库单据的 累计数量 = 托盘数量，如果相等则设置入库单为完成，如果超出 托盘数 系统报错 local order nRet, order = m3.GetDataObjectByKey(strLuaDEID, "GT_Incoming_Info", "S_ORDER_NO", label_card.order_no) if (nRet ~= 0) then return 2, order end if (tonumber(order.acc_pack_qty) == tonumber(order.cntr_qty)) then strCondition = "S_ORDER_NO = '" .. order.order_no .. "'" local strSetSQL = "S_STATE = '完成'" nRet, strRetInfo = mobox.updateTableAttrByCondition(strLuaDEID, "TN_GT_Incoming_Info", strCondition, strSetSQL) if (nRet ~= 0) then return 2, strRetInfo end elseif (tonumber(order.acc_pack_qty) > tonumber(order.cntr_qty)) then return 2, "入库单已完成，不允许入库!" end return 0, label_card end --[ -- PackVerification 装箱校验 -- 1、验证容器货物绑定 -- 2、验证工位与装箱工单是否一致 -- 3、获取入库单号 -- param: -- station_no 入库站点 --] local function PackVerification(strLuaDEID, station_no) local nRet, strRetInfo -- step1获取本工位最新的 【装箱检验】 local strCondition = "S_STATION = '" .. station_no .. "' AND S_STATE = '新建'" local strOrder = "T_CREATE desc" local packing_check nRet, packing_check = m3.GetDataObjByCondition(strLuaDEID, "GT_Packing_Check", strCondition, strOrder) if (nRet == 1) then return 1, "请先用PDA扫描目视卡进行检验!" end if (nRet ~= 0) then return 2, "m3.GetDataObjByCondition 失败!" .. packing_check end --step2 验证工位与装箱工单是否一致 local delivery_no = packing_check.delivery_no -- 收货单号 local delivery_row_no = packing_check.delivery_row_no -- 收货单行号 -- 检验装箱工单上的物料是否在本工位装箱 -- 通过 收货单号、收货单行号， 只要装箱工单上有 这个工位的收货单号、收货单行号获取的入库单号 就通过 -- 查询 状态=启动 的装箱工单 local sql = "SELECT S_ORDER_NO FROM TN_GT_Incoming_Info WHERE S_DELIVERY_NO = '" .. delivery_no .. "' AND N_DELIVERY_ROW_NO = '" .. delivery_row_no .. "'" strCondition = "S_STATION = '" .. station_no .. "' AND S_STATE = '启用' AND S_ORDER_NO = (" .. sql .. ")" local packing_order nRet, packing_order = m3.GetDataObjByCondition(strLuaDEID, "GT_Packing_Order", strCondition, strOrder) if (nRet == 1) then return 1, "目前的装箱工位不能对收货单号为'" .. delivery_no .. "'的物料进行装箱!" end if (nRet ~= 0) then return 2, "m3.GetDataObjByCondition 失败!" .. packing_order end --step3 更新【装箱校验】设置为"完成" strCondition = "S_SERIAL_NO = '" .. packing_check.serial_no .. "' AND S_STATION = '" .. station_no .. "' AND S_STATE = '新建'" local strUpdateSql = "S_STATE = '完成'" nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "GT_Packing_Check", strCondition, strUpdateSql) if (nRet ~= 0) then return 2, "更新【装箱校验】信息失败!" .. strRetInfo end return 0, packing_check.serial_no end --[ -- StockInquiry 库存查询 -- 1、获取巷道货位总数 -- 2、获取满货位总数 -- 3、（满货位总数 / 巷道总数）* 100 = 满货位百分比 -- 4、判断满货位库存是否达到80%,没达到则返回可入库巷道 -- param: -- str_roadway 巷到 --] local function StockInquiry(strLuaDEID) -- 获取未冻结的巷道 local strCondition = "S_AREA_CODE = 'LK' AND N_LOCK_STATE = 0" local nRet, roadway = m3.QueryDataObject(strLuaDEID, "Roadway", strCondition) if (nRet ~= 0) then return 2, '查询巷道信息失败' .. roadway end if (roadway == nil or roadway == '') then return 2, '没有可入库的巷道!' end local str = '' for i = 1, #roadway do local attrs = roadway[i].attrs attrs = m3.KeyValueAttrsToObjAttr(attrs) if (attrs == nil) then goto coroutine end -- 调用WCS接口获取巷道的状态 local data = { req_no = lua.guid(), roadway = attrs.N_ROADWAY } local url = wms_base.Get_sConst(strLuaDEID, "WCS-url") local strurl = url .. "/StackerState" local roadway_state local nRet, strRetInfo = mobox.sendHttpRequest(strurl, "", lua.table2str(data)) if (nRet ~= 0) then return 2, "调用接口失败!" .. strRetInfo end local success, resJson = pcall(json.decode, roadway_state) if(success == 0)then roadway_state = resJson.data[1].roadway_state if(tonumber(roadway_state) == 0 or tonumber(roadway_state) == 3)then goto coroutine end end local strRetInfo -- 获取巷道货位总数 strCondition = "S_AREA_CODE = 'LK' AND N_ROADWAY = " .. attrs.N_ROADWAY nRet, strRetInfo = mobox.getDataObjCount(strLuaDEID, "Location", strCondition) if (nRet ~= 0) then return 2, "getDataObjCount 失败!" .. strRetInfo end local hw_count = tonumber(strRetInfo) -- 指定巷道的货位总数 lua.Debug(strLuaDEID, debug.getinfo(1), "hw_count", hw_count) strCondition = "S_AREA_CODE = 'LK' AND N_CURRENT_NUM <> 0 AND N_ROADWAY = " .. attrs.N_ROADWAY nRet, strRetInfo = mobox.getDataObjCount(strLuaDEID, "Location", strCondition) if (nRet ~= 0) then return 2, "getDataObjCount 失败!" .. strRetInfo end local mhw_count = tonumber(strRetInfo) -- 指定巷道的满货位总数 lua.Debug(strLuaDEID, debug.getinfo(1), "mhw_count", mhw_count) local mhw_ratio = (mhw_count / hw_count) * 100 -- 满货位占比 if (mhw_ratio == nil) then return 1, "计算失败!巷道:" .. attrs.N_ROADWAY .. " 满货位数量:" .. mhw_count .. "货位总数:" .. hw_count end -- 获取字典定义的移库比例 nRet, strRetInfo = mobox.getDictItemIInfo("GT_LK_RATIO") if (nRet ~= 0) then return 2, "getDictItemIInfo 失败!" .. strRetInfo end strRetInfo = json.decode(strRetInfo) local item_ratio = tonumber(strRetInfo[1].name) -- 字典定义的巷道安全库存比例 if (mhw_ratio <= item_ratio) then str = str .. attrs.N_ROADWAY .. "," end ::coroutine:: end -- 去除最后一个, str = lua.trim_laster_char(str) lua.Debug(strLuaDEID, debug.getinfo(1), "str", str) return 0, str end --[ -- RobotBoxing 机器人装箱 -- 1、获取GTWMS同步的流水号 -- 2、GTWMS流水号多行时确定具体处理行 -- 3、获取通过物料编码散装胶组盘规则维护的物料的标准重量 -- 4、根据码盘规则计算重量 -- 5、新增入库单据行信息 -- param: -- order_no 入库单号 -- qty 装箱数量 -- palletizing 码盘规则 --] local function RobotBoxing(strLuaDEID, order_no, qty, palletizing) local nRet, strRetInfo if (qty == nil) then return 2, "散装胶数量非数字或为空!" end if (qty ~= math.floor(qty) or qty <= 0) then return 2, "散装胶数量非正整数" end lua.Debug(strLuaDEID, debug.getinfo(1), 'qty', tonumber(qty)) if (palletizing == '' or palletizing == nil) then return 2, "散装胶码盘规则不能为空!" end --step1 获取GTWMS同步的流水号(可能存在一个单据头，多个流水号的存在) local strCondition = "S_ORDER_NO = '" .. order_no .. "' AND S_SERIAL_NO NOT LIKE 'S%'" local label_crad nRet, label_crad = m3.QueryDataObject(strLuaDEID, "GT_Label_Crad", strCondition) if (nRet ~= 0) then return 2, "m3.GetDataObjByCondition 失败!" .. label_crad end local attr -- step2 GTWMS流水号多行时确定具体处理行 for i = 1, #label_crad do nRet, attr = m3.ObjAttrStrToLuaObj("GT_Label_Crad", lua.table2str(label_crad[i].attrs)) if (nRet ~= 0) then return 2, "m3.ObjAttrStrToLuaObj(GT_Label_Crad) 失败! " .. attr end lua.Debug(strLuaDEID, debug.getinfo(1), 'attr', attr) -- 根据流水号的唯一码统计我们自己返回的散装胶 S开头的编码 的数量总和 strCondition = "S_REQ_NO = '" .. attr.req_no .. "' AND S_SERIAL_NO LIKE 'S%'" local sumQty nRet, sumQty = mobox.getDataObjAttrSum(strLuaDEID, "GT_Label_Crad", strCondition, "F_QTY") if (nRet ~= 0) then return 2, "获取已入库散装胶总数失败 失败! " .. sumQty end sumQty = json.decode(sumQty) if (sumQty[1] == nil or sumQty[1] == '') then sumQty = 0 else sumQty = tonumber(sumQty[1]) end if (tonumber(attr.qty) > tonumber(sumQty)) then goto coroutine end if (i == #label_crad) then return 2, "未查找到对应的入库单据行记录! " end end ::coroutine:: -- label_crad = attr --step3 通过入库单据行的托盘重量和块数计算标准重量 local weight = tonumber(attr.qty) / tonumber(attr.number) lua.Debug(strLuaDEID, debug.getinfo(1), "qty", qty) lua.Debug(strLuaDEID, debug.getinfo(1), "attr", attr) lua.Debug(strLuaDEID, debug.getinfo(1), "weight", weight) --step4 根据码盘规则计算重量 入库单据行重量为机械臂统计的数量 * 标准重量 local all_qty = tonumber(qty) * tonumber(weight) lua.Debug(strLuaDEID, debug.getinfo(1), "all_qty", all_qty) -- 自动生成流水号(编码规则 S + 7位数字) local strCode nRet, strCode = mobox.getSerialNumber("散装胶流水号", 'S', 7) if (nRet ~= 0) then return 2, "申请散装胶入库单据行编码失败!" .. strCode end --setep5 新增入库单据行信息 创建入库单据行 -- 获取一个初始的【入库单据行】数据对象 local new_label_crad = m3.AllocObject(strLuaDEID, "GT_Label_Crad") new_label_crad.delivery_no = attr.delivery_no new_label_crad.delivery_row_no = attr.delivery_row_no new_label_crad.item_code = attr.item_code new_label_crad.item_code_9 = attr.item_code_9 new_label_crad.item_name = attr.item_name new_label_crad.product_date = attr.product_date new_label_crad.batch_no = attr.batch_no new_label_crad.item_state = attr.item_state new_label_crad.qty = all_qty new_label_crad.serial_no = strCode new_label_crad.wh_code = attr.wh_code new_label_crad.storage_loc = attr.storage_loc new_label_crad.order_no = attr.order_no new_label_crad.is_bonded = attr.is_bonded new_label_crad.wheel_type_rot = attr.wheel_type_rot new_label_crad.subpool = attr.subpool new_label_crad.req_no = attr.req_no new_label_crad.dispersoid = attr.dispersoid new_label_crad.palletizing = attr.palletizing lua.Debug(strLuaDEID, debug.getinfo(1), 'new_label_crad', new_label_crad) nRet, new_label_crad = m3.CreateDataObj(strLuaDEID, new_label_crad) if (nRet ~= 0) then return 2, "mobox 创建【入库单据行】对象失败!" .. new_label_crad end return 0, new_label_crad.serial_no end -- 创建作业 local function CreateOperation(strLuaDEID, item_code, batch_no, loc_start, inbound_policy, ext_table, cntr_code) lua.Debug(strLuaDEID, debug.getinfo(1), '进入创建作业', loc_start) lua.Debug(strLuaDEID, debug.getinfo(1), '进入创建作业', inbound_policy) lua.Debug(strLuaDEID, debug.getinfo(1), '进入创建作业', cntr_code) --获取物料类型 local nRet, item_type, material = GT_Get_ItemType(strLuaDEID, item_code) if (nRet ~= 0) then return 1, item_type end lua.Debug(strLuaDEID, debug.getinfo(1), '物料信息', material) -- 添加扩展作业 ext_table.batch_no = batch_no -- 批次号 ext_table.item_code = item_code -- 物料编码 ext_table.item_type = item_type -- 物料类型 ext_table.is_insulate = material.is_insulate -- 是否保温 -- 获取字典定义的天然胶规则 local is_trj nRet, is_trj = mobox.getDictItemIInfo("GT_TRJ_DATE") if (nRet ~= 0) then return 2, "getDictItemIInfo 失败!" .. is_trj end is_trj = json.decode(is_trj) is_trj = tonumber(is_trj[1].name) -- 天然胶规则 1 启用 2 禁用 -- 获取巷道库存未达到 80% 的可入库巷道 local strRetInfo nRet, strRetInfo = StockInquiry(strLuaDEID) if (nRet ~= 0) then return 2, strRetInfo end ext_table.roadway_inventory = strRetInfo -- 作业扩展数据存入这个巷道库存字符串，里面是库存未超过80%的巷道 lua.Debug(strLuaDEID, debug.getinfo(1), '可入库巷道', strRetInfo) -- 判断起点是否为一楼左侧回库口或三楼回库口,如果是只能使用3，4巷道 if (loc_start.code == wms_base.Get_sConst(strLuaDEID, "KL_ReturnRgvStation1") or loc_start.code == wms_base.Get_sConst(strLuaDEID, "F3L_InWeight1") or loc_start.code == wms_base.Get_sConst(strLuaDEID, "F3R_InWeight1")) then local b = wms_base.Get_sConst(strLuaDEID, "佳通-一楼左侧回库口巷道") local str = findCommonNumbers(ext_table.roadway_inventory, b) if (str == nil or str == '') then return 2, "没有可入库的3,4巷道!" end ext_table.roadway_inventory = str end --step5 创建作业 local operation = m3.AllocObject(strLuaDEID, "Operation") operation.start_wh_code = loc_start.wh_code operation.start_area_code = loc_start.area_code operation.start_loc_code = loc_start.code operation.op_type = wms_base.Get_nConst(strLuaDEID, "作业类型-入库") -- 判断客户指定的规则 -- 客户指定胶料入库策略 1：入7、8巷道； 2：不入7、8巷道； 3：系统巷道均衡分配； 针对天然胶物料入库的时候去进行策略的判断。 local end_loc if (tonumber(inbound_policy) == 1) then -- 获取可入库巷道 local b = wms_base.Get_sConst(strLuaDEID, "佳通-保温巷道") local str = findCommonNumbers(ext_table.roadway_inventory, b) if (str == nil or str == '') then return 2, "没有可入库的保温巷道!" end ext_table.roadway_inventory = str operation.op_def_name = "保温材料入库" -- 获取作业终点位置 nRet, end_loc = BW_StorageTactics(strLuaDEID, ext_table) if (nRet ~= 0) then return 2, "计算终点失败！" .. end_loc end if (end_loc == nil or end_loc == '') then return 2, "立库中没有满足条件的货位可以分配!" end -- 获取终点信息 nRet, end_loc = wms_wh.GetLocInfo(end_loc) if (nRet ~= 0) then return 2, 'WMS_GetLocInfo失败!' .. end_loc end operation.end_wh_code = end_loc.wh_code operation.end_area_code = end_loc.area_code operation.end_loc_code = end_loc.code ext_table.roadway = end_loc.roadway goto continue elseif (tonumber(inbound_policy) == 2) then local b = wms_base.Get_sConst(strLuaDEID, "佳通-非保温巷道") local str = findCommonNumbers(ext_table.roadway_inventory, b) if (str == nil or str == '') then return 2, "没有可入库的非保温巷道!" end ext_table.roadway_inventory = str operation.op_def_name = "立库入库" -- 获取终点信息 nRet, end_loc = JL_StorageTactics(strLuaDEID, ext_table) if (nRet ~= 0) then return 2, "计算终点失败！" .. end_loc end if (end_loc == nil or end_loc == '') then return 2, "立库中没有满足条件的货位可以分配!" end -- 获取终点信息 nRet, end_loc = wms_wh.GetLocInfo(end_loc) if (nRet ~= 0) then return 2, 'WMS_GetLocInfo失败!' .. end_loc end operation.end_wh_code = end_loc.wh_code operation.end_area_code = end_loc.area_code operation.end_loc_code = end_loc.code ext_table.roadway = end_loc.roadway goto continue end if (is_trj == 1 and material.is_insulate == 'Y') then -- 获取可入库巷道 local b = wms_base.Get_sConst(strLuaDEID, "佳通-保温巷道") local str = findCommonNumbers(ext_table.roadway_inventory, b) if (str == nil or str == '') then return 2, "没有可入库的保温巷道!" end ext_table.roadway_inventory = str operation.op_def_name = "保温材料入库" -- 获取作业终点位置 nRet, end_loc = BW_StorageTactics(strLuaDEID, ext_table) if (nRet ~= 0) then return 2, "计算终点失败！" .. end_loc end if (end_loc == nil or end_loc == '') then return 2, "立库中没有满足条件的货位可以分配!" end -- 获取终点信息 nRet, end_loc = wms_wh.GetLocInfo(end_loc) if (nRet ~= 0) then return 2, 'WMS_GetLocInfo失败!' .. end_loc end operation.end_wh_code = end_loc.wh_code operation.end_area_code = end_loc.area_code operation.end_loc_code = end_loc.code ext_table.roadway = end_loc.roadway goto continue end if (item_type == '粉料') then operation.op_def_name = "粉料入库" ext_table.isothermal = material.isothermal -- 是否恒温，用来判断粉料是否入恒温库 ext_table.area_code = material.area_code -- 库区，用来判断粉料入库口的位置 -- GT_Area_Type 字典名称 1,2,3 的附加值分别对应东粉料库、西粉料库、粉料比例维护三种 local dictItem nRet, dictItem = mobox.getDictItemIInfo("GT_Area_Type") if (nRet ~= 0) then return 2, dictItem end dictItem = json.decode(dictItem) local loc_code, d_ratio, x_ratio local strCondition, area for m = 1, #dictItem do -- 佳通WMS传的库区和字典定义的值相等则判断字典名称是哪个终点库区 if (material.area_code == dictItem[m].value) then if (tonumber(dictItem[m].name) == 1) then if (material.isothermal == 'Y') then area = "HWPFL" else area = "PFL" end elseif (tonumber(dictItem[m].name) == 2) then if (material.isothermal == 'Y') then area = "HWTFL" else area = "TFL" end else -- 佳通WMS没有指定东西出库口，则通过粉料比例维护来判断入库口 -- 默认比例为5:5 d_ratio = 5 x_ratio = 5 -- 获取东西粉料库该货品的数量 local d_count, x_count, count, d_num, x_num strCondition = "S_CNTR_CODE IN (SELECT S_CNTR_CODE FROM TN_CG_Detail WHERE S_ITEM_CODE = '" .. item_code .. "')" strCondition = strCondition .. " AND S_LOC_CODE IN (SELECT S_CODE FROM TN_Location WHERE S_AREA_CODE IN( 'PFL','HWPFL'))" nRet, d_count = mobox.getDataObjCount(strLuaDEID, "Loc_Container", strCondition) if (nRet ~= 0) then return 2, d_count end strCondition = "S_CNTR_CODE IN (SELECT S_CNTR_CODE FROM TN_CG_Detail WHERE S_ITEM_CODE = '" .. item_code .. "')" strCondition = strCondition .. " AND S_LOC_CODE IN (SELECT S_CODE FROM TN_Location WHERE S_AREA_CODE IN( 'TFL','HWTFL'))" nRet, x_count = mobox.getDataObjCount(strLuaDEID, "Loc_Container", strCondition) if (nRet ~= 0) then return 2, x_count end -- 东西粉料库所有该物料编码的总数 count = tonumber(d_count) + tonumber(x_count) -- 计算东西粉料库占比 if (count ~= 0) then d_num = round(tonumber(d_count) / tonumber(count) * 10) -- 东粉料库占比 x_num = round(tonumber(x_count) / tonumber(count) * 10) -- 西粉料库占比 else d_num = 0 x_num = 0 end if (material.isothermal == 'Y') then if (d_ratio >= d_num) then area = "HWPFL" end if (x_ratio >= x_num) then area = "HWTFL" end else if (d_ratio >= d_num) then area = "PFL" end if (x_ratio >= x_num) then area = "TFL" end end end end end -- 查询条件为库区为指定库区的空货位 strCondition = "S_AREA_CODE = '" .. area .. "' AND N_CURRENT_NUM = 0 AND N_LOCK_STATE = 0 AND C_ENABLE = 'Y'" -- 根据终点库区获取终点货位 按照排列层排序 local strOrder = "N_ROW,N_COL,N_LAYER" -- 最多获取 10 条 nRet, strRetInfo = mobox.queryDataObjAttr3(strLuaDEID, "Location", strCondition, 10, strOrder) if (nRet ~= 0) then return 2, "获取货位信息错误! " .. strRetInfo .. " SQL条件: " .. strCondition end local loc if (strRetInfo ~= '') then local retObjs = json.decode(strRetInfo) nRet, loc = m3.ObjAttrStrToLuaObj("Location", lua.table2str(retObjs[1].attrs)) if (nRet ~= 0) then return 2, "m3.ObjAttrStrToLuaObj(Location) 失败! " .. loc end else return 2, "没有查询到可入库的空货位!" end -- 获取终点信息 nRet, end_loc = wms_wh.GetLocInfo(loc.code) if (nRet ~= 0) then return 2, 'WMS_GetLocInfo失败!' .. end_loc end operation.end_wh_code = end_loc.wh_code operation.end_area_code = end_loc.area_code operation.end_loc_code = end_loc.code elseif (item_type == '钢丝') then local b = wms_base.Get_sConst(strLuaDEID, "佳通-非保温巷道") local str = findCommonNumbers(ext_table.roadway_inventory, b) if (str == nil or str == '') then return 2, "没有可入库的非保温巷道!" end ext_table.roadway_inventory = str operation.op_def_name = "立库入库" -- 获取终点信息 nRet, end_loc = GS_StorageTactics(strLuaDEID, ext_table) if (nRet ~= 0) then return 2, "计算终点失败！" .. end_loc end if (end_loc == nil or end_loc == '') then return 2, "立库中没有满足条件的货位可以分配!" end -- 获取终点信息 nRet, end_loc = wms_wh.GetLocInfo(end_loc) if (nRet ~= 0) then return 2, 'WMS_GetLocInfo失败!' .. end_loc end operation.end_wh_code = end_loc.wh_code operation.end_area_code = end_loc.area_code operation.end_loc_code = end_loc.code ext_table.roadway = end_loc.roadway else operation.op_def_name = "立库入库" -- 获取终点信息 nRet, end_loc = JL_StorageTactics(strLuaDEID, ext_table) if (nRet ~= 0) then return 2, "计算终点失败！" .. end_loc end if (end_loc == nil or end_loc == '') then return 2, "立库中没有满足条件的货位可以分配!" end -- 获取终点信息 nRet, end_loc = wms_wh.GetLocInfo(end_loc) if (nRet ~= 0) then return 2, 'WMS_GetLocInfo失败!' .. end_loc end operation.end_wh_code = end_loc.wh_code operation.end_area_code = end_loc.area_code operation.end_loc_code = end_loc.code ext_table.roadway = end_loc.roadway end ::continue:: lua.Debug(strLuaDEID, debug.getinfo(1), 'operation', operation) local strCode local strHeader = 'TA' .. os.date("%y%m%d") .. '-' nRet, strCode = mobox.getSerialNumber("任务", strHeader, 5) if (nRet ~= 0) then return 2, '申请【任务】编码失败!' .. strCode end ext_table.task_no = strCode operation.ext_data = lua.table2str(ext_table) operation.cntr_code = cntr_code lua.Debug(strLuaDEID, debug.getinfo(1), "end_loc", end_loc) nRet, operation = m3.CreateDataObj(strLuaDEID, operation) if (nRet ~= 0) then return 2, '创建【作业】失败!' .. operation end lua.Debug(strLuaDEID, debug.getinfo(1), "作业创建后信息", operation) -- 终点加锁操作(起点为站点有WCS管控) nRet, strRetInfo = wms.wms_LockLocation(strLuaDEID, operation.end_loc_code, wms_base.Get_nConst(strLuaDEID, "锁类型-入库锁"), ext_table.task_no, operation.code, operation.op_def_name) if (nRet ~= 0) then return 2, "wms_LockLocation 失败!" .. strRetInfo end return 0, '' end --[[ 编码: GT-100-01 名称: WCS入库回调 作者：LZH 入口函数： WCSCallback 功能说明: 通过传参的请求类型判断 1 = 货物入库/退库；2 = 托盘组入库；3 = RFID托盘查询 ；4 = 呼叫空托； 处理逻辑 -- step1 获取接口数据 -- step2 检验参数 -- step3 获取工位起点信息 -- step4 根据不同的类型做不同的操作 1=货物入库/退库；2=托盘组入库；3=RFID托盘查询 ；4 = 呼叫空托 输入数据： { "cntr_code": "106EGRCA1078", -- 容器号 "station_no": "A", -- 工位 "qty":0, -- 数量 "req_no": "11111111", -- GUID唯一标识 "req_type": "1", -- 请求类型 1=货物入库/退库；2=托盘组入库；3=RFID托盘查询 ；4 = 呼叫空托 "weight": "1", -- 重量 "req_time": "2024-12-11" -- 请求时间 } 变更记录: v1.1 lzh 20250421 增加接口请求处理，保证在同一个站点发送某一个请求类型，执行完或报错前不会有别的线程来处理 --]] require("WMS-Equipment") wms_cntr = require("wms_container") wms_wh = require("wms_wh") require("GT-Base") require("GT_InAndOutboundPolicies") function WCSCallback(strLuaDEID) local nRet, strRetInfo, in_date, sn_result, serialRet, label_card, pwgw_Ret, pvRet, pv_Restult, item_code, condition, msg local ext_table = {} -- 作业扩展参数 -- 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), 'in_date', in_date) -- 通用变量赋值 local cntr_code = in_date.cntr_code local station_no = in_date.station_no local qty = tonumber(in_date.qty) local req_no = in_date.req_no -- 唯一码 local req_type = tonumber(in_date.req_type) -- 请求类型 1=货物入库/退库；2=托盘组入库；3=RFID托盘查询 local req_time = in_date.req_time -- 请求时间 local weight = in_date.weight -- 上报的重量 -- step2 接口参数有效性验证 if (station_no == '') then lua.Error(strLuaDEID, debug.getinfo(1), "工位不能为空!") end if (req_no == '') then lua.Error(strLuaDEID, debug.getinfo(1), "请求码不能为空!") end if (req_type > 4 or req_type < 1) then lua.Error(strLuaDEID, debug.getinfo(1), "入库类型不支持!") end -- 如果容器在作业中存在执行状态则退出 condition = "S_CNTR_CODE = '" .. cntr_code .. "' AND N_B_STATE IN( 0,1,3)" nRet, strRetInfo = m3.GetDataObjByCondition(strLuaDEID, "Operation", condition) if (nRet == 0) then lua.Error(strLuaDEID, debug.getinfo(1), "容器已被占用!") end -- step3 获取起点信息 local loc_start = wms_base.Get_sConst(strLuaDEID, station_no) nRet, loc_start = wms_wh.GetLocInfo(loc_start) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), 'WMS_GetLocInfo失败!' .. loc_start) end lua.Debug(strLuaDEID, debug.getinfo(1), 'loc_start', loc_start) -- step4 根据不同的类型做不同的操作 1=货物入库/退库；2=托盘组入库；3=RFID托盘查询 ；4 = 呼叫空托 if (req_type == 1) then lua.Debug(strLuaDEID, debug.getinfo(1), 'in_date', in_date) -- 验证容器 if (cntr_code == '') then lua.Error(strLuaDEID, debug.getinfo(1), "容器不能为空!") end --容器有效性验证 local container nRet, container = wms_cntr.GetInfo(strLuaDEID, cntr_code) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "获取【容器】信息失败! " .. container) end if (container == '') then lua.Error(strLuaDEID, debug.getinfo(1), "【容器】" .. cntr_code .. "不存在!") end -- 查询退料单 条件：容器相同并且状态为编辑 nRet == 1则退料单为空走正常入库逻辑，存在退料单则走退料流程 local rom condition = "S_CNTR_CODE = '" .. cntr_code .. "' AND S_STATE IN( '编辑','执行')" nRet, rom = m3.GetDataObjByCondition(strLuaDEID, "GT_ROM", condition) lua.Debug(strLuaDEID, debug.getinfo(1), 'rom', rom) if (nRet == 1) then -- 判断是否是空托,空托则走空托入库流程 local is_kgz condition = "S_CNTR_CODE = '" .. cntr_code .. "' AND S_ITEM_CODE = 'KGZ'" nRet, is_kgz = m3.GetDataObjByCondition(strLuaDEID, "CG_Detail", condition) if (nRet == 1) then -- 如果不是空托继续走正常入库流程 goto KGZ elseif (nRet == 0) then nRet, strRetInfo = StockInquiry(strLuaDEID) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), strRetInfo) end ext_table.roadway_inventory = strRetInfo -- 作业扩展数据存入这个巷道库存字符串，里面是库存未超过80%的巷道 if (loc_start.code == wms_base.Get_sConst(strLuaDEID, "KL_ReturnRgvStation1") or loc_start.code == wms_base.Get_sConst(strLuaDEID, "F3L_InWeight1") or loc_start.code == wms_base.Get_sConst(strLuaDEID, "F3R_InWeight1")) then local b = wms_base.Get_sConst(strLuaDEID, "佳通-一楼左侧回库口巷道") local str = findCommonNumbers(ext_table.roadway_inventory, b) if (str == nil or str == '') then lua.Error(strLuaDEID, debug.getinfo(1), "没有可入库的3,4巷道!") end ext_table.roadway_inventory = str end -- 创建作业 local operation = m3.AllocObject(strLuaDEID, "Operation") operation.start_wh_code = loc_start.wh_code operation.start_area_code = loc_start.area_code operation.start_loc_code = loc_start.code operation.op_type = wms_base.Get_nConst(strLuaDEID, "作业类型-入库") operation.op_def_name = "国自空托回库" 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 goto BREAK -- 走空托入库创建作业后跳过下面的执行逻辑 end ::KGZ:: -- 获取WCS站点绑定的工位 condition = "S_START_LOC = '" .. loc_start.code .. "'" nRet, strRetInfo = m3.GetDataObjByCondition(strLuaDEID, "GT_PDA_Station", condition) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "获取【工位】信息失败! " .. strRetInfo) end station_no = strRetInfo.station lua.Debug(strLuaDEID, debug.getinfo(1), 'station_no', station_no) --判断入库站台是否有启动状态的装箱工单 local strCondition = "S_STATION = '" .. station_no .. "' AND S_STATE = '启用'" local strOrder = "T_CREATE desc" local packing nRet, packing = m3.GetDataObjByCondition(strLuaDEID, "GT_Packing_Order", strCondition, strOrder) --没有装箱工单走人工绑定流程 if (nRet == 1) then --走人工绑定操作 pwgw_Ret, label_card = ManualBindGeneralOperation(strLuaDEID, cntr_code) if (pwgw_Ret ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '人工绑定操作失败!' .. label_card) end --走装箱工单流程 elseif (nRet == 0) then -- local palletizing = packing.palletizing --lishiming 临时用，码盘规则后续从装箱工单表里直接拿 local palletizing = "1" local dispersoid = packing.dispersoid --lishiming 临时用，散装胶标识 后续从装箱工单表中拿 --机器人装箱工位，需要自动生成流水号，不需要装箱校验 if (dispersoid == 'Y') then --获取入库流水号 serialRet, sn_result = RobotBoxing(strLuaDEID, packing.order_no, qty, palletizing) --获取失败，报错提示 if (serialRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '散装胶获取入库单行数据失败!' .. sn_result) end --走装箱工单通用操作 pwgw_Ret, label_card = PackWorkGeneralOperation(strLuaDEID, sn_result, cntr_code, packing.pack_no, packing.order_no, dispersoid) --获取失败，报错提示 if (pwgw_Ret ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '装箱工单操作失败!' .. label_card) end else -- 获取装箱校验开关是否开启 local is_zxjy = wms_base.Get_sConst(strLuaDEID, "佳通-装箱校验开关") if (is_zxjy == 'Y') then --装箱校验，成功返回流水号 pvRet, pv_Restult = PackVerification(strLuaDEID, station_no) --获取失败，报错提示 if (pvRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '装箱校验失败!' .. pv_Restult) end sn_result = pv_Restult else --非装箱校验，获取流水号 -- 获取未绑定容器的入库单的流水号进行排序,取第一个和容器绑定 local order_by = "S_SERIAL_NO" strCondition = " NOT EXISTS (SELECT S_SERIAL_NO FROM TN_CG_Detail WHERE TN_CG_Detail.S_SERIAL_NO = tn_GT_Label_Crad.S_SERIAL_NO) AND S_ORDER_NO = '" .. packing.order_no .. "'" pvRet, pv_Restult = m3.GetDataObjByCondition(strLuaDEID, "GT_Label_Crad", strCondition, order_by) if (pvRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '获取未绑定的流水号失败!' .. pv_Restult) end -- 目视卡基本属性判断 if (pv_Restult.qty <= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "目视卡'" .. pv_Restult.serial_no .. "'的数量必须有值不能是负数!") end sn_result = pv_Restult.serial_no end --走装箱工单通用操作 pwgw_Ret, label_card = PackWorkGeneralOperation(strLuaDEID, sn_result, cntr_code, packing.pack_no, packing.order_no, dispersoid) --获取失败，报错提示 if (pwgw_Ret ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '装箱工单操作失败!' .. label_card) end end --获取失败，报错提示 elseif (nRet == 2) then lua.Error(strLuaDEID, debug.getinfo(1), 'm3.GetDataObjByCondition 失败!' .. packing) end -- 根据流水号更新入库单据行的称重信息 strCondition = "S_SERIAL_NO = '" .. label_card.serial_no .. "'" local strUpdateSql = "S_WEIGHT = '" .. weight .. "'" nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "GT_Label_Crad", strCondition, strUpdateSql) if (nRet ~= 0) then return 2, "更新【入库单据行】信息失败!" .. strRetInfo end -- 创建对应的作业 nRet, strRetInfo = CreateOperation(strLuaDEID, label_card.item_code, label_card.batch_no, loc_start, label_card.inbound_policy, ext_table, cntr_code) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '创建作业失败!' .. strRetInfo) end elseif (nRet == 0) then -- 判断退料逻辑是否做了容器货品绑定 local cg_detail condition = "S_CNTR_CODE = '" .. cntr_code .. "'" nRet, cg_detail = m3.GetDataObjByCondition(strLuaDEID, "CG_Detail", condition) if (nRet == 1) then lua.Error(strLuaDEID, debug.getinfo(1), "托盘物料未绑定!") elseif (nRet > 1) then lua.Error(strLuaDEID, debug.getinfo(1), "GetDataObjByCondition失败!" .. cg_detail) end lua.Debug(strLuaDEID, debug.getinfo(1), 'cg_detail', cg_detail) local item_type, material nRet, item_type, material = GT_Get_ItemType(strLuaDEID, cg_detail.item_code) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), item_type) end lua.Debug(strLuaDEID, debug.getinfo(1), '物料信息', material) if (item_type == '碳黑') then lua.Error(strLuaDEID, debug.getinfo(1), "碳黑不可入立库!") end nRet, strRetInfo = CreateOperation(strLuaDEID, cg_detail.item_code, cg_detail.batch_no, loc_start, rom.inbound_policy, ext_table, cntr_code) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '创建作业失败!' .. strRetInfo) end -- 根据 容器+状态 更新入库单据行的称重信息和状态 local strSetAttr = "S_STATE = '执行',S_WEIGHT = '" .. weight .. "' " condition = "S_CNTR_CODE = '" .. cntr_code .. "' AND S_STATE <> '完成'" nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "GT_ROM", condition, strSetAttr) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "更新【退料单】状态失败!" .. strRetInfo) end else lua.Error(strLuaDEID, debug.getinfo(1), "GetDataObjByCondition失败!" .. rom) end ::BREAK:: -- req_type = 2 托盘组入库流程 elseif (req_type == 2) then if (cntr_code == '') then lua.Error(strLuaDEID, debug.getinfo(1), "RFID不能为空!") end -- 校验容器是否已绑定货位 condition = "S_CNTR_CODE = '" .. cntr_code .. "'" nRet, strRetInfo = m3.GetDataObjByCondition(strLuaDEID, "Loc_Container", condition) if (nRet == 0) then lua.Error(strLuaDEID, debug.getinfo(1), '容器已绑定' .. strRetInfo.loc_code .. '货位!') end if (qty == nil or qty == 0) then strCondition = "S_CNTR_CODE = '" .. cntr_code .. "'" nRet, cg_detail = m3.QueryDataObject(strLuaDEID, "CG_Detail", strCondition) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "QueryDataObject失败!" .. cg_detail) end qty = cg_detail.qty else -- 绑定空托物料 物料编码 = KGZ 空工装 代表这个容器是空托,容器货品明细的数量的单位为托 local cg_detail = m3.AllocObject(strLuaDEID, "CG_Detail") cg_detail.cntr_code = cntr_code cg_detail.item_code = "KGZ" cg_detail.item_name = "空工装" cg_detail.qty = qty cg_detail.uom = '个' nRet, cg_detail = m3.CreateDataObj(strLuaDEID, cg_detail) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '创建【容器货品明细】对象失败!' .. cg_detail) end end nRet, strRetInfo = StockInquiry(strLuaDEID) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), strRetInfo) end ext_table.roadway_inventory = strRetInfo -- 作业扩展数据存入这个巷道库存字符串，里面是库存未超过80%的巷道 if (loc_start.code == wms_base.Get_sConst(strLuaDEID, "KL_ReturnRgvStation1") or loc_start.code == wms_base.Get_sConst(strLuaDEID, "F3L_InWeight1") or loc_start.code == wms_base.Get_sConst(strLuaDEID, "F3R_InWeight1")) then local b = wms_base.Get_sConst(strLuaDEID, "佳通-一楼左侧回库口巷道") local str = findCommonNumbers(ext_table.roadway_inventory, b) if (str == nil or str == '') then lua.Error(strLuaDEID, debug.getinfo(1), "没有可入库的3,4巷道!") end ext_table.roadway_inventory = str end -- 判断货位容器是否绑定,没有绑定则绑定 local loc_code = wms_wh.GetLocCodeByCNTR(strLuaDEID, cntr_code) if (loc_code == '') then nRet, strRetInfo = wms_wh.Loc_Container_Binding(strLuaDEID, loc_start.code, cntr_code, "绑定解绑方法-系统", "完成") if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '货位容器解绑失败!' .. strRetInfo) end end -- 创建托盘组入库作业 -- 创建作业 local operation = m3.AllocObject(strLuaDEID, "Operation") operation.start_wh_code = loc_start.wh_code operation.start_area_code = loc_start.area_code operation.start_loc_code = loc_start.code operation.op_type = wms_base.Get_nConst(strLuaDEID, "作业类型-入库") operation.op_def_name = "国自空托回库" 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) -- req_type = 3 RFID托盘查询流程 elseif (req_type == 3) then if (cntr_code == '') then lua.Error(strLuaDEID, debug.getinfo(1), "RFID不能为空!") end -- RFID托盘查询 根据容器获取 CG_Detail -- 1 单个托盘（进码盘机） 2 托盘组（人工上料的托盘组） 3 物料（请求类型=3RFID托盘查询时需返回） local data = {} local cg_detail condition = "S_CNTR_CODE = '" .. cntr_code .. "'" nRet, cg_detail = m3.GetDataObjByCondition(strLuaDEID, "CG_Detail", condition) if (nRet ~= 0 and nRet ~= 1) then lua.Error(strLuaDEID, debug.getinfo(1), "获取【容器货品明细】信息失败! " .. cg_detail) end if (nRet == 1) then -- 拼接返回的数据 data.mat_type = 1 mobox.returnValue(strLuaDEID, 1, lua.table2str(data)) return elseif (nRet == 0) then if (cg_detail.item_code == 'KGZ') then data.mat_type = 2 mobox.returnValue(strLuaDEID, 1, lua.table2str(data)) return else data.mat_type = 3 mobox.returnValue(strLuaDEID, 1, lua.table2str(data)) return end end -- req_type = 4呼叫空托流程 elseif (req_type == 4) then -- 获取未冻结的巷道 local strCondition = "S_AREA_CODE = 'LK' AND N_LOCK_STATE = 0" local nRet, roadway_list = m3.QueryDataObject(strLuaDEID, "Roadway", strCondition) lua.Debug(strLuaDEID, debug.getinfo(1), "roadway_list", roadway_list) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '查询巷道信息失败' .. roadway_list) end if (roadway_list == nil or roadway_list == '') then lua.Error(strLuaDEID, debug.getinfo(1), '没有可出库的巷道!') end local str = '' for i = 1, #roadway_list do local attrs = roadway_list[i].attrs attrs = m3.KeyValueAttrsToObjAttr(attrs) if (attrs == nil) then goto coroutine end str = str .. attrs.N_ROADWAY .. "," ::coroutine:: end -- 去除最后一个, str = lua.trim_laster_char(str) -- 获取可出库巷道 if (loc_start.code == wms_base.Get_sConst(strLuaDEID, "KL_ReturnRgvStation1") or loc_start.code == wms_base.Get_sConst(strLuaDEID, "F3L_InWeight1") or loc_start.code == wms_base.Get_sConst(strLuaDEID, "F3R_InWeight1")) then local b = wms_base.Get_sConst(strLuaDEID, "佳通-一楼左侧回库口巷道") str = findCommonNumbers(str, b) end roadway_list = lua.split(str, ",") local data local loc_Container = {} local flag = 0 for i = 1, #roadway_list do local roadway = roadway_list[i] -- 巷道 -- 获取该巷道的 空货箱/托盘组 优先外深位其次内深位 local str_cntr if (station_no == 'KQ_KTPPullCache1') then str_cntr = '106EGP' else str_cntr = '106EGR' -- 胶框前6个字符 托盘是106EGP end -- 获取当前巷道信息 strCondition = "N_ROADWAY = '" .. roadway .. "'" nRet, roadway = m3.GetDataObjByCondition(strLuaDEID, "Roadway", strCondition) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "获取【巷道】信息失败! " .. roadway) end local strOrder = "T_CREATE" -- 获取外深位的空工装 strCondition = "S_LOC_CODE IN (SELECT S_CODE FROM TN_Location WHERE S_AREA_CODE = 'LK' AND N_LOCK_STATE = 0 AND C_ENABLE = 'Y' AND N_POS = 1 AND N_ROADWAY = '" .. roadway.roadway .. "')" strCondition = strCondition .. " AND S_CNTR_CODE IN (SELECT S_CNTR_CODE FROM TN_CG_Detail WHERE S_ITEM_CODE = 'KGZ' AND S_CNTR_CODE LIKE '%" .. str_cntr .. "%')" -- 最多获取 10 条 nRet, strRetInfo = mobox.queryDataObjAttr3(strLuaDEID, "Loc_Container", strCondition, 1, strOrder) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "获取货位信息错误! " .. strRetInfo .. " SQL条件: " .. strCondition) end if (strRetInfo ~= '') then local attrs local retObjs = json.decode(strRetInfo) nRet, attrs = m3.ObjAttrStrToLuaObj("Loc_Container", lua.table2str(retObjs[1].attrs)) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "m3.ObjAttrStrToLuaObj(CG_Detail) 失败! " .. attrs) end data = { loc_code = attrs.loc_code, cntr_code = attrs.cntr_code, roadway = roadway.roadway } break end -- 获取内深位的空工装 strCondition = "S_LOC_CODE IN (SELECT S_CODE FROM TN_Location WHERE S_AREA_CODE = 'LK' AND N_LOCK_STATE = 0 AND C_ENABLE = 'Y' AND N_POS = 2 AND N_ROADWAY = '" .. roadway.roadway .. "')" strCondition = strCondition .. " AND S_CNTR_CODE IN (SELECT S_CNTR_CODE FROM TN_CG_Detail WHERE S_ITEM_CODE = 'KGZ' AND S_CNTR_CODE LIKE '%" .. str_cntr .. "%')" -- 最多获取 10 条 nRet, strRetInfo = mobox.queryDataObjAttr3(strLuaDEID, "Loc_Container", strCondition, 1, strOrder) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "获取货位信息错误! " .. strRetInfo .. " SQL条件: " .. strCondition) end if (strRetInfo ~= '') then local attrs local retObjs = json.decode(strRetInfo) for j = 1, #retObjs do flag = tonumber(flag) + 1 nRet, attrs = m3.ObjAttrStrToLuaObj("Loc_Container", lua.table2str(retObjs[j].attrs)) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "m3.ObjAttrStrToLuaObj(CG_Detail) 失败! " .. attrs) end loc_Container[flag] = attrs end end end local start_loc if (data ~= nil) then lua.Debug(strLuaDEID, debug.getinfo(1), "data", data) cntr_code = data.cntr_code start_loc = data.loc_code elseif (tonumber(#loc_Container) > tonumber(0)) then lua.Debug(strLuaDEID, debug.getinfo(1), "loc_Container", loc_Container) for i = 1, #loc_Container do -- 内深位校验 local success, loc_code = GetPosLoc(strLuaDEID, loc_Container[i].loc_code) if (success == true) then -- 判断内深位是否有货物 strCondition = "S_CODE = '" .. loc_code .. "' AND (N_LOCK_STATE = 0 OR N_CURRENT_NUM = 1)" nRet, strRetInfo = m3.GetDataObjByCondition(strLuaDEID, "Location", strCondition) if (nRet == 2) then lua.Error(strLuaDEID, debug.getinfo(1), "m3.GetDataObjByCondition 失败!" .. strRetInfo) elseif (nRet == 1) then strCondition = "S_CODE = '" .. loc_code .. "' AND N_LOCK_STATE = 0" nRet, strRetInfo = m3.GetDataObjByCondition(strLuaDEID, "Location", strCondition) if (nRet == 2) then lua.Error(strLuaDEID, debug.getinfo(1), "m3.GetDataObjByCondition 失败!" .. strRetInfo) elseif (nRet == 1) then goto coroutine end -- 创建移库任务 -- 获取起点信息 local start_loc_yk, end_loc_yk nRet, start_loc_yk = wms_wh.GetLocInfo(loc_code) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), 'WMS_GetLocInfo失败!' .. start_loc_yk) end -- 获取起点的物料 local cg_detail condition = "S_CNTR_CODE ='" .. loc_Container[i].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 item_type, material nRet, item_type, material = GT_Get_ItemType(strLuaDEID, cg_detail.item_code) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), item_type) end -- 钢丝只能入指定层 local str_yk if (item_type == '钢丝') then str_yk = wms_base.Get_sConst(strLuaDEID, "佳通-立库钢丝货位层") nRet, end_loc_yk = GetEndLoc(strLuaDEID, start_loc_yk.roadway, str_yk) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), end_loc) end else str_yk = wms_base.Get_sConst(strLuaDEID, "佳通-立库非钢丝货位层") nRet, end_loc_yk = GetEndLoc(strLuaDEID, start_loc_yk.roadway, str_yk) if (nRet == 1) then str_yk = wms_base.Get_sConst(strLuaDEID, "佳通-立库钢丝货位层") nRet, end_loc_yk = GetEndLoc(strLuaDEID, start_loc_yk.roadway, str_yk) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), end_loc) end elseif (nRet > 1) then lua.Error(strLuaDEID, debug.getinfo(1), end_loc) end end -- 创建佳通任务 local gt_task = m3.AllocObject(strLuaDEID, "GT_Task") lua.Debug(strLuaDEID, debug.getinfo(1), 'gt_task', gt_task) -- 起点信息 gt_task.start_wh_code = start_loc_yk.wh_code gt_task.start_area_code = start_loc_yk.area_code gt_task.start_loc_code = start_loc_yk.code -- 终点信息 gt_task.end_wh_code = end_loc_yk.wh_code gt_task.end_area_code = end_loc_yk.area_code gt_task.end_loc_code = end_loc_yk.code gt_task.type = 3 -- 1 粉料调拨搬运 2 烘胶搬运 3 同巷道移库 gt_task.priority = 2 -- 大的优先 gt_task.cntr_code = loc_Container[i].cntr_code nRet, gt_task = m3.CreateDataObj(strLuaDEID, gt_task) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '创建【佳通任务】失败!' .. gt_task) end end lua.Debug(strLuaDEID, debug.getinfo(1), "loc_Container[i].loc_code", loc_Container[i].loc_code) cntr_code = loc_Container[i].cntr_code start_loc = loc_Container[i].loc_code break end ::coroutine:: end if (start_loc == nil or start_loc == '') then lua.Error(strLuaDEID, debug.getinfo(1), '巷道没有可出库的空工装!') end else return end nRet, start_loc = wms_wh.GetLocInfo(start_loc) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), 'WMS_GetLocInfo失败!' .. start_loc) end -- step4: 创建搬运作业 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 -- 终点是佳通WMS传过来的 operation.end_wh_code = loc_start.wh_code operation.end_area_code = loc_start.area_code operation.end_loc_code = loc_start.code operation.cntr_code = cntr_code operation.op_def_name = "呼叫空托" operation.op_type = wms_base.Get_nConst(strLuaDEID, "作业类型-出库") 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', operation) end -- v1.1 lzh 执行完成也删除这个请求删除这个请求 end