--[[ 
    编码: GK-API-01
    名称: 货主信息同步接口
    作者: PMN
    日期: 2025-5-20

    入口函数：Storer_Sync
    功能说明:
        1. 接收货主信息同步请求
        2. 判断货主是否存在
        3. 执行新增或修改
        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:InCompanyReq
            xmlns:v1="http://www.gkht.com/Information/INV/Ebs/Schemas/InCompany/V1.0">
            <v1:Company_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:COMPANY_TB>
                        <!--1 or more repetitions:-->
                        <v1:COMPANY_TB_ITEM>
                            <v1:companyCode>CBJJT1</v1:companyCode>
                            <v1:companyName>北京京泰日晟科技有限公司</v1:companyName>
                            <v1:contactName></v1:contactName>
                            <v1:contactPhone></v1:contactPhone>
                            <v1:contactAddress></v1:contactAddress>
                            <v1:memo>个</v1:memo>
                        </v1:COMPANY_TB_ITEM>
						     <v1:COMPANY_TB_ITEM>
                            <v1:companyCode>CBJJXK</v1:companyCode>
                            <v1:companyName>北京吉鑫康商贸有限公司</v1:companyName>
                            <v1:contactName></v1:contactName>
                            <v1:contactPhone></v1:contactPhone>
                            <v1:contactAddress></v1:contactAddress>
                            <v1:memo>个</v1:memo>
                        </v1:COMPANY_TB_ITEM>
                    </v1:COMPANY_TB>
                </v1:InputParameters>
            </v1:Company_Input>
        </v1:InCompanyReq>
    </soapenv:Body>
</soapenv:Envelope>
--]]

wms_base = require("wms_base")
xml = require("oi_base_xml")

-- 检查货主是否存在
local function check_storer_exists(strLuaDEID, storer_item)
    local storerId = storer_item.storerId

    local strCondition = string.format("S_STORER = '%s' ", storerId)
    local nRet, id, strRetInfo = mobox.getDataObjAttrByKeyAttr(strLuaDEID, "STORER", strCondition)
    
    if nRet > 1 then
        return nRet, "检查货主是否存在时出错: " .. strRetInfo
    elseif nRet == 1 then
        return 1, "货主不存在"  -- 不存在
    else
        return 0, id  -- 存在
    end
end

-- 新增货主
local function create_storer(strLuaDEID, storer_data)
    local storer = m3.AllocObject(strLuaDEID, "STORER")
    local nRet1, CONST_WH = wms_base.Get_sConst2(strLuaDEID, "WMS_Default_Warehouse")
    local storerCode = storer_data.storerId
    -- 字段映射
    storer.storer = storerCode
    storer.storer_name = storerCode
    storer.company_code = storer_data.companyCode
    storer.company_name = storer_data.companyName
    storer.contact_name = storer_data.contactName or ""
    storer.contact_phone = storer_data.contactPhone or ""
    storer.contact_address = storer_data.contactAddress or ""
    storer.note = storer_data.memo or ""
    storer.default_wh_code = CONST_WH
    
    local nRet, result = m3.CreateDataObj(strLuaDEID, storer)
    return nRet, result
end

-- 更新货主信息
local function update_storer(strLuaDEID, storer_id, storer_data)
    local update_storer_obj = {
            {
                id = storer_id,
                attrs = {
                    { attr = "S_COMPANY_CODE", value = storer_data.companyCode },
                    { attr = "S_COMPANY_NAME", value = storer_data.companyName },
                    { attr = "S_STORER_NAME", value = storer_data.companyName },
                    { attr = "S_CONTACT_NAME", value = storer_data.contactName },
                    { attr = "S_CONTACT_PHONE", value = storer_data.contactPhone },
                    { attr = "S_CONTACT_ADDRESS", value = storer_data.contactAddress },
                    { attr = "S_NOTE", value = storer_data.memo },
                }
            }
        }
    
    local nRet, result = mobox.updateDataObj( strLuaDEID, "STORER", lua.table2str(update_storer_obj) )
    return nRet, result
end

