百家号数据同步

client/src/components.d.ts

@@ -15,15 +15,9 @@ declare module 'vue' {
     ElBadge: typeof import('element-plus/es')['ElBadge']
     ElButton: typeof import('element-plus/es')['ElButton']
     ElButtonGroup: typeof import('element-plus/es')['ElButtonGroup']
-    ElCascader: typeof import('element-plus/es')['ElCascader']
     ElCheckbox: typeof import('element-plus/es')['ElCheckbox']
-    ElCheckboxGroup: typeof import('element-plus/es')['ElCheckboxGroup']
-    ElCol: typeof import('element-plus/es')['ElCol']
     ElConfigProvider: typeof import('element-plus/es')['ElConfigProvider']
     ElContainer: typeof import('element-plus/es')['ElContainer']
-    ElDatePicker: typeof import('element-plus/es')['ElDatePicker']
-    ElDescriptions: typeof import('element-plus/es')['ElDescriptions']
-    ElDescriptionsItem: typeof import('element-plus/es')['ElDescriptionsItem']
     ElDialog: typeof import('element-plus/es')['ElDialog']
     ElDivider: typeof import('element-plus/es')['ElDivider']
     ElDrawer: typeof import('element-plus/es')['ElDrawer']
@@ -43,7 +37,6 @@ declare module 'vue' {
     ElProgress: typeof import('element-plus/es')['ElProgress']
     ElRadioButton: typeof import('element-plus/es')['ElRadioButton']
     ElRadioGroup: typeof import('element-plus/es')['ElRadioGroup']
-    ElRow: typeof import('element-plus/es')['ElRow']
     ElSelect: typeof import('element-plus/es')['ElSelect']
     ElSubMenu: typeof import('element-plus/es')['ElSubMenu']
     ElSwitch: typeof import('element-plus/es')['ElSwitch']
@@ -52,8 +45,6 @@ declare module 'vue' {
     ElTabPane: typeof import('element-plus/es')['ElTabPane']
     ElTabs: typeof import('element-plus/es')['ElTabs']
     ElTag: typeof import('element-plus/es')['ElTag']
-    ElText: typeof import('element-plus/es')['ElText']
-    ElUpload: typeof import('element-plus/es')['ElUpload']
     Icons: typeof import('./components/icons/index.vue')['default']
     RouterLink: typeof import('vue-router')['RouterLink']
     RouterView: typeof import('vue-router')['RouterView']

server/src/services/HeadlessBrowserService.ts

@@ -944,6 +944,9 @@ class HeadlessBrowserService {
           info.pythonAvailable = true;
         } catch (error) {
           logger.warn(`[Python API] Failed to fetch works for baijiahao:`, error);
+          // 将 Python 侧错误抛出，让任务显示失败原因（如未登录、token 失效），而不是“共同步 0 个作品”
+          const msg = error instanceof Error ? error.message : String(error);
+          throw new Error(msg || '百家号拉取作品列表失败，请检查登录状态后重试');
         }
       }
 

server/src/services/RedisTaskQueue.ts

@@ -412,6 +412,9 @@ class RedisTaskQueueService {
       publish_video: '发布视频',
       batch_reply: '批量回复评论',
       delete_work: '删除作品',
+      xhs_work_stats_backfill: '小红书作品补数',
+      dy_work_stats_backfill: '抖音作品补数',
+      bj_work_stats_backfill: '百家号作品补数',
     };
     return titles[type] || '未知任务';
   }

server/src/services/TaskQueueService.ts

@@ -260,6 +260,7 @@ class TaskQueueService {
       delete_work: '删除作品',
       xhs_work_stats_backfill: '小红书作品补数',
       dy_work_stats_backfill: '抖音作品补数',
+      bj_work_stats_backfill: '百家号作品补数',
     };
     return titles[type] || '未知任务';
   }

server/src/services/WorkService.ts

