114 lines
4.4 KiB
JavaScript
Executable File
114 lines
4.4 KiB
JavaScript
Executable File
const fs = require( 'fs-extra' );
|
|
const glob = require( 'glob' );
|
|
const moment = require( 'moment' );
|
|
const axios = require( 'axios' );
|
|
|
|
const conf=require('../../nationchains/tribes/conf.json')
|
|
|
|
/*
|
|
Model that will process actions plan for each client like sending email campain, or anything that
|
|
are plan in /tribes/tribeid/actions/todo
|
|
*/
|
|
const Cards = {}; //require('../../models/Cards');
|
|
const Contracts = {};
|
|
/*
|
|
Send if envoicampain a liste of email in param.msg.destperso with param.headers
|
|
if not envoicampain, it just return a test about what to send
|
|
@param = {headers, msg:{destperso}}
|
|
*/
|
|
Contracts.sendcampain = async ( param, envoicampain ) => {
|
|
if( envoicampain ) {
|
|
// Carefull w the action post outputs/msg just wait the feedback of the 1st message
|
|
const retcampain = await axios.post( 'https://mail.maildigit.fr/outputs/msg', param.msg, {
|
|
headers: param.headers
|
|
} );
|
|
if( retcampain.status !== 200 ) {
|
|
console.log( "err", retcampain.payload.moreinfo );
|
|
fs.appendFileSync( `${conf.tribes}/log_erreurglobal.txt`, moment( new Date() )
|
|
.format( 'YYYYMMDD HH:mm:ss' ) + ' - IMPOSSIBLE TO SEND CAMPAIN TODO for :' + param.tribeid + ' -- ' + retcampain.payload.moreinfo + '\n', 'utf-8' );
|
|
};
|
|
return retcampain;
|
|
} else {
|
|
// permet de tester ce qu'il y a à envoyer
|
|
let premieremail = "";
|
|
for( let i = 0; i < param.msg.destperso.length; i++ ) {
|
|
premieremail += param.msg.destperso[ 0 ].email + ",";
|
|
}
|
|
return {
|
|
status: 201,
|
|
payload: {
|
|
info: [ 'simplecomptage' ],
|
|
model: 'Contracts',
|
|
moreinfo: "#email: " + param.msg.destperso.length + " - 5 1st emails: " + premieremail
|
|
}
|
|
};
|
|
}
|
|
}
|
|
Contracts.initActiontodo = async ( envoie ) => {
|
|
const datedeb = moment( new Date() )
|
|
.format( 'YYYYMMDD HH:mm:ss' );
|
|
let todo, actiondone;
|
|
let log = {
|
|
nbaction: 0,
|
|
nbactionexec: 0,
|
|
nbactionerr: 0,
|
|
actionlist: ""
|
|
};
|
|
const listclient = fs.readJsonSync( `${conf.tribes}/tribeids.json` );
|
|
for( let clid in listclient ) {
|
|
console.log( listclient[ clid ] );
|
|
let listaction = glob.sync( `${conf.tribes}/${listclient[clid]}/actions/todo/*.json` );
|
|
for( let action in listaction ) {
|
|
console.log( listaction[ action ] )
|
|
log.nbaction++;
|
|
todo = fs.readJsonSync( listaction[ action ] );
|
|
let passdate = true;
|
|
// currentdate doit etre après la startDate si existe et avant valideuntilDate si existe
|
|
// console.log('test now est avant date start ', moment() < moment(todo.startDate, 'YYYYMMDD HH:mm:ss').toDate());
|
|
if( todo.startDate && ( moment() < moment( todo.startDate, 'YYYYMMDD HH:mm:ss' )
|
|
.toDate() ) ) {
|
|
passdate = false;
|
|
};
|
|
// currentdate ne doit pas depasser la date de validité de la tache
|
|
// console.log('test now est après la date de validite ', moment() > moment(todo.validuntilDate, 'YYYYMMDD HH:mm:ss').toDate());
|
|
if( todo.valideuntilDate && ( moment() > moment( todo.validuntilDate, 'YYYYMMDD HH:mm:ss' )
|
|
.toDate() ) ) {
|
|
passdate = false;
|
|
};
|
|
// currentdate
|
|
if( passdate && todo.action && todo.error == "" ) {
|
|
log.nbactionexec++;
|
|
const actiondone = await Contracts[ todo.action ]( todo, envoie );
|
|
todo.datesRun.push( moment( new Date() )
|
|
.format( 'YYYYMMDD HH:mm:ss' ) );
|
|
//console.log("actiondone"
|
|
log.actionlist += "STATUS:" + actiondone.status + " -- " + listaction[ action ] + "\n";
|
|
if( actiondone.status == 200 ) {
|
|
todo.error = "";
|
|
} else {
|
|
log.nbactionerr++;
|
|
todo.error += "status : " + actiondone.status + ' ' + actiondone.payload.moreinfo;
|
|
};
|
|
if( parseInt( todo.maxnumberoftime ) && todo.maxnumberoftime != "999" && ( todo.datesRun.length >= parseInt( todo.maxnumberoftime ) ) ) {
|
|
//archive en done this triggeraction
|
|
fs.outputJsonSync( listaction[ action ].replace( '/todo/', '/done/' ), todo, {
|
|
spaces: 2
|
|
} );
|
|
fs.unlinkSync( listaction[ action ] );
|
|
} else {
|
|
fs.outputJsonSync( listaction[ action ], todo, {
|
|
spaces: 2
|
|
} );
|
|
}
|
|
} else {
|
|
log.actionlist += "STATUS : not executed " + listaction[ action ] + "\n";
|
|
};
|
|
};
|
|
};
|
|
const trace = "###################### LOGS ####################\nSTART:" + datedeb + " END:" + moment( new Date() )
|
|
.format( 'YYYYMMDD HH:mm:ss' ) + "\n nombre d'actions analysées : " + log.nbaction + " dont executées : " + log.nbactionexec + " dont en erreur: " + log.nbactionerr + "\n" + log.actionlist;
|
|
fs.appendFileSync( `${conf.tribes}/log.txt`, trace, 'utf-8' );
|
|
return "done";
|
|
}
|
|
module.exports = Contracts;
|