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 TaskUtils 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;
|
|
@Resource
|
private UploadRealTimeMonitoringDataService uploadRealTimeMonitoringDataService;
|
|
@Resource
|
private OnlineService onlineService;
|
|
@Resource
|
private OnlineReplyService onlineReplyService;
|
|
@Resource
|
private TransactionRecordService transactionRecordService;
|
|
@Resource
|
private ConfirmTransactionRecordService confirmTransactionRecordService;
|
|
@Resource
|
private PlatformStartChargingService platformStartChargingService;
|
|
@Resource
|
private SecurityDetectionService securityDetectionService;
|
|
@Resource
|
private PlatformStartChargingReplyService platformStartChargingReplyService;
|
|
@Resource
|
private MotorAbortService motorAbortService;
|
|
@Resource
|
private ErrorMessageMessageService errorMessageMessageService;
|
|
@Resource
|
private PlatformStopChargingService platformStopChargingService;
|
|
@Resource
|
private PlatformStopChargingReplyService platformStopChargingReplyService;
|
|
@Resource
|
private SetupBillingModelService setupBillingModelService;
|
|
@Resource
|
private SetupBillingModelReplyService setupBillingModelReplyService;
|
|
@Resource
|
private QrCodeDeliveryService qrCodeDeliveryService;
|
|
@Resource
|
private EndChargeService endChargeService;
|
|
|
|
|
|
private Integer port = null;
|
|
@Override
|
public void onApplicationEvent(WebServerInitializedEvent event) {
|
port = event.getWebServer().getPort();
|
}
|
|
|
/**
|
* 定时任务
|
*/
|
@Scheduled(cron = "0 0 10 * * ?")
|
public void run(){
|
if(null != port && port == 5700){
|
bmsInformationService.taskDelete();
|
bmsDemandAndChargerExportationService.taskDelete();
|
uploadRealTimeMonitoringDataService.taskDelete();
|
onlineService.taskDelete();
|
onlineReplyService.taskDelete();
|
billingModeVerifyService.taskDelete();
|
billingModeVerifyReplyService.taskDelete();
|
acquisitionBillingModeService.taskDelete();
|
acquisitionBillingModeReplyService.taskDelete();
|
transactionRecordService.taskDelete();
|
confirmTransactionRecordService.taskDelete();
|
platformStartChargingService.taskDelete();
|
securityDetectionService.taskDelete();
|
platformStartChargingReplyService.taskDelete();
|
chargingHandshakeService.taskDelete();
|
bmsAbortService.taskDelete();
|
motorAbortService.taskDelete();
|
errorMessageMessageService.taskDelete();
|
platformStopChargingService.taskDelete();
|
platformStopChargingReplyService.taskDelete();
|
setupBillingModelService.taskDelete();
|
setupBillingModelReplyService.taskDelete();
|
qrCodeDeliveryService.taskDelete();
|
endChargeService.taskDelete();
|
}
|
}
|
}
|
