sdk新增通过发动机号查询档案接口

张志伟
1 parent 10322773
Showing 5 changed files with 60 additions and 0 deletions
fw-valhalla-sdk/src/main/java/cn/fw/valhalla/sdk/api/CustomerApiService.java
fw-valhalla-server/src/main/java/cn/fw/valhalla/controller/api/CustomerApiServiceImpl.java
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/cust/CustomerBizService.java
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/data/CustomerService.java
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/data/impl/CustomerServiceImpl.java
@@ -162,4 +162,14 @@ public interface CustomerApiService {
      */
     @GetMapping("/queryByMemberId")
     Message<List<CarArchiveDTO>> queryByMemberId(@RequestParam("memberId") Long memberId);
+
+    /**
+     * 通过发动机号查询档案
+     *
+     * @param engineNo
+     * @param groupId
+     * @return
+     */
+    @GetMapping("/query/by/engineNo")
+    Message<CustomerInfoDto> queryByEngineNo(@RequestParam("engineNo") String engineNo, @RequestParam("groupId") Long groupId);
 }
@@ -200,4 +200,20 @@ public class CustomerApiServiceImpl implements CustomerApiService {
         }
         return success(list);
     }
+
+    @Override
+    @GetMapping("/query/by/engineNo")
+    @ControllerMethod("通过发动机号查询保有客档案")
+    public Message<CustomerInfoDto> queryByEngineNo(@RequestParam("engineNo") String engineNo, @RequestParam("groupId") Long groupId) {
+        BV.isTrue(StringUtils.isNotBlank(engineNo), "发动机号号不正确");
+        CustomerDetailDto detailDto = customerBiz.queryByEngineNo(engineNo, groupId);
+        if (Objects.nonNull(detailDto)) {
+            CustomerInfoDto dto = new CustomerInfoDto();
+            BeanUtils.copyProperties(detailDto, dto);
+            dto.setConsultantId(detailDto.getAdviserId());
+            dto.setConsultantName(detailDto.getAdviserName());
+            return success(dto);
+        }
+        return success();
+    }
 }
@@ -533,6 +533,21 @@ public class CustomerBizService extends AbstractCustomerService {
     }
  
     /**
+     * 根据发动机号查询所有档案
+     *
+     * @param engineNo
+     * @param groupId
+     * @return
+     */
+    public CustomerDetailDto queryByEngineNo(final String engineNo, final Long groupId) {
+        Customer customer = customerService.queryByEngineNo(engineNo, groupId);
+        if (Objects.isNull(customer)) {
+            return null;
+        }
+        return renderDto(customer);
+    }
+
+    /**
      * 是否关联了档案
      *
      * @param customerParams
@@ -64,6 +64,15 @@ public interface CustomerService extends IService&lt;Customer&gt; {
     Customer queryByFrameNo(String frameNo, Long groupId);
  
     /**
+     * 根据车牌号查询档案信息
+     *
+     * @param engineNo
+     * @param groupId
+     * @return
+     */
+    Customer queryByEngineNo(String engineNo, Long groupId);
+
+    /**
      * 根据baseId查询档案信息
      *
      * @param baseId
@@ -71,6 +71,16 @@ public class CustomerServiceImpl extends ServiceImpl&lt;CustomerMapper, Customer&gt; i
     }
  
     @Override
+    public Customer queryByEngineNo(String engineNo, Long groupId) {
+        return this.getBaseMapper().selectOne(Wrappers.<Customer>lambdaQuery()
+                .eq(Customer::getEngineNo, engineNo)
+                .eq(Customer::getYn, Boolean.TRUE)
+                .eq(Customer::getGroupId, groupId)
+                .orderByDesc(Customer::getUpdateTime)
+                .last("limit 1"));
+    }
+
+    @Override
     public List<Customer> queryByBaseId(Long baseId) {
         return this.list(Wrappers.<Customer>lambdaQuery()
                 .eq(Customer::getBaseId, baseId)