newCashBook/node_expores/db/auth.js

import connection from "./base.js";

export async function auth_insert({
  name = "",
  user_id = "",
  login_type,
  email = "",
  mobile = "",
  password = "",
  create_time = "",
  update_time = "",
}) {
  return new Promise(async (resolve, reject) => {
    try {
      const sql = `
        INSERT INTO authors (name, user_id, login_type, email, mobile, password, create_time, update_time)
        VALUES (?, ?, ?, ?, ?, ?, ?, ?)
      `;
      const values = [
        name,
        user_id,
        login_type,
        email,
        mobile,
        password,
        create_time,
        update_time,
      ];
      // 直接接收 execute 返回的内容
      const result = await connection.execute(sql, values);
      // console.log("Record inserted successfully:", result);
      return resolve(result);
    } catch (err) {
      console.error("Error inserting data:", err);
      // throw err;
      return resolve(false);
    }
  });
}

// 是否存在重复的数据
export function isHaveUserByUserId({ user_id = "", mobile = "", email = "" }) {
  return new Promise((resolve, reject) => {
    connection.query(
      `SELECT * FROM authors WHERE user_id = ? OR mobile = ? OR email = ?`,
      [user_id, mobile, email],
      (err, rows) => {
        if (err) {
          // reject(err);
          resolve(false); // 如果存在记录，则返回 true，否则返回 false
        } else {
          resolve(rows.length > 0); // 如果存在记录，则返回 true，否则返回 false
        }
      },
    );
  });
}

// 获取用户详情
export function getUserInfoByuserId(user_id) {
  return new Promise((resolve, reject) => {
    connection.query(
      `SELECT * FROM authors WHERE user_id = ?`,
      [user_id],
      (err, rows) => {
        if (err) {
          // reject(err);
          resolve(false); // 如果存在记录，则返回 true，否则返回 false
        } else {
          resolve(rows.length > 0 ? rows[0] : false); // 如果存在记录，则返回 true，否则返回 false
        }
      },
    );
  });
}

// 用户是否已经注册
export function isLoginUserByUserId({
  mobile = "",
  email = "",
  password = "",
}) {
  console.log(7979, {
    mobile,
    email,
    password,
  });
  return new Promise((resolve, reject) => {
    connection.query(
      `SELECT * FROM authors WHERE password = ? AND (mobile = ? OR email = ? )`,
      [password, mobile, email],
      (err, rows) => {
        if (err) {
          // reject(err);
          resolve(false); // 如果存在记录，则返回 true，否则返回 false
        } else {
          resolve(rows.length > 0 ? rows[0] : false); // 如果存在记录，则返回 true，否则返回 false
        }
      },
    );
  });
}