楚江ERP:客户资信-审核结束状态监听

@@ -5,6 +5,7 @@ import com.lframework.starter.bpm.enums.FlowInstanceStatus;
 import com.lframework.starter.bpm.service.BusinessDataHandlerService;
 import com.lframework.starter.web.core.utils.JsonUtil;
 import com.lframework.xingyun.sc.enums.CustomerDevelopStatus;
+import com.lframework.xingyun.sc.service.customer.CustomerCreditService;
 import com.lframework.xingyun.sc.service.customer.CustomerDevelopPlanService;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.MapUtils;
@@ -23,6 +24,8 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
 
     @Resource
     private CustomerDevelopPlanService customerDevelopPlanService;
+    @Resource
+    private CustomerCreditService customerCreditService;
 
 
     /**
@@ -56,6 +59,9 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
             case "CUSTOMER_DEVELOP":
                 handleCustomerDevelopData(flowStatus, businessId);
                 break;
+            case "CUSTOMER_CREDIT":
+                handleCustomerCreditData(flowStatus, businessId);
+                break;
             default:
                 break;
         }
@@ -77,4 +83,18 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
             customerDevelopPlanService.updateStatus(businessId, CustomerDevelopStatus.REFUSE);
         }
     }
+
+    /**
+     * 客户资信业务数据处理
+     *
+     * @param businessId 业务ID
+     */
+    private void handleCustomerCreditData(String flowStatus, String businessId) {
+        if (FlowInstanceStatus.APPROVE_PASS.getCode().equals(flowStatus)) {
+            customerCreditService.updateStatus(businessId, "PASS");
+        } else if (FlowInstanceStatus.REVOKE.getCode().equals(flowStatus)) {
+            customerCreditService.updateStatus(businessId, "REFUSE");
+        }
+    }
+
 }