valhalla / fw-valhalla

Commit 138b8c07669ba28b2b6288fab3586b7b085a117e

Authored by 张志伟
1 parent 1c4d232f

:bug: 推送待办时添加一个异常处理

Inline Side-by-side
Showing 1 changed file with 11 additions and 5 deletions
fw-valhalla-server/src/main/java/cn/fw/valhalla/controller/task/FollowRecordTask.java
  View file @138b8c0
... ... @@ -14,6 +14,7 @@ import cn.fw.valhalla.service.data.FollowRecordService;
14 14 import cn.fw.valhalla.service.data.FollowTaskService;
15 15 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
16 16 import lombok.Getter;
  17 +import lombok.extern.slf4j.Slf4j;
17 18 import org.springframework.beans.factory.annotation.Autowired;
18 19 import org.springframework.beans.factory.annotation.Value;
19 20 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
... ... @@ -32,6 +33,7 @@ import java.util.*;
32 33 * @date: 2020-08-25 16:56
33 34 */
34 35 @Component
  36 +@Slf4j
35 37 @ConditionalOnProperty(prefix = "task", name = "switch", havingValue = "on")
36 38 public class FollowRecordTask {
37 39 private final FollowRecordService followRecordService;
... ... @@ -151,11 +153,15 @@ public class FollowRecordTask {
151 153 for (FollowRecord record : list) {
152 154 FollowTask task = followTaskService.getById(record.getTaskId());
153 155 if (Objects.nonNull(task) && TaskStateEnum.ONGOING.equals(task.getState())) {
154   - BackLogItemDTO dto = new BackLogItemDTO(record.getUserId(), getItemCode(record.getType()), String.valueOf(record.getId()), record.getPlanTime(), record.getShopId());
155   - dto.setExpireTime(record.getDeadline());
156   - dto.setDynamicMap(create(record));
157   - todoRpcService.push(dto);
158   - idList.add(record.getId());
  156 + try {
  157 + BackLogItemDTO dto = new BackLogItemDTO(record.getUserId(), getItemCode(record.getType()), String.valueOf(record.getId()), record.getPlanTime(), record.getShopId());
  158 + dto.setExpireTime(record.getDeadline());
  159 + dto.setDynamicMap(create(record));
  160 + todoRpcService.push(dto);
  161 + idList.add(record.getId());
  162 + } catch (Exception e) {
  163 + log.error("推送待办失败，dataId:{}", record.getId(), e);
  164 + }
159 165 } else {
160 166 failIdList.add(record.getId());
161 167 }
... ...