|
@@ -150,8 +150,8 @@ public class WxTaskService {
|
|
|
if(!addList.isEmpty()){
|
|
if(!addList.isEmpty()){
|
|
|
companyWxClientService.updateBatchById(addList);
|
|
companyWxClientService.updateBatchById(addList);
|
|
|
//根据加微成功的用户,判定是否加入延时执行下一步任务
|
|
//根据加微成功的用户,判定是否加入延时执行下一步任务
|
|
|
- Set<Long> roboticIdSet = addList.stream().map(e -> e.getRoboticId()).collect(Collectors.toSet());
|
|
|
|
|
- Set<Long> userIdSet = addList.stream().map(e -> e.getCustomerId()).collect(Collectors.toSet());
|
|
|
|
|
|
|
+ Set<Long> roboticIdSet = addList.stream().map(CompanyWxClient::getRoboticId).collect(Collectors.toSet());
|
|
|
|
|
+ Set<Long> userIdSet = addList.stream().map(CompanyWxClient::getCustomerId).collect(Collectors.toSet());
|
|
|
|
|
|
|
|
//找到任务
|
|
//找到任务
|
|
|
List<CompanyVoiceRobotic> companyVoiceRobotics = companyVoiceRoboticMapper.selectBatchIds(roboticIdSet);
|
|
List<CompanyVoiceRobotic> companyVoiceRobotics = companyVoiceRoboticMapper.selectBatchIds(roboticIdSet);
|