1. 国科盘点信息同步功能代码校验 2. 小件收货信息同步 3. 完善SKU同步Grid料箱

fy36

2025-06-09 a2861d59d2245b349ded89a6afe8249dd96c52e1

 lua_code/Lua/SKU_Sync.lua

@@ -9,7 +9,8 @@

    功能说明:
        1. 接收来自上游系统的 XML 格式数据，并解析该数据, 创建SKU及SKU_UPC
        
    更新：
        2025/06/09 更新了udf01~udf04的属性变更
        <soapenv:Envelope
            xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/">
            <soap:Header
@@ -70,7 +71,23 @@
       V2.1 Yuanfeng
       1. 统一了返回结果格式，使用Create_result函数创建标准化的返回结构
       2. 优化了代码结构
--]] wms_base = require("wms_base")
--]] --[[ 
    编码: GK-API-001
    名称: 盘点计划同步
    作者: HAN
    日期: 2025-1-29

    入口函数： SKU_Sync
    来源项目:  国科项目

    功能说明:
        1. 接收来自上游系统的 XML 格式数据，并解析该数据, 创建SKU及SKU_UPC
        
    更改记录:
       V2.0 HAN 20250402  代码规范       
       V2.1 Yuanfeng 优化返回结果处理
       V2.2 优化错误处理和返回逻辑
       ]] wms_base = require("wms_base")
xml = require("oi_base_xml")
mobox = require("OILua_JavelinExt")
m3 = require("oi_base_mobox")
@@ -87,7 +104,6 @@

local function create_sku_upc(strLuaDEID, storer, item_code, upc_code)
    local nRet, strRetInfo

    if (upc_code == '' or upc_code == nil) then
        return 0
    end
@@ -102,37 +118,109 @@
    return nRet, strRetInfo
end

-- 创建/更新SKU对应的货品料箱格参数
-- 输入参数：strLuaDEID - 执行环境ID
--          skuModel - SKU数据模型（包含料格参数）
local function create_or_update_sku_gridbox(strLuaDEID, skuModel)
    local nRet, strRetInfo
    local err_msg = ''

    -- 获取默认容器类型定义编码
    local nConstRet, CONST_CTD_CODE = wms_base.Get_sConst2("WMS_Default_CNTR_Type")
    if nConstRet ~= 0 then
        return 1, "获取默认容器类型定义编码失败: " .. CONST_CTD_CODE
    end

    -- 检查必填字段
    if not skuModel.item_code or not skuModel.storer then
        return 1, "缺少必要参数: item_code或storer"
    end

    -- 设置默认料格类型
    skuModel.ctd_code = CONST_CTD_CODE
    skuModel.cell_type = skuModel.cell_type -- 料格类型

    -- 根据商品编码(item_code)和货主(storer)以及容器类型定义编码(ctd_code)关联查询货品料箱格参数
    local strCondition = string.format("S_ITEM_CODE = '%s' AND S_STORER = '%s' AND S_CTD_CODE='%s'", skuModel.item_code,
        skuModel.storer, skuModel.ctd_code)
    lua.DebugEx(strLuaDEID, "查询SKU_GridBox_Parm条件", strCondition)

    local nRet, gridBoxParams = m3.GetDataObjByCondition(strLuaDEID, "SKU_GridBox_Parm", strCondition)
    lua.DebugEx(strLuaDEID, "查询SKU_GridBox_Parm结果", gridBoxParams)

    if nRet == 0 then
        -- 记录已存在，执行更新操作
        local update_gridbox_obj = {{
            id = gridBoxParams.id,
            attrs = {{
                attr = "N_LOADING_LIMIT",
                value = skuModel.loading_limit -- 更新容器装载上限
            }, {
                attr = "S_CELL_TYPE",
                value = skuModel.cell_type -- 更新料格类型
            }}
        }}
        lua.DebugEx(strLuaDEID, "准备更新SKU_GridBox_Parm属性", update_gridbox_obj)
        nRet, strRetInfo = mobox.updateDataObj(strLuaDEID, "SKU_GridBox_Parm", lua.table2str(update_gridbox_obj))
        lua.DebugEx(strLuaDEID, "更新SKU_GridBox_Parm结果", nRet .. "    返回值" .. strRetInfo)
        if nRet ~= 0 then
            return 1, "更新SKU_GridBox_Parm属性失败: " .. strRetInfo
        end
    elseif nRet == 1 then
        -- 记录不存在，创建新的料箱格参数
        local gridbox = m3.AllocObject(strLuaDEID, "SKU_GridBox_Parm")
        gridbox.item_code = skuModel.item_code -- 商品编码
        gridbox.storer = skuModel.storer -- 货主
        gridbox.ctd_code = skuModel.ctd_code -- 容器类型定义编码
        gridbox.loading_limit = skuModel.loading_limit -- 设置容器装载上限
        gridbox.cell_type = skuModel.cell_type -- 格类型
        lua.DebugEx(strLuaDEID, "准备创建SKU_GridBox_Parm", gridbox)
        nRet, strRetInfo = m3.CreateDataObj(strLuaDEID, gridbox)
        if nRet ~= 0 then
            return 1, "创建SKU_GridBox_Parm失败: " .. strRetInfo
        end
    else
        -- 查询出错
        return 1, "查询SKU_GridBox_Parm时出错: " .. strRetInfo
    end
    return 0, strRetInfo
