|
@@ -43,24 +43,24 @@ public class ThemeSchedulerServiceImpl implements ThemeSchedulerService {
|
|
|
return false;
|
|
|
}
|
|
|
|
|
|
- public String generateNextCronExp(CrowdTestProject themeDetail) {
|
|
|
+ public String generateNextCronExp(CrowdTestProject crowdTestProject) {
|
|
|
String cronExp = null;
|
|
|
String dateFormat="ss mm HH dd MM EE";
|
|
|
SimpleDateFormat sdf = new SimpleDateFormat(dateFormat, Locale.US);
|
|
|
Date now = new Date();
|
|
|
- if(now.before(themeDetail.getCreateTime())) {
|
|
|
- cronExp = sdf.format(themeDetail.getCreateTime());
|
|
|
- } else if(now.before(themeDetail.getDeadTime())){
|
|
|
- cronExp = sdf.format(themeDetail.getDeadTime());
|
|
|
+ if(now.before(crowdTestProject.getCreateTime())) {
|
|
|
+ cronExp = sdf.format(crowdTestProject.getCreateTime());
|
|
|
+ } else if(now.before(crowdTestProject.getDeadTime())){
|
|
|
+ cronExp = sdf.format(crowdTestProject.getDeadTime());
|
|
|
}
|
|
|
return cronExp;
|
|
|
}
|
|
|
@Override
|
|
|
- public boolean cancelThemeScheduler(CrowdTestProject themeDetail) {
|
|
|
- if(this.map.containsKey(themeDetail)) {
|
|
|
- ThemeScheduler themeDetailScheduler = map.get(themeDetail);
|
|
|
+ public boolean cancelThemeScheduler(CrowdTestProject crowdTestProject) {
|
|
|
+ if(this.map.containsKey(crowdTestProject)) {
|
|
|
+ ThemeScheduler themeDetailScheduler = map.get(crowdTestProject);
|
|
|
themeDetailScheduler.stopCron();
|
|
|
- map.remove(themeDetail);
|
|
|
+ map.remove(crowdTestProject);
|
|
|
return true;
|
|
|
}
|
|
|
return false;
|
|
@@ -98,12 +98,12 @@ public class ThemeSchedulerServiceImpl implements ThemeSchedulerService {
|
|
|
|
|
|
public MyRunnable() {}
|
|
|
|
|
|
- public MyRunnable (CrowdTestProject themeDetail) {
|
|
|
+ public MyRunnable (CrowdTestProject crowdTestProject) {
|
|
|
this.crowdTestProject = crowdTestProject;
|
|
|
}
|
|
|
-
|
|
|
@Override
|
|
|
public void run() {
|
|
|
+ System.out.println("ThemeScheduler " + this.crowdTestProject.getName() + " updateStatus," + new Date());
|
|
|
Integer result = themeStatusService.updateStatus(this.crowdTestProject);
|
|
|
map.remove(crowdTestProject);
|
|
|
if(result.equals(CrowdTestProject.HAS_CREATED) || result.equals(CrowdTestProject.HAS_RELEASED)) {
|