651 lines
19 KiB
JavaScript
651 lines
19 KiB
JavaScript
const { getAllContactDb } = require("../db/contact.db");
|
|
const {
|
|
InsertNotificationErrorDb,
|
|
updateNotificationErrorDb,
|
|
getReminderNotificationErrorByYearlyDb,
|
|
updateNotificationErrorByChanelReminderDb,
|
|
} = require("../db/notification_error.db");
|
|
const {
|
|
createNotificationErrorUserDb,
|
|
updateNotificationErrorUserDb,
|
|
getNotificationErrorByIdDb,
|
|
} = require("../db/notification_error_user.db");
|
|
const {
|
|
generateTokenRedirect,
|
|
shortUrltiny,
|
|
sendNotifikasi,
|
|
} = require("../db/notification_wa.db");
|
|
const { getErrorCodeByBrandAndCodeDb } = require("../db/brand_code.db");
|
|
const { getDeviceNotificationByIdDb } = require("../db/notification_error.db");
|
|
|
|
const { exec } = require("child_process");
|
|
const util = require("util");
|
|
const execPromise = util.promisify(exec);
|
|
const fs = require('fs').promises;
|
|
const path = require("path");
|
|
const { getDeviceReminderChanelDb } = require("../db/device.db");
|
|
|
|
const baseDir = path.resolve(__dirname, '../scheduler');
|
|
const filePath = path.join(baseDir, 'reminder.json');
|
|
// const filePathLog = path.join(baseDir, 'log.json');
|
|
|
|
const dayjs = require('dayjs');
|
|
const utc = require('dayjs/plugin/utc');
|
|
const timezone = require('dayjs/plugin/timezone');
|
|
|
|
const timeZone = 'Asia/Jakarta';
|
|
|
|
dayjs.extend(utc);
|
|
dayjs.extend(timezone);
|
|
|
|
class NotifikasiWaService {
|
|
|
|
async saveReminder(data, isReset = false) {
|
|
console.log(`Reminder dibuat`);
|
|
|
|
try {
|
|
let existing = [];
|
|
|
|
// pastikan folder ada
|
|
await fs.mkdir(path.dirname(filePath), { recursive: true });
|
|
|
|
try {
|
|
const raw = await fs.readFile(filePath, 'utf-8');
|
|
if (raw) {
|
|
existing = JSON.parse(raw);
|
|
}
|
|
} catch (err) {
|
|
// file belum ada → buat file kosong
|
|
await fs.writeFile(filePath, '[]', 'utf-8');
|
|
existing = [];
|
|
}
|
|
|
|
const now = dayjs().tz(timeZone);
|
|
|
|
const newData = {
|
|
...data,
|
|
|
|
// 🔹 jam (HH:mm) WIB
|
|
time: now.format('HH:mm'),
|
|
|
|
// 🔹 timestamp UTC (untuk DB)
|
|
created_at: now.toISOString()
|
|
};
|
|
|
|
let finalData;
|
|
|
|
if (isReset) {
|
|
// kalau reset → replace semua
|
|
|
|
if (
|
|
data &&
|
|
(
|
|
(Array.isArray(data) && data.length > 0) ||
|
|
(typeof data === 'object' && !Array.isArray(data) && Object.keys(data).length > 0)
|
|
)
|
|
) {
|
|
finalData = data;
|
|
} else {
|
|
finalData = [];
|
|
}
|
|
} else {
|
|
existing.push(newData);
|
|
finalData = existing;
|
|
}
|
|
|
|
await fs.writeFile(filePath, JSON.stringify(finalData, null, 2), 'utf-8');
|
|
|
|
// await this.saveReminder({
|
|
// message: `Reminder berhasil disimpan`,
|
|
// data,
|
|
// });
|
|
|
|
} catch (error) {
|
|
next(error);
|
|
}
|
|
}
|
|
|
|
// async saveLogReminder(data) {
|
|
// console.log(`Reminder Log dibuat`);
|
|
|
|
// try {
|
|
// let existing = [];
|
|
|
|
// // pastikan folder ada
|
|
// await fs.mkdir(path.dirname(filePathLog), { recursive: true });
|
|
|
|
// try {
|
|
// const raw = await fs.readFile(filePathLog, 'utf-8');
|
|
// if (raw) {
|
|
// existing = JSON.parse(raw);
|
|
// }
|
|
// } catch (err) {
|
|
// // file belum ada → buat file kosong
|
|
// await fs.writeFile(filePathLog, '[]', 'utf-8');
|
|
// existing = [];
|
|
// }
|
|
|
|
// const now = dayjs().tz(timeZone);
|
|
|
|
// const newData = {
|
|
// ...data,
|
|
|
|
// // 🔹 jam (HH:mm) WIB
|
|
// time: now.format('HH:mm'),
|
|
|
|
// // 🔹 timestamp UTC (untuk DB)
|
|
// created_at: now.toISOString()
|
|
// };
|
|
|
|
// await existing.push(newData);
|
|
|
|
// await fs.writeFile(filePathLog, JSON.stringify(existing, null, 2), 'utf-8');
|
|
|
|
// console.log(`Reminder Log berhasil disimpan`);
|
|
// } catch (error) {
|
|
// console.log('Error saveReminder:', error);
|
|
// }
|
|
// }
|
|
|
|
async onNotification(topic, message) {
|
|
try {
|
|
const paramDb = {
|
|
limit: 100,
|
|
page: 1,
|
|
criteria: "",
|
|
active: 1,
|
|
};
|
|
|
|
// const chanel = {
|
|
// "time": "2025-12-11 11:10:58",
|
|
// "c_4501": 4,
|
|
// "c_5501": 3,
|
|
// "c_6501": 0
|
|
// }
|
|
|
|
if (topic === process.env.TOPIC_COD ?? "morek") {
|
|
const dataMqtt = JSON.parse(message);
|
|
|
|
const resultChanel = [];
|
|
|
|
Object.entries(dataMqtt).forEach(([key, value]) => {
|
|
if (key.startsWith("c_")) {
|
|
resultChanel.push({
|
|
chanel_id: Number(key.slice(2)),
|
|
value,
|
|
});
|
|
}
|
|
});
|
|
|
|
const results = await getAllContactDb(paramDb);
|
|
|
|
const dataUsers = results.data;
|
|
|
|
for (const chanel of resultChanel) {
|
|
const deviceNotification = await getDeviceNotificationByIdDb(
|
|
Number(chanel.chanel_id)
|
|
);
|
|
|
|
const errorCode = await getErrorCodeByBrandAndCodeDb(
|
|
deviceNotification?.brand_id ?? 0,
|
|
chanel.value
|
|
);
|
|
|
|
const data = {
|
|
error_code_id: chanel.value,
|
|
error_chanel: chanel.chanel_id,
|
|
is_send: false,
|
|
is_delivered: false,
|
|
is_read: false,
|
|
is_active: true,
|
|
};
|
|
|
|
const resultNotificationError = await InsertNotificationErrorDb(data);
|
|
|
|
let isSendNotification = false;
|
|
|
|
for (const dataUser of dataUsers) {
|
|
if (dataUser.is_active) {
|
|
const tokenRedirect = await generateTokenRedirect(
|
|
dataUser.contact_phone,
|
|
dataUser.contact_name,
|
|
resultNotificationError.notification_error_id
|
|
);
|
|
|
|
const encodedToken = encodeURIComponent(tokenRedirect);
|
|
|
|
const shortUrl = await shortUrltiny(encodedToken);
|
|
|
|
const bodyMessage =
|
|
`Hai ${dataUser.contact_name || "-"},\n` +
|
|
`Terjadi peringatan dengan kode ${chanel?.value ?? "-"} "${errorCode?.error_code_name ?? ""
|
|
}", Chanel ${chanel?.chanel_id ?? "-"} ` +
|
|
`pada device ${deviceNotification?.device_name ?? "berikut"},` +
|
|
`\nSilahkan cek detail pada link :` +
|
|
`${shortUrl}`;
|
|
|
|
const param = {
|
|
idData: resultNotificationError.notification_error_id,
|
|
userPhone: dataUser.contact_phone,
|
|
userName: dataUser.contact_name,
|
|
bodyMessage: bodyMessage,
|
|
};
|
|
|
|
const resultNotificationErrorUser =
|
|
await createNotificationErrorUserDb({
|
|
notification_error_id: param.idData,
|
|
|
|
contact_phone: param.userPhone,
|
|
contact_name: param.userName,
|
|
message_error_issue: param.bodyMessage,
|
|
is_send: false,
|
|
});
|
|
|
|
const resultSend = await sendNotifikasi(
|
|
param.userPhone,
|
|
param.bodyMessage
|
|
);
|
|
|
|
await updateNotificationErrorUserDb(
|
|
resultNotificationErrorUser[0].notification_error_user_id,
|
|
{
|
|
is_send: resultSend.success,
|
|
}
|
|
);
|
|
|
|
if (resultSend.success) {
|
|
isSendNotification = resultSend.success;
|
|
}
|
|
}
|
|
}
|
|
|
|
await updateNotificationErrorDb(
|
|
resultNotificationError.notification_error_id,
|
|
{
|
|
is_send: isSendNotification,
|
|
is_delivered: isSendNotification,
|
|
}
|
|
);
|
|
}
|
|
}
|
|
} catch (err) {
|
|
return err;
|
|
}
|
|
}
|
|
|
|
async loadReminder() {
|
|
try {
|
|
const raw = await fs.readFile(filePath, 'utf-8');
|
|
return raw ? JSON.parse(raw) : [];
|
|
} catch (err) {
|
|
return []; // file belum ada
|
|
}
|
|
}
|
|
|
|
async deleteReminder(id) {
|
|
const data = await this.loadReminder();
|
|
|
|
id = Number(id);
|
|
|
|
const newData = data?.filter(item => item.notification_log !== id);
|
|
|
|
// cek apakah ada yang terhapus
|
|
if (data.length === newData.length) {
|
|
console.log(`Reminder ${id} tidak ditemukan`);
|
|
return false;
|
|
}
|
|
|
|
await this.saveReminder(newData, true);
|
|
|
|
await this.saveReminder({
|
|
message: `Reminder ${id} berhasil dihapus`
|
|
})
|
|
|
|
console.log(`Reminder ${id} berhasil dihapus`);
|
|
return true;
|
|
}
|
|
|
|
async deleteReminderByChanelReminder(id) {
|
|
let data = await this.loadReminder();
|
|
|
|
const newData = await data?.filter(item => item.error_chanel !== id);
|
|
|
|
// cek apakah ada yang terhapus
|
|
if (data.length === newData.length) {
|
|
console.log(`Reminder ${id} tidak ditemukan`);
|
|
return false;
|
|
}
|
|
|
|
await this.saveReminder(newData, true);
|
|
|
|
await updateNotificationErrorByChanelReminderDb(
|
|
Number(id),
|
|
{
|
|
is_active: false,
|
|
}
|
|
);
|
|
|
|
await this.saveReminder({
|
|
message: `Reminder ${id} berhasil dihapus`
|
|
})
|
|
|
|
console.log(`Reminder ${id} berhasil dihapus`);
|
|
return true;
|
|
}
|
|
|
|
async runReminder() {
|
|
setInterval(async () => {
|
|
let data = await this.loadReminder();
|
|
|
|
if (Array.isArray(data) && data.length > 0) {
|
|
|
|
// waktu sekarang (WIB)
|
|
const now = dayjs().tz(timeZone);
|
|
|
|
const newData = [];
|
|
for (const item of data) {
|
|
|
|
// skip kalau tidak aktif
|
|
if (!item.active) continue;
|
|
|
|
// skip kalau sudah max
|
|
if (item.count >= item.max) continue;
|
|
|
|
// 🔹 parse last_run (ISO dari DB)
|
|
const lastRunDate = dayjs(item.last_run);
|
|
|
|
if (!lastRunDate.isValid()) {
|
|
throw new Error(`Invalid last_run: ${item.last_run}`);
|
|
}
|
|
|
|
// 🔹 hitung next_run berdasarkan interval (jam)
|
|
const nextRun = lastRunDate.add(item.interval, 'hour');
|
|
|
|
// 🔹 assign hasil
|
|
item.next_run = nextRun.toISOString(); // UTC (untuk DB)
|
|
item.next_run_indo = nextRun.tz(timeZone).format('DD-MM-YYYY HH:mm:ss');
|
|
|
|
// 🔥 trigger check
|
|
if (now.isAfter(nextRun) || now.isSame(nextRun)) {
|
|
|
|
const results = await getNotificationErrorByIdDb(item.notification_log);
|
|
const dataUsers = results?.data ?? [];
|
|
|
|
for (const dataUser of dataUsers) {
|
|
const resultSend = await sendNotifikasi(
|
|
dataUser.userPhone,
|
|
dataUser.bodyMessage
|
|
);
|
|
|
|
await this.saveReminder(resultSend);
|
|
|
|
await updateNotificationErrorUserDb(
|
|
dataUser.notification_error_user_id,
|
|
{
|
|
is_send: resultSend.success,
|
|
}
|
|
);
|
|
|
|
if (resultSend.success) {
|
|
await updateNotificationErrorDb(
|
|
item.notification_log,
|
|
{
|
|
is_send: true,
|
|
is_delivered: true,
|
|
}
|
|
);
|
|
}
|
|
}
|
|
item.last_run = now.toISOString(); // tetap UTC (standar DB)
|
|
item.last_run_indo = now.format('DD-MM-YYYY HH:mm:ss'); // WIB
|
|
item.count += 1;
|
|
}
|
|
|
|
newData.push(item);
|
|
}
|
|
|
|
await this.saveReminder(newData, true);
|
|
}
|
|
|
|
}, 60 * 1000);
|
|
}
|
|
|
|
async onNotificationReminder(topic, message) {
|
|
try {
|
|
const paramDb = {
|
|
limit: 100,
|
|
page: 1,
|
|
criteria: "",
|
|
active: 1,
|
|
};
|
|
|
|
// const chanel = {
|
|
// "time": "2025-12-11 11:10:58",
|
|
// "c_4501": 4,
|
|
// "c_5501": 3,
|
|
// "c_6501": 0
|
|
// }
|
|
|
|
if (topic === process.env.TOPIC_COD_REMINDER ?? "morek") {
|
|
const dataMqtt = JSON.parse(message);
|
|
|
|
const resultChanel = [];
|
|
|
|
Object.entries(dataMqtt).forEach(([key, value]) => {
|
|
if (key.startsWith("c_")) {
|
|
resultChanel.push({
|
|
chanel_id: Number(key.slice(2)),
|
|
value,
|
|
});
|
|
}
|
|
});
|
|
|
|
// console.log('Reminder triggered A',resultChanel);
|
|
|
|
for (const chanel of resultChanel) {
|
|
|
|
const deviceReminder = await getDeviceReminderChanelDb(
|
|
Number(chanel.chanel_id)
|
|
);
|
|
|
|
if (deviceReminder?.[0]?.reminder_at) {
|
|
// waktu sekarang (WIB)
|
|
const now = dayjs().tz(timeZone);
|
|
|
|
const currentYear = dayjs().tz(timeZone).year();
|
|
|
|
// parse dari DB
|
|
const reminderAt = dayjs.tz(
|
|
deviceReminder[0].reminder_at,
|
|
'YYYY-MM-DD HH:mm:ss.SSS',
|
|
timeZone
|
|
);
|
|
|
|
const deviceName = deviceReminder[0].device_name ?? '-';
|
|
|
|
// 🔥 compare sampai menit (tanpa tahun)
|
|
const nowKey = now.format('MM-DD HH:mm');
|
|
const reminderKey = reminderAt.format('MM-DD HH:mm');
|
|
|
|
const isTriggered = nowKey >= reminderKey;
|
|
|
|
if (isTriggered) {
|
|
const valMqtt = chanel.value;
|
|
const yearly = parseInt(valMqtt.match(/\d+/)?.[0], 10);
|
|
|
|
if (!isNaN(yearly)) {
|
|
const checkNotifExist = await getReminderNotificationErrorByYearlyDb(yearly ?? chanel.value, chanel.chanel_id, currentYear);
|
|
|
|
if (!checkNotifExist) {
|
|
|
|
const data = {
|
|
error_code_id: yearly ?? chanel.value,
|
|
error_chanel: chanel.chanel_id,
|
|
is_send: 0,
|
|
is_delivered: 0,
|
|
is_read: 0,
|
|
is_active: 1,
|
|
message_error_issue: `reminder ${chanel.value} in ${currentYear}`,
|
|
};
|
|
|
|
const resultNotificationError = await InsertNotificationErrorDb(data);
|
|
|
|
const results = await getAllContactDb(paramDb);
|
|
|
|
const dataUsers = results.data;
|
|
|
|
let isSendNotification = false;
|
|
|
|
for (const dataUser of dataUsers) {
|
|
if (dataUser.is_active) {
|
|
|
|
const tokenRedirect = await generateTokenRedirect(
|
|
dataUser.contact_phone,
|
|
dataUser.contact_name,
|
|
resultNotificationError.notification_error_id
|
|
);
|
|
|
|
const encodedToken = encodeURIComponent(tokenRedirect);
|
|
|
|
const shortUrl = await shortUrltiny(encodedToken);
|
|
|
|
const bodyMessage =
|
|
`Hai ${dataUser.contact_name || "-"},\n` +
|
|
`Diberitahukan bahwa terdapat sparepart pada device "${deviceName ?? "-"}" ` +
|
|
`yang telah memasuki jadwal perawatan tahunan.\n` +
|
|
`\nSilakan segera lakukan pengecekan dan perawatan untuk memastikan kinerja tetap optimal.` +
|
|
`\nDetail sparepart dapat dilihat pada link berikut:\n${shortUrl}`;
|
|
|
|
const param = {
|
|
idData: resultNotificationError.notification_error_id,
|
|
userPhone: dataUser.contact_phone,
|
|
userName: dataUser.contact_name,
|
|
bodyMessage: bodyMessage,
|
|
};
|
|
|
|
const resultNotificationErrorUser =
|
|
await createNotificationErrorUserDb({
|
|
notification_error_id: param.idData,
|
|
|
|
contact_phone: param.userPhone,
|
|
contact_name: param.userName,
|
|
message_error_issue: param.bodyMessage,
|
|
is_send: false,
|
|
});
|
|
|
|
const resultSend = await sendNotifikasi(
|
|
param.userPhone,
|
|
param.bodyMessage
|
|
);
|
|
|
|
// await this.saveLogReminder({
|
|
// message: `Reminder dijalankan`,
|
|
// resultSend
|
|
// })
|
|
|
|
await updateNotificationErrorUserDb(
|
|
resultNotificationErrorUser[0].notification_error_user_id,
|
|
{
|
|
is_send: resultSend.success,
|
|
}
|
|
);
|
|
|
|
await this.saveReminder({
|
|
notification_log: resultNotificationError.notification_error_id,
|
|
error_code_id: data['error_code_id'],
|
|
error_chanel: data['error_chanel'],
|
|
start_at: reminderAt.format('HH:mm'),
|
|
interval: 1,
|
|
max: 3,
|
|
active: 1,
|
|
count: 0,
|
|
last_run: now.toISOString(),
|
|
last_run_indo: now.format('DD-MM-YYYY HH:mm:ss'),
|
|
next_run: null,
|
|
next_run_indo: null,
|
|
message: `Reminder untuk ${deviceName} dengan reminder ${chanel.value} telah dijalankan pada ${now.format('DD-MM-YYYY HH:mm:ss')}, hasil pengiriman: ${resultSend.success ? 'sukses' : 'gagal'}`,
|
|
}, false);
|
|
|
|
if (resultSend.success) {
|
|
isSendNotification = resultSend.success;
|
|
}
|
|
}
|
|
}
|
|
|
|
await updateNotificationErrorDb(
|
|
resultNotificationError.notification_error_id,
|
|
{
|
|
is_send: isSendNotification,
|
|
is_delivered: isSendNotification,
|
|
}
|
|
);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
} catch (err) {
|
|
console.log('Error onNotificationReminder:', err);
|
|
throw err;
|
|
}
|
|
}
|
|
|
|
async restartWhatsapp() {
|
|
try {
|
|
|
|
const processName = "cod-whatsapp-notif";
|
|
const { stdout } = await execPromise("pm2 jlist");
|
|
const cleanJSON = stdout.replace(/[\u001b\u009b][[()#;?]*(?:[0-9]{1,4}(?:;[0-9]{0,4})*)?[0-9A-ORZcf-nqry=><]/g, '');
|
|
|
|
const startJSON = cleanJSON.indexOf('[');
|
|
const endJSON = cleanJSON.lastIndexOf(']') + 1;
|
|
|
|
if (startJSON === -1 || endJSON === 0) {
|
|
throw new Error(`Terminal tidak mengembalikan JSON yang valid. Output: ${stdout}`);
|
|
}
|
|
|
|
const index = cleanJSON.slice(startJSON, endJSON);
|
|
const processes = JSON.parse(index);
|
|
const waProcess = processes.find((p) => p.name === processName);
|
|
|
|
if (!waProcess) throw new Error(`PM2 proses dengan nama "${processName}" tidak ditemukan!`);
|
|
|
|
const waProcessId = waProcess.pm_id;
|
|
const pathDelete = waProcess.pm2_env.pm_cwd;
|
|
|
|
// console.log(`stop proses id: ${waProcessId}`);
|
|
await execPromise(`pm2 stop ${waProcessId}`);
|
|
|
|
const pathFolderDelete = [
|
|
path.join(pathDelete, ".wwebjs_auth"),
|
|
path.join(pathDelete, ".wwebjs_cache"),
|
|
];
|
|
|
|
// console.log(`path: ${pathDelete}`);
|
|
|
|
for (const dir of pathFolderDelete) {
|
|
try {
|
|
await fs.access(dir);
|
|
console.log(`path folder ditemukan, menghapus: ${dir}`);
|
|
|
|
await fs.rm(dir, { recursive: true, force: true });
|
|
} catch (fsErr) {
|
|
if (fsErr.code !== 'ENOENT') {
|
|
console.error(`Gagal memproses folder ${dir}:`, fsErr.message);
|
|
}
|
|
}
|
|
}
|
|
|
|
// console.log(`start proses id: ${waProcessId}`);
|
|
await execPromise(`pm2 start ${waProcessId}`);
|
|
|
|
return { success: true, message: "WhatsApp has been restarted." };
|
|
} catch (err) {
|
|
return { success: false, error: err.message || err };
|
|
}
|
|
}
|
|
}
|
|
|
|
module.exports = new NotifikasiWaService();
|