Commit e23f369d authored by 赵啸非's avatar 赵啸非

添加消息发送系统

parent 12535da2
...@@ -115,9 +115,7 @@ public class SyncAppointWaitAndFinTaskImpl implements ITaskExcuteService { ...@@ -115,9 +115,7 @@ public class SyncAppointWaitAndFinTaskImpl implements ITaskExcuteService {
List<CpPersonInfo> cpPersonInfos = new ArrayList<>(); List<CpPersonInfo> cpPersonInfos = new ArrayList<>();
while (true) { while (true) {
String value = redisTemplate.opsForList().leftPop(RedisKey.KEY_CP_LIST_CACHE, 5, TimeUnit.SECONDS); String value = redisTemplate.opsForList().leftPop(RedisKey.KEY_CP_LIST_CACHE, 5, TimeUnit.SECONDS);
log.info("cp:{}", value);
CpPersonInfo cpPersonInfo = JSON.parseObject(value, CpPersonInfo.class); CpPersonInfo cpPersonInfo = JSON.parseObject(value, CpPersonInfo.class);
log.info("cp obj:{}", JSON.toJSONString(cpPersonInfo));
if (ObjectUtils.isEmpty(cpPersonInfo)) { if (ObjectUtils.isEmpty(cpPersonInfo)) {
break; break;
} else { } else {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment