Feat : 알림 api 생성

server2/build.gradle

@@ -37,6 +37,7 @@ subprojects { // 각 모듈에 적용할 공통 설정
         testImplementation 'org.springframework.boot:spring-boot-starter-test'
         testImplementation 'org.springframework.amqp:spring-rabbit-test'
         testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
+        implementation 'org.springframework.boot:spring-boot-starter-data-mongodb'
     }
 
     tasks.named('bootJar') { //빌드할 때 bootjar 파일로 하겠다는 의미

server2/server-common/src/main/java/sinhan/server1/Server3Application.java → server2/server-child/src/main/java/shinhan/server_child/ServerChildApplication.java

@@ -1,18 +1,18 @@
-package sinhan.server1;
-
+package shinhan.server_child;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import shinhan.server_common.ServerCommonApplication;
 
-@SpringBootApplication(scanBasePackages = {"server-child", "server-parent"})
-public class Server3Application {
+@SpringBootApplication(scanBasePackages = {"shinhan.server_child", "shinhan.server_common"})
+public class ServerChildApplication {
 
     public static void main(String[] args) {
-        SpringApplication.run(Server3Application.class, args);
+        SpringApplication.run(ServerCommonApplication.class, args);
     }
 
 //    @RabbitListener(queues = "hello")
 //    public void listen(String message) {
 //        System.out.println("Received: " + message);
 //    }
-}
+}

server2/server-child/src/main/java/sinhan/server1/domain/AccountController.java → server2/server-child/src/main/java/shinhan/server_child/domain/AccountController.java

@@ -1,4 +1,4 @@
-package sinhan.server1.domain;
+package shinhan.server_child.domain;
 
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RestController;

server2/server-child/src/test/java/sinhan/server1/Server3ApplicationTests.java → server2/server-child/src/test/java/shinhan/server1/ServerCommonApplicationTests.java

@@ -1,10 +1,10 @@
-package sinhan.server1;
+package shinhan.server1;
 
 import org.junit.jupiter.api.Test;
 import org.springframework.boot.test.context.SpringBootTest;
 
 @SpringBootTest
-class Server3ApplicationTests {
+class ServerCommonApplicationTests {
 
     @Test
     void contextLoads() {

server2/server-common/build.gradle

@@ -26,6 +26,10 @@ subprojects { // 각 모듈에 적용할 공통 설정
     apply plugin: 'org.springframework.boot'
     apply plugin: 'io.spring.dependency-management'
 
+//    dependencies {
+//        implementation 'org.springframework.boot:spring-boot-starter-data-mongodb'
+//    }
+
     tasks.named('bootJar') { //빌드할 때 bootjar 파일로 하겠다는 의미
         enabled = false
     }

server2/server-common/src/main/java/shinhan/server_common/ServerCommonApplication.java

@@ -0,0 +1,28 @@
+package shinhan.server_common;
+
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.FilterType;
+import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
+import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
+import shinhan.server_common.notification.mongo.NotificationRepository;
+
+// common
+@SpringBootApplication//(scanBasePackages = {"server-child", "server-parent"})
+@EnableJpaRepositories(excludeFilters = @ComponentScan.Filter(
+        type = FilterType.ASSIGNABLE_TYPE,
+        classes = NotificationRepository.class))
+@EnableMongoRepositories(basePackages = {"shinhan.server_common.notification.mongo"})
+public class ServerCommonApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(ServerCommonApplication.class, args);
+    }
+
+//    @RabbitListener(queues = "hello")
+//    public void listen(String message) {
+//        System.out.println("Received: " + message);
+//    }
+}

server2/server-common/src/main/java/sinhan/server1/domain/invest/controller/DartController.java → server2/server-common/src/main/java/shinhan/server_common/domain/invest/controller/DartController.java

@@ -1,12 +1,12 @@
-package sinhan.server1.domain.invest.controller;
+package shinhan.server_common.domain.invest.controller;
 
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RestController;
-import sinhan.server1.domain.invest.dto.StockFindDetailResponseDTO;
-import sinhan.server1.domain.invest.service.StockService;
-import sinhan.server1.domain.utils.ApiResult;
+import shinhan.server_common.domain.invest.dto.StockFindDetailResponseDTO;
+import shinhan.server_common.domain.invest.service.StockService;
+import shinhan.server_common.global.utils.ApiResult;
 
 @RestController
 public class DartController {

server2/server-common/src/main/java/sinhan/server1/domain/invest/controller/InvestController.java → server2/server-common/src/main/java/shinhan/server_common/domain/invest/controller/InvestController.java

@@ -1,9 +1,9 @@
-package sinhan.server1.domain.invest.controller;
+package shinhan.server_common.domain.invest.controller;
 
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.PostMapping;
-import sinhan.server1.domain.utils.ApiResult;
+import shinhan.server_common.global.utils.ApiResult;
 
 public class InvestController {
     //투자 거래 내역 조회하기(부모)

server2/server-common/src/main/java/sinhan/server1/domain/invest/controller/ProposalController.java → server2/server-common/src/main/java/shinhan/server_common/domain/invest/controller/ProposalController.java

@@ -1,4 +1,4 @@
-package sinhan.server1.domain.invest.controller;
+package shinhan.server_common.domain.invest.controller;
 
 
 import lombok.extern.slf4j.Slf4j;
@@ -7,14 +7,14 @@
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
-import sinhan.server1.domain.utils.ApiResult;
+import shinhan.server_common.global.utils.ApiResult;
 
 @RestController
 @Slf4j
 public class ProposalController {
     //투자 제안 내역 달변 조회하기(부모)
     @GetMapping("/proposal/invest/history/{co}")
-    public ApiResult getChildInvestProposal(@RequestParam("year") int year,@RequestParam("month") int month,@PathVariable("co") int childOrder){
+    public ApiResult getChildInvestProposal(@RequestParam("year") int year, @RequestParam("month") int month, @PathVariable("co") int childOrder){
         ApiResult<Integer> stringApiResult = ApiResult.responseSuccess(childOrder);
         return stringApiResult;
     }

server2/server-common/src/main/java/sinhan/server1/domain/invest/controller/StockController.java → server2/server-common/src/main/java/shinhan/server_common/domain/invest/controller/StockController.java

@@ -1,4 +1,4 @@
-package sinhan.server1.domain.invest.controller;
+package shinhan.server_common.domain.invest.controller;
 
 
 import org.springframework.web.bind.annotation.DeleteMapping;
@@ -7,8 +7,8 @@
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
-import sinhan.server1.domain.invest.service.StockService;
-import sinhan.server1.domain.utils.ApiResult;
+import shinhan.server_common.domain.invest.service.StockService;
+import shinhan.server_common.global.utils.ApiResult;
 
 @RestController
 public class StockController {

server2/server-common/src/main/java/sinhan/server1/domain/invest/dto/StockFindDetailResponseDTO.java → server2/server-common/src/main/java/shinhan/server_common/domain/invest/dto/StockFindDetailResponseDTO.java

@@ -1,4 +1,4 @@
-package sinhan.server1.domain.invest.dto;
+package shinhan.server_common.domain.invest.dto;
 
 import java.util.List;
 import lombok.AllArgsConstructor;
@@ -7,7 +7,7 @@
 import lombok.Getter;
 import lombok.NoArgsConstructor;
 import lombok.Setter;
-import sinhan.server1.domain.invest.entity.StockCartDate;
+import shinhan.server_common.domain.invest.entity.StockCartDate;
 
 @Getter
 @Setter

server2/server-common/src/main/java/sinhan/server1/domain/invest/entity/StockCartDate.java → server2/server-common/src/main/java/shinhan/server_common/domain/invest/entity/StockCartDate.java

@@ -1,4 +1,4 @@
-package sinhan.server1.domain.invest.entity;
+package shinhan.server_common.domain.invest.entity;
 
 import com.fasterxml.jackson.databind.PropertyNamingStrategy;
 import com.fasterxml.jackson.databind.annotation.JsonNaming;

server2/server-common/src/main/java/sinhan/server1/domain/invest/entity/StockCurrentDetail.java → server2/server-common/src/main/java/shinhan/server_common/domain/invest/entity/StockCurrentDetail.java

@@ -1,4 +1,4 @@
-package sinhan.server1.domain.invest.entity;
+package shinhan.server_common.domain.invest.entity;
 
 import com.fasterxml.jackson.databind.PropertyNamingStrategy;
 import com.fasterxml.jackson.databind.annotation.JsonNaming;

server2/server-common/src/main/java/sinhan/server1/domain/invest/entity/StockCurrentPriceOutput.java → server2/server-common/src/main/java/shinhan/server_common/domain/invest/entity/StockCurrentPriceOutput.java

@@ -1,4 +1,4 @@
-package sinhan.server1.domain.invest.entity;
+package shinhan.server_common.domain.invest.entity;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.fasterxml.jackson.databind.PropertyNamingStrategy;

server2/server-common/src/main/java/sinhan/server1/domain/invest/entity/StockDivideDetail.java → server2/server-common/src/main/java/shinhan/server_common/domain/invest/entity/StockDivideDetail.java

@@ -1,4 +1,4 @@
-package sinhan.server1.domain.invest.entity;
+package shinhan.server_common.domain.invest.entity;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.fasterxml.jackson.databind.PropertyNamingStrategy;

server2/server-common/src/main/java/sinhan/server1/domain/invest/entity/StockDivideOutput.java → server2/server-common/src/main/java/shinhan/server_common/domain/invest/entity/StockDivideOutput.java

@@ -1,4 +1,4 @@
-package sinhan.server1.domain.invest.entity;
+package shinhan.server_common.domain.invest.entity;
 
 
 import com.fasterxml.jackson.databind.PropertyNamingStrategy;

server2/server-common/src/main/java/sinhan/server1/domain/invest/entity/StockDuraionPriceOutput.java → server2/server-common/src/main/java/shinhan/server_common/domain/invest/entity/StockDuraionPriceOutput.java

@@ -1,4 +1,4 @@
-package sinhan.server1.domain.invest.entity;
+package shinhan.server_common.domain.invest.entity;
 
 import java.util.List;
 import lombok.Data;

server2/server-common/src/main/java/sinhan/server1/domain/invest/entity/StockDurationDetail.java → server2/server-common/src/main/java/shinhan/server_common/domain/invest/entity/StockDurationDetail.java

@@ -1,4 +1,4 @@
-package sinhan.server1.domain.invest.entity;
+package shinhan.server_common.domain.invest.entity;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.fasterxml.jackson.databind.PropertyNamingStrategy;

server2/server-common/src/main/java/sinhan/server1/domain/invest/entity/StockFianceDetail.java → server2/server-common/src/main/java/shinhan/server_common/domain/invest/entity/StockFianceDetail.java

@@ -1,4 +1,4 @@
-package sinhan.server1.domain.invest.entity;
+package shinhan.server_common.domain.invest.entity;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.fasterxml.jackson.databind.annotation.JsonNaming;

server2/server-common/src/main/java/sinhan/server1/domain/invest/entity/StockFianceResponseOutput.java → server2/server-common/src/main/java/shinhan/server_common/domain/invest/entity/StockFianceResponseOutput.java

@@ -1,4 +1,4 @@
-package sinhan.server1.domain.invest.entity;
+package shinhan.server_common.domain.invest.entity;
 
 import com.fasterxml.jackson.databind.annotation.JsonNaming;
 import java.util.List;

server2/server-common/src/main/java/sinhan/server1/domain/invest/repository/StockRepository.java → server2/server-common/src/main/java/shinhan/server_common/domain/invest/repository/StockRepository.java

@@ -1,4 +1,4 @@
-package sinhan.server1.domain.invest.repository;
+package shinhan.server_common.domain.invest.repository;
 
 import org.springframework.stereotype.Service;
 

server2/server-common/src/main/java/sinhan/server1/domain/invest/service/StockService.java → server2/server-common/src/main/java/shinhan/server_common/domain/invest/service/StockService.java

@@ -1,4 +1,4 @@
-package sinhan.server1.domain.invest.service;
+package shinhan.server_common.domain.invest.service;
 
 import java.net.URI;
 import java.text.SimpleDateFormat;
@@ -8,11 +8,11 @@
 import org.springframework.web.reactive.function.client.WebClient;
 import org.springframework.web.util.UriBuilder;
 import reactor.core.publisher.Mono;
-import sinhan.server1.domain.invest.dto.StockFindDetailResponseDTO;
-import sinhan.server1.domain.invest.entity.StockDivideOutput;
-import sinhan.server1.domain.invest.entity.StockDuraionPriceOutput;
-import sinhan.server1.domain.invest.entity.StockFianceResponseOutput;
-import sinhan.server1.domain.invest.repository.StockRepository;
+import shinhan.server_common.domain.invest.dto.StockFindDetailResponseDTO;
+import shinhan.server_common.domain.invest.entity.StockDivideOutput;
+import shinhan.server_common.domain.invest.entity.StockDuraionPriceOutput;
+import shinhan.server_common.domain.invest.entity.StockFianceResponseOutput;
+import shinhan.server_common.domain.invest.repository.StockRepository;
 
 @Service
 public class StockService {

server2/server-common/src/main/java/shinhan/server_common/domain/tempuser/TempUser.java

@@ -0,0 +1,27 @@
+package shinhan.server_common.domain.tempuser;
+
+import jakarta.persistence.*;
+import lombok.AccessLevel;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class TempUser {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    int id;
+
+    @Column(name = "serial_num", unique = true)
+    Long serialNumber;
+
+    String name;
+
+    @Builder
+    public TempUser( Long serialNumber, String name) {
+        this.serialNumber = serialNumber;
+        this.name = name;
+    }
+}

server2/server-common/src/main/java/shinhan/server_common/domain/tempuser/TempUserRepository.java

@@ -0,0 +1,7 @@
+package shinhan.server_common.domain.tempuser;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface TempUserRepository extends JpaRepository<TempUser,Integer> {
+    TempUser findBySerialNumber(Long serialNumber);
+}

server2/server-common/src/main/java/sinhan/server1/global/config/WebClientCongif.java → server2/server-common/src/main/java/shinhan/server_common/global/config/WebClientCongif.java

@@ -1,4 +1,4 @@
-package sinhan.server1.global.config;
+package shinhan.server_common.global.config;
 
 import io.netty.channel.ChannelOption;
 import org.springframework.beans.factory.annotation.Value;

server2/server-common/src/main/java/shinhan/server_common/global/exception/CustomException.java

@@ -0,0 +1,12 @@
+package shinhan.server_common.global.exception;
+
+import lombok.Getter;
+
+@Getter
+public class CustomException extends RuntimeException {
+    private final ErrorCode errorCode;
+    public CustomException(ErrorCode errorCode) {
+        super(errorCode.getMessage());
+        this.errorCode = errorCode;
+    }
+}

server2/server-common/src/main/java/shinhan/server_common/global/exception/CustomExceptionHandler.java

@@ -0,0 +1,31 @@
+package shinhan.server_common.global.exception;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.validation.FieldError;
+import org.springframework.web.bind.MethodArgumentNotValidException;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+
+@Slf4j
+@RestControllerAdvice
+public class CustomExceptionHandler {
+
+    @ExceptionHandler
+    protected ResponseEntity<ErrorResponse> handleCustomException(CustomException e) {
+        return ErrorResponse.toResponseEntity(e);
+    }
+
+    // bean validation 관련 에러
+    @ExceptionHandler(MethodArgumentNotValidException.class)
+    protected ResponseEntity<ErrorResponse> handleMethodArgumentNotValidException(MethodArgumentNotValidException e) {
+
+        FieldError fieldError = e.getFieldError();
+
+        log.info(fieldError.toString());
+        return ErrorResponse.toResponseEntity(HttpStatus.BAD_REQUEST, fieldError);
+    }
+
+
+}

server2/server-common/src/main/java/shinhan/server_common/global/exception/ErrorCode.java

@@ -0,0 +1,24 @@
+package shinhan.server_common.global.exception;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import org.springframework.http.HttpStatus;
+
+@Getter
+@AllArgsConstructor
+public enum ErrorCode {
+
+    //유저 예외
+    NOT_FOUND_USER(HttpStatus.NOT_FOUND, "해당 유저를 찾을 수 없습니다."),
+
+    //용돈 예외
+    NOT_FOUND_TEMPORAL_ALLOWANCE(HttpStatus.NOT_FOUND, "해당되는 용돈 조르기가 없습니다."),
+
+    //알람 예외
+    FAILED_NOTIFICATION(HttpStatus.CONFLICT, "알람 보내기에 실패했습니다."),
+
+    NOT_FOUND_MESSAGECODE(HttpStatus.NOT_FOUND, "저장된 알림 메세지 형식을 찾을 수 없습니다.");
+
+    private final HttpStatus status;
+    private final String message;
+}