修复demension丢失

src/main/java/cn/quantgroup/xyqb/controller/external/user/AppController.java

@@ -282,7 +282,7 @@ public class AppController implements IBaseController {
         LOGGER.error("保存 UserDetail 出现异常", e);
       }
     }
-    MqUtils.sendRegisterMessage(channelId,user);
+    MqUtils.sendRegisterMessage(channelId,null,user);
     return user;
   }
 

src/main/java/cn/quantgroup/xyqb/controller/external/user/InnerController.java

@@ -228,7 +228,7 @@ public class InnerController implements IBaseController {
     user = userService.saveUser(user);
     UserRet userRet = null;
     if (user != null) {
-      userRet = MqUtils.sendRegisterMessage(registeredFrom, user);
+      userRet = MqUtils.sendRegisterMessage(registeredFrom, null,user);
     }
     return JsonResult.buildSuccessResult(null, userRet);
   }

src/main/java/cn/quantgroup/xyqb/controller/internal/user/UserController.java

@@ -162,7 +162,7 @@ public class UserController implements IBaseController {
     }
     User user=userService.registerAndReturn(phoneNo, password, registerFrom,btRegisterChannelId);
     LOGGER.info("用户快速注册成功, registerFrom:{}, phoneNo:{}", registerFrom, phoneNo);
-     MqUtils.sendRegisterMessage(channelId, user);
+     MqUtils.sendRegisterMessage(channelId,dimension, user);
     return user;
   }
 

src/main/java/cn/quantgroup/xyqb/service/user/impl/UserServiceImpl.java

@@ -192,7 +192,7 @@ public class UserServiceImpl implements IUserService {
       smsService.sendAfterRegister(phoneNo);
     }
     if(registerSuccess){
-      MqUtils.sendRegisterMessage(channelId, user);
+      MqUtils.sendRegisterMessage(channelId,dimension, user);
     }
     return user != null;
   }

src/main/java/cn/quantgroup/xyqb/util/MqUtils.java

@@ -40,9 +40,9 @@ public class MqUtils {
     }
   }
 
-  public static UserRet sendRegisterMessage(Long registeredFrom, User user) {
+  public static UserRet sendRegisterMessage(Long registeredFrom,String demension, User user) {
     UserRet userRet;
-    UserStatistics statistics=new UserStatistics(user,null,2,registeredFrom);
+    UserStatistics statistics=new UserStatistics(user,demension,2,registeredFrom);
     MqUtils.sendLoanVest(statistics);
     userRet = new UserRet(user);
     //增加用户注册广播