跟进任务详情增加客户等级和进站次数等

张志伟
1 parent e524f8b0
Showing 8 changed files with 32 additions and 1 deletions
fw-valhalla-dao/src/main/resources/mapper/FollowTaskMapper.xml
fw-valhalla-domain/src/main/java/cn/fw/valhalla/domain/dto/FollowPoolDTO.java
fw-valhalla-domain/src/main/java/cn/fw/valhalla/domain/vo/follow/FollowDetailVO.java
fw-valhalla-domain/src/main/java/cn/fw/valhalla/domain/vo/pool/FollowPoolListVO.java
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/follow/strategy/AbstractFollowStrategy.java
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/follow/strategy/impl/FMFollowStrategy.java
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/follow/strategy/impl/IRFollowStrategy.java
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/follow/strategy/impl/RMFollowStrategy.java
@@ -9,6 +9,7 @@
         SELECT t1.id,
         if(t1.type=3 , t4.plate_no, t3.plate_no)plate_no,
         if(t1.type=3 , t4.frame_no, t3.frame_no)frame_no,
+        t3.cus_level                            cus_level,
         t2.expires                              loan_expires,
         t1.type                                 type,
         t1.follow_user                          user_id,
@@ -17,6 +17,10 @@ public class FollowPoolDTO {
      */
     private String plateNo;
     /**
+     * 客户星级
+     */
+    private Integer cusLevel;
+    /**
      * 车架号
      */
     private String frameNo;
@@ -53,6 +53,10 @@ public class FollowDetailVO {
      */
     private String tags;
     /**
+     * 跟进次数
+     */
+    private Integer times;
+    /**
      * 客户星级
      */
     private Integer cusLevel;
@@ -19,6 +19,10 @@ public class FollowPoolListVO {
      */
     private String plateNo;
     /**
+     * 客户星级
+     */
+    private Integer cusLevel;
+    /**
      * 车架号
      */
     private String frameNo;
@@ -825,6 +825,18 @@ public abstract class AbstractFollowStrategy implements FollowStrategy {
         followRecordService.updateById(record);
     }
+    protected void queryTimes(Long clueId, FollowDetailVO vo) {
+        List<FollowTask> list = followTaskService.list(Wrappers.<FollowTask>lambdaQuery()
+                .eq(FollowTask::getClueId, clueId)
+        );
+        if (CollectionUtils.isEmpty(list)) {
+            vo.setTimes(0);
+            return;
+        }
+        int sum = list.stream().filter(r -> Objects.nonNull(r.getTimes())).mapToInt(FollowTask::getTimes).sum();
+        vo.setTimes(sum);
+    }
+
     private void onStopClue(CustomerCluePool clue, TaskDefeatTypeEnum defeatTypeEnum) {
         clue.setClueStatus(ClueStatusEnum.FAILURE);
         clue.setCloseTime(new Date());
@@ -80,6 +80,7 @@ public class FMFollowStrategy extends AbstractFollowStrategy {
         vo.setId(followRecord.getId());
         vo.setTaskId(followRecord.getTaskId());
         vo.setFMExpiration(followTask.getDeadline());
+        queryTimes(followTask.getClueId(), vo);
         int count = followRecordLogService.count(Wrappers.<FollowRecordLog>lambdaQuery()
                 .eq(FollowRecordLog::getTaskId, followRecord.getTaskId())
                 .eq(FollowRecordLog::getAttType, AttTypeEnum.SMART_PHONE)
@@ -17,7 +17,6 @@ import cn.fw.valhalla.domain.enums.*;
 import cn.fw.valhalla.domain.vo.follow.*;
 import cn.fw.valhalla.domain.vo.setting.SettingVO;
 import cn.fw.valhalla.rpc.angel.dto.InsuranceDTO;
-import cn.fw.valhalla.rpc.erp.dto.BackLogItemDTO;
 import cn.fw.valhalla.rpc.erp.dto.PostUserDTO;
 import cn.fw.valhalla.rpc.erp.dto.UserInfoDTO;
 import cn.fw.valhalla.rpc.oop.dto.ShopDTO;
@@ -86,7 +85,10 @@ public class IRFollowStrategy extends AbstractFollowStrategy {
     public FollowDetailVO getDetail(Long id) {
         FollowRecord followRecord = followRecordService.getById(id);
         BV.notNull(followRecord, "跟进记录不存在");
+        FollowTask followTask = followTaskService.getById(followRecord.getTaskId());
+        BV.notNull(followTask, "跟进信息不存在");
         IRDetailVO vo = assemble(followRecord.getCustomerId());
+        queryTimes(followTask.getClueId(), vo);
         int count = followRecordLogService.count(Wrappers.<FollowRecordLog>lambdaQuery()
                 .eq(FollowRecordLog::getTaskId, followRecord.getTaskId())
                 .eq(FollowRecordLog::getAttType, AttTypeEnum.SMART_PHONE)
@@ -103,6 +103,8 @@ public class RMFollowStrategy extends AbstractFollowStrategy {
     public FollowDetailVO getDetail(Long id) {
         FollowRecord followRecord = followRecordService.getById(id);
         BV.notNull(followRecord, "跟进记录不存在");
+        FollowTask followTask = followTaskService.getById(followRecord.getTaskId());
+        BV.notNull(followTask, "跟进信息不存在");
         RMDetailVO vo = assemble(followRecord.getCustomerId());
         int count = followRecordLogService.count(Wrappers.<FollowRecordLog>lambdaQuery()
                 .eq(FollowRecordLog::getAttType, AttTypeEnum.SMART_PHONE)
@@ -112,6 +114,7 @@ public class RMFollowStrategy extends AbstractFollowStrategy {
         vo.setId(followRecord.getId());
         vo.setTaskId(followRecord.getTaskId());
         vo.setDeadline(followRecord.getDeadline());
+        queryTimes(followTask.getClueId(), vo);
         return vo;
     }