feat(*): 新增查询某个档案的全部跟进记录

- 新增查询某个档案的全部跟进记录

feat(*): 新增查询某个档案的全部跟进记录
- 新增查询某个档案的全部跟进记录
张志伟
1 parent 3b8c7908
Showing 2 changed files with 98 additions and 0 deletions
fw-shirasawa-server/src/main/java/cn/fw/shirasawa/server/controller/app/FollowQueryController.java
fw-shirasawa-service/src/main/java/cn/fw/shirasawa/service/bus/follow/FollowBizService.java
@@ -159,6 +159,33 @@ public class FollowQueryController {
     }
  
     /**
+     * 查询客户的跟进历史记录
+     *
+     * @param customerId 客户档案用户id
+     * @param bizType    业态类型
+     * @return
+     */
+    @GetMapping("/customer/history/record")
+    @IgnoreAuth
+    @ControllerMethod("查询客户的跟进历史记录")
+    public Message<List<FollowRecordHistoryVO>> customerRecord(@NotNull(message = "档案id不能为空") final Long customerId, @NotNull(message = "业态类型不能为空") final Integer bizType) {
+        return success(followBizService.queryHistoryByCustomer(customerId, bizType));
+    }
+
+    /**
+     * 查询车辆的跟进历史记录
+     *
+     * @param vin 客户vin
+     * @return
+     */
+    @GetMapping("/vin/history/record")
+    @IgnoreAuth
+    @ControllerMethod("查询车辆的跟进历史记录")
+    public Message<List<FollowRecordHistoryVO>> vinRecord(@CurrentUser LoginAuthBean currentUser, @NotBlank(message = "vin不能为空") final String vin) {
+        return success(followBizService.queryHistoryByVin(vin, currentUser.getGroupId()));
+    }
+
+    /**
      * 查询跟进记录对应线索的跟进记录
      *
      * @param id 跟进待办id
@@ -758,6 +758,46 @@ public class FollowBizService {
     }
  
     /**
+     * 查询客户的跟进历史记录
+     *
+     * @param customerId 客户档案用户id
+     * @param bizType    业态类型
+     */
+    public List<FollowRecordHistoryVO> queryHistoryByCustomer(Long customerId, Integer bizType) {
+        List<FollowRecord> followRecordList = followRecordService.list(Wrappers.<FollowRecord>lambdaQuery()
+                .eq(FollowRecord::getCustomerId, customerId)
+                .eq(FollowRecord::getBizType, bizType)
+                .eq(FollowRecord::getFollowStatus, FollowStatusEnum.CLOSED)
+                .eq(FollowRecord::getYn, Boolean.TRUE)
+                .eq(FollowRecord::getAddTodo, Boolean.TRUE)
+        );
+        if (CollectionUtils.isEmpty(followRecordList)) {
+            return new ArrayList<>();
+        }
+        return transfromData(followRecordList);
+    }
+
+    /**
+     * 查询车辆的跟进历史记录
+     *
+     * @param vin     vin
+     * @param groupId 集团id
+     */
+    public List<FollowRecordHistoryVO> queryHistoryByVin(String vin, Long groupId) {
+        List<FollowRecord> followRecordList = followRecordService.list(Wrappers.<FollowRecord>lambdaQuery()
+                .eq(FollowRecord::getVin, vin)
+                .eq(FollowRecord::getGroupId, groupId)
+                .eq(FollowRecord::getFollowStatus, FollowStatusEnum.CLOSED)
+                .eq(FollowRecord::getYn, Boolean.TRUE)
+                .eq(FollowRecord::getAddTodo, Boolean.TRUE)
+        );
+        if (CollectionUtils.isEmpty(followRecordList)) {
+            return new ArrayList<>();
+        }
+        return transfromData(followRecordList);
+    }
+
+    /**
      * 查询跟进池详情
      *
      * @param taskId
@@ -1224,4 +1264,35 @@ public class FollowBizService {
         historyVOList.sort(Comparator.comparing(ClueHistoryVO::getDeadline));
         return historyVOList;
     }
+
+    private List<FollowRecordHistoryVO> transfromData(List<FollowRecord> followRecordList) {
+        List<Long> recordIds = followRecordList.stream().map(FollowRecord::getId).collect(Collectors.toList());
+        Map<Long, FollowRecord> map = followRecordList.stream().collect(Collectors.toMap(FollowRecord::getId, r -> r));
+        List<FollowRecordLog> attachments = followRecordLogService.getListByRecordIds(recordIds);
+        if (CollectionUtils.isEmpty(attachments)) {
+            return new ArrayList<>();
+        }
+        List<FollowRecordHistoryVO> list = new ArrayList<>();
+        for (FollowRecordLog attachment : attachments) {
+            FollowRecord followRecord = map.get(attachment.getRecordId());
+            if (Objects.isNull(followRecord)) {
+                continue;
+            }
+            FollowRecordHistoryVO vo = new FollowRecordHistoryVO();
+            vo.setAttachments(attachment.getAttachments());
+            vo.setId(attachment.getId());
+            vo.setCustomerName(followRecord.getCustomerName());
+            vo.setRecordId(attachment.getRecordId());
+            vo.setTaskId(attachment.getTaskId());
+            vo.setAttType(attachment.getAttType());
+            vo.setFeedbackType(attachment.getFeedbackType());
+            vo.setFollowType(followRecord.getType());
+            vo.setUploadTime(attachment.getUploadTime());
+            vo.setDescribes(attachment.getDescribes());
+            vo.setUserName(followRecord.getUserName());
+            list.add(vo);
+        }
+
+        return list;
+    }
 }