import { getPendingSyncRecords, markRecordSynced, cleanOldRecords } from './db';
import { deleteLocalImage } from './fs';
import { uploadImage, submitRecord } from '../api/mock';

let isSyncing = false;

/**
 * 启动离线数据同步队列
 * 核心逻辑：
 * 1. 查询所有未同步的数据
 * 2. 如果有图片路径，先上传图片获取云端 URL
 * 3. 提交完整业务数据到后端
 * 4. 成功后：将数据库记录置为已同步，并删除本地沙盒图片释放内存
 */
export const startSyncQueue = async () => {
  if (isSyncing) return;
  
  // 简单判断当前网络是否可用
  const networkType = await new Promise(resolve => {
    uni.getNetworkType({
      success: (res) => resolve(res.networkType)
    });
  });
  
  if (networkType === 'none') {
    console.log('[Sync] 当前无网络，取消同步');
    return;
  }

  isSyncing = true;
  console.log('[Sync] 开始执行同步队列...');

  try {
    const pendingRecords = await getPendingSyncRecords();
    if (pendingRecords.length === 0) {
      console.log('[Sync] 无待同步记录');
      isSyncing = false;
      return;
    }

    for (let record of pendingRecords) {
      try {
        let payload = record.payload;
        
        // 1. 如果存在本地图片，先上传图片
        if (record.local_img_path) {
          const uploadRes = await uploadImage(record.local_img_path);
          if (uploadRes && uploadRes.code === 200) {
            // 将云端 URL 赋值给业务 payload
            payload.cloudImageUrl = uploadRes.url;
          } else {
            throw new Error('图片上传失败');
          }
        }

        // 2. 提交业务数据
        const submitRes = await submitRecord(payload);
        if (submitRes && submitRes.code === 200) {
          // 3. 提交成功后：标记数据库状态
          await markRecordSynced(record.id);
          
          // 4. 最重要：删除本地沙盒图片，释放 4G 设备的有限空间
          if (record.local_img_path) {
            await deleteLocalImage(record.local_img_path);
          }
          console.log(`[Sync] 记录 ${record.id} 同步成功并已清理本地文件`);
        } else {
          throw new Error('业务数据提交失败');
        }
      } catch (err) {
        console.error(`[Sync] 记录 ${record.id} 同步遇到错误，跳过等下次:`, err);
        // 单条失败不阻断循环，继续下一条
      }
    }
  } catch (err) {
    console.error('[Sync] 同步队列执行异常:', err);
  } finally {
    isSyncing = false;
    // 如果一次同步了 20 条，可能还有，可以再次触发
  }
};

/**
 * 每日凌晨或空闲时清理超期废弃数据
 */
export const runDailyCleanup = () => {
  console.log('[Sync] 执行超期数据清理...');
  cleanOldRecords().catch(err => {
    console.error('[Sync] 清理失败:', err);
  });
};