package com.juick.service; import org.apache.commons.collections4.CollectionUtils; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.namedparam.MapSqlParameterSource; import org.springframework.stereotype.Repository; import org.springframework.transaction.annotation.Transactional; import javax.inject.Inject; import java.util.Collection; import java.util.Collections; import java.util.List; /** * Created by aalexeev on 11/13/16. */ @Repository @Transactional(readOnly = true) public class PushQueriesServiceImpl extends BaseJdbcService implements PushQueriesService { @Inject public PushQueriesServiceImpl(JdbcTemplate jdbcTemplate) { super(jdbcTemplate, null); } @Override public List getGCMRegID(final int uid) { return getJdbcTemplate().queryForList( "SELECT regid FROM android WHERE user_id=?", String.class, uid); } @Override public List getGCMTokens(final Collection uids) { if (CollectionUtils.isEmpty(uids)) return Collections.emptyList(); return getNamedParameterJdbcTemplate().queryForList( "SELECT regid FROM android INNER JOIN users ON (users.id = android.user_id) WHERE users.id IN (:ids)", new MapSqlParameterSource("ids", uids), String.class); } @Override public boolean addGCMToken(Integer uid, String token) { return getJdbcTemplate().update("INSERT IGNORE INTO android(user_id,regid) VALUES (?, ?)", uid, token) > 0; } @Override public boolean deleteGCMToken(String token) { return getJdbcTemplate().update("DELETE FROM android WHERE regid=?", token) > 0; } @Override public List getMPNSURL(final int uid) { return getJdbcTemplate().queryForList( "SELECT url FROM winphone WHERE user_id=?", String.class, uid); } @Override public List getMPNSTokens(final Collection uids) { if (CollectionUtils.isEmpty(uids)) return Collections.emptyList(); return getNamedParameterJdbcTemplate().queryForList( "SELECT url FROM winphone INNER JOIN users ON (users.id=winphone.user_id) WHERE users.id IN (:ids)", new MapSqlParameterSource("ids", uids), String.class); } @Override public boolean addMPNSToken(Integer uid, String token) { return getJdbcTemplate().update("INSERT IGNORE INTO winphone(user_id,url) VALUES (?, ?)", uid, token) > 0; } @Override public boolean deleteMPNSToken(String token) { return getJdbcTemplate().update("DELETE FROM winphone WHERE url=?", token) > 0; } @Override public List getAPNSToken(final int uid) { return getJdbcTemplate().queryForList( "SELECT token from ios WHERE user_id=?", String.class, uid); } @Override public boolean deleteAPNSToken(String token) { return getJdbcTemplate().update("DELETE FROM ios WHERE token=?", token) > 0; } @Override public List getAPNSTokens(final Collection uids) { if (CollectionUtils.isEmpty(uids)) return Collections.emptyList(); return getNamedParameterJdbcTemplate().queryForList( "SELECT token FROM ios INNER JOIN users ON (users.id = ios.user_id) WHERE users.id IN (:ids)", new MapSqlParameterSource("ids", uids), String.class); } @Override public boolean addAPNSToken(Integer uid, String token) { return getJdbcTemplate().update("INSERT IGNORE INTO ios(user_id,token) VALUES (?, ?)", uid, token) > 0; } }