push

yd-insurance-base-api/src/main/java/com/yd/insurance/base/api/service/impl/ApiUserSaleExpandServiceImpl.java

@@ -11,6 +11,7 @@ import com.yd.insurance.base.api.service.ApiUserSaleExpandService;
 import com.yd.insurance.base.feign.request.usersaleexpand.*;
 import com.yd.insurance.base.feign.request.usersaleexpand.*;
 import com.yd.insurance.base.feign.response.usersaleexpand.ApiUserSaleExpandDetailResponse;
 import com.yd.insurance.base.feign.response.usersaleexpand.ApiUserSaleExpandDetailResponse;
 import com.yd.insurance.base.feign.response.usersaleexpand.ApiUserSaleExpandPageResponse;
 import com.yd.insurance.base.feign.response.usersaleexpand.ApiUserSaleExpandPageResponse;
+import com.yd.insurance.base.service.dto.QueryUserSaleExpandDTO;
 import com.yd.insurance.base.service.model.UserSaleExpand;
 import com.yd.insurance.base.service.model.UserSaleExpand;
 import com.yd.insurance.base.service.service.IUserSaleExpandService;
 import com.yd.insurance.base.service.service.IUserSaleExpandService;
 import lombok.extern.slf4j.Slf4j;
 import lombok.extern.slf4j.Slf4j;
@@ -53,7 +54,10 @@ public class ApiUserSaleExpandServiceImpl implements ApiUserSaleExpandService {
         if (CollectionUtils.isEmpty(request.getClientUserBizIdList())) {
         if (CollectionUtils.isEmpty(request.getClientUserBizIdList())) {
             return Result.success();
             return Result.success();
         }
         }
-        List<UserSaleExpand> userSaleExpandList = iUserSaleExpandService.queryList(request.getClientUserBizIdList());
+        List<UserSaleExpand> userSaleExpandList = iUserSaleExpandService.queryList(QueryUserSaleExpandDTO.builder()
+                .clientUserBizIdList(request.getClientUserBizIdList())
+                .phone(request.getPhone())
+                .build());
         if (CollectionUtils.isEmpty(userSaleExpandList)) {
         if (CollectionUtils.isEmpty(userSaleExpandList)) {
             return Result.success();
             return Result.success();
         }
         }

yd-insurance-base-feign/src/main/java/com/yd/insurance/base/feign/request/usersaleexpand/ApiUserSaleExpandListRequest.java

@@ -7,4 +7,9 @@ import java.util.List;
 public class ApiUserSaleExpandListRequest {
 public class ApiUserSaleExpandListRequest {
 
 
     private List<String> clientUserBizIdList;
     private List<String> clientUserBizIdList;
+
+    /**
+     * 手机号
+     */
+    private String phone;
 }
 }

yd-insurance-base-service/src/main/java/com/yd/insurance/base/service/dto/QueryUserSaleExpandDTO.java

+package com.yd.insurance.base.service.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import java.util.List;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class QueryUserSaleExpandDTO {
+
+    /**
+     * 用户唯一业务ID列表
+     */
+    private List<String> clientUserBizIdList;
+
+    /**
+     * 手机号
+     */
+    private String phone;
+}

yd-insurance-base-service/src/main/java/com/yd/insurance/base/service/service/IUserSaleExpandService.java

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.yd.insurance.base.feign.request.usersaleexpand.ApiUserSaleExpandPageRequest;
 import com.yd.insurance.base.feign.request.usersaleexpand.ApiUserSaleExpandPageRequest;
 import com.yd.insurance.base.feign.response.usersaleexpand.ApiUserSaleExpandPageResponse;
 import com.yd.insurance.base.feign.response.usersaleexpand.ApiUserSaleExpandPageResponse;
+import com.yd.insurance.base.service.dto.QueryUserSaleExpandDTO;
 import com.yd.insurance.base.service.model.UserSaleExpand;
 import com.yd.insurance.base.service.model.UserSaleExpand;
 
 
 import java.util.List;
 import java.util.List;
@@ -27,4 +28,6 @@ public interface IUserSaleExpandService extends IService<UserSaleExpand> {
     UserSaleExpand queryOne(String userSaleBizId,String clientUserBizId);
     UserSaleExpand queryOne(String userSaleBizId,String clientUserBizId);
 
 
     List<UserSaleExpand> queryList(List<String> clientUserBizIdList);
     List<UserSaleExpand> queryList(List<String> clientUserBizIdList);
+
+    List<UserSaleExpand> queryList(QueryUserSaleExpandDTO dto);
 }
 }

yd-insurance-base-service/src/main/java/com/yd/insurance/base/service/service/impl/UserSaleExpandServiceImpl.java

@@ -7,8 +7,10 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.yd.insurance.base.feign.request.usersaleexpand.ApiUserSaleExpandPageRequest;
 import com.yd.insurance.base.feign.request.usersaleexpand.ApiUserSaleExpandPageRequest;
 import com.yd.insurance.base.feign.response.usersaleexpand.ApiUserSaleExpandPageResponse;
 import com.yd.insurance.base.feign.response.usersaleexpand.ApiUserSaleExpandPageResponse;
 import com.yd.insurance.base.service.dao.UserSaleExpandMapper;
 import com.yd.insurance.base.service.dao.UserSaleExpandMapper;
+import com.yd.insurance.base.service.dto.QueryUserSaleExpandDTO;
 import com.yd.insurance.base.service.model.UserSaleExpand;
 import com.yd.insurance.base.service.model.UserSaleExpand;
 import com.yd.insurance.base.service.service.IUserSaleExpandService;
 import com.yd.insurance.base.service.service.IUserSaleExpandService;
+import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.stereotype.Service;
 
 
@@ -50,4 +52,12 @@ public class UserSaleExpandServiceImpl extends ServiceImpl<UserSaleExpandMapper,
         return this.lambdaQuery().in(UserSaleExpand::getClientUserBizId,clientUserBizIdList).list();
         return this.lambdaQuery().in(UserSaleExpand::getClientUserBizId,clientUserBizIdList).list();
     }
     }
 
 
+    @Override
+    public List<UserSaleExpand> queryList(QueryUserSaleExpandDTO dto) {
+        return this.lambdaQuery()
+                .eq(StringUtils.isNotBlank(dto.getPhone()),UserSaleExpand::getPhone,dto.getPhone())
+                .in(CollectionUtils.isNotEmpty(dto.getClientUserBizIdList()),UserSaleExpand::getClientUserBizId,dto.getClientUserBizIdList())
+                .list();
+    }
+
 }
 }