+ Kriteriniz: ${kriterMetni} — toplam ${yeniler.length} yeni ihale. + Bu bildirimi uygulamadaki Mobil PWA → E-posta Bildirimi bölümünden kapatabilirsiniz. +
`; + + await sendEmail({ + to: a.email, + subject: `İhaleist — ${yeniler.length} yeni ihale (${kriterMetni})`, + html, + }); + markSent(a.id, eslesen.map((t) => t.id)); + gonderilen++; + console.log(`[notifier] ${a.email} → ${yeniler.length} yeni ihale gönderildi (${kriterMetni})`); + } catch (e) { + hata++; + console.warn(`[notifier] abonelik ${a.id} gönderilemedi: ${e.message}`); + } + } + return { abonelik: abonelikler.length, gonderilen, hata }; +} diff --git a/server/notify-store.mjs b/server/notify-store.mjs new file mode 100644 index 0000000..f7d4793 --- /dev/null +++ b/server/notify-store.mjs @@ -0,0 +1,128 @@ +/** + * Otomatik e-posta bildirimi abonelikleri (SQLite). + * Kullanıcı kendi filtre kriterlerini kaydeder; zamanlayıcı yeni eşleşen + * ihaleleri bulup özet e-posta gönderir. + */ + +import fs from 'node:fs'; +import path from 'node:path'; +import { fileURLToPath } from 'node:url'; + +let DatabaseSync = null; +try { + ({ DatabaseSync } = await import('node:sqlite')); +} catch { + console.warn('[notify-store] node:sqlite yok — otomatik bildirim devre dışı'); +} + +const __dirname = path.dirname(fileURLToPath(import.meta.url)); +const DATA_DIR = path.join(__dirname, 'data'); +const DB_PATH = path.join(DATA_DIR, 'notify.sqlite'); + +const SCHEMA = ` +CREATE TABLE IF NOT EXISTS abonelikler ( + id INTEGER PRIMARY KEY AUTOINCREMENT, + email TEXT NOT NULL, + ad TEXT, + sehir TEXT, + sektor TEXT, + alim_turu TEXT, + anahtar TEXT, + kurumlar TEXT, -- JSON: favori kurum listesi + aktif INTEGER NOT NULL DEFAULT 1, + sonGonderim TEXT, + sonGorulenler TEXT, -- JSON: son gönderimde bildirilen ihale id'leri + olusturma TEXT, + UNIQUE(email, sehir, sektor, alim_turu, anahtar) +); +CREATE INDEX IF NOT EXISTS idx_abone_email ON abonelikler(email); +`; + +export function available() { + return Boolean(DatabaseSync); +} + +function open({ create = true } = {}) { + if (!DatabaseSync) return null; + if (!fs.existsSync(DB_PATH)) { + if (!create) return null; + fs.mkdirSync(DATA_DIR, { recursive: true }); + } + const db = new DatabaseSync(DB_PATH); + db.exec(SCHEMA); + return db; +} + +const bosaNull = (v) => (v == null || v === '' ? '' : String(v).trim()); + +export function subscribe(email, kriter = {}, ad = null) { + const db = open(); + if (!db) throw new Error('Bildirim deposu kullanılamıyor'); + try { + db.prepare(` + INSERT INTO abonelikler (email, ad, sehir, sektor, alim_turu, anahtar, kurumlar, aktif, olusturma) + VALUES (?,?,?,?,?,?,?,1,?) + ON CONFLICT(email, sehir, sektor, alim_turu, anahtar) DO UPDATE SET + aktif=1, kurumlar=excluded.kurumlar, ad=excluded.ad + `).run( + email, + ad, + bosaNull(kriter.sehir), + bosaNull(kriter.sektor), + bosaNull(kriter.alimTuru), + bosaNull(kriter.anahtar), + JSON.stringify(kriter.kurumlar || []), + new Date().toISOString() + ); + return list(email); + } finally { + db.close(); + } +} + +export function list(email) { + const db = open({ create: false }); + if (!db) return []; + try { + const rows = email + ? db.prepare('SELECT * FROM abonelikler WHERE email=? ORDER BY id DESC').all(email) + : db.prepare('SELECT * FROM abonelikler WHERE aktif=1 ORDER BY id').all(); + return rows.map((r) => ({ + id: r.id, + email: r.email, + ad: r.ad, + sehir: r.sehir || null, + sektor: r.sektor || null, + alimTuru: r.alim_turu || null, + anahtar: r.anahtar || null, + kurumlar: (() => { try { return JSON.parse(r.kurumlar || '[]'); } catch { return []; } })(), + aktif: Boolean(r.aktif), + sonGonderim: r.sonGonderim, + sonGorulenler: (() => { try { return JSON.parse(r.sonGorulenler || '[]'); } catch { return []; } })(), + })); + } finally { + db.close(); + } +} + +export function remove(id, email) { + const db = open({ create: false }); + if (!db) return false; + try { + const r = db.prepare('DELETE FROM abonelikler WHERE id=? AND email=?').run(id, email); + return r.changes > 0; + } finally { + db.close(); + } +} + +export function markSent(id, ihaleIdleri) { + const db = open({ create: false }); + if (!db) return; + try { + db.prepare('UPDATE abonelikler SET sonGonderim=?, sonGorulenler=? WHERE id=?') + .run(new Date().toISOString(), JSON.stringify(ihaleIdleri.slice(0, 400)), id); + } finally { + db.close(); + } +} diff --git a/server/scheduler.mjs b/server/scheduler.mjs index 7a5d299..9fe933e 100644 --- a/server/scheduler.mjs +++ b/server/scheduler.mjs @@ -14,6 +14,7 @@ import os from 'node:os'; import path from 'node:path'; import { fileURLToPath } from 'node:url'; import { historyStats } from './history-store.mjs'; +import { bildirimleriIsle } from './notifier.mjs'; const __dirname = path.dirname(fileURLToPath(import.meta.url)); @@ -137,7 +138,24 @@ export function schedulerStatus() { }; } -export function startScheduler() { +// --- Otomatik e-posta bildirimi --- +let bildirimCalisiyor = false; + +async function bildirimTuru(tenderGetir) { + if (bildirimCalisiyor) return; + bildirimCalisiyor = true; + try { + const s = await bildirimleriIsle(tenderGetir); + if (s.atlandi) console.log(`[scheduler] bildirim atlandı: ${s.atlandi}`); + else console.log(`[scheduler] bildirim turu: ${s.abonelik} abonelik, ${s.gonderilen || 0} e-posta, ${s.hata || 0} hata`); + } catch (e) { + console.warn('[scheduler] bildirim hatası:', e.message); + } finally { + bildirimCalisiyor = false; + } +} + +export function startScheduler({ tenderGetir } = {}) { if (process.env.SCAN_ENABLED === '0') { console.log('[scheduler] devre dışı (SCAN_ENABLED=0)'); return; @@ -158,4 +176,14 @@ export function startScheduler() { setTimeout(dtTara, 4 * 60 * 1000).unref?.(); setInterval(dtTara, Math.max(1, dtSaat) * 3600 * 1000).unref?.(); } + + // Otomatik e-posta bildirimi + if (process.env.NOTIFY_ENABLED === '0' || !tenderGetir) { + console.log('[scheduler] otomatik e-posta bildirimi devre dışı'); + } else { + const nSaat = Number(process.env.NOTIFY_INTERVAL_SAAT || 6); + console.log(`[scheduler] otomatik e-posta bildirimi her ${nSaat} saatte bir kontrol edilecek`); + setTimeout(() => bildirimTuru(tenderGetir), 6 * 60 * 1000).unref?.(); + setInterval(() => bildirimTuru(tenderGetir), Math.max(1, nSaat) * 3600 * 1000).unref?.(); + } } diff --git a/src/components/tools/NotifySubscriptions.jsx b/src/components/tools/NotifySubscriptions.jsx new file mode 100644 index 0000000..7c6f00a --- /dev/null +++ b/src/components/tools/NotifySubscriptions.jsx @@ -0,0 +1,197 @@ +import React, { useState, useEffect } from 'react'; +import { useApp } from '../../context/AppContext'; +import { getToken } from '../../services/auth'; +import { BellRing, Plus, Trash2, Loader2, AlertTriangle, Info, MapPin, Tag, Building2, Search } from 'lucide-react'; + +/** + * Otomatik e-posta bildirimi abonelikleri. + * Kullanıcı kriter kaydeder; sunucu periyodik olarak eşleşen YENİ ihaleleri + * e-posta ile gönderir. + */ +export const NotifySubscriptions = () => { + const { + authUser, favoriteKurumlar, + selectedCity, selectedSektor, selectedAlimTuru, searchQuery, + } = useApp(); + + const [abonelikler, setAbonelikler] = useState(null); + const [busy, setBusy] = useState(false); + const [error, setError] = useState(null); + const [kriter, setKriter] = useState({ sehir: '', sektor: '', alimTuru: '', anahtar: '', favoriKurumlar: false }); + + const yukle = () => { + if (!authUser) return; + fetch('/api/notify/subscriptions', { headers: { Authorization: `Bearer ${getToken()}` } }) + .then((r) => r.json()) + .then((d) => setAbonelikler(d.abonelikler || [])) + .catch(() => setAbonelikler([])); + }; + useEffect(yukle, [authUser]); + + // Ekrandaki aktif filtreleri forma taşı + const filtreleriAl = () => setKriter({ + sehir: selectedCity || '', + sektor: selectedSektor || '', + alimTuru: selectedAlimTuru || '', + anahtar: searchQuery || '', + favoriKurumlar: false, + }); + + const kaydet = async () => { + setBusy(true); setError(null); + try { + const res = await fetch('/api/notify/subscriptions', { + method: 'POST', + headers: { 'Content-Type': 'application/json', Authorization: `Bearer ${getToken()}` }, + body: JSON.stringify({ + kriter: { + sehir: kriter.sehir, sektor: kriter.sektor, + alimTuru: kriter.alimTuru, anahtar: kriter.anahtar, + kurumlar: kriter.favoriKurumlar ? favoriteKurumlar : [], + }, + }), + }); + const d = await res.json(); + if (!d.success) throw new Error(d.error); + setAbonelikler(d.abonelikler); + setKriter({ sehir: '', sektor: '', alimTuru: '', anahtar: '', favoriKurumlar: false }); + } catch (e) { setError(e.message); } + finally { setBusy(false); } + }; + + const sil = async (id) => { + setBusy(true); + try { + const res = await fetch(`/api/notify/subscriptions?id=${id}`, { + method: 'DELETE', headers: { Authorization: `Bearer ${getToken()}` }, + }); + const d = await res.json(); + setAbonelikler(d.abonelikler || []); + } catch (e) { setError(e.message); } + finally { setBusy(false); } + }; + + const ozet = (a) => [ + a.sehir && `İl: ${a.sehir}`, + a.sektor && `Sektör: ${a.sektor}`, + a.alimTuru && `Tür: ${a.alimTuru}`, + a.anahtar && `“${a.anahtar}”`, + a.kurumlar?.length && `${a.kurumlar.length} favori kurum`, + ].filter(Boolean).join(' · ') || 'Tüm ihaleler'; + + if (!authUser) return null; + + return ( ++ Kaydettiğiniz kriterlere uyan yeni ihaleler çıktığında + {authUser.email} adresine otomatik özet gönderilir. Sunucu bunu + periyodik olarak kontrol eder; aynı ihale iki kez bildirilmez. +
+ + {/* Mevcut abonelikler */} + {abonelikler === null ? ( ++ Henüz kriter eklemediniz. Aşağıdan ekleyin — boş bırakırsanız tüm yeni ihaleler bildirilir. +
+ ) : ( +{ozet(a)}
++ {a.sonGonderim ? `son gönderim: ${new Date(a.sonGonderim).toLocaleString('tr-TR')}` : 'ilk tur bekleniyor'} +
+{error}
++ İlk kriter eklendiğinde mevcut ihaleler bildirilmez — yalnızca temel alınır. + Bundan sonra çıkan yeni ihaleler gönderilir, böylece ilk gün yüzlerce eski ilanla dolmaz. + Sonuçlanmış arşiv kayıtları bildirime girmez. +
+