--[[
     巨星二期WMS项目中Lua调用外包第3方WebAPI接口
     更新记录:
     V1.0  HAN 20241108  -- 创建
     V2.0  HAN 20241109
           新增巨星WMS接口
           改进JW接口
--]]

wms_base = require( "wms_base" )

local jx_api = {_version = "0.1.1"}

--[[
    1# JW_WMS_API_subPickDown    巨沃WMS出库单分拣完成后完工回报接口
    2# JW_WMS_API_newTrans       巨沃WMS入库单上架完成后完工回报接口
    3# JW_WMS_API_subStockCheck  巨沃WMS盘点完成后完工回报接口
    4# JW_WMS_API_newOffShelfs   巨沃WMS盘点差异回报接口
    5# WMS_API_SetPLCJobStatus   巨星WMS出库完成进行状态回报处理
    6# WMS_API_SetLocation      巨星WMS接口，出入库异动，这边是两个，出库和入库都需要
    7# WMS_API_PutOn             巨星WMS接口入库任务完成后，把容器的货位回传巨星WMS
    8# JW_DVC_State              获取设备状态
    9# JW_Cancel                 巨星任务取消

]]

--//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
-- 巨沃WMS出库单分拣完成后完工回报接口
-- oo_no 出库单号, 巨沃WMS这里的波次号
function jx_api.JW_WMS_API_subPickDown(strLuaDEID, oo_no)
    local nRet, strRetInfo
    -- 检查出库单号
    if (oo_no == nil or oo_no == '') then
        return 1, "jx_api.JW_WMS_API_subPickDown 函数中 oo_no 必须有值!"
    end

    -- 查询出库单类型（S_BS_TYPE字段）
    local strCondition = "S_NO = '"..oo_no.."'"
    local outbound_order_objs
    nRet, outbound_order_objs = m3.QueryDataObject(strLuaDEID, "Outbound_Order", strCondition, "")
    if (nRet ~= 0 or #outbound_order_objs == 0) then
        lua.Error(strLuaDEID, debug.getinfo(1), "查询出库单信息失败! " .. (strRetInfo or "无数据"))
    end
    -- 获取 S_BS_TYPE 字段值
    local obj_attrs = m3.KeyValueAttrsToObjAttr(outbound_order_objs[1].attrs)
    local bs_type = obj_attrs.S_BS_TYPE
	lua.Debug(strLuaDEID, debug.getinfo(1), "bs_type", bs_type)
    -- 获取出库单明细信息
    local detailCondition = "S_OO_NO = '"..oo_no.."'"
    local detailOrder = "N_ROW_NO"
    local oo_detail_objs
    nRet, oo_detail_objs = m3.QueryDataObject(strLuaDEID, "Outbound_Detail", detailCondition, detailOrder)
    if (nRet ~= 0) then 
        lua.Error(strLuaDEID, debug.getinfo(1), "获取【Outbound_Detail】信息失败! " .. oo_detail_objs) 
    end

    local obj_attrs_detail
    local item_list = {}

    -- 遍历出库单明细
    for n = 1, #oo_detail_objs do
        obj_attrs_detail = m3.KeyValueAttrsToObjAttr(oo_detail_objs[n].attrs)
        local item = {
            inco = obj_attrs_detail.S_ITEM_CODE,
            container_id = obj_attrs_detail.S_PICK_BOX_CODE,            
            qty = lua.StrToNumber(obj_attrs_detail.F_ACC_O_QTY)
        }
        table.insert(item_list, item)
    end
    lua.Debug(strLuaDEID, debug.getinfo(1), "item_list", item_list)

    -- 判断出库单类型
    local jw_wms = wms_base.Get_sConst(strLuaDEID, "巨沃WMS服务地址")
    local strurl
    local body = {}
    if bs_type == "分拣单" then
        -- 分拣单
        strurl = jw_wms..'?service=subPickDown&appkey=gwall&secret=null&format=JSON'
        body = {
                    taskno = oo_no,  
                    items = item_list
               }
    elseif bs_type == "出库单" then
	lua.Debug(strLuaDEID, debug.getinfo(1), "出库单","1" )
        -- 出库单
        strurl = jw_wms..'?service=newOffShelfs&appkey=gwall&secret=null&format=JSON'
        body = {
                    orderId = oo_no, 
                    items = item_list
               }
    else
        return 1, "无效的出库单类型"
    end

    -- 调用巨沃接口
    lua.Debug(strLuaDEID, debug.getinfo(1), "调巨沃接口-->", strurl)                     
    lua.Debug(strLuaDEID, debug.getinfo(1), "body", body)

    nRet, strRetInfo = mobox.sendHttpRequest(strurl, "", "content="..lua.table2str(body))
    if (nRet ~= 0 or strRetInfo == '') then 
        lua.Error(strLuaDEID, debug.getinfo(1), "调用巨沃WMS接口失败! "..strRetInfo) 
    end  
	lua.Debug( strLuaDEID, debug.getinfo(1), "调巨沃接口结果-->", strRetInfo ) 

--王志坤--返回错误信息 
    if (strRetInfo ~= '') then
        local ret_info = json.decode(strRetInfo)
        if (ret_info.isSuccess == false) then
            return 1,"返回错误-->" ..ret_info.body
        end
    end
    return 0
end


--//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
-- 巨沃WMS入库单上架完成后完工回报接口
-- io_no 入库单号, 
function jx_api.JW_WMS_API_newTrans( strLuaDEID, io_no )
    local nRet, strRetInfo, n
    if ( io_no == nil or io_no == '' ) then return 1, "jx_api.JW_WMS_API_newTrans 函数中 io_no 必须有值!" end

    local strCondition = "S_IO_NO = '"..io_no.."'"
    local strOrder = "N_ROW_NO"
    local io_detail_objs
    nRet, io_detail_objs = m3.QueryDataObject( strLuaDEID, "Inbound_Detail", strCondition, strOrder )
    if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), "获取【Inbound_Detail】信息失败! " .. io_detail_objs ) end

    local obj_attrs
    local item_list = {}

    for n = 1, #io_detail_objs do
        obj_attrs = m3.KeyValueAttrsToObjAttr(io_detail_objs[n].attrs)
        local item = {
            inco = obj_attrs.S_ITEM_CODE,
            qty = lua.StrToNumber( obj_attrs.F_ACC_I_QTY )
        }
        table.insert( item_list, item )
    end
    local jw_wms = wms_base.Get_sConst( strLuaDEID, "巨沃WMS服务地址")

    local strurl =  jw_wms..'?service=newTrans&appkey=gwall&secret=null&format=JSON'
    local body = {
                    orderId = io_no,
                    type = "Shelf",
                    items = item_list
                }
    lua.Debug( strLuaDEID, debug.getinfo(1), "调巨沃接口-->", strurl )                
    lua.Debug( strLuaDEID, debug.getinfo(1), "body", body )

    nRet, strRetInfo = mobox.sendHttpRequest( strurl, "","content="..  lua.table2str(body) )
    if ( nRet ~= 0 or strRetInfo == '' ) then 
        lua.Error( strLuaDEID, debug.getinfo(1), "调用巨沃WMS #subPickDown 接口失败! "..strRetInfo ) 
    end  
    lua.Debug( strLuaDEID, debug.getinfo(1), "调巨沃接口结果-->", strRetInfo ) 	

