增加日志
This commit is contained in:
parent
cd086b5529
commit
f19a65ba74
@ -263,14 +263,14 @@ public class AssessManagerController extends AbstractController{
|
|||||||
|
|
||||||
|
|
||||||
|
|
||||||
log.info("查询到有权限可以推送的人员数量为{}", staffIds.size());
|
log.info("查询到有权限可以推送的人员数量为{}, 如下{}", staffIds.size(), staffIds);
|
||||||
//下面查询当前startId,当前flowProcess下面有多少人员id
|
//下面查询当前startId,当前flowProcess下面有多少人员id
|
||||||
List<ResultRecord> resultRecords = resultRecordMapper.selectStaffIdsByStartIdAndFlowProcess(startId, flowProcess);
|
List<ResultRecord> resultRecords = resultRecordMapper.selectStaffIdsByStartIdAndFlowProcess(startId, flowProcess);
|
||||||
Map<Long, ResultRecord> mapReords =
|
Map<Long, ResultRecord> mapReords =
|
||||||
resultRecords.stream().collect(Collectors.toMap(ResultRecord::getStaffId, Function.identity(), (e, r) -> e));
|
resultRecords.stream().collect(Collectors.toMap(ResultRecord::getStaffId, Function.identity(), (e, r) -> e));
|
||||||
|
|
||||||
List<Long> staffIds1 = mapReords.keySet().stream().collect(Collectors.toList());
|
List<Long> staffIds1 = mapReords.keySet().stream().collect(Collectors.toList());
|
||||||
log.info("查询到在当前节点下的人数为{}", staffIds1.size());
|
log.info("查询到在当前节点下的人数为{},如下{}", staffIds1.size(), staffIds1);
|
||||||
if(staffIds1.size() > 0 && staffIds.size() > 0){
|
if(staffIds1.size() > 0 && staffIds.size() > 0){
|
||||||
staffIds.retainAll(staffIds1);//求交集
|
staffIds.retainAll(staffIds1);//求交集
|
||||||
log.info("最终能推送人员个数{}", staffIds.size());
|
log.info("最终能推送人员个数{}", staffIds.size());
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user