yogiedigital/cod-api
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

repair: get all notification

Browse Source
This commit is contained in:
mhmmdafif
2025-11-14 08:53:58 +07:00
parent c8149c2359
commit b8dd4a61f8
2 changed files with 97 additions and 65 deletions
Download Patch File Download Diff File Expand all files Collapse all files

160
db/notification.db.js
View File

@@ -1,15 +1,56 @@
const pool = require("../config"); const pool = require("../config");
const InsertNotificationErrorDb = async () => {
const insertQuery = `
INSERT INTO notification_error (
error_code_id,
is_active,
is_delivered,
is_read,
is_send,
message_error_issue
)
SELECT
b.error_code_id,
1 AS is_active,
1 AS is_delivered,
0 AS is_read,
1 AS is_send,
COALESCE(b.error_code_description, '') AS message_error_issue
FROM brand_code b
LEFT JOIN notification_error ne
ON ne.error_code_id = b.error_code_id
AND ne.deleted_at IS NULL
LEFT JOIN brand_code_solution c
ON c.error_code_id = b.error_code_id
AND c.deleted_at IS NULL
WHERE b.deleted_at IS NULL
AND ne.notification_error_id IS NULL
`;
await pool.query(insertQuery);
};
const getAllNotificationDb = async (searchParams = {}) => { const getAllNotificationDb = async (searchParams = {}) => {
let queryParams = []; let queryParams = [];
await InsertNotificationErrorDb();
if (searchParams.limit) { if (searchParams.limit) {
const page = Number(searchParams.page ?? 1) - 1; const page = Number(searchParams.page ?? 1) - 1;
queryParams = [Number(searchParams.limit ?? 10), page]; queryParams = [Number(searchParams.limit ?? 10), page];
} }
const { whereOrConditions, whereParamOr } = pool.buildStringOrIlike( const { whereOrConditions, whereParamOr } = pool.buildStringOrIlike(
["a.is_send", "a.is_delivered", "a.is_read", "a.is_active"], [
"b.error_code",
"b.error_code_name",
"c.solution_name",
"COALESCE(a.is_send, 0)",
"COALESCE(a.is_delivered, 0)",
"COALESCE(a.is_read, 0)",
"COALESCE(a.is_active, 0)",
],
searchParams.criteria, searchParams.criteria,
queryParams queryParams
); );
@@ -17,10 +58,26 @@ const getAllNotificationDb = async (searchParams = {}) => {
const { whereConditions, whereParamAnd } = pool.buildFilterQuery( const { whereConditions, whereParamAnd } = pool.buildFilterQuery(
[ [
{ column: "a.is_delivered", param: searchParams.is_delivered, type: "int" }, {
{ column: "a.is_send", param: searchParams.is_send, type: "int" }, column: "COALESCE(a.is_send, 0)",
{ column: "a.is_read", param: searchParams.is_read, type: "int" }, param: searchParams.is_send,
{ column: "a.is_active", param: searchParams.is_active, type: "int" }, type: "int",
},
{
column: "COALESCE(a.is_delivered, 0)",
param: searchParams.is_delivered,
type: "int",
},
{
column: "COALESCE(a.is_read, 0)",
param: searchParams.is_read,
type: "int",
},
{
column: "COALESCE(a.is_active, 0)",
param: searchParams.is_active,
type: "int",
},
], ],
queryParams queryParams
); );
@@ -28,80 +85,53 @@ const getAllNotificationDb = async (searchParams = {}) => {
const queryText = ` const queryText = `
SELECT SELECT
COUNT(*) OVER() AS total_data, COUNT(*) OVER() AS total_data,
a.*,
a.notification_error_id,
COALESCE(a.is_send, 0) AS is_send,
COALESCE(a.is_delivered, 0) AS is_delivered,
COALESCE(a.is_read, 0) AS is_read,
COALESCE(a.is_active, 0) AS is_active,
a.message_error_issue,
b.error_code_id,
b.error_code, b.error_code,
b.error_code_name, b.error_code_name,
b.error_code_description,
c.solution_name, c.solution_name,
c.type_solution, c.type_solution,
c.path_solution c.path_solution
FROM notification_error a
LEFT JOIN brand_code b ON a.error_code_id = b.error_code_id AND b.deleted_at IS NULL FROM brand_code b
LEFT JOIN brand_code_solution c ON a.error_code_id = c.error_code_id AND c.deleted_at IS NULL LEFT JOIN notification_error a
WHERE a.deleted_at IS NULL ON a.error_code_id = b.error_code_id
${whereConditions.length > 0 ? ` AND ${whereConditions.join(" AND ")}` : ""} AND a.deleted_at IS NULL
LEFT JOIN brand_code_solution c
ON b.error_code_id = c.error_code_id
AND c.deleted_at IS NULL
WHERE b.deleted_at IS NULL
${
whereConditions.length > 0
? ` AND ${whereConditions.join(" AND ")}`
: ""
}
${whereOrConditions ? ` ${whereOrConditions}` : ""} ${whereOrConditions ? ` ${whereOrConditions}` : ""}
ORDER BY a.notification_error_id ASC
${searchParams.limit ? `OFFSET $2 * $1 ROWS FETCH NEXT $1 ROWS ONLY` : ''} ORDER BY b.error_code_id ASC
${searchParams.limit ? `OFFSET $2 * $1 ROWS FETCH NEXT $1 ROWS ONLY` : ""}
`; `;
const result = await pool.query(queryText, queryParams); const result = await pool.query(queryText, queryParams);
const total = const total =
result?.recordset?.length > 0 result.recordset?.length > 0 ? Number(result.recordset[0].total_data) : 0;
? parseInt(result.recordset[0].total_data, 10)
: 0;
return { data: result.recordset, total }; return { data: result.recordset, total };
}; };
const getNotificationByIdDb = async (id) => {
const queryText = `
SELECT a.*,
b.error_code,
b.error_code_name,
b.error_code_description,
c.solution_name,
c.type_solution,
c.path_solution
FROM notification_error a
LEFT JOIN brand_code b ON a.error_code_id = b.error_code_id AND b.deleted_at IS NULL
LEFT JOIN brand_code_solution c ON a.error_code_id = c.error_code_id AND c.deleted_at IS NULL
WHERE a.notification_error_id = $1 AND a.deleted_at IS NULL
`;
const result = await pool.query(queryText, [id]);
return result.recordset?.[0] || null;
};
const insertNotificationDb = async (store) => {
const { query: queryText, values } = pool.buildDynamicInsert("notification_error", store);
const result = await pool.query(queryText, values);
const insertedId = result.recordset?.[0]?.inserted_id;
return insertedId ? await getNotificationByIdDb(insertedId) : null;
};
const updateNotificationDb = async (id, data) => {
const store = { ...data };
const whereData = { notification_error_id: id };
const { query: queryText, values } = pool.buildDynamicUpdate("notification_error", store, whereData);
await pool.query(`${queryText} AND deleted_at IS NULL`, values);
return getNotificationByIdDb(id);
};
const deleteNotificationDb = async (id, deletedBy) => {
const queryText = `
UPDATE notification_error
SET deleted_at = CURRENT_TIMESTAMP, deleted_by = $1
WHERE notification_error_id = $2 AND deleted_at IS NULL
`;
await pool.query(queryText, [deletedBy, id]);
return true;
};
module.exports = { module.exports = {
getAllNotificationDb, getAllNotificationDb,
getNotificationByIdDb,
insertNotificationDb,
updateNotificationDb,
deleteNotificationDb,
}; };

2
routes/index.js
View File

@@ -15,6 +15,7 @@ const UserSchedule = require("./user_schedule.route")
const historyValue = require("./history_value.route") const historyValue = require("./history_value.route")
const contact = require("./contact.route") const contact = require("./contact.route")
const brandSparePart = require("./brand_sparepart.route") const brandSparePart = require("./brand_sparepart.route")
const notification = require("./notification.route")
router.use("/auth", auth); router.use("/auth", auth);
router.use("/user", users); router.use("/user", users);
@@ -32,6 +33,7 @@ router.use("/user-schedule", UserSchedule)
router.use("/history", historyValue) router.use("/history", historyValue)
router.use("/contact", contact) router.use("/contact", contact)
router.use("/brand-sparepart", brandSparePart) router.use("/brand-sparepart", brandSparePart)
router.use("/notification", notification)
module.exports = router; module.exports = router;