store归因上报redis

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

@@ -32,6 +32,9 @@ public class UniversalProcess {
     @Resource
     private RedisTemplate<String, String> redisTemplate;
 
+    @Resource
+    private RedisTemplate<String,String> biRedisTemplate;
+
 
     /******************************************** GENERIC METHOD ***********************************************/
 
@@ -82,9 +85,16 @@ public class UniversalProcess {
         return String.format("fc_%s_%d_%s_%s", action.getDeviceId(), action.getPlatformId(),action.getMediaName(),action.getCurrentDateStr());
     }
 
+    public String buildKey(Integer platformId,String deviceId) {
+        return String.format("market:activeness:30:%d:%s",platformId,deviceId);
+    }
 
     /******************************************** REDIS **********************************************************/
 
+    public boolean existsIsAlive(String key) {
+        return Boolean.TRUE.equals(biRedisTemplate.hasKey(key));
+    }
+
     public boolean exists(String key) {
         return Boolean.TRUE.equals(redisTemplate.hasKey(key));
     }

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

@@ -19,7 +19,11 @@ public class StoreAttributionFlow extends NodeFlow<NovelAction> {
     public void process(NovelAction action) {
         //商店归因通知
         if(Objects.isNull(action.getDeliveryDeviceInfo())){
-            up.notifyResult(action, AttributionStatus.STORE_CALLBACK);
+            //商店判断30天活跃，不在活跃天数内，发BI
+            String aliveDeviceKey = up.buildKey(action.getPlatformId(), action.getDeviceId());
+            if (!up.existsIsAlive(aliveDeviceKey)) {
+                up.notifyResult(action, AttributionStatus.STORE_CALLBACK);
+            }
             action.stop(true);   //结束后面所有执行流程
         }
 

src/main/java/com/lwby/marketing/conf/BiRedisConfig.java

+package com.lwby.marketing.conf;
+
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
+import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+/**
+ * @author songxinyu
+ * @version BiRedisConfig.java, v 0.1 2024年03月07日 11:32 songxinyu Exp $
+ */
+@Configuration
+public class BiRedisConfig {
+
+    @Value("${bi.redis.host}")
+    private String biHostName;
+
+    @Value("${bi.redis.port}")
+    private int biHostPort;
+
+    @Bean("biJedisFactory")
+    public JedisConnectionFactory jedisConnectionFactory() {
+        RedisStandaloneConfiguration config = new RedisStandaloneConfiguration();
+        config.setHostName(biHostName);
+        config.setPort(biHostPort);
+
+        return new JedisConnectionFactory(config);
+    }
+
+    @Bean("biRedisTemplate")
+    public RedisTemplate<Object, Object> redisTemplate(@Qualifier("biJedisFactory") RedisConnectionFactory redisConnectionFactory) {
+        RedisTemplate<Object, Object> template = new RedisTemplate<>();
+        StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
+        template.setKeySerializer(stringRedisSerializer);
+        template.setValueSerializer(stringRedisSerializer);
+        template.setConnectionFactory(redisConnectionFactory);
+        return template;
+    }
+}

src/main/java/com/lwby/marketing/conf/RedisConfig.java

 package com.lwby.marketing.conf;
 
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
+import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.data.redis.serializer.StringRedisSerializer;
 
 @Configuration
 public class RedisConfig {
 
-    @Bean
-    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
+    @Value("${spring.redis.host}")
+    private String hostName;
+
+    @Value("${spring.redis.port}")
+    private int hostPort;
+
+    @Bean("jedisFactory")
+    public JedisConnectionFactory jedisConnectionFactory() {
+        RedisStandaloneConfiguration config = new RedisStandaloneConfiguration();
+        config.setHostName(hostName);
+        config.setPort(hostPort);
+
+        return new JedisConnectionFactory(config);
+    }
+
+    @Bean("redisTemplate")
+    public RedisTemplate<Object, Object> redisTemplate(@Qualifier("jedisFactory") RedisConnectionFactory redisConnectionFactory) {
         RedisTemplate<Object, Object> template = new RedisTemplate<>();
         StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
         template.setKeySerializer(stringRedisSerializer);

src/main/resources/application-prod.yml

@@ -33,6 +33,11 @@ spring:
     listener:
       ack-mode: RECORD
 
+bi:
+  redis:
+    host: r-2zethzp7pjl3rjbelp.redis.rds.aliyuncs.com
+    port: 6379
+
 story:
   novel:
     active:

src/main/resources/application-test.yml

@@ -33,6 +33,11 @@ spring:
     listener:
       ack-mode: RECORD
 
+bi:
+  redis:
+    host: 172.17.243.150
+    port: 6379
+
 story:
   novel:
     active: