From 138b8c07669ba28b2b6288fab3586b7b085a117e Mon Sep 17 00:00:00 2001 From: Kurisu Date: Fri, 7 Jan 2022 09:59:37 +0800 Subject: [PATCH] :bug: 推送待办时添加一个异常处理 --- fw-valhalla-server/src/main/java/cn/fw/valhalla/controller/task/FollowRecordTask.java | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) diff --git a/fw-valhalla-server/src/main/java/cn/fw/valhalla/controller/task/FollowRecordTask.java b/fw-valhalla-server/src/main/java/cn/fw/valhalla/controller/task/FollowRecordTask.java index db1a8a4..5765d55 100644 --- a/fw-valhalla-server/src/main/java/cn/fw/valhalla/controller/task/FollowRecordTask.java +++ b/fw-valhalla-server/src/main/java/cn/fw/valhalla/controller/task/FollowRecordTask.java @@ -14,6 +14,7 @@ import cn.fw.valhalla.service.data.FollowRecordService; import cn.fw.valhalla.service.data.FollowTaskService; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import lombok.Getter; +import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; @@ -32,6 +33,7 @@ import java.util.*; * @date: 2020-08-25 16:56 */ @Component +@Slf4j @ConditionalOnProperty(prefix = "task", name = "switch", havingValue = "on") public class FollowRecordTask { private final FollowRecordService followRecordService; @@ -151,11 +153,15 @@ public class FollowRecordTask { for (FollowRecord record : list) { FollowTask task = followTaskService.getById(record.getTaskId()); if (Objects.nonNull(task) && TaskStateEnum.ONGOING.equals(task.getState())) { - BackLogItemDTO dto = new BackLogItemDTO(record.getUserId(), getItemCode(record.getType()), String.valueOf(record.getId()), record.getPlanTime(), record.getShopId()); - dto.setExpireTime(record.getDeadline()); - dto.setDynamicMap(create(record)); - todoRpcService.push(dto); - idList.add(record.getId()); + try { + BackLogItemDTO dto = new BackLogItemDTO(record.getUserId(), getItemCode(record.getType()), String.valueOf(record.getId()), record.getPlanTime(), record.getShopId()); + dto.setExpireTime(record.getDeadline()); + dto.setDynamicMap(create(record)); + todoRpcService.push(dto); + idList.add(record.getId()); + } catch (Exception e) { + log.error("推送待办失败，dataId:{}", record.getId(), e); + } } else { failIdList.add(record.getId()); } -- libgit2 0.22.2