|
@@ -55,6 +55,7 @@ import java.util.Map;
|
|
|
import java.util.Objects;
|
|
|
import java.util.Optional;
|
|
|
import java.util.Random;
|
|
|
+import java.util.function.Function;
|
|
|
import java.util.stream.Collectors;
|
|
|
import java.util.stream.IntStream;
|
|
|
|
|
@@ -160,16 +161,23 @@ public class CustomerServiceBatchSendingServiceImpl extends ServiceImpl<Customer
|
|
|
Map<Long, String> usernameMap = sysUsers.stream()
|
|
|
.collect(Collectors.toMap(SysUser::getId, SysUser::getUsername, (o, n) -> n));
|
|
|
|
|
|
- Map<Long, String> mobileMap = sysUsers.stream()
|
|
|
- .collect(Collectors.toMap(SysUser::getId, SysUser::getPhone, (o, n) -> n));
|
|
|
+ Map<Long, SysUser> senderMap = sysUsers.stream()
|
|
|
+ .collect(Collectors.toMap(SysUser::getId, Function.identity(), (o, n) -> n));
|
|
|
|
|
|
// 发送群体,发送声部
|
|
|
+ SysUser sysUser;
|
|
|
for (CustomerServiceBatchSendingWrapper.CustomerServiceBatchSending item : sendings) {
|
|
|
|
|
|
// 创建用户
|
|
|
- item.sender(mobileMap.getOrDefault(item.getSenderId(), ""))
|
|
|
+ item.sender("").mobile("")
|
|
|
.setCreateUser(usernameMap.getOrDefault(item.getCreateBy(), ""));
|
|
|
|
|
|
+ if (senderMap.containsKey(item.getSenderId())) {
|
|
|
+ sysUser = senderMap.get(item.getSenderId());
|
|
|
+
|
|
|
+ item.sender(sysUser.getUsername()).mobile(sysUser.getPhone());
|
|
|
+ }
|
|
|
+
|
|
|
List<Long> collect = Arrays.stream(Optional.ofNullable(item.getSendSubject()).orElse("").split(","))
|
|
|
.map(Long::parseLong).distinct().collect(Collectors.toList());
|
|
|
|