Merge pull request 'wisdom' (#64) from wisdom into main

Reviewed-on: #64

app.js

@@ -9,7 +9,7 @@ const compression = require("compression");
 const unknownEndpoint = require("./middleware/unKnownEndpoint");
 const { handleError } = require("./helpers/error");
 const { checkConnection, mqttClient } = require("./config");
-const { onNotification } = require("./services/notifikasi-wa.service");
+const notifikasiWaService = require("./services/notifikasi-wa.service");
 
 const app = express();
 
@@ -50,8 +50,11 @@ app.use(handleError);
 
 // Saat pesan diterima
 mqttClient.on('message', (topic, message) => {
-  console.log(`Received message on topic "${topic}":`, message.toString());
+  // console.log(`Received message on topic "${topic}":`, message.toString());
-  onNotification(topic, message);
+  notifikasiWaService.onNotification(topic, message);
+  notifikasiWaService.onNotificationReminder(topic, message);
 });
 
+notifikasiWaService.runReminder();
+
 module.exports = app;

config/index.js

@@ -57,7 +57,7 @@ async function query(text, params = []) {
   // Ubah $1, $2 jadi @p1, @p2
   const sqlText = text.replace(/\$(\d+)/g, (_, num) => `@p${num}`);
 
-  console.log(sqlText, params);
+  // console.log(sqlText, params);
   return request.query(sqlText);
 }
 
@@ -301,7 +301,10 @@ const mqttOptions = {
 };
 
 const mqttUrl = process.env.MQTT_HOST; // Ganti dengan broker kamu
-const topic = process.env.TOPIC_COD ?? 'morek';
+const topics = [
+  process.env.TOPIC_COD ?? 'PIU_COD/ERROR_CODE',
+  process.env.TOPIC_COD_REMINDER ?? 'PIU_COD/REMINDERSPAREPART'
+];
 
 const mqttClient = mqtt.connect(mqttUrl, mqttOptions);
 
@@ -310,9 +313,9 @@ mqttClient.on('connect', () => {
   console.log('MQTT connected');
 
   // Subscribe ke topik tertentu
-  mqttClient.subscribe(topic, (err) => {
+  mqttClient.subscribe(topics, (err) => {
     if (!err) {
-      console.log(`Subscribed to topic "${topic}"`);
+      console.log(`Subscribed to topic "${topics}"`);
     } else {
       console.error('Subscribe error:', err);
     }

db/contact.db.js

@@ -25,6 +25,7 @@ const getAllContactDb = async (searchParams = {}) => {
       { column: "a.contact_name", param: searchParams.name, type: "string" },
       { column: "a.contact_type", param: searchParams.code, type: "string" },
       { column: "a.is_active", param: searchParams.active, type: "boolean" },
+      { column: "a.email", param: searchParams.email, type: "string" },
     ],
     queryParams
   );

db/device.db.js

@@ -63,12 +63,12 @@ const getAllDevicesDb = async (searchParams = {}) => {
   return { data: result.recordset, total };
 };
 
-
 const getDeviceByIdDb = async (id) => {
   const queryText = `
     SELECT 
     a.*,
     b.brand_name,
+    a.reminder_at AT TIME ZONE 'UTC' AT TIME ZONE 'SE Asia Standard Time' AS reminder_at_local,
     COALESCE(a.device_code, '') + ' - ' + COALESCE(a.device_name, '') AS device_code_name
     FROM m_device a
     LEFT JOIN m_brands b ON a.brand_id = b.brand_id
@@ -115,19 +115,94 @@ const updateDeviceDb = async (id, data) => {
 };
 
 const deleteDeviceDb = async (id, deletedBy) => {
+  // Jika deletedBy adalah string, konversi ke integer atau gunakan default
+  const deletedById = typeof deletedBy === 'string' ? parseInt(deletedBy) || 0 : deletedBy || 0;
+  
   const queryText = `
     UPDATE m_device
     SET deleted_at = CURRENT_TIMESTAMP, deleted_by = $1
     WHERE device_id = $2 AND deleted_at IS NULL
   `;
-  await pool.query(queryText, [deletedBy, id]);
+  await pool.query(queryText, [deletedById, id]);
   return true;
 };
 
+const getDeviceReminderChanelDb = async (id) => {
+  const queryText = `
+    SELECT 
+    a.*,
+    b.brand_name,
+    COALESCE(a.device_code, '') + ' - ' + COALESCE(a.device_name, '') AS device_code_name
+    FROM m_device a
+    LEFT JOIN m_brands b ON a.brand_id = b.brand_id
+    WHERE a.listen_channel_reminder = $1 AND a.deleted_at IS NULL
+  `;
+  const result = await pool.query(queryText, [id]);
+  return result.recordset;
+};
+
+const getDeviceReminderMonthlyDb = async (id) => {
+  const queryText = `
+    SELECT 
+    a.*,
+    b.brand_name,
+    COALESCE(a.device_code, '') + ' - ' + COALESCE(a.device_name, '') AS device_code_name
+    FROM m_device a
+    LEFT JOIN m_brands b ON a.brand_id = b.brand_id
+    WHERE a.device_id = $1 AND a.deleted_at IS NULL
+  `;
+  const result = await pool.query(queryText, [id]);
+  return result.recordset;
+};
+
+const updateDeviceReminderMonthlyDb = async (deviceId, reminderMonthly) => {
+  const queryText = `
+    UPDATE m_device
+    SET reminder_at_monthly = $1,
+        updated_at = CURRENT_TIMESTAMP
+    WHERE device_id = $2 AND deleted_at IS NULL
+  `;
+  await pool.query(queryText, [reminderMonthly, deviceId]);
+  return getDeviceByIdDb(deviceId);
+};
+
+const getDeviceReminderCustomDb = async (id) => {
+  const queryText = `
+    SELECT 
+    a.*,
+    b.brand_name,
+    COALESCE(a.device_code, '') + ' - ' + COALESCE(a.device_name, '') AS device_code_name
+    FROM m_device a
+    LEFT JOIN m_brands b ON a.brand_id = b.brand_id
+    WHERE a.device_id = $1 
+      AND a.deleted_at IS NULL 
+  `;
+  const result = await pool.query(queryText, [id]);
+  return result.recordset;
+};
+
+const updateDeviceReminderCustomDb = async (deviceId, startDate, endDate) => {
+  const queryText = `
+    UPDATE m_device
+    SET start_date = $1, 
+        end_date = $2,
+        updated_at = CURRENT_TIMESTAMP
+    WHERE device_id = $3 AND deleted_at IS NULL
+  `;
+  await pool.query(queryText, [startDate, endDate, deviceId]);
+  return getDeviceByIdDb(deviceId);
+};
+
+
 module.exports = {
   getAllDevicesDb,
   getDeviceByIdDb,
   createDeviceDb,
   updateDeviceDb,
   deleteDeviceDb,
-};
+  getDeviceReminderChanelDb,
+  getDeviceReminderMonthlyDb,
+  getDeviceReminderCustomDb,
+  updateDeviceReminderCustomDb,
+  updateDeviceReminderMonthlyDb
+};

db/notification_error.db.js

@@ -17,10 +17,10 @@ const getNotificationByIdDb = async (id) => {
       a.*,
       b.plant_sub_section_id,
       c.plant_sub_section_name,
-      d.device_code,
+      COALESCE(d.device_code, f.device_code) AS device_code,
-      d.device_name,
+      COALESCE(d.device_name, f.device_name) AS device_name,
-      d.device_location,
+      COALESCE(d.device_location, f.device_location) AS device_location,
-      d.listen_channel,
+      COALESCE(d.listen_channel, f.listen_channel_reminder) AS listen_channel,
       e.brand_name,
       e.brand_id
 
@@ -34,6 +34,9 @@ const getNotificationByIdDb = async (id) => {
 
     LEFT JOIN m_device d
         ON a.error_chanel = d.listen_channel AND d.deleted_at IS NULL
+    
+    LEFT JOIN m_device f
+        ON a.error_chanel = f.listen_channel_reminder AND d.deleted_at IS NULL
 
     LEFT JOIN m_brands e
         ON d.brand_id = e.brand_id AND d.deleted_at IS NULL
@@ -61,6 +64,25 @@ const getDeviceNotificationByIdDb = async (chanel_id) => {
   return result.recordset[0];
 };
 
+const getDeviceChannelReminder = async (chanel_reminder) => {
+  const queryText = `
+    SELECT 
+      brand_id,
+      device_code, 
+      device_name, 
+      device_location, 
+      listen_channel,
+      listen_channel_reminder,
+      reminder_at,
+
+    FROM m_device 
+    WHERE listen_channel_reminder = $1 
+    AND deleted_at IS NULL 
+  `;
+  const result = await pool.query(queryText, [chanel_reminder]);
+  return result.recordset[0];
+};
+
 
 const getAllNotificationDb = async (searchParams = {}) => {
   let queryParams = [];
@@ -177,6 +199,19 @@ const updateNotificationErrorDb = async (id, data) => {
   return getNotificationByIdDb(id);
 };
 
+const updateNotificationErrorByChanelReminderDb = async (id, data) => {
+  const store = { ...data };
+  const whereData = { error_chanel: id };
+
+  const { query: queryText, values } = pool.buildDynamicUpdate(
+    "notification_error",
+    store,
+    whereData
+  );
+
+  return await pool.query(`${queryText} AND deleted_at IS NULL`, values);
+};
+
 const getUsersNotificationErrorDb = async (id) => {
   const queryText = `
     SELECT 
@@ -202,12 +237,65 @@ const getUsersNotificationErrorDb = async (id) => {
   return result.recordset;
 };
 
+const getReminderNotificationErrorByYearlyDb = async (errorCode, chanel, year) => {
+  const queryText = `
+    SELECT a.*
+
+    FROM notification_error a
+    
+    WHERE a.error_code_id = $1 
+      AND a.error_chanel = $2 
+      AND YEAR(a.created_at) = $3
+      AND a.message_error_issue LIKE 'reminder%'
+      AND a.is_active = 1
+      AND a.deleted_at IS NULL
+  `;
+
+  const result = await pool.query(queryText, [errorCode, chanel, year]);
+  return result.recordset[0];
+};
+
+const getReminderNotificationErrorByMonthlyDb = async (errorCode, monthly, deviceId) => {
+  const queryText = `
+    SELECT a.*
+    FROM notification_error a
+    WHERE a.error_code_id = $1 
+      AND MONTH(a.created_at) = $2
+      AND a.message_error_issue LIKE '%device_id: ' + CAST($3 AS VARCHAR) + '%'
+      AND a.is_active = 1
+      AND a.deleted_at IS NULL
+  `;
+
+  const result = await pool.query(queryText, [errorCode, monthly, deviceId]);
+  return result.recordset[0];
+};
+
+const getReminderNotificationErrorByCustomDb = async (errorCode, custom, deviceId) => {
+  const queryText = `
+    SELECT a.*
+    FROM notification_error a
+    WHERE a.error_code_id = $1 
+      AND a.created_at = $2
+      AND a.message_error_issue LIKE '%device_id: ' + CAST($3 AS VARCHAR) + '%'
+      AND a.is_active = 1
+      AND a.deleted_at IS NULL
+  `;
+
+  const result = await pool.query(queryText, [errorCode, custom, deviceId]);
+  return result.recordset[0];
+};
+
 module.exports = {
   getNotificationByIdDb,
   getDeviceNotificationByIdDb,
   getAllNotificationDb,
   InsertNotificationErrorDb,
   updateNotificationErrorDb,
-  getUsersNotificationErrorDb
+  getUsersNotificationErrorDb,
+  getDeviceChannelReminder,
+  getReminderNotificationErrorByYearlyDb,
+  getReminderNotificationErrorByMonthlyDb,
+  getReminderNotificationErrorByCustomDb,
+  updateNotificationErrorByChanelReminderDb
 
 };

db/sparepart.db.js

@@ -179,6 +179,60 @@ const getSparepartsByIdsDb = async (sparepartIds) => {
   return result.recordset;
 };
 
+const getSparepartsByYearlyDb = async (yearly) => {
+
+  const queryText = `
+    SELECT *
+    FROM m_sparepart
+    WHERE deleted_at IS NULL
+    AND EXISTS (
+      SELECT 1
+      FROM OPENJSON(sparepart_yearly)
+      WHERE value = $1
+    )
+  `;
+
+  const result = await pool.query(queryText, [yearly]);
+
+  return result.recordset;
+};
+
+const getSparepartsByMonthlyDb = async (monthly) => {
+
+  const queryText = `
+    SELECT *
+    FROM m_sparepart
+    WHERE deleted_at IS NULL
+    AND EXISTS (
+      SELECT 1
+      FROM OPENJSON(sparepart_monthly)
+      WHERE value = $1
+    )
+  `;
+
+  const result = await pool.query(queryText, [monthly]);
+
+  return result.recordset;
+};
+
+const getSparepartsByCustomDb = async (custom) => {
+
+  const queryText = `
+    SELECT *
+    FROM m_sparepart
+    WHERE deleted_at IS NULL
+    AND EXISTS (
+      SELECT 1
+      FROM OPENJSON(sparepart_custom)
+      WHERE value = $1
+    )
+  `;
+
+  const result = await pool.query(queryText, [custom]);
+
+  return result.recordset;
+};
+
 module.exports = {
   getAllSparepartDb,
   getSparepartByIdDb,
@@ -187,4 +241,7 @@ module.exports = {
   createSparepartDb,
   updateSparepartDb,
   deleteSparepartDb,
+  getSparepartsByYearlyDb,
+  getSparepartsByMonthlyDb,
+  getSparepartsByCustomDb
 };

package.json

@@ -29,6 +29,7 @@
     "cors": "^2.8.5",
     "crypto": "^1.0.1",
     "crypto-js": "^4.2.0",
+    "dayjs": "^1.11.20",
     "dotenv": "^8.2.0",
     "exceljs": "^4.4.0",
     "express": "^4.18.2",
@@ -44,6 +45,7 @@
     "mqtt": "^5.14.0",
     "mssql": "^11.0.1",
     "multer": "^1.4.5-lts.2",
+    "node-cron": "^4.5.0",
     "nodemailer": "^6.8.0",
     "pg": "^8.8.0",
     "pino": "^6.11.3",

routes/notifikasi-wa.route.js

@@ -1,5 +1,8 @@
 const express = require('express');
 const router = express.Router();
+
+const verifyToken = require("../middleware/verifyToken");
+const verifyAccess = require("../middleware/verifyAccess");
 const NotifikasiWaService = require('../services/notifikasi-wa.service');
 
 router.post('/restart-wa', async (req, res) => {
@@ -11,4 +14,73 @@ router.post('/restart-wa', async (req, res) => {
   }
 });
 
+router.post('/reminder-monthly/:id', verifyToken.verifyAccessToken, verifyAccess(), async (req, res) => {
+  try {
+    const { id } = req.params;
+    const { reminder_at_monthly } = req.body;
+    const result = await NotifikasiWaService.onMonthlyReminder(id, reminder_at_monthly);
+    return res.status(200).json(result);
+  } catch (error) {
+    return res.status(500).json(error);
+  }
+});
+
+router.post('/reminder-custom/:id', verifyToken.verifyAccessToken, verifyAccess(), async (req, res) => {
+  try {
+    const { id } = req.params;
+    const { start_date, end_date } = req.body;
+    const result = await NotifikasiWaService.onCustomReminder(id, start_date, end_date);
+    return res.status(200).json(result);
+  } catch (error) {
+    return res.status(500).json(error);
+  }
+});
+
+// router.get('/cron/jobs', async (req, res) => {
+//   try {
+//     const activeJobs = NotifikasiWaService.getActiveCronJobs();
+//     return res.status(200).json({
+//       success: true,
+//       total: activeJobs.length,
+//       jobs: activeJobs
+//     });
+//   } catch (error) {
+//     return res.status(500).json({ 
+//       success: false, 
+//       message: error.message 
+//     });
+//   }
+// });
+
+// router.delete('/cron/jobs/:deviceId', async (req, res) => {
+//   try {
+//     const { deviceId } = req.params;
+//     NotifikasiWaService.stopCronJob(deviceId);
+//     return res.status(200).json({
+//       success: true,
+//       message: `Cron job untuk device ${deviceId} dihentikan`
+//     });
+//   } catch (error) {
+//     return res.status(500).json({ 
+//       success: false, 
+//       message: error.message 
+//     });
+//   }
+// });
+
+// router.delete('/cron/jobs', async (req, res) => {
+//   try {
+//     NotifikasiWaService.stopAllCronJobs();
+//     return res.status(200).json({
+//       success: true,
+//       message: 'Semua cron job dihentikan'
+//     });
+//   } catch (error) {
+//     return res.status(500).json({ 
+//       success: false, 
+//       message: error.message 
+//     });
+//   }
+// });
+
 module.exports = router;

services/device.service.js

@@ -5,7 +5,9 @@ const {
   updateDeviceDb,
   deleteDeviceDb
 } = require('../db/device.db');
+const { updateNotificationErrorByChanelReminderDb } = require('../db/notification_error.db');
 const { ErrorHandler } = require('../helpers/error');
+const notifikasiWaService = require('./notifikasi-wa.service');
 
 class DeviceService {
   // Get all devices
@@ -59,6 +61,17 @@ class DeviceService {
         throw new ErrorHandler(404, 'Device not found');
       }
 
+      const updateStatus = await updateNotificationErrorByChanelReminderDb(
+        Number(dataExist[0].listen_channel_reminder),
+        { is_active: 0, userId: data.userId }
+      );
+
+      await notifikasiWaService.deleteReminderByChanelReminder(Number(dataExist[0].listen_channel_reminder));
+
+      if (!updateStatus) {
+        throw new ErrorHandler(500, 'Failed to update notification');
+      }
+
       const result = await updateDeviceDb(id, data);
 
       return result;

services/notification_error.service.js

@@ -31,6 +31,9 @@ const {
 } = require("../db/notification_wa.db");
 
 const { ErrorHandler } = require("../helpers/error");
+const { getSparepartsByYearlyDb, getSparepartsByMonthlyDb } = require("../db/sparepart.db");
+
+const notifikasiWaService = require("./notifikasi-wa.service");
 
 class NotificationService {
   static async getAllNotification(param) {
@@ -134,6 +137,23 @@ class NotificationService {
 
       notification.activity_logs = notificationLogs;
 
+      notification.is_reminder = false;
+      notification.spareparts_reminder = [];
+      if (notification.message_error_issue) {
+
+        const [sparepartsYearly, sparepartsMonthly] = await Promise.all([
+          getSparepartsByYearlyDb(notification.error_code_id),
+          getSparepartsByMonthlyDb(notification.error_code_id)
+        ]);
+
+        notification.spareparts_reminder = [
+          ...(sparepartsYearly ?? []),
+          ...(sparepartsMonthly ?? [])
+        ];
+
+        notification.is_reminder = true;
+      }
+
       return notification;
     } catch (error) {
       throw new ErrorHandler(error.statusCode, error.message);
@@ -150,6 +170,8 @@ class NotificationService {
 
       const notification = Array.isArray(dataExist) ? dataExist[0] : dataExist;
 
+      await notifikasiWaService.deleteReminder(notification_error_id)
+
       if (notification.is_read === true) {
         return { success: true, message: "Notification has already been read" };
       }

services/sparepart.service.js

@@ -28,7 +28,10 @@ class SparepartService {
         throw new ErrorHandler(404, "Sparepart not found");
       }
 
-      sparepart[0].sparepart_yearly = JSON.parse(sparepart[0].sparepart_yearly);
+      if (sparepart[0]) {
+        if (sparepart[0].sparepart_yearly) sparepart[0].sparepart_yearly = JSON.parse(sparepart[0].sparepart_yearly);
+        if (sparepart[0].sparepart_monthly) sparepart[0].sparepart_monthly = JSON.parse(sparepart[0].sparepart_monthly);
+      }
 
       return sparepart[0];
     } catch (error) {
@@ -49,6 +52,10 @@ class SparepartService {
         data.sparepart_yearly = JSON.stringify(data.sparepart_yearly);
       }
 
+      if (data.sparepart_monthly) {
+        data.sparepart_monthly = JSON.stringify(data.sparepart_monthly);
+      }
+
       const created = await createSparepartDb(data);
       if (!created) throw new ErrorHandler(500, "Failed to create Sparepart");
       return created;
@@ -70,14 +77,17 @@ class SparepartService {
           data.sparepart_number,
           id
         );
-        if (exists)
-          throw new ErrorHandler(400, "Sparepart name already exists");
       }
 
       if (data.sparepart_yearly) {
         data.sparepart_yearly = JSON.stringify(data.sparepart_yearly);
       }
 
+      if (data.sparepart_monthly) {
+        data.sparepart_monthly = JSON.stringify(data.sparepart_monthly);
+      }
+
+
       const updated = await updateSparepartDb(id, data);
       if (!updated) throw new ErrorHandler(500, "Failed to update Sparepart");
       return await this.getSparepartById(id);

validate/contact.schema.js

@@ -13,7 +13,8 @@ const insertContactSchema = Joi.object({
         "Phone number must be a valid Indonesian number in format +628XXXXXXXXX",
     }),
   is_active: Joi.boolean().required(),
-  contact_type: Joi.string().max(255).optional().allow(null)
+  contact_type: Joi.string().max(255).optional().allow(null),
+  email: Joi.string().email().optional().allow(null)
 });
 
 const updateContactSchema = Joi.object({
@@ -26,7 +27,8 @@ const updateContactSchema = Joi.object({
         "Phone number must be a valid Indonesian number in format +628XXXXXXXXX",
     }),
   is_active: Joi.boolean().optional(),
-  contact_type: Joi.string().max(255).optional().allow(null)
+  contact_type: Joi.string().max(255).optional().allow(null),
+  email: Joi.string().email().optional().allow(null)
 });
 
 module.exports = {

validate/device.schema.js

@@ -19,6 +19,9 @@ const insertDeviceSchema = Joi.object({
     listen_channel: Joi.string().max(100).required(),
     listen_channel_reminder: Joi.string().max(100).allow('', null),
     reminder_at: Joi.date().iso().allow('', null),
+    reminder_at_monthly: Joi.date().iso().allow('', null),
+    start_date: Joi.date().iso().allow('', null),
+    end_date: Joi.date().iso().allow('', null),
 });
 
 const updateDeviceSchema = Joi.object({
@@ -35,6 +38,9 @@ const updateDeviceSchema = Joi.object({
     listen_channel: Joi.string().max(100),
     listen_channel_reminder: Joi.string().max(100).allow('', null),
     reminder_at: Joi.date().iso().allow('', null),
+    reminder_at_monthly: Joi.date().iso().allow('', null),
+    start_date: Joi.date().iso().allow('', null),
+    end_date: Joi.date().iso().allow('', null),
 
 }).min(1);
 

validate/sparepart.schema.js

@@ -14,6 +14,11 @@ const insertSparepartSchema = Joi.object({
   sparepart_merk: Joi.string().max(255).optional(),
   sparepart_stok: Joi.string().max(255).optional(),
   sparepart_yearly: Joi.array()
+    .items(Joi.number().integer())
+    .min(0)
+    .allow(null)
+    .optional(),
+  sparepart_monthly: Joi.array()
     .items(Joi.number().integer())
     .min(0)
     .allow(null)
@@ -33,11 +38,17 @@ const updateSparepartSchema = Joi.object({
   sparepart_merk: Joi.string().max(255).optional(),
   sparepart_stok: Joi.string().max(255).optional(),
   sparepart_yearly: Joi.array()
+    .items(Joi.number().integer())
+    .min(0)
+    .allow(null)
+    .optional(),
+  sparepart_monthly: Joi.array()
     .items(Joi.number().integer())
     .min(0)
     .allow(null)
     .optional()
-});
+})
+
 module.exports = {
   insertSparepartSchema,
   updateSparepartSchema,