增加任务频次

src/main/java/com/adx/tencent/honor/store/HonorHotStore.java

@@ -33,7 +33,7 @@ import java.util.concurrent.ConcurrentHashMap;
 public class HonorHotStore {
 
     private static final Logger log = LoggerFactory.getLogger(HonorHotStore.class);
-    private static final Duration IMPRESSION_BID_TTL = Duration.ofHours(1);
+    private static final Duration IMPRESSION_BID_TTL = Duration.ofMinutes(30);
     private static final Duration DEFAULT_CONVERSION_SEEN_TTL = Duration.ofDays(7);
     private static final Duration DEFAULT_DEDUCTION_COUNTER_TTL = Duration.ofDays(7);
 

src/main/java/com/adx/tencent/kuaishou/store/KuaishouHotStore.java

@@ -35,7 +35,7 @@ import java.util.concurrent.ConcurrentHashMap;
 public class KuaishouHotStore {
 
     private static final Logger log = LoggerFactory.getLogger(KuaishouHotStore.class);
-    private static final Duration IMPRESSION_BID_TTL = Duration.ofHours(1);
+    private static final Duration IMPRESSION_BID_TTL = Duration.ofMinutes(30);
     private static final Duration DEFAULT_CONVERSION_SEEN_TTL = Duration.ofDays(7);
     private static final Duration DEFAULT_DEDUCTION_COUNTER_TTL = Duration.ofDays(7);
 

src/main/java/com/adx/tencent/oppo/store/OppoHotStore.java

@@ -36,7 +36,7 @@ import java.util.concurrent.ConcurrentHashMap;
 public class OppoHotStore {
 
     private static final Logger log = LoggerFactory.getLogger(OppoHotStore.class);
-    private static final Duration IMPRESSION_BID_TTL = Duration.ofHours(1);
+    private static final Duration IMPRESSION_BID_TTL = Duration.ofMinutes(30);
     private static final Duration DEFAULT_CONVERSION_SEEN_TTL = Duration.ofDays(7);
     private static final Duration DEFAULT_DEDUCTION_COUNTER_TTL = Duration.ofDays(7);
 

src/main/java/com/adx/tencent/storage/RedisHotStore.java

@@ -27,7 +27,7 @@ public class RedisHotStore {
 
     private static final Logger log = LoggerFactory.getLogger(RedisHotStore.class);
     public static final String BID_NOT_FOUND_MSG = "bid not found";
-    private static final Duration IMPRESSION_BID_TTL = Duration.ofHours(1);
+    private static final Duration IMPRESSION_BID_TTL = Duration.ofMinutes(30);
     private static final Duration DEFAULT_CONVERSION_SEEN_TTL = Duration.ofDays(7);
     private static final Duration DEFAULT_DEDUCTION_COUNTER_TTL = Duration.ofDays(7);
 

src/main/java/com/adx/tencent/vivo/store/VivoHotStore.java

@@ -35,7 +35,7 @@ import java.util.concurrent.ConcurrentHashMap;
 public class VivoHotStore {
 
     private static final Logger log = LoggerFactory.getLogger(VivoHotStore.class);
-    private static final Duration IMPRESSION_BID_TTL = Duration.ofHours(1);
+    private static final Duration IMPRESSION_BID_TTL = Duration.ofMinutes(30);
     private static final Duration DEFAULT_CONVERSION_SEEN_TTL = Duration.ofDays(7);
     private static final Duration DEFAULT_DEDUCTION_COUNTER_TTL = Duration.ofDays(7);
 

src/test/java/com/adx/tencent/oppo/store/OppoHotStoreTest.java

@@ -51,10 +51,10 @@ class OppoHotStoreTest {
 
     @Test
     @SuppressWarnings({"rawtypes", "unchecked"})
-    void impressionCachesAreSmallAndExpireInThreeHoursButStreamKeepsFullEvent() throws Exception {
+    void impressionCachesAreSmallAndExpireInThirtyMinutesButStreamKeepsFullEvent() throws Exception {
         OppoBidRecord record = record();
         store(Duration.ofHours(36)).recordBid(record);
-        JsonNode hot = cachePayload(Duration.ofHours(3));
+        JsonNode hot = cachePayload(Duration.ofMinutes(30));
         assertEquals("click-url", hot.get("clickUrls").get(0).asText());
         assertEquals("store-url", hot.get("appStoreLink").asText());
         assertFalse(hot.has("showUrls"));