|
@@ -66,11 +66,27 @@ public class TaskFilesServiceImpl extends ServiceImpl<TaskFilesMapper, TaskFiles
|
|
|
.eq(TaskFiles::getFinalChargeStatus,0)
|
|
|
.eq(TaskFiles::getNeedFileCharge,1)
|
|
|
.in(TaskFiles::getId,ids));
|
|
|
+ List<TaskFiles> multiChargeList = taskFilesList.stream().filter(t -> {
|
|
|
+ if (t.getChargeOneId().equals(t.getChargeTwoId())) {
|
|
|
+ return false;
|
|
|
+ } else {
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+ }).collect(Collectors.toList());
|
|
|
+ List<TaskFiles> singleChargeList = taskFilesList.stream().filter(t -> {
|
|
|
+ if (t.getChargeOneId().equals(t.getChargeTwoId())) {
|
|
|
+ return true;
|
|
|
+ } else {
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ }).collect(Collectors.toList());
|
|
|
+
|
|
|
//通过
|
|
|
List<Integer> stageOneToUpdateList = new ArrayList<>();
|
|
|
List<Integer> stageTwoToUpdateList = new ArrayList<>();
|
|
|
+ //审核人一、二如果是同一个,则通过直接结束,驳回返回阶段一
|
|
|
List<TaskComment> commentList = new ArrayList<>();
|
|
|
- for (TaskFiles taskFiles : taskFilesList) {
|
|
|
+ for (TaskFiles taskFiles : multiChargeList) {
|
|
|
//判断所处阶段
|
|
|
if(1 == taskFiles.getChargeStage()){
|
|
|
stageOneToUpdateList.add(taskFiles.getId());
|
|
@@ -87,6 +103,17 @@ public class TaskFilesServiceImpl extends ServiceImpl<TaskFilesMapper, TaskFiles
|
|
|
comment.setUserName(user.getName());
|
|
|
commentList.add(comment);
|
|
|
}
|
|
|
+ for (TaskFiles taskFiles : singleChargeList) {
|
|
|
+ String content = user.getName()+"审核通过了任务文件【"+taskFiles.getDocumentName()+"】";
|
|
|
+ TaskComment comment = new TaskComment();
|
|
|
+ comment.setTaskId(taskFiles.getTaskId());
|
|
|
+ comment.setUserId(user.getId());
|
|
|
+ comment.setContent(content);
|
|
|
+ comment.setCreateTime(LocalDateTime.now());
|
|
|
+ comment.setUserColor(user.getColor());
|
|
|
+ comment.setUserName(user.getName());
|
|
|
+ commentList.add(comment);
|
|
|
+ }
|
|
|
if(CollectionUtils.isNotEmpty(stageOneToUpdateList)){
|
|
|
taskFilesMapper.update(null,new LambdaUpdateWrapper<TaskFiles>()
|
|
|
.set(TaskFiles::getChargeStage,2)
|
|
@@ -106,6 +133,19 @@ public class TaskFilesServiceImpl extends ServiceImpl<TaskFilesMapper, TaskFiles
|
|
|
.in(TaskFiles::getId,stageTwoToUpdateList)
|
|
|
);
|
|
|
}
|
|
|
+ if(CollectionUtils.isNotEmpty(singleChargeList)){
|
|
|
+ List<Integer> collect = singleChargeList.stream().map(TaskFiles::getId).collect(Collectors.toList());
|
|
|
+ taskFilesMapper.update(null,new LambdaUpdateWrapper<TaskFiles>()
|
|
|
+ .set(TaskFiles::getChargeStage,3)
|
|
|
+ .set(TaskFiles::getFinalChargeStatus,1)
|
|
|
+ .set(TaskFiles::getChargeOneStatus,1)
|
|
|
+ .set(TaskFiles::getChargeTwoStatus,1)
|
|
|
+ .set(TaskFiles::getChargeOneTime,new Date())
|
|
|
+ .set(TaskFiles::getChargeTwoTime,new Date())
|
|
|
+ .set(TaskFiles::getFileRejectReason,null)
|
|
|
+ .in(TaskFiles::getId,collect)
|
|
|
+ );
|
|
|
+ }
|
|
|
if(CollectionUtils.isNotEmpty(commentList)){
|
|
|
taskCommentMapper.insertBatch(commentList);
|
|
|
}
|
|
@@ -132,12 +172,26 @@ public class TaskFilesServiceImpl extends ServiceImpl<TaskFilesMapper, TaskFiles
|
|
|
.eq(TaskFiles::getFinalChargeStatus,0)
|
|
|
.in(TaskFiles::getId,ids)
|
|
|
);
|
|
|
+ List<TaskFiles> multiChargeList = taskFiles.stream().filter(t -> {
|
|
|
+ if (t.getChargeOneId().equals(t.getChargeTwoId())) {
|
|
|
+ return false;
|
|
|
+ } else {
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+ }).collect(Collectors.toList());
|
|
|
+ List<TaskFiles> singleChargeList = taskFiles.stream().filter(t -> {
|
|
|
+ if (t.getChargeOneId().equals(t.getChargeTwoId())) {
|
|
|
+ return true;
|
|
|
+ } else {
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ }).collect(Collectors.toList());
|
|
|
List<Integer> stageOneToUpdateList = new ArrayList<>();
|
|
|
List<Integer> stageTwoToUpdateList = new ArrayList<>();
|
|
|
// StringBuilder userNames = new StringBuilder();
|
|
|
Map<String,String> remindMap = new HashMap<>();
|
|
|
List<TaskComment> commentList = new ArrayList<>();
|
|
|
- for (TaskFiles taskFile : taskFiles) {
|
|
|
+ for (TaskFiles taskFile : multiChargeList) {
|
|
|
if(1 == taskFile.getChargeStage()){
|
|
|
//阶段一,更新阶段一状态
|
|
|
stageOneToUpdateList.add(taskFile.getId());
|
|
@@ -152,6 +206,13 @@ public class TaskFilesServiceImpl extends ServiceImpl<TaskFilesMapper, TaskFiles
|
|
|
// }else{
|
|
|
// userNames.append(tmpUser.getName()).append(",");
|
|
|
// }
|
|
|
+ if(remindMap.containsKey(tmpUser.getCorpwxUserid())){
|
|
|
+ String s = remindMap.get(tmpUser.getCorpwxUserid());
|
|
|
+ s += "任务文件【"+taskFile.getDocumentName()+"】因【"+reason+"】被驳回,请及时处理";
|
|
|
+ remindMap.put(tmpUser.getCorpwxUserid(),s);
|
|
|
+ }else{
|
|
|
+ remindMap.put(tmpUser.getCorpwxUserid(),"任务文件【"+taskFile.getDocumentName()+"】因【"+reason+"】被驳回,请及时处理");
|
|
|
+ }
|
|
|
remindMap.put(tmpUser.getCorpwxUserid(),"任务文件【"+taskFile.getDocumentName()+"】因【"+reason+"】被驳回,请及时处理");
|
|
|
String content = user.getName()+"审核驳回了任务文件【"+taskFile.getDocumentName()+"】";
|
|
|
TaskComment comment = new TaskComment();
|
|
@@ -163,6 +224,26 @@ public class TaskFilesServiceImpl extends ServiceImpl<TaskFilesMapper, TaskFiles
|
|
|
comment.setUserName(user.getName());
|
|
|
commentList.add(comment);
|
|
|
}
|
|
|
+ for (TaskFiles taskFile : singleChargeList) {
|
|
|
+ User tmpUser = companyUserMap.get(taskFile.getCreatorId());
|
|
|
+ if(remindMap.containsKey(tmpUser.getCorpwxUserid())){
|
|
|
+ String s = remindMap.get(tmpUser.getCorpwxUserid());
|
|
|
+ s += "任务文件【"+taskFile.getDocumentName()+"】因【"+reason+"】被驳回,请及时处理";
|
|
|
+ remindMap.put(tmpUser.getCorpwxUserid(),s);
|
|
|
+ }else{
|
|
|
+ remindMap.put(tmpUser.getCorpwxUserid(),"任务文件【"+taskFile.getDocumentName()+"】因【"+reason+"】被驳回,请及时处理");
|
|
|
+ }
|
|
|
+
|
|
|
+ String content = user.getName()+"审核驳回了任务文件【"+taskFile.getDocumentName()+"】";
|
|
|
+ TaskComment comment = new TaskComment();
|
|
|
+ comment.setTaskId(taskFile.getTaskId());
|
|
|
+ comment.setUserId(user.getId());
|
|
|
+ comment.setContent(content);
|
|
|
+ comment.setCreateTime(LocalDateTime.now());
|
|
|
+ comment.setUserColor(user.getColor());
|
|
|
+ comment.setUserName(user.getName());
|
|
|
+ commentList.add(comment);
|
|
|
+ }
|
|
|
if(CollectionUtils.isNotEmpty(stageOneToUpdateList)){
|
|
|
//阶段一,更新阶段一状态
|
|
|
taskFilesMapper.update(null,new LambdaUpdateWrapper<TaskFiles>()
|
|
@@ -180,6 +261,17 @@ public class TaskFilesServiceImpl extends ServiceImpl<TaskFilesMapper, TaskFiles
|
|
|
.in(TaskFiles::getId,stageTwoToUpdateList)
|
|
|
);
|
|
|
}
|
|
|
+ if(CollectionUtils.isNotEmpty(singleChargeList)){
|
|
|
+ List<Integer> collect = singleChargeList.stream().map(TaskFiles::getId).collect(Collectors.toList());
|
|
|
+ taskFilesMapper.update(null,new LambdaUpdateWrapper<TaskFiles>()
|
|
|
+ .set(TaskFiles::getFileRejectReason,reason)
|
|
|
+ .set(TaskFiles::getChargeOneTime,new Date())
|
|
|
+ .set(TaskFiles::getChargeTwoTime,new Date())
|
|
|
+ .set(TaskFiles::getChargeOneStatus,2)
|
|
|
+ .set(TaskFiles::getChargeStage,1)
|
|
|
+ .in(TaskFiles::getId,collect)
|
|
|
+ );
|
|
|
+ }
|
|
|
|
|
|
if(CollectionUtils.isNotEmpty(commentList)){
|
|
|
taskCommentMapper.insertBatch(commentList);
|