diff options
23 files changed, 357 insertions, 0 deletions
diff --git a/server-core/src/main/java/com/juick/configuration/DataConfiguration.java b/server-core/src/main/java/com/juick/configuration/DataConfiguration.java index f31dbcdb..88fc00b3 100644 --- a/server-core/src/main/java/com/juick/configuration/DataConfiguration.java +++ b/server-core/src/main/java/com/juick/configuration/DataConfiguration.java @@ -2,6 +2,7 @@ package com.juick.configuration; import org.apache.commons.dbcp2.BasicDataSource; import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.PropertySource; import org.springframework.core.env.Environment; @@ -20,6 +21,7 @@ import javax.sql.DataSource; @Configuration @EnableTransactionManagement @PropertySource(value = {"classpath:juick.conf"}) +@ComponentScan(basePackages = {"com.juick.service"}) public class DataConfiguration implements TransactionManagementConfigurer { @Resource private Environment env; diff --git a/server-core/src/main/java/com/juick/server/helpers/ApplicationStatus.java b/server-core/src/main/java/com/juick/server/helpers/ApplicationStatus.java index 986c8275..61109c47 100644 --- a/server-core/src/main/java/com/juick/server/helpers/ApplicationStatus.java +++ b/server-core/src/main/java/com/juick/server/helpers/ApplicationStatus.java @@ -1,5 +1,7 @@ package com.juick.server.helpers; +import org.apache.commons.lang3.builder.ToStringBuilder; + /** * Created by vt on 03/09/16. */ @@ -7,6 +9,14 @@ public class ApplicationStatus { private boolean connected; private boolean crosspostEnabled; + @Override + public String toString() { + return new ToStringBuilder(this) + .append("connected", connected) + .append("crosspostEnabled", crosspostEnabled) + .toString(); + } + public boolean isConnected() { return connected; } diff --git a/server-core/src/main/java/com/juick/service/AdsService.java b/server-core/src/main/java/com/juick/service/AdsService.java new file mode 100644 index 00000000..f8a0f5cf --- /dev/null +++ b/server-core/src/main/java/com/juick/service/AdsService.java @@ -0,0 +1,11 @@ +package com.juick.service; + +/** + * Created by aalexeev on 11/13/16. + */ +public interface AdsService { + + int getAdMid(int uid); + + int logAdMid(int uid, int mid); +} diff --git a/server-core/src/main/java/com/juick/service/AdsServiceImpl.java b/server-core/src/main/java/com/juick/service/AdsServiceImpl.java new file mode 100644 index 00000000..32effd21 --- /dev/null +++ b/server-core/src/main/java/com/juick/service/AdsServiceImpl.java @@ -0,0 +1,43 @@ +package com.juick.service; + +import org.springframework.stereotype.Repository; +import org.springframework.transaction.annotation.Transactional; + +import java.util.List; + +/** + * Created by aalexeev on 11/13/16. + */ +@Repository +public class AdsServiceImpl extends BaseJdbcDao implements AdsService { + + @Transactional(readOnly = true) + @Override + public int getAdMid(final int uid) { + List<Integer> list; + + if (uid > 0) + list = getJdbcTemplate().queryForList( + "SELECT message_id FROM ads_messages " + + "WHERE message_id NOT IN (SELECT message_id FROM ads_messages_log WHERE user_id = ? " + + "AND ts > UNIX_TIMESTAMP() - 60*60*24 GROUP BY message_id HAVING COUNT(*) > 2) ORDER BY RAND() LIMIT 1", + Integer.class, + uid); + + else + list = getJdbcTemplate().queryForList( + "SELECT message_id FROM ads_messages ORDER BY RAND() LIMIT 1", + Integer.class); + + return list.isEmpty() ? + 0 : list.get(0); + } + + @Transactional + @Override + public int logAdMid(final int uid, final int mid) { + return getJdbcTemplate().update( + "INSERT INTO ads_messages_log(user_id, message_id, ts) VALUES (?, ?, UNIX_TIMESTAMP())", + uid, mid); + } +} diff --git a/server-core/src/main/java/com/juick/service/BaseJdbcDao.java b/server-core/src/main/java/com/juick/service/BaseJdbcDao.java new file mode 100644 index 00000000..948e6e6b --- /dev/null +++ b/server-core/src/main/java/com/juick/service/BaseJdbcDao.java @@ -0,0 +1,42 @@ +package com.juick.service; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.InitializingBean; +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate; +import org.springframework.util.Assert; + +import javax.inject.Inject; + +/** + * Created by aalexeev on 11/13/16. + */ +public class BaseJdbcDao implements InitializingBean { + protected final Logger logger = LoggerFactory.getLogger(getClass()); + + private JdbcTemplate jdbcTemplate; + private NamedParameterJdbcTemplate namedParameterJdbcTemplate; + + protected JdbcTemplate getJdbcTemplate() { + return jdbcTemplate; + } + + protected NamedParameterJdbcTemplate getNamedParameterJdbcTemplate() { + return namedParameterJdbcTemplate; + } + + @Override + public void afterPropertiesSet() throws Exception { + logger.debug("Checking required beans"); + + Assert.notNull(jdbcTemplate); + Assert.notNull(namedParameterJdbcTemplate); + } + + @Inject + public void setJdbcTemplate(JdbcTemplate jdbcTemplate) { + this.jdbcTemplate = jdbcTemplate; + namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(jdbcTemplate); + } +} diff --git a/server-core/src/main/java/com/juick/service/CrosspostService.java b/server-core/src/main/java/com/juick/service/CrosspostService.java new file mode 100644 index 00000000..88821b60 --- /dev/null +++ b/server-core/src/main/java/com/juick/service/CrosspostService.java @@ -0,0 +1,24 @@ +package com.juick.service; + +import com.juick.server.helpers.ApplicationStatus; +import org.apache.commons.lang3.tuple.Pair; + +import java.util.Optional; + +/** + * Created by aalexeev on 11/13/16. + */ +public interface CrosspostService { + + Optional<Pair<String, String>> getTwitterTokens(int uid); + + Optional<String> getFacebookToken(int uid); + + ApplicationStatus getFbCrossPostStatus(int uid); + + String getTwitterName(int uid); + + String getTelegramName(int uid); + + Optional<Pair<String, String>> getVkTokens(int uid); +} diff --git a/server-core/src/main/java/com/juick/service/CrosspostServiceImpl.java b/server-core/src/main/java/com/juick/service/CrosspostServiceImpl.java new file mode 100644 index 00000000..6c6f7442 --- /dev/null +++ b/server-core/src/main/java/com/juick/service/CrosspostServiceImpl.java @@ -0,0 +1,89 @@ +package com.juick.service; + +import com.juick.server.helpers.ApplicationStatus; +import org.apache.commons.lang3.tuple.Pair; +import org.springframework.stereotype.Repository; +import org.springframework.transaction.annotation.Transactional; + +import java.util.List; +import java.util.Optional; + +/** + * Created by aalexeev on 11/13/16. + */ +@Repository +public class CrosspostServiceImpl extends BaseJdbcDao implements CrosspostService { + + @Transactional(readOnly = true) + @Override + public Optional<Pair<String, String>> getTwitterTokens(final int uid) { + List<Optional<Pair<String, String>>> list = getJdbcTemplate().query( + "SELECT access_token,access_token_secret FROM twitter WHERE user_id = ? AND crosspost = 1", + (rs, num) -> Optional.of(Pair.of(rs.getString(1), rs.getString(2))), + uid); + + return list.isEmpty() ? + Optional.empty() : list.get(0); + } + + @Override + public Optional<String> getFacebookToken(final int uid) { + List<String> list = getJdbcTemplate().queryForList( + "SELECT access_token FROM facebook WHERE user_id = ? AND access_token IS NOT NULL AND crosspost = 1", + String.class, + uid); + return list.isEmpty() ? + Optional.empty() : Optional.of(list.get(0)); + } + + @Override + public ApplicationStatus getFbCrossPostStatus(final int uid) { + List<ApplicationStatus> list = getJdbcTemplate().query( + "SELECT 1, crosspost FROM facebook WHERE user_id = ? LIMIT 1", + (rs, num) -> { + ApplicationStatus status = new ApplicationStatus(); + + status.setConnected(rs.getInt(1) > 0); + status.setCrosspostEnabled(rs.getBoolean(2)); + + return status; + }, + uid); + + return list.isEmpty() ? + new ApplicationStatus() : list.get(0); + } + + @Override + public String getTwitterName(final int uid) { + List<String> list = getJdbcTemplate().queryForList( + "SELECT uname FROM twitter WHERE user_id = ?", + String.class, + uid); + + return list.isEmpty() ? + "" : list.get(0); + } + + @Override + public String getTelegramName(final int uid) { + List<String> list = getJdbcTemplate().queryForList( + "SELECT tg_name FROM telegram WHERE user_id = ?", + String.class, + uid); + + return list.isEmpty() ? + "" : list.get(0); + } + + @Override + public Optional<Pair<String, String>> getVkTokens(final int uid) { + List<Optional<Pair<String, String>>> list = getJdbcTemplate().query( + "SELECT vk_id, access_token FROM vk WHERE user_id = ? AND crosspost = 1", + (rs, num) -> Optional.of(Pair.of(rs.getString(1), rs.getString(2))), + uid); + + return list.isEmpty() ? + Optional.empty() : list.get(0); + } +} diff --git a/server-core/src/main/java/com/juick/service/MessagesService.java b/server-core/src/main/java/com/juick/service/MessagesService.java new file mode 100644 index 00000000..23ccf8e9 --- /dev/null +++ b/server-core/src/main/java/com/juick/service/MessagesService.java @@ -0,0 +1,7 @@ +package com.juick.service; + +/** + * Created by aalexeev on 11/13/16. + */ +public interface MessagesService { +} diff --git a/server-core/src/main/java/com/juick/service/MessagesServiceImpl.java b/server-core/src/main/java/com/juick/service/MessagesServiceImpl.java new file mode 100644 index 00000000..1955d9f9 --- /dev/null +++ b/server-core/src/main/java/com/juick/service/MessagesServiceImpl.java @@ -0,0 +1,10 @@ +package com.juick.service; + +import org.springframework.stereotype.Repository; + +/** + * Created by aalexeev on 11/13/16. + */ +@Repository +public class MessagesServiceImpl extends BaseJdbcDao implements MessagesService { +} diff --git a/server-core/src/main/java/com/juick/service/PMQueriesService.java b/server-core/src/main/java/com/juick/service/PMQueriesService.java new file mode 100644 index 00000000..5e2e2b75 --- /dev/null +++ b/server-core/src/main/java/com/juick/service/PMQueriesService.java @@ -0,0 +1,7 @@ +package com.juick.service; + +/** + * Created by aalexeev on 11/13/16. + */ +public interface PMQueriesService { +} diff --git a/server-core/src/main/java/com/juick/service/PMQueriesServiceImpl.java b/server-core/src/main/java/com/juick/service/PMQueriesServiceImpl.java new file mode 100644 index 00000000..4c8f4ae9 --- /dev/null +++ b/server-core/src/main/java/com/juick/service/PMQueriesServiceImpl.java @@ -0,0 +1,10 @@ +package com.juick.service; + +import org.springframework.stereotype.Repository; + +/** + * Created by aalexeev on 11/13/16. + */ +@Repository +public class PMQueriesServiceImpl extends BaseJdbcDao implements PushQueriesService { +} diff --git a/server-core/src/main/java/com/juick/service/PrivacyQueriesService.java b/server-core/src/main/java/com/juick/service/PrivacyQueriesService.java new file mode 100644 index 00000000..29116081 --- /dev/null +++ b/server-core/src/main/java/com/juick/service/PrivacyQueriesService.java @@ -0,0 +1,7 @@ +package com.juick.service; + +/** + * Created by aalexeev on 11/13/16. + */ +public interface PrivacyQueriesService { +} diff --git a/server-core/src/main/java/com/juick/service/PrivacyQueriesServiceImpl.java b/server-core/src/main/java/com/juick/service/PrivacyQueriesServiceImpl.java new file mode 100644 index 00000000..d4e43728 --- /dev/null +++ b/server-core/src/main/java/com/juick/service/PrivacyQueriesServiceImpl.java @@ -0,0 +1,10 @@ +package com.juick.service; + +import org.springframework.stereotype.Repository; + +/** + * Created by aalexeev on 11/13/16. + */ +@Repository +public class PrivacyQueriesServiceImpl extends BaseJdbcDao implements PrivacyQueriesService { +} diff --git a/server-core/src/main/java/com/juick/service/PushQueriesService.java b/server-core/src/main/java/com/juick/service/PushQueriesService.java new file mode 100644 index 00000000..dbb5ac06 --- /dev/null +++ b/server-core/src/main/java/com/juick/service/PushQueriesService.java @@ -0,0 +1,7 @@ +package com.juick.service; + +/** + * Created by aalexeev on 11/13/16. + */ +public interface PushQueriesService { +} diff --git a/server-core/src/main/java/com/juick/service/PushQueriesServiceImpl.java b/server-core/src/main/java/com/juick/service/PushQueriesServiceImpl.java new file mode 100644 index 00000000..0381f913 --- /dev/null +++ b/server-core/src/main/java/com/juick/service/PushQueriesServiceImpl.java @@ -0,0 +1,10 @@ +package com.juick.service; + +import org.springframework.stereotype.Repository; + +/** + * Created by aalexeev on 11/13/16. + */ +@Repository +public class PushQueriesServiceImpl extends BaseJdbcDao implements PushQueriesService { +} diff --git a/server-core/src/main/java/com/juick/service/ShowQueriesService.java b/server-core/src/main/java/com/juick/service/ShowQueriesService.java new file mode 100644 index 00000000..2d42988d --- /dev/null +++ b/server-core/src/main/java/com/juick/service/ShowQueriesService.java @@ -0,0 +1,7 @@ +package com.juick.service; + +/** + * Created by aalexeev on 11/13/16. + */ +public interface ShowQueriesService { +} diff --git a/server-core/src/main/java/com/juick/service/ShowQueriesServiceImpl.java b/server-core/src/main/java/com/juick/service/ShowQueriesServiceImpl.java new file mode 100644 index 00000000..d3470c75 --- /dev/null +++ b/server-core/src/main/java/com/juick/service/ShowQueriesServiceImpl.java @@ -0,0 +1,10 @@ +package com.juick.service; + +import org.springframework.stereotype.Repository; + +/** + * Created by aalexeev on 11/13/16. + */ +@Repository +public class ShowQueriesServiceImpl extends BaseJdbcDao implements SubscriptionService { +} diff --git a/server-core/src/main/java/com/juick/service/SubscriptionService.java b/server-core/src/main/java/com/juick/service/SubscriptionService.java new file mode 100644 index 00000000..0ed3f55a --- /dev/null +++ b/server-core/src/main/java/com/juick/service/SubscriptionService.java @@ -0,0 +1,7 @@ +package com.juick.service; + +/** + * Created by aalexeev on 11/13/16. + */ +public interface SubscriptionService { +} diff --git a/server-core/src/main/java/com/juick/service/SubscriptionServiceImpl.java b/server-core/src/main/java/com/juick/service/SubscriptionServiceImpl.java new file mode 100644 index 00000000..811f5af0 --- /dev/null +++ b/server-core/src/main/java/com/juick/service/SubscriptionServiceImpl.java @@ -0,0 +1,10 @@ +package com.juick.service; + +import org.springframework.stereotype.Repository; + +/** + * Created by aalexeev on 11/13/16. + */ +@Repository +public class SubscriptionServiceImpl extends BaseJdbcDao implements SubscriptionService { +} diff --git a/server-core/src/main/java/com/juick/service/TagService.java b/server-core/src/main/java/com/juick/service/TagService.java new file mode 100644 index 00000000..1083d663 --- /dev/null +++ b/server-core/src/main/java/com/juick/service/TagService.java @@ -0,0 +1,7 @@ +package com.juick.service; + +/** + * Created by aalexeev on 11/13/16. + */ +public interface TagService { +} diff --git a/server-core/src/main/java/com/juick/service/TagServiceImpl.java b/server-core/src/main/java/com/juick/service/TagServiceImpl.java new file mode 100644 index 00000000..9649ce74 --- /dev/null +++ b/server-core/src/main/java/com/juick/service/TagServiceImpl.java @@ -0,0 +1,10 @@ +package com.juick.service; + +import org.springframework.stereotype.Repository; + +/** + * Created by aalexeev on 11/13/16. + */ +@Repository +public class TagServiceImpl extends BaseJdbcDao implements TagService { +} diff --git a/server-core/src/main/java/com/juick/service/UserService.java b/server-core/src/main/java/com/juick/service/UserService.java new file mode 100644 index 00000000..ecf8ad07 --- /dev/null +++ b/server-core/src/main/java/com/juick/service/UserService.java @@ -0,0 +1,7 @@ +package com.juick.service; + +/** + * Created by aalexeev on 11/13/16. + */ +public interface UserService { +} diff --git a/server-core/src/main/java/com/juick/service/UserServiceImpl.java b/server-core/src/main/java/com/juick/service/UserServiceImpl.java new file mode 100644 index 00000000..93dc90dc --- /dev/null +++ b/server-core/src/main/java/com/juick/service/UserServiceImpl.java @@ -0,0 +1,10 @@ +package com.juick.service; + +import org.springframework.stereotype.Repository; + +/** + * Created by aalexeev on 11/13/16. + */ +@Repository +public class UserServiceImpl extends BaseJdbcDao implements UserService { +} |