package com.tievd.cube.modules.system.controller;
|
|
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.collection.ListUtil;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.text.NamingCase;
|
import cn.hutool.core.util.StrUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.tievd.cube.commons.constant.CommonConst;
|
import com.tievd.cube.commons.base.CubeController;
|
import com.tievd.cube.commons.mybatisplus.QueryGenerator;
|
import com.tievd.cube.commons.annotations.AutoLog;
|
import com.tievd.cube.commons.annotations.DictMethod;
|
import com.tievd.cube.commons.base.Result;
|
import com.tievd.cube.commons.utils.SystemContextUtil;
|
import com.tievd.cube.commons.utils.web.HttpServletUtil;
|
import com.tievd.cube.modules.system.entity.SysAnnouncement;
|
import com.tievd.cube.modules.system.model.api.request.AddAnnouncementRequest;
|
import com.tievd.cube.modules.system.model.api.request.ListAnnouncementRequest;
|
import com.tievd.cube.modules.system.model.api.request.UpdateAnnouncementRequest;
|
import com.tievd.cube.modules.system.model.api.response.AnnouncementListByUserResponse;
|
import com.tievd.cube.modules.system.service.ISysAnnouncementService;
|
import io.swagger.v3.oas.annotations.Operation;
|
import io.swagger.v3.oas.annotations.Parameter;
|
import io.swagger.v3.oas.annotations.Parameters;
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.IOException;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* 系统通告
|
*
|
* @author 杨欣武
|
* @version 2.5.3
|
* @since 2022-08-12
|
*/
|
@Slf4j
|
@Tag(name = "系统通告相关接口")
|
@RestController
|
@RequestMapping("/sys/announcement")
|
public class SysAnnouncementController extends CubeController<SysAnnouncement, ISysAnnouncementService> {
|
|
/**
|
* 分页列表查询
|
*/
|
@DictMethod
|
@GetMapping("/list")
|
@Operation(summary = "分页列表查询")
|
@Parameters({@Parameter(name = "title", description = "标题"),
|
@Parameter(name = "sender", description = "发送人"),
|
@Parameter(name = "priority", description = "优先级"),
|
@Parameter(name = "msgCategory", description = "消息分类"),
|
@Parameter(name = "msgType", description = "消息类型"),
|
@Parameter(name = "sendStatus", description = "发送状态"),
|
@Parameter(name = "pageNo", description = "页数"),
|
@Parameter(name = "pageSize", description = "每页数量"),
|
@Parameter(name = "column", description = "排序字段"),
|
@Parameter(name = "order", description = "排序方式")
|
})
|
public Result<IPage<SysAnnouncement>> queryPageList(@Parameter(hidden = true) @Validated ListAnnouncementRequest request) {
|
SysAnnouncement announcement = new SysAnnouncement();
|
announcement.setDelFlag(CommonConst.NOT_DELETED);
|
BeanUtil.copyProperties(request, announcement);
|
QueryWrapper<SysAnnouncement> queryWrapper = new QueryWrapper<>(announcement);
|
Page<SysAnnouncement> page = new Page<>(request.getPageNo(), request.getPageSize());
|
String column = request.getColumn();
|
String order = request.getOrder();
|
if (StrUtil.isNotEmpty(column)) {
|
String orderBy = NamingCase.toUnderlineCase(column).toLowerCase();
|
if ("asc".equals(order)) {
|
queryWrapper.orderByAsc(orderBy);
|
} else {
|
queryWrapper.orderByDesc(orderBy);
|
}
|
}
|
IPage<SysAnnouncement> pageList = service.page(page, queryWrapper);
|
return Result.ok(pageList);
|
}
|
|
/**
|
* 新增
|
*/
|
@AutoLog("系统通告-新增")
|
@PostMapping("/add")
|
@Operation(summary = "新增")
|
public Result<?> add(@RequestBody AddAnnouncementRequest request) {
|
SysAnnouncement announcement = new SysAnnouncement();
|
BeanUtil.copyProperties(request, announcement);
|
announcement.setSendStatus(CommonConst.NO_SEND);
|
service.saveAnnouncement(announcement);
|
return Result.ok();
|
}
|
|
/**
|
* 更新
|
*/
|
@AutoLog("系统通告-更新")
|
@PutMapping("/edit")
|
@Operation(summary = "更新")
|
public Result<?> edit(@Validated @RequestBody UpdateAnnouncementRequest request) {
|
SysAnnouncement announcement = new SysAnnouncement();
|
BeanUtil.copyProperties(request, announcement);
|
service.updateAnnouncement(announcement);
|
return Result.ok();
|
}
|
|
/**
|
* 通过id删除
|
*
|
* @param id 通告id
|
*/
|
@AutoLog("系统通告-通过id删除")
|
@DeleteMapping("/delete")
|
@Operation(summary = "通过id删除")
|
public Result<?> delete(@RequestParam String id) {
|
service.removeById(id);
|
return Result.ok();
|
}
|
|
/**
|
* 批量删除
|
*
|
* @param ids 通告id（多个逗号分隔）
|
*/
|
@AutoLog("系统通告-批量删除")
|
@DeleteMapping("/deleteBatch")
|
@Operation(summary = "批量删除")
|
public Result<?> deleteBatch(@Parameter(description = "通告id（多个逗号分隔）") @RequestParam String ids) {
|
service.removeBatchByIds(ListUtil.of(ids.split(",")));
|
return Result.ok();
|
}
|
|
/**
|
* 通过id查询
|
*
|
* @param id 通告id
|
*/
|
@DictMethod
|
@GetMapping("/queryById")
|
@Operation(summary = "通过id查询")
|
public Result<SysAnnouncement> queryById(@RequestParam String id) {
|
SysAnnouncement sysAnnouncement = service.getById(id);
|
if (sysAnnouncement == null) {
|
return Result.error("未找到对应数据！");
|
}
|
return Result.ok(sysAnnouncement);
|
}
|
|
/**
|
* 发布通告
|
*
|
* @param id 通告id
|
*/
|
@AutoLog("系统通告-发布通告")
|
@GetMapping("/doReleaseData")
|
@Operation(summary = "发布通告")
|
public Result<?> doReleaseData(@RequestParam Long id) {
|
service.release(id);
|
return Result.ok();
|
}
|
|
/**
|
* 撤回通告
|
*
|
* @param id 通告id
|
*/
|
@AutoLog("系统通告-撤回通告")
|
@GetMapping("/doRevokeData")
|
@Operation(summary = "撤回通告")
|
public Result<?> doRevokeData(@RequestParam Long id) {
|
service.revoke(id);
|
return Result.ok();
|
}
|
|
/**
|
* 查询用户数据并返回系统消息
|
*/
|
@GetMapping("/listByUser")
|
@Operation(summary = "查询用户数据并返回系统消息")
|
public Result<AnnouncementListByUserResponse> listByUser() {
|
AnnouncementListByUserResponse response = service.listByUser();
|
return Result.ok(response);
|
}
|
|
/**
|
* 同步消息
|
*
|
* @param anntId 通告id
|
*/
|
@AutoLog("系统通告-同步消息")
|
@GetMapping("/syncNotice")
|
@Operation(summary = "同步消息")
|
public Result<?> syncNotice(@RequestParam(required = false) Long anntId) {
|
service.syncNotice(anntId);
|
return Result.ok();
|
}
|
|
/**
|
* 导出系统通告为Excel
|
*
|
* @param sysAnnouncement 查询参数
|
*/
|
@GetMapping("/exportXls")
|
@Operation(summary = "导出系统通告为Excel")
|
public void exportXls(SysAnnouncement sysAnnouncement, HttpServletRequest request, HttpServletResponse response) throws IOException {
|
// Step.1 组装查询条件
|
QueryWrapper<SysAnnouncement> queryWrapper = QueryGenerator.initQueryWrapper(sysAnnouncement, request.getParameterMap());
|
List<SysAnnouncement> sysAnnouncements = service.list(queryWrapper);
|
//导出文件名称
|
String date = DateUtil.format(new Date(), "yyyyMMddHHmmss");
|
HttpServletUtil.addDownloadHeader(response, "系统通告-" + date + easyExcel.getExtension());
|
easyExcel.export(sysAnnouncements, response.getOutputStream(), SystemContextUtil.dictTranslator());
|
}
|
}
|
