--[[
|
巨星二期WMS项目中Lua用到的一下公共函数
|
|
更改记录:
|
V3.0 HAN 20241127 增加对设备状态的获取
|
--]]
|
|
|
|
wms_wh = require ("wms_wh")
|
wms_out = require ("wms_outbound")
|
wms_alg = require ("wms_base_algorithm")
|
jx_api = require ("jx_external_api")
|
|
local jx_base = {_version = "0.1.1"}
|
|
--[[
|
1# GetBoxStyle 根据物料的尺寸计算该物料适配的料箱规格
|
2# Generate_Batch_No 生成货品储存时用的批次号，同一个货品在一个料格要换一次批次号用顺序号解决
|
3# Get_StorageCache_Loc 获取输送线存储缓存区货位
|
|
5# Get_Usable_Lane 获取可用巷道（有些堆垛机故障后这些巷道会不可用）
|
6# Get_Station_ExtData 获取机台的扩展数据(里面有mac地址，货位，去向库区等)
|
7# Get_Usable_Lane 获取机台的货位
|
8# Get_EmptyBox_Loc ***获取指定库区内的空料箱
|
9# Organize_CNTR_PostProcess 组盘入库后处理
|
]]
|
|
--//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
|
-- 根据物料的长中短尺寸计算适用料箱
|
-- long 长边 middle 中边 short 短边
|
-- 返回参数：
|
-- nRet 0 成功 非0失败
|
-- box_style
|
function jx_base.GetBoxStyle( strLuaDEID, long, middle, short )
|
local nRet, strRetInfo
|
|
-- 校验输入参数
|
if ( long == nil or long <= 0 or long >= 60) then return 1, "长边值不符合规范! 长边不能超过 60 " end
|
if ( middle == nil or middle <= 0 or middle >= 40) then return 1, "中边值不符合规范! 中边不能超过 40 " end
|
if ( short == nil or short <= 0 or short >= 30) then return 1, "短边边值不符合规范! 短边不能超 30 " end
|
if ( middle > long or short > middle ) then return 1, "长中短边顺序不对!" end
|
|
-- 计算料箱型号
|
if ( long < 20 ) then
|
return 0, '["A","B","C","D","E"]'
|
elseif ( long >= 20 and long < 30) then
|
if ( middle < 20 ) then
|
return 0, '["A","B","C","D","E"]'
|
elseif ( middle >= 20 and middle < 30 ) then
|
if ( short < 20 ) then
|
return 0, '["A","B","C","D"]'
|
else
|
return 0, '["A","B"]'
|
end
|
end
|
elseif ( long >= 30 and long < 40) then
|
if ( middle < 20 ) then
|
return 0, '["A","B","C"]'
|
elseif ( middle >= 20 and middle < 30 ) then
|
if ( short < 20 ) then
|
return 0, '["A","B","C"]'
|
else
|
return 0, '["A","B"]'
|
end
|
elseif ( middle >= 30 and middle < 40 ) then
|
return 0, '["A"]'
|
end
|
elseif ( long >= 40 and long < 60) then
|
return 0, '["A"]'
|
end
|
return 1, "长边参数不对!"
|
end
|
--//////////////////////////////////////////////////////////////////////////
|
-- 生成货品储存时用的批次号，同一个货品在一个料格要换一次批次号用顺序号解决
|
function jx_base.Generate_Batch_No( item_code )
|
local nRet, strRetInfo
|
|
if ( item_code == '' or item_code == nil ) then return 1, "generate_batch_no 输入参数必须有值" end
|
local strCode = ''
|
local strHeader = item_code..'_'..os.date("%y%m%d")..'-'
|
nRet, strCode = mobox.getSerialNumber( "入库批次", strHeader, 3 )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), '申请入库批次号失败!'..strCode ) end
|
local seg = lua.split( strCode, "_" )
|
return 0, seg[2]
|
end
|
|
--[[
|
获取 area_code 库区里可使用的堆垛机设备所在的巷道
|
--]]
|
function jx_base.Get_Usable_Lane( strLuaDEID, area_code )
|
local nRet, strRetInfo
|
|
if ( area_code == nil or area_code == '') then
|
return 1, "jx_base.Get_Usable_Lane 输入参数 area_code不能为空!"
|
end
|
local stacker_dev = wms_base.Get_sConst( strLuaDEID, area_code.."-堆垛机设备" )
|
end
|
|
-- 获取 ‘机台-XX’ 常量并且解析成一个 站台扩展属性的 table
|
function jx_base.Get_Station_ExtData( strLuaDEID, station_code )
|
if ( station_code == nil or station_code == '') then
|
return 1, "jx_base.Get_Station_ExtData 函数中 station_code 不能为空!"
|
end
|
-- 通过盘点站台获取出库终点货位
|
local station_info = wms_base.Get_sConst( strLuaDEID, "机台-"..station_code, 1 )
|
if ( station_info == '' ) then
|
return 1, "机台-"..station_code.." 常量中没有定义信息, 或没定义这个机台常量!"
|
end
|
local staion_attr = json.decode( station_info )
|
|
return 0, staion_attr
|
end
|
|
-- 获取 ‘机台-XX’ 所在货位
|
function jx_base.Get_Station_Loc( strLuaDEID, station_code )
|
local nRet, station_data
|
nRet, station_data = jx_base.Get_Station_ExtData( strLuaDEID, station_code )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), station_data ) end
|
return station_data.loc_code
|
end
|
|
--[[
|
获取某个库区内设备的状态（在JX项目中特指库区内的堆垛机状态）
|
输入参数:
|
area_code -- 库区编码
|
station -- 入库时的扫码点，可以不输入
|
|
返回参数:
|
nRet = 0 成功 非零 失败
|
stacker_dev = [{"dev_no"::xxx",lane:1,enable:0/1,cntr_num:0}]
|
-- cntr_num 巷道入库接驳位容器数量
|
-- lane 巷道号
|
-- dev_no 堆垛机号
|
--]]
|
function jx_base.Get_stacker_dev_state( strLuaDEID, area_code, station )
|
local nRet, strRetInfo
|
if ( station == nil ) then station = '' end
|
|
-- 获取 area_code 库区堆垛机设备工作状态，确定哪些巷道可以使用
|
strRetInfo = wms_base.Get_sConst( strLuaDEID, "库区"..area_code.."-堆垛机设备" )
|
if ( strRetInfo == '') then
|
return 1, "常量'库区"..area_code.."-堆垛机设备' 不能为空! "
|
end
|
--[{"dev_no"::xxx",lane:1,enable:false/true}]
|
local stacker_dev = json.decode( strRetInfo )
|
local n, m
|
local dev_codes = ''
|
for n = 1, #stacker_dev do
|
dev_codes = dev_codes..stacker_dev[n].dev_no..","
|
end
|
if ( dev_codes == '') then
|
return 1, "库区'"..area_code.."'没有定义设备!"
|
end
|
dev_codes = lua.trim_laster_char( dev_codes )
|
|
-- 调用WCS接口获取设备状态
|
-- [{"DVC_NO":"TC21","IS_USE":0/1,"CON_NUM":1},...]
|
nRet, dev_state = jx_api.JW_DVC_State( strLuaDEID, dev_codes, station )
|
if ( nRet ~= 0 ) then return nRet, dev_state end
|
local find
|
for n = 1, #stacker_dev do
|
find = false
|
for m = 1, #dev_state do
|
if ( stacker_dev[n].dev_no == dev_state[m].DVC_NO ) then
|
find = true
|
stacker_dev[n].enable = lua.Get_NumAttrValue( dev_state[m].IS_USE )
|
stacker_dev[n].cntr_num = lua.Get_NumAttrValue( dev_state[m].CON_NUM )
|
break
|
end
|
end
|
if ( find == false ) then
|
return 1, "WCS返回的设备状态中没有编码='"..stacker_dev[n].dev_no.."'的设备状态！"
|
end
|
end
|
return 0, stacker_dev
|
end
|
|
-- 获取库区库可用的堆垛机巷道号 -- 1, 2, 4
|
function jx_base.Get_Available_Lane( strLuaDEID, area_code )
|
local nRet, stacker_dev
|
|
nRet, stacker_dev = jx_base.Get_stacker_dev_state( strLuaDEID, area_code )
|
if ( nRet ~= 0 ) then return nRet, stacker_dev end
|
|
local n
|
local lane = ''
|
for n = 1, #stacker_dev do
|
if ( stacker_dev[n].enable == 1 ) then
|
lane = lane..stacker_dev[n].lane..","
|
end
|
end
|
lane = lua.trim_laster_char( lane )
|
return 0, lane
|
end
|
|
--//////////////////////////////////////////////////////////////////////////
|
local function get_lane_connect_loc( lane_connect_loc_set, lane_no )
|
local n
|
|
for n = 1, #lane_connect_loc_set do
|
if ( lane_connect_loc_set[n].lane == lane_no ) then
|
return lane_connect_loc_set[n]
|
end
|
end
|
return ''
|
end
|
|
-- 排序
|
local function roadway_loc_sort( loc1, loc2 )
|
if ( loc1.abc_cls < loc2.abc_cls ) then
|
return true
|
elseif ( loc1.abc_cls == loc2.abc_cls ) then
|
-- 距离入口近的优先
|
return loc1.weight < loc2.weight
|
end
|
return false
|
end
|
|
-- 巷道任务+空料箱排序
|
local function lane_list_sort( loc1, loc2 )
|
if ( loc1.abc_cls < loc2.abc_cls ) then
|
return true
|
elseif ( loc1.abc_cls == loc2.abc_cls ) then
|
-- 巷道空位多优先
|
return loc1.roadway_empty_num > loc2.roadway_empty_num
|
end
|
return false
|
end
|
|
local function task_num_abc_cls( lane_list )
|
local max_task_num = 0
|
local n, nCount
|
|
nCount = #lane_list
|
if ( 0 == nCount ) then return 0 end
|
for n = 1, nCount do
|
if ( lane_list[n].task_num > max_task_num ) then
|
max_task_num = lane_list[n].task_num
|
end
|
end
|
if ( max_task_num <= 3 ) then
|
for n = 1, nCount do
|
if ( lane_list[n].task_num == 0 ) then
|
lane_list[n].abc_cls = "A"
|
elseif ( lane_list[n].task_num >= 2 ) then
|
lane_list[n].abc_cls = "C"
|
else
|
lane_list[n].abc_cls = "B"
|
end
|
end
|
else
|
for n = 1, nCount do
|
if ( lane_list[n].task_num == 0 ) then
|
lane_list[n].abc_cls = "A"
|
elseif ( lane_list[n].task_num < max_task_num/2 ) then
|
lane_list[n].abc_cls = "B"
|
else
|
lane_list[n].abc_cls = "C"
|
end
|
end
|
end
|
table.sort( lane_list, lane_list_sort )
|
end
|
|
-- 计算料箱库入库区货位（任务均衡），考虑巷道货位均衡, 基本原则是: 巷道任务少优先，巷道空货位多的优先
|
-- 返回入库缓存区货位和巷道内存储货位（2个货位）
|
-- V2.0 HAN 20241120 根据站台位置获取相应的 堆垛机入库缓存区，增加一个站台编码 station
|
function jx_base.Get_StorageCache_Loc( strLuaDEID, station )
|
local nRet, strRetInfo
|
local task_type = wms_base.Get_nConst( strLuaDEID, "任务类型-输送线入库搬运" )
|
|
local station_attr
|
--[[
|
station_attr = {"loc_code":"S-A","entry_area_name":"A","code":"A","factory":"0001","storage_area":"K2","entry_area_code":"K4","mac":"A"}
|
entry_area -- 入库接驳区 storage_area -- 存储区 loc_orde = 0 根据列顺序 1 -- 倒序
|
]]
|
nRet, station_attr = jx_base.Get_Station_ExtData( strLuaDEID, station )
|
if ( nRet ~= 0 ) then return 2, station_attr end
|
local loc_order = lua.Get_NumAttrValue( station_attr.loc_order )
|
|
-- 站台指定的入库接驳区
|
local storage_cache_arae = lua.Get_StrAttrValue( station_attr.entry_area_code )
|
if ( storage_cache_arae == '') then
|
return 2, "'机台-"..station.."'没有定义入库口区域编码信息!"
|
end
|
|
-- 获取入库接驳区货位的使用情况
|
local strCondition = "C_ENABLE = 'Y' AND S_AREA_CODE = '"..storage_cache_arae.."'"
|
local strOrder = "S_CODE"
|
local loc_objs
|
local lane_connect_loc_set = {}
|
nRet, loc_objs = m3.QueryDataObject( strLuaDEID, "Location", strCondition, strOrder )
|
if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), "获取【Location】信息失败! " .. loc_objs ) end
|
|
for n = 1, #loc_objs do
|
obj_attrs = m3.KeyValueAttrsToObjAttr(loc_objs[n].attrs)
|
-- 这些货位里把这个货位对应的巷道信息保存在 S_EXT_ATTR
|
roadway = lua.StrToNumber( obj_attrs.S_EXT_ATTR )
|
if ( roadway <= 0 or roadway > 4 ) then
|
return 2, "输送线入库缓存位'"..obj_attrs.S_CODE.."'没有定义对应的巷道号或巷道号不合法"
|
end
|
local connect_loc = {
|
lane = roadway,
|
loc_code = obj_attrs.S_CODE,
|
--capacity = lua.StrToNumber( obj_attrs.N_CAPACITY ),
|
--cur_num = lua.StrToNumber( obj_attrs.N_CURRENT_NUM ),
|
}
|
table.insert( lane_connect_loc_set, connect_loc )
|
end
|
|
lua.Debug( strLuaDEID, debug.getinfo(1), "jx_base.Get_StorageCache_Loc-->lane_connect_loc_set", lane_connect_loc_set)
|
|
-- 站台指定的入库存储区
|
local storage_area = lua.Get_StrAttrValue( station_attr.storage_area )
|
if ( storage_area == '') then
|
return 2, "'机台-"..station.."'没有定义存储区编码信息!"
|
end
|
-- 获取库区 storage_area 内设备状态
|
local stacker_dev
|
nRet, stacker_dev = jx_base.Get_stacker_dev_state( strLuaDEID, storage_area, station )
|
if ( nRet ~= 0 ) then return 2, stacker_dev end
|
|
lua.Debug( strLuaDEID, debug.getinfo(1), "jx_base.Get_StorageCache_Loc-->stacker_dev", stacker_dev)
|
|
local n, m
|
local storage_cache_list = {}
|
local obj_attrs
|
local task_num, max_task_num, empty_loc_num
|
local loc_count = #loc_objs
|
local loc_index
|
local connect_loc
|
|
-- 获取立库巷道口货位的基本信息，保存到 storage_cache_list
|
max_task_num = 0
|
for n = 1, #stacker_dev do
|
-- 获取设备所在巷道
|
roadway = stacker_dev[n].lane
|
if ( roadway <= 0 or roadway > 4 ) then
|
return 2, "库区"..storage_area.."中的巷道号只能在1~4!"
|
end
|
-- enable = 1 表示巷道堆垛机可用
|
if ( stacker_dev[n].enable == 1 ) then
|
task_num = stacker_dev[n].cntr_num
|
if ( task_num > max_task_num ) then
|
max_task_num = task_num
|
end
|
|
-- 查询货位启用、空货位、在本巷道、没被锁的货位数量
|
strCondition = "N_ROADWAY = "..roadway.." AND S_AREA_CODE = '"..storage_area.."' AND C_ENABLE = 'Y' AND N_CURRENT_NUM = 0 AND N_LOCK_STATE = 0"
|
nRet, strRetInfo = mobox.getDataObjCount( strLuaDEID, "Location", strCondition )
|
if ( nRet ~= 0 ) then return nRet, strRetInfo end
|
empty_loc_num = lua.StrToNumber( strRetInfo )
|
if ( empty_loc_num > 0 ) then
|
-- 获取该巷道的 入库接驳位
|
loc_index = 0
|
for m = 1, #lane_connect_loc_set do
|
if ( lane_connect_loc_set[m].lane == roadway ) then
|
loc_index = m
|
break
|
end
|
end
|
if ( loc_index ~= 0 ) then
|
local cache_loc = {
|
loc_code = lane_connect_loc_set[loc_index].loc_code,
|
roadway = roadway,
|
task_num = task_num, -- 任务数量
|
roadway_empty_num = empty_loc_num, -- 对应巷道的空货位数量
|
abc_cls = "" -- ABC 分类
|
}
|
table.insert( storage_cache_list, cache_loc )
|
end
|
end
|
end
|
end
|
|
lua.Debug( strLuaDEID, debug.getinfo(1), "jx_base.Get_StorageCache_Loc-->storage_cache_list1", storage_cache_list)
|
|
-- 计算 各入库缓存区的 任务数量 ABC 分类值 没有任务的为 A，任务数大于 0 小于 max_task_num/2 的为B，其余为 C
|
local nCount = #storage_cache_list
|
if ( nCount == 0 ) then
|
return 1, "系统无法分配货位!"
|
end
|
|
-- 排序 abc_cls 按ABC排序，同样等级的abc_cls 根据roadway_empty_num排序，空货位多的在前面
|
task_num_abc_cls( storage_cache_list )
|
|
lua.Debug( strLuaDEID, debug.getinfo(1), "jx_base.Get_StorageCache_Loc-->storage_cache_list2", storage_cache_list)
|
|
-- 获取巷道内空货位
|
local storage_arae = wms_base.Get_sConst( strLuaDEID, "料箱库存储区" )
|
local ret_loc
|
|
-- strLuaDEID, 库区, 巷道号, 货位排序方法, 顺序/倒序, 附加条件, 取货位数量
|
nRet, ret_loc = wms_alg.Get_Roadway_Empty_Loc( strLuaDEID, storage_arae, storage_cache_list[1].roadway, 0, loc_order, "", 1 )
|
|
if ( nRet ~= 0 ) then
|
return 1, "计算巷道"..storage_cache_list[1].roadway.."内货位失败!"..ret_loc
|
end
|
nRet, loc = wms_wh.GetLocInfo( ret_loc.loc_code )
|
if ( nRet ~= 0 ) then
|
return 1, "获取货位'"..ret_loc.loc_code.."'信息失败! "..loc
|
end
|
|
-- 返回 立库巷道口入库货位，巷道内存储货位
|
return 0, storage_cache_list[1].loc_code, ret_loc.loc_code
|
end
|
|
-- 获取一个空料箱货位
|
local function get_empty_box_location( strLuaDEID, trans_id, area_code, lane_list, box_type )
|
local nRet, strRetInfo, n
|
local nCount = #lane_list
|
|
-- 对巷道内任务数量进行重新分类
|
task_num_abc_cls( lane_list )
|
-- 取排列第一的exit_loc_list 所在巷道的空料箱
|
lua.Debug( strLuaDEID, debug.getinfo(1), "jx_base.Get_EmptyBox_Loc--->lane_list1", lane_list )
|
local roadway = 0
|
for n = 1, nCount do
|
if ( lane_list[n].roadway_empty_num > 0 ) then
|
roadway = lane_list[n].roadway
|
break
|
end
|
end
|
if ( roadway == 0 ) then return 1, "库区'"..area_code.."'没有空料箱!" end
|
|
-- 要联表查询的表
|
local strTable = "TN_Container a LEFT JOIN TN_Loc_Container b ON a.S_CODE = b.S_CNTR_CODE"
|
-- 要查询的属性
|
local strAttrs = "a.S_CODE, b.S_LOC_CODE"
|
|
-- 从指定的巷道获取巷道内 巨星空料箱，根据位置进行排序
|
strCondition = "a.N_EMPTY_FULL = 0 AND a.N_TYPE = "..box_type..
|
"AND a.S_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.."' AND N_ROADWAY = "..roadway.."))"..
|
"AND a.N_LOCK_STATE = 0 AND a.C_ENABLE = 'Y'"
|
strOrder = ""
|
nRet, strRetInfo = mobox.queryMultiTable(strLuaDEID, strAttrs, strTable, 1, strCondition, strOrder )
|
|
if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1),"QueryDataObject失败!"..strRetInfo ) end
|
if ( strRetInfo == '' ) then return 1, "库区'"..area_code.."'没有空料箱!" end
|
local ret_attr = json.decode(strRetInfo)
|
|
-- 巷道任务+1，这种批量分配的料箱还没创建任务，所以查Task是查不到巷道任务数量的
|
for n = 1, nCount do
|
if ( lane_list[n].roadway == roadway ) then
|
lane_list[n].task_num = lane_list[n].task_num + 1
|
lane_list[n].roadway_empty_num = lane_list[n].roadway_empty_num - 1
|
break
|
end
|
end
|
lua.Debug( strLuaDEID, debug.getinfo(1), "jx_base.Get_EmptyBox_Loc--->lane_list2", lane_list )
|
|
-- 返回: 巷道, 容器编码、货位编码
|
local cntr_code = ret_attr[1][1]
|
local loc_code = ret_attr[1][2]
|
nRet, strRetInfo = wms_cntr.Lock( strLuaDEID, cntr_code, 2, trans_id )
|
if ( nRet ~= 0 ) then return 2, strRetInfo end
|
return 0, roadway, cntr_code, loc_code
|
end
|
|
--[[
|
【关键函数】
|
空料箱货位计算, 基本原则是: 巷道任务少优先，巷道空料箱多的优先， 不锁容器
|
参数说明:
|
area_code -- 存储库区编码
|
trans_id -- 事务标识
|
box_type = 2 是给巨星WMS用的容器， 3 -- 是料箱给巨沃用的料箱
|
num -- 空料箱的个数缺省=1
|
返回参数：
|
nRet, roadway -- 巷道 cntr_code/料箱号, loc_code/货位号
|
]]
|
|
function jx_base.Get_EmptyBox_Loc( strLuaDEID, trans_id, area_code, box_type, num )
|
local nRet, strRetInfo
|
|
if ( area_code == nil or area_code == '') then
|
return 2, "jx_base.Get_EmptyBox_Loc 中参数 area_code 必须有值! "
|
end
|
if ( box_type == nil ) then
|
return 2, "jx_base.Get_EmptyBox_Loc 中参数 box_type 必须有值! "
|
end
|
if ( num == nil ) then num = 1 end
|
|
-- 获取库区内设备状态
|
nRet, stacker_dev = jx_base.Get_stacker_dev_state( strLuaDEID, area_code )
|
if ( nRet ~= 0 ) then return 2, stacker_dev end
|
|
local n, roadway
|
local lane_list = {} -- 巷道
|
local task_num, empty_box_num
|
|
-- 获取立库巷道口货位的基本信息，保存到 storage_cache_list
|
for n = 1, #stacker_dev do
|
-- 获取设备所在巷道
|
roadway = stacker_dev[n].lane
|
if ( roadway <= 0 or roadway > 4 ) then
|
return 2, "库区"..area_code.."中的巷道号只能在1~4!"
|
end
|
if ( stacker_dev[n].enable == 1 ) then
|
-- 获取该巷道未完成的任务数量
|
-- N_B_STATE < 3 表示任务的状态为 0等待/1已推送/2执行中, 任务的 area_code 的巷道 roadway
|
-- 任务包括进出的
|
strCondition = "N_B_STATE < 3 AND ( N_START_LANE = "..roadway.." or N_END_LANE = "..roadway..")"..
|
"AND ( S_START_AREA = '"..area_code.."' or S_END_AREA = '"..area_code.."')"
|
|
nRet, strRetInfo = mobox.getDataObjCount( strLuaDEID, "Task", strCondition )
|
if ( nRet ~= 0 ) then return nRet, strRetInfo end
|
task_num = lua.StrToNumber( strRetInfo )
|
|
-- 查询容器为空，满足类型条件，在某库区，某巷道
|
strCondition = "N_EMPTY_FULL = 0 AND N_TYPE = "..box_type..
|
"AND S_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.."' AND N_ROADWAY = "..roadway.."))"..
|
"AND N_LOCK_STATE = 0 AND C_ENABLE = 'Y'"
|
|
nRet, strRetInfo = mobox.getDataObjCount( strLuaDEID, "Container", strCondition )
|
if ( nRet ~= 0 ) then return nRet, strRetInfo end
|
empty_box_num = lua.StrToNumber( strRetInfo )
|
|
if ( empty_box_num > 0 ) then
|
local lane = {
|
roadway = roadway,
|
task_num = task_num, -- 任务数量
|
roadway_empty_num = empty_box_num, -- 对应巷道的空料箱数量
|
abc_cls = "" -- ABC 分类
|
}
|
table.insert( lane_list, lane )
|
end
|
end
|
end
|
|
-- 计算 各入库缓存区的 任务数量 ABC 分类值 没有任务的为 A，任务数大于 0 小于 max_task_num/2 的为B，其余为 C
|
local nCount = #lane_list
|
if ( nCount == 0 ) then
|
return 1, "库区'"..area_code.."'无法出空料箱!"
|
end
|
|
local empty_box_list = {}
|
for n = 1, num do
|
nRet, roadway, cntr_code, loc_code = get_empty_box_location( strLuaDEID, trans_id, area_code, lane_list, box_type )
|
if ( nRet == 0 ) then
|
local empty_box = {
|
roadway = roadway, cntr_code = cntr_code, loc_code = loc_code
|
}
|
table.insert( empty_box_list, empty_box )
|
else
|
if ( nRet > 1 ) then return 2, roadway end
|
end
|
end
|
return 0, empty_box_list
|
|
end
|
|
|
-- 输送线入库任务完成，系统自动创建一个堆垛机入库任务
|
function jx_base.ConveyorLineStorage_Task_Finish( strLuaDEID, task, operation )
|
local nRet, strRetInfo
|
|
-- 创建堆垛机入库任务
|
local new_task = m3.AllocObject(strLuaDEID,"Task")
|
|
new_task.op_code = operation.code -- 作业编码
|
new_task.source_sys = operation.source_sys -- 来源系统
|
new_task.op_name = operation.op_def_name
|
new_task.factory = operation.factory -- 工厂
|
new_task.bs_type = operation.bs_type
|
new_task.bs_no = operation.bs_no
|
new_task.type = wms_base.Get_nConst(strLuaDEID, "任务类型-堆垛机入库搬运")
|
new_task.cntr_code = task.cntr_code
|
-- 起点
|
new_task.start_wh_code = task.end_wh_code
|
new_task.start_area_code = task.end_area_code
|
new_task.start_loc_code = task.end_loc_code
|
-- 终点
|
new_task.end_wh_code = operation.end_wh_code
|
new_task.end_area_code = operation.end_area_code
|
new_task.end_loc_code = operation.end_loc_code
|
new_task.schedule_type = wms_base.Get_nConst(strLuaDEID, "调度类型-堆垛机") -- 设置调度类型
|
|
nRet, new_task = m3.CreateDataObj(strLuaDEID, new_task)
|
if (nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1),"创建堆垛机任务失败!"..new_task) end
|
|
return 0
|
end
|
|
--[[
|
根据站台位置创建一个入库作业，处理以下事情
|
-- 从立库中获取一个空货位
|
-- 创建一个作业
|
-- 给获取的空货位加入库锁
|
|
输入参数:
|
-- source_sys 来源系统
|
-- station 站台位置
|
-- cntr_code 容器号
|
-- op_def_name 作业定义名称
|
-- ext_info 扩展参数{orgc_no,bs_type,bs_no,cc_no,dc_no}
|
orgc_no 组盘用 cc_no 盘点 dc_no 分拣
|
返回:
|
nRet
|
operation
|
]]
|
|
function jx_base.Create_StorageOperation( strLuaDEID, source_sys, station, cntr_code, op_def_name, ext_info )
|
local nRet, strRetInfo
|
local loc_code = jx_base.Get_Station_Loc( strLuaDEID, station )
|
local loc
|
nRet, loc = wms_wh.GetLocInfo( loc_code )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), '获取货位信息失败! '..loc_code ) end
|
|
local operation = m3.AllocObject(strLuaDEID,"Operation")
|
operation.source_sys = source_sys
|
operation.start_wh_code = loc.wh_code
|
operation.start_area_code = loc.area_code
|
operation.start_loc_code = loc_code
|
|
-- 计算料箱入库货位，首先计算到哪个输送线入库缓存区
|
local str_end_loc_code, roadway_in_loc
|
nRet, roadway_in_loc, str_end_loc_code = jx_base.Get_StorageCache_Loc( strLuaDEID, station )
|
if ( nRet ~= 0 ) then
|
if ( nRet == 1 ) then
|
return 1, "jx_base.Get_StorageCache_Loc 失败!"..roadway_in_loc
|
end
|
lua.Error( strLuaDEID, debug.getinfo(1), roadway_in_loc )
|
end
|
local end_loc
|
nRet, end_loc = wms_wh.GetLocInfo( str_end_loc_code )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), '获取货位信息失败! '..str_end_loc_code ) end
|
operation.end_wh_code = end_loc.wh_code
|
operation.end_area_code = end_loc.area_code
|
operation.end_loc_code = str_end_loc_code
|
operation.ext_data = roadway_in_loc -- 巷道口入库缓存货位
|
|
operation.op_type = wms_base.Get_nConst(strLuaDEID, "作业类型-入库")
|
operation.op_def_name = op_def_name
|
operation.cntr_code = cntr_code
|
|
if ( ext_info ~= nil and ext_info ~= '') then
|
if ( ext_info.orgc_no ~= nil ) then
|
-- 有组盘的（先空料箱呼出）
|
operation.orgc_no = ext_info.orgc_no
|
end
|
if ( ext_info.cc_no ~= nil ) then
|
-- 盘点回库
|
operation.cc_no = ext_info.cc_no
|
end
|
if ( ext_info.dc_no ~= nil ) then
|
-- 盘点回库
|
operation.dc_no = ext_info.dc_no
|
end
|
operation.bs_type = lua.Get_StrAttrValue( ext_info.bs_type )
|
operation.bs_no = lua.Get_StrAttrValue( ext_info.bs_no )
|
end
|
|
nRet, operation = m3.CreateDataObj( strLuaDEID, operation )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), '创建【作业】失败!'..operation ) end
|
|
return 0, operation
|
end
|
|
--[[
|
得到当前登录人员的账号信息，并且获取登录人员的PC MAC地址，根据这个地址获取绑定的站台
|
返回一个json table
|
nRet, ret_value { login, user_name, mac, station }
|
]]
|
function jx_base.Get_CurLoginUserInfo( strLuaDEID )
|
local nRet, strRetInfo
|
local ret_value = {}
|
|
local strUserLogin, strUserName
|
nRet, strUserLogin, strUserName = mobox.getCurUserInfo( strLuaDEID )
|
if ( nRet ~= 0 ) then return 2, "获取当前操作人员信息失败! "..strUserLogin end
|
|
ret_value.login = strUserLogin
|
ret_value.user_name = strUserName
|
ret_value.mac = ""
|
ret_value.station = ""
|
|
-- 获取当前登录账号的电脑MAC地址（如果在MBC上登录是可以获取的）
|
nRet, strRetInfo = mobox.getCacheValue( strUserLogin, "__user_terminal__" )
|
if ( nRet == 0 ) then
|
local user_terminal = json.decode( strRetInfo )
|
ret_value.mac = lua.Get_StrAttrValue( user_terminal.mac )
|
|
-- 根据 MAC-站台 绑定常量获取 站台
|
if ( ret_value.mac ~= '' ) then
|
ret_value.station = wms_base.Get_sConst( strLuaDEID, ret_value.mac)
|
end
|
end
|
|
return 0, ret_value
|
|
end
|
|
--[[
|
检查一下 orgc_no 下面的 detail 是否已经完成处理完成，如果完成处理 创建一个 入库作业
|
返回值：
|
action
|
]]
|
function jx_base.Organize_CNTR_PostProcess( strLuaDEID, orgc_no, station, cntr_code, bs_no )
|
local nRet, strRetInfo
|
|
-- 检查一下当前料箱的入库任务是否已经全部完成，如果完成就创建一个【货品入库】作业
|
-- N_B_STATE = 1 表示科执行的入库任务
|
local strCondition = "S_CNTR_CODE = '"..cntr_code.."' AND N_B_STATE = 1 AND S_BS_NO = '"..bs_no.."'"
|
nRet, strRetInfo = mobox.getDataObjCount( strLuaDEID, "Organize_CNTR_Detail", strCondition )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo ) end
|
local nCount = lua.StrToNumber( strRetInfo )
|
|
local operation = {}
|
local strUpdateSql
|
local action = {
|
{
|
action_type = "refresh_master_panel",
|
value = {
|
sub_page = {"当前任务", "未执行任务"}
|
}
|
}
|
}
|
|
if ( nCount == 0 ) then
|
-- ***
|
-- 发现过相同有相同组盘的入库作业，这是严重的数据错误，这里加一个判断
|
strCondition = "S_ORGC_NO = '"..orgc_no.."' AND N_TYPE = 1"
|
nRet, strRetInfo = mobox.existThisData( strLuaDEID, "Operation", strCondition )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo ) end
|
-- 如果该车辆编码的动作已经在队列，返回，不做处理
|
if ( strRetInfo == "yes" ) then
|
lua.Error( strLuaDEID, debug.getinfo(1), "容器号'"..cntr_code.."'不能重复创建货品入库作业!" )
|
end
|
|
-- 创建【货品入库】作业. 【组盘容器】状态改为3， CG_Detail 加【组盘容器明细】中的内容
|
local ext_info = {}
|
ext_info.orgc_no = orgc_no
|
nRet, operation = jx_base.Create_StorageOperation( strLuaDEID, "巨沃", station, cntr_code, "货品入库", ext_info )
|
if ( nRet ~= 0 ) then
|
mobox.setInfo( strLuaDEID, operation )
|
-- 3 组盘完成，回库出现问题
|
strUpdateSql = "N_B_STATE = 3"
|
strCondition = "S_ORGC_NO = '"..orgc_no.."'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Organize_Container", strCondition, strUpdateSql )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "更新【组盘容器】信息失败!"..strRetInfo ) end
|
return action
|
end
|
|
--【组盘容器】+ 回库作业号, 状态 = 4 （回库）
|
local strUpdateSql = "S_BACK_OP_NO = '"..operation.code.."', N_B_STATE = 4"
|
strCondition = "S_ORGC_NO = '"..orgc_no.."'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Organize_Container", strCondition, strUpdateSql )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "更新【组盘容器】信息失败!"..strRetInfo ) end
|
|
--容器中的【CG_Detail】新增，把【组盘容器明细】中的内容加入
|
nRet, strRetInfo = wms_cntr.Add_CG_Detail_ByOrgcDetail( strLuaDEID, cntr_code, orgc_no )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), 'wms_cntr.Add_CG_Detail_ByOrgcDetail!'..strRetInfo ) end
|
|
--重置料箱信息
|
local container
|
nRet, container = wms_cntr.GetInfo( strLuaDEID, cntr_code )
|
if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), "获取【容器】信息失败! " .. container) end
|
nRet, strRetInfo = wms_cntr.Reset( strLuaDEID, container )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo ) end
|
|
--入库作业产生需要对入库作业的终点获取加入库锁
|
nRet, strRetInfo = wms.wms_LockLocation(strLuaDEID, operation.end_loc_code, wms_base.Get_nConst( strLuaDEID, "锁类型-入库锁" ),
|
"", operation.code, operation.op_def_name )
|
if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), "wms_LockLocation 失败!"..strRetInfo ) end
|
|
action[2] = {
|
action_type = "set_dlg_attr",
|
value = {
|
{ attr = "UPC", value = "", enable = true, prompt = "请扫商品条码..." },
|
{ attr = "S_CNTR_CODE", value = "", enable = false },
|
{ attr = "S_CELL_NO", value = "", enable = false },
|
{ attr = "S_ITEM_CODE", F_QTY = "", enable = false },
|
{ attr = "F_QTY", value = "", enable = false },
|
{ attr = "F_ACT_QTY", value = "", enable = false },
|
{ attr = "S_ITEM_NAME", value = "", enable = false }
|
}
|
}
|
action[3] = {
|
action_type = "refresh_related_panel",
|
value = {
|
{
|
panel_name = "料格显示",
|
input_parameter = {
|
cell_no = ""
|
}
|
}
|
}
|
}
|
|
action[4] = {
|
action_type = "set_master_panel_cursor",
|
value = { form_name = "3055 TOP VIEW", ctrl_id = "S_CNTR_CODE", value = ""}
|
}
|
end
|
|
return action
|
end
|
|
|
--[[
|
检查一下当前正在分拣的料箱容器 dc_no (配盘容器) 下面的 detail 是否已经完成处理完成，如果完成处理表示该容器分拣完成 创建一个 料箱入库
|
|
返回值：
|
action --
|
]]
|
function jx_base.Distribution_CNTR_PostProcess( strLuaDEID, parameter )
|
local nRet, strRetInfo
|
local strCondition
|
|
-- 检查一下当前料箱的分拣出库任务是否已经全部完成，如果完成就创建一个【料箱h入库】作业
|
-- N_B_STATE = 1 表示科执行的入库任务
|
strCondition = "S_CNTR_CODE = '"..parameter.cntr_code.."' AND N_B_STATE = 1 AND S_BS_NO = '"..parameter.bs_no.."'"
|
nRet, strRetInfo = mobox.getDataObjCount( strLuaDEID, "Distribution_CNTR_Detail", strCondition )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), strRetInfo ) end
|
local nCount = lua.StrToNumber( strRetInfo )
|
|
-- 当前的配盘中已经没有需要执行的出库任务
|
local operation = {}
|
local action = {
|
{
|
action_type = "refresh_master_panel",
|
value = {
|
sub_page = {"当前任务", "未执行任务"}
|
}
|
}
|
}
|
|
if ( nCount == 0 ) then
|
-- 创建【料箱入库】作业. 【配盘容器】状态改为4（拣货完成）， CG_Detail 减去【配盘容器明细】中的内容
|
local ext_info = {dc_no = parameter.dc_no}
|
nRet, operation = jx_base.Create_StorageOperation( strLuaDEID, "巨沃", parameter.station, parameter.cntr_code, "料箱入库", ext_info )
|
if ( nRet ~= 0 ) then
|
mobox.setInfo( strLuaDEID, operation )
|
-- 9 分拣完成，回库出现问题
|
strUpdateSql = "N_B_STATE = 9"
|
strCondition = "S_DC_NO = '"..parameter.dc_no.."'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Distribution_CNTR", strCondition, strUpdateSql )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "更新【配盘】信息失败!"..strRetInfo ) end
|
return action
|
end
|
|
-- 【配盘】+ 回库作业号, 状态 = 5 （回库）
|
strUpdateSql = "S_BACK_OP_NO = '"..operation.code.."', N_B_STATE = 5"
|
strCondition = "S_DC_NO = '"..parameter.dc_no.."'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Distribution_CNTR", strCondition, strUpdateSql )
|
if ( nRet ~= 0 ) then
|
lua.Error( strLuaDEID, debug.getinfo(1), "更新【配盘】信息失败!"..strRetInfo )
|
end
|
local distribution_cntr
|
nRet, distribution_cntr = m3.GetDataObjByCondition( strLuaDEID, "Distribution_CNTR", strCondition )
|
if ( nRet ~= 0 ) then
|
lua.Error( strLuaDEID, debug.getinfo(1), "获取【配盘】信息失败!"..strRetInfo )
|
end
|
|
--容器中的【CG_Detail】减【配盘明细】中的内容, 并且生成下架记录， 扣减量表信息
|
nRet, strRetInfo = wms_out.Distribution_CNTR_Detail_PostProcess( strLuaDEID, parameter.wh_code, parameter.area_code, parameter.loc_code, parameter.dc_no )
|
if ( nRet ~= 0 ) then
|
lua.Error( strLuaDEID, debug.getinfo(1), 'wms_out.Distribution_CNTR_Detail_PostProcess!'..strRetInfo )
|
end
|
|
-- 增加一个后台进程对配盘进行处理，触发配盘明细中的 出库单是否可以完成
|
local add_wfp = {
|
wfp_type = 1,
|
cls = "Distribution_CNTR",
|
obj_id = distribution_cntr.id,
|
obj_name = "配盘'"..parameter.dc_no.."'-->出库后处理",
|
trigger_event = "出库后处理"
|
}
|
nRet, strRetInfo = m3.AddSysWFP( strLuaDEID, add_wfp )
|
if ( nRet ~= 0 ) then
|
lua.Error( strLuaDEID, debug.getinfo(1), "AddSysWFP失败!"..strRetInfo )
|
end
|
-- 位置加入库锁
|
nRet, strRetInfo = wms.wms_LockLocation(strLuaDEID, operation.end_loc_code, wms_base.Get_nConst( strLuaDEID, "锁类型-入库锁" ),
|
"", operation.code, operation.op_def_name )
|
if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), "wms_LockLocation 失败!"..strRetInfo ) end
|
|
action[2] = {
|
action_type = "set_dlg_attr",
|
value = {
|
{ attr = "UPC", value = "", enable = true, prompt = "请扫商品条码..." },
|
{ attr = "Prompt", value = "请扫商品条码..." },
|
{ attr = "S_CNTR_CODE", value = "", enable = false },
|
{ attr = "S_CELL_NO", value = "", enable = false },
|
{ attr = "S_ITEM_CODE", value = "", enable = false },
|
{ attr = "F_QTY", value = "", enable = false },
|
{ attr = "F_ACC_P_QTY", value = "", enable = false },
|
{ attr = "S_ITEM_NAME", value = "", enable = false }
|
}
|
}
|
action[3] = {
|
action_type = "refresh_related_panel",
|
value = {
|
{
|
panel_name = "料格显示",
|
input_parameter = {
|
cell_no = ""
|
}
|
},
|
{
|
panel_name = "拣料箱显示",
|
input_parameter = {
|
pick_box_code = "", -- 拣料箱号
|
}
|
}
|
}
|
}
|
|
action[4] = {
|
action_type = "set_master_panel_cursor",
|
value = { form_name = "3055 TOP VIEW", ctrl_id = "S_CNTR_CODE", value = ""}
|
}
|
end
|
|
return action
|
end
|
|
--[[
|
创建一个空料箱出库作业（组盘出）
|
obj_attrs 组盘对象
|
]]
|
function jx_base.CreateEmptyBoxOutOperation ( strLuaDEID, obj_attrs )
|
local nRet, strRetInfo
|
local msg
|
local orgc_no = obj_attrs.S_ORGC_NO
|
local b_state = lua.Get_NumAttrValue( obj_attrs.N_B_STATE )
|
local to_station = obj_attrs.S_STATION_NO
|
local cntr_code = lua.Get_StrAttrValue( obj_attrs.S_CNTR_CODE )
|
local bs_type = lua.Get_StrAttrValue( obj_attrs.S_BS_TYPE )
|
local bs_no = lua.Get_StrAttrValue( obj_attrs.S_BS_NO )
|
|
-- 【组盘容器】数据对象属性判断，不合法的终止程序执行
|
if ( b_state ~= 0 ) then
|
msg = "组盘号'"..orgc_no.."'的状态不是未执行状态，不能启动料箱出库作业!"
|
lua.Warning( strLuaDEID, debug.getinfo(1), msg )
|
return 1, msg
|
end
|
if ( cntr_code == '' ) then
|
msg = "组盘号'"..orgc_no.."'中的容器编码为空!"
|
lua.Warning( strLuaDEID, debug.getinfo(1), msg )
|
return 1, msg
|
end
|
|
local from_loc_code = wms_wh.GetLocCodeByCNTR( strLuaDEID, cntr_code )
|
if ( from_loc_code == nil or from_loc_code == '' ) then
|
msg = "组盘号'"..orgc_no.."'中的容器'"..cntr_code.."'没有绑定货位!"
|
return 1, msg
|
end
|
|
local from_loc
|
nRet, from_loc = wms_wh.GetLocInfo( from_loc_code )
|
if ( nRet ~= 0 ) then
|
return 1, '获取货位信息失败! '..loc_code
|
end
|
|
-- 创建【料箱出库】作业
|
-- 获取站点货位，站点货位定义在常量中
|
local to_loc_code = jx_base.Get_Station_Loc( strLuaDEID, to_station )
|
local to_loc
|
nRet, to_loc = wms_wh.GetLocInfo( to_loc_code )
|
if ( nRet ~= 0 ) then
|
return 1, '获取货位信息失败! '..to_loc
|
end
|
|
local operation = m3.AllocObject(strLuaDEID,"Operation")
|
operation.bs_state = 8 -- 待启动前，这些作业有待后台脚本来设置为状态 0
|
operation.start_wh_code = from_loc.wh_code
|
operation.start_area_code = from_loc.area_code
|
operation.start_loc_code = from_loc_code
|
|
operation.end_wh_code = to_loc.wh_code
|
operation.end_area_code = to_loc.area_code
|
operation.end_loc_code = to_loc_code
|
|
operation.op_type = wms_base.Get_nConst(strLuaDEID, "作业类型-出库")
|
operation.op_def_name = "料箱出库"
|
operation.cntr_code = cntr_code
|
operation.orgc_no = orgc_no
|
operation.source_sys = "巨沃"
|
|
nRet, operation = m3.CreateDataObj( strLuaDEID, operation )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), '创建【作业】失败!'..operation ) end
|
|
-- 更新【组盘容器】对象属性
|
-- N_B_STATE = 1 表示组盘容器已经安排作业进行搬运
|
local strUpdateSql = "S_FROM_LOC = '"..from_loc_code.."', N_B_STATE = 1, S_OUT_OP_NO = '"..operation.code.."'"
|
strCondition = "S_ORGC_NO = '"..orgc_no.."'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Organize_Container", strCondition, strUpdateSql )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "更新【组盘容器】信息失败!"..strRetInfo ) end
|
|
-- 获取【组盘容器】的业务来源，设置业务来源的状态
|
if ( bs_type == "Inbound_Wave" and bs_no ~= '') then
|
-- N_B_STATE = 2 表示入库波次已经开始作业
|
strUpdateSql = "N_B_STATE = 2"
|
strCondition = "S_WAVE_NO = '"..bs_no.."'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Inbound_Wave", strCondition, strUpdateSql )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "更新【入库波次】信息失败!"..strRetInfo ) end
|
end
|
|
return 0
|
end
|
|
--[[
|
创建一个配盘出库作业
|
obj_attrs 配盘数据对象 obj_attrs.S_DC_NO,...
|
--]]
|
function jx_base.Create_Distribution_OutOperation ( strLuaDEID, obj_attrs )
|
local nRet, strRetInfo
|
local msg
|
local dc_no = obj_attrs.S_DC_NO
|
local b_state = lua.Get_NumAttrValue( obj_attrs.N_B_STATE )
|
local to_station = lua.Get_StrAttrValue( obj_attrs.S_STATION_NO )
|
local cntr_code = obj_attrs.S_CNTR_CODE
|
local from_loc_code = lua.Get_StrAttrValue( obj_attrs.S_LOC_CODE )
|
local to_loc_code = lua.Get_StrAttrValue( obj_attrs.S_EXIT_LOC_CODE ) -- 出库货位
|
local bs_no = lua.Get_StrAttrValue( obj_attrs.S_BS_NO ) -- 业务来源
|
local bs_type = lua.Get_StrAttrValue( obj_attrs.S_BS_TYPE ) -- 业务来源类型
|
|
-- 【组盘容器】数据对象属性判断，不合法的终止程序执行
|
-- b_state = 1 表示配盘完成
|
if ( b_state ~= 1 ) then
|
msg = "配盘号'"..dc_no.."'的状态不是未执行状态，不能启动配盘出库作业!"
|
lua.Warning( strLuaDEID, debug.getinfo(1), msg )
|
return 1, msg
|
end
|
|
if ( from_loc_code == '') then
|
from_loc_code = wms_wh.GetLocCodeByCNTR( strLuaDEID, cntr_code )
|
if ( from_loc_code == nil or from_loc_code == '' ) then
|
return 1, "配盘号'"..orgc_no.."'中的容器'"..cntr_code.."'没有绑定货位!"
|
end
|
end
|
|
local from_loc
|
nRet, from_loc = wms_wh.GetLocInfo( from_loc_code )
|
if ( nRet ~= 0 ) then
|
return 1, '获取货位信息失败! '..loc_code
|
end
|
|
-- 创建【货品出库】作业. 【配盘】状态改为2（出库中）， CG_Detail 加【组盘容器明细】中的内容
|
-- 获取站点货位，站点货位定义在常量中
|
if ( to_loc_code == '' ) then
|
if ( to_station == '') then
|
return 1, "配盘号'"..dc_no.."'的配盘没定义出库站台或货位!"
|
end
|
to_loc_code = jx_base.Get_Station_Loc( strLuaDEID, to_station )
|
end
|
local to_loc
|
nRet, to_loc = wms_wh.GetLocInfo( to_loc_code )
|
if ( nRet ~= 0 ) then
|
return 1, '获取货位信息失败! '..to_loc
|
end
|
|
local operation = m3.AllocObject(strLuaDEID,"Operation")
|
operation.bs_state = 8 -- 待启动前，这些作业有待后台脚本来设置为状态 0
|
operation.start_wh_code = from_loc.wh_code
|
operation.start_area_code = from_loc.area_code
|
operation.start_loc_code = from_loc_code
|
|
operation.end_wh_code = to_loc.wh_code
|
operation.end_area_code = to_loc.area_code
|
operation.end_loc_code = to_loc_code
|
|
operation.op_type = wms_base.Get_nConst(strLuaDEID, "作业类型-出库")
|
operation.op_def_name = "货品出库"
|
operation.cntr_code = cntr_code
|
operation.dc_no = dc_no
|
operation.source_sys = "巨沃"
|
|
operation.bs_type = bs_type
|
operation.bs_no = bs_no
|
|
nRet, operation = m3.CreateDataObj( strLuaDEID, operation )
|
if ( nRet ~= 0 ) then return 1, '创建【作业】失败!'..operation end
|
|
-- 更新【配盘】对象属性
|
-- N_B_STATE = 2 表示配盘容器已经安排作业进行搬运
|
local strUpdateSql = "S_LOC_CODE = '"..from_loc_code.."', N_B_STATE = 2, S_OUT_OP_NO = '"..operation.code.."'"
|
strCondition = "S_DC_NO = '"..dc_no.."'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Distribution_CNTR", strCondition, strUpdateSql )
|
if ( nRet ~= 0 ) then return 1, "更新【配盘】信息失败!"..strRetInfo end
|
|
return 0
|
end
|
|
--[[
|
从 wms_count.Get_CountPlan_QueryPanel_Condition 复制到巨星项目，大部分程序一样，只是在容器盘点时只盘点巨沃WMS的料箱
|
即 容器的类型 N_TYPE = 3 是带料格的料箱，其他和标准函数一样
|
获取新增 盘点计划 的查询面板中的查询条件, 注意这和定义的查询页面中的控件有关系，这个是标准功能里的面板获取查询条件的代码
|
|
isSetQueryCondition = true 的情况下 容器查询 需要返回 base64
|
|
返回 nRet, ret_condition_type, strCondition
|
nRet = 0 成功， nRet = 1 条件不满足 nRet = 2 错误
|
ret_condition_type = 0 返回的字符串是 纯SQL
|
]]
|
function jx_base.Get_CountPlan_QueryPanel_Condition( strLuaDEID, isSetQueryCondition )
|
local nRet, strRetInfo
|
local wh_code
|
local attrs = {}
|
local ret_condition_type = 0 -- 非base64
|
|
-- step1 获取当前查询输入面板中的 仓库编码/库区/物料编码/物料名称
|
nRet, attrs = m3.GetSysInputParameter( strLuaDEID )
|
if ( nRet ~= 0 ) then return 2, 0, "获取当前查询面板里的输入属性时失败! "..attrs end
|
|
local obj_attrs = m3.KeyValueAttrsToObjAttr(attrs)
|
if (obj_attrs == nil) then return 2, 0, "询面板里的输入属性为空" end
|
-- "N_TYPE","S_WH_CODE","Area","ItemCode", "ItemName"
|
local check_type = tonumber(obj_attrs.N_TYPE) -- 盘点类型
|
local wh_code = obj_attrs.S_WH_CODE -- 仓库编码
|
local area_code = obj_attrs.S_AREA_CODE -- 库区编码
|
if ( area_code == nil ) then area_code = '' end
|
|
local strCondition = ''
|
local strOrder = ''
|
|
if ( check_type == 0 ) then return 1, 0, "必须选择一种盘点类型" end
|
if ( wh_code == '' ) then return 1, 0, "必须选择一个仓库" end
|
|
if ( check_type == wms_base.Get_nConst(strLuaDEID, "盘点类型-货品盘点")) then
|
local item_code = obj_attrs.ItemCode -- 物料编码
|
local item_name = obj_attrs.ItemName -- 物料名称
|
local item_condition = ''
|
|
if ( item_code ~= '' and item_code ~= nil ) then
|
item_condition = " AND S_ITEM_CODE like '%%"..item_code.."%%'"
|
end
|
if ( item_name ~= '' and item_name ~= nil ) then
|
item_condition = item_condition.." AND S_ITEM_NAME like '%%"..item_name.."%%' "
|
end
|
strOrder = 'S_ITEM_CODE'
|
-- 如果是货物盘点
|
if ( area_code == '') then
|
-- 没有输入库区就直接查仓库量表
|
strCondition = "F_QTY > 0 AND S_WH_CODE = '"..wh_code.."' "..item_condition
|
else
|
-- 有库区查库区量表
|
strCondition = "F_QTY > 0 AND S_WH_CODE = '"..wh_code.."' AND S_AREA_CODE = '"..area_code.."' "..item_condition
|
end
|
else
|
-- 如果是货位盘点
|
local roadway = lua.StrToNumber(obj_attrs.Roadway) -- 巷道
|
local row = lua.StrToNumber(obj_attrs.Row) -- 排
|
local col = lua.StrToNumber(obj_attrs.Col) -- 列
|
local layer = lua.StrToNumber(obj_attrs.layer) -- 层
|
|
strCondition = "S_WH_CODE = '"..wh_code.."'"
|
if ( area_code ~= '') then
|
strCondition = strCondition .. " AND S_AREA_CODE = '"..area_code.."' "
|
end
|
if ( roadway ~= 0 ) then
|
strCondition = strCondition .. " AND N_ROADWAY = "..roadway
|
end
|
if ( row ~= 0 ) then
|
strCondition = strCondition .. " AND N_ROW = "..row
|
end
|
if ( col ~= 0 ) then
|
strCondition = strCondition .. " AND N_COL = "..col
|
end
|
if ( layer ~= 0 ) then
|
strCondition = strCondition .. " AND N_LAYER = "..layer
|
end
|
|
-- V2.0
|
if ( check_type == wms_base.Get_nConst(strLuaDEID, "盘点类型-货位盘点")) then
|
strCondition = strCondition.." AND N_CURRENT_NUM > 0"
|
else
|
-- 容器盘点
|
-- 这里的查询条件带 In 不能用简单模式
|
if ( isSetQueryCondition ) then
|
local sql_condition = {
|
{
|
{
|
field = "C_ENABLE",
|
value = "Y",
|
op = "="
|
}
|
},
|
{
|
{
|
field = "N_LOCK_STATE",
|
value = "0",
|
op = "="
|
}
|
},
|
{
|
{
|
field = "N_TYPE",
|
value = "3",
|
op = "="
|
}
|
},
|
{
|
{
|
field = "S_CODE",
|
value = "(select S_CNTR_CODE from TN_Loc_Container with (NOLOCK) where S_LOC_CODE in (select S_CODE from TN_Location with (NOLOCK) where "..strCondition.."))",
|
op = "in"
|
}
|
}
|
}
|
|
lua.Debug( strLuaDEID, debug.getinfo(1), "sql_condition", sql_condition )
|
|
nRet, strCondition = mobox.strToBase64( lua.table2str(sql_condition) )
|
|
lua.Debug( strLuaDEID, debug.getinfo(1), "base64", strCondition )
|
|
if ( nRet ~= 0 ) then return 2, 0, "strToBase64 失败: "..strCondition end
|
ret_condition_type = 1
|
else
|
strCondition = "C_ENABLE = 'Y' AND N_LOCK_STATE = 0 AND N_TYPE = 3 AND "..
|
"S_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 "..strCondition.."))"
|
end
|
end
|
end
|
return 0, ret_condition_type, strCondition
|
end
|
|
return jx_base
|