@@ -265,6 +265,16 @@ export class WorkService {
         const legacyFallbackId = `${platform}_${titleForId}_${publishTimeForId}`.substring(0, 100);
         let canonicalVideoId = (workItem.videoId || '').trim() || legacyFallbackId;
 
+        // 小红书每日同步只同步三个月内的作品（原为一年内，现改为三个月）
+        if (platform === 'xiaohongshu') {
+          const publishedAt = this.parsePublishTime(workItem.publishTime);
+          if (publishedAt) {
+            const threeMonthsAgo = new Date();
+            threeMonthsAgo.setMonth(threeMonthsAgo.getMonth() - 3);
+            if (publishedAt < threeMonthsAgo) continue;
+          }
+        }
+
         if (platform === 'weixin_video') {
           const rawVideoId = (workItem.videoId || '').trim();
           if (rawVideoId) {
@@ -409,6 +419,10 @@ export class WorkService {
         logger.info(`[SyncAccountWorks] Skipping local deletions for ${platform} account ${account.id} to avoid false deletions`);
         skipLocalDeletions = true;
       }
+      if (platform === 'xiaohongshu') {
+        logger.info(`[SyncAccountWorks] Skipping local deletions for ${platform} account ${account.id} (only syncing works within 3 months)`);
+        skipLocalDeletions = true;
+      }
 
       const matchedCount = localWorks.reduce(
         (sum, w) => sum + (remotePlatformVideoIds.has(w.platformVideoId) ? 1 : 0),
@@ -528,6 +542,46 @@ export class WorkService {
       }
     }
 
+    // 百家号：如果是新作品且 work_day_statistics 中尚无任何记录，则异步补齐历史日统计 & works.yesterday_*（使用 BaijiahaoWorkDailyStatisticsImportService）
+    if (platform === 'baijiahao') {
+      try {
+        const works = await this.workRepository.find({
+          where: { accountId: account.id, platform },
+          select: ['id'],
+        });
+        const workIds = works.map((w) => w.id);
+        if (workIds.length > 0) {
+          const rows = await AppDataSource.getRepository(WorkDayStatistics)
+            .createQueryBuilder('wds')
+            .select('DISTINCT wds.work_id', 'workId')
+            .where('wds.work_id IN (:...ids)', { ids: workIds })
+            .getRawMany();
+          const hasStats = new Set<number>(rows.map((r: any) => Number(r.workId)));
+          const needInitIds = workIds.filter((id) => !hasStats.has(id));
+
+          if (needInitIds.length > 0) {
+            logger.info(
+              `[SyncAccountWorks] BJ account ${account.id} has ${needInitIds.length} works without statistics, enqueue bj_work_stats_backfill task.`
+            );
+            taskQueueService.createTask(account.userId, {
+              type: 'bj_work_stats_backfill',
+              title: `百家号作品补数（${needInitIds.length}）`,
+              accountId: account.id,
+              platform: 'baijiahao',
+              data: {
+                workIds: needInitIds,
+              },
+            });
+          }
+        }
+      } catch (err) {
+        logger.error(
+          `[SyncAccountWorks] Failed to enqueue BJ work_day_statistics backfill for account ${account.id}:`,
+          err
+        );
+      }
+    }
+
     return {
       syncedCount,
       worksListLength: accountInfo.worksList?.length || 0,

server/src/services/taskExecutors.ts

@@ -10,6 +10,7 @@ import { AccountService } from './AccountService.js';
 import { PublishService } from './PublishService.js';
 import { XiaohongshuWorkNoteStatisticsImportService } from './XiaohongshuWorkNoteStatisticsImportService.js';
 import { DouyinWorkStatisticsImportService } from './DouyinWorkStatisticsImportService.js';
+import { BaijiahaoWorkDailyStatisticsImportService } from './BaijiahaoWorkDailyStatisticsImportService.js';
 import { AppDataSource, PlatformAccount } from '../models/index.js';
 import { logger } from '../utils/logger.js';
 
@@ -312,6 +313,41 @@ async function dyWorkStatsBackfillExecutor(task: Task, updateProgress: ProgressU
 }
 
 /**
+ * 百家号作品日统计/快照补数（不阻塞同步作品）
+ * 任务 data: { workIds: number[] }，实际执行时对整个账号运行 importAccountWorkDaily（补全所有作品的历史日统计）
+ */
+async function bjWorkStatsBackfillExecutor(task: Task, updateProgress: ProgressUpdater): Promise<TaskResult> {
+  updateProgress({ progress: 5, currentStep: '准备百家号作品补数任务...' });
+
+  const userId = (task as Task & { userId?: number }).userId;
+  if (!userId) throw new Error('缺少用户ID');
+  if (!task.accountId) throw new Error('缺少账号ID');
+
+  const workIdsRaw = (task as Task & { workIds?: unknown }).workIds;
+  const workIds = Array.isArray(workIdsRaw)
+    ? workIdsRaw.map((x) => Number(x)).filter((n) => Number.isFinite(n) && n > 0)
+    : [];
+
+  // 仅允许当前用户自己的百家号账号
+  const account = await AppDataSource.getRepository(PlatformAccount).findOne({
+    where: { id: task.accountId, userId, platform: 'baijiahao' as any },
+  });
+  if (!account) throw new Error('未找到百家号账号或无权限');
+
+  updateProgress({ progress: 15, currentStep: `开始百家号作品补数（需补数作品：${workIds.length}）...` });
+
+  await BaijiahaoWorkDailyStatisticsImportService.runDailyImportForAccount(account.id);
+
+  updateProgress({ progress: 100, currentStep: '百家号作品补数完成' });
+
+  return {
+    success: true,
+    message: `百家号作品补数完成`,
+    data: { workIdsCount: workIds.length },
+  };
+}
+
+/**
  * 注册所有任务执行器
  */
 export function registerTaskExecutors(): void {
@@ -322,6 +358,7 @@ export function registerTaskExecutors(): void {
   taskQueueService.registerExecutor('delete_work', deleteWorkExecutor);
   taskQueueService.registerExecutor('xhs_work_stats_backfill', xhsWorkStatsBackfillExecutor);
   taskQueueService.registerExecutor('dy_work_stats_backfill', dyWorkStatsBackfillExecutor);
-  
+  taskQueueService.registerExecutor('bj_work_stats_backfill', bjWorkStatsBackfillExecutor);
+
   logger.info('All task executors registered');
 }

shared/src/types/task.ts

@@ -11,7 +11,8 @@ export type TaskType =
   | 'batch_reply'            // 批量回复评论
   | 'delete_work'            // 删除平台作品
   | 'xhs_work_stats_backfill' // 小红书作品首批日统计/快照补数（后台执行）
-  | 'dy_work_stats_backfill'; // 抖音作品日统计/快照补数（后台执行）
+  | 'dy_work_stats_backfill'  // 抖音作品日统计/快照补数（后台执行）
+  | 'bj_work_stats_backfill'; // 百家号作品日统计/快照补数（后台执行）
 
 // 任务状态
 export type TaskStatus = 
@@ -101,6 +102,11 @@ export const TASK_TYPE_CONFIG: Record<TaskType, {
     icon: 'DataLine',
     color: '#2ecc71',
   },
+  bj_work_stats_backfill: {
+    name: '百家号作品补数',
+    icon: 'DataLine',
+    color: '#3498db',
+  },
 };
 
 // WebSocket 任务事件类型