归因切换 小说

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

@@ -47,7 +47,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 = storyKafkaTemplate.send("ocpc_result_test", jsonString);
+        ListenableFuture<SendResult<String, String>> active_result = storyKafkaTemplate.send("ocpc_result", jsonString);
         active_result.addCallback(
                 result -> NOVEL_SYS_LOG.info("归因成功[{}],归因类型[{}]", jsonString, status.desc),
                 ex -> NOVEL_ERROR_LOG.error("归因失败[{}],归因类型[{}]", jsonString, status.desc, ex)

src/main/java/com/lwby/marketing/notify/media/gdt/NovelGDTNotify.java

@@ -43,12 +43,10 @@ public class NovelGDTNotify extends MobileNotify {
 
         String userAction = JSONObject.toJSONString(dto);
         try {
-            //TODO;测试不执行
-//            String result = HttpUtil.post(sb.toString(), userAction);
-//            Integer resultCode = (Integer) JSON.parseObject(result).get("code");
-//            return resultCode == 0;
-            log.info("Callback info:{}",userAction);
-            return true;
+            String result = HttpUtil.post(sb.toString(), userAction);
+            Integer resultCode = (Integer) JSON.parseObject(result).get("code");
+            log.info("Callback gdt info:{},resultCode={}",userAction,resultCode);
+            return resultCode == 0;
         } catch (Exception e) {
             return false;
         }

src/main/java/com/lwby/marketing/notify/media/jrtt/NovelJRTTNotify.java

@@ -35,12 +35,10 @@ public class NovelJRTTNotify extends MobileNotify {
 
         String userJson = JSONObject.toJSONString(request);
         try {
-            //TODO;测试不执行
-//            String result = HttpUtil.post(ATTRIBUTE_URL, userJson);
-//            Integer resultCode = (Integer) JSON.parseObject(result).get("code");
-//            return resultCode == 0;
-            log.info("Callback info:{}",userJson);
-            return true;
+            String result = HttpUtil.post(ATTRIBUTE_URL, userJson);
+            Integer resultCode = (Integer) JSON.parseObject(result).get("code");
+            log.info("Callback jrtt info:{},resultCode={}",userJson,resultCode);
+            return resultCode == 0;
         } catch (Exception e) {
             return false;
         }