app2-api/modules/events/events_inscriptions.service.js

/* global Venue */
'use strict';

const _ = require('lodash');
const moment = require('moment');
const { generateService, parseParamsToFindOptions } = require('../../helpers/service.helper');
const models = require('../../core/models');
const marketing = require('../../helpers/mailchimp.helper')
const Sequelize = require('sequelize');
const xlsx = require("node-xlsx");
const fs = require("fs");
const cdnHelper = require('../../helpers/cdn.helper');

moment.locale('es');

function generateNewCodeTicket() {

    let longitud = 8;
    let timestamp = +new Date;

    var _getRandomInt = function (min, max) {
        return Math.floor(Math.random() * (max - min + 1)) + min;
    }

   
    var ts = timestamp.toString();
    var parts = ts.split("").reverse();
    var id = "";

    for (var i = 0; i < longitud; ++i) {
        var index = _getRandomInt(0, longitud - 1);
        id += parts[index];
    }

    return id;
}

const extraMethods = { 

    _getInscriptionById: (id) => {
        return models.EventInscription.scope('includeEventAndVenue').findOne({
            include: { model: models.EventReservation, as: 'reservation', require: false, },            
            where: {
                id: id,
            },
        })
    },

    _getInscriptionByEventAndUser: (eventId, userId) => {
        return models.EventInscription.scope('includeEventAndVenue').findOne({
            where: {
                eventId: eventId,
                userId: userId
            },

        })
    },

    _getInscriptionByEvent: (eventId) => {
        return models.EventInscription.scope('defaultScope').findAll({
            where: {
                eventId: eventId,
            },
        })
    },

    _getInscriptionsUser: (userId) => {
        return models.EventInscription.scope('includeEventAndVenue').findAll({
            attributes: {
                exclude: ['marketing_memberId', 'overflowEventId', 'createdAt', 'updatedAt', 'userId', 'eventId', 'validateUserId']
            },
            where: {
                userId: userId
            },
        })
    },

    _getInscriptionsOfNextEventsUser: (userId) => {
        return models.EventInscription.count({
            include: [{ model: models.Event, 
                        as: 'event', 
                        where: {
                            end_date: {[Sequelize.Op.gte]: moment().utc()},
                        }
                    }],
            where: { userId: userId },
            });
    },

    //Nos devuelve el número de inscripciones confirmadas para ese evento sin tener en cuenta reservas
    _getCountInscriptionsWithoutReservationAndOverflow: (eventId) => {
        return models.EventInscription.count({
                where: {
                    eventId: eventId,
                    reservationId: null,
                    overflowEventId: null
                },
        })
    },

    //Nos devuelve el número de inscripciones realizadas con esa reserva
    _getCountInscriptionsWithReservation: (reservationId) => {
        return models.EventInscription.count({
            where: {
                reservationId: reservationId,
            },
        })
    },

    //Nos devuelve el número de inscripciones realizadas con esa reserva
    _getCountInscriptionsWithOverflowEventId: (overflowEventId) => {
        return models.EventInscription.count({
            where: {
                overflowEventId: overflowEventId,
            },
        })
    },
    
    _updateReservationOfInscription: (id, reservationId) => {
        return models.EventInscription.update ({
                reservationId: reservationId,
                },
                {
                where: { id: id }
                });
    },

    _updateMarketingMemberOfInscription: (id, marketingMemberId) => {
        return models.EventInscription.update({
            marketing_memberId: marketingMemberId,
        },
            {
                where: { id: id }
            });
    },

    _createInscription: (eventId, userId, type, validated, source, reservationId, overflowEventId) => {
        console.log('>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>><<valores de la inscripcion');
        console.log(eventId, userId, type, validated, source, reservationId, overflowEventId);

        return new Promise(function (resolve, reject) {
            models.EventInscription.create({
                eventId: eventId,
                date: moment().utc(),
                userId: userId,
                type: type,
                code_ticket: ('ENT-' + generateNewCodeTicket()),                
                source: source,
                validated: validated,
                reservationId: reservationId,
                overflowEventId: overflowEventId,
            })
                .then(function (result) {
                    resolve(result);
                })
                .catch(function (error) {
                    reject(error)
                });
        });
    },

    _deleteInscription: (id) => {

//habria que poner el idusuario para asegurar que otro usuario no borra una inscripcion de otro

        return models.EventInscription.destroy({
            where: {
                id: id,
            }
        });
    },

    _addMember: (marketingListId, member) => {

//        console.log('aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaasddddddmemberrrrr1');
//        console.log(member);

        return new Promise(function (resolve, reject) {
            if (!marketingListId) { // || !member.validated) {
            resolve(member)
        } else {
                marketing.addMember(marketingListId, member)
                .then(function (result) {
                    resolve(result.ID);
                })
                .catch(function (error) {
                    reject(error)
                });
            }
        }); 
    },


    _deleteMember: (marketingListId, marketingMemberId) => {
console.log('Elimino miembro de la lista de milchimp>>>>>>>>>>>>>>>>>>>>>>>>>>>>><<', marketingListId, marketingMemberId);        
        
        return new Promise(function (resolve, reject) {
            if ((!marketingListId) || (!marketingMemberId)) {
                resolve();
            } else {
                resolve(marketing.deleteMember(marketingListId, marketingMemberId))
            }       
        });
    },
   
    _getInscriptionsExcel: (user, eventId, callback) => {
        models.EventInscription.findAll({
            where: {
                eventId: eventId,
                type: 'regular'
            },
            include: [{
                model: models.Event,
                as: 'event',
                attributes: ['id', 'name'],
            }],
            order:[
//                [{ model: models.Entity }, 'name', 'ASC'],  
//                [{ model: models.User },'name', 'ASC'],  
            ],

        }).then(function (inscriptions) {
            if (inscriptions.length) {
                var data = [];

                data.push(["Centro educativo", "Número de entrada", "Nombre", "Apellidos", "Email", "Válido"]);

                for (var c = 0; c < inscriptions.length; c++) {
                    var inscription = inscriptions[c];
                    console.log(inscription);

                    var code = inscription.code_ticket;
                    var name = inscription.user.name;
                    var surname = inscription.user.surname ? inscription.user.surname : "";
                    var email = inscription.user.email;
                    var college = inscription.user.entityId ? inscription.user.entity : "";
                    var valid = inscription.validated ? "Válido" : "No válido";

                    data.push([college, code, name, surname, email, valid]);
                }

                var buffer = xlsx.build([{
                    name: inscriptions[0].event.name,
                    data: data
                }]);

                var fileName = cdnHelper.sanitizeFilename(inscriptions[0].event.name + "-inscripciones.xlsx");
                var xlsxPath = cdnHelper.getCDNPath('xlsx') + fileName;
                var wstream = fs.createWriteStream(xlsxPath);
                wstream.write(buffer);
                wstream.end();

                wstream.on("close", function () {
                    return callback({
                        messenger: {
                            success: true,
                            message: 'Ok',
                            code: 'S99001'
                        },
                        data: {
                            path: xlsxPath,
                            name: fileName
                        }
                    }, 200);
                });
            } else {
                return callback({
                    messenger: {
                        success: true,
                        message: 'Ok',
                        code: 'S99002'
                    }
                }, 200);
            }
        }).catch(function (error) {
            console.log(error);
            return callback({
                messenger: {
                    success: false,
                    message: 'Database error getting inscription.',
                    code: 'E01004'
                }
            }, 500);
        });
    },

};

module.exports = generateService(models.EventInscription, extraMethods);