-- 处理单个货主记录
local function process_storer_item(strLuaDEID, storer_item)
    
    -- 1. 检查货主是否存在
    local nRet, result = check_storer_exists(strLuaDEID, storer_item)
    if nRet > 1 then
        return nRet, result
    end
    
    -- 2. 存在则更新，不存在则新增
    if nRet == 0 then
        local storer_id = result
        -- 货主存在，更新信息
        nRet, result = update_storer(strLuaDEID, storer_id, storer_item)
        if nRet ~= 0 then
            return nRet, "更新货主信息失败: " .. tostring(result)
        end
        return 0, {action = "update", id = storer_id}
    else
        -- 货主不存在，新增
        nRet, result = create_storer(strLuaDEID, storer_item)
        if nRet ~= 0 then
            return nRet, "新增货主失败: " .. tostring(result)
        end
        return 0, {action = "create", id = result}
    end
end

function Storer_Sync(strLuaDEID)
    local nRet, strRetInfo, nErr
    local err_msg
    nErr = 0
    local isStop = 0
    local err = {}
    
    -- m3.PrintLuaDEInfo(strLuaDEID)
    
    -- 1. 获取接口输入数据
    local soap_xml
    nRet, soap_xml = mobox.getCurEditDataPacket(strLuaDEID)
    if nRet ~= 0 then 
        lua.Stop(strLuaDEID, "无法获取数据包: " .. soap_xml)
        isStop = 3
        return
    end
    
    -- 2. 解析XML
    local parsed_data
    nRet, parsed_data = xml.parse(soap_xml)
    if nRet ~= 0 then
        lua.Stop(strLuaDEID, "接口输入的XML格式非法!")
        isStop = 3
        return
    end
    
    -- 3. 提取货主数据
    local company_data = parsed_data.Envelope.Body.InCompanyReq.Company_Input
    local input_params = company_data.InputParameters
    local company_tb = input_params.COMPANY_TB
    
    -- 处理单条或多条货主数据
    local storer_items = {}
    if company_tb.COMPANY_TB_ITEM[1] ~= nil then
        storer_items = company_tb.COMPANY_TB_ITEM
    else
        storer_items = {company_tb.COMPANY_TB_ITEM}
    end
    
    -- 4. 处理每条货主记录
    for i, item in ipairs(storer_items) do
        local storer_data = {
            storerId = item.storerId,
            companyCode = item.companyCode,
            companyName = item.companyName,
            contactName = item.contactName or "",
            contactPhone = item.contactPhone or "",
            contactAddress = item.contactAddress or "",
            memo = item.memo or ""
        }
        
        -- 必填字段校验
        if not storer_data.companyCode or storer_data.companyCode == "" then
            err_msg = string.format("第%d条记录: companyCode不能为空", i)
            wms_base.Warning(strLuaDEID, 1, 601, err_msg, "从GK-WMS系统同步货主信息")
            nErr = nErr + 1
            err[nErr] = err_msg
            lua.Stop(strLuaDEID, err_msg)
            isStop = 5
        end
        
        if not storer_data.companyName or storer_data.companyName == "" then
            err_msg = string.format("第%d条记录: companyName不能为空", i)
            wms_base.Warning(strLuaDEID, 1, 601, err_msg, "从GK-WMS系统同步货主信息")
            nErr = nErr + 1
            err[nErr] = err_msg
            lua.Stop(strLuaDEID, err_msg)
            isStop = 5
        end

        if not storer_data.storerId or storer_data.storerId == "" then
            err_msg = string.format("第%d条记录: storerId不能为空", i)
            wms_base.Warning(strLuaDEID, 1, 601, err_msg, "从GK-WMS系统同步货主信息")
            nErr = nErr + 1
            err[nErr] = err_msg
            lua.Stop(strLuaDEID, err_msg)
            isStop = 5
        end
        
        -- 处理货主记录
        nRet, result = process_storer_item(strLuaDEID, storer_data)
        if nRet ~= 0 then
            err_msg = result
            wms_base.Warning(strLuaDEID, 1, 601, err_msg, "从GK-WMS系统同步货主信息")
            nErr = nErr + 1
            err[nErr] = err_msg
            lua.Stop(strLuaDEID, err_msg)
            isStop = 5
        end
    end
    
    -- 5. 返回响应
    local response = {
        flag = nErr > 0 and "failure" or "success",
        code = nErr,
        message = nErr > 0 and table.concat(err, "; ") or "处理成功",
    }
    
    local xml_result = xml.json_to_xml(response, "response")
    mobox.returnValue(strLuaDEID, 0, xml_result, isStop)
end