diff --git a/services/telegramBot.js b/services/telegramBot.js index bdeb560..7556b3f 100644 --- a/services/telegramBot.js +++ b/services/telegramBot.js @@ -7,6 +7,9 @@ const mikrotikSvc = require('./mikrotikService'); const customerDevice = require('./customerDeviceService'); const whatsappService = require('./whatsappService'); const db = require('../config/database'); +const monitoringSvc = require('./monitoringService'); +const oltSvc = require('./oltService'); +const ticketSvc = require('./ticketService'); let bot = null; @@ -680,6 +683,76 @@ function initTelegram() { bot.sendMessage(msg.chat.id, res, { parse_mode: 'Markdown' }); }); + + // โ”€โ”€ Monitoring (admin): /sistem /tunggakan /tiket /olt /trafik โ”€โ”€ + bot.onText(/\/(sistem|monitor|health)/i, async (msg) => { + if (!isAdmin(msg)) return; + try { + const h = monitoringSvc.getHealthStatus(); + const m = (h && h.metrics) ? h.metrics : monitoringSvc.getAllMetrics(); + const sys = (m && m.system) || {}; + const cpu = (sys.cpu && sys.cpu.usage != null) ? sys.cpu.usage : '-'; + const cores = (sys.cpu && sys.cpu.cores) ? sys.cpu.cores : '-'; + const ram = (sys.memory && sys.memory.percentage != null) ? sys.memory.percentage : '-'; + const ramUsed = (sys.memory && sys.memory.used) ? sys.memory.used : '-'; + const ramTotal = (sys.memory && sys.memory.total) ? sys.memory.total : '-'; + const disk = (m && m.disk && m.disk.percentage) ? m.disk.percentage : '-'; + const la = sys.loadAverage || {}; + let t = `๐Ÿ–ฅ๏ธ *MONITORING SISTEM*\n\n`; + t += `โš™๏ธ CPU : *${cpu}%* (${cores} core)\n`; + t += `๐Ÿง  RAM : *${ram}%* (${ramUsed}/${ramTotal})\n`; + t += `๐Ÿ“€ Disk: *${disk}*\n`; + t += `โณ Load: ${la['1min'] != null ? la['1min'] : '-'} / ${la['5min'] != null ? la['5min'] : '-'} / ${la['15min'] != null ? la['15min'] : '-'}\n`; + t += `๐Ÿ•’ Uptime: ${sys.uptime || '-'}\n`; + if (h && h.issues && h.issues.length) t += `\n๐Ÿ”ด *Masalah:*\n- ${h.issues.join('\n- ')}`; + if (h && h.warnings && h.warnings.length) t += `\n๐ŸŸก *Peringatan:*\n- ${h.warnings.join('\n- ')}`; + bot.sendMessage(msg.chat.id, t, { parse_mode: 'Markdown' }); + } catch (e) { bot.sendMessage(msg.chat.id, 'Gagal: ' + e.message); } + }); + + bot.onText(/\/tunggakan/i, async (msg) => { + if (!isAdmin(msg)) return; + try { + const row = db.prepare("SELECT COUNT(*) c, COALESCE(SUM(amount),0) s FROM invoices WHERE status='unpaid'").get(); + const top = db.prepare("SELECT c.name, COALESCE(c.customer_code,'-') code, SUM(i.amount) t FROM invoices i JOIN customers c ON c.id=i.customer_id WHERE i.status='unpaid' GROUP BY i.customer_id ORDER BY t DESC LIMIT 8").all(); + let t = `๐Ÿ’ฐ *TUNGGAKAN*\n\nTotal: *${row.c} tagihan*\nNominal: *Rp ${Number(row.s).toLocaleString('id-ID')}*\n`; + if (top.length) { t += `\n*Top ${top.length}:*\n`; top.forEach((r, i) => { t += `${i + 1}. ${r.name} (${r.code}) โ€” Rp ${Number(r.t).toLocaleString('id-ID')}\n`; }); } + bot.sendMessage(msg.chat.id, t, { parse_mode: 'Markdown' }); + } catch (e) { bot.sendMessage(msg.chat.id, 'Gagal: ' + e.message); } + }); + + bot.onText(/\/tiket/i, async (msg) => { + if (!isAdmin(msg)) return; + try { + const s = ticketSvc.getTicketStats(); + const open = ticketSvc.getAllTickets('open') || []; + let t = `๐ŸŽซ *TIKET*\n\nOpen: *${s.open}* ยท Proses: *${s.inProgress}* ยท Selesai: *${s.resolved}*\n`; + if (open.length) { t += `\n*Open terbaru:*\n`; open.slice(0, 8).forEach(x => { t += `#${x.id} ${x.subject} โ€” ${x.customer_name || '-'}\n`; }); } + bot.sendMessage(msg.chat.id, t, { parse_mode: 'Markdown' }); + } catch (e) { bot.sendMessage(msg.chat.id, 'Gagal: ' + e.message); } + }); + + bot.onText(/\/(olt|oltstatus|olt-status)/i, async (msg) => { + if (!isAdmin(msg)) return; + bot.sendMessage(msg.chat.id, '๐Ÿ“ก Mengambil status OLT, mohon tungguโ€ฆ'); + try { + const o = await oltSvc.getAllOltsStats(); + let t = `๐Ÿ“ก *OLT STATUS*\n\nONU total: *${o.onus_total}*\n๐ŸŸข Online: *${o.onus_online}*\n๐Ÿ”ด Offline: *${o.onus_offline}*\n๐ŸŸก Lemah: *${o.onus_weak}*\n`; + if (o.error) t += `\n_Catatan: ${o.error}_`; + bot.sendMessage(msg.chat.id, t, { parse_mode: 'Markdown' }); + } catch (e) { bot.sendMessage(msg.chat.id, 'Gagal: ' + e.message); } + }); + + bot.onText(/\/(trafik|online)/i, async (msg) => { + if (!isAdmin(msg)) return; + try { + let count = 0; + try { const map = await mikrotikSvc.getAllActiveSessionsMap(); count = (map && map.size != null) ? map.size : ((map && map.length) || 0); } catch (e) {} + const t = `๐Ÿ“ถ *SESI AKTIF*\n\nPPPoE/Hotspot online: *${count}* sesi\n`; + bot.sendMessage(msg.chat.id, t, { parse_mode: 'Markdown' }); + } catch (e) { bot.sendMessage(msg.chat.id, 'Gagal: ' + e.message); } + }); + bot.onText(/\/ringkasan/i, async (msg) => { if (!isAdmin(msg)) return; const chatId = msg.chat.id;