添加更新客服消息发送人数的定时任务

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

@@ -17,10 +17,7 @@ import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
-import java.util.Calendar;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
+import java.util.*;
 import java.util.stream.Collectors;
 
 @Component
@@ -38,7 +35,8 @@ public class SchedulingTask {
     @Autowired
     private CrowdPackageServiceImpl crowdPackageService;
 
-
+    @Autowired
+    private RedisTemplate<String, Object> redisTemplate;
 
     /**
      * 每10min扫描一次正常客服
@@ -108,4 +106,23 @@ public class SchedulingTask {
     public void updateCrowdPackageNumFromRedis() {
         crowdPackageService.updateCrowdPackageNumFromRedis();
     }
+
+    @Scheduled(cron = "0 0 1 * * ?")
+    public void refreshCustomrMaterialSendNum() {
+        List<CustomerGraphics> list = customerGraphicsService.list(new QueryWrapper<CustomerGraphics>().lt("post_time", new Date()));
+        Map<Object, Object> customerCount = redisTemplate.opsForHash().entries("CUSTOMER_COUNT");
+        Map<Long, Integer> map = new HashMap<>();
+        for (Map.Entry<Object, Object> objectObjectEntry : customerCount.entrySet()) {
+            map.put(Long.valueOf(objectObjectEntry.getKey().toString()), Integer.valueOf(objectObjectEntry.getValue().toString()));
+        }
+
+        List<CustomerGraphics> updateList = new ArrayList<>();
+        for (CustomerGraphics customerGraphics : list) {
+            CustomerGraphics entity = new CustomerGraphics();
+            entity.setId(customerGraphics.getId());
+            entity.setSendNum(map.getOrDefault(customerGraphics.getId(), 0));
+            updateList.add(entity);
+        }
+        customerGraphicsService.updateBatchById(updateList);
+    }
 }