IdentifiantMot de passe
Loading...
Mot de passe oublié ?Je m'inscris ! (gratuit)
Navigation

Inscrivez-vous gratuitement
pour pouvoir participer, suivre les réponses en temps réel, voter pour les messages, poser vos propres questions et recevoir la newsletter

Développement Web en Java Discussion :

JEE: Automatisation de tâches


Sujet :

Développement Web en Java

Vue hybride

Message précédent Message précédent   Message suivant Message suivant
  1. #1
    Invité
    Invité(e)
    Par défaut JEE: Automatisation de tâches
    Bonjour,

    Je travaille sur un projet web JEE auquel j’aimerais intégrer le système suivant : en récupérant le cours du taux de change des devises, je voudrais mettre en place un système d’envoi de mail automatique dès qu’un taux atteint une certaine valeur.

    Je rencontre un problème au niveau de l’automatisation de l’envoi de mail… En utilisant l’API JavaMail, j’arrive effectivement à envoyer un mail. De plus, j’ai la fonction qui permet de comparer le cours avec une valeur souhaitée et elle fonctionne impeccablement. Ainsi, il ne me manque plus que de pouvoir lancer cette fonction à intervalle de temps régulier sans avoir à faire quoi que ce soit, ce serait au serveur de le faire toutes les 10 minutes par exemple.
    J’ai essayé d’utiliser @Schedule ou encore le framework Quartz, mais rien n’y fait, je n’y arrive pas. Pourriez-vous me dire comment faire, s’il vous plait ?

  2. #2
    Membre Expert

    Profil pro
    Inscrit en
    Décembre 2011
    Messages
    974
    Détails du profil
    Informations personnelles :
    Localisation : France

    Informations forums :
    Inscription : Décembre 2011
    Messages : 974
    Par défaut
    petite question: comment récupères-tu le taux de change des dévises ? (synchrone ou asynchrone ?)

  3. #3
    Invité
    Invité(e)
    Par défaut
    Salut,
    Je ne sais pas trop, je dirais asynchrone... On parse un fichier XML dont on récupère les informations grâce à son URL.

  4. #4
    Membre Expert

    Profil pro
    Inscrit en
    Décembre 2011
    Messages
    974
    Détails du profil
    Informations personnelles :
    Localisation : France

    Informations forums :
    Inscription : Décembre 2011
    Messages : 974
    Par défaut
    toutes les 10 minutes, tu souhaites parser le fichier XML etc....

    peux-tu nous montrer le code de ton ejb timer ?

    et en annotant la méthode qui fait le boulot par:

    Code : Sélectionner tout - Visualiser dans une fenêtre à part
    @Schedule(minute="*/10", hour="*")

  5. #5
    Invité
    Invité(e)
    Par défaut
    Ce n'est pas tout à fait ça, la fonction quand elle est appelée dans un servlet fonctionne sans problème. Ce que je voudrais c'est que la méthode ci-dessous soit lancée au démarrage du serveur puis périodiquement sans appel par un servlet:

    Code : Sélectionner tout - Visualiser dans une fenêtre à part
    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
     
     
     
     
     
    package dao.impl;
     
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.SQLException;
    import java.util.List;
    import java.util.Properties;
     
    import javax.annotation.Resource;
    import javax.ejb.Schedule;
    import javax.ejb.Singleton;
    import javax.ejb.Timer;
    import javax.ejb.TimerService;
    import javax.mail.Message;
    import javax.mail.MessagingException;
    import javax.mail.PasswordAuthentication;
    import javax.mail.Session;
    import javax.mail.Transport;
    import javax.mail.internet.InternetAddress;
    import javax.mail.internet.MimeMessage;
     
    import managers.InscriptionManager;
    import managers.RecupTauxManager;
    import entities.Inscription;
     
     
    public class FoncMailauplusbas  {
     
    	public double EnvoiMail(){
    		double taux;
    		List<Inscription> listeInscriptions=InscriptionManager.getInstance().listerInscriptions(); //récupération des inscriptions contenues dans la BDD, et mises dans une liste
    		String instrument;
    		String pays;
     
    		final String username = "monMail@gmail.com";
    		final String password = "*****";
     
    		 Properties props = new Properties();                       //instanciation des propriétés propres à l'envoi de mail avec "gmail"
    			props.put("mail.smtp.auth", "true");
    			props.put("mail.smtp.starttls.enable", "true");
    			props.put("mail.smtp.host", "smtp.gmail.com");
    			props.put("mail.smtp.port", "587");
     
    			Session session = Session.getInstance(props,
    			  new javax.mail.Authenticator() {
    				protected PasswordAuthentication getPasswordAuthentication() {
    					return new PasswordAuthentication(username, password);
    				}
    			  });
     
     
     
    		for(int i=0;i<listeInscriptions.size()-1;i++){
    			if("USA".equals(listeInscriptions.get(i).getPays())){
    				taux= RecupTauxManager.getInstance().FoncTaux("USD");// Récupération du bon taux de change actuel en fonction du pays souhaité pour la comparaison
    				if(listeInscriptions.get(i).getPrixvoulu()>listeInscriptions.get(i).getPrixact()/taux){  // Si le prix maximum souhaité est supérieur au prix de l'instrument dans sa devise initiale divisé par le taux de change actuel, alors il faut prévenir l'utilisateur
     
    					instrument=listeInscriptions.get(i).getInstrument();
    					pays=listeInscriptions.get(i).getPays();
     
     
    				    String emailTo = listeInscriptions.get(i).getEmail();		
    				    String messageText = "Bonjour, l'application à laquelle vous vous êtes inscrit vous indique que l'instrument "+instrument+ "a atteint le prix que vous souhaitiez si l'on se base sur le cours de la devise aujourd'hui dans le pays"+pays+". Si l'instrument n'a pas changé de prix sur le site indiqué, il convient de l'acheter maintenant, conformément à votre demande. N'oubliez pas qu'il peut y avoir des frais suppplémentaires liés aux taxes et frais de tranports. A bientôt !" ;
     
     
    				    try {  //envoi du mail à l'utilisateur
     
    						Message message = new MimeMessage(session);
    						message.setFrom(new InternetAddress("monMail@gmail.com"));
    						message.setRecipients(Message.RecipientType.TO,
    							InternetAddress.parse(emailTo));
    						message.setSubject("Votre Instrument au prix voulu");
    						message.setText(messageText);
     
    						Transport.send(message);
     
    						System.out.println("Message Envoyé US Prix le plus bas");
     
    					} catch (MessagingException e) {
    						throw new RuntimeException(e);
    					}
    				    try {   // Supprimer la ligne dans la BDD correspondant à l'instrument dont le prix atteint convient à l'utilisateur, afin qu'il ne soit pas prévenu une nouvelle fois lorsque la méthode se relance
     
    						Connection connection = DataSourceProvider.getDataSource().getConnection();
    						PreparedStatement stmt = connection.prepareStatement("DELETE FROM inscription WHERE instrument=?");
    						stmt.setString(1, instrument);
    						stmt.executeUpdate();
    			            connection.close();
    					} catch (SQLException e) {
    						e.printStackTrace();
    					}
     
     
     
     
    				}
    				}if("AUSTRALIE".equals(listeInscriptions.get(i).getPays())){
    					taux= RecupTauxManager.getInstance().FoncTaux("AUD");
    					if(listeInscriptions.get(i).getPrixvoulu()>listeInscriptions.get(i).getPrixact()/taux){
     
     
    						instrument=listeInscriptions.get(i).getInstrument();
    						pays=listeInscriptions.get(i).getPays();
     
     
    					    String emailTo = listeInscriptions.get(i).getEmail();		
    					    String messageText = "Bonjour, l'application à laquelle vous vous êtes inscrit vous indique que l'instrument "+instrument+ "a atteint le prix que vous souhaitiez si l'on se base sur le cours de la devise aujourd'hui dans le pays"+pays+". Si l'instrument n'a pas changé de prix sur le site indiqué, il convient de l'acheter maintenant, conformément à votre demande. N'oubliez pas qu'il peut y avoir des frais suppplémentaires liés aux taxes et frais de tranports. A bientôt !" ;
     
     
    					    try {
     
    							Message message = new MimeMessage(session);
    							message.setFrom(new InternetAddress("monMail@gmail.com"));
    							message.setRecipients(Message.RecipientType.TO,
    								InternetAddress.parse(emailTo));
    							message.setSubject("Votre Instrument au prix voulu");
    							message.setText(messageText);
     
    							Transport.send(message);
     
    							System.out.println("Message Envoyé AUS Prix le plus bas");
     
    						} catch (MessagingException e) {
    							throw new RuntimeException(e);
    						}
     
    					    try {
     
    							Connection connection = DataSourceProvider.getDataSource().getConnection();
    							PreparedStatement stmt = connection.prepareStatement("DELETE FROM inscription WHERE instrument=?");
    							stmt.setString(1, instrument);
    							stmt.executeUpdate();
    				            connection.close();
    						} catch (SQLException e) {
    							e.printStackTrace();
    						}
     
     
     
     
    					}
    					}
    				if("JAPON".equals(listeInscriptions.get(i).getPays())){
    					taux= RecupTauxManager.getInstance().FoncTaux("JPY");
    					if(listeInscriptions.get(i).getPrixvoulu()>listeInscriptions.get(i).getPrixact()/taux){
     
    						instrument=listeInscriptions.get(i).getInstrument();
    						pays=listeInscriptions.get(i).getPays();
     
     
    					    String emailTo = listeInscriptions.get(i).getEmail();		
    					    String messageText = "Bonjour, l'application à laquelle vous vous êtes inscrit vous indique que l'instrument "+instrument+ "a atteint le prix que vous souhaitiez si l'on se base sur le cours de la devise aujourd'hui dans le pays"+pays+". Si l'instrument n'a pas changé de prix sur le site indiqué, il convient de l'acheter maintenant, conformément à votre demande. N'oubliez pas qu'il peut y avoir des frais suppplémentaires liés aux taxes et frais de tranports. A bientôt !" ;
     
     
    					    try {
     
    							Message message = new MimeMessage(session);
    							message.setFrom(new InternetAddress("monMail@gmail.com"));
    							message.setRecipients(Message.RecipientType.TO,
    								InternetAddress.parse(emailTo));
    							message.setSubject("Votre Instrument au prix voulu");
    							message.setText(messageText);
     
    							Transport.send(message);
     
    							System.out.println("Message Envoyé JAP Prix le plus bas");
     
    						} catch (MessagingException e) {
    							throw new RuntimeException(e);
    						}
     
    					    try {
     
    							Connection connection = DataSourceProvider.getDataSource().getConnection();
    							PreparedStatement stmt = connection.prepareStatement("DELETE FROM inscription WHERE instrument=?");
    							stmt.setString(1, instrument);
    							stmt.executeUpdate();
    				            connection.close();
    						} catch (SQLException e) {
    							e.printStackTrace();
    						}
     
     
     
     
    					}
    					}
    				if("ANGLETERRE".equals(listeInscriptions.get(i).getPays())){
    					taux= RecupTauxManager.getInstance().FoncTaux("GBP");
    					if(listeInscriptions.get(i).getPrixvoulu()>listeInscriptions.get(i).getPrixact()/taux){
     
    						instrument=listeInscriptions.get(i).getInstrument();
    						pays=listeInscriptions.get(i).getPays();
     
     
    					    String emailTo = listeInscriptions.get(i).getEmail();		
    					    String messageText = "Bonjour, l'application à laquelle vous vous êtes inscrit vous indique que l'instrument "+instrument+ "a atteint le prix que vous souhaitiez si l'on se base sur le cours de la devise aujourd'hui dans le pays"+pays+". Si l'instrument n'a pas changé de prix sur le site indiqué, il convient de l'acheter maintenant, conformément à votre demande. N'oubliez pas qu'il peut y avoir des frais suppplémentaires liés aux taxes et frais de tranports. A bientôt !" ;
     
     
    					    try {
     
    							Message message = new MimeMessage(session);
    							message.setFrom(new InternetAddress("monMail@gmail.com"));
    							message.setRecipients(Message.RecipientType.TO,
    								InternetAddress.parse(emailTo));
    							message.setSubject("Votre Instrument au prix voulu ");
    							message.setText(messageText);
     
    							Transport.send(message);
     
    							System.out.println("Message Envoyé ANG Prix le plus bas");
     
    						} catch (MessagingException e) {
    							throw new RuntimeException(e);
    						}
     
     
    					    try {
     
    							Connection connection = DataSourceProvider.getDataSource().getConnection();
    							PreparedStatement stmt = connection.prepareStatement("DELETE FROM inscription WHERE instrument=?");
    							stmt.setString(1, instrument);
    							stmt.executeUpdate();
    				            connection.close();
    						} catch (SQLException e) {
    							e.printStackTrace();
    						}
     
     
     
     
    					}
    					}
    				if("AFRIQUE DU SUD".equals(listeInscriptions.get(i).getPays())){
    					taux= RecupTauxManager.getInstance().FoncTaux("ZAR");
    					if(listeInscriptions.get(i).getPrixvoulu()>listeInscriptions.get(i).getPrixact()/taux){
     
    						instrument=listeInscriptions.get(i).getInstrument();
    						pays=listeInscriptions.get(i).getPays();
     
     
    					    String emailTo = listeInscriptions.get(i).getEmail();		
    					    String messageText = "Bonjour, l'application à laquelle vous vous êtes inscrit vous indique que l'instrument "+instrument+ "a atteint le prix que vous souhaitiez si l'on se base sur le cours de la devise aujourd'hui dans le pays"+pays+". Si l'instrument n'a pas changé de prix sur le site indiqué, il convient de l'acheter maintenant, conformément à votre demande. N'oubliez pas qu'il peut y avoir des frais suppplémentaires liés aux taxes et frais de tranports. A bientôt !" ;
     
     
    					    try {
     
    							Message message = new MimeMessage(session);
    							message.setFrom(new InternetAddress("monMail@gmail.com"));
    							message.setRecipients(Message.RecipientType.TO,
    								InternetAddress.parse(emailTo));
    							message.setSubject("Votre Instrument au prix voulu ");
    							message.setText(messageText);
     
    							Transport.send(message);
     
    							System.out.println("Message Envoyé AFS Prix le plus bas");
     
    						} catch (MessagingException e) {
    							throw new RuntimeException(e);
    						}
     
     
    					    try {
     
    							Connection connection = DataSourceProvider.getDataSource().getConnection();
    							PreparedStatement stmt = connection.prepareStatement("DELETE FROM inscription WHERE instrument=?");
    							stmt.setString(1, instrument);
    							stmt.executeUpdate();
    				            connection.close();
    						} catch (SQLException e) {
    							e.printStackTrace();
    						}
     
     
     
     
    					}
    					}
     
     
     
     
     
     
     
    		}
    		return 0;}}

  6. #6
    Membre Expert

    Profil pro
    Inscrit en
    Décembre 2011
    Messages
    974
    Détails du profil
    Informations personnelles :
    Localisation : France

    Informations forums :
    Inscription : Décembre 2011
    Messages : 974
    Par défaut
    sauf erreur de ma part, dans cette classe, tu ne parses pas le fichier xml.

    Code : Sélectionner tout - Visualiser dans une fenêtre à part
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
     
     
    @Stateless
    @LocalBean
    public class LectureDataXml {
     
    ..........
     
      @Schedule(minute="*/10", hour="*")
      public void lectureDataDixMinutes() {
     
          //lecture fichier XML
         // traitement suivant 
      }
        ......
    }