--返回错误信息 
    if (strRetInfo ~= '') then
        local ret_info = json.decode(strRetInfo)
        if (ret_info.isSuccess == false) then
            return 1,"返回错误-->" ..ret_info.body
        end
    end

    return 0
end

--//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
-- 巨沃WMS盘点完成后完工回报接口
-- orderno 盘点计划单号, 
function jx_api.JW_WMS_API_subStockCheck( strLuaDEID, orderno )
    local nRet, strRetInfo, n
    if ( orderno == nil or orderno == '' ) then return 1, "jx_api.JW_WMS_API_subStockCheck 函数中 orderno 必须有值!" end

    local strCondition = "S_CP_NO = '"..orderno.."'"
    local count_plan
    nRet, count_plan = m3.QueryDataObject( strLuaDEID, "CP_Good_List", strCondition )--查询计划盘点货品
    if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), "获取【Inbound_Detail】信息失败! " .. count_plan ) end

    local obj_attrs
    local item_list = {}

    for n = 1, #count_plan do
        obj_attrs = m3.KeyValueAttrsToObjAttr(count_plan[n].attrs)
        local item = {
            inco = obj_attrs.S_ITEM_CODE,
            qty = lua.StrToNumber( obj_attrs.F_ACT_QTY )
        }
        table.insert( item_list, item )
    end
    local jw_wms = wms_base.Get_sConst( strLuaDEID, "巨沃WMS服务地址")

    local strurl = jw_wms..'?service=subStockCheck&appkey=gwall&secret=null&format=JSON'
    local body = {
                    orderno = orderno,--盘点计划单号
                    items = item_list
                }
    lua.Debug( strLuaDEID, debug.getinfo(1), "调巨沃接口-->", strurl )                
    lua.Debug( strLuaDEID, debug.getinfo(1), "body", body )

    nRet, strRetInfo = mobox.sendHttpRequest( strurl, "","content="..  lua.table2str(body) )
    if ( nRet ~= 0 or strRetInfo == '' ) then 
        lua.Error( strLuaDEID, debug.getinfo(1), "调用巨沃WMS #subPickDown 接口失败! "..strRetInfo ) 
    end  
    lua.Debug( strLuaDEID, debug.getinfo(1), "调巨沃接口结果-->", strRetInfo ) 	