end

local function create_sku(strLuaDEID, sku_input_data)
    local nRet, strRetInfo
    local err_msg = ''

    -- 分配SKU对象
    local sku = m3.AllocObject(strLuaDEID, "SKU")
    lua.DebugEx(strLuaDEID, "SKU分配对象", sku)
    sku.item_code = sku_input_data.skuId
    sku.storer = sku_input_data.storerId
    sku.short_name = sku_input_data.skuName
    sku.item_name = sku_input_data.skuDec
    sku.spec = sku_input_data.spec
    sku.udf01 = sku_input_data.packageCode
    sku.udf02 = sku_input_data.packageQty
    sku.unit = sku_input_data.goodsUnit
    sku.long = lua.Get_NumAttrValue(sku_input_data.length)
    sku.middle = lua.Get_NumAttrValue(sku_input_data.width)
    sku.short = lua.Get_NumAttrValue(sku_input_data.height)
    sku.abc_type = sku_input_data.abcType
    sku.long = lua.Get_NumAttrValue(sku_input_data.length) or 0
    sku.middle = lua.Get_NumAttrValue(sku_input_data.width) or 0
    sku.short = lua.Get_NumAttrValue(sku_input_data.height) or 0
    sku.count_method = "Limit";
    sku.abc_type = sku_input_data.abcType or ""
    sku.is_life_mgt = (sku_input_data.isBatchMgr == "1" and 'Y') or 'N'
    sku.is_sn_mgt = (sku_input_data.isSnMgr == "1" and 'Y') or 'N'
    sku.udf03 = sku_input_data.isSnStorageMgr
    sku.img_url = sku_input_data.imgUrl
    sku.img_url = sku_input_data.imgUrl or ""
    sku.cell_type = sku_input_data.cidtype
    sku.prod_line = sku_input_data.productLine
    sku.udf04 = sku_input_data.storageConditions
    sku.item_type = sku_input_data.skuType
    sku.loading_limit = lua.Get_NumAttrValue(sku_input_data.maxCount)
    sku.loading_limit = lua.Get_NumAttrValue(sku_input_data.maxCount) or 0
    --- 2025/6/9 新增/更改字段
    sku.udf01 = sku_input_data.productLine or "";
    sku.udf03 = sku_input_data.isSnStorageMgr or ""
    sku.udf02 = sku_input_data.storageConditions or ""
    sku.udf04 = sku_input_data.packageCode or "";
    sku.udf05 = lua.Get_NumAttrValue(sku_input_data.packageQty) or 0;
    lua.DebugEx(strLuaDEID, "SKU赋值后", sku)

    -- 检查SKU是否已存在
    local id
    local strCondition = "S_ITEM_CODE = '" .. sku.item_code .. "' AND S_STORER = '" .. sku.storer .. "'"
    local strCondition = string.format("S_ITEM_CODE = '%s' AND S_STORER = '%s'", sku.item_code, sku.storer)
    nRet, id, strRetInfo = mobox.getDataObjAttrByKeyAttr(strLuaDEID, "SKU", strCondition)

    if nRet > 1 then
