fix : IP解析历史数据处理新增线程池调试

game-module/game-module-manage/src/main/java/com/zanxiang/game/module/manage/ManageApplication.java

@@ -23,7 +23,7 @@ public class ManageApplication {
 
     public static void main(String[] args) {
         SpringApplication.run(ManageApplication.class, args);
-        System.out.println("赞象Manage服务启动成功 < (IP解析历史数据处理新增线程池 ･･)ﾉ(._.`) \n" +
+        System.out.println("赞象Manage服务启动成功 < (IP解析历史数据处理新增线程池调试 ･･)ﾉ(._.`) \n" +
                 "___  ___  ___   _   _   ___  _____  _____ \n" +
                 "|  \\/  | / _ \\ | \\ | | / _ \\|  __ \\|  ___|\n" +
                 "| .  . |/ /_\\ \\|  \\| |/ /_\\ \\ |  \\/| |__  \n" +

game-module/game-module-manage/src/main/java/com/zanxiang/game/module/manage/controller/UserController.java

@@ -166,6 +166,15 @@ public class UserController {
         return ResultVO.ok();
     }
 
+    @ApiOperation(value = "根据主键id解析数据IP")
+    @PatchMapping(value = "/ip/assay/by/ids")
+    @PreAuthorize(permissionKey = "manage:user:ipAssay")
+    @ApiResponses(value = {@ApiResponse(code = 200, message = "成功")})
+    public ResultVO<Void> userIpAssayById(@RequestParam String ids) {
+        ipDataAssayService.userHandleByIds(ids);
+        return ResultVO.ok();
+    }
+
     @ApiOperation(value = "玩家登录日志数据IP解析")
     @PatchMapping(value = "/login/log/ip/assay")
     @PreAuthorize(permissionKey = "manage:user:loginLogIpAssay")

game-module/game-module-manage/src/main/java/com/zanxiang/game/module/manage/service/IIpDataAssayService.java

@@ -9,6 +9,13 @@ import java.util.List;
  */
 public interface IIpDataAssayService {
 
+    /**
+     * 根据主键id处理
+     *
+     * @param ids : 主键id
+     */
+    void userHandleByIds(String ids);
+
     /**
      * 用户表处理
      */

game-module/game-module-manage/src/main/java/com/zanxiang/game/module/manage/service/impl/IpDataAssayServiceImpl.java

@@ -24,6 +24,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
+import java.util.Arrays;
 import java.util.List;
 import java.util.Objects;
 import java.util.concurrent.LinkedBlockingQueue;
@@ -61,6 +62,25 @@ public class IpDataAssayServiceImpl implements IIpDataAssayService {
             new ThreadFactoryBuilder()
                     .setNameFormat("sync-ipDataAssay-%d").build());
 
+    @Override
+    public void userHandleByIds(String ids) {
+        List<Long> userIds = Arrays.stream(ids.split(",")).map(Long::valueOf).collect(Collectors.toList());
+        List<User> userList = userService.listByIds(userIds);
+        if (CollectionUtils.isEmpty(userList)) {
+            return;
+        }
+        userList.forEach(user -> {
+            String ipData = this.ipAssay(user.getIp());
+            log.error("IP解析返回的结果, ipData : {}", ipData);
+            if (Strings.isBlank(ipData)) {
+                return;
+            }
+            userService.update(new LambdaUpdateWrapper<User>()
+                    .set(User::getIpData, ipData)
+                    .eq(User::getId, user.getId()));
+        });
+    }
+
     @Override
     public void userHandle(long supperGameId) {
         long page = 1L;
@@ -74,19 +94,24 @@ public class IpDataAssayServiceImpl implements IIpDataAssayService {
             log.error("查询游戏列表列表为空");
             return;
         }
+        List<User> userList;
         do {
             Page<User> pageUser = userService.page(new Page<>(page, pageSize), new LambdaQueryWrapper<User>()
                     .select(User::getId, User::getIp, User::getIpData)
                     .in(User::getGameId, gameIdList)
                     .orderByDesc(User::getCreateTime));
             totalPage = pageUser.getPages();
-            List<User> userList = pageUser.getRecords();
+            userList = pageUser.getRecords();
             log.error("用户执行页, page : {}, totalPage : {}, size : {}", page, totalPage, userList.size());
             this.pageUserHandle(userList);
         } while (++page <= totalPage);
     }
 
     private void pageUserHandle(List<User> userList) {
+        if (CollectionUtils.isEmpty(userList)) {
+            log.error("用户单页数据为空, 不处理");
+            return;
+        }
         THREAD_POOL_IP_DATA_ASSAY.execute(() -> userList.forEach(user -> {
             if (Strings.isNotBlank(user.getIpData())) {
                 return;
@@ -107,6 +132,7 @@ public class IpDataAssayServiceImpl implements IIpDataAssayService {
         long page = 1L;
         long pageSize = 5000L;
         long totalPage;
+        List<UserLoginLog> userLoginLogList;
         do {
             Page<UserLoginLog> pageUserLoginLog = userLoginLogService.page(new Page<>(page, pageSize),
                     new LambdaQueryWrapper<UserLoginLog>()
@@ -114,13 +140,17 @@ public class IpDataAssayServiceImpl implements IIpDataAssayService {
                             .ge(UserLoginLog::getCreateTime, LocalDateTime.now().minusMonths(2))
                             .orderByDesc(UserLoginLog::getCreateTime));
             totalPage = pageUserLoginLog.getPages();
-            List<UserLoginLog> userLoginLogList = pageUserLoginLog.getRecords();
+            userLoginLogList = pageUserLoginLog.getRecords();
             log.error("登录日志执行页, page : {}, totalPage : {}, size : {}", page, totalPage, userLoginLogList.size());
             this.pageUserLoginLogHandle(userLoginLogList);
         } while (++page <= totalPage);
     }
 
     private void pageUserLoginLogHandle(List<UserLoginLog> userLoginLogList) {
+        if (CollectionUtils.isEmpty(userLoginLogList)) {
+            log.error("登录日志单页数据为空, 不处理");
+            return;
+        }
         THREAD_POOL_IP_DATA_ASSAY.execute(() -> userLoginLogList.forEach(userLoginLog -> {
             if (Strings.isNotBlank(userLoginLog.getIpData())) {
                 return;