add:神策登录埋点

pom.xml

@@ -25,6 +25,11 @@
     </properties>
 
     <dependencies>
+        <dependency>
+            <groupId>com.sensorsdata.analytics.javasdk</groupId>
+            <artifactId>SensorsAnalyticsSDK</artifactId>
+            <version>3.2.0</version>
+        </dependency>
         <!-- swagger2 start -->
         <dependency>
         <groupId>io.springfox</groupId>

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

+package cn.quantgroup.xyqb.event;
+
+import com.sensorsdata.analytics.javasdk.ISensorsAnalytics;
+import com.sensorsdata.analytics.javasdk.SensorsAnalytics;
+import com.sensorsdata.analytics.javasdk.consumer.BatchConsumer;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.io.IOException;
+
+/**
+ * @author ：hongzhi
+ */
+@Configuration
+public class UserLoginEvent {
+        @Value("${sc.url}")
+        private String dataUrl;
+
+        @Bean(destroyMethod = "shutdown")
+        public ISensorsAnalytics init() throws IOException {
+//            //本地日志模式（此模式会在指定路径生成相应的日志文件）
+//            return new SensorsAnalytics(new ConcurrentLoggingConsumer("/Users/hongzhi/scEvent/"));
+            //网络批量发送模式（此模式在容器关闭的时候，如果存在数据还没有发送完毕，就会丢失未发送的数据！！！）
+            return new SensorsAnalytics(new BatchConsumer(dataUrl));
+        }
+
+}

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

@@ -34,6 +34,8 @@ import cn.quantgroup.xyqb.util.ValidationUtil;
 import com.alibaba.fastjson.JSON;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
+import com.sensorsdata.analytics.javasdk.ISensorsAnalytics;
+import com.sensorsdata.analytics.javasdk.bean.EventRecord;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -327,6 +329,8 @@ public class UserServiceImpl implements IUserService, IBaseController {
         log.info("清理用户缓存成功,uuid:{},phoneNo:{}", uuid, phoneNo);
     }
 
+    @Autowired
+    private ISensorsAnalytics iSensorsAnalytics;
     @Override
     @RedisLock(prefix = "lock:login:fast:", key = "#this[8]")
     public JsonResult loginFast(Long channelId, String appChannel, Long createdFrom, Long btRegisterChannelId,
@@ -350,6 +354,22 @@ public class UserServiceImpl implements IUserService, IBaseController {
         if (!wechatRelateUserIfNecessary(user, request)) {
             return JsonResult.buildErrorStateResult("登录时微信关联失败", null);
         }
+        try{
+            if(!StringUtils.isEmpty(merchant.getId()+"")){
+                if("7".equals(merchant.getId()+"")){
+                    EventRecord userRecord = EventRecord.builder().setDistinctId(user.getUuid()).isLoginId(Boolean.TRUE)
+                            .setEventName("PD_WUXIEC_UserLogin")
+                            .addProperty("son_channel_id", user.getRegisteredFrom())
+                            .addProperty("parent_channel_id", "")
+                            .addProperty("vcc_uuid", user.getUuid())
+                            .build();
+                    iSensorsAnalytics.track(userRecord);
+                    iSensorsAnalytics.flush();
+                }
+            }
+        }catch (Exception e){
+            log.info("神策埋点出现问题",e);
+        }
         LoginProperties loginProperties = new LoginProperties("", 3, channelId, createdFrom, appChannel, merchant.getId(), merchant.getName());
         AuthBean session = sessionService.createSession(user, loginProperties);
         session.setRegister(register);