From ae9c39f562250c61441bea8be7a72c1221dd3d92 Mon Sep 17 00:00:00 2001
From: alitpc25 <alitpc2525@gmail.com>
Date: Tue, 19 Dec 2023 14:42:02 +0300
Subject: [PATCH] #559 Recurrent need implementation.

---
 resq/backend/resq/pom.xml                     |  4 ++
 .../com/groupa1/resq/ResqApplication.java     |  2 +
 .../java/com/groupa1/resq/entity/Need.java    |  2 +
 .../groupa1/resq/jobs/RecurrentNeedJob.java   | 67 +++++++++++++++++++
 .../resq/repository/NeedRepository.java       |  2 +
 .../resq/request/CreateNeedRequest.java       |  1 +
 .../resq/request/UpdateNeedRequest.java       |  1 +
 .../com/groupa1/resq/service/NeedService.java |  2 +
 .../com/groupa1/resq/service/TaskService.java |  4 +-
 9 files changed, 83 insertions(+), 2 deletions(-)
 create mode 100644 resq/backend/resq/src/main/java/com/groupa1/resq/jobs/RecurrentNeedJob.java

diff --git a/resq/backend/resq/pom.xml b/resq/backend/resq/pom.xml
index 990bc3e6..11f8c4f5 100644
--- a/resq/backend/resq/pom.xml
+++ b/resq/backend/resq/pom.xml
@@ -82,6 +82,10 @@
 			<artifactId>commons-beanutils</artifactId>
 			<version>1.9.4</version>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-quartz</artifactId>
+		</dependency>
 		<!-- https://mvnrepository.com/artifact/com.google.firebase/firebase-admin
 		<dependency>
 			<groupId>com.google.firebase</groupId>
