楚江ERP-节点完成监听器接口开发

@@ -250,4 +250,17 @@ public class CustomerDevelopPlanServiceImpl extends BaseMpServiceImpl<CustomerDe
                 .eq(CustomerDevelopPlan::getId, id);
         getBaseMapper().update(updateWrapper);
     }
+
+    @OpLog(type = OtherOpLogType.class, name = "更新状态，ID：{}", params = {"#id"})
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public void updateStatus(String id, CustomerDevelopStatus status) {
+        if (StringUtils.isBlank(id) || status == null) {
+            return;
+        }
+        LambdaUpdateWrapper<CustomerDevelopPlan> updateWrapper = Wrappers.lambdaUpdate(CustomerDevelopPlan.class)
+                .set(CustomerDevelopPlan::getStatus, status)
+                .eq(CustomerDevelopPlan::getId, id);
+        getBaseMapper().update(updateWrapper);
+    }
 }

+package com.lframework.xingyun.sc.listeners.flow;
+
+import com.lframework.starter.bpm.enums.FlowInstanceStatus;
+import com.lframework.xingyun.sc.enums.CustomerDevelopStatus;
+import com.lframework.xingyun.sc.service.customer.CustomerDevelopPlanService;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.MapUtils;
+import org.dromara.warm.flow.core.entity.Instance;
+import org.dromara.warm.flow.core.listener.Listener;
+import org.dromara.warm.flow.core.listener.ListenerVariable;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.util.Map;
+
+@Component
+@Slf4j
+public class NodeFinishListener implements Listener {
+
+
+    @Resource
+    private CustomerDevelopPlanService customerDevelopPlanService;
+
+
+    /**
+     * 业务表新增或者更新操作
+     *
+     * @param listenerVariable 监听器变量
+     */
+    @Override
+    public void notify(ListenerVariable listenerVariable) {
+        log.info("==================== 流程节点完成监听器开始......");
+        Instance instance = listenerVariable.getInstance();
+        Map<String, Object> variable = listenerVariable.getVariable();
+        if (MapUtils.isEmpty(variable)) {
+            return;
+        }
+        String businessId = instance.getBusinessId();
+        String businessType = (String) variable.get("businessType");
+        // 获取审核结果
+        String flowStatus = listenerVariable.getFlowParams().getFlowStatus();
+        // 更新业务数据
+        switch (businessType) {
+            case "CUSTOMER_DEVELOP":
+                handleCustomerDevelopData(flowStatus, businessId);
+                break;
+            default:
+                break;
+        }
+        log.info("==================== 流程节点完成监听器结束......");
+    }
+
+
+    /**
+     * 客户开发业务数据处理
+     *
+     * @param businessId        业务ID
+     */
+    private void handleCustomerDevelopData(String flowStatus, String businessId) {
+        if (FlowInstanceStatus.APPROVE_PASS.getCode().equals(flowStatus)) {
+            customerDevelopPlanService.updateStatus(businessId, CustomerDevelopStatus.PASS);
+        } else if (FlowInstanceStatus.REVOKE.getCode().equals(flowStatus)) {
+            customerDevelopPlanService.updateStatus(businessId, CustomerDevelopStatus.REFUSE);
+        }
+    }
+}
\ No newline at end of file

+//import lombok.extern.slf4j.Slf4j;
+//
+//@Component
+//@Slf4j
+//public class ProcessCompleteListener implements ExecutionListener {
+//
+//
+//    @Autowired
+//    private JdbcTemplate jdbcTemplate; // 或者使用其他数据访问方式
+//
+//    @Override
+//    public void notify(DelegateExecution execution) throws Exception {
+//        try {
+//            // 1. 获取流程变量或执行结果
+//            String businessKey = execution.getProcessBusinessKey(); // 获取业务主键
+//            String processInstanceId = execution.getProcessInstanceId();
+//            String result = (String) execution.getVariable("processResult"); // 假设流程结果存储在变量中
+//
+//            // 2. 根据业务逻辑确定要更新的表和状态
+//            String tableName = determineTableName(execution); // 实现此方法以确定表名
+//            String status = determineStatus(result); // 实现此方法以映射状态
+//
+//            // 3. 构建并执行更新语句
+//            String sql = "UPDATE " + tableName + " SET status = ? WHERE process_instance_id = ?";
+//            int updatedRows = jdbcTemplate.update(sql, status, processInstanceId);
+//
+//            if (updatedRows > 0) {
+//                log.info("Successfully updated {} rows in table {} for process instance {}",
+//                        updatedRows, tableName, processInstanceId);
+//            } else {
+//                log.warn("No rows updated in table {} for process instance {}",
+//                        tableName, processInstanceId);
+//            }
+//        } catch (Exception e) {
+//            log.error("Error updating business table status for process instance: " +
+//                    execution.getProcessInstanceId(), e);
+//            throw e; // 重新抛出异常以便流程引擎处理
+//        }
+//    }
+//
+//    /**
+//     * 根据流程信息确定业务表名
+//     */
+//    private String determineTableName(DelegateExecution execution) {
+//        // 示例：根据流程定义key或其他变量确定表名
+//        String processDefinitionKey = execution.getProcessDefinitionId().split(":")[0];
+//        // 这里可以加入具体的业务逻辑来映射表名
+//        return "business_table"; // 示例表名
+//    }
+//
+//    /**
+//     * 根据流程结果映射业务状态
+//     */
+//    private String determineStatus(String processResult) {
+//        // 示例：将流程结果映射为业务状态
+//        if ("approved".equalsIgnoreCase(processResult)) {
+//            return "APPROVED";
+//        } else if ("rejected".equalsIgnoreCase(processResult)) {
+//            return "REJECTED";
+//        } else {
+//            return "PROCESSING";
+//        }
+//    }
+//}

 package com.lframework.xingyun.sc.service.customer;
 
+import com.lframework.xingyun.sc.enums.CustomerDevelopStatus;
 import com.lframework.xingyun.sc.vo.customer.develop.CreateCustomerDevelopPlanVo;
 import com.lframework.xingyun.sc.vo.customer.develop.QueryCustomerDevelopPlanVo;
 import com.lframework.xingyun.sc.vo.customer.develop.UpdateCustomerDevelopPlanVo;
@@ -67,4 +68,12 @@ public interface CustomerDevelopPlanService extends BaseMpService<CustomerDevelo
      * @param id    主键ID
      */
     void cancel(String id);
+
+    /**
+     * 根据主键ID更新状态
+     *
+     * @param id        主键ID
+     * @param status    状态
+     */
+    void updateStatus(String id, CustomerDevelopStatus status);
 }