diff --git a/.gitignore b/.gitignore
index 6ca05c4a5184..6ea7841c64d0 100644
--- a/.gitignore
+++ b/.gitignore
@@ -3,6 +3,7 @@ out
target
*.iml
log
+config
diff --git a/Procfile b/Procfile
new file mode 100644
index 000000000000..4afeb7900918
--- /dev/null
+++ b/Procfile
@@ -0,0 +1 @@
+web: java $JAVA_OPTS -Dspring.profiles.active="datajpa,heroku" -DTOPJAVA_ROOT="." -jar target/dependency/webapp-runner.jar --port $PORT target/*.war
\ No newline at end of file
diff --git a/README.md b/README.md
new file mode 100644
index 000000000000..4dc8d880712d
--- /dev/null
+++ b/README.md
@@ -0,0 +1,141 @@
+Java Enterprise Online Project
+===============================
+
+[](https://www.codacy.com/app/javawebinar/topjava06)
+
+
+Наиболее востребованные технологии /инструменты / фреймворки Java Enterprise:
+Maven/ Spring/ Security/ JPA(Hibernate)/ REST(Jackson)/ Bootstrap(CSS)/ jQuery + plugins.
+
+ Когда вы слышите что-то, вы забываете это.
+ Когда вы видите что-то, вы запоминаете это.
+ Но только когда вы начинаете делать это,
+ вы начинаете понимать это
+
+ Старинная китайская поговорка
+
+## Описание и план проекта
+### Демо разрабатываемого приложения
+
+### Test UserMealRestController (application deployed with context `topjava`).
+> For windows use `Git Bash`
+
+#### get All
+`curl -s http://localhost:8080/topjava/rest/profile/meals`
+
+#### get 100003
+`curl -s http://localhost:8080/topjava/rest/profile/meals/100003`
+
+#### get between
+`curl -s "http://localhost:8080/topjava/rest/profile/meals/between?startDateTime=2015-05-30T08:00:00&endDateTime=2015-05-30T16:00:00"`
+
+#### get not found
+`curl -s -v http://localhost:8080/rest/meals/100008`
+
+#### delete
+`curl -s -X DELETE http://localhost:8080/rest/meals/100002`
+
+#### create
+`curl -s -v -X POST -d '{"dateTime":"2015-06-01T12:00","description":"Created lunch","calories":300}' -H 'Content-Type:application/json;charset=UTF-8' http://localhost:8080/topjava/rest/profile/meals`
+
+#### update
+`curl -s -v -X PUT -d '{"dateTime":"2015-05-30T07:00", "description":"Updated breakfast", "calories":200}' -H 'Content-Type: application/json' http://localhost:8080/topjava/rest/profile/meals/100003`
+### Требования к участникам, Wiki
+
+Вводное занятие
+===============
+##  Системы управления версиями. Git.
+
+- Система управления версиями. VCS/DVSC.
+- Ресурсы:
+ - Интерактивная Git обучалка
+ - Основы Git
+ - Working with remote repositories
+ - Видео по обучению Git
+ - Как начать работать с GitHub: быстрый старт
+ - Справочник в графическом виде
+ - Git Overview
+ - Видеокурс по Git
+
+##  Работа с проектом (выполнять инструкции)
+- **Prepare_ to_ HW0.patch (скачать и положить в каталог вашего проекта)**
+- Доступно о Java 8 Lambda
+
+## Инструкция по шагам (из видео):
+- Установить ПО (git, JDK8, IntelliJ IDEA, Maven)
+- Создать аккаунт на GitHub
+- Сделать Fork ЭТОГО проекта (https://github.com/JavaOPs/topjava)
+- Сделать локальный репозиторий проекта:
+
+- Открыть и настроить проект в IDEA
+- По ходу видео сделать Apply Patch... скаченного патча Prepare_ to_ HW0.patch
+- Закоммитить и запушить изменения (commit + push)
+- Сделать ветку домашнего задания
+- Выполнить задание и залить на GitHub (commit + push)
+- Переключиться в основную ветку проекта master.
+
+## Домашнее задание HW0
+
+- Java 8 Date and Time API
+- Time complexity
+- Временная сложность алгоритма
+- Вычислительная сложность
+```
+Реализовать UserMealsUtil.getFilteredMealsWithExceeded:
+- должны возвращаться только записи между startTime и endTime
+- поле UserMealWithExceed.exceed должно показывать,
+ превышает ли сумма калорий за весь день параметра метода caloriesPerDay
+
+Т.е UserMealWithExceed - это запись одной еды, но поле exceeded будет одинаково для всех записей за этот день.
+
+- Проверте результат выполнения ДЗ (можно проверить логику в http://topjava.herokuapp.com , список еды)
+- Оцените Time complexity вашего алгоритма (если он O(N*N)- попробуйте сделать O(N).
+```
+Optional
+
+- Java 8: Lambda выражения
+- Java 8: Потоки
+- Pуководство по Java 8 Stream
+- Лямбда-выражения в Java 8
+- Шпаргалка Java Stream API
+- stream.map vs forEach
+
+```
+Сделать реализация через Java 8 Stream API. Заменяйте forEach оператором stream.map(..)
+```
+
+### Ваши вопросы
+> Как брать диапазон дат? Какие брать дефолтные значения для null?
+
+Для диапазона нужно использовать уже готовый `TimeUtil.isBetween`. Как приложение должно себя вести можно проверить на demo.
+
+
+### Составление резюме, подготовка к интервью, поиск работы
+### Ресурсы для подготовки к проекту
+#### (желательно иметь представление для лучшего усвоения материала)
+
+#### Java Web (Servlets, JSP)
+- Введение в сетевое программирование
+- Основы Java на реальном примере (Servlets, JSP)
+- Как создать Servlet? Полное руководство.
+- Технологии Java для разработки веб-приложений
+
+#### HTML, JavaScript, CSS
+- Основы работы с HTML/CSS/JavaScript
+- jQuery для начинающих
+- Уроки Bootstrap 3
+
+#### Java Core (Reflection API, JUnit)
+- Введение в Java Reflection API
+- Java JUnit
+
+#### JDBC, SQL
+- Уроки по JDBC
+- Learn SQL
+- Try SQL
+
+#### Разное
+- Интуит. Программирование на Java
+- Oracle Java tutorial на русском.
+- Эффективная работа с кодом в IntelliJ IDEA
\ No newline at end of file
diff --git a/config/setenv.bat b/config/setenv.bat
new file mode 100644
index 000000000000..ebbd659386f6
--- /dev/null
+++ b/config/setenv.bat
@@ -0,0 +1,4 @@
+rem run tomcat with JMX ability
+rem Run Tomcat as admin
+rem for remote connection add -Djava.rmi.server.hostname=TomcatServer_IP
+set CATALINA_OPTS=-Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.port=1099 -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false
diff --git a/cv.md b/cv.md
new file mode 100644
index 000000000000..95a53c28f61a
--- /dev/null
+++ b/cv.md
@@ -0,0 +1,55 @@
+## Составление резюме, подготовка к интервью, поиск работы
+
+
+
+- Научиться программировать сложнее, чем кажется
+
+### Составление резюме:
+- Идеальное резюме Junior’а
+- Как продать свое резюме в 2 раза дороже
+- Как правильно составить резюме
+- Резюме программистов. Часть 1 (плохие)
+- Резюме программистов. Часть 2 (хорошие)
+- Как составить резюме на английском
+
+### Интервью:
+- Михаил Портнов. Собеседование на работу: как продать себя грамотно
+- Михаил Портнов. Какие вопросы мы задаем на собеседовании?
+- Канал: Резюме, поиск работы, интервью
+- Яков Файн: Как стать профессиональным Java разработчиком
+- Quizful- тесты онлайн
+- Сборка по вопросам на интервью
+- Тест на знание SQL
+- Сборка вопросов от JavaRush
+> про clone и finalize объязательно прочтите Джошуа Блох: Java. Эффективное программирование (второе издание)
+
+- Cracking the Coding Interview
+> Особенно обратите внимание на раздел: Часть VIII. Вопросы собеседования
+
+### От себя:
+- email, skype - очень желательно, чтобы по ним вы были узнаваемы. Заведите рабочие, если не так.
+- написать ВЕСЬ IT опыт (исключая опыт пользователя: Windows, MS Word, Photophop, Yandex disk, Google docs, ..): технологии, какие задачи решали (конкретные), какие инструменты использовали, VCS, DB, инструменты сборки, ... включая опыт в ВУЗе.
+- на English иметь желательно. Если вакансия опублинована на Englsih - шлите на нем. Часто могут на нем попросить, если работодатель иностранный.
+- удобно иметь резюме где то в инете (hh, linkedin, google doc, чтобы им было удобно делиться).
+
+### Позиционирование проекта Topjava:
+- После завершения проекта вы освоите все заявленные в нем технологии - вставьте в квалификацию (включая java 8 Stream and Time API)
+- Делайте упор не на обучение, а на *участие в проекте*. Выполнение домашних заданий - это полноценное участие с написанием функционала по всем этим технологиям. Например:
+
+ Участие в разработке Spring/JPA Enterprise приложения c авторизацией и правами доступа на основе ролей
+ на стеке Maven/ Spring MVC/ Security/ REST(Jackson)/ Java 8 Stream API:
+ - реализация сохранения в базы Postgres и HSQLDB на основе Spring JBDC, JPA(Hibernate) и Spring-Data-JPA
+ - реализация и тестирование REST и AJAX контроллеров
+ - реализация клиента на Bootstrap (css/js), datatables, jQuery + plugins.
+ - отлично будет, если вы его еще как то сами доработаете
+
+- По поводу обучения на курсах- можно упомянуть в разделе образования. Но на собеседовании меньше смотрят на то, что вы заканчивали, больше - на ваш опыт и то что вы знаете.
+
+### В течении проекта заполните форму соискателя "Разработчик Java"
+Я ее рассылаю всем знакомым HR, уже есть пинги и трудоустройство.
+
+### Основные сайты поиска работы:
+- HH
+- LinkedIn
+- djinni.co (более актуально для Украины)
+- moikrug
diff --git a/description.md b/description.md
new file mode 100644
index 000000000000..cbb102fa72aa
--- /dev/null
+++ b/description.md
@@ -0,0 +1,67 @@
+#### Разработка полнофункционального Spring/JPA Enterprise приложения c авторизацией и правами доступа на основе ролей с использованием наиболее популярных инструментов и технологий Java: Maven, Spring MVC, Security, JPA(Hibernate), REST(Jackson), Bootstrap (css,js), datatables, jQuery + plugins, Java 8 Stream and Time API
+- Основное внимание будет уделяться способам решения многочисленных проблем разработки в Spring/JPA, а также структурному (красивому и надежному) java кодированию и архитектуре приложения.
+- Каждая итерация проекта в закрепляется домашним заданием по реализации схожей функциональности. Следующее занятие начинается с разбора домашних заданий.
+- Большое внимание уделяется тестированию кода: в проекте 88 JUnit тестов.
+- Несмотря на относительно небольшой размер, приложение разрабатывается с нуля как большой проект (например мы используем кэш 2-го уровня Hibernate, настраиваем Jenkins для работы с ленивой загрузкой
+Hibernate, делаем конверторы для типов LocalDateTime (Java 8 time API), которые еще не поддерживаются ни JPA/Hibernate, ни Jackson/json).
+ Разбираются архитектурные паттерны: слои приложения и как правильно разбивать логику по слоям, когда нужно применять Data Transfer Object.
+ Т.е на выходе получается не учебный проект, а хорошо маштабируемый шаблон для большого проекта на всех пройденных технологиях.
+- Большое внимание уделяется деталям: популяция базы, использование транзакционности, тесты сервисов и REST
+ контроллеров, насторойка EntityManagerFactory,
+ выбор реализации пула коннектов. Особое внимание уделяется работе с базой: через Spring JDBC, Spring ORM и
+ Spring Data Jpa.
+- Используются самые востребованные на сегодняшний момент фреймворки: Maven, Spring Security 4
+ вместе с Spring Security Test, наиболее удобный для работы с базой проект Spring Data Jpa, библиотека логирования logback, реализующая SLF4J, повсеместно используемый Bootstrap и jQuery.
+
+#### Демо разрабатываемого приложения
+
+## План проекта (ссылки на некоторые темы открыты для просмотра)
+### Архитектура проекта. Персистентность.
+- Системы управления версиями
+- Java 8: Lambda, Stream API
+- Обзор используемых в проекте технологий и инструментов.
+- Инструмент сборки Maven.
+- WAR. Веб-контейнер Tomcat. Сервлеты.
+- Логирование.
+- Обзор стандартных библиотек. Apache Commons, Guava
+- Слои приложения. Создание каркаса приложения.
+- Обзор Spring Framework. Spring Context.
+- Тестирование через JUnit.
+- Spring Test
+- Базы данных. PostgreSQL. Обзор NoSQL и Java persistence solution без ORM.
+- Настройка Database в IDEA.
+- Скрипты инициализации базы. Spring Jdbc Template.
+- Spring: инициализация и популирование DB
+- ORM. Hibernate. JPA.
+- Поддержка HSQLDB
+- Транзакции
+- Профили Maven и Spring
+- Пул коннектов
+- Spring Data JPA
+- Кэш Hibernate
+
+### Разработка WEB
+- Spring кэш
+- Spring Web
+- JSP, JSTL, i18n
+- Tomcat maven plugin. JNDI
+- Spring Web MVC
+- Spring Internationalization
+- Тестирование Spring MVC
+- REST контроллеры
+- Тестирование REST контроллеров. Jackson.
+- jackson-datatype-hibernate. Тестирование через матчеры.
+- Тестирование через SoapUi. UTF-8
+- WebJars.
+- Bootstrap. Datatables.
+- AJAX. jQuery. Notifications.
+- Spring Security
+- Spring Binding/Validation
+- Работа с Datatables через Ajax.
+- Spring Security Test
+- Encoding password
+- CSRF (добавление в проект защиты от межсайтовой подделки запроса)
+- form-login. Spring Security Taglib
+- Handler interceptor
+- Spring Exception Handling
+- Деплой в Heroku
diff --git a/hr.bat b/hr.bat
new file mode 100644
index 000000000000..a7d83b14d89b
--- /dev/null
+++ b/hr.bat
@@ -0,0 +1,2 @@
+call mvn -B -s settings.xml -DskipTests=true clean package
+call java -Dspring.profiles.active="datajpa,heroku" -DDATABASE_URL="postgres://user:password@localhost:5432/topjava" -jar target/dependency/webapp-runner.jar target/*.war
diff --git a/pom.xml b/pom.xml
index c8a1c78f3b29..89c5c858988b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -1,10 +1,10 @@
-4.0.0ru.javawebinartopjava
- jar
+ war1.0-SNAPSHOT
@@ -15,11 +15,42 @@
1.8UTF-8UTF-8
+
+ 1.9.4.RELEASE
+ 4.2.5.RELEASE
+ 4.0.4.RELEASE
+
+ 7.0.57
+
+
+ 1.1.6
+ 1.7.18
+
+
+ 9.4.1208
+
+ 4.12
+
+
+ 5.1.0.Final
+ 5.2.4.Final
+
+
+ 1.3
+ 2.7.3
+ 2.10.1
+
+
+ 3.3.6
+ 2.2.3
+ 2.4.7
+ 2.3.8
+ 1.10.11topjava
- install
+ packageorg.apache.maven.plugins
@@ -30,15 +61,315 @@
${java.version}
+
+ org.apache.maven.plugins
+ maven-surefire-plugin
+ 2.19.1
+
+ -Dfile.encoding=UTF-8
+
+
+
+
+ org.apache.tomcat.maven
+ tomcat7-maven-plugin
+ 2.2
+
+ src/main/resources/tomcat/context.xml
+
+ UTF-8
+ tomcat,datajpa
+
+ org.apache.coyote.http11.Http11NioProtocol
+
+
+
+ org.postgresql
+ postgresql
+ ${postgresql.version}
+
+
+
+
+
+
+ org.slf4j
+ slf4j-api
+ ${slf4j.version}
+ compile
+
+
+
+ org.slf4j
+ jcl-over-slf4j
+ ${slf4j.version}
+ runtime
+
+
+
+ org.slf4j
+ jul-to-slf4j
+ ${slf4j.version}
+ runtime
+
+
+
+ ch.qos.logback
+ logback-classic
+ ${logback.version}
+ runtime
+
+
+
+
+ org.springframework
+ spring-context-support
+ ${spring.version}
+
+
+ commons-logging
+ commons-logging
+
+
+
+
+
+
+ junit
+ junit
+ ${junit.version}
+ test
+
+
+ hamcrest-core
+ org.hamcrest
+
+
+
+
+
+
+ org.springframework.security
+ spring-security-web
+ ${spring-security.version}
+
+
+ org.springframework.security
+ spring-security-config
+ ${spring-security.version}
+
+
+ org.springframework.security
+ spring-security-taglibs
+ ${spring-security.version}
+
+
+
+
+ org.webjars
+ bootstrap
+ ${webjars-bootstrap.version}
+
+
+ org.webjars
+ jquery
+ ${webjars-jquery.version}
+
+
+ org.webjars.bower
+ datetimepicker
+ ${webjars-datetimepicker.version}
+
+
+ org.webjars.bower
+ noty
+ ${webjars-noty.version}
+
+
+ org.webjars
+ datatables
+ ${webjars-datatables.version}
+
+
+
+
+ com.fasterxml.jackson.core
+ jackson-databind
+ ${jackson-json.version}
+
+
+ com.fasterxml.jackson.datatype
+ jackson-datatype-hibernate5
+ ${jackson-json.version}
+
+
+ com.fasterxml.jackson.datatype
+ jackson-datatype-jsr310
+ ${jackson-json.version}
+
+
+
+ org.hamcrest
+ hamcrest-all
+ ${hamcrest.version}
+ test
+
+
+ javax.servlet
+ jstl
+ 1.2
+
+
+
+ org.apache.tomcat
+ tomcat-servlet-api
+ ${tomcat.version}
+ provided
+
+
+
+ org.springframework
+ spring-webmvc
+ ${spring.version}
+
+
+ commons-logging
+ commons-logging
+
+
+
+
+ org.springframework
+ spring-test
+ ${spring.version}
+ test
+
+
+
+ org.springframework.data
+ spring-data-jpa
+ ${spring-data-jpa.version}
+
+
+ org.hibernate
+ hibernate-entitymanager
+ ${hibernate.version}
+
+
+ org.hibernate
+ hibernate-java8
+ ${hibernate.version}
+
+
+ javax.transaction
+ jta
+ 1.1
+ runtime
+
+
+ org.hibernate
+ hibernate-validator
+ ${hibernate-validator.version}
+
+
+ org.hibernate
+ hibernate-ehcache
+ ${hibernate.version}
+
+
+
+ net.sf.ehcache
+ ehcache
+ ${ehcache.version}
+
+
+
+ javax.el
+ javax.el-api
+ 2.2.5
+ provided
+
+
+ org.springframework.security
+ spring-security-test
+ ${spring-security.version}
+
+
+ hsqldb
+
+
+ org.hsqldb
+ hsqldb
+ 2.3.2
+
+
+
+
+ postgres
+
+
+ org.postgresql
+ postgresql
+ ${postgresql.version}
+
+
+ org.apache.tomcat
+ tomcat-jdbc
+ ${tomcat.version}
+
+
+
+ true
+
+
+
+ heroku
+
+
+
+ org.apache.maven.plugins
+ maven-dependency-plugin
+ 2.10
+
+
+ package
+
+ copy
+
+
+
+
+ com.github.jsimone
+ webapp-runner
+ 7.0.57.2
+ webapp-runner.jar
+
+
+
+
+
+
+
+
+
+
+
+ org.springframework
+ spring-framework-bom
+ ${spring.version}
+ pom
+ import
+
+
diff --git a/settings.xml b/settings.xml
new file mode 100644
index 000000000000..cb1c8aa69b1b
--- /dev/null
+++ b/settings.xml
@@ -0,0 +1,11 @@
+
+
+
+
+
+ postgres
+ heroku
+
+
diff --git a/src/main/java/ru/javawebinar/topjava/LoggedUser.java b/src/main/java/ru/javawebinar/topjava/LoggedUser.java
new file mode 100644
index 000000000000..251dbb31dc01
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/LoggedUser.java
@@ -0,0 +1,62 @@
+package ru.javawebinar.topjava;
+
+import org.springframework.security.core.Authentication;
+import org.springframework.security.core.context.SecurityContextHolder;
+import ru.javawebinar.topjava.model.User;
+import ru.javawebinar.topjava.to.UserTo;
+import ru.javawebinar.topjava.util.UserUtil;
+
+import static java.util.Objects.requireNonNull;
+
+/**
+ * GKislin
+ * 06.03.2015.
+ *
+ * Mock implementation
+ */
+public class LoggedUser extends org.springframework.security.core.userdetails.User {
+ private static final long serialVersionUID = 1L;
+
+ private UserTo userTo;
+
+ public LoggedUser(User user) {
+ super(user.getEmail(), user.getPassword(), user.isEnabled(), true, true, true, user.getRoles());
+ this.userTo = UserUtil.asTo(user);
+ }
+
+ public static LoggedUser safeGet() {
+ Authentication auth = SecurityContextHolder.getContext().getAuthentication();
+ if (auth == null) {
+ return null;
+ }
+ Object user = auth.getPrincipal();
+ return (user instanceof LoggedUser) ? (LoggedUser) user : null;
+ }
+
+ public static LoggedUser get() {
+ LoggedUser user = safeGet();
+ requireNonNull(user, "No authorized user found");
+ return user;
+ }
+
+ public static int id() {
+ return get().userTo.getId();
+ }
+
+ public static int getCaloriesPerDay() {
+ return get().userTo.getCaloriesPerDay();
+ }
+
+ public void update(UserTo newTo) {
+ userTo = newTo;
+ }
+
+ public UserTo getUserTo() {
+ return userTo;
+ }
+
+ @Override
+ public String toString() {
+ return userTo.toString();
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/Profiles.java b/src/main/java/ru/javawebinar/topjava/Profiles.java
new file mode 100644
index 000000000000..4ce31d6f690a
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/Profiles.java
@@ -0,0 +1,17 @@
+package ru.javawebinar.topjava;
+
+/**
+ * User: gkislin
+ * Date: 19.08.2014
+ */
+public class Profiles {
+ public static final String
+ POSTGRES = "postgres",
+ HSQLDB = "hsqldb",
+ JDBC = "jdbc",
+ JPA = "jpa",
+ DATAJPA = "datajpa";
+
+ public static final String ACTIVE_DB = POSTGRES;
+ public static final String DB_IMPLEMENTATION = DATAJPA;
+}
diff --git a/src/main/java/ru/javawebinar/topjava/model/BaseEntity.java b/src/main/java/ru/javawebinar/topjava/model/BaseEntity.java
new file mode 100644
index 000000000000..35e2a8c21cf4
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/model/BaseEntity.java
@@ -0,0 +1,59 @@
+package ru.javawebinar.topjava.model;
+
+import javax.persistence.*;
+
+/**
+ * User: gkislin
+ * Date: 22.08.2014
+ */
+@MappedSuperclass
+@Access(AccessType.FIELD)
+//@JsonAutoDetect(fieldVisibility = ANY, getterVisibility = NONE, isGetterVisibility = NONE, setterVisibility = NONE)
+public class BaseEntity {
+ public static final int START_SEQ = 100000;
+
+ @Id
+ @SequenceGenerator(name = "global_seq", sequenceName = "global_seq", allocationSize = 1)
+ @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "global_seq")
+ protected Integer id;
+
+ public BaseEntity() {
+ }
+
+ protected BaseEntity(Integer id) {
+ this.id = id;
+ }
+
+ public void setId(Integer id) {
+ this.id = id;
+ }
+
+ public Integer getId() {
+ return id;
+ }
+
+ public boolean isNew() {
+ return (this.id == null);
+ }
+
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ BaseEntity that = (BaseEntity) o;
+ if (id == null || that.id == null) {
+ return false;
+ }
+ return id.equals(that.id);
+ }
+
+ @Override
+ public int hashCode() {
+ return (id == null) ? 0 : id;
+ }
+
+}
diff --git a/src/main/java/ru/javawebinar/topjava/model/NamedEntity.java b/src/main/java/ru/javawebinar/topjava/model/NamedEntity.java
new file mode 100644
index 000000000000..e593d37981e7
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/model/NamedEntity.java
@@ -0,0 +1,39 @@
+package ru.javawebinar.topjava.model;
+
+import org.hibernate.validator.constraints.NotEmpty;
+
+import javax.persistence.Column;
+import javax.persistence.MappedSuperclass;
+
+/**
+ * User: gkislin
+ * Date: 22.08.2014
+ */
+@MappedSuperclass
+public class NamedEntity extends BaseEntity {
+
+ @NotEmpty
+ @Column(name = "name", nullable = false)
+ protected String name;
+
+ public NamedEntity() {
+ }
+
+ protected NamedEntity(Integer id, String name) {
+ super(id);
+ this.name = name;
+ }
+
+ public void setName(String name) {
+ this.name = name;
+ }
+
+ public String getName() {
+ return this.name;
+ }
+
+ @Override
+ public String toString() {
+ return name;
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/model/Role.java b/src/main/java/ru/javawebinar/topjava/model/Role.java
new file mode 100644
index 000000000000..9c5210417f0b
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/model/Role.java
@@ -0,0 +1,17 @@
+package ru.javawebinar.topjava.model;
+
+import org.springframework.security.core.GrantedAuthority;
+
+/**
+ * User: gkislin
+ * Date: 22.08.2014
+ */
+public enum Role implements GrantedAuthority {
+ ROLE_USER,
+ ROLE_ADMIN;
+
+ @Override
+ public String getAuthority() {
+ return name();
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/model/User.java b/src/main/java/ru/javawebinar/topjava/model/User.java
new file mode 100644
index 000000000000..82a2bdb80bd5
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/model/User.java
@@ -0,0 +1,150 @@
+package ru.javawebinar.topjava.model;
+
+import org.hibernate.annotations.Cache;
+import org.hibernate.annotations.CacheConcurrencyStrategy;
+import org.hibernate.validator.constraints.Email;
+import org.hibernate.validator.constraints.Length;
+import org.hibernate.validator.constraints.NotEmpty;
+import ru.javawebinar.topjava.util.UserUtil;
+
+import javax.persistence.*;
+import javax.validation.constraints.Digits;
+import java.util.Date;
+import java.util.EnumSet;
+import java.util.List;
+import java.util.Set;
+
+/**
+ * User: gkislin
+ * Date: 22.08.2014
+ */
+@NamedQueries({
+ @NamedQuery(name = User.DELETE, query = "DELETE FROM User u WHERE u.id=:id"),
+ @NamedQuery(name = User.BY_EMAIL, query = "SELECT u FROM User u LEFT JOIN FETCH u.roles WHERE u.email=?1"),
+ @NamedQuery(name = User.ALL_SORTED, query = "SELECT DISTINCT(u) FROM User u LEFT JOIN FETCH u.roles ORDER BY u.name, u.email"),
+})
+@Cache(usage = CacheConcurrencyStrategy.NONSTRICT_READ_WRITE)
+@Entity
+@Table(name = "users", uniqueConstraints = {@UniqueConstraint(columnNames = "email", name = "users_unique_email_idx")})
+public class User extends NamedEntity {
+
+ public static final String DELETE = "User.delete";
+ public static final String ALL_SORTED = "User.getAllSorted";
+ public static final String BY_EMAIL = "User.getByEmail";
+
+ @Column(name = "email", nullable = false, unique = true)
+ @Email
+ @NotEmpty
+ protected String email;
+
+ @Column(name = "password", nullable = false)
+ @NotEmpty
+ @Length(min = 5)
+ protected String password;
+
+ @Column(name = "enabled", nullable = false)
+ protected boolean enabled = true;
+
+ @Column(name = "registered", columnDefinition = "timestamp default now()")
+ protected Date registered = new Date();
+
+ @Enumerated(EnumType.STRING)
+ @CollectionTable(name = "user_roles", joinColumns = @JoinColumn(name = "user_id"))
+ @Column(name = "role")
+ @ElementCollection(fetch = FetchType.EAGER)
+ @Cache(usage = CacheConcurrencyStrategy.NONSTRICT_READ_WRITE)
+ protected Set roles;
+
+ @Column(name = "calories_per_day", columnDefinition = "default 2000")
+ @Digits(fraction = 0, integer = 4)
+ protected int caloriesPerDay = UserUtil.DEFAULT_CALORIES_PER_DAY;
+
+ @OneToMany(cascade = CascadeType.REMOVE, fetch = FetchType.LAZY, mappedBy = "user")
+ @OrderBy("dateTime DESC")
+// @JsonIgnore
+ protected List meals;
+
+ public User() {
+ }
+
+ public User(User u) {
+ this(u.getId(), u.getName(), u.getEmail(), u.getPassword(), u.getCaloriesPerDay(), u.isEnabled(), u.getRoles());
+ }
+
+ public User(Integer id, String name, String email, String password, int caloriesPerDay, Role role, Role... roles) {
+ this(id, name, email, password, caloriesPerDay, true, EnumSet.of(role, roles));
+ }
+
+ public User(Integer id, String name, String email, String password, int caloriesPerDay, boolean enabled, Set roles) {
+ super(id, name);
+ this.email = email;
+ this.password = password;
+ this.caloriesPerDay = caloriesPerDay;
+ this.enabled = enabled;
+ this.roles = EnumSet.copyOf(roles);
+ }
+
+ public String getEmail() {
+ return email;
+ }
+
+ public void setEmail(String email) {
+ this.email = email;
+ }
+
+ public Date getRegistered() {
+ return registered;
+ }
+
+ public void setRegistered(Date registered) {
+ this.registered = registered;
+ }
+
+ public int getCaloriesPerDay() {
+ return caloriesPerDay;
+ }
+
+ public void setCaloriesPerDay(int caloriesPerDay) {
+ this.caloriesPerDay = caloriesPerDay;
+ }
+
+ public boolean isEnabled() {
+ return enabled;
+ }
+
+ public void setEnabled(boolean enabled) {
+ this.enabled = enabled;
+ }
+
+ public Set getRoles() {
+ return roles;
+ }
+
+ public void setRoles(List roles) {
+ this.roles = EnumSet.copyOf(roles);
+ }
+
+ public String getPassword() {
+ return password;
+ }
+
+ public void setPassword(String password) {
+ this.password = password;
+ }
+
+ public List getMeals() {
+ return meals;
+ }
+
+ @Override
+ public String toString() {
+ return "User (" +
+ "id=" + id +
+ ", email=" + email +
+ ", name=" + name +
+ ", enabled=" + enabled +
+ ", roles=" + roles +
+ ", caloriesPerDay=" + caloriesPerDay +
+ ')';
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/model/UserMeal.java b/src/main/java/ru/javawebinar/topjava/model/UserMeal.java
new file mode 100644
index 000000000000..50dfb34f4259
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/model/UserMeal.java
@@ -0,0 +1,104 @@
+package ru.javawebinar.topjava.model;
+
+import org.hibernate.validator.constraints.NotEmpty;
+import org.hibernate.validator.constraints.Range;
+
+import javax.persistence.*;
+import javax.validation.constraints.NotNull;
+import java.time.LocalDateTime;
+
+/**
+ * GKislin
+ * 11.01.2015.
+ */
+@SuppressWarnings("JpaQlInspection")
+@NamedQueries({
+ @NamedQuery(name = UserMeal.GET, query = "SELECT m FROM UserMeal m WHERE m.id=:id AND m.user.id=:userId"),
+ @NamedQuery(name = UserMeal.ALL_SORTED, query = "SELECT m FROM UserMeal m WHERE m.user.id=:userId ORDER BY m.dateTime DESC"),
+ @NamedQuery(name = UserMeal.DELETE, query = "DELETE FROM UserMeal m WHERE m.id=:id AND m.user.id=:userId"),
+ @NamedQuery(name = UserMeal.GET_BETWEEN, query = "SELECT m FROM UserMeal m "+
+ "WHERE m.user.id=:userId AND m.dateTime BETWEEN :startDate AND :endDate ORDER BY m.dateTime DESC"),
+
+// @NamedQuery(name = UserMeal.UPDATE, query = "UPDATE UserMeal m SET m.dateTime = :datetime, m.calories= :calories," +
+// "m.description=:desc where m.id=:id and m.user.id=:userId")
+})
+@Entity
+@Table(name = "meals", uniqueConstraints = {@UniqueConstraint(columnNames = {"user_id", "date_time"}, name = "meals_unique_user_datetime_idx")})
+public class UserMeal extends BaseEntity {
+ public static final String GET = "UserMeal.get";
+ public static final String ALL_SORTED = "UserMeal.getAll";
+ public static final String DELETE = "UserMeal.delete";
+ public static final String GET_BETWEEN = "UserMeal.getBetween";
+
+ @Column(name = "date_time", nullable = false)
+ @NotNull
+ private LocalDateTime dateTime;
+
+ @Column(name = "description", nullable = false)
+ @NotEmpty
+ private String description;
+
+ @Column(name = "calories", nullable = false)
+ @Range(min = 10, max = 5000)
+ protected int calories;
+
+ @ManyToOne(fetch = FetchType.LAZY)
+ @JoinColumn(name = "user_id", nullable = false)
+ private User user;
+
+ public UserMeal() {
+ }
+
+ public UserMeal(LocalDateTime dateTime, String description, int calories) {
+ this(null, dateTime, description, calories);
+ }
+
+ public UserMeal(Integer id, LocalDateTime dateTime, String description, int calories) {
+ super(id);
+ this.dateTime = dateTime;
+ this.description = description;
+ this.calories = calories;
+ }
+
+ public LocalDateTime getDateTime() {
+ return dateTime;
+ }
+
+ public String getDescription() {
+ return description;
+ }
+
+ public int getCalories() {
+ return calories;
+ }
+
+ public void setDateTime(LocalDateTime dateTime) {
+ this.dateTime = dateTime;
+ }
+
+ public void setDescription(String description) {
+ this.description = description;
+ }
+
+ public void setCalories(int calories) {
+ this.calories = calories;
+ }
+
+ public User getUser() {
+ return user;
+ }
+
+ public void setUser(User user) {
+ this.user = user;
+ }
+
+ @Override
+ public String toString() {
+ return "UserMeal{" +
+ "id=" + id +
+ ", dateTime=" + dateTime +
+ ", description='" + description + '\'' +
+ ", calories=" + calories +
+ '}';
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/ru/javawebinar/topjava/repository/JpaUtil.java b/src/main/java/ru/javawebinar/topjava/repository/JpaUtil.java
new file mode 100644
index 000000000000..75b3d82ba3cb
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/repository/JpaUtil.java
@@ -0,0 +1,25 @@
+package ru.javawebinar.topjava.repository;
+
+import org.hibernate.Session;
+import org.hibernate.SessionFactory;
+
+import javax.persistence.EntityManager;
+import javax.persistence.PersistenceContext;
+
+public class JpaUtil {
+
+ @PersistenceContext
+ private EntityManager em;
+
+ public void clear2ndLevelHibernateCache() {
+ Session s = (Session) em.getDelegate();
+ SessionFactory sf = s.getSessionFactory();
+// sf.evict(User.class);
+// sf.getCache().evictEntity(User.class, BaseEntity.START_SEQ);
+// sf.getCache().evictEntityRegion(User.class);
+ sf.getCache().evictQueryRegions();
+ sf.getCache().evictDefaultQueryRegion();
+ sf.getCache().evictCollectionRegions();
+ sf.getCache().evictEntityRegions();
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/repository/UserMealRepository.java b/src/main/java/ru/javawebinar/topjava/repository/UserMealRepository.java
new file mode 100644
index 000000000000..5b283b14feac
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/repository/UserMealRepository.java
@@ -0,0 +1,31 @@
+package ru.javawebinar.topjava.repository;
+
+import ru.javawebinar.topjava.model.UserMeal;
+
+import java.time.LocalDateTime;
+import java.util.Collection;
+
+/**
+ * GKislin
+ * 06.03.2015.
+ */
+public interface UserMealRepository {
+ // null if updated meal do not belong to userId
+ UserMeal save(UserMeal userMeal, int userId);
+
+ // false if meal do not belong to userId
+ boolean delete(int id, int userId);
+
+ // null if meal do not belong to userId
+ UserMeal get(int id, int userId);
+
+ // ORDERED dateTime
+ Collection getAll(int userId);
+
+ // ORDERED dateTime
+ Collection getBetween(LocalDateTime startDate, LocalDateTime endDate, int userId);
+
+ default UserMeal getWithUser(Integer id, Integer userId) {
+ throw new UnsupportedOperationException();
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/repository/UserRepository.java b/src/main/java/ru/javawebinar/topjava/repository/UserRepository.java
new file mode 100644
index 000000000000..47ded4cec6b8
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/repository/UserRepository.java
@@ -0,0 +1,28 @@
+package ru.javawebinar.topjava.repository;
+
+import ru.javawebinar.topjava.model.User;
+
+import java.util.List;
+
+/**
+ * User: gkislin
+ * Date: 22.08.2014
+ */
+public interface UserRepository {
+ User save(User user);
+
+ // false if not found
+ boolean delete(int id);
+
+ // null if not found
+ User get(int id);
+
+ // null if not found
+ User getByEmail(String email);
+
+ List getAll();
+
+ default User getWithMeals(int id){
+ throw new UnsupportedOperationException();
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/repository/datajpa/DataJpaUserMealRepositoryImpl.java b/src/main/java/ru/javawebinar/topjava/repository/datajpa/DataJpaUserMealRepositoryImpl.java
new file mode 100644
index 000000000000..5a633070298d
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/repository/datajpa/DataJpaUserMealRepositoryImpl.java
@@ -0,0 +1,58 @@
+package ru.javawebinar.topjava.repository.datajpa;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Repository;
+import org.springframework.transaction.annotation.Transactional;
+import ru.javawebinar.topjava.model.UserMeal;
+import ru.javawebinar.topjava.repository.UserMealRepository;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * GKislin
+ * 27.03.2015.
+ */
+@Repository
+public class DataJpaUserMealRepositoryImpl implements UserMealRepository {
+ @Autowired
+ private ProxyUserMealRepository proxy;
+
+ @Autowired
+ private ProxyUserRepository userProxy;
+
+ @Override
+ @Transactional
+ public UserMeal save(UserMeal userMeal, int userId) {
+ if (!userMeal.isNew() && get(userMeal.getId(), userId) == null) {
+ return null;
+ }
+ userMeal.setUser(userProxy.getOne(userId));
+ return proxy.save(userMeal);
+ }
+
+ @Override
+ public boolean delete(int id, int userId) {
+ return proxy.delete(id, userId) != 0;
+ }
+
+ @Override
+ public UserMeal get(int id, int userId) {
+ return proxy.get(id, userId);
+ }
+
+ @Override
+ public List getAll(int userId) {
+ return proxy.getAll(userId);
+ }
+
+ @Override
+ public List getBetween(LocalDateTime startDate, LocalDateTime endDate, int userId) {
+ return proxy.getBetween(startDate, endDate, userId);
+ }
+
+ @Override
+ public UserMeal getWithUser(Integer id, Integer userId) {
+ return proxy.getWithUser(id, userId);
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/repository/datajpa/DataJpaUserRepositoryImpl.java b/src/main/java/ru/javawebinar/topjava/repository/datajpa/DataJpaUserRepositoryImpl.java
new file mode 100644
index 000000000000..a56542361801
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/repository/datajpa/DataJpaUserRepositoryImpl.java
@@ -0,0 +1,62 @@
+package ru.javawebinar.topjava.repository.datajpa;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.Sort;
+import org.springframework.stereotype.Repository;
+import ru.javawebinar.topjava.model.BaseEntity;
+import ru.javawebinar.topjava.model.User;
+import ru.javawebinar.topjava.repository.UserRepository;
+
+import javax.validation.ValidationException;
+import java.util.List;
+
+/**
+ * GKislin
+ * 27.03.2015.
+ */
+
+@Repository
+public class DataJpaUserRepositoryImpl implements UserRepository {
+ private static final Sort SORT_NAME_EMAIL = new Sort("name", "email");
+
+ @Autowired
+ private ProxyUserRepository proxy;
+
+ public void checkModificationAllowed(Integer id) {
+ if (id != null && id < BaseEntity.START_SEQ + 2) {
+ throw new ValidationException("Admin/User modification is not allowed.
Register » your own please.");
+ }
+ }
+
+ @Override
+ public User save(User user) {
+ checkModificationAllowed(user.getId());
+ return proxy.save(user);
+ }
+
+ @Override
+ public boolean delete(int id) {
+ checkModificationAllowed(id);
+ return proxy.delete(id) != 0;
+ }
+
+ @Override
+ public User get(int id) {
+ return proxy.findOne(id);
+ }
+
+ @Override
+ public User getByEmail(String email) {
+ return proxy.getByEmail(email);
+ }
+
+ @Override
+ public List getAll() {
+ return proxy.findAll(SORT_NAME_EMAIL);
+ }
+
+ @Override
+ public User getWithMeals(int id) {
+ return proxy.getWithMeals(id);
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/repository/datajpa/ProxyUserMealRepository.java b/src/main/java/ru/javawebinar/topjava/repository/datajpa/ProxyUserMealRepository.java
new file mode 100644
index 000000000000..3c857a4c4880
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/repository/datajpa/ProxyUserMealRepository.java
@@ -0,0 +1,36 @@
+package ru.javawebinar.topjava.repository.datajpa;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+import org.springframework.transaction.annotation.Transactional;
+import ru.javawebinar.topjava.model.UserMeal;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+@Transactional(readOnly = true)
+public interface ProxyUserMealRepository extends JpaRepository {
+
+ @Modifying
+ @Transactional
+ @Query("DELETE FROM UserMeal m WHERE m.id=:id AND m.user.id=:userId")
+ int delete(@Param("id") int id, @Param("userId") int userId);
+
+ @Override
+ UserMeal save(UserMeal item);
+
+ @Query("SELECT m FROM UserMeal m WHERE m.id=:id AND m.user.id=:userId")
+ UserMeal get(@Param("id") int id, @Param("userId") int userId);
+
+ @Query("SELECT m FROM UserMeal m WHERE m.user.id=:userId ORDER BY m.dateTime DESC")
+ List getAll(@Param("userId") int userId);
+
+ @SuppressWarnings("JpaQlInspection")
+ @Query("SELECT m from UserMeal m WHERE m.user.id=:userId AND m.dateTime BETWEEN :startDate AND :endDate ORDER BY m.dateTime DESC")
+ List getBetween(@Param("startDate") LocalDateTime startDate, @Param("endDate") LocalDateTime endDate, @Param("userId") int userId);
+
+ @Query("SELECT um FROM UserMeal um JOIN FETCH um.user WHERE um.id = ?1 and um.user.id = ?2")
+ UserMeal getWithUser(Integer id, Integer userId);
+}
diff --git a/src/main/java/ru/javawebinar/topjava/repository/datajpa/ProxyUserRepository.java b/src/main/java/ru/javawebinar/topjava/repository/datajpa/ProxyUserRepository.java
new file mode 100644
index 000000000000..b3c497b46c31
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/repository/datajpa/ProxyUserRepository.java
@@ -0,0 +1,40 @@
+package ru.javawebinar.topjava.repository.datajpa;
+
+import org.springframework.data.domain.Sort;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+import org.springframework.transaction.annotation.Transactional;
+import ru.javawebinar.topjava.model.User;
+
+import java.util.List;
+
+/**
+ * GKislin
+ * 27.03.2015.
+ */
+@Transactional(readOnly = true)
+public interface ProxyUserRepository extends JpaRepository {
+
+ @Transactional
+ @Modifying
+// @Query(name = User.DELETE)
+ @Query("DELETE FROM User u WHERE u.id=:id")
+ int delete(@Param("id") int id);
+
+ @Override
+ @Transactional
+ User save(User user);
+
+ @Override
+ User findOne(Integer id);
+
+ @Override
+ List findAll(Sort sort);
+
+ User getByEmail(String email);
+
+ @Query("SELECT u FROM User u LEFT JOIN FETCH u.meals WHERE u.id = ?1")
+ User getWithMeals(Integer id);
+}
diff --git a/src/main/java/ru/javawebinar/topjava/repository/jdbc/AbstractJdbcUserMealRepositoryImpl.java b/src/main/java/ru/javawebinar/topjava/repository/jdbc/AbstractJdbcUserMealRepositoryImpl.java
new file mode 100644
index 000000000000..66d4524c50a7
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/repository/jdbc/AbstractJdbcUserMealRepositoryImpl.java
@@ -0,0 +1,91 @@
+package ru.javawebinar.topjava.repository.jdbc;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.dao.support.DataAccessUtils;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.RowMapper;
+import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
+import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
+import org.springframework.jdbc.core.simple.SimpleJdbcInsert;
+import org.springframework.transaction.annotation.Transactional;
+import ru.javawebinar.topjava.model.UserMeal;
+import ru.javawebinar.topjava.repository.UserMealRepository;
+
+import javax.sql.DataSource;
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * User: gkislin
+ * Date: 26.08.2014
+ */
+@Transactional(readOnly = true)
+public abstract class AbstractJdbcUserMealRepositoryImpl implements UserMealRepository {
+
+ private final SimpleJdbcInsert insertUserMeal;
+
+ private final RowMapper rowMapper;
+
+ @Autowired
+ private JdbcTemplate jdbcTemplate;
+
+ @Autowired
+ private NamedParameterJdbcTemplate namedParameterJdbcTemplate;
+
+ public AbstractJdbcUserMealRepositoryImpl(RowMapper rowMapper, DataSource dataSource) {
+ this.rowMapper = rowMapper;
+ this.insertUserMeal = new SimpleJdbcInsert(dataSource)
+ .withTableName("meals")
+ .usingGeneratedKeyColumns("id");
+ }
+
+ protected abstract T toDbValue(LocalDateTime ldt);
+
+ @Override
+ @Transactional
+ public UserMeal save(UserMeal userMeal, int userId) {
+ MapSqlParameterSource map = new MapSqlParameterSource()
+ .addValue("id", userMeal.getId())
+ .addValue("description", userMeal.getDescription())
+ .addValue("calories", userMeal.getCalories())
+ .addValue("date_time", toDbValue(userMeal.getDateTime()))
+ .addValue("user_id", userId);
+
+ if (userMeal.isNew()) {
+ Number newId = insertUserMeal.executeAndReturnKey(map);
+ userMeal.setId(newId.intValue());
+ } else {
+ if (namedParameterJdbcTemplate.update(
+ "UPDATE meals SET description=:description, calories=:calories, date_time=:date_time " +
+ " WHERE id=:id AND user_id=:user_id", map) == 0) {
+ return null;
+ }
+ }
+ return userMeal;
+ }
+
+ @Override
+ @Transactional
+ public boolean delete(int id, int userId) {
+ return jdbcTemplate.update("DELETE FROM meals WHERE id=? AND user_id=?", id, userId) != 0;
+ }
+
+ @Override
+ public UserMeal get(int id, int userId) {
+ List userMeals = jdbcTemplate.query(
+ "SELECT * FROM meals WHERE id = ? AND user_id = ?", rowMapper, id, userId);
+ return DataAccessUtils.singleResult(userMeals);
+ }
+
+ public List getAll(int userId) {
+ return jdbcTemplate.query(
+ "SELECT * FROM meals WHERE user_id=? ORDER BY date_time DESC", rowMapper, userId);
+ }
+
+ @Override
+ public List getBetween(LocalDateTime startDate, LocalDateTime endDate, int userId) {
+ return jdbcTemplate.query(
+ "SELECT * FROM meals WHERE user_id=? AND date_time BETWEEN ? AND ? ORDER BY date_time DESC",
+ rowMapper, userId, toDbValue(startDate), toDbValue(endDate));
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/ru/javawebinar/topjava/repository/jdbc/Java8JdbcUserMealRepositoryImpl.java b/src/main/java/ru/javawebinar/topjava/repository/jdbc/Java8JdbcUserMealRepositoryImpl.java
new file mode 100644
index 000000000000..7bbb7ae02d08
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/repository/jdbc/Java8JdbcUserMealRepositoryImpl.java
@@ -0,0 +1,31 @@
+package ru.javawebinar.topjava.repository.jdbc;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Profile;
+import org.springframework.jdbc.core.BeanPropertyRowMapper;
+import org.springframework.stereotype.Repository;
+import ru.javawebinar.topjava.Profiles;
+import ru.javawebinar.topjava.model.UserMeal;
+
+import javax.sql.DataSource;
+import java.time.LocalDateTime;
+
+/**
+ * User: gkislin
+ * Date: 26.08.2014
+ */
+
+@Repository
+@Profile(Profiles.POSTGRES)
+public class Java8JdbcUserMealRepositoryImpl extends AbstractJdbcUserMealRepositoryImpl {
+
+ @Autowired
+ public Java8JdbcUserMealRepositoryImpl(DataSource dataSource) {
+ super(BeanPropertyRowMapper.newInstance(UserMeal.class), dataSource);
+ }
+
+ @Override
+ protected LocalDateTime toDbValue(LocalDateTime ldt) {
+ return ldt;
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/ru/javawebinar/topjava/repository/jdbc/JdbcUserRepositoryImpl.java b/src/main/java/ru/javawebinar/topjava/repository/jdbc/JdbcUserRepositoryImpl.java
new file mode 100644
index 000000000000..54b3e8d45489
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/repository/jdbc/JdbcUserRepositoryImpl.java
@@ -0,0 +1,160 @@
+package ru.javawebinar.topjava.repository.jdbc;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.dao.support.DataAccessUtils;
+import org.springframework.jdbc.core.BatchPreparedStatementSetter;
+import org.springframework.jdbc.core.BeanPropertyRowMapper;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.RowMapper;
+import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
+import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
+import org.springframework.jdbc.core.simple.SimpleJdbcInsert;
+import org.springframework.stereotype.Repository;
+import org.springframework.transaction.annotation.Transactional;
+import ru.javawebinar.topjava.model.Role;
+import ru.javawebinar.topjava.model.User;
+import ru.javawebinar.topjava.repository.UserRepository;
+
+import javax.sql.DataSource;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+/**
+ * User: gkislin
+ * Date: 26.08.2014
+ */
+
+@Repository
+@Transactional(readOnly = true)
+public class JdbcUserRepositoryImpl implements UserRepository {
+
+ private static final BeanPropertyRowMapper ROW_MAPPER = BeanPropertyRowMapper.newInstance(User.class);
+ private static final RowMapper ROLE_ROW_MAPPER = (rs, rowNum) -> Role.valueOf(rs.getString("role"));
+
+ @Autowired
+ private JdbcTemplate jdbcTemplate;
+
+ @Autowired
+ private NamedParameterJdbcTemplate namedParameterJdbcTemplate;
+
+ private SimpleJdbcInsert insertUser;
+
+ @Autowired
+ public JdbcUserRepositoryImpl(DataSource dataSource) {
+ this.insertUser = new SimpleJdbcInsert(dataSource)
+ .withTableName("USERS")
+ .usingGeneratedKeyColumns("id");
+ }
+
+ @Override
+ @Transactional
+ public User save(User user) {
+ MapSqlParameterSource map = new MapSqlParameterSource()
+ .addValue("id", user.getId())
+ .addValue("name", user.getName())
+ .addValue("email", user.getEmail())
+ .addValue("password", user.getPassword())
+ .addValue("registered", user.getRegistered())
+ .addValue("enabled", user.isEnabled())
+ .addValue("caloriesPerDay", user.getCaloriesPerDay());
+
+ if (user.isNew()) {
+ Number newKey = insertUser.executeAndReturnKey(map);
+ user.setId(newKey.intValue());
+ insertRoles(user);
+ } else {
+ deleteRoles(user);
+ insertRoles(user);
+ namedParameterJdbcTemplate.update(
+ "UPDATE users SET name=:name, email=:email, password=:password, " +
+ "registered=:registered, enabled=:enabled, calories_per_day=:caloriesPerDay WHERE id=:id", map);
+ }
+ return user;
+ }
+
+ @Override
+ @Transactional
+ public boolean delete(int id) {
+ return jdbcTemplate.update("DELETE FROM users WHERE id=?", id) != 0;
+ }
+
+ @Override
+ public User get(int id) {
+ List users = jdbcTemplate.query("SELECT * FROM users WHERE id=?", ROW_MAPPER, id);
+ return setRoles(DataAccessUtils.singleResult(users));
+ }
+
+ @Override
+ public User getByEmail(String email) {
+ return setRoles(jdbcTemplate.queryForObject("SELECT * FROM users WHERE email=?", ROW_MAPPER, email));
+ }
+
+ @Override
+ public List getAll() {
+ List users = jdbcTemplate.query("SELECT * FROM users ORDER BY name, email", ROW_MAPPER);
+
+ class UserRole {
+ final private Role role;
+ final private int userId;
+
+ private UserRole(Role role, int userId) {
+ this.role = role;
+ this.userId = userId;
+ }
+
+ public Role getRole() {
+ return role;
+ }
+
+ public int getUserId() {
+ return userId;
+ }
+ }
+
+ Map> userRolesMap = jdbcTemplate.query("SELECT role, user_id FROM user_roles",
+ (rs, rowNum) -> new UserRole(Role.valueOf(rs.getString("role")), rs.getInt("user_id"))).stream()
+ .collect(
+ Collectors.groupingBy(UserRole::getUserId, Collectors.mapping(UserRole::getRole, Collectors.toList()))
+ );
+
+ users.forEach(u -> u.setRoles(userRolesMap.get(u.getId())));
+ return users;
+ }
+
+ private void insertRoles(User u) {
+ Set roles = u.getRoles();
+ Iterator iterator = roles.iterator();
+
+ jdbcTemplate.batchUpdate("INSERT INTO user_roles (user_id, role) VALUES (?, ?)",
+ new BatchPreparedStatementSetter() {
+ @Override
+ public void setValues(PreparedStatement ps, int i) throws SQLException {
+ ps.setInt(1, u.getId());
+ ps.setString(2, iterator.next().name());
+ }
+
+ @Override
+ public int getBatchSize() {
+ return roles.size();
+ }
+ });
+ }
+
+ private void deleteRoles(User u) {
+ jdbcTemplate.update("DELETE FROM user_roles WHERE user_id=?", u.getId());
+ }
+
+ private User setRoles(User u) {
+ if (u != null) {
+ List roles = jdbcTemplate.query("SELECT role FROM user_roles WHERE user_id=?",
+ ROLE_ROW_MAPPER, u.getId());
+ u.setRoles(roles);
+ }
+ return u;
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/repository/jdbc/TimestampJdbcUserMealRepositoryImpl.java b/src/main/java/ru/javawebinar/topjava/repository/jdbc/TimestampJdbcUserMealRepositoryImpl.java
new file mode 100644
index 000000000000..559bd51d5169
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/repository/jdbc/TimestampJdbcUserMealRepositoryImpl.java
@@ -0,0 +1,34 @@
+package ru.javawebinar.topjava.repository.jdbc;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Profile;
+import org.springframework.stereotype.Repository;
+import ru.javawebinar.topjava.Profiles;
+import ru.javawebinar.topjava.model.UserMeal;
+
+import javax.sql.DataSource;
+import java.sql.Timestamp;
+import java.time.LocalDateTime;
+
+/**
+ * User: gkislin
+ * Date: 26.08.2014
+ */
+
+@Repository
+@Profile(Profiles.HSQLDB)
+public class TimestampJdbcUserMealRepositoryImpl extends AbstractJdbcUserMealRepositoryImpl {
+
+ @Autowired
+ public TimestampJdbcUserMealRepositoryImpl(DataSource dataSource) {
+ super((rs, rowNum) ->
+ new UserMeal(rs.getInt("id"), rs.getTimestamp("date_time").toLocalDateTime(),
+ rs.getString("description"), rs.getInt("calories")), dataSource
+ );
+ }
+
+ @Override
+ protected Timestamp toDbValue(LocalDateTime ldt) {
+ return Timestamp.valueOf(ldt);
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/ru/javawebinar/topjava/repository/jpa/JpaUserMealRepositoryImpl.java b/src/main/java/ru/javawebinar/topjava/repository/jpa/JpaUserMealRepositoryImpl.java
new file mode 100644
index 000000000000..3e4ead5e0cda
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/repository/jpa/JpaUserMealRepositoryImpl.java
@@ -0,0 +1,74 @@
+package ru.javawebinar.topjava.repository.jpa;
+
+import org.springframework.dao.support.DataAccessUtils;
+import org.springframework.stereotype.Repository;
+import org.springframework.transaction.annotation.Transactional;
+import ru.javawebinar.topjava.model.User;
+import ru.javawebinar.topjava.model.UserMeal;
+import ru.javawebinar.topjava.repository.UserMealRepository;
+
+import javax.persistence.EntityManager;
+import javax.persistence.PersistenceContext;
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * User: gkisline
+ * Date: 26.08.2014
+ */
+
+@Repository
+@Transactional(readOnly = true)
+public class JpaUserMealRepositoryImpl implements UserMealRepository {
+
+ @PersistenceContext
+ private EntityManager em;
+
+ @Override
+ @Transactional
+ public UserMeal save(UserMeal userMeal, int userId) {
+ if (!userMeal.isNew() && get(userMeal.getId(), userId) == null) {
+ return null;
+ }
+ userMeal.setUser(em.getReference(User.class, userId));
+ if (userMeal.isNew()) {
+ em.persist(userMeal);
+ return userMeal;
+ } else {
+ return em.merge(userMeal);
+ }
+ }
+
+ @Override
+ @Transactional
+ public boolean delete(int id, int userId) {
+ return em.createNamedQuery(UserMeal.DELETE)
+ .setParameter("id", id)
+ .setParameter("userId", userId)
+ .executeUpdate() != 0;
+ }
+
+ @Override
+ public UserMeal get(int id, int userId) {
+ List userMeals = em.createNamedQuery(UserMeal.GET, UserMeal.class)
+ .setParameter("id", id)
+ .setParameter("userId", userId)
+ .getResultList();
+ return DataAccessUtils.singleResult(userMeals);
+ }
+
+ @Override
+ public List getAll(int userId) {
+ return em.createNamedQuery(UserMeal.ALL_SORTED, UserMeal.class)
+ .setParameter("userId", userId)
+ .getResultList();
+ }
+
+ @Override
+ public List getBetween(LocalDateTime startDate, LocalDateTime endDate, int userId) {
+ return em.createNamedQuery(UserMeal.GET_BETWEEN, UserMeal.class)
+ .setParameter("userId", userId)
+ .setParameter("startDate", startDate)
+ .setParameter("endDate", endDate).getResultList();
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/ru/javawebinar/topjava/repository/jpa/JpaUserRepositoryImpl.java b/src/main/java/ru/javawebinar/topjava/repository/jpa/JpaUserRepositoryImpl.java
new file mode 100644
index 000000000000..2b4057f3a4b4
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/repository/jpa/JpaUserRepositoryImpl.java
@@ -0,0 +1,70 @@
+package ru.javawebinar.topjava.repository.jpa;
+
+import org.springframework.stereotype.Repository;
+import org.springframework.transaction.annotation.Transactional;
+import ru.javawebinar.topjava.model.User;
+import ru.javawebinar.topjava.repository.UserRepository;
+
+import javax.persistence.EntityManager;
+import javax.persistence.PersistenceContext;
+import java.util.List;
+
+/**
+ * User: gkislin
+ * Date: 29.08.2014
+ */
+@Repository
+@Transactional(readOnly = true)
+public class JpaUserRepositoryImpl implements UserRepository {
+
+/*
+ @Autowired
+ private SessionFactory sessionFactory;
+
+ private Session openSession() {
+ return sessionFactory.getCurrentSession();
+ }
+*/
+
+ @PersistenceContext
+ private EntityManager em;
+
+ @Override
+ @Transactional
+ public User save(User user) {
+ if (user.isNew()) {
+ em.persist(user);
+ return user;
+ } else {
+ return em.merge(user);
+ }
+ }
+
+ @Override
+ public User get(int id) {
+ return em.find(User.class, id);
+ }
+
+ @Override
+ @Transactional
+ public boolean delete(int id) {
+
+/* User ref = em.getReference(User.class, id);
+ em.remove(ref);
+
+ Query query = em.createQuery("DELETE FROM User u WHERE u.id=:id");
+ return query.setParameter("id", id).executeUpdate() != 0;
+*/
+ return em.createNamedQuery(User.DELETE).setParameter("id", id).executeUpdate() != 0;
+ }
+
+ @Override
+ public User getByEmail(String email) {
+ return em.createNamedQuery(User.BY_EMAIL, User.class).setParameter(1, email).getSingleResult();
+ }
+
+ @Override
+ public List getAll() {
+ return em.createNamedQuery(User.ALL_SORTED, User.class).getResultList();
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/service/UserMealService.java b/src/main/java/ru/javawebinar/topjava/service/UserMealService.java
new file mode 100644
index 000000000000..9cfd2f128aeb
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/service/UserMealService.java
@@ -0,0 +1,33 @@
+package ru.javawebinar.topjava.service;
+
+import ru.javawebinar.topjava.model.UserMeal;
+import ru.javawebinar.topjava.util.exception.NotFoundException;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.util.Collection;
+
+/**
+ * GKislin
+ * 15.06.2015.
+ */
+public interface UserMealService {
+ UserMeal get(int id, int userId) throws NotFoundException;
+
+ void delete(int id, int userId) throws NotFoundException;
+
+ default Collection getBetweenDates(LocalDate startDate, LocalDate endDate, int userId) {
+ return getBetweenDateTimes(LocalDateTime.of(startDate, LocalTime.MIN), LocalDateTime.of(endDate, LocalTime.MAX), userId);
+ }
+
+ Collection getBetweenDateTimes(LocalDateTime startDateTime, LocalDateTime endDateTime, int userId);
+
+ Collection getAll(int userId);
+
+ UserMeal update(UserMeal meal, int userId) throws NotFoundException;
+
+ UserMeal save(UserMeal meal, int userId);
+
+ UserMeal getWithUser(Integer id, Integer userId);
+}
diff --git a/src/main/java/ru/javawebinar/topjava/service/UserMealServiceImpl.java b/src/main/java/ru/javawebinar/topjava/service/UserMealServiceImpl.java
new file mode 100644
index 000000000000..bb433aa35d5a
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/service/UserMealServiceImpl.java
@@ -0,0 +1,62 @@
+package ru.javawebinar.topjava.service;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import ru.javawebinar.topjava.model.UserMeal;
+import ru.javawebinar.topjava.repository.UserMealRepository;
+import ru.javawebinar.topjava.util.exception.ExceptionUtil;
+
+import java.time.LocalDateTime;
+import java.util.Collection;
+
+/**
+ * GKislin
+ * 06.03.2015.
+ */
+@Service
+public class UserMealServiceImpl implements UserMealService {
+
+ @Autowired
+ private UserMealRepository repository;
+
+ @Override
+ public UserMeal get(int id, int userId) {
+ return ExceptionUtil.check(repository.get(id, userId), id);
+ }
+
+ @Override
+ public void delete(int id, int userId) {
+ ExceptionUtil.check(repository.delete(id, userId), id);
+ }
+
+ @Override
+ public Collection getBetweenDateTimes(LocalDateTime startDateTime, LocalDateTime endDateTime, int userId) {
+ return repository.getBetween(startDateTime, endDateTime, userId);
+ }
+
+ @Override
+ public Collection getAll(int userId) {
+ return repository.getAll(userId);
+ }
+
+ @Override
+ public UserMeal update(UserMeal meal, int userId) {
+ return ExceptionUtil.check(repository.save(meal, userId), meal.getId());
+ }
+
+ @Override
+ public UserMeal save(UserMeal meal, int userId) {
+ return repository.save(meal, userId);
+ }
+
+// @Autowired
+// private UserRepository userRepository;
+
+ // @Transactional
+ public UserMeal getWithUser(Integer id, Integer userId) {
+// UserMeal meal = get(id, userId);
+// meal.setUser(userRepository.get(userId));
+// return meal;
+ return ExceptionUtil.check(repository.getWithUser(id, userId), id);
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/service/UserService.java b/src/main/java/ru/javawebinar/topjava/service/UserService.java
new file mode 100644
index 000000000000..ac1b88529775
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/service/UserService.java
@@ -0,0 +1,35 @@
+package ru.javawebinar.topjava.service;
+
+
+import ru.javawebinar.topjava.model.User;
+import ru.javawebinar.topjava.to.UserTo;
+import ru.javawebinar.topjava.util.exception.NotFoundException;
+
+import java.util.List;
+
+/**
+ * User: gkislin
+ * Date: 22.08.2014
+ */
+public interface UserService {
+
+ User save(User user);
+
+ void delete(int id) throws NotFoundException;
+
+ User get(int id) throws NotFoundException;
+
+ User getByEmail(String email) throws NotFoundException;
+
+ void update(UserTo user);
+
+ List getAll();
+
+ void update(User user);
+
+ void evictCache();
+
+ void enable(int id, boolean enable);
+
+ User getWithMeals(int id);
+}
diff --git a/src/main/java/ru/javawebinar/topjava/service/UserServiceImpl.java b/src/main/java/ru/javawebinar/topjava/service/UserServiceImpl.java
new file mode 100644
index 000000000000..e1f8a3722ddd
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/service/UserServiceImpl.java
@@ -0,0 +1,102 @@
+package ru.javawebinar.topjava.service;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cache.annotation.CacheEvict;
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.security.core.userdetails.UserDetailsService;
+import org.springframework.security.core.userdetails.UsernameNotFoundException;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import ru.javawebinar.topjava.LoggedUser;
+import ru.javawebinar.topjava.model.User;
+import ru.javawebinar.topjava.repository.UserRepository;
+import ru.javawebinar.topjava.to.UserTo;
+import ru.javawebinar.topjava.util.UserUtil;
+import ru.javawebinar.topjava.util.exception.ExceptionUtil;
+import ru.javawebinar.topjava.util.exception.NotFoundException;
+
+import java.util.List;
+import java.util.Objects;
+
+/**
+ * GKislin
+ * 06.03.2015.
+ */
+@Service("userService")
+public class UserServiceImpl implements UserService, UserDetailsService {
+
+ @Autowired
+ private UserRepository repository;
+
+ @CacheEvict(value = "users", allEntries = true)
+ @Override
+ public User save(User user) {
+ return repository.save(user);
+ }
+
+ @CacheEvict(value = "users", allEntries = true)
+ @Override
+ public void delete(int id) {
+ ExceptionUtil.check(repository.delete(id), id);
+ }
+
+ @Override
+ public User get(int id) throws NotFoundException {
+ return ExceptionUtil.check(repository.get(id), id);
+ }
+
+ @Override
+ public User getByEmail(String email) throws NotFoundException {
+ Objects.requireNonNull(email, "Email must not be empty");
+ return ExceptionUtil.check(repository.getByEmail(email), "email=" + email);
+ }
+
+ @Cacheable("users")
+ @Override
+ public List getAll() {
+ return repository.getAll();
+ }
+
+ @CacheEvict(value = "users", allEntries = true)
+ @Override
+ public void update(User user) {
+ repository.save(user);
+ }
+
+ @CacheEvict(value = "users", allEntries = true)
+ @Transactional
+ @Override
+ public void update(UserTo userTo) {
+ User user = get(userTo.getId());
+ repository.save(UserUtil.updateFromTo(user, userTo));
+ }
+
+
+ @CacheEvict(value = "users", allEntries = true)
+ @Override
+ public void evictCache() {
+ }
+
+ @CacheEvict(value = "users", allEntries = true)
+ @Override
+ @Transactional
+ public void enable(int id, boolean enabled) {
+ User user = get(id);
+ user.setEnabled(enabled);
+ repository.save(user);
+ }
+
+ @Override
+ public LoggedUser loadUserByUsername(String email) throws UsernameNotFoundException {
+ User u = repository.getByEmail(email.toLowerCase());
+ if (u == null) {
+ throw new UsernameNotFoundException("User " + email + " is not found");
+ }
+ return new LoggedUser(u);
+ }
+
+ @Override
+ public User getWithMeals(int id) {
+ return ExceptionUtil.check(repository.getWithMeals(id), id);
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/to/UserMealTo.java b/src/main/java/ru/javawebinar/topjava/to/UserMealTo.java
new file mode 100644
index 000000000000..a4470f8cb8ea
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/to/UserMealTo.java
@@ -0,0 +1,79 @@
+package ru.javawebinar.topjava.to;
+
+import org.hibernate.validator.constraints.NotEmpty;
+import org.hibernate.validator.constraints.Range;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import javax.validation.constraints.NotNull;
+import java.time.LocalDateTime;
+
+/**
+ * GKislin
+ * 11.01.2015.
+ */
+public class UserMealTo {
+ private int id;
+
+ @NotNull
+ @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm")
+ private LocalDateTime dateTime;
+
+ @NotEmpty
+ private String description;
+
+ @Range(min = 10, max = 5000)
+ @NotNull
+ protected Integer calories;
+
+ public UserMealTo() {
+ }
+
+ public UserMealTo(int id, LocalDateTime dateTime, String description, int calories) {
+ this.id = id;
+ this.dateTime = dateTime;
+ this.description = description;
+ this.calories = calories;
+ }
+
+ public int getId() {
+ return id;
+ }
+
+ public void setId(int id) {
+ this.id = id;
+ }
+
+ public LocalDateTime getDateTime() {
+ return dateTime;
+ }
+
+ public void setDateTime(LocalDateTime dateTime) {
+ this.dateTime = dateTime;
+ }
+
+ public String getDescription() {
+ return description;
+ }
+
+ public void setDescription(String description) {
+ this.description = description;
+ }
+
+ public Integer getCalories() {
+ return calories;
+ }
+
+ public void setCalories(Integer calories) {
+ this.calories = calories;
+ }
+
+ @Override
+ public String toString() {
+ return "UserMeal{" +
+ "id=" + id +
+ ", dateTime=" + dateTime +
+ ", description='" + description + '\'' +
+ ", calories=" + calories +
+ '}';
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/ru/javawebinar/topjava/to/UserMealWithExceed.java b/src/main/java/ru/javawebinar/topjava/to/UserMealWithExceed.java
new file mode 100644
index 000000000000..9baf52947227
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/to/UserMealWithExceed.java
@@ -0,0 +1,64 @@
+package ru.javawebinar.topjava.to;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import java.time.LocalDateTime;
+
+/**
+ * GKislin
+ * 11.01.2015.
+ */
+public class UserMealWithExceed {
+ protected final Integer id;
+
+ private final LocalDateTime dateTime;
+
+ private final String description;
+
+ private final int calories;
+
+ private final boolean exceed;
+
+ public UserMealWithExceed(@JsonProperty("id") Integer id,
+ @JsonProperty("dateTime") LocalDateTime dateTime,
+ @JsonProperty("description") String description,
+ @JsonProperty("calories") int calories,
+ @JsonProperty("exceed") boolean exceed) {
+ this.id = id;
+ this.dateTime = dateTime;
+ this.description = description;
+ this.calories = calories;
+ this.exceed = exceed;
+ }
+
+ public Integer getId() {
+ return id;
+ }
+
+ public LocalDateTime getDateTime() {
+ return dateTime;
+ }
+
+ public String getDescription() {
+ return description;
+ }
+
+ public int getCalories() {
+ return calories;
+ }
+
+ public boolean isExceed() {
+ return exceed;
+ }
+
+ @Override
+ public String toString() {
+ return "UserMealWithExceed{" +
+ "id=" + id +
+ ", dateTime=" + dateTime +
+ ", description='" + description + '\'' +
+ ", calories=" + calories +
+ ", exceed=" + exceed +
+ '}';
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/to/UserTo.java b/src/main/java/ru/javawebinar/topjava/to/UserTo.java
new file mode 100644
index 000000000000..c9b085f43716
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/to/UserTo.java
@@ -0,0 +1,95 @@
+package ru.javawebinar.topjava.to;
+
+import org.hibernate.validator.constraints.Email;
+import org.hibernate.validator.constraints.NotEmpty;
+import org.hibernate.validator.constraints.Range;
+import ru.javawebinar.topjava.util.UserUtil;
+
+import javax.validation.constraints.NotNull;
+import javax.validation.constraints.Size;
+import java.io.Serializable;
+
+public class UserTo implements Serializable {
+ private static final long serialVersionUID = 1L;
+
+ protected int id;
+
+ @NotEmpty
+ protected String name;
+
+ @Email
+ @NotEmpty
+ protected String email;
+
+ @Size(min = 5, max = 64, message = " must between 5 and 64 characters")
+ protected String password;
+
+ @Range(min = 100, max = 5000)
+ @NotNull(message = " must not be empty")
+ protected Integer caloriesPerDay = UserUtil.DEFAULT_CALORIES_PER_DAY;
+
+ public UserTo() {
+ }
+
+ public UserTo(int id, String name, String email, String password, int caloriesPerDay) {
+ this.id = id;
+ this.name = name;
+ this.email = email;
+ this.password = password;
+ this.caloriesPerDay = caloriesPerDay;
+ }
+
+ public void setId(int id) {
+ this.id = id;
+ }
+
+ public Integer getId() {
+ return id;
+ }
+
+ public void setId(Integer id) {
+ this.id = (id == null ? 0 : id);
+ }
+
+ public String getPassword() {
+ return password;
+ }
+
+ public void setPassword(String password) {
+ this.password = password;
+ }
+
+ public String getName() {
+ return name;
+ }
+
+ public void setName(String name) {
+ this.name = name;
+ }
+
+ public String getEmail() {
+ return email;
+ }
+
+ public void setEmail(String email) {
+ this.email = email;
+ }
+
+ public Integer getCaloriesPerDay() {
+ return caloriesPerDay;
+ }
+
+ public void setCaloriesPerDay(Integer caloriesPerDay) {
+ this.caloriesPerDay = caloriesPerDay;
+ }
+
+ @Override
+ public String toString() {
+ return "UserTo{" +
+ "id=" + id +
+ ", name='" + name + '\'' +
+ ", email='" + email + '\'' +
+ ", caloriesPerDay='" + caloriesPerDay + '\'' +
+ '}';
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/util/PasswordUtil.java b/src/main/java/ru/javawebinar/topjava/util/PasswordUtil.java
new file mode 100644
index 000000000000..07faed1e87d7
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/util/PasswordUtil.java
@@ -0,0 +1,39 @@
+package ru.javawebinar.topjava.util;
+
+import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
+import org.springframework.security.crypto.password.PasswordEncoder;
+import org.springframework.util.StringUtils;
+
+import java.util.regex.Pattern;
+
+/**
+ * GKislin
+ * 05.01.2015.
+ */
+
+public class PasswordUtil {
+ private static final Pattern BCRYPT_PATTERN = Pattern.compile("\\A\\$2a?\\$\\d\\d\\$[./0-9A-Za-z]{53}");
+ public static final PasswordEncoder PASSWORD_ENCODER = new BCryptPasswordEncoder();
+
+ public static PasswordEncoder getPasswordEncoder() {
+ return PASSWORD_ENCODER;
+ }
+
+ public static String encode(String newPassword) {
+ if (StringUtils.isEmpty(newPassword)) {
+ return null;
+ }
+ if (isEncoded(newPassword)) {
+ return newPassword;
+ }
+ return PASSWORD_ENCODER.encode(newPassword);
+ }
+
+ public static boolean isMatch(String rawPassword, String password) {
+ return PASSWORD_ENCODER.matches(rawPassword, password);
+ }
+
+ public static boolean isEncoded(String newPassword) {
+ return BCRYPT_PATTERN.matcher(newPassword).matches();
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/util/TimeUtil.java b/src/main/java/ru/javawebinar/topjava/util/TimeUtil.java
new file mode 100644
index 000000000000..a0ce821ef0d4
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/util/TimeUtil.java
@@ -0,0 +1,45 @@
+package ru.javawebinar.topjava.util;
+
+import org.springframework.util.StringUtils;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.time.format.DateTimeFormatter;
+
+/**
+ * GKislin
+ * 07.01.2015.
+ */
+public class TimeUtil {
+ public static final DateTimeFormatter DATE_TIME_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm");
+ public static final LocalDate MIN_DATE = LocalDate.of(1, 1, 1);
+ public static final LocalDate MAX_DATE = LocalDate.of(3000, 1, 1);
+
+ private TimeUtil() {
+ }
+
+ public static > boolean isBetween(T value, T start, T end) {
+ return value.compareTo(start) >= 0 && value.compareTo(end) <= 0;
+ }
+
+ public static String toString(LocalDateTime ldt) {
+ return ldt == null ? "" : ldt.format(DATE_TIME_FORMATTER);
+ }
+
+ public static LocalDate parseLocalDate(String str) {
+ return StringUtils.isEmpty(str) ? null : LocalDate.parse(str);
+ }
+
+ public static LocalTime parseLocalTime(String str) {
+ return StringUtils.isEmpty(str) ? null : LocalTime.parse(str);
+ }
+
+ public static LocalDateTime parseLocalDateTime(String str) {
+ return parseLocalDateTime(str, DATE_TIME_FORMATTER);
+ }
+
+ public static LocalDateTime parseLocalDateTime(String str, DateTimeFormatter formatter) {
+ return StringUtils.isEmpty(str) ? LocalDateTime.now() : LocalDateTime.parse(str, formatter);
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/ru/javawebinar/topjava/util/UserMealsUtil.java b/src/main/java/ru/javawebinar/topjava/util/UserMealsUtil.java
new file mode 100644
index 000000000000..ad340c4c70ee
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/util/UserMealsUtil.java
@@ -0,0 +1,74 @@
+package ru.javawebinar.topjava.util;
+
+import ru.javawebinar.topjava.model.UserMeal;
+import ru.javawebinar.topjava.to.UserMealTo;
+import ru.javawebinar.topjava.to.UserMealWithExceed;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.time.Month;
+import java.util.*;
+import java.util.stream.Collectors;
+
+/**
+ * GKislin
+ * 31.05.2015.
+ */
+public class UserMealsUtil {
+ public static final List MEAL_LIST = Arrays.asList(
+ new UserMeal(LocalDateTime.of(2015, Month.MAY, 30, 10, 0), "Завтрак", 500),
+ new UserMeal(LocalDateTime.of(2015, Month.MAY, 30, 13, 0), "Обед", 1000),
+ new UserMeal(LocalDateTime.of(2015, Month.MAY, 30, 20, 0), "Ужин", 500),
+ new UserMeal(LocalDateTime.of(2015, Month.MAY, 31, 10, 0), "Завтрак", 1000),
+ new UserMeal(LocalDateTime.of(2015, Month.MAY, 31, 13, 0), "Обед", 500),
+ new UserMeal(LocalDateTime.of(2015, Month.MAY, 31, 20, 0), "Ужин", 510)
+ );
+
+ public static void main(String[] args) {
+ List filteredMealsWithExceeded = getFilteredWithExceeded(MEAL_LIST, LocalTime.of(7, 0), LocalTime.of(12, 0), UserUtil.DEFAULT_CALORIES_PER_DAY);
+ filteredMealsWithExceeded.forEach(System.out::println);
+
+ System.out.println(getFilteredWithExceededByCycle(MEAL_LIST, LocalTime.of(7, 0), LocalTime.of(12, 0), UserUtil.DEFAULT_CALORIES_PER_DAY));
+ }
+
+ public static List getWithExceeded(Collection mealList, int caloriesPerDay) {
+ return getFilteredWithExceeded(mealList, LocalTime.MIN, LocalTime.MAX, caloriesPerDay);
+ }
+
+ public static List getFilteredWithExceeded(Collection mealList, LocalTime startTime, LocalTime endTime, int caloriesPerDay) {
+ Map caloriesSumByDate = mealList.stream()
+ .collect(
+ Collectors.groupingBy(um -> um.getDateTime().toLocalDate(),
+ Collectors.summingInt(UserMeal::getCalories))
+ );
+
+ return mealList.stream()
+ .filter(um -> TimeUtil.isBetween(um.getDateTime().toLocalTime(), startTime, endTime))
+ .map(um -> createWithExceed(um, caloriesSumByDate.get(um.getDateTime().toLocalDate()) > caloriesPerDay))
+ .collect(Collectors.toList());
+ }
+
+ public static List getFilteredWithExceededByCycle(List mealList, LocalTime startTime, LocalTime endTime, int caloriesPerDay) {
+
+ final Map caloriesSumPerDate = new HashMap<>();
+ mealList.forEach(meal -> caloriesSumPerDate.merge(meal.getDateTime().toLocalDate(), meal.getCalories(), Integer::sum));
+
+ final List mealExceeded = new ArrayList<>();
+ mealList.forEach(meal -> {
+ final LocalDateTime dateTime = meal.getDateTime();
+ if (TimeUtil.isBetween(dateTime.toLocalTime(), startTime, endTime)) {
+ mealExceeded.add(createWithExceed(meal, caloriesSumPerDate.get(dateTime.toLocalDate()) > caloriesPerDay));
+ }
+ });
+ return mealExceeded;
+ }
+
+ public static UserMealWithExceed createWithExceed(UserMeal um, boolean exceeded) {
+ return new UserMealWithExceed(um.getId(), um.getDateTime(), um.getDescription(), um.getCalories(), exceeded);
+ }
+
+ public static UserMeal createFromTo(UserMealTo userMealTo) {
+ return new UserMeal(userMealTo.getId(), userMealTo.getDateTime(), userMealTo.getDescription(), userMealTo.getCalories());
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/util/UserUtil.java b/src/main/java/ru/javawebinar/topjava/util/UserUtil.java
new file mode 100644
index 000000000000..871d9b946091
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/util/UserUtil.java
@@ -0,0 +1,34 @@
+package ru.javawebinar.topjava.util;
+
+import ru.javawebinar.topjava.model.Role;
+import ru.javawebinar.topjava.model.User;
+import ru.javawebinar.topjava.to.UserTo;
+
+/**
+ * GKislin
+ */
+public class UserUtil {
+ public static final int DEFAULT_CALORIES_PER_DAY = 2000;
+
+ public static User createFromTo(UserTo newUser) {
+ return new User(null, newUser.getName(), newUser.getEmail().toLowerCase(), newUser.getPassword(), newUser.getCaloriesPerDay(), Role.ROLE_USER);
+ }
+
+ public static UserTo asTo(User user) {
+ return new UserTo(user.getId(), user.getName(), user.getEmail(), user.getPassword(), user.getCaloriesPerDay());
+ }
+
+ public static User updateFromTo(User user, UserTo userTo) {
+ user.setName(userTo.getName());
+ user.setEmail(userTo.getEmail());
+ user.setCaloriesPerDay(userTo.getCaloriesPerDay());
+ user.setPassword(userTo.getPassword());
+ return prepareToSave(user);
+ }
+
+ public static User prepareToSave(User user) {
+ user.setPassword(PasswordUtil.encode(user.getPassword()));
+ user.setEmail(user.getEmail().toLowerCase());
+ return user;
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/util/converter/LocalDateFormatter.java b/src/main/java/ru/javawebinar/topjava/util/converter/LocalDateFormatter.java
new file mode 100644
index 000000000000..9d125a809f82
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/util/converter/LocalDateFormatter.java
@@ -0,0 +1,26 @@
+package ru.javawebinar.topjava.util.converter;
+
+import org.springframework.format.Formatter;
+import ru.javawebinar.topjava.util.TimeUtil;
+
+import java.text.ParseException;
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+import java.util.Locale;
+
+/**
+ * GKislin
+ * 15.04.2015.
+ */
+public class LocalDateFormatter implements Formatter {
+
+ @Override
+ public LocalDate parse(String text, Locale locale) throws ParseException {
+ return TimeUtil.parseLocalDate(text);
+ }
+
+ @Override
+ public String print(LocalDate lt, Locale locale) {
+ return lt.format(DateTimeFormatter.ISO_LOCAL_DATE);
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/util/converter/LocalTimeFormatter.java b/src/main/java/ru/javawebinar/topjava/util/converter/LocalTimeFormatter.java
new file mode 100644
index 000000000000..c25a71db553e
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/util/converter/LocalTimeFormatter.java
@@ -0,0 +1,26 @@
+package ru.javawebinar.topjava.util.converter;
+
+import org.springframework.format.Formatter;
+import ru.javawebinar.topjava.util.TimeUtil;
+
+import java.text.ParseException;
+import java.time.LocalTime;
+import java.time.format.DateTimeFormatter;
+import java.util.Locale;
+
+/**
+ * GKislin
+ * 15.04.2015.
+ */
+public class LocalTimeFormatter implements Formatter {
+
+ @Override
+ public LocalTime parse(String text, Locale locale) throws ParseException {
+ return TimeUtil.parseLocalTime(text);
+ }
+
+ @Override
+ public String print(LocalTime lt, Locale locale) {
+ return lt.format(DateTimeFormatter.ISO_LOCAL_TIME);
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/util/exception/ErrorInfo.java b/src/main/java/ru/javawebinar/topjava/util/exception/ErrorInfo.java
new file mode 100644
index 000000000000..c422c409e630
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/util/exception/ErrorInfo.java
@@ -0,0 +1,17 @@
+package ru.javawebinar.topjava.util.exception;
+
+/**
+ * User: gkislin
+ * Date: 19.08.2014
+ */
+public class ErrorInfo {
+ public final String url;
+ public final String cause;
+ public final String detail;
+
+ public ErrorInfo(CharSequence url, Throwable ex) {
+ this.url = url.toString();
+ this.cause = ex.getClass().getSimpleName();
+ this.detail = ex.getLocalizedMessage();
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/util/exception/ExceptionUtil.java b/src/main/java/ru/javawebinar/topjava/util/exception/ExceptionUtil.java
new file mode 100644
index 000000000000..9fd18938830f
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/util/exception/ExceptionUtil.java
@@ -0,0 +1,30 @@
+package ru.javawebinar.topjava.util.exception;
+
+
+/**
+ * User: gkislin
+ * Date: 14.05.2014
+ */
+public class ExceptionUtil {
+ private ExceptionUtil() {
+ }
+
+ public static void check(boolean found, int id) {
+ check(found, "id=" + id);
+ }
+
+ public static T check(T object, int id) {
+ return check(object, "id=" + id);
+ }
+
+ public static T check(T object, String msg) {
+ check(object != null, msg);
+ return object;
+ }
+
+ public static void check(boolean found, String msg) {
+ if (!found) {
+ throw new NotFoundException("Not found entity with " + msg);
+ }
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/util/exception/NotFoundException.java b/src/main/java/ru/javawebinar/topjava/util/exception/NotFoundException.java
new file mode 100644
index 000000000000..1c85842a3497
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/util/exception/NotFoundException.java
@@ -0,0 +1,15 @@
+package ru.javawebinar.topjava.util.exception;
+
+import org.springframework.http.HttpStatus;
+import org.springframework.web.bind.annotation.ResponseStatus;
+
+/**
+ * User: gkislin
+ * Date: 19.08.2014
+ */
+@ResponseStatus(value = HttpStatus.NOT_FOUND, reason = "No data found") // 404
+public class NotFoundException extends RuntimeException {
+ public NotFoundException(String message) {
+ super(message);
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/web/ExceptionInfoHandler.java b/src/main/java/ru/javawebinar/topjava/web/ExceptionInfoHandler.java
new file mode 100644
index 000000000000..0d1f050c0945
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/web/ExceptionInfoHandler.java
@@ -0,0 +1,65 @@
+package ru.javawebinar.topjava.web;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.core.Ordered;
+import org.springframework.core.annotation.Order;
+import org.springframework.dao.DataIntegrityViolationException;
+import org.springframework.http.HttpStatus;
+import org.springframework.validation.BindException;
+import org.springframework.validation.BindingResult;
+import org.springframework.web.bind.annotation.*;
+import ru.javawebinar.topjava.util.exception.ErrorInfo;
+import ru.javawebinar.topjava.util.exception.NotFoundException;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.validation.ValidationException;
+
+/**
+ * User: gkislin
+ * Date: 23.09.2014
+ */
+@ControllerAdvice(annotations = RestController.class)
+public class ExceptionInfoHandler {
+ Logger LOG = LoggerFactory.getLogger(ExceptionInfoHandler.class);
+
+ @ResponseStatus(HttpStatus.NOT_FOUND)
+ @ExceptionHandler(NotFoundException.class)
+ @ResponseBody
+ @Order(Ordered.HIGHEST_PRECEDENCE)
+ public ErrorInfo handleError(HttpServletRequest req, NotFoundException e) {
+ return logAndGetErrorInfo(req, e, false);
+ }
+
+ @ResponseStatus(value = HttpStatus.CONFLICT) // 409
+ @ExceptionHandler(DataIntegrityViolationException.class)
+ @ResponseBody
+ @Order(Ordered.HIGHEST_PRECEDENCE + 1)
+ public ErrorInfo conflict(HttpServletRequest req, DataIntegrityViolationException e) {
+ return logAndGetErrorInfo(req, e, true);
+ }
+
+ @ResponseStatus(value = HttpStatus.UNPROCESSABLE_ENTITY) // 422
+ @ExceptionHandler(BindException.class)
+ @ResponseBody
+ @Order(Ordered.HIGHEST_PRECEDENCE + 2)
+ public ErrorInfo bindValidationError(HttpServletRequest req, BindingResult result) {
+ LOG.error("BindException at request " + req.getRequestURL());
+ StringBuilder sb = new StringBuilder();
+ result.getFieldErrors().forEach(fe -> sb.append(fe.getField()).append(" ").append(fe.getDefaultMessage()).append(" "));
+ return logAndGetErrorInfo(req, new ValidationException(sb.toString()), false);
+ }
+
+ @ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)
+ @ExceptionHandler(Exception.class)
+ @ResponseBody
+ @Order(Ordered.LOWEST_PRECEDENCE)
+ public ErrorInfo handleError(HttpServletRequest req, Exception e) {
+ return logAndGetErrorInfo(req, e, true);
+ }
+
+ public ErrorInfo logAndGetErrorInfo(HttpServletRequest req, Exception e, boolean logException) {
+ LOG.error("Exception at request " + req.getRequestURL(), logException ? e : null);
+ return new ErrorInfo(req.getRequestURL(), e);
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/web/GlobalControllerExceptionHandler.java b/src/main/java/ru/javawebinar/topjava/web/GlobalControllerExceptionHandler.java
new file mode 100644
index 000000000000..74dcb049bc97
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/web/GlobalControllerExceptionHandler.java
@@ -0,0 +1,36 @@
+package ru.javawebinar.topjava.web;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.core.Ordered;
+import org.springframework.core.annotation.Order;
+import org.springframework.web.bind.annotation.ControllerAdvice;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.servlet.ModelAndView;
+import ru.javawebinar.topjava.LoggedUser;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * User: gkislin
+ * Date: 23.09.2014
+ */
+@ControllerAdvice
+public class GlobalControllerExceptionHandler {
+ private static final Logger LOG = LoggerFactory.getLogger(GlobalControllerExceptionHandler.class);
+
+ @ExceptionHandler(Exception.class)
+ @Order(Ordered.LOWEST_PRECEDENCE)
+ ModelAndView defaultErrorHandler(HttpServletRequest req, Exception e) throws Exception {
+ LOG.error("Exception at request " + req.getRequestURL(), e);
+ ModelAndView mav = new ModelAndView("exception/exception");
+ mav.addObject("exception", e);
+
+ // Interceptor is not invoked, put userTo
+ LoggedUser loggedUser = LoggedUser.safeGet();
+ if (loggedUser != null) {
+ mav.addObject("userTo", loggedUser.getUserTo());
+ }
+ return mav;
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/web/RootController.java b/src/main/java/ru/javawebinar/topjava/web/RootController.java
new file mode 100644
index 000000000000..604c75c9bfbe
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/web/RootController.java
@@ -0,0 +1,95 @@
+package ru.javawebinar.topjava.web;
+
+import org.springframework.dao.DataIntegrityViolationException;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.stereotype.Controller;
+import org.springframework.ui.ModelMap;
+import org.springframework.validation.BindingResult;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.support.SessionStatus;
+import ru.javawebinar.topjava.LoggedUser;
+import ru.javawebinar.topjava.to.UserTo;
+import ru.javawebinar.topjava.util.UserUtil;
+import ru.javawebinar.topjava.web.user.AbstractUserController;
+
+import javax.validation.Valid;
+
+/**
+ * User: gkislin
+ * Date: 22.08.2014
+ */
+@Controller
+public class RootController extends AbstractUserController {
+
+ @RequestMapping(value = "/", method = RequestMethod.GET)
+ public String root() {
+ return "redirect:meals";
+ }
+
+// @Secured("ROLE_ADMIN")
+ @PreAuthorize("hasRole('ROLE_ADMIN')")
+ @RequestMapping(value = "/users", method = RequestMethod.GET)
+ public String userList() {
+ return "userList";
+ }
+
+ @RequestMapping(value = "/meals", method = RequestMethod.GET)
+ public String mealList() {
+ return "mealList";
+ }
+
+ @RequestMapping(value = "/login", method = RequestMethod.GET)
+ public String login(ModelMap model,
+ @RequestParam(value = "error", required = false) boolean error,
+ @RequestParam(value = "message", required = false) String message) {
+
+ model.put("error", error);
+ model.put("message", message);
+ return "login";
+ }
+
+ @RequestMapping(value = "/profile", method = RequestMethod.GET)
+ public String profile() {
+ return "profile";
+ }
+
+ @RequestMapping(value = "/profile", method = RequestMethod.POST)
+ public String updateProfile(@Valid UserTo userTo, BindingResult result, SessionStatus status) {
+ if (!result.hasErrors()) {
+ try {
+ userTo.setId(LoggedUser.id());
+ super.update(userTo);
+ LoggedUser.get().update(userTo);
+ status.setComplete();
+ return "redirect:meals";
+ } catch (DataIntegrityViolationException ex) {
+ result.rejectValue("email", "exception.duplicate_email");
+ }
+ }
+ return "profile";
+ }
+
+ @RequestMapping(value = "/register", method = RequestMethod.GET)
+ public String register(ModelMap model) {
+ model.addAttribute("userTo", new UserTo());
+ model.addAttribute("register", true);
+ return "profile";
+ }
+
+ @RequestMapping(value = "/register", method = RequestMethod.POST)
+ public String saveRegister(@Valid UserTo userTo, BindingResult result, SessionStatus status, ModelMap model) {
+ if (!result.hasErrors()) {
+ try {
+ super.create(UserUtil.createFromTo(userTo));
+ status.setComplete();
+ return "redirect:login?message=app.registered";
+ } catch (DataIntegrityViolationException ex) {
+ result.rejectValue("email", "exception.duplicate_email");
+ }
+ }
+ model.addAttribute("register", true);
+ return "profile";
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/web/interceptor/ModelInterceptor.java b/src/main/java/ru/javawebinar/topjava/web/interceptor/ModelInterceptor.java
new file mode 100644
index 000000000000..47e3410c370e
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/web/interceptor/ModelInterceptor.java
@@ -0,0 +1,24 @@
+package ru.javawebinar.topjava.web.interceptor;
+
+import org.springframework.web.servlet.ModelAndView;
+import org.springframework.web.servlet.handler.HandlerInterceptorAdapter;
+import ru.javawebinar.topjava.LoggedUser;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+/**
+ * This interceptor adds the user to the model of every requests managed
+ */
+public class ModelInterceptor extends HandlerInterceptorAdapter {
+
+ @Override
+ public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) throws Exception {
+ if (modelAndView != null && !modelAndView.isEmpty()) {
+ LoggedUser loggedUser = LoggedUser.safeGet();
+ if (loggedUser != null) {
+ modelAndView.getModelMap().addAttribute("userTo", loggedUser.getUserTo());
+ }
+ }
+ }
+}
diff --git a/src/main/java/ru/javawebinar/topjava/web/json/JacksonObjectMapper.java b/src/main/java/ru/javawebinar/topjava/web/json/JacksonObjectMapper.java
new file mode 100644
index 000000000000..cdd7fcdd4d3b
--- /dev/null
+++ b/src/main/java/ru/javawebinar/topjava/web/json/JacksonObjectMapper.java
@@ -0,0 +1,39 @@
+package ru.javawebinar.topjava.web.json;
+
+import com.fasterxml.jackson.annotation.JsonAutoDetect;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.PropertyAccessor;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.SerializationFeature;
+import com.fasterxml.jackson.datatype.hibernate5.Hibernate5Module;
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
+
+/**
+ * User: gkislin
+ * Date: 26.05.2014
+ *
+ Java Enterprise проект с
+ регистрацией/авторизацией и интерфейсом на основе ролей (USER, ADMIN).
+ Администратор может создавать/редактировать/удалять/пользователей, а пользователь - управлять своим
+ профилем и данными (день, еда, калории) через UI (по AJAX) и по REST интерфейсу с базовой авторизацией.
+ Возможна фильтрация данных по датам и времени, при этом цвет записи таблицы еды зависит от того, превышает ли
+ сумма
+ калорий за день норму (редактируемый параметр в профиле пользователя).
+ Весь REST интерфейс покрывается JUnit тестами, используя Spring MVC Test и Spring Security Test.
+
+
+
+
+
\ No newline at end of file
diff --git a/src/main/webapp/WEB-INF/jsp/mealList.jsp b/src/main/webapp/WEB-INF/jsp/mealList.jsp
new file mode 100644
index 000000000000..2869bd9acec4
--- /dev/null
+++ b/src/main/webapp/WEB-INF/jsp/mealList.jsp
@@ -0,0 +1,121 @@
+<%@ page contentType="text/html;charset=UTF-8" language="java" %>
+<%@ taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core" %>
+<%@ taglib prefix="spring" uri="http://www.springframework.org/tags" %>
+<%@taglib prefix="form" uri="http://www.springframework.org/tags/form" %>
+
+
+
+
+
+
+
+
+
+