添加流程控制

siwei-modules/siwei-apply/src/main/java/com/siwei/apply/service/impl/Gyjsydjfwscdjmpl.java

@@ -14,6 +14,14 @@ import org.springframework.stereotype.Service;
 
 import static com.siwei.apply.common.Common.UserId;
 
+// 新增导入：项目流程相关
+import org.springframework.transaction.annotation.Transactional;
+import com.siwei.apply.domain.ProjectWorkflow;
+import com.siwei.apply.domain.Workflow;
+import com.siwei.apply.mapper.ProjectWorkflowMapper;
+import com.siwei.apply.mapper.WorkflowMapper;
+import java.util.List;
+
 /**
  * 国有建设用地使用权及房屋所有权首次登记 服务实现类
  */
@@ -23,6 +31,11 @@ public class Gyjsydjfwscdjmpl implements GyjsydjfwscdjService {
     private GyjsydjfwscdjMapper gyjsydjfwscdjMapper;
     @Autowired
     private ProjectMapper projectMapper;
+    // 新增：项目流程相关Mapper
+    @Autowired
+    private ProjectWorkflowMapper projectWorkflowMapper;
+    @Autowired
+    private WorkflowMapper workflowMapper;
 
     @Override
     public Boolean isExit(String projectId) {
@@ -30,12 +43,32 @@ public class Gyjsydjfwscdjmpl implements GyjsydjfwscdjService {
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public String add(GyjsydjfwscdjVo gyjsydjfwscdjVo) {
         Gyjsydjfwscdj gyjsydjfwscdj = new Gyjsydjfwscdj();
         BeanUtils.copyProperties(gyjsydjfwscdjVo, gyjsydjfwscdj);
         gyjsydjfwscdj.generateId();
         gyjsydjfwscdj.setCreatorId(UserId);
         gyjsydjfwscdjMapper.add(gyjsydjfwscdj);
+        // 添加项目流程（仿照YdbpImpl）
+        Integer projectType = projectMapper.getProjectTypeById(gyjsydjfwscdj.getProjectId());
+        Workflow workflow = workflowMapper.selectByProjectTypeAndTableName(projectType, "t_gyjsydjfwscdj");
+        Workflow workflowPrev = workflowMapper.selectPrevByProjectTypeAndTableName(projectType, "t_gyjsydjfwscdj");
+        String parentId = "";
+        if (workflowPrev != null) {
+            List<ProjectWorkflow> projectWorkflows = projectWorkflowMapper.selectByProjectIdAndNodeTableName(gyjsydjfwscdj.getProjectId(), workflowPrev.getTableName());
+            if (projectWorkflows != null && !projectWorkflows.isEmpty()) {
+                parentId = projectWorkflows.get(0).getNodeId();
+            }
+        }
+        ProjectWorkflow projectWorkflow = new ProjectWorkflow();
+        projectWorkflow.setId(gyjsydjfwscdj.getId());
+        projectWorkflow.setParentId(parentId);
+        projectWorkflow.setWorkflowId(workflow.getId());
+        projectWorkflow.setProjectId(gyjsydjfwscdj.getProjectId());
+        projectWorkflow.setNodeId(gyjsydjfwscdj.getId());
+        projectWorkflow.setNodeTableName(workflow.getTableName());
+        projectWorkflowMapper.add(projectWorkflow);
         return gyjsydjfwscdj.getId();
     }
 

siwei-modules/siwei-apply/src/main/java/com/siwei/apply/service/impl/GyjsydscdjImpl.java

@@ -14,6 +14,15 @@ import org.springframework.stereotype.Service;
 
 import static com.siwei.apply.common.Common.UserId;
 
+// 新增导入：项目流程相关
+import org.springframework.transaction.annotation.Transactional;
+import com.siwei.apply.domain.ProjectWorkflow;
+import com.siwei.apply.domain.Workflow;
+import com.siwei.apply.mapper.ProjectWorkflowMapper;
+import com.siwei.apply.mapper.WorkflowMapper;
+
+import java.util.List;
+
 /**
  * 国有建设用地使用权首次登记 服务实现类
  */
@@ -23,6 +32,11 @@ public class GyjsydscdjImpl implements GyjsydscdjService {
     private GyjsydscdjMapper gyjsydscdjMapper;
     @Autowired
     private ProjectMapper projectMapper;
+    // 新增：项目流程相关Mapper
+    @Autowired
+    private ProjectWorkflowMapper projectWorkflowMapper;
+    @Autowired
+    private WorkflowMapper workflowMapper;
 
     @Override
     public Boolean isExit(String projectId) {
@@ -30,12 +44,32 @@ public class GyjsydscdjImpl implements GyjsydscdjService {
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public String add(GyjsydscdjVo gyjsydscdjVo) {
         Gyjsydscdj gyjsydscdj = new Gyjsydscdj();
         BeanUtils.copyProperties(gyjsydscdjVo, gyjsydscdj);
         gyjsydscdj.generateId();
         gyjsydscdj.setCreatorId(UserId);
         gyjsydscdjMapper.add(gyjsydscdj);
+        // 添加项目流程（仿照YdbpImpl）
+        Integer projectType = projectMapper.getProjectTypeById(gyjsydscdj.getProjectId());
+        Workflow workflow = workflowMapper.selectByProjectTypeAndTableName(projectType, "t_gyjsydscdj");
+        Workflow workflowPrev = workflowMapper.selectPrevByProjectTypeAndTableName(projectType, "t_gyjsydscdj");
+        String parentId = "";
+        if (workflowPrev != null) {
+            List<ProjectWorkflow> projectWorkflows = projectWorkflowMapper.selectByProjectIdAndNodeTableName(gyjsydscdj.getProjectId(), workflowPrev.getTableName());
+            if (projectWorkflows != null && !projectWorkflows.isEmpty()) {
+                parentId = projectWorkflows.get(0).getNodeId();
+            }
+        }
+        ProjectWorkflow projectWorkflow = new ProjectWorkflow();
+        projectWorkflow.setId(gyjsydscdj.getId());
+        projectWorkflow.setParentId(parentId);
+        projectWorkflow.setWorkflowId(workflow.getId());
+        projectWorkflow.setProjectId(gyjsydscdj.getProjectId());
+        projectWorkflow.setNodeId(gyjsydscdj.getId());
+        projectWorkflow.setNodeTableName(workflow.getTableName());
+        projectWorkflowMapper.add(projectWorkflow);
         return gyjsydscdj.getId();
     }
 

siwei-modules/siwei-apply/src/main/java/com/siwei/apply/service/impl/JsgcghxkImpl.java

@@ -16,6 +16,13 @@ import java.util.List;
 
 import static com.siwei.apply.common.Common.UserId;
 
+// 新增导入：项目流程相关
+import org.springframework.transaction.annotation.Transactional;
+import com.siwei.apply.domain.ProjectWorkflow;
+import com.siwei.apply.domain.Workflow;
+import com.siwei.apply.mapper.ProjectWorkflowMapper;
+import com.siwei.apply.mapper.WorkflowMapper;
+
 /**
  * 建设工程规划许可 服务实现类
  */
@@ -25,6 +32,11 @@ public class JsgcghxkImpl implements JsgcghxkService {
     private JsgcghxkMapper jsgcghxkMapper;
     @Autowired
     private ProjectMapper projectMapper;
+    // 新增：项目流程相关Mapper
+    @Autowired
+    private ProjectWorkflowMapper projectWorkflowMapper;
+    @Autowired
+    private WorkflowMapper workflowMapper;
 
     @Override
     public Boolean isExit(String projectId) {
@@ -32,12 +44,32 @@ public class JsgcghxkImpl implements JsgcghxkService {
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public String add(JsgcghxkVo jsgcghxkVo) {
         Jsgcghxk jsgcghxk = new Jsgcghxk();
         BeanUtils.copyProperties(jsgcghxkVo, jsgcghxk);
         jsgcghxk.generateId();
         jsgcghxk.setCreatorId(UserId);
         jsgcghxkMapper.add(jsgcghxk);
+        // 添加项目流程（仿照YdbpImpl）
+        Integer projectType = projectMapper.getProjectTypeById(jsgcghxk.getProjectId());
+        Workflow workflow = workflowMapper.selectByProjectTypeAndTableName(projectType, "t_jsgcghxk");
+        Workflow workflowPrev = workflowMapper.selectPrevByProjectTypeAndTableName(projectType, "t_jsgcghxk");
+        String parentId = "";
+        if (workflowPrev != null) {
+            List<ProjectWorkflow> projectWorkflows = projectWorkflowMapper.selectByProjectIdAndNodeTableName(jsgcghxk.getProjectId(), workflowPrev.getTableName());
+            if (projectWorkflows != null && !projectWorkflows.isEmpty()) {
+                parentId = projectWorkflows.get(0).getNodeId();
+            }
+        }
+        ProjectWorkflow projectWorkflow = new ProjectWorkflow();
+        projectWorkflow.setId(jsgcghxk.getId());
+        projectWorkflow.setParentId(parentId);
+        projectWorkflow.setWorkflowId(workflow.getId());
+        projectWorkflow.setProjectId(jsgcghxk.getProjectId());
+        projectWorkflow.setNodeId(jsgcghxk.getId());
+        projectWorkflow.setNodeTableName(workflow.getTableName());
+        projectWorkflowMapper.add(projectWorkflow);
         return jsgcghxk.getId();
     }
 

siwei-modules/siwei-apply/src/main/java/com/siwei/apply/service/impl/JsydghxkImpl.java

@@ -11,6 +11,13 @@ import com.siwei.apply.service.JsydghxkService;
 import com.siwei.common.core.utils.bean.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import com.siwei.apply.domain.ProjectWorkflow;
+import com.siwei.apply.domain.Workflow;
+import com.siwei.apply.mapper.ProjectWorkflowMapper;
+import com.siwei.apply.mapper.WorkflowMapper;
+
+import java.util.List;
 
 import static com.siwei.apply.common.Common.UserId;
 
@@ -23,6 +30,10 @@ public class JsydghxkImpl implements JsydghxkService {
     private JsydghxkMapper jsydghxkMapper;
     @Autowired
     private ProjectMapper projectMapper;
+    @Autowired
+    private ProjectWorkflowMapper projectWorkflowMapper;
+    @Autowired
+    private WorkflowMapper workflowMapper;
 
     @Override
     public Boolean isExit(String projectId) {
@@ -30,12 +41,32 @@ public class JsydghxkImpl implements JsydghxkService {
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public String add(JsydghxkVo jsydghxkVo) {
         Jsydghxk jsydghxk = new Jsydghxk();
         BeanUtils.copyProperties(jsydghxkVo, jsydghxk);
         jsydghxk.generateId();
         jsydghxk.setCreatorId(UserId);
         jsydghxkMapper.add(jsydghxk);
+
+        Integer projectType = projectMapper.getProjectTypeById(jsydghxk.getProjectId());
+        Workflow workflow = workflowMapper.selectByProjectTypeAndTableName(projectType, "t_jsydghxk");
+        Workflow workflowPrev = workflowMapper.selectPrevByProjectTypeAndTableName(projectType, "t_jsydghxk");
+        String parentId = "";
+        if (workflowPrev != null) {
+            List<ProjectWorkflow> projectWorkflows = projectWorkflowMapper.selectByProjectIdAndNodeTableName(jsydghxk.getProjectId(), workflowPrev.getTableName());
+            if (projectWorkflows != null && !projectWorkflows.isEmpty()) {
+                parentId = projectWorkflows.get(0).getNodeId();
+            }
+        }
+        ProjectWorkflow projectWorkflow = new ProjectWorkflow();
+        projectWorkflow.setId(jsydghxk.getId());
+        projectWorkflow.setParentId(parentId);
+        projectWorkflow.setWorkflowId(workflow.getId());
+        projectWorkflow.setProjectId(jsydghxk.getProjectId());
+        projectWorkflow.setNodeId(jsydghxk.getId());
+        projectWorkflow.setNodeTableName(workflow.getTableName());
+        projectWorkflowMapper.add(projectWorkflow);
         return jsydghxk.getId();
     }
 

siwei-modules/siwei-apply/src/main/java/com/siwei/apply/service/impl/TdgyImpl.java

@@ -21,6 +21,13 @@ import java.util.stream.Collectors;
 
 import static com.siwei.apply.common.Common.UserId;
 
+// 新增导入：项目流程相关
+import org.springframework.transaction.annotation.Transactional;
+import com.siwei.apply.domain.ProjectWorkflow;
+import com.siwei.apply.domain.Workflow;
+import com.siwei.apply.mapper.ProjectWorkflowMapper;
+import com.siwei.apply.mapper.WorkflowMapper;
+
 /**
  * 土地供应 服务实现类
  */
@@ -32,6 +39,11 @@ public class TdgyImpl implements TdgyService {
     private ProjectMapper projectMapper;
     @Autowired
     private LandTypeMapper landTypeMapper;
+    // 新增：项目流程相关Mapper
+    @Autowired
+    private ProjectWorkflowMapper projectWorkflowMapper;
+    @Autowired
+    private WorkflowMapper workflowMapper;
 
     @Override
     public Boolean isExit(String projectId) {
@@ -39,12 +51,32 @@ public class TdgyImpl implements TdgyService {
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public String add(TdgyVo tdgyVo) {
         Tdgy tdgy = new Tdgy();
         BeanUtils.copyProperties(tdgyVo, tdgy);
         tdgy.generateId();
         tdgy.setCreatorId(UserId);
         tdgyMapper.add(tdgy);
+        // 添加项目流程（仿照YdbpImpl）
+        Integer projectType = projectMapper.getProjectTypeById(tdgy.getProjectId());
+        Workflow workflow = workflowMapper.selectByProjectTypeAndTableName(projectType, "t_tdgy");
+        Workflow workflowPrev = workflowMapper.selectPrevByProjectTypeAndTableName(projectType, "t_tdgy");
+        String parentId = "";
+        if (workflowPrev != null) {
+            List<ProjectWorkflow> projectWorkflows = projectWorkflowMapper.selectByProjectIdAndNodeTableName(tdgy.getProjectId(), workflowPrev.getTableName());
+            if (projectWorkflows != null && !projectWorkflows.isEmpty()) {
+                parentId = projectWorkflows.get(0).getNodeId();
+            }
+        }
+        ProjectWorkflow projectWorkflow = new ProjectWorkflow();
+        projectWorkflow.setId(tdgy.getId());
+        projectWorkflow.setParentId(parentId);
+        projectWorkflow.setWorkflowId(workflow.getId());
+        projectWorkflow.setProjectId(tdgy.getProjectId());
+        projectWorkflow.setNodeId(tdgy.getId());
+        projectWorkflow.setNodeTableName(workflow.getTableName());
+        projectWorkflowMapper.add(projectWorkflow);
         return tdgy.getId();
     }
 

siwei-modules/siwei-apply/src/main/java/com/siwei/apply/service/impl/TdhyhsImpl.java

@@ -14,6 +14,14 @@ import org.springframework.stereotype.Service;
 
 import static com.siwei.apply.common.Common.UserId;
 
+// 新增导入：项目流程相关
+import org.springframework.transaction.annotation.Transactional;
+import com.siwei.apply.domain.ProjectWorkflow;
+import com.siwei.apply.domain.Workflow;
+import com.siwei.apply.mapper.ProjectWorkflowMapper;
+import com.siwei.apply.mapper.WorkflowMapper;
+import java.util.List;
+
 /**
  * 土地核验与规划核实 服务实现类
  */
@@ -23,6 +31,11 @@ public class TdhyhsImpl implements TdhyhsService {
     private TdhyhsMapper tdhyhsMapper;
     @Autowired
     private ProjectMapper projectMapper;
+    // 新增：项目流程相关Mapper
+    @Autowired
+    private ProjectWorkflowMapper projectWorkflowMapper;
+    @Autowired
+    private WorkflowMapper workflowMapper;
 
     @Override
     public Boolean isExit(String projectId) {
@@ -30,12 +43,32 @@ public class TdhyhsImpl implements TdhyhsService {
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public String add(TdhyhsVo tdhyhsVo) {
         Tdhyhs tdhyhs = new Tdhyhs();
         BeanUtils.copyProperties(tdhyhsVo, tdhyhs);
         tdhyhs.generateId();
         tdhyhs.setCreatorId(UserId);
         tdhyhsMapper.add(tdhyhs);
+        // 添加项目流程（仿照YdbpImpl）
+        Integer projectType = projectMapper.getProjectTypeById(tdhyhs.getProjectId());
+        Workflow workflow = workflowMapper.selectByProjectTypeAndTableName(projectType, "t_tdhyhs");
+        Workflow workflowPrev = workflowMapper.selectPrevByProjectTypeAndTableName(projectType, "t_tdhyhs");
+        String parentId = "";
+        if (workflowPrev != null) {
+            List<ProjectWorkflow> projectWorkflows = projectWorkflowMapper.selectByProjectIdAndNodeTableName(tdhyhs.getProjectId(), workflowPrev.getTableName());
+            if (projectWorkflows != null && !projectWorkflows.isEmpty()) {
+                parentId = projectWorkflows.get(0).getNodeId();
+            }
+        }
+        ProjectWorkflow projectWorkflow = new ProjectWorkflow();
+        projectWorkflow.setId(tdhyhs.getId());
+        projectWorkflow.setParentId(parentId);
+        projectWorkflow.setWorkflowId(workflow.getId());
+        projectWorkflow.setProjectId(tdhyhs.getProjectId());
+        projectWorkflow.setNodeId(tdhyhs.getId());
+        projectWorkflow.setNodeTableName(workflow.getTableName());
+        projectWorkflowMapper.add(projectWorkflow);
         return tdhyhs.getId();
     }