删除新登陆统计（kafka，已弃用）

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

 package cn.quantgroup.xyqb.controller.external.user;
 
-import cn.quantgroup.acolyte.buddhistscriptures.pojo.Login;
 import cn.quantgroup.tech.db.DSType;
 import cn.quantgroup.tech.db.TargetDataSource;
 import cn.quantgroup.user.enums.Relation;
@@ -9,7 +8,6 @@ import cn.quantgroup.xyqb.aspect.accessable.IpValidator;
 import cn.quantgroup.xyqb.controller.IBaseController;
 import cn.quantgroup.xyqb.entity.*;
 import cn.quantgroup.xyqb.entity.enumerate.*;
-import cn.quantgroup.xyqb.event.StatisticsEvent;
 import cn.quantgroup.xyqb.exception.UserNotExistException;
 import cn.quantgroup.xyqb.model.*;
 import cn.quantgroup.xyqb.service.api.IUserApiService;
@@ -42,8 +40,6 @@ import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.util.CollectionUtils;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
-import org.springframework.web.context.request.RequestContextHolder;
-import org.springframework.web.context.request.ServletRequestAttributes;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
@@ -1226,10 +1222,6 @@ public class InnerController implements IBaseController {
         // 推送老的登陆统计信息
         UserStatistics statistics = new UserStatistics(user, dimension, 3, channelId);
         MqUtils.sendLoanVest(statistics);
-        // 发布新的登录统计信息事件
-        HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
-        Login login = new Login(user.getId(), createdFrom, channelId, IPUtil.getRemoteIP(request), 3, System.currentTimeMillis());
-        applicationEventPublisher.publishEvent(new StatisticsEvent(this, login));
         return JsonResult.buildSuccessResult("校验成功", new UserRet(user));
     }
 

src/main/java/cn/quantgroup/xyqb/event/MQRegisteredEventListener.java

 package cn.quantgroup.xyqb.event;
 
-import cn.quantgroup.acolyte.buddhistscriptures.ingester.UserIngest;
-import cn.quantgroup.acolyte.buddhistscriptures.pojo.Register;
 import cn.quantgroup.xyqb.entity.User;
 import cn.quantgroup.xyqb.model.UserRegisterParam;
 import cn.quantgroup.xyqb.util.MqUtils;
 import org.springframework.context.ApplicationListener;
 import org.springframework.stereotype.Component;
 
-import javax.annotation.Resource;
 
 /**
  * 发mq, 目前只有数据可视化分析系统需要这个
@@ -18,10 +15,6 @@ import javax.annotation.Resource;
 @Component
 public class MQRegisteredEventListener implements ApplicationListener<RegisterEvent> {
 
-    @Resource
-    private UserIngest userIngest;
-
-
     @Override
     public void onApplicationEvent(RegisterEvent event) {
         UserRegisterParam userRegisterParam = event.getUserRegisterParam();
@@ -37,7 +30,5 @@ public class MQRegisteredEventListener implements ApplicationListener<RegisterEv
         }
         // 发送注册成功统计消息
         MqUtils.sendRegisterMessage(channelId, dimension, user);
-        Register register = new Register(user.getUuid(), user.getId(), user.getPhoneNo(), user.getRegisteredFrom(), channelId, dimension, user.getCreatedAt().getTime());
-        userIngest.sendRegisterInfo(register);
     }
 }

src/main/java/cn/quantgroup/xyqb/event/StatisticsEvent.java

-package cn.quantgroup.xyqb.event;
-
-import cn.quantgroup.acolyte.buddhistscriptures.pojo.Login;
-import lombok.Getter;
-import lombok.Setter;
-import org.springframework.context.ApplicationEvent;
-
-/**
- * 统计事件
- *
- * @author renwc
- * @date 2018-06-26
- */
-@Getter
-@Setter
-public class StatisticsEvent extends ApplicationEvent {
-    /**
-     * 登录统计
-     */
-    private Login login;
-
-    public StatisticsEvent(Object source) {
-        super(source);
-    }
-
-    public StatisticsEvent(Object source, Login login) {
-        super(source);
-        this.login = login;
-    }
-}

src/main/java/cn/quantgroup/xyqb/service/session/impl/SessionServiceImpl.java

@@ -5,7 +5,6 @@ import java.util.*;
 import java.util.concurrent.TimeUnit;
 
 import javax.annotation.Resource;
-import javax.servlet.http.HttpServletRequest;
 
 import org.apache.commons.lang3.StringUtils;
 
@@ -15,16 +14,12 @@ import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
-import org.springframework.web.context.request.RequestContextHolder;
-import org.springframework.web.context.request.ServletRequestAttributes;
 
 import com.alibaba.fastjson.JSON;
 import lombok.extern.slf4j.Slf4j;
 
-import cn.quantgroup.acolyte.buddhistscriptures.pojo.Login;
 import cn.quantgroup.xyqb.Constants;
 import cn.quantgroup.xyqb.entity.User;
-import cn.quantgroup.xyqb.event.StatisticsEvent;
 import cn.quantgroup.xyqb.model.AuthBean;
 import cn.quantgroup.xyqb.model.LoginProperties;
 import cn.quantgroup.xyqb.model.UserStatistics;
@@ -33,7 +28,6 @@ import cn.quantgroup.xyqb.model.session.SessionValue;
 import cn.quantgroup.xyqb.service.session.ISessionService;
 import cn.quantgroup.xyqb.service.session.aspect.UserBtRegisterFill;
 import cn.quantgroup.xyqb.service.user.IUserService;
-import cn.quantgroup.xyqb.util.IPUtil;
 import cn.quantgroup.xyqb.util.MqUtils;
 
 /**
@@ -140,10 +134,6 @@ public class SessionServiceImpl implements ISessionService {
         UserStatistics statistics = new UserStatistics(user, null, properties.getAction(), properties.getChannelId());
         // 推送老的登陆统计信息
         MqUtils.sendLoanVest(statistics);
-        // 发布新的登录统计信息事件
-        HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
-        Login login = new Login(user.getId(), properties.getCreatedFrom(), properties.getChannelId(), IPUtil.getRemoteIP(request), properties.getAction(), System.currentTimeMillis());
-        applicationEventPublisher.publishEvent(new StatisticsEvent(this, login));
         return sessionStruct;
     }