--[[
    编码:   GK-API-05
    名称:   小件任务创建接口
    作者:   Peter fang
    日期:   2025-05-13

    入口函数： Inbound_Sync
    来源项目： 国科项目
    
    功能说明：
        1. 接收来自上游系统的XML格式数据，并解析该数据，创建Inbound Order及Inbound Detail
        2. 创建Inbound Palletization及Inbound Pallet Detail
]]

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

-- 创建统一返回结果
local function create_result(flag, code, msg)
    return {
        flag = flag or "success",
        code = code or "0",
        message = msg or ""
    }
end

local function return_value(strLuaDEID, success,err_msg)
    if success==false then
        lua.Stop( strLuaDEID, err_msg )
    end
    local flag = "success"
    local code="0"
    if success==true then
        flag = "success"
        code="0"
    else
        flag = "failure"
        code="1"
    end
    local result= create_result( flag, code, err_msg )
    local xml_result = xml.json_to_xml(result, "response")
    local value=0
    if flag=="success" then
        value=0
    else
        value=3
    end 
    mobox.returnValue(strLuaDEID,1,xml_result,value)
end

local function count_cell_list(t)
    local count = 0
    for cell,group in pairs(t) do
        if(cell~=nil and cell~="") then
            count = count + 1
        end
    end
    return count
end

local function group_by(t, key)
    local result = {}
    local getKey = type(key) == "function" and key or function(item)
        return item[key]
    end
    for _, item in ipairs(t) do
        local groupKey = getKey(item)
        if groupKey ~= nil then
            if not result[groupKey] then
                result[groupKey] = {}
            end
            table.insert(result[groupKey], item)
        end
    end
    return result
end

local function goods_count(items)
    local group_table = group_by(items, "skuId")
    local count = 0
    for _ in pairs(group_table) do
        count = count + 1
    end
    return count
end

local function sku_count(items)
    local qty=0
    for _,v in ipairs(items) do
        if v.qty~=nil then
            qty=qty+lua.Get_NumAttrValue(v.qty)
        end
    end
    return qty
end

local function get_celltype(group,cid)
    local spec="A"
    local cellItems={}
    for _,cell in ipairs(group) do
        table.insert(cellItems,cell)
    end
    local by_cell=group_by(cellItems,"boxCode")
    local cellCount=count_cell_list(by_cell)
    if (cellCount==1) then
        spec="A"
    elseif (cellCount==2) then
        spec="B"
    elseif (cellCount==3) then
        spec="C"    
    elseif (cellCount==4) then
        spec="D"
    elseif (cellCount==6) then
        spec="E"
    elseif (cellCount==8) then
        spec="F"
    else
        return 1, "料格数量"..cellCount.. "料箱规格超出系统定义！cntr_code= "..cid
    end
    return 0, spec
end

