处理最新表数据重复出现的情况

Procedure/backend/project/src/main/java/com/sundata/product/rwa/calc/service/ReportCalcService.java

@@ -68,8 +68,8 @@ public class ReportCalcService {
         String TERM = context.get("TERM").toString();
         String DATA_DATE = context.get("DATA_DATE").toString();
 
-        jdbcTemplate.update("delete from RWA_SYSTEM_REPORT_PROCESS_TABLE where CALCINDEX = :CALCINDEX", sqlParam);
-        jdbcTemplate.update("delete from RWA_SYSTEM_REPORT_PROCESS_TABLEUNIT where CALCINDEX = :CALCINDEX", sqlParam);
+        jdbcTemplate.update("truncate table RWA_SYSTEM_REPORT_PROCESS_TABLE ", sqlParam);
+        jdbcTemplate.update("truncate table RWA_SYSTEM_REPORT_PROCESS_TABLEUNIT ", sqlParam);
 
         List<ReportDefinitionModel> reportParamDefineModels = service.getDataList(new ReportDefinitionModel());
         context.putAll(reportParam);

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

@@ -131,7 +131,7 @@ public class GeneralLedgerGetterUnit extends CalcUnit {
         sqlParam.addValue("ORGCODE", "000000");// TODO 找不到对应科目的法人机构号
 
 
-        String deleteSql = "delete from rwa_apm_bus_rs_ledgergeneral where TERM = :TERM";
+        String deleteSql = "truncate table rwa_apm_bus_rs_ledgergeneral";
 
         jdbcTemplate.update(deleteSql, sqlParam);
 

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

@@ -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("truncate table rwa_apm_bus_rs_accadjustment ", sqlParam);
+        jdbcTemplate.update("truncate table rwa_leart_ins_ledgresult ", 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<>();