--[[
 编码:
 名称: LocStateFeedBack
 作者:
 入口函数：LocStateFeedBack
 功能说明:
 变更历史:
 --]]
require("WMS-Equipment")
wms_cntr = require("wms_container")
wms_wh = require("wms_wh")
require("GT-Base")
require("GT_InAndOutboundPolicies")
function LocStateFeedBack(strLuaDEID)
    local nRet, in_date, strRetInfo
    -- step1 获取接口数据
    nRet, in_date = m3.GetSysDataJson(strLuaDEID)
    if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "无法获取数据包!" .. in_date) end
    lua.Debug(strLuaDEID, debug.getinfo(1), '参数:', in_date)

    -- step2 判断 必填项 是否都有值？没值报错返回
    local loc_code = in_date.loc_code              -- 货位
    local type = lua.StrToNumber(in_date.type)     -- 1 允许取货 2 允许放货 3 取货完成允许离开 4 放货完成允许离开
    local req_no = lua.StrToNumber(in_date.req_no) -- 唯一码
    if (loc_code == nil or loc_code == '') then lua.Error(strLuaDEID, debug.getinfo(1), "站点不能为空!") end
    if (type == nil) then lua.Error(strLuaDEID, debug.getinfo(1), "类型不能为空!") end

    -- 根据WCS站点获取货位
    loc_code = wms_base.Get_sConst(strLuaDEID, loc_code)

    -- 根据类型和站点 获取对应的AGV任务
    local task_no
    if (type == 1 or type == 3) then
        -- 站点为起点,任务状态为已推送
        local condition = "S_START_LOC = '" ..
        loc_code ..
        "' AND N_B_STATE = 1 AND S_CODE IN (SELECT S_TASK_CODE FROM TN_Task_Action WHERE N_ACTION_CODE = " .. type .. ")"
        nRet, strRetInfo = m3.GetDataObjByCondition(strLuaDEID, "Task", condition, "T_CREATE")
        if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "获取【任务】信息失败! " .. strRetInfo) end
        task_no = strRetInfo.code
    elseif (type == 2) then
        -- 站点为终点,任务状态为已推送
        local condition = "S_END_LOC = '" ..
        loc_code ..
        "' AND N_B_STATE = 1 AND S_CODE IN (SELECT S_TASK_CODE FROM TN_Task_Action WHERE N_ACTION_CODE = " .. type .. ")"
        nRet, strRetInfo = m3.GetDataObjByCondition(strLuaDEID, "Task", condition, "T_CREATE")
        if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "获取【任务】信息失败! " .. strRetInfo) end
        task_no = strRetInfo.code
    elseif (type == 4) then
        -- 站点为终点,任务状态为已推送
        local condition = "S_END_LOC = '" ..
        loc_code .. "' AND S_CODE IN (SELECT S_TASK_CODE FROM TN_Task_Action WHERE N_ACTION_CODE = " .. type .. ")"
        nRet, strRetInfo = m3.GetDataObjByCondition(strLuaDEID, "Task", condition, "T_CREATE")
        if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "获取【任务】信息失败! " .. strRetInfo) end
        if (strRetInfo.op_name == '退料入库' or strRetInfo.op_name == 'AGV空托回库') then
            -- 解锁货位
            nRet, strRetInfo = wms.wms_UnlockByTask(strLuaDEID, loc_code)
            if (nRet ~= 0) then lua.Error(strLuaDEID, debug.getinfo(1), "wms_UnlockByTask 失败! " .. strRetInfo) end
        end
    else
        lua.Error(strLuaDEID, debug.getinfo(1), "未定义的状态反馈类型!")
    end

    -- 调用AGV的安全交互接口
    local url = wms_base.Get_sConst(strLuaDEID, "AGV-url")
    local strurl = url .. "/AllowThrough"
    local strHeader = ""
    local data = {
        task_no = task_no,
        type = type, -- 1 允许取货 2 允许放货 3 取货完成允许离开 4 放货完成允许离开
        loc = loc_code,
        req_no = req_no
    }
    nRet, strRetInfo = CreateInterfaceExc(strLuaDEID, strurl, strHeader, data, "AGV", "货位状态反馈")
    if (nRet ~= 0) then
        lua.Error(strLuaDEID, debug.getinfo(1), "调用接口失败!" .. strRetInfo)
    end
end