|
@@ -149,6 +149,9 @@ public class BizDeptServiceImpl implements IBizDeptService {
|
|
|
if (docIds.stream().anyMatch(Objects::isNull)) {
|
|
if (docIds.stream().anyMatch(Objects::isNull)) {
|
|
|
throw new ServiceException(TRExcCode.SYSTEM_ERROR_B0001, "文档ID列表中包含空值");
|
|
throw new ServiceException(TRExcCode.SYSTEM_ERROR_B0001, "文档ID列表中包含空值");
|
|
|
}
|
|
}
|
|
|
|
|
+ //先删除全量数据
|
|
|
|
|
+ bizDocDeptService.remove(new LambdaQueryWrapper<BizDocDeptPO>().eq(BizDocDeptPO::getDeptId, deptId));
|
|
|
|
|
+ //再插入
|
|
|
List<BizDocDeptPO> bizDocDeptPOS = docIds.stream().map(docId->{
|
|
List<BizDocDeptPO> bizDocDeptPOS = docIds.stream().map(docId->{
|
|
|
BizDocDeptPO bizDocDeptPO = new BizDocDeptPO();
|
|
BizDocDeptPO bizDocDeptPO = new BizDocDeptPO();
|
|
|
bizDocDeptPO.setDocId(docId);
|
|
bizDocDeptPO.setDocId(docId);
|
|
@@ -157,10 +160,9 @@ public class BizDeptServiceImpl implements IBizDeptService {
|
|
|
}).collect(Collectors.toList());
|
|
}).collect(Collectors.toList());
|
|
|
bizDocDeptService.saveOrUpdateBatch(bizDocDeptPOS);
|
|
bizDocDeptService.saveOrUpdateBatch(bizDocDeptPOS);
|
|
|
//修改 宣教文档关联个数
|
|
//修改 宣教文档关联个数
|
|
|
- Integer count = Optional.ofNullable(bizDeptPO.getMissionDocCount()).orElse(0);
|
|
|
|
|
- return baseRepository.update(null,
|
|
|
|
|
|
|
+ return baseRepository.update(null,
|
|
|
new LambdaUpdateWrapper<BizDeptPO>()
|
|
new LambdaUpdateWrapper<BizDeptPO>()
|
|
|
- .set(BizDeptPO::getMissionDocCount, count + bizDocDeptPOS.size())
|
|
|
|
|
|
|
+ .set(BizDeptPO::getMissionDocCount, bizDocDeptPOS.size())
|
|
|
.eq(BizDeptPO::getId, deptId)) != 0;
|
|
.eq(BizDeptPO::getId, deptId)) != 0;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -185,6 +187,9 @@ public class BizDeptServiceImpl implements IBizDeptService {
|
|
|
if (questionGroupIds.stream().anyMatch(Objects::isNull)) {
|
|
if (questionGroupIds.stream().anyMatch(Objects::isNull)) {
|
|
|
throw new ServiceException(TRExcCode.SYSTEM_ERROR_B0001, "问卷组ID列表中包含空值");
|
|
throw new ServiceException(TRExcCode.SYSTEM_ERROR_B0001, "问卷组ID列表中包含空值");
|
|
|
}
|
|
}
|
|
|
|
|
+ //先删除全量数据
|
|
|
|
|
+ bizQuestionDeptService.remove(new LambdaQueryWrapper<BizQuestionDeptPO>().eq(BizQuestionDeptPO::getDeptId, deptId));
|
|
|
|
|
+ //再插入
|
|
|
List<BizQuestionDeptPO> collect = questionGroupIds.stream().map(questionGroupId -> {
|
|
List<BizQuestionDeptPO> collect = questionGroupIds.stream().map(questionGroupId -> {
|
|
|
BizQuestionDeptPO bizQuestionDeptPO = new BizQuestionDeptPO();
|
|
BizQuestionDeptPO bizQuestionDeptPO = new BizQuestionDeptPO();
|
|
|
bizQuestionDeptPO.setDeptId(deptId);
|
|
bizQuestionDeptPO.setDeptId(deptId);
|
|
@@ -192,11 +197,9 @@ public class BizDeptServiceImpl implements IBizDeptService {
|
|
|
return bizQuestionDeptPO;
|
|
return bizQuestionDeptPO;
|
|
|
}).collect(Collectors.toList());
|
|
}).collect(Collectors.toList());
|
|
|
bizQuestionDeptService.saveOrUpdateBatch(collect);
|
|
bizQuestionDeptService.saveOrUpdateBatch(collect);
|
|
|
-
|
|
|
|
|
- Integer count = Optional.ofNullable(bizDeptPO.getQuestionCount()).orElse(0);
|
|
|
|
|
return baseRepository.update(null,
|
|
return baseRepository.update(null,
|
|
|
new LambdaUpdateWrapper<BizDeptPO>()
|
|
new LambdaUpdateWrapper<BizDeptPO>()
|
|
|
- .set(BizDeptPO::getQuestionCount,count + collect.size())
|
|
|
|
|
|
|
+ .set(BizDeptPO::getQuestionCount, collect.size())
|
|
|
.eq(BizDeptPO::getId, deptId)) != 0;
|
|
.eq(BizDeptPO::getId, deptId)) != 0;
|
|
|
}
|
|
}
|
|
|
|
|
|