--返回错误信息 
    if (strRetInfo ~= '') then
        local ret_info = json.decode(strRetInfo)
        if (ret_info.isSuccess == false) then
            return 1,"返回错误-->" ..ret_info.body
        end
    end

    return 0
end

--//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
-- 巨沃WMS盘点差异回报接口
-- count_no 盘点差异单号, 
function jx_api.JW_WMS_API_newOffShelfs( strLuaDEID, count_no )
    local nRet, strRetInfo, n
    if ( count_no == nil or count_no == '' ) then return 1, "jx_api.JW_WMS_API_newOffShelfs 函数中 count_no 必须有值!" end

    local strCondition = "S_COUNT_NO = '"..count_no.."'"
    --local strOrder = "N_ROW_NO"--是否需要修改
    local count_diff
    nRet, count_diff = m3.QueryDataObject( strLuaDEID, "Count_Diff", strCondition, strOrder )--盘点差异表,是否需要判断差异是否移库的状态Y/N的状态值
    if (nRet ~= 0) then 
        lua.Error( strLuaDEID, debug.getinfo(1), "获取【Inbound_Detail】信息失败! " .. count_diff ) 
    end


    local obj_attrs
    local item_list = {}
    --取差异值
    for n = 1, #count_diff do
        obj_attrs = m3.KeyValueAttrsToObjAttr(count_diff[n].attrs)
        local item = {
            inco = obj_attrs.S_ITEM_CODE,
            qty = lua.StrToNumber( obj_attrs.F_QTY ) - lua.StrToNumber( obj_attrs.F_ACTUAL_QTY )
        }
        table.insert( item_list, item )
    end
	lua.Debug( strLuaDEID, debug.getinfo(1), "item_list", item_list )
    local jw_wms = wms_base.Get_sConst( strLuaDEID, "巨沃WMS服务地址")

    local strurl =  jw_wms..'?service=newOffShelfs&appkey=gwall&secret=null&format=JSON'
    local body = {
                    
                    items = item_list
                }
    lua.Debug( strLuaDEID, debug.getinfo(1), "调巨沃接口-->", strurl )                
    lua.Debug( strLuaDEID, debug.getinfo(1), "body", body )

    nRet, strRetInfo = mobox.sendHttpRequest( strurl, "","content="..  lua.table2str(body) )
    if ( nRet ~= 0 or strRetInfo == '' ) then 
        lua.Error( strLuaDEID, debug.getinfo(1), "调用巨沃WMS #subPickDown 接口失败! "..strRetInfo ) 
    end  
    lua.Debug( strLuaDEID, debug.getinfo(1), "调巨沃接口结果-->", strRetInfo ) 	

--返回错误信息 
    if (strRetInfo ~= '') then
        local ret_info = json.decode(strRetInfo)
        if (ret_info.isSuccess == false) then
            return 1,"返回错误-->" ..ret_info.body
        end
    end

    return 0
end

