NewsService.java 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387
  1. package com.goafanti.news.service;
  2. import java.text.ParseException;
  3. import java.util.Date;
  4. import java.util.HashMap;
  5. import java.util.List;
  6. import java.util.Map;
  7. import java.util.UUID;
  8. import org.apache.shiro.web.util.SavedRequest;
  9. import org.codehaus.groovy.classgen.ReturnAdder;
  10. import org.slf4j.Logger;
  11. import org.slf4j.LoggerFactory;
  12. import org.springframework.beans.factory.annotation.Autowired;
  13. import org.springframework.beans.factory.annotation.Value;
  14. import org.springframework.cache.annotation.CacheEvict;
  15. import org.springframework.cache.annotation.CachePut;
  16. import org.springframework.cache.annotation.Cacheable;
  17. import org.springframework.stereotype.Service;
  18. import org.springframework.transaction.annotation.Transactional;
  19. import com.goafanti.app.bo.AppDiscoveryBo;
  20. import com.goafanti.common.bo.PolicyEntity;
  21. import com.goafanti.common.constant.AFTConstants;
  22. import com.goafanti.common.dao.JtCollectSearchMapper;
  23. import com.goafanti.common.dao.NewsMapper;
  24. import com.goafanti.common.dao.NewsPublishMapper;
  25. import com.goafanti.common.enums.collectType;
  26. import com.goafanti.common.model.JtCollectSearch;
  27. import com.goafanti.common.model.News;
  28. import com.goafanti.common.model.NewsPublish;
  29. import com.goafanti.common.model.NewsPublishExample;
  30. import com.goafanti.common.utils.DateUtils;
  31. import com.goafanti.common.utils.LoggerUtils;
  32. import com.goafanti.common.utils.StringUtils;
  33. import com.goafanti.core.mybatis.BaseMybatisDao;
  34. import com.goafanti.core.mybatis.page.Pagination;
  35. import com.goafanti.news.bo.NewsPortalList;
  36. import com.goafanti.news.bo.NewsResult;
  37. import com.goafanti.news.bo.NewsSummary;
  38. @Service
  39. @Transactional
  40. public class NewsService extends BaseMybatisDao<NewsMapper> {
  41. @Autowired
  42. NewsMapper newsMapper;
  43. @Autowired
  44. NewsPublishMapper newsPublishMapper;
  45. @Autowired
  46. JtCollectSearchMapper jtCollectSearchMapper;
  47. @Value("${spring.profiles.active}")
  48. private String env;
  49. @Value(value="${collect_flag}")
  50. private Boolean collectFlag ;
  51. private static final Logger logger = LoggerFactory.getLogger(NewsService.class);
  52. @Cacheable(value = "IndexNewsListCache", key = "'NewsList:Page:'+#pageNo+'Type:'+#type+'Size:'+#pageSize")
  53. public List<NewsSummary> findIndexNewsList(Integer pageNo, Integer type, Integer pageSize) {
  54. Map<String, Object> params = new HashMap<String, Object>();
  55. params.put("type", type);
  56. params.put("pageSize", pageSize);
  57. params.put("pageNo", pageNo);
  58. return newsMapper.findIndexNewsLists(params);
  59. }
  60. @CacheEvict(value = "IndexNewsListCache", allEntries = true)
  61. public void cleanIndexNewsList() {
  62. LoggerUtils.debug(logger, "清除首页新闻列表缓存");
  63. }
  64. @Cacheable(value = "NewsCache", key = "'News:'+#id")
  65. public News selectById(Long id) {
  66. return newsMapper.selectByPrimaryKey(id);
  67. }
  68. @Cacheable(value = "NewsListCache", key = "'NewsList:Page:'+#pageNo+'Type:'+#type+'Size:'+#pageSize+'domainName:'+#domainName+'picReq:'+#picRequired")
  69. public List<NewsSummary> findNewsList(Integer pageNo, Integer type, Integer pageSize, String domainName,
  70. Boolean picRequired) {
  71. Map<String, Object> params = new HashMap<String, Object>();
  72. params.put("type", type);
  73. params.put("pageSize", pageSize);
  74. params.put("pageNo", pageNo);
  75. if (!StringUtils.equals(env, "dev") && !StringUtils.equals(env, "local")) {
  76. params.put("website", domainName);
  77. }
  78. if (picRequired) {
  79. params.put("picRequired", picRequired);
  80. }
  81. return newsMapper.findList(params);
  82. }
  83. @CacheEvict(value = "NewsListCache", allEntries = true)
  84. public void cleanList() {
  85. LoggerUtils.debug(logger, "清除新闻列表缓存");
  86. }
  87. @CacheEvict(value = "NewsCache", key = "'News:'+#id")
  88. public void clean(String id) {
  89. LoggerUtils.debug(logger, "清除新闻缓存:[%s]", id);
  90. }
  91. @CachePut(value = "NewsCache", key = "'News:'+#id")
  92. public News save(Long id, News news) {
  93. news.setId(id);
  94. newsMapper.insert(news);
  95. return news;
  96. }
  97. public News save(News news,List<String>webPages,List<String>appPages) {
  98. newsMapper.insert(news);
  99. NewsPublish newsPublish=null;
  100. if(webPages!=null && webPages.size()>0)
  101. {
  102. for(String s:webPages)
  103. {
  104. newsPublish=new NewsPublish();
  105. newsPublish.setId(UUID.randomUUID().toString());
  106. newsPublish.setPublishPage(s);
  107. newsPublish.setNewsId(news.getId()+"");
  108. newsPublish.setIfTop(0);
  109. newsPublish.setPublishClient(0);
  110. newsPublish.setPublisher("");
  111. newsPublish.setPublishPlatform("");
  112. newsPublish.setPublishTime(new Date());
  113. newsPublishMapper.insert(newsPublish);
  114. }
  115. }
  116. if(appPages!=null && appPages.size()>0)
  117. {
  118. for(String s:appPages)
  119. {
  120. newsPublish=new NewsPublish();
  121. newsPublish.setId(UUID.randomUUID().toString());
  122. newsPublish.setPublishPage(s);
  123. newsPublish.setNewsId(news.getId()+"");
  124. newsPublish.setIfTop(0);
  125. newsPublish.setPublishClient(1);
  126. newsPublish.setPublisher("");
  127. newsPublish.setPublishPlatform("");
  128. newsPublish.setPublishTime(new Date());
  129. newsPublishMapper.insert(newsPublish);
  130. }
  131. }
  132. return news;
  133. }
  134. @CachePut(value = "NewsCache", key = "'News:'+#id")
  135. public News update(long id, News news) {
  136. newsMapper.updateByPrimaryKeyWithBLOBs(news);
  137. return news;
  138. }
  139. public int updateSelectivelyWithoutPages(News news)
  140. {
  141. return newsMapper.updateByPrimaryKeySelective(news);
  142. }
  143. public int updateSelectively(News news,List<String>webPages,List<String>appPages) {
  144. newsPublishMapper.deleteByNewsId(news.getId());
  145. NewsPublish newsPublish=null;
  146. if(webPages!=null && webPages.size()>0)
  147. {
  148. for(String s:webPages)
  149. {
  150. newsPublish=new NewsPublish();
  151. newsPublish.setId(UUID.randomUUID().toString());
  152. newsPublish.setPublishPage(s);
  153. newsPublish.setNewsId(news.getId()+"");
  154. newsPublish.setIfTop(0);
  155. newsPublish.setPublishClient(0);
  156. newsPublish.setPublisher("");
  157. newsPublish.setPublishPlatform("");
  158. newsPublish.setPublishTime(new Date());
  159. newsPublishMapper.insert(newsPublish);
  160. }
  161. }
  162. if(appPages!=null && appPages.size()>0)
  163. {
  164. for(String s:appPages)
  165. {
  166. newsPublish=new NewsPublish();
  167. newsPublish.setId(UUID.randomUUID().toString());
  168. newsPublish.setPublishPage(s);
  169. newsPublish.setNewsId(news.getId()+"");
  170. newsPublish.setIfTop(0);
  171. newsPublish.setPublishClient(1);
  172. newsPublish.setPublisher("");
  173. newsPublish.setPublishPlatform("");
  174. newsPublish.setPublishTime(new Date());
  175. newsPublishMapper.insert(newsPublish);
  176. }
  177. }
  178. return newsMapper.updateByPrimaryKeySelective(news);
  179. }
  180. /*
  181. * type(0-普通 99-公众号新闻 98-技淘百科)
  182. * */
  183. @SuppressWarnings("unchecked")
  184. public Pagination<News> listNews(Integer type, String title, String author, String startCreateTime,
  185. String endCreateTime, String source, Integer hot, Integer pNo, Integer pSize,String auditStatus,String releaseStatus,String publishPage) {
  186. Map<String, Object> params = new HashMap<>();
  187. if(null !=publishPage) {
  188. params.put("publishPage", publishPage);
  189. }
  190. if (null != auditStatus) {
  191. params.put("auditStatus", auditStatus);
  192. }
  193. if (null != releaseStatus) {
  194. params.put("releaseStatus", releaseStatus);
  195. }
  196. if (null != type) {
  197. params.put("type", type);
  198. }
  199. if (StringUtils.isNotBlank(title)) {
  200. params.put("title", title);
  201. }
  202. if (StringUtils.isNotBlank(author)) {
  203. params.put("author", author);
  204. }
  205. if (StringUtils.isNotBlank(startCreateTime)) {
  206. try {
  207. params.put("sDate", DateUtils.parseDate(startCreateTime, AFTConstants.YYYYMMDD));
  208. } catch (ParseException e) {
  209. }
  210. }
  211. if (StringUtils.isNotBlank(endCreateTime)) {
  212. try {
  213. params.put("eDate", DateUtils.addDays(DateUtils.parseDate(endCreateTime, AFTConstants.YYYYMMDD), 1));
  214. } catch (ParseException e) {
  215. }
  216. }
  217. if (StringUtils.isNotBlank(source)) {
  218. params.put("source", source);
  219. }
  220. if (null != hot) {
  221. params.put("hot", hot);
  222. }
  223. if (pNo == null || pNo < 0) {
  224. pNo = 1;
  225. }
  226. if (pSize == null || pSize < 0 || pSize > 10) {
  227. pSize = 10;
  228. }
  229. return (Pagination<News>) findPage("findNewsListByPage", "findNewsCount", params, pNo, pSize);
  230. }
  231. public NewsResult findNewsDetail(Long id) {
  232. NewsResult newsResult=newsMapper.selectByPrimaryKey(id);
  233. List<NewsPublish> newsPublishs=newsPublishMapper.selectByNewsId(id);
  234. newsResult.setNewsPublishs(newsPublishs);
  235. return newsResult;
  236. }
  237. public int batchDeleteByPrimaryKey(List<String> id) {
  238. return newsMapper.batchDeleteByPrimaryKey(id);
  239. }
  240. @SuppressWarnings("unchecked")
  241. public Pagination<NewsPortalList> portalNewsList(Integer pSize, Integer pNo, Integer type, Integer hot,
  242. Integer provinceId, String keyword,Integer auditStatus) {
  243. Map<String, Object> params = new HashMap<String, Object>();
  244. if (null != hot) {
  245. params.put("hot", hot);
  246. }
  247. if (null != type) {
  248. params.put("type", type);
  249. }
  250. if (null != provinceId) {
  251. params.put("provinceId", provinceId);
  252. }
  253. if (null != keyword) {
  254. params.put("keyword", keyword);
  255. }
  256. if (pNo == null || pNo < 0) {
  257. pNo = 1;
  258. }
  259. if (pSize == null || pSize < 0 || pSize > 10) {
  260. pSize = 10;
  261. }
  262. if(auditStatus!=null) {
  263. params.put("auditStatus", auditStatus);
  264. }
  265. return (Pagination<NewsPortalList>) findPage("portalNewsList", "portalNewsCount", params, pNo, pSize);
  266. }
  267. @CacheEvict(value = "NewsPortalListCache", allEntries = true)
  268. public void cleanPortalList() {
  269. LoggerUtils.debug(logger, "清除门户端新闻列表缓存");
  270. }
  271. public List<NewsSummary> findJmrhNewsList(String type) {
  272. Map<String, Object> params = new HashMap<String, Object>();
  273. params.put("type", type);
  274. return newsMapper.findJmrhNewsList(params);
  275. }
  276. public List<NewsPortalList> portalNewsPolicy(){
  277. return newsMapper.portalNewsPolicy();
  278. }
  279. public List<NewsPortalList> portalNewsQuestion(){
  280. return newsMapper.portalNewsQuestion();
  281. }
  282. @SuppressWarnings("unchecked")
  283. public Pagination<AppDiscoveryBo> appListinformation( Integer pNo,Integer pSize){
  284. Map<String, Object> params=new HashMap<>();
  285. if (pNo == null || pNo < 1)pNo = 1;
  286. if (pSize == null || pSize < 1 )pSize = 10;
  287. Pagination<AppDiscoveryBo>p=(Pagination<AppDiscoveryBo>) findPage("appNewsList", "appNewsCount", params, pNo, pSize);
  288. List<AppDiscoveryBo> l=(List<AppDiscoveryBo>) p.getList();
  289. for (AppDiscoveryBo a : l) {
  290. a.setContent(a.getContent().replaceAll("<p>", "").replaceAll("</p>", ""));
  291. }
  292. return p;
  293. }
  294. public int deleteByPrimaryKey(long id) {
  295. newsPublishMapper.deleteByNewsId(id);
  296. return newsMapper.deleteByPrimaryKey(id);
  297. }
  298. public List<News>getNewsList(int size){
  299. List<News> news=newsMapper.getNewsList(size);
  300. return news;
  301. }
  302. public PolicyEntity getPolicyDetail(String id) {
  303. PolicyEntity res=newsMapper.getPolicyDetail(id);
  304. return res;
  305. }
  306. public NewsPortalList informationDetail(String id) {
  307. return newsMapper.selectinformationDetail(id);
  308. }
  309. @SuppressWarnings("unchecked")
  310. public Pagination<AppDiscoveryBo> listEncyclopedia(Integer pageNo, Integer pageSize) {
  311. Map<String, Object> params=new HashMap<>();
  312. if (pageNo == null || pageNo < 1)pageNo = 1;
  313. if (pageSize == null || pageSize < 1 )pageSize = 10;
  314. Pagination<AppDiscoveryBo>p= (Pagination<AppDiscoveryBo>) findPage("encyclopediaList", "encyclopediaCount", params, pageNo, pageSize);
  315. List<AppDiscoveryBo> l=(List<AppDiscoveryBo>) p.getList();
  316. for (AppDiscoveryBo a : l) {
  317. a.setContent(a.getContent().replaceAll("<p>", "").replaceAll("</p>", ""));
  318. }
  319. return p;
  320. }
  321. public News findAppNewsDetail(long id) {
  322. return newsMapper.selectByPrimaryKey(id);
  323. }
  324. public void addJtCollectSearch(News news) {
  325. if(collectFlag){
  326. JtCollectSearch r=new JtCollectSearch();
  327. r.setFromTable(collectType.NEWS.getDesc());
  328. r.setKeyword(news.getKeyword());
  329. r.setTitle(news.getTitle());
  330. r.setRowId(news.getId().toString());
  331. jtCollectSearchMapper.insertSelective(r);
  332. }
  333. }
  334. public void updateJtCollectSearch(News news) {
  335. if(collectFlag)jtCollectSearchMapper.deleteByrowId(news.getId().toString());
  336. }
  337. }