Method uploadLocalChanges

src/main/core/sync/syncEngine.ts:278–367

* 上传本地变更到云端

()

   * 上传本地变更到云端
   */
  private async uploadLocalChanges(): Promise<{
    count: number
    errors: number
    processedDocIds: Set<string>
  }> {
    // 获取所有需要同步的文档（_cloudSynced === false）
    const pendingDocs = await this.getUnsyncedDocs()

    if (pendingDocs.length === 0) {
      console.log('[Sync] 没有待上传的文档')
      return { count: 0, errors: 0, processedDocIds: new Set() }
    }

    console.log(`[Sync] 待上传文档数量: ${pendingDocs.length}`)

    let uploaded = 0
    let errors = 0
    const processedDocIds = new Set<string>()

    for (const doc of pendingDocs) {
      try {
        // 跳过已处理的文档
        if (processedDocIds.has(doc._id)) {
          continue
        }

        // 检查云端是否有更新版本
        const remoteDoc = await this.webdavClient.downloadDoc(doc._id)

        if (remoteDoc && this.hasConflict(doc, remoteDoc)) {
          // 冲突：使用 Last Write Wins 策略
          const winner = doc._lastModified! > remoteDoc._lastModified! ? doc : remoteDoc

          if (winner === doc) {
            // 本地版本胜出，上传到云端
            await this.webdavClient.uploadDoc({
              ...doc,
              _lastModified: Date.now()
            })

            // 更新本地同步状态
            const updatedDoc = await this.db.promises.get(doc._id)
            if (updatedDoc) {
              updatedDoc._cloudSynced = true
              await this.updateDocSyncStatus(doc._id, updatedDoc)
            }

            uploaded++
            console.log(`[Sync] 冲突已解决: ${doc._id}, 胜出: 本地，已上传`)
          } else {
            // 云端版本胜出，更新本地
            remoteDoc._cloudSynced = true
            await this.updateDocSyncStatus(doc._id, remoteDoc)

            console.log(`[Sync] 冲突已解决: ${doc._id}, 胜出: 云端，已下载`)
          }

          // 标记为已处理，避免下载阶段重复处理