用地报批流程添加

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

@@ -11,6 +11,12 @@ import com.siwei.apply.service.YdbpService;
 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 static com.siwei.apply.common.Common.UserId;
 
@@ -23,6 +29,10 @@ public class YdbpImpl implements YdbpService {
     private YdbpMapper ydbpMapper;
     @Autowired
     private ProjectMapper projectMapper;
+    @Autowired
+    private ProjectWorkflowMapper projectWorkflowMapper;
+    @Autowired
+    private WorkflowMapper workflowMapper;
 
     @Override
     public Boolean isExit(String projectId) {
@@ -30,12 +40,23 @@ public class YdbpImpl implements YdbpService {
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public String add(YdbpVo ydbpVo) {
         Ydbp ydbp = new Ydbp();
         BeanUtils.copyProperties(ydbpVo, ydbp);
         ydbp.generateId();
         ydbp.setCreatorId(UserId);
         ydbpMapper.add(ydbp);
+        // 添加项目流程
+        Integer projectType = projectMapper.getProjectTypeById(ydbp.getProjectId());
+        Workflow workflow = workflowMapper.selectByProjectTypeAndTableName(projectType, "t_ydbp");
+        ProjectWorkflow projectWorkflow = new ProjectWorkflow();
+        projectWorkflow.setId(ydbp.getId());
+        projectWorkflow.setParentId("");
+        projectWorkflow.setProjectId(ydbp.getProjectId());
+        projectWorkflow.setNodeId(ydbp.getId());
+        projectWorkflow.setNodeTableName(workflow.getTableName());
+        projectWorkflowMapper.add(projectWorkflow);
         return ydbp.getId();
     }