短剧APP归因

src/main/java/com/lwby/marketing/att/dyvideo/DyVideoUniversalProcess.java

@@ -107,6 +107,12 @@ public class DyVideoUniversalProcess extends UniversalProcess {
                 : String.format("fc_%d_%d_%s", action.getUserId(), action.getPlatformId(),action.getMediaName());
     }
 
+    public int getExpire(StoryNovelAction action) {
+        return Objects.equals(action.getType(), CallBackType.active.getType())
+                ? 60 * 60 * 24
+                : 60 * 60 * 24 * 7;
+    }
+
     public ThirdAccountDy getDyAccessToken(String client_id, String client_secret,String dyTokenUrl) {
         Map<String,String> upMap = new HashMap<>();
         upMap.put("client_key",client_id);

src/main/java/com/lwby/marketing/att/dyvideo/handle/DyvideoDeduFlow.java

@@ -65,7 +65,7 @@ public class DyvideoDeduFlow extends NodeSwitchFlow<StoryNovelAction> {
                     action.getPlatformId(), action.getChannelId(),action.getPlanId(), sprDedu, channelTotalCount, channelCallbackCount, 1);
         } else {
             up.notifyResult(action,"ocpc_behavior_test", AttributionStatus.NORMAL_DEDUCTION_CALLBACK);
-            up.set(up.getFirstCheckerKey(action),60 * 60 * 24,"1");
+            up.set(up.getFirstCheckerKey(action), up.getExpire(action), "1");
             DYVIDEO_SYS_LOG.info(
                     "ChannelAttributionFlow.process0.deduction doing dynamic, platformId = {}, channel = {}, planId={}, sprDedu = {}, channelTotalCount = {}, channelCallbackCount = {}, v = {}",
                     action.getPlatformId(), action.getChannelId(),action.getPlanId(), sprDedu, channelTotalCount, channelCallbackCount, 0);

src/main/java/com/lwby/marketing/att/dyvideo/handle/UploadDyVideoCallFlow.java

@@ -26,7 +26,7 @@ public class UploadDyVideoCallFlow extends NodeFlow<StoryNovelAction> {
         if (success) {
             action.getVideoUpload().setActiveTime(System.currentTimeMillis());
             up.notifyResult(action, type.getTopic()+"_test",type.getStatus());
-            up.set(up.getFirstCheckerKey(action),60 * 60 * 24,"1");
+            up.set(up.getFirstCheckerKey(action),up.getExpire(action),"1");
         }
     }
 }

src/main/java/com/lwby/marketing/att/videoapp/VideoAppUniversalProcess.java

@@ -102,6 +102,12 @@ public class VideoAppUniversalProcess extends UniversalProcess {
                 : String.format("fc_%d_%d_%s", action.getDeviceId(), action.getPlatformId(),action.getMediaName());
     }
 
+    public int getExpire(NovelAction action) {
+        return Objects.equals(action.getType(), CallBackType.active.getType())
+                ? 60 * 60 * 24
+                : 60 * 60 * 24 * 7;
+    }
+
     public String buildKey(Integer platformId,String deviceId) {
         return String.format("market:activeness:30:%d:%s",platformId,deviceId);
     }

src/main/java/com/lwby/marketing/att/videoapp/handle/UploadVideoAppCallFlow.java

@@ -25,7 +25,7 @@ public class UploadVideoAppCallFlow extends NodeFlow<NovelAction> {
         boolean success = action.getMedia().notify(action);
         if (success) {
             up.notifyResult(action, type.getTopic()+"_test",type.getStatus());
-            up.set(up.getFirstCheckerKey(action),60 * 60 * 24,"1");
+            up.set(up.getFirstCheckerKey(action), up.getExpire(action), "1");
         }
     }
 }