处理数据相关的操作过程。

Procedure/backend/project/src/main/java/com/sundata/product/rwa/calc/service/implement/units/GeneralLedgerGetterUnit.java

@@ -47,9 +47,9 @@ public class GeneralLedgerGetterUnit extends CalcUnit {
         boolean isMaster = false;
         boolean isNow = false;
         try {
-            isHis = !StrUtil.equals("0", (DBExecutor.doQuery("select count(1) as counts from RWA_LEART_INS_LEDGRESULT" + FinalStrs._ALLHIS + " from CALCINDEX = '" + calculateInstanceNumber + "'")));
-            isMaster = !StrUtil.equals("0", (DBExecutor.doQuery("select count(1) as counts from RWA_LEART_INS_LEDGRESULT" + FinalStrs._MASTER + " from CALCINDEX = '" + calculateInstanceNumber + "'")));
-            isNow = !StrUtil.equals("0", (DBExecutor.doQuery("select count(1) as counts from RWA_LEART_INS_LEDGRESULT from CALCINDEX = '" + calculateInstanceNumber + "'")));
+            isHis = !StrUtil.equals("0", (DBExecutor.doQuery("select count(1) as counts from RWA_LEART_INS_LEDGRESULT" + FinalStrs._ALLHIS + " where CALCINDEX = '" + calculateInstanceNumber + "'")));
+            isMaster = !StrUtil.equals("0", (DBExecutor.doQuery("select count(1) as counts from RWA_LEART_INS_LEDGRESULT" + FinalStrs._MASTER + " where CALCINDEX = '" + calculateInstanceNumber + "'")));
+            isNow = !StrUtil.equals("0", (DBExecutor.doQuery("select count(1) as counts from RWA_LEART_INS_LEDGRESULT where CALCINDEX = '" + calculateInstanceNumber + "'")));
         } catch (Exception e) {
             log.warn("若首次运行，且没有进行初始化操作，MASTER 与 ALLHIS 表会自动创建，无需处理");
             log.error(e.getMessage());
@@ -127,7 +127,7 @@ public class GeneralLedgerGetterUnit extends CalcUnit {
         sqlParam.addValue("ORGCODE", "000000");// TODO 找不到对应科目的法人机构号
 
 
-        String deleteSql = "delete from rwa_apm_bus_rs_ledgergeneral where CALCINDEX = :CALCINDEX";
+        String deleteSql = "delete from rwa_apm_bus_rs_ledgergeneral where TERM = :TERM";
 
         jdbcTemplate.update(deleteSql, sqlParam);
 

Procedure/backend/project/src/main/java/com/sundata/product/rwa/calc/service/implement/units/GeneralLedgerUnit.java

@@ -87,17 +87,17 @@ public class GeneralLedgerUnit extends CalcUnit {
         String TERM = context.get("TERM").toString();
         // 计算之后，将数据复制到对应的 master与 allhis 表中
         // 总分勾稽规则定义表
-        UnitStaticFun.handleTableDataInsertByCalcNum("RWA_OBJ_CONF_GL_RECONCILIATION",FinalStrs._ALLHIS,CALCINDEX);
-        UnitStaticFun.handleTableDataInsertByCalcNum("RWA_OBJ_CONF_GL_RECONCILIATION",FinalStrs._MASTER,TERM);
+        UnitStaticFun.handleTableDataInsertByCalcNum("RWA_OBJ_CONF_GL_RECONCILIATION", FinalStrs._ALLHIS, CALCINDEX);
+        UnitStaticFun.handleTableDataInsertByCalcNum("RWA_OBJ_CONF_GL_RECONCILIATION", FinalStrs._MASTER, TERM);
         // 差异容忍度规则定义
-        UnitStaticFun.handleTableDataInsertByCalcNum("RWA_CALC_CONF_DIFFTOLERANCE",FinalStrs._ALLHIS,CALCINDEX);
-        UnitStaticFun.handleTableDataInsertByCalcNum("RWA_CALC_CONF_DIFFTOLERANCE",FinalStrs._MASTER,TERM);
+        UnitStaticFun.handleTableDataInsertByCalcNum("RWA_CALC_CONF_DIFFTOLERANCE", FinalStrs._ALLHIS, CALCINDEX);
+        UnitStaticFun.handleTableDataInsertByCalcNum("RWA_CALC_CONF_DIFFTOLERANCE", FinalStrs._MASTER, TERM);
         // 总账勾稽结果表
-        UnitStaticFun.handleTableDataInsertByCalcNum("RWA_LEART_INS_LEDGRESULT",FinalStrs._ALLHIS,CALCINDEX);
-        UnitStaticFun.handleTableDataInsertByCalcNum("RWA_LEART_INS_LEDGRESULT",FinalStrs._MASTER,TERM);
+        UnitStaticFun.handleTableDataInsertByCalcNum("RWA_LEART_INS_LEDGRESULT", FinalStrs._ALLHIS, CALCINDEX);
+        UnitStaticFun.handleTableDataInsertByCalcNum("RWA_LEART_INS_LEDGRESULT", FinalStrs._MASTER, TERM);
         // 总账差异结果表
-        UnitStaticFun.handleTableDataInsertByCalcNum("RWA_APM_BUS_RS_ACCADJUSTMENT",FinalStrs._ALLHIS,CALCINDEX);
-        UnitStaticFun.handleTableDataInsertByCalcNum("RWA_APM_BUS_RS_ACCADJUSTMENT",FinalStrs._MASTER,TERM);
+        UnitStaticFun.handleTableDataInsertByCalcNum("RWA_APM_BUS_RS_ACCADJUSTMENT", FinalStrs._ALLHIS, CALCINDEX);
+        UnitStaticFun.handleTableDataInsertByCalcNum("RWA_APM_BUS_RS_ACCADJUSTMENT", FinalStrs._MASTER, TERM);
 
     }
 
@@ -147,8 +147,8 @@ public class GeneralLedgerUnit extends CalcUnit {
         List<DiffconfigListModel> diffconfigListModels = diffconfigListService.rule_querylist(new DiffconfigListModel());
         Map<String, DiffconfigListModel> subjectDiffConfig = new HashMap<>();
 
-        jdbcTemplate.update("delete from rwa_apm_bus_rs_accadjustment where CALCINDEX = :CALCINDEX",sqlParam);
-        jdbcTemplate.update("delete from rwa_leart_ins_ledgresult where CALCINDEX = :CALCINDEX",sqlParam);
+        jdbcTemplate.update("delete from rwa_apm_bus_rs_accadjustment where CALCINDEX = :CALCINDEX", sqlParam);
+        jdbcTemplate.update("delete from rwa_leart_ins_ledgresult where CALCINDEX = :CALCINDEX", sqlParam);
         // 初始化 风险暴露分类
         List<Map<String, Object>> riskTypeList = jdbcTemplate.query("select CALCINDEX, SDATE, EDATE, TERM, DATA_DATE, RISKEXPOSURE_NO, RISKEXPOSURE_NAME,RISKEXPOSURE_STAGE_ID, DEFAULT_OUT, RISKEXPOSURE_INDEX, RISKEXPOSURE_SUPER,RISKEXPOSURE_ISMINI, RISKEXPOSURE_WEIGHT, RISKEXPOSURE_STATE from RWA_CALC_CONF_RISKEXPOSURE", new UpperMapRowMapper());
         Map<String, RiskExposureDefinitionModel> riskExposureDefinitionModelMap = new HashMap<>();
@@ -375,7 +375,8 @@ public class GeneralLedgerUnit extends CalcUnit {
             String insertLedgresult = "insert into rwa_leart_ins_ledgresult (CALCINDEX, SDATE, EDATE, TERM, DATA_DATE, ORGCODE, RULE_ID, RULE_NAME, SUBJCODE, SUBJNAME, CCY, GLAMT, LEDGARTAMT, DIFFERAMT, DIFFERRATE, PERCTHRESHOLD, LEARTRESULTTYPE, OFFSETDIFFERAMT) " +
                     "values (:CALCINDEX, :SDATE, :EDATE, :TERM, :DATA_DATE, :ORGCODE, :RULE_ID, :RULE_NAME, :SUBJCODE, :SUBJNAME, :CCY, :GLAMT, :LEDGARTAMT, :DIFFERAMT, :DIFFERRATE, :PERCTHRESHOLD, :LEARTRESULTTYPE, :OFFSETDIFFERAMT)";
             jdbcTemplate.update(insertLedgresult, sqlParam);
-            thisResult.put(this.getCalcCode(),"计算完成");
+
         }
+        thisResult.put(this.getCalcCode(), "计算完成");
     }
 }