From 7a41e6a1d4e8c2c1f19061255749840c17246eef Mon Sep 17 00:00:00 2001
From: Surya Paolo <paolo.arena77@gmail.com>
Date: Fri, 23 Dec 2022 17:06:54 +0100
Subject: [PATCH] replace username

---
 src/server/tools/globalTables.js | 229 +++++++++++++++++--------------
 1 file changed, 127 insertions(+), 102 deletions(-)

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