✨✨✨ AGGIORNAMENTO SITO ✨✨✨

👉🏻 E' possibile ora visualizzare la Posizione Reale d'imbarco di quando si verrà aggiunti alle prossime Navi Definitive.
Le posizioni verranno aggiornate ogni ora in automatico!

👉🏻 Ora gli imbarchi comprendono anche le navi provvisorie, pertanto è possibile annullarli oppure cambiare l'Invitante, dalla lista imbarchi.

 👉🏻 E' ora possibile spostare gli invitati solo se si hanno piu' di 2 invitati per ogni Nave già partita.

👨🏻‍💻 Per i Tutor:
👉🏻- Sostituzioni : Cliccando su "Cerca il Primo Disponibile" vi suggerirà in automatico il primo passeggero disponibile per la sostituzione.

✨✨✨✨✨✨✨✨✨✨✨✨✨✨✨✨

src/server/models/graduatoria.js

@@ -0,0 +1,395 @@
+const bcrypt = require('bcryptjs');
+const mongoose = require('mongoose');
+const validator = require('validator');
+const jwt = require('jsonwebtoken');
+const _ = require('lodash');
+
+const tools = require('../tools/general');
+
+const { ObjectID } = require('mongodb');
+
+const { Nave } = require('./nave');
+const { Settings } = require('./settings');
+
+const shared_consts = require('../tools/shared_nodejs');
+const queryclass = require('../classes/queryclass');
+
+mongoose.Promise = global.Promise;
+
+mongoose.level = "F";
+// Resolving error Unknown modifier: $pushAll
+mongoose.plugin(schema => {
+  schema.options.usePushEach = true
+});
+
+mongoose.set('debug', process.env.DEBUG);
+
+const GraduatoriaSchema = new mongoose.Schema({
+  idapp: {
+    type: String,
+    required: true,
+  },
+  index: {
+    type: Number,
+  },
+  idListaIngresso: {
+    type: String,
+  },
+  ind_order: {
+    type: Number,
+  },
+  num_tess: {
+    type: Number,
+  },
+  ind: {
+    type: Number,
+  },
+  // USER:
+  username: {
+    type: String,
+  },
+  name: {
+    type: String,
+  },
+  surname: {
+    type: String,
+  },
+  indimbarco: {
+    type: Number,
+  },
+  numNaviEntrato: {  // Numero dell'Imbarco attuale
+    type: Number,
+  },
+  numinvitati: {
+    type: Number,
+  },
+  numinvitatiattivi: {
+    type: Number,
+  },
+  numinvitatiTot: {
+    type: Number,
+  },
+  numinvitatiattiviTot: {
+    type: Number,
+  },
+  punteggio: {
+    type: Number,
+  },
+  invitante_username: {
+    type: String,
+  },
+  date_added: {  // Data d'Ingresso (Completato i Requisiti o premuto Bottone Magico)
+    type: Date,
+  },
+
+});
+
+GraduatoriaSchema.pre('save', async function (next) {
+  if (this.isNew) {
+    try {
+      if (!this.index) {
+        const myrec = await Graduatoria.findOne({ idapp: this.idapp }).limit(1).sort({ index: -1 });
+
+        if (!!myrec) {
+          this.index = myrec._doc.index + 1;
+        } else {
+          this.index = 1;
+        }
+      }
+    } catch (e) {
+      this.index = 2;
+    }
+  }
+
+  next();
+});
+
+
+GraduatoriaSchema.statics.findByIndOrder = function (idapp, ind_order) {
+  const Graduatoria = this;
+
+  try {
+    return Graduatoria.findOne({
+      'idapp': idapp,
+      'ind_order': ind_order,
+    });
+  } catch (e) {
+
+  }
+};
+
+GraduatoriaSchema.statics.findByAllRecByUsername = function (idapp, username) {
+  const Graduatoria = this;
+
+  try {
+    return Graduatoria.find({
+      idapp,
+      username,
+    });
+  } catch (e) {
+
+  }
+};
+
+GraduatoriaSchema.statics.getNumDaImbarcare = async function (idapp) {
+  const Graduatoria = this;
+
+  return await Graduatoria.count({ idapp })
+
+};
+
+GraduatoriaSchema.statics.AggiornaIndiceGraduatoria = async function (idapp) {
+  const Graduatoria = this;
+
+  let index = 1;
+
+  await Graduatoria.find({ idapp }).sort({ punteggio: -1, date_added: 1 }).then(async (arrrec) => {
+
+    for (const rec of arrrec) {
+
+      await Graduatoria.findOneAndUpdate({ _id: rec._id }, { $set: { index } }, { new: false });
+      index++;
+    }
+  });
+
+  return index - 1;
+
+};
+
+GraduatoriaSchema.statics.getLastImbarco = async function (idapp, username) {
+  const Graduatoria = this;
+
+  return await Graduatoria.findOne({ idapp, username }).sort({ _id: -1 });
+
+};
+
+GraduatoriaSchema.statics.getFirstUserGradFree = async function (idapp) {
+  const Graduatoria = this;
+
+  const { User } = require('../models/user');
+
+  const arrrecgrad = await Graduatoria.find({ idapp, ind_order: { $gt: 0 } }).sort({ index: 1 }).limit(20);
+  if (!!arrrecgrad) {
+    for (const recgrad of arrrecgrad) {
+      const myuser = await User.findOne({
+        idapp,
+        username: recgrad.username,
+        $or: [{ deleted: { $exists: false } }, { deleted: { $exists: true, $eq: false } }]
+      });
+
+      if (!!myuser) {
+        return recgrad;
+      }
+    }
+  }
+
+  return null;
+
+};
+
+
+GraduatoriaSchema.statics.addSingoloInGraduatoria_InFondo = async function (idapp, recingr) {
+  const Graduatoria = this;
+
+  const lastimbarco = await Graduatoria.getLastImbarco(idapp, recingr.username);
+
+  const arrindex = [];
+
+  const { ListaIngresso } = require('../models/listaingresso');
+
+  arrindex[recingr.username] = lastimbarco.indimbarco;
+
+  const newingr = await ListaIngresso.aggiornaRecListaIngr(idapp, recingr, arrindex);
+
+  const myrectoadd = addRecGraduatoria(idapp, newingr);
+
+  return await myrectoadd.save(myrectoadd)
+    .then((ris) => {
+      return !!ris;
+    })
+    .catch((e) => {
+      console.error(e.message);
+    });
+
+};
+
+function addRecGraduatoria(idapp, ingr, index) {
+
+  try {
+    let rec = new Graduatoria({
+      _id: new ObjectID(),
+      idapp,
+      idListaIngresso: ingr._id,
+      ind_order: ingr.ind_order,
+      num_tess: ingr.num_tess,
+      username: ingr.username,
+      name: ingr.name,
+      surname: ingr.surname,
+      indimbarco: ingr.indimbarco,
+      numNaviEntrato: ingr.numNaviEntrato,
+      numinvitati: ingr.numinvitati,
+      numinvitatiattivi: ingr.numinvitatiattivi,
+      numinvitatiTot: ingr.numinvitatiTot,
+      numinvitatiattiviTot: ingr.numinvitatiattiviTot,
+      punteggio: ingr.punteggio,
+      invitante_username: ingr.invitante_username,
+      date_added: ingr.date_added,
+    });
+
+    if (!!index) {
+      rec.index = index;
+    }
+    return rec;
+  } catch (e) {
+    console.error(e.message);
+    return null;
+  }
+
+}
+
+GraduatoriaSchema.statics.addArrayInGraduatoria = async function (idapp, arrayingr) {
+  const Graduatoria = this;
+
+  try {
+    let myobjadd = [];
+
+    let index = 0;
+
+    for (const ingr of arrayingr) {
+
+      index++;
+
+      myobjadd.push(addRecGraduatoria(idapp, ingr, index));
+    }
+
+    // Cancella prima tutto
+    await Graduatoria.deleteMany({ idapp });
+
+    // Riscrivi Tutto
+    const ris = await Graduatoria.insertMany(myobjadd);
+
+
+    if (!!ris)
+      return ris.length;
+    else
+      return 0;
+
+  } catch (e) {
+    console.error(e.message);
+  }
+  return null;
+};
+
+GraduatoriaSchema.statics.getFieldsForSearch = function () {
+  return [
+    { field: 'index', type: tools.FieldType.number },
+    { field: 'ind_order', type: tools.FieldType.number },
+    { field: 'name', type: tools.FieldType.string },
+    { field: 'surname', type: tools.FieldType.string },
+    { field: 'username', type: tools.FieldType.string },
+    { field: 'invitante_username', type: tools.FieldType.string },
+  ]
+};
+
+GraduatoriaSchema.statics.executeQueryTable = function (idapp, params) {
+  params.fieldsearch = this.getFieldsForSearch();
+  return tools.executeQueryTable(this, idapp, params);
+};
+
+GraduatoriaSchema.statics.findAllIdApp = function (idapp) {
+  const Graduatoria = this;
+
+  const myfind = { idapp };
+
+  return Graduatoria.find(myfind, (err, arrrec) => {
+    return arrrec
+  });
+};
+
+GraduatoriaSchema.statics.isWorking = function (idapp) {
+
+  return Settings.getValDbSettings(idapp, 'GRAD_WORK', false);
+
+};
+
+GraduatoriaSchema.statics.setWorking = function (idapp, stato) {
+
+  return Settings.setBool(idapp, 'GRAD_WORK', stato);
+
+};
+
+function getinvit(index, myrec) {
+  let inv = myrec.numinvitati;
+  let invattivi = myrec.numinvitatiattivi;
+
+  const step = (myrec.numNaviEntrato + index) * 2;
+
+  inv -= step;
+  // console.log('inv', inv, 'step = ', step)
+  invattivi -= step;
+  if (inv < 0)
+    inv = 0;
+  if (invattivi < 0)
+    invattivi = 0;
+  if (inv > 2)
+    inv = 2;
+  if (invattivi > 2)
+    invattivi = 2;
+
+  return { invattivi, inv }
+}
+
+/*
+function getnuminv(index, myrec) {
+  const ris = getinvit(index, myrec);
+
+  return ris.inv
+}
+
+function getnuminvattivi(index, myrec) {
+  const ris = getinvit(index, myrec);
+
+  return ris.invattivi
+}*/
+
+
+GraduatoriaSchema.statics.getPosizioneInGraduatoria = async function (idapp, ind_order, username, num_tess) {
+  const Graduatoria = this;
+
+  const totposiz = await Graduatoria.countDocuments({ idapp });
+
+  return Graduatoria.findOne({ idapp, username, ind_order, num_tess }).then((rec) => {
+
+    if (!!rec) {
+
+    } else {
+      return {
+        posiz: 0,
+        totposiz: 0,
+        num_tess: 0,
+        numinvitatiTot: 0,
+        numinvitatiattiviTot: 0,
+        numNaviEntrato: 0,
+        indimbarco: 1,
+      }
+    }
+
+    const ris = {
+      totposiz,
+      posiz: rec.index,
+      numinvitatiTot: rec.numinvitatiTot,
+      numinvitatiattiviTot: rec.numinvitatiattiviTot,
+      num_tess: rec.num_tess,
+      numNaviEntrato: rec.numNaviEntrato,
+      indimbarco: rec.indimbarco,
+    };
+
+    return ris;
+  });
+
+};
+
+
+const Graduatoria = mongoose.model('Graduatoria', GraduatoriaSchema);
+
+module.exports = { Graduatoria };

