新增sdk接口

夏天
1 parent 668f48ef
Showing 3 changed files with 31 additions and 8 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
 package cn.fw.valhalla.sdk.api;
  
 import cn.fw.data.base.domain.common.Message;
-import cn.fw.valhalla.sdk.param.ChangeAdviserReq;
-import cn.fw.valhalla.sdk.param.ChangePlateNoReq;
-import cn.fw.valhalla.sdk.param.ChangeSpecCodeReq;
-import cn.fw.valhalla.sdk.param.CustomerParams;
+import cn.fw.valhalla.sdk.param.*;
 import cn.fw.valhalla.sdk.result.*;
 import org.springframework.cloud.openfeign.FeignClient;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.*;
  
 import javax.validation.Valid;
+
 import java.util.List;
  
 /**
@@ -155,6 +150,16 @@ public interface CustomerApiService {
     Message<ReceptionResultDto> queryReceivable(@RequestParam("userId") Long userId, @RequestParam("plateNo") String plateNo);
  
     /**
+     * 查询不能接车的售后接待人员
+     *
+     * @param cusId 档案id
+     * @return 售后接待人员id集合
+     */
+    @GetMapping("/query/illegal/adviser")
+    Message<List<Long>> queryIllegalAdviser(@RequestParam("cusId") Long cusId);
+
+
+    /**
      * 修改车牌号
      *
      * @param changePlateNoReq
@@ -187,6 +187,13 @@ public class CustomerApiServiceImpl implements CustomerApiService {
     }
  
     @Override
+    @GetMapping("/query/illegal/adviser")
+    @ControllerMethod("查询不能接车的售后接待人员")
+    public Message<List<Long>> queryIllegalAdviser(final Long cusId) {
+        return success(customerBiz.queryIllegalAdviser(cusId));
+    }
+
+    @Override
     @PostMapping("/updatePlateNo")
     @ControllerMethod("通过vin修改车牌号")
     public Message<Boolean> updatePlateNo(@Valid @RequestBody ChangePlateNoReq changePlateNoReq) {
@@ -351,6 +351,17 @@ public class CustomerBizService extends AbstractCustomerService {
         return new ReceptionResultDto(true, "");
     }
  
+    public List<Long> queryIllegalAdviser(Long cusId){
+        List<AffiliationRecord> list = affiliationRecordService.list(Wrappers.<AffiliationRecord>lambdaQuery()
+                .eq(AffiliationRecord::getType, CustomerChangeTypeEnum.DEFEAT)
+                .eq(AffiliationRecord::getCustomerId, cusId)
+                .ge(AffiliationRecord::getDefeatTime, DateUtil.getNowExpiredMonth(-12)));
+        if(CollectionUtils.isEmpty(list)){
+            return Collections.emptyList();
+        }
+        return list.stream().map(AffiliationRecord::getOriginUserId).distinct().collect(Collectors.toList());
+    }
+
     /**
      * 根据档案id查询详情
      *