From fac94f9e4c24f436662170d8194d238bfa4ad363 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期五, 20 六月 2025 11:05:26 +0800
Subject: [PATCH] Merge branch 'dev' of http://120.76.84.145:10101/gitblit/r/java/mx_charging_pile
---
ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/util/TaskUtil.java | 111 +++++++++++++++++++++++++++++++++----------------------
1 files changed, 67 insertions(+), 44 deletions(-)
diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/util/TaskUtil.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/util/TaskUtil.java
index de47e18..9ed48f0 100644
--- a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/util/TaskUtil.java
+++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/util/TaskUtil.java
@@ -1,44 +1,67 @@
-package com.ruoyi.integration.util;
-
-import com.ruoyi.integration.mongodb.service.PingService;
-import com.ruoyi.integration.mongodb.service.PongService;
-import com.ruoyi.integration.rocket.produce.ChargingMessageListener;
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Component;
-
-import javax.annotation.Resource;
-
-
-/**
- * @author zhibing.pu
- * @date 2023/7/11 8:39
- */
-@Component
-public class TaskUtil {
-
- @Resource
- private ChargingMessageListener chargingMessageListener;
-
- @Resource
- private PingService pingService;
-
- @Resource
- private PongService pongService;
-
-
- /**
- * 5分钟执行的定时任务
- */
- @Scheduled(fixedRate = 300000)
- public void taskMonth() {
- chargingMessageListener.transactionRecord();
- }
-
-
-
- @Scheduled(cron = "0 0 0 * * ?")
- public void task2() {
- pingService.delPing();
- pongService.delPong();
- }
-}
+//package com.ruoyi.integration.util;
+//
+//import com.ruoyi.integration.mongodb.service.*;
+//import org.springframework.boot.web.context.WebServerInitializedEvent;
+//import org.springframework.context.ApplicationListener;
+//import org.springframework.scheduling.annotation.Scheduled;
+//import org.springframework.stereotype.Component;
+//
+//import javax.annotation.Resource;
+//
+///**
+// * 定时任务工具类
+// * @author zhibing.pu
+// * @Date 2025/5/21 11:43
+// */
+//@Component
+//public class TaskUtil implements ApplicationListener<WebServerInitializedEvent> {
+//
+// @Resource
+// private AcquisitionBillingModeReplyService acquisitionBillingModeReplyService;
+//
+// @Resource
+// private AcquisitionBillingModeService acquisitionBillingModeService;
+//
+// @Resource
+// private BillingModeVerifyReplyService billingModeVerifyReplyService;
+//
+// @Resource
+// private BillingModeVerifyService billingModeVerifyService;
+//
+// @Resource
+// private BmsAbortService bmsAbortService;
+//
+// @Resource
+// private BmsDemandAndChargerExportationService bmsDemandAndChargerExportationService;
+//
+// @Resource
+// private BmsInformationService bmsInformationService;
+//
+// @Resource
+// private ChargingHandshakeService chargingHandshakeService;
+//
+// private Integer port = null;
+//
+// @Override
+// public void onApplicationEvent(WebServerInitializedEvent event) {
+// port = event.getWebServer().getPort();
+// }
+//
+//
+// /**
+// * 定时任务
+// */
+// @Scheduled(cron = "0 0 9 * * ?")
+// public void run(){
+// if(null != port && port == 5701){
+// acquisitionBillingModeReplyService.taskDelete();
+// acquisitionBillingModeService.taskDelete();
+// billingModeVerifyReplyService.taskDelete();
+// billingModeVerifyService.taskDelete();
+// bmsAbortService.taskDelete();
+// bmsDemandAndChargerExportationService.taskDelete();
+// bmsInformationService.taskDelete();
+// chargingHandshakeService.taskDelete();
+// }
+// }
+//}
--
Gitblit v1.7.1