Script php qui se relance tout seul

Version imprimable

02/10/2017, 09h00
davidlariv

Script php qui se relance tout seul

Bonjour,

Je programme en php depuis plus de 10 ans et je suis un peu abasourdi par un constat sur lequel je cale depuis plusieurs jours...

Pour un envoi massif de mail, un appel ajax envoie les adresses mail en file d'attente sur la DB. Ensuite un Cronjob appelle la page php toutes les 15 min. qui envoie les mails à concurrence de 25 mails de 10 recipients (destinataires) en BCC avec phpMailer en SMTP.

Si la commande $mail->Send(); de phpmailer est désactivée (//) le script php se déroule normalement: Les mails "envoyés" sont retirés de la file d'attente. Et si la rangée concernée dans la DB est vidée, elle est supprimée.
Soit le déroulement normal du script, outre l'envoi, bien-sûr.

Par contre... si $mail->Send(); est actif, le script s'exécute... le temps d'exécution devient très très long... (+ 1 minute) mais surtout: le script recommence et donc plusieurs rangées de la DB sont lues, et tous les mails de la file d'attente envoyés, le quota d'envoi est alors complètement dépassé!!!!

Sur le principe, cela est-il possible qu'un script php soit relu par le serveur ?

Merci pour vos réponses, je nage en pleine 4ème dimension.
02/10/2017, 11h17
Celira

Dans les deux cas, le script est lancé par la tache planifiée ? ou à la main ?
02/10/2017, 11h44
davidlariv

Salut Célira,
Programmée (Cronjob). Mais à la main, ça donne le même résultat...
02/10/2017, 11h50
Celira

Cela ne parait effectivement pas normal :cfou: Peut-on voir le code du script en question ?

Voici...

Ce qui est étonnant c'est que mes variables sont bien remplies.
Les echo sont là en test et le dernier $to_bbc_untab rempli d'adresse mail (masquée, mais elles fonctionnent) avant envoi est là pour le test... Je ne souhaite pas que les utilisateurs reçoivent des mails d'essai...

J'ajoute la fonction de phpMailer...

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
<?php 
 
date_default_timezone_set('Europe/Brussels');
 
 
require_once('../connection/connection_db_vv.php'); 
 
 
//include_once ('../includes/functions.php');
 
//ini_set('display_errors', 1);
 
$now = time();
 
// timing de script illimité
ini_set('max_execution_time', 0);
 
// inclus fonction mailing
include('../fonctions_php/fonction_mailing_bcc.php');
 
//$jours=array('dimanche','lundi','mardi','mercredi','jeudi','vendredi','samedi');
 
 
 
// import des données lieu
$lieu = $connexion_vv_encours->prepare('SELECT * FROM lieu');
$lieu->execute();
$data_lieu=array();
$data_lieu = $lieu->fetch() ;	
$lieu->closeCursor();
 
$max_par_quart_dheure = $data_lieu['mailing_max_quart_dheure']; //3;
$max_recipient_mail = $data_lieu['mailing_max_recipient_mail']; //5;
 
$max_des_envois_pour_ce_script = $max_par_quart_dheure * $max_recipient_mail;
 
 
// import file d'attente
 
 
// TESTE POUR DONNER LA PRIORITé à la file des envois de mails aux réservants plutôt qu'à la Newsletter...
$file_attente_mail_reserv = $connexion_vv_encours->prepare('SELECT * FROM envoi_mail_reserv_cronjob ORDER BY id');
$file_attente_mail_reserv->execute();
$data_file_attente=array();
$data_file_attente = $file_attente_mail_reserv->fetchAll() ;	
$file_attente_mail_reserv->closeCursor();
 
 
$test_si_newsletter = 0;
 
if (empty($data_file_attente)) {
 
	$test_si_newsletter = 1;
 
	// Select file d'attente Mailing
	$file_attente = $connexion_vv_encours->prepare('SELECT * FROM newsletter_send_cronjob ORDER BY id');
	$file_attente->execute();
	$data_file_attente=array();
	$data_file_attente = $file_attente->fetchAll() ;	
	$file_attente->closeCursor();
 
}
 
if (!empty($data_file_attente)) {
 
 
	if ($test_si_newsletter == 1) {
 
		// SI NEWSLETTER
		$id_newsletter =  $data_file_attente[0]['id_newsletter'];
		$newsletter = $connexion_vv_encours->prepare('SELECT * FROM newsletter WHERE id = ?');
		$re_insert = $connexion_vv_encours->prepare('UPDATE newsletter_send_cronjob SET id_destinataires=? WHERE id = ?');
		$stmt = $connexion_vv_encours->prepare('DELETE FROM newsletter_send_cronjob WHERE id = ?');
 
		$texte_bouton_unsuscribe = 'Se&nbsp;d&eacute;sabonner&nbsp;&agrave;&nbsp;la&nbsp;newsletter';
		$unsuscribe = '<br />
		<br />
		<a href="'.$data_lieu['adresse_site'].'/ticketing/newsletter/unsuscribe.php"  target="_blank"><input id="unsuscribe" type="button" style="
		background: #db5034;
		border: 0;
		box-shadow:none;
		font-family: Arial;
		color: #ffffff;
		font-size: 18px;
		padding: 10px 20px 10px 20px;
		text-decoration: none;
		cursor:pointer;" 
		value="'.$texte_bouton_unsuscribe.'"/></a>'; 
 
 
	} else {
 
		// SI MAIL AUX RESERVANTS
		$id_newsletter =  $data_file_attente[0]['id_mail'];
		$newsletter = $connexion_vv_encours->prepare('SELECT * FROM envoi_mail_reservants WHERE id = ?');
		$re_insert = $connexion_vv_encours->prepare('UPDATE envoi_mail_reserv_cronjob SET id_destinataires=? WHERE id=?');
		$stmt = $connexion_vv_encours->prepare('DELETE FROM envoi_mail_reserv_cronjob WHERE id=?');
		$unsuscribe = '';
	}
 
	// Concatene ID destinataires
	$tab_id_users_complet = explode(',', $data_file_attente[0]['id_destinataires']); //'15,21,274,284,286,287');
 
 
 
 
	// Supprime entree si vide de destinataire
	if (!($tab_id_users_complet[0] > 0)) {
 
		// Supprime la file d'attente 
		$stmt->bindValue(1, $data_file_attente[0]['id'], PDO::PARAM_INT);
		$stmt->execute();
		$stmt->closeCursor();
		  // Et arrête le script
		//exit;
 
	} else {
 
 
 
 
		// import de la newsletter
		$newsletter->bindValue( 1 , $id_newsletter , PDO::PARAM_INT); 
		$newsletter->execute();
		$data_newsletter = array();
		$data_newsletter = $newsletter->fetch() ;	
		$newsletter->closeCursor();
 
		$sujet_mail = $data_newsletter['sujet_mail'];
		$texte_mail = $data_newsletter['texte_mail'];
		$date_envoi = $data_newsletter['date_envoi'];
		$auteur = $data_newsletter['auteur'];
		$id_auteur = $data_newsletter['id_auteur'];
		$signature_check = $data_newsletter['signature'];
 
 
 
		// import de l'AUTEUR
		$import_auteur = $connexion_vv_encours->prepare('SELECT * FROM users WHERE id = ?');
		$import_auteur->bindValue( 1 , $id_auteur , PDO::PARAM_INT); 
		$import_auteur->execute();
		$data_import_auteur = array();
		$data_import_auteur = $import_auteur->fetch() ;	
		$import_auteur->closeCursor();
 
 
 
	// PREPARE importe les abonnés transmis				
		$count_destinataires_total = count($tab_id_users_complet);
 
		$nb_envoi_pour_ce_script = $max_des_envois_pour_ce_script;
		if ($max_des_envois_pour_ce_script > $count_destinataires_total) $nb_envoi_pour_ce_script = $count_destinataires_total;
 
 
		// Cree tab et traite les id destinataires
		$tab_id_users = array_slice($tab_id_users_complet, 0, $nb_envoi_pour_ce_script);      // retourne "a", "b", et "c"		
		$count_destinataires = count($tab_id_users);
 
		// Cree tab des id restants à ré-insérer
		$tab_re_insert = array_slice($tab_id_users_complet, $nb_envoi_pour_ce_script);         // retourne  "d", et "e"
		$re_insert_texte = implode(',',$tab_re_insert);
 
		// Réinjecte l'array non envoyé ou supprime si vide
		if (!empty($tab_re_insert)) {
 
			$re_insert->bindValue( 1 , $re_insert_texte, PDO::PARAM_STR);
			$re_insert->bindValue( 2 , $data_file_attente[0]['id'], PDO::PARAM_INT);
			$re_insert->execute();
			$re_insert->closeCursor();			
 
		} else {
 
			// Supprime la file d'attente 
			$stmt->bindValue(1, $data_file_attente[0]['id'], PDO::PARAM_INT);
			$stmt->execute();
			$stmt->closeCursor();
 
		}
 
		// Prepare texte mail
		// Remplace les elements  
		$mail_corps_html = $texte_mail;
		$texte_bouton = 'Visiter&nbsp;notre&nbsp;site';
		$mail_corps_html = str_replace ( '[bouton_lien_site]' , 
			'<a href="'.$data_lieu['adresse_site'].'"  target="_blank"><input type="button" style="
			background: #3498db;
			border: 0;
			box-shadow:none;
			font-family: Arial;
			color: #ffffff;
			font-size: 18px;
			padding: 10px 20px 10px 20px;
			text-decoration: none;
			cursor:pointer;" 
			value="'.$texte_bouton.'"/></a>' , $mail_corps_html); 
 
		// Ajoute unsuscribe si newsletter
		$mail_corps_html .= $unsuscribe; 
 
		// import de la "signature"
		$signature = ''; 
		//insère la signature si option checked
		if ($signature_check == 1) {
 
			$mail_signature = $connexion_vv_encours->prepare('SELECT mail FROM mails_defaut WHERE id = 1');
			$mail_signature->execute();
			$data_mail_signature=array();
			$data_mail_signature = $mail_signature->fetch() ;	
			$mail_signature->closeCursor();
 
			$prenom_user = htmlentities($data_import_auteur['prenom']);
			$nom_user = htmlentities($data_import_auteur['nom']);
			$mail_user = $data_import_auteur['email'];
			$fonction_user = htmlentities($data_import_auteur['fonction_vv']);
 
			$signature = $data_mail_signature['mail'];
			$signature = str_replace ( '[fonction]' , $fonction_user , $signature); 
			$signature = str_replace ( '[prenom_user_en_cours]' , $prenom_user , $signature); 
			$signature = str_replace ( '[nom_user_en_cours]' , $nom_user , $signature); 
			$signature = str_replace ( '[email_user_en_cours]' , $mail_user , $signature); 		
 
			$mail_corps_html .= '<br/><br />'.$signature; 	
		}
 
		$auteur = $prenom_user.' '.$nom_user;
 
 
		$spectateurs = $connexion_vv_encours->prepare('SELECT email FROM spectateurs WHERE id = ?');
		$spectateurs->bindParam( 1 , $id_user_en_cours , PDO::PARAM_INT); 
 
		// IMporte le mail de chaque destinataire
		$tab_email_tous = array();
 
		foreach ($tab_id_users as $id_spectateur) {
 
			$id_user_en_cours = $id_spectateur;
			$spectateurs->execute();
			$data_spectateur = array();
			$data_spectateur = $spectateurs->fetch() ;
 
			// S'assure qu'il n'y a pas d' espace devant et derrière l'adresse mail
			$email = trim($data_spectateur['email']);
 
			//Prépare et envoie le mail si existe
			if (strlen($email) > 4) $tab_email_tous[] = $email;
 
		}	
		$spectateurs->closeCursor();
 
		$mailretour=$data_lieu['mail_retour'];
		$nom_lieu=$data_lieu['nom_lieu'];
 
		if ($sujet_mail == '') {
 
			$sujet_mail = $nom_lieu;
		}
 
		$message_html="<html>
		<body>
		".$mail_corps_html."
		</body>
		</html>";
 
 
		// SAUCISSONNE la mailing liste
		$count_nb_envoi = 0;
		$fin_liste = 0;
		$to_bcc = array();
		while ($count_nb_envoi < $max_par_quart_dheure) {
 
 
			$debut_liste =  $count_nb_envoi * $max_recipient_mail;
 
			// reprends la liste où elle s'est arrêtée
			$to_bcc = array_slice($tab_email_tous, $debut_liste, $max_recipient_mail);    
 
 
			if (!empty($to_bcc)) {
 
				//$to_bbc_untab = implode(',',$to_bcc);
				$to_bbc_untab = 'xxxxx@xxxxx.fr,xxxxx@xxxxxx.be';
 
				//mailing($mailretour,utf8_decode($nom_lieu),utf8_decode($sujet_mail),$message_html,$to_bbc_untab);	
				mailing($mailretour,utf8_decode($nom_lieu),utf8_decode($sujet_mail.' --- '.$debut_liste),$message_html,$to_bbc_untab);	
 
 
				//echo 'Envoi = '.$to_bbc_untab;
			}
	echo $data_file_attente[0]['id'].' -- '.$count_nb_envoi.' --- <br />'.implode(',',$to_bcc).'<br />';
 
			$count_nb_envoi++;
		}
	}
}
?>

Fonction de phpMailer:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
 
if (file_exists("../php_mailer/class.phpmailer.php")) {
 
	include("../php_mailer/class.phpmailer.php");
 
} else {
 
	include("../../php_mailer/class.phpmailer.php");
}
 
$smtp_email = $connexion_vv_encours->prepare('SELECT * FROM mail_smtp');
$smtp_email->execute();
$tab_smtp=$smtp_email->fetch();
$smtp_email->closeCursor();	
 
$mail_smtp=$tab_smtp['email'];
$password_smtp=$tab_smtp['code_smtp'];
$username_smtp=$tab_smtp['username_smtp'];
$host_smtp=$tab_smtp['host_smtp'];
 
function mailing($mailretour,$nom_lieu,$sujet,$message_html,$to_bbc_untab) {
 
		global $mail_smtp, $password_smtp, $username_smtp, $host_smtp;	
		// appelle la fonction PHP_MAILER
		$mail = new PHPMailer();
		$mail->IsSMTP(); 
 
		$mail->SMTPAuth = true;    
		$mail->SMTPSecure = 'ssl'; 
		$mail->Host = $host_smtp;
        $mail->Port = 465;  
		$mail->Username = $username_smtp;
		$mail->Password = $password_smtp;
 
		$mail->From = $mail_smtp;
		$mail->FromName = $nom_lieu; 
 
		$mail->AddAddress("undisclosed-recipients:;");
 
		$to_bcc = explode (',',$to_bbc_untab);
 
		foreach($to_bcc as $email)
		{
		   $mail->AddBCC($email);
		}
 
 
		$mail->AddReplyTo($mailretour, $nom_lieu);
 
		$mail->WordWrap = 50;                                
		$mail->IsHTML(true);                                
 
		$mail->Subject = $sujet;
		$mail->Body    = $message_html;
 
		$mail->SMTPDebug = false;
		$mail->do_debug = 0;
 
		$mail->Send();
 
		unset($mail);
 
 
}		 
?>

Désolé pour la longueur du code et merci de te pencher sur ce cas...

02/10/2017, 12h07
davidlariv

Le problème est celui-ci:
ça fonctionne, je reçois bien les mails d'essai mais je reçois toutes les vagues d'une fois même si j'ai plusieurs rows dans la liste d'attente de DB et celles-ci sont toutes lues puis effacées. Exactement comme si la page était relancée...
02/10/2017, 12h11
davidlariv

J'ajoute le sql de la db:

Citation:

CREATE TABLE IF NOT EXISTS `envoi_mail_reserv_cronjob` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`id_destinataires` text NOT NULL,
`id_mail` int(15) NOT NULL,
`total_destinataires` int(11) NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 AUTO_INCREMENT=28 ;

--
-- Dumping data for table `envoi_mail_reserv_cronjob`
--

INSERT INTO `envoi_mail_reserv_cronjob` (`id`, `id_destinataires`, `id_mail`, `total_destinataires`) VALUES
(26, '24,25,27,29,30,39,43,44,45,46,47,42,48,49,50,51,52,53,59,60,62,63,64,66,68,71,72,73,74,75,76,77,78,79,80,81,82,84,85,86,18,89,90,91,70,92,93,94,95,96,97,99,100,101,102,103,104,105,106,107,108,109,111,112,113,114,115,116,117,118,120,122,121,123,124,125,126,127,15,130,131,132,133,134,135,137,138,139,136,140,141,142,146,98,148,149,150,152,153,154,155,156,157,158,159,161,69,162,163,119,164,165,166,167,168,169,170,171,172,83,173,174,175,176,177,178,179,180,181,182,183,184,185,186,188,189,190,191,192,193,194,195,196,197,198,199,147,200,201,202,203,204,205,206,207,208,210,211,212,213,214,215,216,67,218,219,220,160,54,221,217,222,223,224,225,226,227,228,229,230,231,232,233,234,235,236,237,238,239,240,241,242,243,244,245,246,247,248,249,250,251,253,254,255,256,257,258,259,260,261,263,264,265,266,267,268,269,270,271,272,273,276,278,279', 45, 224),
(27, '24,25,27,29,30,39,43,44,45,46,47,42,48,49,50,51,52,53,59,60,62,63,64,66,68,71,72,73,74,75,76,77,78,79,80,81,82,84,85,86,18,89,90,91,70,92,93,94,95,96,97,99,100,101,102,103,104,105,106,107,108,109,111,112,113,114,115,116,117,118,120,122,121,123,124,125,126,127,15,130,131,132,133,134,135,137,138,139,136,140,141,142,146,98,148,149,150,152,153,154,155,156,157,158,159,161,69,162,163,119,164,165,166,167,168,169,170,171,172,83,173,174,175,176,177,178,179,180,181,182,183,184,185,186,188,189,190,191,192,193,194,195,196,197,198,199,147,200,201,202,203,204,205,206,207,208,210,211,212,213,214,215,216,67,218,219,220,160,54,221,217,222,223,224,225,226,227,228,229,230,231,232,233,234,235,236,237,238,239,240,241,242,243,244,245,246,247,248,249,250,251,253,254,255,256,257,258,259,260,261,263,264,265,266,267,268,269,270,271,272,273,276,278,279', 46, 224);
02/10/2017, 14h20
Celira

Hum... Et la différence, c'est que tu commentes ou non la ligne $mail->Send(); ? :koi: Franchement, je vois pas trop où est le problème...
02/10/2017, 18h09
davidlariv

Oui c'est ça.... Je ne pige pas non plus...
Tu n'as jamais entendu parler de relance de script pour délai d'exécution trop long?
03/10/2017, 10h07
Celira

Non, si tu dépasses le temps d'exécution max, ça s'arrête avec une erreur TimeOut, point.
A ce propos, quelle est la valeur du temps max d'exécution ? (max_execution_time dans le php.ini ou une valeur affectée manuellement par set_time_limit)
03/10/2017, 10h21
Loralina

Bonjour,
Il y a de nombreux tests possibles :
Désactiver complètement la tâche planifiée.
Remplacer l'instruction "send" par un "sleep" d'une durée comparable.
Si avec "sleep", le script ne semble pas relancé, tenter une boucle "while/for" à vide d'une durée comparable (le sleep pouvant ne pas être comptabilisé dans le temps d'exécution).
Si le résultat est le même, aller voir dans la fonction "send" pour désactiver certaines instructions, jusqu'à cibler celle qui pose problème.
Par contre, si avec "sleep" ou une boucle à vide, le problème est le même, alors désactiver la boucle while ($count_nb_envoi < $max_par_quart_dheure) { et mettre par exemple sleep(70) à la place.
Si le problème persiste, mettre tout le code en commentaire, mettre au début une instruction d'insertion dans une table de test ayant un champ "id autoincrement", suivie d'un sleep(70).
Si un seul enregistrement apparaît en base, reprendre le script initial, ajouter au début l'instruction d'insertion dans la table de test, puis désactiver progressivement du code jusqu'à se rapprocher du test précédent.

Sinon, est-ce que le script a bien été testé en étant lancé directement ? Il n'est pas inclus dans un autre script ?
Au niveau d'ajax, il n'y a pas un "timeout" trop court défini avec une relance du script en cas d'erreur ? (en supposant que le script appelé soit immédiatement suivi d'un premier envoi de courriels).
03/10/2017, 11h26
davidlariv

Merci Loralina,

Je viens de passer 2 h avec le fournisseur d'hébergement et il apparaît que:
C'est tout à fait possible!!!

Le temps d'exécution trop long, la page était relancée... par le serveur!!!!

La solution (bidouillée, certe!) est de placer une fonction qui teste en début de script le time() de la dernière lecture du script (envoyée en DB dès l'exécution complète) et annule la suite si inférieure à 14min. Ce qui empêche la relecture du script.

Merci pour ta patience...
Belle journée.