valhalla / fw-valhalla

Commit 953745ee071aee1e7d702e596c0e761cc9cc1426

Authored by 张志伟
1 parent 06c394ca

feature(*): 新增区域站岗线索池 

- 新增区域站岗线索池
Inline Side-by-side
Showing 2 changed files with 14 additions and 0 deletions
fw-valhalla-service/src/main/java/cn/fw/valhalla/component/consumer/FollowResultConsumer.java
  View file @953745e
... ... @@ -3,6 +3,7 @@ package cn.fw.valhalla.component.consumer;
3 3 import cn.fw.shirasawa.sdk.enums.DataTypeEnum;
4 4 import cn.fw.shirasawa.sdk.mq.FollowResultDTO;
5 5 import cn.fw.valhalla.domain.db.follow.FollowClue;
  6 +import cn.fw.valhalla.domain.enums.FollowTypeEnum;
6 7 import cn.fw.valhalla.service.bus.follow.FollowBizService;
7 8 import cn.fw.valhalla.service.bus.pub.PubStandBizService;
8 9 import cn.fw.valhalla.service.data.FollowClueService;
... ... @@ -63,6 +64,13 @@ public class FollowResultConsumer implements RocketMQListener<FollowResultDTO> {
63 64 }
64 65 pubStandBizService.join(dto.getUserId(), false);
65 66 Long val = Long.valueOf(dto.getDetailId());
  67 + if (DataTypeEnum.PL.getValue().equals(dto.getType())) {
  68 + FollowClue clue = new FollowClue();
  69 + clue.setId(val);
  70 + clue.setClueType(FollowTypeEnum.PL);
  71 + followBizService.afterFollowComplete(clue, dto.isOverdue());
  72 + return;
  73 + }
66 74 FollowClue clue = followClueService.getById(val);
67 75 if (Objects.isNull(clue)) {
68 76 return;
... ...
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/follow/strategy/impl/PubFollowStrategy.java
  View file @953745e
... ... @@ -229,6 +229,12 @@ public class PubFollowStrategy implements FollowStrategy {
229 229 // 公共池线索不存在这种场景
230 230 }
231 231  
  232 + /**
  233 + * 维护跟进次数
  234 + *
  235 + * @param clue 虚拟的跟进线索[只有id 和类型 其他信息没有]
  236 + * @param overdue
  237 + */
232 238 @Override
233 239 public void onFollowComplete(final FollowClue clue, final boolean overdue) {
234 240 ClueTask task = clueTaskService.queryOngoingTaskByClueId(clue.getId(), FollowTypeEnum.PL);
... ...