From 05d2819f1069d24ceb96615705d40f44ab5f1f9c Mon Sep 17 00:00:00 2001 From: CZT <czt18638530771@163.com> Date: 星期四, 28 十二月 2023 13:55:50 +0800 Subject: [PATCH] 调整上海嘉定纪委接口3 --- src/main/java/com/fzzy/push/shjdjw2023/Shjdjw2023HttpClientUtil.java | 36 ++++++++++++++++-------------------- 1 files changed, 16 insertions(+), 20 deletions(-) diff --git a/src/main/java/com/fzzy/push/shjdjw2023/Shjdjw2023HttpClientUtil.java b/src/main/java/com/fzzy/push/shjdjw2023/Shjdjw2023HttpClientUtil.java index bb7f07f..d43370f 100644 --- a/src/main/java/com/fzzy/push/shjdjw2023/Shjdjw2023HttpClientUtil.java +++ b/src/main/java/com/fzzy/push/shjdjw2023/Shjdjw2023HttpClientUtil.java @@ -1,21 +1,14 @@ package com.fzzy.push.shjdjw2023; import com.alibaba.fastjson.JSON; -import com.alibaba.fastjson.TypeReference; import com.fzzy.api.entity.ApiConfs; import com.fzzy.api.utils.AESUtils; -import com.fzzy.api.utils.MyMD5Util; -import com.fzzy.api.utils.SnowflakeIdWorker; -import com.fzzy.push.gd2022.dto.GD2022AuthToken; -import com.fzzy.push.gd2022.dto.GD2022ResponseDto; +import com.fzzy.push.shjdjw2023.dto.ShjdjwRespDto; import lombok.extern.slf4j.Slf4j; - +import org.apache.commons.lang.StringUtils; import java.io.*; -import java.lang.reflect.Type; import java.net.HttpURLConnection; import java.net.URL; -import java.util.Map; -import java.util.UUID; /** * 涓婃捣鍢夊畾绾鐩戠骞冲彴-涓婁紶鏁版嵁鏈嶅姟绫� @@ -32,17 +25,15 @@ * @throws Exception */ @SuppressWarnings("resource") - public static GD2022ResponseDto postPushData(String url, String data , ApiConfs apiConfs) throws Exception { + public static ShjdjwRespDto postPushData(String url, String data , ApiConfs apiConfs) throws Exception { log.info("---------鎺ュ彛璇锋眰鍦板潃锛�" +url+ "----------鍙傛暟锛�" + data +"---------"); BufferedReader in = null; URL urls = new URL(url); HttpURLConnection connection = null; OutputStream outputStream = null; String rs = ""; - GD2022ResponseDto responseDto; + ShjdjwRespDto responseDto; try { - String md = AESUtils.encryptByEcb(data, apiConfs.getPublicKey()); - log.info("---------鎺ュ彛璇锋眰鍦板潃锛�" +url+ "----------瀵嗘枃鍙傛暟锛�" + md +"---------"); connection = (HttpURLConnection) urls.openConnection(); connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8"); connection.setDoOutput(true); @@ -54,10 +45,10 @@ connection.setConnectTimeout(20000); connection.setReadTimeout(30000); connection.setRequestMethod("POST"); - StringBuffer buffer = new StringBuffer(); - buffer.append(md); + outputStream = connection.getOutputStream(); - outputStream.write(buffer.toString().getBytes("UTF-8")); + + outputStream.write(data.getBytes("UTF-8")); try { connection.connect(); if (connection.getResponseCode() == 200) { @@ -75,12 +66,17 @@ System.out.println("鍙戠敓寮傚父"); log.error(e.getMessage(),e); rs = null; - return new GD2022ResponseDto(99,e.getMessage()); + return new ShjdjwRespDto(99,e.getMessage()); } log.info("---------鎺ュ彛杩斿洖锛�" + rs +"---------"); - responseDto = JSON.parseObject(rs,GD2022ResponseDto.class); - if(responseDto == null ) return new GD2022ResponseDto(99,"鎺ュ彛璇锋眰鍙戠敓鏈煡閿欒"); - return responseDto; + if(StringUtils.isEmpty(rs)){ + return new ShjdjwRespDto(99,"鎺ュ彛璇锋眰鍙戠敓鏈煡閿欒"); + } + if("dDTJ5xGqsmo32r40WKKPOLW6ORtH3mwMyv4YaJNzc4g=".equals(rs)){ + return new ShjdjwRespDto(1,"涓婃姤鎴愬姛"); + } +// responseDto = JSON.parseObject(rs, ShjdjwRespDto.class); + return new ShjdjwRespDto(1,"涓婃姤鎴愬姛"); } finally { try { outputStream.close(); -- Gitblit v1.9.3