80000Coding · ChanHoHan · Aug 24, 2023 · Sep 3, 2023 · Sep 3, 2023 · Sep 3, 2023
diff --git a/build.gradle b/build.gradle
@@ -30,11 +30,12 @@ dependencies {
 	implementation 'org.springframework.boot:spring-boot-starter-jdbc'
 	implementation 'org.springframework.boot:spring-boot-starter-data-redis'
 	implementation 'com.jcraft:jsch:0.1.55'
+	implementation 'org.springframework.boot:spring-boot-starter-mail'
 	implementation 'org.springframework.boot:spring-boot-starter-data-redis'
 
-
 	implementation 'org.springdoc:springdoc-openapi-starter-webmvc-ui:2.1.0'
 	implementation 'org.springframework.boot:spring-boot-starter-validation'
+	implementation 'com.fasterxml.jackson.datatype:jackson-datatype-jsr310'
 
 	// jwt
 	implementation group: 'io.jsonwebtoken', name: 'jjwt-api', version: '0.11.5'

diff --git a/src/main/java/io/oopy/coding/common/config/RedisConfig.java b/src/main/java/io/oopy/coding/common/config/RedisConfig.java
@@ -1,13 +1,17 @@
 package io.oopy.coding.common.config;
 
+import io.oopy.coding.common.redis.organizationcert.OrganizationCertification;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.data.redis.connection.RedisConnectionFactory;
 import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
 import org.springframework.data.redis.connection.lettuce.LettuceClientConfiguration;
 import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.data.redis.repository.configuration.EnableRedisRepositories;
+import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
 
 @Configuration
 @EnableRedisRepositories
@@ -24,4 +28,13 @@ public RedisConnectionFactory redisConnectionFactory() {
         LettuceClientConfiguration clientConfig = LettuceClientConfiguration.builder().build();
         return new LettuceConnectionFactory(config, clientConfig);
     }
+
+    @Bean
+    public RedisTemplate<String, OrganizationCertification> redisTemplate() {
+        RedisTemplate<String, OrganizationCertification> redisTemplate = new RedisTemplate<>();
+        redisTemplate.setConnectionFactory(redisConnectionFactory());
+        redisTemplate.setKeySerializer(new StringRedisSerializer());   // Key: String
+        redisTemplate.setValueSerializer(new Jackson2JsonRedisSerializer<>(OrganizationCertification.class));  // Value: 직렬화에 사용할 Object 사용하기
+        return redisTemplate;
+    }
 }
diff --git a/src/main/java/io/oopy/coding/common/config/security/SecurityConfig.java b/src/main/java/io/oopy/coding/common/config/security/SecurityConfig.java
@@ -42,7 +42,8 @@ public class SecurityConfig {
             "/api/v1/auth/login/**", "/api/v1/auth/signup",
             "/api/v1/contents/get", "api/v1/comments/get",
             "/api/v1/profile/**",
-            "/login/oauth2/**", "/api/v1/feed/title", "/api/v1/feed/body", "/api/v1/feed/nickname"
+            "/login/oauth2/**", "/api/v1/feed/title", "/api/v1/feed/body",
+            "/api/v1/email-cert/cert/**", "/api/v1/feed/nickname"
     };
 
     @Bean

