--[[
|
编码: JX-300-04
|
名称: WCS->WMS 料箱扫码入库
|
作者：HAN
|
日期：2025-1-29
|
|
级别：项目
|
|
函数： BoxStorage
|
|
WCS 这边的输入参数
|
{
|
"requestPk": "pk2022120614242376",
|
"containerCode": "60001",
|
"curPos": "15021"
|
"taskNo": "xxxx"
|
}
|
|
功能:
|
-- WCS 在料箱过扫码点的时候触发
|
-- 判断容器是否有在【巨星任务】，如果有创建的是一个【巨星入库】作业
|
-- 判断是否是巨沃的入库作业
|
|
更改记录:
|
V2.0 HAN 20241207
|
-- 取消料箱初始化入库
|
V3.0 HAN 20241209
|
V4.0 HAN 20241217 + 对JW_CNTR_Goods_INIT的处理 + 对O23,M24为目的地的 巨星入库任务的处理
|
V5.0 HAN 20241219 对已经启动了作业的容器特别处理
|
V6.0 HAN 20241225 在扫码前先判断一下堆垛机的状态
|
V7.0 HAN 20241229 巨星出库任务没指定出库货位的要根据库区的任务数量做均衡
|
V7.1 HAN 20241230 加改进任务巷道信息
|
V8.0 HAN 20250218 JX_Task里新增来源巨沃的码盘入库任务
|
--V20250315--
|
--]]
|
|
wms_cntr = require( "wms_container" )
|
wms_op = require( "wms_operation" )
|
wms_task = require( "wms_task" )
|
jx_base = require( "jx_base" )
|
wms_wh = require( "wms_wh" )
|
|
local CAN_TO_3_4_FLOOR_STATION = "16120"
|
local AREA_3_FLOOR = "L24"
|
local AREA_4_FLOOR = "M23"
|
local LOC_3_FLOOR = "L812301"
|
local LOC_4_FLOOR = "L812401"
|
|
-- 合并CG_Detail明细
|
local function CG_detail_Merge(strLuaDEID, cntr_code)
|
local result = { success = true, errMsg = "" }
|
|
-- 查询 JX_Transfer_Order 表，检查是否存在 N_B_STATE 为 0 的记录
|
strCondition = "S_CNTR_CODE = '" .. cntr_code .. "'"
|
nRet, cntr_list = m3.QueryDataObject(strLuaDEID, "JX_Transfer_Order", strCondition)
|
|
lua.Debug(strLuaDEID, debug.getinfo(1), "cntr_list--->", cntr_list)
|
|
-- 检查查询是否成功
|
if (nRet ~= 0) then
|
result.success = false
|
result.errMsg = "查询 JX_Transfer_Order 表失败！"
|
lua.Warning(strLuaDEID, debug.getinfo(1), "查询失败: " .. result.errMsg)
|
return 200, result.errMsg
|
end
|
|
-- 如果查询到数据，则进行循环判断
|
if cntr_list and #cntr_list > 0 then
|
for i = 1, #cntr_list do
|
local order_attrs = m3.KeyValueAttrsToObjAttr(cntr_list[i].attrs)
|
local b_state = order_attrs.N_B_STATE
|
if (b_state == '0') then
|
result.success = false
|
result.errMsg = "容器号 " .. cntr_code .. " 存在 N_B_STATE 为 0 的记录，操作中止！"
|
lua.Warning(strLuaDEID, debug.getinfo(1), "查询失败: " .. result.errMsg)
|
return 200, result.errMsg
|
end
|
end
|
end
|
|
-- 查询 JX_TO_Detail 表
|
local container_data, nRet
|
local strCondition = "S_TO_NO IN (SELECT S_NO FROM TN_JX_Transfer_Order WHERE S_CNTR_CODE = '" .. cntr_code .. "' AND N_B_STATE = 1)"
|
|
nRet, container_data = m3.QueryDataObject(strLuaDEID, "JX_TO_Detail", strCondition)
|
lua.Debug(strLuaDEID, debug.getinfo(1), "container_data--->", container_data)
|
|
-- 检查查询结果
|
if (nRet ~= 0 or container_data == '') then
|
result.success = false
|
result.errMsg = "没有找到数据!"
|
lua.Warning(strLuaDEID, debug.getinfo(1), "查询失败: " .. result.errMsg)
|
return 200, result.errMsg
|
end
|
|
-- 用来存储合并后的数据
|
local merged_data = {}
|
local cell_no, item_code, item_name, qty, weight, volume
|
|
-- 遍历查询到的每条数据
|
for i = 1, #container_data do
|
local record = m3.KeyValueAttrsToObjAttr(container_data[i].attrs)
|
|
local cell_no = record.S_CELL_NO -- 获取料格号
|
item_code = record.S_ITEM_CODE -- 获取物料编码
|
item_name = record.S_ITEM_NAME
|
qty = lua.Get_NumAttrValue(record.F_QTY) -- 获取数量
|
weight = lua.Get_NumAttrValue(record.F_WEIGHT) -- 获取重量
|
volume = lua.Get_NumAttrValue(record.F_VOLUME) -- 获取体积
|
local no = record.S_TO_NO --移库单号
|
|
local key = cntr_code .. "_" .. cell_no .. "_" .. item_code
|
|
|
-- 检查该键是否已经存在于合并的数据表中
|
if merged_data[key] then
|
-- 如果已经存在，累加数据
|
merged_data[key].qty = merged_data[key].qty + qty
|
merged_data[key].weight = merged_data[key].weight + weight
|
merged_data[key].volume = merged_data[key].volume + volume
|
else
|
-- 否则，创建一个新记录并保存
|
merged_data[key] = {
|
cell_no = cell_no,
|
item_code = item_code,
|
item_name = item_name,
|
qty = qty,
|
weight = weight,
|
volume = volume
|
}
|
end
|
-- 合并CG_Detail明细的时候，更改状态值为完成2
|
strUpdateSql = "N_B_STATE = 2"
|
strCondition = "S_NO = '"..no.."'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "JX_Transfer_Order", strCondition, strUpdateSql )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "更新【JX_Transfer_Order】信息失败!"..strRetInfo ) end
|
|
end
|
|
lua.Debug(strLuaDEID, debug.getinfo(1), "Merged Data--->", merged_data)
|
|
|
-- 遍历合并后的数据，插入新记录
|
for _, merged_record in pairs(merged_data) do
|
|
local nRet,batch_no = jx_base.Generate_Batch_No(merged_record.item_code)
|
if ( nRet ~= 0 ) then return 200, batch_no end
|
|
lua.Debug(strLuaDEID, debug.getinfo(1), "batch_no--->", batch_no)
|
|
local cg_detail = m3.AllocObject(strLuaDEID, "CG_Detail")
|
cg_detail.cntr_code = cntr_code
|
cg_detail.cell_no = merged_record.cell_no
|
cg_detail.item_code = merged_record.item_code
|
cg_detail.item_name = merged_record.item_name
|
cg_detail.batch_no = batch_no
|
cg_detail.qty = merged_record.qty
|
cg_detail.weight = merged_record.weight
|
cg_detail.volume = merged_record.volume
|
|
nRet, cg_detail = m3.CreateDataObj(strLuaDEID, cg_detail)
|
|
lua.Debug(strLuaDEID, debug.getinfo(1), "Create Result--->", cg_detail)
|
|
if (nRet ~= 0) then
|
result.success = false
|
result.errMsg = "插入【CG_Detail】记录失败!"
|
lua.Warning(strLuaDEID, debug.getinfo(1), "Insert operation failed: " .. result.errMsg)
|
return 200, result.errMsg
|
end
|
end
|
|
return 0, "成功合并容器数据"
|
end
|
|
|
|
|
-- 设置CG_Detail中的批次号
|
local function reset_cg_detial_batch_no( strLuaDEID, cntr_code )
|
local nRet, strRetInfo, n
|
local strCondition, strSetAttr
|
local data_objs
|
|
strCondition = "S_CNTR_CODE = '"..cntr_code.."'"
|
nRet, data_objs = m3.QueryDataObject(strLuaDEID, "CG_Detail", strCondition, "S_CELL_NO" )
|
if ( nRet ~= 0 ) then return 2, "QueryDataObject失败!"..data_objs end
|
if ( data_objs == '' ) then return 0 end
|
|
local cg_detail, batch_no
|
for n = 1, #data_objs do
|
cg_detail = m3.KeyValueAttrsToObjAttr(data_objs[n].attrs)
|
|
nRet, batch_no = jx_base.Generate_Batch_No( cg_detail.S_ITEM_CODE )
|
if ( nRet ~= 0 ) then return 2, batch_no end
|
|
strCondition = "S_ID = '"..data_objs[n].id.."'"
|
strSetAttr = "S_BATCH_NO = '"..batch_no.."'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "CG_Detail", strCondition, strSetAttr )
|
if ( nRet ~= 0 ) then return 2, "更新【CG_Detail】信息失败!"..strRetInfo end
|
end
|
return 0
|
end
|
|
-- 【初始巨沃料箱货品】处理
|
local function jw_cntr_goods_init_process( strLuaDEID, station, cntr_code )
|
local nRet, strRetInfo
|
local operation
|
local cntr
|
|
if ( StrIsEmpty( cntr_code ) ) then return 1, "jw_cntr_goods_init_process 函数 cntr_code 不能为空!" end
|
nRet, cntr = wms_cntr.GetInfo( strLuaDEID, cntr_code )
|
if ( nRet ~= 0 ) then return 200, cntr end
|
|
-- 重置容器的空满和基础信息
|
wms_cntr.Reset( strLuaDEID, cntr )
|
-- 设置CG_Detail中的批次号
|
nRet, strRetInfo = reset_cg_detial_batch_no( strLuaDEID, cntr_code )
|
if ( nRet ~= 0 ) then return 200, "设置CG_Detail批次信息时失败!"..strRetInfo end
|
|
-- 这种作业类型会根据 CG_Detail 里的货品数量 + 货品量表
|
local ext_info = { bs_type = "JW_CNTR_Goods_INIT", bs_no = cntr_code }
|
nRet, operation = jx_base.Create_StorageOperation( strLuaDEID, "巨沃", station, cntr_code, "初始入库", ext_info )
|
if ( nRet ~= 0 ) then
|
err_code = 203
|
msg = "创建码盘入库作业失败!".. operation
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS料箱入库接口失败: "..msg )
|
return err_code, msg
|
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
|
|
return 0, operation
|
end
|
|
function BoxStorage ( strLuaDEID )
|
local nRet, strRetInfo, nCount
|
local body
|
local err_code = 0
|
local msg = "success"
|
local station_obj
|
local requestPk, cntr_code, station, task_code
|
local operation
|
local start_loc
|
local ext_info = {}
|
local jx_task, data_objs, obj_attrs
|
local toPos = ''
|
local state, roadway_in_loc, end_loc_code
|
local cntr, task_attrs
|
local go_up = false
|
local stacker_dev
|
|
-- 获取接口传入的数据
|
nRet, body = m3.GetSysDataJson(strLuaDEID)
|
if ( nRet ~= 0 ) then
|
err_code = 200
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: 输入参数的格式有问题!"..body )
|
msg = "输入参数的格式有问题!"
|
goto api_call_return
|
end
|
lua.Debug( strLuaDEID, debug.getinfo(1), "body--->", body )
|
|
requestPk = lua.Get_StrAttrValue( body.requestPk )
|
cntr_code = lua.Get_StrAttrValue( body.containerCode )
|
station = lua.Get_StrAttrValue( body.curPos )
|
task_code = lua.Get_StrAttrValue( body.taskNo )
|
|
if ( requestPk == '') then
|
err_code = 201
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: 输入参数有问题! requestPk 必须有值" )
|
msg = "requestPk 必须有值"
|
goto api_call_return
|
end
|
if ( cntr_code == '') then
|
err_code = 201
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: 输入参数有问题! containerCode 必须有值!" )
|
msg = "contNo 必须有值!"
|
goto api_call_return
|
end
|
if ( station == '') then
|
err_code = 201
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: 输入参数有问题! curPos 必须有值!" )
|
msg = "curPos 必须有值!"
|
goto api_call_return
|
end
|
|
-- 获取扫码点站台信息
|
nRet, station_obj = jx_base.Get_Station_ExtData( strLuaDEID, station )
|
if ( nRet ~= 0 ) then
|
err_code = 202
|
msg = station_obj
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: 输入参数有问题! "..msg )
|
goto api_call_return
|
end
|
-- 获取起点货位
|
nRet, start_loc = wms_wh.GetLocInfo( station_obj.loc_code )
|
if ( nRet ~= 0 ) then
|
err_code = 202
|
msg = start_loc
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: 输入参数有问题! "..msg )
|
goto api_call_return
|
end
|
|
-- 确定容器是否存在
|
nRet, cntr = wms_cntr.GetInfo( strLuaDEID, cntr_code )
|
if ( nRet ~= 0 ) then
|
err_code = 202
|
msg = "检查容器是否存在时失败! "..cntr
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: "..msg )
|
goto api_call_return
|
end
|
if ( cntr == '' ) then
|
err_code = 203
|
msg = "容器编码 = '".. cntr_code.."'的容器不存在!"
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: "..msg )
|
goto api_call_return
|
end
|
|
-- V4.0 MDF BY HAN @20241219 判断一下容器是否已经有作业启动, 扫码点有一个环穿，经扫码点的容器也有可能是有作业的
|
if ( task_code ~= '' ) then
|
-- Task 已经存在说明这个任务已经是有创建过作业
|
nRet, task = wms_task.GetInfo( strLuaDEID, task_code )
|
if ( nRet > 1 ) then lua.Error( strLuaDEID, debug.getinfo(1), "获取【任务】信息失败!"..task ) end
|
if ( nRet == 1 ) then
|
err_code = 210
|
msg = "编码 = '".. task_code.."'的任务不存在!"
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: "..msg )
|
goto api_call_return
|
end
|
|
-- 获取任务所属的作业对象
|
nRet, operation = wms_op.GetInfo( strLuaDEID, task.op_code )
|
if ( nRet > 1 ) then lua.Error( strLuaDEID, debug.getinfo(1), "获取【作业】信息失败!"..operation ) end
|
if ( nRet == 1 ) then
|
err_code = 210
|
msg = "编码 = '".. task.op_code.."'的作业不存在!"
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: "..msg )
|
goto api_call_return
|
end
|
|
-- BY KUN 判断作业名称是不是巨星作业的站台搬运类型，如果是的话，就用原来的位置，跳出
|
if (operation.op_def_name == '站台搬运' )then
|
toPos = operation.end_loc_code
|
goto api_call_return
|
end
|
|
-- 已存在的作业，需要重新计算货位， 有两种情况 1# 巨沃的入库任务，2# 就是巨星任务经过循环输送线再次进入扫码点
|
-- 重新计算一个入库货位
|
nRet, roadway_in_loc, end_loc_code = jx_base.Get_StorageCache_Loc( strLuaDEID, station )
|
if ( nRet ~= 0 ) then
|
if ( nRet == 1 ) then
|
-- 还是老位置
|
toPos = task.end_loc_code
|
goto api_call_return
|
end
|
|
err_code = 213
|
msg = "计算立库存储货位失败".. roadway_in_loc
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: "..msg )
|
goto api_call_return
|
end
|
|
-- 改变任务去向
|
toPos = roadway_in_loc
|
if ( task.end_loc_code ~= toPos ) then
|
-- 如果 原来的任务终点不一样, 改任务终点货位
|
-- V7.1 加改进任务巷道信息
|
-- 获取终点货位信息
|
nRet, end_loc = wms_wh.GetLocInfo( toPos )
|
if ( nRet ~= 0 ) then
|
err_code = 202
|
msg = end_loc
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: 输入参数有问题! "..msg )
|
goto api_call_return
|
end
|
|
strUpdateSql = "S_END_LOC = '"..toPos.."', N_END_LANE = "..end_loc.roadway
|
strCondition = "S_CODE = '"..task_code.."'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Task", strCondition, strUpdateSql )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "更新【任务】信息失败!"..strRetInfo ) end
|
end
|
if ( operation.end_loc_code ~= end_loc_code ) then
|
nRet, strRetInfo = wms.wms_UnlockByOperation( strLuaDEID, operation.code)
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "解锁失败!"..strRetInfo ) end
|
|
strUpdateSql = "S_END_LOC = '"..end_loc_code.."'"
|
strCondition = "S_CODE = '"..operation.code.."'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "Operation", strCondition, strUpdateSql )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "更新【作业】信息失败!"..strRetInfo ) end
|
|
-- 给新的终点货位加入库锁
|
nRet, strRetInfo = wms.wms_LockLocation(strLuaDEID, 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
|
end
|
|
goto api_call_return
|
end
|
|
-- 判断扫码的容器是巨星相关入库，还是处理料箱初始化，还是 巨沃相关入库作业
|
-- V2.0 MDF BY HAN @20241130 增加对【巨星作业】任务池的判断
|
strCondition = "S_CNTR_CODE = '"..cntr_code.."' AND ( N_B_STATE = 0 or N_B_STATE = 1 )"
|
nRet, data_objs = m3.QueryDataObject(strLuaDEID, "JX_Task", strCondition )
|
if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1),"QueryDataObject失败!"..data_objs ) end
|
if ( data_objs == '' ) then
|
-- 判断是否在【JX_ASRS_EmptyBox_In】自动化立库空料箱初始化表
|
strCondition = "S_CNTR_CODE = '"..cntr_code.."'"
|
nRet, data_objs = m3.QueryDataObject(strLuaDEID, "JX_ASRS_EmptyBox_In", strCondition )
|
if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1),"QueryDataObject失败!"..data_objs ) end
|
if ( data_objs == '' ) then
|
-- V4.0 判断是否在【初始巨沃料箱货品】
|
strCondition = "S_CNTR_CODE = '"..cntr_code.."'"
|
nRet, data_objs = m3.QueryDataObject(strLuaDEID, "JW_CNTR_Goods_INIT", strCondition )
|
if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1),"QueryDataObject失败!"..data_objs ) end
|
if ( data_objs == '' ) then
|
err_code = 210
|
msg = "料箱编码 = '".. cntr_code.."' 没有找到可执行任务!(巨沃)"
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: "..msg )
|
goto api_call_return
|
else
|
nRet, operation = jw_cntr_goods_init_process( strLuaDEID, station, cntr_code )
|
if ( nRet ~= 0 ) then
|
err_code = 211
|
msg = "料箱编码 = '".. cntr_code.."' 在处理初始巨沃料箱货品入库时失败!"..operation
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: "..msg )
|
end
|
toPos = operation.ext_data -- 作业这里会有接驳位信息
|
goto api_call_return
|
end
|
else
|
-- 空料箱初始化操作
|
ext_info = { bs_type = "JX_ASRS_EmptyBox_In", bs_no = cntr_code }
|
nRet, operation = jx_base.Create_StorageOperation( strLuaDEID, "杭叉", station, cntr_code, "空箱入库", ext_info )
|
if ( nRet ~= 0 ) then
|
err_code = 203
|
msg = "创建料箱入库作业失败!".. operation
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS料箱入库接口失败: "..msg )
|
goto api_call_return
|
end
|
toPos = operation.ext_data -- 作业这里会有接驳位信息
|
|
-- 【注意】如果上面的程序有入库作业产生需要对入库作业的终点货位加入库锁
|
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
|
end
|
else
|
if ( #data_objs > 1 ) then
|
err_code = 203
|
msg = "任务池里有多个容器编码='".. cntr_code.."'的未执行完成任务，请先处理这些不合法的数据!"
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: "..msg )
|
goto api_call_return
|
end
|
|
obj_attrs = m3.KeyValueAttrsToObjAttr(data_objs[1].attrs)
|
state = lua.Get_NumAttrValue( obj_attrs.N_B_STATE )
|
if ( obj_attrs.S_TASK_TYPE ~= '入库' ) then
|
err_code = 203
|
msg = "任务池中容器编码='".. cntr_code.."'的任务不是入库任务"
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: "..msg )
|
goto api_call_return
|
end
|
if ( state == 1 ) then
|
err_code = 203
|
msg = "任务池中容器编码='".. cntr_code.."'的任务已经启动!"
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: "..msg )
|
goto api_call_return
|
end
|
|
-- V4.0 MDF BY HAN 如果去3，4楼的巨星任务只能是16120扫码点
|
-- V8.0
|
if ( obj_attrs.S_SOURCESYS == "GSWMS" ) then
|
if ( obj_attrs.S_END_AREA == AREA_3_FLOOR or obj_attrs.S_END_AREA == AREA_4_FLOOR ) then
|
if ( station ~= CAN_TO_3_4_FLOOR_STATION ) then
|
err_code = 210
|
msg = "任务='".. obj_attrs.S_SOURNO.."'的任务只能是通过'"..CAN_TO_3_4_FLOOR_STATION.."'扫码点上3,4楼!"
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: "..msg )
|
goto api_call_return
|
end
|
if ( obj_attrs.S_END_AREA == AREA_3_FLOOR ) then
|
end_loc_code = LOC_3_FLOOR
|
else
|
end_loc_code = LOC_4_FLOOR
|
end
|
|
ext_info = { bs_type = "JX-Task", bs_no = obj_attrs.S_SOURNO, lock_cntr = 'N', source_sys = "巨星" }
|
nRet, operation = wms_op.Create( strLuaDEID, cntr_code, station, end_loc_code,
|
wms_base.Get_nConst(strLuaDEID, "作业类型-入库"), "站台搬运", ext_info )
|
|
if ( nRet ~= 0 ) then
|
err_code = 203
|
msg = "创建巨星入库作业失败!".. operation
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: "..msg )
|
goto api_call_return
|
end
|
toPos = end_loc_code
|
else
|
ext_info = { bs_type = "JX-Task", bs_no = obj_attrs.S_SOURNO }
|
nRet, operation = jx_base.Create_StorageOperation( strLuaDEID, "巨星", station, cntr_code, "巨星入库", ext_info )
|
if ( nRet ~= 0 ) then
|
err_code = 203
|
msg = "创建巨星入库作业失败!".. operation
|
lua.Warning( strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: "..msg )
|
goto api_call_return
|
end
|
toPos = operation.ext_data -- 作业这里会有接驳位信息
|
-- 进立库终点货位要加入库锁
|
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
|
end
|
elseif (obj_attrs.S_SOURCESYS == "巨沃") then
|
ext_info = { bs_type = "JX-Task", bs_no = obj_attrs.S_SOURNO }
|
-- 调用合并函数，合并相同的容器号、料格号、物料编码的数据
|
local nRet, mergeResult = CG_detail_Merge(strLuaDEID, cntr_code)
|
if (nRet ~= 0) then
|
err_code = 204
|
msg = "合并容器数据失败: " .. mergeResult
|
lua.Warning(strLuaDEID, debug.getinfo(1), "容器数据合并失败: " .. msg)
|
goto api_call_return
|
end
|
|
-- 合并完成后，继续创建巨沃入库作业
|
nRet, operation = jx_base.Create_StorageOperation(strLuaDEID, "巨沃", station, cntr_code, "码盘入库", ext_info)
|
if (nRet ~= 0) then
|
err_code = 203
|
msg = "创建巨沃入库作业失败!" .. operation
|
lua.Warning(strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: " .. msg)
|
goto api_call_return
|
end
|
|
toPos = operation.ext_data -- 作业这里会有接驳位信息
|
|
-- 进立库终点货位要加入库锁
|
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
|
elseif(obj_attrs.S_SOURCESYS == "巨沃入库") then
|
ext_info = { bs_type = "JX-Task", bs_no = obj_attrs.S_SOURNO }
|
|
nRet, operation = jx_base.Create_StorageOperation(strLuaDEID, "巨沃", station, cntr_code, "料箱入库", ext_info)
|
if (nRet ~= 0) then
|
err_code = 203
|
msg = "创建巨沃入库作业失败!" .. operation
|
lua.Warning(strLuaDEID, debug.getinfo(1), "WCS调用WMS扫码入库接口失败: " .. msg)
|
goto api_call_return
|
end
|
|
toPos = operation.ext_data -- 作业这里会有接驳位信息
|
|
-- 进立库终点货位要加入库锁
|
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
|
|
else
|
lua.Error( strLuaDEID, debug.getinfo(1), "【巨星任务】中的字段S_SOURCESYS必须有值!" )
|
end
|
|
-- N_B_STATE = 1 任务执行
|
strUpdateSql = "N_B_STATE = 1, S_OP_CODE = '"..operation.code.."'"
|
strCondition = "S_SOURNO = '"..obj_attrs.S_SOURNO.."'"
|
nRet, strRetInfo = mobox.updateDataAttrByCondition( strLuaDEID, "JX_Task", strCondition, strUpdateSql )
|
if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "更新【巨星任务】信息失败!"..strRetInfo ) end
|
end
|
|
::api_call_return::
|
-- 设置返回结果
|
local result = {
|
code = err_code,
|
msg = msg,
|
toPos = toPos, -- 在扫码点重新分配的货位
|
requestPk = body.requestPk
|
}
|
m3.EPI_Return( strLuaDEID, result )
|
lua.Debug( strLuaDEID, debug.getinfo(1), "result--->", result )
|
end
|
