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();
		}
	}
}