local function create_inbound_pallet(strLuaDEID,inboundData,items)
    local nRet,strRetInfo
    local by_pallet=group_by(items,"cid")
    for cid, group in pairs(by_pallet) do
        if cid~=nil and cid~="" then
            if(group[1].boxCode~=nil and group[1].boxCode~="") then
                local spec
                nRet, spec = get_celltype(group,cid)
                if nRet ~= 0 then
                    return 1, spec
                end
                local detail_item_data = {}
                for _,cell in ipairs(group) do
                    local strTableName = "TN_SKU"
                    local strFieldList = '["S_UDF01"]'
                    local strCondition =string.format("S_STORER='%s' AND S_ITEM_CODE='%s'",inboundData.storerId,cell.skuId)
                    nRet, strRetInfo=mobox.queryTable(strLuaDEID,strTableName, strFieldList,1, strCondition, "")
                    if (nRet ~= 0) then
                        return 1,"查询SKU信息失败!"..strRetInfo
                    end
                    local sku_info = json.decode(strRetInfo)
                    if not sku_info or #sku_info == 0 then
                        return 1,"SKU信息不存在"..cell.skuId
                    end
                    local sudf01 = sku_info[1].S_UDF01

                    local item_detail 
                    item_detail = m3.AllocObject2( strLuaDEID, "INB_Pallet_Detail")
                    item_detail.S_CNTR_CODE = cid
                    local seg = lua.split(cell.boxCode, '-' )
                    if ( #seg ~= 2 ) then
                        return 1,"料格号格式错误"..cell.boxCode
                    end
                    item_detail.S_CELL_NO =spec.."-".. lua.StrToNumber(seg[2])
                    item_detail.S_CELL_CODE=cell.boxCode
                    item_detail.S_ITEM_CODE = cell.skuId
                    item_detail.S_ITEM_NAME = cell.skuId
                    item_detail.S_ITEM_STATE=cell.skuStatus
                    item_detail.S_STORER=inboundData.storerId
                    item_detail.S_OWNER=inboundData.ownerId
                    item_detail.F_QTY = cell.qty
                    item_detail.S_UDF01=sudf01
                    item_detail.S_UDF02=cell.registerNo
                    item_detail.S_WMS_BN = cell.batchNo
                    item_detail.S_BATCH_NO = cell.produceCode
                    item_detail.D_PRD_DATE = cell.productDate
                    item_detail.D_EXP_DATE = cell.expiryDate
                    item_detail.S_BS_TYPE="GK_IN_TASK"
                    item_detail.S_BS_NO=inboundData.taskId
                    item_detail.N_BS_ROW_NO=cell.row_no

                    table.insert(detail_item_data, item_detail)
                end
                nRet, strRetInfo = wms_pallet.Add_INB_Pallet_Detail( strLuaDEID, cid, detail_item_data,"GK_IN_TASK",inboundData.taskId)
                if nRet ~= 0 then
                    return 1,"生成码盘信息失败".. strRetInfo
                end                     
            end
        end
    end
    return 0, ""
end
local function create_container(strLuaDEID,inboundData,items)
    local nRet,strRetInfo
    local by_pallet=group_by(items,"cid")
    for cid, group in pairs(by_pallet) do
        if cid~=nil and cid~="" then
            if(group[1].boxCode~=nil and group[1].boxCode~="") then
                local spec
                nRet, spec = get_celltype(group,cid)
                if nRet ~= 0 then
                    lua.DebugEx(strLuaDEID, "create_container", group[1].boxCode.. "cid="..cid)
                    return 1, spec
                end
            nRet, strRetInfo = wms.wms_GetConst("WMS_Default_CNTR_Type")
                if (nRet ~= 0) then
                    return 1, "获取默认容器类型失败！"..strRetInfo
                end
                local container_type_info = strRetInfo
                local strObjID
                local strCondition =string.format("S_CODE='%s'",cid)
                nRet,strObjID,strRetInfo=mobox.getDataObjAttrByKeyAttr(strLuaDEID,"Container",strCondition)
                if nRet ~= 0 then   
                    return 1,cid.."容器不存在!"..strRetInfo
                end
                local update_container_obj={
                {
                    id = strObjID,
                    attrs = {
                        { attr = "S_CTD_CODE", value =container_type_info }, -- 料箱类型
                        { attr = "S_SPEC", value = spec }, -- 料箱规格
                    }
                }}
                nRet, strRetInfo = mobox.updateDataObj( strLuaDEID, "Container", lua.table2str(update_container_obj) )
                if (nRet ~= 0 ) then 
                    return 1,"更新【Container】属性失败!"..strRetInfo
                end    
            end
        end
    end
    return 0, ""
end

local function create_inbound_detail(strLuaDEID,detail)
    local nRet, strRetInfo

    local inbound_detail = m3.AllocObject( strLuaDEID,"Inbound_Detail")
    inbound_detail.row_no=detail.row_no
    inbound_detail.io_no=detail.io_no
    inbound_detail.storer=detail.storer
    inbound_detail.owner=detail.owner
    inbound_detail.bs_row_no=detail.bs_row_no
    inbound_detail.item_code=detail.item_code
    inbound_detail.item_name=detail.item_name
    inbound_detail.item_state=detail.item_state
    inbound_detail.qty=detail.qty
    inbound_detail.wms_bn=detail.wms_bn
    inbound_detail.batch_no=detail.batch_no
    inbound_detail.prd_date=detail.prd_date
    inbound_detail.exp_date=detail.exp_date
    inbound_detail.ext_attr1=detail.registerNo
    inbound_detail.note=detail.note

    local strTableName = "TN_SKU"
    local strFieldList = '["S_UDF01"]'
    local strCondition =string.format("S_STORER='%s' AND S_ITEM_CODE='%s'",detail.storer,detail.item_code)
    nRet, strRetInfo=mobox.queryTable(strLuaDEID,strTableName, strFieldList,1, strCondition, "")
    if (nRet ~= 0) then
        return 1,"查询SKU信息失败!"..strRetInfo
    end
    local sku_info = json.decode(strRetInfo)
    if not sku_info or #sku_info == 0 then
        return 1,"SKU信息不存在"..detail.item_code
    end
    inbound_detail.udf01 = sku_info[1].S_UDF01
    inbound_detail.udf19=detail.sn
    inbound_detail.udf20=detail.cntr_code

    nRet, strRetInfo = m3.CreateDataObj(strLuaDEID, inbound_detail)
    if (nRet==nil or nRet ~= 0 ) then
        return 1, "创建系统入库单明细失败！"..strRetInfo.."no= "..detail.io_no
    end
    return 0, ""
end 

local function gk_create_inbound_detail(strLuaDEID,inboundData, inboundItem,index)
    local nRet, strRetInfo

    local inbound_detail = m3.AllocObject( strLuaDEID,"GK_IN_TASK_Detail")
    inbound_detail.row_no=index
    inbound_detail.io_no=inboundData.taskId
    inbound_detail.storer=inboundData.storerId
    inbound_detail.owner=inboundData.ownerId
    inbound_detail.bs_row_no=inboundItem.orderItemId
    inbound_detail.item_code=inboundItem.skuId
    inbound_detail.item_name=inboundItem.skuId
    inbound_detail.item_state=inboundItem.skuStatus
    inbound_detail.qty=lua.Get_NumAttrValue(inboundItem.qty)
    inbound_detail.wms_bn=inboundItem.batchNo
    inbound_detail.batch_no=inboundItem.produceCode
    inbound_detail.prd_date=inboundItem.productDate
    inbound_detail.exp_date=inboundItem.expiryDate
    inbound_detail.register_no=inboundItem.registerNo
    inbound_detail.cntr_code=inboundItem.cid
    inbound_detail.cell_no=inboundItem.boxCode
    inbound_detail.sn=inboundItem.sn

    nRet, strRetInfo = m3.CreateDataObj(strLuaDEID, inbound_detail)
    if (nRet==nil or nRet ~= 0 ) then
        return 1, "创建入库单明细失败！"..strRetInfo.."no= "..inboundData.taskId
    end

    if inboundItem.boxCode==nil or inboundItem.boxCode=="" then
         nRet, strRetInfo=create_inbound_detail(strLuaDEID,inbound_detail)
        if (nRet==nil or nRet ~= 0 ) then
            return 1, "创建系统入库单明细失败！"..strRetInfo.."no= "..inboundData.taskId
        end
    end
   
    return 0, ""
end 

local function create_inbound(strLuaDEID, gk_inbound)
   local nRet, strRetInfo

   local inbound = m3.AllocObject( strLuaDEID,"Inbound_Order")
   inbound.no=gk_inbound.no
   inbound.b_state=0
   inbound.factory=gk_inbound.factory
   inbound.wh_code=gk_inbound.wh_code
   inbound.bs_type=gk_inbound.bs_type
   inbound.bs_no=gk_inbound.bs_no
   inbound.asn_no=gk_inbound.asn_no
   inbound.op_date=gk_inbound.op_date
   inbound.priority=gk_inbound.priority
   inbound.note=gk_inbound.note
   
    nRet, strRetInfo = m3.CreateDataObj(strLuaDEID, inbound)
   if (nRet==nil or nRet ~= 0 ) then
       return 1,  "创建系统入库单失败！"..strRetInfo.."no= "..gk_inbound.no
   end

    return 0,""
end

local function gk_create_inbound(strLuaDEID, inboundData,emptyCellCount)
   local nRet, strRetInfo

   local inbound = m3.AllocObject( strLuaDEID,"GK_IN_TASK")
   inbound.no=inboundData.taskId
   inbound.b_state=0
   nRet, strRetInfo = wms.wms_GetConst("WMS_Default_Factory")
    if (nRet ~= 0) then
         return 1, "获取默认工厂失败！"..strRetInfo
    end
   inbound.factory=strRetInfo
   nRet, strRetInfo = wms.wms_GetConst("WMS_Default_Warehouse")
   if (nRet ~= 0) then
        return 1, "获取默认仓库失败！"..strRetInfo
   end
   inbound.wh_code=strRetInfo
   inbound.bs_type=inboundData.taskType
   inbound.bs_no=inboundData.orderNo
   inbound.asn_no=inboundData.asnNo
   inbound.op_date=inboundData.orderDate
   inbound.priority=inboundData.priority
   inbound.source_no=inboundData.sourceBillNo
   inbound.note=inboundData.memo
   
   local detailItems = inboundData.TaskCreation_TB_ITEM
   local items={}
   if detailItems==nil then
       return 1, "入库单明细为空"
   end
   if detailItems[1]==nil then
        items={detailItems}
   else
        items=detailItems
   end
   if items==nil or items[1]==nil then
       return 1, "入库单明细为空"
    else
        local index=1
        for index, item in ipairs(items) do
            --创建入库单明细
            item.row_no=index
             nRet, strRetInfo = gk_create_inbound_detail(strLuaDEID,inboundData,item,index)
             if (nRet==nil or nRet ~= 0 ) then
                return 1, "创建入库单明细失败！"..strRetInfo.."no= "..inboundData.taskId
             end
        end
    end

    inbound.good_type_num=goods_count(items)
    inbound.total_qty=sku_count(items)
    nRet, inbound = m3.CreateDataObj(strLuaDEID, inbound)
   if (nRet==nil or nRet ~= 0 ) then
       return 1,  "创建入库单失败！"..inbound.."no= "..inboundData.taskId
   end

    --创建系统入库单
    if emptyCellCount>0 then
         nRet, strRetInfo =create_inbound(strLuaDEID,inbound)
        if (nRet==nil or nRet ~= 0 ) then
            return 1, "创建系统入库单失败！"..strRetInfo.."no= "..inboundData.taskId
        end
    end

    --创建入库单码盘
    nRet, strRetInfo =create_inbound_pallet(strLuaDEID,inboundData,items)
    if (nRet==nil or nRet ~= 0 ) then
        return 1, "创建码盘明细失败！"..strRetInfo.."no= "..inboundData.taskId
    end
    
    --创建容器料格信息
    nRet, strRetInfo = create_container(strLuaDEID,inboundData,items)
    if (nRet==nil or nRet ~= 0 ) then
        return 1, "创建容器失败！"..strRetInfo.."no= "..inboundData.taskId
    end

    return 0,""
end

function Inbound_Sync(strLuaDEID)
    local nRet, strRetInfo
    local err_msg
    
    --m3.PrintLuaDEInfo(strLuaDEID)

    local soap_xml
    nRet,soap_xml=mobox.getCurEditDataPacket(strLuaDEID)
    if ( nRet ~=0 ) then 
        return_value(strLuaDEID, false,  "无法获取数据包 !"..soap_xml)
        return
    end
    local parsed_data
    nRet, parsed_data = xml.parse(soap_xml)
    if ( nRet ~= 0 ) then
        return_value(strLuaDEID, false, "接口输入的XML格式非法!")
        return
    end
    
    local inboundItems=parsed_data.Envelope.Body.InTaskCreationReq.TaskCreation_Input.InputParameters.TaskCreation_TB
    local inboundSet={}
    if inboundItems==nil then
        return_value(strLuaDEID, false, "接口输入的XML格式非法!")
        return
    end
    if inboundItems[1]==nil then
        inboundSet={inboundItems}
    else
        inboundSet=inboundItems
    end

    for i, inboundData in ipairs(inboundSet) do
         if inboundData.TaskCreation_TB_ITEM==nil then
            err_msg = "入库明细为空"
            return_value(strLuaDEID, false, err_msg)
            return
        end

          --判断InBound是否存在,取消状态后面考虑
        local id
        local strCondition =string.format("S_NO='%s' AND N_B_STATE<>91",inboundData.taskId)
        nRet,id,strRetInfo=mobox.getDataObjAttrByKeyAttr(strLuaDEID,"GK_IN_TASK",strCondition)
        if nRet==0 then
            err_msg = "入库单号已存在！"..inboundData.taskId
            return_value(strLuaDEID, true, err_msg)
            return
        end

        --判断料箱是否存在，不存在拒绝
        local detailItems = inboundData.TaskCreation_TB_ITEM
        local items={}
        if detailItems==nil then
            return 1, "入库单明细为空"
        end
        if detailItems[1]==nil then
            items={detailItems}
        else
            items=detailItems
        end
        local by_pallet=group_by(items,"cid")
        local emptyCellCount=0
        for cid, group in pairs(by_pallet) do
            for _,cell in ipairs(group) do
                if cell.boxCode==nil or cell.boxCode=="" then
                    emptyCellCount=emptyCellCount+1
                end
            end
            if cid~=nil and cid~="" then
                --判断料箱是否存在
                local strCondition =string.format("S_CODE='%s'",cid)
                nRet,strRetInfo=mobox.existThisData(strLuaDEID,"Container",strCondition)
                if nRet~=0 then
                    err_msg = "查询数据出错！"..cid
                    return_value(strLuaDEID, false, err_msg)
                    return
                end
                if strRetInfo=="no" then
                    err_msg = "料箱不存在！"..cid
                    return_value(strLuaDEID, false, err_msg)
                    return
                end
                --判断料箱是否完成入库
                 local strCondition =string.format("S_CNTR_CODE='%s' AND N_B_STATE NOT IN(30,40)",cid)
                nRet,strRetInfo=mobox.existThisData(strLuaDEID,"Inbound_Palletization",strCondition)
                if nRet~=0 then
                    err_msg = "查询数据出错！"..cid
                    return_value(strLuaDEID, false, err_msg)
                    return
                end
                if strRetInfo=="yes" then
                    err_msg = "该料箱码盘数据未完成！"..cid
                    return_value(strLuaDEID, false, err_msg)
                    return
                end
                --判断料箱是否存在库存
                strCondition=string.format("S_CNTR_CODE='%s' AND F_QTY>0",cid)
                nRet,strRetInfo=mobox.existThisData(strLuaDEID,"INV_Detail",strCondition)
                if nRet~=0 then
                    err_msg = "查询数据出错！"..cid
                    return_value(strLuaDEID, false, err_msg..strRetInfo)
                    return
                end
                if strRetInfo=="yes" then
                    lua.DebugEx(strLuaDEID, "料箱存在库存")
                    err_msg = "料箱存在库存"..cid
                    return_value(strLuaDEID, false, err_msg..strRetInfo)
                    return
                end
            end
        end

        nRet,err_msg= gk_create_inbound(strLuaDEID, inboundData,emptyCellCount)
        if (nRet==nil or nRet~=0) then
            return_value(strLuaDEID, false, err_msg)
        else
            return_value(strLuaDEID, true, "")
        end
    end
end