la creazione dell'annuncio impiega troppo tempo (e le persone cliccavano su "Salva" più volte)...

This commit is contained in:
Surya Paolo
2023-06-18 22:29:06 +02:00
parent 95a812f002
commit 3393af36aa
7 changed files with 277 additions and 246 deletions

View File

@@ -29,3 +29,15 @@ Gio 16/02 ORE 18:14: USER [paoloar77]: vai al sito
Mar 06/06 ORE 19:39: USER [paoloar77]: ciaooooooooooooooooo Mar 06/06 ORE 19:39: USER [paoloar77]: ciaooooooooooooooooo
Mar 06/06 ORE 19:54: USER [paoloar77]: dasjdalksjdasdklasjkldasjlkdjasl Mar 06/06 ORE 19:54: USER [paoloar77]: dasjdalksjdasdklasjkldasjlkdjasl
Sab 17/06 ORE 20:03: USER [paoloar77]: pro v adsasdasdaksdas
Dom 18/06 ORE 19:22: USER [paoloar77]: /start inv
Dom 18/06 ORE 19:42: USER [paoloar77]: /start inv
Dom 18/06 ORE 19:58: USER [paoloar77]: /start inv
Dom 18/06 ORE 19:59: USER [paoloar77]: /start inv
Dom 18/06 ORE 19:59: USER [paoloar77]: /start inv

View File

@@ -10,4 +10,8 @@ ciaooooooooooooooooo
Mar 06/06 ORE 19:49: 🤖: Da Sùrya (Paolo) undefined (paoloar77): Mar 06/06 ORE 19:49: 🤖: Da Sùrya (Paolo) undefined (paoloar77):
✅ SuryaArena2 è stato Abilitato correttamente (da paoloar77)! ✅ SuryaArena2 è stato Abilitato correttamente (da paoloar77)!
Mar 06/06 ORE 19:54: 🤖: Da Sùrya (Paolo) undefined (paoloar77): Mar 06/06 ORE 19:54: 🤖: Da Sùrya (Paolo) undefined (paoloar77):
dasjdalksjdasdklasjkldasjlkdjasl dasjdalksjdasdklasjkldasjlkdjasl
Sab 17/06 ORE 20:03: 🤖: Da Sùrya (Paolo) undefined (paoloar77):
pro v adsasdasdaksdas
Dom 18/06 ORE 19:22: 🤖: Da Sùrya (Paolo) undefined (paoloar77):
/start inv

View File

