surya/freeplanet_serverside
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

replace username

Browse Source
This commit is contained in:
Surya Paolo
2022-12-23 17:06:54 +01:00
parent 7e1407cbb1
commit 7a41e6a1d4
1 changed files with 127 additions and 102 deletions
Download Patch File Download Diff File Expand all files Collapse all files

229
src/server/tools/globalTables.js
View File

@@ -8,52 +8,52 @@ require('../config/config');
require('../models/subscribers'); require('../models/subscribers');
const {ObjectID} = require('mongodb'); const { ObjectID } = require('mongodb');
const {User} = require('../models/user'); const { User } = require('../models/user');
const {MyGroup} = require('../models/mygroup'); const { MyGroup } = require('../models/mygroup');
const {Booking} = require('../models/booking'); const { Booking } = require('../models/booking');
const {Operator} = require('../models/operator'); const { Operator } = require('../models/operator');
const {Where} = require('../models/where'); const { Where } = require('../models/where');
const {MyEvent} = require('../models/myevent'); const { MyEvent } = require('../models/myevent');
const {Contribtype} = require('../models/contribtype'); const { Contribtype } = require('../models/contribtype');
const {PaymentType} = require('../models/paymenttype'); const { PaymentType } = require('../models/paymenttype');
const {Discipline} = require('../models/discipline'); const { Discipline } = require('../models/discipline');
const {Skill} = require('../models/skill'); const { Skill } = require('../models/skill');
const {Good} = require('../models/good'); const { Good } = require('../models/good');
const {SubSkill} = require('../models/subskill'); const { SubSkill } = require('../models/subskill');
const {MySkill} = require('../models/myskill'); const { MySkill } = require('../models/myskill');
const {MyGood} = require('../models/mygood'); const { MyGood } = require('../models/mygood');
const {MyBacheca} = require('../models/mybacheca'); const { MyBacheca } = require('../models/mybacheca');
const {MyHosp} = require('../models/myhosp'); const { MyHosp } = require('../models/myhosp');
const {StatusSkill} = require('../models/statusSkill'); const { StatusSkill } = require('../models/statusSkill');
const {City} = require('../models/city'); const { City } = require('../models/city');
const {Province} = require('../models/province'); const { Province } = require('../models/province');
const {Sector} = require('../models/sector'); const { Sector } = require('../models/sector');
const {SectorGood} = require('../models/sectorgood'); const { SectorGood } = require('../models/sectorgood');
const {CatGrp} = require('../models/catgrp'); const { CatGrp } = require('../models/catgrp');
const {Level} = require('../models/level'); const { Level } = require('../models/level');
const {AdType} = require('../models/adtype'); const { AdType } = require('../models/adtype');
const {AdTypeGood} = require('../models/adtypegood'); const { AdTypeGood } = require('../models/adtypegood');
const {Circuit} = require('../models/circuit'); const { Circuit } = require('../models/circuit');
const {Account} = require('../models/account'); const { Account } = require('../models/account');
const {Movement} = require('../models/movement'); const { Movement } = require('../models/movement');
const Pickup = require('../models/pickup'); const Pickup = require('../models/pickup');
const {Newstosent} = require('../models/newstosent'); const { Newstosent } = require('../models/newstosent');
const {MyPage} = require('../models/mypage'); const { MyPage } = require('../models/mypage');
const {MyElem} = require('../models/myelem'); const { MyElem } = require('../models/myelem');
const {MyBot} = require('../models/bot'); const { MyBot } = require('../models/bot');
const {CfgServer} = require('../models/cfgserver'); const { CfgServer } = require('../models/cfgserver');
const {CalZoom} = require('../models/calzoom'); const { CalZoom } = require('../models/calzoom');
const {Gallery} = require('../models/gallery'); const { Gallery } = require('../models/gallery');
const {TemplEmail} = require('../models/templemail'); const { TemplEmail } = require('../models/templemail');
const {OpzEmail} = require('../models/opzemail'); const { OpzEmail } = require('../models/opzemail');
const {MailingList} = require('../models/mailinglist'); const { MailingList } = require('../models/mailinglist');
const {Settings} = require('../models/settings'); const { Settings } = require('../models/settings');
const {SendMsg} = require('../models/sendmsg'); const { SendMsg } = require('../models/sendmsg');
const {Permission} = require('../models/permission'); const { Permission } = require('../models/permission');
const {MsgTemplate} = require('../models/msg_template'); const { MsgTemplate } = require('../models/msg_template');
const {Graduatoria} = require('../models/graduatoria'); const { Graduatoria } = require('../models/graduatoria');
const Product = require('../models/product'); const Product = require('../models/product');
const Producer = require('../models/producer'); const Producer = require('../models/producer');
const Cart = require('../models/cart'); const Cart = require('../models/cart');
@@ -65,7 +65,7 @@ const Site = require('../models/site');
const IscrittiConacreis = require('../models/iscrittiConacreis'); const IscrittiConacreis = require('../models/iscrittiConacreis');
const IscrittiArcadei = require('../models/iscrittiArcadei'); const IscrittiArcadei = require('../models/iscrittiArcadei');
const Group = require('../models/group'); const Group = require('../models/group');
const {Todo} = require('../models/todo'); const { Todo } = require('../models/todo');
const Hours = require('../models/hours'); const Hours = require('../models/hours');
const Order = require('../models/order'); const Order = require('../models/order');
const Cash = require('../models/cash'); const Cash = require('../models/cash');
@@ -88,7 +88,7 @@ module.exports = {
mytable = MyGroup; mytable = MyGroup;
else if (tablename === 'tessitura') else if (tablename === 'tessitura')
mytable = Tessitura; mytable = Tessitura;
// else if (tablename === 'extralist') // else if (tablename === 'extralist')
// mytable = ExtraList; // mytable = ExtraList;
else if (tablename === 'bookings') else if (tablename === 'bookings')
mytable = Booking; mytable = Booking;
@@ -168,7 +168,7 @@ module.exports = {
mytable = MsgTemplate; mytable = MsgTemplate;
else if (tablename === 'navepersistente') else if (tablename === 'navepersistente')
mytable = NavePersistente; mytable = NavePersistente;
// else if (tablename === 'listaingressos') // else if (tablename === 'listaingressos')
// mytable = ListaIngresso; // mytable = ListaIngresso;
else if (tablename === 'graduatorias') else if (tablename === 'graduatorias')
mytable = Graduatoria; mytable = Graduatoria;
@@ -282,7 +282,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);
@@ -294,7 +294,7 @@ module.exports = {
if (params.typesend === 0) if (params.typesend === 0)
params.typesend = shared_consts.TypeSend.PUSH_NOTIFICATION; params.typesend = shared_consts.TypeSend.PUSH_NOTIFICATION;
let query = {idapp}; let query = { idapp };
let addquery = {}; let addquery = {};
let invia = true; let invia = true;
@@ -302,39 +302,39 @@ module.exports = {
if (params.typemsg === shared_consts.TypeMsg.SEND_TO_ALL) { if (params.typemsg === shared_consts.TypeMsg.SEND_TO_ALL) {
addquery = {}; addquery = {};
} else if (params.typemsg === shared_consts.TypeMsg.SEND_TO_SOCI) { } else if (params.typemsg === shared_consts.TypeMsg.SEND_TO_SOCI) {
addquery = {'profile.socio': true}; addquery = { 'profile.socio': true };
} else if (params.typemsg === } else if (params.typemsg ===
shared_consts.TypeMsg.SEND_TO_SOCIO_RESIDENTE) { shared_consts.TypeMsg.SEND_TO_SOCIO_RESIDENTE) {
addquery = {'profile.socioresidente': true}; addquery = { 'profile.socioresidente': true };
} else if (params.typemsg === shared_consts.TypeMsg.SEND_TO_CONSIGLIO) { } else if (params.typemsg === shared_consts.TypeMsg.SEND_TO_CONSIGLIO) {
addquery = {'profile.consiglio': true}; addquery = { 'profile.consiglio': true };
} else if (params.typemsg === shared_consts.TypeMsg.SEND_TO_NON_SOCI) { } else if (params.typemsg === shared_consts.TypeMsg.SEND_TO_NON_SOCI) {
addquery = {'profile.socio': false}; addquery = { 'profile.socio': false };
} else if (params.typemsg === shared_consts.TypeMsg.SEND_TO_PAOLO) { } else if (params.typemsg === shared_consts.TypeMsg.SEND_TO_PAOLO) {
addquery = {username: 'paoloar77'}; addquery = { username: 'paoloar77' };
} else if (params.typemsg === shared_consts.TypeMsg.SEND_TO_USER) { } else if (params.typemsg === shared_consts.TypeMsg.SEND_TO_USER) {
addquery = {username: params.usernameDest}; addquery = { username: params.usernameDest };
} else if (params.typemsg === shared_consts.TypeMsg.SEND_TO_MYSELF) { } else if (params.typemsg === shared_consts.TypeMsg.SEND_TO_MYSELF) {
addquery = {username: params.usernameDest}; addquery = { username: params.usernameDest };
} else if (params.typemsg === shared_consts.TypeMsg.SEND_TO_TELEG_NO_USERNAME_TELEG) { } else if (params.typemsg === shared_consts.TypeMsg.SEND_TO_TELEG_NO_USERNAME_TELEG) {
addquery = { addquery = {
'profile.teleg_id': {$gt: 1}, 'profile.teleg_id': { $gt: 1 },
$or: [ $or: [
{'profile.username_telegram': {$exists: false}}, { 'profile.username_telegram': { $exists: false } },
{'profile.username_telegram': {$exists: true, $eq: ''}}], { 'profile.username_telegram': { $exists: true, $eq: '' } }],
}; };
} else if (params.typemsg === shared_consts.TypeMsg.SEND_TO_TELEG_NO_VERIF_BY_APORTADOR) { } else if (params.typemsg === shared_consts.TypeMsg.SEND_TO_TELEG_NO_VERIF_BY_APORTADOR) {
addquery = { addquery = {
'profile.teleg_id': {$gt: 1}, 'profile.teleg_id': { $gt: 1 },
'profile.username_telegram': {$exists: true}, 'profile.username_telegram': { $exists: true },
$expr: {$gt: [{$strLenCP: '$profile.username_telegram'}, 3]}, $expr: { $gt: [{ $strLenCP: '$profile.username_telegram' }, 3] },
'verified_by_aportador': {$exists: false}, 'verified_by_aportador': { $exists: false },
}; };
} else if (params.typemsg === shared_consts.TypeMsg.SEND_TO_GROUP) { } else if (params.typemsg === shared_consts.TypeMsg.SEND_TO_GROUP) {
if (params.groupnameDest) { if (params.groupnameDest) {
addquery = { addquery = {
'profile.mygroups': { 'profile.mygroups': {
$elemMatch: {groupname: {$eq: params.groupnameDest}}, $elemMatch: { groupname: { $eq: params.groupnameDest } },
}, },
}; };
} else { } else {
@@ -344,7 +344,7 @@ module.exports = {
if (params.circuitnameDest) { if (params.circuitnameDest) {
addquery = { addquery = {
'profile.mycircuits': { 'profile.mycircuits': {
$elemMatch: {circuitname: {$eq: params.circuitnameDest}}, $elemMatch: { circuitname: { $eq: params.circuitnameDest } },
}, },
}; };
} else { } else {
@@ -358,14 +358,14 @@ module.exports = {
if (invia) { if (invia) {
const allquery = {...query, ...addquery}; const allquery = { ...query, ...addquery };
const arrusers = await User.find( const arrusers = await User.find(
allquery, allquery,
{ {
username: 1, username: 1,
'profile.teleg_id': 1, 'profile.teleg_id': 1,
}, },
).lean(); ).lean();
@@ -378,15 +378,15 @@ module.exports = {
if (params.sendreally) { if (params.sendreally) {
if (tools.isBitActive(params.typesend, shared_consts.TypeSend.PUSH_NOTIFICATION)) { if (tools.isBitActive(params.typesend, shared_consts.TypeSend.PUSH_NOTIFICATION)) {
const myparam = {...params}; const myparam = { ...params };
risult = await tools.sendNotificationToUser(user._id, mytitle, mycontent, myparam.openUrl, myparam.openUrl2, myparam.tag, risult = await tools.sendNotificationToUser(user._id, mytitle, mycontent, myparam.openUrl, myparam.openUrl2, myparam.tag,
myparam.actions, myparam.id). myparam.actions, myparam.id).
then(ris => { then(ris => {
}). }).
catch(e => { catch(e => {
console.error(e.message); console.error(e.message);
}); });
} }
if (tools.isBitActive(params.typesend, shared_consts.TypeSend.TELEGRAM)) { if (tools.isBitActive(params.typesend, shared_consts.TypeSend.TELEGRAM)) {
@@ -429,7 +429,7 @@ module.exports = {
}, },
SendMsgToAll: async function(idapp, params) { SendMsgToAll: async function (idapp, params) {
params.typemsg = shared_consts.TypeMsg.SEND_TO_ALL; params.typemsg = shared_consts.TypeMsg.SEND_TO_ALL;
params.sendreally = true; params.sendreally = true;
@@ -439,62 +439,87 @@ module.exports = {
}, },
replaceUsername: async function (idapp, search_username, replace_username) { replaceUsername: async function (idapp, search_username, replace_username) {
try { try {
let ris = null; let ris = null;
console.log('replaceUsername = ', search_username, replace_username); console.log('replaceUsername = ', search_username, replace_username);
ris = await User.findOneAndUpdate({ idapp, username: search_username }, { $set: { username: replace_username } }); ris = await User.findOneAndUpdate({ idapp, username: search_username }, { $set: { username: replace_username } });
console.log('username result = ', ris); console.log('username result = ', ris);
ris = await User.findOneAndUpdate({ idapp, 'profile.username_telegram': search_username }, { $set: { 'profile.username_telegram': replace_username } }); ris = await User.findOneAndUpdate({ idapp, 'profile.username_telegram': search_username }, { $set: { 'profile.username_telegram': replace_username } });
console.log('profile.username_telegram result = ', ris); console.log('profile.username_telegram result = ', ris);
ris = await User.updateOne({ idapp, 'profile.friends.username': search_username }, ris = await User.updateMany({ idapp, aportador_iniziale: search_username },
{
$set:
{ aportador_iniziale: replace_username }
});
console.log('aportador_iniziale result = ', ris);
ris = await User.updateMany({ idapp, username_who_report: search_username },
{
$set:
{ username_who_report: replace_username }
});
console.log('username_who_report result = ', ris);
ris = await User.updateMany({ idapp, aportador_solidario: search_username },
{
$set:
{ aportador_solidario: replace_username }
});
console.log('aportador_solidario result = ', ris);
ris = await User.updateMany({ idapp, 'profile.friends.username': search_username },
{ {
$set: $set:
{ 'profile.friends.$.username': replace_username } { 'profile.friends.$.username': replace_username }
}); });
console.log('friends.username result = ', ris); console.log('friends.username result = ', ris);
ris = await User.updateOne({ idapp, 'profile.req_friends.username': search_username }, ris = await User.updateMany({ idapp, 'profile.req_friends.username': search_username },
{ {
$set: $set:
{ 'profile.req_friends.$.username': replace_username } { 'profile.req_friends.$.username': replace_username }
}); });
console.log('req_friends.username result = ', ris); console.log('req_friends.username result = ', ris);
ris = await Circuit.updateOne({ idapp, 'admins.username': search_username }, ris = await Circuit.updateMany({ idapp, 'admins.username': search_username },
{ $set: { 'admins.$.username': replace_username } }); { $set: { 'admins.$.username': replace_username } });
console.log('Circuit.admins.username result = ', ris); console.log('Circuit.admins.username result = ', ris);
ris = await Circuit.updateOne({ idapp, 'req_users.username': search_username }, ris = await Circuit.updateMany({ idapp, 'req_users.username': search_username },
{ $set: { 'req_users.$.username': replace_username } }); { $set: { 'req_users.$.username': replace_username } });
console.log('Circuit.req_users.username result = ', ris); console.log('Circuit.req_users.username result = ', ris);
ris = await Circuit.updateOne({ idapp, 'refused_users.username': search_username }, ris = await Circuit.updateMany({ idapp, 'refused_users.username': search_username },
{ $set: { 'refused_users.$.username': replace_username } }); { $set: { 'refused_users.$.username': replace_username } });
console.log('Circuit.refused_users.username result = ', ris); console.log('Circuit.refused_users.username result = ', ris);
ris = await MyGroup.updateOne({ idapp, 'admins.username': search_username }, ris = await Account.updateMany({ idapp, 'username': search_username },
{ $set: { 'username': replace_username } });
console.log('Account.username result = ', ris);
ris = await MyGroup.updateMany({ idapp, 'admins.username': search_username },
{ $set: { 'admins.$.username': replace_username } }); { $set: { 'admins.$.username': replace_username } });
console.log('MyGroup.refused_users.username result = ', ris); console.log('MyGroup.refused_users.username result = ', ris);
ris = await MyGroup.updateOne({ idapp, 'req_users.username': search_username }, ris = await MyGroup.updateMany({ idapp, 'req_users.username': search_username },
{ $set: { 'req_users.$.username': replace_username } }); { $set: { 'req_users.$.username': replace_username } });
console.log('MyGroup.req_users.username result = ', ris); console.log('MyGroup.req_users.username result = ', ris);
// MyGroup.refused_users.username // MyGroup.refused_users.username
ris = await MyGroup.updateOne({ idapp, 'refused_users.username': search_username }, ris = await MyGroup.updateMany({ idapp, 'refused_users.username': search_username },
{ $set: { 'refused_users.$.username': replace_username } }); { $set: { 'refused_users.$.username': replace_username } });
console.log('MyGroup.refused_users.username result = ', ris); console.log('MyGroup.refused_users.username result = ', ris);
} catch (e) { } catch (e) {
console.error(e); console.error(e);
} }
}, },
}; };