src/server/models/listaingresso.js

@@ -1,4 +1,4 @@
-var bcrypt = require('bcryptjs');
+const bcrypt = require('bcryptjs');
 const mongoose = require('mongoose');
 const validator = require('validator');
 const jwt = require('jsonwebtoken');
@@ -9,6 +9,7 @@ const tools = require('../tools/general');
 const { ObjectID } = require('mongodb');
 
 const { Nave } = require('./nave');
+const { Graduatoria } = require('./graduatoria');
 
 const shared_consts = require('../tools/shared_nodejs');
 const queryclass = require('../classes/queryclass');
@@ -108,6 +109,63 @@ ListaIngressoSchema.statics.getTotInLista = async function (idapp) {
   return await ListaIngresso.count(myfind);
 };
 
+ListaIngressoSchema.statics.getImbarcatiDaily = function (idapp, nrec) {
+
+  const query = [
+    {
+      $match: {
+        idapp, deleted: false, date_added: { $gte: tools.IncDateNow(-(1000 * 60 * 60 * 24 * nrec)) },
+      }
+    },
+    {
+      $group: { _id: { $dateToString: { format: "%Y-%m-%d", date: "$date_added" } }, count: { $sum: 1 } }
+    },
+    {
+      $sort: { _id: 1 }
+    }
+  ];
+  return query
+};
+
+
+ListaIngressoSchema.statics.getImbarcatiWeekly = function (idapp, nrec) {
+
+  const query = [
+    {
+      $match: {
+        idapp, deleted: false, date_added: { $gte: tools.IncDateNow(-(1000 * 60 * 60 * 24 * nrec)) },
+      }
+    },
+    {
+      $group: { _id: { $dateToString: { format: "%Y-%U", date: "$date_added" } }, count: { $sum: 1 } }
+    },
+    {
+      $sort: { _id: 1 }
+    }
+  ];
+  return query
+};
+
+
+ListaIngressoSchema.statics.ImbarcatiWeekly = async function (idapp) {
+  const ListaIngresso = this;
+
+  return ListaIngresso.aggregate(ListaIngresso.getImbarcatiWeekly(idapp, 20 * 7))
+    .then(ris => {
+      return JSON.stringify(ris.slice(0, -1));
+    });
+};
+
+ListaIngressoSchema.statics.ImbarcatiDaily = async function (idapp) {
+  const ListaIngresso = this;
+
+  return ListaIngresso.aggregate(ListaIngresso.getImbarcatiDaily(idapp, 30))
+    .then(ris => {
+      return JSON.stringify(ris.slice(0, -1));
+    });
+};
+
+
 ListaIngressoSchema.statics.findByIndOrder = function (idapp, ind_order) {
   const ListaIngresso = this;
 
@@ -220,6 +278,12 @@ ListaIngressoSchema.statics.addUserInListaIngresso = async function (idapp, user
         const ris = await listaingresso.save();
         if (addednowreal) {
           if (!!ris) {
+
+            if (addednowreal) {
+              // Aggiungilo anche nella Graduatoria !
+              await Graduatoria.addSingoloInGraduatoria_InFondo(idapp, listaingresso);
+            }
+
             const nome = await User.getNameSurnameByUsername(idapp, username);
             const numimbarcare = await ListaIngresso.getNumDaImbarcare(idapp);
             let msgtext = '🛳 ';
@@ -238,7 +302,7 @@ ListaIngressoSchema.statics.addUserInListaIngresso = async function (idapp, user
             if (!!opt) {
               if (!!opt.sendmsgtoinvitante) {
                 if (opt.sendmsgtoinvitante) {
-                  const nome = await User.getNameSurnameByUsername(idapp, invitante_username);
+                  // const nome = await User.getNameSurnameByUsername(idapp, invitante_username);
                   // msgtext = '🔵 ' + nome + ' (' + username + ') ' + tools.gettranslate('ADDED_TOLISTAINGRESSO', lang);
                   // await telegrambot.sendMsgTelegram(idapp, username, msgtext, true);  // Anche a STAFF
                 }
@@ -271,6 +335,49 @@ ListaIngressoSchema.statics.addUserInListaIngresso = async function (idapp, user
 ;
 
 
+function getQueryNumInvitati(myfilter, myobjField, myfilter2, mygroup) {
+  const query = [
+    { $match: myfilter },
+    {
+      $lookup: {
+        from: "users",
+        as: "user",
+        let: { username: '$username' },
+        pipeline: [
+          {
+            $match: {
+              $expr: {
+                $and: [
+                  { $eq: ['$username', '$$username'] },
+                  { $eq: ['$idapp', myfilter.idapp] },
+                ]
+              }
+            }
+          }
+        ]
+      }
+    },
+    {
+      $replaceRoot: { newRoot: { $mergeObjects: [{ $arrayElemAt: ["$user", 0] }, "$$ROOT"] } }
+    },
+    { $match: myfilter2 },
+  ];
+
+  if (!!mygroup) {
+    query.push(
+      { $group: mygroup }
+    );
+  }
+
+  if (!!myobjField) {
+    query.push(
+      { $project: myobjField }
+    );
+  }
+
+  return query;
+}
+
 function getQueryProj(myfilter, myobjField, myfilter2, mygroup) {
   const query = [
     { $match: myfilter },
@@ -358,6 +465,7 @@ function getQueryIndOrder(myfilter, myobjField, myfilter2, mygroup) {
 }
 
 
+/*
 ListaIngressoSchema.statics.getPosizioneInLista = async function (idapp, arrrec, ind_order, num_tess) {
 
 
@@ -376,6 +484,7 @@ ListaIngressoSchema.statics.getPosizioneInLista = async function (idapp, arrrec,
   return { posiz: posiz + 1, totposiz, num_tess, numNaviEntrato }
 
 };
+*/
 
 ListaIngressoSchema.statics.showListaOrd = async function (idapp, solonuovi) {
   const ListaIngresso = this;
@@ -386,6 +495,7 @@ ListaIngressoSchema.statics.showListaOrd = async function (idapp, solonuovi) {
   let conta = 1;
   for (const rec of arrrec) {
     mystr += conta + '- ' + ' [' + rec.numinvitatiattivi + '-' + rec.numinvitati + '] (' + rec.index + ') ';
+    mystr += ' {' + rec.numinvitatiattivireali + ',' + rec.numinvitatireali + '} ';
     mystr += ' [' + tools.getstrDateShort(rec.date_added, 'it') + '] ';
     mystr += rec.username + ' ' + rec.name + ' ' + rec.surname;
     mystr += ' inv = ' + rec.invitante_username;
@@ -426,15 +536,89 @@ ListaIngressoSchema.statics.findAllIdApp = function (idapp) {
 
 function sortRec(rec) {
   return rec.sort(function (reca, recb) {
-    return Math.round((recb.numinvitatiattivi + recb.numinvitati) / recb.num_tess) - Math.round((reca.numinvitatiattivi + reca.numinvitati) / reca.num_tess);
+    // return Math.round((recb.numinvitatiattivi + recb.numinvitati) / recb.num_tess) - Math.round((reca.numinvitatiattivi + reca.numinvitati) / reca.num_tess);
+    // return Math.round((recb.numinvitatiattivi + recb.numinvitati) / recb.indimbarco * 2) - Math.round((reca.numinvitatiattivi + reca.numinvitati) / reca.indimbarco * 2);
+    // return Math.round((recb.numinvitatiattiviTot + recb.numinvitatiTot) / (recb.indimbarco + recb.numNaviEntrato * 2)) - Math.round((reca.numinvitatiattiviTot + reca.numinvitatiTot) / (reca.indimbarco + reca.numNaviEntrato * 2));
+
+    // return ((recb.numinvitatiattiviTot - recb.numNaviEntrato * 2) - (recb.indimbarco - 1) * 2) + ((recb.numinvitatiTot - recb.numNaviEntrato * 2) - (recb.indimbarco - 1) * 2) /
+    //    (((reca.numinvitatiattiviTot - reca.numNaviEntrato * 2) - (reca.indimbarco - 1) * 2)) +  ((reca.numinvitatiTot - reca.numNaviEntrato * 2) - (reca.indimbarco - 1) * 2);
+//
+    //return Math.round(((recb.numinvitatiattiviTot * 2) + recb.numinvitatiTot) / (recb.indimbarco + recb.numNaviEntrato * 2)) - Math.round(((reca.numinvitatiattiviTot * 2)  + reca.numinvitatiTot) / (reca.indimbarco + reca.numNaviEntrato * 2));
+
   });
 }
 
-ListaIngressoSchema.statics.getProssimiInLista = async function (idapp, solonuovi) {
+ListaIngressoSchema.statics.getProssimiInLista = function (idapp, solonuovi) {
+  return Graduatoria.findAllIdApp(idapp).sort({ index: 1 });
+};
+
+
+ListaIngressoSchema.statics.aggiornaRecListaIngr = async function (idapp, rec, arrindex) {
+
+  rec.numNaviEntrato = await Nave.getnumNaviByUsername(idapp, rec.username);
+
+  rec.numinvitati = await ListaIngresso.getnumInvitati(idapp, rec.username);
+  rec.numinvitatiattivi = await ListaIngresso.getnumInvitatiAttivi(idapp, rec.username);
+
+  const arrListaIngrUser = arrindex[rec.username];
+  if (!arrListaIngrUser) {
+    // arrindex[rec.username] = 1 + rec.numNaviEntrato;
+    arrindex[rec.username] = 1;
+  } else {
+    arrindex[rec.username] += 1; // incrementa
+  }
+
+  rec.indimbarco = arrindex[rec.username];
+  rec.numinvitatiTot = rec.numinvitati;
+  rec.numinvitatiattiviTot = rec.numinvitatiattivi;
+
+  // rec.punteggio = (((rec.numinvitatiattiviTot * 1.5) - (rec.numNaviEntrato * 2)) - (rec.indimbarco - 1) * 2) + ((rec.numinvitatiTot - (rec.numNaviEntrato * 2)) - (rec.indimbarco - 1) * 2);
+
+  let val1 = (((rec.numinvitatiattiviTot * 1.5) - (rec.numNaviEntrato * 2)) - (rec.indimbarco - 1) * 2);
+  let val2 = ((rec.numinvitatiTot - (rec.numNaviEntrato * 2)) - (rec.indimbarco - 1) * 2);
+
+  if (val1 < 0)
+    val1 = 0;
+  if (val2 < 0)
+    val2 = 0;
+  if (val1 > 2)
+    val1 = 2;
+  if (val2 > 2)
+    val2 = 2;
+
+  rec.punteggio = val1 + val2;
+
+  // if (rec.num_tess > 2) {
+  rec.numinvitati = rec.numinvitati - (arrindex[rec.username] - 1) * 2;
+  rec.numinvitatiattivi = rec.numinvitatiattivi - (arrindex[rec.username] - 1) * 2;
+  // }
+  if (rec.numinvitati < 0) {
+    rec.numinvitati = 0;
+  }
+  if (rec.numinvitati > 2) {
+    rec.numinvitati = 2;
+  }
+  if (rec.numinvitatiattivi < 0) {
+    rec.numinvitatiattivi = 0;
+  }
+
+  if (rec.numinvitatiattivi > 2)
+    rec.numinvitatiattivi = 2;
+
+  return rec;
+};
+
+ListaIngressoSchema.statics.GeneraGraduatoria = async function (idapp, solonuovi) {
   const ListaIngresso = this;
 
   let myquery = '';
 
+  //++Todo: DA TOGLIERE IL COMMENTO !!!
+  // if (await Graduatoria.isWorking(idapp))
+  //   return;
+
+  await Graduatoria.setWorking(idapp, true);
+
   let myobjField = {
     idapp: 1,
     index: 1,
@@ -452,77 +636,68 @@ ListaIngressoSchema.statics.getProssimiInLista = async function (idapp, solonuov
     sospeso: 1,
   };
 
-  let myfilter2 = {
-    surname: { $exists: true },
-    $or: [{ deleted: { $exists: false } }, { deleted: { $exists: true, $eq: false } }],
-  };
+  try {
+    let myfilter2 = {
+      surname: { $exists: true },
+      $or: [{ deleted: { $exists: false } }, { deleted: { $exists: true, $eq: false } }],
+    };
 
-  if (solonuovi) {
-    myquery = getQueryProj({
-      'idapp': idapp,
-      ind_order: { $gte: 0 },
-      added: false,
-      deleted: false,
-    }, myobjField, myfilter2);
-  } else {
-    myquery = getQueryProj({
-      'idapp': idapp,
-      ind_order: { $gte: 0 },
-      deleted: false,
-    }, myobjField, myfilter2);
+    if (solonuovi) {
+      myquery = getQueryProj({
+        'idapp': idapp,
+        ind_order: { $gte: 0 },
+        added: false,
+        deleted: false,
+      }, myobjField, myfilter2);
+    } else {
+      myquery = getQueryProj({
+        'idapp': idapp,
+        ind_order: { $gte: 0 },
+        deleted: false,
+      }, myobjField, myfilter2);
+    }
+
+    // await ListaIngresso.aggiornaIndex();
+
+    arrrec = await ListaIngresso.aggregate(myquery)
+      .then(async (arrlista) => {
+
+        const { User } = require('../models/user');
+
+        let arrindex = {};
+
+        for (const rec of arrlista) {
+
+          await ListaIngresso.aggiornaRecListaIngr(idapp, rec, arrindex)
+
+        }
+
+        /*if (arrlista) {
+          arrlista = sortRec(arrlista);
+          // arrlista.reverse();
+        }*/
+
+        const salvasudb = true;
+        if (salvasudb) {
+          numrec = await Graduatoria.addArrayInGraduatoria(idapp, arrlista);
+        }
+
+        await Graduatoria.AggiornaIndiceGraduatoria(idapp);
+
+        await Graduatoria.setWorking(idapp, false);
+
+        return numrec;
+      }).catch((e) => {
+        Graduatoria.setWorking(idapp, false);
+
+        console.error(e.message);
+        return null
+      });
+
+  } catch (e) {
+    await Graduatoria.setWorking(idapp, false);
   }
 
-  // await ListaIngresso.aggiornaIndex();
-
-  arrrec = await ListaIngresso.aggregate(myquery).sort({ date_added: 1 })
-    .then(async (arrlista) => {
-
-      const { User } = require('../models/user');
-
-      const arrindex = {};
-
-      for (const rec of arrlista) {
-
-        if (true) {
-          rec.numNaviEntrato = await Nave.getnumNaviByUsername(idapp, rec.username);
-
-          rec.numinvitati = await ListaIngresso.getnumInvitati(idapp, rec.username);
-          rec.numinvitatiattivi = await ListaIngresso.getnumInvitatiAttivi(idapp, rec.username);
-        }
-
-        const arrListaIngrUser = arrindex[rec.username];
-        if (!arrListaIngrUser) {
-          arrindex[rec.username] = 1 + rec.numNaviEntrato;
-        } else {
-          arrindex[rec.username] += 1; // incrementa
-        }
-
-        // if (rec.num_tess > 2) {
-        rec.numinvitati = rec.numinvitati - (arrindex[rec.username] - 1) * 2;
-        rec.numinvitatiattivi = rec.numinvitatiattivi - (arrindex[rec.username] - 1) * 2;
-        // }
-        if (rec.numinvitati < 0) {
-          rec.numinvitati = 0;
-        }
-        if (rec.numinvitatiattivi < 0) {
-          rec.numinvitatiattivi = 0;
-        }
-
-        if (rec.numinvitatiattivi > 2)
-          rec.numinvitatiattivi = 2;
-      }
-
-      if (arrlista) {
-        arrlista = sortRec(arrlista);
-        // arrlista.reverse();
-      }
-
-      return arrlista;
-    }).catch((e) => {
-      console.error(e.message);
-      return null
-    });
-
   return arrrec;
 };
 
@@ -558,7 +733,7 @@ ListaIngressoSchema.statics.creaTessituraeConv = async function (idapp) {
   try {
     if (true) {
       // Elimina TUTTI i Cancellati (ma non Sospesi)
-      await User.remove({
+      await User.deleteMany({
         idapp,
         $and: [
           { deleted: { $exists: true, $eq: true } },  // cancellati
@@ -718,7 +893,7 @@ ListaIngressoSchema.statics.creaTessituraeConv = async function (idapp) {
     }
 
     // RIMUOVI IL CAMPO IND_ORDER SULLA USER!
-    await User.update({}, {$unset: {ind_order: 1}}, {multi: true});
+    await User.update({}, { $unset: { ind_order: 1 } }, { multi: true });
 
     // Ricalcola il Campo Index
     await User.ricalcolaIndex(idapp);
@@ -757,7 +932,7 @@ ListaIngressoSchema.statics.getarray = async function (idapp, filtri, myobjField
 
   let myfilter2 = {
     surname: { $exists: true },
-    $or: [{ deleted: { $exists: false } }, { deleted: { $exists: true, $eq: false } }],
+    $or: [{ 'user.deleted': { $exists: false } }, { 'user.deleted': { $exists: true, $eq: false } }],
   };
 
   let myquery = getQueryProj(
@@ -788,13 +963,33 @@ ListaIngressoSchema.statics.getarrayIndOrder = async function (idapp, filtri, my
 
 };
 
+ListaIngressoSchema.statics.getIngrEUserByFilter = async function (idapp, myfilter) {
+  const ListaIngresso = this;
+
+  const arr = await ListaIngresso.getarray(idapp, myfilter, {
+    _id: 1,
+    idapp: 1,
+    username: 1,
+    ind_order: 1,
+    name: 1,
+    surname: 1,
+    index: 1
+  });
+
+  if (!!arr) {
+    return arr.length > 0 ? arr[0] : null;
+  }
+  return null;
+
+};
+
 
 ListaIngressoSchema.statics.getInvitati = async function (idapp, username, includemyself, myobjField) {
   const ListaIngresso = this;
 
   let myq = {
     idapp,
-    deleted: false,
+    $or: [{ 'user.deleted': { $exists: false } }, { 'user.deleted': { $exists: true, $eq: false } }],
     invitante_username: username,
   };
 
@@ -828,9 +1023,71 @@ ListaIngressoSchema.statics.getUserByInvitante_Username = async function (idapp,
 
 */
 
+ListaIngressoSchema.statics.getnumInvitatiBase = async function (idapp, username, attivi) {
+  const ListaIngresso = this;
+
+  const { User } = require('./user');
+
+  let myfilter2 = {
+    surname: { $exists: true },
+  };
+
+  if (attivi) {
+    myfilter2 = {
+      ...myfilter2,
+      $and: User.getQueryQualified(),
+    }
+  }
+
+  let myquery = getQueryProj({
+      idapp,
+      invitante_username: username,
+      // username: { $ne: username },
+      $or: [{ 'user.deleted': { $exists: false } }, { 'user.deleted': { $exists: true, $eq: false } }],
+    },
+    { username: 1, ind_order: 1 },
+    myfilter2,
+  );
+
+  // { _id: null, count: { $sum: 1 }
+
+  arrlistainv = await ListaIngresso.aggregate(myquery);
+
+  // Ottieni gli invitati che ancora non hanno un'imbarco
+  let myqueryuser = {
+    idapp,
+    aportador_solidario: username,
+    //$or: [{ deleted: { $exists: false } }, { deleted: { $exists: true, $eq: false } }],
+    $or: [{ 'user.deleted': { $exists: false } }, { 'user.deleted': { $exists: true, $eq: false } }],
+  };
+
+  if (attivi) {
+    myqueryuser = {
+      ...myqueryuser,
+      $and: User.getQueryQualified()
+    }
+  }
+
+  const arrinv = await User.find(myqueryuser);
+
+  for (const inv of arrinv) {
+    if (!arrlistainv.find((rec) => rec.username === inv.username))
+      arrlistainv.push(inv);
+  }
+
+  if (!!arrlistainv)
+    return arrlistainv.length;
+  else
+    return 0;
+};
+
+
 ListaIngressoSchema.statics.getnumInvitati = async function (idapp, username) {
   const ListaIngresso = this;
 
+  return ListaIngresso.getnumInvitatiBase(idapp, username, false);
+
+  /*
   const arrlistainv = await ListaIngresso.find({
     idapp,
     invitante_username: username,
@@ -847,71 +1104,31 @@ ListaIngressoSchema.statics.getnumInvitati = async function (idapp, username) {
     $or: [{ deleted: { $exists: false } }, { deleted: { $exists: true, $eq: false } }]
   });
 
-  for (const inv of arrinv) {
-    if (!arrlistainv.find((rec) => rec.username === inv.username))
-      arrlistainv.push(inv);
-  }
-
-  if (!!arrlistainv)
-    return arrlistainv.length;
-  else
-    return 0;
-
-};
-
-ListaIngressoSchema.statics.getnumInvitatiAttivi = async function (idapp, username) {
-  const ListaIngresso = this;
-
-  const { User } = require('./user');
-
-  let myfilter2 = {
-    surname: { $exists: true },
-    $and: User.getQueryQualified(),
-  };
-
-  let myquery = getQueryProj({
-      idapp,
-      invitante_username: username,
-      // username: { $ne: username },
-      deleted: false,
-    },
-    { username: 1, ind_order: 1 },
-    myfilter2,
-  );
-
-  // { _id: null, count: { $sum: 1 }
-
-  arrlistainv = await ListaIngresso.aggregate(myquery);
-
-  // Ottieni gli invitati che ancora non hanno un'imbarco
-  const arrinv = await User.find({
-    idapp,
-    aportador_solidario: username,
-    $or: [{ deleted: { $exists: false } }, { deleted: { $exists: true, $eq: false } }],
-    $and: User.getQueryQualified()
-  });
 
 
   for (const inv of arrinv) {
     if (!arrlistainv.find((rec) => rec.username === inv.username))
       arrlistainv.push(inv);
-  }
+  } */
+
 
-  if (!!arrlistainv)
-    return arrlistainv.length;
-  else
-    return 0;
 };
 
-
-ListaIngressoSchema.statics.aggiornaIndex = function (idapp) {
+ListaIngressoSchema.statics.Esegui_CronTab = async function (idapp) {
   const ListaIngresso = this;
 
-  const arrlista = ListaIngresso.find({ idapp }).sort({ created: 1 });
+  console.log('Lancia CronTab: [IDAPP=' + idapp + ']');
 
+  await ListaIngresso.GeneraGraduatoria(idapp, true);
 
 };
 
+ListaIngressoSchema.statics.getnumInvitatiAttivi = function (idapp, username) {
+  const ListaIngresso = this;
+
+  return ListaIngresso.getnumInvitatiBase(idapp, username, true);
+};
+
 
 const ListaIngresso = mongoose.model('ListaIngresso', ListaIngressoSchema);
 

src/server/models/nave.js

@@ -36,6 +36,9 @@ const NaveSchema = new mongoose.Schema({
   col: {
     type: Number,
   },
+  idListaIngresso: {
+    type: String,
+  },
   ind_order: {
     type: Number,
   },
@@ -57,6 +60,9 @@ const NaveSchema = new mongoose.Schema({
     type: Boolean,
     default: false,
   },
+  offerta_al_fondo: {
+    type: Number,
+  },
   date_received_gift: {
     type: Date,
   },
@@ -75,7 +81,7 @@ const NaveSchema = new mongoose.Schema({
 NaveSchema.statics.getTotInLista = async function (idapp) {
   const Nave = this;
 
-  const myfind = { idapp };
+  const myfind = { idapp, ind_order: { $gte: 0 } };
 
   return await Nave.count(myfind);
 };
@@ -410,6 +416,7 @@ function getQueryProj(myfilter) {
     _id: 1,
     idapp: 1,
     lang: 1,
+    idListaIngresso: 1,
     ind_order: 1,
     name: 1,
     surname: 1,
@@ -488,6 +495,7 @@ function getQueryProj(myfilter) {
 function getQueryInvitante(myfilter) {
 
   myobjField = {
+    idListaIngresso: 1,
     ind_order: 1,
     name: 1,
     surname: 1,
@@ -550,7 +558,6 @@ function getQueryInvitante(myfilter) {
 }
 
 
-
 NaveSchema.statics.setRiga = function (idapp, riga) {
   return Settings.setKeyNum(idapp, 'riga', riga);
 };
@@ -567,11 +574,6 @@ NaveSchema.statics.getCol = function (idapp) {
   return Settings.getKeyNum(idapp, 'col', 1);
 };
 
-function getmaxcol(riga) {
-
-  return Math.pow(2, riga - 1);
-}
-
 function getPrimoFuocoByIndCol(col) {
   // let ris = Math.ceil(col - (col % 8)) + 1;
   let ris = ((Math.ceil(col / 8) - 1) * 8) + 1;
@@ -602,6 +604,7 @@ async function getusertextbyrec(myrec, symbol, lettera, riga, col, ind) {
 function checkifNullThenEmpty(rec, riga, col) {
   if (rec === null) {
     return {
+      idListaIngresso: -1,
       name: '',
       surname: '',
       username: '',
@@ -803,7 +806,7 @@ NaveSchema.statics.getNavePos = async function (idapp, riga, col, solorecord, in
 
     mystr += tools.ACAPO + '4️⃣° 🌀 ' + tools.get__('MEDIATORE', lang) + ':' + await getusertextbyrec(recmediatore, '', '', riga, col, '') + tools.ACAPO + tools.ACAPO;
 
-    mystr +=  '3️⃣° ' + tools.get__('INTERMEDIO', lang) +':' + tools.ACAPO;
+    mystr += '3️⃣° ' + tools.get__('INTERMEDIO', lang) + ':' + tools.ACAPO;
     for (let indterra = 1; indterra <= 2; indterra++) {
       miacol = calcval(riga, col, 2) + (indterra);
       miariga = riga + 1;
@@ -813,7 +816,7 @@ NaveSchema.statics.getNavePos = async function (idapp, riga, col, solorecord, in
 
     mystr += tools.ACAPO;
 
-    mystr +=  '2️⃣° ' + tools.get__('INTERMEDIO', lang) + ':' + tools.ACAPO;
+    mystr += '2️⃣° ' + tools.get__('INTERMEDIO', lang) + ':' + tools.ACAPO;
     for (let indaria = 1; indaria <= 4; indaria++) {
       miacol = calcval(riga, col, 4) + (indaria);
       miariga = riga + 2;
@@ -983,7 +986,7 @@ NaveSchema.statics.showListaOrd = async function (idapp) {
 };
 
 NaveSchema.statics.getLastRigaCol = async function (idapp) {
-  return Nave.findOne({ idapp }).sort({ _id: -1 });
+  return Nave.findOne({ idapp }).sort({ riga: -1, col: -1 });
 };
 
 async function addRecordNaveByParams(params, siRitesse) {
@@ -1014,8 +1017,10 @@ async function addRecordNaveByParams(params, siRitesse) {
       num_tess: params.num_tess
     });
     if (!!giapresente) {
-      let fields_to_update = { added: true };
-      await ListaIngresso.findOneAndUpdate({ _id: params.id.toString() }, { $set: fields_to_update }, { new: false });
+      if (params.persistenti) {
+        let fields_to_update = { added: true };
+        await ListaIngresso.findOneAndUpdate({ _id: params.id.toString() }, { $set: fields_to_update }, { new: false });
+      }
 
       return false;
     }
@@ -1024,6 +1029,7 @@ async function addRecordNaveByParams(params, siRitesse) {
 
   let myNave = new Nave({
     idapp: params.idapp,
+    idListaIngresso: params.id,
     ind_order: params.ind_order,
     riga: params.riga,
     col: params.col,
@@ -1044,15 +1050,17 @@ async function addRecordNaveByParams(params, siRitesse) {
     myNave.parent_id = "0";
   }
 
-  console.log('addRecordNaveByParams (' + myNave.parent_id + ')');
+  // console.log('addRecordNaveByParams (' + myNave.parent_id + ')');
 
   return await myNave.save()
     .then(async (result) => {
 
       if (!!result) {
 
-        let fields_to_update = { added: true };
-        await ListaIngresso.findOneAndUpdate({ _id: params.id.toString() }, { $set: fields_to_update }, { new: false });
+        if (params.persistenti) {
+          let fields_to_update = { added: true };
+          await ListaIngresso.findOneAndUpdate({ _id: params.id.toString() }, { $set: fields_to_update }, { new: false });
+        }
 
         params.conta++;
 
@@ -1071,7 +1079,7 @@ async function addRecordNaveByParams(params, siRitesse) {
           params.riga++;
           params.rigaparent = params.riga - 1;
           params.col = 1;
-          params.maxcol = getmaxcol(params.riga);
+          params.maxcol = tools.getmaxcol(params.riga);
         } else {
           params.col++;
         }
@@ -1126,7 +1134,7 @@ NaveSchema.statics.addUserFromListaIngresso_IntoNave = async function (init, ida
   params.primavolta = (params.riga === 1) && (params.col === 1);
   params.riga = await Nave.getRiga(idapp);
   params.col = await Nave.getCol(idapp);
-  params.maxcol = getmaxcol(params.riga);
+  params.maxcol = tools.getmaxcol(params.riga);
   params.colparent = Math.ceil(params.col / 2);
   params.rigaparent = params.riga - 1;
 
@@ -1139,7 +1147,7 @@ NaveSchema.statics.addUserFromListaIngresso_IntoNave = async function (init, ida
   const inserito = await addRecordNaveByParams(params, false);
   if (inserito) {
     if (idapp === tools.AYNI) {
-      if (((params.col) % 8) === 0) {
+      if ((((params.col) % 8) === 0) && (params.col % 64 !== 0))  {
         let recmediatore = await Nave.findMediatoreByFuoco(idapp, myriga, mycol, 0);
         if (!!recmediatore) {
           const ris = await Nave.checkifDeveRitessersi(recmediatore);
@@ -1149,13 +1157,16 @@ NaveSchema.statics.addUserFromListaIngresso_IntoNave = async function (init, ida
               params.ind_order = recmediatore.ind_order;
               params.id = recmediatore._id;
               params.num_tess = recmediatore.num_tess + 1;
+              params.idListaIngresso = -1;
 
               await addRecordNaveByParams(params, true);
             }
           }
         }
       }
-      if ((params.riga === 4 + 3) && (params.col === (8 * 2) + 3)) {
+
+      /**
+       if ((params.riga === 4 + 3) && (params.col === (8 * 2) + 3)) {
         // Si ritesse il Fondo AYNI nella Nave 3.3
         const userFondo = await User.findByIndex(idapp, 0);
         params.ind_order = userFondo.ind_order;
@@ -1163,7 +1174,8 @@ NaveSchema.statics.addUserFromListaIngresso_IntoNave = async function (init, ida
         params.num_tess = userFondo.num_tess;
 
         await addRecordNaveByParams(params, true);
-      }
+      } **/
+
     }
   }
 
@@ -1174,7 +1186,7 @@ NaveSchema.statics.addUserFromListaIngresso_IntoNave = async function (init, ida
 
 };
 
-NaveSchema.statics.generaNave = async function (idapp, mydata) {
+NaveSchema.statics.generaNave = async function (idapp, mydata, persistenti) {
   const Nave = this;
 
   const { User } = require('./user');
@@ -1189,6 +1201,10 @@ NaveSchema.statics.generaNave = async function (idapp, mydata) {
     numpersone: mydata.numpersone,
   };
 
+  if (!persistenti) {
+    params.numpersone = 2000; // Mettili tutti
+  }
+
   //++Todo: date_gift_chat_open e date_start : Ricalcolarle in Automatico...
 
   params.primavolta = (params.riga === 1) && (params.col === 1);
@@ -1215,8 +1231,9 @@ NaveSchema.statics.generaNave = async function (idapp, mydata) {
   for (const reclista of arrlistaingresso) {
 
     params.ind_order = reclista.ind_order;
-    params.id = reclista._id;
+    params.id = reclista.idListaIngresso;
     params.num_tess = reclista.num_tess;
+    params.persistenti = persistenti;
 
     await Nave.addUserFromListaIngresso_IntoNave(index === 0, idapp, params, false);
     index++;
@@ -1233,9 +1250,12 @@ async function addUserToNave(idapp, rec) {
 
   let params = {};
 
-  params.id = rec._id;
+  params.ind_order = rec.ind_order;
+  params.id = rec.idListaIngresso;
   params.num_tess = rec.num_tess;
+  params.persistenti = false;
 
+  //CONTROLLARE SE SERVE ANCORA !!!!!!!!!!!!!!!!!!!!!!
   return await Nave.addUserFromListaIngresso_IntoNave(true, idapp, params, true);
 
 }
@@ -1401,6 +1421,12 @@ NaveSchema.statics.getDonatoridelSognatore = async function (idapp, riganave, co
 
 };
 
+NaveSchema.statics.isDefinitiva = async function (idapp, mynave) {
+  const nave = await NavePersistente.findByRigaColByDonatore(idapp, mynave.riga, mynave.col, 0);
+  return (!!nave) ? !nave.provvisoria : false;
+
+};
+
 NaveSchema.statics.ricalcolaNave = async function (idapp, nave, riga1don, col1don, ricalcola, index) {
   const Nave = this;
 
@@ -1490,16 +1516,43 @@ NaveSchema.statics.getnumNaviByUsername = async function (idapp, username) {
       ind_order: 1
     });
 
-    if (!!arrrec)
-      return arrrec.length;
-    else
-      return 0;
+    // SOLO QUELLE PERMANENTI !
+    let ind = 0;
+    for (const mynave of arrrec) {
+      const trovato = await NavePersistente.findByRigaColByDonatore(idapp, mynave.riga, mynave.col, 0);
+      if (!!trovato) {
+        ind++;
+      }
+    }
+
+    return ind;
 
   } catch (e) {
     console.error(e.message);
   }
 };
 
+NaveSchema.statics.checkIfMadeGift = async function (idapp, username) {
+  const Nave = this;
+
+  const { ListaIngresso } = require('./listaingresso');
+
+  const arrlistaingr = await ListaIngresso.find({ idapp, username });
+  for (const ingr of arrlistaingr) {
+
+    let mynave = await Nave.findOne({ idapp, ind_order: ingr.ind_order });
+    if (!!mynave) {
+      if (mynave.made_gift) {
+        return true;
+      }
+    }
+  }
+
+  return false;
+
+
+};
+
 NaveSchema.statics.getSognatoreByRigaColMediatore = async function (idapp, navemediatore) {
 
   const ris = this.getRigaColSognatoreByMediatore(idapp, navemediatore.riga, navemediatore.col, 3);

src/server/models/navepersistente.js

@@ -250,7 +250,7 @@ NavePersistenteSchema.statics.findByRigaCol = function (idapp, riga, col) {
 
 
 NavePersistenteSchema.statics.getLastRigaCol = async function (idapp) {
-  return NavePersistente.findOne({ idapp }).sort({ _id: -1 });
+  return NavePersistente.findOne({ idapp }).sort({ riga: -1, col: -1 });
 };
 
 NavePersistenteSchema.statics.getLastRigaColDefinitiva = async function (idapp) {
@@ -270,6 +270,19 @@ NavePersistenteSchema.pre('save', async function (next) {
   next();
 });
 
+function getNextDayNave(miadata) {
+
+  const dayofweek = [1, 3, 5];  // LUNEDI, MERCOLEDI, VENERDI
+
+  let mydate = tools.AddDate(miadata, 1);
+
+  while (!dayofweek.includes(mydate.getDay())) {
+    mydate = tools.AddDate(mydate, 1);
+  }
+
+  return mydate
+
+}
 
 NavePersistenteSchema.statics.addRecordNavePersistenteByParams = async function (params) {
 
@@ -281,14 +294,27 @@ NavePersistenteSchema.statics.addRecordNavePersistenteByParams = async function
   });
 
   if (!giapresente) {
+    // Prende la nave prima:
+    const lastnave = await NavePersistente.findOne({idapp}).sort({riga: -1, col: -1});
+
+    let nextgiftchat = null;
+
+    if (((params.col - 1) % 8 === 0)) {
+      nextgiftchat = getNextDayNave(lastnave.date_gift_chat_open);
+    } else {
+      nextgiftchat = lastnave.date_gift_chat_open;
+    }
+
+    const next_date_start = tools.AddDate(nextgiftchat, 7);
+
     let myNavePersistente = new NavePersistente({
       idapp: params.idapp,
       riga: params.riga,
       col: params.col,
       riga1don: params.riga1don,
       col1don: params.col1don,
-      date_start: params.date_start,
-      date_gift_chat_open: params.date_gift_chat_open,
+      date_gift_chat_open: nextgiftchat,
+      date_start: next_date_start,
       provvisoria: true,
     });
     return await myNavePersistente.save();

src/server/models/settings.js

@@ -114,6 +114,24 @@ SettingsSchema.statics.setKeyNum = async function (idapp, key, value) {
 
 };
 
+SettingsSchema.statics.setBool = async function (idapp, key, valbool) {
+  const Settings = this;
+
+  let myrec = await Settings.findOne({ idapp, key });
+  if (!myrec) {
+    myrec = new Settings({ key });
+    myrec._id = new ObjectID();
+    myrec.idapp = idapp;
+    myrec.type = tools.FieldType.boolean;
+    myrec.value_bool = valbool;
+
+    return await myrec.save();
+  } else {
+    myrec = await Settings.findOneAndUpdate({ idapp, key }, { $set: { value_bool: valbool } }, { new: false });
+  }
+
+};
+
 
 SettingsSchema.statics.getKeyNum = async function (idapp, key, mydefault) {
   const Settings = this;

src/server/models/user.js

@@ -8,6 +8,7 @@ const tools = require('../tools/general');
 
 const { Settings } = require('../models/settings');
 const { ListaIngresso } = require('../models/listaingresso');
+const { Graduatoria } = require('../models/graduatoria');
 const { Nave } = require('../models/nave');
 const { NavePersistente } = require('../models/navepersistente');
 // const { ExtraList } = require('../models/extralist');
@@ -557,6 +558,7 @@ UserSchema.statics.getQueryQualified = function () {
 }
 
 
+
 UserSchema.statics.isUserQualified7 = async function (idapp, username) {
   const User = this;
 
@@ -921,12 +923,15 @@ UserSchema.statics.SetTelegramWasBlocked = async function (idapp, teleg_id) {
     'profile.teleg_id': 0,
   };
 
-  const ris = await User.findOneAndUpdate({
-    idapp,
-    'profile.teleg_id': teleg_id
-  }, { $set: fields_to_update }, { new: false }).then((record) => {
-    return record;
-  });
+  if (process.env.PROD === 1) {
+
+    const ris = await User.findOneAndUpdate({
+      idapp,
+      'profile.teleg_id': teleg_id
+    }, { $set: fields_to_update }, { new: false }).then((record) => {
+      return record;
+    });
+  }
 
 };
 
@@ -1213,15 +1218,15 @@ UserSchema.statics.getDashboard = async function (idapp, aportador_solidario, us
 
     dashboard.arrposizioni = await Nave.getArrPosizioniByUsername(idapp, username);
 
-    let arrrec = [];
+    /* let arrrec = [];
     if (dashboard.arrimbarchi.length > 0) {
       arrrec = await ListaIngresso.getProssimiInLista(idapp, true);
-    }
+    }*/
 
     for (let myimbarco of dashboard.arrimbarchi) {
       if (!!myimbarco.invitante_username)
         dashboard.arrusers[myimbarco.invitante_username] = await User.getUserShortDataByUsername(idapp, myimbarco.invitante_username);
-      myimbarco._doc.posiz = await ListaIngresso.getPosizioneInLista(idapp, arrrec, myimbarco.ind_order, myimbarco.num_tess);
+      myimbarco._doc.posiz = await Graduatoria.getPosizioneInGraduatoria(idapp, myimbarco.ind_order, myimbarco.username, myimbarco.num_tess);
     }
     dashboard.navi_partenza = await NavePersistente.getListaNavi(idapp);
 
@@ -1681,7 +1686,10 @@ UserSchema.statics.calculateStat = async function (idapp, username) {
 UserSchema.statics.getDistinctNationalityQuery = function (idapp) {
   const query = [
     {
-      $match: { idapp }
+      $match: {
+        idapp,
+        $or: [{ deleted: { $exists: false } }, { deleted: { $exists: true, $eq: false } }],
+      }
     },
     {
       $group: { _id: "$profile.nationality", count: { $sum: 1 } }