|
|
@@ -46,17 +46,20 @@ public class XxlJobServiceImpl implements XxlJobService {
|
|
|
private XxlJobLogReportDao xxlJobLogReportDao;
|
|
|
|
|
|
@Override
|
|
|
- public Map<String, Object> pageList(int start, int length, int jobGroup, int triggerStatus, String jobDesc, String executorHandler, String author) {
|
|
|
+ public Map<String, Object> pageList(int start, int length, int jobGroup, int triggerStatus, String jobDesc,
|
|
|
+ String executorHandler, String author) {
|
|
|
|
|
|
// page list
|
|
|
- List<XxlJobInfo> list = xxlJobInfoDao.pageList(start, length, jobGroup, triggerStatus, jobDesc, executorHandler, author);
|
|
|
- int list_count = xxlJobInfoDao.pageListCount(start, length, jobGroup, triggerStatus, jobDesc, executorHandler, author);
|
|
|
+ List<XxlJobInfo> list = xxlJobInfoDao.pageList(start, length, jobGroup, triggerStatus, jobDesc, executorHandler,
|
|
|
+ author);
|
|
|
+ int list_count = xxlJobInfoDao.pageListCount(start, length, jobGroup, triggerStatus, jobDesc, executorHandler,
|
|
|
+ author);
|
|
|
|
|
|
// package result
|
|
|
Map<String, Object> maps = new HashMap<String, Object>();
|
|
|
- maps.put("recordsTotal", list_count); // 总记录数
|
|
|
- maps.put("recordsFiltered", list_count); // 过滤后的总记录数
|
|
|
- maps.put("data", list); // 分页列表
|
|
|
+ maps.put("recordsTotal", list_count); // 总记录数
|
|
|
+ maps.put("recordsFiltered", list_count); // 过滤后的总记录数
|
|
|
+ maps.put("data", list); // 分页列表
|
|
|
return maps;
|
|
|
}
|
|
|
|
|
|
@@ -66,43 +69,51 @@ public class XxlJobServiceImpl implements XxlJobService {
|
|
|
// valid base
|
|
|
XxlJobGroup group = xxlJobGroupDao.load(jobInfo.getJobGroup());
|
|
|
if (group == null) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("system_please_choose") + I18nUtil.getString("jobinfo_field_jobgroup")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("system_please_choose") + I18nUtil.getString("jobinfo_field_jobgroup")));
|
|
|
}
|
|
|
if (jobInfo.getJobDesc() == null || jobInfo.getJobDesc().trim().length() == 0) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("system_please_input") + I18nUtil.getString("jobinfo_field_jobdesc")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("system_please_input") + I18nUtil.getString("jobinfo_field_jobdesc")));
|
|
|
}
|
|
|
if (jobInfo.getAuthor() == null || jobInfo.getAuthor().trim().length() == 0) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("system_please_input") + I18nUtil.getString("jobinfo_field_author")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("system_please_input") + I18nUtil.getString("jobinfo_field_author")));
|
|
|
}
|
|
|
|
|
|
// valid trigger
|
|
|
ScheduleTypeEnum scheduleTypeEnum = ScheduleTypeEnum.match(jobInfo.getScheduleType(), null);
|
|
|
if (scheduleTypeEnum == null) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
if (scheduleTypeEnum == ScheduleTypeEnum.CRON) {
|
|
|
if (jobInfo.getScheduleConf() == null || !CronExpression.isValidExpression(jobInfo.getScheduleConf())) {
|
|
|
return new ReturnT<String>(ReturnT.FAIL_CODE, "Cron" + I18nUtil.getString("system_unvalid"));
|
|
|
}
|
|
|
- } else if (scheduleTypeEnum == ScheduleTypeEnum.FIX_RATE/* || scheduleTypeEnum == ScheduleTypeEnum.FIX_DELAY*/) {
|
|
|
+ } else if (scheduleTypeEnum == ScheduleTypeEnum.FIX_RATE/* || scheduleTypeEnum == ScheduleTypeEnum.FIX_DELAY */) {
|
|
|
if (jobInfo.getScheduleConf() == null) {
|
|
|
return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type")));
|
|
|
}
|
|
|
try {
|
|
|
int fixSecond = Integer.valueOf(jobInfo.getScheduleConf());
|
|
|
if (fixSecond < 1) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
}
|
|
|
|
|
|
// valid job
|
|
|
if (GlueTypeEnum.match(jobInfo.getGlueType()) == null) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("jobinfo_field_gluetype") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("jobinfo_field_gluetype") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
- if (GlueTypeEnum.BEAN == GlueTypeEnum.match(jobInfo.getGlueType()) && (jobInfo.getExecutorHandler() == null || jobInfo.getExecutorHandler().trim().length() == 0)) {
|
|
|
+ if (GlueTypeEnum.BEAN == GlueTypeEnum.match(jobInfo.getGlueType())
|
|
|
+ && (jobInfo.getExecutorHandler() == null || jobInfo.getExecutorHandler().trim().length() == 0)) {
|
|
|
return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("system_please_input") + "JobHandler"));
|
|
|
}
|
|
|
// 》fix "\r" in shell
|
|
|
@@ -112,13 +123,16 @@ public class XxlJobServiceImpl implements XxlJobService {
|
|
|
|
|
|
// valid advanced
|
|
|
if (ExecutorRouteStrategyEnum.match(jobInfo.getExecutorRouteStrategy(), null) == null) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("jobinfo_field_executorRouteStrategy") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("jobinfo_field_executorRouteStrategy") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
if (MisfireStrategyEnum.match(jobInfo.getMisfireStrategy(), null) == null) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("misfire_strategy") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("misfire_strategy") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
if (ExecutorBlockStrategyEnum.match(jobInfo.getExecutorBlockStrategy(), null) == null) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("jobinfo_field_executorBlockStrategy") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("jobinfo_field_executorBlockStrategy") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
|
|
|
// 》ChildJobId valid
|
|
|
@@ -129,11 +143,13 @@ public class XxlJobServiceImpl implements XxlJobService {
|
|
|
XxlJobInfo childJobInfo = xxlJobInfoDao.loadById(Integer.parseInt(childJobIdItem));
|
|
|
if (childJobInfo == null) {
|
|
|
return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
- MessageFormat.format((I18nUtil.getString("jobinfo_field_childJobId") + "({0})" + I18nUtil.getString("system_not_found")), childJobIdItem));
|
|
|
+ MessageFormat.format((I18nUtil.getString("jobinfo_field_childJobId") + "({0})"
|
|
|
+ + I18nUtil.getString("system_not_found")), childJobIdItem));
|
|
|
}
|
|
|
} else {
|
|
|
return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
- MessageFormat.format((I18nUtil.getString("jobinfo_field_childJobId") + "({0})" + I18nUtil.getString("system_unvalid")), childJobIdItem));
|
|
|
+ MessageFormat.format((I18nUtil.getString("jobinfo_field_childJobId") + "({0})"
|
|
|
+ + I18nUtil.getString("system_unvalid")), childJobIdItem));
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -153,7 +169,8 @@ public class XxlJobServiceImpl implements XxlJobService {
|
|
|
jobInfo.setGlueUpdatetime(new Date());
|
|
|
xxlJobInfoDao.save(jobInfo);
|
|
|
if (jobInfo.getId() < 1) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("jobinfo_field_add") + I18nUtil.getString("system_fail")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("jobinfo_field_add") + I18nUtil.getString("system_fail")));
|
|
|
}
|
|
|
|
|
|
return new ReturnT<String>(String.valueOf(jobInfo.getId()));
|
|
|
@@ -161,6 +178,7 @@ public class XxlJobServiceImpl implements XxlJobService {
|
|
|
|
|
|
private boolean isNumeric(String str) {
|
|
|
try {
|
|
|
+ @SuppressWarnings("unused")
|
|
|
int result = Integer.valueOf(str);
|
|
|
return true;
|
|
|
} catch (NumberFormatException e) {
|
|
|
@@ -173,44 +191,53 @@ public class XxlJobServiceImpl implements XxlJobService {
|
|
|
|
|
|
// valid base
|
|
|
if (jobInfo.getJobDesc() == null || jobInfo.getJobDesc().trim().length() == 0) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("system_please_input") + I18nUtil.getString("jobinfo_field_jobdesc")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("system_please_input") + I18nUtil.getString("jobinfo_field_jobdesc")));
|
|
|
}
|
|
|
if (jobInfo.getAuthor() == null || jobInfo.getAuthor().trim().length() == 0) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("system_please_input") + I18nUtil.getString("jobinfo_field_author")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("system_please_input") + I18nUtil.getString("jobinfo_field_author")));
|
|
|
}
|
|
|
|
|
|
// valid trigger
|
|
|
ScheduleTypeEnum scheduleTypeEnum = ScheduleTypeEnum.match(jobInfo.getScheduleType(), null);
|
|
|
if (scheduleTypeEnum == null) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
if (scheduleTypeEnum == ScheduleTypeEnum.CRON) {
|
|
|
if (jobInfo.getScheduleConf() == null || !CronExpression.isValidExpression(jobInfo.getScheduleConf())) {
|
|
|
return new ReturnT<String>(ReturnT.FAIL_CODE, "Cron" + I18nUtil.getString("system_unvalid"));
|
|
|
}
|
|
|
- } else if (scheduleTypeEnum == ScheduleTypeEnum.FIX_RATE /*|| scheduleTypeEnum == ScheduleTypeEnum.FIX_DELAY*/) {
|
|
|
+ } else if (scheduleTypeEnum == ScheduleTypeEnum.FIX_RATE /* || scheduleTypeEnum == ScheduleTypeEnum.FIX_DELAY */) {
|
|
|
if (jobInfo.getScheduleConf() == null) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
try {
|
|
|
int fixSecond = Integer.valueOf(jobInfo.getScheduleConf());
|
|
|
if (fixSecond < 1) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
}
|
|
|
|
|
|
// valid advanced
|
|
|
if (ExecutorRouteStrategyEnum.match(jobInfo.getExecutorRouteStrategy(), null) == null) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("jobinfo_field_executorRouteStrategy") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("jobinfo_field_executorRouteStrategy") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
if (MisfireStrategyEnum.match(jobInfo.getMisfireStrategy(), null) == null) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("misfire_strategy") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("misfire_strategy") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
if (ExecutorBlockStrategyEnum.match(jobInfo.getExecutorBlockStrategy(), null) == null) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("jobinfo_field_executorBlockStrategy") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("jobinfo_field_executorBlockStrategy") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
|
|
|
// 》ChildJobId valid
|
|
|
@@ -221,11 +248,13 @@ public class XxlJobServiceImpl implements XxlJobService {
|
|
|
XxlJobInfo childJobInfo = xxlJobInfoDao.loadById(Integer.parseInt(childJobIdItem));
|
|
|
if (childJobInfo == null) {
|
|
|
return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
- MessageFormat.format((I18nUtil.getString("jobinfo_field_childJobId") + "({0})" + I18nUtil.getString("system_not_found")), childJobIdItem));
|
|
|
+ MessageFormat.format((I18nUtil.getString("jobinfo_field_childJobId") + "({0})"
|
|
|
+ + I18nUtil.getString("system_not_found")), childJobIdItem));
|
|
|
}
|
|
|
} else {
|
|
|
return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
- MessageFormat.format((I18nUtil.getString("jobinfo_field_childJobId") + "({0})" + I18nUtil.getString("system_unvalid")), childJobIdItem));
|
|
|
+ MessageFormat.format((I18nUtil.getString("jobinfo_field_childJobId") + "({0})"
|
|
|
+ + I18nUtil.getString("system_unvalid")), childJobIdItem));
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -242,28 +271,34 @@ public class XxlJobServiceImpl implements XxlJobService {
|
|
|
// group valid
|
|
|
XxlJobGroup jobGroup = xxlJobGroupDao.load(jobInfo.getJobGroup());
|
|
|
if (jobGroup == null) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("jobinfo_field_jobgroup") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("jobinfo_field_jobgroup") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
|
|
|
// stage job info
|
|
|
XxlJobInfo exists_jobInfo = xxlJobInfoDao.loadById(jobInfo.getId());
|
|
|
if (exists_jobInfo == null) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("jobinfo_field_id") + I18nUtil.getString("system_not_found")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("jobinfo_field_id") + I18nUtil.getString("system_not_found")));
|
|
|
}
|
|
|
|
|
|
// next trigger time (5s后生效,避开预读周期)
|
|
|
long nextTriggerTime = exists_jobInfo.getTriggerNextTime();
|
|
|
- boolean scheduleDataNotChanged = jobInfo.getScheduleType().equals(exists_jobInfo.getScheduleType()) && jobInfo.getScheduleConf().equals(exists_jobInfo.getScheduleConf());
|
|
|
+ boolean scheduleDataNotChanged = jobInfo.getScheduleType().equals(exists_jobInfo.getScheduleType())
|
|
|
+ && jobInfo.getScheduleConf().equals(exists_jobInfo.getScheduleConf());
|
|
|
if (exists_jobInfo.getTriggerStatus() == 1 && !scheduleDataNotChanged) {
|
|
|
try {
|
|
|
- Date nextValidTime = JobScheduleHelper.generateNextValidTime(jobInfo, new Date(System.currentTimeMillis() + JobScheduleHelper.PRE_READ_MS));
|
|
|
+ Date nextValidTime = JobScheduleHelper.generateNextValidTime(jobInfo,
|
|
|
+ new Date(System.currentTimeMillis() + JobScheduleHelper.PRE_READ_MS));
|
|
|
if (nextValidTime == null) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
nextTriggerTime = nextValidTime.getTime();
|
|
|
} catch (Exception e) {
|
|
|
logger.error(e.getMessage(), e);
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -286,7 +321,6 @@ public class XxlJobServiceImpl implements XxlJobService {
|
|
|
exists_jobInfo.setUpdateTime(new Date());
|
|
|
xxlJobInfoDao.update(exists_jobInfo);
|
|
|
|
|
|
-
|
|
|
return ReturnT.SUCCESS;
|
|
|
}
|
|
|
|
|
|
@@ -316,14 +350,17 @@ public class XxlJobServiceImpl implements XxlJobService {
|
|
|
// next trigger time (5s后生效,避开预读周期)
|
|
|
long nextTriggerTime = 0;
|
|
|
try {
|
|
|
- Date nextValidTime = JobScheduleHelper.generateNextValidTime(xxlJobInfo, new Date(System.currentTimeMillis() + JobScheduleHelper.PRE_READ_MS));
|
|
|
+ Date nextValidTime = JobScheduleHelper.generateNextValidTime(xxlJobInfo,
|
|
|
+ new Date(System.currentTimeMillis() + JobScheduleHelper.PRE_READ_MS));
|
|
|
if (nextValidTime == null) {
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
nextTriggerTime = nextValidTime.getTime();
|
|
|
} catch (Exception e) {
|
|
|
logger.error(e.getMessage(), e);
|
|
|
- return new ReturnT<String>(ReturnT.FAIL_CODE, (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
+ return new ReturnT<String>(ReturnT.FAIL_CODE,
|
|
|
+ (I18nUtil.getString("schedule_type") + I18nUtil.getString("system_unvalid")));
|
|
|
}
|
|
|
|
|
|
xxlJobInfo.setTriggerStatus(1);
|
|
|
@@ -348,7 +385,6 @@ public class XxlJobServiceImpl implements XxlJobService {
|
|
|
return ReturnT.SUCCESS;
|
|
|
}
|
|
|
|
|
|
-
|
|
|
@Override
|
|
|
public ReturnT<String> trigger(XxlJobUser loginUser, int jobId, String executorParam, String addressList) {
|
|
|
// permission
|
|
|
@@ -391,7 +427,8 @@ public class XxlJobServiceImpl implements XxlJobService {
|
|
|
int jobLogSuccessCount = 0;
|
|
|
XxlJobLogReport xxlJobLogReport = xxlJobLogReportDao.queryLogReportTotal();
|
|
|
if (xxlJobLogReport != null) {
|
|
|
- jobLogCount = xxlJobLogReport.getRunningCount() + xxlJobLogReport.getSucCount() + xxlJobLogReport.getFailCount();
|
|
|
+ jobLogCount = xxlJobLogReport.getRunningCount() + xxlJobLogReport.getSucCount()
|
|
|
+ + xxlJobLogReport.getFailCount();
|
|
|
jobLogSuccessCount = xxlJobLogReport.getSucCount();
|
|
|
}
|
|
|
|