检测tidb的call_record表数据是否有重复数据工具

src/main/java/cn/quantgroup/report/service/baihang/BaiHangZhuDaiService.java

@@ -392,9 +392,18 @@ public class BaiHangZhuDaiService {
                     String reqId_log = repaymentLoanInfo.getReqID();
                     try {
                         RepaymentInfoZhuDai repaymentLoanInfo1 = repaymentLoanInfoDbMapper.findLastOne(BaiHangRepayment.builder().loanId(repaymentLoanInfo.getLoanId()).termNo(repaymentLoanInfo.getTermNo()).build());
-                        if (j > 0 && Objects.nonNull(repaymentLoanInfo1)) {
+                        if (j > 0 && Objects.nonNull(repaymentLoanInfo1)) {//逾期的，跳过
                             tg_atomicInt.getAndIncrement();
-                            log.info("量化派助贷TO百行报送-实时还款逾期跳过报送, reqId_log: {} , loanId: {} , termNo: {} , startnyr: {} , endnyr: {} , bean: {} , param: {} ", reqId_log, repaymentLoanInfo.getLoanId(), repaymentLoanInfo.getTermNo(), startnyr, endnyr, JSON.toJSONString(repaymentLoanInfo1),JSON.toJSONString(repaymentLoanInfo));
+                            log.info("量化派助贷TO百行报送-实时还款逾期跳过报送, reqId_log: {} , loanId: {} , termNo: {} , startnyr: {} , endnyr: {} , bean: {} ", reqId_log, repaymentLoanInfo.getLoanId(), repaymentLoanInfo.getTermNo(), startnyr, endnyr, JSON.toJSONString(repaymentLoanInfo1));
+
+                            //----------2020.02.02 保存跳过的数据，用于以后补全
+                            try{
+                                FileUtils.write(new File("/home/quant_group/baihang-report/data/baihang/D3/yuqi_tg/"+startnyr+"_"+endnyr+".json"),
+                                        JSON.toJSONString(repaymentLoanInfo)+"\r\n", "UTF-8", true);
+                            }catch (Exception e){
+                                log.error("量化派助贷TO百行报送-实时逾期跳过, Json数据保存文件异常,",e);
+                            }
+
                             continue;
                         }
                         totail_atomicInt.getAndIncrement();