diff options
author | Alexander Alexeev | 2016-11-13 23:45:32 +0700 |
---|---|---|
committer | Alexander Alexeev | 2016-11-13 23:45:32 +0700 |
commit | 590c650f8ac3478b31fd3fd3382c9b35284844b7 (patch) | |
tree | 950de6ee245ba45aba1b1f147ec475ac921ab291 /server-core/src/main/java/com/juick/service/AdsServiceImpl.java | |
parent | e20ab1d1f26d18211004ee8d1b64eea51d790253 (diff) |
jdbc service (repository) layer is added
Diffstat (limited to 'server-core/src/main/java/com/juick/service/AdsServiceImpl.java')
-rw-r--r-- | server-core/src/main/java/com/juick/service/AdsServiceImpl.java | 43 |
1 files changed, 43 insertions, 0 deletions
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); + } +} |