---
--- Created by wsz.
--- DateTime: 2025/5/15 下午3:31
---

--[[
 编码: GK-API-07
 名称: 订单取消接口
 作者: wsz
 入口函数：Order_Sync
 功能说明: 接收报文创建 Order_Hold 实体  ，对于已存在的数据无条件更新，返回报无需创建还货单 ；新增的数据设置需要创建还货单
 变更历史:v0.0.1

注意：
    1、按照此报文形式,这应是单条发送
    2、报文解析项少了来源单号、拦截类型、：存储时 来源单号不填，拦截类型填Interface
    3、needReturnOrder 仅 根据出库单的状态会涉及到

   订单类型： asn 入库订单 so出库订单 inventory 盘点单
   三者单据的主键no-与报文的taskId 对应
   入库单和盘点单已执行不允许取消，出库单订单未完成都允许取消，允许取消才插入Order_Hold

-----------------------------------------

入库单 Inbound_Order   no | b_state
状态为N_B_STATE>=20 AND N_B_STATE<=55  不允许取消
取消插入Order_Hold 表  同时更新N_BSTATE=91

盘点单  Count_Order   count_no | b_state
状态为N_B_STATE>=20 AND N_B_STATE<=50不允许取消，
取消插入Order_Hold 表  同时更新N_BSTATE=91

出库单 Outbound_Order no | b_state
状态为N_B_STATE IN(50,55,90,91)不允许取消，
，取消插入Order_Hold 表,
如果状态N_B_STATE>=25 AND N_B_STATE<=55,出参needReturnOrder=1



 --]]

local json = require("json")
local mobox = require("OILua_JavelinExt")
local m3 = require("oi_base_mobox")

local xml = require("oi_base_xml")

--- 实体标识-订单取消同步 TN_ORDER_CANCEL
local CLSID_OrderHold = "Order_Hold"

local CLSID_OrderHold_desc = "订单取消接口"

--- 实体标识-入库单
local CLSID_InboundOrder = "Inbound_Order"
--- 实体标识-出库单
local CLSID_OutboundOrder = "Outbound_Order"
--- 实体标识-盘点单
local CLSID_CountOrder = "Count_Order"

--根标签
local RootTag =  "response"


----- 出库单 -状态列表
--local STATUS_array_OutboundOrder = {"0"}
----- 入库单 - 状态列表
--local STATUS_array_Inbound_Order = {"0"}
----- 盘点单 - 状态列表
--local STATUS_array_Count_Order = {"0"}

--
local luaDEID

local ERR


-- 返回部分-----------------------------------------
--[[
-- 事务回滚-返回信息后终止执行
]]
local function result_transaction_back(strLuaDEID, msg)

    -- 回滚当次处理
    lua.Stop(strLuaDEID, msg)
    lua.Debug(strLuaDEID, debug.getinfo(1), "result_transaction_back-Stop 执行完毕", "")

    local result = {}
    result.flag = "failure" -- success|failure
    result.code = 5
    result.message = msg

    local  xmlstr = xml.json_to_xml(result,RootTag)

    do
        local nRet = mobox.returnValue(strLuaDEID, 1, xmlstr, result.code)
        if nRet ~= 0 then
            lua.Error(strLuaDEID, debug.getinfo(1), 'result_transaction_back-执行mobox.returnValue失败 ' .. nRet)
        end
    end
    error(msg,0)
    -- lua.Error(strLuaDEID, debug.getinfo(1), xmlstr)
end


--[[
-- 执行成功
]]
local function result_success(strLuaDEID,needReturnOrder,msg)

    local result = {}
    result.flag = "success" -- success|failure
    result.code = 0
    result.message = msg
    if needReturnOrder then   -- nil false
        result.needReturnOrder = needReturnOrder
    end

    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 result_failure(strLuaDEID,msg)

    local result = {}
    result.flag = "failure" -- success|failure
    result.code = 0
    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_failure-执行mobox.returnValue失败 ' .. nRet)
        end
    end