diff --git a/src/main/java/io/oopy/coding/common/constant/EmailConstant.java b/src/main/java/io/oopy/coding/common/constant/EmailConstant.java
@@ -0,0 +1,41 @@
+package io.oopy.coding.common.constant;
+
+import lombok.AccessLevel;
+import lombok.NoArgsConstructor;
+
+@NoArgsConstructor(access = AccessLevel.PRIVATE)
+public class EmailConstant {
+    public static final Integer EMAIL_EXPIRED_PERIOD_SECONDS = 600; // 임시 10분
+    public static final String CERT_TITLE = String.format("[%s] 조직 이메일 인증", GlobalConstant.PROJECT_NAME);
+    public static final String CERT_CONTENT = "<head>\n" +
+            "<meta charset=\"UTF-8\">\n" +
+            "<meta name=\"viewport\" content=\"width=device-width, initial-scale=1.0\">\n" +
+            "<style>\n" +
+            "  .link-button {\n" +
+            "    display: inline-block;\n" +
+            "    padding: 10px 20px;\n" +
+            "    background-color: #3498db;\n" +
+            "    color: #fff;\n" +
+            "    text-align: center;\n" +
+            "    text-decoration: none;\n" +
+            "    border-radius: 5px;\n" +
+            "    border: none;\n" +
+            "    cursor: pointer;\n" +
+            "    transition: background-color 0.3s;\n" +
+            "    cursor: pointer\n"+
+            "  }\n" +
+            "  .text-color {\n" +
+            "    color: #fff;\n" +
+            "  }\n" +
+            "\n" +
+            "  .link-button:hover {\n" +
+            "    background-color: #2980b9;\n" +
+            "  }\n" +
+            "</style>\n" +
+            "</head>\n" +
+            "<body>\n" +
+            "<a href=%s/api/v1/email-cert/cert/%s/%s/%s target=\"_blank\" class=\"link-button\"><div class=\"text-color\">인증하기</div></a>\n" +
+            "\n" +
+            "</body>\n" +
+            "</html>";
+}
diff --git a/src/main/java/io/oopy/coding/common/constant/GlobalConstant.java b/src/main/java/io/oopy/coding/common/constant/GlobalConstant.java
@@ -0,0 +1,9 @@
+package io.oopy.coding.common.constant;
+
+import lombok.AccessLevel;
+import lombok.NoArgsConstructor;
+
+@NoArgsConstructor(access = AccessLevel.PRIVATE)
+public class GlobalConstant {
+    public static final String PROJECT_NAME = "팔만코딩경";
+}
diff --git a/src/main/java/io/oopy/coding/common/email/dto/EmailSend.java b/src/main/java/io/oopy/coding/common/email/dto/EmailSend.java
@@ -0,0 +1,22 @@
+package io.oopy.coding.common.email.dto;
+
+import lombok.*;
+
+@Getter
+@AllArgsConstructor(access = AccessLevel.PROTECTED)
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+public class EmailSend {
+
+    private String targetEmail;
+    @Setter
+    private String title;
+    @Setter
+    private String content;
+
+    public static EmailSend of(String targetEmail, String title, String content) {
+        return new EmailSend(targetEmail,
+                title,
+                content
+        );
+    }
+}
diff --git a/src/main/java/io/oopy/coding/common/email/service/EmailService.java b/src/main/java/io/oopy/coding/common/email/service/EmailService.java
@@ -0,0 +1,29 @@
+package io.oopy.coding.common.email.service;
+
+import io.oopy.coding.common.email.dto.EmailSend;
+import jakarta.mail.Message;
+import jakarta.mail.MessagingException;
+import jakarta.mail.internet.MimeMessage;
+import lombok.RequiredArgsConstructor;
+import org.springframework.mail.javamail.JavaMailSender;
+import org.springframework.stereotype.Service;
+
+/**
+ * email db를 만들 가능성이 있으므로, service
+ */
+@Service
+@RequiredArgsConstructor
+public class EmailService {
+
+    private final JavaMailSender javaMailSender;
+    private static final String MAIL_CHARACTER_SET = "utf-8";
+    private static final String MAIL_SUB_TYPE = "html";
+
+    public void sendMail(EmailSend emailSend) throws MessagingException {
+        MimeMessage message = javaMailSender.createMimeMessage();
+        message.addRecipients(Message.RecipientType.TO, emailSend.getTargetEmail());
+        message.setSubject(emailSend.getTitle());
+        message.setText(emailSend.getContent(), MAIL_CHARACTER_SET, MAIL_SUB_TYPE);
+        javaMailSender.send(message);
+    }
+}
diff --git a/src/main/java/io/oopy/coding/common/redis/organizationcert/OrganizationCertification.java b/src/main/java/io/oopy/coding/common/redis/organizationcert/OrganizationCertification.java
@@ -0,0 +1,48 @@
+package io.oopy.coding.common.redis.organizationcert;
+
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateTimeDeserializer;
+import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateTimeSerializer;
+import lombok.*;
+
+import java.time.LocalDateTime;
+import java.time.temporal.ChronoUnit;
+
+@Getter
+@NoArgsConstructor
+@AllArgsConstructor(access = AccessLevel.PRIVATE)
+@EqualsAndHashCode
+public class OrganizationCertification {
+
+    private String id;
+    private String certToken;
+    private String userEmail;
+    private String organizationCode;
+    private String organizationName;
+    @JsonSerialize(using = LocalDateTimeSerializer.class)
+    @JsonDeserialize(using = LocalDateTimeDeserializer.class)
+    private LocalDateTime expiredAt;
+    private Boolean expired;
+
+    @Builder
+    private OrganizationCertification(String certToken, String id, String userEmail,
+                                      String organizationCode, String organizationName, long ttl) {
+        this.certToken = certToken;
+        this.id = id;
+        this.userEmail = userEmail;
+        this.organizationCode = organizationCode;
+        this.organizationName = organizationName;
+        this.expiredAt = LocalDateTime.now().plus(ttl, ChronoUnit.SECONDS);
+    }
+
+    public static OrganizationCertification of(String certToken, String id, String userEmail,
+                                               String organizationCode, String organizationName, long ttl) {
+        return new OrganizationCertification(certToken, id, userEmail,
+                                             organizationCode, organizationName, ttl);
+    }
+
+    public boolean isExpired() {
+        return this.expiredAt.isAfter(LocalDateTime.now());
+    }
+}
diff --git a/...ava/io/oopy/coding/common/redis/organizationcert/OrganizationCertificationRepository.java b/...ava/io/oopy/coding/common/redis/organizationcert/OrganizationCertificationRepository.java
@@ -0,0 +1,6 @@
+package io.oopy.coding.common.redis.organizationcert;
+
+import org.springframework.data.repository.CrudRepository;
+
+public interface OrganizationCertificationRepository extends CrudRepository<OrganizationCertification, String> {
+}
diff --git a/...n/java/io/oopy/coding/common/redis/organizationcert/OrganizationCertificationService.java b/...n/java/io/oopy/coding/common/redis/organizationcert/OrganizationCertificationService.java
@@ -0,0 +1,117 @@
+package io.oopy.coding.common.redis.organizationcert;
+
+import io.oopy.coding.common.redis.organizationcert.dto.OrganizationCertificationDto;
+import io.oopy.coding.common.redis.organizationcert.dto.OrganizationCertKey;
+import io.oopy.coding.common.redis.organizationcert.dto.OrganizationKey;
+import io.oopy.coding.organization.service.OrganizationService;
+import io.oopy.coding.organization.service.dto.OrganizationDto;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.data.redis.core.ListOperations;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.ObjectUtils;
+
+import java.time.ZoneId;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Optional;
+import java.util.stream.Collectors;
+
+/**
+ * 조직 인증 관련 서비스. Redis를 사용
+ */
+@Service
+@Slf4j
+public class OrganizationCertificationService {
+
+    private final ListOperations<String, OrganizationCertification> listOperations;
+    private final RedisTemplate<String, OrganizationCertification> redisTemplate;
+    private final OrganizationService organizationService;
+    private static final long EXPIRED_TIME = 600;
+
+    public OrganizationCertificationService(RedisTemplate<String, OrganizationCertification> redisTemplate,
+                                            OrganizationService organizationService) {
+        this.listOperations = redisTemplate.opsForList();
+        this.redisTemplate = redisTemplate;
+        this.organizationService = organizationService;
+    }
+
+    /**
+     * 인증 진행중인 조직 정보 리스트 조회
+     * @param organizationCertKey
+     * @return
+     */
+    @Transactional(readOnly = true)
+    public List<OrganizationCertification> getOrganizationCertifications(OrganizationKey organizationCertKey) {
+        List<OrganizationCertification> organizationCertifications = listOperations.range(organizationCertKey.getKey(), 0, -1);
+        if (ObjectUtils.isEmpty(organizationCertifications))
+            return new ArrayList<>();
+        List<OrganizationCertification> filteredOrganizationCertifications = organizationCertifications.stream()
+                .filter(v -> v.isExpired())
+                .collect(Collectors.toList());
+        return ObjectUtils.isEmpty(filteredOrganizationCertifications) ?
+                new ArrayList<>() :
+                filteredOrganizationCertifications;
+    }
+
+    /**
+     * 조직 인증 등록. 만료시간 : 600초
+     * @param register
+     */
+    @Transactional
+    public void register(OrganizationCertificationDto.Register register) {
+        if(organizationService.isUserAlreadyRegistered(
+                OrganizationDto.Cert.of(register.getOrganizationCode(),
+                        Long.parseLong(register.userId()),
+                        register.userEmail()
+                ))) {
+                throw new RuntimeException("이미 인증된 조직입니다.");
+        }
+        Optional<OrganizationCertification> checkOrganizationCertification = getOrganizationCertification(register);
+        if (checkOrganizationCertification.isPresent()) {
+            throw new RuntimeException("인증 진행중입니다.");
+        }
+        OrganizationCertification organizationCertification = OrganizationCertification.of(register.token(),
+                register.userId(),
+                register.userEmail(),
+                register.code(),
+                register.organizationName(),
+                EXPIRED_TIME
+        );
+        listOperations.rightPush(register.getKey(), organizationCertification);
+        ZoneId zoneId = ZoneId.systemDefault();
+        redisTemplate.expireAt(register.getKey(),
+                organizationCertification.getExpiredAt().atZone(zoneId).toInstant());
+    }
+
+    /**
+     * 조직 인증 삭제
+     * @param organizationCertKey
+     */
+    @Transactional
+    public void delete(OrganizationCertKey organizationCertKey) {
+        Optional<OrganizationCertification> organizationCertification = getOrganizationCertification(organizationCertKey);
+        if (organizationCertification.isEmpty()) {
+            throw new RuntimeException("인증 내역 없음.");
+        }
+        listOperations.remove(organizationCertKey.getKey(), 0, organizationCertification.get());
+    }
+
+    /**
+     * 진행 중인 조직 정보 리스트 중에, 특정 조직 하나를 뽑아낸다.
+     * @param cert
+     * @return
+     */
+    public Optional<OrganizationCertification> getOrganizationCertification(OrganizationCertKey cert) {
+        List<OrganizationCertification> organizationCertificationList = getOrganizationCertifications(cert);
+        if (ObjectUtils.isEmpty(organizationCertificationList)) {
+            return Optional.empty();
+        }
+        Optional<OrganizationCertification> organizationCertification = organizationCertificationList.stream()
+                .filter(v -> v.getOrganizationCode() != null &&
+                        v.getOrganizationCode().equals(cert.getOrganizationCode()))
+                .findFirst();
+        return organizationCertification;
+    }
+}
diff --git a/src/main/java/io/oopy/coding/common/redis/organizationcert/dto/OrganizationCertKey.java b/src/main/java/io/oopy/coding/common/redis/organizationcert/dto/OrganizationCertKey.java
@@ -0,0 +1,5 @@
+package io.oopy.coding.common.redis.organizationcert.dto;
+
+public interface OrganizationCertKey extends OrganizationKey{
+    String getOrganizationCode();
+}