--//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
-- 巨星WMS接口
-- 完工回报
-- 任务状态：Status Y:完工回报; 9：已下发已接,强制完成传Y
function jx_api.WMS_API_SetPLCJobStatus( strLuaDEID, jx_task, Status )
    local nRet, strRetInfo, n
    if ( jx_task == nil ) then return 1, "jx_api.WMS_API_SetPLCJobStatus 函数中 jx_task 必须有值!" end

    local jx_wms = wms_base.Get_sConst( strLuaDEID, "巨星WMS服务地址")
    local strurl =  jx_wms..'/api/SetPLCJobStatus'
    local body = {
                    clientKey1 = "GREATSTAR",
                    clientKey2 = "HNWSRFID",
                    jobNo = jx_task.sour_no,
                    palletNo = jx_task.cntr_code,
                    destLocationCode = jx_task.end_loc_code,
                    whCode = jx_task.start_wh_code,
                    jobStatus = Status,
					oper ="WMS"
                    --oper = jx_task.operator_name
                }
    lua.Debug( strLuaDEID, debug.getinfo(1), "调巨星接口-->", strurl )                     
    lua.Debug( strLuaDEID, debug.getinfo(1), "body", body )


    nRet, strRetInfo = mobox.sendHttpRequest( strurl, "", lua.table2str(body) )
    if ( nRet ~= 0 or strRetInfo == '' ) then 
        lua.Error( strLuaDEID, debug.getinfo(1), "调用巨星WMS #subPickDown 接口失败! "..strRetInfo ) 
    end  
    lua.Debug( strLuaDEID, debug.getinfo(1), "调巨星接口结果-->", strRetInfo ) 	

    if (strRetInfo ~= '') then
        local ret_info = json.decode(strRetInfo)
        if (ret_info.isSuccess == false) then
            return 1,"返回错误-->" ..ret_info.body
        end
    end
    return 0
end

--//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

--  巨星WMS接口，具体位置在出入库异动
--  model 出/入库
function jx_api.WMS_API_SetLocation(strLuaDEID, jx_task, model)
    local nRet, strRetInfo, n
    if ( jx_task == nil ) then return 1, "jx_api.WMS_API_SetLocation 函数中必须有值!" end

    local jx_wms = wms_base.Get_sConst( strLuaDEID, "巨星WMS服务地址")
    local strurl =  jx_wms..'/api/SetLocation'
    local body = {
                clientKey1 = "GREATSTAR",
                clientKey2 = "HNWSRFID",
                jobNo = jx_task.sour_no,
                palletNo = jx_task.cntr_code,
                destLocationCode = jx_task.end_loc_code,
                locationCode = jx_task.start_loc_code, --托盘起点货位
				model = model,
                oper = "WMS"
                --oper = jx_task.operator_name
                }
    lua.Debug( strLuaDEID, debug.getinfo(1), "调巨星接口-->", strurl )                     
    lua.Debug( strLuaDEID, debug.getinfo(1), "body", body )


    nRet, strRetInfo = mobox.sendHttpRequest( strurl, "", lua.table2str(body) )
    if ( nRet ~= 0 or strRetInfo == '' ) then 
        lua.Error( strLuaDEID, debug.getinfo(1), "调用巨星WMS #SetLocation 接口失败! "..strRetInfo ) 
    end  
    lua.Debug( strLuaDEID, debug.getinfo(1), "调巨星接口结果-->", strRetInfo ) 	


    if (strRetInfo ~= '') then
        local ret_info = json.decode(strRetInfo)
        if (ret_info.isSuccess == false) then
            return 1,"返回错误-->" ..ret_info.body
        end
    end

    return 0
end

