|
@@ -87,13 +87,13 @@ public class DmsCheckTaskServiceImpl implements DmsCheckTaskService {
|
|
|
public Map<String, Object> tasks() {
|
|
|
// User user = this.userMapper.selectById(Convert.toLong(StpUtil.getLoginId()));
|
|
|
Long userId = SecurityFrameworkUtils.getLoginUserId();
|
|
|
- LocalDateTime now = LocalDateTime.now();
|
|
|
+ LocalDateTime now = LocalDateTime.now();
|
|
|
Long total = this.checkTaskMapper.selectCount(new LambdaQueryWrapper<DmsCheckTaskDO>()
|
|
|
- .eq(DmsCheckTaskDO::getExecutorId,userId).le(DmsCheckTaskDO::getStartTime,now)
|
|
|
+ .eq(DmsCheckTaskDO::getExecutorId, userId).le(DmsCheckTaskDO::getStartTime, now)
|
|
|
.eq(DmsCheckTaskDO::getUseFlag, 1));
|
|
|
Long end = this.checkTaskMapper.selectCount(new LambdaQueryWrapper<DmsCheckTaskDO>()
|
|
|
- .eq(DmsCheckTaskDO::getExecutorId,userId).le(DmsCheckTaskDO::getStartTime,now)
|
|
|
- .eq(DmsCheckTaskDO::getUseFlag, 1).eq(DmsCheckTaskDO::getEndFlag,1));
|
|
|
+ .eq(DmsCheckTaskDO::getExecutorId, userId).le(DmsCheckTaskDO::getStartTime, now)
|
|
|
+ .eq(DmsCheckTaskDO::getUseFlag, 1).eq(DmsCheckTaskDO::getEndFlag, 1));
|
|
|
|
|
|
List<DmsCheckTaskDO> checkTasks = this.checkTaskMapper.selectList(new LambdaQueryWrapper<DmsCheckTaskDO>()
|
|
|
.eq(DmsCheckTaskDO::getExecutorId, userId).eq(DmsCheckTaskDO::getUseFlag, 1)
|
|
@@ -113,36 +113,41 @@ public class DmsCheckTaskServiceImpl implements DmsCheckTaskService {
|
|
|
map.put("endTasks", endList);
|
|
|
return map;
|
|
|
}
|
|
|
+
|
|
|
@Override
|
|
|
public String tmpSave(DmsCheckTaskDO checkTask) {
|
|
|
LocalDateTime now = LocalDateTime.now();
|
|
|
- this.checkTaskMapper.update(null, new LambdaUpdateWrapper<DmsCheckTaskDO>().set(DmsCheckTaskDO::getNote,checkTask.getNote())
|
|
|
- .set(DmsCheckTaskDO::getUpdateTime,now).set(DmsCheckTaskDO::getStatus,2).
|
|
|
- eq(DmsCheckTaskDO::getId,checkTask.getId()));
|
|
|
+ this.checkTaskMapper.update(null, new LambdaUpdateWrapper<DmsCheckTaskDO>().set(DmsCheckTaskDO::getNote, checkTask.getNote())
|
|
|
+ .set(DmsCheckTaskDO::getUpdateTime, now).set(DmsCheckTaskDO::getStatus, 2).
|
|
|
+ eq(DmsCheckTaskDO::getId, checkTask.getId()));
|
|
|
|
|
|
Map<Long, DmsCheckTaskItemDO> itemMap = checkTask.getCheckTaskItems().stream().collect(Collectors.toMap(item -> item.getId(), item -> item));
|
|
|
List<DmsCheckTaskItemDO> taskItems = this.checkTaskItemMapper.selectList(new LambdaQueryWrapper<DmsCheckTaskItemDO>()
|
|
|
.eq(DmsCheckTaskItemDO::getCheckTaskId, checkTask.getId()).eq(DmsCheckTaskItemDO::getUseFlag, 1));
|
|
|
- taskItems.stream().forEach(item->{item.setContent(itemMap.get(item.getId()).getContent())
|
|
|
- .setImgs(itemMap.get(item.getId()).getImgs()).setUpdateTime(now);});
|
|
|
+ taskItems.stream().forEach(item -> {
|
|
|
+ item.setContent(itemMap.get(item.getId()).getContent())
|
|
|
+ .setImgs(itemMap.get(item.getId()).getImgs()).setUpdateTime(now);
|
|
|
+ });
|
|
|
this.checkTaskItemMapper.updateBatch(taskItems);
|
|
|
- return"任务暂存成功!";
|
|
|
+ return "任务暂存成功!";
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public String commit(DmsCheckTaskDO checkTask) {
|
|
|
LocalDateTime now = LocalDateTime.now();
|
|
|
- this.checkTaskMapper.update(null, new LambdaUpdateWrapper<DmsCheckTaskDO>().set(DmsCheckTaskDO::getNote,checkTask.getNote())
|
|
|
- .set(DmsCheckTaskDO::getStatus,3)
|
|
|
- .set(DmsCheckTaskDO::getExecutorTime,now).set(DmsCheckTaskDO::getUpdateTime,now)
|
|
|
- .set(DmsCheckTaskDO::getEndFlag,1).eq(DmsCheckTaskDO::getId,checkTask.getId()));
|
|
|
+ this.checkTaskMapper.update(null, new LambdaUpdateWrapper<DmsCheckTaskDO>().set(DmsCheckTaskDO::getNote, checkTask.getNote())
|
|
|
+ .set(DmsCheckTaskDO::getStatus, 3)
|
|
|
+ .set(DmsCheckTaskDO::getExecutorTime, now).set(DmsCheckTaskDO::getUpdateTime, now)
|
|
|
+ .set(DmsCheckTaskDO::getEndFlag, 1).eq(DmsCheckTaskDO::getId, checkTask.getId()));
|
|
|
|
|
|
Map<Long, DmsCheckTaskItemDO> itemMap = checkTask.getCheckTaskItems().stream().collect(Collectors.toMap(item -> item.getId(), item -> item));
|
|
|
LambdaQueryWrapper<DmsCheckTaskItemDO> eq = new LambdaQueryWrapper<DmsCheckTaskItemDO>().eq(DmsCheckTaskItemDO::getUseFlag, 1)
|
|
|
.eq(DmsCheckTaskItemDO::getCheckTaskId, checkTask.getId());
|
|
|
List<DmsCheckTaskItemDO> taskItems = this.checkTaskItemMapper.selectList(eq);
|
|
|
- taskItems.stream().forEach(item->{item.setContent(itemMap.get(item.getId()).getContent())
|
|
|
- .setImgs(itemMap.get(item.getId()).getImgs()).setUpdateTime(now);});
|
|
|
+ taskItems.stream().forEach(item -> {
|
|
|
+ item.setContent(itemMap.get(item.getId()).getContent())
|
|
|
+ .setImgs(itemMap.get(item.getId()).getImgs()).setUpdateTime(now);
|
|
|
+ });
|
|
|
this.checkTaskItemMapper.updateBatch(taskItems);
|
|
|
|
|
|
return "任务暂存成功!";
|
|
@@ -153,7 +158,7 @@ public class DmsCheckTaskServiceImpl implements DmsCheckTaskService {
|
|
|
|
|
|
LambdaQueryWrapper<DmsCheckTaskDO> wrapper = new LambdaQueryWrapper<DmsCheckTaskDO>()
|
|
|
.eq(DmsCheckTaskDO::getEndFlag, 0);
|
|
|
- if(Objects.nonNull(checkTask.getExecutorId())){
|
|
|
+ if (Objects.nonNull(checkTask.getExecutorId())) {
|
|
|
wrapper.eq(DmsCheckTaskDO::getExecutorId, checkTask.getExecutorId());
|
|
|
}
|
|
|
return this.checkTaskMapper.selectCount(wrapper);
|