@@ -397,16 +397,21 @@ AccountSchema.statics.getUserAccounts = async function (idapp, username) {
if (ris) { if (ris) {
for (const account of ris) { for (const account of ris) {
const pendingtransactions = await SendNotif.getSumPendingTransactions(idapp, username, account.circuit.name); try {
const saldopending = pendingtransactions.reduce((sum, rec) => sum + rec.extrarec.qty, 0); const pendingtransactions = await SendNotif.getSumPendingTransactions(idapp, username, account.circuit.name);
account.saldo -= saldopending; const saldopending = pendingtransactions.reduce((sum, rec) => sum + rec.extrarec.qty, 0);
account.totTransato = account.totTransato || 0; account.saldo -= saldopending;
account.totTransato = account.totTransato || 0;
} catch (e) {
console.error('getUserAccounts 1) ', e);
}
} }
} }
return ris; return ris;
} catch (e) { } catch (e) {
console.error('e', e); console.error('getUserAccounts', e);
} }
}; };
@@ -516,7 +521,7 @@ AccountSchema.statics.SetMinMaxPersonali = async function (idapp, valmin, valmax
const Account = this; const Account = this;
if (circuitId) { if (circuitId) {
ris = await Account.updateMany({ idapp, circuitId, fidoConcesso: { $gt: 0 }, username: { "$nin": [null, ""] } }, ris = await Account.updateMany({ idapp, circuitId, fidoConcesso: { $gt: 0 }, username: { "$nin": [null, ""] } },
{ {
$set: $set:
{ {

View File

@@ -478,7 +478,9 @@ router.post('/settable', authenticate, async (req, res) => {
} }
if (setnotif) { if (setnotif) {
await SendNotif.createNewNotification(req, res, { groupnameDest, circuitnameDest }, params.table, myrec, typedir, typeid); const myreq = {...req};
const myres = {...res};
SendNotif.createNewNotification(myreq, myres, { groupnameDest, circuitnameDest }, params.table, myrec, typedir, typeid);
} }
if (params.table === 'circuits') { if (params.table === 'circuits') {

View File

@@ -5,7 +5,7 @@ const appTelegram = [tools.FREEPLANET, tools.RISO];
const appTelegram_TEST = [tools.FREEPLANET, tools.RISO]; const appTelegram_TEST = [tools.FREEPLANET, tools.RISO];
const appTelegram_DEVELOP = [tools.RISO]; const appTelegram_DEVELOP = [tools.RISO];
const appTelegramFinti = ['2', tools.CNM, tools.ARCADEI]; const appTelegramFinti = ['2', tools.CNM];
const appTelegramDest = [tools.FREEPLANET, tools.FREEPLANET]; const appTelegramDest = [tools.FREEPLANET, tools.FREEPLANET];
const printf = require('util').format; const printf = require('util').format;
@@ -143,6 +143,7 @@ MsgBot = {
'grazie 😘', 'grazie 😘',
'grazie😘'], 'grazie😘'],
PRINCIPE_AZZURRO: ['principe azzurro'], PRINCIPE_AZZURRO: ['principe azzurro'],
START_INV: ['/start inv'],
COSE_COVID: [ COSE_COVID: [
'cos\'è il covid', 'cos\'è il covid',
'cosa è il covid', 'cosa è il covid',
@@ -709,7 +710,7 @@ const MyTelegramBot = {
MyForm = null) { MyForm = null) {
if (!idtelegram) if (!idtelegram)
return {text: ''}; return { text: '' };
const cl = getclTelegByidapp(idapp); const cl = getclTelegByidapp(idapp);
if (cl && idtelegram) { if (cl && idtelegram) {
@@ -718,7 +719,7 @@ const MyTelegramBot = {
chat_id, ripr_menuPrec); chat_id, ripr_menuPrec);
} }
return {text: ''}; return { text: '' };
}, },
@@ -1035,270 +1036,268 @@ const MyTelegramBot = {
sendMsgTelegramToTheAdminsOfCircuit: async function ( sendMsgTelegramToTheAdminsOfCircuit: async function (
idapp, circuitpath, text, onlyintofile = false, MyForm = null, nottousername = '') { idapp, circuitpath, text, onlyintofile = false, MyForm = null, nottousername = '') {
tools.writeManagersLog(text); tools.writeManagersLog(text);
let teleg_id = 0; let teleg_id = 0;
if (!onlyintofile) { if (!onlyintofile) {
const usersmanagers = await Circuit.getListAdminsByCircuitPath(idapp, circuitpath); const usersmanagers = await Circuit.getListAdminsByCircuitPath(idapp, circuitpath);
if (usersmanagers) { if (usersmanagers) {
for (const rec of usersmanagers) { for (const rec of usersmanagers) {
if (rec.username !== nottousername) { if (rec.username !== nottousername) {
teleg_id = await User.TelegIdByUsername(idapp, rec.username); teleg_id = await User.TelegIdByUsername(idapp, rec.username);
if (teleg_id) { if (teleg_id) {
await this.sendMsgTelegramByIdTelegram(idapp, teleg_id, await this.sendMsgTelegramByIdTelegram(idapp, teleg_id,
emo.ROBOT_FACE + ': ' + text, undefined, undefined, true, emo.ROBOT_FACE + ': ' + text, undefined, undefined, true,
MyForm); MyForm);
await tools.snooze(100); await tools.snooze(100);
}
} }
} }
} }
} }
} return true;
return true;
}, },
sendMsgTelegramToTheManagersAndZoomeri: async function ( sendMsgTelegramToTheManagersAndZoomeri: async function (
idapp, text, onlyintofile, MyForm = null) { idapp, text, onlyintofile, MyForm = null) {
tools.writeManagersLog(text); tools.writeManagersLog(text);
if (!onlyintofile) { if (!onlyintofile) {
// const usersmanagers = await User.getusersManagersAndZoomeri(idapp); // const usersmanagers = await User.getusersManagersAndZoomeri(idapp);
const usersmanagers = await User.getusersManagers(idapp); const usersmanagers = await User.getusersManagers(idapp);
if (usersmanagers) { if (usersmanagers) {
for (const rec of usersmanagers) { for (const rec of usersmanagers) {
await this.sendMsgTelegramByIdTelegram(idapp, rec.profile.teleg_id, await this.sendMsgTelegramByIdTelegram(idapp, rec.profile.teleg_id,
emo.ROBOT_FACE + ': ' + text, undefined, undefined, true, MyForm); emo.ROBOT_FACE + ': ' + text, undefined, undefined, true, MyForm);
await tools.snooze(100); await tools.snooze(100);
}
} }
} }
} return true;
return true;
}, },
getMsgByTipoMsg: async function (mydata, lang, user, sonosognatore) { getMsgByTipoMsg: async function (mydata, lang, user, sonosognatore) {
if (!!mydata.msgextra) { if (!!mydata.msgextra) {
return { body: mydata.msgextra, title: '' }; return { body: mydata.msgextra, title: '' };
}
let title = '';
let msg = '';
if (mydata.tipomsg === tools.TipoMsg.SEND_LINK_CHAT_DONATORI) {
if (sonosognatore)
msg = printf(tools.gettranslate('SEND_LINK_CHAT_SOGNATORE', lang),
user.name,
mydata.navemediatore.riga + '.' + mydata.navemediatore.col,
mydata.msgpar1);
else
msg = printf(tools.gettranslate('SEND_LINK_CHAT_DONATORI', lang),
user.name,
mydata.navemediatore.riga + '.' + mydata.navemediatore.col,
mydata.msgpar1);
} else if (mydata.tipomsg === tools.TipoMsg.SEND_MSG || mydata.tipomsg ===
tools.TipoMsg.SEND_MSG_SINGOLO) {
if (!!mydata.username_mitt) {
msg = '[' + tools.gettranslate('MSG_SEND_FROM', lang) + ' ' +
mydata.username_mitt + ']:' + tools.ACAPO;
} }
msg += mydata.msgpar1;
} else if (mydata.tipomsg >= 1000) {
const ris = await MsgTemplate.getMsgByLang(user.idapp, user, mydata.tipomsg,
lang);
msg = ris.body;
title = ris.title;
}
const cl = getclTelegByidapp(user.idapp); let title = '';
if (cl) { let msg = '';
msg = await tools.convertSpecialTags(rec.user, msg);
}
if (!!mydata.flotta) { if (mydata.tipomsg === tools.TipoMsg.SEND_LINK_CHAT_DONATORI) {
// SOSTITUISCI LE PAROLE CHIAVI if (sonosognatore)
if (!!mydata.flotta.date_start) msg = printf(tools.gettranslate('SEND_LINK_CHAT_SOGNATORE', lang),
msg = msg.replace('{date_start}', user.name,
tools.getstrDateLongTot(new Date(mydata.flotta.date_start), mydata.navemediatore.riga + '.' + mydata.navemediatore.col,
user.lang)); mydata.msgpar1);
if (!!mydata.flotta.date_close) else
msg = msg.replace('{date_close}', msg = printf(tools.gettranslate('SEND_LINK_CHAT_DONATORI', lang),
tools.getstrDateLongTot(new Date(mydata.flotta.date_close), user.name,
user.lang)); mydata.navemediatore.riga + '.' + mydata.navemediatore.col,
if (!!mydata.flotta.link_superchat) mydata.msgpar1);
msg = msg.replace('{link_superchat}', mydata.flotta.link_superchat); } else if (mydata.tipomsg === tools.TipoMsg.SEND_MSG || mydata.tipomsg ===
if (!!mydata.flotta.tutor1) tools.TipoMsg.SEND_MSG_SINGOLO) {
msg = msg.replace('{tutor1}', mydata.flotta.tutor1); if (!!mydata.username_mitt) {
if (!!mydata.flotta.tutor2) msg = '[' + tools.gettranslate('MSG_SEND_FROM', lang) + ' ' +
msg = msg.replace('{tutor2}', mydata.flotta.tutor2); mydata.username_mitt + ']:' + tools.ACAPO;
if (!!mydata.flotta.tutor3) }
msg = msg.replace('{tutor3}', mydata.flotta.tutor3); msg += mydata.msgpar1;
if (!!mydata.flotta.tutorslo) } else if (mydata.tipomsg >= 1000) {
msg = msg.replace('{tutorslo}', mydata.flotta.tutorslo); const ris = await MsgTemplate.getMsgByLang(user.idapp, user, mydata.tipomsg,
if (!!mydata.flotta.sognatore_nomecognome) lang);
msg = msg.replace('{sognatore}', mydata.flotta.sognatore_nomecognome); msg = ris.body;
if (!!mydata.flotta.sognatore_nomecognome) title = ris.title;
msg = msg.replace('{flotta}', }
mydata.flotta.riga + '.' + Math.ceil(mydata.flotta.col_prima / 8) +
' - ' + mydata.flotta.riga + '.' +
Math.ceil(mydata.flotta.col_ultima / 8));
}
return { body: msg, title }; const cl = getclTelegByidapp(user.idapp);
}, if (cl) {
msg = await tools.convertSpecialTags(rec.user, msg);
}
sendMsgTelegramToTheAdminAllSites: async function (text, senzaintestazione) { if (!!mydata.flotta) {
for (const idapp of this.getAppTelegram()) { // SOSTITUISCI LE PAROLE CHIAVI
text = text.replace('{appname}', tools.getNomeAppByIdApp(idapp)); if (!!mydata.flotta.date_start)
await this.sendMsgTelegramToTheAdmin(idapp, text, senzaintestazione); msg = msg.replace('{date_start}',
} tools.getstrDateLongTot(new Date(mydata.flotta.date_start),
}, user.lang));
if (!!mydata.flotta.date_close)
msg = msg.replace('{date_close}',
tools.getstrDateLongTot(new Date(mydata.flotta.date_close),
user.lang));
if (!!mydata.flotta.link_superchat)
msg = msg.replace('{link_superchat}', mydata.flotta.link_superchat);
if (!!mydata.flotta.tutor1)
msg = msg.replace('{tutor1}', mydata.flotta.tutor1);
if (!!mydata.flotta.tutor2)
msg = msg.replace('{tutor2}', mydata.flotta.tutor2);
if (!!mydata.flotta.tutor3)
msg = msg.replace('{tutor3}', mydata.flotta.tutor3);
if (!!mydata.flotta.tutorslo)
msg = msg.replace('{tutorslo}', mydata.flotta.tutorslo);
if (!!mydata.flotta.sognatore_nomecognome)
msg = msg.replace('{sognatore}', mydata.flotta.sognatore_nomecognome);
if (!!mydata.flotta.sognatore_nomecognome)
msg = msg.replace('{flotta}',
mydata.flotta.riga + '.' + Math.ceil(mydata.flotta.col_prima / 8) +
' - ' + mydata.flotta.riga + '.' +
Math.ceil(mydata.flotta.col_ultima / 8));
}
sendMsgTelegramToTheAdmin: async function (idapp, text, senzaintestazione) { return { body: msg, title };
const usersmanagers = await User.getusersAdmin(idapp); },
let intestaz = emo.ROBOT_FACE + '[BOT-ADMIN]' + emo.ADMIN + ': '; sendMsgTelegramToTheAdminAllSites: async function (text, senzaintestazione) {
if (senzaintestazione) for (const idapp of this.getAppTelegram()) {
intestaz = ''; text = text.replace('{appname}', tools.getNomeAppByIdApp(idapp));
await this.sendMsgTelegramToTheAdmin(idapp, text, senzaintestazione);
}
},
if (usersmanagers) { sendMsgTelegramToTheAdmin: async function (idapp, text, senzaintestazione) {
for (const rec of usersmanagers) { const usersmanagers = await User.getusersAdmin(idapp);
if (User.isAdmin(rec.perm)) {
this.sendMsgTelegramByIdTelegram(idapp, rec.profile.teleg_id, let intestaz = emo.ROBOT_FACE + '[BOT-ADMIN]' + emo.ADMIN + ': ';
intestaz + text, undefined, undefined, true); if (senzaintestazione)
intestaz = '';
if (usersmanagers) {
for (const rec of usersmanagers) {
if (User.isAdmin(rec.perm)) {
this.sendMsgTelegramByIdTelegram(idapp, rec.profile.teleg_id,
intestaz + text, undefined, undefined, true);
await tools.snooze(300);
}
}
}
return true;
},
sendMsgTelegramToALL: async function (idapp, text) {
const usersall = await User.getUsersTelegALL(idapp);
if (usersall) {
for (const rec of usersall) {
this.sendMsgTelegramByIdTelegram(idapp, rec.profile.teleg_id, text);
await tools.snooze(300); await tools.snooze(300);
} }
} }
}
return true;
}, },
sendMsgTelegramToALL: async function (idapp, text) { sendMsgTelegram: async function (
const usersall = await User.getUsersTelegALL(idapp); idapp, username, text, alsotomanagers = false, username_mitt = '') {
const { User } = require('../models/user');
if (usersall) { const teleg_id = await User.TelegIdByUsername(idapp, username);
for (const rec of usersall) { const cl = getclTelegByidapp(idapp);
this.sendMsgTelegramByIdTelegram(idapp, rec.profile.teleg_id, text); let ris = null;
await tools.snooze(300); if (cl && teleg_id) {
ris = await cl.sendMsg(teleg_id, text);
} }
}
}, if (cl && teleg_id) {
if (alsotomanagers) {
sendMsgTelegram: async function ( await this.sendMsgTelegramToTheManagers(idapp, text);
idapp, username, text, alsotomanagers = false, username_mitt = '') { }
const { User } = require('../models/user'); if (!!username_mitt) {
const rec = cl.getRecByUsername(username);
const teleg_id = await User.TelegIdByUsername(idapp, username); if (rec) {
const cl = getclTelegByidapp(idapp); rec.msgall_username_specifico = username_mitt;
let ris = null; }
if (cl && teleg_id) {
ris = await cl.sendMsg(teleg_id, text);
}
if (cl && teleg_id) {
if (alsotomanagers) {
await this.sendMsgTelegramToTheManagers(idapp, text);
}
if (!!username_mitt) {
const rec = cl.getRecByUsername(username);
if (rec) {
rec.msgall_username_specifico = username_mitt;
} }
}
}
return ris;
},
sendMsgTelegramByIdTelegram: async function (
idapp, idtelegram, text, message_id, chat_id, ripr_menuPrec,
MyForm = null) {
console.log('sendMsgTelegramByIdTelegram', text);
if (!idtelegram)
return;
const cl = getclTelegByidapp(idapp);
if (cl && idtelegram) {
let myform = null;
return await cl.sendMsg(idtelegram, text, null, MyForm, message_id,
chat_id, ripr_menuPrec);
}
},
reloadMenuBot: async function (idapp) {
const cl = getclTelegByidapp(idapp);
if (cl) {
return cl.updateMenuBot();
}
},
reloadSites: async function () {
tools.loadApps();
},
sendMsgFromSite: async function (idapp, user, params) {
try {
let ris = {
numrec: 0,
nummsgsent: 0,
text: '',
};
let invia = false;
let content = '';
let tipomsgtempl = 0;
params.sendreally = true;
if (params.typemsg === shared_consts.TypeMsg.SEND_TO_MYSELF) {
params.usernameDest = user.username;
}
if (params.cmd === shared_consts.MsgTeleg.SHARE_MSGREG) {
tipomsgtempl = shared_consts.TypeMsgTemplate.MS_SHARE_LINK;
invia = true;
} else if (params.cmd === shared_consts.MsgTeleg.SHARE_TEXT) {
invia = !!params.content;
}
if (tipomsgtempl > 0) {
const rismsg = await MsgTemplate.getMsgByLang(idapp, user, tipomsgtempl, user.lang);
params.content = rismsg.body;
params.title = rismsg.title;
}
if (invia) {
ris = await globalTables.SendMsgToParam(idapp, params);
} }
return ris; return ris;
},
} catch (e) { sendMsgTelegramByIdTelegram: async function (
console.error('sendMsgFromSite', e); idapp, idtelegram, text, message_id, chat_id, ripr_menuPrec,
} MyForm = null) {
},
sendMsgFromSiteToBotTelegram: async function (idapp, user, params) { if (!idtelegram)
return;
if (!params.typesend) { const cl = getclTelegByidapp(idapp);
params.typesend = shared_consts.TypeSend.TELEGRAM; if (cl && idtelegram) {
} let myform = null;
return this.sendMsgFromSite(idapp, user, params); return await cl.sendMsg(idtelegram, text, null, MyForm, message_id,
chat_id, ripr_menuPrec);
}
}, },
reloadMenuBot: async function (idapp) {
const cl = getclTelegByidapp(idapp);
if (cl) {
return cl.updateMenuBot();
}
},
reloadSites: async function () {
tools.loadApps();
},
sendMsgFromSite: async function (idapp, user, params) {
try {
let ris = {
numrec: 0,
nummsgsent: 0,
text: '',
};
let invia = false;
let content = '';
let tipomsgtempl = 0;
params.sendreally = true;
if (params.typemsg === shared_consts.TypeMsg.SEND_TO_MYSELF) {
params.usernameDest = user.username;
}
if (params.cmd === shared_consts.MsgTeleg.SHARE_MSGREG) {
tipomsgtempl = shared_consts.TypeMsgTemplate.MS_SHARE_LINK;
invia = true;
} else if (params.cmd === shared_consts.MsgTeleg.SHARE_TEXT) {
invia = !!params.content;
}
if (tipomsgtempl > 0) {
const rismsg = await MsgTemplate.getMsgByLang(idapp, user, tipomsgtempl, user.lang);
params.content = rismsg.body;
params.title = rismsg.title;
}
if (invia) {
ris = await globalTables.SendMsgToParam(idapp, params);
}
return ris;
} catch (e) {
console.error('sendMsgFromSite', e);
}
},
sendMsgFromSiteToBotTelegram: async function (idapp, user, params) {
if (!params.typesend) {
params.typesend = shared_consts.TypeSend.TELEGRAM;
}
return this.sendMsgFromSite(idapp, user, params);
},
}; };
@@ -1676,6 +1675,9 @@ class Telegram {
} else if (MsgBot.PRINCIPE_AZZURRO.find( } else if (MsgBot.PRINCIPE_AZZURRO.find(
(rec) => testo.indexOf(rec) > -1)) { (rec) => testo.indexOf(rec) > -1)) {
risp = 'Chissà... Forse si!\nAnche se meglio averne un altro di scorta, nel caso il Principe non sia disponibile.'; risp = 'Chissà... Forse si!\nAnche se meglio averne un altro di scorta, nel caso il Principe non sia disponibile.';
} else if (MsgBot.START_INV.find(
(rec) => testo.indexOf(rec) > -1)) {
risp = 'Sei già registrato a RISO. Per accedere alla App, aprila dall\'icona sul tuo schermo, oppure vai su https://riso.app ed installa la App.\n\nSe hai dimenticato la password: \n clicca sul menu in basso su "⚒ Strumenti" e poi "🔑 Cambio Password"'
} else if (MsgBot.COSE_COVID.find( } else if (MsgBot.COSE_COVID.find(
(rec) => testo.indexOf(rec) > -1)) { (rec) => testo.indexOf(rec) > -1)) {
risp = 'Un \'influenza più "grave", dovuta a paure e a fattori interiori di evoluzione, oltre ad una pulizia del corpo. '; risp = 'Un \'influenza più "grave", dovuta a paure e a fattori interiori di evoluzione, oltre ad una pulizia del corpo. ';
@@ -3090,7 +3092,7 @@ class Telegram {
status = this.getstatus(rec); status = this.getstatus(rec);
if (testo === Menu.EXIT_TELEGRAM) { if (testo === Menu.EXIT_TELEGRAM) {
await this.menuExitToTelegram(msg); await this.menuExitToTelegram(msg);
}else if (status === Status.WAITFOR_USERNAME_TELEGRAM && !this.selectMenuHelp(msg) && !this.selectMenuLang(msg)) { } else if (status === Status.WAITFOR_USERNAME_TELEGRAM && !this.selectMenuHelp(msg) && !this.selectMenuLang(msg)) {
// await this.setUsernameBo(msg); // await this.setUsernameBo(msg);
await this.settotheDatabase(msg); await this.settotheDatabase(msg);
} else if (status === Status.WAITFOR_USERNAME_INVITANTE && !this.selectMenuHelp(msg) && !this.selectMenuLang(msg)) { } else if (status === Status.WAITFOR_USERNAME_INVITANTE && !this.selectMenuHelp(msg) && !this.selectMenuLang(msg)) {
@@ -3530,8 +3532,10 @@ class Telegram {
return 0; return 0;
if (process.env.LOCALE === '1') { if (process.env.LOCALE === '1') {
if (id !== ADMIN_IDTELEGRAM_TEST) if (id !== ADMIN_IDTELEGRAM_TEST) {
text = '[Msg da inviare ipoteticamente a : ' + id + ']' + '\n' + text;
id = '12429864'; id = '12429864';
}
} }
if (!!msg_id) { if (!!msg_id) {
@@ -3565,7 +3569,7 @@ class Telegram {
} }
try { try {
console.log('<<< SEND MSG TELEGRAM: >>> ', text.substring(0, 100)); console.log('<<< SEND MSG TELEGRAM: >>> [id=', id, ']', text.substring(0, 100));
text = text.replace(/<br>/g, '\n'); text = text.replace(/<br>/g, '\n');
text = text.replace(/<br\/>/g, '\n'); text = text.replace(/<br\/>/g, '\n');
text = text.replace(/<div>/g, ''); text = text.replace(/<div>/g, '');
@@ -3656,7 +3660,10 @@ class Telegram {
async sendMsgLog(id, text, menu, form, msg_id, chat_id, ripr_menuPrec) { async sendMsgLog(id, text, menu, form, msg_id, chat_id, ripr_menuPrec) {
const rec = this.getRecInMemById(id); const rec = this.getRecInMemById(id);
const username = rec ? rec.username_bo : ''; let username = rec ? rec.username_bo : '';
if (!username) {
}
console.log('Msg inviato a ', username, '(', id, ')', text); console.log('Msg inviato a ', username, '(', id, ')', text);
return await this.sendMsg(id, text, menu, form, msg_id, chat_id, ripr_menuPrec); return await this.sendMsg(id, text, menu, form, msg_id, chat_id, ripr_menuPrec);

View File

@@ -1452,7 +1452,7 @@ module.exports = {
}, },
checkUserOk(userpassed, userauth, res) { checkUserOk(userpassed, userauth, res) {
this.mylog('checkUserOk', userpassed, userauth); // this.mylog('checkUserOk', userpassed, userauth);
if (String(userpassed) !== String(userauth)) { if (String(userpassed) !== String(userauth)) {
// I'm trying to write something not mine! // I'm trying to write something not mine!
this.mylog('I\'m trying to write something not mine!: userId = ', userpassed, 'req.user._id', userauth); this.mylog('I\'m trying to write something not mine!: userId = ', userpassed, 'req.user._id', userauth);

View File

@@ -288,7 +288,7 @@ module.exports = {
SendMsgToParam: async function (idapp, params) { SendMsgToParam: async function (idapp, params) {
try { try {
console.log('SendMsgToParam', params.typesend); // console.log('SendMsgToParam', params.typesend, params.typemsg);
const { User } = require('../models/user'); const { User } = require('../models/user');
@@ -414,7 +414,7 @@ module.exports = {
text = tools.getContentNotifByParams(params, mycontent, shared_consts.TypeSend.TELEGRAM); text = tools.getContentNotifByParams(params, mycontent, shared_consts.TypeSend.TELEGRAM);
if (telegid > 0) { if (telegid > 0) {
risult = await telegrambot.local_sendMsgTelegramByIdTelegram(idapp, telegid, text); risult = await telegrambot.local_sendMsgTelegramByIdTelegram(idapp, telegid, text);
await tools.snooze(50); await tools.snooze(25);
textsent = risult.text; textsent = risult.text;
} }
@@ -434,7 +434,8 @@ module.exports = {
} }
if (nummsgsent > 0) { if (nummsgsent > 0) {
console.log('FINE Invio Messaggi ! Inviati Totali: ', nummsgsent, 'su', numrec); if (nummsgsent != numrec && (numrec !== 1))
console.log('FINE Invio Messaggi ! Inviati Totali: ', nummsgsent, 'su', numrec);
} }
return { return {