客服开启

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

@@ -85,6 +85,7 @@ public class SchedulingTask {
     /**
      * 每10min扫描一次正常客服
      */
+    @Scheduled(cron = "0 0/10 * * * *")
     public void publishCustomerMessage(){
 
         Calendar calendar = Calendar.getInstance();

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

@@ -96,18 +96,21 @@ public class AccountOrderServiceImpl extends ServiceImpl<AccountOrderMapper, Acc
     public void calculateAvgMonth(IntegrationRequestDTO integrationRequestDTO) {
         //获取近一月每个用户的平均充值
         List<UserAvgAmountVO> userAvgAmountVos= baseMapper.findMonthDailyAccountOrder();
-        Map<String, Double> userAvgAmountMap = userAvgAmountVos.stream().collect(Collectors.toMap(UserAvgAmountVO::getOpenId, UserAvgAmountVO::getAvgAmount, (v1, v2) -> v1));
-        //获取付费用户信息
-        List<RegisterUserEntity> userList = registerUserEntityService.list(new QueryWrapper<RegisterUserEntity>().gt(RegisterUserEntity.COL_PAY_TYPE, 0));
+        if(!userAvgAmountVos.isEmpty()){
+            Map<String, Double> userAvgAmountMap = userAvgAmountVos.stream().collect(Collectors.toMap(UserAvgAmountVO::getOpenId, UserAvgAmountVO::getAvgAmount, (v1, v2) -> v1));
+            //获取付费用户信息
+            List<RegisterUserEntity> userList = registerUserEntityService.list(new QueryWrapper<RegisterUserEntity>().gt(RegisterUserEntity.COL_PAY_TYPE, 0));
 
-        if (userList!=null&&!userList.isEmpty()){
+            if (userList!=null&&!userList.isEmpty()){
 
-            for (RegisterUserEntity registerUserEntity : userList) {
+                for (RegisterUserEntity registerUserEntity : userList) {
 
-                registerUserEntity.setAvgMonth(userAvgAmountMap.get(registerUserEntity.getOpenId()));
+                    registerUserEntity.setAvgMonth(userAvgAmountMap.get(registerUserEntity.getOpenId()));
+                }
             }
+            registerUserEntityService.updateBatchById(userList);
         }
-        registerUserEntityService.updateBatchById(userList);
+
     }