--[[ 编码: GT-119-19 名称: 创建作业 作者：LZH 日期：2024/8/13 函数： CreateOperation 功能: step1 判断出库单据是否是启动状态 step2 启动状态则通过出库策略获取作业起点 step3 创建作业 变更记录: V1.1 LZH 20241122 出库单修改为主子表，代码调整 V1.2 LZH 20250326 新增采购退货流程，如果GTWMS下发的终点机台为固定的 --]] json = require("json") mobox = require("OILua_JavelinExt") m3 = require("oi_base_mobox") wms_base = require("wms_base") require("GT-Base") require("GT_InAndOutboundPolicies") wms_wh = require("wms_wh") function CreateOperation(strLuaDEID) local nRet, strRetInfo local stock_out nRet, stock_out = m3.GetSysCurEditDataObj(strLuaDEID, "GT_Stock_Out") if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), stock_out) end lua.Debug(strLuaDEID, debug.getinfo(1), 'stock_out', stock_out) local ret_loc if (stock_out.state == '启用') then -- 获取该物料的物料类型 local item_type, material nRet, item_type, material = GT_Get_ItemType(strLuaDEID, stock_out.item_code) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), item_type) end -- 获取 物料+批号 所在库区 local strCondition = "S_CNTR_CODE IN (SELECT S_CNTR_CODE FROM TN_CG_Detail WHERE S_ITEM_CODE = '" .. stock_out.item_code .. "' AND S_BATCH_NO = '" .. stock_out.batch_no .. "')" local loc_container nRet, loc_container = m3.GetDataObjByCondition(strLuaDEID, "Loc_Container", strCondition) if (nRet == 1) then lua.Error(strLuaDEID, debug.getinfo(1), "不存在批次号为" .. stock_out.batch_no .. "的物料!") elseif (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "m3.GetDataObjByCondition 失败!" .. loc_container) end -- 获取货位信息 local loc_info nRet, loc_info = wms_wh.Location_GetInfo(strLuaDEID, loc_container.loc_code) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "WMS_Location_GetInfo失败!" .. loc_info) end local op_def_name = '' local end_loc_code, loc_baseinfo if (stock_out.ms_code == 'ABC') then op_def_name = "采购退货" -- 获取机台下维护的出库库区 local area_link strCondition = "S_MS_CODE = 'ABC'" nRet, area_link = m3.QueryDataObject(strLuaDEID, "MS_Area_Link", strCondition) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '获取采购退货机台信息失败!' .. area_link) end if (area_link == nil or area_link == '') then lua.Error(strLuaDEID, debug.getinfo(1), '请维护采购退货出库库区或位置!') end lua.Debug(strLuaDEID, debug.getinfo(1), 'area_link', area_link) -- 获取随机数,随机指定出库库区位置 local randomInt = math.random(1, #area_link) local attr nRet, attr = m3.ObjAttrStrToLuaObj("MS_Area_Link", lua.table2str(area_link[randomInt].attrs)) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "m3.ObjAttrStrToLuaObj(GT_Label_Crad) 失败! " .. attr) end lua.Debug(strLuaDEID, debug.getinfo(1), 'attr', attr) if (tonumber(attr.la_type) == 0) then end_loc_code = attr.la_code .. "-QY" elseif (tonumber(attr.la_type) == 1) then end_loc_code = attr.la_code end else if (loc_info.area_code == 'PFL' or loc_info.area_code == 'TFL' or loc_info.area_code == 'HWPFL' or loc_info.area_code == 'HWTFL') then nRet, ret_loc = FL_StockOut(strLuaDEID, stock_out) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), ret_loc) end op_def_name = "粉料出库" end_loc_code = stock_out.ms_code elseif (loc_info.area_code == 'LK') then nRet, ret_loc = LK_StockOut(strLuaDEID, stock_out) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), ret_loc) end op_def_name = "立库出库" nRet, end_loc_code = wms_base.GetAreaAvaliableLoc(strLuaDEID, stock_out.ms_code, "") if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "WMS_GetAreaAvaliableLoc失败！" .. end_loc_code) end end_loc_code = end_loc_code.loc_code end if (ret_loc == nil or ret_loc == '') then lua.Error(strLuaDEID, debug.getinfo(1), "没有可出库的货品!") end lua.Debug(strLuaDEID, debug.getinfo(1), 'ret_loc', ret_loc) nRet, loc_baseinfo = wms.wms_GetLocBaseInfo(ret_loc.start_loc_code) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "获取货位基本信息失败!" .. loc_baseinfo) end lua.Debug(strLuaDEID, debug.getinfo(1), '起点货位信息', loc_baseinfo) loc_baseinfo = json.decode(loc_baseinfo) end lua.Debug(strLuaDEID, debug.getinfo(1), 'end_loc_code', end_loc_code) local end_loc nRet, end_loc = wms.wms_GetLocBaseInfo(end_loc_code) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "获取货位基本信息失败!" .. end_loc) end lua.Debug(strLuaDEID, debug.getinfo(1), '终点货位信息', end_loc) end_loc = json.decode(end_loc) -- step4: 创建搬运作业 local operation = m3.AllocObject(strLuaDEID, "Operation") operation.start_wh_code = loc_baseinfo.wh_code operation.start_area_code = loc_baseinfo.area_code operation.start_loc_code = loc_baseinfo.code -- 终点是佳通WMS传过来的 operation.end_wh_code = end_loc.wh_code operation.end_area_code = end_loc.area_code operation.end_loc_code = end_loc.code operation.bs_no = stock_out.delivery_no -- 业务单号为出库任务号 operation.cntr_code = ret_loc.cntr_code operation.op_def_name = op_def_name operation.op_type = wms_base.Get_nConst(strLuaDEID, "作业类型-出库") 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 -- 设置扩展参数带入作业启动，任务完成 local ext_table = {} ext_table.batch_no = stock_out.batch_no ext_table.item_type = item_type ext_table.delivery_no = stock_out.delivery_no ext_table.task_no = strCode 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 -- 作业的起点加锁 nRet, strRetInfo = wms.wms_LockLocation(strLuaDEID, operation.start_loc_code, wms_base.Get_nConst(strLuaDEID, "锁类型-出库锁"), strCode, operation.code, operation.op_def_name) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "wms_LockLocation 失败!" .. strRetInfo) end -- 容器加锁 local container nRet, container = wms_cntr.GetInfo(strLuaDEID, operation.cntr_code) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1),'获取容器对象失败!' .. container) end nRet, strRetInfo = wms_cntr.SetLock(strLuaDEID, container, "锁类型-出库锁", operation.code) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '托盘容器添加出库锁失败!' .. strRetInfo) end -- 新增出库单明细 local so_detail = m3.AllocObject(strLuaDEID, "GT_SO_Detail") -- 起点信息 so_detail.delivery_no = stock_out.delivery_no so_detail.op_code = operation.code so_detail.cntr_code = ret_loc.cntr_code so_detail.start_area_code = loc_baseinfo.area_code so_detail.start_loc_code = loc_baseinfo.code so_detail.end_area_code = end_loc.area_code so_detail.end_loc_code = end_loc.code nRet, so_detail = m3.CreateDataObj(strLuaDEID, so_detail) if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '创建【出库单明细】失败!' .. so_detail) end end end