moliparty/peko-java
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修复quartz

Browse Source
This commit is contained in:
liaozetao
2023-11-27 17:03:59 +08:00
parent cfce43741f
commit 5048cd55fb
1 changed files with 0 additions and 51 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
accompany-business/accompany-business-web/src/test/java/servicetest/CrossRoomPkTest.java
View File

@@ -1,6 +1,5 @@
package servicetest;
import cn.hutool.core.util.ObjectUtil;
import com.accompany.business.constant.CrossRoomRecordStatusEnum;
import com.accompany.business.dto.CrossRoomPkNotifyDto;
import com.accompany.business.dto.CrossRoomPkPanelDto;
@@ -40,10 +39,8 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.google.gson.Gson;
import org.junit.Test;
import org.quartz.*;
import org.springframework.beans.factory.annotation.Autowired;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Date;
@@ -71,9 +68,6 @@ public class CrossRoomPkTest extends CommonTest {
@Autowired
private SysConfService sysConfService;
@Autowired
private Scheduler scheduler;
@Autowired
private HomeService homeService;
@@ -205,51 +199,6 @@ public class CrossRoomPkTest extends CommonTest {
}
@Test
public void triggerTest() throws SchedulerException {
Long roundId = 99999l;
String CRON_FORMAT = "ss mm HH dd MM ? yyyy";
Date currentTime = new Date();
Long planEndTimeMs = currentTime.getTime() + 20 * 1000;
Date planEndDate = DateTimeUtil.convertMsToDate(planEndTimeMs);
/*TriggerKey triggerKey1 = TriggerKey.triggerKey(String.valueOf(roundId));
CronTrigger triggerQ1 = (CronTrigger) scheduler.getTrigger(triggerKey1);
//取消定时任务执行
if (ObjectUtil.isNotNull(triggerQ1)) {
SimpleDateFormat formatQ1 = new SimpleDateFormat(CRON_FORMAT);
String taskCronQ1 = formatQ1.format(planEndDate);
CronScheduleBuilder scheduleBuilderQ = CronScheduleBuilder.cronSchedule(taskCronQ1);
triggerQ1 = triggerQ1.getTriggerBuilder().withIdentity(triggerKey1).withSchedule(scheduleBuilderQ).build();
scheduler.rescheduleJob(triggerKey1, triggerQ1);
}*/
SimpleDateFormat format = new SimpleDateFormat(CRON_FORMAT);
String taskCron = format.format(planEndDate);
/*JobDetail jobDetail = JobBuilder.newJob(CrossRoomPKEndJob.class).withIdentity(String.valueOf(roundId)).build();
jobDetail.getJobDataMap().put("crossRoomPKEndJob", roundId);
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(taskCron);
CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(String.valueOf(roundId)).withSchedule(scheduleBuilder).build();
scheduler.scheduleJob(jobDetail, trigger);*/
TriggerKey triggerKey = TriggerKey.triggerKey(String.valueOf(roundId));
CronTrigger triggerQ = (CronTrigger) scheduler.getTrigger(triggerKey);
//取消定时任务执行
if (ObjectUtil.isNotNull(triggerQ)) {
SimpleDateFormat formatQ = new SimpleDateFormat(CRON_FORMAT);
String taskCronQ = format.format(planEndDate);
CronScheduleBuilder scheduleBuilderQ = CronScheduleBuilder.cronSchedule(taskCron);
triggerQ = triggerQ.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilderQ).build();
scheduler.rescheduleJob(triggerKey, triggerQ);
}
System.out.println("结束测试...");
}
@Test
public void pkStatusCheck() {
List<PlayRoomVo> playRoomVos = new ArrayList<>();