|
@@ -3,6 +3,7 @@ package com.cec.plugins.service.task;
|
|
|
import cn.hutool.core.date.DateUtil;
|
|
import cn.hutool.core.date.DateUtil;
|
|
|
import cn.hutool.core.util.IdUtil;
|
|
import cn.hutool.core.util.IdUtil;
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
|
|
+import cn.hutool.json.JSONUtil;
|
|
|
import com.cec.plugins.domain.reported.SystemLogDto;
|
|
import com.cec.plugins.domain.reported.SystemLogDto;
|
|
|
import com.cec.plugins.enumerate.TaskEnum;
|
|
import com.cec.plugins.enumerate.TaskEnum;
|
|
|
import com.cec.plugins.service.RedisClientSource;
|
|
import com.cec.plugins.service.RedisClientSource;
|
|
@@ -27,8 +28,9 @@ public class LogService implements ApplicationRunner {
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
public void run(ApplicationArguments args) throws Exception {
|
|
public void run(ApplicationArguments args) throws Exception {
|
|
|
- log.info("订阅redis, key: {}", "LOGINFO");
|
|
|
|
|
- redisClientSource.subscribe("LOGINFO", SystemLogDto.LogItem.class, logItem -> {
|
|
|
|
|
|
|
+ redisClientSource.subscribe("LOGINFO", String.class, messageStr -> {
|
|
|
|
|
+ log.info("订阅redis, key: {}, message: {}", "LOGINFO", messageStr);
|
|
|
|
|
+ SystemLogDto.LogItem logItem = JSONUtil.toBean(messageStr, SystemLogDto.LogItem.class);
|
|
|
SystemLogDto dto = new SystemLogDto();
|
|
SystemLogDto dto = new SystemLogDto();
|
|
|
String taskId = redisClientSource.getCacheStr(TaskEnum.TaskId.getKey());
|
|
String taskId = redisClientSource.getCacheStr(TaskEnum.TaskId.getKey());
|
|
|
if (StrUtil.isBlank(taskId)) {
|
|
if (StrUtil.isBlank(taskId)) {
|