|
@@ -92,7 +92,6 @@ public class CheckJobServiceImpl extends BaseServiceImpl<CheckJobMapper, CheckJo
|
|
List<Integer> statusList = new ArrayList<Integer>();
|
|
List<Integer> statusList = new ArrayList<Integer>();
|
|
statusList.add(CheckJobStatusEnum.NOT_EXECUTE.getValue());
|
|
statusList.add(CheckJobStatusEnum.NOT_EXECUTE.getValue());
|
|
statusList.add(CheckJobStatusEnum.EXECUTING.getValue());
|
|
statusList.add(CheckJobStatusEnum.EXECUTING.getValue());
|
|
- statusList.add(CheckJobStatusEnum.OUT_OF_DATE.getValue());
|
|
|
|
record.setStatusList(statusList);
|
|
record.setStatusList(statusList);
|
|
return mapper.getNotFinishNumByDTO(record);
|
|
return mapper.getNotFinishNumByDTO(record);
|
|
}
|
|
}
|
|
@@ -172,7 +171,6 @@ public class CheckJobServiceImpl extends BaseServiceImpl<CheckJobMapper, CheckJo
|
|
List<Integer> statusList = new ArrayList<Integer>();
|
|
List<Integer> statusList = new ArrayList<Integer>();
|
|
statusList.add(CheckJobStatusEnum.NOT_EXECUTE.getValue());
|
|
statusList.add(CheckJobStatusEnum.NOT_EXECUTE.getValue());
|
|
statusList.add(CheckJobStatusEnum.EXECUTING.getValue());
|
|
statusList.add(CheckJobStatusEnum.EXECUTING.getValue());
|
|
- statusList.add(CheckJobStatusEnum.OUT_OF_DATE.getValue());
|
|
|
|
model.setStatusList(statusList);
|
|
model.setStatusList(statusList);
|
|
List<CheckJobVO> voList = mapper.selectList(model);
|
|
List<CheckJobVO> voList = mapper.selectList(model);
|
|
|
|
|
|
@@ -356,7 +354,7 @@ public class CheckJobServiceImpl extends BaseServiceImpl<CheckJobMapper, CheckJo
|
|
relation.setLastGenerateTime(standard.getLastGenerateTime());
|
|
relation.setLastGenerateTime(standard.getLastGenerateTime());
|
|
relation.setLastNum(standard.getLastNum() == null ? 0 : standard.getLastNum());
|
|
relation.setLastNum(standard.getLastNum() == null ? 0 : standard.getLastNum());
|
|
projectStandardRelationList.add(relation);
|
|
projectStandardRelationList.add(relation);
|
|
-
|
|
|
|
|
|
+ checkJob.setReceiveOvertime(false);
|
|
checkJob.setPlanId(projectPlan.getPlanId());
|
|
checkJob.setPlanId(projectPlan.getPlanId());
|
|
checkJob.setStatus(CheckJobStatusEnum.NOT_EXECUTE.getValue());
|
|
checkJob.setStatus(CheckJobStatusEnum.NOT_EXECUTE.getValue());
|
|
// 计算计划开始时间和结束时间
|
|
// 计算计划开始时间和结束时间
|
|
@@ -458,6 +456,9 @@ public class CheckJobServiceImpl extends BaseServiceImpl<CheckJobMapper, CheckJo
|
|
if(sbInfo == null){
|
|
if(sbInfo == null){
|
|
continue;
|
|
continue;
|
|
}
|
|
}
|
|
|
|
+ if(!sbInfo.getStatus().equals(SbInfoStatusEnum.IN_USE.getValue())){
|
|
|
|
+ continue;
|
|
|
|
+ }
|
|
if(standard.getCheckUserType() == null){
|
|
if(standard.getCheckUserType() == null){
|
|
if(standard.getPeriodType()< CheckPlanPeriodTypeEnum.WEEK.getValue()){
|
|
if(standard.getPeriodType()< CheckPlanPeriodTypeEnum.WEEK.getValue()){
|
|
checkJob.setCheckUserId(sbInfo.getSaveUser());
|
|
checkJob.setCheckUserId(sbInfo.getSaveUser());
|
|
@@ -619,6 +620,10 @@ public class CheckJobServiceImpl extends BaseServiceImpl<CheckJobMapper, CheckJo
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
+ /**
|
|
|
|
+ * 如果当前时间大于了任务的期限,则判断过期
|
|
|
|
+ *
|
|
|
|
+ */
|
|
@Override
|
|
@Override
|
|
public void checkJobStatus() {
|
|
public void checkJobStatus() {
|
|
// 1.查询状态为未执行和执行中的任务
|
|
// 1.查询状态为未执行和执行中的任务
|
|
@@ -626,15 +631,22 @@ public class CheckJobServiceImpl extends BaseServiceImpl<CheckJobMapper, CheckJo
|
|
Integer[] status = {1, 2};
|
|
Integer[] status = {1, 2};
|
|
weekend.weekendCriteria().andIn(CheckJob::getStatus, Arrays.asList(status));
|
|
weekend.weekendCriteria().andIn(CheckJob::getStatus, Arrays.asList(status));
|
|
List<CheckJob> checkJobs = mapper.selectByExample(weekend);
|
|
List<CheckJob> checkJobs = mapper.selectByExample(weekend);
|
|
|
|
+ List<CheckJob> updateJobs = new ArrayList<>();
|
|
// 2.判断当前时间是否大于结束时间是则设置状态未已过期
|
|
// 2.判断当前时间是否大于结束时间是则设置状态未已过期
|
|
LocalDate now = LocalDate.now();
|
|
LocalDate now = LocalDate.now();
|
|
checkJobs.forEach(job -> {
|
|
checkJobs.forEach(job -> {
|
|
LocalDate endTime = job.getEndTime();
|
|
LocalDate endTime = job.getEndTime();
|
|
if (now.isAfter(endTime)) {
|
|
if (now.isAfter(endTime)) {
|
|
- job.setStatus(CheckJobStatusEnum.OUT_OF_DATE.getValue());
|
|
|
|
- mapper.updateByPrimaryKeySelective(job);
|
|
|
|
|
|
+ CheckJob updateJob = new CheckJob();
|
|
|
|
+ updateJob.setId(job.getId());
|
|
|
|
+ updateJob.setReceiveOvertime(true);
|
|
|
|
+ updateJobs.add(updateJob);
|
|
}
|
|
}
|
|
});
|
|
});
|
|
|
|
+
|
|
|
|
+ if(CollectionUtil.isNotEmpty(updateJobs)){
|
|
|
|
+ mapper.updateBatch(updateJobs);
|
|
|
|
+ }
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -887,7 +899,7 @@ public class CheckJobServiceImpl extends BaseServiceImpl<CheckJobMapper, CheckJo
|
|
@Override
|
|
@Override
|
|
public void executeJob(Object id) {
|
|
public void executeJob(Object id) {
|
|
CheckJob checkJob = mapper.selectByPrimaryKey(id);
|
|
CheckJob checkJob = mapper.selectByPrimaryKey(id);
|
|
- if(!CheckJobStatusEnum.NOT_EXECUTE.getValue().equals(checkJob.getStatus()) && !CheckJobStatusEnum.OUT_OF_DATE.getValue().equals(checkJob.getStatus())){
|
|
|
|
|
|
+ if(!CheckJobStatusEnum.NOT_EXECUTE.getValue().equals(checkJob.getStatus())){
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
checkJob.setStatus(CheckJobStatusEnum.EXECUTING.getValue());
|
|
checkJob.setStatus(CheckJobStatusEnum.EXECUTING.getValue());
|
|
@@ -960,7 +972,6 @@ public class CheckJobServiceImpl extends BaseServiceImpl<CheckJobMapper, CheckJo
|
|
List<Integer> statusList = new ArrayList<Integer>();
|
|
List<Integer> statusList = new ArrayList<Integer>();
|
|
statusList.add(CheckJobStatusEnum.NOT_EXECUTE.getValue());
|
|
statusList.add(CheckJobStatusEnum.NOT_EXECUTE.getValue());
|
|
statusList.add(CheckJobStatusEnum.EXECUTING.getValue());
|
|
statusList.add(CheckJobStatusEnum.EXECUTING.getValue());
|
|
- statusList.add(CheckJobStatusEnum.OUT_OF_DATE.getValue());
|
|
|
|
Weekend<CheckJob> weekend = new Weekend<>(CheckJob.class);
|
|
Weekend<CheckJob> weekend = new Weekend<>(CheckJob.class);
|
|
WeekendCriteria<CheckJob, Object> weekendCriteria = weekend.weekendCriteria();
|
|
WeekendCriteria<CheckJob, Object> weekendCriteria = weekend.weekendCriteria();
|
|
weekendCriteria.andEqualTo(CheckJob::getStandardId, checkJob.getStandardId()).andIn(CheckJob::getStatus, statusList);
|
|
weekendCriteria.andEqualTo(CheckJob::getStandardId, checkJob.getStandardId()).andIn(CheckJob::getStatus, statusList);
|
|
@@ -977,6 +988,7 @@ public class CheckJobServiceImpl extends BaseServiceImpl<CheckJobMapper, CheckJo
|
|
calcNextJobTime(nextCheckJob, checkJob.getActualEndTime(), checkStandard);
|
|
calcNextJobTime(nextCheckJob, checkJob.getActualEndTime(), checkStandard);
|
|
nextCheckJob.setCreatedTime(LocalDateTime.now());
|
|
nextCheckJob.setCreatedTime(LocalDateTime.now());
|
|
nextCheckJob.setSbId(checkStandard.getSbId());
|
|
nextCheckJob.setSbId(checkStandard.getSbId());
|
|
|
|
+ nextCheckJob.setReceiveOvertime(false);
|
|
nextCheckJob.setCheckUserId(checkJob.getCheckUserId());
|
|
nextCheckJob.setCheckUserId(checkJob.getCheckUserId());
|
|
nextCheckJob.setPartId(checkStandard.getPart());
|
|
nextCheckJob.setPartId(checkStandard.getPart());
|
|
nextCheckJob.setStandardId(checkStandard.getId());
|
|
nextCheckJob.setStandardId(checkStandard.getId());
|
|
@@ -1057,7 +1069,6 @@ public class CheckJobServiceImpl extends BaseServiceImpl<CheckJobMapper, CheckJo
|
|
List<Integer> statusList = new ArrayList<Integer>();
|
|
List<Integer> statusList = new ArrayList<Integer>();
|
|
statusList.add(CheckJobStatusEnum.NOT_EXECUTE.getValue());
|
|
statusList.add(CheckJobStatusEnum.NOT_EXECUTE.getValue());
|
|
statusList.add(CheckJobStatusEnum.EXECUTING.getValue());
|
|
statusList.add(CheckJobStatusEnum.EXECUTING.getValue());
|
|
- statusList.add(CheckJobStatusEnum.OUT_OF_DATE.getValue());
|
|
|
|
Weekend<CheckJob> weekend = new Weekend<>(CheckJob.class);
|
|
Weekend<CheckJob> weekend = new Weekend<>(CheckJob.class);
|
|
WeekendCriteria<CheckJob, Object> weekendCriteria = weekend.weekendCriteria();
|
|
WeekendCriteria<CheckJob, Object> weekendCriteria = weekend.weekendCriteria();
|
|
weekendCriteria.andEqualTo(CheckJob::getStandardId, checkJob.getStandardId()).andIn(CheckJob::getStatus, statusList);
|
|
weekendCriteria.andEqualTo(CheckJob::getStandardId, checkJob.getStandardId()).andIn(CheckJob::getStatus, statusList);
|
|
@@ -1164,7 +1175,7 @@ public class CheckJobServiceImpl extends BaseServiceImpl<CheckJobMapper, CheckJo
|
|
weekendCriteria.andEqualTo(CheckJob::getType, type);
|
|
weekendCriteria.andEqualTo(CheckJob::getType, type);
|
|
|
|
|
|
List<Integer> statusList = ListUtils.newArrayList(CheckJobStatusEnum.NOT_EXECUTE.getValue(),
|
|
List<Integer> statusList = ListUtils.newArrayList(CheckJobStatusEnum.NOT_EXECUTE.getValue(),
|
|
- CheckJobStatusEnum.EXECUTING.getValue(), CheckJobStatusEnum.OUT_OF_DATE.getValue());
|
|
|
|
|
|
+ CheckJobStatusEnum.EXECUTING.getValue());
|
|
weekendCriteria.andIn(CheckJob::getStatus, statusList);
|
|
weekendCriteria.andIn(CheckJob::getStatus, statusList);
|
|
return mapper.selectCountByExample(weekend);
|
|
return mapper.selectCountByExample(weekend);
|
|
}
|
|
}
|
|
@@ -1195,7 +1206,7 @@ public class CheckJobServiceImpl extends BaseServiceImpl<CheckJobMapper, CheckJo
|
|
weekendCriteria.andEqualTo(CheckJob::getType, type);
|
|
weekendCriteria.andEqualTo(CheckJob::getType, type);
|
|
|
|
|
|
List<Integer> statusList = ListUtils.newArrayList(CheckJobStatusEnum.NOT_EXECUTE.getValue(),
|
|
List<Integer> statusList = ListUtils.newArrayList(CheckJobStatusEnum.NOT_EXECUTE.getValue(),
|
|
- CheckJobStatusEnum.EXECUTING.getValue(), CheckJobStatusEnum.OUT_OF_DATE.getValue());
|
|
|
|
|
|
+ CheckJobStatusEnum.EXECUTING.getValue());
|
|
weekendCriteria.andIn(CheckJob::getStatus, statusList);
|
|
weekendCriteria.andIn(CheckJob::getStatus, statusList);
|
|
return mapper.selectCountByExample(weekend);
|
|
return mapper.selectCountByExample(weekend);
|
|
}
|
|
}
|