[task-1449] 风险管理功能重构 / 风险控制后续降低风险登记记录表流程开启、风险改进记录表流程接口开启

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

@@ -0,0 +1,48 @@
+package com.lc.ibps.platform.plan.job;
+
+import com.lc.ibps.base.core.util.AppUtil;
+import com.lc.ibps.base.framework.table.ICommonDao;
+import com.lc.ibps.components.quartz.BaseJob2;
+import org.quartz.JobExecutionContext;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.List;
+import java.util.Map;
+
+public class RiskIdentificationJob extends BaseJob2 {
+
+    private static final Logger logger = LoggerFactory.getLogger(RiskIdentificationJob.class);
+    private ICommonDao<?> commonDao = AppUtil.getBean(ICommonDao.class);
+
+    @Override
+    public void executeJob(JobExecutionContext context) throws Exception {
+        //step1: update status
+        updateStatusStep();
+        //step2. add data to 降低风险项目登记表_子表（djbzb）
+        addDateToDjbzbStep();
+        //step3. start flow by djbzb id
+        startFlowStep();
+    }
+
+    private void startFlowStep() {
+    }
+
+    private void addDateToDjbzbStep() {
+        String fetchSql = "SELECT c.id_,a.zong_id_ AS parent_id_,c.di_dian_,b.bian_zhi_ren_,b.bian_zhi_bu_men_,c.yao_su_tiao_kuan_," +
+                " c.gong_zuo_huan_jie,c.gong_zuo_miao_shu,c.feng_xian_miao_sh,c.feng_xian_zhi_shu " +
+                " FROM t_fxssb a,t_fxsbpgb b,t_fxsbpgbzb c " +
+                " WHERE a.zong_id_=b.zong_id_ AND a.zhuang_tai_='已识别' AND b.id_=c.parent_id_ AND feng_xian_ying_du='风险降低'";
+    }
+
+    private void updateStatusStep() {
+        String fetchSql = "SELECT id_ FROM t_fxssb a " +
+                " WHERE shi_fou_guo_shen_ = '已完成' AND zhuang_tai_ = '' AND zong_id_  NOT IN (" +
+                " SELECT zong_id_ FROM t_fxsbpgb WHERE shi_fou_guo_shen_ <>'已完成' )";
+
+        String execSql = "UPDATE t_fxssb SET zhuang_tai_='已识别' WHERE id_=#{id_}";
+        List<Map<String, Object>> list = (List<Map<String, Object>>) commonDao.query(fetchSql);
+        commonDao.executeOfMaps(execSql,list);
+
+    }
+}