刷新客服消息送达人数调整

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

@@ -10,6 +10,7 @@ import com.yaoyaozw.customer.entity.CrowdPackage;
 import com.yaoyaozw.customer.service.AccountOrderService;
 import com.yaoyaozw.customer.service.RegisterUserEntityService;
 import com.yaoyaozw.customer.service.impl.CrowdPackageServiceImpl;
+import lombok.extern.slf4j.Slf4j;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -20,6 +21,7 @@ import org.springframework.stereotype.Component;
 import java.util.*;
 import java.util.stream.Collectors;
 
+@Slf4j
 @Component
 public class SchedulingTask {
 
@@ -107,9 +109,17 @@ public class SchedulingTask {
         crowdPackageService.updateCrowdPackageNumFromRedis();
     }
 
-    @Scheduled(cron = "0 0 1 * * ?")
+    @Scheduled(cron = "0 3 1 * * ?")
     public void refreshCustomrMaterialSendNum() {
-        List<CustomerGraphics> list = customerGraphicsService.list(new QueryWrapper<CustomerGraphics>().lt("post_time", new Date()));
+        log.info("开始刷新客服消息送达人数...");
+
+        Calendar instance = Calendar.getInstance();
+        instance.add(Calendar.DAY_OF_YEAR, -3);
+        Date startTime = instance.getTime();
+
+        List<CustomerGraphics> list = customerGraphicsService.list(new QueryWrapper<CustomerGraphics>().between("post_time", startTime, new Date()));
+        log.info("开始刷新客服消息送达人数，待处理客服消息数：{}", list.size());
+
         Map<Object, Object> customerCount = redisTemplate.opsForHash().entries("CUSTOMER_COUNT");
         Map<Long, Integer> map = new HashMap<>();
         for (Map.Entry<Object, Object> objectObjectEntry : customerCount.entrySet()) {
@@ -124,5 +134,6 @@ public class SchedulingTask {
             updateList.add(entity);
         }
         customerGraphicsService.updateBatchById(updateList);
+        log.info("刷新客服消息送达人数完成...");
     }
 }