package com.stylefeng.guns.modular.system.utils.PortUtil;

import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpResponse;
import com.alibaba.fastjson.JSONObject;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.google.gson.Gson;
import com.google.gson.JsonArray;
import com.google.gson.JsonElement;
import com.stylefeng.guns.core.common.exception.BizExceptionEnum;
import com.stylefeng.guns.core.exception.GunsException;
import com.stylefeng.guns.core.util.ToolUtil;
import com.stylefeng.guns.modular.system.warpper.TerminaleDataWarpper;

import java.io.IOException;

public class LBCTStrategy implements WharfStrategy {

    private static final String url = "https://www.lbct.com/CargoSearch/GetMultiCargoSearchJson";


//    public static void main(String[] args) throws IOException {
//
//        // 假设您有一个JSON字符串
//        String jsonString = "{\"field1\":\"value1\",\"nestedObject\":{\"field2\":\"value2\"}}";
//
//// 创建ObjectMapper对象
//        ObjectMapper objectMapper = new ObjectMapper();
//
//// 将JSON字符串解析为JsonNode对象
//        JsonNode jsonNode = objectMapper.readTree(jsonString);
//
//// 获取嵌套对象中的字段值
//        String field2Value = jsonNode.get("nestedObject").get("field2").asText();
//
//        System.out.println(field2Value);
//
//
//    }

    public static void main(String[] args) {
        String us = url+ "?timestamp="+System.currentTimeMillis()+"&listOfSearchId="+"GCXU5491260";
        HttpResponse execute = HttpRequest.get(us).header("user-agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/105.0.0.0 Safari/537.36")
                .header("cookie", "_ga=GA1.2.1226281326.1675309614; _gid=GA1.2.1467106222.1675309614; _ga=GA1.4.1226281326.1675309614; _gid=GA1.4.1467106222.1675309614; AWSALB=1bWqINVI+LJP87FTEXfEw1Ob1nkbr+I4baSbUGUmu5+/LdiqL9ic04Nj7F0Vz3rvharAG7a8dVe3MX6YMNEbUINVr++CCv/UBw6JeCRS0PcbRLxK7wVHb1lPT8Jl; AWSALBCORS=1bWqINVI+LJP87FTEXfEw1Ob1nkbr+I4baSbUGUmu5+/LdiqL9ic04Nj7F0Vz3rvharAG7a8dVe3MX6YMNEbUINVr++CCv/UBw6JeCRS0PcbRLxK7wVHb1lPT8Jl")
                .header("path", "?timestamp=" + System.currentTimeMillis() + "&listOfSearchId=" + "GCXU5491260")
                .execute();
        String body = execute.body();
        System.out.println(body);
    }
    @Override
    public TerminaleDataWarpper executeLogic(String... params) {
        String enums = "";
        if (params.length == 0) {
            throw new GunsException(BizExceptionEnum.REQUEST_EMPTY_ERROR);
        } else {
            enums = params[0];
        }
        String us = url+ "?timestamp="+System.currentTimeMillis()+"&listOfSearchId="+enums;
        HttpResponse execute = HttpRequest.get(us).header("user-agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/105.0.0.0 Safari/537.36")
                .header("cookie", "_ga=GA1.2.1226281326.1675309614; _gid=GA1.2.1467106222.1675309614; _ga=GA1.4.1226281326.1675309614; _gid=GA1.4.1467106222.1675309614; AWSALB=1bWqINVI+LJP87FTEXfEw1Ob1nkbr+I4baSbUGUmu5+/LdiqL9ic04Nj7F0Vz3rvharAG7a8dVe3MX6YMNEbUINVr++CCv/UBw6JeCRS0PcbRLxK7wVHb1lPT8Jl; AWSALBCORS=1bWqINVI+LJP87FTEXfEw1Ob1nkbr+I4baSbUGUmu5+/LdiqL9ic04Nj7F0Vz3rvharAG7a8dVe3MX6YMNEbUINVr++CCv/UBw6JeCRS0PcbRLxK7wVHb1lPT8Jl")
                .header("path", "?timestamp=" + System.currentTimeMillis() + "&listOfSearchId=" + enums)
                .execute();
        String body = execute.body();
        ObjectMapper objectMapper = new ObjectMapper();
        JsonNode jsonArray = null;
        TerminaleDataWarpper warpper = new TerminaleDataWarpper();
        if (ToolUtil.isEmpty(body)){
            return warpper;
        }
        try {
            jsonArray = objectMapper.readTree(body);
            JsonNode jsonNode = jsonArray.get(0);
            String appointmentDateTimeLocal = jsonNode.get("gateAppt").asText();
            JSONObject jsonObject = JSONObject.parseObject(appointmentDateTimeLocal);
            Object o = jsonObject.get("IsTMF");
            if (o.equals("true")){
                warpper.setPierpass("hold");
            }

            Object location = jsonObject.get("location");
            if ("GROUNDED".equals(location)){
                warpper.setClosedArea(location.toString());
            }
            Object lfd = jsonObject.get("freeTimeExpiration");
            if (ToolUtil.isNotEmpty(lfd)){
                warpper.setLfd(lfd.toString());
            }

            Object available = jsonObject.get("available");
            if (ToolUtil.isNotEmpty(available)){
                warpper.setAvailability(available.toString());
            }

            ObjectMapper insMapp = new ObjectMapper();
            JsonNode gateAppt1 = insMapp.readTree(jsonObject.get("gateAppt").toString());
            String gkey = gateAppt1.get("Gkey").asText();
            if (ToolUtil.isNotEmpty(gkey)){
                warpper.setAppointmentNumber(gkey);
            }

            Object listOfFlag = jsonNode.get(0).get("listOfFlag");
            Gson gson = new Gson();
            JsonArray jsonElements = gson.fromJson(listOfFlag.toString(), JsonArray.class);
            for (JsonElement jsonElement : jsonElements) {
                String holdName = jsonElement.getAsJsonObject().get("holdName").getAsString();
                String type = jsonElement.getAsJsonObject().get("type").getAsString();
                switch (holdName){
                    case "CTF_CONTAINER_HOLD":
                            warpper.setCtf(type);
                        break;
                    case "CUSTOMS_DEFAULT_HOLD":
                            warpper.setCustomHold(type);
                        break;
                    case "FREIGHT_BL_HOLD":
                            warpper.setLineHold(type);
                        break;
                }
            }
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
        return warpper;
    }
}