Browse Source

Merge branch 'dev' of chenweida/patient-co-management into dev

chenweida 7 years ago
parent
commit
58bbb3f55b

+ 6 - 4
patient-co-statistics-es/src/main/java/com/yihu/wlyy/statistics/service/JobService.java

@ -27,6 +27,8 @@ import java.util.*;
 */
@Service
public class JobService {
    private Long sleepTime = 10000L;
    @Autowired
    private QuartzHelper quartzHelper;
@ -147,7 +149,7 @@ public class JobService {
                    params.put("endTime", getYesterday(0 - i));
                    if (!StringUtils.isEmpty(quartzJobConfig.getJobClass())) {
                        quartzHelper.startNow(getRightClass(quartzJobConfig), quartzJobConfig.getId() + UUID.randomUUID().toString().replace("-", ""), params);
                       Thread.sleep(6000L);
                        Thread.sleep(sleepTime);
                    }
                }
            }
@ -189,7 +191,7 @@ public class JobService {
                params.put("timeLevel", j + "");
                if (!StringUtils.isEmpty(quartzJobConfig.getJobClass())) {
                    quartzHelper.startNow(getRightClass(quartzJobConfig), quartzJobConfig.getId() + UUID.randomUUID().toString().replace("-", ""), params);
                    Thread.sleep(6000L);
                    Thread.sleep(sleepTime);
                }
            }
@ -235,7 +237,7 @@ public class JobService {
            params.put("timeLevel", j + "");
            if (!StringUtils.isEmpty(quartzJobConfig.getJobClass())) {
                quartzHelper.startNow(getRightClass(quartzJobConfig), quartzJobConfig.getId() + UUID.randomUUID().toString().replace("-", ""), params);
                Thread.sleep(6000L);
                Thread.sleep(sleepTime);
            }
        }
    }
@ -264,7 +266,7 @@ public class JobService {
                params.put("timeLevel", j + "");
                if (!StringUtils.isEmpty(quartzJobConfig.getJobClass())) {
                    quartzHelper.startNow(getRightClass(quartzJobConfig), quartzJobConfig.getId() + UUID.randomUUID().toString().replace("-", ""), params);
                    Thread.sleep(6000L);
                    Thread.sleep(sleepTime);
                }
            }
        }