@@ -180,9 +268,6 @@
                attr = "S_CELL_TYPE",
                value = sku.cell_type
            }, {
                attr = "S_PROD_LINE",
                value = sku.prod_line
            }, {
                attr = "N_LOADING_LIMIT",
                value = sku.loading_limit
            }, {
@@ -206,6 +291,9 @@
            }, {
                attr = "S_UDF04",
                value = sku.udf04
            }, {
                attr = "S_UDF05",
                value = sku.udf05
            }}
        }}

@@ -217,7 +305,7 @@

    -- 处理SKU_UPC
    local upc_codes = {sku_input_data.sptm, sku_input_data.barcode1, sku_input_data.barcode2, sku_input_data.barcode3,
                       sku_input_data.barcode_pk}
                       sku_input_data.barcode_pk, sku_input_data.upc}

    for _, upc_code in ipairs(upc_codes) do
        if upc_code and upc_code ~= '' then
@@ -228,22 +316,38 @@
        end
    end

    -- 处理SKU_GridBox_Parm
    nRet, strRetInfo = create_or_update_sku_gridbox(strLuaDEID, sku)
    if nRet ~= 0 then
        return 1, "处理SKU_GridBox_Parm失败: " .. strRetInfo
    end

    return 0
end

-- Main函数
function SKU_Sync(strLuaDEID)
    -- 初始化最终结果
    local FinalRes = Create_result()

    -- 1. 获取xml数据包
    local nRet, soap_xml = mobox.getCurEditDataPacket(strLuaDEID)
    if nRet ~= 0 then
        FinalRes = Create_result("failure", "201", "无法获取数据包: " .. soap_xml)
        local xml_result = xml.json_to_xml(FinalRes, "response")
        mobox.returnValue(strLuaDEID, 0, xml_result, 0)
        lua.Stop(strLuaDEID, "获取数据包失败", FinalRes)
        return
    end

    lua.DebugEx(strLuaDEID, "获取到的数据包", soap_xml)

    -- 2. 解析xml
    local nRet, parsed_data = xml.parse(soap_xml)
    if nRet ~= 0 then
        FinalRes = Create_result("failure", "202", "xml格式非法")
        local xml_result = xml.json_to_xml(FinalRes, "response")
        mobox.returnValue(strLuaDEID, 0, xml_result, 0)
        lua.Stop(strLuaDEID, "xml格式非法", FinalRes)
        return
    end
@@ -252,6 +356,8 @@
    local sku_data = parsed_data.Envelope.Body.inCommodityReq.COMMODITY_Input.InputParameters.COMMODITY_TB
    if not sku_data or not sku_data.COMMODITY_TB_ITEM then
        FinalRes = Create_result("failure", "203", "xml数据格式错误，缺少COMMODITY_TB_ITEM")
        local xml_result = xml.json_to_xml(FinalRes, "response")
        mobox.returnValue(strLuaDEID, 0, xml_result, 0)
        lua.Stop(strLuaDEID, "xml数据格式错误", FinalRes)
        return
    end
@@ -263,7 +369,6 @@
    end

    -- 5. 遍历所有SKU数据
    local FinalRes = Create_result()
    for i = 1, #sku_items do
        local sku_item = sku_items[i]

@@ -275,12 +380,15 @@

            -- 设置错误结果并停止处理
            FinalRes = Create_result("failure", "204", "SKU同步失败", err_msg)
            local xml_result = xml.json_to_xml(FinalRes, "response")
            mobox.returnValue(strLuaDEID, 0, xml_result, 0)
            lua.Stop(strLuaDEID, "SKU同步失败: " .. sku_item.skuId, FinalRes)
            return
        end
    end

    -- 6. 返回成功
    FinalRes = Create_result("success", "0", "SKU同步成功")
    local xml_result = xml.json_to_xml(FinalRes, "response")
    mobox.returnValue(strLuaDEID, 0, xml_result, 0)
end