增加判断

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

@@ -108,7 +108,7 @@ public class AppController implements IBaseController {
     bean.setPhoneNo(phoneNo);
     LOGGER.info("第三方用户登录成功, loginFrom:{}, phoneNo:{},appChannel:{}", registerFrom, phoneNo, appChannel);
     //增加登陆统计发送
-    UserStatistics statistics=new UserStatistics(user,null,4);
+    UserStatistics statistics=new UserStatistics(user,null,4,channelId);
     MqUtils.sendLoanVest(statistics);
     return new JsonResult(bean);
   }
@@ -163,7 +163,7 @@ public class AppController implements IBaseController {
 
     LOGGER.info("第三方用户获取信息登录成功, loginFrom:{}, phoneNo:{},appChannel:{}", registerFrom, phoneNo, appChannel);
     //增加登陆统计发送
-    UserStatistics statistics=new UserStatistics(user,null,4);
+    UserStatistics statistics=new UserStatistics(user,null,4,channelId);
     MqUtils.sendLoanVest(statistics);
     return JsonResult.buildSuccessResult("", loginInfo);
 
@@ -250,7 +250,7 @@ public class AppController implements IBaseController {
       }
     }
     //增加登陆统计发送
-    UserStatistics statistics=new UserStatistics(user,null,4);
+    UserStatistics statistics=new UserStatistics(user,null,4,channelId);
     MqUtils.sendLoanVest(statistics);
     return user;
   }

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

@@ -119,7 +119,7 @@ public class UserController implements IBaseController {
       }
     }
     //增加登陆统计发送
-    UserStatistics statistics=new UserStatistics(user,null,3);
+    UserStatistics statistics=new UserStatistics(user,null,3,channelId);
     MqUtils.sendLoanVest(statistics);
     return new JsonResult(sessionService.createSession(channelId, createdFrom, appChannel, user, merchant));
     // return createSession(channelId, createdFrom, appChannel, user);
@@ -452,7 +452,7 @@ public class UserController implements IBaseController {
     //用户信息存在,更新session中的最后访问时间,重新写入缓存.
     if (null != user || !user.getEnable()) {
       //增加登陆统计发送
-      UserStatistics statistics=new UserStatistics(user,dimension,1);
+      UserStatistics statistics=new UserStatistics(user,dimension,1,channelId);
       MqUtils.sendLoanVest(statistics);
       return new JsonResult(sessionService.createSession(channelId, createdFrom, appChannel, user, merchant));
     } else {

src/main/java/cn/quantgroup/xyqb/model/UserStatistics.java

@@ -13,15 +13,17 @@ public class UserStatistics {
   private Long registerFrom;
   private String dimension;
   private int action;//登录0，注册1，快捷登录2，免密登录3
+  private Long channel;
 
   public UserStatistics() {
 
   }
 
-  public UserStatistics(User user, String dimension, int action) {
+  public UserStatistics(User user, String dimension, int action,Long channel) {
     this.uuid = user.getUuid();
     this.registerFrom = user.getRegisteredFrom();
     this.action = action;
     this.dimension = dimension;
+    this.channel=channel;
   }
 }

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

@@ -185,7 +185,7 @@ public class UserServiceImpl implements IUserService {
 
     if(registerSuccess){
       //增加登陆统计发送
-      UserStatistics statistics=new UserStatistics(user,null,3);
+      UserStatistics statistics=new UserStatistics(user,null,3,channelId);
       MqUtils.sendLoanVest(statistics);
     }