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

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

Browse Source 
Reviewed-on: #64
This commit is contained in:
zain_arif
2026-07-08 07:18:55 +00:00
parent 1735db35ef 13ce1705fa
commit a0330f5635
3 changed files with 55 additions and 54 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
db/device.db.js
View File

@@ -155,15 +155,14 @@ const getDeviceReminderMonthlyDb = async (id) => {
return result.recordset; return result.recordset;
}; };
const updateDeviceReminderMonthlyDb = async (deviceId, reminderMonthly, period) => { const updateDeviceReminderMonthlyDb = async (deviceId, reminderMonthly) => {
const queryText = ` const queryText = `
UPDATE m_device UPDATE m_device
SET reminder_at_monthly = $1, SET reminder_at_monthly = $1,
period = $2
updated_at = CURRENT_TIMESTAMP updated_at = CURRENT_TIMESTAMP
WHERE device_id = $2 AND deleted_at IS NULL WHERE device_id = $2 AND deleted_at IS NULL
`; `;
await pool.query(queryText, [reminderMonthly, deviceId, period]); await pool.query(queryText, [reminderMonthly, deviceId]);
return getDeviceByIdDb(deviceId); return getDeviceByIdDb(deviceId);
}; };

102
routes/notifikasi-wa.route.js
View File

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

2
services/notifikasi-wa.service.js
View File

@@ -614,7 +614,7 @@ class NotifikasiWaService {
} }
async onMonthlyReminder(deviceId, reminderMonthly, period) { async onMonthlyReminder(deviceId, reminderMonthly) {
try { try {
const paramDb = { const paramDb = {