rick user filter

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/xxl/RickUserCacheJob.java

@@ -38,7 +38,7 @@ public class RickUserCacheJob {
         // 执行 ODPS Sql，获取数据
         Pair<List<String>, List<String>> pairs = queryRiskUser();
         if (pairs == null) {
-            XxlJobLogger.log("updateNotUserUploadUserCache, uids is empty");
+            XxlJobLogger.log("updateRiskUserCache, data is empty");
             return ReturnT.SUCCESS;
         }
         List<String> uids = pairs.getLeft();
@@ -47,7 +47,7 @@ public class RickUserCacheJob {
                 @Override
                 public <K, V> String execute(RedisOperations<K, V> redisOperations) throws DataAccessException {
                     redisOperations.delete((K) RedisKeyConstants.Recommend.riskUserUid);
-                    ((SetOperations<String, String>)redisOperations.opsForSet()).add(RedisKeyConstants.Recommend.riskUserUid,
+                    ((SetOperations<String, String>) redisOperations.opsForSet()).add(RedisKeyConstants.Recommend.riskUserUid,
                             uids.toArray(new java.lang.String[uids.size()]));
                     return null;
                 }
@@ -60,7 +60,7 @@ public class RickUserCacheJob {
                 @Override
                 public <K, V> String execute(RedisOperations<K, V> redisOperations) throws DataAccessException {
                     redisOperations.delete((K) RedisKeyConstants.Recommend.riskUserMid);
-                    ((SetOperations<String, String>)redisOperations.opsForSet()).add(RedisKeyConstants.Recommend.riskUserMid,
+                    ((SetOperations<String, String>) redisOperations.opsForSet()).add(RedisKeyConstants.Recommend.riskUserMid,
                             mids.toArray(new java.lang.String[mids.size()]));
                     return null;
                 }
@@ -71,7 +71,8 @@ public class RickUserCacheJob {
     }
 
     private Pair<List<String>, List<String>> queryRiskUser() {
-        String sql = "SELECT uid,mid FROM loghubods.wx_review_staff_list WHERE dt = MAX_PT('loghubods.wx_review_staff_list')";
+        String sql = "SELECT uid,mid FROM loghubods.wx_review_staff_list WHERE dt = MAX_PT('loghubods" +
+                ".wx_review_staff_list');";
         List<Record> records = odpsManager.query(sql);
         if (records == null || records.size() == 0) {
             return null;