添加消息发送

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

@@ -157,6 +157,7 @@ public class SyncAppointWaitAndFinTaskImpl implements ITaskExcuteService {
                 String value = redisTemplate.opsForList().leftPop(RedisKey.KEY_CP_LIST_CACHE, 5 , TimeUnit.SECONDS);
                 log.info("cp:{}",value);
                 CpPersonInfo cpPersonInfo = JSON.parseObject(value, CpPersonInfo.class);
+                log.info("cp obj:{}",JSON.toJSONString(cpPersonInfo));
                 if (ObjectUtils.isEmpty(cpPersonInfo)) {
                     break;
                 } else {
@@ -462,7 +463,7 @@ public class SyncAppointWaitAndFinTaskImpl implements ITaskExcuteService {
 
     public static void main(String[] args) {
 
-
+/*
         Date date = new Date();  // 待判断的时间对象
         List<CareConfigTimesEntity> timePeriodList = new ArrayList<>();  // 时间段列表
         CareConfigTimesEntity careConfigTimesEntity = new CareConfigTimesEntity();
@@ -480,7 +481,16 @@ public class SyncAppointWaitAndFinTaskImpl implements ITaskExcuteService {
         boolean isIn = timePeriodList.stream()
                 .anyMatch((tp) -> (tp.getServiceTimeStart().equals(date) || tp.getServiceTimeStart().before(date))
                         && (tp.getServiceTimeEnd().equals(date) || tp.getServiceTimeEnd().after(date)));
-        System.out.println(isIn);
+        System.out.println(isIn);*/
+
+
+        String value="{\"id\":\"76007\",\"peopleid\":\"0\",\"idcardData_PhotoFileName\":\"\",\"option_id\":\"不满意\",\"content_ids\":\"6,22\",\"pic_url\":\"\",\"sectionid\":\"424\",\"source\":\"安卓评价\",\"opinion\":\"\",\"siteid\":\"1\",\"windowid\":\"205\",\"queueid\":\"752197\",\"create_time\":\"2025-04-08 09:45:46\",\"update_time\":\"2025-04-08 09:45:46\",\"pjxt\":\"1\",\"workman_id\":\"1062\",\"device_id\":\"226\",\"evaluatestatus\":\"2\",\"evaluatetype\":\"1\",\"photobefor\":\"\",\"photoautograph\":\"\",\"picture\":\"\",\"process\":\"\",\"eyevaluate\":\"0\",\"type\":\"phpj\",\"hallid\":\"8\",\"devicenum\":\"08-00-27-E1-42-F7\",\"window_name\":\"行政审批窗口\",\"window_fronum\":\"2E32\",\"workman_name\":\"陈莹\",\"workman_number\":\"RS107\",\"section\":\"市人力资源社会保障局\",\"flounum\":\"EP005\",\"content\":\"等待时间长,服务态度差\",\"idcard_Name\":\"\",\"idcard_IDCardNo\":\"\",\"phone\":\"\"}";
+
+        log.info("cp:{}",value);
+        CpPersonInfo cpPersonInfo = JSON.parseObject(value, CpPersonInfo.class);
+        log.info("cp obj:{}",JSON.toJSONString(cpPersonInfo));
+
+
 
     }