mirror of
https://github.com/cheveguerra/bot-whatsapp.git
synced 2026-04-18 11:39:15 +00:00
141 lines
4.4 KiB
JavaScript
141 lines
4.4 KiB
JavaScript
|
|
const ExcelJS = require('exceljs');
|
|
const moment = require('moment');
|
|
const fs = require('fs');
|
|
const { MessageMedia, Buttons } = require('whatsapp-web.js');
|
|
const { cleanNumber } = require('./handle')
|
|
const DELAY_TIME = 170; //ms
|
|
const DIR_MEDIA = `${__dirname}/../mediaSend`;
|
|
|
|
/**
|
|
* Enviamos archivos multimedia a nuestro cliente
|
|
* @param {*} number
|
|
* @param {*} fileName
|
|
*/
|
|
|
|
const sendMedia = (client, number, fileName) => {
|
|
number = cleanNumber(number)
|
|
const file = `${DIR_MEDIA}/${fileName}`;
|
|
if (fs.existsSync(file)) {
|
|
const media = MessageMedia.fromFilePath(file);
|
|
client.sendMessage(number, media, { sendAudioAsVoice: true });
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Enviamos archivos como notas de voz
|
|
* @param {*} number
|
|
* @param {*} fileName
|
|
*/
|
|
|
|
const sendMediaVoiceNote = (client, number, fileName) => {
|
|
number = cleanNumber(number)
|
|
const file = `${DIR_MEDIA}/${fileName}`;
|
|
if (fs.existsSync(file)) {
|
|
const media = MessageMedia.fromFilePath(file);
|
|
client.sendMessage(number, media ,{ sendAudioAsVoice: true });
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Enviamos un mensaje simple (texto) a nuestro cliente
|
|
* @param {*} number
|
|
*/
|
|
const sendMessage = async (client, number = null, text = null, trigger = null) => {
|
|
setTimeout(async () => {
|
|
number = cleanNumber(number)
|
|
const message = text
|
|
client.sendMessage(number, message);
|
|
await readChat(number, message, trigger)
|
|
console.log(`⚡⚡⚡ Enviando mensajes....`);
|
|
},DELAY_TIME)
|
|
}
|
|
|
|
/**
|
|
* Enviamos un mensaje con buttons a nuestro cliente
|
|
* @param {*} number
|
|
*/
|
|
const sendMessageButton = async (client, number = null, text = null, actionButtons) => {
|
|
number = cleanNumber(number)
|
|
const { title = null, message = null, footer = null, buttons = [] } = actionButtons;
|
|
let button = new Buttons(message,[...buttons], title, footer);
|
|
client.sendMessage(number, button);
|
|
|
|
console.log(`⚡⚡⚡ Enviando mensajes....`);
|
|
}
|
|
|
|
|
|
/**
|
|
* Opte
|
|
*/
|
|
const lastTrigger = (number) => new Promise((resolve, reject) => {
|
|
number = cleanNumber(number)
|
|
const pathExcel = `${__dirname}/../chats/${number}.xlsx`;
|
|
const workbook = new ExcelJS.Workbook();
|
|
if (fs.existsSync(pathExcel)) {
|
|
workbook.xlsx.readFile(pathExcel)
|
|
.then(() => {
|
|
const worksheet = workbook.getWorksheet(1);
|
|
const lastRow = worksheet.lastRow;
|
|
const getRowPrevStep = worksheet.getRow(lastRow.number);
|
|
const lastStep = getRowPrevStep.getCell('C').value;
|
|
resolve(lastStep)
|
|
});
|
|
} else {
|
|
resolve(null)
|
|
}
|
|
})
|
|
|
|
/**
|
|
* Guardar historial de conversacion
|
|
* @param {*} number
|
|
* @param {*} message
|
|
*/
|
|
const readChat = async (number, message, trigger = null) => {
|
|
setTimeout(() => {
|
|
number = cleanNumber(number)
|
|
const pathExcel = `${__dirname}/../chats/${number}.xlsx`;
|
|
const workbook = new ExcelJS.Workbook();
|
|
const today = moment().format('DD-MM-YYYY hh:mm')
|
|
|
|
if (fs.existsSync(pathExcel)) {
|
|
/**
|
|
* Si existe el archivo de conversacion lo actualizamos
|
|
*/
|
|
const workbook = new ExcelJS.Workbook();
|
|
workbook.xlsx.readFile(pathExcel)
|
|
.then(() => {
|
|
const worksheet = workbook.getWorksheet(1);
|
|
const lastRow = worksheet.lastRow;
|
|
var getRowInsert = worksheet.getRow(++(lastRow.number));
|
|
getRowInsert.getCell('A').value = today;
|
|
getRowInsert.getCell('B').value = message;
|
|
getRowInsert.getCell('C').value = trigger;
|
|
getRowInsert.commit();
|
|
workbook.xlsx.writeFile(pathExcel);
|
|
});
|
|
|
|
} else {
|
|
/**
|
|
* NO existe el archivo de conversacion lo creamos
|
|
*/
|
|
const worksheet = workbook.addWorksheet('Chats');
|
|
worksheet.columns = [
|
|
{ header: 'Fecha', key: 'number_customer' },
|
|
{ header: 'Mensajes', key: 'message' },
|
|
{ header: 'Disparador', key: 'trigger' }
|
|
];
|
|
worksheet.addRow([today, message, trigger]);
|
|
workbook.xlsx.writeFile(pathExcel)
|
|
.then(() => {
|
|
|
|
console.log("saved");
|
|
})
|
|
.catch((err) => {
|
|
console.log("err", err);
|
|
});
|
|
}
|
|
}, 150)
|
|
}
|
|
|
|
module.exports = { sendMessage, sendMedia, lastTrigger, sendMessageButton, readChat, sendMediaVoiceNote } |