package com.fzzy.push.shjdjw2023; import com.alibaba.fastjson.JSON; import com.fzzy.api.entity.ApiConfs; import com.fzzy.api.utils.AESUtils; import com.fzzy.push.shjdjw2023.dto.ShjdjwRespDto; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; import java.io.*; import java.net.HttpURLConnection; import java.net.URL; /** * 上海嘉定纪委监管平台-上传数据服务类 * @author czt * @date 2023/5/9 14:21 */ @Slf4j public class Shjdjw2023HttpClientUtil { /** * post formData * @param url * @return * @throws Exception */ @SuppressWarnings("resource") 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 = ""; ShjdjwRespDto responseDto = null; try { String md = AESUtils.encrypt(data, apiConfs.getPublicKey()); log.info("---------接口请求地址:" +url+ "----------密文参数:" + md +"---------"); connection = (HttpURLConnection) urls.openConnection(); connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8"); connection.setDoOutput(true); connection.setDoInput(true); connection.setRequestProperty("Accept-Language", "zh-CN,zh;q=0.8"); connection.setRequestProperty("Accept", "*/*"); connection.setRequestProperty("Range", "bytes=" + ""); connection.setRequestProperty("token", apiConfs.getPassword()); 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")); try { connection.connect(); if (connection.getResponseCode() == 200) { in = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8")); String line = ""; while ((line = in.readLine()) != null) { rs += line; } }else{ log.error("http状态:" + connection.getResponseCode()); log.error("http消息:" + connection.getResponseMessage()); } } catch (Exception e) { System.out.println("发生异常"); log.error(e.getMessage(),e); rs = null; return new ShjdjwRespDto(99,e.getMessage()); } if(StringUtils.isNotEmpty(rs)){ rs = rs.replaceAll("\"", ""); log.info("---------接口返回,秘文:" + rs +"---------"); rs = AESUtils.decrypt(rs, apiConfs.getPublicKey()); log.info("---------接口返回,解析后:" + rs +"---------"); responseDto = JSON.parseObject(rs, ShjdjwRespDto.class); } if(responseDto == null ) return new ShjdjwRespDto(99,"接口请求发生未知错误"); return responseDto; } finally { try { outputStream.close(); if (in != null){ in.close(); } } catch (Exception e) { } outputStream = null; if (connection != null) connection.disconnect(); connection = null; } } }