|
@@ -344,9 +344,8 @@ public class CronJobServiceImpl extends BaseEntityService implements CronJobServ
|
|
public boolean executeCronJob(Long id, User user) throws NotFoundException, UnAuthorizedException, ServerException {
|
|
public boolean executeCronJob(Long id, User user) throws NotFoundException, UnAuthorizedException, ServerException {
|
|
|
|
|
|
CronJob cronJob = getCronJob(id);
|
|
CronJob cronJob = getCronJob(id);
|
|
- System.out.println("执行任务....." + cronJob.getName());
|
|
|
|
-// checkWritePermission(entity, cronJob.getProjectId(), user, "execute");
|
|
|
|
- System.out.println("执行任务.....正在执行!" + cronJob.getName());
|
|
|
|
|
|
+ log.info("执行任务....." + cronJob.getName());
|
|
|
|
+ checkWritePermission(entity, cronJob.getProjectId(), user, "execute");
|
|
ExecutorService executorService = ExecutorUtils.getJobWorkers();
|
|
ExecutorService executorService = ExecutorUtils.getJobWorkers();
|
|
ExecutorUtils.printThreadPoolStatus(executorService, "JOB_WORKERS", scheduleLogger);
|
|
ExecutorUtils.printThreadPoolStatus(executorService, "JOB_WORKERS", scheduleLogger);
|
|
executorService.submit(() -> {
|
|
executorService.submit(() -> {
|
|
@@ -376,7 +375,7 @@ public class CronJobServiceImpl extends BaseEntityService implements CronJobServ
|
|
QualityTask qualityTask = qualityTaskService.getQualityTaskByCronJobId(cronJob.getId());
|
|
QualityTask qualityTask = qualityTaskService.getQualityTaskByCronJobId(cronJob.getId());
|
|
if (null != qualityTask) {
|
|
if (null != qualityTask) {
|
|
qualityTaskService.auditor(qualityTask.getId());
|
|
qualityTaskService.auditor(qualityTask.getId());
|
|
- System.out.println("execute quality auditor");
|
|
|
|
|
|
+ log.info("execute quality auditor");
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|