|
@@ -1,7 +1,7 @@
|
|
|
package com.qmth.themis.task.start;
|
|
|
|
|
|
+import com.qmth.themis.business.util.JacksonUtil;
|
|
|
import com.qmth.themis.task.config.DictionaryConfig;
|
|
|
-import com.qmth.themis.task.quartz.MqJob;
|
|
|
import com.qmth.themis.task.service.QuartzService;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
@@ -9,7 +9,7 @@ import org.springframework.boot.CommandLineRunner;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
-import java.util.HashMap;
|
|
|
+import java.util.List;
|
|
|
import java.util.Map;
|
|
|
|
|
|
/**
|
|
@@ -33,10 +33,11 @@ public class StartRunning implements CommandLineRunner {
|
|
|
public void run(String... args) throws Exception {
|
|
|
log.info("服务器启动时执行 start");
|
|
|
log.info("增加mqjob start");
|
|
|
- Map map = new HashMap();
|
|
|
- map.put("name", MqJob.class.getName());
|
|
|
- quartzService.deleteJob(dictionaryConfig.quartzConfigDomain().getBackendJobName(), dictionaryConfig.quartzConfigDomain().getBackendJobGroupName());
|
|
|
- quartzService.addJob(MqJob.class, dictionaryConfig.quartzConfigDomain().getBackendJobName(), dictionaryConfig.quartzConfigDomain().getBackendJobGroupName(), "0 0/1 * * * ?", map);
|
|
|
+ //如果已经创建了任务,下次并不需要删除和新增
|
|
|
+// Map map = new HashMap();
|
|
|
+// map.put("name", MqJob.class.getName());
|
|
|
+// quartzService.deleteJob(dictionaryConfig.quartzConfigDomain().getBackendJobName(), dictionaryConfig.quartzConfigDomain().getBackendJobGroupName());
|
|
|
+// quartzService.addJob(MqJob.class, dictionaryConfig.quartzConfigDomain().getBackendJobName(), dictionaryConfig.quartzConfigDomain().getBackendJobGroupName(), "0 0/1 * * * ?", map);
|
|
|
log.info("增加mqjob end");
|
|
|
log.info("服务器启动时执行 end");
|
|
|
}
|