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
| public class RunThread implements Runnable{
String a;
boolean actif;
public RunThread(String a) {
this.a = a;
}
public void run() {
try {
URL url = new URL("http://xxxxxx.com");
String CONVERTER_URL=url.toString();
System.out.println("Converter url -->"+CONVERTER_URL);
String ShortNumber ="smart";
String id="aa";
String table="";
if (table =="" && id=="aa"){
HttpSession session = com.beans.Util.getSession();
table=session.getAttribute("table").toString();
idBulk=session.getAttribute("id").toString();
}
DemarrerService(CONVERTER_URL, table, id);
} catch (Exception e) {
e.printStackTrace();
}
}
public static void DemarrerService(String CONVERTER_URL, String table, String id) {
int solde=0;
int nbre_total=0;
Connection connection=null;
Statement stmt1=null;
ResultSet rset1=null;
System.out.println("---------------------------------- avant getsession");
HttpSession session = com.beans.Util.getSession();
// HttpSession session = Util.getSession();
String id="";
String header="";
String header_table="";
String phoneNumber="";
String sql="select id,num_tel,header from "+table+" where traiter='non' limit 10";
System.out.println("------------------------------ sql done -----------------");
try{
System.out.println("------------------------------ before connection -----------------"+sql);
connection = dao.Database.getConnection();
System.out.println("----- connection is OK ------");
nbre_total=Commons.compterNbre(table, connection);
System.out.println("----- nbre totale des element dans la table------"+nbre_total);
if(connection !=null && !connection.isClosed()){
stmt1= connection.createStatement();
rset1= stmt1.executeQuery(sql);
System.out.println("***********"+beans.CompagneBean.arreteSilTePlait);
while(rset1.next()) {
id= rset1.getString("id");
System.out.println("-------le id de la com-------");
phoneNumber = rset1.getString("num_tel");
header=rset1.getString("header");
// traitement des lignes de base de donnée
// je veux stoper le traitement apres le traitement de qlq lignes de la BD
if (condition)
{
Commons.UpdateCompagneValide(id,table, connection);
System.out.println(phoneNumber+"\n");
System.out.println("-------- numero de tel ---- "+phoneNumber+ " done successfully");
solde++;
if (beans.CompagneBean.arreteSilTePlait==false)
break;
try{
// faire une pause de 10 secondes entre le traitement de chacune des lignes pour laisser le temps pour mettre en pause
Thread.sleep(10000);
}
catch (Exception e){
e.printStackTrace();
}
// notifier l'utilisateur que le traitement est terminé
if (solde==nbre_total){
//call notification
boolean updateSolde= Commons.updateSolde(id, solde, connection);
System.out.println("-------Suppression de la table-------");
// boolean deleteTable=Commons.SupprimerTable(table, connection);
System.out.println("-------delete OK -------");
}
}
else{
Commons.UpdateCompagneErr(id,table, connection);
System.out.println("------erreur --------");
}
}
}
stmt1.close();
connection.close();
}
catch(Exception e){
e.printStackTrace();
}
}
} |
Bouton pour stopper un traitement
Répondre avec citation
Partager