增加ka的mq统计

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

@@ -24,6 +24,7 @@ import cn.quantgroup.xyqb.model.UserExtInfoRet;
 import cn.quantgroup.xyqb.model.UserInfo;
 import cn.quantgroup.xyqb.model.UserRet;
 import cn.quantgroup.xyqb.model.UserSpouseRet;
+import cn.quantgroup.xyqb.model.UserStatistics;
 import cn.quantgroup.xyqb.model.XContactInfo;
 import cn.quantgroup.xyqb.service.auth.IIdCardService;
 import cn.quantgroup.xyqb.service.http.IHttpService;
@@ -36,6 +37,7 @@ import cn.quantgroup.xyqb.service.user.IUserExtInfoService;
 import cn.quantgroup.xyqb.service.user.IUserService;
 import cn.quantgroup.xyqb.service.user.IUserSpouseService;
 import cn.quantgroup.xyqb.service.wechat.IWechatService;
+import cn.quantgroup.xyqb.util.MqUtils;
 import cn.quantgroup.xyqb.util.ValidationUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
@@ -242,6 +244,8 @@ public class InnerController implements IBaseController {
     user = userService.saveUser(user);
     UserRet userRet = null;
     if (user != null) {
+      UserStatistics statistics=new UserStatistics(user,null,2,user.getRegisteredFrom());
+      MqUtils.sendLoanVest(statistics);
       userRet = new UserRet(user);
     }
     return JsonResult.buildSuccessResult(null, userRet);