Pārlūkot izejas kodu

Merge branch 'dev-xym-update1' of Server/growth-manager into master

xueyiming 10 stundas atpakaļ
vecāks
revīzija
b942858408

+ 16 - 2
api-module/src/main/java/com/tzld/piaoquan/api/service/strategy/impl/BuckStrategyV1.java

@@ -47,6 +47,9 @@ public class BuckStrategyV1 implements ReplyStrategyService {
     @Value("${bucketStrategyConfig:{}}")
     private String bucketStrategyConfigV2;
 
+    @Value("${rootSourceConfig:{}}")
+    private String rootSourceConfig;
+
     private static final String MANUAL = "manual";
 
     private static final String manualConfig = "{\"manual\":[0,1,2,3,4,5,6,7,8,9]}";
@@ -260,6 +263,19 @@ public class BuckStrategyV1 implements ReplyStrategyService {
         if (CollectionUtils.isEmpty(smallDataCgiReplyList)) {
             return smallDataCgiReplyList;
         }
+        String putScene = "touliu";
+        String channel = "tencentgzh";
+        String ghId1 = smallDataCgiReplyList.get(0).getGhId();
+        JSONObject rootSourceConfigs = JSON.parseObject(rootSourceConfig);
+        JSONObject jsonObject1 = rootSourceConfigs.getJSONObject(ghId1);
+        if(jsonObject1 != null){
+            if(StringUtils.isNotEmpty(jsonObject1.getString("putScene"))){
+                putScene = jsonObject1.getString("putScene");
+            }
+            if(StringUtils.isNotEmpty(jsonObject1.getString("channel"))){
+                channel = jsonObject1.getString("channel");
+            }
+        }
         Set<String> keys = smallDataCgiReplyList.stream().map(x -> x.getGhId() + "&" + x.getMiniVideoId() + "&" + x.getSort()).collect(Collectors.toSet());
         Map<String, SmallPageUrlDetail> keyPageUrl = new HashMap<>();
         // gh-id + videoId + sort 复用同一page_url及落地页id
@@ -275,8 +291,6 @@ public class BuckStrategyV1 implements ReplyStrategyService {
             SmallPageUrlDetail smallPageUrlDetail = new SmallPageUrlDetail();
             if (CollectionUtils.isEmpty(cgiReplyBucketData)) {
                 // 库里不存在,调用新生成
-                String putScene = "touliu";
-                String channel = "tencentgzh";
                 String response = touLiuHttpClient.sendAdFlowAddRequest(GET_SMALL_PAGE_URL, videoId, putScene, channel, "自动", "公众号", "自动回复小程序", "位置" + sort, ghId);
                 JSONObject jsonObject = JSON.parseObject(response);
                 if (jsonObject.getInteger("code").equals(0)) {