diff --git a/jeecg-boot-base-core/src/main/java/org/jeecg/common/properties/HttpClientHostProperties.java b/jeecg-boot-base-core/src/main/java/org/jeecg/common/properties/HttpClientHostProperties.java index da68ea9..62d4360 100644 --- a/jeecg-boot-base-core/src/main/java/org/jeecg/common/properties/HttpClientHostProperties.java +++ b/jeecg-boot-base-core/src/main/java/org/jeecg/common/properties/HttpClientHostProperties.java @@ -14,4 +14,6 @@ public class HttpClientHostProperties { */ private String oceanHost; + private String armdHost; + } diff --git a/jeecg-module-large-screen/src/main/java/org/jeecg/sysEmail/controller/SysEmailController.java b/jeecg-module-large-screen/src/main/java/org/jeecg/sysEmail/controller/SysEmailController.java new file mode 100644 index 0000000..403dc1a --- /dev/null +++ b/jeecg-module-large-screen/src/main/java/org/jeecg/sysEmail/controller/SysEmailController.java @@ -0,0 +1,410 @@ +package org.jeecg.sysEmail.controller; + +import com.fasterxml.jackson.core.type.TypeReference; +import com.fasterxml.jackson.databind.ObjectMapper; +import io.swagger.v3.oas.annotations.Operation; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.apache.http.client.utils.URIBuilder; +import org.jeecg.common.api.vo.Result; +import org.jeecg.common.properties.HttpClientHostProperties; +import org.jeecg.sysEmail.entity.SysEmail; +import org.jeecg.utils.HttpClientUtil; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.format.annotation.DateTimeFormat; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.RequestParam; +import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.bind.annotation.RequestMapping; + +import java.io.IOException; +import java.net.URI; +import java.net.URISyntaxException; +import java.net.URLEncoder; +import java.time.LocalDate; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.stream.Collectors; +import java.util.stream.IntStream; + +@RestController +@RequestMapping("/sysEmail") +@Slf4j +@RequiredArgsConstructor +public class SysEmailController { + + private final HttpClientHostProperties hostProperties; + + + @Operation(summary = "获取邮箱列表") + @GetMapping("/getEmailList") + public Result> getEmailList() throws IOException { + String url = hostProperties.getArmdHost(); + String apiUrl = url + "sysEmail/sourceList"; + Map getHeaders = Map.of("Authorization", ""); + + String apiResult= HttpClientUtil.doGet(apiUrl, getHeaders, true); // 启用 SSL + //region + String getResult = "{\n" + + " \"success\": true,\n" + + " \"message\": \"\",\n" + + " \"code\": 200,\n" + + " \"result\": [\n" + + " {\n" + + " \"sourceId\": \"1002\",\n" + + " \"sourceName\": \"15210169137\",\n" + + " \"hostId\": null,\n" + + " \"cpuUsedItemId\": null,\n" + + " \"enabled\": 1\n" + + " },\n" + + " {\n" + + " \"sourceId\": \"1001\",\n" + + " \"sourceName\": \"15210169137@139.com\",\n" + + " \"hostId\": null,\n" + + " \"cpuUsedItemId\": null,\n" + + " \"enabled\": 1\n" + + " },\n" + + " {\n" + + " \"sourceId\": \"1999017699534446594\",\n" + + " \"sourceName\": \"test0002\",\n" + + " \"hostId\": null,\n" + + " \"cpuUsedItemId\": null,\n" + + " \"enabled\": 1\n" + + " }\n" + + " ],\n" + + " \"timestamp\": 1765456465367\n" + + "}"; + //endregion + try { + ObjectMapper objectMapper = new ObjectMapper(); + Result> result = objectMapper.readValue(getResult, new TypeReference<>() { + }); + if (result.getCode() == 200) { + return result; + } else { + return Result.error("API 请求失败, 错误码: " + result.getCode() + ", 消息: " + result.getMessage()); + } + } catch (Exception e) { + e.printStackTrace(); + return Result.error("获取邮箱服务器列表失败: " + e.getMessage()); + } + } + + /** + * 获取最近的邮箱数据信息 + * + * @return + */ + @Operation(summary = "获取昨天和今天的邮件信息") + @GetMapping("/getRecentAlarms") + public Result> getRecentAlarms() throws IOException { + String url = hostProperties.getArmdHost(); + String apiUrl = url + "sysEmailLog/getRecentAlarms"; + Map getHeaders = Map.of("Authorization", ""); + String apiResult= HttpClientUtil.doGet(apiUrl, getHeaders, true); // 启用 SSL + //region + String toDayResult = " {\n" + + " \"success\": true,\n" + + " \"message\": \"\",\n" + + " \"code\": 200,\n" + + " \"result\": {\n" + + " \"categories\": [\n" + + " \"00:00\",\n" + + " \"01:00\",\n" + + " \"02:00\",\n" + + " \"03:00\",\n" + + " \"04:00\",\n" + + " \"05:00\",\n" + + " \"06:00\",\n" + + " \"07:00\",\n" + + " \"08:00\",\n" + + " \"09:00\",\n" + + " \"10:00\",\n" + + " \"11:00\",\n" + + " \"12:00\",\n" + + " \"13:00\",\n" + + " \"14:00\",\n" + + " \"15:00\",\n" + + " \"16:00\",\n" + + " \"17:00\",\n" + + " \"18:00\",\n" + + " \"19:00\",\n" + + " \"20:00\",\n" + + " \"21:00\",\n" + + " \"22:00\",\n" + + " \"23:00\"\n" + + " ],\n" + + " \"series\": {\n" + + " \"todayAlarm\": [\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0\n" + + " ],\n" + + " \"todayProcess\": [\n" + + " 54,\n" + + " 41,\n" + + " 46,\n" + + " 40,\n" + + " 48,\n" + + " 48,\n" + + " 66,\n" + + " 49,\n" + + " 47,\n" + + " 44,\n" + + " 47,\n" + + " 39,\n" + + " 50,\n" + + " 43,\n" + + " 45,\n" + + " 40,\n" + + " 21,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0\n" + + " ],\n" + + " \"yesterdayAlarm\": [\n" + + " 3,\n" + + " 4,\n" + + " 4,\n" + + " 4,\n" + + " 4,\n" + + " 3,\n" + + " 4,\n" + + " 4,\n" + + " 4,\n" + + " 3,\n" + + " 4,\n" + + " 4,\n" + + " 4,\n" + + " 3,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0\n" + + " ],\n" + + " \"yesterdayProcess\": [\n" + + " 49,\n" + + " 52,\n" + + " 52,\n" + + " 56,\n" + + " 58,\n" + + " 50,\n" + + " 80,\n" + + " 38,\n" + + " 69,\n" + + " 39,\n" + + " 66,\n" + + " 31,\n" + + " 50,\n" + + " 60,\n" + + " 51,\n" + + " 37,\n" + + " 60,\n" + + " 40,\n" + + " 55,\n" + + " 41,\n" + + " 50,\n" + + " 42,\n" + + " 52,\n" + + " 34\n" + + " ]\n" + + " }\n" + + " },\n" + + " \"timestamp\": 1765528894649\n" + + "}"; + + + //endregion + try { + ObjectMapper objectMapper = new ObjectMapper(); + Result> result = objectMapper.readValue(toDayResult, new TypeReference<>() { + }); + if (result.getCode() == 200) { + return result; + } else { + return Result.error("API 请求失败, 错误码: " + result.getCode() + ", 消息: " + result.getMessage()); + } + } catch (Exception e) { + e.printStackTrace(); + return Result.error("获取邮箱服务器列表失败: " + e.getMessage()); + } + + + } + + @GetMapping("/getMonthly") + @Operation(summary = "获取一月的邮件信息") + public Result> getMonthly(@RequestParam("emailId") String emailId, + @RequestParam("startDate") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate startDate, + @RequestParam("endDate") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate endDate) throws URISyntaxException, IOException { + String url = hostProperties.getArmdHost(); + String apiUrl = url + "sysEmailLog/getYesterdayAndToday"; + Map getHeaders = Map.of("Authorization", ""); + + String fullUrl = apiUrl + "?emailId=" + URLEncoder.encode(emailId, "UTF-8") + + "&startDate=" + startDate.toString() // LocalDate的toString()默认就是yyyy-MM-dd格式 + + "&endDate=" + endDate.toString(); + String apiResult = HttpClientUtil.doGet(fullUrl, getHeaders, true); + //region + String DataResult = " {\n" + + " \"success\": true,\n" + + " \"message\": \"\",\n" + + " \"code\": 200,\n" + + " \"result\": {\n" + + " \"categories\": [\n" + + " \"11-12\",\n" + + " \"11-13\",\n" + + " \"11-14\",\n" + + " \"11-15\",\n" + + " \"11-16\",\n" + + " \"11-17\",\n" + + " \"11-18\",\n" + + " \"11-19\",\n" + + " \"11-20\",\n" + + " \"11-21\",\n" + + " \"11-22\",\n" + + " \"11-23\",\n" + + " \"11-24\",\n" + + " \"11-25\",\n" + + " \"11-26\",\n" + + " \"11-27\",\n" + + " \"11-28\",\n" + + " \"11-29\",\n" + + " \"11-30\",\n" + + " \"12-01\",\n" + + " \"12-02\",\n" + + " \"12-03\",\n" + + " \"12-04\",\n" + + " \"12-05\",\n" + + " \"12-06\",\n" + + " \"12-07\",\n" + + " \"12-08\",\n" + + " \"12-09\",\n" + + " \"12-10\",\n" + + " \"12-11\",\n" + + " \"12-12\"\n" + + " ],\n" + + " \"series\": {\n" + + " \"alarm\": [\n" + + " 52,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 0,\n" + + " 1,\n" + + " 32,\n" + + " 52,\n" + + " 0\n" + + " ],\n" + + " \"process\": [\n" + + " 2900,\n" + + " 1673,\n" + + " 1060,\n" + + " 2030,\n" + + " 2364,\n" + + " 2060,\n" + + " 2325,\n" + + " 1438,\n" + + " 1116,\n" + + " 1138,\n" + + " 1173,\n" + + " 1134,\n" + + " 1123,\n" + + " 1158,\n" + + " 1097,\n" + + " 1102,\n" + + " 1203,\n" + + " 1124,\n" + + " 1137,\n" + + " 1201,\n" + + " 1125,\n" + + " 1138,\n" + + " 1200,\n" + + " 1275,\n" + + " 1133,\n" + + " 1255,\n" + + " 1288,\n" + + " 1083,\n" + + " 1167,\n" + + " 1212,\n" + + " 768\n" + + " ]\n" + + " }\n" + + " },\n" + + " \"timestamp\": 1765531641598\n" + + "}";//HttpClientUtil.doGet(getUrl, getHeaders, true); // 启用 SSL + + + //endregion + try { + ObjectMapper objectMapper = new ObjectMapper(); + Result> result = objectMapper.readValue(DataResult, new TypeReference<>() { + }); + + if (result.getCode() == 200) { + return result; + } else { + return Result.error("API 请求失败, 错误码: " + result.getCode() + ", 消息: " + result.getMessage()); + } + } catch (Exception e) { + e.printStackTrace(); + return Result.error("获取邮箱服务器列表失败: " + e.getMessage()); + } + } + + +} diff --git a/jeecg-module-large-screen/src/main/java/org/jeecg/sysEmail/entity/SysEmail.java b/jeecg-module-large-screen/src/main/java/org/jeecg/sysEmail/entity/SysEmail.java new file mode 100644 index 0000000..5c45966 --- /dev/null +++ b/jeecg-module-large-screen/src/main/java/org/jeecg/sysEmail/entity/SysEmail.java @@ -0,0 +1,20 @@ +package org.jeecg.sysEmail.entity; + +import java.io.Serializable; +import lombok.Data; + +@Data +public class SysEmail implements Serializable { + private String sourceId; + + private String sourceName; + + private String hostId; + + private String cpuUsedItemId; + + /** + * 是否启用邮箱（0-不启用，1-启用） + */ + private Integer enabled; +}