modify

src/main/java/com/lwby/marketing/att/novel/AttributionStatus.java → src/main/java/com/lwby/marketing/att/AttributionStatus.java

-package com.lwby.marketing.att.novel;
+package com.lwby.marketing.att;
 
 public enum AttributionStatus {
     ACTIVE_CALLBACK(2,"激活回传"),

src/main/java/com/lwby/marketing/att/bystory/CallBackType.java

 package com.lwby.marketing.att.bystory;
 
-import com.lwby.marketing.att.novel.AttributionStatus;
+import com.lwby.marketing.att.AttributionStatus;
 
 /**
  * @author songxinyu

src/main/java/com/lwby/marketing/att/bystory/DyStoryUniversalProcess.java

@@ -5,7 +5,7 @@ import com.alicp.jetcache.anno.CacheRefresh;
 import com.alicp.jetcache.anno.CacheType;
 import com.alicp.jetcache.anno.Cached;
 import com.lwby.marketing.att.UniversalProcess;
-import com.lwby.marketing.att.novel.AttributionStatus;
+import com.lwby.marketing.att.AttributionStatus;
 import com.lwby.marketing.att.novel.AttributionType;
 import com.lwby.marketing.vo.DeliveryDeviceInfo;
 import com.lwby.marketing.vo.StoryNovelAction;

src/main/java/com/lwby/marketing/att/bystory/handle/ParameterSetupStoryNovelFlow.java

@@ -39,14 +39,12 @@ public class ParameterSetupStoryNovelFlow extends NodeFlow<StoryNovelAction> {
         StoryLogin storyLogin = up.get(StoryLogin.class,assembleKey(openId));
         action.setStoryLogin(storyLogin);
         
-        //NovelAction对像参数填充
+        //StoryNovelAction对像参数填充
         action.setPlatformId(platformId);
         action.setUserId(action.getUserId());
         action.setCurrentDateStr(DateTimUtils.getCurrentDateString());
-
         action.setChannelId(action.getClientInfo().getChannel());
 
-
         //非商店吊起参数设置
         if (Objects.nonNull(storyLogin)) {
             deliveryDeviceInfo = new DeliveryDeviceInfo();

src/main/java/com/lwby/marketing/att/bystory/handle/PaySpduFlow.java

 package com.lwby.marketing.att.bystory.handle;
 
 import com.alibaba.fastjson.JSON;
-import com.lwby.marketing.att.novel.AttributionStatus;
+import com.lwby.marketing.att.AttributionStatus;
 import com.lwby.marketing.att.novel.AttributionType;
 import com.lwby.marketing.att.bystory.DyStoryUniversalProcess;
 import com.lwby.marketing.flow.NodeSwitchFlow;
@@ -27,18 +27,13 @@ public class PaySpduFlow extends NodeSwitchFlow<StoryNovelAction> {
     @Resource
     DyStoryUniversalProcess up;
 
-    @Override
-    public void process(StoryNovelAction action) {
-        process0(action, AttributionType.CHANNEL);
-    }
-
     @Override
     public boolean checked(StoryNovelAction action) {
         return action.getType() == 2;
     }
 
-    public void process0(StoryNovelAction action, AttributionType type) {
-
+    @Override
+    public void process(StoryNovelAction action) {
         int platformId = action.getPlatformId();
         int channelId = action.getChannelId();
         String shaveMakeCall = up.getAttributeRuleByPlatformIdAndChannelId(platformId,channelId);
@@ -77,9 +72,9 @@ public class PaySpduFlow extends NodeSwitchFlow<StoryNovelAction> {
         }
 
         //总数
-        String channelTotal =  up.getTotalCountKey(type, action.getPlatformId(), action.getChannelId(),goodId, sprDedu, action.getCurrentDateStr());
+        String channelTotal =  up.getTotalCountKey(AttributionType.CHANNEL, action.getPlatformId(), action.getChannelId(),goodId, sprDedu, action.getCurrentDateStr());
         //回传
-        String channelCallback = up.getCallbackCountKey(type, action.getPlatformId(), action.getChannelId(),goodId, sprDedu, action.getCurrentDateStr());
+        String channelCallback = up.getCallbackCountKey(AttributionType.CHANNEL, action.getPlatformId(), action.getChannelId(),goodId, sprDedu, action.getCurrentDateStr());
 
         long channelTotalCount = up.incrby(channelTotal, 0, 60 * 60 * 24);
         long channelCallbackCount = up.incrby(channelCallback, 0, 60 * 60 * 24);
@@ -99,7 +94,6 @@ public class PaySpduFlow extends NodeSwitchFlow<StoryNovelAction> {
                     "PaySpduFlow.process0.deduction doing dynamic, platformId = {}, channel = {}, sprDedu = {}, goodId = {}, channelTotalCount = {}, channelCallbackCount = {}, v = {}",
                     platformId, channelId, sprDedu, goodId, channelTotalCount, channelCallbackCount, 0);
         }
-
     }
 
     private boolean isCallback(long channelTotalCount, long channelCallbackCount, Integer sprDedu) {

src/main/java/com/lwby/marketing/att/bystory/handle/StoreDyStoryAttributionFlow.java

 package com.lwby.marketing.att.bystory.handle;
 
-import com.lwby.marketing.att.novel.AttributionStatus;
+import com.lwby.marketing.att.AttributionStatus;
 import com.lwby.marketing.att.bystory.CallBackType;
 import com.lwby.marketing.att.bystory.DyStoryUniversalProcess;
 import com.lwby.marketing.flow.NodeFlow;

src/main/java/com/lwby/marketing/att/bystory/handle/UploadCallFlow.java

@@ -20,15 +20,11 @@ public class UploadCallFlow extends NodeFlow<StoryNovelAction> {
 
     @Override
     public void process(StoryNovelAction action) {
-        process0(action, CallBackType.getCallBackTypeByType(action.getType()));
+        CallBackType type = CallBackType.getCallBackTypeByType(action.getType());
 
-    }
-
-    private void process0(StoryNovelAction action, CallBackType callBackTypeByType) {
         boolean success = action.getMedia().notify(action);
         if (success) {
-            up.notifyResult(action, callBackTypeByType.getTopic(),
-                    callBackTypeByType.getStatus());
+            up.notifyResult(action, type.getTopic(),type.getStatus());
             up.set(up.getFirstCheckerKey(action),60 * 60 * 24,"1");
         }
     }

src/main/java/com/lwby/marketing/att/novel/NovelUniversalProcess.java

 package com.lwby.marketing.att.novel;
 
 import com.alibaba.fastjson.JSONObject;
+import com.lwby.marketing.att.AttributionStatus;
 import com.lwby.marketing.att.UniversalProcess;
 import com.lwby.marketing.vo.NovelAction;
 import com.lwby.marketing.vo.DeliveryDeviceInfo;
@@ -42,7 +43,7 @@ public class NovelUniversalProcess extends UniversalProcess {
         ddi.setDevice_status(exists(PRIZE_FLOW_PREFIX.concat(String.valueOf(ddi.getUserId()))) ? 2 : 0);
 
         String jsonString = JSONObject.toJSONString(ddi);
-        ListenableFuture<SendResult<String, String>> active_result = kafkaTemplate.send("ocpc_result_test", jsonString);
+        ListenableFuture<SendResult<String, String>> active_result = kafkaTemplate.send("ocpc_result", jsonString);
         active_result.addCallback(
                 result -> log.info("归因成功[{}],归因类型[{}]", jsonString, status.desc),
                 ex -> log.error("归因失败[{}],归因类型[{}]", jsonString, status.desc, ex)

src/main/java/com/lwby/marketing/att/novel/handle/ChannelAttributionFlow.java

 package com.lwby.marketing.att.novel.handle;
 
-import com.lwby.marketing.att.novel.AttributionStatus;
+import com.lwby.marketing.att.AttributionStatus;
 import com.lwby.marketing.att.novel.AttributionType;
 import com.lwby.marketing.att.novel.NovelUniversalProcess;
 import com.lwby.marketing.flow.NodeSwitchFlow;

src/main/java/com/lwby/marketing/att/novel/handle/CrossPlatformAttributionFlow.java

@@ -3,7 +3,7 @@ package com.lwby.marketing.att.novel.handle;
 import com.alicp.jetcache.anno.CacheRefresh;
 import com.alicp.jetcache.anno.CacheType;
 import com.alicp.jetcache.anno.Cached;
-import com.lwby.marketing.att.novel.AttributionStatus;
+import com.lwby.marketing.att.AttributionStatus;
 import com.lwby.marketing.att.novel.AttributionType;
 import com.lwby.marketing.att.novel.NovelUniversalProcess;
 import com.lwby.marketing.flow.NodeSwitchFlow;

src/main/java/com/lwby/marketing/att/novel/handle/StoreAttributionFlow.java

 package com.lwby.marketing.att.novel.handle;
 
-import com.lwby.marketing.att.novel.AttributionStatus;
+import com.lwby.marketing.att.AttributionStatus;
 import com.lwby.marketing.att.novel.DeviceType;
 import com.lwby.marketing.att.novel.NovelUniversalProcess;
 import com.lwby.marketing.flow.NodeFlow;