[task-1677] 风险管理功能重构 / 风险评估报告流程接口开启

ibps-provider-root/modules/provider-platform/src/main/java/com/lc/ibps/platform/plan/job/RiskIdentificationJob.java

@@ -22,6 +22,7 @@ public class RiskIdentificationJob extends AbstractJob {
         updateStatusToShibieStep();
         //step2. add data to 降低风险项目登记表_子表（djbzb）
         insertRecordsFromTemplate("fxkz_step2");
+
         //step3. 风险改进记录表（bmfxgjjl）
         insertRecordsFromTemplate("fxkz_step3");
         //step4. update status to 改进中
@@ -29,10 +30,31 @@ public class RiskIdentificationJob extends AbstractJob {
         //step5. start flow by djbzb id
         startWorkflow("t_bmfxgjjl","bmfxgjjl", "Process_0jl7e02");
 
-        //step 6.1 创建风险报告
+        //step 6 创建风险报告
         insertRecordsFromTemplate("fxkz_step6");
-        //step 6.2 启动风险报告流程
+        //step 7 update status to 报告编制中
+        updateStatusToBaogaoStep();
+        //step 8 启动风险报告流程
         startWorkflow("t_fxkzbg","fxbg", "Process_0mrlsj7");
+
+        //step 9 update status to 已完成
+        updateStatusToWanchengStep();
+    }
+
+    private void updateStatusToWanchengStep() {
+        String execSql = "UPDATE t_fxssb SET zhuang_tai_='已完成' WHERE zong_id_=#{zong_id_}";
+        List<Map<String, Object>> list = fetchRecords("fxkz_step9_fetch");
+        if (list != null) {
+            commonDao.executeOfMaps(execSql, list);
+        }
+    }
+
+    private void updateStatusToBaogaoStep() {
+        String execSql = "UPDATE t_fxssb SET zhuang_tai_='报告编制中' WHERE zong_id_=#{zong_id_}";
+        List<Map<String, Object>> list = fetchRecords("fxkz_step7_fetch");
+        if (list != null) {
+            commonDao.executeOfMaps(execSql, list);
+        }
     }
 
     private void updateStatusToGaijingStep() {