diff --git a/resq/backend/resq/src/main/java/com/groupa1/resq/ResqApplication.java b/resq/backend/resq/src/main/java/com/groupa1/resq/ResqApplication.java
index a3762509..ed3627df 100644
--- a/resq/backend/resq/src/main/java/com/groupa1/resq/ResqApplication.java
+++ b/resq/backend/resq/src/main/java/com/groupa1/resq/ResqApplication.java
@@ -2,8 +2,10 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
+@EnableScheduling
 public class ResqApplication {
 
 	public static void main(String[] args) {
diff --git a/resq/backend/resq/src/main/java/com/groupa1/resq/entity/Need.java b/resq/backend/resq/src/main/java/com/groupa1/resq/entity/Need.java
index acfe4f25..f2bcaf02 100644
--- a/resq/backend/resq/src/main/java/com/groupa1/resq/entity/Need.java
+++ b/resq/backend/resq/src/main/java/com/groupa1/resq/entity/Need.java
@@ -50,4 +50,6 @@ public class Need extends BaseEntity{
     @Enumerated(EnumType.STRING)
     private ENeedStatus status;
 
+    private Boolean isRecurrent;
+
 }
diff --git a/resq/backend/resq/src/main/java/com/groupa1/resq/jobs/RecurrentNeedJob.java b/resq/backend/resq/src/main/java/com/groupa1/resq/jobs/RecurrentNeedJob.java
new file mode 100644
index 00000000..f73a53f7
--- /dev/null
+++ b/resq/backend/resq/src/main/java/com/groupa1/resq/jobs/RecurrentNeedJob.java
@@ -0,0 +1,67 @@
+package com.groupa1.resq.jobs;
+
+import com.groupa1.resq.entity.Need;
+import com.groupa1.resq.entity.Request;
+import com.groupa1.resq.entity.enums.ENeedStatus;
+import com.groupa1.resq.repository.NeedRepository;
+import com.groupa1.resq.repository.RequestRepository;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+
+import java.util.HashSet;
+
+@Service
+@Slf4j
+public class RecurrentNeedJob {
+
+    @Autowired
+    private NeedRepository needRepository;
+
+    @Autowired
+    private RequestRepository requestRepository;
+
+    // will be open later
+    //@Scheduled(cron = "0 0 8 * * ?")
+    public void run() {
+        // This job will create a request consisting of recurrent needs every day.
+        HashSet<Request> requests = new HashSet<>();
+        needRepository.findAllByIsRecurrentTrue().forEach(need -> {
+            Request request = need.getRequest();
+            if(!requests.contains(request)) {
+                Request newRequest = new Request();
+                newRequest.setNeeds(new HashSet<>());
+                newRequest.setRequester(request.getRequester());
+                newRequest.setDescription(request.getDescription());
+                newRequest.setLongitude(request.getLongitude());
+                newRequest.setLatitude(request.getLatitude());
+                newRequest.setUrgency(request.getUrgency());
+                newRequest.setStatus(request.getStatus());
+
+                request.getNeeds().forEach(need1 -> {
+                    if (need1.getIsRecurrent()) {
+                        Need newNeed = new Need();
+                        newNeed.setIsRecurrent(false);
+                        newNeed.setLatitude(need1.getLatitude());
+                        newNeed.setLongitude(need1.getLongitude());
+                        newNeed.setQuantity(need1.getQuantity());
+                        newNeed.setSize(need1.getSize());
+                        newNeed.setDescription(need1.getDescription());
+                        newNeed.setStatus(ENeedStatus.NOT_INVOLVED);
+                        newNeed.setRequester(need1.getRequester());
+                        newNeed.setCategoryTreeId(need1.getCategoryTreeId());
+                        newNeed.setRequest(newRequest);
+                        needRepository.save(newNeed);
+                        newRequest.getNeeds().add(newNeed);
+                    }
+
+                });
+                requests.add(request);
+                requestRepository.save(newRequest);
+            }
+        });
+        log.info("Recurrent Need Job");
+        System.out.println("Recurrent Need Job");
+    }
+}
diff --git a/resq/backend/resq/src/main/java/com/groupa1/resq/repository/NeedRepository.java b/resq/backend/resq/src/main/java/com/groupa1/resq/repository/NeedRepository.java
index 0d9f7625..de8ca1e5 100644
--- a/resq/backend/resq/src/main/java/com/groupa1/resq/repository/NeedRepository.java
+++ b/resq/backend/resq/src/main/java/com/groupa1/resq/repository/NeedRepository.java
@@ -20,6 +20,8 @@ public interface NeedRepository extends JpaRepository<Need, Long> {
 
     List<Need> findAll(Specification<Need> specification);
 
+    List<Need> findAllByIsRecurrentTrue();
+
 
     //Haversine formula
     @Query(value = "SELECT * FROM NEED WHERE (6371 * acos(cos(radians(?1)) * cos(radians(latitude)) * cos(radians(longitude) - radians(?2)) + sin(radians(?1)) * sin(radians(latitude)))) < ?3", nativeQuery = true)
diff --git a/resq/backend/resq/src/main/java/com/groupa1/resq/request/CreateNeedRequest.java b/resq/backend/resq/src/main/java/com/groupa1/resq/request/CreateNeedRequest.java
index e388f353..d511d019 100644
--- a/resq/backend/resq/src/main/java/com/groupa1/resq/request/CreateNeedRequest.java
+++ b/resq/backend/resq/src/main/java/com/groupa1/resq/request/CreateNeedRequest.java
@@ -12,4 +12,5 @@ public class CreateNeedRequest {
     private String categoryTreeId;
     private Integer quantity;
     private String size;
+    private Boolean isRecurrent;
 }
diff --git a/resq/backend/resq/src/main/java/com/groupa1/resq/request/UpdateNeedRequest.java b/resq/backend/resq/src/main/java/com/groupa1/resq/request/UpdateNeedRequest.java
index a4b30e93..4777c52f 100644
--- a/resq/backend/resq/src/main/java/com/groupa1/resq/request/UpdateNeedRequest.java
+++ b/resq/backend/resq/src/main/java/com/groupa1/resq/request/UpdateNeedRequest.java
@@ -12,4 +12,5 @@ public class UpdateNeedRequest {
     private String categoryTreeId;
     private Integer quantity;
     private String size;
+    private Boolean isRecurent;
 }
diff --git a/resq/backend/resq/src/main/java/com/groupa1/resq/service/NeedService.java b/resq/backend/resq/src/main/java/com/groupa1/resq/service/NeedService.java
index 03c4899b..4631a32f 100644
--- a/resq/backend/resq/src/main/java/com/groupa1/resq/service/NeedService.java
+++ b/resq/backend/resq/src/main/java/com/groupa1/resq/service/NeedService.java
@@ -58,6 +58,7 @@ public Long save(Long userId, CreateNeedRequest createNeedRequest) {
         need.setCategoryTreeId(createNeedRequest.getCategoryTreeId());
         need.setSize(ESize.valueOf(createNeedRequest.getSize()));
         need.setStatus(ENeedStatus.NOT_INVOLVED);
+        need.setIsRecurrent(createNeedRequest.getIsRecurrent());
         return needRepository.save(need).getId();
 
     }
@@ -105,6 +106,7 @@ public ResponseEntity<String> update (UpdateNeedRequest updateNeedRequest, Long
         need.setQuantity(updateNeedRequest.getQuantity());
         need.setCategoryTreeId(updateNeedRequest.getCategoryTreeId());
         need.setSize(ESize.valueOf(updateNeedRequest.getSize()));
+        need.setIsRecurrent(updateNeedRequest.getIsRecurent());
         needRepository.save(need);
         return ResponseEntity.ok("Need updated successfully");
     }
diff --git a/resq/backend/resq/src/main/java/com/groupa1/resq/service/TaskService.java b/resq/backend/resq/src/main/java/com/groupa1/resq/service/TaskService.java
index e5908e15..560795c4 100644
--- a/resq/backend/resq/src/main/java/com/groupa1/resq/service/TaskService.java
+++ b/resq/backend/resq/src/main/java/com/groupa1/resq/service/TaskService.java
@@ -186,7 +186,7 @@ public ResponseEntity<List<TaskResponse>> viewAllTasks(Long userId) {
                 task.getResources().forEach(resource -> {
 
                 resourceResponse.setId(resource.getId())
-                        .setSender(resource.getSender()) // may change to resource.getOwner().getId()
+                        .setSenderId(resource.getSender().getId()) // may change to resource.getOwner().getId()
                         .setQuantity(resource.getQuantity())
                         .setGender(resource.getGender())
                         .setCategoryId(resource.getCategoryTreeId())
@@ -331,7 +331,7 @@ public ResponseEntity<List<TaskResponse>> viewTaskByFilter(Long assignerId, Long
             resources.forEach( resource -> {
                 ResourceResponse resourceResponse = new ResourceResponse();
                 resourceResponse.setId(resource.getId())
-                        .setSender(resource.getSender())
+                        .setSenderId(resource.getSender().getId())
                         .setQuantity(resource.getQuantity())
                         .setCategoryId(resource.getCategoryTreeId())
                         .setGender(resource.getGender())