还款&逾期方法优化

src/main/java/cn/quantgroup/report/job/QuantGroupZhuDaiReportToBaiHang.java

@@ -46,7 +46,8 @@ public class QuantGroupZhuDaiReportToBaiHang {
     private DingTalk dingTalk;
 
     @Async
-    @Scheduled(cron = "0 0 05 * * ?")
+    //@Scheduled(cron = "0 0 05 * * ?")
+    @Scheduled(cron = "0 0 04 * * ?")
     public void startZhuDaiReport(){
         if(increment()){
             redisTemplate.expire(Constant.QG_ZHU_DAI_REPORT_LOCK_KEY, 10, TimeUnit.SECONDS);

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

@@ -407,19 +407,17 @@ public class BaiHangZhuDaiService {
                     log.info("量化派助贷TO百行报送-联合贷实时还款, startnyr: {} , endnyr: {} , 大小: {} , 耗时: {} ", startnyr, endnyr, repaymentLoanInfosLh.size(), (realTimeStopWatch2.stop().elapsed(TimeUnit.MILLISECONDS) / 1000) + ".s");
 
                 } else {
-                    /* 2020.06.18 暂时先注掉，补报 2020-06-11到2020-06-18的还款
                     Stopwatch realTimeOverdueStopWatch3 = Stopwatch.createStarted();
-                    //repaymentLoanInfos = repaymentLoanInfoMapper.findRealTimeRepayMentOverdue(timeRecord);
+                    repaymentLoanInfos = repaymentLoanInfoMapper.findRealTimeRepayMentOverdue(timeRecord);
                     //2020.06.18 方法findRealTimeRepayMentOverdue用in查询已经慢的查不出，用等于吧
-                    repaymentLoanInfos = this.findRealTimeRepayMentOverdueByFCId(startnyr, endnyr);
+                    //repaymentLoanInfos = this.findRealTimeRepayMentOverdueByFCId(startnyr, endnyr);
 
                     log.info("量化派助贷TO百行报送-非联合贷实时还款逾期, startnyr: {} , endnyr: {} , 大小: {} , 耗时: {} ", startnyr, endnyr, repaymentLoanInfos.size(), (realTimeOverdueStopWatch3.stop().elapsed(TimeUnit.MILLISECONDS) / 1000) + ".s");
 
                     Stopwatch realTimeOverdueStopWatch4 = Stopwatch.createStarted();
                     repaymentLoanInfosLh = repaymentLoanInfoMapper.findRealTimeRepayMentOverdueLh(timeRecord);
                     log.info("量化派助贷TO百行报送-联合贷实时还款逾期, startnyr: {} , endnyr: {} , 大小: {} , 耗时: {} ", startnyr, endnyr, repaymentLoanInfosLh.size(), (realTimeOverdueStopWatch4.stop().elapsed(TimeUnit.MILLISECONDS) / 1000) + ".s");
-                    */
-                    continue;
+
                 }
 
                 if (repaymentLoanInfos == null) {
@@ -517,6 +515,7 @@ public class BaiHangZhuDaiService {
             } catch (Exception e) {
                 log.error("量化派助贷TO百行报送-异常 J: {} , 开始时间: {} , 结束时间: {} ", j, startnyr, endnyr, e);
                 dingTalk.talk("Error","量化派助贷TO百行报送-"+(j==0?"还款":"逾期")+"信息异常", e);
+                dingTalk.talk_ToUser("D3报送失败", "量化派助贷TO百行报送-"+(j==0?"还款":"逾期")+"信息异常,请尽快手动处理!");
             }
         }
         log.info("量化派助贷TO百行报送-实时还款&逾期结束, resMsg: {} ", resMsg);
@@ -2354,6 +2353,7 @@ public class BaiHangZhuDaiService {
                 if(tmpList!=null && tmpList.size()>0){
                     allRepaymentLoanInfo.addAll(tmpList);
                 }
+                Thread.sleep(10 * 60 * 1000); //sleep 10分钟，分钟tidb实例内存满了
             }catch (Exception e){
                 log.error("非联合贷还款-按资方id查询异常, fundingCorpId: {} ", fundingCorpId, e);
                 allRepaymentLoanInfo = null;
@@ -2378,6 +2378,7 @@ public class BaiHangZhuDaiService {
                 if(tmpList!=null && tmpList.size()>0){
                     allRepaymentLoanInfo.addAll(tmpList);
                 }
+                Thread.sleep(10 * 60 * 1000); //sleep 10分钟，分钟tidb实例内存满了
             }catch (Exception e){
                 log.error("非联合贷逾期按资方id查询异常, fundingCorpId: {} ", fundingCorpId, e);
                 allRepaymentLoanInfo = null;

src/main/java/cn/quantgroup/report/utils/dingtalk/DingTalk.java

@@ -77,7 +77,7 @@ public class DingTalk {
             param.put("alarmLevel", "ERROE");//
             param.put("msgTitle", "量化派2百行："+msgTitle);
             param.put("msgContent", msgContent);
-            param.put("toUsers", "18010105506");
+            param.put("toUsers", "18631397041");
             String resp = iHttpService.post(talkUri, param);
             log.info("钉钉报警接口调用结束, resp: {} ", resp);
         }catch (Exception e){