end


-------------------------------------------

-- util--------------------

------------------------
-- 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


--[[

strClsID: 数据类id
dataObj：待创建的数据对象

--]]
local function create_obj(strLuaDEID, strClsID, dataObj)

    -- 基础验证
    if (nil == strClsID or strClsID == '') then
        result_transaction_back(strLuaDEID, CLSID_OrderHold_desc .. "-创建对象失败,strClsID不可为空")
    end
    if type(dataObj) ~= 'table' then
        result_transaction_back(strLuaDEID, CLSID_OrderHold_desc .. "-创建对象失败,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


--[[
param
    table:字符串数组
    value:要判断是否存在的值
return
    true：存在
    false：不存在
]]
local function contains(table, value)
    for _, v in ipairs(table) do
        if v == value then return true end
    end
    return false
end



--[[
组装临时对象
]]
local function buildTemp(dataSet)
    local temp = {} -- 放置待创建数据

    -- 任务编号
    temp.no = lua.Get_StrAttrValue(dataSet.taskId)
    -- 订单类型
    temp.no_type = lua.Get_StrAttrValue(dataSet.taskType)
    -- 来源单号
    temp.bs_no = ""
    -- 货主编码
    temp.storer = lua.Get_StrAttrValue(dataSet.storerId)
    -- 物权
    temp.owner = lua.Get_StrAttrValue(dataSet.ownerId)
    -- 拦截类型
    temp.hold_type = "Interface"
    -- 状态
    temp.state = "10"
    -- 取消原因
    temp.note = lua.Get_StrAttrValue(dataSet.reason)

    return temp
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_OrderHold, json.encode(temp))

        if nRet ~= 0 then
            result_transaction_back(strLuaDEID, CLSID_OrderHold ..' 更新时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 updateStrDataJson = lua.table2str(updateObj)
    lua.Debug(strLuaDEID, debug.getinfo(1), CLSID_OrderHold .."-update准备覆盖已有数据", updateStrDataJson)
    local nRet, strRetInfo = mobox.updateDataObj(strLuaDEID, CLSID_OrderHold, updateStrDataJson)
    if (nRet ~= 0) then
        result_transaction_back(strLuaDEID, string.format(CLSID_OrderHold .."更新操作失败。code：%s，msg：%s", nRet, strRetInfo))
    end
end


--[[
desc:创建目标数据
]]
local function creatBussData(strLuaDEID, dataSet)

    -- 前置判断
    if dataSet.taskType == nil and  lua.trim(dataSet.taskType) == "" then
        result_transaction_back(strLuaDEID, string.format([[ %s 数据验证-操作失败。%s ]], CLSID_OrderHold, "报文‘订单类型(taskType)’-字段，不可为空"))
    end

    -- 允许创建‘订单取消实体’标记  - 暂留
    local FLAG = false
    -- 仅用于出库单组装返回报文用   nil、 0、 1
    local needReturnOrder

    -- 1. 出库订单判断-Outbound_Order
    if dataSet.taskType == "so" then
        lua.Debug(strLuaDEID, debug.getinfo(1), "订单类型-出库订单", dataSet.taskType)

        local strCondition
        do
            local filters = {}
            table.insert(filters, string.format([[ %s = '%s' ]], "S_NO", lua.Get_StrAttrValue(dataSet.taskId)))
            strCondition = table.concat(filters, " and ")
            lua.Debug(strLuaDEID, debug.getinfo(1), "filters-组装 出库订单 的where条件", strCondition)
        end
        -- strRetInfo:str   attr-value 型的数据
        local nRet, id, strRetInfo = mobox.getDataObjAttrByKeyAttr(strLuaDEID, CLSID_OutboundOrder, strCondition)
        if nRet == 0 then
            local  luaDataArray = json.decode(strRetInfo)
            lua.Debug(strLuaDEID, debug.getinfo(1), "出库单-luaDataArray", luaDataArray)
            local  luaData = m3.KeyValueAttrsToObjAttr(luaDataArray)
            lua.Debug(strLuaDEID, debug.getinfo(1), "出库单-luaData", luaData)
            --local  state = lua.Get_StrAttrValue( luaData.b_state)
            local  state = lua.Get_StrAttrValue( luaData.N_B_STATE)
            lua.Debug(strLuaDEID, debug.getinfo(1), "出库订单 b_state", state)

            FLAG = not  contains( { "50","55","90","91" },state ) --包含状态不准取消

            if FLAG then
                local state_toNum =  lua.Get_NumAttrValue(state)
                needReturnOrder = (state_toNum >=25 and state_toNum  <= 55 ) and 1 or 0
            end

        elseif nRet == 1 then
            --目标单据不存在
            result_transaction_back(strLuaDEID, string.format([[出库订单-出库单号:%s,不存在！]],lua.Get_StrAttrValue(dataSet.taskId)))
        else
            result_transaction_back(strLuaDEID, string.format([[异常:查询出库订单-出库单号:%s，时失败：%s]],lua.Get_StrAttrValue(dataSet.taskId),strRetInfo))
        end
    end


    -- 2. 入库单-Inbound_Order
    if dataSet.taskType == "asn" then
        lua.Debug(strLuaDEID, debug.getinfo(1), "订单类型-入库单", dataSet.taskType)

        local strCondition
        do
            local filters = {}
            table.insert(filters, string.format([[ %s = '%s' ]], "S_NO", lua.Get_StrAttrValue(dataSet.taskId)))
            strCondition = table.concat(filters, " and ")
            lua.Debug(strLuaDEID, debug.getinfo(1), "filters-组装 入库单 的where条件", strCondition)
        end
        -- strRetInfo:str   attr-value 型的数据
        local nRet, id, strRetInfo = mobox.getDataObjAttrByKeyAttr(strLuaDEID, CLSID_InboundOrder, strCondition)
        --local nRet, id, strRetInfo = mobox.GetDataObjByCondition(strLuaDEID, CLSID_InboundOrder, strCondition)

        if nRet == 0 then
            local  luaDataArray = json.decode(strRetInfo)
            --lua.Debug(strLuaDEID, debug.getinfo(1), "入库单 strRetInfo 类型", type(strRetInfo))
            --lua.Debug(strLuaDEID, debug.getinfo(1), "入库单 strRetInfo", strRetInfo)
            --local  luaJson = m3.objAttrsToLuaJson(CLSID_InboundOrder,strRetInfo)
            --lua.Debug(strLuaDEID, debug.getinfo(1), "入库单 luaJson", luaJson)
            local  luaData = m3.KeyValueAttrsToObjAttr(luaDataArray)
            lua.Debug(strLuaDEID, debug.getinfo(1), "入库单 luaData", luaData)
            --FLAG =  contains( STATUS_array_OutboundOrder, lua.Get_StrAttrValue( luaData.b_state))
            --local  state = lua.Get_StrAttrValue( luaData.b_state)
            local  state = lua.Get_StrAttrValue( luaData.N_B_STATE)
            lua.Debug(strLuaDEID, debug.getinfo(1), "入库单 b_state", state)
            local state_toNum =  lua.Get_NumAttrValue(state)
            FLAG = not (state_toNum >=20 and state_toNum  <= 55 )

            if FLAG then -- 需要更新 入库单 N_BSTATE=91
                local temp = {}
                temp.b_state = 91
                local nRet, str_data_attrset = mobox.luaJsonToObjAttrs(CLSID_InboundOrder, json.encode(temp))
                if nRet ~= 0 then
                    result_transaction_back(strLuaDEID, '更新入库单状态b_state时 luaJsonToObjAttrs 函数执行失败！msg：' .. str_data_attrset)
                end
                -- 反序列化为目标格式
                local attrValueObj = json.decode(str_data_attrset)

                -- 组装批量更新的数据格式
                local updateObj = {}

                local updateObj_item = {}
                updateObj_item.id = id
                updateObj_item.attrs = attrValueObj
                table.insert(updateObj, updateObj_item)

                local updateStrDataJson = lua.table2str(updateObj)
                lua.Debug(strLuaDEID, debug.getinfo(1), "入库单-update准备覆盖已有数据", updateStrDataJson)
                local nRet, strRetInfo = mobox.updateDataObj(strLuaDEID, CLSID_InboundOrder, updateStrDataJson)
                if (nRet ~= 0) then
                    result_transaction_back(strLuaDEID, string.format("入库单更新操作失败！code：%s，msg：%s", nRet, strRetInfo))
                end
            end

        elseif nRet == 1 then
            --目标单据不存在
            result_transaction_back(strLuaDEID, string.format([[入库单-入库单号:%s,不存在！]],lua.Get_StrAttrValue(dataSet.taskId)))
        else
            result_transaction_back(strLuaDEID, string.format([[异常:查询入库单-入库单号:%s，时失败：%s]],lua.Get_StrAttrValue(dataSet.taskId),strRetInfo))
        end
    end


    -- 3. 盘点单-Count_Order
    if dataSet.taskType == "inventory" then
        lua.Debug(strLuaDEID, debug.getinfo(1), "订单类型-盘点单", dataSet.taskType)

        local strCondition
        do
            local filters = {}
            table.insert(filters, string.format([[ %s = '%s' ]], "S_COUNT_NO", lua.Get_StrAttrValue(dataSet.taskId)))
            strCondition = table.concat(filters, " and ")
            lua.Debug(strLuaDEID, debug.getinfo(1), "filters-组装 盘点单 的where条件", strCondition)
        end
        -- strRetInfo:str   attr-value 型的数据
        local nRet, id, strRetInfo = mobox.getDataObjAttrByKeyAttr(strLuaDEID, CLSID_CountOrder, strCondition)
        if nRet == 0 then
            local  luaDataArray = json.decode(strRetInfo)
            lua.Debug(strLuaDEID, debug.getinfo(1), "盘点单-luaDataArray", luaDataArray)
            local  luaData = m3.KeyValueAttrsToObjAttr(luaDataArray)

            local  state = lua.Get_StrAttrValue( luaData.N_B_STATE)

            lua.Debug(strLuaDEID, debug.getinfo(1), "盘点单 b_state", state)

            local state_toNum =  lua.Get_NumAttrValue(state)
            FLAG = not (state_toNum >=20 and state_toNum  <= 50 )

            if FLAG then -- 需要更新 盘点单 N_BSTATE=91
                local temp = {}
                temp.b_state = 91
                local nRet, str_data_attrset = mobox.luaJsonToObjAttrs(CLSID_CountOrder, json.encode(temp))
                if nRet ~= 0 then
                    result_transaction_back(strLuaDEID, '更新盘点单状态b_state时 luaJsonToObjAttrs 函数执行失败！msg：' .. str_data_attrset)
                end
                -- 反序列化为目标格式
                local attrValueObj = json.decode(str_data_attrset)

                -- 组装批量更新的数据格式
                local updateObj = {}

                local updateObj_item = {}
                updateObj_item.id = id
                updateObj_item.attrs = attrValueObj
                table.insert(updateObj, updateObj_item)

                local updateStrDataJson = lua.table2str(updateObj)
                lua.Debug(strLuaDEID, debug.getinfo(1), "盘点单-update准备覆盖已有数据", updateStrDataJson)
                local nRet, strRetInfo = mobox.updateDataObj(strLuaDEID, CLSID_CountOrder, updateStrDataJson)
                if (nRet ~= 0) then
                    result_transaction_back(strLuaDEID, string.format("盘点单更新操作失败！code：%s，msg：%s", nRet, strRetInfo))
                end
            end

        elseif nRet == 1 then
            --目标单据不存在
            result_transaction_back(strLuaDEID, string.format([[盘点单-盘点单号:%s,不存在！]],lua.Get_StrAttrValue(dataSet.taskId)))
        else
            result_transaction_back(strLuaDEID, string.format([[异常:查询盘点单-盘点单号:%s，时失败：%s]],lua.Get_StrAttrValue(dataSet.taskId),strRetInfo))
        end
    end


    ------
    if not FLAG then
        result_failure(strLuaDEID, "目标单据状态不满足取消条件！不会生成‘单据取消’记录！")
        return -- 结束后续执行
    end

    -- 创建取消单记录
    local temp = buildTemp(dataSet)
    lua.Debug(strLuaDEID, debug.getinfo(1), "OrderHold待新增数据-temp", temp)
    create_obj(strLuaDEID, CLSID_OrderHold, temp)

    -- 返回数据
    result_success(strLuaDEID,needReturnOrder)

end









--[[
业务数据处理
]]
local function bussHandle(strLuaDEID, dataSet)

    -- 组装sql过滤条件
    local strCondition
    do
        local filters = {}
        table.insert(filters, string.format([[ %s = '%s' ]], "S_NO", lua.Get_StrAttrValue(dataSet.taskId)))
        strCondition = table.concat(filters, " and ")
        lua.Debug(strLuaDEID, debug.getinfo(1), "filters-组装的ordercancel的where条件", strCondition)
    end

    local nRet, id, strRetInfo = mobox.getDataObjAttrByKeyAttr(strLuaDEID, CLSID_OrderHold, strCondition)

    if nRet == 0 then
        -- key已存在
        lua.Debug(strLuaDEID, debug.getinfo(1), "add", "数据更新：" .. strRetInfo)
        -- updateBussData(strLuaDEID, dataSet, id)

        --result_failure(strLuaDEID,  string.format("任务id：%s 已存在",id))
        result_success(strLuaDEID,  nil,string.format("任务id：%s 已存在",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

    -- result_success(strLuaDEID,1) -- 更新的数据不需要创建 WMS还货入库单

end




local function Order_Cancel_main(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-07xml报文", 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"]
    ["OrderCancellationReq"]
    ["OrderCancellation_Input"]
    ["InputParameters"]
    ["OrderCancellation_TB"]

    if nil == dataSet then
        -- wms_base.Warning(strLuaDEID, 2, 201, CLSID_OrderHold_desc .."-未解析到soap目标节点!", json.encode(dataSet), "", CLSID_OrderHold_desc .."-dataSet")
        result_transaction_back(strLuaDEID, CLSID_OrderHold_desc .."-未解析到soap目标节点!")
    elseif #dataSet == 0 then
        -- 仅单条数据
        lua.Debug(strLuaDEID, debug.getinfo(1), "单条", dataSet)
        bussHandle(strLuaDEID, dataSet)
    else
        for i = 1, #dataSet do
            lua.Debug(strLuaDEID, debug.getinfo(1), "多条", "")
            bussHandle(strLuaDEID, dataSet[i])
        end
    end



end

--[[
固定-错误捕获处理
]]
local function errorHandler(err)
    ERR = err
    lua.Debug(luaDEID, debug.getinfo(1), "err-记录", err)
    --lua.Error(strLuaDEID, debug.getinfo(1), "err-记录:" .. err)
    return err
end

--[[ 入口函数 ]]
function Order_Cancel(strLuaDEID)
    luaDEID = strLuaDEID
    local success, result = xpcall(Order_Cancel_main, errorHandler,strLuaDEID)

    if not success then
        -- lua.Error(strLuaDEID, debug.getinfo(1), ERR)
    end

end