处理飞鱼同步数据的时间

manage/ad-platform-management/src/main/java/com/baiye/modules/system/service/impl/TaskServiceImpl.java

@@ -188,7 +188,10 @@ public class TaskServiceImpl implements TaskService {
         }
         taskRepository.save(task);
         String key = "task:encryption:" + taskId;
-        redisUtils.del(key);
+//        redisUtils.del(key);
+        if (!redisUtils.hasKey(key)) {
+            redisUtils.set(key, task.getIsEncryption() + "", 2592000);
+        }
     }
 
     /**

services/ad-platform-source/src/main/java/com/baiye/task/OceanEngineSync.java

@@ -86,8 +86,9 @@ public class OceanEngineSync {
             return;
         }
         Date currentTime = DateUtil.date();
-        Date startTime = DateUtil.offsetMinute(currentTime, 1);
-        Date endTime = DateUtil.offsetMinute(currentTime, 30);
+        Date startTime = DateUtil.beginOfMinute(DateUtil.offsetMinute(currentTime, -15));
+        Date endTime = DateUtil.endOfMinute(DateUtil.offsetMinute(currentTime, -1));
+        log.info("查询时间==当前时间={},开始时间={},结束时间={}", currentTime, startTime, endTime);
         Map<String, Object> map = new HashMap<>(5);
         map.put("advertiser_ids", advertiseList);
         map.put("start_time", startTime.toString());
@@ -100,7 +101,6 @@ public class OceanEngineSync {
         parseAndSaveData(userId, taskId, array);
         log.info("同步成功==========");
     }
-
     /**
      * 解析线索
      *

services/ad-platform-source/src/main/resources/application.yml

@@ -10,7 +10,7 @@ spring:
   freemarker:
     check-template-location: false
   profiles:
-    active: dev
+    active: test
   application:
     name: @artifactId@
   jackson: