--[[
|
编码: JX-58-12
|
名称: 入库波次-强制完成
|
作者：HAN
|
日期：2025-2-14
|
|
入口函数： ForceFinish
|
|
功能说明:
|
入库波次强制完成
|
-- 首先判断只有 未组盘/组盘/执行/暂停 状态的入库波次才能做 强制完成操作
|
不同状态的入库波次 强制完成的处理逻辑不一样
|
0 -- 未组盘
|
-- +关闭数量
|
-- 状态设置为关闭
|
1 -- 已组盘/暂停
|
-- 删除组盘对象，释放已经分配的料格
|
-- +关闭数量
|
-- 状态设置为关闭
|
2 -- 执行
|
-- 检测所以目前该波次创建的作业是否有在执行的，有设置波次状态 = 关闭中 需要等待这些作业完成后才能关闭
|
-- 删除等待启动的作业
|
-- 删除组盘对象，释放已经分配的料格
|
-- +关闭数量
|
-- 状态设置为关闭
|
|
-- 判断该入库波次的作业是否还有正在执行中的作业，如果有 入库波次的状态 设置为 关闭中
|
等这个入库波次正在执行的作业都完成后，入库波次状态自动该为 关闭
|
|
-- 如果已经没有正在执行中的入库作业，入库波次的状态设置为 关闭
|
-- 并且在如果波次明细中补全 关闭数量，确保计划入库数量 = 关闭数量+入库数量
|
-- 触发入库波次进行完工回报
|
|
更改记录:
|
|
--]]
|
|
wms_op = require( "wms_operation" )
|
wms_cntr = require( "wms_container" )
|
jx_base = require( "jx_base" )
|
|
function ForceFinish ( strLuaDEID )
|
local nRet, strRetInfo
|
local objs
|
|
-- step1 获取当前点中的作业
|
nRet, objs = m3.GetSysDataJson( strLuaDEID )
|
if ( nRet ~=0 ) then lua.Error( strLuaDEID, debug.getinfo(1), objs ) end
|
-- [{"id":"","attrs":[{"attr":"","value":""},..]},..]
|
local nCount = #objs
|
if (nCount == 0) then return end
|
|
local strObjJson, data_objs
|
local n, data_attrs
|
local strCondition
|
local success
|
local indound_wave = {}
|
for n = 1, nCount do
|
nRet, indound_wave = m3.ObjAttrStrToLuaObj( "Inbound_Wave", lua.table2str( objs[n].attrs ) )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "objAttrsToLuaJson (Inbound_Wave) 返回的的JSON格式不合法 !"..indound_wave ) end
|
if ( indound_wave.b_state == 0 or indound_wave.b_state == 1) then
|
-- 0 未配盘 1 -- 组盘
|
-- 把入库单设置为完成，并且关闭数量=入库数量
|
nRet, strRetInfo = jx_base.Set_Inbound_Wave_Force_Finish( strLuaDEID, indound_wave.wave_no )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo ) end
|
elseif ( indound_wave.b_state == 2 or indound_wave.b_state == 5 ) then
|
-- 2/执行 5/暂停
|
-- 判断这个入库波次的作业是否还有在执行中的，如果有就不能马上关闭，只能设置为关闭中，等执行中的作业完成后才能设置为关闭，这个另外程序来处理
|
-- 判断是否有存在正在执行的作业 N_B_STATE = 1
|
strCondition = "S_BS_TYPE = 'Inbound_Wave' AND S_BS_NO = '"..indound_wave.wave_no.."' AND N_B_STATE = 1"
|
nRet, strRetInfo = mobox.existThisData( strLuaDEID, "Operation", strCondition )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo ) end
|
if ( strRetInfo == "yes" ) then
|
-- 存在正在执行的作业
|
strCondition = "S_WAVE_NO = '"..indound_wave.wave_no.."'"
|
strUpdateSql = "N_B_STATE = 6 " -- 关闭中
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Inbound_Wave", strCondition, strUpdateSql )
|
if ( nRet ~= 0 ) then
|
lua.Error( strLuaDEID, debug.getinfo(1), "更新【入库波次】信息失败!"..strRetInfo )
|
end
|
else
|
-- 已经没有正在执行的作业
|
nRet, strRetInfo = jx_base.Set_Inbound_Wave_Force_Finish( strLuaDEID, indound_wave.wave_no )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo ) end
|
end
|
-- 把作业状态 = 等待，等待前 的作业状态设置为 取消
|
strCondition = "S_BS_TYPE = 'Inbound_Wave' AND S_BS_NO = '"..indound_wave.wave_no.."' AND ( N_B_STATE = 0 or N_B_STATE = 6 or N_B_STATE = 8 )"
|
strUpdateSql = "N_B_STATE = 7 "
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Operation", strCondition, strUpdateSql )
|
if ( nRet ~= 0 ) then
|
lua.Error( strLuaDEID, debug.getinfo(1), "更新【作业】信息失败!"..strRetInfo )
|
end
|
end
|
end
|
|
local action = {}
|
if ( nCount == 1 ) then
|
-- 如果就是一行刷新当前行
|
action = {
|
{
|
action_type = "refresh_cur_row", value = ""
|
}
|
}
|
else
|
action = {
|
{
|
action_type = "refresh", value = ""
|
}
|
}
|
end
|
nRet, strRetInfo = mobox.setAction(strLuaDEID, lua.table2str(action) )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "setAction错误: "..strRetInfo) end
|
end
|
