import connection from "./base.js";

// 获取类型详情
export function getTypesById({ typeId = "", book_id = "", author_id = "" }) {
  return new Promise((resolve, reject) => {
    connection.query(
      `SELECT * FROM types WHERE id = ? AND author_id = ? AND book_id = ?`,
      [typeId, author_id, book_id],
      (err, rows) => {
        if (err) {
          resolve(false);
        } else {
          resolve(rows.length > 0 ? rows[0] : false);
        }
      }
    );
  });
}

// 获取用户所有的类型
export function getTypesByUserId({ book_id = "", author_id = "" }) {
  return new Promise((resolve, reject) => {
    connection.query(
      `SELECT * FROM types WHERE book_id = ? AND author_id = ?`,
      [book_id, author_id],
      (err, rows) => {
        if (err) {
          resolve(false);
        } else {
          resolve(rows);
        }
      }
    );
  });
}
// 用户是否已经注册
export function isType({ book_id = "", author_id = "", type = "" }) {
  return new Promise((resolve, reject) => {
    connection.query(
      `SELECT * FROM types WHERE book_id = ? AND author_id = ? AND name = ?`,
      [book_id, author_id, type],
      (err, rows) => {
        if (err) {
          // reject(err);
          resolve(false); // 如果存在记录，则返回 true，否则返回 false
        } else {
          resolve(rows.length > 0 ? rows[0] : false); // 如果存在记录，则返回 true，否则返回 false
        }
      }
    );
  });
}

export async function type_insert({
  book_id = "",
  author_id = "",
  type = "",
  create_time = "",
  update_time = "",
}) {
  return new Promise(async (resolve, reject) => {
    try {
      const sql = `
        INSERT INTO types (name, book_id, author_id, create_time, update_time)
        VALUES (?, ?, ?, ?, ?)
      `;
      const values = [type, book_id, author_id, create_time, update_time];
      // 直接接收 execute 返回的内容
      const result = await connection.execute(sql, values);
      return resolve(result);
    } catch (err) {
      console.error("Error inserting data:", err);
      // throw err;
      return resolve(false);
    }
  });
}