调整分区格式

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

@@ -50,7 +50,13 @@ public class RickVideoCacheJob {
         XxlJobLogger.log("updateRiskVideoCacheHandler start...");
         try {
             //1. 从大数据读取数据 最大不超过10万条
-            String dt = "MAX_PT('" + PROJECT + "." + riskVideoTable + "')";
+//            String dt = "MAX_PT('" + PROJECT + "." + riskVideoTable + "')";
+            String dt = new SimpleDateFormat("yyyyMMddHH").format(new Date());
+            //支持手动指定分区
+            if (Objects.nonNull(params) && !Objects.equals("", params.trim())) {
+                dt = params;
+            }
+            XxlJobLogger.log("dt = {}", dt);
             List<Record> records = odpsManager.tableTunnelQuery(PROJECT, riskVideoTable, "dt=" + dt);
             if (Objects.isNull(records) || records.isEmpty()) {
                 XxlJobLogger.log("records is empty");