删除信息接口改造,支持指定人删除
This commit is contained in:
@ -171,10 +171,16 @@ public class BizMessageProducerServiceImpl implements BizMessageProducerService
|
|||||||
List<String> magIds = messageList.stream().map(BizMessage::getId).distinct().collect(Collectors.toList());
|
List<String> magIds = messageList.stream().map(BizMessage::getId).distinct().collect(Collectors.toList());
|
||||||
Map<String,Integer> map = new HashMap<>();
|
Map<String,Integer> map = new HashMap<>();
|
||||||
if(magIds!=null&&magIds.size()>0) {
|
if(magIds!=null&&magIds.size()>0) {
|
||||||
List<String> userIds = new ArrayList<>();
|
|
||||||
userIds.add(userId);
|
List<String> userIds = null;
|
||||||
|
if(userId!=null){
|
||||||
|
userIds = new ArrayList<>();
|
||||||
|
userIds.add(userId);
|
||||||
|
}
|
||||||
|
|
||||||
|
List<String> finalUserIds = userIds;
|
||||||
magIds.forEach(magid->{
|
magIds.forEach(magid->{
|
||||||
messageMapper.deleteAuthorizeByServicecdoe(magid,userIds);
|
messageMapper.deleteAuthorizeByServicecdoe(magid, finalUserIds);
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
return true;
|
return true;
|
||||||
|
Reference in New Issue
Block a user