--[[
|
版本： Version 1.0
|
创建日期： 2025-1-26
|
创建人： HAN
|
|
功能：
|
和出库相关的操作,如配盘
|
|
-- Shipping_Order_CheckState 检查【发货单明细】 配盘是否全部完成，如果全部完成 N_B_STATE = 1
|
** Creat_Distribution 创建配盘及配盘明细（适合手工配盘）
|
-- Check_Distribution_WholeOut 检测配盘是否为整出
|
-- Get_Outbound_Detail_list 根据输入的出库单编码获取 出库单明细列表，oo_no_set 是一个出库单编码数组，如["OO010","OO012"]
|
** Split_Distribution_CNTR_Detail 波次合并后产生的 配盘明细 批分到每个出库单明细
|
** Distribution_Procedure 根据货品列表系统自动生成配盘和配盘明细，条件是根据货品编码 item_code 确定货品，
|
根据批次号顺序配盘，批次号小的优先出
|
-- Creat_Distribution_list 创建配盘及配盘明细数据对象
|
-- Sum_outbound_detail 把出库单明细中的 item 加入出库明细汇总链表
|
-- Distribution_CNTR_Detail_PostProcess 配盘明细的后处理程序（分拣出库后对数据的处理）
|
** 标记的是主要函数
|
|
更改说明：
|
V2.0 HAN 20241122 Distribution_Procedure 增加全属性覆盖，条件判断改进
|
--]]
|
|
wms_cntr = require("wms_container")
|
wms_wh = require("wms_wh")
|
|
local wms_out = { _version = "0.1.1" }
|
|
-- 检查 发货单明细 配盘是否全部完成，如果全部完成 N_B_STATE = 1
|
function wms_out.Shipping_Order_CheckState (strLuaDEID, shipping_no)
|
local n, nRet, strRetInfo
|
|
-- 获取【发货单明细】
|
local strCondition = "S_SHIPPING_NO = '" .. shipping_no .. "'"
|
local strOrder = ""
|
local data_objs
|
local distribution_finish = true
|
|
nRet, data_objs = m3.QueryDataObject(strLuaDEID, "Shipping_Detail", strCondition, strOrder)
|
if (nRet ~= 0) then
|
return 1, "获取【Shipping_Detail】信息失败! " .. data_objs
|
end
|
local obj_attrs
|
local qty, acc_d_qty
|
|
for n = 1, #data_objs do
|
obj_attrs = m3.KeyValueAttrsToObjAttr(data_objs[n].attrs)
|
qty = lua.StrToNumber(obj_attrs.F_QTY)
|
acc_d_qty = lua.StrToNumber(obj_attrs.F_ACC_D_QTY)
|
if (qty > acc_d_qty) then
|
distribution_finish = false
|
break
|
end
|
end
|
if (distribution_finish) then
|
local strUpdateSql = "N_B_STATE = 1"
|
strCondition = "S_NO = '" .. shipping_no .. "'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "Shipping_Order", strCondition, strUpdateSql)
|
if (nRet ~= 0) then
|
return 1, "更新【发货单】信息失败!" .. strRetInfo
|
end
|
end
|
return 0
|
end
|
|
-- 检测配盘是否为整出, 判断的依据是 CG_Detail中的 qty - 配盘明细中的qty 后的值全部为 0
|
-- distribution_id 【配盘】对象标识
|
-- nRet = 0 程序执行无错误 否则 > 0. strRetInfo = "yes" 表示是整拖出
|
function wms_out.Check_Distribution_WholeOut(strLuaDEID, distribution_cntr)
|
local nRet, strRetInfo, n, i
|
|
if (distribution_id == nil or type(distribution_cntr) ~= 'table') then
|
return 1, "wms_out.Check_Distribution_WholeOut 函数中 distribution 不能为空,必须为table!"
|
end
|
|
-- 获取【配盘明细】
|
local data_objects
|
local strCondition = "S_DC_NO = '" .. distribution_cntr.dc_no .. "'"
|
nRet, data_objects = m3.QueryDataObject(strLuaDEID, "Distribution_CNTR_Detail", strCondition, "S_ITEM_CODE")
|
if (nRet ~= 0) then
|
return 2, "QueryDataObject失败!" .. data_objects
|
end
|
if (data_objects == '') then
|
return 0, "no"
|
end
|
local dc_detail = {}
|
for n = 1, #data_objects do
|
dc_detail[n] = m3.KeyValueAttrsToObjAttr(data_objects[n].attrs)
|
end
|
|
-- 获取【INV_Detail】
|
local strCondition = "S_CNTR_CODE = '" .. distribution_cntr.cntr_code .. "'"
|
nRet, data_objects = m3.QueryDataObject(strLuaDEID, "INV_Detail", strCondition, "S_ITEM_CODE")
|
if (nRet ~= 0) then
|
return 2, "QueryDataObject失败!" .. data_objects
|
end
|
if (data_objects == '') then
|
return 0, "no"
|
end
|
local obj_attrs
|
|
if (#data_objects > #dc_detail) then
|
-- 如果容器中的货品条数 > 配盘明细 肯定不是整托出
|
return 0, "no"
|
end
|
|
-- 遍历 容器货品明细 判断：inv_detail.qty - dc_detail.qty = 0
|
local inv_detail_qty, dc_detail_qty
|
local count = #dc_detail
|
for n = 1, #data_objects do
|
obj_attrs = m3.KeyValueAttrsToObjAttr(data_objects[n].attrs)
|
inv_detail_qty = lua.StrToNumber(obj_attrs.F_QTY)
|
-- 从【Distribution_CNTR_Detail】找到 cg_detial.S_ID 相同的 配盘明细
|
for i = 1, count do
|
if (dc_detail[i].G_INV_DETAIL_ID == data_objects[n].id) then
|
dc_detail_qty = lua.StrToNumber(dc_detail[i].F_QTY)
|
if (inv_detail_qty > dc_detail_qty) then
|
-- 如果容器货品中的数量大于本次配盘出库数量，说明出不完，不是整托出
|
return 0, "no"
|
end
|
break
|
end
|
end
|
end
|
return 0, "yes"
|
end
|
|
--[[
|
创建配盘及配盘明细, 用于手工配盘
|
输入参数 distribution_info -- 配盘信息，是一个table，格式如下
|
{
|
bs_type = "Outbound_Ordre", -- 来源类型（出库单/出库波次）
|
bs_no = "XX-001", -- 来源单号
|
factory = "81" -- 工厂标识
|
bs_row_no = bs_row_no, -- 来源单行号
|
cntr_code = "", -- 容器号
|
loc_code = "", -- 容器来源货位信息
|
inv_detail_id = "xxxx", -- INV_Detail 中记录标识 S_ID
|
item_code = "", -- 物料编码
|
batch_no = "", -- 批次号
|
serial_no = "", -- 系列号
|
qty = 1, -- 配盘数量
|
loc_code = loc_code, -- 容器所在货位
|
exit_area_code = area_code, -- 出库口库区编码
|
exit_loc_code = ""
|
urgent_outbound = false -- 是否紧急出库
|
}
|
--]]
|
-- 返回值 nRet = 0 表示成功配盘 1 -- 表示业务流程不许可 2 -- 程序错误
|
function wms_out.Creat_Distribution(strLuaDEID, distribution_info)
|
local nRet, strRetInfo, strErr
|
|
-- step1 判断一下是否已经存在配盘
|
-- 查找 容器编码 = cntr_code 并且 状态=0，1，2 的配盘容器
|
local distribution_cntr
|
|
-- 输入参数检查，一些关键的属性必须有值
|
if (distribution_info.cntr_code == nil or distribution_info.cntr_code == '') then
|
return 1, "输入的配盘信息中必须有 cntr_code !"
|
end
|
if (distribution_info.bs_type == nil or distribution_info.bs_type == '') then
|
return 1, "输入的配盘信息中必须有 bs_type !"
|
end
|
if (distribution_info.bs_no == nil or distribution_info.bs_no == '') then
|
return 1, "输入的配盘信息中必须有 bs_no !"
|
end
|
if (distribution_info.inv_detail_id == nil or distribution_info.inv_detail_id == '') then
|
return 1, "输入的配盘信息中必须有 inv_detail_id !"
|
end
|
if (distribution_info.loc_code == nil or distribution_info.loc_code == '') then
|
return 1, "输入的配盘信息中必须有 loc_code !"
|
end
|
local cntr_code = distribution_info.cntr_code
|
local loc
|
nRet, loc = wms_wh.GetLocInfo(distribution_info.loc_code)
|
if (nRet ~= 0) then
|
return 1, '获取货位信息失败! ' .. distribution_info.loc_code
|
end
|
|
local strCondition = "S_CNTR_CODE = '" .. distribution_info.cntr_code .. "' AND N_B_STATE >= 0 AND N_B_STATE <= 3"
|
nRet, distribution_cntr = m3.GetDataObjByCondition(strLuaDEID, "Distribution_CNTR", strCondition)
|
-- nRet = 0 表示配盘已经存在
|
local b_have_sanme_inv_detail = false
|
local distribution_detail = {}
|
if (nRet == 0) then
|
if (distribution_cntr.b_state ~= 0) then
|
return 1, "容器号 = '" .. distribution_info.cntr_code .. "' 的容器已经配盘完成不能继续配盘!"
|
end
|
|
-- 进一步判断配盘明细里是否已经存在 该 INV_Detail ID相同的配货信息(发货单一样)，如果有数量累计即可，不需要另外创建
|
strCondition = "S_DC_NO = '" .. distribution_cntr.dc_no .. "' AND G_INV_DETAIL_ID = '" .. distribution_info.inv_detail_id .. "'"
|
strCondition = strCondition .. " AND S_BS_TYPE = '" .. distribution_info.bs_type .. "' AND S_BS_NO = '" .. distribution_info.bs_no .. "'"
|
nRet, distribution_detail = m3.GetDataObjByCondition(strLuaDEID, "Distribution_CNTR_Detail", strCondition)
|
if (nRet == 0) then
|
b_have_sanme_inv_detail = true
|
elseif (nRet > 1) then
|
return 1, "在检查[配盘明细]是否在时失败! " .. distribution_detail
|
end
|
|
-- 如果有紧急配盘，需要把配盘业务状态设置为 = 1（配盘完成）
|
if (distribution_info.urgent_outbound) then
|
-- 检查一下是否为整出
|
nRet, strRetInfo = wms_out.Check_Distribution_WholeOut(strLuaDEID, distribution_cntr)
|
if (nRet ~= 0) then
|
return nRet, strRetInfo
|
end
|
|
strCondition = "S_ID = '" .. distribution_cntr.id .. "'"
|
local strSetAttr = "N_B_STATE = 1, S_B_STATE = '配盘完成' "
|
if (strRetInfo == "yes") then
|
-- 说明是整个容器的货品都出库
|
strSetAttr = strSetAttr .. ", C_WHOLE_OUT = 'Y'"
|
end
|
nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "Distribution_CNTR", strCondition, strSetAttr)
|
if (nRet ~= 0) then
|
return 1, "updateDataAttrByCondition(Distribution_CNTR)失败" .. strRetInfo
|
end
|
end
|
|
elseif (nRet == 1) then
|
-- step2 如果配盘不存在 创建配盘
|
distribution_cntr = m3.AllocObject(strLuaDEID, "Distribution_CNTR")
|
distribution_cntr.factory = distribution_info.factory
|
distribution_cntr.bs_type = distribution_info.bs_type
|
distribution_cntr.bs_no = distribution_info.bs_no
|
|
distribution_cntr.cntr_code = cntr_code
|
distribution_cntr.wh_code = loc.wh_code
|
distribution_cntr.area_code = loc.area_code
|
distribution_cntr.loc_code = loc.code
|
distribution_cntr.exit_area_code = distribution_info.exit_area_code
|
distribution_cntr.exit_loc_code = distribution_info.exit_loc_code
|
|
-- 如果有紧急配盘，需要把配盘业务状态设置为 = 1（配盘完成）
|
if (distribution_info.urgent_outbound) then
|
-- 检查一下是否为整出
|
nRet, strRetInfo = wms_out.Check_Distribution_WholeOut(strLuaDEID, distribution_cntr)
|
if (nRet ~= 0) then
|
return nRet, strRetInfo
|
end
|
|
distribution_cntr.b_state = 1
|
distribution_cntr.b_state_name = "配盘完成" -- 这地方要改成从字典获取
|
if (strRetInfo == "yes") then
|
distribution_cntr.whole_out = 'Y'
|
end
|
end
|
|
nRet, distribution_cntr = m3.CreateDataObj(strLuaDEID, distribution_cntr)
|
if (nRet ~= 0) then
|
return 1, '创建【配盘】对象失败!' .. distribution_cntr
|
end
|
|
else
|
return 1, "GetDataObjByCondition失败! " .. distribution_cntr
|
end
|
|
local dc_no = distribution_cntr.dc_no -- 获取配盘号
|
|
-- step3 创建【配盘明细/Distribution_CNTR_Detail】
|
-- 获取 INV_Detail 信息
|
if (b_have_sanme_inv_detail) then
|
-- 【配盘明细】中已经存在相同的 INV_Detail， 更新数量
|
local strSetSQL = "F_QTY = F_QTY + " .. distribution_info.qty
|
strCondition = "S_DC_NO = '" .. distribution_cntr.dc_no .. "' AND G_INV_DETAIL_ID = '" .. distribution_info.inv_detail_id .. "'"
|
strCondition = strCondition .. " AND S_BS_TYPE = '" .. distribution_info.bs_type .. "' AND S_BS_NO = '" .. distribution_info.bs_no .. "'"
|
|
nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "Distribution_CNTR_Detail", strCondition, strSetSQL)
|
if (nRet ~= 0) then
|
return 1, "设置【配盘明细】 数量失败!" .. strRetInfo
|
end
|
else
|
local inv_detail
|
nRet, inv_detail = m3.GetDataObject(strLuaDEID, "INV_Detail", distribution_info.inv_detail_id)
|
if (nRet ~= 0) then
|
return 1, '获取【容器货品明细】对象失败!' .. inv_detail
|
end
|
|
distribution_detail = m3.AllocObject(strLuaDEID, "Distribution_CNTR_Detail")
|
distribution_detail.dc_no = dc_no
|
distribution_detail.cntr_code = inv_detail.cntr_code
|
distribution_detail.item_code = inv_detail.item_code
|
distribution_detail.item_name = inv_detail.item_name
|
distribution_detail.item_spec = inv_detail.item_spec
|
distribution_detail.cell_no = inv_detail.cell_no
|
distribution_detail.item_state = inv_detail.item_state
|
distribution_detail.item_state_name = inv_detail.item_state_name
|
distribution_detail.batch_no = inv_detail.batch_no
|
distribution_detail.serial_no = inv_detail.serial_no
|
distribution_detail.end_user = inv_detail.end_user
|
distribution_detail.owner = inv_detail.owner
|
distribution_detail.supplier = inv_detail.supplier
|
distribution_detail.uom = inv_detail.uom
|
distribution_detail.qty = distribution_info.qty
|
|
distribution_detail.bs_type = distribution_info.bs_type
|
distribution_detail.bs_no = distribution_info.bs_no
|
distribution_detail.bs_row_no = distribution_info.bs_row_no
|
distribution_detail.inv_detail_id = distribution_info.inv_detail_id
|
|
distribution_detail.wh_code = loc.wh_code
|
distribution_detail.area_code = loc.area_code
|
|
nRet, distribution_detail = m3.CreateDataObj(strLuaDEID, distribution_detail)
|
if (nRet ~= 0) then
|
return 1, '创建【配盘明细】对象失败!' .. distribution_detail
|
end
|
end
|
|
-- 仓库/库区量表+分配量
|
local item = {}
|
-- 量表变化参数
|
item[1] = {
|
N_ROW_NO = 1,
|
S_ITEM_CODE = distribution_detail.item_code,
|
S_ITEM_NAME = distribution_detail.item_name,
|
F_QTY = distribution_info.qty
|
}
|
-- + 仓库/库区分配量
|
nRet, strRetInfo = wms.wms_IPA_Start(loc.wh_code, loc.area_code, lua.table2str(item))
|
if (nRet ~= 0 or strRetInfo == '') then
|
return 1, 'wms_IPA_Start 失败!' .. strRetInfo
|
end
|
local success
|
local pre_alloc_storage
|
success, pre_alloc_storage = pcall(json.decode, strRetInfo)
|
if (success == false) then
|
return 1, "wms_IPA_Start 返回非法的JSON格式!" .. pre_alloc_storage
|
end
|
local trans_id = pre_alloc_storage.trans_id -- +分配量 事务标识
|
-- 如果没有trans_id说明+分配量失败
|
if (trans_id == nil or trans_id == '') then
|
return 1, "系统在增加仓库/库区分配量时失败! 可能是库存量不足!"
|
end
|
-- INV_Detail 加分配量
|
strCondition = "S_ID = '" .. distribution_info.inv_detail_id .. "'"
|
nRet, strRetInfo = mobox.incDataObjAccQty(strLuaDEID, "INV_Detail", strCondition, "F_QTY", "F_ALLOC_QTY", distribution_info.qty)
|
if (nRet ~= 0 or strRetInfo ~= '') then
|
wms.wms_IPA_Abort(trans_id)
|
return 1, '在增加【容器货品明细】中的分配量时失败!' .. strRetInfo
|
end
|
-- 业务来源这里加累计配盘数量
|
if (distribution_info.bs_type == "Shipping_Order") then
|
-- 发货单
|
strCondition = "S_SHIPPING_NO = '" .. distribution_info.bs_no .. "' AND N_ROW_NO = " .. distribution_info.bs_row_no
|
nRet, strRetInfo = mobox.incDataObjAccQty(strLuaDEID, "Shipping_Detail", strCondition, "F_QTY", "F_ACC_D_QTY", distribution_info.qty)
|
if (nRet ~= 0 or strRetInfo ~= '') then
|
wms.wms_IPA_Abort(trans_id)
|
return 1, '在增加【发货单明细】中的累计配货数量时失败!' .. strRetInfo
|
end
|
nRet, strRetInfo = wms_out.Shipping_Order_CheckState(strLuaDEID, distribution_info.bs_no)
|
if (nRet ~= 0) then
|
wms.wms_IPA_Abort(trans_id)
|
return 1, strRetInfo
|
end
|
else
|
-- 出库单
|
end
|
|
wms.wms_IPA_Commit(trans_id)
|
return 0
|
end
|
|
--[[
|
根据输入的出库单编码获取 出库单明细列表，oo_no_set 是一个出库单编码数组，如["OO010","OO012"]
|
返回值: 1 -- nRet 0 正确 2 --outbound_detail_list 出库单明细列表 table
|
]]
|
function wms_out.Get_Outbound_Detail_list(strLuaDEID, oo_no_set)
|
local nRet, strRetInfo
|
local where, nCount, n
|
local outbound_detail_list = {}
|
|
nCount = #oo_no_set
|
if (nCount == 0) then
|
return 1, "出库单编码不能为空!"
|
end
|
if (nCount == 1) then
|
where = " S_OO_NO = '" .. oo_no_set[1] .. "'"
|
else
|
where = " S_OO_NO IN ("
|
for n = 1, nCount do
|
where = where .. "'" .. oo_no_set[n] .. "',"
|
end
|
where = lua.trim_laster_char(where) .. ")"
|
end
|
|
local strOrder = "S_ITEM_CODE"
|
|
nRet, strRetInfo = mobox.queryDataObjAttr(strLuaDEID, "Outbound_Detail", where, strOrder)
|
if (nRet ~= 0) then
|
return 1, "获取【发货单明细】失败! " .. strRetInfo
|
end
|
-- 如果没有满足条件的出库单明细就直接返回
|
if (strRetInfo == '') then
|
return 0, outbound_detail_list
|
end
|
|
local retObjs = json.decode(strRetInfo)
|
local outbound_detail
|
|
for n = 1, #retObjs do
|
nRet, outbound_detail = m3.ObjAttrStrToLuaObj("Outbound_Detail", lua.table2str(retObjs[n].attrs))
|
table.insert(outbound_detail_list, outbound_detail)
|
end
|
return 0, outbound_detail_list
|
end
|
|
--[[
|
把配盘明细中的货品 批分到每个出库单明细， 前提是这个配盘是针对 出库波次单 进行的出库分拣操作
|
输入参数: d_cntr_detail_list [配盘明细]
|
返回值: 1 -- nRet 0 正确 2 --outbound_detail_list 出库单明细列表 table
|
]]
|
function wms_out.Split_Distribution_CNTR_Detail(strLuaDEID, wave_no, wave_cls_id, d_cntr_detail_list, outbound_detail_list)
|
|
local new_d_cntr_detail_list = {}
|
|
for n = 1, #d_cntr_detail_list do
|
local cd_item_code = d_cntr_detail_list[n].S_ITEM_CODE
|
local cd_item_state = d_cntr_detail_list[n].S_ITEM_STATE
|
local cd_storer = d_cntr_detail_list[n].S_STORER
|
local cd_qty = tonumber(d_cntr_detail_list[n].F_QTY)
|
for m = 1, #outbound_detail_list do
|
local out_item_code = outbound_detail_list[m].item_code
|
local out_item_state = outbound_detail_list[m].item_state
|
local out_storer = outbound_detail_list[m].storer
|
local out_qty = tonumber(outbound_detail_list[m].qty)
|
local acc_d_qty = tonumber(outbound_detail_list[m].acc_d_qty)
|
if (cd_item_code == out_item_code and cd_item_state == out_item_state and cd_storer == out_storer and out_qty > acc_d_qty) then
|
local d_cntr_detail = {
|
item_code = d_cntr_detail_list[n].S_ITEM_CODE,
|
item_name = d_cntr_detail_list[n].S_ITEM_NAME,
|
cntr_code = d_cntr_detail_list[n].S_CNTR_CODE,
|
batch_no = d_cntr_detail_list[n].S_BATCH_NO,
|
cell_no = d_cntr_detail_list[n].S_CELL_NO,
|
station = d_cntr_detail_list[n].S_STATION_NO,
|
serial_no = d_cntr_detail_list[n].S_SERIAL_NO,
|
item_spec = d_cntr_detail_list[n].S_ITEM_SPEC,
|
end_user = d_cntr_detail_list[n].S_END_USER,
|
owner = d_cntr_detail_list[n].S_OWNER,
|
uom = d_cntr_detail_list[n].S_UOM,
|
volume = d_cntr_detail_list[n].F_VOLUME,
|
weight = d_cntr_detail_list[n].F_WEIGHT,
|
wh_code = d_cntr_detail_list[n].S_WH_CODE,
|
area_code = d_cntr_detail_list[n].S_AREA_CODE,
|
loc_code = d_cntr_detail_list[n].S_LOC_CODE,
|
inv_detail_id = d_cntr_detail_list[n].G_INV_DETAIL_ID,
|
pick_box_code = "",
|
qty = 0
|
}
|
|
local need_qty = out_qty - acc_d_qty -- 出库单明细需求量
|
local split_qty -- 本次批分数量
|
if (cd_qty > need_qty) then
|
split_qty = need_qty
|
else
|
split_qty = cd_qty
|
end
|
|
cd_qty = cd_qty - split_qty -- 配盘明细剩余量
|
acc_d_qty = acc_d_qty + split_qty -- 出库单明细累计配货量
|
|
d_cntr_detail.qty = split_qty
|
d_cntr_detail.bs_type = "Outbound_Order"
|
d_cntr_detail.bs_no = outbound_detail_list[m].oo_no
|
d_cntr_detail.bs_row_no = outbound_detail_list[m].row_no
|
d_cntr_detail.wave_no = wave_no
|
d_cntr_detail.wave_cls_id = wave_cls_id
|
table.insert(new_d_cntr_detail_list, d_cntr_detail)
|
if (cd_qty == 0) then
|
break
|
end
|
end
|
end
|
end
|
return new_d_cntr_detail_list
|
end
|
|
|
--[[
|
出库分拣标准配货算法 ****
|
说明：
|
根据 parameter 的业务来源类型和来源编码获取需要出库的货品清单 item_lits
|
遍历 item_list 从库存中找出匹配的库存明细进行预分配，生成 d_cntr_detail_list 配盘明细（出库任务）
|
如果有缺件 保存 在shortage_list
|
注意：item_list中的 item(SKU) 参与查询条件的属性-- S_PICKING_RULE, S_MATCH_RULE 中定义的规则进行
|
parameter = {
|
wh_code, area_code 出库货品仓库-库区 ，
|
station -- 分拣站台, 可以为空
|
exit_loc -- 出库出口货位，货位对象{ area_code, code }
|
aisle -- 可用巷道
|
bs_type --（Outbound_Order/Outbound_Wave）
|
bs_no -- 波次号/出库单号
|
factory -- 工厂标识
|
cntr_out_op_def -- 容器出库作业定义
|
cntr_back_op_def -- 容器回库作业定义
|
}
|
|
返回:
|
d_cntr_list 配盘/Distribution_CNTR
|
d_cntr_detail_list 配盘明细/Distribution_CNTR_Detail
|
shortage_list -- 缺件清单
|
更改记录:
|
|
]]
|
function wms_out.Distribution_Procedure(strLuaDEID, parameter, d_cntr_list, d_cntr_detail_list, shortage_list)
|
|
local nRet, strRetInfo
|
local strCondition
|
local outbound_order
|
local data_objs
|
local storer_data
|
|
local str_loc_where = ""
|
local default_match_rule = ""
|
local default_picking_rule = ""
|
|
-- 输入参数判断
|
if (parameter == nil or parameter == "") then
|
return 1, "输入参数错误， wh_code必须有值"
|
end
|
if (parameter.wh_code == nil or parameter.wh_code == "") then
|
return 1, "输入参数错误， parameter.wh_code必须有值"
|
end
|
if (parameter.bs_type == nil or parameter.bs_type == "") then
|
return 1, "输入参数错误， parameter.bs_type 必须有值"
|
end
|
if (parameter.bs_no == nil or parameter.bs_no == "") then
|
return 1, "输入参数错误， parameter.bs_no 必须有值"
|
end
|
|
-- 获取入库货品清单item_list
|
if parameter.bs_type == "Outbound_Wave" then
|
|
-- 获取波次明细
|
nRet, data_objs = m3.QueryDataObject(strLuaDEID, "OW_Detail", "S_WAVE_NO = '" .. parameter.bs_no .. "'", "N_ROW_NO")
|
if (nRet ~= 0) then
|
return 2, "QueryDataObject失败!" .. data_objs
|
end
|
|
elseif parameter.bs_type == "Outbound_Order" then
|
|
-- 获取出库单明细
|
nRet, data_objs = m3.QueryDataObject(strLuaDEID, "Outbound_Detail", "S_OO_NO = '" .. parameter.bs_no .. "'", "N_ROW_NO")
|
if (nRet ~= 0) then
|
return 2, "QueryDataObject失败!" .. data_objs
|
end
|
|
-- 获取出库单的拣货规则，匹配规则
|
nRet, outbound_order = m3.GetDataObjByCondition(strLuaDEID, "Outbound_Order", "S_NO = '" .. parameter.bs_no .. "'")
|
if (nRet ~= 0) then
|
return 2, "获取出库单信息失败!" .. outbound_order
|
end
|
|
local order_match_rule = outbound_order.match_rule or ""
|
local order_picking_rule = outbound_order.picking_rule or ""
|
local storer = outbound_order.storer or ""
|
|
if (storer == "") then
|
return 2, "出库单'" .. parameter.bs_no .. "'没定义货主!"
|
end
|
|
nRet, storer_data = m3.GetDataFromCache("Storer", storer)
|
if (nRet ~= 0) then
|
return 2, storer_data
|
end
|
if order_match_rule ~= "" then
|
default_match_rule = order_match_rule
|
else
|
default_match_rule = storer_data.S_MATCH_RULE or ""
|
end
|
if order_picking_rule ~= "" then
|
default_picking_rule = order_picking_rule
|
else
|
default_picking_rule = storer_data.S_PICKING_RULE or ""
|
end
|
else
|
return 1, "输入参数错误，parameter.bs_type不合规!"
|
end
|
if (data_objs == "") then
|
return 1, "编号号'" .. parameter.bs_no .. "'的'" .. parameter.bs_type .. "'为空!"
|
end
|
|
local OUT_DETAIL_ATTR_COUNT = #OUTBOUND_DETAIL_BASE_ATTRS
|
local UDF_ATTRS_COUNT = #UDF_ATTRS
|
local DC_DETAIL_ATTRS_COUNT = #DC_DETAIL_ATTRS
|
|
local item_list = {}
|
for n = 1, #data_objs do
|
local detail_attrs = m3.KeyValueAttrsToObjAttr(data_objs[n].attrs)
|
|
local item = {}
|
for m = 1, OUT_DETAIL_ATTR_COUNT do
|
item[OUTBOUND_DETAIL_BASE_ATTRS[m]] = detail_attrs[OUTBOUND_DETAIL_BASE_ATTRS[m]]
|
end
|
for m = 1, UDF_ATTRS_COUNT do
|
item[UDF_ATTRS[m]] = detail_attrs[UDF_ATTRS[m]]
|
end
|
|
item.qty = lua.Get_NumAttrValue(detail_attrs.F_QTY) - lua.Get_NumAttrValue(detail_attrs.F_ACC_D_QTY)
|
item.alloc_qty = 0
|
table.insert(item_list, item)
|
end
|
|
-- 拣货策略和匹配策略确定，如果 Detail 里有定义就根据Detail里的定义，没有就从 Order 上找，Order上没有就从 货主这里找
|
-- 从 INV_Detail 中分配数量
|
local attr_set = {}
|
local strTable = "TN_INV_Detail a LEFT JOIN TN_Container b ON a.S_CNTR_CODE = b.S_CODE"
|
local strAttrs = 'a.S_ID, a.S_WH_CODE, a.S_AREA_CODE, a.S_LOC_CODE,'
|
local INV_DETAIL_BASE_ATTRS_COUNT = #INV_DETAIL_BASE_ATTRS
|
for m = 1, INV_DETAIL_BASE_ATTRS_COUNT do
|
strAttrs = strAttrs .. "a." .. INV_DETAIL_BASE_ATTRS[m] .. ","
|
table.insert(attr_set, INV_DETAIL_BASE_ATTRS[m])
|
end
|
for m = 1, UDF_ATTRS_COUNT do
|
strAttrs = strAttrs .. "a." .. UDF_ATTRS[m] .. ","
|
table.insert(attr_set, UDF_ATTRS[m])
|
end
|
strAttrs = lua.trim_laster_char(strAttrs)
|
|
str_loc_where = "S_WH_CODE = '" .. parameter.wh_code .. "'"
|
if (parameter.area_code ~= nil and parameter.area_code ~= '') then
|
str_loc_where = str_loc_where .. " AND S_AREA_CODE = '" .. parameter.area_code .. "'"
|
end
|
|
local match_rule, picking_rule, inv_condition, inv_order
|
local index, qty, need_qty, d_qty
|
local strUpdateSql
|
local have_alloc = false
|
|
-- 遍历待出库货品清单
|
for n, item in ipairs(item_list) do
|
inv_order = ""
|
-- step2.1 组织查询条件
|
-- 获取匹配策略
|
match_rule = item.S_MATCH_RULE or ""
|
if match_rule == "" then
|
match_rule = default_match_rule
|
end
|
-- 拣货规则
|
picking_rule = item.S_PICKING_RULE or ""
|
if picking_rule == "" then
|
picking_rule = default_picking_rule
|
end
|
inv_condition = wms_base.Get_INV_Detail_MatchSql(item, match_rule)
|
inv_order = wms_base.Get_INV_Detail_QueryOrder(picking_rule)
|
|
-- b.C_ENABLE 容器没禁用 a.F_QTY_VALID 可用量大于0
|
strCondition = inv_condition .. " AND b.C_ENABLE = 'Y' AND a.F_QTY_VALID > 0 " .. "AND a.S_CNTR_CODE IN (select S_CNTR_CODE from TN_Loc_Container where S_LOC_CODE IN (select S_CODE from TN_Location where " .. str_loc_where .. ")) "
|
|
lua.Debug(strLuaDEID, debug.getinfo(1), "配盘查询内容 -->", strAttrs)
|
lua.Debug(strLuaDEID, debug.getinfo(1), "配盘查询联表 -->", strTable)
|
lua.Debug(strLuaDEID, debug.getinfo(1), "最终配盘条件 -->", strCondition)
|
|
-- step2.2 多表联查获取容器货品信息
|
nRet, strRetInfo = mobox.queryMultiTable(strLuaDEID, strAttrs, strTable, 1000, strCondition, inv_order)
|
if (nRet ~= 0) then
|
return 2, "查询【容器货品明细】信息失败! " .. strRetInfo
|
end
|
if (strRetInfo ~= "") then
|
local inv_detail_set = json.decode(strRetInfo)
|
-- step2.3 根据出库数量遍历2.2获取的容器货品信息进行数量批分
|
-- item.qty --> 需要出库的数量 item.alloc_qty --> 已经配货数量
|
for _, inv_detail in ipairs(inv_detail_set) do
|
|
-- step2.3.1 配货数量已经到达出库数量
|
if (lua.equation(item.qty, item.alloc_qty)) then
|
break
|
end
|
|
-- 获取查询获取的 INV_Detail 中的属性
|
local inv_detail_data = {}
|
inv_detail_data.S_ID = inv_detail[1]
|
inv_detail_data.S_WH_CODE = inv_detail[2]
|
inv_detail_data.S_AREA_CODE = inv_detail[3]
|
inv_detail_data.S_LOC_CODE = inv_detail[4]
|
index = 5
|
for m = 1, INV_DETAIL_BASE_ATTRS_COUNT do
|
inv_detail_data[INV_DETAIL_BASE_ATTRS[m]] = inv_detail[index]
|
index = index + 1
|
end
|
for m = 1, UDF_ATTRS_COUNT do
|
inv_detail_data[UDF_ATTRS[m]] = inv_detail[index]
|
index = index + 1
|
end
|
|
-- 容器中可用于配货的数量
|
qty = lua.StrToNumber(inv_detail_data.F_QTY_VALID)
|
need_qty = item.qty - item.alloc_qty
|
|
-- 把容器加入 配货容器 清单
|
-- step2.3.3 检查一下容器是否已经在 d_cntr_list, 如果不存在要把 容器加入 d_cntr_lis
|
local cntr_code = inv_detail_data.S_CNTR_CODE
|
local bFind = false
|
for i = 1, #d_cntr_list do
|
if (d_cntr_list[i].S_CNTR_CODE == cntr_code) then
|
bFind = true
|
break
|
end
|
end
|
if (bFind == false) then
|
-- 初始化【配盘】容器信息
|
local distribution_cntr = m3.AllocObject2(strLuaDEID, "Distribution_CNTR")
|
distribution_cntr.S_FACTORY = parameter.factory
|
distribution_cntr.S_BS_TYPE = parameter.bs_type
|
distribution_cntr.S_BS_NO = parameter.bs_no
|
distribution_cntr.S_OUT_OP_NAME = parameter.cntr_out_op_def or ""
|
distribution_cntr.S_BACK_OP_NAME = parameter.cntr_back_op_def or ""
|
distribution_cntr.S_CNTR_CODE = cntr_code
|
distribution_cntr.N_B_STATE = 1
|
distribution_cntr.S_WH_CODE = parameter.wh_code
|
distribution_cntr.S_AREA_CODE = parameter.area_code
|
distribution_cntr.S_LOC_CODE = inv_detail_data.S_LOC_CODE
|
distribution_cntr.S_BS_TYPE = parameter.bs_type
|
distribution_cntr.S_BS_NO = parameter.bs_no
|
distribution_cntr.S_EXIT_AREA_CODE = ""
|
distribution_cntr.S_EXIT_LOC_CODE = ""
|
distribution_cntr.S_STATION_NO = parameter.station
|
distribution_cntr.S_DC_NO = ""
|
if (parameter.exit_loc ~= nil) then
|
distribution_cntr.S_EXIT_AREA_CODE = parameter.exit_loc.area_code
|
distribution_cntr.S_EXIT_LOC_CODE = parameter.exit_loc.code
|
end
|
table.insert(d_cntr_list, distribution_cntr)
|
end
|
|
-- step2.3.4 批分容器配盘数量
|
if (need_qty > qty) then
|
d_qty = qty
|
else
|
d_qty = need_qty
|
end
|
if (d_qty > 0) then
|
have_alloc = true
|
item.alloc_qty = item.alloc_qty + d_qty
|
|
-- step2.3.5 生成 配盘明细并且加入配盘明细清单
|
local d_cntr_detail = m3.AllocObject2(strLuaDEID, "Distribution_CNTR_Detail")
|
d_cntr_detail.S_BS_TYPE = parameter.bs_type
|
d_cntr_detail.S_BS_NO = parameter.bs_no
|
d_cntr_detail.N_BS_ROW_NO = n
|
d_cntr_detail.G_INV_DETAIL_ID = inv_detail_data.S_ID
|
d_cntr_detail.S_PICK_BOX_CODE = ""
|
d_cntr_detail.S_STATION_NO = parameter.station
|
for m = 1, DC_DETAIL_ATTRS_COUNT do
|
d_cntr_detail[DC_DETAIL_ATTRS[m]] = inv_detail_data[DC_DETAIL_ATTRS[m]]
|
end
|
d_cntr_detail.F_QTY = d_qty
|
table.insert(d_cntr_detail_list, d_cntr_detail)
|
|
-- INV_Detail 的 + F_ALLOC_QTY，并且创建库存锁定日志
|
nRet, strRetInfo = wms_inv.INV_Detail_Add_AllocQty(strLuaDEID, inv_detail_data, d_qty, parameter.bs_type, parameter.bs_no)
|
if nRet ~= 0 then
|
return 2, "wms_inv.INV_Detail_Add_AllocQty 失败!" .. strRetInfo
|
end
|
-- 入库单明细/入库波次明细 货品的累计配货数量 + d_qty
|
strCondition = "AND S_ITEM_CODE = '" .. item.S_ITEM_CODE .. "' AND S_ITEM_STATE = '" .. item.S_ITEM_STATE .. "' AND S_STORER = '" .. item.S_STORER .. "'"
|
if parameter.bs_type == "Outbound_Wave" then
|
strCondition = "S_WAVE_NO = '" .. parameter.bs_no .. "'" .. strCondition
|
strUpdateSql = "F_ACC_D_QTY = F_ACC_D_QTY + " .. d_qty
|
nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "OW_Detail", strCondition, strUpdateSql)
|
if (nRet ~= 0) then
|
return 2, "更新【波次明细】信息失败!" .. strRetInfo
|
end
|
elseif parameter.bs_type == "Outbound_Order" then
|
strCondition = "S_OO_NO = '" .. parameter.bs_no .. "'" .. strCondition
|
strUpdateSql = "F_ACC_D_QTY = F_ACC_D_QTY + " .. d_qty
|
nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "Outbound_Detail", strCondition, strUpdateSql)
|
if (nRet ~= 0) then
|
return 2, "更新【入库单明细】信息失败!" .. strRetInfo
|
end
|
end
|
end
|
end
|
end
|
end
|
|
-- step3 检查一下是否有未分配完成的货品，如果有生成缺件清单
|
local alloc_is_ok = true
|
for _, item in ipairs(item_list) do
|
if item.qty > item.alloc_qty then
|
-- 加入缺件清单
|
alloc_is_ok = false
|
local shortage = {
|
storer = item.S_STORER, item_code = item.S_ITEM_CODE, item_state = item.S_ITEM_STATE, item_name = item.S_ITEM_NAME,
|
qty = item.qty - item.alloc_qty
|
}
|
table.insert(shortage_list, shortage)
|
end
|
end
|
|
-- 如果出库单明细中已经全部分配完成
|
if alloc_is_ok then
|
-- 更新出库单、出库波次的状态为 -- 配货完成
|
if parameter.bs_type == "Outbound_Wave" then
|
strCondition = "S_WAVE_NO = '" .. parameter.bs_no .. "'"
|
strUpdateSql = "N_B_STATE = " .. OUTBOUND_ORDER_STATE.AllocOK .. ",C_PRE_PICKING_OK = 'Y'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "Outbound_Wave", strCondition, strUpdateSql)
|
if (nRet ~= 0) then
|
return 2, "更新【出库波次】信息失败!" .. strRetInfo
|
end
|
elseif parameter.bs_type == "Outbound_Order" then
|
strCondition = "S_NO = '" .. parameter.bs_no .. "'"
|
strUpdateSql = "N_B_STATE = " .. OUTBOUND_ORDER_STATE.AllocOK .. ",C_PRE_PICKING_OK = 'Y'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "Outbound_Order", strCondition, strUpdateSql)
|
if (nRet ~= 0) then
|
return 2, "更新【出库单】信息失败!" .. strRetInfo
|
end
|
end
|
end
|
|
return 0
|
end
|
|
--[[
|
创建配盘及配盘明细数据对象
|
参数: d_cntr_list 【配盘】链表 [{cntr_code, bs_type, bs_no, wh_code, area_code, exit_area_code, exit_loc_code }]
|
d_cntr_detail_list【配盘明细】链表 [{item_code, item_name, batch_no, serial_no, cntr_code, cell_no, item_state, uom, qty, bs_type, bs_no, wave_cls_id, wave_no, inv_detail_id }]
|
返回值 nRet = 0 表示创建成功
|
]]
|
function wms_out.Creat_Distribution_list(strLuaDEID, wave_no, d_cntr_list, d_cntr_detail_list)
|
|
local nRet
|
|
-- 创建配盘单并获取单号
|
for n = 1, #d_cntr_list do
|
local distribution_cntr = m3.AllocObject(strLuaDEID, "Distribution_CNTR")
|
distribution_cntr.cntr_code = d_cntr_list[n].S_CNTR_CODE
|
distribution_cntr.b_state = d_cntr_list[n].N_B_STATE
|
distribution_cntr.wh_code = d_cntr_list[n].S_WH_CODE
|
distribution_cntr.area_code = d_cntr_list[n].S_AREA_CODE
|
distribution_cntr.loc_code = d_cntr_list[n].S_LOC_CODE
|
distribution_cntr.bs_type = d_cntr_list[n].S_BS_TYPE
|
distribution_cntr.bs_no = d_cntr_list[n].S_BS_NO
|
distribution_cntr.station = d_cntr_list[n].S_STATION_NO
|
distribution_cntr.exit_area_code = d_cntr_list[n].S_EXIT_AREA_CODE
|
distribution_cntr.exit_loc_code = d_cntr_list[n].S_EXIT_LOC_CODE
|
distribution_cntr.out_op_name = '货品出库'
|
distribution_cntr.back_op_name = '料箱入库'
|
lua.Debug(strLuaDEID, debug.getinfo(1), "配盘创建前 -->", distribution_cntr)
|
nRet, distribution_cntr = m3.CreateDataObj(strLuaDEID, distribution_cntr)
|
if (nRet ~= 0) then
|
return 1, "创建【配盘】对象失败!" .. distribution_cntr
|
end
|
local dc_no = distribution_cntr.dc_no
|
d_cntr_list[n].S_DC_NO = dc_no
|
|
for m = 1, #d_cntr_detail_list do
|
local dc_detail = d_cntr_detail_list[m]
|
if (dc_detail.cntr_code == distribution_cntr.cntr_code) then
|
local distribution_detail = m3.AllocObject(strLuaDEID, "Distribution_CNTR_Detail")
|
distribution_detail.dc_no = dc_no
|
distribution_detail.wave_no = wave_no
|
distribution_detail.wh_code = d_cntr_list[n].S_WH_CODE
|
distribution_detail.area_code = d_cntr_list[n].S_AREA_CODE
|
distribution_detail.loc_code = distribution_cntr.loc_code
|
distribution_detail.cntr_code = dc_detail.cntr_code
|
distribution_detail.item_code = dc_detail.item_code
|
distribution_detail.item_name = dc_detail.item_name
|
distribution_detail.item_spec = dc_detail.item_spec
|
distribution_detail.cell_no = dc_detail.cell_no
|
distribution_detail.item_state = dc_detail.item_state
|
distribution_detail.item_state_name = dc_detail.item_state_name
|
distribution_detail.batch_no = dc_detail.batch_no
|
distribution_detail.serial_no = dc_detail.serial_no
|
distribution_detail.end_user = dc_detail.end_user
|
distribution_detail.owner = dc_detail.owner
|
distribution_detail.supplier = dc_detail.supplier
|
distribution_detail.uom = dc_detail.uom
|
distribution_detail.qty = dc_detail.qty
|
distribution_detail.bs_type = dc_detail.bs_type
|
distribution_detail.bs_no = dc_detail.bs_no
|
distribution_detail.bs_row_no = dc_detail.bs_row_no
|
distribution_detail.inv_detail_id = dc_detail.inv_detail_id
|
distribution_detail.wh_code = dc_detail.wh_code
|
distribution_detail.area_code = dc_detail.area_code
|
distribution_detail.pick_box_code = dc_detail.pick_box_code
|
distribution_detail.station = d_cntr_list[n].S_STATION_NO
|
lua.Debug(strLuaDEID, debug.getinfo(1), "配盘明细创建前 -->", distribution_detail)
|
nRet, distribution_detail = m3.CreateDataObj(strLuaDEID, distribution_detail)
|
if (nRet ~= 0) then
|
return 1, "创建【配盘明细】对象失败!" .. distribution_detail
|
end
|
end
|
end
|
end
|
return 0
|
end
|
|
-- 把出库单明细中的 item 加入出库明细汇总链表 sum_outbound_detail, 如果 货品编码相同 数量相加
|
-- strOONo 出库单号
|
-- sum_outbound_detail 出库单波次明细 [{item_name,item_code,qty,weight,volume,cell_type}]
|
-- 返回：nRet = 0 outbound_detail_info -- 出库单明细汇总信息
|
-- outbound_detail_info { total_qty, total_weight, total_volume }
|
function wms_out.Sum_outbound_detail(strLuaDEID, strOONo, sum_outbound_detail)
|
|
local nRet, strRetInfo
|
local strCondition
|
local data_objs
|
local outbound_detail_info = {
|
total_qty = 0, total_weight = 0, total_volume = 0
|
}
|
|
strCondition = "S_OO_NO = '" .. strOONo .. "'"
|
nRet, data_objs = m3.QueryDataObject(strLuaDEID, "Outbound_Detail", strCondition, "N_ROW_NO")
|
if (nRet ~= 0) then
|
return 2, "QueryDataObject失败!" .. data_objs
|
end
|
if (data_objs == '') then
|
return 0, outbound_detail_info
|
end
|
|
local bFind
|
|
for n = 1, #data_objs do
|
local detail_attrs = m3.KeyValueAttrsToObjAttr(data_objs[n].attrs)
|
local item_code = lua.Get_StrAttrValue(detail_attrs.S_ITEM_CODE)
|
local item_state = lua.Get_StrAttrValue(detail_attrs.S_ITEM_STATE)
|
local storer = lua.Get_StrAttrValue(detail_attrs.S_STORER)
|
local qty = lua.StrToNumber(detail_attrs.F_QTY)
|
local weight = lua.StrToNumber(detail_attrs.F_WEIGHT)
|
local volume = lua.StrToNumber(detail_attrs.F_VOLUME)
|
|
if (item_code ~= "" and qty > 0) then
|
|
outbound_detail_info.total_qty = outbound_detail_info.total_qty + qty
|
outbound_detail_info.total_weight = outbound_detail_info.total_weight + qty * weight
|
outbound_detail_info.total_volume = outbound_detail_info.total_volume + qty * volume
|
|
bFind = false
|
for m = 1, #sum_outbound_detail do
|
if (sum_outbound_detail[m].item_code == item_code and sum_outbound_detail[m].item_state == item_state and sum_outbound_detail[m].storer == storer) then
|
sum_outbound_detail[m].qty = sum_outbound_detail[m].qty + qty
|
bFind = true
|
break
|
end
|
end
|
if (bFind == false) then
|
local out_item = {
|
item_code = item_code,
|
item_name = lua.Get_StrAttrValue(detail_attrs.S_ITEM_NAME),
|
item_state = item_state,
|
storer = storer,
|
qty = qty,
|
alloc_qty = 0,
|
weight = weight,
|
volume = volume,
|
cell_type = lua.Get_StrAttrValue(detail_attrs.S_CELL_TYPE)
|
}
|
table.insert(sum_outbound_detail, out_item)
|
end
|
end
|
end
|
return 0, outbound_detail_info
|
end
|
|
|
--[[
|
分拣出库后，根据配盘明细中的分拣结果 影响 量表，INV_Detail
|
[配盘明细 /Distribution_CNTR_Detail] 的后处理程序
|
--减仓库/库区量表的分配量
|
--减仓库/库区量表的存储量
|
--生成【OnOff_Shelves】上下架记录
|
--减 INV_Detail 中的QTY个ALLOC_QTY
|
--更新 来源单号 中的累计出库数量
|
--更新容器料格中的强制置满标记 C_FORCED_FILL = N
|
]]
|
function wms_out.Distribution_CNTR_Detail_PostProcess(strLuaDEID, wh_code, area_code, loc_code, dc_no)
|
local nRet, strRetInfo
|
|
if (dc_no == nil or dc_no == '') then
|
return 1, "wms_out.Distribution_CNTR_Detail_PostProcess 函数中 dc_no 必须有值!"
|
end
|
|
local chg_target = '' -- 量表变化对象
|
if (wh_code == '' or wh_code == nil) then
|
return 1, "wms_out.Distribution_CNTR_Detail_PostProcess 函数中仓库编码必须有值!"
|
end
|
if (area_code == nil) then
|
area_code = ''
|
end
|
if (loc_code == nil) then
|
loc_code = ''
|
end
|
|
-- 获取 Pre_Alloc_CNTR_Detail
|
local strOrder = ''
|
local strCondition = "S_DC_NO = '" .. dc_no .. "'"
|
|
nRet, strRetInfo = mobox.queryDataObjAttr(strLuaDEID, "Distribution_CNTR_Detail", strCondition, strOrder)
|
if (nRet ~= 0) then
|
return 1, "获取【配盘明细】失败! " .. strRetInfo
|
end
|
if (strRetInfo == '') then
|
lua.Warning(strLuaDEID, debug.getinfo(1), "配盘号'" .. dc_no .. "'的明细为空!")
|
return 1, "配盘号'" .. dc_no .. "'的明细为空!"
|
end
|
|
local retObjs = json.decode(strRetInfo)
|
local n
|
|
local alloc_qty_change = {} -- 分配量变化
|
local dc_detail = {}
|
local onoff_shelves = {} -- 上下架记录
|
local days = os.date("%Y%m%d")
|
local cancel_qty -- 取消数量
|
local strSetAttr
|
|
-- 获取存储量变化数据 并且创建 上下架记录
|
for n = 1, #retObjs do
|
nRet, dc_detail = m3.ObjAttrStrToLuaObj("Distribution_CNTR_Detail", lua.table2str(retObjs[n].attrs))
|
if (nRet ~= 0) then
|
return 1, "m3.ObjAttrStrToLuaObj(Pre_Alloc_CNTR_Detail) 失败! " .. dc_detail
|
end
|
|
-- 更新容器料格中的强制置满标记 C_FORCED_FILL = N
|
strCondition = "S_CNTR_CODE = '" .. dc_detail.cntr_code .. "' AND S_CELL_NO = '" .. dc_detail.cell_no .. "'"
|
strSetAttr = "C_FORCED_FILL = 'N'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "Container_Cell", strCondition, strSetAttr)
|
if (nRet ~= 0) then
|
return 1, "设置【Container_Cell】属性失败!" .. strRetInfo
|
end
|
|
-- 强制完成产生的取消数量 qty/计划检出数量 acc_p_qty/实际检出数量
|
cancel_qty = dc_detail.qty - dc_detail.acc_p_qty
|
if (dc_detail.acc_p_qty > 0) then
|
|
-- 生成分配量变化输入参数
|
local alloc_qty_info = {
|
item_code = dc_detail.item_code,
|
item_name = dc_detail.item_name,
|
qty = dc_detail.qty,
|
wh_code = wh_code,
|
area_code = area_code
|
}
|
table.insert(alloc_qty_change, alloc_qty_info)
|
|
-- 生成上架记录【OnOff_Shelves】
|
onoff_shelves = m3.AllocObject(strLuaDEID, "OnOff_Shelves")
|
onoff_shelves.action = "-"
|
onoff_shelves.d_action = days
|
|
onoff_shelves.wh_code = wh_code
|
onoff_shelves.area_code = area_code
|
onoff_shelves.loc_code = loc_code
|
|
onoff_shelves.item_code = dc_detail.item_code
|
onoff_shelves.item_name = dc_detail.item_name
|
onoff_shelves.batch_no = dc_detail.batch_no
|
onoff_shelves.serial_no = dc_detail.serial_no
|
onoff_shelves.item_spec = dc_detail.item_spec
|
onoff_shelves.item_state_name = dc_detail.item_state_name
|
onoff_shelves.item_state = dc_detail.item_state
|
|
onoff_shelves.end_user = dc_detail.end_user
|
onoff_shelves.owner = dc_detail.owner
|
onoff_shelves.supplier = dc_detail.supplier
|
onoff_shelves.supplier_name = dc_detail.supplier_name
|
|
onoff_shelves.cntr_code = dc_detail.cntr_code
|
onoff_shelves.cell_no = dc_detail.cell_no
|
|
onoff_shelves.qty = dc_detail.acc_p_qty
|
onoff_shelves.uom = dc_detail.uom
|
|
onoff_shelves.bs_no = dc_detail.bs_no
|
onoff_shelves.bs_type = dc_detail.bs_type
|
|
nRet, onoff_shelves = m3.CreateDataObj(strLuaDEID, onoff_shelves)
|
if (nRet ~= 0) then
|
return 1, 'mobox 创建【上下架记录】对象失败!' .. onoff_shelves
|
end
|
end
|
|
-- 减库存量表
|
if (dc_detail.inv_detail_id ~= '') then
|
-- 配盘明细没有合并
|
nRet, strRetInfo = wms_inv.INV_Detail_Out(strLuaDEID, dc_detail.inv_detail_id, dc_detail.acc_p_qty, dc_detail.qty,
|
dc_detail.bs_type, dc_detail.bs_no)
|
if (nRet ~= 0) then
|
return 1, "wms_inv.INV_Detail_Out 失败! " .. strRetInfo
|
end
|
else
|
-- 配盘明细是合并 INV_Detail 的因此需要把计划出库数量，实际出库数量批分到 INV_Detail 上
|
strOrder = "S_BATCH_NO"
|
strCondition = "S_CNTR_CODE = '" .. dc_detail.cntr_code .. "' AND S_CELL_NO = '" .. dc_detail.cell_no .. "'"
|
nRet, strRetInfo = wms_inv.INV_Detail_SplitOut(strLuaDEID, strCondition, strOrder, dc_detail.acc_p_qty, dc_detail.qty,
|
dc_detail.bs_type, dc_detail.bs_no)
|
if (nRet ~= 0) then
|
return 1, "wms_inv.INV_Detail_SplitOut 失败! " .. strRetInfo
|
end
|
end
|
|
-- 如果来源类型 = Outbound_Order 更新出库单的累计出库数量
|
if (dc_detail.bs_type == "Outbound_Order") then
|
if (dc_detail.bs_no ~= nil and dc_detail.bs_no ~= '') then
|
strCondition = "S_OO_NO = '" .. dc_detail.bs_no .. "' AND S_ITEM_CODE = '" .. dc_detail.item_code .. "'"
|
strSetAttr = "F_ACC_O_QTY = F_ACC_O_QTY +" .. dc_detail.acc_p_qty
|
if (lua.equation(0, cancel_qty) == false) then
|
strSetAttr = strSetAttr .. ", F_ACC_C_QTY = F_ACC_C_QTY + " .. cancel_qty
|
end
|
nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "Outbound_Detail", strCondition, strSetAttr)
|
if (nRet ~= 0) then
|
return 1, "设置【Outbound_Detail】累计出库数量失败!" .. strRetInfo
|
end
|
end
|
end
|
if (dc_detail.wave_cls_id == 'Outbound_Wave') then
|
if (dc_detail.wave_no ~= nil and dc_detail.wave_no ~= '') then
|
strCondition = "S_WAVE_NO = '" .. dc_detail.wave_no .. "' AND S_ITEM_CODE = '" .. dc_detail.item_code .. "'"
|
strSetAttr = "F_ACC_O_QTY = F_ACC_O_QTY +" .. dc_detail.acc_p_qty
|
if (lua.equation(0, cancel_qty) == false) then
|
strSetAttr = strSetAttr .. ", F_ACC_C_QTY = F_ACC_C_QTY + " .. cancel_qty
|
end
|
nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "OW_Detail", strCondition, strSetAttr)
|
if (nRet ~= 0) then
|
return 1, "设置【OW_Detail】累计出库数量失败!" .. strRetInfo
|
end
|
end
|
end
|
end
|
|
return 0
|
end
|
|
--[[
|
根据物料/货品号创建指定出库作业（可能会有多个容器）
|
SOO -- Specify Outbound Operation
|
输入参数:
|
so_no -- 指定出库指令号
|
item_code -- 物料货品编码
|
to_loc_code -- 出库口货位
|
op_def_name -- 作业类型
|
source_sys -- 来源系统
|
--]]
|
function wms_out.Create_SOO_ByMaterial(strLuaDEID, station, so_no, area_code, item_code, to_loc_code, op_def_name, source_sys)
|
local nRet, strRetInfo, n
|
|
-- step1：输入参数合法性检查
|
if (so_no == nil or so_no == '') then
|
return 1, "so_no 必须有值!"
|
end
|
if (area_code == nil or area_code == '') then
|
return 1, "area_code 必须有值!"
|
end
|
if (source_sys == nil) then
|
source_sys = ""
|
end
|
if (item_code == nil or item_code == '') then
|
return 1, "item_code 必须有值!"
|
end
|
if (to_loc_code == nil or to_loc_code == '') then
|
return 1, "loc_code 必须有值!"
|
end
|
if (station == nil or station == '') then
|
return 1, "station 必须有值!"
|
end
|
|
|
-- 判断目标货位是否正确
|
local to_loc
|
nRet, to_loc = wms_wh.GetLocInfo(to_loc_code)
|
if (nRet ~= 0) then
|
return 1, '获取货位信息失败! ' .. to_loc
|
end
|
|
-- 通过货品找出货品所在容器
|
local str_good_condition
|
local success, queryInfo, dataSet
|
local nPage, nPageCount
|
local cntr_code
|
|
str_good_condition = "S_ITEM_CODE = '" .. item_code .. "' AND S_CNTR_CODE in " ..
|
"(select S_CNTR_CODE from TN_Loc_Container with (NOLOCK) where S_LOC_CODE in (select S_CODE from TN_Location with (NOLOCK) where S_AREA_CODE = '" .. area_code .. "'))"
|
|
-- 查询有该货品的容器编号
|
-- 获取货品所在容器（考虑到有比较极端情况容器数量大于1000因此采用 queryDataObjAttr2 ）
|
nRet, strRetInfo = mobox.queryDataObjAttr2(strLuaDEID, "INV_Detail", str_good_condition, strOrder, 100, "S_CNTR_CODE")
|
if (nRet ~= 0) then
|
return 1, "queryDataObjAttr2: " .. strRetInfo
|
end
|
if (strRetInfo == '') then
|
return 0
|
end
|
|
lua.Debug(strLuaDEID, debug.getinfo(1), "货品所在容器 -- >", strRetInfo)
|
|
success, queryInfo = pcall(json.decode, strRetInfo)
|
if (success == false) then
|
return 2, "queryDataObjAttr2 返回结果啊非法的JSON格式!"
|
end
|
|
queryID = queryInfo.queryID
|
nPageCount = queryInfo.pageCount
|
nPage = 1
|
dataSet = queryInfo.dataSet -- 查询出来的数据集
|
local count = 0
|
while (nPage <= nPageCount) do
|
for i = 1, #dataSet do
|
cntr_code = dataSet[i].attrs[1].value
|
nRet, strRetInfo = create_so_cntr_operation(strLuaDEID, station, so_no, cntr_code, to_loc, item_code, source_sys)
|
if (nRet ~= 0) then
|
wms.wms_AbortCntrLockTrans(so_no)
|
return 1, "create_so_cntr_operation! " .. strRetInfo
|
end
|
count = count + 1
|
end
|
|
nPage = nPage + 1
|
if (nPage <= nPageCount) then
|
-- 取下一页
|
nRet, strRetInfo = mobox.queryDataObjAttr2(queryID, nPage)
|
if (nRet ~= 0) then
|
wms.wms_AbortCntrLockTrans(so_no)
|
return 2, "queryDataObjAttr2失败! nPage=" .. nPage .. " " .. strRetInfo
|
end
|
queryInfo = json.decode(strRetInfo)
|
dataSet = queryInfo.dataSet
|
end
|
end
|
|
|
-- 设置 Specify_Outbound 状态为执行 N_B_STATE = 2 执行中
|
strUpdateSql = "N_B_STATE = 2, N_CNTR_TOTAL = " .. count
|
strCondition = "S_SO_NO = '" .. so_no .. "'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "Specify_Outbound", strCondition, strUpdateSql)
|
if (nRet ~= 0) then
|
wms.wms_AbortCntrLockTrans(so_no)
|
return 2, "更新【Specify_Outbound】信息失败!" .. strRetInfo
|
end -- create_so_cntr_operation 有锁容器操作
|
wms.wms_CommitCntrLockTrans(so_no)
|
return 0
|
end
|
|
-- 根据体积进行排序，体积大的放前面
|
local function dc_detail_sort_by_volume(t1, t2)
|
return t1.volume * t1.qty > t2.volume * t2.qty
|
end
|
|
local function picking_box_sort_by_volume(t1, t2)
|
return t1.box_volume > t2.box_volume
|
end
|
|
--[[
|
把配盘明细批分到拣料箱里
|
输入参数:
|
d_cntr_detail_list ( 某个出库单相关的配盘明细 )
|
pick_box_code 拣料箱编码，如果有多个拣料箱用 ; 分割
|
new_d_cntr_detail_list 批分结果
|
注意：
|
如果出库的是出库波次，下面这个双份没考虑根据出库单进行批分拣料箱
|
--]]
|
function wms_out.Split_CD_Detial_ByPickingBox(strLuaDEID, d_cntr_detail_list, picking_box_code, new_d_cntr_detail_list)
|
|
local seg = lua.split(picking_box_code, ",")
|
|
-- 初始化拣料箱
|
local picking_box_list = {}
|
local box_volume = wms_base.Get_nConst(strLuaDEID, "拣料箱体积")
|
local pick_box_num = #seg
|
for n = 1, pick_box_num do
|
local picking_box = {
|
picking_box_code = seg[n],
|
box_volume = box_volume,
|
}
|
table.insert(picking_box_list, picking_box)
|
end
|
|
-- 批分到不同的拣料箱
|
local find, volume, qty, need_split_qty
|
|
for n = 1, #d_cntr_detail_list do
|
find = false
|
volume = d_cntr_detail_list[n].qty * d_cntr_detail_list[n].volume
|
for m = 1, pick_box_num do
|
if (volume <= picking_box_list[m].box_volume) then
|
d_cntr_detail_list[n].pick_box_code = picking_box_list[m].picking_box_code
|
picking_box_list[m].box_volume = picking_box_list[m].box_volume - volume
|
find = true
|
break
|
end
|
end
|
if (find) then
|
table.insert(new_d_cntr_detail_list, d_cntr_detail_list[n])
|
else
|
-- 需要批分，把一条【配盘明细】根据拣料箱
|
need_split_qty = d_cntr_detail_list[n].qty -- 需要批分的数量
|
|
for m = 1, pick_box_num do
|
if (picking_box_list[m].box_volume > 0) then
|
qty = math.floor(picking_box_list[m].box_volume / d_cntr_detail_list[n].volume)
|
if (need_split_qty < qty) then
|
qty = need_split_qty
|
end
|
need_split_qty = need_split_qty - qty
|
|
local d_cntr_detail = {
|
item_code = d_cntr_detail_list[n].item_code,
|
item_name = d_cntr_detail_list[n].item_name,
|
cntr_code = d_cntr_detail_list[n].cntr_code,
|
batch_no = d_cntr_detail_list[n].batch_no,
|
cell_no = d_cntr_detail_list[n].cell_no,
|
station = d_cntr_detail_list[n].station,
|
|
serial_no = d_cntr_detail_list[n].serial_no,
|
item_spec = d_cntr_detail_list[n].item_spec,
|
end_user = d_cntr_detail_list[n].end_user,
|
owner = d_cntr_detail_list[n].owner,
|
uom = d_cntr_detail_list[n].uom,
|
volume = d_cntr_detail_list[n].volume,
|
weight = d_cntr_detail_list[n].weight,
|
wh_code = d_cntr_detail_list[n].wh_code,
|
area_code = d_cntr_detail_list[n].area_code,
|
loc_code = d_cntr_detail_list[n].loc_code,
|
|
cg_detail_id = d_cntr_detail_list[n].cg_detail_id,
|
bs_type = d_cntr_detail_list[n].bs_type,
|
bs_no = d_cntr_detail_list[n].bs_no,
|
bs_row_no = d_cntr_detail_list[n].bs_row_no,
|
wave_no = d_cntr_detail_list[n].wave_no,
|
wave_cls_id = d_cntr_detail_list[n].wave_cls_id,
|
|
pick_box_code = picking_box_list[m].picking_box_code,
|
qty = qty
|
}
|
picking_box_list[m].box_volume = picking_box_list[m].box_volume - qty * d_cntr_detail_list[n].volume
|
table.insert(new_d_cntr_detail_list, d_cntr_detail)
|
end
|
if (need_split_qty == 0) then
|
break
|
end
|
end
|
|
-- 如果还有 need_split_qty 说明无法分配拣货箱，这是有问题的需要报警
|
if (need_split_qty > 0) then
|
return 1, "货品'" .. d_cntr_detail_list[n].item_code .. "'因为体积的原因无法分配拣料箱!"
|
end
|
end
|
|
end
|
return 0
|
end
|
|
--[[
|
根据配盘明细创建【拣料箱】/【拣料箱明细】
|
输入参数:
|
dc_detail_id 配盘明细标识
|
pc_code 拣料箱编码
|
qty -- 拣料数量
|
返回
|
nRet 0 成功 非0 失败
|
pc_detail_data -- Picking_CNTR_Detail 数据对象（数据库表属性模式）
|
--]]
|
function wms_out.Creat_Picking_CNTR_Detail(strLuaDEID, dc_detail_id, qty, pc_code, pc_cell_no)
|
local nRet, strRetInfo
|
local pc_detail_data = {}
|
|
if dc_detail_id == nil or dc_detail_id == '' then
|
return 1, "wms_out.Creat_Picking_CNTR_Detail 输入参数中 dc_detail_id 必须有值！"
|
end
|
if pc_code == nil or pc_code == '' then
|
return 1, "wms_out.Creat_Picking_CNTR_Detail 输入参数中 pc_code 必须有值!"
|
end
|
if qty == nil or qty <= 0 then
|
return 1, "wms_out.Creat_Picking_CNTR_Detail 输入参数中 qty 不合规!"
|
end
|
if pc_cell_no == nil then
|
pc_cell_no = ''
|
end
|
|
-- 获取配盘明细对象
|
local dc_detail_data
|
dc_detail_id = lua.trim_guid_str(dc_detail_id)
|
nRet, dc_detail_data = m3.GetDataObject2(strLuaDEID, "Distribution_CNTR_Detail", dc_detail_id)
|
if (nRet ~= 0) then
|
lua.Stop(strLuaDEID, dc_detail_data)
|
return
|
end
|
|
-- 首先检查一下是否存在没封箱的【拣料箱】，如果不存在需要先创建
|
local picking_cntr
|
local strCondition = "N_B_STATE = " .. PICKING_CNTR_STATE.WaitPicking .. " AND S_CNTR_CODE = '" .. pc_code .. "'"
|
nRet, picking_cntr = m3.GetDataObjByCondition(strLuaDEID, "Picking_CNTR", strCondition)
|
if (nRet == 1) then
|
-- 不存在需要新增【拣料箱】
|
local loc_code
|
nRet, loc_code = wms_cntr.Get_Container_Loc(strLuaDEID, pc_code)
|
if nRet ~= 0 then
|
return 1, "wms_cntr.Get_Container_Loc 失败!" .. loc_code
|
end
|
picking_cntr = m3.AllocObject(strLuaDEID, "Picking_CNTR")
|
picking_cntr.cntr_code = pc_code
|
picking_cntr.bs_type = dc_detail_data.S_BS_TYPE
|
picking_cntr.bs_no = dc_detail_data.S_BS_NO
|
picking_cntr.station = dc_detail_data.S_STATION_NO
|
picking_cntr.loc_code = loc_code
|
nRet, picking_cntr = m3.CreateDataObj(strLuaDEID, picking_cntr)
|
if (nRet ~= 0) then
|
return 2, "创建【拣料箱】失败!" .. picking_cntr
|
end
|
elseif nRet ~= 0 then
|
return 2, picking_cntr
|
end
|
|
pc_detail_data = m3.AllocObject2(strLuaDEID, "Picking_CNTR_Detail")
|
pc_detail_data.S_PC_NO = picking_cntr.pc_no
|
for m = 1, #DC_DETAIL_ATTRS do
|
pc_detail_data[DC_DETAIL_ATTRS[m]] = dc_detail_data[DC_DETAIL_ATTRS[m]]
|
end
|
pc_detail_data.S_CNTR_CODE = pc_code
|
pc_detail_data.S_CELL_NO = pc_cell_no
|
pc_detail_data.F_QTY = qty
|
pc_detail_data.G_DC_DETAIL_ID = dc_detail_id
|
nRet, pc_detail_data = m3.CreateDataObj2(strLuaDEID, pc_detail_data)
|
if (nRet ~= 0) then
|
return 2, "创建【拣料箱明细】失败!" .. pc_detail_data
|
end
|
|
return 0, pc_detail_data
|
end
|
|
return wms_out
|
