--[[
|
编码: GK-API-06
|
名称: 出库单创建接口
|
作者: DJW
|
日期: 2025-5-14
|
|
入口函数： Main
|
功能说明:
|
1. 接收上游系统的入库任务XML数据
|
2. 检查入库单是否已存在
|
3. 创建Outbound_Order主表和Outbound_Detail子表记录
|
4. 返回处理结果
|
|
输入XML示例:
|
<soapenv:Envelope
|
xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">
|
<soap:Header
|
xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/">
|
</soap:Header>
|
<soapenv:Body>
|
<v1:InTaskCreationReq
|
xmlns:v1="http://www.gkht.com/OutReceive/INV/Ebs/Schemas/OutTaskCreation/V1.0">
|
<v1:TaskCreation_Input>
|
<v1:RESTHeader>
|
<v1:Responsibility/>
|
<v1:RespApplication/>
|
<v1:SecurityGroup/>
|
<v1:NLSLanguage>SIMPLIFIED CHINESE</v1:NLSLanguage>
|
<v1:Org_Id>0</v1:Org_Id>
|
</v1:RESTHeader>
|
<v1:InputParameters>
|
<v1:TaskCreation_TB>
|
<!-- 1 or more repetitions:-->
|
<v1:taskId>TASK20000001</v1:taskId>
|
<v1:taskType>normal</v1:taskType>
|
<v1:orderFlag>
|
</v1:orderFlag>
|
<v1:orderNo>2025050602</v1:orderNo>
|
<v1:waveId>BCH1001</v1:waveId>
|
<v1:storerId>CGKHTY</v1:storerId>
|
<v1:ownerId>CGKHTY</v1:ownerId>
|
<v1:orderDate>2025-05-06</v1:orderDate>
|
<v1:priority>0</v1:priority>
|
<v1:memo>
|
</v1:memo>
|
<v1:TaskCreation_TB_ITEM>
|
<v1:orderItemId>1</v1:orderItemId>
|
<v1:skuId>XR33201-2L080B</v1:skuId>
|
<v1:skuStatus>AVL</v1:skuStatus>
|
<v1:qty>2</v1:qty>
|
<v1:batchNo>PHI00000000000001309</v1:batchNo>
|
<v1:produceCode>YL201125</v1:produceCode>
|
<v1:productDate>2016-04-23</v1:productDate>
|
<v1:expiryDate>2099-12-31</v1:expiryDate>
|
<v1:registerNo>国食药监械（准)字2012</v1:registerNo>
|
<v1:cid>
|
</v1:cid>
|
</v1:TaskCreation_TB_ITEM>
|
<v1:TaskCreation_TB_ITEM>
|
<v1:orderItemId>2</v1:orderItemId>
|
<v1:skuId>KH32803017</v1:skuId>
|
<v1:skuStatus>AVL</v1:skuStatus>
|
<v1:qty>5</v1:qty>
|
<v1:batchNo>PHI00000000000001308</v1:batchNo>
|
<v1:produceCode>YL2011256</v1:produceCode>
|
<v1:productDate>2023-04-23</v1:productDate>
|
<v1:expiryDate>2099-12-31</v1:expiryDate>
|
<v1:registerNo>
|
</v1:registerNo>
|
<v1:cid>
|
</v1:cid>
|
</v1:TaskCreation_TB_ITEM>
|
</v1:TaskCreation_TB>
|
</v1:InputParameters>
|
</v1:TaskCreation_Input>
|
</v1:InTaskCreationReq>
|
</soapenv:Body>
|
</soapenv:Envelope>
|
--]]
|
wms_base = require("wms_base")
|
xml = require("oi_base_xml")
|
xml2lua = require("xml2lua")
|
-- 创建出库单主表记录
|
local function create_outbound_order(strLuaDEID, order_data)
|
local order = m3.AllocObject(strLuaDEID, "Outbound_Order")
|
local nRet1,CONST_FACTORY= wms_base.Get_sConst2(strLuaDEID,"GK_Default_Factory");
|
--默认工厂标识
|
local nRet2,CONST_WH= wms_base.Get_sConst2(strLuaDEID,"GK_Default_Warehouse");
|
if nRet1 ~= 0 or nRet2 ~= 0 then
|
return 1, "获取工厂或仓库常量失败"
|
end
|
-- 主表字段映射
|
order.no = order_data.taskId
|
order.bs_type = order_data.taskType
|
order.bs_no = order_data.orderNo
|
order.wave_no = order_data.waveId
|
--order.D_OP_DATE = order_data.orderDate
|
--order.N_PRIORITY = order_data.priority
|
order.note = order_data.memo or ""
|
order.wh_code = CONST_WH
|
order.area_code=" "
|
order.factory=CONST_FACTORY
|
|
local nRet, result = m3.CreateDataObj(strLuaDEID, order)
|
return nRet, result
|
end
|
|
-- 创建出库单明细记录
|
local function create_outbound_detail(strLuaDEID, order_no, item_data)
|
local detail = m3.AllocObject(strLuaDEID, "Outbound_Detail")
|
|
-- 明细表字段映射
|
detail.oo_no = order_no
|
detail.storer = item_data.storerId
|
detail.owner = item_data.ownerId
|
detail.row_no = item_data.orderItemId
|
detail.item_code = item_data.skuId
|
detail.item_state = item_data.skuStatus
|
--detail.qty = lua.Get_NumAttrValue(item_data.qty)
|
detail.batch_no = item_data.produceCode
|
detail.wms_bn = item_data.batchNo
|
--detail.D_PRD_DATE = item_data.productDate
|
--detail.D_EXP_DATE = item_data.expiryDate
|
detail.ext_attr3 = item_data.registerNo or ""
|
detail.ext_attr1 = item_data.cid or ""
|
|
local nRet, result = m3.CreateDataObj(strLuaDEID, detail)
|
return nRet, result
|
end
|
|
-- isJson传1表示json格式，0表示xml格式
|
-- value是table数据
|
-- isStop传0表示正常，3表示要回滚
|
function ApiReturn(strLuaDEID, isJson, value, isStop)
|
local strReturn = value
|
--Debug( strLuaDEID, debug.getinfo(1), "ApiReturn失败!", value )
|
--mobox.writeLuaLog( lua.table2str( value ) )
|
if isJson == 0 then
|
strReturn = xml2lua.toXml(value)
|
mobox.writeLuaLog(strReturn)
|
end
|
mobox.returnValue(strLuaDEID, isJson, value, isStop);
|
return
|
end
|
function Main(strLuaDEID)
|
local nRet, strRetInfo,err_msg
|
local soap_xml,parsed_data,task_data,input_params,task_tb,order_no
|
local strCondition,id,task_items
|
local isStop = 0
|
local err = {}
|
local items = {}
|
|
|
|
-- m3.PrintLuaDEInfo(strLuaDEID)
|
local result = {
|
flag = "success",
|
code = "0",
|
msg = ""
|
}
|
-- 1. 获取接口输入数据
|
|
nRet, soap_xml = mobox.getCurEditDataPacket(strLuaDEID)
|
if nRet ~= 0 then
|
-- lua.Stop(strLuaDEID, "无法获取数据包: " .. soap_xml)
|
result.flag = "failure"
|
result.code = "1"
|
result.msg = "无法获取数据包: "
|
goto api_call_return
|
|
-- return
|
end
|
|
-- 2. 解析XML
|
|
nRet, parsed_data = xml.parse(soap_xml)
|
if nRet ~= 0 then
|
-- lua.Stop(strLuaDEID, "接口输入的XML格式非法!")
|
result.flag = "failure"
|
result.code = "2"
|
result.msg = "接口输入的XML格式非法: "
|
goto api_call_return
|
-- return
|
end
|
|
-- 3. 提取任务数据
|
task_data = parsed_data.Envelope.Body.InTaskCreationReq.TaskCreation_Input
|
input_params = task_data.InputParameters
|
task_tb = input_params.TaskCreation_TB
|
|
-- 4. 检查出库单是否已存在
|
order_no = task_tb.taskId
|
strCondition = string.format("S_NO = '%s'", order_no)
|
nRet, id, strRetInfo = mobox.getDataObjAttrByKeyAttr(strLuaDEID, "Outbound_Order", strCondition)
|
if nRet > 1 then
|
result.flag = "failure"
|
result.code = "3"
|
result.msg = "检查出库单是否存在时出错: " .. strRetInfo
|
goto api_call_return
|
elseif nRet == 0 then
|
result.flag = "failure"
|
result.code = "4"
|
result.msg = "出库单已存在: "
|
goto api_call_return
|
end
|
-- 5. 创建出库单主表
|
nRet, strRetInfo = create_outbound_order(strLuaDEID, task_tb)
|
if nRet ~= 0 then
|
-- lua.Stop(strLuaDEID, "创建出库单主表失败:" .. strRetInfo)
|
result.flag = "failure"
|
result.code = "5"
|
result.msg = "创建出库单主表失败:" .. strRetInfo
|
isStop=3
|
goto api_call_return
|
-- return
|
end
|
|
-- 6. 处理明细数据
|
task_items = task_tb.TaskCreation_TB_ITEM
|
|
-- 情况2：多条明细（数组形式）
|
if task_items[1] ~= nil then
|
items = task_items
|
-- 情况3：单条明细（非数组形式）
|
else
|
items = {task_items}
|
end
|
|
for i, item in ipairs(items) do
|
nRet, strRetInfo = create_outbound_detail(strLuaDEID, order_no, item)
|
if nRet ~= 0 then
|
err_msg = string.format("创建出库单明细失败(行号:%d): %s", item.orderItemId, strRetInfo)
|
-- wms_base.Warning(strLuaDEID, 1, 604, err_msg, "创建出库单明细")
|
-- nErr = nErr + 1
|
-- err[nErr] = err_msg
|
-- lua.Stop(strLuaDEID, err_msg)
|
result.flag = "failure"
|
result.code = "5"
|
result.msg = err_msg
|
isStop=3
|
goto api_call_return
|
end
|
end
|
::api_call_return::
|
-- 7. 返回处理结果
|
|
-- m3.EPI_Return(strLuaDEID, result)
|
ApiReturn(strLuaDEID, 0, result, isStop)
|
end
|
