package project.news.internal;
|
|
import java.io.Serializable;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
import org.apache.commons.collections.CollectionUtils;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
|
import kernel.bo.RecordObjectMapper;
|
import kernel.web.Page;
|
import project.Constants;
|
import project.RedisKeys;
|
import project.news.News;
|
import project.news.NewsService;
|
import project.party.PartyService;
|
import project.party.model.Party;
|
import project.party.model.UserRecom;
|
import project.party.recom.UserRecomService;
|
import project.redis.RedisHandler;
|
|
public class NewsServiceImpl implements NewsService {
|
private JdbcTemplate jdbcTemplate;
|
private RedisHandler redisHandler;
|
private PartyService partyService;
|
private UserRecomService userRecomService;
|
|
public void save(News entity) {
|
entity.setCreateTime(new Date());
|
|
String insertSql = "INSERT INTO T_NEWS(UUID,TITLE,CONTENT,CREATE_TIME,LANGUAGE,INDEX_TOP,PARTY_ID,IMG_URL,IMG_JUMP_URL,"
|
+ "CLICK,POP_UP,START_TIME,END_TIME) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?)";
|
jdbcTemplate.update(insertSql,entity.getId(),entity.getTitle(),entity.getContent(),entity.getCreateTime(),entity.getLanguage(),
|
entity.getIndex()?"Y":"N",entity.getPartyId(),entity.getImgUrl(),entity.getImgJumpUrl(),entity.getClick(),entity.getPopUp(),entity.getStartTime(),entity.getEndTime());
|
|
redisHandler.setSync(RedisKeys.NEWS_ID + entity.getId().toString(), entity);
|
|
Map<String, News> cacheLanguage = (Map<String, News>) redisHandler
|
.get(RedisKeys.NEWS_LANGUAGE + entity.getLanguage());
|
if (cacheLanguage == null) {
|
cacheLanguage = new ConcurrentHashMap<String, News>();
|
}
|
cacheLanguage.put(entity.getId().toString(), entity);
|
redisHandler.setSync(RedisKeys.NEWS_LANGUAGE + entity.getLanguage(), cacheLanguage);
|
|
}
|
|
public Page cachePagedQuery(int pageNo, int pageSize, String language) {
|
if (!StringUtils.isNotEmpty(language)) {
|
language = "en";
|
}
|
Map<String, News> cacheLanguage = (Map<String, News>) redisHandler.get(RedisKeys.NEWS_LANGUAGE + language);
|
List<News> list = null;
|
if (cacheLanguage != null) {
|
list = new ArrayList<News>(cacheLanguage.values());
|
}
|
|
if (CollectionUtils.isEmpty(list))
|
return Page.EMPTY_PAGE;
|
list.sort(new News());
|
|
Page page = new Page(pageNo, pageSize, Integer.MAX_VALUE);
|
// 0-29 30-59
|
int start = page.getFirstElementNumber();
|
if (start >= list.size()) {
|
return new Page();
|
}
|
// int start = (pageNo - 1) * pageSize;
|
int end = start + pageSize;
|
if (list.size() <= end)
|
end = list.size();
|
|
page.setElements(list.subList(start, end));
|
|
// StringBuffer queryString = new StringBuffer("");
|
// queryString.append(" FROM News WHERE 1=1 ");
|
// Map parameters = new HashMap();
|
// if (StringUtils.isNotEmpty(language)) {
|
// queryString.append("AND language=:language ");
|
// parameters.put("language", language);
|
// }
|
//
|
// queryString.append(" order by createTime desc ");
|
// Page page = this.pagedDao.pagedQueryHql(pageNo, pageSize, queryString.toString(), parameters);
|
return page;
|
}
|
|
public Page cachePagedQuery_v2(int pageNo, int pageSize, String language, boolean popup) {
|
|
if (!StringUtils.isNotEmpty(language)) {
|
language = "en";
|
}
|
|
Map<String, News> cacheLanguage = (Map<String, News>) this.redisHandler.get(RedisKeys.NEWS_LANGUAGE + language);
|
List<News> newsList = new ArrayList<News>();
|
if (cacheLanguage != null) {
|
newsList = new ArrayList<News>(cacheLanguage.values());
|
}
|
|
Date date = new Date();
|
|
List<News> list = new ArrayList<News>();
|
for (int i = 0; i < newsList.size(); i++) {
|
News news = newsList.get(i);
|
|
if ((null != news.getStartTime() && date.before(news.getStartTime()))
|
|| (null != news.getEndTime() && news.getEndTime().before(date))) {
|
continue;
|
}
|
|
if (null != news) {
|
|
if (null == news.getPartyId() || kernel.util.StringUtils.isEmptyString(news.getPartyId().toString())) {
|
// 全局配置
|
if (popup) {
|
if (1 == news.getPopUp()) {
|
list.add(news);
|
}
|
} else {
|
if (0 == news.getPopUp()) {
|
list.add(news);
|
}
|
}
|
}
|
}
|
}
|
|
if (CollectionUtils.isEmpty(list))
|
return Page.EMPTY_PAGE;
|
list.sort(new News());
|
|
Page page = new Page(pageNo, pageSize, Integer.MAX_VALUE);
|
// 0-29 30-59
|
int start = page.getFirstElementNumber();
|
if (start >= list.size()) {
|
return new Page();
|
}
|
// int start = (pageNo - 1) * pageSize;
|
int end = start + pageSize;
|
if (list.size() <= end)
|
end = list.size();
|
|
page.setElements(list.subList(start, end));
|
return page;
|
}
|
|
public Page cachePagedQuery_v2_token(int pageNo, int pageSize, String language, String partyId, boolean popup) {
|
|
if (!StringUtils.isNotEmpty(language)) {
|
language = "en";
|
}
|
|
List<String> parents_partyid = new ArrayList<String>();
|
|
if (!kernel.util.StringUtils.isEmptyString(partyId)) {
|
List<UserRecom> parents = this.userRecomService.getParents(partyId);
|
for (int j = 0; j < parents.size(); j++) {
|
Party party = this.partyService.cachePartyBy(parents.get(j).getReco_id(), true);
|
if (null == party) {
|
continue;
|
}
|
if (!Constants.SECURITY_ROLE_AGENT.equals(party.getRolename())
|
&& !Constants.SECURITY_ROLE_AGENTLOW.equals(party.getRolename())) {
|
// 非代理
|
continue;
|
}
|
parents_partyid.add(party.getId().toString());
|
}
|
}
|
|
Map<String, News> cacheLanguage = (Map<String, News>) this.redisHandler.get(RedisKeys.NEWS_LANGUAGE + language);
|
List<News> newsList = new ArrayList<News>();
|
if (cacheLanguage != null) {
|
newsList = new ArrayList<News>(cacheLanguage.values());
|
}
|
|
Date date = new Date();
|
|
List<News> list = new ArrayList<News>();
|
for (int i = 0; i < newsList.size(); i++) {
|
News news = newsList.get(i);
|
|
if ((null != news.getStartTime() && date.before(news.getStartTime()))
|
|| (null != news.getEndTime() && news.getEndTime().before(date))) {
|
continue;
|
}
|
|
if (null != news) {
|
|
if (null == news.getPartyId() || kernel.util.StringUtils.isEmptyString(news.getPartyId().toString())) {
|
// 全局配置
|
if (popup) {
|
if (1 == news.getPopUp()) {
|
list.add(news);
|
}
|
} else {
|
if (0 == news.getPopUp()) {
|
list.add(news);
|
}
|
}
|
} else {
|
|
if (news.getPartyId().toString().equals(partyId)) {
|
// 用户配置
|
if (popup) {
|
if (1 == news.getPopUp()) {
|
list.add(news);
|
}
|
} else {
|
if (0 == news.getPopUp()) {
|
list.add(news);
|
}
|
}
|
}
|
|
if (parents_partyid.contains(news.getPartyId().toString())) {
|
// 代理配置
|
if (popup) {
|
if (1 == news.getPopUp()) {
|
list.add(news);
|
}
|
} else {
|
if (0 == news.getPopUp()) {
|
list.add(news);
|
}
|
}
|
}
|
}
|
}
|
}
|
|
if (CollectionUtils.isEmpty(list))
|
return Page.EMPTY_PAGE;
|
list.sort(new News());
|
|
Page page = new Page(pageNo, pageSize, Integer.MAX_VALUE);
|
// 0-29 30-59
|
int start = page.getFirstElementNumber();
|
if (start >= list.size()) {
|
return new Page();
|
}
|
// int start = (pageNo - 1) * pageSize;
|
int end = start + pageSize;
|
if (list.size() <= end)
|
end = list.size();
|
|
page.setElements(list.subList(start, end));
|
return page;
|
}
|
|
public News findById(Serializable id) {
|
List<News> list = jdbcTemplate.query("SELECT * FROM T_NEWS WHERE UUID=?", RecordObjectMapper.newInstance(News.class), id);
|
if (null != list && list.size() > 0) {
|
return list.get(0);
|
}
|
return null;
|
}
|
|
public News cacheById(Serializable id) {
|
News news = (News) redisHandler.get(RedisKeys.NEWS_ID + id.toString());
|
return news;
|
}
|
|
public void delete(String id) {
|
News entity = findById(id);
|
if (entity != null) {
|
jdbcTemplate.update("DELETE FROM T_NEWS WHERE UUID=?", entity.getId());
|
|
redisHandler.remove(RedisKeys.NEWS_ID + entity.getId().toString());
|
Map<String, News> cacheLanguage = (Map<String, News>) redisHandler
|
.get(RedisKeys.NEWS_LANGUAGE + entity.getLanguage());
|
if (cacheLanguage != null) {
|
cacheLanguage.remove(entity.getId().toString());
|
}
|
redisHandler.setSync(RedisKeys.NEWS_LANGUAGE + entity.getLanguage(), cacheLanguage);
|
|
}
|
}
|
|
public void update(News entity) {
|
if (null == entity) {
|
return;
|
}
|
String updateSql = "UPDATE T_NEWS SET TITLE=?,CONTENT=?,LANGUAGE=?,INDEX_TOP=?,PARTY_ID=?,IMG_URL=?,IMG_JUMP_URL=?,CLICK=?,POP_UP=?,START_TIME=?,END_TIME=? WHERE UUID=?";
|
jdbcTemplate.update(updateSql, entity.getTitle(), entity.getContent(), entity.getLanguage(), entity.getIndex(), entity.getPartyId(),
|
entity.getImgUrl(), entity.getImgJumpUrl(), entity.getClick(), entity.getPopUp(), entity.getStartTime(), entity.getEndTime(), entity.getId());
|
|
redisHandler.setSync(RedisKeys.NEWS_ID + entity.getId().toString(), entity);
|
|
Map<String, News> cacheLanguage = (Map<String, News>) redisHandler
|
.get(RedisKeys.NEWS_LANGUAGE + entity.getLanguage());
|
if (cacheLanguage == null) {
|
cacheLanguage = new ConcurrentHashMap<String, News>();
|
}
|
cacheLanguage.put(entity.getId().toString(), entity);
|
redisHandler.setSync(RedisKeys.NEWS_LANGUAGE + entity.getLanguage(), cacheLanguage);
|
|
}
|
|
@Override
|
public News getIndex(String language) {
|
|
Map<String, News> cacheLanguage = (Map<String, News>) redisHandler.get(RedisKeys.NEWS_LANGUAGE + language);
|
List<News> list = new ArrayList<News>();
|
if (cacheLanguage != null) {
|
|
Date date = new Date();
|
|
for (News news : cacheLanguage.values()) {
|
|
if ((null != news.getStartTime() && date.before(news.getStartTime()))
|
|| (null != news.getEndTime() && news.getEndTime().before(date))) {
|
continue;
|
}
|
|
if (news.getIndex() && 0 == news.getPopUp()) {
|
list.add(news);
|
}
|
}
|
}
|
|
if (CollectionUtils.isEmpty(list))
|
return null;
|
list.sort(new News());
|
|
return list.get(0);
|
|
}
|
|
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
|
this.jdbcTemplate = jdbcTemplate;
|
}
|
|
public void setRedisHandler(RedisHandler redisHandler) {
|
this.redisHandler = redisHandler;
|
}
|
|
public void setPartyService(PartyService partyService) {
|
this.partyService = partyService;
|
}
|
|
public void setUserRecomService(UserRecomService userRecomService) {
|
this.userRecomService = userRecomService;
|
}
|
|
}
|
