--[[ 
    编码: GK-API-06
    名称: 出库单创建接口
    作者: yuanfeng
    日期: 2025-7-24

    入口函数： Outbound_Sync
    功能说明:
        1. 接收上游系统的入库任务XML数据
        2. 检查入库单是否已存在
        3. 创建Outbound_Order主表和Outbound_Detail子表记录
        4. 返回处理结果
    更新
        2025-07-12 V1.1 新增出库单主表，state 默认为 "定版"
        
    输入XML示例:
--]] wms_base = require("wms_base")
xml = require("oi_base_xml")
xml2lua = require("xml2lua")

-- 创建出库单主表记录
local function create_outbound_order(strLuaDEID, order_data)

    local nRet1, CONST_FACTORY = wms_base.Get_sConst2("WMS_Default_Factory")
    -- 默认工厂标识
    local nRet2, CONST_WH = wms_base.Get_sConst2("WMS_Default_Warehouse")
    if nRet1 ~= 0 or nRet2 ~= 0 then
        return 1, "获取工厂或仓库常量失败"
    end

    local order = m3.AllocObject(strLuaDEID, "Outbound_Order")
    order.no = order_data.taskId
    order.bs_type = order_data.taskType
    order.bs_no = order_data.orderNo
    order.wave_no = order_data.waveId
    order.op_date = order_data.orderDate
    order.priority = order_data.priority
    order.note = order_data.memo or ""
    order.wh_code = CONST_WH
    order.area_code = ""
    order.factory = CONST_FACTORY
    -- 新增出库单主表状态字段
    order.state = "定版"
    -- 新增货主编码
    order.storer = order_data.storerId
    -- 新增源单号
    order.source_no = order_data.sourceBillNo
    -- lua.DebugEx(strLuaDEID, "预创建出库单主表", order)
    local nRet, result = m3.CreateDataObj(strLuaDEID, order)
    return nRet, result
end

-- 创建出库单明细记录
-- @param:item_date 是传入的物料明细实体数据
-- @param:order_data 传入出库单主表实体数据
local function create_outbound_detail(strLuaDEID, order_no, item_data, order_data)
    local detail = m3.AllocObject(strLuaDEID, "Outbound_Detail")
    -- 明细表字段映射
    detail.oo_no = order_no
    detail.storer = order_data.storerId
    detail.owner = order_data.ownerId
    detail.bs_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.prd_date = item_data.productDate
    detail.exp_date = item_data.expiryDate
    detail.udf01 = item_data.registerNo or ""
    detail.udf02 = item_data.cid or ""
    -- lua.DebugEx(strLuaDEID, "预创建出库单明细", detail)
    local nRet, result = m3.CreateDataObj(strLuaDEID, detail)
    return nRet, result
end
function Outbound_Sync(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",
        message = "成功"
    }
    -- lua.Debug(strLuaDEID, debug.getinfo(1), "出库单数据:", result)

    -- 1. 获取接口输入数据

    nRet, soap_xml = mobox.getCurEditDataPacket(strLuaDEID)
    if nRet ~= 0 then
        -- lua.Stop(strLuaDEID, "无法获取数据包: " .. soap_xml)
        result.flag = "failure"
        result.code = "1"
        result.message = "无法获取数据包: "
        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.message = "接口输入的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)
    -- lua.Debug(strLuaDEID, debug.getinfo(1), "查询出来的出库单数据:", strRetInfo)

    if nRet > 1 then
        result.flag = "failure"
        result.code = "3"
        result.message = "检查出库单是否存在时出错: " .. strRetInfo
        goto api_call_return
    elseif nRet == 0 then
        result.flag = "failure"
        result.code = "4"
        result.message = "出库单已存在 "
        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.message = "创建出库单主表失败:" .. 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, task_tb)
        if nRet ~= 0 then
            err_msg = string.format("创建出库单明细失败(行号:%d): %s", item.orderItemId, strRetInfo)
            result.flag = "failure"
            result.code = "5"
            result.message = err_msg
            isStop = 3
            goto api_call_return
        end
    end
    ::api_call_return::
    -- 7. 返回处理结果
    -- local result = {
    -- flag = nErr > 0 and "failure" or "success", 
    -- code = nErr,
    -- message = nErr > 0 and table.concat(err, "; ") or "成功", 
    -- }
    local xml_result = xml.json_to_xml(result, "response")

    mobox.returnValue(strLuaDEID, 0, xml_result, isStop)

    -- m3.EPI_Return(strLuaDEID, result)
    -- ApiReturn(strLuaDEID, 0, result, isStop)

end