wangyunpeng пре 1 месец
родитељ
комит
c38ae01f31

+ 1 - 1
api-module/src/main/java/com/tzld/piaoquan/api/common/enums/contentplatform/ChannelType.java

@@ -5,7 +5,7 @@ package com.tzld.piaoquan.api.common.enums.contentplatform;
  */
 public enum ChannelType {
     MINIAPP_TOULIU,      // 1. 小程序投流-稳定
-    GZH_COOPERATE_JIZHUAN, // 2. 公众号合作-即转-稳定
+    GZH_COOPERATE_REPLY, // 2. 公众号合作-即转-稳定
     QW_COOPERATE,        // 3. 群/企微合作-稳定
     GZH_TOULIU,          // 4. 公众号投流-稳定
     FWH_COOPERATE_DAILY, // 5. 服务号合作-Daily-自选

+ 6 - 6
api-module/src/main/java/com/tzld/piaoquan/api/job/ExternalChannelProcessJob.java

@@ -220,8 +220,8 @@ public class ExternalChannelProcessJob {
                 case MINIAPP_TOULIU:
                     processMiniAppTouliu(record);
                     break;
-                case GZH_COOPERATE_JIZHUAN:
-                    processGzhCooperateJizhuan(record);
+                case GZH_COOPERATE_REPLY:
+                    processGzhCooperateReply(record);
                     break;
                 case QW_COOPERATE:
                     processQwCooperate(record);
@@ -268,7 +268,7 @@ public class ExternalChannelProcessJob {
         if (rootSourceId.startsWith(PREFIX_TOULIU_TENCENT)) {
             return ChannelType.MINIAPP_TOULIU;
         } else if (rootSourceId.startsWith(PREFIX_DYYJS)) {
-            return ChannelType.GZH_COOPERATE_JIZHUAN;
+            return ChannelType.GZH_COOPERATE_REPLY;
         } else if (rootSourceId.startsWith(PREFIX_DYYQW) || rootSourceId.startsWith(PREFIX_TOULIU_TENCENTWBqw)) {
             return ChannelType.QW_COOPERATE;
         } else if (rootSourceId.startsWith(PREFIX_TOULIU_TENCENTGZH)
@@ -434,7 +434,7 @@ public class ExternalChannelProcessJob {
      * 渠道判断:rootSourceId 以 dyyjs_ 开头
      * 处理逻辑:查询 cgi_reply_bucket_data 获取 ghId,再查询 content_platform_gzh_account 获取合作方
      */
-    private void processGzhCooperateJizhuan(ExternalChannel record) {
+    private void processGzhCooperateReply(ExternalChannel record) {
         String rootSourceId = record.getRootSourceId();
         Long recordId = record.getId();
         log.info("处理公众号合作-即转, id={}, rootSourceId={}", recordId, rootSourceId);
@@ -854,7 +854,7 @@ public class ExternalChannelProcessJob {
 
             // 初始化所有已支持的渠道
             totalCount += initChannelHistory(ChannelType.MINIAPP_TOULIU, startDate, days);
-            totalCount += initChannelHistory(ChannelType.GZH_COOPERATE_JIZHUAN, startDate, days);
+            totalCount += initChannelHistory(ChannelType.GZH_COOPERATE_REPLY, startDate, days);
             totalCount += initChannelHistory(ChannelType.QW_COOPERATE, startDate, days);
             totalCount += initChannelHistory(ChannelType.GZH_TOULIU, startDate, days);
             totalCount += initChannelHistory(ChannelType.FWH_COOPERATE_DAILY, startDate, days);
@@ -889,7 +889,7 @@ public class ExternalChannelProcessJob {
             case MINIAPP_TOULIU:
                 // 小程序投流: 历史已手动导入一年
                 break;
-            case GZH_COOPERATE_JIZHUAN:
+            case GZH_COOPERATE_REPLY:
                 // 公众号合作-即转:从cgi_reply_bucket_data查询dyyjs_开头的rootSourceId
                 rootSourceIds = queryRootSourceIdsFromCgiReply(PREFIX_DYYJS, startDate);
                 break;