---
|
--- Created by wsz.
|
--- DateTime: 2025/5/13 上午9:02
|
---
|
--[[
|
编码:GK-API-03
|
名称: 商品批次同步接口
|
作者:
|
入口函数：Batch_Sync
|
功能说明:创建、覆盖GK_BATCH实体 同时更新CG_Detail相关自定义字段
|
变更历史:
|
|
v0.0.2
|
格式验证不通过的返回报文
|
系统异常需要error抛出
|
resp
|
|
v0.0.3
|
CG_Detail弃用，变更为 库存表 INV_Detail
|
|
--]]
|
|
local json = require("json")
|
local mobox = require("OILua_JavelinExt")
|
local m3 = require("oi_base_mobox")
|
|
local xml = require("oi_base_xml")
|
|
--- 实体标识-商品批次同步 TN_GK_BATCH
|
local CLSID_GKbatch = "GK_BATCH"
|
--- 实体标识-货位容器货品明细 TN_CG_Detail | 变更为 库存表 INV_Detail
|
local CLSID_INVdetail = "INV_Detail"
|
|
-- local apiDesc = "商品批次同步接口"
|
|
|
--根标签
|
local RootTag = "response"
|
|
|
|
--[[
|
desc:处理xml->table 部分空节点被转化为{}
|
parameter:
|
value-字符串或空table{}
|
return: nil/字符串
|
-- 备 集中处理
|
--]]
|
local function getStrHandle(value)
|
--if (type(value) == "table" and #value == 0) then
|
-- return nil
|
--else
|
-- return lua.Get_StrAttrValue(value)
|
--end
|
return lua.Get_StrAttrValue(value)
|
end
|
|
|
-- mergeTablesDeep辅助-递归
|
local function deepCopy(original)
|
if type(original) ~= 'table' then
|
return original
|
end
|
local copy = {}
|
for key, value in pairs(original) do
|
copy[key] = deepCopy(value)
|
end
|
return copy
|
end
|
|
-- 将tableb合并到tablea
|
local function mergeTablesDeep(tablea, tableb)
|
local bCopy = deepCopy(tableb)
|
for key, value in pairs(bCopy) do
|
tablea[key] = value
|
end
|
return tablea
|
end
|
|
|
--[[
|
-- 事务回滚-返回信息后终止执行
|
]]
|
local function result_transaction_back(strLuaDEID, msg)
|
|
-- 回滚当次处理
|
lua.Stop(strLuaDEID, msg)
|
|
local result = {}
|
result.flag = "failure" -- success|failure
|
result.code = 5
|
result.message = msg
|
|
do
|
local nRet = mobox.returnValue(strLuaDEID, 1, xml.json_to_xml(result, RootTag), result.code)
|
if nRet ~= 0 then
|
lua.Error(strLuaDEID, debug.getinfo(1), 'result_transaction_back-执行mobox.returnValue失败 ' .. nRet)
|
end
|
end
|
|
lua.Error(strLuaDEID, debug.getinfo(1), msg)
|
end
|
|
|
--[[
|
-- 执行成功
|
]]
|
local function result_success(strLuaDEID)
|
|
local result = {}
|
result.flag = "success" -- success|failure
|
result.code = 0
|
result.message = ""
|
do
|
local nRet = mobox.returnValue(strLuaDEID, 1, xml.json_to_xml(result, RootTag), result.code)
|
if nRet ~= 0 then
|
lua.Error(strLuaDEID, debug.getinfo(1), 'result_success-执行mobox.returnValue失败 ' .. nRet)
|
end
|
end
|
end
|
|
|
|
|
--[[
|
组装临时对象
|
]]
|
local function buildTemp(dataSet)
|
local temp = {} -- 放置待创建数据
|
|
-- 物料编码/商品代码
|
temp.storer_no = getStrHandle(dataSet.storerId)-- getStrHandle(dataSet.skuId)
|
-- 货主编码
|
temp.item_code = getStrHandle(dataSet.skuId) --getStrHandle(dataSet.storerId)
|
-- 物权
|
temp.owner_no = getStrHandle(dataSet.ownerId)
|
-- 批次编码
|
temp.wms_bn = getStrHandle(dataSet.batchNo)
|
-- 批号
|
temp.batch_no = getStrHandle(dataSet.produceCode)
|
-- 生产日期
|
temp.product_date = getStrHandle(dataSet.productDate)
|
-- 有效日期
|
temp.expiry_date = getStrHandle(dataSet.expiryDate)
|
-- 注册证号
|
temp.register_no = getStrHandle(dataSet.registerNo)
|
-- 生产企业
|
temp.company_name = getStrHandle(dataSet.companyName)
|
-- 证件生产厂家
|
temp.cert_company_name = getStrHandle(dataSet.certCompanyName)
|
-- 委托生产厂家
|
temp.consign_company_name = getStrHandle(dataSet.consignCompanyWTName)
|
-- 灭菌日期
|
temp.sterilization_date = getStrHandle(dataSet.sterilizationData)
|
-- 备注
|
temp.note = getStrHandle(dataSet.memo)
|
-- 备注
|
temp.ex1 = getStrHandle(dataSet.ex1)
|
-- 备注
|
temp.ex2 = getStrHandle(dataSet.ex2)
|
-- 备注
|
temp.ex3 = getStrHandle(dataSet.ex3)
|
|
return temp
|
end
|
|
|
--[[
|
|
strClsID: 数据类id
|
dataObj：待创建的数据对象
|
|
--]]
|
local function create_obj(strLuaDEID, strClsID, dataObj)
|
|
-- 基础验证
|
if (nil == strClsID or strClsID == '') then
|
result_transaction_back(strLuaDEID, "[商品批次同步接口]-创建对象失败,strClsID不可为空")
|
end
|
if type(dataObj) ~= 'table' then
|
result_transaction_back(strLuaDEID, "[商品批次同步接口]-创建对象失败,dataObj必须为table类型")
|
end
|
|
--
|
local creatobj = m3.AllocObject(strLuaDEID, strClsID)
|
|
mergeTablesDeep(creatobj, dataObj)
|
local nRet, resultData = m3.CreateDataObj(strLuaDEID, creatobj)
|
if (nRet ~= 0) then
|
result_transaction_back(strLuaDEID, string.format("创建对象[%s]失败,msg：%s", strClsID, resultData))
|
end
|
end
|
|
|
--[[
|
desc:更新目标数据
|
]]
|
local function updateBussData(strLuaDEID, dataSet, id)
|
local temp = buildTemp(dataSet)
|
|
local attrValueObj
|
do
|
-- 取得 可用来更新数据库的 attr-value 的 table 类型 [attrValueObj]
|
-- luaJsonToObjAttrs 执行后返回的str_data_attrset 是字符串，且attr 是数据库字符串 需反序列化处理为table
|
local nRet, str_data_attrset = mobox.luaJsonToObjAttrs(CLSID_GKbatch, json.encode(temp))
|
|
if nRet ~= 0 then
|
result_transaction_back(strLuaDEID, 'upd-goodsbatsh item 时luaJsonToObjAttrs执行失败，详细：' .. str_data_attrset)
|
end
|
-- 反序列化为目标格式
|
attrValueObj = json.decode(str_data_attrset)
|
end
|
-- 当程序可以运行以下时 - 认为 if nRet == 0 --- 执行upd逻辑
|
lua.Debug(strLuaDEID, debug.getinfo(1), "attrValueObj", attrValueObj)
|
-- 组装批量更新的数据格式
|
local updateObj = {}
|
|
local updateObj_item = {}
|
updateObj_item.id = id
|
updateObj_item.attrs = attrValueObj
|
table.insert(updateObj, updateObj_item)
|
|
--local updateObj = {
|
-- {
|
-- id = id,
|
-- attrs = attrValueObj
|
-- }
|
--}
|
|
local updateStrDataJson = lua.table2str(updateObj)
|
lua.Debug(strLuaDEID, debug.getinfo(1), "goodsbatch-update准备覆盖已有数据", updateStrDataJson)
|
local nRet, strRetInfo = mobox.updateDataObj(strLuaDEID, CLSID_GKbatch, updateStrDataJson)
|
if (nRet ~= 0) then
|
result_transaction_back(strLuaDEID, string.format("goodbatch更新操作失败。code：%s，msg：%s", nRet, strRetInfo))
|
end
|
end
|
|
|
--[[
|
desc:创建目标数据
|
]]
|
local function creatBussData(strLuaDEID, dataSet)
|
local temp = buildTemp(dataSet)
|
|
lua.Debug(strLuaDEID, debug.getinfo(1), "goodsbatch待新增数据-temp", temp)
|
|
create_obj(strLuaDEID, CLSID_GKbatch, temp)
|
end
|
|
|
--[[
|
单条
|
]]
|
local function bussHandle(strLuaDEID, dataSet)
|
|
-- 对于 非数组表 返回0 认定仅单条???
|
lua.Debug(strLuaDEID, debug.getinfo(1), "dataSet", dataSet)
|
|
-- 组装sql过滤条件
|
local strCondition
|
do
|
local filters = {}
|
table.insert(filters, string.format([[ %s = '%s' ]], "S_STORER", getStrHandle(dataSet.storerId)))--getStrHandle(dataSet.skuId)))
|
table.insert(filters, string.format([[ %s = '%s' ]], "S_ITEM_CODE", getStrHandle(dataSet.skuId)))--getStrHandle(dataSet.storerId)))
|
table.insert(filters, string.format([[ %s = '%s' ]], "S_OWNER", getStrHandle(dataSet.ownerId)))
|
table.insert(filters, string.format([[ %s = '%s' ]], "S_WMS_BN", getStrHandle(dataSet.batchNo)))
|
strCondition = table.concat(filters, " and ")
|
lua.Debug(strLuaDEID, debug.getinfo(1), "filters-组装的goodsbatch的where条件", strCondition)
|
end
|
|
local nRet, id, strRetInfo = mobox.getDataObjAttrByKeyAttr(strLuaDEID, CLSID_GKbatch, strCondition)
|
lua.Debug(strLuaDEID, debug.getinfo(1), "getDataObjAttrByKeyAttr", strRetInfo)
|
if nRet == 0 then
|
-- key已存在，更新原数据
|
lua.Debug(strLuaDEID, debug.getinfo(1), "add", "数据更新：" .. strRetInfo)
|
updateBussData(strLuaDEID, dataSet, id)
|
elseif nRet == 1 then
|
-- key不存在，新增
|
lua.Debug(strLuaDEID, debug.getinfo(1), "upd", "数据新增")
|
creatBussData(strLuaDEID, dataSet)
|
else
|
result_transaction_back(strLuaDEID, string.format("查询目标数据失败，code：%s，msg：%s", nRet, strRetInfo))
|
end
|
end
|
|
--[[
|
组装数据key
|
skuId+storerId+ownerId+batchNo唯一（必填）
|
]]
|
local function getId(dataSet)
|
return getStrHandle(dataSet.skuId)
|
.. getStrHandle(dataSet.storerId)
|
.. getStrHandle(dataSet.ownerId)
|
.. getStrHandle(dataSet.batchNo)
|
end
|
|
|
|
|
|
|
|
|
--[[
|
同时更新 CGDetail 字段
|
策略：查找 skuId+storerId+ownerId+batchNo 数据，然后的
|
]]
|
local function updateCG_Detail(strLuaDEID, dataSet)
|
|
lua.Debug(strLuaDEID, debug.getinfo(1), "开始更新updateCG_Detail", '')
|
-- 1. 组装查询条件 type:str
|
local strCondition
|
do
|
local filters = {}
|
table.insert(filters, string.format([[ %s = '%s' ]], "S_STORER", getStrHandle(dataSet.storerId)))
|
table.insert(filters, string.format([[ %s = '%s' ]], "S_OWNER", getStrHandle(dataSet.ownerId)))
|
table.insert(filters, string.format([[ %s = '%s' ]], "S_ITEM_CODE", getStrHandle(dataSet.skuId)))
|
table.insert(filters, string.format([[ %s = '%s' ]], "S_WMS_BN", getStrHandle(dataSet.batchNo)))
|
strCondition = table.concat(filters, " and ")
|
lua.Debug(strLuaDEID, debug.getinfo(1), "filters-组装的cg-detail的where条件", strCondition)
|
end
|
|
-- 2. 组装待更新字段 type:str
|
local strUpdateSql
|
do
|
local updater = {}
|
table.insert(updater, string.format([[ %s = '%s' ]], "S_BATCH_NO", getStrHandle(dataSet.produceCode))) -- 批号 | 批号
|
table.insert(updater, string.format([[ %s = '%s' ]], "D_PRD_DATE", getStrHandle(dataSet.productDate))) -- 生产日期 | 生产日期
|
table.insert(updater, string.format([[ %s = '%s' ]], "D_EXP_DATE", getStrHandle(dataSet.expiryDate))) -- 有效日期 | 有效日期
|
table.insert(updater, string.format([[ %s = '%s' ]], "S_UDF01", getStrHandle(dataSet.registerNo))) -- 注册证号 | 自定义字段1
|
table.insert(updater, string.format([[ %s = '%s' ]], "S_UDF02", getStrHandle(dataSet.companyName))) -- 生产企业 | 自定义字段2
|
table.insert(updater, string.format([[ %s = '%s' ]], "S_UDF03", getStrHandle(dataSet.certCompanyName))) -- 证件生产厂家 | 自定义字段3
|
table.insert(updater, string.format([[ %s = '%s' ]], "S_UDF04", getStrHandle(dataSet.consignCompanyWTName))) -- 委托生产厂家 | 自定义字段4
|
table.insert(updater, string.format([[ %s = '%s' ]], "S_UDF05", getStrHandle(dataSet.sterilizationDate))) -- 灭菌日期 | 自定义字段5
|
table.insert(updater, string.format([[ %s = '%s' ]], "S_UDF06", getStrHandle(dataSet.ex1))) -- 扩展字段1 | 自定义字段6
|
table.insert(updater, string.format([[ %s = '%s' ]], "S_UDF07", getStrHandle(dataSet.ex2))) -- 扩展字段2 | 自定义字段7
|
table.insert(updater, string.format([[ %s = '%s' ]], "S_UDF08", getStrHandle(dataSet.ex3))) -- 扩展字段3 | 自定义字段8
|
strUpdateSql = table.concat(updater, " , ")
|
lua.Debug(strLuaDEID, debug.getinfo(1), "filters-组装的cg-detail的set字段", strUpdateSql)
|
end
|
-- 3. 更新执行
|
do
|
local nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, CLSID_INVdetail, strCondition, strUpdateSql)
|
if (nRet ~= 0) then
|
result_transaction_back(strLuaDEID, CLSID_INVdetail .. "更新信息失败!" .. strRetInfo)
|
end
|
end
|
end
|
|
function Batch_Sync(strLuaDEID)
|
|
-- 1.1 getxml
|
local soap_xml
|
do
|
local nRet, data = mobox.getCurEditDataPacket(strLuaDEID)
|
if (nRet ~= 0) then
|
result_transaction_back(strLuaDEID, "无法获取数据包 datajson !" .. data)
|
end
|
soap_xml = data
|
lua.Debug(strLuaDEID, debug.getinfo(1), "GK-API-03xml报文", soap_xml)
|
end
|
|
-- 1.2 xml->luaobj
|
local parsed_data
|
do
|
local nRet, data = xml.parse(soap_xml)
|
if (nRet ~= 0) then
|
result_transaction_back(strLuaDEID, "接口输入的XML格式非法!")
|
end
|
parsed_data = data
|
end
|
|
|
-- 1.3 取得商品批次表item的tableObj
|
local dataSet = parsed_data["Envelope"]["Body"]
|
["InBatchGoodsReq"]
|
["BatchGoods_Input"]
|
["InputParameters"]
|
["BATCHGOODS_TB"]
|
["BATCHGOODS_TB_ITEM"]
|
|
if nil == dataSet then
|
-- wms_base.Warning( strLuaDEID, 1, 601, err_msg, "从GK-WMS系统同步SKU信息" )
|
--wms_base.Warning(strLuaDEID, 2, 201, "[商品批次同步接口]-未解析到soap商品批次节点!", json.encode(dataSet), "", "[商品批次同步接口]-dataSet")
|
result_transaction_back(strLuaDEID, "[商品批次同步接口]-未解析到soap商品批次节点!")
|
elseif #dataSet == 0 then
|
-- 仅单条数据
|
lua.Debug(strLuaDEID, debug.getinfo(1), "单条", "")
|
bussHandle(strLuaDEID, dataSet)
|
updateCG_Detail(strLuaDEID, dataSet)
|
else
|
for i = 1, #dataSet do
|
lua.Debug(strLuaDEID, debug.getinfo(1), "多条", "")
|
bussHandle(strLuaDEID, dataSet[i])
|
updateCG_Detail(strLuaDEID, dataSet)
|
end
|
end
|
|
result_success(strLuaDEID)
|
|
end
|
