add: CRUD tags
This commit is contained in:
Muhammad Afif
116
db/tag.db.js
116
db/tag.db.js
@@ -1,116 +0,0 @@
|
||||
const { query, buildFilterQuery, buildDynamicUpdate } = require("../config");
|
||||
|
||||
// Get all tags
|
||||
const getAllTagsDb = async (searchParams = {}) => {
|
||||
const { whereConditions, queryParams } = buildFilterQuery([
|
||||
{ column: "mt.tag_name", param: searchParams.name, type: "string" },
|
||||
{ column: "mt.tag_code", param: searchParams.code, type: "string" },
|
||||
{
|
||||
column: "md.device_name",
|
||||
param: searchParams.deviceName,
|
||||
type: "string",
|
||||
},
|
||||
{
|
||||
column: "pss.sub_section_name",
|
||||
param: searchParams.subSectionName,
|
||||
type: "string",
|
||||
},
|
||||
]);
|
||||
|
||||
const whereClause = whereConditions.length
|
||||
? `AND ${whereConditions.join(" AND ")}`
|
||||
: "";
|
||||
|
||||
const queryText = `
|
||||
SELECT
|
||||
mt.tag_id, mt.device_id, mt.tag_code, mt.tag_name, mt.tag_number,
|
||||
mt.data_type, mt.unit, mt.is_active, mt.sub_section_id,
|
||||
mt.created_at, mt.updated_at, mt.deleted_at,
|
||||
md.device_name,md.ip_address,
|
||||
pss.sub_section_code, pss.sub_section_name
|
||||
FROM m_tags mt
|
||||
INNER JOIN m_device md ON mt.device_id = md.device_id
|
||||
INNER JOIN plant_sub_section pss ON mt.sub_section_id = pss.sub_section_id
|
||||
WHERE mt.deleted_at IS NULL ${whereClause}
|
||||
ORDER BY mt.tag_id ASC
|
||||
`;
|
||||
const result = await query(queryText, queryParams);
|
||||
return result.recordset;
|
||||
};
|
||||
|
||||
// Get tag by ID
|
||||
const getTagByIdDb = async (id) => {
|
||||
const queryText = `
|
||||
SELECT
|
||||
mt.tag_id, mt.device_id, mt.tag_code, mt.tag_name, mt.tag_number,
|
||||
mt.data_type, mt.unit, mt.is_active, mt.sub_section_id,
|
||||
mt.created_at, mt.updated_at, mt.deleted_at,
|
||||
md.device_name,
|
||||
pss.sub_section_code, pss.sub_section_name
|
||||
FROM m_tags mt
|
||||
LEFT JOIN m_device md ON mt.device_id = md.device_id
|
||||
LEFT JOIN plant_sub_section pss ON mt.sub_section_id = pss.sub_section_id
|
||||
WHERE mt.tag_id = $1 AND mt.deleted_at IS NULL
|
||||
`;
|
||||
const result = await query(queryText, [id]);
|
||||
return result.recordset[0];
|
||||
};
|
||||
|
||||
// Create tag
|
||||
const createTagDb = async (data) => {
|
||||
const queryText = `
|
||||
INSERT INTO m_tags
|
||||
(device_id, tag_code, tag_name, tag_number, data_type, unit, is_active, sub_section_id, created_by)
|
||||
VALUES
|
||||
($1,$2,$3,$4,$5,$6,$7,$8,$9);
|
||||
SELECT SCOPE_IDENTITY() as tag_id;
|
||||
`;
|
||||
|
||||
const values = [
|
||||
data.device_id,
|
||||
data.tag_code,
|
||||
data.tag_name,
|
||||
data.tag_number,
|
||||
data.data_type,
|
||||
data.unit,
|
||||
data.is_active || 1, //default aktif
|
||||
data.sub_section_id,
|
||||
data.created_by,
|
||||
];
|
||||
|
||||
const result = await query(queryText, values);
|
||||
return result.recordset[0]?.tag_id;
|
||||
};
|
||||
|
||||
const updateTagDb = async (tagId, data) => {
|
||||
const { query: queryText, values } = buildDynamicUpdate("m_tags", data, {
|
||||
tag_id: tagId,
|
||||
updated_at: "GETDATE()",
|
||||
});
|
||||
const finalQuery = queryText.replace("WHERE", "WHERE deleted_at IS NULL AND");
|
||||
await query(finalQuery, values);
|
||||
return true;
|
||||
};
|
||||
|
||||
const deleteTagDb = async (tagId, deletedBy) => {
|
||||
const queryText = `
|
||||
UPDATE m_tags
|
||||
SET
|
||||
deleted_at = GETDATE(),
|
||||
deleted_by = $1,
|
||||
is_active = 0
|
||||
WHERE tag_id = $2
|
||||
AND deleted_at IS NULL
|
||||
`;
|
||||
|
||||
await query(queryText, [deletedBy, tagId]);
|
||||
return true;
|
||||
};
|
||||
|
||||
module.exports = {
|
||||
getAllTagsDb,
|
||||
getTagByIdDb,
|
||||
createTagDb,
|
||||
updateTagDb,
|
||||
deleteTagDb,
|
||||
};
|
||||
144
db/tags.db.js
Normal file
144
db/tags.db.js
Normal file
@@ -0,0 +1,144 @@
|
||||
const pool = require("../config");
|
||||
|
||||
// Get all tags
|
||||
const getAllTagsDb = async (searchParams = {}) => {
|
||||
let queryParams = [];
|
||||
|
||||
if (searchParams.limit) {
|
||||
const page = Number(searchParams.page ?? 1) - 1;
|
||||
queryParams = [Number(searchParams.limit ?? 10), page];
|
||||
}
|
||||
|
||||
const { whereOrConditions, whereParamOr } = pool.buildStringOrIlike(
|
||||
[
|
||||
"a.tag_name",
|
||||
"a.tag_code",
|
||||
"a.tag_number",
|
||||
"a.data_type",
|
||||
"a.unit",
|
||||
"b.device_name",
|
||||
"c.sub_section_name",
|
||||
],
|
||||
searchParams.criteria,
|
||||
queryParams
|
||||
);
|
||||
|
||||
if (whereParamOr) queryParams = whereParamOr;
|
||||
|
||||
// Filter tambahan (AND conditions)
|
||||
const { whereConditions, whereParamAnd } = pool.buildFilterQuery(
|
||||
[
|
||||
{ column: "a.tag_name", param: searchParams.name, type: "string" },
|
||||
{ column: "a.tag_code", param: searchParams.code, type: "string" },
|
||||
{ column: "a.data_type", param: searchParams.data, type: "string" },
|
||||
{ column: "a.unit", param: searchParams.unit, type: "string" },
|
||||
{ column: "b.device_name", param: searchParams.device, type: "string" },
|
||||
{
|
||||
column: "b.device_description",
|
||||
param: searchParams.device,
|
||||
type: "string",
|
||||
},
|
||||
{ column: "b.ip_address", param: searchParams.device, type: "string" },
|
||||
{
|
||||
column: "c.sub_section_name",
|
||||
param: searchParams.subsection,
|
||||
type: "string",
|
||||
},
|
||||
],
|
||||
queryParams
|
||||
);
|
||||
|
||||
if (whereParamAnd) queryParams = whereParamAnd;
|
||||
|
||||
const queryText = `
|
||||
SELECT
|
||||
COUNT(*) OVER() AS total_data,
|
||||
a.*,
|
||||
b.device_name,
|
||||
b.device_location,
|
||||
b.device_description,
|
||||
c.sub_section_name
|
||||
FROM m_tags a
|
||||
LEFT JOIN m_device b ON a.device_id = b.device_id
|
||||
LEFT JOIN plant_sub_section c ON a.sub_section_id = c.sub_section_id
|
||||
WHERE a.deleted_at IS NULL
|
||||
${whereConditions.length > 0 ? ` AND ${whereConditions.join(" AND ")}` : ""}
|
||||
${whereOrConditions ? ` ${whereOrConditions}` : ""}
|
||||
ORDER BY a.tag_id ASC
|
||||
${searchParams.limit ? `OFFSET $2 ROWS FETCH NEXT $1 ROWS ONLY` : ""}
|
||||
`;
|
||||
|
||||
const result = await pool.query(queryText, queryParams);
|
||||
|
||||
const total =
|
||||
result?.recordset?.length > 0
|
||||
? parseInt(result.recordset[0].total_data, 10)
|
||||
: 0;
|
||||
|
||||
return { data: result.recordset, total };
|
||||
};
|
||||
|
||||
const getTagsByIdDb = async (id) => {
|
||||
const queryText = `
|
||||
SELECT
|
||||
a.*,
|
||||
b.device_name,
|
||||
b.device_location,
|
||||
b.device_description,
|
||||
c.sub_section_name
|
||||
FROM m_tags a
|
||||
LEFT JOIN m_device b ON a.device_id = b.device_id
|
||||
LEFT JOIN plant_sub_section c ON a.sub_section_id = c.sub_section_id
|
||||
WHERE a.tag_id = $1 AND a.deleted_at IS NULL
|
||||
`;
|
||||
const result = await pool.query(queryText, [id]);
|
||||
return result.recordset;
|
||||
};
|
||||
|
||||
const createTagsDb = async (data) => {
|
||||
const newCode = await pool.generateKode("TAG", "m_tags", "tag_code");
|
||||
|
||||
const store = {
|
||||
...data,
|
||||
tag_code: newCode,
|
||||
};
|
||||
|
||||
const { query: queryText, values } = pool.buildDynamicInsert("m_tags", store);
|
||||
const result = await pool.query(queryText, values);
|
||||
const insertedId = result.recordset[0]?.inserted_id;
|
||||
|
||||
return insertedId ? await getTagsByIdDb(insertedId) : null;
|
||||
};
|
||||
|
||||
const updateTagsDb = async (id, data) => {
|
||||
const store = { ...data };
|
||||
const whereData = { tag_id: id };
|
||||
|
||||
const { query: queryText, values } = pool.buildDynamicUpdate(
|
||||
"m_tags",
|
||||
store,
|
||||
whereData
|
||||
);
|
||||
|
||||
await pool.query(`${queryText} AND deleted_at IS NULL`, values);
|
||||
return getTagsByIdDb(id);
|
||||
};
|
||||
|
||||
// Soft delete tag
|
||||
const deleteTagsDb = async (id, deletedBy) => {
|
||||
const queryText = `
|
||||
UPDATE m_tags
|
||||
SET deleted_at = CURRENT_TIMESTAMP, deleted_by = $1
|
||||
WHERE tag_id = $2 AND deleted_at IS NULL
|
||||
`;
|
||||
await pool.query(queryText, [deletedBy, id]);
|
||||
return true;
|
||||
};
|
||||
|
||||
module.exports = {
|
||||
getAllTagsDb,
|
||||
getTagsByIdDb,
|
||||
createTagsDb,
|
||||
updateTagsDb,
|
||||
deleteTagsDb,
|
||||
};
|
||||
Reference in New Issue
Block a user