+ Répondre à la discussion
Cette discussion est résolue.

Discussions similaires

  1. Automatisation de tâche Outlook
    Par greg12 dans le forum Outlook
    Réponses: 5
    Dernier message: 26/06/2008, 09h13
  2. Automatiser les tâches Web avec Python
    Par mpereg dans le forum Réseau/Web
    Réponses: 8
    Dernier message: 07/06/2007, 22h49
  3. [debutant]-Automatiser des tâches
    Par petiteso dans le forum ANT
    Réponses: 1
    Dernier message: 26/01/2007, 14h07
  4. Automatiser une tâche
    Par Sun-Burst dans le forum Langage
    Réponses: 1
    Dernier message: 10/06/2006, 14h41
  5. [VB ou VBS]Macro d'automatisation de tâche
    Par letoulouzin31 dans le forum VBScript
    Réponses: 8
    Dernier message: 05/06/2006, 14h27

Partager

Partager
  • Envoyer la discussion sur Viadeo
  • Envoyer la discussion sur Twitter
  • Envoyer la discussion sur Google
  • Envoyer la discussion sur Facebook
  • Envoyer la discussion sur Digg
  • Envoyer la discussion sur Delicious
  • Envoyer la discussion sur MySpace
  • Envoyer la discussion sur Yahoo