浏览代码

更新补录终审 增加晋商需要修改的内容。

CodeLife Leno 2 周之前
父节点
当前提交
616314dd74

+ 3 - 4
Procedure/backend/project/src/main/java/com/sundata/product/tempFile/task/flow/WorkFlow0001Service.java

@@ -4,11 +4,9 @@ import cn.hutool.core.date.DateUtil;
 import com.sundata.admin.AdminUtil;
 import com.sundata.admin.nounmanage.model.DictTree;
 import com.sundata.admin.nounmanage.service.NounManageService;
-import com.sundata.common.exception.BusinessException;
 import com.sundata.common.exception.ServiceException;
 import com.sundata.common.login.ActiveUser;
 import com.sundata.common.util.DBExecutor;
-import com.sundata.common.util.LogUtil;
 import com.sundata.product.taskExecute.service.KingBase2GBaseService;
 import com.sundata.product.taskExecute.service.TaskAllExecuteServer;
 import com.sundata.product.tempFile.task.model.*;
@@ -40,6 +38,8 @@ public class WorkFlow0001Service extends AWorkFlowService {
 
     @Autowired
     KingBase2GBaseService kingBase2GBaseService;
+    @Autowired
+    TaskAllExecuteServer executeServer;
 
     @Override
     public void afterStartOfStartRun(String businessinsid, String busstatime, Object businessData)
@@ -177,7 +177,6 @@ public class WorkFlow0001Service extends AWorkFlowService {
         LOG.debug("流程:{},审核中", businessinsid);
     }
 
-
     @Override
     /**
      * 流程提交调用方法---
@@ -314,7 +313,7 @@ public class WorkFlow0001Service extends AWorkFlowService {
 //
 //            }
 //        });
-        // TODO 确定表,如果有多张表则添加行 ,数据库连接池用的是自动提交。
+        // TODO 晋商需要修改 确定表,如果有多张表则添加行 ,数据库连接池用的是自动提交。
         kingBase2GBaseService.doExecute("GBaseDB","");
 //        String counts = DBExecutor.doQuery("select count(1) from sys_input_suptaskrun_taskallstatus where term = '" + businfo.getTerm() + "' and isover = '0'");
 //        if ("0".equals(counts)) {

+ 1 - 0
Procedure/backend/project/src/main/java/com/sundata/product/tempFile/task/service/ImportTaskBussinessService.java

@@ -616,6 +616,7 @@ public class ImportTaskBussinessService {
                 LOG.debug("其他的暂不处理!!!");
             }
         }
+        // TODO 晋商需要修改,需要处理此处的执行逻辑
         String deleteSql = "delete from sys_imput_suptaskRun_finalIndexData a where term = '${term}'";
         String insertSql = "insert into sys_imput_suptaskRun_finalIndexData(taskbussinessid,flowbussinessid,taskcode,startDate,term,termDT,indexcode, " +
                 "cpvalue,baorfichanges,oeorlevel,raftnextstage,orgcode ,cpvalTypeName , cpValueName) " +