|
|
@@ -274,8 +274,6 @@ public class WxTaskService {
|
|
|
List<CompanyWxClient> resArr = new ArrayList<>();
|
|
|
//找到任务指定的微信用户
|
|
|
List<CompanyVoiceRoboticWx> companyVoiceRoboticWxes = companyVoiceRoboticWxMapper.selectByRoboticIdWithGroupBy(robotic.getId());
|
|
|
- List<CompanyWxAccount> accountIds = companyWxAccountMapper.selectBatchIds(PubFun.listToNewList(companyVoiceRoboticWxes, CompanyVoiceRoboticWx::getAccountId));
|
|
|
- Map<Long, CompanyWxAccount> accountMap = PubFun.listToMapByGroupObject(accountIds, CompanyWxAccount::getId);
|
|
|
Integer totalSize = 0;
|
|
|
if (null != companyVoiceRoboticWxes && !companyVoiceRoboticWxes.isEmpty()) {
|
|
|
totalSize = companyVoiceRoboticWxes.size();
|
|
|
@@ -283,6 +281,8 @@ public class WxTaskService {
|
|
|
log.error("分配对象空,数据异常");
|
|
|
throw new RuntimeException("没有找到任务指定的微信用户");
|
|
|
}
|
|
|
+ List<CompanyWxAccount> accountIds = companyWxAccountMapper.selectBatchIds(PubFun.listToNewList(companyVoiceRoboticWxes, CompanyVoiceRoboticWx::getAccountId));
|
|
|
+ Map<Long, CompanyWxAccount> accountMap = PubFun.listToMapByGroupObject(accountIds, CompanyWxAccount::getId);
|
|
|
List<CompanyWxClient> companyWxClients = companyWxClientMapper.selectListByRoboticId(robotic.getId());
|
|
|
List<Long> ids = PubFun.listToNewList(companyWxClients, CompanyWxClient::getCustomerId);
|
|
|
List<CrmCustomer> crmCustomerList = crmCustomerService.selectCrmCustomerListByIds(ids.stream().map(e -> e + "").collect(Collectors.joining(",")));
|