--//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
-- 巨星WMS接口
-- 入库任务完成后，把容器的货位回传巨星WMS
function jx_api.WMS_API_PutOn( strLuaDEID, jx_task )
    local nRet, strRetInfo, n
    if ( jx_task == nil ) then return 1, "jx_api.WMS_API_PutOn 函数中 jx_task 必须有值!" end

    local jx_wms = wms_base.Get_sConst( strLuaDEID, "巨星WMS服务地址")
    local strurl =  jx_wms..'/api/PutOn'
    local body = {
                    clientKey1 = "GREATSTAR",
                    clientKey2 = "HNWSRFID",
                    flag = true,
                    transType = 0,
                    sourcePallet = jx_task.cntr_code,
                    destLocationCode = jx_task.end_loc_code,
					oper ="WMS"
                    --oper = jx_task.operator_name
                }
    lua.Debug( strLuaDEID, debug.getinfo(1), "调巨星接口-->", strurl )                     
    lua.Debug( strLuaDEID, debug.getinfo(1), "body", body )


    nRet, strRetInfo = mobox.sendHttpRequest( strurl, "", lua.table2str(body) )
    if ( nRet ~= 0 or strRetInfo == '' ) then 
        lua.Error( strLuaDEID, debug.getinfo(1), "调用巨星WMS #subPickDown 接口失败! "..strRetInfo ) 
    end  
	lua.Debug( strLuaDEID, debug.getinfo(1), "调巨星接口结果-->", strRetInfo ) 	

    if (strRetInfo ~= '') then
        local ret_info = json.decode(strRetInfo)
        if (ret_info.isSuccess == false) then
            return 1,"返回错误-->" ..ret_info.body
        end
    end

    return 0
end

--//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
--JW_DVC_State获取设备状态
--reqDvc设备号, readingBit -- 读码位
function jx_api.JW_DVC_State( strLuaDEID, reqDvc, readingBit )
    local dev_state = {
        {DVC_NO = "ZD01", IS_USE = 1},
        {DVC_NO = "ZD02", IS_USE = 1},
        {DVC_NO = "ZD03", IS_USE = 0},
        {DVC_NO = "ZD04", IS_USE = 1}
    }
    return 0, dev_state
end
--[[    
    local nRet, strRetInfo
    local now = os.date("%Y%m%d%H%M%S")  
    local randomNum = math.random(1, 99999)  
    local requestPk = "PK"..now..randomNum
    local wcs_url = wms_base.Get_sConst( strLuaDEID, "WCS服务地址")
    local strurl =  wcs_url..'/wcs-admin/api/dvc-state'

    local body = {
                    requestPk = requestPk,
                    reqDvc = reqDvc,
                    readingBit = readingBit
                }
    lua.Debug( strLuaDEID, debug.getinfo(1), "调WCS接口-->", strurl )                     
    lua.Debug( strLuaDEID, debug.getinfo(1), "body", body )


    nRet, strRetInfo = mobox.sendHttpRequest( strurl, "", lua.table2str(body) )
    if ( nRet ~= 0 or strRetInfo == '' ) then 
        lua.Error( strLuaDEID, debug.getinfo(1), "调用WCS /wcs-admin/api/receive 接口失败! "..strRetInfo ) 
    end  

    lua.Debug( strLuaDEID, debug.getinfo(1), "strRetInfo", strRetInfo )
    
    local ret_info = json.decode(strRetInfo)
    return 0, ret_info.data

end
]]

--//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
--JW_Cancel取消任务
--注意requestPk并不是时间戳而是任务号，任务号的唯一标识
function jx_api.JW_Cancel(strLuaDEID,cntr_code,task_code)
    return 0, ""
end
--[[
    local nRet, strRetInfo,n
    -- local now = os.date("%Y%m%d%H%M%S")  
    -- local randomNum = math.random(1, 99999)  
    -- local requestPk = "PK"..now..randomNum
    local wcs_url = wms_base.Get_sConst( strLuaDEID, "WCS服务地址")

    local strurl =  wcs_url..'/wcs-admin/api/cancel'
    local body = {
                    requestPk = task_code,
                    contNo = cntr_code,
                    clientCode = wms,
                    reqTime = 2022-11-11
                }
    lua.Debug( strLuaDEID, debug.getinfo(1), "调WCS接口-->", strurl )                     
    lua.Debug( strLuaDEID, debug.getinfo(1), "body", body )


    nRet, strRetInfo = mobox.sendHttpRequest( strurl, "",lua.table2str(body) )
    if ( nRet ~= 0 or strRetInfo == '' ) then 
        lua.Error( strLuaDEID, debug.getinfo(1), "调用WCS /wcs-admin/api/receive 接口失败! "..strRetInfo ) 
    end  

    lua.Debug( strLuaDEID, debug.getinfo(1), "strRetInfo", strRetInfo )
    
    local ret_info = json.decode(strRetInfo)
    return 0, ret_info.msg
end
]]

return jx_api