添加消息发送

refined-manager/src/main/java/com/mortals/xhx/daemon/task/SyncAppointWaitAndFinTaskImpl.java

@@ -98,14 +98,12 @@ public class SyncAppointWaitAndFinTaskImpl implements ITaskExcuteService {
 
     @Override
     public void excuteTask(ITask task) throws AppException {
-        log.debug("同步今天等待用户任务");
+        log.info("同步今天等待用户任务");
         syncWaitAndFinQueue();
-        log.debug("同步今天等待用户完成任务");
         log.info("关怀用户任务");
-        updateWaitQueueTime();
+       // updateWaitQueueTime();
         log.info("关怀服务完成任务");
-        log.debug("清理超期等待业务");
-        clearWaitQueueTime();
+       // clearWaitQueueTime();
         //todo 办理完成同步
         log.info("同步办理完成业务");
 
@@ -276,9 +274,9 @@ public class SyncAppointWaitAndFinTaskImpl implements ITaskExcuteService {
             List<CpPersonInfo> cpPersonInfos = new ArrayList<>();
             while (true) {
                 String value = redisTemplate.opsForList().leftPop(RedisKey.KEY_CP_LIST_CACHE, 10, TimeUnit.SECONDS);
+               log.info("cp:{}",value);
                 CpPersonInfo cpPersonInfo = JSON.parseObject(value, CpPersonInfo.class);
-                //  FinPersonInfo finPersonInfo = cacheService.blpop(RedisKey.KEY_FIN_LIST_CACHE,10, FinPersonInfo.class);
-                if (ObjectUtils.isEmpty(cpPersonInfo)) {
+               if (ObjectUtils.isEmpty(cpPersonInfo)) {
                     break;
                 } else {
                     cpPersonInfos.add(cpPersonInfo);