1,优化sql

src/main/java/com/weface/dao/UserTagDao.java

@@ -37,7 +37,7 @@ public interface UserTagDao extends BaseMapper<UserTagEntity> {
      *
      * @return 用户信息
      */
-    List<UserTagEntity> findUserByIdAfter(Integer id, Integer limit);
+    List<UserTagEntity> findUserByIdAfter(@Param("limit") Integer limit);
 
     /**
      * 查询库中无标签用户

src/main/java/com/weface/serviceimpl/UserTagServiceImpl.java

@@ -39,7 +39,7 @@ public class UserTagServiceImpl extends ServiceImpl<UserTagDao, UserTagEntity> i
 
     @Override
     public List<UserTagEntity> findUserByIdAfter(Integer id, Integer limit) {
-        return this.baseMapper.findUserByIdAfter(id, limit);
+        return this.baseMapper.findUserByIdAfter(limit);
     }
 
     @Override

src/main/java/com/weface/task/UserTagsTask.java

@@ -236,17 +236,18 @@ public class UserTagsTask {
             int max = Integer.parseInt(pushSize);
 
             //存储用户标签信息
-            List<UserMenusEntity> userMenusList = new ArrayList<>();
+            List<UserMenusEntity> userMenusList;
             //获取标签列表
             List<MenuTagsEntity> tags = menuTagsService.list();
             //获取小于起始值,且更新时间为当前时间用户信息
             //List<UserTagEntity> beforeUser = userTagService.findUserByTodayAndIdBefore(id);
             //如果每次更新数据为空则全部设置为新增
             //if (CollUtil.isEmpty(beforeUser)) {
-            List<UserMenusEntity> afterTag = getAfterTag(id, max, tags);
-            if (afterTag != null) {
-                userMenusList.addAll(afterTag);
-            }
+            //List<UserMenusEntity> afterTag = getAfterTag(id, max, tags);
+            userMenusList = getAfterTag(id, max, tags);
+            //if (afterTag != null) {
+               // userMenusList.addAll(afterTag);
+            //}
             /*} else {
                 //过滤用户gid
                 List<String> beforeGid = beforeUser.stream().map(UserTagEntity::getGid).distinct().collect(Collectors.toList());
@@ -291,9 +292,9 @@ public class UserTagsTask {
         //如果当天新增数不为空
         if (CollUtil.isNotEmpty(afterUser)) {
             //获取用户最后一条信息
-            UserTagEntity afterUserInfo = afterUser.get(afterUser.size() - 1);
+            //UserTagEntity afterUserInfo = afterUser.get(afterUser.size() - 1);
             //并覆盖起始值
-            RedisUtil.StringOps.set("user_tag_id", String.valueOf(afterUserInfo.getId()));
+            //RedisUtil.StringOps.set("user_tag_id", String.valueOf(afterUserInfo.getId()));
             //过滤用户gid
             List<String> afterGid = afterUser.stream().map(UserTagEntity::getGid).distinct().collect(Collectors.toList());
             //调用个像接口获取新增用户标签

src/main/resources/mapper/UserTagDao.xml

@@ -56,9 +56,8 @@
             us.gid
         FROM
             t_user_tag us
-        WHERE
-            us.id > #{id}
-          AND us.gid IS NOT NULL
+        WHERE 
+              us.gid IS NOT NULL
           AND us.uid NOT IN ( SELECT DISTINCT user_id FROM tb_user_menus)
             LIMIT #{limit}
     </select>