|  | @@ -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());
 | 
	
		
			
				|  |  |  
 |