注册登录神策上报改为异步，去掉定时删除注销用户记录操作

src/main/java/cn/quantgroup/xyqb/service/v2/SMSDirectJiLoginStrategy.java

@@ -24,6 +24,9 @@ import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
 import java.util.UUID;
+import java.util.concurrent.Executor;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 
 /**
  * 极光一键登录
@@ -43,6 +46,9 @@ public class SMSDirectJiLoginStrategy implements LoginStrategy {
 
     private final IUserRegisterService userRegisterService;
 
+    private ExecutorService executorService = Executors.newFixedThreadPool(10);
+
+
     public SMSDirectJiLoginStrategy(ILockIpv4Service lockIpv4Service, IUserService userService, ISessionService sessionService, ISensorsAnalytics iSensorsAnalytics, JiGuangRemoteService jiGuangRemoteService, IUserRegisterService userRegisterService) {
         this.lockIpv4Service = lockIpv4Service;
         this.userService = userService;
@@ -95,33 +101,9 @@ public class SMSDirectJiLoginStrategy implements LoginStrategy {
             }
         }
 
+        //上报神策
         if (scIsOpen) {
-            try {
-                if (!StringUtils.isEmpty(sessionStruct.getScDeviceId())) {
-                    iSensorsAnalytics.trackSignUp(user.getUuid(), sessionStruct.getScDeviceId());
-                }
-                if (!StringUtils.isEmpty(sessionStruct.getTerminal()) && "APP".equals(sessionStruct.getTerminal()) || sessionStruct.getRegisteredFrom() != null && (214 == sessionStruct.getRegisteredFrom() || 217 == sessionStruct.getRegisteredFrom())) {
-
-                    EventRecord userRecord = EventRecord.builder().setDistinctId(user.getUuid()).isLoginId(Boolean.TRUE)
-                            .setEventName("App_RegisterEvent")
-                            .build();
-                    iSensorsAnalytics.track(userRecord);
-
-                    iSensorsAnalytics.flush();
-                } else {
-                    log.info("老神策埋点{},{}------------", user.getRegisteredFrom(), user.getUuid());
-                    EventRecord userRecord = EventRecord.builder().setDistinctId(user.getUuid()).isLoginId(Boolean.TRUE)
-                            .setEventName("PD_WUXIEC_UserLoginVccorCash")
-                            .addProperty("son_channel_id", user.getRegisteredFrom())
-                            .addProperty("parent_channel_id", -1L)
-                            .addProperty("vcccash_uuid", user.getUuid())
-                            .build();
-                    iSensorsAnalytics.track(userRecord);
-                    iSensorsAnalytics.flush();
-                }
-            } catch (Exception e) {
-                log.info("神策埋点出现问题", e);
-            }
+            reportSensorsAnalytics(user, sessionStruct);
         }
 
 
@@ -148,4 +130,41 @@ public class SMSDirectJiLoginStrategy implements LoginStrategy {
         validator.validate(param);
         return param;
     }
+
+    /**
+     * 上报神策
+     */
+    private void reportSensorsAnalytics(User user, SessionStruct sessionStruct) {
+        executorService.execute(new Runnable() {
+            @Override
+            public void run() {
+                try {
+                    if (!StringUtils.isEmpty(sessionStruct.getScDeviceId())) {
+                        iSensorsAnalytics.trackSignUp(user.getUuid(), sessionStruct.getScDeviceId());
+                    }
+                    if (!StringUtils.isEmpty(sessionStruct.getTerminal()) && "APP".equals(sessionStruct.getTerminal()) || sessionStruct.getRegisteredFrom() != null && (214 == sessionStruct.getRegisteredFrom() || 217 == sessionStruct.getRegisteredFrom())) {
+
+                        EventRecord userRecord = EventRecord.builder().setDistinctId(user.getUuid()).isLoginId(Boolean.TRUE)
+                                .setEventName("App_RegisterEvent")
+                                .build();
+                        iSensorsAnalytics.track(userRecord);
+
+                        iSensorsAnalytics.flush();
+                    } else {
+                        log.info("老神策埋点{},{}------------", user.getRegisteredFrom(), user.getUuid());
+                        EventRecord userRecord = EventRecord.builder().setDistinctId(user.getUuid()).isLoginId(Boolean.TRUE)
+                                .setEventName("PD_WUXIEC_UserLoginVccorCash")
+                                .addProperty("son_channel_id", user.getRegisteredFrom())
+                                .addProperty("parent_channel_id", -1L)
+                                .addProperty("vcccash_uuid", user.getUuid())
+                                .build();
+                        iSensorsAnalytics.track(userRecord);
+                        iSensorsAnalytics.flush();
+                    }
+                } catch (Exception e) {
+                    log.info("神策埋点出现问题", e);
+                }
+            }
+        });
+    }
 }

src/main/java/cn/quantgroup/xyqb/xxlJob/DeregisterTimeJobHandler.java

@@ -14,7 +14,10 @@ public class DeregisterTimeJobHandler {
     @Autowired
     private IUserDeregisterService userDeregisterService;
 
-    @XxlJob(value = "DeregisterTimeJobHandler")
+    /**
+     * 为什么要删除呢？可以不删除
+     */
+    //@XxlJob(value = "DeregisterTimeJobHandler")
     public void execute() throws Exception {
         userDeregisterService.executeTask();
         XxlJobHelper.handleSuccess();