NewsService.java 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394
  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. if (null!=news &&news.getAuditStatus()!=null&& news.getAuditStatus()==2) {
  99. addJtCollectSearch( news);
  100. }
  101. newsMapper.insert(news);
  102. NewsPublish newsPublish=null;
  103. if(webPages!=null && webPages.size()>0)
  104. {
  105. for(String s:webPages)
  106. {
  107. newsPublish=new NewsPublish();
  108. newsPublish.setId(UUID.randomUUID().toString());
  109. newsPublish.setPublishPage(s);
  110. newsPublish.setNewsId(news.getId()+"");
  111. newsPublish.setIfTop(0);
  112. newsPublish.setPublishClient(0);
  113. newsPublish.setPublisher("");
  114. newsPublish.setPublishPlatform("");
  115. newsPublish.setPublishTime(new Date());
  116. newsPublishMapper.insert(newsPublish);
  117. }
  118. }
  119. if(appPages!=null && appPages.size()>0)
  120. {
  121. for(String s:appPages)
  122. {
  123. newsPublish=new NewsPublish();
  124. newsPublish.setId(UUID.randomUUID().toString());
  125. newsPublish.setPublishPage(s);
  126. newsPublish.setNewsId(news.getId()+"");
  127. newsPublish.setIfTop(0);
  128. newsPublish.setPublishClient(1);
  129. newsPublish.setPublisher("");
  130. newsPublish.setPublishPlatform("");
  131. newsPublish.setPublishTime(new Date());
  132. newsPublishMapper.insert(newsPublish);
  133. }
  134. }
  135. return news;
  136. }
  137. @CachePut(value = "NewsCache", key = "'News:'+#id")
  138. public News update(long id, News news) {
  139. newsMapper.updateByPrimaryKeyWithBLOBs(news);
  140. return news;
  141. }
  142. public int updateSelectivelyWithoutPages(News news)
  143. {
  144. return newsMapper.updateByPrimaryKeySelective(news);
  145. }
  146. public int updateSelectively(News news,List<String>webPages,List<String>appPages) {
  147. if(collectFlag){
  148. if(news!=null&&news.getAuditStatus()==2)addJtCollectSearch(news);
  149. if(news!=null&&news.getAuditStatus()==4)updateJtCollectSearch(news);
  150. }
  151. newsPublishMapper.deleteByNewsId(news.getId());
  152. NewsPublish newsPublish=null;
  153. if(webPages!=null && webPages.size()>0)
  154. {
  155. for(String s:webPages)
  156. {
  157. newsPublish=new NewsPublish();
  158. newsPublish.setId(UUID.randomUUID().toString());
  159. newsPublish.setPublishPage(s);
  160. newsPublish.setNewsId(news.getId()+"");
  161. newsPublish.setIfTop(0);
  162. newsPublish.setPublishClient(0);
  163. newsPublish.setPublisher("");
  164. newsPublish.setPublishPlatform("");
  165. newsPublish.setPublishTime(new Date());
  166. newsPublishMapper.insert(newsPublish);
  167. }
  168. }
  169. if(appPages!=null && appPages.size()>0)
  170. {
  171. for(String s:appPages)
  172. {
  173. newsPublish=new NewsPublish();
  174. newsPublish.setId(UUID.randomUUID().toString());
  175. newsPublish.setPublishPage(s);
  176. newsPublish.setNewsId(news.getId()+"");
  177. newsPublish.setIfTop(0);
  178. newsPublish.setPublishClient(1);
  179. newsPublish.setPublisher("");
  180. newsPublish.setPublishPlatform("");
  181. newsPublish.setPublishTime(new Date());
  182. newsPublishMapper.insert(newsPublish);
  183. }
  184. }
  185. return newsMapper.updateByPrimaryKeySelective(news);
  186. }
  187. /*
  188. * type(0-普通 99-公众号新闻 98-技淘百科)
  189. * */
  190. @SuppressWarnings("unchecked")
  191. public Pagination<News> listNews(Integer type, String title, String author, String startCreateTime,
  192. String endCreateTime, String source, Integer hot, Integer pNo, Integer pSize,String auditStatus,String releaseStatus,String publishPage) {
  193. Map<String, Object> params = new HashMap<>();
  194. if(null !=publishPage) {
  195. params.put("publishPage", publishPage);
  196. }
  197. if (null != auditStatus) {
  198. params.put("auditStatus", auditStatus);
  199. }
  200. if (null != releaseStatus) {
  201. params.put("releaseStatus", releaseStatus);
  202. }
  203. if (null != type) {
  204. params.put("type", type);
  205. }
  206. if (StringUtils.isNotBlank(title)) {
  207. params.put("title", title);
  208. }
  209. if (StringUtils.isNotBlank(author)) {
  210. params.put("author", author);
  211. }
  212. if (StringUtils.isNotBlank(startCreateTime)) {
  213. try {
  214. params.put("sDate", DateUtils.parseDate(startCreateTime, AFTConstants.YYYYMMDD));
  215. } catch (ParseException e) {
  216. }
  217. }
  218. if (StringUtils.isNotBlank(endCreateTime)) {
  219. try {
  220. params.put("eDate", DateUtils.addDays(DateUtils.parseDate(endCreateTime, AFTConstants.YYYYMMDD), 1));
  221. } catch (ParseException e) {
  222. }
  223. }
  224. if (StringUtils.isNotBlank(source)) {
  225. params.put("source", source);
  226. }
  227. if (null != hot) {
  228. params.put("hot", hot);
  229. }
  230. if (pNo == null || pNo < 0) {
  231. pNo = 1;
  232. }
  233. if (pSize == null || pSize < 0 || pSize > 10) {
  234. pSize = 10;
  235. }
  236. return (Pagination<News>) findPage("findNewsListByPage", "findNewsCount", params, pNo, pSize);
  237. }
  238. public NewsResult findNewsDetail(Long id) {
  239. NewsResult newsResult=newsMapper.selectByPrimaryKey(id);
  240. List<NewsPublish> newsPublishs=newsPublishMapper.selectByNewsId(id);
  241. newsResult.setNewsPublishs(newsPublishs);
  242. return newsResult;
  243. }
  244. public int batchDeleteByPrimaryKey(List<String> id) {
  245. return newsMapper.batchDeleteByPrimaryKey(id);
  246. }
  247. @SuppressWarnings("unchecked")
  248. public Pagination<NewsPortalList> portalNewsList(Integer pSize, Integer pNo, Integer type, Integer hot,
  249. Integer provinceId, String keyword,Integer auditStatus) {
  250. Map<String, Object> params = new HashMap<String, Object>();
  251. if (null != hot) {
  252. params.put("hot", hot);
  253. }
  254. if (null != type) {
  255. params.put("type", type);
  256. }
  257. if (null != provinceId) {
  258. params.put("provinceId", provinceId);
  259. }
  260. if (null != keyword) {
  261. params.put("keyword", keyword);
  262. }
  263. if (pNo == null || pNo < 0) {
  264. pNo = 1;
  265. }
  266. if (pSize == null || pSize < 0 || pSize > 10) {
  267. pSize = 10;
  268. }
  269. if(auditStatus!=null) {
  270. params.put("auditStatus", auditStatus);
  271. }
  272. return (Pagination<NewsPortalList>) findPage("portalNewsList", "portalNewsCount", params, pNo, pSize);
  273. }
  274. @CacheEvict(value = "NewsPortalListCache", allEntries = true)
  275. public void cleanPortalList() {
  276. LoggerUtils.debug(logger, "清除门户端新闻列表缓存");
  277. }
  278. public List<NewsSummary> findJmrhNewsList(String type) {
  279. Map<String, Object> params = new HashMap<String, Object>();
  280. params.put("type", type);
  281. return newsMapper.findJmrhNewsList(params);
  282. }
  283. public List<NewsPortalList> portalNewsPolicy(){
  284. return newsMapper.portalNewsPolicy();
  285. }
  286. public List<NewsPortalList> portalNewsQuestion(){
  287. return newsMapper.portalNewsQuestion();
  288. }
  289. @SuppressWarnings("unchecked")
  290. public Pagination<AppDiscoveryBo> appListinformation( Integer pNo,Integer pSize){
  291. Map<String, Object> params=new HashMap<>();
  292. if (pNo == null || pNo < 1)pNo = 1;
  293. if (pSize == null || pSize < 1 )pSize = 10;
  294. Pagination<AppDiscoveryBo>p=(Pagination<AppDiscoveryBo>) findPage("appNewsList", "appNewsCount", params, pNo, pSize);
  295. List<AppDiscoveryBo> l=(List<AppDiscoveryBo>) p.getList();
  296. for (AppDiscoveryBo a : l) {
  297. a.setContent(a.getContent().replaceAll("<p>", "").replaceAll("</p>", ""));
  298. }
  299. return p;
  300. }
  301. public int deleteByPrimaryKey(long id) {
  302. newsPublishMapper.deleteByNewsId(id);
  303. return newsMapper.deleteByPrimaryKey(id);
  304. }
  305. public List<News>getNewsList(int size){
  306. List<News> news=newsMapper.getNewsList(size);
  307. return news;
  308. }
  309. public PolicyEntity getPolicyDetail(String id) {
  310. PolicyEntity res=newsMapper.getPolicyDetail(id);
  311. return res;
  312. }
  313. public NewsPortalList informationDetail(String id) {
  314. return newsMapper.selectinformationDetail(id);
  315. }
  316. @SuppressWarnings("unchecked")
  317. public Pagination<AppDiscoveryBo> listEncyclopedia(Integer pageNo, Integer pageSize) {
  318. Map<String, Object> params=new HashMap<>();
  319. if (pageNo == null || pageNo < 1)pageNo = 1;
  320. if (pageSize == null || pageSize < 1 )pageSize = 10;
  321. Pagination<AppDiscoveryBo>p= (Pagination<AppDiscoveryBo>) findPage("encyclopediaList", "encyclopediaCount", params, pageNo, pageSize);
  322. List<AppDiscoveryBo> l=(List<AppDiscoveryBo>) p.getList();
  323. for (AppDiscoveryBo a : l) {
  324. a.setContent(a.getContent().replaceAll("<p>", "").replaceAll("</p>", ""));
  325. }
  326. return p;
  327. }
  328. public News findAppNewsDetail(long id) {
  329. return newsMapper.selectByPrimaryKey(id);
  330. }
  331. public void addJtCollectSearch(News news) {
  332. if(collectFlag){
  333. JtCollectSearch r=new JtCollectSearch();
  334. r.setFromTable(collectType.NEWS.getDesc());
  335. r.setKeyword(news.getKeyword());
  336. r.setTitle(news.getTitle());
  337. r.setRowId(news.getId().toString());
  338. jtCollectSearchMapper.insertSelective(r);
  339. }
  340. }
  341. public void updateJtCollectSearch(News news) {
  342. if(collectFlag)jtCollectSearchMapper.deleteByrowId(news.getId().toString());
  343. }
  344. }