Compare commits

...

13 Commits

67 changed files with 4060 additions and 15 deletions

View File

@ -7,6 +7,17 @@ plugins {
group = 'com.example'
version = '0.0.1-SNAPSHOT'
defaultTasks 'bootRun'
jar {
enabled = false
}
bootJar {
archiveFileName = String.format('%s-%s.jar', rootProject.name, version)
}
assert System.properties['java.specification.version'] == '17' || '21'
java {
sourceCompatibility = '17'
}
@ -17,6 +28,20 @@ repositories {
dependencies {
implementation 'org.springframework.boot:spring-boot-starter-web'
implementation 'org.springframework.boot:spring-boot-starter-validation'
implementation 'org.modelmapper:modelmapper:3.2.0'
implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
implementation 'com.h2database:h2:2.2.224'
implementation 'org.springframework.boot:spring-boot-starter-thymeleaf'
implementation 'nz.net.ultraq.thymeleaf:thymeleaf-layout-dialect:3.3.0'
runtimeOnly 'org.webjars.npm:bootstrap:5.3.3'
runtimeOnly 'org.webjars.npm:bootstrap-icons:1.11.3'
implementation 'org.springframework.boot:spring-boot-starter-security'
implementation 'org.thymeleaf.extras:thymeleaf-extras-springsecurity6'
testImplementation 'org.springframework.boot:spring-boot-starter-test'
}

BIN
demo/data.mv.db Normal file

Binary file not shown.

16
demo/data.trace.db Normal file
View File

@ -0,0 +1,16 @@
2024-05-09 02:41:49.382573+04:00 jdbc[3]: exception
org.h2.jdbc.JdbcSQLDataException: Значение слишком длинное для поля "PASSWORD CHARACTER VARYING(50)": "'$2a$10$YM/MDlXkV05Ub/UH4tBpje.TZwOiIwQjq4p0IR7B2fqu7Mmy9ZSDa' (60)"
Value too long for column "PASSWORD CHARACTER VARYING(50)": "'$2a$10$YM/MDlXkV05Ub/UH4tBpje.TZwOiIwQjq4p0IR7B2fqu7Mmy9ZSDa' (60)"; SQL statement:
insert into users (email,password,role,username,id) values (?,?,?,?,?) [22001-224]
2024-05-09 02:46:57.148068+04:00 jdbc[3]: exception
org.h2.jdbc.JdbcSQLDataException: Значение слишком длинное для поля "PASSWORD CHARACTER VARYING(50)": "'$2a$10$FdR5rNqZxx.1jTMZRYqQdulf0wQA5BhiaHiPtts6.A4gQxx9ewhTO' (60)"
Value too long for column "PASSWORD CHARACTER VARYING(50)": "'$2a$10$FdR5rNqZxx.1jTMZRYqQdulf0wQA5BhiaHiPtts6.A4gQxx9ewhTO' (60)"; SQL statement:
insert into users (email,password,role,username,id) values (?,?,?,?,?) [22001-224]
2024-05-09 02:51:16.045659+04:00 jdbc[3]: exception
org.h2.jdbc.JdbcSQLDataException: Значение слишком длинное для поля "PASSWORD CHARACTER VARYING(50)": "'$2a$10$IM6aq.HFxvzjN.lFnlLZ6.bhnhZXOy5LhiUDxJw4H4g7jYgCG/fou' (60)"
Value too long for column "PASSWORD CHARACTER VARYING(50)": "'$2a$10$IM6aq.HFxvzjN.lFnlLZ6.bhnhZXOy5LhiUDxJw4H4g7jYgCG/fou' (60)"; SQL statement:
insert into users (email,password,role,username,id) values (?,?,?,?,?) [22001-224]
2024-05-09 02:51:40.854637+04:00 jdbc[3]: exception
org.h2.jdbc.JdbcSQLDataException: Значение слишком длинное для поля "PASSWORD CHARACTER VARYING(50)": "'$2a$10$O1UBIrRMyV37hUjtNBkilOcJ2V8QM4aMCE6Obuefr7rx.b6AXFiYi' (60)"
Value too long for column "PASSWORD CHARACTER VARYING(50)": "'$2a$10$O1UBIrRMyV37hUjtNBkilOcJ2V8QM4aMCE6Obuefr7rx.b6AXFiYi' (60)"; SQL statement:
insert into users (email,password,role,username,id) values (?,?,?,?,?) [22001-224]

View File

@ -1,13 +1,106 @@
package com.example.demo;
import java.time.LocalDateTime;
import java.util.List;
import java.util.Objects;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class DemoApplication {
import com.example.demo.messages.model.MessageEntity;
import com.example.demo.messages.service.MessageService;
import com.example.demo.orders.model.OrderEntity;
import com.example.demo.orders.service.OrderService;
import com.example.demo.types.model.TypeEntity;
import com.example.demo.types.service.TypeService;
import com.example.demo.users.model.UserEntity;
import com.example.demo.users.model.UserRole;
import com.example.demo.users.service.UserService;
@SpringBootApplication
public class DemoApplication implements CommandLineRunner {
// Логгер
private final Logger log = LoggerFactory.getLogger(DemoApplication.class);
// Бизнес-логика для сущности "Тип" (Тип книг)
private final TypeService typeService;
// Бизнес-логика для сущности "Заказ" (Заказ, содержащий книги)
private final OrderService orderService;
// Бизнес-логика для сущности "Пользователь"
private final UserService userService;
// Бизнес-логика для сущности "Сообщение"
private final MessageService messageService;
// Конструктор
public DemoApplication(
TypeService typeService,
OrderService orderService,
UserService userService,
MessageService messageService) {
this.typeService = typeService;
this.orderService = orderService;
this.userService = userService;
this.messageService = messageService;
}
// Входная точка программы
public static void main(String[] args) {
SpringApplication.run(DemoApplication.class, args);
}
@Override
public void run(String... args) throws Exception {
if (args.length > 0 && Objects.equals("--populate", args[0])) {
log.info("Create default types values");
final var type1 = typeService.create(new TypeEntity("Protection"));
final var type2 = typeService.create(new TypeEntity("Sharpness"));
final var type3 = typeService.create(new TypeEntity("Infinity"));
log.info("Create default users values");
final var user1 = userService.create(new UserEntity("User1", "password", "mail1@gmail.com"));
final var user2 = userService.create(new UserEntity("User2", "password", "mail2@gmail.com"));
final var user3 = userService.create(new UserEntity("User3", "password", "mail3@gmail.com"));
final var admin = new UserEntity("admin", "admin", "admin@gmail.com");
admin.setRole(UserRole.ADMIN);
userService.create(admin);
log.info("Create default order values");
final var orders = List.of(
new OrderEntity(type1, 12.00, 3),
new OrderEntity(type1, 50.00, 20),
new OrderEntity(type2, 15.00, 30),
new OrderEntity(type2, 64.00, 10),
new OrderEntity(type2, 15.00, 6),
new OrderEntity(type3, 80.00, 6),
new OrderEntity(type3, 64.00, 3)
);
orders.forEach(order -> orderService.create(user1.getId(), order));
log.info("Create default messages values");
final var messages1 = List.of(
new MessageEntity("Message1", LocalDateTime.now(), true),
new MessageEntity("Message2", LocalDateTime.now(), false),
new MessageEntity("Message3", LocalDateTime.now(), true)
);
messages1.forEach(message -> messageService.create(user1.getId(), message));
final var messages2 = List.of(
new MessageEntity("Message4", LocalDateTime.now(), false),
new MessageEntity("Message5", LocalDateTime.now(), true)
);
messages2.forEach(message -> messageService.create(user2.getId(), message));
final var messages3 = List.of(
new MessageEntity("Message6", LocalDateTime.now(), false),
new MessageEntity("Message7", LocalDateTime.now(), true)
);
messages3.forEach(message -> messageService.create(user3.getId(), message));
}
}
}

View File

@ -0,0 +1,33 @@
package com.example.demo.core.api;
import org.springframework.web.bind.annotation.ControllerAdvice;
import org.springframework.web.bind.annotation.ModelAttribute;
import com.example.demo.core.session.SessionCart;
import jakarta.servlet.http.HttpServletRequest;
import jakarta.servlet.http.HttpSession;
// Глобальный контроллер
@ControllerAdvice
public class GlobalController {
// Корзина покупок сессии пользователя
private final SessionCart cart;
// Конструктор
public GlobalController(SessionCart cart) {
this.cart = cart;
}
// Получить сервле-путь
@ModelAttribute("servletPath")
String getRequestServletPath(HttpServletRequest request) {
return request.getServletPath();
}
// Получить общую сумму покупок в корзине
@ModelAttribute("totalCart")
double getTotalCart(HttpSession session) {
return cart.getSum();
}
}

View File

@ -0,0 +1,20 @@
package com.example.demo.core.api;
import java.util.Map;
import java.util.function.Function;
import org.springframework.data.domain.Page;
// Класс для преобразования страниц пагинации в атрибуты
public class PageAttributesMapper {
private PageAttributesMapper() {
}
// Метод преобразования
public static <E, D> Map<String, Object> toAttributes(String prefix, Page<E> page, Function<E, D> mapper) {
return Map.of(
prefix + "Items", page.getContent().stream().map(mapper::apply).toList(),
prefix + "CurrentPage", page.getNumber(),
prefix + "TotalPages", page.getTotalPages());
}
}

View File

@ -0,0 +1,28 @@
package com.example.demo.core.configuration;
// Класс для задания констант
public class Constants {
// Имя последовательности
public static final String SEQUENCE_NAME = "hibernate_sequence";
// Размер страницы пагинации
public static final int DEFAULT_PAGE_SIZE = 5;
// URL для перенавправления на другую страницу
public static final String REDIRECT_VIEW = "redirect:";
// Префикс для URL-адресов админ-панели
public static final String ADMIN_PREFIX = "/admin";
// URL для входа в систему
public static final String LOGIN_URL = "/login";
// URL для выхода из системы
public static final String LOGOUT_URL = "/logout";
// Пароль по умолчанию
public static final String DEFAULT_PASSWORD = "123456";
private Constants() {
}
}

View File

@ -0,0 +1,24 @@
package com.example.demo.core.configuration;
import org.modelmapper.ModelMapper;
import org.modelmapper.PropertyMap;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import com.example.demo.core.model.BaseEntity;
// Конфигурация для библиотеки ModelMapper
@Configuration
public class MapperConfiguration {
@Bean
ModelMapper modelMapper() {
final ModelMapper mapper = new ModelMapper();
mapper.addMappings(new PropertyMap<Object, BaseEntity>() {
@Override
protected void configure() {
skip(destination.getId());
}
});
return mapper;
}
}

View File

@ -0,0 +1,14 @@
package com.example.demo.core.configuration;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.ViewControllerRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
// Конфигурация для отключения Cors-проверки
@Configuration
public class WebConfiguration implements WebMvcConfigurer {
@Override
public void addViewControllers(ViewControllerRegistry registry) {
registry.addViewController("/login").setViewName("login");
}
}

View File

@ -0,0 +1,57 @@
package com.example.demo.core.error;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.core.annotation.AnnotationUtils;
import org.springframework.web.bind.annotation.ControllerAdvice;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.ResponseStatus;
import org.springframework.web.servlet.ModelAndView;
import jakarta.servlet.http.HttpServletRequest;
// Глобальный контроллер для обработки исключений
@ControllerAdvice
public class AdviceController {
private final Logger log = LoggerFactory.getLogger(AdviceController.class);
// Получение корневого исключения
private static Throwable getRootCause(Throwable throwable) {
Throwable rootCause = throwable;
while (rootCause.getCause() != null && rootCause.getCause() != rootCause) {
rootCause = rootCause.getCause();
}
return rootCause;
}
// Получение атрибутов исключения для обработки ошибок
private static Map<String, Object> getAttributes(HttpServletRequest request, Throwable throwable) {
final Throwable rootCause = getRootCause(throwable);
final StackTraceElement firstError = rootCause.getStackTrace()[0];
return Map.of(
"message", rootCause.getMessage(),
"url", request.getRequestURL(),
"exception", rootCause.getClass().getName(),
"file", firstError.getFileName(),
"method", firstError.getMethodName(),
"line", firstError.getLineNumber());
}
// Обработка исключений типа Exception
@ExceptionHandler(value = Exception.class)
public ModelAndView defaultErrorHandler(HttpServletRequest request, Throwable throwable) throws Throwable {
if (AnnotationUtils.findAnnotation(throwable.getClass(),
ResponseStatus.class) != null) {
throw throwable;
}
log.error("{}", throwable.getMessage());
throwable.printStackTrace();
final ModelAndView model = new ModelAndView();
model.addAllObjects(getAttributes(request, throwable));
model.setViewName("error");
return model;
}
}

View File

@ -0,0 +1,8 @@
package com.example.demo.core.error;
// Собственное непроверяемое исключение
public class NotFoundException extends RuntimeException {
public <T> NotFoundException(Class<T> clazz, Long id) {
super(String.format("%s with id [%s] is not found or not exists", clazz.getSimpleName(), id));
}
}

View File

@ -0,0 +1,33 @@
package com.example.demo.core.model;
import com.example.demo.core.configuration.Constants;
import jakarta.persistence.GeneratedValue;
import jakarta.persistence.GenerationType;
import jakarta.persistence.Id;
import jakarta.persistence.MappedSuperclass;
import jakarta.persistence.SequenceGenerator;
// Абстрактный класс для базовой сущности
@MappedSuperclass
public abstract class BaseEntity {
// Идентфикатор
@Id
@GeneratedValue(strategy = GenerationType.SEQUENCE, generator = Constants.SEQUENCE_NAME)
@SequenceGenerator(name = Constants.SEQUENCE_NAME, sequenceName = Constants.SEQUENCE_NAME, allocationSize = 1)
protected Long id;
// Конструктор по умолчанию
protected BaseEntity() {
}
// Получить идентификатор
public Long getId() {
return id;
}
// Установить идентификатор
public void setId(Long id) {
this.id = id;
}
}

View File

@ -0,0 +1,67 @@
package com.example.demo.core.security;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.security.authentication.dao.DaoAuthenticationProvider;
import org.springframework.security.config.Customizer;
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.config.annotation.web.configurers.HeadersConfigurer.FrameOptionsConfig;
import org.springframework.security.core.userdetails.UserDetailsService;
import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
import org.springframework.security.crypto.password.PasswordEncoder;
import org.springframework.security.web.SecurityFilterChain;
import com.example.demo.core.configuration.Constants;
import com.example.demo.users.api.UserSignupController;
import com.example.demo.users.model.UserRole;
// Настройка безопасности веб-приложения
@Configuration
@EnableWebSecurity
public class SecurityConfiguration {
// Настройка цепочки фильтров безопасности
@Bean
SecurityFilterChain filterChain(HttpSecurity httpSecurity) throws Exception {
httpSecurity.headers(headers -> headers.frameOptions(FrameOptionsConfig::sameOrigin));
httpSecurity.csrf(AbstractHttpConfigurer::disable);
httpSecurity.cors(Customizer.withDefaults());
httpSecurity.authorizeHttpRequests(requests -> requests
.requestMatchers("/css/**", "/webjars/**", "/*.png")
.permitAll());
httpSecurity.authorizeHttpRequests(requests -> requests
.requestMatchers(Constants.ADMIN_PREFIX + "/**").hasRole(UserRole.ADMIN.name())
.requestMatchers("/h2-console/**").hasRole(UserRole.ADMIN.name())
.requestMatchers(UserSignupController.URL).anonymous()
.requestMatchers(Constants.LOGIN_URL).anonymous()
.anyRequest().authenticated());
httpSecurity.formLogin(formLogin -> formLogin
.loginPage(Constants.LOGIN_URL));
httpSecurity.rememberMe(rememberMe -> rememberMe.key("uniqueAndSecret"));
httpSecurity.logout(logout -> logout
.deleteCookies("JSESSIONID"));
return httpSecurity.build();
}
// Провайдер аутентификации
@Bean
DaoAuthenticationProvider authenticationProvider(UserDetailsService userDetailsService) {
final DaoAuthenticationProvider authProvider = new DaoAuthenticationProvider();
authProvider.setUserDetailsService(userDetailsService);
authProvider.setPasswordEncoder(passwordEncoder());
return authProvider;
}
// Шифрование пароля
@Bean
PasswordEncoder passwordEncoder() {
return new BCryptPasswordEncoder();
}
}

View File

@ -0,0 +1,82 @@
package com.example.demo.core.security;
import java.util.Collection;
import java.util.Set;
import org.springframework.security.core.GrantedAuthority;
import org.springframework.security.core.userdetails.UserDetails;
import com.example.demo.users.model.UserEntity;
// Класс для аутентификации пользователя
public class UserPrincipal implements UserDetails {
// Идентификатор
private final long id;
// Имя/логин пользователя
private final String username;
// Пароль пользователя
private final String password;
// Список ролей пользователя
private final Set<? extends GrantedAuthority> roles;
// Активный аккаунт
private final boolean active;
public UserPrincipal(UserEntity user) {
this.id = user.getId();
this.username = user.getUsername();
this.password = user.getPassword();
this.roles = Set.of(user.getRole());
this.active = true;
}
// Получить идентификатор
public Long getId() {
return id;
}
// Получить имя/логин пользователя
@Override
public String getUsername() {
return username;
}
// Получить пароль пользователя
@Override
public String getPassword() {
return password;
}
// Получить список ролей пользователя
@Override
public Collection<? extends GrantedAuthority> getAuthorities() {
return roles;
}
// Получить признак активности пользователя
@Override
public boolean isEnabled() {
return active;
}
// Признак актуальности учетной записи пользователя
@Override
public boolean isAccountNonExpired() {
return isEnabled();
}
// Признак блокировки пользователя
@Override
public boolean isAccountNonLocked() {
return isEnabled();
}
// Признак актуальности учетной записи пользователя
@Override
public boolean isCredentialsNonExpired() {
return isEnabled();
}
}

View File

@ -0,0 +1,16 @@
package com.example.demo.core.session;
import java.util.HashMap;
import com.example.demo.users.api.UserCartDto;
// Корзина покупок пользователя для текущей сессии
public class SessionCart extends HashMap<Integer, UserCartDto> {
// Получить общую сумму корзины покупок пользователя
public double getSum() {
return this.values().stream()
.map(item -> item.getCount() * item.getPrice())
.mapToDouble(Double::doubleValue)
.sum();
}
}

View File

@ -0,0 +1,18 @@
package com.example.demo.core.session;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Scope;
import org.springframework.context.annotation.ScopedProxyMode;
import org.springframework.web.context.WebApplicationContext;
// Класс конфигурации для управления сессионными компонентами
@Configuration
public class SessionHelper {
// Определение компонента SessionCart
@Bean
@Scope(value = WebApplicationContext.SCOPE_SESSION, proxyMode = ScopedProxyMode.TARGET_CLASS)
SessionCart todos() {
return new SessionCart();
}
}

View File

@ -0,0 +1,104 @@
package com.example.demo.messages.api;
import java.util.Map;
import org.modelmapper.ModelMapper;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.servlet.mvc.support.RedirectAttributes;
import com.example.demo.core.api.PageAttributesMapper;
import com.example.demo.core.configuration.Constants;
import com.example.demo.messages.model.MessageEntity;
import com.example.demo.messages.service.MessageService;
// Контроллер для сущности "Сообщение"
@Controller
@RequestMapping(MessageController.URL)
public class MessageController {
// URL для доступа к методам контроллера
public static final String URL = "/message";
// Представление для отображения списка сообщений
private static final String MESSAGE_VIEW = "messages";
// Атрибут модели для пагинации
private static final String PAGE_ATTRIBUTE = "page";
// Бизнес-логика для сущности "Сообщение"
private final MessageService messageService;
// Библиотека для преобразования сущности
private final ModelMapper modelMapper;
// Конструктор
public MessageController(MessageService messageService, ModelMapper modelMapper) {
this.messageService = messageService;
this.modelMapper = modelMapper;
}
// Преобразовать из сущности в DTO
private MessageDto toDto(MessageEntity entity) {
return modelMapper.map(entity, MessageDto.class);
}
// Получить все элементы
@PreAuthorize("hasRole('ADMIN')")
@GetMapping
public String getAll(
@RequestParam(name = PAGE_ATTRIBUTE, defaultValue = "0") int page,
Model model) {
final Map<String, Object> attributes = PageAttributesMapper.toAttributes(
"message",
messageService.getAll(0L, page, Constants.DEFAULT_PAGE_SIZE), this::toDto);
model.addAllAttributes(attributes);
model.addAttribute(PAGE_ATTRIBUTE, page);
return MESSAGE_VIEW;
}
// Получить опубликованные сообщения с пагинацией
@GetMapping("/published")
public String getPublishedMessages(
@RequestParam(name = PAGE_ATTRIBUTE, defaultValue = "0") int page,
Model model) {
final Map<String, Object> attributes = PageAttributesMapper.toAttributes(
"message",
messageService.getPublishedMessages(page, Constants.DEFAULT_PAGE_SIZE), this::toDto);
model.addAllAttributes(attributes);
model.addAttribute(PAGE_ATTRIBUTE, page);
return MESSAGE_VIEW;
}
// Удалить элемент
@PreAuthorize("hasRole('ADMIN')")
@PostMapping("/delete/{id}")
public String delete(
@PathVariable(name = "id") Long id,
@RequestParam(name = PAGE_ATTRIBUTE, defaultValue = "0") int page,
RedirectAttributes redirectAttributes) {
redirectAttributes.addAttribute(PAGE_ATTRIBUTE, page);
final var messageEntity = messageService.get(id);
messageService.delete(messageEntity.getUser().getId(), id);
return Constants.REDIRECT_VIEW + URL;
}
// Опубликовать сообщение
@PreAuthorize("hasRole('ADMIN')")
@PostMapping("/publish/{id}")
public String publish(
@PathVariable(name = "id") Long id,
@RequestParam(name = PAGE_ATTRIBUTE, defaultValue = "0") int page,
RedirectAttributes redirectAttributes) {
redirectAttributes.addAttribute(PAGE_ATTRIBUTE, page);
final var messageEntity = messageService.get(id);
messageEntity.setIsPublished(true);
messageService.update(messageEntity.getUser().getId(), id, messageEntity);
return Constants.REDIRECT_VIEW + URL;
}
}

View File

@ -0,0 +1,77 @@
package com.example.demo.messages.api;
import java.time.LocalDateTime;
import com.fasterxml.jackson.annotation.JsonProperty;
import jakarta.validation.constraints.NotBlank;
// DTO для сущности "Сообщение"
public class MessageDto {
// Идентфикатор
private Long id;
// Электронная почта отправителя
private String userEmail;
// Текст сообщения
@NotBlank
private String text;
// Дата отправки
private LocalDateTime date;
// Признак публикации сообщения
@JsonProperty(defaultValue = "false")
private boolean isPublished;
// Получить идентификатор
public Long getId() {
return id;
}
// Установить идентификатор
public void setId(Long id) {
this.id = id;
}
// Получить элктронную почту отправителя сообщения
public String getUserEmail() {
return userEmail;
}
// Установить электронную почту отправителя сообщения
public void setUserEmail(String userEmail) {
this.userEmail = userEmail;
}
// Получить текст сообщения
public String getText() {
return text;
}
// Установить текст сообщения
public void setText(String text) {
this.text = text;
}
// Получить дату отправления
public LocalDateTime getDate() {
return date;
}
// Установить дату отправления
public void setDate(LocalDateTime date) {
this.date = date;
}
// Получить признак публикации сообщения
public boolean getIsPublished() {
return isPublished;
}
// Установить признак публикации сообщения
public void setIsPublished(boolean isPublished) {
this.isPublished = isPublished;
}
}

View File

@ -0,0 +1,110 @@
package com.example.demo.messages.model;
import java.time.LocalDateTime;
import java.util.Objects;
import com.example.demo.core.model.BaseEntity;
import com.example.demo.users.model.UserEntity;
import jakarta.persistence.Entity;
import jakarta.persistence.JoinColumn;
import jakarta.persistence.ManyToOne;
import jakarta.persistence.Table;
import jakarta.persistence.Column;
// Сущность "Сообщение"
@Entity
@Table(name = "messages")
public class MessageEntity extends BaseEntity {
// Отправитель сообщения
@ManyToOne
@JoinColumn(name = "userId", nullable = false)
private UserEntity user;
// Текст сообщения
@Column(nullable = false)
private String text;
// Дата отправки
@Column(nullable = false)
private LocalDateTime date;
// Признак публикации сообщения
@Column(nullable = false)
private boolean isPublished;
// Конструктор по умолчанию
public MessageEntity() {
}
// Конструктор с параметрами для создания объекта
public MessageEntity(String text, LocalDateTime date, boolean isPublished) {
this.text = text;
this.date = date;
this.isPublished = isPublished;
}
// Получить отправителя
public UserEntity getUser() {
return user;
}
// Установить отправителя
public void setUser(UserEntity user) {
this.user = user;
if (!user.getMessages().contains(this)) {
user.getMessages().add(this);
}
}
// Получить текст сообщения
public String getText() {
return text;
}
// Установить текст сообщения
public void setText(String text) {
this.text = text;
}
// Получить дату отправления
public LocalDateTime getDate() {
return date;
}
// Установить дату отправления
public void setDate(LocalDateTime date) {
this.date = date;
}
// Получить признак публикации сообщения
public boolean getIsPublished() {
return isPublished;
}
// Установить признак публикации сообщения
public void setIsPublished(boolean isPublished) {
this.isPublished = isPublished;
}
// Получить хэш-код объекта
@Override
public int hashCode() {
return Objects.hash(id, user.getId(), text, date, isPublished);
}
// Сравнить объекты
@Override
public boolean equals(Object obj) {
if (this == obj)
return true;
if (obj == null || getClass() != obj.getClass())
return false;
final MessageEntity other = (MessageEntity) obj;
return Objects.equals(other.getId(), id)
&& Objects.equals(other.getUser().getId(), user.getId())
&& Objects.equals(other.getText(), text)
&& Objects.equals(other.getDate(), date)
&& Objects.equals(other.getIsPublished(), isPublished);
}
}

View File

@ -0,0 +1,35 @@
package com.example.demo.messages.repository;
import java.util.List;
import java.util.Optional;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.CrudRepository;
import org.springframework.data.repository.PagingAndSortingRepository;
import org.springframework.data.repository.query.Param;
import com.example.demo.messages.model.MessageEntity;
// Хранилище для сущности "Сообщение"
public interface MessageRepository extends CrudRepository<MessageEntity, Long>, PagingAndSortingRepository<MessageEntity, Long> {
// Получить сообщение по пользователю и идентификатору
Optional<MessageEntity> findOneByUserIdAndId(Long userId, Long id);
// Получить сообщение по идентификатору с предварительной загрузкой связанных сущностей
@Query("SELECT m FROM MessageEntity m JOIN FETCH m.user u LEFT JOIN FETCH u.messages WHERE m.id = :id")
Optional<MessageEntity> findByIdWithUser(@Param("id") Long id);
// Получить список всех сообщений (с пагинацией)
Page<MessageEntity> findAll(Pageable pageable);
// Получить список сообщений по пользователю
List<MessageEntity> findByUserId(Long userId);
// Получить список сообщений по пользователю (с пагинацией)
Page<MessageEntity> findByUserId(Long userId, Pageable pageable);
// Получить все опубликованные сообщения (с пагинацией)
Page<MessageEntity> findByIsPublishedTrue(Pageable pageable);
}

View File

@ -0,0 +1,117 @@
package com.example.demo.messages.service;
import java.util.List;
import java.util.stream.StreamSupport;
import org.hibernate.Hibernate;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.example.demo.core.error.NotFoundException;
import com.example.demo.messages.model.MessageEntity;
import com.example.demo.messages.repository.MessageRepository;
import com.example.demo.users.model.UserEntity;
import com.example.demo.users.service.UserService;
// Бизнес-логика для сущности "Сообщение"
@Service
public class MessageService {
// Хранилище элементов
private final MessageRepository repository;
// Бизнес-логика для отправителей (пользователей)
private final UserService userService;
// Конструктор
public MessageService(MessageRepository repository, UserService userService) {
this.repository = repository;
this.userService = userService;
}
// Получить все элементы или по заданному фильтру
@Transactional(readOnly = true)
public List<MessageEntity> getAll(Long userId) {
if (userId <= 0L) {
return StreamSupport.stream(repository.findAll().spliterator(), false).toList();
}
else {
userService.get(userId);
return repository.findByUserId(userId);
}
}
// Получить все элементы или по заданному фильтру (с пагинацией)
@Transactional(readOnly = true)
public Page<MessageEntity> getAll(Long userId, int page, int size) {
final PageRequest pageRequest = PageRequest.of(page, size);
if (userId <= 0L) {
return repository.findAll(pageRequest);
}
else {
userService.get(userId);
return repository.findByUserId(userId, pageRequest);
}
}
// Получить страницу опубликованных сообщений
@Transactional(readOnly = true)
public Page<MessageEntity> getPublishedMessages(int page, int size) {
final PageRequest pageRequest = PageRequest.of(page, size);
return repository.findByIsPublishedTrue(pageRequest);
}
// Получить элемент по идентификатору
@Transactional(readOnly = true)
public MessageEntity get(Long userId, Long id) {
userService.get(userId);
return repository.findOneByUserIdAndId(userId, id)
.orElseThrow(() -> new NotFoundException(MessageEntity.class, id));
}
// Получить элемент по идентификатору
@Transactional(readOnly = true)
public MessageEntity get(Long id) {
MessageEntity message = repository.findByIdWithUser(id)
.orElseThrow(() -> new NotFoundException(MessageEntity.class, id));
return message;
}
// Создать элемент
@Transactional
public MessageEntity create(Long userId, MessageEntity entity) {
if (entity == null) {
throw new IllegalArgumentException("Entity is null");
}
final UserEntity existsEntity = userService.get(userId);
entity.setUser(existsEntity);
return repository.save(entity);
}
// Изменить элемент
@Transactional
public MessageEntity update(Long userId, Long id, MessageEntity entity) {
userService.get(userId);
final MessageEntity existsEntity = get(userId, id);
existsEntity.setUser(entity.getUser());
existsEntity.setText(entity.getText());
existsEntity.setIsPublished(entity.getIsPublished());
return repository.save(existsEntity);
}
// Удалить элемент
@Transactional
public MessageEntity delete(Long userId, Long id) {
userService.get(userId);
final MessageEntity existsEntity = get(userId, id);
repository.delete(existsEntity);
return existsEntity;
}
// Удалить все элементы
@Transactional
public void deleteAll() {
repository.deleteAll();
}
}

View File

@ -0,0 +1,70 @@
package com.example.demo.orders.api;
import jakarta.validation.constraints.Min;
import jakarta.validation.constraints.NotNull;
// DTO для сущности "Заказ" (Заказ, содержащий книги)
public class OrderDto {
// Идентфикатор
private Long id;
// Название типа книги
@NotNull
@Min(1)
private String typeName;
// Цена книги
@NotNull
@Min(1)
private Double price;
// Количество книг
@NotNull
@Min(1)
private Integer count;
// Получить идентификатор
public Long getId() {
return id;
}
// Установить идентификатор
public void setId(Long id) {
this.id = id;
}
// Получить название типа книги
public String getTypeName() {
return typeName;
}
// Установить название типа книги
public void setTypeName(String typeName) {
this.typeName = typeName;
}
// Получить цену книги
public Double getPrice() {
return price;
}
// Установить цену книги
public void setPrice(Double price) {
this.price = price;
}
// Получить количество книг
public Integer getCount() {
return count;
}
// Установить количество книг
public void setCount(Integer count) {
this.count = count;
}
// Получить сумму заказа
public Double getSum() {
return price * count;
}
}

View File

@ -0,0 +1,43 @@
package com.example.demo.orders.api;
// DTO для заказов, сгруппированных по типу
public class OrderGroupedDto {
// Название типа
private String typeName;
// Общая стоимость заказов
private Long totalPrice;
// Общее количество заказов
private Integer totalCount;
// Получить название типа
public String getTypeName() {
return typeName;
}
// Установить название типа
public void setTypeName(String typeName) {
this.typeName = typeName;
}
// Получить общую стоимость заказов
public Long getTotalPrice() {
return totalPrice;
}
// Установить общую стоимость заказов
public void setTotalPrice(Long totalPrice) {
this.totalPrice = totalPrice;
}
// Получить общее количество заказов
public Integer getTotalCount() {
return totalCount;
}
// Установить общее количество заказов
public void setTotalCount(Integer totalCount) {
this.totalCount = totalCount;
}
}

View File

@ -0,0 +1,111 @@
package com.example.demo.orders.model;
import java.util.Objects;
import com.example.demo.core.model.BaseEntity;
import com.example.demo.types.model.TypeEntity;
import com.example.demo.users.model.UserEntity;
import jakarta.persistence.Column;
import jakarta.persistence.Entity;
import jakarta.persistence.JoinColumn;
import jakarta.persistence.ManyToOne;
import jakarta.persistence.Table;
// Сущность "Заказ" (Заказ, содержащий книги)
@Entity
@Table(name = "orders")
public class OrderEntity extends BaseEntity {
// Тип книги
@ManyToOne
@JoinColumn(name = "typeId", nullable = false)
private TypeEntity type;
// Заказчик (пользователь)
@ManyToOne
@JoinColumn(name = "userId", nullable = false)
private UserEntity user;
// Цена книги
@Column(nullable = false)
private Double price;
// Количество книг
@Column(nullable = false)
private Integer count;
// Конструктор по умолчанию
public OrderEntity() {
}
// Конструктор с параметрами для создания объекта
public OrderEntity(TypeEntity type, Double price, Integer count) {
this.type = type;
this.price = price;
this.count = count;
}
// Получить тип книги
public TypeEntity getType() {
return type;
}
// Установить тип книги
public void setType(TypeEntity type) {
this.type = type;
}
// Получить заказчика (пользователя)
public UserEntity getUser() {
return user;
}
// Установить заказчика (пользователя)
public void setUser(UserEntity user) {
this.user = user;
if (!user.getOrders().contains(this)) {
user.getOrders().add(this);
}
}
// Получить стоимость книги
public Double getPrice() {
return price;
}
// Установить стоимость книги
public void setPrice(Double price) {
this.price = price;
}
// Получить количество книг
public Integer getCount() {
return count;
}
// Установить количество книг
public void setCount(Integer count) {
this.count = count;
}
// Получить хэш-код объекта
@Override
public int hashCode() {
return Objects.hash(id, type, user.getId(), price, count);
}
// Сравнить объекты
@Override
public boolean equals(Object obj) {
if (this == obj)
return true;
if (obj == null || getClass() != obj.getClass())
return false;
final OrderEntity other = (OrderEntity) obj;
return Objects.equals(other.getId(), id)
&& Objects.equals(other.getType(), type)
&& Objects.equals(other.getUser().getId(), user.getId())
&& Objects.equals(other.getPrice(), price)
&& Objects.equals(other.getCount(), count);
}
}

View File

@ -0,0 +1,15 @@
package com.example.demo.orders.model;
import com.example.demo.types.model.TypeEntity;
// Заказы, сгруппированные по типу
public interface OrderGrouped {
// Тип заказов
TypeEntity getType();
// Общая сумма заказов
double getTotalPrice();
// Общее количество заказов
int getTotalCount();
}

View File

@ -0,0 +1,47 @@
package com.example.demo.orders.repository;
import java.util.Optional;
import java.util.List;
import org.springframework.data.repository.CrudRepository;
import org.springframework.data.repository.PagingAndSortingRepository;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.jpa.repository.Query;
import com.example.demo.orders.model.OrderEntity;
import com.example.demo.orders.model.OrderGrouped;
// Хранилище для сущности "Заказ" (Заказ, содержащий книги)
public interface OrderRepository extends CrudRepository<OrderEntity, Long>, PagingAndSortingRepository<OrderEntity, Long> {
// Получить заказ по пользователю и идентификатору
Optional<OrderEntity> findOneByUserIdAndId(Long userId, Long id);
// Получить список заказов по пользователю
List<OrderEntity> findByUserId(Long userId);
// Получить список заказов по пользователю (с пагинацией)
Page<OrderEntity> findByUserId(Long userId, Pageable pageable);
// Получить список заказов по типу
List<OrderEntity> findByUserIdAndTypeId(Long userId, Long typeId);
// Получить список заказов по типу (с пагинацией)
Page<OrderEntity> findByUserIdAndTypeId(Long userId, Long typeId, Pageable pageable);
// Получить заказы, сгруппированные по типу
// select
// type.name,
// coalesce(sum(order.price), 0),
// coalesce(sum(order.count), 0)
// from types as type
// left join orders as order on type.id = order.type_id and order.user_id = ?
// group by type.name order by type.id
@Query("select "
+ "t as type, "
+ "coalesce(sum(o.price), 0) as totalPrice, "
+ "coalesce(sum(o.count), 0) as totalCount "
+ "from TypeEntity t left join OrderEntity o on o.type = t and o.user.id = ?1 "
+ "group by t order by t.id")
List<OrderGrouped> getOrdersTotalByType(long userId);
}

View File

@ -0,0 +1,118 @@
package com.example.demo.orders.service;
import java.util.List;
import java.util.stream.StreamSupport;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.example.demo.core.error.NotFoundException;
import com.example.demo.orders.model.OrderEntity;
import com.example.demo.orders.model.OrderGrouped;
import com.example.demo.orders.repository.OrderRepository;
import com.example.demo.users.model.UserEntity;
import com.example.demo.users.service.UserService;
// Бизнес-логика для сущности "Заказ" (Заказ, содержащий книги)
@Service
public class OrderService {
// Хранилище элементов
private final OrderRepository repository;
// Бизнес-логика для заказчиков (пользователей)
private final UserService userService;
// Конструктор
public OrderService(OrderRepository repository, UserService userService) {
this.repository = repository;
this.userService = userService;
}
// Получить все элементы или по заданному фильтру
@Transactional(readOnly = true)
public List<OrderEntity> getAll(Long userId, Long typeId) {
userService.get(userId);
if (typeId <= 0L) {
return repository.findByUserId(userId);
}
else {
return repository.findByUserIdAndTypeId(userId, typeId);
}
}
// Получить все элементы или по заданному фильтру (с пагинацией)
@Transactional(readOnly = true)
public Page<OrderEntity> getAll(long userId, long typeId, int page, int size) {
final PageRequest pageRequest = PageRequest.of(page, size);
userService.get(userId);
if (typeId <= 0L) {
return repository.findByUserId(userId, pageRequest);
}
return repository.findByUserIdAndTypeId(userId, typeId, pageRequest);
}
// Получить элемент по идентификатору
@Transactional(readOnly = true)
public OrderEntity get(Long userId, Long id) {
userService.get(userId);
return repository.findOneByUserIdAndId(userId, id)
.orElseThrow(() -> new NotFoundException(OrderEntity.class, id));
}
// Создать элемент
@Transactional
public OrderEntity create(Long userId, OrderEntity entity) {
if (entity == null) {
throw new IllegalArgumentException("Entity is null");
}
final UserEntity existsUser = userService.get(userId);
entity.setUser(existsUser);
return repository.save(entity);
}
// Создать список заказов для пользователя
@Transactional
public List<OrderEntity> createAll(long userId, List<OrderEntity> entities) {
if (entities == null || entities.isEmpty()) {
throw new IllegalArgumentException("Orders list is null or empty");
}
final UserEntity existsUser = userService.get(userId);
entities.forEach(entity -> entity.setUser(existsUser));
return StreamSupport.stream(repository.saveAll(entities).spliterator(), false).toList();
}
// Изменить элемент
@Transactional
public OrderEntity update(Long userId, Long id, OrderEntity entity) {
userService.get(userId);
final OrderEntity existsEntity = get(userId, id);
existsEntity.setType(entity.getType());
existsEntity.setPrice(entity.getPrice());
existsEntity.setCount(entity.getCount());
return repository.save(existsEntity);
}
// Удалить элемент
@Transactional
public OrderEntity delete(Long userId, Long id) {
userService.get(userId);
final OrderEntity existsEntity = get(userId, id);
repository.delete(existsEntity);
return existsEntity;
}
// Удалить все элементы
@Transactional
public void deleteAll() {
repository.deleteAll();
}
// Получить список заказов, сгруппированных по типу
@Transactional(readOnly = true)
public List<OrderGrouped> getTotal(long userId) {
userService.get(userId);
return repository.getOrdersTotalByType(userId);
}
}

View File

@ -0,0 +1,127 @@
package com.example.demo.types.api;
import org.modelmapper.ModelMapper;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.ModelAttribute;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import com.example.demo.core.configuration.Constants;
import com.example.demo.types.model.TypeEntity;
import com.example.demo.types.service.TypeService;
import jakarta.validation.Valid;
// Контроллер для сущности "Тип" (Тип книги)
@Controller
@RequestMapping(TypeController.URL)
public class TypeController {
// URL для доступа к методам контроллера
public static final String URL = Constants.ADMIN_PREFIX + "/type";
// Представление для отображения списка типов
private static final String TYPE_VIEW = "type";
// Представление для создания или редактирования типа
private static final String TYPE_EDIT_VIEW = "type-edit";
// Атрибут модели для обработки данных
private static final String TYPE_ATTRIBUTE = "type";
// Бизнес-логика для сущности "Тип" (Тип книги)
private final TypeService typeService;
// Библиотека для преобразования сущности
private final ModelMapper modelMapper;
// Конструктор
public TypeController(TypeService typeService, ModelMapper modelMapper) {
this.typeService = typeService;
this.modelMapper = modelMapper;
}
// Преобразовать из сущности в DTO
private TypeDto toDto(TypeEntity entity) {
return modelMapper.map(entity, TypeDto.class);
}
// Преобразовать из DTO в сущность
private TypeEntity toEntity(@Valid TypeDto dto) {
return modelMapper.map(dto, TypeEntity.class);
}
// Получить все элементы
@GetMapping
public String getAll(Model model) {
model.addAttribute(
"items",
typeService.getAll().stream()
.map(this::toDto)
.toList());
return TYPE_VIEW;
}
// Создать элемент
@GetMapping("/edit/")
public String create(Model model) {
model.addAttribute(TYPE_ATTRIBUTE, new TypeDto());
return TYPE_EDIT_VIEW;
}
// Создать элемент
@PostMapping("/edit/")
public String create(
@ModelAttribute(name = TYPE_ATTRIBUTE) @Valid TypeDto type,
BindingResult bindingResult,
Model model) {
if (bindingResult.hasErrors()) {
return TYPE_EDIT_VIEW;
}
typeService.create(toEntity(type));
return Constants.REDIRECT_VIEW + URL;
}
// Изменить элемент
@GetMapping("/edit/{id}")
public String update(
@PathVariable(name = "id") Long id,
Model model) {
if (id <= 0) {
throw new IllegalArgumentException();
}
model.addAttribute(TYPE_ATTRIBUTE, toDto(typeService.get(id)));
return TYPE_EDIT_VIEW;
}
// Изменить элемент
@PostMapping("/edit/{id}")
public String update(
@PathVariable(name = "id") Long id,
@ModelAttribute(name = TYPE_ATTRIBUTE) @Valid TypeDto type,
BindingResult bindingResult,
Model model) {
if (bindingResult.hasErrors()) {
return TYPE_EDIT_VIEW;
}
if (id <= 0) {
throw new IllegalArgumentException();
}
typeService.update(id, toEntity(type));
return Constants.REDIRECT_VIEW + URL;
}
// Удалить элемент
@PostMapping("/delete/{id}")
public String delete(
@PathVariable(name = "id") Long id) {
typeService.delete(id);
return Constants.REDIRECT_VIEW + URL;
}
}

View File

@ -0,0 +1,35 @@
package com.example.demo.types.api;
import jakarta.validation.constraints.NotBlank;
import jakarta.validation.constraints.Size;
// DTO для сущности "Тип" (Тип книги)
public class TypeDto {
// Идентфикатор
private Long id;
// Название типа
@NotBlank
@Size(min = 5, max = 50)
private String name;
// Получить идентификатор
public Long getId() {
return id;
}
// Установить идентификатор
public void setId(Long id) {
this.id = id;
}
// Получить название типа
public String getName() {
return name;
}
// Установить название типа
public void setName(String name) {
this.name = name;
}
}

View File

@ -0,0 +1,55 @@
package com.example.demo.types.model;
import java.util.Objects;
import com.example.demo.core.model.BaseEntity;
import jakarta.persistence.Entity;
import jakarta.persistence.Table;
import jakarta.persistence.Column;
// Сущность "Тип" (Тип книги)
@Entity
@Table(name = "types")
public class TypeEntity extends BaseEntity {
// Название типа
@Column(nullable = false, unique = true, length = 50)
private String name;
// Конструктор по умолчанию
public TypeEntity() {
}
// Конструктор с параметрами для создания объекта
public TypeEntity(String name) {
this.name = name;
}
// Получить название типа
public String getName() {
return name;
}
// Установить название типа
public void setName(String name) {
this.name = name;
}
// Получить хэш-код объекта
@Override
public int hashCode() {
return Objects.hash(id, name);
}
// Сравнить объекты
@Override
public boolean equals(Object obj) {
if (this == obj)
return true;
if (obj == null || getClass() != obj.getClass())
return false;
final TypeEntity other = (TypeEntity) obj;
return Objects.equals(other.getId(), id)
&& Objects.equals(other.getName(), name);
}
}

View File

@ -0,0 +1,13 @@
package com.example.demo.types.repository;
import java.util.Optional;
import org.springframework.data.repository.CrudRepository;
import com.example.demo.types.model.TypeEntity;
// Хранилище для сущности "Тип" (Тип книги)
public interface TypeRepository extends CrudRepository<TypeEntity, Long> {
// Найти тип по названию (без учета регистра)
Optional<TypeEntity> findByNameIgnoreCase(String name);
}

View File

@ -0,0 +1,90 @@
package com.example.demo.types.service;
import java.util.Collection;
import java.util.List;
import java.util.Optional;
import java.util.stream.StreamSupport;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.example.demo.core.error.NotFoundException;
import com.example.demo.types.model.TypeEntity;
import com.example.demo.types.repository.TypeRepository;
// Бизнес-логика для сущности "Тип" (Тип книг)
@Service
public class TypeService {
// Хранилище элементов
private final TypeRepository repository;
// Конструктор
public TypeService(TypeRepository repository) {
this.repository = repository;
}
// Проверка уникальности названия типа
private void checkName(Long id, String name) {
final Optional<TypeEntity> existsType = repository.findByNameIgnoreCase(name);
if (existsType.isPresent() && !existsType.get().getId().equals(id)) {
throw new IllegalArgumentException(
String.format("Type with name %s is already exists", name));
}
}
// Получить все элементы
@Transactional(readOnly = true)
public List<TypeEntity> getAll() {
return StreamSupport.stream(repository.findAll().spliterator(), false).toList();
}
// Получить список типов по идентификаторам
@Transactional(readOnly = true)
public List<TypeEntity> getByIds(Collection<Long> ids) {
final List<TypeEntity> types = StreamSupport.stream(repository.findAllById(ids).spliterator(), false).toList();
if (types.size() < ids.size()) {
throw new IllegalArgumentException("Invalid type");
}
return types;
}
// Получить элемент по идентификатору
@Transactional(readOnly = true)
public TypeEntity get(Long id) {
return repository.findById(id)
.orElseThrow(() -> new NotFoundException(TypeEntity.class, id));
}
// Создать элемент
@Transactional
public TypeEntity create(TypeEntity entity) {
if (entity == null) {
throw new IllegalArgumentException("Entity is null");
}
checkName(null, entity.getName());
return repository.save(entity);
}
// Изменить элемент
@Transactional
public TypeEntity update(Long id, TypeEntity entity) {
final TypeEntity existsEntity = get(id);
checkName(id, entity.getName());
existsEntity.setName(entity.getName());
return repository.save(existsEntity);
}
// Удалить элемент
@Transactional
public TypeEntity delete(Long id) {
final TypeEntity existsEntity = get(id);
repository.delete(existsEntity);
return existsEntity;
}
// Удалить все элементы
@Transactional
public void deleteAll() {
repository.deleteAll();
}
}

View File

@ -0,0 +1,177 @@
package com.example.demo.users.api;
import java.util.Collection;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Objects;
import java.util.Set;
import java.util.function.Function;
import java.util.stream.Collectors;
import org.modelmapper.ModelMapper;
import org.springframework.security.core.annotation.AuthenticationPrincipal;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.ModelAttribute;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.SessionAttributes;
import org.springframework.web.bind.support.SessionStatus;
import com.example.demo.core.configuration.Constants;
import com.example.demo.core.security.UserPrincipal;
import com.example.demo.core.session.SessionCart;
import com.example.demo.orders.model.OrderEntity;
import com.example.demo.orders.service.OrderService;
import com.example.demo.types.api.TypeDto;
import com.example.demo.types.model.TypeEntity;
import com.example.demo.types.service.TypeService;
import jakarta.validation.Valid;
// Контроллер для работы с корзиной покупок пользователя
@Controller
@RequestMapping(UserCartController.URL)
@SessionAttributes("types")
public class UserCartController {
// URL для доступа к методам контроллера
public static final String URL = "/cart";
// Представление для отображения корзины покупок
private static final String ORDER_VIEW = "cart";
// Атрибут модели для обработки данных
private static final String ORDER_ATTRIBUTE = "order";
// Атрибут модели для обработки данных
private static final String CART_ATTRIBUTE = "cart";
// Бизнес-логика для сущности "Тип" (Тип товара)
private final TypeService typeService;
// Бизнес-логика для сущности "Заказ"
private final OrderService orderService;
// Корзина покупок
private final SessionCart cart;
// Библиотека для преобразования сущности
private final ModelMapper modelMapper;
// Конструктор
public UserCartController(
TypeService typeService,
OrderService orderService,
SessionCart cart,
ModelMapper modelMapper) {
this.typeService = typeService;
this.orderService = orderService;
this.cart = cart;
this.modelMapper = modelMapper;
}
// Преобразовать из сущности в DTO
private TypeDto toTypeDto(TypeEntity entity) {
return modelMapper.map(entity, TypeDto.class);
}
// Преобразовать из DTO в список сущностей
private List<OrderEntity> toOrderEntities(Collection<UserCartDto> dtos) {
final Set<Long> typeIds = dtos.stream()
.map(UserCartDto::getType)
.collect(Collectors.toSet());
final Map<Long, TypeEntity> types = typeService.getByIds(typeIds).stream()
.collect(Collectors.toMap(TypeEntity::getId, Function.identity()));
return dtos.stream()
.map(dto -> {
final OrderEntity entity = modelMapper.map(dto, OrderEntity.class);
entity.setType(types.get(dto.getType()));
return entity;
})
.toList();
}
// Получить корзину покупок
@GetMapping
public String getCart(Model model) {
model.addAttribute("types",
typeService.getAll().stream()
.map(this::toTypeDto)
.toList());
model.addAttribute(ORDER_ATTRIBUTE, new UserCartDto());
model.addAttribute(CART_ATTRIBUTE, cart.values());
return ORDER_VIEW;
}
// Добавить заказ в корзину
@PostMapping
public String addOrderToCart(
@ModelAttribute(name = ORDER_ATTRIBUTE) @Valid UserCartDto order,
BindingResult bindingResult,
SessionStatus status,
Model model) {
if (bindingResult.hasErrors()) {
return ORDER_VIEW;
}
status.setComplete();
order.setTypeName(typeService.get(order.getType()).getName());
cart.computeIfPresent(order.hashCode(), (key, value) -> {
value.setCount(value.getCount() + order.getCount());
return value;
});
cart.putIfAbsent(order.hashCode(), order);
return Constants.REDIRECT_VIEW + URL;
}
// Сохранить корзину
@PostMapping("/save")
public String saveCart(
Model model,
@AuthenticationPrincipal UserPrincipal principal) {
orderService.createAll(principal.getId(), toOrderEntities(cart.values()));
cart.clear();
return Constants.REDIRECT_VIEW + URL;
}
// Очистить корзину
@PostMapping("/clear")
public String clearCart() {
cart.clear();
return Constants.REDIRECT_VIEW + URL;
}
// Увеличить колчество товара в корзине
@PostMapping("/increase")
public String increaseCartCount(
@RequestParam(name = "type") Long type,
@RequestParam(name = "price") Double price) {
cart.computeIfPresent(Objects.hash(type, price), (key, value) -> {
value.setCount(value.getCount() + 1);
return value;
});
return Constants.REDIRECT_VIEW + URL;
}
// Уменьшить колчество товара в корзине
@PostMapping("/decrease")
public String decreaseCartCount(
@RequestParam(name = "type") Long type,
@RequestParam(name = "price") Double price) {
cart.computeIfPresent(Objects.hash(type, price), (key, value) -> {
value.setCount(value.getCount() - 1);
return value;
});
final Map<Integer, UserCartDto> filteredCart = cart.entrySet()
.stream()
.filter(item -> item.getValue().getCount() > 0)
.collect(Collectors.toMap(Entry::getKey, Entry::getValue));
cart.clear();
cart.putAll(filteredCart);
return Constants.REDIRECT_VIEW + URL;
}
}

View File

@ -0,0 +1,84 @@
package com.example.demo.users.api;
import java.util.Objects;
import jakarta.validation.constraints.Min;
import jakarta.validation.constraints.NotNull;
// DTO для корзины покупок пользователя
public class UserCartDto {
// Идентификатор типа товара
@NotNull
private Long type;
// Название типа товара
private String typeName;
// Цена товара
@NotNull
@Min(1000)
private Double price;
// Количество товаров
@NotNull
@Min(1)
private Integer count;
// Получить идентификатор типа товара
public Long getType() {
return type;
}
// Установить идентификатор типа товара
public void setType(Long typeId) {
this.type = typeId;
}
// Получить название типа товара
public String getTypeName() {
return typeName;
}
// Установить название типа товара
public void setTypeName(String typeName) {
this.typeName = typeName;
}
// Получить цену товара
public Double getPrice() {
return price;
}
// Установить цену товара
public void setPrice(Double price) {
this.price = price;
}
// Получить количество товаров
public Integer getCount() {
return count;
}
// Устаовить количество товаров
public void setCount(Integer count) {
this.count = count;
}
// Получить хэш-код объекта
@Override
public int hashCode() {
return Objects.hash(type, price);
}
// Сравнить объекты
@Override
public boolean equals(Object obj) {
if (this == obj)
return true;
if (obj == null || getClass() != obj.getClass())
return false;
UserCartDto other = (UserCartDto) obj;
return Objects.equals(type, other.type)
&& Objects.equals(price, other.price);
}
}

View File

@ -0,0 +1,153 @@
package com.example.demo.users.api;
import java.util.Map;
import org.modelmapper.ModelMapper;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.ModelAttribute;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.servlet.mvc.support.RedirectAttributes;
import com.example.demo.core.api.PageAttributesMapper;
import com.example.demo.core.configuration.Constants;
import com.example.demo.users.model.UserEntity;
import com.example.demo.users.service.UserService;
import jakarta.validation.Valid;
// Контроллер для сущности "Пользователь"
@Controller
@RequestMapping(UserController.URL)
public class UserController {
// URL для доступа к методам контроллера
public static final String URL = Constants.ADMIN_PREFIX + "/user";
// Представление для отображения списка пользователей
private static final String USER_VIEW = "user";
// Представление для создания или редактирования пользователя
private static final String USER_EDIT_VIEW = "user-edit";
// Атрибут модели для обработки данных
private static final String USER_ATTRIBUTE = "user";
// Атрибут модели для пагинации
private static final String PAGE_ATTRIBUTE = "page";
// Бизнес-логика для сущности "Пользователь"
private final UserService userService;
// Библиотека для преобразования сущности
private final ModelMapper modelMapper;
// Конструктор
public UserController(UserService userService, ModelMapper modelMapper) {
this.userService = userService;
this.modelMapper = modelMapper;
}
// Преобразовать из сущности в DTO
private UserDto toDto(UserEntity entity) {
return modelMapper.map(entity, UserDto.class);
}
// Преобразовать из DTO в сущность
private UserEntity toEntity(@Valid UserDto dto) {
return modelMapper.map(dto, UserEntity.class);
}
// Получить все элементы
@GetMapping
public String getAll(
@RequestParam(name = PAGE_ATTRIBUTE, defaultValue = "0") int page,
Model model) {
final Map<String, Object> attributes = PageAttributesMapper.toAttributes(
"user",
userService.getAll(page, Constants.DEFAULT_PAGE_SIZE), this::toDto);
model.addAllAttributes(attributes);
model.addAttribute(PAGE_ATTRIBUTE, page);
return USER_VIEW;
}
// Создать элемент
@GetMapping("/edit/")
public String create(
@RequestParam(name = PAGE_ATTRIBUTE, defaultValue = "0") int page,
Model model) {
model.addAttribute(USER_ATTRIBUTE, new UserDto());
model.addAttribute(PAGE_ATTRIBUTE, page);
return USER_EDIT_VIEW;
}
// Создать элемент
@PostMapping("/edit/")
public String create(
@RequestParam(name = PAGE_ATTRIBUTE, defaultValue = "0") int page,
@ModelAttribute(name = USER_ATTRIBUTE) @Valid UserDto user,
BindingResult bindingResult,
Model model,
RedirectAttributes redirectAttributes) {
if (bindingResult.hasErrors()) {
model.addAttribute(PAGE_ATTRIBUTE, page);
return USER_EDIT_VIEW;
}
redirectAttributes.addAttribute(PAGE_ATTRIBUTE, page);
userService.create(toEntity(user));
return Constants.REDIRECT_VIEW + URL;
}
// Изменить элемент
@GetMapping("/edit/{id}")
public String update(
@PathVariable(name = "id") Long id,
@RequestParam(name = PAGE_ATTRIBUTE, defaultValue = "0") int page,
Model model) {
if (id <= 0) {
throw new IllegalArgumentException();
}
model.addAttribute(USER_ATTRIBUTE, toDto(userService.get(id)));
model.addAttribute(PAGE_ATTRIBUTE, page);
return USER_EDIT_VIEW;
}
// Изменить элемент
@PostMapping("/edit/{id}")
public String update(
@PathVariable(name = "id") Long id,
@RequestParam(name = PAGE_ATTRIBUTE, defaultValue = "0") int page,
@ModelAttribute(name = USER_ATTRIBUTE) @Valid UserDto user,
BindingResult bindingResult,
Model model,
RedirectAttributes redirectAttributes) {
if (bindingResult.hasErrors()) {
model.addAttribute(PAGE_ATTRIBUTE, page);
return USER_EDIT_VIEW;
}
if (id <= 0) {
throw new IllegalArgumentException();
}
redirectAttributes.addAttribute(PAGE_ATTRIBUTE, page);
userService.update(id, toEntity(user));
return Constants.REDIRECT_VIEW + URL;
}
// Удалить элемент
@PostMapping("/delete/{id}")
public String delete(
@PathVariable(name = "id") Long id,
@RequestParam(name = PAGE_ATTRIBUTE, defaultValue = "0") int page,
RedirectAttributes redirectAttributes) {
redirectAttributes.addAttribute(PAGE_ATTRIBUTE, page);
userService.delete(id);
return Constants.REDIRECT_VIEW + URL;
}
}

View File

@ -0,0 +1,49 @@
package com.example.demo.users.api;
import jakarta.validation.constraints.NotBlank;
import jakarta.validation.constraints.Size;
// DTO для сущности "Пользователь"
public class UserDto {
// Идентфикатор
private Long id;
// Имя/логин пользователя
@NotBlank
@Size(min = 3, max = 50)
private String username;
// Электронный адрес почты пользователя
@NotBlank
private String email;
// Получить идентификатор
public Long getId() {
return id;
}
// Установить идентификатор
public void setId(Long id) {
this.id = id;
}
// Получить имя/логин пользователя
public String getUsername() {
return username;
}
// Установить имя/логин пользователя
public void setUsername(String username) {
this.username = username;
}
// Получить электронный адрес почты пользователя
public String getEmail() {
return email;
}
// Установить электронный адрес почты пользователя
public void setEmail(String email) {
this.email = email;
}
}

View File

@ -0,0 +1,85 @@
package com.example.demo.users.api;
import java.time.LocalDateTime;
import org.modelmapper.ModelMapper;
import org.springframework.security.core.annotation.AuthenticationPrincipal;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.ModelAttribute;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.servlet.mvc.support.RedirectAttributes;
import com.example.demo.core.configuration.Constants;
import com.example.demo.core.security.UserPrincipal;
import com.example.demo.messages.api.MessageDto;
import com.example.demo.messages.model.MessageEntity;
import com.example.demo.messages.service.MessageService;
import jakarta.validation.Valid;
// Контроллер для работы с корзиной покупок пользователя
@Controller
@RequestMapping(UserMessageController.URL)
public class UserMessageController {
// URL для доступа к методам контроллера
public static final String URL = "/message";
// Представление для написания сообщения
private static final String MESSAGE_EDIT_VIEW = "message-edit";
// Атрибут модели для обработки данных
private static final String MESSAGE_ATTRIBUTE = "message";
// Атрибут модели для пагинации
private static final String PAGE_ATTRIBUTE = "page";
// Бизнес-логика для сущости "Сообщение"
private final MessageService messageService;
// Библиотека для преобразования сущности
private final ModelMapper modelMapper;
public UserMessageController(MessageService messageService, ModelMapper modelMapper) {
this.messageService = messageService;
this.modelMapper = modelMapper;
}
private MessageEntity toEntity(MessageDto dto) {
return modelMapper.map(dto, MessageEntity.class);
}
// Отправить сообщение
@GetMapping("/send/")
public String sendMessage(
@RequestParam(name = PAGE_ATTRIBUTE, defaultValue = "0") int page,
Model model) {
model.addAttribute(MESSAGE_ATTRIBUTE, new MessageDto());
model.addAttribute(PAGE_ATTRIBUTE, page);
return MESSAGE_EDIT_VIEW;
}
// Отправить сообщение
@PostMapping("/send/")
public String sendMessage(
@RequestParam(name = PAGE_ATTRIBUTE, defaultValue = "0") int page,
@ModelAttribute(name = MESSAGE_ATTRIBUTE) @Valid MessageDto message,
BindingResult bindingResult,
Model model,
@AuthenticationPrincipal UserPrincipal principal,
RedirectAttributes redirectAttributes) {
if (bindingResult.hasErrors()) {
model.addAttribute(PAGE_ATTRIBUTE, page);
return MESSAGE_EDIT_VIEW;
}
redirectAttributes.addAttribute(PAGE_ATTRIBUTE, page);
message.setDate(LocalDateTime.now());
messageService.create(principal.getId(), toEntity(message));
return Constants.REDIRECT_VIEW + "/";
}
}

View File

@ -0,0 +1,123 @@
package com.example.demo.users.api;
import org.modelmapper.ModelMapper;
import org.springframework.security.core.annotation.AuthenticationPrincipal;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.servlet.mvc.support.RedirectAttributes;
import com.example.demo.core.api.PageAttributesMapper;
import com.example.demo.core.configuration.Constants;
import com.example.demo.core.security.UserPrincipal;
import com.example.demo.messages.api.MessageDto;
import com.example.demo.messages.model.MessageEntity;
import com.example.demo.messages.service.MessageService;
import com.example.demo.orders.api.OrderDto;
import com.example.demo.orders.api.OrderGroupedDto;
import com.example.demo.orders.model.OrderEntity;
import com.example.demo.orders.model.OrderGrouped;
import com.example.demo.orders.service.OrderService;
import com.example.demo.types.api.TypeDto;
import com.example.demo.types.model.TypeEntity;
import com.example.demo.types.service.TypeService;
// Контроллер для профиля пользователя
@Controller
public class UserProfileController {
// URL для доступа к методам контроллера
private static final String PROFILE_VIEW = "profile";
// Атрибут модели для пагинации
private static final String PAGE_ATTRIBUTE = "page";
// Атрибут модели для обработки данных
private static final String TYPEID_ATTRIBUTE = "typeId";
// Бизнес-логика для сущости "Заказ"
private final OrderService orderService;
// Бизнес-логика для сущости "Тип" (Тип товара)
private final TypeService typeService;
// Бизнес-логика для сущости "Сообщение"
private final MessageService messageService;
// Библиотека для преобразования сущности
private final ModelMapper modelMapper;
public UserProfileController(
OrderService orderService,
TypeService typeService,
MessageService messageService,
ModelMapper modelMapper) {
this.orderService = orderService;
this.typeService = typeService;
this.messageService = messageService;
this.modelMapper = modelMapper;
}
private OrderDto toDto(OrderEntity entity) {
return modelMapper.map(entity, OrderDto.class);
}
private OrderGroupedDto toGroupedDto(OrderGrouped entity) {
return modelMapper.map(entity, OrderGroupedDto.class);
}
private TypeDto toTypeDto(TypeEntity entity) {
return modelMapper.map(entity, TypeDto.class);
}
private MessageDto toMessageDto(MessageEntity entity) {
return modelMapper.map(entity, MessageDto.class);
}
@GetMapping
public String getProfile(
@RequestParam(name = PAGE_ATTRIBUTE, defaultValue = "0") int page,
@RequestParam(name = TYPEID_ATTRIBUTE, defaultValue = "0") int typeId,
Model model,
@AuthenticationPrincipal UserPrincipal principal) {
final long userId = principal.getId();
model.addAttribute(PAGE_ATTRIBUTE, page);
model.addAttribute(TYPEID_ATTRIBUTE, typeId);
model.addAllAttributes(PageAttributesMapper.toAttributes(
"order",
orderService.getAll(userId, typeId, page, Constants.DEFAULT_PAGE_SIZE),
this::toDto));
model.addAttribute("stats",
orderService.getTotal(userId).stream()
.map(this::toGroupedDto)
.toList());
model.addAttribute("types",
typeService.getAll().stream()
.map(this::toTypeDto)
.toList());
model.addAllAttributes(PageAttributesMapper.toAttributes(
"message",
messageService.getAll(userId, page, Constants.DEFAULT_PAGE_SIZE),
this::toMessageDto));
return PROFILE_VIEW;
}
@PostMapping("/delete/{id}")
public String deleteOrder(
@PathVariable(name = "id") Long id,
@RequestParam(name = PAGE_ATTRIBUTE, defaultValue = "0") int page,
@RequestParam(name = TYPEID_ATTRIBUTE, defaultValue = "0") int typeId,
RedirectAttributes redirectAttributes,
@AuthenticationPrincipal UserPrincipal principal) {
redirectAttributes.addAttribute(PAGE_ATTRIBUTE, page);
redirectAttributes.addAttribute(TYPEID_ATTRIBUTE, typeId);
orderService.delete(principal.getId(), id);
return Constants.REDIRECT_VIEW + "/";
}
}

View File

@ -0,0 +1,77 @@
package com.example.demo.users.api;
import java.util.Objects;
import org.modelmapper.ModelMapper;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.ModelAttribute;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import com.example.demo.core.configuration.Constants;
import com.example.demo.users.model.UserEntity;
import com.example.demo.users.service.UserService;
import jakarta.validation.Valid;
// Контроллер для регистрации пользователя
@Controller
@RequestMapping(UserSignupController.URL)
public class UserSignupController {
// URL для доступа к методам контроллера
public static final String URL = "/signup";
// Представление для отображения формы регистрации
private static final String SIGNUP_VIEW = "signup";
// Атрибут модели для обработки данных
private static final String USER_ATTRIBUTE = "user";
// Бизнес-логика для сущности "Пользователь"
private final UserService userService;
// Библиотека для преобразования сущности
private final ModelMapper modelMapper;
// Конструктор
public UserSignupController(
UserService userService,
ModelMapper modelMapper) {
this.userService = userService;
this.modelMapper = modelMapper;
}
// Преобразовать из DTO в сущность
private UserEntity toEntity(UserSignupDto dto) {
return modelMapper.map(dto, UserEntity.class);
}
// Регистрация пользователя
@GetMapping
public String getSignup(Model model) {
model.addAttribute(USER_ATTRIBUTE, new UserSignupDto());
return SIGNUP_VIEW;
}
// Регистрация пользователя
@PostMapping
public String signup(
@ModelAttribute(name = USER_ATTRIBUTE) @Valid UserSignupDto user,
BindingResult bindingResult,
Model model) {
if (bindingResult.hasErrors()) {
return SIGNUP_VIEW;
}
if (!Objects.equals(user.getPassword(), user.getPasswordConfirm())) {
bindingResult.rejectValue("password", "signup:passwords", "Пароли не совпадают.");
model.addAttribute(USER_ATTRIBUTE, user);
return SIGNUP_VIEW;
}
userService.create(toEntity(user));
return Constants.REDIRECT_VIEW + Constants.LOGIN_URL + "?signup";
}
}

View File

@ -0,0 +1,67 @@
package com.example.demo.users.api;
import jakarta.validation.constraints.NotBlank;
import jakarta.validation.constraints.Size;
// DTO для регистрации пользователя
public class UserSignupDto {
// Имя/логин пользователя
@NotBlank
@Size(min = 3, max = 20)
private String username;
// Электронная почта пользователя
@NotBlank
@Size(min = 3, max = 50)
private String email;
// Пароль пользователя
@NotBlank
@Size(min = 3, max = 20)
private String password;
// Подтверджение пароля
@NotBlank
@Size(min = 3, max = 20)
private String passwordConfirm;
// Получить имя/логин пользователя
public String getUsername() {
return username;
}
// Установить имя/логин пользователя
public void setUsername(String username) {
this.username = username;
}
// Получить электронную почту пользователя
public String getEmail() {
return email;
}
// Установить электронную почту пользователя
public void setEmail(String email) {
this.email = email;
}
// Получить пароль пользователя
public String getPassword() {
return password;
}
// Установить пароль пользователя
public void setPassword(String password) {
this.password = password;
}
// Получить подтверджение пароля
public String getPasswordConfirm() {
return passwordConfirm;
}
// Установить подтверджение пароля
public void setPasswordConfirm(String passwordConfirm) {
this.passwordConfirm = passwordConfirm;
}
}

View File

@ -0,0 +1,147 @@
package com.example.demo.users.model;
import java.util.Objects;
import java.util.Set;
import java.util.HashSet;
import com.example.demo.core.model.BaseEntity;
import com.example.demo.orders.model.OrderEntity;
import com.example.demo.messages.model.MessageEntity;
import jakarta.persistence.Entity;
import jakarta.persistence.Table;
import jakarta.persistence.Column;
import jakarta.persistence.OneToMany;
import jakarta.persistence.CascadeType;
import jakarta.persistence.OrderBy;
// Сущность "Пользователь"
@Entity
@Table(name = "users")
public class UserEntity extends BaseEntity {
// Имя/логин пользователя
@Column(nullable = false, unique = true, length = 50)
private String username;
// Пароль пользователя
@Column(nullable = false, length = 60)
private String password;
// Электронный адрес почты пользователя
@Column(nullable = false, unique = true)
private String email;
// Роль пользователя
private UserRole role;
// Список заказов пользователя
@OneToMany(mappedBy = "user", cascade = CascadeType.ALL)
@OrderBy("id ASC")
private Set<OrderEntity> orders = new HashSet<>();
// Список сообщений пользователя
@OneToMany(mappedBy = "user", cascade = CascadeType.ALL)
@OrderBy("id ASC")
private Set<MessageEntity> messages = new HashSet<>();
// Конструктор по умолчанию
public UserEntity() {
}
// Конструктор с параметрами для создания объекта
public UserEntity(String username, String password, String email) {
this.username = username;
this.password = password;
this.email = email;
this.role = UserRole.USER;
}
// Получить имя/логин пользователя
public String getUsername() {
return username;
}
// Установить имя/логин пользователя
public void setUsername(String username) {
this.username = username;
}
// Получить пароль пользователя
public String getPassword() {
return password;
}
// Установить пароль пользователя
public void setPassword(String password) {
this.password = password;
}
// Получить электронный адрес почты пользователя
public String getEmail() {
return email;
}
// Установить электронный адрес почты пользователя
public void setEmail(String email) {
this.email = email;
}
// Получить роль пользователя
public UserRole getRole() {
return role;
}
// Установить роль пользователя
public void setRole(UserRole role) {
this.role = role;
}
// Получить список заказов
public Set<OrderEntity> getOrders() {
return orders;
}
// Добавить заказ
public void addOrder(OrderEntity order) {
if (order.getUser() != this) {
order.setUser(this);
}
orders.add(order);
}
// Получить список сообщений
public Set<MessageEntity> getMessages() {
return messages;
}
// Добавить сообщение
public void addMessage(MessageEntity message) {
if (message.getUser() != this) {
message.setUser(this);
}
messages.add(message);
}
// Получить хэш-код объекта
@Override
public int hashCode() {
return Objects.hash(id, username, password, email, role, orders, messages);
}
// Сравнить объекты
@Override
public boolean equals(Object obj) {
if (this == obj)
return true;
if (obj == null || getClass() != obj.getClass())
return false;
final UserEntity other = (UserEntity) obj;
return Objects.equals(other.getId(), id)
&& Objects.equals(other.getUsername(), username)
&& Objects.equals(other.getPassword(), password)
&& Objects.equals(other.getEmail(), email)
&& Objects.equals(other.getRole(), role)
&& Objects.equals(other.getOrders(), orders)
&& Objects.equals(other.getMessages(), messages);
}
}

View File

@ -0,0 +1,18 @@
package com.example.demo.users.model;
import org.springframework.security.core.GrantedAuthority;
// Класс перечисление для ролей пользователя
public enum UserRole implements GrantedAuthority {
ADMIN, // Администратор
USER; // Пользователь
// Префикс роли
private static final String PREFIX = "ROLE_";
// Получить роль с префиксом
@Override
public String getAuthority() {
return PREFIX + this.name();
}
}

View File

@ -0,0 +1,22 @@
package com.example.demo.users.repository;
import java.util.Optional;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.repository.CrudRepository;
import org.springframework.data.repository.PagingAndSortingRepository;
import com.example.demo.users.model.UserEntity;
// Хранилище для сущности "Пользователь"
public interface UserRepository extends CrudRepository<UserEntity, Long>, PagingAndSortingRepository<UserEntity, Long> {
// Получить список всех пользовалей (с пагинацией)
Page<UserEntity> findAll(Pageable pageable);
// Получить пользователя по имени/логину
Optional<UserEntity> findByUsername(String username);
// Получить пользователя по адресу электронной почты
Optional<UserEntity> findByEmail(String email);
}

View File

@ -0,0 +1,135 @@
package com.example.demo.users.service;
import java.util.List;
import java.util.Optional;
import java.util.stream.StreamSupport;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.security.core.userdetails.UserDetails;
import org.springframework.security.core.userdetails.UserDetailsService;
import org.springframework.security.core.userdetails.UsernameNotFoundException;
import org.springframework.security.crypto.password.PasswordEncoder;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StringUtils;
import com.example.demo.core.configuration.Constants;
import com.example.demo.core.error.NotFoundException;
import com.example.demo.core.security.UserPrincipal;
import com.example.demo.users.model.UserEntity;
import com.example.demo.users.model.UserRole;
import com.example.demo.users.repository.UserRepository;
// Бизнес-логика для сущности "Пользователь"
@Service
public class UserService implements UserDetailsService {
// Хранилище элементов
private final UserRepository repository;
// Шифрование паролей
private final PasswordEncoder passwordEncoder;
// Конструктор
public UserService(
UserRepository repository,
PasswordEncoder passwordEncoder) {
this.repository = repository;
this.passwordEncoder = passwordEncoder;
}
// Проверка уникальности имени/логина пользователя
private void checkUsername(Long id, String username) {
final Optional<UserEntity> existsUser = repository.findByUsername(username);
if (existsUser.isPresent() && !existsUser.get().getId().equals(id)) {
throw new IllegalArgumentException(
String.format("User with username %s is already exists", username));
}
}
// Проверка уникальности адреса электронной почты пользователя
private void checkEmail(Long id, String email) {
final Optional<UserEntity> existsUser = repository.findByEmail(email);
if (existsUser.isPresent() && !existsUser.get().getId().equals(id)) {
throw new IllegalArgumentException(
String.format("User with email %s is already exists", email));
}
}
// Получить все элементы
@Transactional(readOnly = true)
public List<UserEntity> getAll() {
return StreamSupport.stream(repository.findAll().spliterator(), false).toList();
}
// Получить все элементы (с пагинацией)
@Transactional(readOnly = true)
public Page<UserEntity> getAll(int page, int size) {
final PageRequest pageRequest = PageRequest.of(page, size);
return repository.findAll(pageRequest);
}
// Получить элемент по идентификатору
@Transactional(readOnly = true)
public UserEntity get(Long id) {
return repository.findById(id)
.orElseThrow(() -> new NotFoundException(UserEntity.class, id));
}
// Получить элемент по имени/логину
@Transactional(readOnly = true)
public UserEntity getByUsername(String username) {
return repository.findByUsername(username)
.orElseThrow(() -> new IllegalArgumentException("Invalid username"));
}
// Создать элемент
@Transactional
public UserEntity create(UserEntity entity) {
if (entity == null) {
throw new IllegalArgumentException("Entity is null");
}
checkUsername(null, entity.getUsername());
checkEmail(null, entity.getEmail());
final String password = Optional.ofNullable(entity.getPassword()).orElse("");
entity.setPassword(
passwordEncoder.encode(
StringUtils.hasText(password.strip()) ? password : Constants.DEFAULT_PASSWORD));
entity.setRole(Optional.ofNullable(entity.getRole()).orElse(UserRole.USER));
return repository.save(entity);
}
// Изменить элемент
@Transactional
public UserEntity update(Long id, UserEntity entity) {
final UserEntity existsEntity = get(id);
existsEntity.setUsername(entity.getUsername());
existsEntity.setEmail(entity.getEmail());
return repository.save(existsEntity);
}
// Удалить элемент
@Transactional
public UserEntity delete(Long id) {
final UserEntity existsEntity = get(id);
repository.delete(existsEntity);
return existsEntity;
}
// Удалить все элементы
@Transactional
public void deleteAll() {
repository.deleteAll();
}
// Загрузить пользователя по имени/логину
@Override
@Transactional(readOnly = true)
public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
final UserEntity existsUser = getByUsername(username);
return new UserPrincipal(existsUser);
}
}

View File

@ -1 +1,20 @@
# Server
spring.main.banner-mode=off
server.port=8080
# Logger settings
# Available levels are: TRACE, DEBUG, INFO, WARN, ERROR, FATAL, OFF
logging.level.com.example.demo=DEBUG
# JPA Settings
spring.datasource.url=jdbc:h2:file:./data
spring.datasource.username=factorino
spring.datasource.password=password
spring.datasource.driver-class-name=org.h2.Driver
spring.jpa.hibernate.ddl-auto=create
spring.jpa.open-in-view=false
# spring.jpa.show-sql=true
# spring.jpa.properties.hibernate.format_sql=true
# H2 console
spring.h2.console.enabled=true

View File

@ -0,0 +1,159 @@
html,
body {
height: 100%;
font-family: Montserrat;
background-color: #363434;
}
._container {
display: flex;
flex-direction: column;
justify-content: center;
margin: 0 auto;
max-width: 1680px;
}
h1 {
font-size: 1.5em;
}
h2 {
margin: 20px auto;
font-size: 25px;
font-weight: 600;
}
h3 {
font-size: 1.1em;
}
td form {
margin: 0;
padding: 0;
margin-top: -.25em;
}
.btn {
display: flex;
justify-content: center;
align-items: center;
background-color: #a721fa;
font-size: 20px;
font-weight: 700;
border-radius: 30px;
}
.btn-primary,
.btn-secondary {
margin-bottom: 30px;
}
.btn:hover {
transform: translateY(-3px);
box-shadow: 10px 10px rgba(0, 0, 0, 0.2);
}
.btn:active {
transform: translateY(-1px);
box-shadow: 10px 10px rgba(0, 0, 0, 0.2);
}
.button-fixed-width {
width: 150px;
}
.button-link {
padding: 0;
}
.invalid-feedback {
display: block;
}
.w-10 {
width: 10% !important;
}
.table {
padding: 3%;
border: solid 5px #a721fa;
color: #fff;
background-color: #2c2a2a;
}
.table tbody tr {
background-color: #363434;
}
.table tbody tr:not(:last-child) {
margin: 5px 0px;
}
/* Шапка */
/* Обертка шапки */
.header {
background-color: #2c2a2a;
padding: 15px 0;
}
.my-navbar {
background-color: #2c2a2a !important;
color: white;
}
.my-navbar .logo {
width: 75px;
height: 75px;
}
.logo__nametag {
margin-left: 20px;
}
/* Название логотипа */
.nametag__title {
font-size: 35px;
font-weight: bold;
color: #a721fa;
}
.nametag__subtitle {
font-size: 16px;
color: #fff;
}
.nav-list {
margin: 0px 10px;
display: flex;
justify-content: center;
text-align: center;
gap: 30px;
}
.nav-link {
text-decoration: none;
color: #fff;
font-size: 20px;
font-weight: 600;
}
.nav-link:hover {
color: #a721fa;
}
.footer {
background-color: #2c2a2a;
width: 100%;
padding: 30px 0px;
color: white;
font-size: 20px;
font-weight: 600;
}
.cart-image {
width: 3.1rem;
padding: 0.25rem;
border-radius: 0.5rem;
}
.cart-item {
height: auto;
}

Binary file not shown.

After

Width:  |  Height:  |  Size: 8.2 KiB

View File

@ -0,0 +1,86 @@
<!DOCTYPE html>
<html lang="ru" xmlns:layout="http://www.ultraq.net.nz/thymeleaf/layout" layout:decorate="~{default}">
<head>
<title>Cart</title>
</head>
<body>
<main layout:fragment="content">
<div class="d-flex flex-column align-items-center">
<div class="mb-2 col-12 col-md-8 col-lg-6 d-flex align-items-center">
<strong class="flex-fill">Cart</strong>
<form action="#" th:action="@{/cart/clear}" method="post">
<button type="submit" class="btn btn-danger button-fixed-width"
onclick="return confirm('Вы уверены?')">
<i class="bi bi-x-lg"></i> Clear
</button>
</form>
</div>
<div class="card col-12 col-md-8 col-lg-6 align-items-center" th:each="cartItem : ${cart}">
<div class="card-body col-12 p-2 d-flex flex-row align-items-center justify-content-center">
<div class="col-9">
[[${cartItem.typeName}]] [[${#numbers.formatDecimal(cartItem.price, 1, 2)}]] *
[[${cartItem.count}]]
=
[[${#numbers.formatDecimal(cartItem.price * cartItem.count, 1, 2)}]]
</div>
<div class="col-3 d-flex justify-content-end">
<form action="#"
th:action="@{/cart/increase?type={type}&price={price}(type=${cartItem.type},price=${cartItem.price})}"
method="post">
<button type="submit" class="btn btn-primary">
<i class="bi bi-plus-lg"></i>
</button>
</form>
<form action="#"
th:action="@{/cart/decrease?type={type}&price={price}(type=${cartItem.type},price=${cartItem.price})}"
method="post">
<button class="btn btn-danger">
<i class="bi bi-dash-lg"></i>
</button>
</form>
</div>
</div>
</div>
<div class=" mb-2 col-12 col-md-8 col-lg-6 d-flex justify-content-end">
<strong>Total: [[${#numbers.formatDecimal(totalCart, 1, 2)}]] &#8381;</strong>
</div>
<div class="mb-2 col-12 col-md-8 col-lg-6 d-flex justify-content-center"
th:if="${not #lists.isEmpty(cart)}">
<form action="#" th:action="@{/cart/save}" method="post">
<button type="submit" class="btn btn-primary" onclick="return confirm('Are you sure?')">
Place order
</button>
</form>
</div>
</div>
<div class="mb-2">
<form action=" #" th:action="@{/cart}" th:object="${order}" method="post">
<div class="mb-2">
<label for="type" class="form-label">Products</label>
<select th:field="*{type}" id="type" class="form-select">
<option selected value="">Select product type</option>
<option th:each="type : ${types}" th:value="${type.id}">[[${type.name}]]</option>
</select>
<div th:if="${#fields.hasErrors('type')}" th:errors="*{type}" class="invalid-feedback"></div>
</div>
<div class="mb-2">
<label for="price" class="form-label">Price</label>
<input type="number" th:field="*{price}" id="price" class="form-control" step="0.50">
<div th:if="${#fields.hasErrors('price')}" th:errors="*{price}" class="invalid-feedback"></div>
</div>
<div class="mb-2">
<label for="count" class="form-label">Count</label>
<input type="number" th:field="*{count}" id="count" class="form-control" value="0" step="1">
<div th:if="${#fields.hasErrors('count')}" th:errors="*{count}" class="invalid-feedback"></div>
</div>
<button type="submit" class="btn btn-primary">Add to cart</button>
</form>
</div>
</main>
</body>
</html>
</html>

View File

@ -0,0 +1,83 @@
<!DOCTYPE html>
<html lang="ru" data-bs-theme="dark" xmlns:th="http://www.thymeleaf.org"
xmlns:layout="http://www.ultraq.net.nz/thymeleaf/layout"
xmlns:sec="http://www.thymeleaf.org/thymeleaf-extras-springsecurity6">
<head>
<meta charset="UTF-8" />
<link rel="icon" type="image/png" href="/logo.png" />
<meta name="viewport" content="width=device-width, initial-scale=1.0" />
<title layout:title-pattern="$LAYOUT_TITLE - $CONTENT_TITLE">Bookshelf</title>
<script type="text/javascript" src="/webjars/bootstrap/5.3.3/dist/js/bootstrap.bundle.min.js"></script>
<link href="https://fonts.googleapis.com/css?family=Montserrat:regular,500,600,700,800,900&display=swap" rel="stylesheet"/>
<link rel="stylesheet" href="/webjars/bootstrap/5.3.3/dist/css/bootstrap.min.css" />
<link rel="stylesheet" href="/webjars/bootstrap-icons/1.11.3/font/bootstrap-icons.min.css" />
<link rel="stylesheet" href="/css/style.css" />
</head>
<body class="h-100 d-flex flex-column">
<div class="header">
<nav class="navbar navbar-expand-md my-navbar _container" data-bs-theme="dark">
<div class="container-fluid">
<a class="navbar-brand d-flex align-center" href="/">
<img src="/logo.png" alt="Bookshelf" class="d-inline-block align-top me-1 logo">
<div class="logo__nametag">
<div class="nametag__title">Bookshelf</div>
<div class="nametag__subtitle">Online-library</div>
</div>
</a>
<th:block sec:authorize="isAuthenticated()" th:with="userName=${#authentication.name}">
<button class="navbar-toggler" type="button" data-bs-toggle="collapse" data-bs-target="#main-navbar"
aria-controls="main-navbar" aria-expanded="false" aria-label="Toggle navigation">
<span class="navbar-toggler-icon"></span>
</button>
<div class="collapse navbar-collapse" id="main-navbar">
<ul class="navbar nav-list me-auto link" th:with="activeLink=${#objects.nullSafe(servletPath, '')}">
<th:block sec:authorize="hasRole('ADMIN')">
<a class="nav-link" href="/admin/user"
th:classappend="${activeLink.startsWith('/admin/user') ? 'active' : ''}">
Users
</a>
<a class="nav-link" href="/admin/type"
th:classappend="${activeLink.startsWith('/admin/type') ? 'active' : ''}">
Types
</a>
<a class="nav-link" href="/message"
th:classappend="${activeLink.startsWith('/message') ? 'active' : ''}">
Messages
</a>
<a class="nav-link" href="/h2-console/" target="_blank">Console H2</a>
</th:block>
<a class="nav-link" href="/message/published"
th:classappend="${activeLink.startsWith('/message/published') ? 'active' : ''}">
Published messages
</a>
</ul>
<ul class="navbar d-flex align-center" th:if="${not #strings.isEmpty(userName)}">
<form th:action="@{/logout}" method="post">
<button type="submit" class="navbar-brand nav-link" onclick="return confirm('Are you sure?')">
Logout ([[${userName}]])
</button>
</form>
<a class="navbar-brand d-flex align-center" href="/cart">
<i class="bi bi-cart2 me-1"></i>
[[${#numbers.formatDecimal(totalCart, 1, 2)}]] &#8381;
</a>
</ul>
</div>
</th:block>
</div>
</nav>
</div>
<main class="container-fluid p-2 _container" layout:fragment="content">
</main>
<footer class="footer mt-auto">
<div class="d-flex flex-shrink-0 justify-content-center align-items-center _container">
made by Factorino, [[${#dates.year(#dates.createNow())}]]
</div>
</footer>
</body>
</html>

View File

@ -0,0 +1,37 @@
<!DOCTYPE html>
<html lang="ru" xmlns:layout="http://www.ultraq.net.nz/thymeleaf/layout" layout:decorate="~{default}">
<head>
<title>Error</title>
</head>
<body>
<main layout:fragment="content">
<ul class="list-group mb-2">
<th:block th:if="${#strings.isEmpty(message)}">
<li class="list-group-item">
Unknown error
</li>
</th:block>
<th:block th:if="${not #strings.isEmpty(message)}">
<li class="list-group-item">
<strong>Error:</strong> [[${message}]]
</li>
</th:block>
<th:block th:if="${not #strings.isEmpty(url)}">
<li class="list-group-item">
<strong>URL:</strong> [[${url}]]
</li>
<li class="list-group-item">
<strong>Exception:</strong> [[${exception}]]
</li>
<li class="list-group-item">
[[${method}]] ([[${file}]]:[[${line}]])
</li>
</th:block>
</ul>
<a class="btn btn-primary button-fixed-width" href="/">Home</a>
</main>
</body>
</html>

View File

@ -0,0 +1,44 @@
<!DOCTYPE html>
<html lang="ru" xmlns:layout="http://www.ultraq.net.nz/thymeleaf/layout" layout:decorate="~{default}">
<head>
<title>Login</title>
</head>
<body>
<main layout:fragment="content">
<form action="#" th:action="@{/login}" method="post">
<div th:if="${param.error}" class="alert alert-danger">
Invalid login or password
</div>
<div th:if="${param.logout}" class="alert alert-success">
The exit was successful
</div>
<div th:if="${param.signup}" class="alert alert-success">
User successfully created
</div>
<div class="mb-3">
<label for="username" class="form-label">Username</label>
<input type="text" id="username" name="username" class="form-control" required minlength="3"
maxlength="20">
</div>
<div class="mb-3">
<label for="password" class="form-label">Password</label>
<input type="password" id="password" name="password" class="form-control" required minlength="3"
maxlength="20">
</div>
<div class="form-check mb-3">
<input class="form-check-input" type="checkbox" id="remember-me" name="remember-me" checked>
<label class="form-check-label" for="remember-me">Remember me</label>
</div>
<div class="mb-3 d-flex flex-row">
<button class="btn btn-primary me-2 button-fixed-width" type="submit">Login</button>
<a class="btn btn-secondary button-fixed-width" href="/signup">Sign up</a>
</div>
</form>
</main>
</body>
</html>
</html>

View File

@ -0,0 +1,24 @@
<!DOCTYPE html>
<html lang="ru" xmlns:layout="http://www.ultraq.net.nz/thymeleaf/layout" layout:decorate="~{default}">
<head>
<title>Send message</title>
</head>
<body>
<main layout:fragment="content">
<form action="#" th:action="@{/message/send/}" th:object="${message}" method="post">
<div class="mb-3">
<label for="text" class="form-label">Text</label>
<input type="text" th:field="*{text}" id="text" class="form-control">
<div th:if="${#fields.hasErrors('text')}" th:errors="*{text}" class="invalid-feedback"></div>
</div>
<div class="mb-3 d-flex flex-row">
<button class="btn btn-primary me-2 button-fixed-width" type="submit">Send message</button>
<a class="btn btn-secondary button-fixed-width" href="/">Cancel</a>
</div>
</form>
</main>
</body>
</html>

View File

@ -0,0 +1,62 @@
<!DOCTYPE html>
<html lang="ru" xmlns:layout="http://www.ultraq.net.nz/thymeleaf/layout" layout:decorate="~{default}">
<head>
<title>Messages</title>
</head>
<body>
<main layout:fragment="content" >
<th:block th:switch="${messageItems.size()}">
<h2 th:case="0">No data available</h2>
<th:block th:case="*">
<h2>Messages</h2>
<table class="table">
<caption></caption>
<thead>
<tr>
<th scope="col" class="w-10">ID</th>
<th scope="col" class="w-10">Sender</th>
<th scope="col" class="w-auto">Message</th>
<th scope="col" class="w-10">Date</th>
<th scope="col" class="w-4" style="text-align: center;">Published</th>
<th sec:authorize="hasRole('ADMIN')" scope="col" class="w-10"></th>
<th sec:authorize="hasRole('ADMIN')" scope="col" class="w-10"></th>
</tr>
</thead>
<tbody>
<tr th:each="message : ${messageItems}">
<th scope="row" th:text="${message.id}"></th>
<td th:text="${message.userEmail}"></td>
<td th:text="${message.text}"></td>
<td th:text="${message.date}"></td>
<td style="text-align: center;">
<input type="checkbox" th:checked="${message.isPublished}" style="display: inline-block;" disabled/>
</td>
<td sec:authorize="hasRole('ADMIN')">
<form th:action="@{/message/publish/{id}(id=${message.id})}" method="post">
<input type="hidden" th:name="page" th:value="${page}">
<button type="submit" class="btn"
onclick="return confirm('Are you sure?')">Publish</button>
</form>
</td>
<td sec:authorize="hasRole('ADMIN')">
<form th:action="@{/message/delete/{id}(id=${message.id})}" method="post">
<input type="hidden" th:name="page" th:value="${page}">
<button type="submit" class="btn"
onclick="return confirm('Are you sure?')">Delete</button>
</form>
</td>
</tr>
</tbody>
</table>
</th:block>
<th:block th:replace="~{ pagination :: pagination (
url=${'admin/message'},
totalPages=${messageTotalPages},
currentPage=${messageCurrentPage}) }" />
</th:block>
</main>
</body>
</html>

View File

@ -0,0 +1,64 @@
<!DOCTYPE html>
<html xmlns:th="http://www.thymeleaf.org">
<body>
<th:block th:fragment="orders (items, totalPages, currentPage)">
<th:block th:switch="${items.size()}">
<h2 th:case="0">No data available</h2>
<th:block th:case="*">
<form th:action="@{/}" method="get" class="row mt-2">
<div class="col-sm-10">
<input type="hidden" th:name="page" th:value="${page}">
<select th:name="typeId" id="typeId" class="form-select">
<option selected value="">Type filter</option>
<option th:each="type : ${types}" th:value="${type.id}" th:selected="${type.id==typeId}">
[[${type.name}]]
</option>
</select>
</div>
<button type="submit" class="btn btn-primary col-sm-2">Submit</button>
</form>
<table class="table mt-2">
<caption></caption>
<thead>
<tr>
<th scope="col" class="w-10">ID</th>
<th scope="col" class="w-auto">Type</th>
<th scope="col" class="w-10">Price</th>
<th scope="col" class="w-10">Count</th>
<th scope="col" class="w-10">Total</th>
<th scope="col" class="w-10"></th>
</tr>
</thead>
<tbody>
<tr th:each="order : ${items}">
<th scope="row" th:text="${order.id}"></th>
<td th:text="${order.typeName}"></td>
<td th:text="${#numbers.formatDecimal(order.price, 1, 2)}"></td>
<td th:text="${order.count}"></td>
<td th:text="${#numbers.formatDecimal(order.sum, 1, 2)}"></td>
<td>
<form th:action="@{/delete/{id}(id=${order.id})}" method="post">
<input type="hidden" th:name="page" th:value="${page}">
<input type="hidden" th:name="typeId" th:value="${typeId}">
<button type="submit" class="btn"
onclick="return confirm('Are you sure?')">Delete</button>
</form>
</td>
</tr>
</tbody>
</table>
</th:block>
<th:block th:replace="~{ pagination :: pagination (
url='',
totalPages=${totalPages},
currentPage=${currentPage}) }" />
<div class="mt-2 d-flex justify-content-center">
<a class="btn btn-primary" href="/cart">Place order</a>
</div>
</th:block>
</th:block>
</body>
</html>

View File

@ -0,0 +1,51 @@
<!DOCTYPE html>
<html xmlns:th="http://www.thymeleaf.org">
<body>
<th:block th:fragment="pagination (url, totalPages, currentPage)">
<nav th:if="${totalPages > 1}" th:with="
maxPage=2,
currentPage=${currentPage + 1}">
<ul class="pagination justify-content-center"
th:with="
seqFrom=${currentPage - maxPage < 1 ? 1 : currentPage - maxPage},
seqTo=${currentPage + maxPage > totalPages ? totalPages : currentPage + maxPage}">
<th:block th:if="${currentPage > maxPage + 1}">
<li class="page-item">
<a class="page-link" aria-label="Previous" th:href="@{/{url}?page=0(url=${url})}">
<span aria-hidden="true">&laquo;</span>
</a>
</li>
<li class="page-item disabled">
<span class="page-link" aria-label="Previous">
<span aria-hidden="true">&hellip;</span>
</span>
</li>
</th:block>
<li class="page-item" th:each="page : ${#numbers.sequence(seqFrom, seqTo)}"
th:classappend="${page == currentPage} ? 'active' : ''">
<a class=" page-link" th:href="@{/{url}?page={page}(url=${url},page=${page - 1})}">
<span th:text="${page}" />
</a>
</li>
<th:block th:if="${currentPage < totalPages - maxPage}">
<li class="page-item disabled">
<span class="page-link" aria-label="Previous">
<span aria-hidden="true">&hellip;</span>
</span>
</li>
<li class="page-item">
<a class="page-link" aria-label="Next"
th:href="@{/{url}?page={page}(url=${url},page=${totalPages - 1})}">
<span aria-hidden="true">&raquo;</span>
</a>
</li>
</th:block>
</ul>
</nav>
</th:block>
</body>
</html>

View File

@ -0,0 +1,48 @@
<!DOCTYPE html>
<html lang="ru" xmlns:layout="http://www.ultraq.net.nz/thymeleaf/layout" layout:decorate="~{default}">
<head>
<title>My account</title>
</head>
<body>
<main layout:fragment="content">
<ul class="nav nav-pills justify-content-center" role="tablist">
<li class="nav-item">
<a class="nav-link active" data-bs-toggle="pill" href="#orders">Orders</a>
</li>
<li class="nav-item">
<a class="nav-link" data-bs-toggle="pill" href="#stats">Statistics</a>
</li>
<li class="nav-item">
<a class="nav-link" data-bs-toggle="pill" href="#messages">Messages</a>
</li>
</ul>
<div class="tab-content mt-2">
<div class="tab-pane container active" id="orders">
<th:block th:replace="~{ orders :: orders (
items=${orderItems},
totalPages=${orderTotalPages},
currentPage=${orderCurrentPage}) }" />
</div>
<div class="tab-pane container fade" id="stats">
<ul class="list-group mb-2">
<li th:each="stat : ${stats}" class="list-group-item">
<strong>[[${stat.typeName}]]</strong>:
[[${#numbers.formatDecimal(stat.totalPrice, 1, 2)}]] &#8381;
([[${stat.totalCount}]] шт.)
</li>
</ul>
</div>
<div class="tab-pane container fade" id="messages">
<th:block th:replace="~{ user-messages :: messages (
items=${messageItems},
totalPages=${messageTotalPages},
currentPage=${messageCurrentPage}) }" />
</div>
</div>
</main>
</body>
</html>

View File

@ -0,0 +1,42 @@
<!DOCTYPE html>
<html lang="ru" xmlns:layout="http://www.ultraq.net.nz/thymeleaf/layout" layout:decorate="~{default}">
<head>
<title>Sign up</title>
</head>
<body>
<main layout:fragment="content">
<form action="#" th:action="@{/signup}" th:object="${user}" method="post">
<div class="mb-3">
<label for="username" class="form-label">Username</label>
<input type="text" th:field="*{username}" id="username" class="form-control">
<div th:if="${#fields.hasErrors('username')}" th:errors="*{username}" class="invalid-feedback"></div>
</div>
<div class="mb-3">
<label for="email" class="form-label">Email</label>
<input type="email" th:field="*{email}" id="email" class="form-control">
<div th:if="${#fields.hasErrors('email')}" th:errors="*{email}" class="invalid-feedback"></div>
</div>
<div class="mb-3">
<label for="password" class="form-label">Password</label>
<input type="password" th:field="*{password}" id="password" class="form-control">
<div th:if="${#fields.hasErrors('password')}" th:errors="*{password}" class="invalid-feedback"></div>
</div>
<div class="mb-3">
<label for="passwordConfirm" class="form-label">Password confirm</label>
<input type="password" th:field="*{passwordConfirm}" id="passwordConfirm" class="form-control">
<div th:if="${#fields.hasErrors('passwordConfirm')}" th:errors="*{passwordConfirm}"
class="invalid-feedback"></div>
</div>
<div class="mb-3 d-flex flex-row">
<button class="btn btn-primary me-2 button-fixed-width" type="submit">Sign up</button>
<a class="btn btn-secondary button-fixed-width" href="/">Cancel</a>
</div>
</form>
</main>
</body>
</html>
</html>

View File

@ -0,0 +1,28 @@
<!DOCTYPE html>
<html lang="ru" xmlns:layout="http://www.ultraq.net.nz/thymeleaf/layout" layout:decorate="~{default}">
<head>
<title>Edit order type</title>
</head>
<body>
<main layout:fragment="content">
<form action="#" th:action="@{/admin/type/edit/{id}(id=${type.id})}" th:object="${type}" method="post">
<div class="mb-3">
<label for="id" class="form-label">ID</label>
<input type="text" th:value="*{id}" id="id" class="form-control" readonly disabled>
</div>
<div class="mb-3">
<label for="name" class="form-label">Type name</label>
<input type="text" th:field="*{name}" id="name" class="form-control">
<div th:if="${#fields.hasErrors('name')}" th:errors="*{name}" class="invalid-feedback"></div>
</div>
<div class="mb-3 d-flex flex-row">
<button class="btn btn-primary me-2 button-fixed-width" type="submit">Save</button>
<a class="btn btn-secondary button-fixed-width" href="/admin/type">Cancel</a>
</div>
</form>
</main>
</body>
</html>

View File

@ -0,0 +1,50 @@
<!DOCTYPE html>
<html lang="ru" xmlns:layout="http://www.ultraq.net.nz/thymeleaf/layout" layout:decorate="~{default}">
<head>
<title>Order types</title>
</head>
<body>
<main layout:fragment="content">
<th:block th:switch="${items.size()}">
<h2 th:case="0">No data available</h2>
<th:block th:case="*">
<h2>Order types</h2>
<div>
<a href="/admin/type/edit/" class="btn btn-primary">Create order type</a>
</div>
<table class="table">
<caption></caption>
<thead>
<tr>
<th scope="col" class="w-10">ID</th>
<th scope="col" class="w-auto">Type name</th>
<th scope="col" class="w-10"></th>
<th scope="col" class="w-10"></th>
</tr>
</thead>
<tbody>
<tr th:each="type : ${items}">
<th scope="row" th:text="${type.id}"></th>
<td th:text="${type.name}"></td>
<td>
<form th:action="@{/admin/type/edit/{id}(id=${type.id})}" method="get">
<button type="submit" class="btn">Edit</button>
</form>
</td>
<td>
<form th:action="@{/admin/type/delete/{id}(id=${type.id})}" method="post">
<button type="submit" class="btn"
onclick="return confirm('Are you sure?')">Delete</button>
</form>
</td>
</tr>
</tbody>
</table>
</th:block>
</th:block>
</main>
</body>
</html>

View File

@ -0,0 +1,34 @@
<!DOCTYPE html>
<html lang="ru" xmlns:layout="http://www.ultraq.net.nz/thymeleaf/layout" layout:decorate="~{default}">
<head>
<title>Edit user</title>
</head>
<body>
<main layout:fragment="content">
<form action="#" th:action="@{/admin/user/edit/{id}(id=${user.id},page=${page})}" th:object="${user}"
method="post">
<div class="mb-3">
<label for="id" class="form-label">ID</label>
<input type="text" th:value="*{id}" id="id" class="form-control" readonly disabled>
</div>
<div class="mb-3">
<label for="username" class="form-label">Username</label>
<input type="text" th:field="*{username}" id="username" class="form-control">
<div th:if="${#fields.hasErrors('username')}" th:errors="*{username}" class="invalid-feedback"></div>
</div>
<div class="mb-3">
<label for="email" class="form-label">Email</label>
<input type="email" th:field="*{email}" id="email" class="form-control">
<div th:if="${#fields.hasErrors('email')}" th:errors="*{email}" class="invalid-feedback"></div>
</div>
<div class="mb-3 d-flex flex-row">
<button class="btn btn-primary me-2 button-fixed-width" type="submit">Save</button>
<a class="btn btn-secondary button-fixed-width" th:href="@{/admin/user(page=${page})}">Cancel</a>
</div>
</form>
</main>
</body>
</html>

View File

@ -0,0 +1,45 @@
<!DOCTYPE html>
<html xmlns:th="http://www.thymeleaf.org">
<body>
<th:block th:fragment="messages (items, totalPages, currentPage)">
<th:block th:switch="${items.size()}">
<h2 th:case="0">No data available</h2>
<th:block th:case="*">
<table class="table mt-2">
<caption></caption>
<thead>
<tr>
<th scope="col" class="w-10">ID</th>
<th scope="col" class="w-10">Sender</th>
<th scope="col" class="w-auto">Message</th>
<th scope="col" class="w-10">Date</th>
<th scope="col" class="w-4" style="text-align: center;">Published</th>
</tr>
</thead>
<tbody>
<tr th:each="message : ${items}">
<th scope="row" th:text="${message.id}"></th>
<td th:text="${message.userEmail}"></td>
<td th:text="${message.text}"></td>
<td th:text="${message.date}"></td>
<td style="text-align: center;">
<input type="checkbox" th:checked="${message.isPublished}" style="display: inline-block;" disabled/>
</td>
</tr>
</tbody>
</table>
</th:block>
<th:block th:replace="~{ pagination :: pagination (
url='',
totalPages=${totalPages},
currentPage=${currentPage}) }" />
<div class="mt-2 d-flex justify-content-center">
<a class="btn btn-primary" href="/message/send/">Send message</a>
</div>
</th:block>
</th:block>
</body>
</html>

View File

@ -0,0 +1,58 @@
<!DOCTYPE html>
<html lang="ru" xmlns:layout="http://www.ultraq.net.nz/thymeleaf/layout" layout:decorate="~{default}">
<head>
<title>Users</title>
</head>
<body>
<main layout:fragment="content">
<th:block th:switch="${userItems.size()}">
<h2 th:case="0">No data available</h2>
<th:block th:case="*">
<h2>Users</h2>
<div>
<a th:href="@{/admin/user/edit/(page=${page})}" class="btn btn-primary">Create user</a>
</div>
<table class="table">
<caption></caption>
<thead>
<tr>
<th scope="col" class="w-10">ID</th>
<th scope="col" class="w-auto">Username</th>
<th scope="col" class="w-auto">Email</th>
<th scope="col" class="w-10"></th>
<th scope="col" class="w-10"></th>
</tr>
</thead>
<tbody>
<tr th:each="user : ${userItems}">
<th scope="row" th:text="${user.id}"></th>
<td th:text="${user.username}"></td>
<td th:text="${user.email}"></td>
<td>
<form th:action="@{/admin/user/edit/{id}(id=${user.id})}" method="get">
<input type="hidden" th:name="page" th:value="${page}">
<button type="submit" class="btn">Edit</button>
</form>
</td>
<td>
<form th:action="@{/admin/user/delete/{id}(id=${user.id})}" method="post">
<input type="hidden" th:name="page" th:value="${page}">
<button type="submit" class="btn"
onclick="return confirm('Are you sure?')">Delete</button>
</form>
</td>
</tr>
</tbody>
</table>
</th:block>
<th:block th:replace="~{ pagination :: pagination (
url=${'admin/user'},
totalPages=${userTotalPages},
currentPage=${userCurrentPage}) }" />
</th:block>
</main>
</body>
</html>

View File

@ -1,13 +0,0 @@
package com.example.demo;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
@SpringBootTest
class DemoApplicationTests {
@Test
void contextLoads() {
}
}

View File

@ -0,0 +1,82 @@
package com.example.demo;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.MethodOrderer.OrderAnnotation;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestMethodOrder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.dao.DataIntegrityViolationException;
import com.example.demo.core.error.NotFoundException;
import com.example.demo.types.model.TypeEntity;
import com.example.demo.types.service.TypeService;
@SpringBootTest
@TestMethodOrder(OrderAnnotation.class)
class TypeServiceTests {
@Autowired
private TypeService typeService;
private TypeEntity type;
@BeforeEach
void createData() {
removeData();
type = typeService.create(new TypeEntity("Protection"));
typeService.create(new TypeEntity("Sharpness"));
typeService.create(new TypeEntity("Infinity"));
}
@AfterEach
void removeData() {
typeService.deleteAll();
}
@Test
void getTest() {
Assertions.assertThrows(NotFoundException.class, () -> typeService.get(0L));
}
@Test
void createTest() {
Assertions.assertEquals(3, typeService.getAll().size());
Assertions.assertEquals(type, typeService.get(type.getId()));
}
@Test
void createNotUniqueTest() {
final TypeEntity nonUniqueType = new TypeEntity("Protection");
Assertions.assertThrows(IllegalArgumentException.class, () -> typeService.create(nonUniqueType));
}
@Test
void createNullableTest() {
final TypeEntity nullableType = new TypeEntity(null);
Assertions.assertThrows(DataIntegrityViolationException.class, () -> typeService.create(nullableType));
}
@Test
void updateTest() {
final String test = "TEST";
final String oldName = type.getName();
final TypeEntity newEntity = typeService.update(type.getId(), new TypeEntity(test));
Assertions.assertEquals(3, typeService.getAll().size());
Assertions.assertEquals(newEntity, typeService.get(type.getId()));
Assertions.assertEquals(test, newEntity.getName());
Assertions.assertNotEquals(oldName, newEntity.getName());
}
@Test
void deleteTest() {
typeService.delete(type.getId());
Assertions.assertEquals(2, typeService.getAll().size());
final TypeEntity newEntity = typeService.create(new TypeEntity(type.getName()));
Assertions.assertEquals(3, typeService.getAll().size());
Assertions.assertNotEquals(type.getId(), newEntity.getId());
}
}

View File

@ -0,0 +1,90 @@
package com.example.demo;
import java.time.LocalDateTime;
import java.util.List;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.MethodOrderer.OrderAnnotation;
import org.junit.jupiter.api.Order;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestMethodOrder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import com.example.demo.messages.model.MessageEntity;
import com.example.demo.messages.service.MessageService;
import com.example.demo.users.model.UserEntity;
import com.example.demo.users.service.UserService;
import jakarta.persistence.EntityManager;
@SpringBootTest
@TestMethodOrder(OrderAnnotation.class)
class UserMessageServiceTests {
@Autowired
private EntityManager entityManager;
@Autowired
private UserService userService;
@Autowired
private MessageService messageService;
private UserEntity user1;
private UserEntity user2;
private UserEntity user3;
@BeforeEach
void createData() {
removeData();
user1 = userService.create(new UserEntity("user1", "password", "mail1@gmail.com"));
user2 = userService.create(new UserEntity("user2", "password", "mail2@gmail.com"));
user3 = userService.create(new UserEntity("user3", "password", "mail3@gmail.com"));
final var messages1 = List.of(
new MessageEntity("message1", LocalDateTime.now(), false),
new MessageEntity("message2", LocalDateTime.now(), false),
new MessageEntity("message3", LocalDateTime.now(), false)
);
messages1.forEach(message -> messageService.create(user1.getId(), message));
final var messages2 = List.of(
new MessageEntity("Message4", LocalDateTime.now(), false),
new MessageEntity("Message5", LocalDateTime.now(), false)
);
messages2.forEach(message -> messageService.create(user2.getId(), message));
}
@AfterEach
void removeData() {
userService.deleteAll();
}
@Test
@Order(1)
void createTest() {
Assertions.assertEquals(5, messageService.getAll(0L).size());
}
@Test
@Order(2)
void orderFilterTest() {
Assertions.assertEquals(3, messageService.getAll(user1.getId()).size());
Assertions.assertEquals(2, messageService.getAll(user2.getId()).size());
Assertions.assertEquals(0, messageService.getAll(user3.getId()).size());
}
@Test
@Order(3)
void userCascadeDeleteTest() {
userService.delete(user1.getId());
final var messages = entityManager.createQuery(
"select count(o) from MessageEntity o where o.user.id = :userId");
messages.setParameter("userId", user1.getId());
Assertions.assertEquals(0, messages.getFirstResult());
}
}

View File

@ -0,0 +1,100 @@
package com.example.demo;
import java.util.List;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Order;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestMethodOrder;
import org.junit.jupiter.api.MethodOrderer.OrderAnnotation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import com.example.demo.orders.model.OrderEntity;
import com.example.demo.orders.service.OrderService;
import com.example.demo.types.model.TypeEntity;
import com.example.demo.types.service.TypeService;
import com.example.demo.users.model.UserEntity;
import com.example.demo.users.service.UserService;
import jakarta.persistence.EntityManager;
@SpringBootTest
@TestMethodOrder(OrderAnnotation.class)
class UserOrderServiceTests {
@Autowired
private EntityManager entityManager;
@Autowired
private TypeService typeService;
@Autowired
private UserService userService;
@Autowired
private OrderService orderService;
private TypeEntity type1;
private TypeEntity type2;
private TypeEntity type3;
private UserEntity user1;
private UserEntity user2;
@BeforeEach
void createData() {
removeData();
type1 = typeService.create(new TypeEntity("Protection"));
type2 = typeService.create(new TypeEntity("Sharpness"));
type3 = typeService.create(new TypeEntity("Infinity"));
user1 = userService.create(new UserEntity("user1", "password", "mail1@gmail.com"));
user2 = userService.create(new UserEntity("user2", "password", "mail2@gmail.com"));
final var orders = List.of(
new OrderEntity(type1, 12.00, 3),
new OrderEntity(type1, 50.00, 20),
new OrderEntity(type2, 15.00, 30),
new OrderEntity(type2, 64.00, 10),
new OrderEntity(type2, 15.00, 6),
new OrderEntity(type3, 80.00, 6),
new OrderEntity(type3, 64.00, 3)
);
orders.forEach(order -> orderService.create(user1.getId(), order));
}
@AfterEach
void removeData() {
userService.deleteAll();
typeService.deleteAll();
}
@Test
@Order(1)
void createTest() {
Assertions.assertEquals(7, orderService.getAll(user1.getId(), 0L).size());
Assertions.assertEquals(0, orderService.getAll(user2.getId(), 0L).size());
}
@Test
@Order(2)
void orderFilterTest() {
Assertions.assertEquals(2, orderService.getAll(user1.getId(), type1.getId()).size());
Assertions.assertEquals(3, orderService.getAll(user1.getId(), type2.getId()).size());
Assertions.assertEquals(2, orderService.getAll(user1.getId(), type3.getId()).size());
}
@Test
@Order(3)
void userCascadeDeleteTest() {
userService.delete(user1.getId());
final var orders = entityManager.createQuery(
"select count(o) from OrderEntity o where o.user.id = :userId");
orders.setParameter("userId", user1.getId());
Assertions.assertEquals(0, orders.getFirstResult());
}
}

View File

@ -0,0 +1,14 @@
# Server
spring.main.banner-mode=off
# Logger settings
# Available levels are: TRACE, DEBUG, INFO, WARN, ERROR, FATAL, OFF
logging.level.com.example.demo=DEBUG
# JPA Settings
spring.datasource.url=jdbc:h2:mem:testdb
spring.datasource.username=factorino
spring.datasource.password=password
spring.datasource.driver-class-name=org.h2.Driver
spring.jpa.hibernate.ddl-auto=create
spring.jpa.open-in-view=false