Files
clinera-site/send-to-obaid.js

201 lines
6.6 KiB
JavaScript

// Send booking confirmation to obaid
const { PrismaClient } = require('@prisma/client');
const crypto = require('crypto');
const prisma = new PrismaClient();
async function sendToObaid() {
console.log('📱 SENDING MESSAGE TO OBAID');
console.log('='.repeat(40));
try {
// 1. Find obaid's lead
console.log('1️⃣ Finding obaid...');
const obaidLead = await prisma.lead.findFirst({
where: {
OR: [
{ name: { contains: 'obaidalah' } },
{ name: { contains: 'obaid' } },
{ phone: '+201066544750' }
]
}
});
if (!obaidLead) {
console.log('❌ Obaid not found, creating new lead...');
const clinic = await prisma.clinic.findFirst();
const newLead = await prisma.lead.create({
data: {
clinicId: clinic.id,
name: 'obaidalah saleh',
phone: '+201066544750',
status: 'new',
source: 'test'
}
});
console.log(`✅ Created new lead: ${newLead.name} (${newLead.phone})`);
obaidLead = newLead;
} else {
console.log(`✅ Found obaid: ${obaidLead.name} (${obaidLead.phone})`);
}
// 2. Get clinic and treatment
const clinic = await prisma.clinic.findFirst();
const treatment = await prisma.treatment.findFirst({
where: { clinicId: clinic.id, isActive: true }
});
console.log(` Clinic: ${clinic.name}`);
console.log(` Treatment: ${treatment.name}`);
// 3. Create appointment for tomorrow
console.log('2️⃣ Creating appointment...');
const appointmentTime = new Date();
appointmentTime.setDate(appointmentTime.getDate() + 1); // Tomorrow
appointmentTime.setHours(14, 30, 0, 0); // 2:30 PM
const appointment = await prisma.appointment.create({
data: {
clinicId: clinic.id,
leadId: obaidLead.id,
treatmentId: treatment.id,
dateTime: appointmentTime,
status: 'scheduled',
confirmToken: crypto.randomBytes(32).toString('hex'),
notes: 'Test appointment for obaid - message sending test'
},
});
console.log(`✅ Appointment created: ${appointment.id}`);
console.log(` DateTime: ${appointmentTime.toLocaleString()}`);
// 4. Schedule booking confirmation (should send immediately)
console.log('3️⃣ Scheduling booking confirmation...');
const template = await prisma.reminderTemplate.findFirst({
where: {
clinicId: clinic.id,
trigger: 'booking_confirmed',
isActive: true
}
});
if (!template) {
console.log('❌ No booking confirmation template found!');
return;
}
// Create reminder for immediate send (outside quiet hours)
const reminder = await prisma.scheduledReminder.create({
data: {
appointmentId: appointment.id,
templateId: template.id,
scheduledFor: new Date(Date.now() + 3000), // 3 seconds from now
},
});
console.log(`✅ Reminder scheduled for immediate send`);
// 5. Wait a moment then trigger cron
console.log('4️⃣ Waiting 5 seconds then sending...');
await new Promise(resolve => setTimeout(resolve, 5000));
console.log('📤 Triggering message send...');
const cronResponse = await fetch('http://localhost:3000/api/cron/send-reminders?key=dev-cron-key', {
method: 'POST'
});
if (cronResponse.ok) {
const cronResult = await cronResponse.json();
console.log(`✅ Cron result: sent=${cronResult.sent}, failed=${cronResult.failed}`);
if (cronResult.sent > 0) {
console.log('🎉 SUCCESS! Message sent to obaid!');
// Check message log
await new Promise(resolve => setTimeout(resolve, 2000));
const messageLog = await prisma.messageLog.findFirst({
where: {
appointmentId: appointment.id,
phone: obaidLead.phone
}
});
if (messageLog) {
console.log('\n📱 MESSAGE DETAILS:');
console.log(` To: ${obaidLead.name}`);
console.log(` Phone: ${obaidLead.phone}`);
console.log(` Status: ${messageLog.status}`);
console.log(` Sent at: ${messageLog.sentAt}`);
console.log(` Message preview:`);
console.log(` "${messageLog.message.substr(0, 100)}..."`);
console.log('\n📲 OBAID SHOULD RECEIVE THIS MESSAGE ON WHATSAPP NOW!');
}
} else if (cronResult.failed > 0) {
console.log('❌ Message failed to send!');
} else {
console.log('⚠️ No messages were processed');
}
} else {
console.log('❌ Cron endpoint failed');
}
// 6. Also schedule other reminders
console.log('\n5️⃣ Scheduling additional reminders...');
const otherTemplates = await prisma.reminderTemplate.findMany({
where: {
clinicId: clinic.id,
isActive: true,
trigger: { not: 'booking_confirmed' }
}
});
for (const t of otherTemplates) {
let scheduledTime;
if (t.trigger === '1_day_before') {
// Schedule for tomorrow at 9 AM (1 day before 2:30 PM appointment)
scheduledTime = new Date(appointmentTime);
scheduledTime.setDate(scheduledTime.getDate() - 1);
scheduledTime.setHours(9, 0, 0, 0);
} else if (t.trigger === '2_hours_before') {
// Schedule for 12:30 PM tomorrow (2 hours before 2:30 PM)
scheduledTime = new Date(appointmentTime);
scheduledTime.setHours(12, 30, 0, 0);
} else {
// Use template offset
scheduledTime = new Date(appointmentTime.getTime() + t.offsetMinutes * 60000);
}
await prisma.scheduledReminder.create({
data: {
appointmentId: appointment.id,
templateId: t.id,
scheduledFor: scheduledTime,
},
});
console.log(` 📅 ${t.trigger} scheduled for ${scheduledTime.toLocaleString()}`);
}
console.log('\n🎯 SUMMARY FOR OBAID:');
console.log(` 📱 Phone: ${obaidLead.phone}`);
console.log(` 📅 Appointment: ${appointmentTime.toLocaleString()}`);
console.log(` 💊 Treatment: ${treatment.name}`);
console.log(` 📨 Immediate confirmation: SENT ✅`);
console.log(` ⏰ Future reminders: SCHEDULED ✅`);
console.log('\n📲 OBAID - CHECK YOUR WHATSAPP FOR THE BOOKING CONFIRMATION!');
} catch (error) {
console.error('❌ Failed to send to obaid:', error);
} finally {
await prisma.$disconnect();
}
}
sendToObaid().catch(console.error);