移动更新人群包人数方法位置

src/main/java/com/yaoyaozw/customer/scheduling/SchedulingTask.java

@@ -126,39 +126,6 @@ public class SchedulingTask {
      */
 //    @Scheduled(cron = "0 0/15 * * * ?")
     public void updateCrowdPackageNumFromRedis() {
-        localLog.info("开始同步redis中人群包人数至数据库");
-        HashMap<String, Integer> entries = (HashMap<String, Integer>) redisTemplate.boundHashOps(CustomerCommonConstant.CROWD_HUMAN_NUN_REDIS_KEY).entries();
-        if (CollectionUtil.isEmpty(entries)) {
-            return;
-        }
-        localLog.info("redis中获取到人群包人数数据: {}对", entries.size());
-        Date now = new Date();
-        List<CrowdPackage> list = crowdPackageService.list();
-        localLog.info("数据库中获取人群包: {}条", list.size());
-        List<CrowdPackage> resultList = list.stream().filter(item -> entries.containsKey(item.getId().toString()))
-                .peek(item -> {
-                    item.setLastCountTime(now);
-                    Integer num = entries.get(item.getId().toString());
-                    item.setCrowdNum(num);
-                }).collect(Collectors.toList());
-
-        if (entries.size() != list.size()) {
-            localLog.info("删除redis在数据库中不存在的人群包");
-            List<String> idList = list.stream().map(item -> String.valueOf(item.getId())).collect(Collectors.toList());
-            for (String key : entries.keySet()) {
-                if (!idList.contains(key)) {
-                    localLog.info("redis中人群包id: {} 在数据库中不存在, 删除", key);
-                    redisTemplate.opsForHash().delete(CustomerCommonConstant.CROWD_HUMAN_NUN_REDIS_KEY, key);
-                }
-            }
-        }
-
-        localLog.info("要更新人群包: {} 条", resultList.size());
-        if (CollectionUtil.isNotEmpty(resultList)) {
-            crowdPackageService.updateBatchById(resultList);
-        }
-        localLog.info("删除创建时的临时数据");
-        crowdPackageService.remove(new QueryWrapper<CrowdPackage>().isNull("package_name"));
-
+        crowdPackageService.updateCrowdPackageNumFromRedis();
     }
 }

src/main/java/com/yaoyaozw/customer/service/CrowdPackageService.java

@@ -99,4 +99,10 @@ public interface CrowdPackageService extends IService<CrowdPackage> {
      * @return {@link BaseResult}
      */
     BaseResult updateUserPackageBatch(List<String> openIdList);
+
+    /**
+     * 更新包num人群复述
+     */
+    void updateCrowdPackageNumFromRedis();
+
 }

src/main/java/com/yaoyaozw/customer/service/impl/CrowdPackageServiceImpl.java

@@ -11,6 +11,7 @@ import com.yaoyaozw.customer.common.GenericsResult;
 import com.yaoyaozw.customer.components.CustomerServiceCommonAsyncComponent;
 import com.yaoyaozw.customer.components.TokenManager;
 import com.yaoyaozw.customer.constants.CrowdPackageCommonConstant;
+import com.yaoyaozw.customer.constants.CustomerCommonConstant;
 import com.yaoyaozw.customer.dto.crowd.CrowdPackageQueryDTO;
 import com.yaoyaozw.customer.dto.crowd.CrowdPackageConditionDTO;
 import com.yaoyaozw.customer.entity.CrowdPackage;
@@ -34,6 +35,7 @@ import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
 
 import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -234,6 +236,44 @@ public class CrowdPackageServiceImpl extends ServiceImpl<MaterialCrowdPackageMap
         return new BaseResult().success();
     }
 
+    @Override
+    public void updateCrowdPackageNumFromRedis() {
+
+        LOCAL_LOG.info("开始同步redis中人群包人数至数据库");
+        HashMap<String, Integer> entries = (HashMap<String, Integer>) redisTemplate.boundHashOps(CustomerCommonConstant.CROWD_HUMAN_NUN_REDIS_KEY).entries();
+        if (CollectionUtil.isEmpty(entries)) {
+            return;
+        }
+        LOCAL_LOG.info("redis中获取到人群包人数数据: {}对", entries.size());
+        Date now = new Date();
+        List<CrowdPackage> list = super.list();
+        LOCAL_LOG.info("数据库中获取人群包: {}条", list.size());
+        List<CrowdPackage> resultList = list.stream().filter(item -> entries.containsKey(item.getId().toString()))
+                .peek(item -> {
+                    item.setLastCountTime(now);
+                    Integer num = entries.get(item.getId().toString());
+                    item.setCrowdNum(num);
+                }).collect(Collectors.toList());
+
+        if (entries.size() != list.size()) {
+            LOCAL_LOG.info("删除redis在数据库中不存在的人群包");
+            List<String> idList = list.stream().map(item -> String.valueOf(item.getId())).collect(Collectors.toList());
+            for (String key : entries.keySet()) {
+                if (!idList.contains(key)) {
+                    LOCAL_LOG.info("redis中人群包id: {} 在数据库中不存在, 删除", key);
+                    redisTemplate.opsForHash().delete(CustomerCommonConstant.CROWD_HUMAN_NUN_REDIS_KEY, key);
+                }
+            }
+        }
+
+        LOCAL_LOG.info("要更新人群包: {} 条", resultList.size());
+        if (CollectionUtil.isNotEmpty(resultList)) {
+            super.updateBatchById(resultList);
+        }
+        LOCAL_LOG.info("删除创建时的临时数据");
+        super.remove(new QueryWrapper<CrowdPackage>().isNull("package_name"));
+    }
+
     /**
      * 构造操作符
      *