瀏覽代碼

消息通知

zouxuan 1 年之前
父節點
當前提交
53df3d172a
共有 1 個文件被更改,包括 7 次插入2 次删除
  1. 7 2
      mec-biz/src/main/java/com/ym/mec/biz/service/impl/SysMessageServiceImpl.java

+ 7 - 2
mec-biz/src/main/java/com/ym/mec/biz/service/impl/SysMessageServiceImpl.java

@@ -566,7 +566,12 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
 			messageParam.setType(type.getCode());
 			messageParam.setType(type.getCode());
 			messageParam.setUrl(url);
 			messageParam.setUrl(url);
 			Map<Long, String> params = new HashMap<>();
 			Map<Long, String> params = new HashMap<>();
-			params.put(userId, Optional.ofNullable(receive.getValue()).orElse(user.getPhone()));
+			if(messageSender == MessageSender.EMAIL){
+				//如果是极光推送,没有用户ID的情况下,使用手机号
+				params.put(userId, Optional.ofNullable(receive.getValue()).orElse(user.getPhone()));
+			}else {
+				params.put(userId, Optional.ofNullable(user.getPhone()).orElse(receive.getValue()));
+			}
 			messageParam.setReceivers(params);
 			messageParam.setReceivers(params);
 			messageParam.setRealSend(!debugMode);
 			messageParam.setRealSend(!debugMode);
 			if(args != null && args.length > 0){
 			if(args != null && args.length > 0){
@@ -633,7 +638,7 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
 			CbsMessageWrapper.MessageParam messageParam = new CbsMessageWrapper.MessageParam();
 			CbsMessageWrapper.MessageParam messageParam = new CbsMessageWrapper.MessageParam();
 			messageParam.setUserId(user.getUserId().longValue());
 			messageParam.setUserId(user.getUserId().longValue());
 			messageParam.setAppKey(EAppKey.GYM);
 			messageParam.setAppKey(EAppKey.GYM);
-			messageParam.setClientType(EClientType.STUDENT);
+			messageParam.setClientType(EClientType.valueOf(jpushType));
 			messageParam.setClientId(messageParam.getClientType());
 			messageParam.setClientId(messageParam.getClientType());
 			messageParam.setType(type.getCode());
 			messageParam.setType(type.getCode());
 			messageParam.setUrl(url);
 			messageParam.setUrl(url);