新单跟进v2

yd-csf-service/src/main/java/com/yd/csf/service/service/impl/PolicyFollowServiceImpl.java

@@ -467,7 +467,7 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
             Policy policy = new Policy();
             BeanUtils.copyProperties(policyFollow, policy, "id");
 
-            if (ObjectUtils.isEmpty(policy.getInsuranceCompany()) || ObjectUtils.isEmpty(policy.getReconciliationCompany())) {
+            if (ObjectUtils.isEmpty(policy.getInsuranceCompany()) || ObjectUtils.isEmpty(policy.getReconciliationCompanyBizId())) {
                 // 获取保单产品信息，填充对账公司相关字段
                 PolicyProductInfo productInfo = getPolicyProductInfo(policyFollow.getProductLaunchBizId());
                 if (productInfo != null) {
@@ -867,11 +867,13 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
                 log.warn("产品信息为空，productLaunchBizId: {}", productLaunchBizId);
                 return null;
             }
+            if (ObjectUtils.isEmpty(productInfo.getReconciliationCompanyBizId())) {
+                throw new BusinessException("产品上架信息未配置对账公司");
+            }
 
-            log.info("成功获取产品信息: productLaunchBizId={}, reconciliationCompany={}, reconciliationCompanyCode={}",
+            log.info("成功获取产品信息: productLaunchBizId={}, reconciliationCompanyBizId={}",
                     productLaunchBizId,
-                    productInfo.getReconciliationCompany(),
-                    productInfo.getReconciliationCompanyCode());
+                    productInfo.getReconciliationCompanyBizId());
 
             return productInfo;
         } catch (Exception e) {