--[[
 编码: GT-100-13
 名称: 国自任务回报
 作者: LZH
 入口函数：TaskStatus
 功能说明: 接收国自的任务返回状态
    输入数据：																						
    {	
        "feed_no": "xxx",  唯一码，用于接口校验，默认生成GUID
        "feed_type": "xxx",  反馈类型 1=任务开始；2=任务完成；3=任务异常；4=任务取消；5=任务更改（待定）6=货物节点
        "task_type": "xxx" ,  任务类型 1=货物入库；2=货物出库；3=托盘组入库；4=托盘组出库；5=移动（不过库位）；6=移库
        "task_no": "xxx",  任务号 单托盘唯一任务号
        "mat_code": "xxx", 货物RFID
        "cur_station_no": "xxx", 当前位置
        "weight": "xxx", 称重重量
        "feed_time": "xxx" 反馈时间
    }

    处理逻辑
    -- step1 解析接口传递的 datajson 参数
    -- step2 校验必传字段是否为空，为空则报错
    -- step3 反馈类型 2 设置任务完成 3 报错 4 设置任务状态为取消并解锁
 变更历史:
    V1.0 LZH 20250121 feed_type = 3则更新工位异常信息
    V2.0 LZH 20250213 新增称重重量字段和类型
 --]]
require("WMS-Equipment")
wms_cntr = require("wms_container")
require("GT-Base")
wms_task = require("wms_task")
function GZTaskStatus(strLuaDEID)
    local nRet, in_date, strRetInfo
    -- step1 获取接口数据
    nRet, in_date = m3.GetSysDataJson(strLuaDEID)
    if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "WCStoreCallback 无法获取数据包!" .. in_date) end


    -- step2 判断 必填项 是否都有值？没值报错返回
    local task_no = in_date.task_no
    if (task_no == nil or task_no == '') then lua.Error(strLuaDEID, debug.getinfo(1), "任务号不能为空!") end
    local cntr_code = in_date.cntr_code
    if (cntr_code == nil or cntr_code == '') then lua.Error(strLuaDEID, debug.getinfo(1), "RFID不能为空!") end
    local feed_type = tonumber(in_date.feed_type)
    if (feed_type == nil) then lua.Error(strLuaDEID, debug.getinfo(1), "反馈类型不能为空!") end
    local task_type = tonumber(in_date.task_type)
    if (task_type == nil) then lua.Error(strLuaDEID, debug.getinfo(1), "任务类型不能为空!") end
    local cur_station_no = in_date.cur_station_no -- 当前位置
    -- V2.0 LZH 新增重量字段
    local weight = in_date.weight                 -- 称重重量
    local err_msg = in_date.err_msg               -- 反馈类型为3时传的工位异常信息

    -- 获取任务中的容器编码和起始货位编码
    local task
    nRet, task = wms_task.GetInfo(strLuaDEID, task_no)
    if (nRet ~= 0) then return end


    if (task.bs_state == 3) then
        lua.Error(strLuaDEID, debug.getinfo(1), "任务已完成!")
    elseif (task.bs_state == 4) then
        lua.Error(strLuaDEID, debug.getinfo(1), "任务异常!")
    end

    -- 反馈类型 2 设置任务完成 3 报错 4 设置任务状态为取消并解锁
    if (feed_type == 2) then
        lua.Debug(strLuaDEID, debug.getinfo(1), 'task:', task)
        lua.Debug(strLuaDEID, debug.getinfo(1), '国自任务反馈参数:', in_date)
        -- 校验终点位置是否传参
        if (task.op_name == '粉料入库' or task.op_name == '立库出库' or task.op_name == '采购退货' or task.op_name == '呼叫空托') then
            if (cur_station_no == nil or cur_station_no == '') then
                lua.Error(strLuaDEID, debug.getinfo(1), "终点未传参!")
            end
            cur_station_no = wms_base.Get_sConst(strLuaDEID, cur_station_no)
            lua.Debug(strLuaDEID, debug.getinfo(1), 'cur_station_no:', cur_station_no)
            task.end_loc_code = cur_station_no
            lua.Debug(strLuaDEID, debug.getinfo(1), 'task:', task)
            nRet, strRetInfo = wms_task.Update(strLuaDEID, task)
            if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "更新任务终点失败!" .. strRetInfo) end
        end


        -- 出库无需绑定终点
        if (task.op_name == '立库出库' or task.op_name == '呼叫空托' or task.op_name == '采购退货' or task.op_name == '点对点出库') then
            -- 容器货位解绑
            nRet, strRetInfo = wms_wh.Loc_Container_Unbinding(strLuaDEID, task.start_loc_code, cntr_code,
                "绑定解绑方法-系统",
                "完成")
            if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '货位容器解绑失败!' .. strRetInfo) end
        elseif (task.op_name == '移库') then
            -- 容器货位解绑
            nRet, strRetInfo = wms_wh.Loc_Container_Unbinding(strLuaDEID, task.start_loc_code, cntr_code,
                "绑定解绑方法-系统",
                "完成")
            if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '货位容器解绑失败!' .. strRetInfo) end

            -- 容器货位绑定
            nRet, strRetInfo = wms_wh.Loc_Container_Binding(strLuaDEID, task.end_loc_code, cntr_code, "绑定解绑方法-系统",
                "完成")
            if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '货位容器绑定失败!' .. strRetInfo) end
        else
            -- 容器货位绑定
            nRet, strRetInfo = wms_wh.Loc_Container_Binding(strLuaDEID, task.end_loc_code, cntr_code, "绑定解绑方法-系统",
                "完成")
            if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '货位容器绑定失败!' .. strRetInfo) end
        end

        -- 强制任务完成
        nRet, strRetInfo = wms.wms_TaskFinish(strLuaDEID, task_no)
        if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "任务编码='" .. task_no .. "'的任务设置完成失败!" .. strRetInfo) end

        -- 增加 任务动作 对象
        local task_action = m3.AllocObject(strLuaDEID, "Task_Action")
        task_action.task_code = task_no
        task_action.action_code = 2
        task_action.action = "国自搬运完成"
        task_action.eq_code = "system"
        task_action.eq_type_name = '完成'
        nRet, strRetInfo = m3.CreateDataObj(strLuaDEID, task_action)
        if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '创建【任务动作】对象失败!' .. strRetInfo) end
    elseif (feed_type == 3) then
        if (cur_station_no == nil or cur_station_no == '') then lua.Error(strLuaDEID, debug.getinfo(1), '异常工位不能为空!') end
        cur_station_no = wms_base.Get_sConst(strLuaDEID, cur_station_no)

        -- 根据工位修改异常信息
        local condition = "S_START_LOC = '" .. cur_station_no .. "'"
        local strSetAttr = "S_ERR_MSG = '" .. err_msg .. "'"
        nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "GT_PDA_Station", condition, strSetAttr)
        if (nRet ~= 0) then
            lua.Error(strLuaDEID, debug.getinfo(1), "工位异常信息失败!" .. strRetInfo)
        end
    elseif (feed_type == 4) then
        lua.Debug(strLuaDEID, debug.getinfo(1), 'task:', task)
        lua.Debug(strLuaDEID, debug.getinfo(1), '国自任务反馈参数:', in_date)
        if (task.op_name == '国自空托回库') then
            -- 给取消的任务解锁
            nRet, strRetInfo = wms.wms_UnlockByTask(strLuaDEID, task_no)
            if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "wms_UnlockByTask 失败! " .. strRetInfo) end
            -- 设置任务状态为取消
            local condition = "S_CODE = '" .. task_no .. "'"
            local strSetAttr = "N_B_STATE = " .. wms_base.Get_nConst(strLuaDEID, "任务状态-取消") .. ", S_B_STATE = '取消'"
            nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "Task", condition, strSetAttr)
            if (nRet ~= 0) then
                lua.Error(strLuaDEID, debug.getinfo(1), "设置任务状态失败!" .. strRetInfo)
            end
            -- 设置作业状态为取消
            local condition = "S_CODE = '" .. task.op_code .. "'"
            strSetAttr = "N_B_STATE = " .. wms_base.Get_nConst(strLuaDEID, "作业状态-取消") .. ", S_B_STATE = '取消'"
            nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "Operation", condition, strSetAttr)
            if (nRet ~= 0) then
                lua.Error(strLuaDEID, debug.getinfo(1), "设置作业状态失败!" .. strRetInfo)
            end
        end
    elseif (feed_type == 6) then
        if (cur_station_no == nil or cur_station_no == '') then lua.Error(strLuaDEID, debug.getinfo(1), '节点工位不能为空!') end
        -- local cur_station_name = wms_base.GetDictItemName(strLuaDEID, "GT_TaskNode", cur_station_no)
        -- 增加 任务动作 对象
        local task_action = m3.AllocObject(strLuaDEID, "Task_Action")
        task_action.task_code = task.code
        task_action.action_code = cur_station_no
        task_action.action = cur_station_name
        task_action.eq_code = "system"
        task_action.eq_type_name = cur_station_name
        nRet, strRetInfo = m3.CreateDataObj(strLuaDEID, task_action)
        if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '创建【任务动作】对象失败!' .. strRetInfo) end

        -- V2.0 LZH 新增类型8 入库重量上报
    elseif (feed_type == 8) then
        lua.Debug(strLuaDEID, debug.getinfo(1), 'task:', task)
        lua.Debug(strLuaDEID, debug.getinfo(1), '国自任务反馈参数:', in_date)
        -- 获取容器货品明细信息
        local strCondition = "S_CNTR_CODE = '" .. cntr_code .. "'"
        local cg_detail
        nRet, cg_detail = m3.GetDataObjByCondition(strLuaDEID, "CG_Detail", strCondition)
        if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), '获取容器货品信息失败!' .. cg_detail) end

        -- 修改入库单据行的称重数量信息
        strCondition = "S_SERIAL_NO = '" .. cg_detail.serial_no .. "'"
        local strSetAttr = "S_WEIGHT = '" .. weight .. "'"
        nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "GT_Label_Crad", strCondition, strSetAttr)
        if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "更新【容器】锁状态失败!" .. strRetInfo) end
    end
end