posts);
+
+ @BeanMapping(nullValuePropertyMappingStrategy = NullValuePropertyMappingStrategy.IGNORE)
+ Post toEntity(PostRequestDto postRequestDto);
+
+ @BeanMapping(nullValuePropertyMappingStrategy = NullValuePropertyMappingStrategy.IGNORE)
+ void updateEntityFromDto(PostRequestDto postRequestDto, @MappingTarget Post post);
+}
diff --git a/post-service/src/main/java/com/codecampus/post/PostServiceApplication.java b/post-service/src/main/java/com/codecampus/post/PostServiceApplication.java
new file mode 100644
index 00000000..33095ed9
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/PostServiceApplication.java
@@ -0,0 +1,15 @@
+package com.codecampus.post;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+
+@SpringBootApplication
+@EnableFeignClients(basePackages = "com.codecampus.post.service.FeignConfig")
+public class PostServiceApplication {
+
+ public static void main(String[] args) {
+ SpringApplication.run(PostServiceApplication.class, args);
+ }
+
+}
diff --git a/post-service/src/main/java/com/codecampus/post/config/AuthenticationRequestInterceptor.java b/post-service/src/main/java/com/codecampus/post/config/AuthenticationRequestInterceptor.java
new file mode 100644
index 00000000..0b6b6536
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/config/AuthenticationRequestInterceptor.java
@@ -0,0 +1,44 @@
+package com.codecampus.post.config;
+
+import feign.RequestInterceptor;
+import feign.RequestTemplate;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.util.StringUtils;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+/**
+ * Feign RequestInterceptor để tự động thêm header Authorization
+ * của HTTP request hiện tại vào mọi request gửi đi qua Feign client.
+ *
+ * Khi có ServletRequestAttributes từ RequestContextHolder,
+ * lấy header "Authorization" từ HttpServletRequest và
+ * thêm vào RequestTemplate; nếu header rỗng, bỏ qua.
+ */
+@Slf4j
+public class AuthenticationRequestInterceptor
+ implements RequestInterceptor {
+ /**
+ * Phương thức được gọi trước khi Feign gửi request.
+ *
+ *
+ * - Lấy ServletRequestAttributes từ RequestContextHolder.
+ * - Nếu tồn tại, lấy HttpServletRequest và trích header "Authorization".
+ * - Nếu header có giá trị, thêm vào RequestTemplate của Feign.
+ *
+ *
+ * @param requestTemplate template của request chuẩn bị gửi đi
+ */
+ @Override
+ public void apply(RequestTemplate requestTemplate) {
+ ServletRequestAttributes attributes =
+ (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
+
+ var authHeader = attributes.getRequest().getHeader("Authorization");
+
+ log.info("Header: {}", authHeader);
+ if (StringUtils.hasText(authHeader)) {
+ requestTemplate.header("Authorization", authHeader);
+ }
+ }
+}
diff --git a/post-service/src/main/java/com/codecampus/post/config/CustomJwtDecoder.java b/post-service/src/main/java/com/codecampus/post/config/CustomJwtDecoder.java
new file mode 100644
index 00000000..c29afefc
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/config/CustomJwtDecoder.java
@@ -0,0 +1,50 @@
+package com.codecampus.post.config;
+
+import com.nimbusds.jwt.SignedJWT;
+import org.springframework.security.oauth2.jwt.Jwt;
+import org.springframework.security.oauth2.jwt.JwtDecoder;
+import org.springframework.security.oauth2.jwt.JwtException;
+import org.springframework.stereotype.Component;
+
+import java.text.ParseException;
+
+/**
+ * JwtDecoder tùy chỉnh sử dụng thư viện Nimbus để phân tích và giải mã JWT.
+ *
+ * Phương thức {@link #decode} sẽ:
+ *
+ * - Parse chuỗi token thành đối tượng SignedJWT.
+ * - Trích xuất thời gian phát hành (issueTime) và thời gian hết hạn (expirationTime)
+ * dưới dạng Instant.
+ * - Tạo đối tượng {@link Jwt} của Spring Security với các thông tin:
+ * token gốc, lần phát hành, thời gian hết hạn, header và claims của JWT.
+ * - Ném {@link JwtException} nếu không thể parse hoặc token không hợp lệ.
+ *
+ *
+ */
+@Component
+public class CustomJwtDecoder implements JwtDecoder {
+ /**
+ * Giải mã chuỗi JWT và trả về đối tượng Jwt chứa thông tin claims.
+ *
+ * @param token chuỗi JWT đã được ký (không bao gồm tiền tố Bearer)
+ * @return đối tượng Jwt chứa token gốc, thời gian phát hành, hết hạn, header và claims
+ * @throws JwtException nếu token không hợp lệ hoặc không parse được
+ */
+ @Override
+ public Jwt decode(String token) throws JwtException {
+ try {
+ SignedJWT signedJWT = SignedJWT.parse(token);
+
+ return new Jwt(
+ token,
+ signedJWT.getJWTClaimsSet().getIssueTime().toInstant(),
+ signedJWT.getJWTClaimsSet().getExpirationTime().toInstant(),
+ signedJWT.getHeader().toJSONObject(),
+ signedJWT.getJWTClaimsSet().getClaims()
+ );
+ } catch (ParseException e) {
+ throw new JwtException("Invalid token");
+ }
+ }
+}
diff --git a/post-service/src/main/java/com/codecampus/post/config/DualPortConfig.java b/post-service/src/main/java/com/codecampus/post/config/DualPortConfig.java
new file mode 100644
index 00000000..c1b786ce
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/config/DualPortConfig.java
@@ -0,0 +1,29 @@
+//package com.codecampus.coding.config;
+//
+//import org.apache.catalina.connector.Connector;
+//import org.springframework.beans.factory.annotation.Value;
+//import org.springframework.boot.web.embedded.tomcat.TomcatServletWebServerFactory;
+//import org.springframework.boot.web.servlet.server.ServletWebServerFactory;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//
+//@Configuration
+//public class DualPortConfig {
+// @Value("${server.http.port}")
+// private int httpPort;
+//
+// @Bean
+// public ServletWebServerFactory servletContainer() {
+// // Tomcat là default container của Spring Boot Starter Web
+// TomcatServletWebServerFactory factory = new TomcatServletWebServerFactory();
+//
+// Connector httpConnector =
+// new Connector(TomcatServletWebServerFactory.DEFAULT_PROTOCOL);
+// httpConnector.setScheme("http");
+// httpConnector.setPort(httpPort);
+// httpConnector.setSecure(false);
+//
+// factory.addAdditionalTomcatConnectors(httpConnector);
+// return factory;
+// }
+//}
diff --git a/post-service/src/main/java/com/codecampus/post/config/FeignConfiguration.java b/post-service/src/main/java/com/codecampus/post/config/FeignConfiguration.java
new file mode 100644
index 00000000..e2513323
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/config/FeignConfiguration.java
@@ -0,0 +1,28 @@
+package com.codecampus.post.config;
+
+import feign.codec.Encoder;
+import feign.form.spring.SpringFormEncoder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * Cấu hình cho Feign client để hỗ trợ gửi dữ liệu dạng multipart/form-data.
+ *
+ * Bean {@link Encoder} được đăng ký sử dụng
+ * {@link SpringFormEncoder} giúp Feign mã hóa các request
+ * có nội dung form hoặc file upload một cách tự động.
+ *
+ */
+@Configuration
+public class FeignConfiguration {
+ /**
+ * Đăng ký {@link Encoder} tùy chỉnh cho Feign,
+ * sử dụng {@link SpringFormEncoder} để mã hóa multipart/form-data.
+ *
+ * @return đối tượng Encoder hỗ trợ form encoding
+ */
+ @Bean
+ public Encoder multipartFormEncoder() {
+ return new SpringFormEncoder();
+ }
+}
diff --git a/post-service/src/main/java/com/codecampus/post/config/JwtAuthenticationEntryPoint.java b/post-service/src/main/java/com/codecampus/post/config/JwtAuthenticationEntryPoint.java
new file mode 100644
index 00000000..64bfe13e
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/config/JwtAuthenticationEntryPoint.java
@@ -0,0 +1,66 @@
+package com.codecampus.post.config;
+
+import com.codecampus.post.dto.common.ApiResponse;
+import com.codecampus.post.exception.ErrorCode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.servlet.http.HttpServletResponse;
+import org.springframework.http.MediaType;
+import org.springframework.security.core.AuthenticationException;
+import org.springframework.security.web.AuthenticationEntryPoint;
+
+import java.io.IOException;
+
+/**
+ * Entry point tùy chỉnh cho Spring Security khi phát hiện yêu cầu không được xác thực.
+ *
+ * Khi quá trình xác thực thất bại (ví dụ thiếu token hoặc token không hợp lệ),
+ * phương thức {@link #commence} sẽ được gọi để trả về phản hồi HTTP 401 với
+ * payload JSON chứa mã lỗi và thông điệp tương ứng.
+ */
+public class JwtAuthenticationEntryPoint
+ implements AuthenticationEntryPoint {
+ /**
+ * Xử lý phản hồi khi yêu cầu không được xác thực.
+ *
+ * Thiết lập:
+ *
+ * - Status HTTP = 401 (Unauthorized).
+ * - Content-Type = application/json.
+ * - Body JSON bao gồm:
+ *
+ * - code: mã lỗi từ {@link ErrorCode#UNAUTHENTICATED}.
+ * - message: thông điệp lỗi tương ứng.
+ *
+ *
+ *
+ *
+ *
+ * @param request đối tượng {@link HttpServletRequest} của client
+ * @param response đối tượng {@link HttpServletResponse} để gửi phản hồi
+ * @param authException ngoại lệ xác thực đã xảy ra
+ * @throws IOException nếu ghi response gặp lỗi I/O
+ */
+ @Override
+ public void commence(
+ HttpServletRequest request,
+ HttpServletResponse response,
+ AuthenticationException authException)
+ throws IOException {
+ ErrorCode errorCode = ErrorCode.UNAUTHENTICATED;
+
+ response.setStatus(errorCode.getStatusCode().value());
+ response.setContentType(MediaType.APPLICATION_JSON_VALUE);
+
+ ApiResponse apiResponse = ApiResponse.builder()
+ .code(errorCode.getCode())
+ .message(errorCode.getMessage())
+ .build();
+
+ ObjectMapper objectMapper = new ObjectMapper();
+
+ response.getWriter()
+ .write(objectMapper.writeValueAsString(apiResponse));
+ response.flushBuffer();
+ }
+}
diff --git a/post-service/src/main/java/com/codecampus/post/config/SecurityConfig.java b/post-service/src/main/java/com/codecampus/post/config/SecurityConfig.java
new file mode 100644
index 00000000..bec1abc3
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/config/SecurityConfig.java
@@ -0,0 +1,167 @@
+package com.codecampus.post.config;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.security.config.annotation.method.configuration.EnableMethodSecurity;
+import org.springframework.security.config.annotation.web.builders.HttpSecurity;
+import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
+import org.springframework.security.config.annotation.web.configurers.AbstractHttpConfigurer;
+import org.springframework.security.oauth2.server.resource.authentication.JwtAuthenticationConverter;
+import org.springframework.security.oauth2.server.resource.authentication.JwtGrantedAuthoritiesConverter;
+import org.springframework.security.web.SecurityFilterChain;
+import org.springframework.web.cors.CorsConfiguration;
+import org.springframework.web.cors.CorsConfigurationSource;
+import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
+
+import java.util.List;
+
+import static com.codecampus.post.constant.config.SecurityConfigConstant.ACCEPT_HEADER;
+import static com.codecampus.post.constant.config.SecurityConfigConstant.AUTHORIZATION_HEADER;
+import static com.codecampus.post.constant.config.SecurityConfigConstant.CONTENT_TYPE_HEADER;
+import static com.codecampus.post.constant.config.SecurityConfigConstant.DELETE_METHOD;
+//import static com.codecampus.post.constant.config.SecurityConfigConstant.FRONTEND_ENDPOINT;
+//import static com.codecampus.post.constant.config.SecurityConfigConstant.FRONTEND_ENDPOINT2;
+//import static com.codecampus.post.constant.config.SecurityConfigConstant.FRONTEND_ENDPOINT3;
+import static com.codecampus.post.constant.config.SecurityConfigConstant.GET_METHOD;
+import static com.codecampus.post.constant.config.SecurityConfigConstant.OPTIONS_METHOD;
+import static com.codecampus.post.constant.config.SecurityConfigConstant.PATCH_METHOD;
+import static com.codecampus.post.constant.config.SecurityConfigConstant.POST_METHOD;
+import static com.codecampus.post.constant.config.SecurityConfigConstant.PUBLIC_ENDPOINTS;
+import static com.codecampus.post.constant.config.SecurityConfigConstant.PUT_METHOD;
+import static com.codecampus.post.constant.config.SecurityConfigConstant.URL_PATTERN_ALL;
+
+/**
+ * Cấu hình bảo mật cho Profile Service sử dụng Spring Security.
+ *
+ * Bao gồm:
+ *
+ * - Định nghĩa các endpoint công khai (không yêu cầu xác thực).
+ * - Cấu hình OAuth2 Resource Server sử dụng JWT với bộ giải mã tùy chỉnh và entry point xử lý lỗi.
+ * - Tắt CSRF để phù hợp với API REST.
+ * - Thiết lập CORS cho các origin, method và header được phép.
+ * - Cấu hình converter để chuyển đổi JWT claims thành GrantedAuthority.
+ *
+ *
+ */
+@Configuration
+@EnableWebSecurity
+@EnableMethodSecurity
+@RequiredArgsConstructor
+public class SecurityConfig {
+ @Autowired
+ private CustomJwtDecoder customJwtDecoder;
+
+ /**
+ * Cấu hình SecurityFilterChain cho HTTP security.
+ *
+ * Thiết lập:
+ *
+ * - Cho phép truy cập PUBLIC_ENDPOINTS không cần xác thực.
+ * - Các request khác phải xác thực JWT.
+ * - Sử dụng customJwtDecoder và jwtAuthenticationConverter để xử lý JWT.
+ * - Sử dụng JwtAuthenticationEntryPoint để trả về 401 khi xác thực thất bại.
+ * - Tắt CSRF.
+ *
+ *
+ *
+ * @param httpSecurity đối tượng HttpSecurity để cấu hình
+ * @return SecurityFilterChain đã cấu hình
+ * @throws Exception nếu cấu hình gặp lỗi
+ */
+ @Bean
+ public SecurityFilterChain securityFilterChain(
+ HttpSecurity httpSecurity) throws Exception {
+ httpSecurity.authorizeHttpRequests(request -> request
+ .requestMatchers(PUBLIC_ENDPOINTS)
+ .permitAll()
+ .anyRequest()
+ .authenticated());
+
+ httpSecurity.oauth2ResourceServer(
+ oauth2 -> oauth2.jwt(jwtConfigurer -> jwtConfigurer
+ .decoder(customJwtDecoder)
+ .jwtAuthenticationConverter(
+ jwtAuthenticationConverter()))
+ .authenticationEntryPoint(
+ new JwtAuthenticationEntryPoint()));
+ httpSecurity.csrf(AbstractHttpConfigurer::disable);
+
+ return httpSecurity.build();
+ }
+
+ /**
+ * Cấu hình CORS cho ứng dụng.
+ *
+ * Phương thức này thiết lập:
+ *
+ * - Các origin được phép truy cập (danh sách FRONTEND_ENDPOINT, FRONTEND_ENDPOINT2, FRONTEND_ENDPOINT3).
+ * - Các phương thức HTTP được phép (GET, POST, PUT, DELETE, PATCH, OPTIONS).
+ * - Cho phép tất cả các header.
+ * - Cho phép gửi credentials.
+ * - Các header được expose (ví dụ: "Authorization").
+ *
+ * Áp dụng cấu hình này cho tất cả các endpoint.
+ *
+ *
+ * @return CorsConfigurationSource chứa cấu hình CORS của ứng dụng
+ */
+ @Bean
+ public CorsConfigurationSource corsConfigurationSource() {
+ CorsConfiguration configuration = new CorsConfiguration();
+
+// // Cho phép các origin truy cập định nghĩa sẵn
+// configuration.setAllowedOrigins(
+// List.of(FRONTEND_ENDPOINT, FRONTEND_ENDPOINT2,
+// FRONTEND_ENDPOINT3)
+// );
+
+ // Cho phép các phương thức HTTP được định nghĩa
+ configuration.setAllowedMethods(
+ List.of(GET_METHOD, POST_METHOD, PUT_METHOD, DELETE_METHOD,
+ PATCH_METHOD, OPTIONS_METHOD));
+
+ // Cho phép tất cả các header
+ configuration.setAllowedHeaders(
+ List.of(AUTHORIZATION_HEADER, CONTENT_TYPE_HEADER,
+ ACCEPT_HEADER));
+
+ // Cho phép gửi credentials (cookie, header, v.v.)
+ configuration.setAllowCredentials(true);
+
+ // Expose header "Authorization"
+ configuration.setExposedHeaders(List.of(AUTHORIZATION_HEADER));
+
+ // Thời gian cache preflight request
+ configuration.setMaxAge(3600L);
+
+ UrlBasedCorsConfigurationSource source =
+ new UrlBasedCorsConfigurationSource();
+
+ // Áp dụng cấu hình cho tất cả các endpoint
+ source.registerCorsConfiguration(URL_PATTERN_ALL, configuration);
+ return source;
+ }
+
+ /**
+ * Tạo {@link JwtAuthenticationConverter} để chuyển đổi JWT claims thành GrantedAuthority.
+ * Loại bỏ prefix mặc định (ví dụ "SCOPE_").
+ *
+ * @return JwtAuthenticationConverter đã cấu hình
+ */
+ @Bean
+ JwtAuthenticationConverter jwtAuthenticationConverter() {
+ JwtGrantedAuthoritiesConverter authConverter =
+ new JwtGrantedAuthoritiesConverter();
+ authConverter.setAuthorityPrefix("");
+
+ JwtAuthenticationConverter converter = new JwtAuthenticationConverter();
+ converter.setJwtGrantedAuthoritiesConverter(authConverter);
+
+ // Principal = claim "username"
+ converter.setPrincipalClaimName("username");
+
+ return converter;
+ }
+}
diff --git a/post-service/src/main/java/com/codecampus/post/config/audit/JpaAuditConfig.java b/post-service/src/main/java/com/codecampus/post/config/audit/JpaAuditConfig.java
new file mode 100644
index 00000000..bfba3045
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/config/audit/JpaAuditConfig.java
@@ -0,0 +1,31 @@
+package com.codecampus.post.config.audit;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.domain.AuditorAware;
+import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
+import org.springframework.security.core.Authentication;
+import org.springframework.security.core.context.SecurityContextHolder;
+
+import java.util.Optional;
+
+@Configuration
+@EnableJpaAuditing(auditorAwareRef = "auditorProvider")
+public class JpaAuditConfig {
+ /**
+ * Trả về username hiện tại (hoặc “system” nếu chưa đăng nhập).
+ * Spring Data sẽ dùng giá trị này để gán vào @CreatedBy / @LastModifiedBy.
+ */
+ @Bean
+ public AuditorAware auditorProvider() {
+ return () -> {
+ Authentication auth = SecurityContextHolder
+ .getContext()
+ .getAuthentication();
+
+ return Optional.ofNullable(auth)
+ .map(Authentication::getName)
+ .or(() -> Optional.of("system"));
+ };
+ }
+}
diff --git a/post-service/src/main/java/com/codecampus/post/config/audit/SoftDeleteInterceptor.java b/post-service/src/main/java/com/codecampus/post/config/audit/SoftDeleteInterceptor.java
new file mode 100644
index 00000000..760d06a1
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/config/audit/SoftDeleteInterceptor.java
@@ -0,0 +1,38 @@
+package com.codecampus.post.config.audit;
+
+import com.codecampus.post.entity.audit.SoftDeletable;
+import lombok.extern.slf4j.Slf4j;
+import org.hibernate.EmptyInterceptor;
+import org.hibernate.type.Type;
+import org.springframework.security.core.context.SecurityContextHolder;
+
+import java.time.Instant;
+
+@Slf4j
+public class SoftDeleteInterceptor extends EmptyInterceptor {
+ @Override
+ public void onDelete(
+ Object entity,
+ Object id,
+ Object[] state,
+ String[] propertyNames,
+ Type[] types) {
+ if (entity instanceof SoftDeletable soft) {
+ // Chặn DELETE -> UPDATE
+ soft.markDeleted(SecurityContextHolder
+ .getContext()
+ .getAuthentication()
+ .getName());
+
+ // Đẩy giá trị vào state[] để Hibernate cập nhật DB
+ for (int i = 0; i < propertyNames.length; i++) {
+ switch (propertyNames[i]) {
+ case "deletedBy" -> state[i] = soft.getDeletedBy();
+ case "deletedAt" -> state[i] = Instant.now();
+ }
+ }
+ } else {
+ super.onDelete(entity, id, state, propertyNames, types);
+ }
+ }
+}
diff --git a/post-service/src/main/java/com/codecampus/post/constant/PostAccessEnum.java b/post-service/src/main/java/com/codecampus/post/constant/PostAccessEnum.java
new file mode 100644
index 00000000..b50fa057
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/constant/PostAccessEnum.java
@@ -0,0 +1,6 @@
+package com.codecampus.post.constant;
+
+public enum PostAccessEnum {
+ PUBLIC,
+ PRIVATE,
+}
diff --git a/post-service/src/main/java/com/codecampus/post/constant/config/SecurityConfigConstant.java b/post-service/src/main/java/com/codecampus/post/constant/config/SecurityConfigConstant.java
new file mode 100644
index 00000000..3a6bbfc6
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/constant/config/SecurityConfigConstant.java
@@ -0,0 +1,35 @@
+package com.codecampus.post.constant.config;
+
+import lombok.NoArgsConstructor;
+
+@NoArgsConstructor
+public class SecurityConfigConstant {
+ // HEADER REQUEST
+ public static final String AUTHORIZATION_HEADER = "Authorization";
+ public static final String CONTENT_TYPE_HEADER = "Content-Type";
+ public static final String ACCEPT_HEADER = "Accept";
+
+
+ // PATTERN REQUEST
+ public static final String URL_PATTERN_ALL = "/**";
+
+ // PUBLIC ENDPOINT
+ public static final String[] PUBLIC_ENDPOINTS = {
+ "/hello",
+ "/health",
+ "/actuator/**",
+ };
+
+// // FRONTEND ENDPOINT
+// public static final String FRONTEND_ENDPOINT = "http://192.168.1.30:4200";
+// public static final String FRONTEND_ENDPOINT2 = "http://localhost:4200";
+// public static final String FRONTEND_ENDPOINT3 = "http://127.0.0.1:5500";
+
+ // METHOD ALLOWED
+ public static String GET_METHOD = "GET";
+ public static String POST_METHOD = "POST";
+ public static String DELETE_METHOD = "DELETE";
+ public static String PUT_METHOD = "PUT";
+ public static String PATCH_METHOD = "PATCH";
+ public static String OPTIONS_METHOD = "OPTIONS";
+}
diff --git a/post-service/src/main/java/com/codecampus/post/constant/exception/ErrorCodeConstant.java b/post-service/src/main/java/com/codecampus/post/constant/exception/ErrorCodeConstant.java
new file mode 100644
index 00000000..86a814e6
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/constant/exception/ErrorCodeConstant.java
@@ -0,0 +1,20 @@
+package com.codecampus.post.constant.exception;
+
+import lombok.NoArgsConstructor;
+
+import static com.sun.source.doctree.DocTree.Kind.AUTHOR;
+import static io.grpc.Status.NOT_FOUND;
+import static org.springframework.http.HttpStatus.*;
+
+@NoArgsConstructor
+public class ErrorCodeConstant {
+ public static final String INTERNAL_SERVER_STATUS =
+ INTERNAL_SERVER_ERROR.toString();
+ public static final String BAD_REQUEST_STATUS = BAD_REQUEST.toString();
+ public static final String UNAUTHORIZED_STATUS =
+ org.springframework.http.HttpStatus.UNAUTHORIZED.toString();
+ public static final String FORBIDDEN_STATUS = FORBIDDEN.toString();
+ public static final String NOT_FOUND_STATUS = NOT_FOUND.toString();
+ public static final String CONFLICT_STATUS = CONFLICT.toString();
+ public static final String AUTHOR_STATUS = AUTHOR.toString();
+}
diff --git a/post-service/src/main/java/com/codecampus/post/controller/PostAccessController.java b/post-service/src/main/java/com/codecampus/post/controller/PostAccessController.java
new file mode 100644
index 00000000..97e9ad17
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/controller/PostAccessController.java
@@ -0,0 +1,44 @@
+package com.codecampus.post.controller;
+
+import com.codecampus.post.dto.common.ApiResponse;
+import com.codecampus.post.dto.request.PostAccessRequestDto;
+import com.codecampus.post.entity.PostAccess;
+import com.codecampus.post.service.PostAccessService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+@RestController
+@RequestMapping("/postAccess")
+@RequiredArgsConstructor
+public class PostAccessController {
+
+ private final PostAccessService postAccessService;
+
+ @PostMapping("/addAccess")
+ public ResponseEntity addOrUpdateAccess(@RequestBody PostAccessRequestDto dto) {
+ postAccessService.saveOrUpdateAccess(dto);
+ return ResponseEntity.ok(ApiResponse.builder()
+ .message("Access list updated successfully")
+ .build());
+ }
+
+ @DeleteMapping("/deleteAccess")
+ public ResponseEntity deleteAccess(
+ @RequestBody PostAccessRequestDto userIds) {
+ postAccessService.deleteAccess( userIds);
+ return ResponseEntity.ok(ApiResponse.builder()
+ .message("Access list deleted successfully")
+ .build());
+ }
+
+ @GetMapping("/getPostAccess/{postId}")
+ public ResponseEntity getAccessList(@PathVariable String postId) {
+ return ResponseEntity.ok(ApiResponse.builder()
+ .message("Access list retrieved successfully")
+ .result(postAccessService.getAccessByPostId(postId))
+ .build());
+ }
+}
diff --git a/post-service/src/main/java/com/codecampus/post/controller/PostCommentController.java b/post-service/src/main/java/com/codecampus/post/controller/PostCommentController.java
new file mode 100644
index 00000000..7ed27667
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/controller/PostCommentController.java
@@ -0,0 +1,80 @@
+package com.codecampus.post.controller;
+
+import com.codecampus.post.dto.common.ApiResponse;
+import com.codecampus.post.dto.request.CommentRequestDto;
+import com.codecampus.post.dto.request.UpdateCommentDto;
+import com.codecampus.post.dto.response.CommentResponseDto;
+import com.codecampus.post.entity.PostComment;
+import com.codecampus.post.service.PostCommentService;
+import jakarta.servlet.http.HttpServletRequest;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+@RestController
+@RequestMapping("/comments")
+@RequiredArgsConstructor
+public class PostCommentController {
+
+ private final PostCommentService postCommentService;
+
+ @PostMapping("/addComment")
+ public ResponseEntity addComment(
+ @RequestBody CommentRequestDto dto,
+ HttpServletRequest request
+ ) {
+
+ PostComment saved = postCommentService.addComment(dto, request);
+ return ResponseEntity.ok(
+ ApiResponse.builder()
+ .message("Thêm bình luận thành công")
+ .build()
+ );
+ }
+
+ @GetMapping("/getCmtByPostId/{postId}")
+ public ResponseEntity getComments(@PathVariable String postId) {
+ List comments = postCommentService.getCommentsByPost(postId);
+ return ResponseEntity.ok(
+ ApiResponse.builder()
+ .message("Lấy bình luận thành công")
+ .result(comments)
+ .build()
+ );
+ }
+
+ @PutMapping("/updateComment")
+ public ResponseEntity updateComment(
+ @RequestBody UpdateCommentDto requestDto,
+ HttpServletRequest request
+ ) {
+ postCommentService.updateComment(requestDto, request);
+ return ResponseEntity.ok(
+ ApiResponse.builder()
+ .message("Bình luận chỉnh sửa thành công")
+ .build()
+ );
+ }
+
+ @DeleteMapping("/deleteComment/{commentId}")
+ public ResponseEntity deleteComment(
+ @PathVariable String commentId,
+ HttpServletRequest request
+ ) {
+ postCommentService.deleteComment(commentId, request);
+ return ResponseEntity.ok(
+ ApiResponse.builder()
+ .message("Xoá bình luận thành công")
+ .build()
+ );
+ }
+
+ private String extractUserIdFromToken(HttpServletRequest request) {
+ String token = request.getHeader("Authorization").substring(7);
+ // giả sử bạn có customJwtDecoder như ở PostService
+ return "decodedUserId"; // thay bằng code decode thực tế
+ }
+}
+
diff --git a/post-service/src/main/java/com/codecampus/post/controller/PostController.java b/post-service/src/main/java/com/codecampus/post/controller/PostController.java
new file mode 100644
index 00000000..145be9b1
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/controller/PostController.java
@@ -0,0 +1,73 @@
+package com.codecampus.post.controller;
+
+import com.codecampus.post.dto.common.ApiResponse;
+import com.codecampus.post.dto.common.PageRequestDto;
+import com.codecampus.post.dto.request.AddFileDocumentDto;
+import com.codecampus.post.dto.request.PostRequestDto;
+import com.codecampus.post.service.PostService;
+import jakarta.servlet.http.HttpServletRequest;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+@RestController()
+@RequestMapping("/posts")
+public class PostController {
+
+ @Autowired
+ private PostService postService;
+
+ @GetMapping("/getAllAccessiblePosts")
+ public ResponseEntity getAllAccessiblePosts(HttpServletRequest request, @RequestBody PageRequestDto pageRequestDto) {
+ return ResponseEntity.ok(ApiResponse.builder()
+ .message("Success")
+ .result(postService.getAllAccessiblePosts(request, pageRequestDto))
+ .build());
+ }
+
+ @GetMapping("/seachPosts/{searchText}")
+ public ResponseEntity SeachPosts(@PathVariable("searchText") String searchText, HttpServletRequest request, @RequestBody PageRequestDto pageRequestDto) {
+ return ResponseEntity.ok(ApiResponse.builder()
+ .message("Success")
+ .result(postService.SeachPosts(searchText, request, pageRequestDto))
+ .build());
+ }
+
+// @GetMapping("/getPostByIdIfAccessible/{postId}")
+// public ResponseEntity getPostByIdIfAccessible(@PathVariable("postId") String postId, HttpServletRequest request) {
+// return ResponseEntity.ok(ApiResponse.builder()
+// .message("Success")
+// .result(postService.getPostByIdIfAccessible(postId, request))
+// .build());
+// }
+
+ @PostMapping("/createPost")
+ public ResponseEntity createPost(
+ @ModelAttribute PostRequestDto postRequestDto,
+ HttpServletRequest request
+ ) {
+ postService.createPost(postRequestDto, request);
+ return ResponseEntity.ok(ApiResponse.builder()
+ .message("Post created successfully")
+ .build());
+ }
+
+ @PutMapping("/updatePost")
+ public ResponseEntity updatePost(
+ @ModelAttribute PostRequestDto postRequestDto,
+ HttpServletRequest request
+ ) {
+ postService.updatePost(postRequestDto, request);
+ return ResponseEntity.ok(ApiResponse.builder()
+ .message("Post updated successfully")
+ .build());
+ }
+
+ @PutMapping("/deletePost/{postId}")
+ public ResponseEntity deletePost(@PathVariable("postId") String postId, HttpServletRequest request) {
+ postService.deletePost(postId, request);
+ return ResponseEntity.ok(ApiResponse.builder()
+ .message("Post deleted successfully")
+ .build());
+ }
+}
diff --git a/post-service/src/main/java/com/codecampus/post/controller/PostReactionController.java b/post-service/src/main/java/com/codecampus/post/controller/PostReactionController.java
new file mode 100644
index 00000000..4062bf56
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/controller/PostReactionController.java
@@ -0,0 +1,50 @@
+package com.codecampus.post.controller;
+
+import com.codecampus.post.dto.common.ApiResponse;
+import com.codecampus.post.dto.request.PostReactionRequestDto;
+import com.codecampus.post.service.PostReactionService;
+import jakarta.servlet.http.HttpServletRequest;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+@RestController
+@RequestMapping("/postReaction")
+@RequiredArgsConstructor
+public class PostReactionController {
+
+ private final PostReactionService postReactionService;
+
+ // Toggle reaction (upvote / downvote)
+ @PostMapping("/toggle")
+ public ResponseEntity toggleReaction(@RequestBody PostReactionRequestDto requestDto,
+ HttpServletRequest request) {
+ postReactionService.toggleReaction(requestDto, request);
+ return ResponseEntity.ok(ApiResponse.builder()
+ .message("Reaction toggled successfully")
+ .build());
+ }
+
+ // Get reaction count cho post
+ @GetMapping("/post/{postId}")
+ public ResponseEntity getPostReactions(@PathVariable String postId) {
+ Map counts = postReactionService.getReactionCount(postId, null);
+ return ResponseEntity.ok(ApiResponse.builder()
+ .message("Reaction counts retrieved successfully")
+ .result(counts)
+ .build());
+ }
+
+ // Get reaction count cho comment trong post
+ @GetMapping("/post/{postId}/comment/{commentId}")
+ public ResponseEntity getCommentReactions(@PathVariable String postId,
+ @PathVariable String commentId) {
+ Map counts = postReactionService.getReactionCount(postId, commentId);
+ return ResponseEntity.ok(ApiResponse.builder()
+ .message("Reaction counts retrieved successfully")
+ .result(counts)
+ .build());
+ }
+}
diff --git a/post-service/src/main/java/com/codecampus/post/dto/common/ApiResponse.java b/post-service/src/main/java/com/codecampus/post/dto/common/ApiResponse.java
new file mode 100644
index 00000000..e108de9e
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/dto/common/ApiResponse.java
@@ -0,0 +1,25 @@
+package com.codecampus.post.dto.common;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import lombok.*;
+import lombok.experimental.FieldDefaults;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+@FieldDefaults(level = AccessLevel.PRIVATE)
+@JsonInclude(JsonInclude.Include.NON_NULL)
+public class ApiResponse {
+ // Mã phản hồi mặc định (20000) cho các phản hồi thành công
+ @Builder.Default
+ int code = 20000;
+
+ String message;
+
+ // Trạn thái phản hồi mặc định (mã 20000) cho các phản hồi thành công
+ @Builder.Default
+ String status = "Thành công!";
+
+ private T result;
+}
diff --git a/post-service/src/main/java/com/codecampus/post/dto/common/PageRequestDto.java b/post-service/src/main/java/com/codecampus/post/dto/common/PageRequestDto.java
new file mode 100644
index 00000000..e11d3ee4
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/dto/common/PageRequestDto.java
@@ -0,0 +1,11 @@
+package com.codecampus.post.dto.common;
+
+import lombok.Data;
+
+@Data
+public class PageRequestDto {
+ private int page;
+ private int size;
+ private String sortBy;
+ private String sortDirection;
+}
diff --git a/post-service/src/main/java/com/codecampus/post/dto/common/PageResponse.java b/post-service/src/main/java/com/codecampus/post/dto/common/PageResponse.java
new file mode 100644
index 00000000..3d0d191e
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/dto/common/PageResponse.java
@@ -0,0 +1,25 @@
+package com.codecampus.post.dto.common;
+
+import lombok.AccessLevel;
+import lombok.Builder;
+import lombok.Data;
+import lombok.experimental.FieldDefaults;
+
+import java.util.Collections;
+import java.util.List;
+
+@Data
+@Builder
+@FieldDefaults(level = AccessLevel.PRIVATE)
+// Mặc định cho phép response cả null khi Dev
+// Khi build thì KHÔNG response null
+//@JsonInclude(JsonInclude.Include.NON_NULL)
+public class PageResponse {
+ int currentPage;
+ int totalPages;
+ int pageSize;
+ long totalElements;
+
+ @Builder.Default
+ private List data = Collections.emptyList();
+}
diff --git a/post-service/src/main/java/com/codecampus/post/dto/request/AddFileDocumentDto.java b/post-service/src/main/java/com/codecampus/post/dto/request/AddFileDocumentDto.java
new file mode 100644
index 00000000..2afac42d
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/dto/request/AddFileDocumentDto.java
@@ -0,0 +1,21 @@
+package com.codecampus.post.dto.request;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import lombok.Data;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.List;
+import java.util.UUID;
+
+@Data
+@JsonInclude(JsonInclude.Include.NON_NULL)
+public class AddFileDocumentDto {
+ private MultipartFile file;
+ private String category; // enum truyền dạng string
+ private String description;
+ private List tags;
+ private boolean isLectureVideo = false;
+ private boolean isTextbook = false;
+ private UUID orgId;
+}
diff --git a/post-service/src/main/java/com/codecampus/post/dto/request/CommentRequestDto.java b/post-service/src/main/java/com/codecampus/post/dto/request/CommentRequestDto.java
new file mode 100644
index 00000000..e2449c00
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/dto/request/CommentRequestDto.java
@@ -0,0 +1,16 @@
+package com.codecampus.post.dto.request;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@JsonInclude(JsonInclude.Include.NON_NULL)
+public class CommentRequestDto {
+ private String postId;
+ private String parentCommentId; // null nếu là comment gốc
+ private String content;
+}
diff --git a/post-service/src/main/java/com/codecampus/post/dto/request/PostAccessRequestDto.java b/post-service/src/main/java/com/codecampus/post/dto/request/PostAccessRequestDto.java
new file mode 100644
index 00000000..b8fa8531
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/dto/request/PostAccessRequestDto.java
@@ -0,0 +1,16 @@
+package com.codecampus.post.dto.request;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class PostAccessRequestDto {
+ private String postId;
+ private List userIds;
+ private Boolean isExcluded;
+}
diff --git a/post-service/src/main/java/com/codecampus/post/dto/request/PostReactionRequestDto.java b/post-service/src/main/java/com/codecampus/post/dto/request/PostReactionRequestDto.java
new file mode 100644
index 00000000..4d614630
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/dto/request/PostReactionRequestDto.java
@@ -0,0 +1,18 @@
+package com.codecampus.post.dto.request;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+@Builder
+@JsonInclude(JsonInclude.Include.NON_NULL)
+public class PostReactionRequestDto {
+ private String postId;
+ private String userId;
+ private String commentId; // for comment reactions, can be null if reacting to the post itself
+ private String reactionType; // upvote || downvote
+}
+
diff --git a/post-service/src/main/java/com/codecampus/post/dto/request/PostRequestDto.java b/post-service/src/main/java/com/codecampus/post/dto/request/PostRequestDto.java
new file mode 100644
index 00000000..aa884929
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/dto/request/PostRequestDto.java
@@ -0,0 +1,28 @@
+package com.codecampus.post.dto.request;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.Setter;
+
+
+@Getter
+@Setter
+@Builder
+@AllArgsConstructor
+@JsonInclude(JsonInclude.Include.NON_NULL)
+public class PostRequestDto {
+ private String postId; // for update post
+ private String title;
+ private String orgId;
+ private String content;
+ private String oldImgesUrls; // for update post img
+ private boolean isPublic;
+ private boolean allowComment;
+ private String postType;
+ private String hashtag;
+ private String status;
+ private AddFileDocumentDto fileDocument; // for add file document
+// private PostAccess postAccess;
+}
diff --git a/post-service/src/main/java/com/codecampus/post/dto/request/UpdateCommentDto.java b/post-service/src/main/java/com/codecampus/post/dto/request/UpdateCommentDto.java
new file mode 100644
index 00000000..9a03c5d6
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/dto/request/UpdateCommentDto.java
@@ -0,0 +1,13 @@
+package com.codecampus.post.dto.request;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+@AllArgsConstructor
+public class UpdateCommentDto {
+ private String commentId;
+ private String content;
+}
diff --git a/post-service/src/main/java/com/codecampus/post/dto/response/AddFileResponseDto.java b/post-service/src/main/java/com/codecampus/post/dto/response/AddFileResponseDto.java
new file mode 100644
index 00000000..16ff566d
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/dto/response/AddFileResponseDto.java
@@ -0,0 +1,13 @@
+package com.codecampus.post.dto.response;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class AddFileResponseDto {
+ private int code;
+ private String message;
+ private String status;
+ private String result;
+}
diff --git a/post-service/src/main/java/com/codecampus/post/dto/response/CommentResponseDto.java b/post-service/src/main/java/com/codecampus/post/dto/response/CommentResponseDto.java
new file mode 100644
index 00000000..f40abf28
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/dto/response/CommentResponseDto.java
@@ -0,0 +1,18 @@
+package com.codecampus.post.dto.response;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class CommentResponseDto {
+ private String commentId;
+ private String userId;
+ private String content;
+ private List replies;
+}
+
diff --git a/post-service/src/main/java/com/codecampus/post/dto/response/PostAccessResponseDto.java b/post-service/src/main/java/com/codecampus/post/dto/response/PostAccessResponseDto.java
new file mode 100644
index 00000000..eb057b5b
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/dto/response/PostAccessResponseDto.java
@@ -0,0 +1,12 @@
+package com.codecampus.post.dto.response;
+
+import lombok.Builder;
+import lombok.Data;
+
+@Data
+@Builder
+public class PostAccessResponseDto {
+ private String postId;
+ private String userId;
+ private boolean isExcluded;
+}
diff --git a/post-service/src/main/java/com/codecampus/post/entity/Post.java b/post-service/src/main/java/com/codecampus/post/entity/Post.java
new file mode 100644
index 00000000..2e87851b
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/entity/Post.java
@@ -0,0 +1,41 @@
+package com.codecampus.post.entity;
+
+import com.codecampus.post.entity.audit.AuditMetadata;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import jakarta.persistence.*;
+import lombok.Getter;
+import lombok.Setter;
+
+import java.util.List;
+
+@Entity
+@Getter
+@Setter
+@Table(name = "post")
+public class Post extends AuditMetadata {
+ @Id
+ @GeneratedValue(strategy = GenerationType.UUID)
+ private String postId;
+
+ private String userId;
+ private String orgId;
+ private String postType; //global, organization, group, etc.
+ private String title;
+ private String content;
+ private Boolean isPublic;
+ private Boolean allowComment;
+ private String hashtag;
+ private String status;
+ private List imagesUrls;
+
+ @OneToMany(mappedBy = "post", cascade = CascadeType.ALL)
+ @JsonIgnore
+ private List comments;
+
+ @OneToMany(mappedBy = "post", cascade = CascadeType.ALL)
+ private List reactions;
+
+ @OneToMany(mappedBy = "post", cascade = CascadeType.ALL)
+ private List accesses;
+}
+
diff --git a/post-service/src/main/java/com/codecampus/post/entity/PostAccess.java b/post-service/src/main/java/com/codecampus/post/entity/PostAccess.java
new file mode 100644
index 00000000..487d4d5e
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/entity/PostAccess.java
@@ -0,0 +1,24 @@
+package com.codecampus.post.entity;
+
+import com.codecampus.post.entity.audit.AuditMetadata;
+import jakarta.persistence.*;
+import lombok.Data;
+import org.hibernate.annotations.Fetch;
+import org.springframework.context.annotation.Lazy;
+
+@Entity
+@Data
+@Table(name = "post_access")
+public class PostAccess extends AuditMetadata {
+ @Id
+ @GeneratedValue(strategy = GenerationType.UUID)
+ private String postAccessId;
+
+ @ManyToOne(fetch = FetchType.LAZY)
+ @JoinColumn(name = "post_id", nullable = false)
+ private Post post;
+
+ private String userId;
+ private Boolean isExcluded;
+}
+
diff --git a/post-service/src/main/java/com/codecampus/post/entity/PostComment.java b/post-service/src/main/java/com/codecampus/post/entity/PostComment.java
new file mode 100644
index 00000000..2d4f12e6
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/entity/PostComment.java
@@ -0,0 +1,32 @@
+package com.codecampus.post.entity;
+
+import com.codecampus.post.entity.audit.AuditMetadata;
+import jakarta.persistence.*;
+import lombok.Data;
+
+import java.util.List;
+
+@Entity
+@Data
+@Table(name = "post_comment")
+public class PostComment extends AuditMetadata {
+ @Id
+ @GeneratedValue(strategy = GenerationType.UUID)
+ private String commentId;
+
+ private String userId;
+ private String content;
+
+
+ @ManyToOne
+ @JoinColumn(name = "post_id", nullable = false)
+ private Post post;
+
+ @ManyToOne
+ @JoinColumn(name = "parent_comment_id")
+ private PostComment parentComment; // comment reply
+
+ @OneToMany(mappedBy = "parentComment", cascade = CascadeType.ALL)
+ private List replies;
+}
+
diff --git a/post-service/src/main/java/com/codecampus/post/entity/PostImage.java b/post-service/src/main/java/com/codecampus/post/entity/PostImage.java
new file mode 100644
index 00000000..087c81bd
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/entity/PostImage.java
@@ -0,0 +1,23 @@
+//package com.codecampus.post.entity;
+//
+//import com.codecampus.post.entity.audit.AuditMetadata;
+//import jakarta.persistence.*;
+//
+//import java.time.LocalDateTime;
+//import java.util.UUID;
+//
+//@Entity
+//@Table(name = "post_image")
+//public class PostImage extends AuditMetadata {
+// @Id
+// @GeneratedValue(strategy = GenerationType.UUID)
+// private String postImageId;
+//
+// private String imageUrl;
+// private String altText;
+//
+// @ManyToOne
+// @JoinColumn(name = "post_id", nullable = false)
+// private Post post;
+//}
+//
diff --git a/post-service/src/main/java/com/codecampus/post/entity/PostReaction.java b/post-service/src/main/java/com/codecampus/post/entity/PostReaction.java
new file mode 100644
index 00000000..30b583e4
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/entity/PostReaction.java
@@ -0,0 +1,25 @@
+package com.codecampus.post.entity;
+
+import com.codecampus.post.entity.audit.AuditMetadata;
+import jakarta.persistence.*;
+import lombok.Getter;
+import lombok.Setter;
+
+@Entity
+@Getter
+@Setter
+@Table(name = "post_reaction")
+public class PostReaction extends AuditMetadata {
+ @Id
+ @GeneratedValue(strategy = GenerationType.UUID)
+ private String reactionId;
+
+ private String userId;
+ private String commentId; // for comment reactions
+ private String emojiType;
+
+
+ @ManyToOne
+ @JoinColumn(name = "post_id", nullable = false)
+ private Post post;
+}
diff --git a/post-service/src/main/java/com/codecampus/post/entity/audit/AuditMetadata.java b/post-service/src/main/java/com/codecampus/post/entity/audit/AuditMetadata.java
new file mode 100644
index 00000000..222709a1
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/entity/audit/AuditMetadata.java
@@ -0,0 +1,57 @@
+package com.codecampus.post.entity.audit;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.EntityListeners;
+import jakarta.persistence.MappedSuperclass;
+import lombok.AccessLevel;
+import lombok.Data;
+import lombok.experimental.FieldDefaults;
+import org.springframework.data.annotation.CreatedBy;
+import org.springframework.data.annotation.CreatedDate;
+import org.springframework.data.annotation.LastModifiedBy;
+import org.springframework.data.annotation.LastModifiedDate;
+import org.springframework.data.jpa.domain.support.AuditingEntityListener;
+
+import java.time.Instant;
+
+@Data
+@MappedSuperclass
+@EntityListeners(AuditingEntityListener.class)
+@FieldDefaults(level = AccessLevel.PROTECTED)
+public class AuditMetadata implements SoftDeletable {
+ /* ---- create ---- */
+ @CreatedBy
+ @Column(name = "created_by")
+ String createdBy;
+
+ @CreatedDate
+ @Column(name = "created_at")
+ Instant createdAt;
+
+ /* ---- update ---- */
+ @LastModifiedBy
+ @Column(name = "updated_by")
+ String updatedBy;
+
+ @LastModifiedDate
+ @Column(name = "updated_at")
+ Instant updatedAt;
+
+ /* ---- soft-delete ---- */
+ @Column(name = "deleted_by")
+ String deletedBy;
+
+ @Column(name = "deleted_at")
+ Instant deletedAt;
+
+ @Override
+ public void markDeleted(String by) {
+ this.deletedBy = by;
+ this.deletedAt = Instant.now();
+ }
+
+ @Override
+ public boolean isDeleted() {
+ return deletedAt != null;
+ }
+}
diff --git a/post-service/src/main/java/com/codecampus/post/entity/audit/SoftDeletable.java b/post-service/src/main/java/com/codecampus/post/entity/audit/SoftDeletable.java
new file mode 100644
index 00000000..991bc432
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/entity/audit/SoftDeletable.java
@@ -0,0 +1,9 @@
+package com.codecampus.post.entity.audit;
+
+public interface SoftDeletable {
+ void markDeleted(String by);
+
+ boolean isDeleted();
+
+ String getDeletedBy();
+}
diff --git a/post-service/src/main/java/com/codecampus/post/exception/AppException.java b/post-service/src/main/java/com/codecampus/post/exception/AppException.java
new file mode 100644
index 00000000..434d3af2
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/exception/AppException.java
@@ -0,0 +1,15 @@
+package com.codecampus.post.exception;
+
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+public class AppException extends RuntimeException {
+ private ErrorCode errorCode;
+
+ public AppException(ErrorCode errorCode) {
+ super(errorCode.getMessage());
+ this.errorCode = errorCode;
+ }
+}
diff --git a/post-service/src/main/java/com/codecampus/post/exception/ErrorCode.java b/post-service/src/main/java/com/codecampus/post/exception/ErrorCode.java
new file mode 100644
index 00000000..08776a21
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/exception/ErrorCode.java
@@ -0,0 +1,65 @@
+package com.codecampus.post.exception;
+
+import lombok.Getter;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.HttpStatusCode;
+
+import static com.codecampus.post.constant.exception.ErrorCodeConstant.*;
+import static org.springframework.http.HttpStatus.*;
+
+@Getter
+public enum ErrorCode {
+ // Các lỗi không phân loại và lỗi chung
+ UNCATEGORIZED_EXCEPTION(99999, INTERNAL_SERVER_STATUS,
+ "Lỗi chưa phân loại", INTERNAL_SERVER_ERROR),
+
+ // 400 - Bad Request
+
+
+ // 401 - Unauthorized
+ UNAUTHENTICATED(4019001, UNAUTHORIZED_STATUS, "Chưa xác thực!",
+ HttpStatus.UNAUTHORIZED),
+ AUTHOR_UNAUTHORIZED(4019002,AUTHOR_STATUS, "Không phải người đăng bài",
+ HttpStatus.UNAUTHORIZED),
+
+ // 403 - Forbidden
+ UNAUTHORIZED(4039001, FORBIDDEN_STATUS, "Bạn không có quyền truy cập!",
+ FORBIDDEN),
+
+ // 404 - Not Found
+ USER_NOT_FOUND(4049001, NOT_FOUND_STATUS, "Không tìm thấy người dùng!",
+ NOT_FOUND),
+ TARGET_USER_NOT_FOUND(4049003, NOT_FOUND_STATUS,
+ "Không tìm thấy người dùng mục tiêu!", NOT_FOUND),
+ POST_NOT_FOUND(4049004, NOT_FOUND_STATUS, "Không tìm thấy bài đăng!",
+ NOT_FOUND),
+ ORG_NOT_FOUND(4049004, NOT_FOUND_STATUS, "Không tìm thấy tổ chức!",
+ NOT_FOUND),
+
+
+ // 409 - Conflict
+ USER_ALREADY_EXISTS(4099001, CONFLICT_STATUS, "Người dùng đã tồn tại!",
+ CONFLICT),
+
+ //410 - invalid
+ INVALID_FILE_TYPE(4109001, BAD_REQUEST_STATUS, "Định dạng tệp không hợp lệ",
+ HttpStatus.BAD_REQUEST)
+
+ ;
+
+ private final int code;
+ private final String status;
+ private final String message;
+ private final HttpStatusCode statusCode;
+
+ ErrorCode(
+ int code,
+ String status,
+ String message,
+ HttpStatusCode statusCode) {
+ this.code = code;
+ this.status = status;
+ this.message = message;
+ this.statusCode = statusCode;
+ }
+}
diff --git a/post-service/src/main/java/com/codecampus/post/exception/GlobalExceptionHandler.java b/post-service/src/main/java/com/codecampus/post/exception/GlobalExceptionHandler.java
new file mode 100644
index 00000000..349345cc
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/exception/GlobalExceptionHandler.java
@@ -0,0 +1,102 @@
+package com.codecampus.post.exception;
+
+import com.codecampus.post.dto.common.ApiResponse;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import feign.FeignException;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.security.access.AccessDeniedException;
+import org.springframework.web.bind.annotation.ControllerAdvice;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+
+@ControllerAdvice
+@Slf4j
+@RequiredArgsConstructor
+public class GlobalExceptionHandler {
+
+ private final ObjectMapper objectMapper;
+
+ /**
+ * Xử lý các ngoại lệ RuntimeException không được bắt riêng.
+ *
+ * @param exception ngoại lệ RuntimeException được ném ra
+ * @return ResponseEntity chứa ApiResponse với mã lỗi, thông điệp và trạng thái lỗi tương ứng
+ */
+ @ExceptionHandler(value = Exception.class)
+ ResponseEntity> handlingRuntimeException(
+ RuntimeException exception) {
+ log.error("Exception: " + exception.getMessage(), exception);
+
+ ApiResponse apiResponse = new ApiResponse<>();
+ apiResponse.setCode(ErrorCode.UNCATEGORIZED_EXCEPTION.getCode());
+ apiResponse.setMessage(ErrorCode.UNCATEGORIZED_EXCEPTION.getMessage());
+ apiResponse.setStatus(ErrorCode.UNCATEGORIZED_EXCEPTION.getStatus());
+
+ return ResponseEntity.badRequest().body(apiResponse);
+ }
+
+ /**
+ * Xử lý ngoại lệ ứng dụng (AppException) và chuyển thành ApiResponse.
+ *
+ * @param exception ngoại lệ AppException được ném ra
+ * @return ResponseEntity chứa ApiResponse với thông tin lỗi tương ứng
+ */
+ @ExceptionHandler(value = AppException.class)
+ ResponseEntity> handlingAppException(
+ AppException exception) {
+ log.error("Exception: " + exception.getMessage(), exception);
+
+ ErrorCode errorCode = exception.getErrorCode();
+ ApiResponse apiResponse = new ApiResponse<>();
+ apiResponse.setCode(errorCode.getCode());
+ apiResponse.setMessage(errorCode.getMessage());
+ apiResponse.setStatus(errorCode.getStatus());
+
+ return ResponseEntity.status(errorCode.getStatusCode())
+ .body(apiResponse);
+ }
+
+ /**
+ * Xử lý ngoại lệ AccessDeniedException khi người dùng không có quyền truy cập.
+ *
+ * @param exception ngoại lệ AccessDeniedException
+ * @return ResponseEntity chứa ApiResponse với thông tin lỗi truy cập
+ */
+ @ExceptionHandler(value = AccessDeniedException.class)
+ ResponseEntity> handlingAccessDeniedException(
+ AccessDeniedException exception) {
+ ErrorCode errorCode = ErrorCode.UNAUTHORIZED;
+
+ ApiResponse apiResponse = ApiResponse.builder()
+ .code(errorCode.getCode())
+ .message(errorCode.getMessage())
+ .status(errorCode.getStatus())
+ .build();
+
+ return ResponseEntity.status(errorCode.getStatusCode())
+ .body(apiResponse);
+ }
+
+ @ExceptionHandler(value = FeignException.class)
+ ResponseEntity handlingFeignException(FeignException exception) {
+ log.error("FeignException: " + exception.getMessage(), exception);
+
+ try {
+ // Lấy body lỗi từ service kia (UTF-8)
+ String body = exception.contentUTF8();
+
+ // Parse về ApiResponse nếu format giống của mình
+ ApiResponse apiResponse = objectMapper.readValue(body, ApiResponse.class);
+
+ return ResponseEntity.status(exception.status())
+ .body(apiResponse);
+
+ } catch (Exception e) {
+ // Nếu parse thất bại thì trả body thô
+ return ResponseEntity.status(exception.status())
+ .body(exception.contentUTF8());
+ }
+ }
+}
diff --git a/post-service/src/main/java/com/codecampus/post/repository/PostAccessRepository.java b/post-service/src/main/java/com/codecampus/post/repository/PostAccessRepository.java
new file mode 100644
index 00000000..35051b8e
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/repository/PostAccessRepository.java
@@ -0,0 +1,16 @@
+package com.codecampus.post.repository;
+
+import com.codecampus.post.entity.PostAccess;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository
+public interface PostAccessRepository extends JpaRepository {
+
+ List findByPost_PostId(String postId);
+
+ void deleteByPost_PostIdAndUserIdIn(String postId, List userIds);
+}
+
diff --git a/post-service/src/main/java/com/codecampus/post/repository/PostCommentRepository.java b/post-service/src/main/java/com/codecampus/post/repository/PostCommentRepository.java
new file mode 100644
index 00000000..338d3508
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/repository/PostCommentRepository.java
@@ -0,0 +1,16 @@
+package com.codecampus.post.repository;
+
+import com.codecampus.post.entity.PostComment;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository
+public interface PostCommentRepository extends JpaRepository {
+
+ List findByPost_PostIdAndParentCommentIsNullOrderByCommentIdDesc(String postId);
+
+ List findByParentComment_CommentIdOrderByCommentIdAsc(String parentCommentId);
+}
+
diff --git a/post-service/src/main/java/com/codecampus/post/repository/PostReactionRepository.java b/post-service/src/main/java/com/codecampus/post/repository/PostReactionRepository.java
new file mode 100644
index 00000000..69725e22
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/repository/PostReactionRepository.java
@@ -0,0 +1,16 @@
+package com.codecampus.post.repository;
+
+import com.codecampus.post.entity.PostAccess;
+import com.codecampus.post.entity.PostReaction;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+import java.util.Optional;
+
+@Repository
+public interface PostReactionRepository extends JpaRepository {
+ Optional findByPost_PostIdAndUserId(String postId, String userId);
+ Optional findByPost_PostIdAndUserIdAndCommentId(String postId, String userId, String commentId);
+ long countByPost_PostIdAndEmojiType(String postId, String emojiType);
+ long countByPost_PostIdAndCommentIdAndEmojiType(String postId, String commentId, String emojiType);
+}
diff --git a/post-service/src/main/java/com/codecampus/post/repository/PostRepository.java b/post-service/src/main/java/com/codecampus/post/repository/PostRepository.java
new file mode 100644
index 00000000..f421350b
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/repository/PostRepository.java
@@ -0,0 +1,62 @@
+package com.codecampus.post.repository;
+
+import com.codecampus.post.entity.Post;
+import feign.Param;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+import java.util.Optional;
+
+@Repository
+public interface PostRepository extends JpaRepository {
+ @Query("""
+ SELECT DISTINCT p FROM Post p
+ LEFT JOIN p.accesses a
+ WHERE p.isPublic = true OR a.userId = :userId
+""")
+ List findAccessiblePosts(String userId);
+
+ @Query("""
+ SELECT p FROM Post p
+ LEFT JOIN p.accesses a
+ WHERE p.postId = :postId AND (p.isPublic = true OR a.userId = :userId)
+""")
+ Optional findAccessiblePostById(String postId, String userId);
+
+ @Query("""
+ SELECT DISTINCT p FROM Post p
+ LEFT JOIN p.accesses pa
+ WHERE p.deletedAt IS NULL
+ AND (
+ p.postType = 'Global'
+ OR p.isPublic = true
+ OR (pa.userId = :userId AND (pa.isExcluded IS NULL OR pa.isExcluded = false))
+ )
+""")
+ Page findAllVisiblePosts(String userId, Pageable pageable);
+
+ @Query(value = """
+ SELECT DISTINCT p.*
+ FROM post p
+ LEFT JOIN post_access pa ON p.post_id = pa.post_id
+ WHERE p.deleted_at IS NULL
+ AND p.search_vector @@ plainto_tsquery('simple', :searchText)
+ AND (
+ p.post_type = 'Global'
+ OR p.is_public = true
+ OR (pa.user_id = :userId AND (pa.is_excluded IS NULL OR pa.is_excluded = false))
+ )
+ """,
+ nativeQuery = true)
+ Page searchVisiblePosts(
+ @Param("searchText") String searchText,
+ @Param("userId") String userId,
+ Pageable pageable
+ );
+
+
+}
diff --git a/post-service/src/main/java/com/codecampus/post/service/FeignConfig/FeignMultipartSupportConfig.java b/post-service/src/main/java/com/codecampus/post/service/FeignConfig/FeignMultipartSupportConfig.java
new file mode 100644
index 00000000..934b5d79
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/service/FeignConfig/FeignMultipartSupportConfig.java
@@ -0,0 +1,24 @@
+package com.codecampus.post.service.FeignConfig;
+
+import feign.codec.Encoder;
+import feign.form.spring.SpringFormEncoder;
+import org.springframework.cloud.openfeign.support.SpringEncoder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.beans.factory.ObjectFactory;
+import org.springframework.boot.autoconfigure.http.HttpMessageConverters;
+
+@Configuration
+public class FeignMultipartSupportConfig {
+
+ private final ObjectFactory messageConverters;
+
+ public FeignMultipartSupportConfig(ObjectFactory messageConverters) {
+ this.messageConverters = messageConverters;
+ }
+
+ @Bean
+ public Encoder feignFormEncoder() {
+ return new SpringFormEncoder(new SpringEncoder(messageConverters));
+ }
+}
diff --git a/post-service/src/main/java/com/codecampus/post/service/FeignConfig/FileServiceClient.java b/post-service/src/main/java/com/codecampus/post/service/FeignConfig/FileServiceClient.java
new file mode 100644
index 00000000..5ceab4cf
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/service/FeignConfig/FileServiceClient.java
@@ -0,0 +1,20 @@
+package com.codecampus.post.service.FeignConfig;
+
+import com.codecampus.post.dto.request.AddFileDocumentDto;
+import com.codecampus.post.dto.response.AddFileResponseDto;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.ModelAttribute;
+import org.springframework.web.bind.annotation.PostMapping;
+
+@FeignClient(name = "file-service",
+ url = "http://localhost:8082",
+ configuration = FeignMultipartSupportConfig.class)
+public interface FileServiceClient {
+
+ @PostMapping(
+ value = "/file/api/FileDocument/add",
+ consumes = MediaType.MULTIPART_FORM_DATA_VALUE
+ )
+ AddFileResponseDto uploadFile(@ModelAttribute AddFileDocumentDto dto);
+}
diff --git a/post-service/src/main/java/com/codecampus/post/service/PostAccessService.java b/post-service/src/main/java/com/codecampus/post/service/PostAccessService.java
new file mode 100644
index 00000000..e41aaad3
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/service/PostAccessService.java
@@ -0,0 +1,74 @@
+package com.codecampus.post.service;
+
+import com.codecampus.post.dto.response.PostAccessResponseDto;
+import com.codecampus.post.entity.PostAccess;
+import com.codecampus.post.dto.request.PostAccessRequestDto;
+import com.codecampus.post.entity.Post;
+import com.codecampus.post.repository.PostAccessRepository;
+import com.codecampus.post.repository.PostRepository;
+import jakarta.transaction.Transactional;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+@Service
+@RequiredArgsConstructor
+public class PostAccessService {
+
+ private final PostAccessRepository postAccessRepository;
+ private final PostRepository postRepository;
+
+ // Thêm hoặc cập nhật quyền truy cập cho nhiều user
+ @Transactional
+ public void saveOrUpdateAccess(PostAccessRequestDto dto) {
+ Post post = postRepository.findById(dto.getPostId())
+ .orElseThrow(() -> new RuntimeException("Post not found"));
+
+ // lấy danh sách userId đã có
+ Set existingUserIds = postAccessRepository.findByPost_PostId(dto.getPostId())
+ .stream()
+ .map(PostAccess::getUserId)
+ .collect(Collectors.toSet());
+
+ // chỉ giữ lại userId chưa có
+ List newAccessList = dto.getUserIds().stream()
+ .filter(userId -> !existingUserIds.contains(userId))
+ .map(userId -> {
+ PostAccess pa = new PostAccess();
+ pa.setPost(post);
+ pa.setUserId(userId);
+ pa.setIsExcluded(dto.getIsExcluded());
+ return pa;
+ })
+ .toList();
+
+ if (!newAccessList.isEmpty()) {
+ postAccessRepository.saveAll(newAccessList);
+ }
+ }
+
+
+ // Xoá quyền của nhiều user
+ @Transactional
+ public void deleteAccess(PostAccessRequestDto dto) {
+ postAccessRepository.deleteByPost_PostIdAndUserIdIn(dto.getPostId(), dto.getUserIds());
+ }
+
+ // Lấy danh sách quyền của 1 bài post
+ @Transactional
+ public List getAccessByPostId(String postId) {
+ return postAccessRepository.findByPost_PostId(postId).stream()
+ .map(pa -> PostAccessResponseDto.builder()
+ .postId(pa.getPost().getPostId())
+ .userId(pa.getUserId())
+ .isExcluded(Boolean.TRUE.equals(pa.getIsExcluded()))
+ .build()
+ )
+ .toList();
+ }
+
+}
+
diff --git a/post-service/src/main/java/com/codecampus/post/service/PostCommentService.java b/post-service/src/main/java/com/codecampus/post/service/PostCommentService.java
new file mode 100644
index 00000000..48da42f1
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/service/PostCommentService.java
@@ -0,0 +1,166 @@
+package com.codecampus.post.service;
+
+import com.codecampus.post.config.CustomJwtDecoder;
+import com.codecampus.post.dto.request.CommentRequestDto;
+import com.codecampus.post.dto.request.UpdateCommentDto;
+import com.codecampus.post.dto.response.CommentResponseDto;
+import com.codecampus.post.entity.Post;
+import com.codecampus.post.entity.PostComment;
+import com.codecampus.post.repository.PostCommentRepository;
+import com.codecampus.post.repository.PostRepository;
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.transaction.Transactional;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.stream.Stream;
+
+@Service
+@RequiredArgsConstructor
+public class PostCommentService {
+
+ private final PostCommentRepository postCommentRepository;
+ private final PostRepository postRepository;
+ private final CustomJwtDecoder customJwtDecoder;
+
+ @Transactional
+ public PostComment addComment(CommentRequestDto dto, HttpServletRequest request) {
+ String token = request.getHeader("Authorization");
+ if(token == null || !token.startsWith("Bearer ")) {
+ throw new IllegalArgumentException("Authorization token is missing or invalid");
+ }
+ String userId = customJwtDecoder.decode(token.substring(7)).getClaims().get("userId").toString(); // Assuming user ID is stored in the principal
+
+ Post post = postRepository.findById(dto.getPostId())
+ .orElseThrow(() -> new RuntimeException("Post not found"));
+
+ PostComment comment = new PostComment();
+ comment.setPost(post);
+ comment.setUserId(userId);
+ comment.setContent(dto.getContent());
+
+ if (dto.getParentCommentId() != null) {
+ PostComment parent = postCommentRepository.findById(dto.getParentCommentId())
+ .orElseThrow(() -> new RuntimeException("Parent comment not found"));
+ comment.setParentComment(parent);
+ }
+
+ return postCommentRepository.save(comment);
+ }
+
+ public List getCommentsByPost(String postId) {
+ List parents = postCommentRepository
+ .findByPost_PostIdAndParentCommentIsNullOrderByCommentIdDesc(postId);
+
+ return parents.stream()
+ .filter(c -> !c.isDeleted()) // chỉ lấy comment chưa xóa
+ .map(c -> mapWithLimitDepth(c, 1)) // bắt đầu từ depth = 1
+ .toList();
+ }
+
+ private CommentResponseDto mapWithLimitDepth(PostComment comment, int depth) {
+ List replyDtos;
+
+ if (depth < 2) {
+ // cấp 1 -> cho phép lấy reply
+ replyDtos = comment.getReplies() != null
+ ? comment.getReplies().stream()
+ .filter(r -> !r.isDeleted())
+ .flatMap(r -> {
+ if (depth + 1 < 2) {
+ // vẫn còn trong giới hạn, tiếp tục đệ quy
+ return Stream.of(mapWithLimitDepth(r, depth + 1));
+ } else {
+ // cấp 2 rồi, gom hết con/cháu thành cấp 2 luôn
+ return flattenReplies(r).stream();
+ }
+ })
+ .toList()
+ : List.of();
+ } else {
+ // depth >= 2 thì không bao giờ xảy ra vì ta dừng ở depth=1 rồi flatten
+ replyDtos = List.of();
+ }
+
+ return new CommentResponseDto(
+ comment.getCommentId(),
+ comment.getUserId(),
+ comment.getContent(),
+ replyDtos
+ );
+ }
+
+ /**
+ * Flatten toàn bộ reply từ comment con (cấp >= 2) thành danh sách cấp 2
+ */
+ private List flattenReplies(PostComment comment) {
+ List flatList = new ArrayList<>();
+
+ if (!comment.isDeleted()) {
+ flatList.add(new CommentResponseDto(
+ comment.getCommentId(),
+ comment.getUserId(),
+ comment.getContent(),
+ List.of() // ép thành cấp 2 -> không còn replies
+ ));
+ }
+
+ if (comment.getReplies() != null) {
+ for (PostComment child : comment.getReplies()) {
+ flatList.addAll(flattenReplies(child)); // đệ quy gom vào 1 list
+ }
+ }
+
+ return flatList;
+ }
+
+
+
+
+
+
+ @Transactional
+ public void updateComment(UpdateCommentDto requestDto, HttpServletRequest request) {
+ String token = request.getHeader("Authorization");
+ if(token == null || !token.startsWith("Bearer ")) {
+ throw new IllegalArgumentException("Authorization token is missing or invalid");
+ }
+ String userId = customJwtDecoder.decode(token.substring(7)).getClaims().get("userId").toString(); // Assuming user ID is stored in the principal
+ if (userId == null) {
+ throw new IllegalArgumentException("User ID is required for updating comment");
+ }
+
+ PostComment comment = postCommentRepository.findById(requestDto.getCommentId())
+ .orElseThrow(() -> new RuntimeException("Comment not found"));
+
+ if (!comment.getUserId().equals(userId)) {
+ throw new RuntimeException("Not allowed to edit this comment");
+ }
+
+ comment.setContent(requestDto.getContent());
+ postCommentRepository.save(comment);
+ }
+
+ @Transactional
+ public void deleteComment(String commentId, HttpServletRequest request) {
+ String token = request.getHeader("Authorization");
+ if (token == null || !token.startsWith("Bearer ")) {
+ throw new IllegalArgumentException("Authorization token is missing or invalid");
+ }
+ String userId = customJwtDecoder.decode(token.substring(7)).getClaims().get("userId").toString();
+ if (userId == null) {
+ throw new IllegalArgumentException("User ID is required for deleting comment");
+ }
+
+ PostComment comment = postCommentRepository.findById(commentId)
+ .orElseThrow(() -> new RuntimeException("Comment not found"));
+
+ if (!comment.isDeleted()) {
+ comment.markDeleted(userId);
+ postCommentRepository.save(comment);
+ }
+ }
+}
+
diff --git a/post-service/src/main/java/com/codecampus/post/service/PostReactionService.java b/post-service/src/main/java/com/codecampus/post/service/PostReactionService.java
new file mode 100644
index 00000000..60223be7
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/service/PostReactionService.java
@@ -0,0 +1,97 @@
+package com.codecampus.post.service;
+
+import com.codecampus.post.config.CustomJwtDecoder;
+import com.codecampus.post.dto.request.PostReactionRequestDto;
+import com.codecampus.post.entity.Post;
+import com.codecampus.post.entity.PostReaction;
+import com.codecampus.post.repository.PostReactionRepository;
+import com.codecampus.post.repository.PostRepository;
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.transaction.Transactional;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Optional;
+
+@Service
+@RequiredArgsConstructor
+public class PostReactionService {
+ private final PostReactionRepository postReactionRepository;
+ private final PostRepository postRepository;
+ private final CustomJwtDecoder customJwtDecoder;
+
+ @Transactional
+ public void toggleReaction(PostReactionRequestDto requestDto, HttpServletRequest request) {
+ String token = request.getHeader("Authorization");
+ if (token == null || !token.startsWith("Bearer ")) {
+ throw new IllegalArgumentException("Authorization token is missing or invalid");
+ }
+
+ String userId = customJwtDecoder.decode(token.substring(7))
+ .getClaims()
+ .get("userId")
+ .toString();
+
+ if (userId == null) {
+ throw new IllegalArgumentException("User ID is required for post reaction");
+ }
+
+ // Kiểm tra reaction đã tồn tại chưa
+ Optional existingReaction = (requestDto.getCommentId() != null)
+ ? postReactionRepository.findByPost_PostIdAndUserIdAndCommentId(
+ requestDto.getPostId(), userId, requestDto.getCommentId())
+ : postReactionRepository.findByPost_PostIdAndUserId(
+ requestDto.getPostId(), userId);
+
+ if (existingReaction.isPresent()) {
+ PostReaction reaction = existingReaction.get();
+
+ if (reaction.getEmojiType().equals(requestDto.getReactionType())) {
+ // Nếu user bấm lại cùng loại reaction -> xóa
+ postReactionRepository.delete(reaction);
+ return;
+ } else {
+ // Nếu user chọn reaction khác -> update
+ reaction.setEmojiType(requestDto.getReactionType());
+ postReactionRepository.save(reaction);
+ return;
+ }
+ }
+
+ //chưa có reaction nào -> tạo mới
+ Post post = postRepository.findById(requestDto.getPostId())
+ .orElseThrow(() -> new RuntimeException("Post not found"));
+
+ PostReaction newReaction = new PostReaction();
+ newReaction.setPost(post);
+ newReaction.setUserId(userId);
+ newReaction.setCommentId(requestDto.getCommentId());
+ newReaction.setEmojiType(requestDto.getReactionType());
+
+ postReactionRepository.save(newReaction);
+ }
+
+ @Transactional
+ public Map getReactionCount(String postId, String commentId) {
+ long upvotes;
+ long downvotes;
+
+ if (commentId == null) {
+ // Reaction cho post
+ upvotes = postReactionRepository.countByPost_PostIdAndEmojiType(postId, "upvote");
+ downvotes = postReactionRepository.countByPost_PostIdAndEmojiType(postId, "downvote");
+ } else {
+ // Reaction cho comment trong post
+ upvotes = postReactionRepository.countByPost_PostIdAndCommentIdAndEmojiType(postId, commentId, "upvote");
+ downvotes = postReactionRepository.countByPost_PostIdAndCommentIdAndEmojiType(postId, commentId, "downvote");
+ }
+
+ Map result = new HashMap<>();
+ result.put("upvote", upvotes);
+ result.put("downvote", downvotes);
+ return result;
+ }
+
+}
diff --git a/post-service/src/main/java/com/codecampus/post/service/PostService.java b/post-service/src/main/java/com/codecampus/post/service/PostService.java
new file mode 100644
index 00000000..430a4186
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/service/PostService.java
@@ -0,0 +1,197 @@
+package com.codecampus.post.service;
+
+
+import com.codecampus.post.Mapper.PostMapper;
+import com.codecampus.post.config.CustomJwtDecoder;
+import com.codecampus.post.dto.common.PageRequestDto;
+import com.codecampus.post.dto.common.PageResponse;
+import com.codecampus.post.dto.request.AddFileDocumentDto;
+import com.codecampus.post.dto.request.PostRequestDto;
+import com.codecampus.post.dto.response.AddFileResponseDto;
+import com.codecampus.post.entity.Post;
+import com.codecampus.post.exception.AppException;
+import com.codecampus.post.exception.ErrorCode;
+import com.codecampus.post.repository.PostRepository;
+import com.codecampus.post.service.FeignConfig.FileServiceClient;
+import jakarta.servlet.http.HttpServletRequest;
+import lombok.AllArgsConstructor;
+import lombok.RequiredArgsConstructor;
+import org.springframework.context.annotation.Lazy;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.domain.Sort;
+import org.springframework.http.MediaType;
+import org.springframework.stereotype.Service;
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.imageio.ImageIO;
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.http.HttpHeaders;
+import java.util.*;
+import java.util.stream.Collectors;
+
+@Service
+@RequiredArgsConstructor
+public class PostService {
+ private final CustomJwtDecoder customJwtDecoder;
+ private final PostRepository postRepository;
+ private final PostMapper postMapper;
+ private final FileServiceClient fileServiceClient;
+
+ public PageResponse getAllAccessiblePosts(HttpServletRequest request, PageRequestDto pageRequestDto) {
+ String token = request.getHeader("Authorization");
+ String userId = customJwtDecoder.decode(token.substring(7)).getClaims().get("userId").toString();
+ Pageable pageable = PageRequest.of(pageRequestDto.getPage(), pageRequestDto.getSize(), Sort.by("createdAt").descending());
+ Page postPage = postRepository.findAllVisiblePosts(userId, pageable);
+
+ return PageResponse.builder()
+ .currentPage(postPage.getNumber())
+ .totalPages(postPage.getTotalPages())
+ .pageSize(postPage.getSize())
+ .totalElements(postPage.getTotalElements())
+ .data(postPage.getContent())
+ .build();
+ }
+
+ public PageResponse SeachPosts(String searchText, HttpServletRequest request, PageRequestDto pageRequestDto) {
+ String token = request.getHeader("Authorization");
+ String userId = customJwtDecoder.decode(token.substring(7)).getClaims().get("userId").toString();
+ Pageable pageable = PageRequest.of(pageRequestDto.getPage(), pageRequestDto.getSize(), Sort.by("created_at").descending());
+ Page postPage = postRepository.searchVisiblePosts(searchText, userId, pageable);
+
+ return PageResponse.builder()
+ .currentPage(postPage.getNumber())
+ .totalPages(postPage.getTotalPages())
+ .pageSize(postPage.getSize())
+ .totalElements(postPage.getTotalElements())
+ .data(postPage.getContent())
+ .build();
+ }
+
+// public Optional getPostByIdIfAccessible(String postId, HttpServletRequest request) {
+// String token = request.getHeader("Authorization");
+// String userId = customJwtDecoder.decode(token.substring(7)).getClaims().get("userId").toString();
+// return postRepository.findAccessiblePostById(postId, userId)
+// .filter(post -> !post.isDeleted())
+// .map(postMapper::toDto);
+// }
+
+ public void createPost(PostRequestDto postRequestDto, HttpServletRequest request) {
+ String token = request.getHeader("Authorization");
+ String userId = customJwtDecoder.decode(token.substring(7))
+ .getClaims()
+ .get("userId")
+ .toString();
+
+ List fileUrls = Collections.emptyList();
+
+ var fileDoc = postRequestDto.getFileDocument();
+ if (fileDoc != null && fileDoc.getFile() != null && !fileDoc.getFile().isEmpty()) {
+
+ MultipartFile file = fileDoc.getFile();
+
+ // Kiểm tra file được tải lên có phải ảnh thật hay không
+ if (!isRealImage(file)) {
+ throw new AppException(ErrorCode.INVALID_FILE_TYPE);
+ }
+
+ // Upload file sau khi xác thực
+ AddFileResponseDto response = fileServiceClient.uploadFile(fileDoc);
+
+ // Nếu API C# trả result là String URL
+ fileUrls = Optional.ofNullable(response)
+ .map(AddFileResponseDto::getResult)
+ .map(List::of)
+ .orElse(Collections.emptyList());
+ }
+
+ Post post = postMapper.toEntity(postRequestDto);
+ post.setImagesUrls(fileUrls);
+ post.setUserId(userId);
+
+ postRepository.save(post);
+ }
+
+ public void updatePost(PostRequestDto postRequestDto, HttpServletRequest request) {
+ String token = request.getHeader("Authorization");
+ String userId = customJwtDecoder.decode(token.substring(7))
+ .getClaims()
+ .get("userId").toString();
+ String username = customJwtDecoder.decode(token.substring(7))
+ .getClaims()
+ .get("username").toString();
+
+ Optional optionalPost = postRepository.findById(postRequestDto.getPostId());
+ if (optionalPost.isEmpty()) throw new AppException(ErrorCode.POST_NOT_FOUND);
+
+ Post existingPost = optionalPost.get();
+
+ // Chỉ cho phép người tạo hoặc admin chỉnh sửa
+ if (!existingPost.getUserId().equals(userId) && !"admin".equals(username)) {
+ throw new AppException(ErrorCode.UNAUTHORIZED);
+ }
+
+ // Danh sách ảnh sau khi chỉnh sửa
+ List updatedImageUrls = new ArrayList<>();
+
+ // 1. Giữ lại ảnh cũ mà người dùng vẫn muốn giữ
+ if (postRequestDto.getOldImgesUrls() != null && !postRequestDto.getOldImgesUrls().isEmpty()) {
+ updatedImageUrls.addAll(
+ existingPost.getImagesUrls().stream()
+ .filter(url -> postRequestDto.getOldImgesUrls().contains(url))
+ .toList()
+ );
+ }
+
+ // 2. Nếu có ảnh mới thì kiểm tra và upload
+ if (postRequestDto.getFileDocument() != null &&
+ postRequestDto.getFileDocument().getFile() != null &&
+ !postRequestDto.getFileDocument().getFile().isEmpty()) {
+
+ MultipartFile file = postRequestDto.getFileDocument().getFile();
+ if (!isRealImage(file)) {
+ throw new AppException(ErrorCode.INVALID_FILE_TYPE);
+ }
+
+ // Upload ảnh mới
+ AddFileResponseDto response = fileServiceClient.uploadFile(postRequestDto.getFileDocument());
+ List newFileUrls = Optional.ofNullable(response)
+ .map(AddFileResponseDto::getResult)
+ .map(List::of)
+ .orElse(Collections.emptyList());
+
+ updatedImageUrls.addAll(newFileUrls);
+ }
+
+ // 3. Cập nhật các field khác
+ postMapper.updateEntityFromDto(postRequestDto, existingPost);
+ existingPost.setImagesUrls(updatedImageUrls);
+
+ postRepository.save(existingPost);
+ }
+
+
+ public void deletePost(String postId, HttpServletRequest request) {
+ String token = request.getHeader("Authorization");
+ String deletedBy = customJwtDecoder.decode(token.substring(7)).getClaims().get("username").toString();
+ Post post = postRepository.findById(postId)
+ .orElseThrow(() -> new IllegalArgumentException("Post not found with id: " + postId));
+ post.markDeleted(deletedBy);
+ postRepository.save(post);
+ }
+
+ public boolean isRealImage(MultipartFile file) {
+ try (InputStream input = file.getInputStream()) {
+ return ImageIO.read(input) != null;
+ } catch (IOException e) {
+ return false;
+ }
+ }
+
+
+}
+
diff --git a/post-service/src/main/java/com/codecampus/post/utils/ConvertUtils.java b/post-service/src/main/java/com/codecampus/post/utils/ConvertUtils.java
new file mode 100644
index 00000000..d7b12b6a
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/utils/ConvertUtils.java
@@ -0,0 +1,80 @@
+package com.codecampus.post.utils;
+
+import org.mapstruct.Named;
+
+import java.time.Instant;
+import java.time.LocalDate;
+import java.time.ZoneId;
+import java.time.ZoneOffset;
+import java.time.format.DateTimeFormatter;
+
+/**
+ * Tiện ích chuyển đổi giữa định dạng chuỗi ngày "dd/MM/yyyy"
+ * và đối tượng {@link Instant}.
+ *
+ * Cung cấp các phương thức:
+ *
+ * - {@link #parseDdMmYyyyToInstant(String)}: Chuyển chuỗi ngày sang {@code Instant} tại đầu ngày (00:00 UTC).
+ * - {@link #formatInstantToDdMmYyyyUtc(Instant)}: Định dạng {@code Instant} sang chuỗi ngày theo UTC.
+ * - {@link #formatInstantToDdMmYyyyLocal(Instant)}: Định dạng {@code Instant} sang chuỗi ngày theo múi giờ hệ thống.
+ *
+ *
+ */
+public class ConvertUtils {
+ // Định dạng dd/MM/yyyy
+ private static final DateTimeFormatter DMY_FORMATTER =
+ DateTimeFormatter.ofPattern("dd/MM/yyyy");
+
+ /**
+ * Chuyển chuỗi ngày có định dạng dd/MM/yyyy sang Instant (đầu ngày).
+ *
+ * @param dateStr chuỗi ngày theo định dạng "dd/MM/yyyy", ví dụ "31/12/2024"
+ * @return Instant tương ứng (thời điểm bắt đầu ngày đó) theo múi giờ hệ thống
+ */
+ @Named("DdMmYyyyToInstant")
+ public static Instant parseDdMmYyyyToInstant(String dateStr) {
+ if (dateStr == null || dateStr.isBlank()) {
+ return null;
+ }
+
+ // Parse thành LocalDate
+ LocalDate localDate = LocalDate.parse(dateStr, DMY_FORMATTER);
+ // Chuyển sang Instant tại thời điểm 00:00 của ngày, theo múi giờ hệ thống
+ return localDate.atStartOfDay(ZoneOffset.UTC).toInstant();
+ }
+
+ /**
+ * Chuyển Instant về chuỗi ngày "dd/MM/yyyy" tính theo UTC.
+ *
+ * @param instant thời điểm cần format
+ * @return chuỗi ngày dạng "dd/MM/yyyy"
+ */
+ @Named("instantToDdMmYyyyUTC")
+ public static String formatInstantToDdMmYyyyUtc(Instant instant) {
+ if (instant == null) {
+ return null;
+ }
+
+ return instant
+ .atZone(ZoneOffset.UTC)
+ .toLocalDate()
+ .format(DMY_FORMATTER);
+ }
+
+ /**
+ * Chuyển Instant về chuỗi ngày "dd/MM/yyyy" tính theo múi giờ hệ thống.
+ *
+ * @param instant thời điểm cần format
+ * @return chuỗi ngày dạng "dd/MM/yyyy"
+ */
+ public static String formatInstantToDdMmYyyyLocal(Instant instant) {
+ if (instant == null) {
+ return null;
+ }
+
+ return instant
+ .atZone(ZoneId.systemDefault())
+ .toLocalDate()
+ .format(DMY_FORMATTER);
+ }
+}
diff --git a/post-service/src/main/java/com/codecampus/post/utils/DateTimeFormatter.java b/post-service/src/main/java/com/codecampus/post/utils/DateTimeFormatter.java
new file mode 100644
index 00000000..d78f18b3
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/utils/DateTimeFormatter.java
@@ -0,0 +1,113 @@
+package com.codecampus.post.utils;
+
+import org.springframework.stereotype.Component;
+
+import java.time.Instant;
+import java.time.LocalDateTime;
+import java.time.ZoneId;
+import java.time.temporal.ChronoUnit;
+import java.util.LinkedHashMap;
+import java.util.Map;
+import java.util.function.Function;
+
+/**
+ * Tiện ích định dạng ngày giờ (DateTime) cho các thông báo hiển thị tương đối.
+ *
+ * Cung cấp phương thức format(Instant) để trả về chuỗi mô tả khoảng thời gian đã trôi qua:
+ *
+ * - Nếu dưới 60 giây, hiển thị "x second(s) ago".
+ * - Nếu dưới 60 phút, hiển thị "x minute(s) ago".
+ * - Nếu dưới 24 giờ, hiển thị "x hour(s) ago".
+ * - Nếu lớn hơn hoặc bằng 24 giờ, hiển thị ngày theo định dạng ISO (YYYY-MM-DD).
+ *
+ *
+ */
+@Component
+public class DateTimeFormatter {
+ /**
+ * Bản đồ chiến lược format dựa trên ngưỡng thời gian (giây).
+ * Key: số giây tối đa, Value: hàm format tương ứng.
+ */
+ Map> strategyMap = new LinkedHashMap<>();
+
+ /**
+ * Khởi tạo bản đồ chiến lược với các ngưỡng:
+ *
+ * - 60 giây → formatInSeconds()
+ * - 3600 giây (60 phút) → formatInMinutes()
+ * - 86400 giây (24 giờ) → formatInHours()
+ * - Long.MAX_VALUE → formatInDate()
+ *
+ */
+ public DateTimeFormatter() {
+ strategyMap.put(60L, this::formatInSeconds);
+ strategyMap.put(3600L, this::formatInMinutes);
+ strategyMap.put(86400L, this::formatInHours);
+ strategyMap.put(Long.MAX_VALUE, this::formatInDate);
+ }
+
+ /**
+ * Định dạng Instant thành chuỗi mô tả khoảng thời gian đã trôi qua.
+ *
+ * @param instant thời điểm cần định dạng
+ * @return chuỗi mô tả thời gian (ví dụ "5 minute(s) ago" hoặc "2025-06-14")
+ */
+ public String format(Instant instant) {
+ long elapseSeconds = ChronoUnit.SECONDS.between(instant, Instant.now());
+
+ var strategy = strategyMap.entrySet()
+ .stream()
+ .filter(longFunctionEntry -> elapseSeconds <
+ longFunctionEntry.getKey())
+ .findFirst().get();
+ return strategy.getValue().apply(instant);
+ }
+
+ /**
+ * Format khoảng thời gian tính theo giây.
+ *
+ * @param instant thời điểm cần so sánh
+ * @return "x second(s) ago"
+ */
+ private String formatInSeconds(Instant instant) {
+ long elapseSeconds = ChronoUnit.SECONDS.between(instant, Instant.now());
+ return String.format("%s second(s) ago", elapseSeconds);
+ }
+
+ /**
+ * Format khoảng thời gian tính theo phút.
+ *
+ * @param instant thời điểm cần so sánh
+ * @return "x minute(s) ago"
+ */
+ private String formatInMinutes(Instant instant) {
+ long elapseMinutes = ChronoUnit.MINUTES.between(instant, Instant.now());
+ return String.format("%s minute(s) ago", elapseMinutes);
+ }
+
+ /**
+ * Format khoảng thời gian tính theo giờ.
+ *
+ * @param instant thời điểm cần so sánh
+ * @return "x hour(s) ago"
+ */
+ private String formatInHours(Instant instant) {
+ long elapseHours = ChronoUnit.HOURS.between(instant, Instant.now());
+ return String.format("%s hour(s) ago", elapseHours);
+ }
+
+ /**
+ * Khi khoảng thời gian đã quá 24 giờ, format về chuỗi ngày ISO (YYYY-MM-DD).
+ *
+ * @param instant thời điểm cần định dạng
+ * @return chuỗi ngày ISO
+ */
+ private String formatInDate(Instant instant) {
+ LocalDateTime localDateTime =
+ instant.atZone(ZoneId.systemDefault()).toLocalDateTime();
+ java.time.format.DateTimeFormatter dateTimeFormatter =
+ java.time.format.DateTimeFormatter.ISO_DATE;
+
+ return localDateTime.format(dateTimeFormatter);
+ }
+}
diff --git a/post-service/src/main/java/com/codecampus/post/utils/PageResponseUtils.java b/post-service/src/main/java/com/codecampus/post/utils/PageResponseUtils.java
new file mode 100644
index 00000000..009389f8
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/utils/PageResponseUtils.java
@@ -0,0 +1,28 @@
+package com.codecampus.post.utils;
+
+import com.codecampus.post.dto.common.PageResponse;
+import org.springframework.data.domain.Page;
+
+public class PageResponseUtils {
+ private PageResponseUtils() {
+ }
+
+ /**
+ * Chuyển một {@link Page}<T> thành {@link PageResponse}<T>.
+ *
+ * @param pageData đối tượng Spring Data Page chứa dữ liệu và thông tin phân trang
+ * @param currentPage số trang hiện tại (bắt đầu từ 1)
+ * @param kiểu của phần tử trong trang
+ * @return {@link PageResponse}<T> tương ứng
+ */
+ public static PageResponse toPageResponse(Page pageData,
+ int currentPage) {
+ return PageResponse.builder()
+ .currentPage(currentPage)
+ .pageSize(pageData.getSize())
+ .totalPages(pageData.getTotalPages())
+ .totalElements(pageData.getTotalElements())
+ .data(pageData.getContent().stream().toList())
+ .build();
+ }
+}
diff --git a/post-service/src/main/java/com/codecampus/post/utils/SecurityUtils.java b/post-service/src/main/java/com/codecampus/post/utils/SecurityUtils.java
new file mode 100644
index 00000000..7df2c1d4
--- /dev/null
+++ b/post-service/src/main/java/com/codecampus/post/utils/SecurityUtils.java
@@ -0,0 +1,20 @@
+package com.codecampus.post.utils;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.security.core.context.SecurityContextHolder;
+
+/**
+ * Tiện ích hỗ trợ lấy thông tin người dùng hiện đang đăng nhập
+ * từ ngữ cảnh bảo mật của Spring Security.
+ */
+@Slf4j
+public class SecurityUtils {
+ /**
+ * Lấy ID của người dùng đã đăng nhập.
+ *
+ * @return chuỗi tên đăng nhập hoặc null nếu chưa xác thực
+ */
+ public static String getMyUserId() {
+ return SecurityContextHolder.getContext().getAuthentication().getName();
+ }
+}
diff --git a/post-service/src/main/resources/application.yml b/post-service/src/main/resources/application.yml
new file mode 100644
index 00000000..724ae936
--- /dev/null
+++ b/post-service/src/main/resources/application.yml
@@ -0,0 +1,31 @@
+server:
+ port: 8090
+
+ servlet:
+ context-path: /post
+
+file:
+ service:
+ file-url: http://localhost:8082
+
+spring:
+ application:
+ name: post-service
+ datasource:
+ url: jdbc:postgresql://localhost:5439/post_db
+ username: postgres_post
+ password: dinhanst2832004
+ driver-class-name: org.postgresql.Driver
+
+ jpa:
+ hibernate:
+ ddl-auto: update
+ properties:
+ hibernate:
+ dialect: org.hibernate.dialect.PostgreSQLDialect
+ show-sql: true
+
+ cloud:
+ openfeign:
+ multipart:
+ enabled: true
diff --git a/post-service/src/test/java/com/codecampus/post/PostServiceApplicationTests.java b/post-service/src/test/java/com/codecampus/post/PostServiceApplicationTests.java
new file mode 100644
index 00000000..11f7ce3f
--- /dev/null
+++ b/post-service/src/test/java/com/codecampus/post/PostServiceApplicationTests.java
@@ -0,0 +1,13 @@
+package com.codecampus.post;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest
+class PostServiceApplicationTests {
+
+ @Test
+ void contextLoads() {
+ }
+
+}
diff --git a/profile-service/src/main/java/com/codecampus/profile/repository/OrgRepository.java b/profile-service/src/main/java/com/codecampus/profile/repository/OrgRepository.java
index 13cde93c..7e9e2e97 100644
--- a/profile-service/src/main/java/com/codecampus/profile/repository/OrgRepository.java
+++ b/profile-service/src/main/java/com/codecampus/profile/repository/OrgRepository.java
@@ -15,6 +15,8 @@ public interface OrgRepository
@Query(value = """
MATCH (o:Organization {orgId:$orgId})-[a:ASSIGNED_ORG_EXERCISE]->(e:Exercise)
RETURN a, e ORDER BY e.title
+ SKIP $skip
+ LIMIT $limit
""",
countQuery = """
MATCH (o:Organization {orgId:$orgId})-[a:ASSIGNED_ORG_EXERCISE]->(:Exercise)
diff --git a/profile-service/src/main/java/com/codecampus/profile/repository/UserProfileRepository.java b/profile-service/src/main/java/com/codecampus/profile/repository/UserProfileRepository.java
index 63b881c7..aaf8fb5e 100644
--- a/profile-service/src/main/java/com/codecampus/profile/repository/UserProfileRepository.java
+++ b/profile-service/src/main/java/com/codecampus/profile/repository/UserProfileRepository.java
@@ -47,6 +47,8 @@ public interface UserProfileRepository
MATCH (u)-[completed:COMPLETED_EXERCISE]->(e:Exercise)
RETURN completed, e
ORDER BY completed.completedAt DESC
+ SKIP $skip
+ LIMIT $limit
""",
countQuery = """
MATCH (u:User {userId:$userId})
@@ -64,6 +66,8 @@ Page findCompletedExercises(
MATCH (u)-[saved:SAVED_EXERCISE]->(e:Exercise)
RETURN saved, e
ORDER BY saved.saveAt DESC
+ SKIP $skip
+ LIMIT $limit
""",
countQuery = """
MATCH (u:User {userId:$userId})
@@ -81,6 +85,8 @@ Page findSavedExercises(
MATCH (u)-[created:CREATED_EXERCISE]->(e:Exercise)
RETURN created, e
ORDER BY created.id DESC
+ SKIP $skip
+ LIMIT $limit
""",
countQuery = """
MATCH (u:User {userId:$userId})
@@ -100,6 +106,8 @@ Page findCreatedExercises(
MATCH (u)-[cs:CONTEST_STATUS]->(c:Contest)
RETURN cs, c
ORDER BY cs.updatedAt DESC
+ SKIP $skip
+ LIMIT $limit
""",
countQuery = """
MATCH (u:User {userId:$userId})
@@ -119,6 +127,8 @@ Page findContestStatuses(
MATCH (u)-[sp:SAVED_POST]->(p:Post)
RETURN sp, p
ORDER BY sp.saveAt DESC
+ SKIP $skip
+ LIMIT $limit
""",
countQuery = """
MATCH (u:User {userId:$userId})
@@ -136,6 +146,8 @@ Page findSavedPosts(
MATCH (u)-[r:REACTION]->(p:Post)
RETURN r, p
ORDER BY r.at DESC
+ SKIP $skip
+ LIMIT $limit
""",
countQuery = """
MATCH (u:User {userId:$userId})
@@ -153,6 +165,8 @@ Page findReactions(
MATCH (u)-[rp:REPORTED_POST]->(p:Post)
RETURN rp, p
ORDER BY rp.reportedAt DESC
+ SKIP $skip
+ LIMIT $limit
""",
countQuery = """
MATCH (u:User {userId:$userId})
@@ -172,6 +186,8 @@ Page findReportedPosts(
MATCH (u)-[:HAS_ACTIVITY]->(a:ActivityWeek)
RETURN a
ORDER BY a.weekStart DESC
+ SKIP $skip
+ LIMIT $limit
""",
countQuery = """
MATCH (u:User {userId:$userId})
@@ -192,6 +208,8 @@ Page findActivityWeek(
WHERE target.deletedAt IS NULL
RETURN f, target
ORDER BY f.since DESC
+ SKIP $skip
+ LIMIT $limit
""",
countQuery = """
MATCH (me:User {userId:$userId})
@@ -211,6 +229,8 @@ Page findFollowings(
WHERE src.deletedAt IS NULL
RETURN f, src
ORDER BY f.since DESC
+ SKIP $skip
+ LIMIT $limit
""",
countQuery = """
MATCH (me:User {userId:$userId})
@@ -230,6 +250,8 @@ Page findFollowers(
WHERE target.deletedAt IS NULL
RETURN b, target
ORDER BY b.since DESC
+ SKIP $skip
+ LIMIT $limit
""",
countQuery = """
MATCH (me:User {userId:$userId})
@@ -250,6 +272,8 @@ Page findBlocked(
MATCH (u)-[m:MEMBER_ORG]->(o:Organization)
RETURN m, o
ORDER BY m.joinAt DESC
+ SKIP $skip
+ LIMIT $limit
""",
countQuery = """
MATCH (u:User {userId:$userId})
@@ -268,6 +292,8 @@ Page findMemberOrgs(
WHERE m.memberRole = $role
RETURN m, o
ORDER BY m.joinAt DESC
+ SKIP $skip
+ LIMIT $limit
""",
countQuery = """
MATCH (u:User {userId:$userId})
@@ -287,6 +313,8 @@ Page findMemberOrgsByRole(
MATCH (u)-[c:CREATED_ORG]->(o:Organization)
RETURN c, o
ORDER BY c.createdAt DESC
+ SKIP $skip
+ LIMIT $limit
""",
countQuery = """
MATCH (u:User {userId:$userId})
@@ -306,6 +334,8 @@ Page findCreatedOrgs(
MATCH (u)-[s:SUBSCRIBED_TO]->(p:Package)
RETURN s, p
ORDER BY s.start DESC
+ SKIP $skip
+ LIMIT $limit
""",
countQuery = """
MATCH (u:User {userId:$userId})
@@ -326,6 +356,8 @@ Page findSubscriptions(
WHERE f.type = $type
RETURN sr, f
ORDER BY sr.saveAt DESC
+ SKIP $skip
+ LIMIT $limit
""",
countQuery = """
MATCH (u:User {userId:$userId})