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

- MyProfile

Browse Source 
- Immagine profilo e small
This commit is contained in:
paoloar77
2022-01-03 21:53:50 +01:00
parent b587b5e0a7
commit 181af3c895
7 changed files with 447 additions and 326 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/server/models/city.js
View File

@@ -93,6 +93,13 @@ CitySchema.statics.getFieldsForSearch = function () {
CitySchema.statics.executeQueryTable = function (idapp, params) { CitySchema.statics.executeQueryTable = function (idapp, params) {
params.fieldsearch = this.getFieldsForSearch(); params.fieldsearch = this.getFieldsForSearch();
const strfind = params.search;
if (strfind === '') {
return [];
}
return tools.executeQueryTable(this, 0, params); return tools.executeQueryTable(this, 0, params);
}; };

54
src/server/models/user.js
View File

@@ -865,7 +865,8 @@ UserSchema.statics.setUserQualified = async function(idapp, username) {
return !!myrec; return !!myrec;
}; };
UserSchema.statics.setVerifiedByAportador = async function(idapp, username, valuebool) { UserSchema.statics.setVerifiedByAportador = async function(
idapp, username, valuebool) {
const User = this; const User = this;
if (username === undefined) if (username === undefined)
@@ -882,13 +883,13 @@ UserSchema.statics.setVerifiedByAportador = async function(idapp, username, valu
return !!myrec; return !!myrec;
}; };
UserSchema.statics.setVerifiedByAportadorToALL = async function () { UserSchema.statics.setVerifiedByAportadorToALL = async function() {
return User.updateMany({}, {$set: {'verified_by_aportador': true}}, {new: false}); return User.updateMany({}, {$set: {'verified_by_aportador': true}},
{new: false});
}; };
UserSchema.statics.setUserQualified_2Invitati = async function( UserSchema.statics.setUserQualified_2Invitati = async function(
idapp, username) { idapp, username) {
const User = this; const User = this;
@@ -1147,6 +1148,51 @@ UserSchema.statics.getUserById = function(idapp, id) {
}); });
}; };
UserSchema.statics.getUserProfileByUsername = async function(idapp, username) {
let perm = tools.Perm.PERM_ALL; //++Todo: sistemare
let whatToShow = {};
if (perm === tools.Perm.PERM_ALL) {
whatToShow = {
lang: 1,
index: 1,
username: 1,
aportador_solidario: 1,
name: 1,
surname: 1,
deleted: 1,
sospeso: 1,
verified_email: 1,
verified_by_aportador: 1,
'profile.nationality': 1,
'profile.biografia': 1,
'profile.teleg_id': 1,
'profile.username_telegram': 1,
'profile.img': 1,
'profile.sex': 1,
'profile.dateofbirth': 1,
'profile.born_city': 1,
'profile.born_province': 1,
'profile.born_country': 1,
email: 1,
date_reg: 1,
img: 1,
};
}
return User.findOne({
idapp, username,
$or: [{deleted: {$exists: false}}, {deleted: {$exists: true, $eq: false}}],
}, whatToShow).then((rec) => {
return (rec._doc);
}).catch((e) => {
return null;
});
};
UserSchema.statics.getAportadorSolidarioByUsername = async function( UserSchema.statics.getAportadorSolidarioByUsername = async function(
idapp, username) { idapp, username) {
const User = this; const User = this;

2
src/server/router/index_router.js
View File

@@ -319,6 +319,8 @@ function getTableByTableName(tablename) {
mytable = Level; mytable = Level;
else if (shared_consts.TablePickup.includes(tablename)) else if (shared_consts.TablePickup.includes(tablename))
mytable = Pickup; mytable = Pickup;
else if (shared_consts.TableCities.includes(tablename))
mytable = City;
return mytable; return mytable;
} }

694
src/server/router/users_router.js
View File

@@ -1,18 +1,18 @@
const express = require('express'); const express = require('express');
const router = express.Router(); const router = express.Router();
const { User } = require('../models/user'); const {User} = require('../models/user');
// const { Nave } = require('../models/nave'); // const { Nave } = require('../models/nave');
const Hours = require('../models/hours'); const Hours = require('../models/hours');
//const { NavePersistente } = require('../models/navepersistente'); //const { NavePersistente } = require('../models/navepersistente');
//const { ListaIngresso } = require('../models/listaingresso'); //const { ListaIngresso } = require('../models/listaingresso');
//const { Graduatoria } = require('../models/graduatoria'); //const { Graduatoria } = require('../models/graduatoria');
// const { ExtraList } = require('../models/extralist'); // const { ExtraList } = require('../models/extralist');
const { ObjectID } = require('mongodb'); const {ObjectID} = require('mongodb');
const sendemail = require('../sendemail'); const sendemail = require('../sendemail');
const { Settings } = require('../models/settings'); const {Settings} = require('../models/settings');
const tools = require('../tools/general'); const tools = require('../tools/general');
const shared_consts = require('../tools/shared_nodejs'); const shared_consts = require('../tools/shared_nodejs');
@@ -25,25 +25,23 @@ const _ = require('lodash');
const reg = require('../reg/registration'); const reg = require('../reg/registration');
const { authenticate } = require('../middleware/authenticate'); const {authenticate} = require('../middleware/authenticate');
const Cart = require('../models/cart'); const Cart = require('../models/cart');
const CartClass = require('../modules/Cart') const CartClass = require('../modules/Cart');
const Product = require('../models/product') const Product = require('../models/product');
const Variant = require('../models/variant') const Variant = require('../models/variant');
const TypedError = require('../modules/ErrorHandler') const TypedError = require('../modules/ErrorHandler');
const mongoose = require('mongoose').set('debug', false) const mongoose = require('mongoose').set('debug', false);
const Subscription = mongoose.model('subscribers'); const Subscription = mongoose.model('subscribers');
function existSubScribe(userId, access, browser) { function existSubScribe(userId, access, browser) {
return Subscription.findOne({ userId, access, browser }) return Subscription.findOne({userId, access, browser}).then(itemsub => {
.then(itemsub => { return itemsub;
return itemsub }).catch(err => {
}) return null;
.catch(err => { });
return null
})
} }
@@ -53,8 +51,9 @@ function getMobileComplete(user) {
// str = str.replace(/.+/g, ''); // str = str.replace(/.+/g, '');
// str = str.replace(/-+/g, ''); // str = str.replace(/-+/g, '');
return str return str;
} }
router.post('/test1', async (req, res) => { router.post('/test1', async (req, res) => {
const user = await User.findOne({ const user = await User.findOne({
@@ -65,13 +64,22 @@ router.post('/test1', async (req, res) => {
await sendemail.sendEmail_Registration(user.lang, user.email, user, await sendemail.sendEmail_Registration(user.lang, user.email, user,
user.idapp, user.linkreg); user.idapp, user.linkreg);
});
})
// POST /users // POST /users
router.post('/', async (req, res) => { router.post('/', async (req, res) => {
tools.mylog("POST /users"); tools.mylog('POST /users');
const body = _.pick(req.body, ['email', 'password', 'username', 'name', 'surname', 'idapp', 'keyappid', 'lang', 'profile', 'aportador_solidario']); const body = _.pick(req.body, [
'email',
'password',
'username',
'name',
'surname',
'idapp',
'keyappid',
'lang',
'profile',
'aportador_solidario']);
body.email = body.email.toLowerCase(); body.email = body.email.toLowerCase();
const user = new User(body); const user = new User(body);
@@ -79,19 +87,21 @@ router.post('/', async (req, res) => {
// tools.mylog("LANG PASSATO = " + user.lang, "IDAPP", user.idapp); // tools.mylog("LANG PASSATO = " + user.lang, "IDAPP", user.idapp);
if (!tools.isAlphaNumeric(body.username) || body.email.length < 6 || body.username.length < 6 || body.password.length < 6) { if (!tools.isAlphaNumeric(body.username) || body.email.length < 6 ||
body.username.length < 6 || body.password.length < 6) {
await tools.snooze(5000); await tools.snooze(5000);
res.status(400).send({ code: server_constants.RIS_CODE_USERNAME_NOT_VALID, msg: '' }); res.status(400).
send({code: server_constants.RIS_CODE_USERNAME_NOT_VALID, msg: ''});
return 1; return 1;
} }
if (tools.blockwords(body.username) || tools.blockwords(body.name) || tools.blockwords(body.surname)) { if (tools.blockwords(body.username) || tools.blockwords(body.name) ||
tools.blockwords(body.surname)) {
// tools.writeIPToBan(user.ipaddr + ': [' + user.username + '] ' + user.name + ' ' + user.surname); // tools.writeIPToBan(user.ipaddr + ': [' + user.username + '] ' + user.name + ' ' + user.surname);
await tools.snooze(5000); await tools.snooze(5000);
return res.status(404).send(); return res.status(404).send();
} }
user.linkreg = reg.getlinkregByEmail(body.idapp, body.email, body.username); user.linkreg = reg.getlinkregByEmail(body.idapp, body.email, body.username);
user.verified_email = false; user.verified_email = false;
user.lasttimeonline = new Date(); user.lasttimeonline = new Date();
@@ -104,15 +114,18 @@ router.post('/', async (req, res) => {
// Controlla se anche l'ultimo record era dallo stesso IP: // Controlla se anche l'ultimo record era dallo stesso IP:
const lastrec = await User.getLastRec(body.idapp); const lastrec = await User.getLastRec(body.idapp);
if (!!lastrec) { if (!!lastrec) {
if (process.env.LOCALE !== "1") { if (process.env.LOCALE !== '1') {
if (lastrec.ipaddr === user.ipaddr) { if (lastrec.ipaddr === user.ipaddr) {
// Se l'ha fatto troppo ravvicinato // Se l'ha fatto troppo ravvicinato
if (lastrec.date_reg) { if (lastrec.date_reg) {
let ris = tools.isdiffSecDateLess(lastrec.date_reg, 120); let ris = tools.isdiffSecDateLess(lastrec.date_reg, 120);
if (ris) { if (ris) {
tools.writeIPToBan(user.ipaddr + ': [' + user.username + '] ' + user.name + ' ' + user.surname); tools.writeIPToBan(
user.ipaddr + ': [' + user.username + '] ' + user.name + ' ' +
user.surname);
await tools.snooze(10000); await tools.snooze(10000);
res.status(400).send({ code: server_constants.RIS_CODE_BANIP, msg: '' }); res.status(400).
send({code: server_constants.RIS_CODE_BANIP, msg: ''});
return 1; return 1;
} }
} }
@@ -133,37 +146,48 @@ router.post('/', async (req, res) => {
let exit; let exit;
// Check if already esist email or username // Check if already esist email or username
exit = await User.findByUsername(user.idapp, user.username).then((useralreadyexist) => { exit = await User.findByUsername(user.idapp, user.username).
if (useralreadyexist) { then((useralreadyexist) => {
res.status(400).send({ code: server_constants.RIS_CODE_USERNAME_ALREADY_EXIST, msg: '' }); if (useralreadyexist) {
return 1; res.status(400).
} send({
code: server_constants.RIS_CODE_USERNAME_ALREADY_EXIST,
msg: '',
});
return 1;
}
}); });
if (exit === 1) if (exit === 1)
return; return;
exit = await User.findByEmail(user.idapp, user.email) exit = await User.findByEmail(user.idapp, user.email).
.then((useralreadyexist) => { then((useralreadyexist) => {
if (useralreadyexist) { if (useralreadyexist) {
res.status(400).send({ code: server_constants.RIS_CODE_EMAIL_ALREADY_EXIST, msg: '' }); res.status(400).
return 1; send({
} code: server_constants.RIS_CODE_EMAIL_ALREADY_EXIST,
msg: '',
});
return 1;
}
}); });
if (exit === 1) if (exit === 1)
return; return;
let recuser = null; let recuser = null;
recuser = await User.findByCellAndNameSurname(user.idapp, user.profile.cell, user.name, user.surname); recuser = await User.findByCellAndNameSurname(user.idapp, user.profile.cell,
user.name, user.surname);
if (recuser) { if (recuser) {
console.log('UTENTE GIA ESISTENTE:\n'); console.log('UTENTE GIA ESISTENTE:\n');
console.log(user); console.log(user);
// User already registered! // User already registered!
res.status(400).send({ code: server_constants.RIS_CODE_USER_ALREADY_EXIST, msg: '' }); res.status(400).
send({code: server_constants.RIS_CODE_USER_ALREADY_EXIST, msg: ''});
return 1; return 1;
} }
@@ -190,8 +214,8 @@ router.post('/', async (req, res) => {
return 1; return 1;
}*/ }*/
let already_registered = (recextra || user.aportador_solidario === tools.APORTADOR_NONE) && (user.idapp === tools.AYNI); let already_registered = (recextra || user.aportador_solidario ===
tools.APORTADOR_NONE) && (user.idapp === tools.AYNI);
// Check if is an other people aportador_solidario // Check if is an other people aportador_solidario
@@ -207,10 +231,9 @@ router.post('/', async (req, res) => {
return 1; return 1;
} */ } */
return user.save() return user.save().then(async () => {
.then(async () => { return User.findByUsername(user.idapp, user.username, false).
return User.findByUsername(user.idapp, user.username, false) then((usertrovato) => {
.then((usertrovato) => {
// tools.mylog("TROVATO USERNAME ? ", user.username, usertrovato); // tools.mylog("TROVATO USERNAME ? ", user.username, usertrovato);
if (usertrovato !== null) { if (usertrovato !== null) {
@@ -219,8 +242,8 @@ router.post('/', async (req, res) => {
res.status(400).send(); res.status(400).send();
return 0; return 0;
} }
}) }).
.then(async (token) => { then(async (token) => {
// tools.mylog("passo il TOKEN: ", token); // tools.mylog("passo il TOKEN: ", token);
if (recextra) { if (recextra) {
@@ -231,23 +254,24 @@ router.post('/', async (req, res) => {
// await User.fixUsername(user.idapp, user.ind_order, user.username); // await User.fixUsername(user.idapp, user.ind_order, user.username);
} }
return token; return token;
}) }).
.then(async (token) => { then(async (token) => {
// tools.mylog("LINKREG = " + user.linkreg); // tools.mylog("LINKREG = " + user.linkreg);
// Invia un'email all'utente // Invia un'email all'utente
// tools.mylog('process.env.TESTING_ON', process.env.TESTING_ON); // tools.mylog('process.env.TESTING_ON', process.env.TESTING_ON);
console.log('res.locale', res.locale); console.log('res.locale', res.locale);
// if (!tools.testing()) { // if (!tools.testing()) {
await sendemail.sendEmail_Registration(user.lang, user.email, user, user.idapp, user.linkreg); await sendemail.sendEmail_Registration(user.lang, user.email, user,
user.idapp, user.linkreg);
// } // }
res.header('x-auth', token).send(user); res.header('x-auth', token).send(user);
return true; return true;
}); });
}).catch((e) => { }).catch((e) => {
console.error(e.message); console.error(e.message);
res.status(400).send(e); res.status(400).send(e);
}) });
}); });
router.get('/:idapp/:username', async (req, res) => { router.get('/:idapp/:username', async (req, res) => {
@@ -277,26 +301,43 @@ router.patch('/:id', authenticate, (req, res) => {
if (!User.isAdmin(req.user.perm)) { if (!User.isAdmin(req.user.perm)) {
// If without permissions, exit // If without permissions, exit
return res.status(404).send({ code: server_constants.RIS_CODE_ERR_UNAUTHORIZED, msg: '' }); return res.status(404).
send({code: server_constants.RIS_CODE_ERR_UNAUTHORIZED, msg: ''});
} }
User.findByIdAndUpdate(id, { $set: body }).then((user) => { User.findByIdAndUpdate(id, {$set: body}).then((user) => {
tools.mylogshow(' USER TO MODIFY: ', user); tools.mylogshow(' USER TO MODIFY: ', user);
if (!user) { if (!user) {
return res.status(404).send(); return res.status(404).send();
} else { } else {
res.send({ code: server_constants.RIS_CODE_OK, msg: '' }); res.send({code: server_constants.RIS_CODE_OK, msg: ''});
} }
}).catch((e) => { }).catch((e) => {
tools.mylogserr('Error patch USER: ', e); tools.mylogserr('Error patch USER: ', e);
res.status(400).send(); res.status(400).send();
}) });
}); });
router.post('/profile', (req, res) => {
const username = req.body['username'];
idapp = req.body.idapp;
locale = req.body.locale;
//++Todo: controlla che tipo di dati ha il permesso di leggere
return User.getUserProfileByUsername(idapp, username).then((ris) => {
res.send(ris);
}).catch((e) => {
tools.mylog('ERRORE IN Profile: ' + e.message);
res.status(400).send();
});
});
router.post('/login', (req, res) => { router.post('/login', (req, res) => {
var body = _.pick(req.body, ['username', 'password', 'idapp', 'keyappid', 'lang']); var body = _.pick(req.body,
['username', 'password', 'idapp', 'keyappid', 'lang']);
var user = new User(body); var user = new User(body);
// const subs = _.pick(req.body, ['subs']); // const subs = _.pick(req.body, ['subs']);
@@ -309,57 +350,70 @@ router.post('/login', (req, res) => {
let resalreadysent = false; let resalreadysent = false;
User.findByCredentials(user.idapp, user.username, user.password) User.findByCredentials(user.idapp, user.username, user.password).
.then(async (user) => { then(async (user) => {
// tools.mylog("CREDENZIALI ! "); // tools.mylog("CREDENZIALI ! ");
if (!user) { if (!user) {
await tools.snooze(3000); await tools.snooze(3000);
const msg = "Tentativo di Login ERRATO [" + body.username + ' , ' + body.password + ']\n' + '[IP: ' + tools.getiPAddressUser(req) + ']'; const msg = 'Tentativo di Login ERRATO [' + body.username + ' , ' +
tools.mylogshow(msg); body.password + ']\n' + '[IP: ' + tools.getiPAddressUser(req) +
// telegrambot.sendMsgTelegramToTheManagers(body.idapp, msg); ']';
res.status(404).send({ code: server_constants.RIS_CODE_LOGIN_ERR }); tools.mylogshow(msg);
} else if (!!user.subaccount && user.subaccount) { // telegrambot.sendMsgTelegramToTheManagers(body.idapp, msg);
await tools.snooze(1000); res.status(404).send({code: server_constants.RIS_CODE_LOGIN_ERR});
// const msg = "Tentativo di Login ERRATO [" + body.username + ' , ' + body.password + ']\n' + '[IP: ' + tools.getiPAddressUser(req) + ']'; } else if (!!user.subaccount && user.subaccount) {
// tools.mylogshow(msg); await tools.snooze(1000);
// telegrambot.sendMsgTelegramToTheManagers(body.idapp, msg); // const msg = "Tentativo di Login ERRATO [" + body.username + ' , ' + body.password + ']\n' + '[IP: ' + tools.getiPAddressUser(req) + ']';
res.status(404).send({ code: server_constants.RIS_CODE_LOGIN_ERR_SUBACCOUNT }); // tools.mylogshow(msg);
return null; // telegrambot.sendMsgTelegramToTheManagers(body.idapp, msg);
} res.status(404).
return user send({code: server_constants.RIS_CODE_LOGIN_ERR_SUBACCOUNT});
}) return null;
.then(user => { }
if (user) { return user;
return user.generateAuthToken(req).then((token) => { }).
var usertosend = new User(); then(user => {
if (user) {
return user.generateAuthToken(req).then((token) => {
var usertosend = new User();
shared_consts.fieldsUserToChange().forEach((field) => { shared_consts.fieldsUserToChange().forEach((field) => {
usertosend[field] = user[field] usertosend[field] = user[field];
}); });
// usertosend._id = user._id.toHexString(); // usertosend._id = user._id.toHexString();
// if (!User.isAdmin(req.user)) { // if (!User.isAdmin(req.user)) {
// usertosend.ipaddr = user.ipaddr; // usertosend.ipaddr = user.ipaddr;
// } // }
// tools.mylog("user.verified_email:" + user.verified_email); // tools.mylog("user.verified_email:" + user.verified_email);
// tools.mylog("usertosend.userId", usertosend.userId); // tools.mylog("usertosend.userId", usertosend.userId);
return { usertosend, token } return {usertosend, token};
}) }).then((myris) => {
.then((myris) => {
const access = 'auth'; const access = 'auth';
const browser = req.get('User-Agent'); const browser = req.get('User-Agent');
// Check if already exist Subscribe // Check if already exist Subscribe
return existSubScribe(myris.usertosend._id, access, browser).then(subscribe => { return existSubScribe(myris.usertosend._id, access, browser).
return (subscribe !== null) then(subscribe => {
}).then(subsExistonDb => { return (subscribe !== null);
return { usertosend: myris.usertosend, token: myris.token, subsExistonDb } }).
}).catch(err => { then(subsExistonDb => {
return { usertosend: myris.usertosend, token: myris.token, subsExistonDb: false } return {
}) usertosend: myris.usertosend,
token: myris.token,
subsExistonDb,
};
}).
catch(err => {
return {
usertosend: myris.usertosend,
token: myris.token,
subsExistonDb: false,
};
});
}).then(myris => { }).then(myris => {
// console.log('res', myris.token, myris.usertosend); // console.log('res', myris.token, myris.usertosend);
@@ -367,20 +421,21 @@ router.post('/login', (req, res) => {
res.header('x-auth', myris.token).send({ res.header('x-auth', myris.token).send({
usertosend: myris.usertosend, usertosend: myris.usertosend,
code: server_constants.RIS_CODE_OK, code: server_constants.RIS_CODE_OK,
subsExistonDb: myris.subsExistonDb subsExistonDb: myris.subsExistonDb,
}); });
// tools.mylog("TROVATOOO!"); // tools.mylog("TROVATOOO!");
// tools.mylog('FINE LOGIN') // tools.mylog('FINE LOGIN')
}); });
} }
}) }).
.catch((e) => { catch((e) => {
tools.mylog("ERRORE IN LOGIN: " + e.message); tools.mylog('ERRORE IN LOGIN: ' + e.message);
if (!resalreadysent) if (!resalreadysent)
res.status(400).send({ code: server_constants.RIS_CODE_LOGIN_ERR_GENERIC }); res.status(400).
}); send({code: server_constants.RIS_CODE_LOGIN_ERR_GENERIC});
});
}); });
router.delete('/me/token', authenticate, (req, res) => { router.delete('/me/token', authenticate, (req, res) => {
@@ -394,7 +449,7 @@ router.delete('/me/token', authenticate, (req, res) => {
router.post('/setperm', authenticate, (req, res) => { router.post('/setperm', authenticate, (req, res) => {
const body = _.pick(req.body, ['idapp', 'username', 'perm']); const body = _.pick(req.body, ['idapp', 'username', 'perm']);
tools.mylog("SETPERM = " + req.token); tools.mylog('SETPERM = ' + req.token);
User.setPermissionsById(res.user._id, body).then(() => { User.setPermissionsById(res.user._id, body).then(() => {
res.status(200).send(); res.status(200).send();
@@ -425,183 +480,183 @@ async function eseguiDbOp(idapp, mydata, locale) {
if (mydata.dbop === '') { if (mydata.dbop === '') {
// } else if (mydata.dbop === 'rigeneraTutto') { // } else if (mydata.dbop === 'rigeneraTutto') {
// await ListaIngresso.Esegui_CronTab(idapp, mydata); // await ListaIngresso.Esegui_CronTab(idapp, mydata);
} else if (mydata.dbop === 'visuStat') { } else if (mydata.dbop === 'visuStat') {
ris = await User.visuUtentiNonInNavi(idapp); ris = await User.visuUtentiNonInNavi(idapp);
//} else if (mydata.dbop === 'creaNavi') { //} else if (mydata.dbop === 'creaNavi') {
// const num = await Nave.generaNave(idapp, mydata, false); // const num = await Nave.generaNave(idapp, mydata, false);
// ris = { num }; // ris = { num };
//} else if (mydata.dbop === 'CreaNaviPersistenti') { //} else if (mydata.dbop === 'CreaNaviPersistenti') {
// const num = await Nave.generaNave(idapp, mydata, true); // const num = await Nave.generaNave(idapp, mydata, true);
// ris = { num }; // ris = { num };
/*} else if (mydata.dbop === 'delNavi') { /*} else if (mydata.dbop === 'delNavi') {
await Nave.setRiga(idapp, 1); await Nave.setRiga(idapp, 1);
await Nave.setCol(idapp, 1); await Nave.setCol(idapp, 1);
const num = await Nave.deleteOne({ idapp }); const num = await Nave.deleteOne({ idapp });
ris = { num }; ris = { num };
// } else if (mydata.dbop === 'delNaviNoStarted') { // } else if (mydata.dbop === 'delNaviNoStarted') {
// await Nave.setRiga(idapp, 1); // await Nave.setRiga(idapp, 1);
// await Nave.setCol(idapp, 1); // await Nave.setCol(idapp, 1);
// const num = await Nave.remove({ idapp, date_start: { $gte: tools.IncDateNow(-1000 * 60 * 60 * 24 * 3) } }); // const num = await Nave.remove({ idapp, date_start: { $gte: tools.IncDateNow(-1000 * 60 * 60 * 24 * 3) } });
// ris = { num }; // ris = { num };
} else if (mydata.dbop === 'delNaviProvvisorie') { } else if (mydata.dbop === 'delNaviProvvisorie') {
ris = await Nave.delNaviProvvisorie(idapp); ris = await Nave.delNaviProvvisorie(idapp);
} else if (mydata.dbop === 'visuListaNave') { } else if (mydata.dbop === 'visuListaNave') {
mystr = await Nave.showListaOrd(idapp); mystr = await Nave.showListaOrd(idapp);
ris = { mystr }; ris = { mystr };
} else if (mydata.dbop === 'pulisciNonPresenzeInNave') { } else if (mydata.dbop === 'pulisciNonPresenzeInNave') {
mystr = await Nave.pulisciNonPresenzeInNave(idapp); mystr = await Nave.pulisciNonPresenzeInNave(idapp);
ris = { mystr }; ris = { mystr };
} else if (mydata.dbop === 'checkInserimentiUtentiInNave') { } else if (mydata.dbop === 'checkInserimentiUtentiInNave') {
mystr = await Nave.checkIfDevoAggiungereInNave(idapp); mystr = await Nave.checkIfDevoAggiungereInNave(idapp);
ris = { mystr }; ris = { mystr };
} else if (mydata.dbop === 'visuListaIngresso') { } else if (mydata.dbop === 'visuListaIngresso') {
mystr = await ListaIngresso.showListaOrd(idapp, false); mystr = await ListaIngresso.showListaOrd(idapp, false);
ris = { mystr }; ris = { mystr };
} else if (mydata.dbop === 'visuListaIngressoNuovi') { } else if (mydata.dbop === 'visuListaIngressoNuovi') {
mystr = await ListaIngresso.showListaOrd(idapp, true); mystr = await ListaIngresso.showListaOrd(idapp, true);
ris = { mystr }; ris = { mystr };
} else if (mydata.dbop === 'GeneraGraduatoria') { } else if (mydata.dbop === 'GeneraGraduatoria') {
mystr = await ListaIngresso.GeneraGraduatoria(idapp, true); mystr = await ListaIngresso.GeneraGraduatoria(idapp, true);
ris = { mystr }; ris = { mystr };
} else if (mydata.dbop === 'AggiornaIndiceGraduatoria') { } else if (mydata.dbop === 'AggiornaIndiceGraduatoria') {
mystr = await Graduatoria.AggiornaIndiceGraduatoria(idapp); mystr = await Graduatoria.AggiornaIndiceGraduatoria(idapp);
ris = { mystr }; ris = { mystr };
} else if (mydata.dbop === 'visuNaviUtentiEliminati') { } else if (mydata.dbop === 'visuNaviUtentiEliminati') {
ris = await Nave.visuNaviUtentiEliminati(idapp); ris = await Nave.visuNaviUtentiEliminati(idapp);
} else if (mydata.dbop === 'convSubAccount') { } else if (mydata.dbop === 'convSubAccount') {
ris = await User.convSubAccount(idapp); ris = await User.convSubAccount(idapp);
} else if (mydata.dbop === 'flagUtentiNaviNonPresenti') { } else if (mydata.dbop === 'flagUtentiNaviNonPresenti') {
ris = await User.flagUtentiNaviNonPresenti(idapp); ris = await User.flagUtentiNaviNonPresenti(idapp);
} else if (mydata.dbop === 'generaFlotte') { } else if (mydata.dbop === 'generaFlotte') {
ris = await NavePersistente.generaFlotte(idapp); ris = await NavePersistente.generaFlotte(idapp);
} else if (mydata.dbop === 'mettiSognoePaypal') { } else if (mydata.dbop === 'mettiSognoePaypal') {
ris = await User.mettiSognoePaypal(idapp, true); ris = await User.mettiSognoePaypal(idapp, true);
} else if (mydata.dbop === 'mettiSognoePaypalView') { } else if (mydata.dbop === 'mettiSognoePaypalView') {
ris = await User.mettiSognoePaypal(idapp, false); ris = await User.mettiSognoePaypal(idapp, false);
} else if (mydata.dbop === 'addNavePerUtentiNaviNonPresenti') { } else if (mydata.dbop === 'addNavePerUtentiNaviNonPresenti') {
ris = await User.addNavePerUtentiNaviNonPresenti(idapp); ris = await User.addNavePerUtentiNaviNonPresenti(idapp);
} else if (mydata.dbop === 'creaTessituraeConv') { } else if (mydata.dbop === 'creaTessituraeConv') {
ris = await ListaIngresso.creaTessituraeConv(idapp); ris = await ListaIngresso.creaTessituraeConv(idapp);
ris = { mystr }; ris = { mystr };
} else if (mydata.dbop === 'eliminaListeIngressoNascoste') { } else if (mydata.dbop === 'eliminaListeIngressoNascoste') {
ris = await ListaIngresso.eliminaListeIngressoNascoste(idapp); ris = await ListaIngresso.eliminaListeIngressoNascoste(idapp);
ris = { mystr }; ris = { mystr };
} else if (mydata.dbop === 'RendiVisibileIrecordNascosti') { } else if (mydata.dbop === 'RendiVisibileIrecordNascosti') {
ris = await ListaIngresso.RendiVisibileIrecordNascosti(idapp); ris = await ListaIngresso.RendiVisibileIrecordNascosti(idapp);
ris = { mystr }; ris = { mystr };
} else if (mydata.dbop === 'convNaviTessinListaIngressoRec') { } else if (mydata.dbop === 'convNaviTessinListaIngressoRec') {
let num = 0; let num = 0;
const arrnavitess = await Nave.find({ idapp, num_tess: { $gte: 3 } }); const arrnavitess = await Nave.find({ idapp, num_tess: { $gte: 3 } });
for (const recnave of arrnavitess) { for (const recnave of arrnavitess) {
if (recnave.num_tess === 3 || recnave.num_tess === 5 || recnave.num_tess === 7) { if (recnave.num_tess === 3 || recnave.num_tess === 5 || recnave.num_tess === 7) {
const ind_order = recnave.ind_order; const ind_order = recnave.ind_order;
// Prima controlla se ho già 2 record dello stesso ind_order, allora non lo faccio: // Prima controlla se ho già 2 record dello stesso ind_order, allora non lo faccio:
const arringr = await ListaIngresso.find({ idapp, ind_order }); const arringr = await ListaIngresso.find({ idapp, ind_order });
let dafare = true; let dafare = true;
if (arringr.length > 0) { if (arringr.length > 0) {
const arringrtest = await ListaIngresso.find({ idapp, ind_order }).distinct('num_tess'); const arringrtest = await ListaIngresso.find({ idapp, ind_order }).distinct('num_tess');
if (arringr.length !== arringrtest.length) { if (arringr.length !== arringrtest.length) {
dafare = false; // Ci sono 2 o piu record! pertanto probabilmente l'ho già fatto! dafare = false; // Ci sono 2 o piu record! pertanto probabilmente l'ho già fatto!
}
}
if (dafare) {
// const user = await User.findByOldOrder(idapp, ind_order);
const user = await User.findByIndOrder(idapp, ind_order);
if (!!user) {
//let note = recnave.num_tess;
// Crea record ListaIngresso
const newrecingr = await ListaIngresso.addUserInListaIngresso(idapp, user.username, user.username, user.lang, false, true, recnave.created, '', true);
const fieldsvalue = {
ind_order: newrecingr.ind_order,
num_tess: 1,
};
// Aggiorna la nave con l'Ind_order nuovo e il num_tess a 1
await Nave.findOneAndUpdate({ _id: recnave._id }, { $set: fieldsvalue }, { new: false });
num++;
}
} }
} }
if (dafare) { }
// const user = await User.findByOldOrder(idapp, ind_order);
const user = await User.findByIndOrder(idapp, ind_order);
if (!!user) {
//let note = recnave.num_tess;
// Crea record ListaIngresso
const newrecingr = await ListaIngresso.addUserInListaIngresso(idapp, user.username, user.username, user.lang, false, true, recnave.created, '', true);
const fieldsvalue = { const arrnavitess2 = await Nave.find({ idapp, num_tess: 2 });
ind_order: newrecingr.ind_order,
num_tess: 1,
};
// Aggiorna la nave con l'Ind_order nuovo e il num_tess a 1 for (const recnave of arrnavitess2) {
await Nave.findOneAndUpdate({ _id: recnave._id }, { $set: fieldsvalue }, { new: false });
}
ris = { num };
} else if (mydata.dbop === 'initListaIngresso') {
// const aaa = await User.updateMany({ idapp }, { $set: { 'profile.nationality': 'IT' } });
const num = await ListaIngresso.updateMany({ idapp }, { $set: { added: false } });
ris = { num };
} else if (mydata.dbop === 'ImpostaATuttiPaypal') {
const listautenti = await User.find({ idapp });
let num = 0;
for (let rec of listautenti) {
if (!rec._doc.profile.paymenttypes.includes('paypal')) {
rec._doc.profile.paymenttypes = [...rec._doc.profile.paymenttypes, 'paypal'];
const user = await User.findOneAndUpdate({ _id: rec._id }, { $set: { 'profile.paymenttypes': rec._doc.profile.paymenttypes } });
// await rec.save();
num++;
}
// const num = await User.f({ idapp }, { $set: { 'profile: false } });
}
ris = { num };
} else if (mydata.dbop === 'numtessUno') {
const listanavi = await ListaIngresso.find({ idapp });
let num = 0;
for (let rec of listanavi) {
if (!rec._doc.num_tess) {
rec._doc.num_tess = 1;
const risu = await ListaIngresso.findOneAndUpdate({ _id: rec._id }, { $set: { num_tess: rec._doc.num_tess } }, { new: false });
// await rec.save();
if (!!risu)
num++;
}
// const num = await User.f({ idapp }, { $set: { 'profile: false } });
}
ris = { num };
} else if (mydata.dbop === 'Corregginumtess') {
const listanavi = await Nave.find({ idapp });
let num = 0;
for (let rec of listanavi) {
const myarrrec = await Nave.find({ idapp, ind_order: rec.ind_order }).sort({ riga: 1, col: 1 });
let indextess = 1;
for (let ind = 0; ind < myarrrec.length; ind++) {
if (myarrrec[ind].num_tess !== indextess && myarrrec[ind].num_tess === 1) {
myarrrec[ind].num_tess = indextess;
const risu = await Nave.findOneAndUpdate({ _id: myarrrec[ind]._id }, { $set: { num_tess: myarrrec[ind].num_tess } }, { new: false });
num++; num++;
} }
indextess++;
} }
} }
}
ris = { num };
const arrnavitess2 = await Nave.find({ idapp, num_tess: 2 }); */
for (const recnave of arrnavitess2) {
}
ris = { num };
} else if (mydata.dbop === 'initListaIngresso') {
// const aaa = await User.updateMany({ idapp }, { $set: { 'profile.nationality': 'IT' } });
const num = await ListaIngresso.updateMany({ idapp }, { $set: { added: false } });
ris = { num };
} else if (mydata.dbop === 'ImpostaATuttiPaypal') {
const listautenti = await User.find({ idapp });
let num = 0;
for (let rec of listautenti) {
if (!rec._doc.profile.paymenttypes.includes('paypal')) {
rec._doc.profile.paymenttypes = [...rec._doc.profile.paymenttypes, 'paypal'];
const user = await User.findOneAndUpdate({ _id: rec._id }, { $set: { 'profile.paymenttypes': rec._doc.profile.paymenttypes } });
// await rec.save();
num++;
}
// const num = await User.f({ idapp }, { $set: { 'profile: false } });
}
ris = { num };
} else if (mydata.dbop === 'numtessUno') {
const listanavi = await ListaIngresso.find({ idapp });
let num = 0;
for (let rec of listanavi) {
if (!rec._doc.num_tess) {
rec._doc.num_tess = 1;
const risu = await ListaIngresso.findOneAndUpdate({ _id: rec._id }, { $set: { num_tess: rec._doc.num_tess } }, { new: false });
// await rec.save();
if (!!risu)
num++;
}
// const num = await User.f({ idapp }, { $set: { 'profile: false } });
}
ris = { num };
} else if (mydata.dbop === 'Corregginumtess') {
const listanavi = await Nave.find({ idapp });
let num = 0;
for (let rec of listanavi) {
const myarrrec = await Nave.find({ idapp, ind_order: rec.ind_order }).sort({ riga: 1, col: 1 });
let indextess = 1;
for (let ind = 0; ind < myarrrec.length; ind++) {
if (myarrrec[ind].num_tess !== indextess && myarrrec[ind].num_tess === 1) {
myarrrec[ind].num_tess = indextess;
const risu = await Nave.findOneAndUpdate({ _id: myarrrec[ind]._id }, { $set: { num_tess: myarrrec[ind].num_tess } }, { new: false });
num++;
}
indextess++;
}
}
ris = { num };
*/
/* /*
} }
@@ -643,24 +698,25 @@ async function eseguiDbOp(idapp, mydata, locale) {
} }
ris = { num }; */ ris = { num }; */
/*} else if (mydata.dbop === 'CorreggiDataGiftChat') { /*} else if (mydata.dbop === 'CorreggiDataGiftChat') {
const listanavi = await NavePersistente.find({ idapp }); const listanavi = await NavePersistente.find({ idapp });
let num = 0; let num = 0;
for (let rec of listanavi) { for (let rec of listanavi) {
const fieldsvalue = { const fieldsvalue = {
date_gift_chat_open: tools.AddDate(rec.date_start, -7) date_gift_chat_open: tools.AddDate(rec.date_start, -7)
}; };
const risu = await NavePersistente.findOneAndUpdate({ _id: rec._id }, { $set: fieldsvalue }, { new: false }); const risu = await NavePersistente.findOneAndUpdate({ _id: rec._id }, { $set: fieldsvalue }, { new: false });
if (!!risu) { if (!!risu) {
num++; num++;
}
} }
}
ris = { num }; ris = { num };
*/} else if (mydata.dbop === 'creaUtentiTest') { */
} else if (mydata.dbop === 'creaUtentiTest') {
let num = 0; let num = 0;
lastrec = await User.find({ idapp }).sort({ _id: -1 }).limit(1); lastrec = await User.find({idapp}).sort({_id: -1}).limit(1);
let last = 1; let last = 1;
if (lastrec) { if (lastrec) {
last = lastrec[0].index; last = lastrec[0].index;
@@ -674,46 +730,46 @@ async function eseguiDbOp(idapp, mydata, locale) {
myuser._id = new ObjectID(); myuser._id = new ObjectID();
myuser.index = last + ind + 1; myuser.index = last + ind + 1;
myuser.idapp = idapp; myuser.idapp = idapp;
myuser.password = "$2a$12$DEaX1h5saTUVC43f7kubyOAlah1xHDgqQTfSIux0.RFDT9WGbyCaG"; myuser.password = '$2a$12$DEaX1h5saTUVC43f7kubyOAlah1xHDgqQTfSIux0.RFDT9WGbyCaG';
myuser.lang = 'it'; myuser.lang = 'it';
myuser.email = "miaemail@email.it"; myuser.email = 'miaemail@email.it';
myuser.name = 'U' + myuser.index; myuser.name = 'U' + myuser.index;
myuser.surname = 'Ar' + myuser.index; myuser.surname = 'Ar' + myuser.index;
myuser.verified_email = true; myuser.verified_email = true;
myuser.verified_by_aportador = true; myuser.verified_by_aportador = true;
if (myuser.index < 2) if (myuser.index < 2)
myuser.perm = "3"; myuser.perm = '3';
myuser.username = "Userna_" + myuser.name; myuser.username = 'Userna_' + myuser.name;
myuser.profile.special_req = true; myuser.profile.special_req = true;
myuser.profile.nationality = 'IT'; myuser.profile.nationality = 'IT';
await myuser.save(); await myuser.save();
num++; num++;
} }
ris = { num }; ris = {num};
/*} else if (mydata.dbop === 'visuPlacca') { /*} else if (mydata.dbop === 'visuPlacca') {
mystr = '✨✨✨✨✨✨✨✨✨✨✨✨✨✨✨✨✨\n' + mystr = '✨✨✨✨✨✨✨✨✨✨✨✨✨✨✨✨✨\n' +
'NAVI CHE SALPANO DALLA ' + mydata.riga + '.' + mydata.col + ' ALLA ' + mydata.riga + '.' + (parseInt(mydata.col) + 7) + '\n' + 'NAVI CHE SALPANO DALLA ' + mydata.riga + '.' + mydata.col + ' ALLA ' + mydata.riga + '.' + (parseInt(mydata.col) + 7) + '\n' +
'AUGURI ALLA NUOVA SOGNATRICE !!!\n' + 'AUGURI ALLA NUOVA SOGNATRICE !!!\n' +
'✨✨✨✨✨✨✨✨✨✨✨✨✨✨✨✨✨'; '✨✨✨✨✨✨✨✨✨✨✨✨✨✨✨✨✨';
const visu_nave_Bot = await Settings.getValDbSettings(idapp, 'VISU_NAVE_BOT'); const visu_nave_Bot = await Settings.getValDbSettings(idapp, 'VISU_NAVE_BOT');
for (let ind = 0; ind < 8; ind++) { for (let ind = 0; ind < 8; ind++) {
mystr += await Nave.getNavePos(idapp, parseInt(mydata.riga), parseInt(mydata.col) + ind, false); mystr += await Nave.getNavePos(idapp, parseInt(mydata.riga), parseInt(mydata.col) + ind, false);
mystr += tools.ACAPO; mystr += tools.ACAPO;
if (visu_nave_Bot && ind === 3) { if (visu_nave_Bot && ind === 3) {
await telegrambot.sendMsgTelegramToTheAdmin(idapp, mystr, true); await telegrambot.sendMsgTelegramToTheAdmin(idapp, mystr, true);
mystr = ''; mystr = '';
}
} }
}
if (visu_nave_Bot) if (visu_nave_Bot)
await telegrambot.sendMsgTelegramToTheAdmin(idapp, mystr, true); await telegrambot.sendMsgTelegramToTheAdmin(idapp, mystr, true);
ris = { mystr }; ris = { mystr };
*/ */
} else if (mydata.dbop === 'CorreggiTabHours') { } else if (mydata.dbop === 'CorreggiTabHours') {
await Hours.correggiHours(idapp); await Hours.correggiHours(idapp);
@@ -722,34 +778,33 @@ async function eseguiDbOp(idapp, mydata, locale) {
await User.setVerifiedByAportadorToALL(); await User.setVerifiedByAportadorToALL();
/*} else if (mydata.dbop === 'visuNave') { /*} else if (mydata.dbop === 'visuNave') {
mystr = await Nave.getNavePos(idapp, parseInt(mydata.riga), parseInt(mydata.col)); mystr = await Nave.getNavePos(idapp, parseInt(mydata.riga), parseInt(mydata.col));
const visu_nave_Bot = await Settings.getValDbSettings(idapp, 'VISU_NAVE_BOT'); const visu_nave_Bot = await Settings.getValDbSettings(idapp, 'VISU_NAVE_BOT');
if (visu_nave_Bot) if (visu_nave_Bot)
telegrambot.sendMsgTelegramToTheAdmin(idapp, mystr, true); telegrambot.sendMsgTelegramToTheAdmin(idapp, mystr, true);
ris = { mystr }; ris = { mystr };
} else if (mydata.dbop === 'getnavibyuser') { } else if (mydata.dbop === 'getnavibyuser') {
let arrnavi = null; let arrnavi = null;
const user = await User.getUserShortDataByUsername(idapp, mydata.username); const user = await User.getUserShortDataByUsername(idapp, mydata.username);
if (user) { if (user) {
arrnavi = await Nave.getArrPosizioniByUsername(idapp, user.username); arrnavi = await Nave.getArrPosizioniByUsername(idapp, user.username);
for (let mynave of arrnavi) {
mynave._doc.rec = await Nave.getNaveByRigaCol(idapp, mynave.riga, mynave.col);
}
for (let mynave of arrnavi) {
mynave._doc.rec = await Nave.getNaveByRigaCol(idapp, mynave.riga, mynave.col);
} }
} ris = { data: arrnavi };
ris = { data: arrnavi }; */
*/
} }
// console.log('ris', ris); // console.log('ris', ris);
return ris; return ris;
@@ -771,5 +826,4 @@ router.post('/dbop', authenticate, async (req, res) => {
}); });
module.exports = router; module.exports = router;

13
src/server/tools/general.js
View File

@@ -408,6 +408,12 @@ module.exports = {
SEND_MSG_DONO_NON_RICEVUTO: 1050, SEND_MSG_DONO_NON_RICEVUTO: 1050,
}, },
Perm: {
PERM_NONE: 0,
PERM_FRIEND: 1,
PERM_ALL: 10,
},
Placca: { Placca: {
DONATORI: 1, DONATORI: 1,
TUTTI: 2, TUTTI: 2,
@@ -1218,7 +1224,12 @@ module.exports = {
} }
if (params.filtercustom) { if (params.filtercustom) {
filtriadded.push(...params.filtercustom); for (const myfilter of params.filtercustom) {
if (myfilter["userId"]) {
myfilter["userId"] = ObjectID(myfilter["userId"]);
}
filtriadded.push(myfilter);
}
} }
if (params.filtersearch) { if (params.filtersearch) {

2
src/server/tools/server_constants.js
View File

@@ -92,7 +92,7 @@ module.exports = Object.freeze({
LIST_START: null, LIST_START: null,
PREFIX_IMG: 'm_', PREFIX_IMG: 'm_',
PREFIX_IMG_SMALL: 'small_', PREFIX_IMG_SMALL: 'sm_',
Privacy: { Privacy: {
all: 'all', all: 'all',

1
src/server/tools/shared_nodejs.js
View File

@@ -43,6 +43,7 @@ module.exports = {
KEY_TO_CRYPTED: ['PWD_FROM'], KEY_TO_CRYPTED: ['PWD_FROM'],
TablePickup: ['countries', 'phones'], TablePickup: ['countries', 'phones'],
TableCities: ['citta', 'province'],
PaymentTypes: [ PaymentTypes: [
'Nessuno', 'Nessuno',