From caaa6ec6ee809b1c9e56600ba1468e8f4da0103b Mon Sep 17 00:00:00 2001 From: whj <1070107765@qq.com> Date: 星期二, 19 七月 2022 15:39:15 +0800 Subject: [PATCH] commit --- src/main/java/com/example/jz/service/impl/AnnouncementServiceImpl.java | 64 ++++++++++++++++++++++++++++++++ 1 files changed, 64 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/example/jz/service/impl/AnnouncementServiceImpl.java b/src/main/java/com/example/jz/service/impl/AnnouncementServiceImpl.java index 0887f7e..5e343a3 100644 --- a/src/main/java/com/example/jz/service/impl/AnnouncementServiceImpl.java +++ b/src/main/java/com/example/jz/service/impl/AnnouncementServiceImpl.java @@ -1,10 +1,23 @@ package com.example.jz.service.impl; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; +import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.example.jz.dao.AnnouncementDao; +import com.example.jz.dao.UserDao; +import com.example.jz.modle.PageParam; import com.example.jz.modle.entity.Announcement; +import com.example.jz.modle.entity.User; +import com.example.jz.modle.vo.AnnouncementVo; import com.example.jz.service.AnnouncementService; +import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.util.Date; +import java.util.List; +import java.util.stream.Collectors; /** * 鍏憡琛�(Announcement)琛ㄦ湇鍔″疄鐜扮被 @@ -15,4 +28,55 @@ @Service("announcementService") public class AnnouncementServiceImpl extends ServiceImpl<AnnouncementDao, Announcement> implements AnnouncementService { + @Resource + AnnouncementDao announcementDao; + @Resource + UserDao userDao; + + @Override + public PageParam<AnnouncementVo> getAnnouncements(Integer size, Integer current, String content, Integer status, Integer groupId) { + PageParam<Announcement> announcementPageParam = new PageParam<>(); + announcementPageParam.setSize(size); + announcementPageParam.setCurrent(current); + QueryWrapper<Announcement> announcementQueryWrapper = new QueryWrapper<>(); + if (StringUtils.isNotBlank(content)) { + announcementQueryWrapper.like("text", content); + } + if (status != null) { + announcementQueryWrapper.eq("status", status); + } + announcementQueryWrapper.eq("group_id", groupId); + announcementQueryWrapper.orderByDesc("ctime"); + PageParam<Announcement> announcementPageParamList = announcementDao.selectPage(announcementPageParam, announcementQueryWrapper); + List<AnnouncementVo> announcementVoList = announcementPageParamList.getRecords().stream().map( + a -> { + AnnouncementVo announcementVo = new AnnouncementVo(); + BeanUtils.copyProperties(a, announcementVo); + announcementVo.setCreateName(userDao.selectOne(new QueryWrapper<User>().eq("id", a.getCreator())).getRealName()); + return announcementVo; + } + ).collect(Collectors.toList()); + PageParam<AnnouncementVo> announcementVoPageParam = new PageParam<>(); + BeanUtils.copyProperties(announcementPageParamList, announcementVoPageParam); + announcementVoPageParam.setRecords(announcementVoList); + return announcementVoPageParam; + } + + @Override + public Integer updateStatus(Integer id) { + return announcementDao.update(new Announcement().setStatus(1), new UpdateWrapper<Announcement>().eq("id", id)); + } + + @Override + public Integer updateStatusUnshelve(Integer id) { + return announcementDao.update(new Announcement().setStatus(2), new UpdateWrapper<Announcement>().eq("id", id)); + } + + @Override + public Integer add(Integer groupId, Announcement announcement) { + announcement.setStatus(0); + announcement.setCtime(new Date()); + announcement.setGroupId(groupId); + return announcementDao.insert(announcement); + } } -- Gitblit v1.8.0