Changeset b8dc761 for src/main/java/it/finki/charitable/util/AutomaticEvents.java

Timestamp:

01/05/22 15:57:29 (2 years ago)

Author:

NikolaCenevski <cenevskinikola@…>

Branches:

master

Children:

6fa3d09

Parents:

881a233

Message:

part 2

File:

• src/main/java/it/finki/charitable/util/AutomaticEvents.java (modified) (3 diffs)

src/main/java/it/finki/charitable/util/AutomaticEvents.java

@@ -2 +2 @@
 
 import it.finki.charitable.entities.AppUser;
+import it.finki.charitable.entities.DonationPost;
+import it.finki.charitable.entities.EmailMessage;
 import it.finki.charitable.security.ConfirmationToken;
-import it.finki.charitable.services.ConfirmationTokenService;
-import it.finki.charitable.services.UserService;
+import it.finki.charitable.services.*;
+import org.springframework.mail.SimpleMailMessage;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+import java.time.Duration;
+import java.time.LocalDate;
 import java.util.List;
+import java.util.stream.Collectors;
 
 @Component
@@ -15 +20 @@
     private final UserService userService;
     private final ConfirmationTokenService confirmationTokenService;
+    private final DonationPostService donationPostService;
+    private final EmailMessageService emailMessageService;
+    private final EmailService emailService;
 
-    public AutomaticEvents(UserService userService, ConfirmationTokenService confirmationTokenService) {
+    public AutomaticEvents(UserService userService, ConfirmationTokenService confirmationTokenService, DonationPostService donationPostService, EmailMessageService emailMessageService, EmailService emailService) {
         this.userService = userService;
         this.confirmationTokenService = confirmationTokenService;
+        this.donationPostService = donationPostService;
+        this.emailMessageService = emailMessageService;
+        this.emailService = emailService;
     }
 
@@ -32 +43 @@
         }
     }
+
+    @Scheduled(cron = "0 0 0 * * *")
+    public void setRisk() {
+        System.out.println("cron");
+        List<DonationPost> donationPosts = donationPostService.findAll();
+        donationPosts = donationPosts.stream().filter(post -> {
+            long daysToEnd = Duration.between(LocalDate.now().atTime(0, 0, 0), post.getDateDue().atTime(0, 0, 0)).toDays();
+            long totalDays = Duration.between(post.getCreatedAt().atTime(0, 0, 0), post.getDateDue().atTime(0, 0, 0)).toDays();
+            System.out.println(daysToEnd + " " + totalDays);
+
+            if(totalDays < 10)
+                return true;
+
+            return (daysToEnd * 1f/totalDays) * 100 < 75;
+        }).collect(Collectors.toList());
+
+        donationPosts.forEach(post -> {
+            float dailyAverage = post.getTotalFundsCollected() / (Duration.between(post.getCreatedAt().atTime(0, 0, 0), LocalDate.now().atTime(0, 0, 0)).toDays() + 1);
+            float neededAverage = (post.getFundsNeeded() - post.getTotalFundsCollected()) / (Duration.between(LocalDate.now().atTime(0, 0, 0), post.getDateDue().atTime(0, 0, 0)).toDays()+1);
+
+            System.out.println(dailyAverage + " " + neededAverage);
+            int risk = (int) (dailyAverage / neededAverage * 100);
+
+            if(risk > 100) {
+                risk = 100;
+            }
+
+            if(Duration.between(LocalDate.now().atTime(0, 0, 0), post.getDateDue().atTime(0, 0, 0)).toDays() == 0) {
+                risk = 0;
+            }
+
+            if(post.getFundsNeeded() <= post.getTotalFundsCollected()) {
+                risk = 101;
+            }
+
+            post.setRiskFactor(risk);
+            donationPostService.save(post);
+        });
+    }
+
+    @Scheduled(cron = "0 0 * * * *")
+    public void sendMessages() {
+        List<EmailMessage> messages = emailMessageService.findAll();
+        for(EmailMessage message: messages) {
+            SimpleMailMessage simpleMailMessage = new SimpleMailMessage();
+            simpleMailMessage.setTo(message.getSendTo());
+            simpleMailMessage.setSubject(message.getSubject());
+            simpleMailMessage.setText(message.getText());
+            emailService.sendMail(simpleMailMessage);
+            emailMessageService.delete(message);
+        }
+    }
 }