|
@@ -1,6 +1,5 @@
|
|
|
package cn.com.ty.lift.quan.news.service.impl;
|
|
|
|
|
|
-import cn.com.ty.lift.common.export.ExportUtils;
|
|
|
import cn.com.ty.lift.quan.news.dao.entity.MapInfo;
|
|
|
import cn.com.ty.lift.quan.news.dao.entity.QuanNews;
|
|
|
import cn.com.ty.lift.quan.news.dao.entity.model.QuanNewsReq;
|
|
@@ -43,7 +42,7 @@ public class QuanNewsServiceImpl extends ServiceImpl<QuanNewsMapper, QuanNews> i
|
|
|
*
|
|
|
* @since 2019/12/3 10:30
|
|
|
*/
|
|
|
- public RestResponse news(QuanNewsReq request) {
|
|
|
+ public RestResponse appNews(QuanNewsReq request) {
|
|
|
Page<QuanNews> page = new Page<>(request.getPageNum(), request.getPageSize());
|
|
|
IPage<Map<String, Object>> news = this.pageMaps(page, new QueryWrapper<QuanNews>()
|
|
|
.select("id", "title", "content", "top_serial topSerial", "video_url videoUrl", "release_id releaseId", "release_user releaseUser", "release_date releaseDate")
|
|
@@ -69,6 +68,19 @@ public class QuanNewsServiceImpl extends ServiceImpl<QuanNewsMapper, QuanNews> i
|
|
|
return RestResponse.success(result);
|
|
|
}
|
|
|
|
|
|
+ public RestResponse news(QuanNewsReq request) {
|
|
|
+ Page<QuanNews> page = new Page<>(request.getPageNum(), request.getPageSize());
|
|
|
+ IPage<Map<String, Object>> news = this.pageMaps(page, new QueryWrapper<QuanNews>()
|
|
|
+ .select("id", "title", "content", "top_serial topSerial", "video_url videoUrl", "release_id releaseId", "release_user releaseUser", "release_date releaseDate")
|
|
|
+ .orderByDesc("release_date"));
|
|
|
+ //全部新闻的浏览量列表
|
|
|
+ Map<Object, Object> lookTimes = redisTemplate.boundHashOps("system-quanNews-look-time").entries();
|
|
|
+ //全部新闻的点赞用户列表
|
|
|
+ Map<Object, Object> likeUsers = redisTemplate.opsForHash().entries("system-quanNews-like-users");
|
|
|
+ newsAddLookAndLike(news.getRecords(), lookTimes, likeUsers);
|
|
|
+ return RestResponse.success(news);
|
|
|
+ }
|
|
|
+
|
|
|
/**
|
|
|
* 将新闻置顶
|
|
|
*
|
|
@@ -185,71 +197,6 @@ public class QuanNewsServiceImpl extends ServiceImpl<QuanNewsMapper, QuanNews> i
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public RestResponse addNew(QuanNewsReq request) {
|
|
|
- QuanNews quanNews = new QuanNews();
|
|
|
- quanNews.setTitle(request.getTitle())
|
|
|
- .setContent(request.getContent())
|
|
|
- .setReleaseId(request.getReleaseId())
|
|
|
- .setReleaseUser(request.getReleaseUser())
|
|
|
- .setTopSerial(0);
|
|
|
- if (request.getIsTop() != 0) {
|
|
|
- List<QuanNews> tops;
|
|
|
- //获取置顶新闻列表
|
|
|
- tops = this.list(new QueryWrapper<QuanNews>().ne("top_serial", 0));
|
|
|
- //设置添加的新闻置顶排序为第1个
|
|
|
- quanNews.setTopSerial(1);
|
|
|
- //遍历其它新闻,序号+1
|
|
|
- if (!tops.isEmpty()) {
|
|
|
- tops.forEach(top -> top.setTopSerial(top.getTopSerial() + 1));
|
|
|
- if (this.updateBatchById(tops) && this.save(quanNews)) {
|
|
|
- return RestResponse.success(quanNews.getId(), "成功");
|
|
|
- } else {
|
|
|
- return RestResponse.fail();
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- //添加新闻
|
|
|
- if (this.save(quanNews)) {
|
|
|
- return RestResponse.success(quanNews.getId(), "成功");
|
|
|
- } else {
|
|
|
- return RestResponse.fail();
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 更新新闻
|
|
|
- *
|
|
|
- * @since 2019/12/4 13:34
|
|
|
- */
|
|
|
- public RestResponse updateNews(QuanNews quanNews) {
|
|
|
- if (this.updateById(quanNews)) {
|
|
|
- return RestResponse.success(null, "成功");
|
|
|
- } else {
|
|
|
- return RestResponse.fail();
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 删除新闻
|
|
|
- *
|
|
|
- * @since 2019/12/4 13:55
|
|
|
- */
|
|
|
- public RestResponse delete(Long id) {
|
|
|
- QuanNews byId = this.getById(id);
|
|
|
- if (null == byId) {
|
|
|
- return RestResponse.success();
|
|
|
-
|
|
|
- }
|
|
|
- if (byId.getTopSerial() != 0) {
|
|
|
- //取消新闻置顶
|
|
|
- this.top(id, 0);
|
|
|
- }
|
|
|
- if (this.removeById(id)) {
|
|
|
- return RestResponse.success(null, "成功");
|
|
|
- } else {
|
|
|
- return RestResponse.fail();
|
|
|
- }
|
|
|
- }
|
|
|
|
|
|
public RestResponse like(QuanNewsReq request) {
|
|
|
String userId = request.getUserId().toString();
|