修改增加58注册

src/main/java/cn/quantgroup/xyqb/service/jr58/impl/Jr58ServiceImpl.java

@@ -6,6 +6,7 @@ import cn.quantgroup.xyqb.entity.UserDetail;
 import cn.quantgroup.xyqb.entity.UserJr58;
 import cn.quantgroup.xyqb.model.IdCardInfo;
 import cn.quantgroup.xyqb.model.IdType;
+import cn.quantgroup.xyqb.model.UserStatistics;
 import cn.quantgroup.xyqb.model.jr58.Jr58Authorization;
 import cn.quantgroup.xyqb.model.jr58.Jr58RegisterParam;
 import cn.quantgroup.xyqb.model.jr58.Jr58RegisterResult;
@@ -17,6 +18,7 @@ import cn.quantgroup.xyqb.service.http.IHttpService;
 import cn.quantgroup.xyqb.service.jr58.Jr58Service;
 import cn.quantgroup.xyqb.service.user.ILkbUserService;
 import cn.quantgroup.xyqb.util.GZipUtil;
+import cn.quantgroup.xyqb.util.MqUtils;
 import com.alibaba.fastjson.JSONObject;
 import com.google.common.collect.ImmutableMap;
 import org.apache.commons.lang3.StringUtils;
@@ -106,7 +108,9 @@ public class Jr58ServiceImpl implements Jr58Service {
 
     LOGGER.info("Save UserJr58:{}", user.getId());
     this.saveUserJr58(param, user.getId());
-
+    //增加登陆统计发送
+    UserStatistics statistics=new UserStatistics(user,null,2,user.getRegisteredFrom());
+    MqUtils.sendLoanVest(statistics);
     LOGGER.info("用户注册成功, registerFrom:{}, phoneNo:{}", Constants.Channel.JR58, param.getPhone());
     return uuid;
   }