package com.yuanchu.mom.Task; import cn.hutool.http.HttpRequest; import com.yuanchu.mom.utils.JsonUtil; import com.yuanchu.mom.vo.Result; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Objects; import java.util.stream.Collectors; /** * @Author 张宾 * @Date 2023/9/19 */ public class SyncOrder { private static final String TOKEN_URL="http://192.168.18.16:9999/auth/oauth/token"; private static final String GET_ORDER_MAIN_URL="http://192.168.18.16:9999/order/otcService/getOrderInfoForHyxtMes"; private static final String GET_ORDER_INNER_URL="http://192.168.18.16:9999/order/otcService/getOrderLineForHyxtMes"; private static final Map GET_TOKEN_HEADER=new HashMap<>(2); private static final MapUSER_INFO=new HashMap<>(4); static { GET_TOKEN_HEADER.put("Authorization","Basic cGlnOnBpZw=="); GET_TOKEN_HEADER.put("Content-Type","application/x-www-form-urlencoded"); USER_INFO.put("username","external_interface_hyxt_mes"); USER_INFO.put("password","uCc+u3iP83WhO2dAU+5HUkCgfINnKfrHXMT/lwI/1f0="); USER_INFO.put("scope","server"); USER_INFO.put("grant_type","password"); } private static String getToken(){ String body = HttpRequest.post(TOKEN_URL) .headerMap(GET_TOKEN_HEADER, true) .form(USER_INFO)//表单内容 .timeout(20000)//超时,毫秒 .execute().body(); return String.valueOf(JsonUtil.jsonToPojo(body, Map.class).get("access_token")); } public static List> getMainOrder(String time){ Map orderCondition = new HashMap(); orderCondition.put("selectTime", time); String result = HttpRequest.get(GET_ORDER_MAIN_URL) .header("Authorization", "Bearer " + getToken()) .form(orderCondition) .execute().body(); List>list = JsonUtil.jsonToPojo(JsonUtil.jsonToString(JsonUtil.jsonToPojo(result,Result.class).getData()),List.class); return list.stream().filter(l-> Objects.equals(l.get("status"),"已下达")).collect(Collectors.toList()); } public static List> getInnerOrder(String time,String orderNo){ Map orderCondition = new HashMap(); orderCondition.put("selectTime", time); orderCondition.put("orderNo",orderNo); String result = HttpRequest.get(GET_ORDER_INNER_URL) .header("Authorization", "Bearer " + getToken()) .form(orderCondition) .execute().body(); List>list = JsonUtil.jsonToPojo(JsonUtil.jsonToString(JsonUtil.jsonToPojo(result,Result.class).getData()),List.class); return list; } }