auth.js 2.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091
  1. import connection from "./base.js";
  2. export async function auth_insert({
  3. name = "",
  4. user_id = "",
  5. account = "",
  6. password = "",
  7. create_time = "",
  8. update_time = "",
  9. }) {
  10. return new Promise(async (resolve, reject) => {
  11. try {
  12. const sql = `
  13. INSERT INTO authors (name, user_id, account, password, create_time, update_time)
  14. VALUES (?, ?, ?, ?, ?, ?)
  15. `;
  16. const values = [
  17. name,
  18. user_id,
  19. account,
  20. password,
  21. create_time,
  22. update_time,
  23. ];
  24. // 直接接收 execute 返回的内容
  25. connection.execute(sql, values, (result, fields) => {
  26. return resolve(fields);
  27. });
  28. } catch (err) {
  29. console.error("Error inserting data:", err);
  30. return resolve(false);
  31. }
  32. });
  33. }
  34. // 是否存在重复的数据
  35. export function isHaveUserByUserId({ user_id = "", account = ""}) {
  36. return new Promise((resolve, reject) => {
  37. connection.query(
  38. `SELECT * FROM authors WHERE user_id = ? OR account = ?`,
  39. [user_id, account],
  40. (err, rows) => {
  41. if (err) {
  42. // reject(err);
  43. resolve(false); // 如果存在记录,则返回 true,否则返回 false
  44. } else {
  45. resolve(rows.length > 0); // 如果存在记录,则返回 true,否则返回 false
  46. }
  47. },
  48. );
  49. });
  50. }
  51. // 获取用户详情
  52. export function getUserInfoByuserId(user_id) {
  53. return new Promise((resolve, reject) => {
  54. connection.query(
  55. `SELECT * FROM authors WHERE user_id = ?`,
  56. [user_id],
  57. (err, rows) => {
  58. if (err) {
  59. // reject(err);
  60. resolve(false); // 如果存在记录,则返回 true,否则返回 false
  61. } else {
  62. resolve(rows.length > 0 ? rows[0] : false); // 如果存在记录,则返回 true,否则返回 false
  63. }
  64. },
  65. );
  66. });
  67. }
  68. // 用户是否已经注册
  69. export function isLoginUserByUserId({
  70. account = "",
  71. password = "",
  72. }) {
  73. return new Promise((resolve, reject) => {
  74. connection.query(
  75. `SELECT * FROM authors WHERE password = ? AND account = ?`,
  76. [password, account],
  77. (err, rows) => {
  78. if (err) {
  79. // reject(err);
  80. resolve(false); // 如果存在记录,则返回 true,否则返回 false
  81. } else {
  82. resolve(rows.length > 0 ? rows[0] : false); // 如果存在记录,则返回 true,否则返回 false
  83. }
  84. },
  85. );
  86. });
  87. }