Merge pull request #14 from Ureca-QuickPick/feature/v3

Feature/v3

Author: sangyunpark99

.github/workflows/CI.yml

@@ -0,0 +1,62 @@
+name: CI FOR MVP
+
+on:
+  push:
+#    branches-ignore:
+#      - main
+#      - develop
+
+jobs:
+  CI:
+    name: Continuous Integration
+    runs-on: ubuntu-latest
+    permissions:
+      contents: read
+
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v4
+
+      - name: Set up JDK 17
+        uses: actions/setup-java@v4
+        with:
+          java-version: '17'
+          distribution: 'temurin'
+
+      - name: Setup MySQL
+        uses: mirromutth/[email protected]
+        with:
+          mysql database: 'testDB'
+          mysql user: 'test'
+          mysql password: 'testPW'
+
+      - name: Setup Gradle
+        uses: gradle/actions/setup-gradle@417ae3ccd767c252f5661f1ace9f835f9654f2b5
+
+      - name: Get short SHA
+        id: slug
+        run: echo "sha7=$(echo ${GITHUB_SHA} | cut -c1-7)" >> $GITHUB_OUTPUT
+
+      - name: Create application.properties
+        run: |
+          cat <<EOT > ./src/main/resources/application.properties
+          spring.application.name=ureca
+
+          spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
+          spring.datasource.url=jdbc:mysql://localhost:3306/testDB?characterEncoding=UTF-8&serverTimezone=Asia/Seoul
+          spring.datasource.username=test
+          spring.datasource.password=testPW
+
+          # spring jpa
+          spring.jpa.database=mysql
+          spring.jpa.properties.hibernate.show_sql=true
+          spring.jpa.hibernate.ddl-auto=create-drop
+          spring.jpa.properties.hibernate.format_sql=true
+          EOT
+        shell: bash
+
+      - name: Grant execute permission for gradlew
+        run: chmod +x ./gradlew
+
+      - name: Build with Gradle Wrapper
+        run: ./gradlew build

.gitignore

@@ -35,3 +35,5 @@ out/
 
 ### VS Code ###
 .vscode/
+
+/src/main/resources/application.properties

build.gradle

@@ -28,6 +28,11 @@ dependencies {
 	implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
 	implementation 'org.springframework.boot:spring-boot-starter-thymeleaf'
 	implementation 'org.springframework.boot:spring-boot-starter-web'
+	implementation 'org.springframework.boot:spring-boot-starter-data-redis'
+	implementation 'org.springframework.kafka:spring-kafka'
+	implementation 'com.fasterxml.jackson.core:jackson-databind'
+
+	testImplementation 'org.springframework.kafka:spring-kafka-test'
 	compileOnly 'org.projectlombok:lombok'
 	runtimeOnly 'com.mysql:mysql-connector-j'
 	annotationProcessor 'org.projectlombok:lombok'

gradlew

@@ -2,12 +2,14 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
+@EnableJpaAuditing
+@EnableScheduling
 public class UrecaApplication {
-
 	public static void main(String[] args) {
 		SpringApplication.run(UrecaApplication.class, args);
 	}
-
-}
+}

src/main/java/com/quickpick/ureca/UrecaApplication.java

@@ -0,0 +1,26 @@
+package com.quickpick.ureca.v3.common;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.EntityListeners;
+import jakarta.persistence.MappedSuperclass;
+import lombok.Getter;
+import org.springframework.data.annotation.CreatedDate;
+import org.springframework.data.annotation.LastModifiedDate;
+import org.springframework.data.jpa.domain.support.AuditingEntityListener;
+
+import java.time.LocalDateTime;
+
+@Getter
+@MappedSuperclass
+@EntityListeners(AuditingEntityListener.class)
+public abstract class BaseEntityV3 {
+    @CreatedDate
+    @Column(length = 6, name = "created_at", updatable = false)
+    private LocalDateTime createdAt;
+
+    @LastModifiedDate
+    @Column(length = 6, name = "updated_at")
+    private LocalDateTime updatedAt;
+
+}
+

src/main/java/com/quickpick/ureca/v3/common/BaseEntityV3.java

@@ -0,0 +1,24 @@
+package com.quickpick.ureca.v3.config;
+
+import com.quickpick.ureca.v3.ticket.event.TicketPurchaseEventV3;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
+import org.springframework.kafka.core.ConsumerFactory;
+
+@Configuration
+public class KafkaConsumerConfigV3 {
+
+    @Bean
+    public ConcurrentKafkaListenerContainerFactory<String, TicketPurchaseEventV3> batchFactory(
+            ConsumerFactory<String, TicketPurchaseEventV3> consumerFactory) {
+
+        ConcurrentKafkaListenerContainerFactory<String, TicketPurchaseEventV3> factory =
+                new ConcurrentKafkaListenerContainerFactory<>();
+
+        factory.setConsumerFactory(consumerFactory);
+        factory.setBatchListener(true); // 핵심
+        factory.setConcurrency(3);
+        return factory;
+    }
+}

