新单跟进同步预约信息test

yd-csf-api/src/main/java/com/yd/csf/api/controller/ApiCustomerController.java

@@ -2,6 +2,10 @@ package com.yd.csf.api.controller;
 
 import cn.hutool.core.collection.CollUtil;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yd.base.feign.client.relobjectcertificate.ApiRelObjectCertificateFeignClient;
+import com.yd.base.feign.dto.ApiCertificateDto;
+import com.yd.base.feign.request.relobjectcertificate.ApiRelObjectCertificateListRequest;
+import com.yd.base.feign.response.relobjectcertificate.ApiRelObjectCertificateListResponse;
 import com.yd.common.enums.CommonEnum;
 import com.yd.common.enums.ResultCode;
 import com.yd.common.exception.BusinessException;
@@ -15,16 +19,21 @@ import com.yd.csf.service.dto.CustomerQueryRequest;
 import com.yd.csf.service.dto.CustomerUpdateRequest;
 import com.yd.csf.service.model.Customer;
 import com.yd.csf.service.service.CustomerService;
+import com.yd.csf.service.utils.GSONUtil;
 import com.yd.csf.service.vo.CustomerVO;
 
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import org.apache.commons.lang3.ObjectUtils;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.CollectionUtils;
 import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
+import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
@@ -44,6 +53,8 @@ public class ApiCustomerController {
     private CustomerService customerService;
     @Resource
     private ApiTaxationService apiTaxationService;
+    @Resource
+    private ApiRelObjectCertificateFeignClient apiRelObjectCertificateFeignClient;
 
     /**
      * 创建客户
@@ -170,6 +181,50 @@ public class ApiCustomerController {
         return Result.success(customerService.getCustomerVO(customer));
     }
 
+    @GetMapping("/get/vo/test")
+    public Result<Boolean> getCustomerVOTest() {
+
+        // 查询数据库
+        List<Customer> customerList = customerService.list();
+
+        if (!CollUtil.isEmpty(customerList)) {
+            for (Customer customer : customerList) {
+                List<ApiCertificateDto> apiCertificateDtoList = apiCertificateDtoList(customer.getCustomerBizId());
+                if (CollUtil.isNotEmpty(apiCertificateDtoList)) {
+                    customer.setCertificateList(GSONUtil.toJson(apiCertificateDtoList));
+                    customerService.lambdaUpdate()
+                            .set(Customer::getCertificateList, customer.getCertificateList())
+                            .eq(Customer::getId, customer.getId())
+                            .update();
+                    try {
+                        Thread.sleep(1000);
+                    } catch (InterruptedException e) {
+                        e.printStackTrace();
+                    }
+                }
+            }
+        }
+
+        // 获取封装类
+        return Result.success(true);
+    }
+
+    public List<ApiCertificateDto> apiCertificateDtoList(String customerBizId) {
+        List<ApiCertificateDto> apiCertificateDtoList = new ArrayList<>();
+        //查询投保人证件列表信息
+        Result<List<ApiRelObjectCertificateListResponse>> result = apiRelObjectCertificateFeignClient.list(ApiRelObjectCertificateListRequest.builder()
+                .objectBizId(customerBizId)
+                .build());
+        if (!CollectionUtils.isEmpty(result.getData())) {
+            apiCertificateDtoList = result.getData().stream().map(dto -> {
+                ApiCertificateDto apiCertificateDto = new ApiCertificateDto();
+                BeanUtils.copyProperties(dto,apiCertificateDto);
+                return apiCertificateDto;
+            }).collect(Collectors.toList());
+        }
+        return apiCertificateDtoList;
+    }
+
     /**
      * 分页获取客户列表（仅管理员可用）
      *