From d4020168658efdee89a633083cd9c14b06c4d863 Mon Sep 17 00:00:00 2001 From: zhangf <1603559716@qq.com> Date: 星期三, 11 九月 2024 17:09:10 +0800 Subject: [PATCH] 修改消息推送时间间隔 --- src/main/java/com/gkhy/fourierSpecialGasMonitor/schedule/TestSchedule.java | 148 ++++++++++++++++++++++++------------------------ 1 files changed, 74 insertions(+), 74 deletions(-) diff --git a/src/main/java/com/gkhy/fourierSpecialGasMonitor/schedule/TestSchedule.java b/src/main/java/com/gkhy/fourierSpecialGasMonitor/schedule/TestSchedule.java index bbdc5f9..ce890cb 100644 --- a/src/main/java/com/gkhy/fourierSpecialGasMonitor/schedule/TestSchedule.java +++ b/src/main/java/com/gkhy/fourierSpecialGasMonitor/schedule/TestSchedule.java @@ -37,19 +37,19 @@ // private static final DateTimeFormatter execformatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); // // -// //@Scheduled(cron = "1 * * * * ?") -// //@Async(value = "SocketTaskExecutor") -// //public void testDeviceMonitor() { -// // logger.info("【硬件设备一分钟一次推送测试】:" + LocalDateTime.now().format(execformatter)); -// // DeviceMonitorReqDTO deviceMonitorReqDTO = new DeviceMonitorReqDTO(); -// // deviceMonitorReqDTO.setTime(LocalDateTime.now()); -// // deviceMonitorReqDTO.setConState(0); -// // deviceMonitorReqDTO.setFluxState(0); -// // List<Integer> list = new ArrayList<>(); -// // list.add(0); -// // deviceMonitorReqDTO.setHardwareState(list); -// // dataReceiveService.deviceMonitor(deviceMonitorReqDTO); -// //} +// @Scheduled(cron = "1 * * * * ?") +// @Async(value = "SocketTaskExecutor") +// public void testDeviceMonitor() { +// logger.info("【硬件设备一分钟一次推送测试】:" + LocalDateTime.now().format(execformatter)); +// DeviceMonitorReqDTO deviceMonitorReqDTO = new DeviceMonitorReqDTO(); +// deviceMonitorReqDTO.setTime(LocalDateTime.now()); +// deviceMonitorReqDTO.setConState(1); +// deviceMonitorReqDTO.setFluxState(0); +// List<Integer> list = new ArrayList<>(); +// list.add(0); +// deviceMonitorReqDTO.setHardwareState(list); +// dataReceiveService.deviceMonitor(deviceMonitorReqDTO); +// } // // // //@Scheduled(cron = "0/30 * * * * ?") @@ -139,65 +139,65 @@ // @Autowired // private DataReceiveController dataReceiveController; // -// @Scheduled(cron = "0/30 * * * * ?") -// //@Scheduled(cron = "0 0/15 * * * ?") -// @Async(value = "SocketTaskExecutor") -// public void testGasFlux() { -// logger.info("【气体通量推送测试】:"+LocalDateTime.now().format(execformatter)); -// for (int i = 1; i <= 6 ; i++) { -// Random random = new Random(); -// double randomDouble = random.nextDouble() * 99.9 + 1; // 生成1到100之间的随机双精度数 -// DecimalFormat decimalFormat = new DecimalFormat("0.0"); -// String formattedDouble = decimalFormat.format(randomDouble); -// double result = Double.parseDouble(formattedDouble); -// UploadGasFluxReqDTO dto = new UploadGasFluxReqDTO(); -// dto.setEquipmentId("No-123456"); -// dto.setTime(LocalDateTime.now()); -// dto.setAreaId(i); -// dto.setType(1); -// dto.setWindSpeed(12.3); -// dto.setWindDirection(56); -// dto.setGasName01(1); -// dto.setGasValue01(result); -// dto.setGasName02(2); -// dto.setGasValue02(result); -// dto.setGasName03(3); -// dto.setGasValue03(result); -// dto.setGasName04(4); -// dto.setGasValue04(result); -// dto.setGasName05(5); -// dto.setGasValue05(result); -// dto.setGasName06(6); -// dto.setGasValue06(result); -// dto.setGasName07(7); -// dto.setGasValue07(result); -// dto.setGasName08(8); -// dto.setGasValue08(result); -// dto.setGasName09(9); -// dto.setGasValue09(result); -// dto.setGasName10(10); -// dto.setGasValue10(result); -// dto.setGasName11(11); -// dto.setGasValue11(result); -// dto.setGasName12(12); -// dto.setGasValue12(result); -// dto.setGasName13(13); -// dto.setGasValue13(result); -// dto.setGasName14(14); -// dto.setGasValue14(result); -// dto.setGasName15(15); -// dto.setGasValue15(result); -// dto.setGasName16(16); -// dto.setGasValue16(result); -// dto.setGasName17(17); -// dto.setGasValue17(result); -// dto.setGasName18(18); -// dto.setGasValue18(result); -// dto.setGasName19(19); -// dto.setGasValue19(result); -// dto.setGasName20(20); -// dto.setGasValue20(result); -// dataReceiveController.uploadGasFlux(dto); -// } -// } +// //@Scheduled(cron = "0/30 * * * * ?") +// ////@Scheduled(cron = "0 0/15 * * * ?") +// //@Async(value = "SocketTaskExecutor") +// //public void testGasFlux() { +// // logger.info("【气体通量推送测试】:"+LocalDateTime.now().format(execformatter)); +// // for (int i = 1; i <= 6 ; i++) { +// // Random random = new Random(); +// // double randomDouble = random.nextDouble() * 99.9 + 1; // 生成1到100之间的随机双精度数 +// // DecimalFormat decimalFormat = new DecimalFormat("0.0"); +// // String formattedDouble = decimalFormat.format(randomDouble); +// // double result = Double.parseDouble(formattedDouble); +// // UploadGasFluxReqDTO dto = new UploadGasFluxReqDTO(); +// // dto.setEquipmentId("No-123456"); +// // dto.setTime(LocalDateTime.now()); +// // dto.setAreaId(i); +// // dto.setType(1); +// // dto.setWindSpeed(12.3); +// // dto.setWindDirection(56); +// // dto.setGasName01(1); +// // dto.setGasValue01(result); +// // dto.setGasName02(2); +// // dto.setGasValue02(result); +// // dto.setGasName03(3); +// // dto.setGasValue03(result); +// // dto.setGasName04(4); +// // dto.setGasValue04(result); +// // dto.setGasName05(5); +// // dto.setGasValue05(result); +// // dto.setGasName06(6); +// // dto.setGasValue06(result); +// // dto.setGasName07(7); +// // dto.setGasValue07(result); +// // dto.setGasName08(8); +// // dto.setGasValue08(result); +// // dto.setGasName09(9); +// // dto.setGasValue09(result); +// // dto.setGasName10(10); +// // dto.setGasValue10(result); +// // dto.setGasName11(11); +// // dto.setGasValue11(result); +// // dto.setGasName12(12); +// // dto.setGasValue12(result); +// // dto.setGasName13(13); +// // dto.setGasValue13(result); +// // dto.setGasName14(14); +// // dto.setGasValue14(result); +// // dto.setGasName15(15); +// // dto.setGasValue15(result); +// // dto.setGasName16(16); +// // dto.setGasValue16(result); +// // dto.setGasName17(17); +// // dto.setGasValue17(result); +// // dto.setGasName18(18); +// // dto.setGasValue18(result); +// // dto.setGasName19(19); +// // dto.setGasValue19(result); +// // dto.setGasName20(20); +// // dto.setGasValue20(result); +// // dataReceiveController.uploadGasFlux(dto); +// // } +// //} //} \ No newline at end of file -- Gitblit v1.9.2