121 lines
3.4 KiB
JavaScript
121 lines
3.4 KiB
JavaScript
const pool = require("../config");
|
|
|
|
// Get all users
|
|
const getAllUsersDb = async () => {
|
|
const queryText = `
|
|
SELECT u.user_id, u.user_fullname, u.user_name, u.user_email, u.user_phone,
|
|
u.is_active, u.created_at, u.updated_at, u.deleted_at,
|
|
u.updated_by, u.deleted_by,
|
|
r.role_id, r.role_name
|
|
FROM m_users u
|
|
LEFT JOIN m_roles r ON u.role_id = r.role_id
|
|
WHERE u.deleted_at IS NULL
|
|
ORDER BY u.user_id ASC
|
|
`;
|
|
const result = await pool.query(queryText);
|
|
return result.recordset;
|
|
};
|
|
|
|
// Get user by ID
|
|
const getUserByIdDb = async (id) => {
|
|
const queryText = `
|
|
SELECT u.user_id, u.user_fullname, u.user_name, u.user_email, u.user_phone,
|
|
u.is_active, u.created_at, u.updated_at, u.deleted_at,
|
|
u.updated_by, u.deleted_by,
|
|
r.role_id, r.role_name
|
|
FROM m_users u
|
|
LEFT JOIN m_roles r ON u.role_id = r.role_id
|
|
WHERE u.user_id = $1 AND u.deleted_at IS NULL
|
|
`;
|
|
const result = await pool.query(queryText, [id]);
|
|
return result.recordset[0];
|
|
};
|
|
|
|
// Get user by email (login)
|
|
const getUserByUserEmailDb = async (email) => {
|
|
const queryText = `
|
|
SELECT u.user_id, u.user_fullname, u.user_name, u.user_email, u.user_phone,
|
|
u.user_password, u.is_active, u.is_sa,
|
|
r.role_id, r.role_name
|
|
FROM m_users u
|
|
LEFT JOIN m_roles r ON u.role_id = r.role_id
|
|
WHERE u.user_email = $1 AND u.deleted_at IS NULL
|
|
`;
|
|
const result = await pool.query(queryText, [email]);
|
|
return result.recordset[0];
|
|
};
|
|
|
|
// Get user by username
|
|
const getUserByUsernameDb = async (username) => {
|
|
const queryText = `
|
|
SELECT u.user_id, u.user_fullname, u.user_name, u.user_email, u.user_phone, u.user_password,
|
|
u.is_active, u.role_id,
|
|
r.role_name
|
|
FROM m_users u
|
|
LEFT JOIN m_roles r ON u.role_id = r.role_id
|
|
WHERE u.user_name = $1 AND u.deleted_at IS NULL
|
|
`;
|
|
const result = await pool.query(queryText, [username]);
|
|
return result.recordset[0];
|
|
};
|
|
|
|
// Create user
|
|
const createUserDb = async (data) => {
|
|
const { query: queryText, values } = pool.buildDynamicInsert("m_users", data);
|
|
const result = await pool.query(queryText, values);
|
|
return result.recordset[0]?.inserted_id || null;
|
|
};
|
|
|
|
// Update user
|
|
const updateUserDb = async (userId, data) => {
|
|
const { query: queryText, values } = pool.buildDynamicUpdate("m_users", data, { user_id: userId });
|
|
await pool.query(queryText, values);
|
|
return true;
|
|
};
|
|
|
|
// Change user password
|
|
const changeUserPasswordDb = async (userId, newPassword) => {
|
|
const queryText = `
|
|
UPDATE m_users
|
|
SET user_password = $1, updated_at = GETDATE()
|
|
WHERE user_id = $2 AND deleted_at IS NULL
|
|
`;
|
|
await pool.query(queryText, [newPassword, userId]);
|
|
return true;
|
|
};
|
|
|
|
// Soft delete user
|
|
const deleteUserDb = async (userId, deletedBy) => {
|
|
const queryText = `
|
|
UPDATE m_users
|
|
SET deleted_at = GETDATE(),
|
|
deleted_by = $1
|
|
WHERE user_id = $2
|
|
`;
|
|
await pool.query(queryText, [deletedBy, userId]);
|
|
return true;
|
|
};
|
|
|
|
// Get all roles
|
|
const getAllRoleDb = async () => {
|
|
const queryText = `
|
|
SELECT role_id, role_name
|
|
FROM m_roles
|
|
ORDER BY role_id ASC
|
|
`;
|
|
const result = await pool.query(queryText);
|
|
return result.recordset;
|
|
};
|
|
|
|
module.exports = {
|
|
getAllUsersDb,
|
|
getUserByIdDb,
|
|
getUserByUserEmailDb,
|
|
updateUserDb,
|
|
createUserDb,
|
|
deleteUserDb,
|
|
getUserByUsernameDb,
|
|
changeUserPasswordDb,
|
|
getAllRoleDb,
|
|
};
|