소스 검색

fix:短信推送

liujunchi 3 년 전
부모
커밋
4aa289482d
1개의 변경된 파일11개의 추가작업 그리고 2개의 파일을 삭제
  1. 11 2
      cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/SysMessageServiceImpl.java

+ 11 - 2
cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/SysMessageServiceImpl.java

@@ -212,8 +212,17 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
 			return;
 		}
 
-		String[] tos = new String[receivers.size()];
-		tos = receivers.entrySet().stream().map(longStringEntry -> String.valueOf(longStringEntry.getKey())).collect(Collectors.toList()).toArray(tos);
+		String[] tos;
+		if(messageSender.getSendMode().equals(MessageSender.JIGUANG.getSendMode())) {
+			tos= new String[receivers.size()];
+			tos = receivers.entrySet()
+						   .stream()
+						   .map(longStringEntry -> String.valueOf(longStringEntry.getKey()))
+						   .collect(Collectors.toList())
+						   .toArray(tos);
+		} else {
+			tos = receivers.values().toArray(new String[receivers.size()]);
+		}
 		SysMessageConfig messageConfig = sysMessageConfigService.queryByType(type.getCode());
 		if (messageConfig == null) {
 			throw new BizException("消息类型错误");