From 36bc9ef2f1066a216b562fab095a397dbc0a5a4f Mon Sep 17 00:00:00 2001 From: root Date: Thu, 26 Feb 2026 09:07:01 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AF=84=E7=82=B9=E7=94=B5=E7=AB=99=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E6=8E=A5=E5=85=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../business/service/ShipEnergyService.java | 177 +++++++++ .../controller/ShipEnergyController.java | 32 ++ .../common/tools/constant/CommonConstant.java | 5 + .../ho/common/tools/util/AddressUntils.java | 2 +- .../com/ho/common/tools/util/HttpUtils.java | 342 ++++++++++++++++++ 5 files changed, 557 insertions(+), 1 deletion(-) create mode 100644 business-service-dao/src/main/java/com/ho/business/service/ShipEnergyService.java create mode 100644 business-service/src/main/java/com/ho/business/controller/ShipEnergyController.java create mode 100644 common-tools/src/main/java/com/ho/common/tools/util/HttpUtils.java diff --git a/business-service-dao/src/main/java/com/ho/business/service/ShipEnergyService.java b/business-service-dao/src/main/java/com/ho/business/service/ShipEnergyService.java new file mode 100644 index 0000000..49ce30d --- /dev/null +++ b/business-service-dao/src/main/java/com/ho/business/service/ShipEnergyService.java @@ -0,0 +1,177 @@ +package com.ho.business.service; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; +import com.google.common.collect.Maps; +import com.ho.business.vo.req.StationReqVO; +import com.ho.common.tools.constant.CommonConstant; +import com.ho.common.tools.service.RedisService; +import com.ho.common.tools.util.HttpUtils; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.io.IOException; +import java.math.BigDecimal; +import java.util.Date; +import java.util.HashMap; +import java.util.Map; +import java.util.concurrent.TimeUnit; + +/** + * 西安寄点能源股份有限公司 + * 西安寄点能源 API 接口 服务 + * + * @author kerwin + */ +@Service +@Slf4j +public class ShipEnergyService { + + /** + * token 缓存 key + */ + private static final String SHIP_ENERGY_TOKEN_KEY = "ShipEnergyToken"; + + /** + * 获取token 参数 platform + */ + private static final String PLATFORM = "f9599b6c79a5efbfc6ddce5fed1bbed5"; + + /** + * 获取token 参数 platformsecret + */ + private static final String PLATFORM_SECRET = "2928b16f9cb8e85199a4caa6ba3b6620"; + + /** + * 寄点能源- 获取token Url + */ + private static final String TOKEN_URL = "https://www.emind2000.cloud/rest-api/gettoken"; + + /** + * 寄点能源- 获取项目列表 Url + */ + private static final String STATION_URL = "https://www.emind2000.cloud/rest-api/getStations"; + + /** + * 寄点能源- 主监控汇总 Url + */ + private static final String MAIN_URL = "https://www.emind2000.cloud/rest-api/getMainTotal"; + + @Autowired + private RedisService redisService; + + @Autowired + private StationService stationService; + + /** + * 寄点能源 - 获取token + * @return token + */ + public String getToken(){ + String token = null; + if(redisService.hasKey(SHIP_ENERGY_TOKEN_KEY)){ + token = (String)redisService.get(SHIP_ENERGY_TOKEN_KEY); + } + Map params = Maps.newHashMap(); + params.put("platform",PLATFORM); + params.put("platformsecret",PLATFORM_SECRET); + try { + String json = HttpUtils.getWithForm(TOKEN_URL,params); + JSONObject jsonObject = JSONObject.parseObject(json); + Integer code = jsonObject.getInteger("code"); + if(CommonConstant.HttpCode.SUCCESS_CODE.equals(code)){ + JSONObject data = jsonObject.getJSONObject("data"); + token = data.getString("access_token"); + //redis 缓存 + redisService.set(SHIP_ENERGY_TOKEN_KEY,token,10, TimeUnit.HOURS); + } + } catch (IOException e) { + throw new RuntimeException(e); + } + return token; + } + + /** + * 寄点能源 - 获取 项目列表 + * @return 项目列表 json 字符串 + */ + public String getStations(){ + String Authorization = "eyJhbGciOiJIUzUxMiJ9.eyJ1c2VyX2lkIjo5Nzg2LCJ1c2VyX2tleSI6Ijk3ODY6N2RkNjU0MTgtNDg5ZS00MzgzLWI1ZmYtMTU2MmI5ZTY0NDFkIiwidXNlcm5hbWUiOiJ6emt5YXBpIn0.fQLMlOHaEjmfHeyEu5EcxZmQ8UjRBOUoteNV-tJ2ttAwyJmQidOk7xqL25K_wRIC-OQKt0vFVOpTzMFdH71uhw"; + Map headers = new HashMap<>(); + headers.put("Authorization",Authorization); + try { + String json = HttpUtils.getWithHeaders(STATION_URL,null,headers); + JSONObject jsonObject = JSONObject.parseObject(json); + Integer code = jsonObject.getInteger("code"); + if(CommonConstant.HttpCode.SUCCESS_CODE.equals(code)){ + JSONObject data = jsonObject.getJSONObject("data"); + return data.getString("rows"); + } + } catch (IOException e) { + throw new RuntimeException(e); + } + return null; + } + + /** + * + * 寄点能源 - 获取 主监控汇总信息 + * @param stationId 电站id + * @return 返回对应电站汇总信息 + */ + public String getMainTotal(String stationId){ + String Authorization = "eyJhbGciOiJIUzUxMiJ9.eyJ1c2VyX2lkIjo5Nzg2LCJ1c2VyX2tleSI6Ijk3ODY6MmE5YjUzODUtNjNiNC00OWRiLWFjODEtNzhmNWRmNjE0ZDgyIiwidXNlcm5hbWUiOiJ6emt5YXBpIn0.WMi4PgYQByeYXBfOGVM0mc4P5GcyAcGRkDo8F7TK8fXIkj9QZ9D34WmugiVX3GxRGODFs3u1ujH7qJyuQAM99w"; + Map headers = new HashMap<>(); + headers.put("Authorization",Authorization); + Map params = new HashMap<>(); + params.put("stationId",stationId); + try { + String json = HttpUtils.getWithHeaders(MAIN_URL,params,headers); + JSONObject jsonObject = JSONObject.parseObject(json); + Integer code = jsonObject.getInteger("code"); + if(CommonConstant.HttpCode.SUCCESS_CODE.equals(code)){ + return jsonObject.getString("data"); + } + } catch (IOException e) { + throw new RuntimeException(e); + } + return null; + } + /*****************************************业务处理******************************************************/ + + /** + * 寄点能源 - 电站信息融合储能平台处理 + */ + public void addShipEnergyStation(){ + String stationJson = getStations(); + JSONArray jsonStation = JSON.parseArray(stationJson); + jsonStation.forEach(i->{ + JSONObject jsonObj = (JSONObject) i; + Integer stationId = jsonObj.getInteger("stationId"); + String name = jsonObj.getString("name"); + String address = jsonObj.getString("address"); + String province = jsonObj.getString("province"); + String city = jsonObj.getString("city"); + BigDecimal longitude = jsonObj.getBigDecimal("longitude"); + BigDecimal latitude = jsonObj.getBigDecimal("latitude"); + BigDecimal maxPower = jsonObj.getBigDecimal("maxPower"); + BigDecimal capacity = jsonObj.getBigDecimal("capacity"); + Date commossioningTime = jsonObj.getDate("commossioningTime"); + StationReqVO vo = new StationReqVO(); + vo.setId(stationId+10000); + vo.setName(name); + vo.setAddress(address); + vo.setLongitude(longitude); + vo.setLatitude(latitude); + vo.setCapacity(capacity); + vo.setRatePower(maxPower); + vo.setGridTime(commossioningTime); + vo.setGroupId(155); + vo.setDeptId(155); + stationService.insertStation(vo); + }); + } +} + diff --git a/business-service/src/main/java/com/ho/business/controller/ShipEnergyController.java b/business-service/src/main/java/com/ho/business/controller/ShipEnergyController.java new file mode 100644 index 0000000..bf0e90a --- /dev/null +++ b/business-service/src/main/java/com/ho/business/controller/ShipEnergyController.java @@ -0,0 +1,32 @@ +package com.ho.business.controller; + +import com.ho.business.service.ShipEnergyService; +import com.ho.common.tools.annotation.TokenIgnore; +import com.ho.common.tools.constant.ContextConstant; +import com.ho.common.tools.exception.DataResult; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +@RequestMapping(ContextConstant.BUSINESS + "shipEnergyStation") +@RestController +@Api(tags = "业务模块-寄点能源电站管理") +public class ShipEnergyController { + + + @Autowired + ShipEnergyService shipEnergyService; + + + @PostMapping("add") + @ApiOperation(value = "新增电站接口") + @TokenIgnore + public DataResult add() { + shipEnergyService.addShipEnergyStation(); + return DataResult.success(); + } + +} diff --git a/common-tools/src/main/java/com/ho/common/tools/constant/CommonConstant.java b/common-tools/src/main/java/com/ho/common/tools/constant/CommonConstant.java index 60ce218..748f161 100644 --- a/common-tools/src/main/java/com/ho/common/tools/constant/CommonConstant.java +++ b/common-tools/src/main/java/com/ho/common/tools/constant/CommonConstant.java @@ -994,4 +994,9 @@ public interface CommonConstant { String CF_FROZEN = "cfFrozen"; //将数据库统配符合“_”变成普通字符 String JOIN_STATION_ID = "\\_"; + + interface HttpCode { + // 调用成功code + Integer SUCCESS_CODE = 200; + } } diff --git a/common-tools/src/main/java/com/ho/common/tools/util/AddressUntils.java b/common-tools/src/main/java/com/ho/common/tools/util/AddressUntils.java index 921cc53..a9a2af0 100644 --- a/common-tools/src/main/java/com/ho/common/tools/util/AddressUntils.java +++ b/common-tools/src/main/java/com/ho/common/tools/util/AddressUntils.java @@ -35,7 +35,7 @@ public class AddressUntils { } public static JSONObject getLocationInfo(String lat, String lng) throws IOException { - String urlString = "https://apis.map.qq.com/ws/geocoder/v1/?location=" + lat + "," + lng + "&key=" + secretKey; + String urlString = "http://apis.map.qq.com/ws/geocoder/v1/?location=" + lat + "," + lng + "&key=" + secretKey; System.out.println("请求经纬度url:" + urlString); URL url = new URL(urlString); HttpURLConnection conn = (HttpURLConnection) url.openConnection(); diff --git a/common-tools/src/main/java/com/ho/common/tools/util/HttpUtils.java b/common-tools/src/main/java/com/ho/common/tools/util/HttpUtils.java new file mode 100644 index 0000000..452215c --- /dev/null +++ b/common-tools/src/main/java/com/ho/common/tools/util/HttpUtils.java @@ -0,0 +1,342 @@ +package com.ho.common.tools.util; + +import java.io.*; +import java.net.HttpURLConnection; +import java.net.URL; +import java.net.URLEncoder; +import java.nio.charset.StandardCharsets; +import java.util.HashMap; +import java.util.Map; +import java.util.StringJoiner; + +/** + * HTTP工具类 - 支持GET/POST请求，支持表单和JSON传参 + */ +public class HttpUtils { + /** + * 连接超时时间（毫秒） + */ + private static final int CONNECT_TIMEOUT = 10000; + + /** + * 读取超时时间（毫秒） + */ + private static final int READ_TIMEOUT = 30000; + + /** + * 发送GET请求（表单参数模式） + * + * @param url 请求URL + * @param params 表单参数 + * @return 响应字符串 + * @throws IOException 网络异常 + */ + public static String getWithForm(String url, Map params) throws IOException { + return get(url, buildFormParams(params), "application/x-www-form-urlencoded"); + } + + /** + * 发送GET请求（JSON参数模式） + * + * @param url 请求URL + * @param jsonParams JSON参数字符串 + * @return 响应字符串 + * @throws IOException 网络异常 + */ + public static String getWithJson(String url, String jsonParams) throws IOException { + // 注意：GET请求通常不支持请求体中的JSON参数 + // 但某些API可能支持，这里将其作为查询参数传递 + Map params = new HashMap<>(); + params.put("json", jsonParams); + return get(url, buildFormParams(params), "application/x-www-form-urlencoded"); + } + + /** + * 发送POST请求（表单参数模式） + * + * @param url 请求URL + * @param params 表单参数 + * @return 响应字符串 + * @throws IOException 网络异常 + */ + public static String postWithForm(String url, Map params) throws IOException { + return post(url, buildFormParams(params), "application/x-www-form-urlencoded"); + } + + /** + * 发送POST请求（JSON参数模式） + * + * @param url 请求URL + * @param jsonParams JSON参数字符串 + * @return 响应字符串 + * @throws IOException 网络异常 + */ + public static String postWithJson(String url, String jsonParams) throws IOException { + return post(url, jsonParams, "application/json; charset=utf-8"); + } + + /** + * 发送POST请求（JSON参数模式，使用Map自动转换为JSON） + * + * @param url 请求URL + * @param params 参数Map + * @return 响应字符串 + * @throws IOException 网络异常 + */ + public static String postWithJson(String url, Map params) throws IOException { + String jsonParams = mapToJson(params); + return postWithJson(url, jsonParams); + } + + /** + * 发送GET请求（基础方法） + */ + private static String get(String url, String queryParams, String contentType) throws IOException { + String fullUrl = url; + if (queryParams != null && !queryParams.isEmpty()) { + fullUrl = url + "?" + queryParams; + } + + HttpURLConnection connection = null; + BufferedReader reader = null; + + try { + URL requestUrl = new URL(fullUrl); + connection = (HttpURLConnection) requestUrl.openConnection(); + connection.setRequestMethod("GET"); + connection.setConnectTimeout(CONNECT_TIMEOUT); + connection.setReadTimeout(READ_TIMEOUT); + connection.setRequestProperty("Content-Type", contentType); + connection.setRequestProperty("User-Agent", "HttpUtils/1.0"); + + int responseCode = connection.getResponseCode(); + if (responseCode == HttpURLConnection.HTTP_OK) { + reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8)); + return readResponse(reader); + } else { + reader = new BufferedReader(new InputStreamReader(connection.getErrorStream(), StandardCharsets.UTF_8)); + String errorResponse = readResponse(reader); + throw new IOException("HTTP GET Request Failed with Error Code: " + responseCode + ", Response: " + errorResponse); + } + } finally { + reader.close(); + connection.disconnect(); + } + } + + /** + * 发送POST请求（基础方法） + */ + private static String post(String url, String requestBody, String contentType) throws IOException { + HttpURLConnection connection = null; + OutputStream outputStream = null; + BufferedReader reader = null; + + try { + URL requestUrl = new URL(url); + connection = (HttpURLConnection) requestUrl.openConnection(); + connection.setRequestMethod("POST"); + connection.setConnectTimeout(CONNECT_TIMEOUT); + connection.setReadTimeout(READ_TIMEOUT); + connection.setDoOutput(true); + connection.setRequestProperty("Content-Type", contentType); + connection.setRequestProperty("User-Agent", "HttpUtils/1.0"); + connection.setRequestProperty("Accept", "application/json, text/plain, */*"); + + // 写入请求体 + if (requestBody != null && !requestBody.isEmpty()) { + outputStream = connection.getOutputStream(); + outputStream.write(requestBody.getBytes(StandardCharsets.UTF_8)); + outputStream.flush(); + } + + int responseCode = connection.getResponseCode(); + if (responseCode == HttpURLConnection.HTTP_OK || + responseCode == HttpURLConnection.HTTP_CREATED || + responseCode == HttpURLConnection.HTTP_ACCEPTED) { + reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8)); + return readResponse(reader); + } else { + reader = new BufferedReader(new InputStreamReader(connection.getErrorStream(), StandardCharsets.UTF_8)); + String errorResponse = readResponse(reader); + throw new IOException("HTTP POST Request Failed with Error Code: " + responseCode + ", Response: " + errorResponse); + } + } finally { + outputStream.close(); + reader.close(); + connection.connect(); + } + } + + /** + * 构建表单参数字符串 + */ + private static String buildFormParams(Map params) throws UnsupportedEncodingException { + if (params == null || params.isEmpty()) { + return ""; + } + + StringJoiner joiner = new StringJoiner("&"); + for (Map.Entry entry : params.entrySet()) { + String encodedKey = URLEncoder.encode(entry.getKey(), StandardCharsets.UTF_8.toString()); + String encodedValue = URLEncoder.encode(entry.getValue(), StandardCharsets.UTF_8.toString()); + joiner.add(encodedKey + "=" + encodedValue); + } + return joiner.toString(); + } + /** + * 将Map转换为JSON字符串（简单实现，实际项目中建议使用Jackson/Gson等库） + */ + private static String mapToJson(Map params) { + if (params == null || params.isEmpty()) { + return "{}"; + } + + StringBuilder jsonBuilder = new StringBuilder("{"); + boolean first = true; + + for (Map.Entry entry : params.entrySet()) { + if (!first) { + jsonBuilder.append(","); + } + first = false; + + jsonBuilder.append("\"").append(escapeJson(entry.getKey())).append("\":"); + + Object value = entry.getValue(); + if (value == null) { + jsonBuilder.append("null"); + } else if (value instanceof String) { + jsonBuilder.append("\"").append(escapeJson((String) value)).append("\""); + } else if (value instanceof Number || value instanceof Boolean) { + jsonBuilder.append(value); + } else { + // 复杂对象需要序列化，这里简单处理 + jsonBuilder.append("\"").append(escapeJson(value.toString())).append("\""); + } + } + + jsonBuilder.append("}"); + return jsonBuilder.toString(); + } + /** + * 转义JSON特殊字符 + */ + private static String escapeJson(String input) { + if (input == null) { + return ""; + } + + return input.replace("\\", "\\\\") + .replace("\"", "\\\"") + .replace("\b", "\\b") + .replace("\f", "\\f") + .replace("\n", "\\n") + .replace("\r", "\\r") + .replace("\t", "\\t"); + } + /** + * 读取响应内容 + */ + private static String readResponse(BufferedReader reader) throws IOException { + StringBuilder response = new StringBuilder(); + String line; + while ((line = reader.readLine()) != null) { + response.append(line); + } + return response.toString(); + } + + + /** + * 发送带请求头的GET请求（扩展方法） + */ + public static String getWithHeaders(String url, Map params, Map headers) throws IOException { + String fullUrl = url; + if (params != null && !params.isEmpty()) { + fullUrl = url + "?" + buildFormParams(params); + } + + HttpURLConnection connection = null; + BufferedReader reader = null; + + try { + URL requestUrl = new URL(fullUrl); + connection = (HttpURLConnection) requestUrl.openConnection(); + connection.setRequestMethod("GET"); + connection.setConnectTimeout(CONNECT_TIMEOUT); + connection.setReadTimeout(READ_TIMEOUT); + connection.setRequestProperty("User-Agent", "HttpUtils/1.0"); + + // 添加自定义请求头 + if (headers != null) { + for (Map.Entry header : headers.entrySet()) { + connection.setRequestProperty(header.getKey(), header.getValue()); + } + } + + int responseCode = connection.getResponseCode(); + if (responseCode == HttpURLConnection.HTTP_OK) { + reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8)); + return readResponse(reader); + } else { + reader = new BufferedReader(new InputStreamReader(connection.getErrorStream(), StandardCharsets.UTF_8)); + String errorResponse = readResponse(reader); + throw new IOException("HTTP GET Request Failed with Error Code: " + responseCode + ", Response: " + errorResponse); + } + } finally { + reader.close(); + connection.disconnect(); + } + } + + /** + * 发送带请求头的POST请求（扩展方法） + */ + public static String postWithHeaders(String url, String requestBody, String contentType, Map headers) throws IOException { + HttpURLConnection connection = null; + OutputStream outputStream = null; + BufferedReader reader = null; + + try { + URL requestUrl = new URL(url); + connection = (HttpURLConnection) requestUrl.openConnection(); + connection.setRequestMethod("POST"); + connection.setConnectTimeout(CONNECT_TIMEOUT); + connection.setReadTimeout(READ_TIMEOUT); + connection.setDoOutput(true); + connection.setRequestProperty("Content-Type", contentType); + connection.setRequestProperty("User-Agent", "HttpUtils/1.0"); + + // 添加自定义请求头 + if (headers != null) { + for (Map.Entry header : headers.entrySet()) { + connection.setRequestProperty(header.getKey(), header.getValue()); + } + } + + // 写入请求体 + if (requestBody != null && !requestBody.isEmpty()) { + outputStream = connection.getOutputStream(); + outputStream.write(requestBody.getBytes(StandardCharsets.UTF_8)); + outputStream.flush(); + } + + int responseCode = connection.getResponseCode(); + if (responseCode == HttpURLConnection.HTTP_OK || + responseCode == HttpURLConnection.HTTP_CREATED || + responseCode == HttpURLConnection.HTTP_ACCEPTED) { + reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8)); + return readResponse(reader); + } else { + reader = new BufferedReader(new InputStreamReader(connection.getErrorStream(), StandardCharsets.UTF_8)); + String errorResponse = readResponse(reader); + throw new IOException("HTTP POST Request Failed with Error Code: " + responseCode + ", Response: " + errorResponse); + } + } finally { + outputStream.close(); + reader.close(); + connection.disconnect(); + } + } +}