Merge branch '7-短剧app关键行为优化' into 'release_20240408_01'

dy短剧关键行为优化

See merge request !38

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

@@ -83,8 +83,7 @@ public class DyVideoUniversalProcess extends UniversalProcess {
         );
     }
 
-    @Override
-    public <T> T get(Class<T> clazz, String key) {
+    public <T> T getOld(Class<T> clazz, String key) {
         String value = oldMarketRedisTemplate.opsForValue().get(key);
         if(!Objects.isNull(value)){
             return JSON.parseObject(value,clazz);
@@ -229,9 +228,9 @@ public class DyVideoUniversalProcess extends UniversalProcess {
                             tvcCount +=  costI;
 
                         }
-                        hsetNew(upcBehaviorKey,"tvc",60 * 60 * 24 * 3,JSON.toJSONString(tvcCount));
-                        hsetNew(upcBehaviorKey,"mvc",60 * 60 * 24 * 3,JSON.toJSONString(motivateCount));
-                        hsetNew(upcBehaviorKey,"vec",60 * 60 * 24 * 3,JSON.toJSONString(pecpmCount));
+                        hset(upcBehaviorKey,"tvc",60 * 60 * 24 * 3,JSON.toJSONString(tvcCount));
+                        hset(upcBehaviorKey,"mvc",60 * 60 * 24 * 3,JSON.toJSONString(motivateCount));
+                        hset(upcBehaviorKey,"vec",60 * 60 * 24 * 3,JSON.toJSONString(pecpmCount));
 
                     }
 

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

@@ -96,7 +96,7 @@ public class DyvideoBehaviorFlow extends NodeSwitchFlow<StoryNovelAction> {
             ThirdAccountDy thirdAccountDy = null;
             DYVIDEO_SYS_LOG.info("thirdAccountDy url={}",Objects.equals(env.getActiveProfiles()[0],"prod") ? tokenDyProdUrl : tokenDyDevUrl);
             if (up.existsOld(tokenDy)) {
-                thirdAccountDy = up.get(ThirdAccountDy.class, tokenDy);
+                thirdAccountDy = up.getOld(ThirdAccountDy.class, tokenDy);
             } else {
                 thirdAccountDy = up.getDyAccessToken(dyMarketPlatformAppIdList.get(0), dyMarketPlatformAppIdList.get(1),
                         Objects.equals(env.getActiveProfiles()[0],"prod") ? tokenDyProdUrl : tokenDyDevUrl);

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

@@ -38,6 +38,8 @@ public class BiRedisConfig {
         StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
         template.setKeySerializer(stringRedisSerializer);
         template.setValueSerializer(stringRedisSerializer);
+        template.setHashKeySerializer(stringRedisSerializer);
+        template.setHashValueSerializer(stringRedisSerializer);
         template.setConnectionFactory(redisConnectionFactory);
         return template;
     }

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

@@ -34,6 +34,8 @@ public class RedisConfig {
         StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
         template.setKeySerializer(stringRedisSerializer);
         template.setValueSerializer(stringRedisSerializer);
+        template.setHashKeySerializer(stringRedisSerializer);
+        template.setHashValueSerializer(stringRedisSerializer);
         template.setConnectionFactory(redisConnectionFactory);
         return template;
     }