-- 库存查询
|
--[
|
-- 1、获取巷道货位总数
|
-- 2、获取满货位总数
|
-- 3、（满货位总数 / 巷道总数）* 100 = 满货位百分比
|
-- 4、判断满货位库存是否达到80%,没达到则返回可入库巷道
|
--]
|
local function StockInquiry(strLuaDEID)
|
-- 获取未冻结的巷道
|
local strCondition = "N_LOCK_STATE = 0"
|
local nRet, roadway = m3.QueryDataObject(strLuaDEID, "Roadway", strCondition)
|
if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '查询巷道信息失败' .. roadway) end
|
if (roadway == nil or roadway == '') then lua.Error(strLuaDEID, debug.getinfo(1), '没有可入库的巷道!') end
|
|
-- 获取字典定义的移库比例
|
local strRetInfo
|
nRet, strRetInfo = mobox.getDictItemIInfo("GT_LK_RATIO")
|
if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "getDictItemIInfo 失败!" .. strRetInfo) end
|
strRetInfo = json.decode(strRetInfo)
|
local item_ratio = tonumber(strRetInfo[1].name) -- 字典定义的巷道安全库存比例
|
|
local str = ''
|
for i = 1, #roadway do
|
local attrs = roadway[i].attrs
|
attrs = m3.KeyValueAttrsToObjAttr(attrs)
|
|
-- 获取巷道货位总数
|
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
|
|
if (mhw_ratio <= item_ratio) then
|
str = str .. attrs.N_ROADWAY .. ","
|
end
|
end
|
-- 去除最后一个,
|
str = lua.trim_laster_char(str)
|
lua.Debug(strLuaDEID, debug.getinfo(1), "str", str)
|
return 0, str
|
end
|
--[[
|
编码: GT-100-06
|
名称: GT-WMS
|
作者：LZH
|
入口函数： CreateROM
|
|
|
功能说明:
|
GT-WMS下发退料信息给 GZ-WMS系统，GZ-WMS系统创建相关数据绑定和入库作业
|
|
输入数据：
|
{
|
"delivery_no": "xxx", 收货单号
|
"delivery_row_no": "xxx", 收货单行号
|
"serial_no": "xxx", 流水号
|
"batch_no": "xxx", 批次号
|
"qty": xxx, 重量
|
"item_code": "xxx", 物料编码
|
"product_date": "xxx", 生产日期
|
"storage_loc": "xxx", 库位
|
"wh_code": "xxx", 仓库编号
|
"is_bonded": "xxx", 是否保税
|
"cntr_code": "xxx", 托盘号
|
"start_loc_code": "xxx", 起点
|
"item_state": "xxx", 质量状态
|
"req_no": "xxx", 唯一标识
|
"inbound_policy": 3, 胶料入库策略
|
"wheel_type_rot": "xxx", 轮型/左右旋
|
"vendor":"xxx", 供应商
|
"remark1": "", -- 备注 暂未启用
|
"remark2": "", -- 备注 暂未启用
|
"remark3": "", -- 备注 暂未启用
|
"remark4": "" -- 备注 暂未启用
|
}
|
|
|
处理逻辑
|
-- step1 解析接口传递的 datajson 参数
|
-- step2 校验必传字段是否为空，为空则报错
|
-- step3 容器货品绑定
|
-- step4 创建退料单
|
-- step5 起点不为空则 货位容器绑定 并创建AGV两段搬运任务，一段从起点到起点库区绑定的接驳位，一段从接驳位到立库
|
|
变更记录:
|
V1.1 LZH 20250417 加上供应商字段
|
--]]
|
m3 = require("oi_base_mobox")
|
json = require("json")
|
mobox = require("OILua_JavelinExt")
|
require("WMS-Equipment")
|
wms_cntr = require("wms_container")
|
wms_wh = require("wms_wh")
|
require("GT-Base")
|
function CreateROM(strLuaDEID)
|
local nRet, strRetInfo, in_date
|
-- 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)
|
|
-- step2 判断是否都有值？没值报错返回
|
local delivery_no = in_date.delivery_no
|
if (delivery_no == nil or delivery_no == '') then lua.Error(strLuaDEID, debug.getinfo(1), "收货单号不能为空!") end
|
local delivery_row_no = in_date.delivery_row_no
|
if (delivery_row_no == nil) then lua.Error(strLuaDEID, debug.getinfo(1), "收货单行号不能为空!") end
|
local serial_no = in_date.serial_no
|
if (serial_no == nil or serial_no == '') then lua.Error(strLuaDEID, debug.getinfo(1), "流水号不能为空!") end
|
local batch_no = in_date.batch_no
|
if (batch_no == nil or batch_no == '') then lua.Error(strLuaDEID, debug.getinfo(1), "批次号不能为空!") end
|
local qty = tonumber(in_date.qty)
|
if (qty == nil) then lua.Error(strLuaDEID, debug.getinfo(1), "托盘重量不能为空!") end
|
local item_code = in_date.item_code
|
if (item_code == nil or item_code == '') then lua.Error(strLuaDEID, debug.getinfo(1), "物料编码不能为空!") end
|
local product_date = in_date.product_date
|
if (product_date == nil or product_date == '') then lua.Error(strLuaDEID, debug.getinfo(1), "生产日期不能为空!") end
|
local wh_code = in_date.wh_code
|
if (wh_code == nil or wh_code == '') then lua.Error(strLuaDEID, debug.getinfo(1), "仓库编号不能为空!") end
|
local is_bonded = in_date.is_bonded
|
if (is_bonded == nil or is_bonded == '') then lua.Error(strLuaDEID, debug.getinfo(1), "是否保税不能为空!") end
|
local item_state = in_date.item_state
|
if (item_state == nil or item_state == '') then lua.Error(strLuaDEID, debug.getinfo(1), "质量状态不能为空!") end
|
local wheel_type_rot = in_date.wheel_type_rot
|
local storage_loc = in_date.storage_loc
|
local cntr_code = in_date.cntr_code
|
local start_loc_code = in_date.start_loc_code
|
local req_no = in_date.req_no
|
local inbound_policy = in_date.inbound_policy
|
local vendor = in_date.vendor
|
local remark1 = in_date.remark1
|
local remark2 = in_date.remark2
|
local remark3 = in_date.remark3
|
local remark4 = in_date.remark4
|
|
-- 获取物料信息的物料种类
|
local item_type, material
|
nRet, item_type, material = GT_Get_ItemType(strLuaDEID, item_code)
|
if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), item_type) end
|
lua.Debug(strLuaDEID, debug.getinfo(1), '物料信息', material)
|
|
-- step3 容器货品绑定
|
local cg_detail = m3.AllocObject(strLuaDEID, "CG_Detail")
|
cg_detail.cntr_code = cntr_code
|
cg_detail.batch_no = batch_no
|
cg_detail.item_code = item_code
|
cg_detail.item_name = material.item_name
|
cg_detail.qty = qty
|
cg_detail.uom = 'kg'
|
cg_detail.serial_no = serial_no
|
cg_detail.is_tl = 1 -- 退料标识 0 正常 1 退料
|
lua.Debug(strLuaDEID, debug.getinfo(1), 'cg_detail', cg_detail)
|
nRet, cg_detail = m3.CreateDataObj(strLuaDEID, cg_detail)
|
if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), 'mobox 创建【容器货品明细】对象失败!' .. cg_detail) end
|
|
-- step4 创建退料单
|
-- 获取一个初始的【退料单】数据对象
|
local rom = m3.AllocObject(strLuaDEID, "GT_ROM")
|
-- 生成作业编码
|
local strCode = ''
|
local strHeader = 'TL' .. os.date("%y%m%d") .. '-'
|
nRet, strCode = mobox.getSerialNumber("退料", strHeader, 5)
|
if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '申请退料单编码失败!' .. strCode) end
|
|
rom.no = strCode
|
rom.delivery_no = delivery_no
|
rom.delivery_row_no = delivery_row_no
|
rom.item_code = item_code
|
rom.product_date = product_date
|
rom.batch_no = batch_no
|
rom.item_state = item_state
|
rom.qty = qty
|
rom.serial_no = serial_no
|
rom.wheel_type_rot = wheel_type_rot
|
rom.wh_code = wh_code
|
rom.storage_loc = storage_loc
|
rom.is_bonded = is_bonded
|
rom.cntr_code = cntr_code
|
rom.start_loc_code = start_loc_code
|
rom.req_no = req_no
|
rom.inbound_policy = inbound_policy
|
rom.vendor = vendor
|
|
if (start_loc_code == nil or start_loc_code == '') then
|
nRet, rom = m3.CreateDataObj(strLuaDEID, rom)
|
if (nRet ~= 0) then
|
lua.Error(strLuaDEID, debug.getinfo(1), 'mobox 创建【退料单】对象失败!' .. rom)
|
end
|
else
|
rom.state = "执行"
|
nRet, rom = m3.CreateDataObj(strLuaDEID, rom)
|
if (nRet ~= 0) then
|
lua.Error(strLuaDEID, debug.getinfo(1), 'mobox 创建【退料单】对象失败!' .. rom)
|
end
|
|
local ext_table = {}
|
ext_table.is_insulate = material.is_insulate
|
|
-- V1.3 获取巷道库存未达到 80% 的可入库巷道
|
nRet, strRetInfo = StockInquiry(strLuaDEID)
|
if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), strRetInfo) end
|
ext_table.roadway_inventory = strRetInfo -- 作业扩展数据存入这个巷道库存字符串，里面是库存未超过80%的巷道
|
|
-- 获取起点信息
|
local loc_start
|
nRet, loc_start = wms_wh.GetLocInfo(start_loc_code)
|
if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), 'WMS_GetLocInfo失败!' .. loc_start) 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, "作业类型-入库")
|
operation.op_def_name = "退料入库"
|
operation.cntr_code = cntr_code
|
ext_table.batch_no = batch_no -- 批次号
|
ext_table.item_code = item_code -- 物料编码
|
ext_table.item_type = item_type -- 物料类型
|
ext_table.rom_no = strCode -- 退料单号
|
ext_table.is_sign = "AGV搬运" -- 退料单号
|
ext_table.area_code = material.area_code -- 库区
|
ext_table.isothermal = material.isothermal -- 是否恒温
|
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
|