src/main/java/com/quickpick/ureca/v3/config/KafkaConsumerConfigV3.java

@@ -0,0 +1,59 @@
+package com.quickpick.ureca.v3.init;
+
+import com.quickpick.ureca.v3.ticket.domain.TicketV3;
+import com.quickpick.ureca.v3.ticket.repository.RedisStockRepositoryV3;
+import com.quickpick.ureca.v3.ticket.repository.TicketRepositoryV3;
+import jakarta.transaction.Transactional;
+import lombok.RequiredArgsConstructor;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
+
+@RestController
+@RequestMapping("/v3/init")
+@RequiredArgsConstructor
+public class InitControllerV3 {
+
+    private final TicketRepositoryV3 ticketRepositoryV3;
+    private final RedisStockRepositoryV3 redisStockRepositoryV3;
+    private final JdbcTemplate jdbcTemplate;
+
+    @PostMapping
+    @Transactional
+    public void init() {
+
+        String sql = "INSERT INTO user (user_id, name, age, gender, password) VALUES (?, ?, ?, ?, ?)";
+        List<Object[]> batchArgs = new ArrayList<>();
+
+        for (long i = 1; i <= 10000; i++) {
+            batchArgs.add(new Object[]{
+                    i,
+                    "abc" + i,
+                    i+20,
+                    "MALE",
+                    "password" + i
+
+            });
+        }
+
+        jdbcTemplate.batchUpdate(sql, batchArgs);
+        System.out.println("=== 10만명 유저 생성 완료 ===");
+
+
+        TicketV3 ticketV3 = TicketV3.builder()
+                .name("ticket")
+                .quantity(3000L)
+                .reserveTime(LocalDateTime.now())
+                .startDate(LocalDate.now())
+                .build();
+
+        TicketV3 saveTicketV3 = ticketRepositoryV3.save(ticketV3);
+        redisStockRepositoryV3.setTicket(saveTicketV3.getId(), 3000L);
+    }
+}

src/main/java/com/quickpick/ureca/v3/init/InitControllerV3.java

@@ -0,0 +1,57 @@
+//package com.quickpick.ureca.v3.init;
+//
+//import com.quickpick.ureca.v3.ticket.domain.TicketV3;
+//import com.quickpick.ureca.v3.ticket.repository.RedisStockRepositoryV3;
+//import com.quickpick.ureca.v3.ticket.repository.TicketRepositoryV3;
+//import jakarta.transaction.Transactional;
+//import lombok.RequiredArgsConstructor;
+//import org.springframework.boot.CommandLineRunner;
+//import org.springframework.jdbc.core.JdbcTemplate;
+//import org.springframework.stereotype.Component;
+//
+//import java.time.LocalDate;
+//import java.time.LocalDateTime;
+//import java.util.ArrayList;
+//import java.util.List;
+//
+//@Component
+//@RequiredArgsConstructor
+//public class InitDataLoaderV3 implements CommandLineRunner {
+//
+//    private final TicketRepositoryV3 ticketRepositoryV3;
+//    private final RedisStockRepositoryV3 redisStockRepositoryV3;
+//    private final JdbcTemplate jdbcTemplate;
+//
+//    @Transactional
+//    @Override
+//    public void run(String... args) {
+//        String sql = "INSERT INTO user (user_id, name, age, gender, password) VALUES (?, ?, ?, ?, ?)";
+//
+//        List<Object[]> batchArgs = new ArrayList<>();
+//
+//        for (long i = 1; i <= 10000; i++) {
+//            batchArgs.add(new Object[]{
+//                    i,
+//                    "abc" + i,
+//                    i+20,
+//                    "MALE",
+//                    "password" + i
+//
+//            });
+//        }
+//
+//        jdbcTemplate.batchUpdate(sql, batchArgs);
+//        System.out.println("=== 10만명 유저 생성 완료 ===");
+//
+//
+//        TicketV3 ticketV3 = TicketV3.builder()
+//                .name("ticket")
+//                .quantity(3000L)
+//                .reserveTime(LocalDateTime.now())
+//                .startDate(LocalDate.now())
+//                .build();
+//
+//        TicketV3 saveTicketV3 = ticketRepositoryV3.save(ticketV3);
+//        redisStockRepositoryV3.setTicket(saveTicketV3.getId(), 3000L);
+//    }
+//}

src/main/java/com/quickpick/ureca/v3/init/InitDataLoaderV3.java

@@ -0,0 +1,5 @@
+package com.quickpick.ureca.v3.reserve.domain;
+
+public enum ReserveStatusV3 {
+    SUCCESS, FAIL
+}