黑名单实时每日早上6点导入近5天没的数据

src/main/java/cn/quantgroup/qgblservice/constant/Constant.java

@@ -31,7 +31,7 @@ public class Constant {
         public static String XYQB_QUERY_USER_MAX_OVERDUE_SQL = "select max(if(repayment_status=3,DATEDIFF(repaid_at,deadline)+1,DATEDIFF(CURDATE(),deadline)+1)) max_overdue_days from repayment_plan where user_id in (%s) and deadline<=CURDATE() and (repayment_status not in (3,4) or (repayment_status=3 and repaid_at>=deadline));";
 
 
-        public static String XYQB_USER_QUERY_USER_DETAIL_INFO_SQL = "select c.id, c.uuid uuid, b.name, c.phone_no phoneNo, b.id_no idNo from user_detail b left join user c on b.user_id=c.id where b.user_id=%s';";
+        public static String XYQB_USER_QUERY_USER_DETAIL_INFO_SQL = "select c.id, c.uuid uuid, b.name, c.phone_no phoneNo, b.id_no idNo from user_detail b left join user c on b.user_id=c.id where b.user_id='%s';";
         public static String XYQB_USER_QUERY_USER_DETAIL_BY_PHONE_NO_SQL = "select user_id from user a left join user_detail b on a.id=b.user_id where b.phone_no='%s';";
         public static String XYQB_USER_QUERY_USER_DETAIL_BY_ID_NO_SQL = "select user_id from user a left join user_detail b on a.id=b.user_id where b.id_no='%s';";
         public static String XYQB_USER_QUERY_USER_DETAIL_BY_UUID_SQL = "select user_id from user a left join user_detail b on a.id=b.user_id where a.uuid = '%s'";

src/main/java/cn/quantgroup/qgblservice/controller/BlackListImportManagerController.java

@@ -54,4 +54,10 @@ public class BlackListImportManagerController {
         return GlobalResponse.success();
     }
 
+    @RequestMapping("/black_list_real_time_test")
+    public GlobalResponse blackListRealTimeTest(){
+        iBlackListManagerService.blackListRealTimeManagerByDay();
+        return GlobalResponse.success();
+    }
+
 }

src/main/java/cn/quantgroup/qgblservice/repository/mybatis/entity/blacklist/test.java

-package cn.quantgroup.qgblservice.repository.mybatis.entity.blacklist;
-
-/**
- * @Author fengjunkai
- * @Date 2019-07-02 14:50
- */
-public class test {
-}

src/main/java/cn/quantgroup/qgblservice/repository/mybatis/entity/xyqbuser/test.java

-package cn.quantgroup.qgblservice.repository.mybatis.entity.xyqbuser;
-
-/**
- * @Author fengjunkai
- * @Date 2019-07-02 14:50
- */
-public class test {
-}

src/main/java/cn/quantgroup/qgblservice/repository/mybatis/mapper/blacklist/test.java

-package cn.quantgroup.qgblservice.repository.mybatis.mapper.blacklist;
-
-/**
- * @Author fengjunkai
- * @Date 2019-07-02 14:50
- */
-public interface test {
-}

src/main/java/cn/quantgroup/qgblservice/service/impl/BlackListManagerServiceImpl.java

@@ -68,8 +68,9 @@ public class BlackListManagerServiceImpl implements IBlackListManagerService {
         }
 
         if (CollectionUtils.isNotEmpty(blackListQueryTidbVo0s)) {
+            Stopwatch stopwatch = Stopwatch.createStarted();
             int batchExecuteResult = JdbcExecuters.blackListImportBatchExecute(blackListQueryTidbVo0s, Constant.SQL.BLACK_LIST_NEW_BATCH_INSERT_BLACK_THREE_ELE_LIST_SQL, blackListJdbcTemplate, Constant.BATCH_TYPE.BATCH_IDCARDS_MONTH);
-            log.info("每日定时导入近5天逾期15+的用户黑名单完成, 查询大小: {} , 入库大小: {} ", userLoanOverdue15DaysLists.size(), batchExecuteResult);
+            log.info("每日定时导入近5天逾期15+的用户黑名单完成, 查询大小: {} , 入库大小: {} , 耗时: {} ", userLoanOverdue15DaysLists.size(), batchExecuteResult, stopwatch.stop().elapsed(TimeUnit.MILLISECONDS));
         }
     }