历史数据导入

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

@@ -873,7 +873,7 @@ public class ExternalChannelProcessJob {
                 break;
             case GZH_COOPERATE_JIZHUAN:
                 // 公众号合作-即转：从cgi_reply_bucket_data查询dyyjs_开头的rootSourceId
-                rootSourceIds = queryRootSourceIdsFromCgiReply(PREFIX_DYYJS, startDate);
+                //rootSourceIds = queryRootSourceIdsFromCgiReply(PREFIX_DYYJS, startDate);
                 break;
             case QW_COOPERATE:
                 // 群/企微合作：从content_platform_qw_plan查询
@@ -896,7 +896,7 @@ public class ExternalChannelProcessJob {
                 break;
             case FWH_TOULIU_DAILY:
                 // 服务号投流-Daily：从cgi_reply_bucket_data查询fwhtouliu_开头（非fwhtouliu_tencentgzh）
-                rootSourceIds = queryRootSourceIdsFromCgiReply(PREFIX_FWHTOULIU, startDate);
+                // 从aigc查询
                 break;
             case GZH_COOPERATE_DAILY:
                 // 公众号合作-Daily：从content_platform_gzh_plan_video查询longArticles_开头
@@ -904,9 +904,11 @@ public class ExternalChannelProcessJob {
                 break;
             case GZH_BUY_ACCOUNT:
                 // 公众号买号：需确认数据来源
+                // 从aigc查询
                 break;
             case GZH_OPERATION_DAILY:
                 // 公众号代运营-Daily：需确认数据来源
+                // 从aigc查询
                 break;
             default:
                 return 0;
@@ -982,10 +984,8 @@ public class ExternalChannelProcessJob {
             ContentPlatformQwPlanExample example = new ContentPlatformQwPlanExample();
             example.createCriteria()
                     .andStatusEqualTo(1)
-                    .andRootSourceIdIsNotNull();
-            // create_timestamp 是 BIGINT 类型，需要转换
-            long startTimestamp = startDate.getTime() / 1000;
-            example.getOredCriteria().get(0).andCreateTimestampGreaterThanOrEqualTo(startTimestamp);
+                    .andRootSourceIdIsNotNull()
+                    .andCreateTimestampGreaterThanOrEqualTo(startDate.getTime());
             List<ContentPlatformQwPlan> list = qwPlanMapper.selectByExample(example);
             if (!CollectionUtils.isEmpty(list)) {
                 for (ContentPlatformQwPlan plan : list) {
@@ -1013,7 +1013,8 @@ public class ExternalChannelProcessJob {
             ContentPlatformGzhPlanVideoExample example = new ContentPlatformGzhPlanVideoExample();
             example.createCriteria()
                     .andRootSourceIdLike(prefix + "%")
-                    .andStatusEqualTo(1);
+                    .andStatusEqualTo(1)
+                    .andCreateTimestampGreaterThanOrEqualTo(startDate.getTime());
             List<ContentPlatformGzhPlanVideo> list = gzhPlanVideoMapper.selectByExample(example);
             if (!CollectionUtils.isEmpty(list)) {
                 for (ContentPlatformGzhPlanVideo video : list) {