1,回调打印改为info

2,更新标签过滤自定义标签

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

@@ -122,7 +122,7 @@ public class PushCallBackServiceImpl extends ServiceImpl<PushCallBackDao, PushCa
         List<PushCallBackEntity> list = new ArrayList<>();
         while (matcher.find()) {
             String group = matcher.group(1);
-            log.error("回调信息:{}", group);
+            log.info("回调信息:{}", group);
             PushCallBackEntity callBackInfo = JSONObject.parseObject(group, PushCallBackEntity.class);
             String desc = JSONObject.parseObject(group).getString("desc");
             callBackInfo.setDescStr(desc);

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

@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.weface.code.CommonResult;
+import com.weface.common.utils.CommonUtil;
 import com.weface.common.utils.SnowIdUtil;
 import com.weface.dao.UserMenusDao;
 import com.weface.dto.UserMenuFrom;
@@ -33,28 +34,20 @@ public class UserMenusServiceImpl extends ServiceImpl<UserMenusDao, UserMenusEnt
      */
     @Override
     public void batchInsert(List<UserMenusEntity> userMenusList) {
+        try {
             if (CollUtil.isNotEmpty(userMenusList)) {
                 List<String> deleteUid = getDeleteUid(userMenusList);
+                List<List<String>> lists = CommonUtil.fixedGrouping(deleteUid, 10000);
+                for (List<String> list : lists) {
                     //批量插入前全删
-            List<Long> ids = this.baseMapper.findIdByUserId(deleteUid);
+                    List<Long> ids = this.baseMapper.findIdByUserId(list);
                     this.removeByIds(ids);
-            //获取集合长度
-            int count = userMenusList.size();
-            //每次批量插入个数
-            int limit = 10000;
-            int sum = 0;
-            //计算页数
-            int totalPage = (count % limit == 0) ? (count / limit) : (count / limit + 1);
-            for (int i = 0; i < totalPage; i++) {
-                List<UserMenusEntity> userMenusEntities = new ArrayList<>(10000);
-                //如果是最后一页,则截取到最后
-                if (i == totalPage - 1) {
-                    userMenusEntities = userMenusList.subList(i * limit, count);
-                } else {
-                    userMenusEntities = userMenusList.subList(i * limit, (i + 1) * limit);
                 }
+                int sum = 0;
+                List<List<UserMenusEntity>> tagLists = CommonUtil.fixedGrouping(userMenusList, 10000);
+                for (List<UserMenusEntity> tagList : tagLists) {
                     //批量插入每次一万条
-                sum += this.baseMapper.batchInsert(userMenusEntities);
+                    sum += this.baseMapper.batchInsert(tagList);
                 }
                 if (sum > 0) {
                     log.warn("新增成功记录=={}==条", sum);
@@ -62,6 +55,10 @@ public class UserMenusServiceImpl extends ServiceImpl<UserMenusDao, UserMenusEnt
                     log.error("新增失败");
                 }
             }
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error("新增用户标签失败{}", e.getMessage());
+        }
     }
 
     @Override

src/main/resources/mapper/UserMenusDao.xml

@@ -22,10 +22,17 @@
 
 <!--    根据uid查询标签id-->
     <select id="findIdByUserId" resultType="long">
-        SELECT id FROM tb_user_menus WHERE is_valid = 1 AND user_id IN
+        SELECT
+        um.id
+        FROM
+        ( SELECT id, tags_id FROM tb_user_menus WHERE is_valid = 1 AND user_id IN
         <foreach collection="list" item="item" index="index" separator="," open="(" close=")">
             #{item}
         </foreach>
+        ) um
+        LEFT JOIN tb_menu_tags mt ON um.tags_id = mt.id
+        WHERE
+        mt.is_custom = 0
     </select>
 
 </mapper>
\ No newline at end of file