|
@@ -46,12 +46,6 @@ public class AsyncChatSopService {
|
|
|
List<QwSopTemp> tempList = qwSopTempMapper.selectListByIds(PubFun.listToNewList(ruleTimeVOList, ChatSopRuleTimeVO::getTempId));
|
|
|
Map<String, QwSopTemp> tempMap = PubFun.listToMapByGroupObject(tempList, QwSopTemp::getId);
|
|
|
ruleTimeVOList = ruleTimeVOList.stream().filter(e -> tempMap.containsKey(e.getTempId())).collect(Collectors.toList());
|
|
|
- List<String> updateIdList = ruleTimeVOList.stream().filter(e -> "0".equals(tempMap.get(e.getTempId()).getStatus())).map(ChatSopRuleTimeVO::getId).collect(Collectors.toList());
|
|
|
- if(!updateIdList.isEmpty()){
|
|
|
- QwSop qwSop = new QwSop();
|
|
|
- qwSop.setStatus(0L);
|
|
|
- qwSopMapper.update(qwSop, new QueryWrapper<QwSop>().in("id", updateIdList));
|
|
|
- }
|
|
|
List<QwUserVO> qwUserVOList = qwUserService.selectQwUserVOByIds(ruleTimeVOList.stream().flatMap(e -> Arrays.stream(e.getQwUserIds().split(",")).map(Long::parseLong)).toArray(Long[]::new));
|
|
|
Map<String, QwUserVO> qwUserMap = PubFun.listToMapByGroupObject(qwUserVOList, QwUserVO::getQwUserId);
|
|
|
List<QwGroupChat> qwGroupChatList = qwGroupChatService.selectQwGroupChatByChatIds(ruleTimeVOList.stream().flatMap(e -> Arrays.stream(e.getChatId().split(","))).toArray(String[]::new));
|