push

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

@@ -35,6 +35,7 @@ import javax.servlet.http.HttpServletResponse;
 import java.io.UnsupportedEncodingException;
 import java.net.URLEncoder;
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
@@ -285,10 +286,6 @@ public class ApiCommissionExpectedController {
         return Result.success(response);
     }
 
-    /**
-     * 处理receivableReportPage
-     * @return
-     */
     private void enrichReceivableReportWithCompanyName(IPage<ReceivableReportVO> page) {
         if (page == null || CollectionUtils.isEmpty(page.getRecords())) {
             return;
@@ -301,7 +298,7 @@ public class ApiCommissionExpectedController {
                 .distinct()
                 .collect(Collectors.toList());
 
-        if (CollectionUtils.isEmpty(bizIdList)) {
+        if (bizIdList.isEmpty()) {
             return;
         }
 
@@ -309,33 +306,10 @@ public class ApiCommissionExpectedController {
         ApiInsuranceReconciliationCompanyPageRequest request = new ApiInsuranceReconciliationCompanyPageRequest();
         request.setReconciliationCompanyBizIdList(bizIdList);
         request.setPageNo(1);
-        request.setPageSize(bizIdList.size()); // 确保一次查全
-
-        Result result = companyFeignClient.page(request); // 返回原始 Result 类型
-        if (result == null || result.getCode() != 200 || result.getData() == null) {
-            return;
-        }
-
-        // 由于实际数据类型是 IPage<ApiInsuranceReconciliationCompanyPageResponse>，进行安全转换
-        Object data = result.getData();
-        if (!(data instanceof IPage<?>)) {
-            // 类型不符合预期，记录日志并返回
-            return;
-        }
-
-        IPage<?> rawPage = (IPage<?>) data;
-        if (CollectionUtils.isEmpty(rawPage.getRecords())) {
-            return;
-        }
-
-        // 提取 records，并安全转换为目标类型
-        List<ApiInsuranceReconciliationCompanyPageResponse> companyList = new ArrayList<>();
-        for (Object record : rawPage.getRecords()) {
-            if (record instanceof ApiInsuranceReconciliationCompanyPageResponse) {
-                companyList.add((ApiInsuranceReconciliationCompanyPageResponse) record);
-            }
-        }
+        request.setPageSize(bizIdList.size());
 
+        Result result = companyFeignClient.page(request);
+        List<ApiInsuranceReconciliationCompanyPageResponse> companyList = extractCompanyListFromResult(result);
         if (companyList.isEmpty()) {
             return;
         }
@@ -350,13 +324,34 @@ public class ApiCommissionExpectedController {
                 ));
 
         // 回填名称
-        for (ReceivableReportVO vo : page.getRecords()) {
+        page.getRecords().forEach(vo -> {
             if (StringUtils.isNotBlank(vo.getReconciliationCompanyBizId())) {
                 String name = nameMap.get(vo.getReconciliationCompanyBizId());
                 if (StringUtils.isNotBlank(name)) {
                     vo.setReconciliationCompany(name);
                 }
             }
+        });
+    }
+
+    /**
+     * 从 Feign 返回结果中安全提取公司列表
+     */
+    @SuppressWarnings("unchecked")
+    private List<ApiInsuranceReconciliationCompanyPageResponse> extractCompanyListFromResult(Result result) {
+        if (result == null || result.getCode() != 200 || result.getData() == null) {
+            return Collections.emptyList();
+        }
+        Object data = result.getData();
+        if (!(data instanceof IPage<?>)) {
+            // 可根据需要记录日志
+            return Collections.emptyList();
+        }
+        IPage<?> page = (IPage<?>) data;
+        if (CollectionUtils.isEmpty(page.getRecords())) {
+            return Collections.emptyList();
         }
+        // 由于实际类型已知，直接转换（类型安全由服务端保证）
+        return (List<ApiInsuranceReconciliationCompanyPageResponse>) page.getRecords();
     }
 }