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.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;
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
public class APMStrategy implements WharfStrategy{
|
|
//Sandbox Interface
|
private static final String url = "https://api-sandbox.apmterminals.com/import-availability";
|
|
//Production Interface
|
// private static final String url = "https://api.apmterminals.com/import-availability";
|
|
private static final String auth_url = "https://api.apmterminals.com/oauth/client_credential/accesstoken";
|
|
private static final String KEY = "di3RgCcM9zlgb5BG1UiYSIxwYdmYUxTo";
|
private static final String SECRET = "AIJczPxBeocsEjtI";
|
|
private static String bearerToken = "5dDHq3LwPW3EYZ6rtPGK0zqWsRA5";
|
|
|
public static void main(String[] args) {
|
getAuth();
|
String us = auth_url+ "?assetId="+"EITU1509974"+"&facilityCode="+"USLAX";
|
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", "?assetId=" + "EITU1509974" + "&facilityCode=" + "USLAX")
|
.header("Authorization", "Bearer " + bearerToken)
|
.execute();
|
int status = execute.getStatus();
|
System.out.println(status);
|
System.out.println(execute.body());
|
}
|
|
@Override
|
public TerminaleDataWarpper executeLogic(String... params) {
|
String containerId = "";
|
String enums = "";
|
if (params.length == 0) {
|
throw new GunsException(BizExceptionEnum.REQUEST_EMPTY_ERROR);
|
} else {
|
containerId = params[0];
|
enums = params[1];
|
}
|
|
String us = url+ "?assetId="+containerId+"&facilityCode="+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", "?assetId=" + containerId + "&facilityCode=" + enums)
|
.header("Authorization", "Bearer " + bearerToken)
|
.execute();
|
|
String body = execute.body();
|
int status = execute.getStatus();
|
if (status != 200){
|
getAuth();
|
return executeLogic();
|
}
|
ObjectMapper objectMapper = new ObjectMapper();
|
JsonNode jsonArray = null;
|
TerminaleDataWarpper warpper = new TerminaleDataWarpper();
|
try {
|
jsonArray = objectMapper.readTree(body);
|
for (JsonNode jsonNode : jsonArray) {
|
String appointmentDateTimeLocal = jsonNode.get("appointmentDateTimeLocal").asText();
|
warpper.setLfd(appointmentDateTimeLocal);
|
String appointmentNumber = jsonNode.get("containerId").asText();
|
warpper.setAppointmentNumber(appointmentNumber);
|
|
String readyForDelivery = jsonNode.get("readyForDelivery").asText();
|
if (ToolUtil.isNotEmpty(readyForDelivery)) {
|
warpper.setAvailability(readyForDelivery);
|
}
|
|
String containerHolds = jsonNode.get("containerHolds").asText();
|
String location = jsonNode.get("location").asText();
|
if (ToolUtil.isNotEmpty(location)){
|
warpper.setClosedArea(location);
|
}
|
List<String> collect = new ArrayList<>();
|
if (ToolUtil.isEmpty(containerHolds)){
|
return warpper;
|
}
|
if (containerHolds.contains(",")){
|
String[] split = containerHolds.split(",");
|
collect = Arrays.stream(split).collect(Collectors.toList());
|
if (collect.contains("LINE")){
|
warpper.setLineHold("1");
|
}
|
if (collect.contains("TMF")){
|
warpper.setCustomHold("1");
|
}
|
if (collect.contains("PIER")){
|
warpper.setPierpass("1");
|
}
|
if (collect.contains("CTF")){
|
warpper.setCtf("1");
|
}
|
|
}else {
|
if (containerHolds.equals("LINE")){
|
warpper.setLineHold("1");
|
}
|
if (containerHolds.equals("TMF")){
|
warpper.setCustomHold("1");
|
}
|
if (containerHolds.equals("PIER")){
|
warpper.setPierpass("1");
|
}
|
if (containerHolds.equals("CTF")){
|
warpper.setCtf("1");
|
}
|
if (containerHolds.equals("AREA")){
|
warpper.setClosedArea("1");
|
}
|
}
|
break;
|
}
|
} catch (IOException e) {
|
throw new RuntimeException(e);
|
}
|
|
return warpper;
|
}
|
|
|
public static void getAuth(){
|
String us = auth_url+ "?grant_type=client_credentials";
|
String body = HttpRequest.post(us)
|
.form("client_id", KEY)
|
.form("client_id", SECRET)
|
.execute().body();
|
JSONObject object = JSONObject.parseObject(body);
|
Object o = object.get("access_token");
|
if (ToolUtil.isNotEmpty(o)){
|
bearerToken = (String) o;
|
}
|
}
|
}
|
