import 'dart:convert';

import '../../model/video/video_model.dart';
import '../../model/video/watch_record_model.dart';

import 'sqlite_utils.dart';

class DBManager {
  ///初始化
  static  List<String> getTables()  {
    List<String> tables = [
      '''
      CREATE TABLE IF NOT Exists WATCH_RECORD(
        _ID INTEGER NOT NULL PRIMARY KEY,
        _VIDEO_ID TEXT NOT NULL UNIQUE,
        _VIDEOS TEXT NOT NULL,
        _VIDEO_DETAIL TEXT NOT NULL,
        _POSITION INTEGER NOT NULL,
        _CREATE_TIME INTEGER NOT NULL,
        _UPDATE_TIME INTEGER NOT NULL
      );
      '''
    ];
  return tables;
  }

  ///添加观看记录
  static void addWatchRecord(VideoInfoModel videoInfo,
      VideoDetailInfo detailInfo, int position) async {
    VideoInfoModel temp=VideoInfoModel.fromJson(videoInfo.toJson());
    temp.videoDetailList = null;
    List<Map> resultList = await SQLiteUtil.select(
        "SELECT * FROM WATCH_RECORD where _VIDEO_ID = ?", [temp.id]);
    if (resultList.isEmpty) {
      String sql =
          "INSERT INTO WATCH_RECORD(_VIDEO_ID,_VIDEOS,_VIDEO_DETAIL,_POSITION,_CREATE_TIME,_UPDATE_TIME) VALUES(?,?,?,?,?,?)";
      await SQLiteUtil.insert(sql, [
        [
          temp.id!,
          jsonEncode(temp.toJson()),
          jsonEncode(detailInfo.toJson()),
          position,
          DateTime.now().millisecondsSinceEpoch,
          DateTime.now().millisecondsSinceEpoch,
        ]
      ]);
    } else {
      String sql =
          "UPDATE WATCH_RECORD SET _VIDEOS=?,_VIDEO_DETAIL=?,_POSITION=?,_UPDATE_TIME=? WHERE _ID=?";
      await SQLiteUtil.executeSQLWithParams(sql, [
        jsonEncode(temp.toJson()),
        jsonEncode(detailInfo.toJson()),
        position,
        DateTime.now().millisecondsSinceEpoch,
        resultList[0]["_ID"]
      ]);
    }
  }

  ///删除观看记录
  static Future deleteWatchRecord(List<String> ids) async {
    String sql = "DELETE FROM WATCH_RECORD WHERE ";
    for (var element in ids) {
      sql += " _ID = ? OR";
    }
    if (sql.endsWith("OR")) {
      sql = sql.substring(0, sql.length - 2);
    }
    await SQLiteUtil.executeSQLWithParams(sql, ids);
  }

  ///获取观看记录列表
  static Future<List<WatchRecordModel>> listWatchRecord(
      int page, int pageSize) async {
    String sql =
        "select * from WATCH_RECORD ORDER BY _UPDATE_TIME DESC LIMIT ?,?";
    List<Map> result =
        await SQLiteUtil.select(sql, [(page - 1) * pageSize, pageSize]);
    List<WatchRecordModel> list = [];
    result.forEach((element) {
      list.add(WatchRecordModel(
        id: element["_ID"],
        videoId: element["_VIDEO_ID"],
        video: VideoInfoModel.fromJson(jsonDecode(element["_VIDEOS"])),
        videoDetail:
            VideoDetailInfo.fromJson(jsonDecode(element["_VIDEO_DETAIL"])),
        position: element["_POSITION"],
        createTime: element["_CREATE_TIME"],
        updateTime: element["_UPDATE_TIME"],
      ));
    });
    return list;
  }

  static Future<int> countWatchRecord() async {
    String sql = "select count(*) from WATCH_RECORD";
    return await SQLiteUtil.count(sql, []);
  }
}