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

src/main/java/com/yaoyaozw/customer/controller/TestController.java

@@ -116,26 +116,6 @@ public class TestController {
         }
     }
 
-    @GetMapping("/refreshSendNum")
-    public void refreshSendNum() {
-        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);
-
-
-    }
 
     @Resource
     private WeChatService weChatService;
@@ -172,4 +152,32 @@ public class TestController {
         acquisitionExceptionEventPublisher.inspectAndExecute(linkId);
     }
 
+    @GetMapping("/refreshCustomerMaterialSendNum")
+    public void refreshCustomerMaterialSendNum() {
+        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()) {
+            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);
+        log.info("刷新客服消息送达人数完成...");
+    }
+
 }