芋道源码
3 years ago
committed by
Gitee
commit
8684468f50
@ -0,0 +1,30 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.api.notify;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.module.system.api.notify.dto.NotifySendSingleToUserReqDTO;
|
||||||
|
|
||||||
|
import javax.validation.Valid;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 站内信发送 API 接口
|
||||||
|
*
|
||||||
|
* @author xrcoder
|
||||||
|
*/
|
||||||
|
public interface NotifyMessageSendApi {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 发送单条站内信给 Admin 用户
|
||||||
|
*
|
||||||
|
* @param reqDTO 发送请求
|
||||||
|
* @return 发送消息 ID
|
||||||
|
*/
|
||||||
|
Long sendSingleMessageToAdmin(@Valid NotifySendSingleToUserReqDTO reqDTO);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 发送单条站内信给 Member 用户
|
||||||
|
*
|
||||||
|
* @param reqDTO 发送请求
|
||||||
|
* @return 发送消息 ID
|
||||||
|
*/
|
||||||
|
Long sendSingleMessageToMember(@Valid NotifySendSingleToUserReqDTO reqDTO);
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,33 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.api.notify.dto;
|
||||||
|
|
||||||
|
import lombok.Data;
|
||||||
|
|
||||||
|
import javax.validation.constraints.NotEmpty;
|
||||||
|
import javax.validation.constraints.NotNull;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 站内信发送给 Admin 或者 Member 用户
|
||||||
|
*
|
||||||
|
* @author xrcoder
|
||||||
|
*/
|
||||||
|
@Data
|
||||||
|
public class NotifySendSingleToUserReqDTO {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 用户编号
|
||||||
|
*/
|
||||||
|
@NotNull(message = "用户编号不能为空")
|
||||||
|
private Long userId;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 站内信模板编号
|
||||||
|
*/
|
||||||
|
@NotEmpty(message = "站内信模板编号不能为空")
|
||||||
|
private String templateCode;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 站内信模板参数
|
||||||
|
*/
|
||||||
|
private Map<String, Object> templateParams;
|
||||||
|
}
|
||||||
@ -0,0 +1,33 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.api.notify;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.module.system.api.notify.dto.NotifySendSingleToUserReqDTO;
|
||||||
|
import cn.iocoder.yudao.module.system.service.notify.NotifyMessageService;
|
||||||
|
import cn.iocoder.yudao.module.system.service.notify.NotifySendService;
|
||||||
|
import org.springframework.stereotype.Service;
|
||||||
|
|
||||||
|
import javax.annotation.Resource;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 站内信发送 API 实现类
|
||||||
|
*
|
||||||
|
* @author xrcoder
|
||||||
|
*/
|
||||||
|
@Service
|
||||||
|
public class NotifyMessageSendApiImpl implements NotifyMessageSendApi {
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private NotifySendService notifySendService;
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Long sendSingleMessageToAdmin(NotifySendSingleToUserReqDTO reqDTO) {
|
||||||
|
return notifySendService.sendSingleNotifyToAdmin(reqDTO.getUserId(),
|
||||||
|
reqDTO.getTemplateCode(), reqDTO.getTemplateParams());
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Long sendSingleMessageToMember(NotifySendSingleToUserReqDTO reqDTO) {
|
||||||
|
return notifySendService.sendSingleNotifyToMember(reqDTO.getUserId(),
|
||||||
|
reqDTO.getTemplateCode(), reqDTO.getTemplateParams());
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,95 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.controller.admin.notify;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.framework.common.enums.UserTypeEnum;
|
||||||
|
import cn.iocoder.yudao.framework.common.pojo.CommonResult;
|
||||||
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.message.NotifyMessageMyPageReqVO;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.message.NotifyMessagePageReqVO;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.message.NotifyMessageRespVO;
|
||||||
|
import cn.iocoder.yudao.module.system.convert.notify.NotifyMessageConvert;
|
||||||
|
import cn.iocoder.yudao.module.system.dal.dataobject.notify.NotifyMessageDO;
|
||||||
|
import cn.iocoder.yudao.module.system.service.notify.NotifyMessageService;
|
||||||
|
import io.swagger.annotations.Api;
|
||||||
|
import io.swagger.annotations.ApiImplicitParam;
|
||||||
|
import io.swagger.annotations.ApiOperation;
|
||||||
|
import org.springframework.security.access.prepost.PreAuthorize;
|
||||||
|
import org.springframework.validation.annotation.Validated;
|
||||||
|
import org.springframework.web.bind.annotation.*;
|
||||||
|
|
||||||
|
import javax.annotation.Resource;
|
||||||
|
import javax.validation.Valid;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
|
||||||
|
import static cn.iocoder.yudao.framework.security.core.util.SecurityFrameworkUtils.getLoginUserId;
|
||||||
|
|
||||||
|
@Api(tags = "管理后台 - 我的站内信")
|
||||||
|
@RestController
|
||||||
|
@RequestMapping("/system/notify-message")
|
||||||
|
@Validated
|
||||||
|
public class NotifyMessageController {
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private NotifyMessageService notifyMessageService;
|
||||||
|
|
||||||
|
// ========== 管理所有的站内信 ==========
|
||||||
|
|
||||||
|
@GetMapping("/get")
|
||||||
|
@ApiOperation("获得站内信")
|
||||||
|
@ApiImplicitParam(name = "id", value = "编号", required = true, example = "1024", dataTypeClass = Long.class)
|
||||||
|
@PreAuthorize("@ss.hasPermission('system:notify-message:query')")
|
||||||
|
public CommonResult<NotifyMessageRespVO> getNotifyMessage(@RequestParam("id") Long id) {
|
||||||
|
NotifyMessageDO notifyMessage = notifyMessageService.getNotifyMessage(id);
|
||||||
|
return success(NotifyMessageConvert.INSTANCE.convert(notifyMessage));
|
||||||
|
}
|
||||||
|
|
||||||
|
@GetMapping("/page")
|
||||||
|
@ApiOperation("获得站内信分页")
|
||||||
|
@PreAuthorize("@ss.hasPermission('system:notify-message:query')")
|
||||||
|
public CommonResult<PageResult<NotifyMessageRespVO>> getNotifyMessagePage(@Valid NotifyMessagePageReqVO pageVO) {
|
||||||
|
PageResult<NotifyMessageDO> pageResult = notifyMessageService.getNotifyMessagePage(pageVO);
|
||||||
|
return success(NotifyMessageConvert.INSTANCE.convertPage(pageResult));
|
||||||
|
}
|
||||||
|
|
||||||
|
// ========== 查看自己的站内信 ==========
|
||||||
|
|
||||||
|
@GetMapping("/my-page")
|
||||||
|
@ApiOperation("获得我的站内信分页")
|
||||||
|
public CommonResult<PageResult<NotifyMessageRespVO>> getMyMyNotifyMessagePage(@Valid NotifyMessageMyPageReqVO pageVO) {
|
||||||
|
PageResult<NotifyMessageDO> pageResult = notifyMessageService.getMyMyNotifyMessagePage(pageVO,
|
||||||
|
getLoginUserId(), UserTypeEnum.ADMIN.getValue());
|
||||||
|
return success(NotifyMessageConvert.INSTANCE.convertPage(pageResult));
|
||||||
|
}
|
||||||
|
|
||||||
|
@PutMapping("/update-read")
|
||||||
|
@ApiOperation("标记站内信为已读")
|
||||||
|
@ApiImplicitParam(name = "ids", value = "编号列表", required = true, example = "1024,2048", dataTypeClass = List.class)
|
||||||
|
public CommonResult<Boolean> updateNotifyMessageRead(@RequestParam("ids") List<Long> ids) {
|
||||||
|
notifyMessageService.updateNotifyMessageRead(ids, getLoginUserId(), UserTypeEnum.ADMIN.getValue());
|
||||||
|
return success(Boolean.TRUE);
|
||||||
|
}
|
||||||
|
|
||||||
|
@PutMapping("/update-all-read")
|
||||||
|
@ApiOperation("标记所有站内信为已读")
|
||||||
|
public CommonResult<Boolean> updateAllNotifyMessageRead() {
|
||||||
|
notifyMessageService.updateAllNotifyMessageRead(getLoginUserId(), UserTypeEnum.ADMIN.getValue());
|
||||||
|
return success(Boolean.TRUE);
|
||||||
|
}
|
||||||
|
|
||||||
|
@GetMapping("/get-unread-list")
|
||||||
|
@ApiOperation("获取当前用户的最新站内信列表，默认 10 条")
|
||||||
|
@ApiImplicitParam(name = "size", value = "10", defaultValue = "10", dataTypeClass = Integer.class)
|
||||||
|
public CommonResult<List<NotifyMessageRespVO>> getUnreadNotifyMessageList(
|
||||||
|
@RequestParam(name = "size", defaultValue = "10") Integer size) {
|
||||||
|
List<NotifyMessageDO> list = notifyMessageService.getUnreadNotifyMessageList(
|
||||||
|
getLoginUserId(), UserTypeEnum.ADMIN.getValue(), size);
|
||||||
|
return success(NotifyMessageConvert.INSTANCE.convertList(list));
|
||||||
|
}
|
||||||
|
|
||||||
|
@GetMapping("/get-unread-count")
|
||||||
|
@ApiOperation("获得当前用户的未读站内信数量")
|
||||||
|
public CommonResult<Long> getUnreadNotifyMessageCount() {
|
||||||
|
return success(notifyMessageService.getUnreadNotifyMessageCount(getLoginUserId(), UserTypeEnum.ADMIN.getValue()));
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,83 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.controller.admin.notify;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.framework.common.pojo.CommonResult;
|
||||||
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.template.*;
|
||||||
|
import cn.iocoder.yudao.module.system.convert.notify.NotifyTemplateConvert;
|
||||||
|
import cn.iocoder.yudao.module.system.dal.dataobject.notify.NotifyTemplateDO;
|
||||||
|
import cn.iocoder.yudao.module.system.service.notify.NotifySendService;
|
||||||
|
import cn.iocoder.yudao.module.system.service.notify.NotifyTemplateService;
|
||||||
|
import io.swagger.annotations.Api;
|
||||||
|
import io.swagger.annotations.ApiImplicitParam;
|
||||||
|
import io.swagger.annotations.ApiOperation;
|
||||||
|
import org.springframework.security.access.prepost.PreAuthorize;
|
||||||
|
import org.springframework.validation.annotation.Validated;
|
||||||
|
import org.springframework.web.bind.annotation.*;
|
||||||
|
|
||||||
|
import javax.annotation.Resource;
|
||||||
|
import javax.validation.Valid;
|
||||||
|
|
||||||
|
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
|
||||||
|
|
||||||
|
@Api(tags = "管理后台 - 站内信模版")
|
||||||
|
@RestController
|
||||||
|
@RequestMapping("/system/notify-template")
|
||||||
|
@Validated
|
||||||
|
public class NotifyTemplateController {
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private NotifyTemplateService notifyTemplateService;
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private NotifySendService notifySendService;
|
||||||
|
|
||||||
|
@PostMapping("/create")
|
||||||
|
@ApiOperation("创建站内信模版")
|
||||||
|
@PreAuthorize("@ss.hasPermission('system:notify-template:create')")
|
||||||
|
public CommonResult<Long> createNotifyTemplate(@Valid @RequestBody NotifyTemplateCreateReqVO createReqVO) {
|
||||||
|
return success(notifyTemplateService.createNotifyTemplate(createReqVO));
|
||||||
|
}
|
||||||
|
|
||||||
|
@PutMapping("/update")
|
||||||
|
@ApiOperation("更新站内信模版")
|
||||||
|
@PreAuthorize("@ss.hasPermission('system:notify-template:update')")
|
||||||
|
public CommonResult<Boolean> updateNotifyTemplate(@Valid @RequestBody NotifyTemplateUpdateReqVO updateReqVO) {
|
||||||
|
notifyTemplateService.updateNotifyTemplate(updateReqVO);
|
||||||
|
return success(true);
|
||||||
|
}
|
||||||
|
|
||||||
|
@DeleteMapping("/delete")
|
||||||
|
@ApiOperation("删除站内信模版")
|
||||||
|
@ApiImplicitParam(name = "id", value = "编号", required = true, dataTypeClass = Long.class)
|
||||||
|
@PreAuthorize("@ss.hasPermission('system:notify-template:delete')")
|
||||||
|
public CommonResult<Boolean> deleteNotifyTemplate(@RequestParam("id") Long id) {
|
||||||
|
notifyTemplateService.deleteNotifyTemplate(id);
|
||||||
|
return success(true);
|
||||||
|
}
|
||||||
|
|
||||||
|
@GetMapping("/get")
|
||||||
|
@ApiOperation("获得站内信模版")
|
||||||
|
@ApiImplicitParam(name = "id", value = "编号", required = true, example = "1024", dataTypeClass = Long.class)
|
||||||
|
@PreAuthorize("@ss.hasPermission('system:notify-template:query')")
|
||||||
|
public CommonResult<NotifyTemplateRespVO> getNotifyTemplate(@RequestParam("id") Long id) {
|
||||||
|
NotifyTemplateDO notifyTemplate = notifyTemplateService.getNotifyTemplate(id);
|
||||||
|
return success(NotifyTemplateConvert.INSTANCE.convert(notifyTemplate));
|
||||||
|
}
|
||||||
|
|
||||||
|
@GetMapping("/page")
|
||||||
|
@ApiOperation("获得站内信模版分页")
|
||||||
|
@PreAuthorize("@ss.hasPermission('system:notify-template:query')")
|
||||||
|
public CommonResult<PageResult<NotifyTemplateRespVO>> getNotifyTemplatePage(@Valid NotifyTemplatePageReqVO pageVO) {
|
||||||
|
PageResult<NotifyTemplateDO> pageResult = notifyTemplateService.getNotifyTemplatePage(pageVO);
|
||||||
|
return success(NotifyTemplateConvert.INSTANCE.convertPage(pageResult));
|
||||||
|
}
|
||||||
|
|
||||||
|
@PostMapping("/send-notify")
|
||||||
|
@ApiOperation("发送站内信")
|
||||||
|
@PreAuthorize("@ss.hasPermission('system:notify-template:send-notify')")
|
||||||
|
public CommonResult<Long> sendNotify(@Valid @RequestBody NotifyTemplateSendReqVO sendReqVO) {
|
||||||
|
return success(notifySendService.sendSingleNotifyToAdmin(sendReqVO.getUserId(),
|
||||||
|
sendReqVO.getTemplateCode(), sendReqVO.getTemplateParams()));
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,28 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.controller.admin.notify.vo.message;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.framework.common.pojo.PageParam;
|
||||||
|
import io.swagger.annotations.ApiModel;
|
||||||
|
import io.swagger.annotations.ApiModelProperty;
|
||||||
|
import lombok.Data;
|
||||||
|
import lombok.EqualsAndHashCode;
|
||||||
|
import lombok.ToString;
|
||||||
|
import org.springframework.format.annotation.DateTimeFormat;
|
||||||
|
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
|
||||||
|
import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND;
|
||||||
|
|
||||||
|
@ApiModel("管理后台 - 站内信分页 Request VO")
|
||||||
|
@Data
|
||||||
|
@EqualsAndHashCode(callSuper = true)
|
||||||
|
@ToString(callSuper = true)
|
||||||
|
public class NotifyMessageMyPageReqVO extends PageParam {
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "是否已读", example = "true")
|
||||||
|
private Boolean readStatus;
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "创建时间")
|
||||||
|
@DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
|
||||||
|
private LocalDateTime[] createTime;
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,38 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.controller.admin.notify.vo.message;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.framework.common.pojo.PageParam;
|
||||||
|
import io.swagger.annotations.ApiModel;
|
||||||
|
import io.swagger.annotations.ApiModelProperty;
|
||||||
|
import lombok.Data;
|
||||||
|
import lombok.EqualsAndHashCode;
|
||||||
|
import lombok.ToString;
|
||||||
|
import org.springframework.format.annotation.DateTimeFormat;
|
||||||
|
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
import java.util.Date;
|
||||||
|
|
||||||
|
import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND;
|
||||||
|
|
||||||
|
@ApiModel("管理后台 - 站内信分页 Request VO")
|
||||||
|
@Data
|
||||||
|
@EqualsAndHashCode(callSuper = true)
|
||||||
|
@ToString(callSuper = true)
|
||||||
|
public class NotifyMessagePageReqVO extends PageParam {
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "用户编号", example = "25025")
|
||||||
|
private Long userId;
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "用户类型", example = "1")
|
||||||
|
private Integer userType;
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "模板编码", example = "test_01")
|
||||||
|
private String templateCode;
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "模版类型", example = "2")
|
||||||
|
private Integer templateType;
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "创建时间")
|
||||||
|
@DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
|
||||||
|
private LocalDateTime[] createTime;
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,19 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.controller.admin.notify.vo.message;
|
||||||
|
|
||||||
|
import lombok.*;
|
||||||
|
import java.util.*;
|
||||||
|
import io.swagger.annotations.*;
|
||||||
|
|
||||||
|
@ApiModel("管理后台 - 站内信 Response VO")
|
||||||
|
@Data
|
||||||
|
@EqualsAndHashCode(callSuper = true)
|
||||||
|
@ToString(callSuper = true)
|
||||||
|
public class NotifyMessageRespVO extends NotifyMessageBaseVO {
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "ID", required = true, example = "1024")
|
||||||
|
private Long id;
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "创建时间", required = true)
|
||||||
|
private Date createTime;
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,11 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.controller.admin.notify.vo.template;
|
||||||
|
|
||||||
|
import lombok.*;
|
||||||
|
import io.swagger.annotations.*;
|
||||||
|
|
||||||
|
@ApiModel("管理后台 - 站内信模版创建 Request VO")
|
||||||
|
@Data
|
||||||
|
@EqualsAndHashCode(callSuper = true)
|
||||||
|
@ToString(callSuper = true)
|
||||||
|
public class NotifyTemplateCreateReqVO extends NotifyTemplateBaseVO {
|
||||||
|
}
|
||||||
@ -0,0 +1,33 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.controller.admin.notify.vo.template;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.framework.common.util.date.LocalDateTimeUtils;
|
||||||
|
import lombok.*;
|
||||||
|
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
import java.util.*;
|
||||||
|
import io.swagger.annotations.*;
|
||||||
|
import cn.iocoder.yudao.framework.common.pojo.PageParam;
|
||||||
|
import org.springframework.format.annotation.DateTimeFormat;
|
||||||
|
|
||||||
|
import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND;
|
||||||
|
|
||||||
|
@ApiModel("管理后台 - 站内信模版分页 Request VO")
|
||||||
|
@Data
|
||||||
|
@EqualsAndHashCode(callSuper = true)
|
||||||
|
@ToString(callSuper = true)
|
||||||
|
public class NotifyTemplatePageReqVO extends PageParam {
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "模版编码", example = "test_01")
|
||||||
|
private String code;
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "模版名称", example = "我是名称")
|
||||||
|
private String name;
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "状态", example = "1", notes = "参见 CommonStatusEnum 枚举类")
|
||||||
|
private Integer status;
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "创建时间")
|
||||||
|
@DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
|
||||||
|
private LocalDateTime[] createTime;
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,22 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.controller.admin.notify.vo.template;
|
||||||
|
|
||||||
|
import lombok.*;
|
||||||
|
import java.util.*;
|
||||||
|
import io.swagger.annotations.*;
|
||||||
|
|
||||||
|
@ApiModel("管理后台 - 站内信模版 Response VO")
|
||||||
|
@Data
|
||||||
|
@EqualsAndHashCode(callSuper = true)
|
||||||
|
@ToString(callSuper = true)
|
||||||
|
public class NotifyTemplateRespVO extends NotifyTemplateBaseVO {
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "ID", required = true, example = "1024")
|
||||||
|
private Long id;
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "参数数组", example = "name,code")
|
||||||
|
private List<String> params;
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "创建时间", required = true)
|
||||||
|
private Date createTime;
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,25 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.controller.admin.notify.vo.template;
|
||||||
|
|
||||||
|
import io.swagger.annotations.ApiModel;
|
||||||
|
import io.swagger.annotations.ApiModelProperty;
|
||||||
|
import lombok.Data;
|
||||||
|
|
||||||
|
import javax.validation.constraints.NotEmpty;
|
||||||
|
import javax.validation.constraints.NotNull;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
|
@ApiModel("管理后台 - 站内信模板的发送 Request VO")
|
||||||
|
@Data
|
||||||
|
public class NotifyTemplateSendReqVO {
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "用户id", required = true, example = "01")
|
||||||
|
@NotNull(message = "用户id不能为空")
|
||||||
|
private Long userId;
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "模板编码", required = true, example = "01")
|
||||||
|
@NotEmpty(message = "模板编码不能为空")
|
||||||
|
private String templateCode;
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "模板参数")
|
||||||
|
private Map<String, Object> templateParams;
|
||||||
|
}
|
||||||
@ -0,0 +1,17 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.controller.admin.notify.vo.template;
|
||||||
|
|
||||||
|
import lombok.*;
|
||||||
|
import io.swagger.annotations.*;
|
||||||
|
import javax.validation.constraints.*;
|
||||||
|
|
||||||
|
@ApiModel("管理后台 - 站内信模版更新 Request VO")
|
||||||
|
@Data
|
||||||
|
@EqualsAndHashCode(callSuper = true)
|
||||||
|
@ToString(callSuper = true)
|
||||||
|
public class NotifyTemplateUpdateReqVO extends NotifyTemplateBaseVO {
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "ID", required = true, example = "1024")
|
||||||
|
@NotNull(message = "ID 不能为空")
|
||||||
|
private Long id;
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,28 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.convert.notify;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.message.NotifyMessageRespVO;
|
||||||
|
import cn.iocoder.yudao.module.system.dal.dataobject.notify.NotifyMessageDO;
|
||||||
|
import org.mapstruct.Mapper;
|
||||||
|
import org.mapstruct.factory.Mappers;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 站内信 Convert
|
||||||
|
*
|
||||||
|
* @author xrcoder
|
||||||
|
*/
|
||||||
|
@Mapper
|
||||||
|
public interface NotifyMessageConvert {
|
||||||
|
|
||||||
|
NotifyMessageConvert INSTANCE = Mappers.getMapper(NotifyMessageConvert.class);
|
||||||
|
|
||||||
|
NotifyMessageRespVO convert(NotifyMessageDO bean);
|
||||||
|
|
||||||
|
List<NotifyMessageRespVO> convertList(List<NotifyMessageDO> list);
|
||||||
|
|
||||||
|
PageResult<NotifyMessageRespVO> convertPage(PageResult<NotifyMessageDO> page);
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,34 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.convert.notify;
|
||||||
|
|
||||||
|
import java.util.*;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.template.NotifyTemplateCreateReqVO;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.template.NotifyTemplateRespVO;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.template.NotifyTemplateUpdateReqVO;
|
||||||
|
import org.mapstruct.Mapper;
|
||||||
|
import org.mapstruct.factory.Mappers;
|
||||||
|
import cn.iocoder.yudao.module.system.dal.dataobject.notify.NotifyTemplateDO;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 站内信模版 Convert
|
||||||
|
*
|
||||||
|
* @author xrcoder
|
||||||
|
*/
|
||||||
|
@Mapper
|
||||||
|
public interface NotifyTemplateConvert {
|
||||||
|
|
||||||
|
NotifyTemplateConvert INSTANCE = Mappers.getMapper(NotifyTemplateConvert.class);
|
||||||
|
|
||||||
|
NotifyTemplateDO convert(NotifyTemplateCreateReqVO bean);
|
||||||
|
|
||||||
|
NotifyTemplateDO convert(NotifyTemplateUpdateReqVO bean);
|
||||||
|
|
||||||
|
NotifyTemplateRespVO convert(NotifyTemplateDO bean);
|
||||||
|
|
||||||
|
List<NotifyTemplateRespVO> convertList(List<NotifyTemplateDO> list);
|
||||||
|
|
||||||
|
PageResult<NotifyTemplateRespVO> convertPage(PageResult<NotifyTemplateDO> page);
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,72 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.dal.dataobject.notify;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
|
||||||
|
import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
|
||||||
|
import com.baomidou.mybatisplus.annotation.KeySequence;
|
||||||
|
import com.baomidou.mybatisplus.annotation.TableField;
|
||||||
|
import com.baomidou.mybatisplus.annotation.TableId;
|
||||||
|
import com.baomidou.mybatisplus.annotation.TableName;
|
||||||
|
import com.baomidou.mybatisplus.extension.handlers.JacksonTypeHandler;
|
||||||
|
import lombok.*;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 站内信模版 DO
|
||||||
|
*
|
||||||
|
* @author xrcoder
|
||||||
|
*/
|
||||||
|
@TableName(value = "system_notify_template", autoResultMap = true)
|
||||||
|
@KeySequence("system_notify_template_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库，可不写。
|
||||||
|
@Data
|
||||||
|
@EqualsAndHashCode(callSuper = true)
|
||||||
|
@ToString(callSuper = true)
|
||||||
|
@Builder
|
||||||
|
@NoArgsConstructor
|
||||||
|
@AllArgsConstructor
|
||||||
|
public class NotifyTemplateDO extends BaseDO {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* ID
|
||||||
|
*/
|
||||||
|
@TableId
|
||||||
|
private Long id;
|
||||||
|
/**
|
||||||
|
* 模版名称
|
||||||
|
*/
|
||||||
|
private String name;
|
||||||
|
/**
|
||||||
|
* 模版编码
|
||||||
|
*/
|
||||||
|
private String code;
|
||||||
|
/**
|
||||||
|
* 模版类型
|
||||||
|
*
|
||||||
|
* 对应 system_notify_template_type 字典
|
||||||
|
*/
|
||||||
|
private Integer type;
|
||||||
|
/**
|
||||||
|
* 发送人名称
|
||||||
|
*/
|
||||||
|
private String nickname;
|
||||||
|
/**
|
||||||
|
* 模版内容
|
||||||
|
*/
|
||||||
|
private String content;
|
||||||
|
/**
|
||||||
|
* 参数数组
|
||||||
|
*/
|
||||||
|
@TableField(typeHandler = JacksonTypeHandler.class)
|
||||||
|
private List<String> params;
|
||||||
|
/**
|
||||||
|
* 状态
|
||||||
|
*
|
||||||
|
* 枚举 {@link CommonStatusEnum}
|
||||||
|
*/
|
||||||
|
private Integer status;
|
||||||
|
/**
|
||||||
|
* 备注
|
||||||
|
*/
|
||||||
|
private String remark;
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,70 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.dal.mysql.notify;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
||||||
|
import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
|
||||||
|
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
|
||||||
|
import cn.iocoder.yudao.framework.mybatis.core.query.QueryWrapperX;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.message.NotifyMessageMyPageReqVO;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.message.NotifyMessagePageReqVO;
|
||||||
|
import cn.iocoder.yudao.module.system.dal.dataobject.notify.NotifyMessageDO;
|
||||||
|
import org.apache.ibatis.annotations.Mapper;
|
||||||
|
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
import java.util.Collection;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
@Mapper
|
||||||
|
public interface NotifyMessageMapper extends BaseMapperX<NotifyMessageDO> {
|
||||||
|
|
||||||
|
default PageResult<NotifyMessageDO> selectPage(NotifyMessagePageReqVO reqVO) {
|
||||||
|
return selectPage(reqVO, new LambdaQueryWrapperX<NotifyMessageDO>()
|
||||||
|
.eqIfPresent(NotifyMessageDO::getUserId, reqVO.getUserId())
|
||||||
|
.eqIfPresent(NotifyMessageDO::getUserType, reqVO.getUserType())
|
||||||
|
.likeIfPresent(NotifyMessageDO::getTemplateCode, reqVO.getTemplateCode())
|
||||||
|
.eqIfPresent(NotifyMessageDO::getTemplateType, reqVO.getTemplateType())
|
||||||
|
.betweenIfPresent(NotifyMessageDO::getCreateTime, reqVO.getCreateTime())
|
||||||
|
.orderByDesc(NotifyMessageDO::getId));
|
||||||
|
}
|
||||||
|
|
||||||
|
default PageResult<NotifyMessageDO> selectPage(NotifyMessageMyPageReqVO reqVO, Long userId, Integer userType) {
|
||||||
|
return selectPage(reqVO, new LambdaQueryWrapperX<NotifyMessageDO>()
|
||||||
|
.eqIfPresent(NotifyMessageDO::getReadStatus, reqVO.getReadStatus())
|
||||||
|
.betweenIfPresent(NotifyMessageDO::getCreateTime, reqVO.getCreateTime())
|
||||||
|
.eq(NotifyMessageDO::getUserId, userId)
|
||||||
|
.eq(NotifyMessageDO::getUserType, userType)
|
||||||
|
.orderByDesc(NotifyMessageDO::getId));
|
||||||
|
}
|
||||||
|
|
||||||
|
default int updateListRead(Collection<Long> ids, Long userId, Integer userType) {
|
||||||
|
return update(new NotifyMessageDO().setReadStatus(true).setReadTime(LocalDateTime.now()),
|
||||||
|
new LambdaQueryWrapperX<NotifyMessageDO>()
|
||||||
|
.in(NotifyMessageDO::getId, ids)
|
||||||
|
.eq(NotifyMessageDO::getUserId, userId)
|
||||||
|
.eq(NotifyMessageDO::getUserType, userType)
|
||||||
|
.eq(NotifyMessageDO::getReadStatus, false));
|
||||||
|
}
|
||||||
|
|
||||||
|
default int updateListRead(Long userId, Integer userType) {
|
||||||
|
return update(new NotifyMessageDO().setReadStatus(true).setReadTime(LocalDateTime.now()),
|
||||||
|
new LambdaQueryWrapperX<NotifyMessageDO>()
|
||||||
|
.eq(NotifyMessageDO::getUserId, userId)
|
||||||
|
.eq(NotifyMessageDO::getUserType, userType)
|
||||||
|
.eq(NotifyMessageDO::getReadStatus, false));
|
||||||
|
}
|
||||||
|
|
||||||
|
default List<NotifyMessageDO> selectUnreadListByUserIdAndUserType(Long userId, Integer userType, Integer size) {
|
||||||
|
return selectList(new QueryWrapperX<NotifyMessageDO>() // 由于要使用 limitN 语句，所以只能用 QueryWrapperX
|
||||||
|
.eq("user_id", userId)
|
||||||
|
.eq("user_type", userType)
|
||||||
|
.eq("read_status", false)
|
||||||
|
.orderByDesc("id").limitN(size));
|
||||||
|
}
|
||||||
|
|
||||||
|
default Long selectUnreadCountByUserIdAndUserType(Long userId, Integer userType) {
|
||||||
|
return selectCount(new LambdaQueryWrapperX<NotifyMessageDO>()
|
||||||
|
.eq(NotifyMessageDO::getReadStatus, false)
|
||||||
|
.eq(NotifyMessageDO::getUserId, userId)
|
||||||
|
.eq(NotifyMessageDO::getUserType, userType));
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,26 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.dal.mysql.notify;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
||||||
|
import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
|
||||||
|
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.template.NotifyTemplatePageReqVO;
|
||||||
|
import cn.iocoder.yudao.module.system.dal.dataobject.notify.NotifyTemplateDO;
|
||||||
|
import org.apache.ibatis.annotations.Mapper;
|
||||||
|
|
||||||
|
@Mapper
|
||||||
|
public interface NotifyTemplateMapper extends BaseMapperX<NotifyTemplateDO> {
|
||||||
|
|
||||||
|
default NotifyTemplateDO selectByCode(String code) {
|
||||||
|
return selectOne(NotifyTemplateDO::getCode, code);
|
||||||
|
}
|
||||||
|
|
||||||
|
default PageResult<NotifyTemplateDO> selectPage(NotifyTemplatePageReqVO reqVO) {
|
||||||
|
return selectPage(reqVO, new LambdaQueryWrapperX<NotifyTemplateDO>()
|
||||||
|
.likeIfPresent(NotifyTemplateDO::getCode, reqVO.getCode())
|
||||||
|
.likeIfPresent(NotifyTemplateDO::getName, reqVO.getName())
|
||||||
|
.eqIfPresent(NotifyTemplateDO::getStatus, reqVO.getStatus())
|
||||||
|
.betweenIfPresent(NotifyTemplateDO::getCreateTime, reqVO.getCreateTime())
|
||||||
|
.orderByDesc(NotifyTemplateDO::getId));
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,29 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.mq.consumer.notify;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.framework.mq.core.pubsub.AbstractChannelMessageListener;
|
||||||
|
import cn.iocoder.yudao.module.system.mq.message.notify.NotifyTemplateRefreshMessage;
|
||||||
|
import cn.iocoder.yudao.module.system.service.notify.NotifyTemplateService;
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
|
import javax.annotation.Resource;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 针对 {@link NotifyTemplateRefreshMessage} 的消费者
|
||||||
|
*
|
||||||
|
* @author xrcoder
|
||||||
|
*/
|
||||||
|
@Component
|
||||||
|
@Slf4j
|
||||||
|
public class NotifyTemplateRefreshConsumer extends AbstractChannelMessageListener<NotifyTemplateRefreshMessage> {
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private NotifyTemplateService notifyTemplateService;
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void onMessage(NotifyTemplateRefreshMessage message) {
|
||||||
|
log.info("[onMessage][收到 NotifyTemplate 刷新消息]");
|
||||||
|
notifyTemplateService.initLocalCache();
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,21 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.mq.message.notify;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.framework.mq.core.pubsub.AbstractChannelMessage;
|
||||||
|
import lombok.Data;
|
||||||
|
import lombok.EqualsAndHashCode;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 站内信模板的数据刷新 Message
|
||||||
|
*
|
||||||
|
* @author xrcoder
|
||||||
|
*/
|
||||||
|
@Data
|
||||||
|
@EqualsAndHashCode(callSuper = true)
|
||||||
|
public class NotifyTemplateRefreshMessage extends AbstractChannelMessage {
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public String getChannel() {
|
||||||
|
return "system.notify-template.refresh";
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,33 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.mq.producer.notify;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.framework.mq.core.RedisMQTemplate;
|
||||||
|
import cn.iocoder.yudao.module.system.mq.message.notify.NotifyTemplateRefreshMessage;
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
|
import javax.annotation.Resource;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Notify 站内信相关消息的 Producer
|
||||||
|
*
|
||||||
|
* @author xrcoder
|
||||||
|
* @since 2022-08-06
|
||||||
|
*/
|
||||||
|
@Slf4j
|
||||||
|
@Component
|
||||||
|
public class NotifyProducer {
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private RedisMQTemplate redisMQTemplate;
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 发送 {@link NotifyTemplateRefreshMessage} 消息
|
||||||
|
*/
|
||||||
|
public void sendNotifyTemplateRefreshMessage() {
|
||||||
|
NotifyTemplateRefreshMessage message = new NotifyTemplateRefreshMessage();
|
||||||
|
redisMQTemplate.send(message);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,97 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.service.notify;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.message.NotifyMessageMyPageReqVO;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.message.NotifyMessagePageReqVO;
|
||||||
|
import cn.iocoder.yudao.module.system.dal.dataobject.notify.NotifyMessageDO;
|
||||||
|
import cn.iocoder.yudao.module.system.dal.dataobject.notify.NotifyTemplateDO;
|
||||||
|
|
||||||
|
import java.util.Collection;
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 站内信 Service 接口
|
||||||
|
*
|
||||||
|
* @author xrcoder
|
||||||
|
*/
|
||||||
|
public interface NotifyMessageService {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 创建站内信
|
||||||
|
*
|
||||||
|
* @param userId 用户编号
|
||||||
|
* @param userType 用户类型
|
||||||
|
* @param template 模版信息
|
||||||
|
* @param templateContent 模版内容
|
||||||
|
* @param templateParams 模版参数
|
||||||
|
* @return 站内信编号
|
||||||
|
*/
|
||||||
|
Long createNotifyMessage(Long userId, Integer userType,
|
||||||
|
NotifyTemplateDO template, String templateContent, Map<String, Object> templateParams);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获得站内信分页
|
||||||
|
*
|
||||||
|
* @param pageReqVO 分页查询
|
||||||
|
* @return 站内信分页
|
||||||
|
*/
|
||||||
|
PageResult<NotifyMessageDO> getNotifyMessagePage(NotifyMessagePageReqVO pageReqVO);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获得【我的】站内信分页
|
||||||
|
*
|
||||||
|
* @param pageReqVO 分页查询
|
||||||
|
* @param userId 用户编号
|
||||||
|
* @param userType 用户类型
|
||||||
|
* @return 站内信分页
|
||||||
|
*/
|
||||||
|
PageResult<NotifyMessageDO> getMyMyNotifyMessagePage(NotifyMessageMyPageReqVO pageReqVO, Long userId, Integer userType);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获得站内信
|
||||||
|
*
|
||||||
|
* @param id 编号
|
||||||
|
* @return 站内信
|
||||||
|
*/
|
||||||
|
NotifyMessageDO getNotifyMessage(Long id);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获得【我的】未读站内信列表
|
||||||
|
*
|
||||||
|
* @param userId 用户编号
|
||||||
|
* @param userType 用户类型
|
||||||
|
* @param size 数量
|
||||||
|
* @return 站内信列表
|
||||||
|
*/
|
||||||
|
List<NotifyMessageDO> getUnreadNotifyMessageList(Long userId, Integer userType, Integer size);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 统计用户未读站内信条数
|
||||||
|
*
|
||||||
|
* @param userId 用户编号
|
||||||
|
* @param userType 用户类型
|
||||||
|
* @return 返回未读站内信条数
|
||||||
|
*/
|
||||||
|
Long getUnreadNotifyMessageCount(Long userId, Integer userType);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 标记站内信为已读
|
||||||
|
*
|
||||||
|
* @param ids 站内信编号集合
|
||||||
|
* @param userId 用户编号
|
||||||
|
* @param userType 用户类型
|
||||||
|
* @return 更新到的条数
|
||||||
|
*/
|
||||||
|
int updateNotifyMessageRead(Collection<Long> ids, Long userId, Integer userType);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 标记所有站内信为已读
|
||||||
|
*
|
||||||
|
* @param userId 用户编号
|
||||||
|
* @param userType 用户类型
|
||||||
|
* @return 更新到的条数
|
||||||
|
*/
|
||||||
|
int updateAllNotifyMessageRead(Long userId, Integer userType);
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,77 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.service.notify;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.message.NotifyMessageMyPageReqVO;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.message.NotifyMessagePageReqVO;
|
||||||
|
import cn.iocoder.yudao.module.system.dal.dataobject.notify.NotifyMessageDO;
|
||||||
|
import cn.iocoder.yudao.module.system.dal.dataobject.notify.NotifyTemplateDO;
|
||||||
|
import cn.iocoder.yudao.module.system.dal.mysql.notify.NotifyMessageMapper;
|
||||||
|
import org.springframework.stereotype.Service;
|
||||||
|
import org.springframework.validation.annotation.Validated;
|
||||||
|
|
||||||
|
import javax.annotation.Resource;
|
||||||
|
import java.util.Collection;
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
|
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 站内信 Service 实现类
|
||||||
|
*
|
||||||
|
* @author xrcoder
|
||||||
|
*/
|
||||||
|
@Service
|
||||||
|
@Validated
|
||||||
|
public class NotifyMessageServiceImpl implements NotifyMessageService {
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private NotifyMessageMapper notifyMessageMapper;
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Long createNotifyMessage(Long userId, Integer userType,
|
||||||
|
NotifyTemplateDO template, String templateContent, Map<String, Object> templateParams) {
|
||||||
|
NotifyMessageDO message = new NotifyMessageDO().setUserId(userId).setUserType(userType)
|
||||||
|
.setTemplateId(template.getId()).setTemplateCode(template.getCode())
|
||||||
|
.setTemplateType(template.getType()).setTemplateNickname(template.getNickname())
|
||||||
|
.setTemplateContent(templateContent).setTemplateParams(templateParams).setReadStatus(false);
|
||||||
|
notifyMessageMapper.insert(message);
|
||||||
|
return message.getId();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public PageResult<NotifyMessageDO> getNotifyMessagePage(NotifyMessagePageReqVO pageReqVO) {
|
||||||
|
return notifyMessageMapper.selectPage(pageReqVO);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public PageResult<NotifyMessageDO> getMyMyNotifyMessagePage(NotifyMessageMyPageReqVO pageReqVO, Long userId, Integer userType) {
|
||||||
|
return notifyMessageMapper.selectPage(pageReqVO, userId, userType);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public NotifyMessageDO getNotifyMessage(Long id) {
|
||||||
|
return notifyMessageMapper.selectById(id);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public List<NotifyMessageDO> getUnreadNotifyMessageList(Long userId, Integer userType, Integer size) {
|
||||||
|
return notifyMessageMapper.selectUnreadListByUserIdAndUserType(userId, userType, size);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Long getUnreadNotifyMessageCount(Long userId, Integer userType) {
|
||||||
|
return notifyMessageMapper.selectUnreadCountByUserIdAndUserType(userId, userType);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int updateNotifyMessageRead(Collection<Long> ids, Long userId, Integer userType) {
|
||||||
|
return notifyMessageMapper.updateListRead(ids, userId, userType);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int updateAllNotifyMessageRead(Long userId, Integer userType) {
|
||||||
|
return notifyMessageMapper.updateListRead(userId, userType);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,86 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.service.notify;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
|
||||||
|
import cn.iocoder.yudao.framework.common.enums.UserTypeEnum;
|
||||||
|
import cn.iocoder.yudao.module.system.dal.dataobject.notify.NotifyTemplateDO;
|
||||||
|
import com.google.common.annotations.VisibleForTesting;
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
import org.springframework.stereotype.Service;
|
||||||
|
import org.springframework.validation.annotation.Validated;
|
||||||
|
|
||||||
|
import javax.annotation.Resource;
|
||||||
|
import java.util.Map;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
|
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
|
||||||
|
import static cn.iocoder.yudao.module.system.enums.ErrorCodeConstants.*;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 站内信发送 Service 实现类
|
||||||
|
*
|
||||||
|
* @author xrcoder
|
||||||
|
*/
|
||||||
|
@Service
|
||||||
|
@Validated
|
||||||
|
@Slf4j
|
||||||
|
public class NotifySendServiceImpl implements NotifySendService {
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private NotifyTemplateService notifyTemplateService;
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private NotifyMessageService notifyMessageService;
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Long sendSingleNotifyToAdmin(Long userId, String templateCode, Map<String, Object> templateParams) {
|
||||||
|
return sendSingleNotify(userId, UserTypeEnum.ADMIN.getValue(), templateCode, templateParams);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Long sendSingleNotifyToMember(Long userId, String templateCode, Map<String, Object> templateParams) {
|
||||||
|
return sendSingleNotify(userId, UserTypeEnum.MEMBER.getValue(), templateCode, templateParams);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Long sendSingleNotify(Long userId, Integer userType, String templateCode, Map<String, Object> templateParams) {
|
||||||
|
// 校验模版
|
||||||
|
NotifyTemplateDO template = checkNotifyTemplateValid(templateCode);
|
||||||
|
if (Objects.equals(template.getStatus(), CommonStatusEnum.DISABLE.getStatus())) {
|
||||||
|
log.info("[sendSingleNotify][模版({})已经关闭，无法给用户({}/{})发送]", templateCode, userId, userType);
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
// 校验参数
|
||||||
|
checkTemplateParams(template, templateParams);
|
||||||
|
|
||||||
|
// 发送站内信
|
||||||
|
String content = notifyTemplateService.formatNotifyTemplateContent(template.getContent(), templateParams);
|
||||||
|
return notifyMessageService.createNotifyMessage(userId, userType, template, content, templateParams);
|
||||||
|
}
|
||||||
|
|
||||||
|
@VisibleForTesting
|
||||||
|
public NotifyTemplateDO checkNotifyTemplateValid(String templateCode) {
|
||||||
|
// 获得站内信模板。考虑到效率，从缓存中获取
|
||||||
|
NotifyTemplateDO template = notifyTemplateService.getNotifyTemplateByCodeFromCache(templateCode);
|
||||||
|
// 站内信模板不存在
|
||||||
|
if (template == null) {
|
||||||
|
throw exception(NOTICE_NOT_FOUND);
|
||||||
|
}
|
||||||
|
return template;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 校验站内信模版参数是否确实
|
||||||
|
*
|
||||||
|
* @param template 邮箱模板
|
||||||
|
* @param templateParams 参数列表
|
||||||
|
*/
|
||||||
|
@VisibleForTesting
|
||||||
|
public void checkTemplateParams(NotifyTemplateDO template, Map<String, Object> templateParams) {
|
||||||
|
template.getParams().forEach(key -> {
|
||||||
|
Object value = templateParams.get(key);
|
||||||
|
if (value == null) {
|
||||||
|
throw exception(NOTIFY_SEND_TEMPLATE_PARAM_MISS, key);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,266 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.service.notify;
|
||||||
|
|
||||||
|
import cn.hutool.core.map.MapUtil;
|
||||||
|
import cn.iocoder.yudao.framework.common.enums.UserTypeEnum;
|
||||||
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
||||||
|
import cn.iocoder.yudao.framework.mybatis.core.enums.SqlConstants;
|
||||||
|
import cn.iocoder.yudao.framework.test.core.ut.BaseDbUnitTest;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.message.NotifyMessageMyPageReqVO;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.message.NotifyMessagePageReqVO;
|
||||||
|
import cn.iocoder.yudao.module.system.dal.dataobject.notify.NotifyMessageDO;
|
||||||
|
import cn.iocoder.yudao.module.system.dal.dataobject.notify.NotifyTemplateDO;
|
||||||
|
import cn.iocoder.yudao.module.system.dal.mysql.notify.NotifyMessageMapper;
|
||||||
|
import com.baomidou.mybatisplus.annotation.DbType;
|
||||||
|
import org.junit.jupiter.api.Test;
|
||||||
|
import org.springframework.context.annotation.Import;
|
||||||
|
|
||||||
|
import javax.annotation.Resource;
|
||||||
|
import java.util.Arrays;
|
||||||
|
import java.util.Collection;
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
|
import static cn.hutool.core.util.RandomUtil.randomEle;
|
||||||
|
import static cn.iocoder.yudao.framework.common.util.date.LocalDateTimeUtils.buildBetweenTime;
|
||||||
|
import static cn.iocoder.yudao.framework.common.util.date.LocalDateTimeUtils.buildTime;
|
||||||
|
import static cn.iocoder.yudao.framework.common.util.object.ObjectUtils.cloneIgnoreId;
|
||||||
|
import static cn.iocoder.yudao.framework.test.core.util.AssertUtils.assertPojoEquals;
|
||||||
|
import static cn.iocoder.yudao.framework.test.core.util.RandomUtils.*;
|
||||||
|
import static org.junit.jupiter.api.Assertions.*;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* {@link NotifyMessageServiceImpl} 的单元测试类
|
||||||
|
*
|
||||||
|
* @author 芋道源码
|
||||||
|
*/
|
||||||
|
@Import(NotifyMessageServiceImpl.class)
|
||||||
|
public class NotifyMessageServiceImplTest extends BaseDbUnitTest {
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private NotifyMessageServiceImpl notifyMessageService;
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private NotifyMessageMapper notifyMessageMapper;
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testCreateNotifyMessage_success() {
|
||||||
|
// 准备参数
|
||||||
|
Long userId = randomLongId();
|
||||||
|
Integer userType = randomEle(UserTypeEnum.values()).getValue();
|
||||||
|
NotifyTemplateDO template = randomPojo(NotifyTemplateDO.class);
|
||||||
|
String templateContent = randomString();
|
||||||
|
Map<String, Object> templateParams = randomTemplateParams();
|
||||||
|
// mock 方法
|
||||||
|
|
||||||
|
// 调用
|
||||||
|
Long messageId = notifyMessageService.createNotifyMessage(userId, userType,
|
||||||
|
template, templateContent, templateParams);
|
||||||
|
// 断言
|
||||||
|
NotifyMessageDO message = notifyMessageMapper.selectById(messageId);
|
||||||
|
assertNotNull(message);
|
||||||
|
assertEquals(userId, message.getUserId());
|
||||||
|
assertEquals(userType, message.getUserType());
|
||||||
|
assertEquals(template.getId(), message.getTemplateId());
|
||||||
|
assertEquals(template.getCode(), message.getTemplateCode());
|
||||||
|
assertEquals(template.getType(), message.getTemplateType());
|
||||||
|
assertEquals(template.getNickname(), message.getTemplateNickname());
|
||||||
|
assertEquals(templateContent, message.getTemplateContent());
|
||||||
|
assertEquals(templateParams, message.getTemplateParams());
|
||||||
|
assertEquals(false, message.getReadStatus());
|
||||||
|
assertNull(message.getReadTime());
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testGetNotifyMessagePage() {
|
||||||
|
// mock 数据
|
||||||
|
NotifyMessageDO dbNotifyMessage = randomPojo(NotifyMessageDO.class, o -> { // 等会查询到
|
||||||
|
o.setUserId(1L);
|
||||||
|
o.setUserType(UserTypeEnum.ADMIN.getValue());
|
||||||
|
o.setTemplateCode("test_01");
|
||||||
|
o.setTemplateType(10);
|
||||||
|
o.setCreateTime(buildTime(2022, 1, 2));
|
||||||
|
o.setTemplateParams(randomTemplateParams());
|
||||||
|
});
|
||||||
|
notifyMessageMapper.insert(dbNotifyMessage);
|
||||||
|
// 测试 userId 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setUserId(2L)));
|
||||||
|
// 测试 userType 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setUserType(UserTypeEnum.MEMBER.getValue())));
|
||||||
|
// 测试 templateCode 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setTemplateCode("test_11")));
|
||||||
|
// 测试 templateType 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setTemplateType(20)));
|
||||||
|
// 测试 createTime 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setCreateTime(buildTime(2022, 2, 1))));
|
||||||
|
// 准备参数
|
||||||
|
NotifyMessagePageReqVO reqVO = new NotifyMessagePageReqVO();
|
||||||
|
reqVO.setUserId(1L);
|
||||||
|
reqVO.setUserType(UserTypeEnum.ADMIN.getValue());
|
||||||
|
reqVO.setTemplateCode("est_01");
|
||||||
|
reqVO.setTemplateType(10);
|
||||||
|
reqVO.setCreateTime(buildBetweenTime(2022, 1, 1, 2022, 1, 10));
|
||||||
|
|
||||||
|
// 调用
|
||||||
|
PageResult<NotifyMessageDO> pageResult = notifyMessageService.getNotifyMessagePage(reqVO);
|
||||||
|
// 断言
|
||||||
|
assertEquals(1, pageResult.getTotal());
|
||||||
|
assertEquals(1, pageResult.getList().size());
|
||||||
|
assertPojoEquals(dbNotifyMessage, pageResult.getList().get(0));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testGetMyNotifyMessagePage() {
|
||||||
|
// mock 数据
|
||||||
|
NotifyMessageDO dbNotifyMessage = randomPojo(NotifyMessageDO.class, o -> { // 等会查询到
|
||||||
|
o.setUserId(1L);
|
||||||
|
o.setUserType(UserTypeEnum.ADMIN.getValue());
|
||||||
|
o.setReadStatus(true);
|
||||||
|
o.setCreateTime(buildTime(2022, 1, 2));
|
||||||
|
o.setTemplateParams(randomTemplateParams());
|
||||||
|
});
|
||||||
|
notifyMessageMapper.insert(dbNotifyMessage);
|
||||||
|
// 测试 userId 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setUserId(2L)));
|
||||||
|
// 测试 userType 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setUserType(UserTypeEnum.MEMBER.getValue())));
|
||||||
|
// 测试 readStatus 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setReadStatus(false)));
|
||||||
|
// 测试 createTime 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setCreateTime(buildTime(2022, 2, 1))));
|
||||||
|
// 准备参数
|
||||||
|
Long userId = 1L;
|
||||||
|
Integer userType = UserTypeEnum.ADMIN.getValue();
|
||||||
|
NotifyMessageMyPageReqVO reqVO = new NotifyMessageMyPageReqVO();
|
||||||
|
reqVO.setReadStatus(true);
|
||||||
|
reqVO.setCreateTime(buildBetweenTime(2022, 1, 1, 2022, 1, 10));
|
||||||
|
|
||||||
|
// 调用
|
||||||
|
PageResult<NotifyMessageDO> pageResult = notifyMessageService.getMyMyNotifyMessagePage(reqVO, userId, userType);
|
||||||
|
// 断言
|
||||||
|
assertEquals(1, pageResult.getTotal());
|
||||||
|
assertEquals(1, pageResult.getList().size());
|
||||||
|
assertPojoEquals(dbNotifyMessage, pageResult.getList().get(0));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testGetUnreadNotifyMessageList() {
|
||||||
|
SqlConstants.init(DbType.MYSQL);
|
||||||
|
// mock 数据
|
||||||
|
NotifyMessageDO dbNotifyMessage = randomPojo(NotifyMessageDO.class, o -> { // 等会查询到
|
||||||
|
o.setUserId(1L);
|
||||||
|
o.setUserType(UserTypeEnum.ADMIN.getValue());
|
||||||
|
o.setReadStatus(false);
|
||||||
|
o.setTemplateParams(randomTemplateParams());
|
||||||
|
});
|
||||||
|
notifyMessageMapper.insert(dbNotifyMessage);
|
||||||
|
// 测试 userId 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setUserId(2L)));
|
||||||
|
// 测试 userType 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setUserType(UserTypeEnum.MEMBER.getValue())));
|
||||||
|
// 测试 readStatus 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setReadStatus(true)));
|
||||||
|
// 准备参数
|
||||||
|
Long userId = 1L;
|
||||||
|
Integer userType = UserTypeEnum.ADMIN.getValue();
|
||||||
|
Integer size = 10;
|
||||||
|
|
||||||
|
// 调用
|
||||||
|
List<NotifyMessageDO> list = notifyMessageService.getUnreadNotifyMessageList(userId, userType, size);
|
||||||
|
// 断言
|
||||||
|
assertEquals(1, list.size());
|
||||||
|
assertPojoEquals(dbNotifyMessage, list.get(0));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testGetUnreadNotifyMessageCount() {
|
||||||
|
SqlConstants.init(DbType.MYSQL);
|
||||||
|
// mock 数据
|
||||||
|
NotifyMessageDO dbNotifyMessage = randomPojo(NotifyMessageDO.class, o -> { // 等会查询到
|
||||||
|
o.setUserId(1L);
|
||||||
|
o.setUserType(UserTypeEnum.ADMIN.getValue());
|
||||||
|
o.setReadStatus(false);
|
||||||
|
o.setTemplateParams(randomTemplateParams());
|
||||||
|
});
|
||||||
|
notifyMessageMapper.insert(dbNotifyMessage);
|
||||||
|
// 测试 userId 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setUserId(2L)));
|
||||||
|
// 测试 userType 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setUserType(UserTypeEnum.MEMBER.getValue())));
|
||||||
|
// 测试 readStatus 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setReadStatus(true)));
|
||||||
|
// 准备参数
|
||||||
|
Long userId = 1L;
|
||||||
|
Integer userType = UserTypeEnum.ADMIN.getValue();
|
||||||
|
|
||||||
|
// 调用，并断言
|
||||||
|
assertEquals(1, notifyMessageService.getUnreadNotifyMessageCount(userId, userType));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testUpdateNotifyMessageRead() {
|
||||||
|
// mock 数据
|
||||||
|
NotifyMessageDO dbNotifyMessage = randomPojo(NotifyMessageDO.class, o -> { // 等会查询到
|
||||||
|
o.setUserId(1L);
|
||||||
|
o.setUserType(UserTypeEnum.ADMIN.getValue());
|
||||||
|
o.setReadStatus(false);
|
||||||
|
o.setReadTime(null);
|
||||||
|
o.setTemplateParams(randomTemplateParams());
|
||||||
|
});
|
||||||
|
notifyMessageMapper.insert(dbNotifyMessage);
|
||||||
|
// 测试 userId 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setUserId(2L)));
|
||||||
|
// 测试 userType 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setUserType(UserTypeEnum.MEMBER.getValue())));
|
||||||
|
// 测试 readStatus 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setReadStatus(true)));
|
||||||
|
// 准备参数
|
||||||
|
Collection<Long> ids = Arrays.asList(dbNotifyMessage.getId(), dbNotifyMessage.getId() + 1,
|
||||||
|
dbNotifyMessage.getId() + 2, dbNotifyMessage.getId() + 3);
|
||||||
|
Long userId = 1L;
|
||||||
|
Integer userType = UserTypeEnum.ADMIN.getValue();
|
||||||
|
|
||||||
|
// 调用
|
||||||
|
int updateCount = notifyMessageService.updateNotifyMessageRead(ids, userId, userType);
|
||||||
|
// 断言
|
||||||
|
assertEquals(1, updateCount);
|
||||||
|
NotifyMessageDO notifyMessage = notifyMessageMapper.selectById(dbNotifyMessage.getId());
|
||||||
|
assertTrue(notifyMessage.getReadStatus());
|
||||||
|
assertNotNull(notifyMessage.getReadTime());
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testUpdateAllNotifyMessageRead() {
|
||||||
|
// mock 数据
|
||||||
|
NotifyMessageDO dbNotifyMessage = randomPojo(NotifyMessageDO.class, o -> { // 等会查询到
|
||||||
|
o.setUserId(1L);
|
||||||
|
o.setUserType(UserTypeEnum.ADMIN.getValue());
|
||||||
|
o.setReadStatus(false);
|
||||||
|
o.setReadTime(null);
|
||||||
|
o.setTemplateParams(randomTemplateParams());
|
||||||
|
});
|
||||||
|
notifyMessageMapper.insert(dbNotifyMessage);
|
||||||
|
// 测试 userId 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setUserId(2L)));
|
||||||
|
// 测试 userType 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setUserType(UserTypeEnum.MEMBER.getValue())));
|
||||||
|
// 测试 readStatus 不匹配
|
||||||
|
notifyMessageMapper.insert(cloneIgnoreId(dbNotifyMessage, o -> o.setReadStatus(true)));
|
||||||
|
// 准备参数
|
||||||
|
Long userId = 1L;
|
||||||
|
Integer userType = UserTypeEnum.ADMIN.getValue();
|
||||||
|
|
||||||
|
// 调用
|
||||||
|
int updateCount = notifyMessageService.updateAllNotifyMessageRead(userId, userType);
|
||||||
|
// 断言
|
||||||
|
assertEquals(1, updateCount);
|
||||||
|
NotifyMessageDO notifyMessage = notifyMessageMapper.selectById(dbNotifyMessage.getId());
|
||||||
|
assertTrue(notifyMessage.getReadStatus());
|
||||||
|
assertNotNull(notifyMessage.getReadTime());
|
||||||
|
}
|
||||||
|
|
||||||
|
private static Map<String, Object> randomTemplateParams() {
|
||||||
|
return MapUtil.<String, Object>builder().put(randomString(), randomString())
|
||||||
|
.put(randomString(), randomString()).build();
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,146 @@
|
|||||||
|
package cn.iocoder.yudao.module.system.service.notify;
|
||||||
|
|
||||||
|
import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
|
||||||
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
||||||
|
import cn.iocoder.yudao.framework.test.core.ut.BaseDbUnitTest;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.template.NotifyTemplateCreateReqVO;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.template.NotifyTemplatePageReqVO;
|
||||||
|
import cn.iocoder.yudao.module.system.controller.admin.notify.vo.template.NotifyTemplateUpdateReqVO;
|
||||||
|
import cn.iocoder.yudao.module.system.dal.dataobject.notify.NotifyTemplateDO;
|
||||||
|
import cn.iocoder.yudao.module.system.dal.mysql.notify.NotifyTemplateMapper;
|
||||||
|
import cn.iocoder.yudao.module.system.mq.producer.notify.NotifyProducer;
|
||||||
|
import org.junit.jupiter.api.Test;
|
||||||
|
import org.springframework.boot.test.mock.mockito.MockBean;
|
||||||
|
import org.springframework.context.annotation.Import;
|
||||||
|
|
||||||
|
import javax.annotation.Resource;
|
||||||
|
|
||||||
|
import static cn.iocoder.yudao.framework.common.util.date.LocalDateTimeUtils.buildBetweenTime;
|
||||||
|
import static cn.iocoder.yudao.framework.common.util.date.LocalDateTimeUtils.buildTime;
|
||||||
|
import static cn.iocoder.yudao.framework.common.util.object.ObjectUtils.cloneIgnoreId;
|
||||||
|
import static cn.iocoder.yudao.framework.test.core.util.AssertUtils.assertPojoEquals;
|
||||||
|
import static cn.iocoder.yudao.framework.test.core.util.AssertUtils.assertServiceException;
|
||||||
|
import static cn.iocoder.yudao.framework.test.core.util.RandomUtils.*;
|
||||||
|
import static cn.iocoder.yudao.module.system.enums.ErrorCodeConstants.NOTIFY_TEMPLATE_NOT_EXISTS;
|
||||||
|
import static org.junit.jupiter.api.Assertions.*;
|
||||||
|
import static org.mockito.Mockito.verify;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* {@link NotifyTemplateServiceImpl} 的单元测试类
|
||||||
|
*
|
||||||
|
* @author 芋道源码
|
||||||
|
*/
|
||||||
|
@Import(NotifyTemplateServiceImpl.class)
|
||||||
|
public class NotifyTemplateServiceImplTest extends BaseDbUnitTest {
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private NotifyTemplateServiceImpl notifyTemplateService;
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private NotifyTemplateMapper notifyTemplateMapper;
|
||||||
|
|
||||||
|
@MockBean
|
||||||
|
private NotifyProducer notifyProducer;
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testCreateNotifyTemplate_success() {
|
||||||
|
// 准备参数
|
||||||
|
NotifyTemplateCreateReqVO reqVO = randomPojo(NotifyTemplateCreateReqVO.class,
|
||||||
|
o -> o.setStatus(randomCommonStatus()));
|
||||||
|
|
||||||
|
// 调用
|
||||||
|
Long notifyTemplateId = notifyTemplateService.createNotifyTemplate(reqVO);
|
||||||
|
// 断言
|
||||||
|
assertNotNull(notifyTemplateId);
|
||||||
|
// 校验记录的属性是否正确
|
||||||
|
NotifyTemplateDO notifyTemplate = notifyTemplateMapper.selectById(notifyTemplateId);
|
||||||
|
assertPojoEquals(reqVO, notifyTemplate);
|
||||||
|
verify(notifyProducer).sendNotifyTemplateRefreshMessage();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testUpdateNotifyTemplate_success() {
|
||||||
|
// mock 数据
|
||||||
|
NotifyTemplateDO dbNotifyTemplate = randomPojo(NotifyTemplateDO.class);
|
||||||
|
notifyTemplateMapper.insert(dbNotifyTemplate);// @Sql: 先插入出一条存在的数据
|
||||||
|
// 准备参数
|
||||||
|
NotifyTemplateUpdateReqVO reqVO = randomPojo(NotifyTemplateUpdateReqVO.class, o -> {
|
||||||
|
o.setId(dbNotifyTemplate.getId()); // 设置更新的 ID
|
||||||
|
o.setStatus(randomCommonStatus());
|
||||||
|
});
|
||||||
|
|
||||||
|
// 调用
|
||||||
|
notifyTemplateService.updateNotifyTemplate(reqVO);
|
||||||
|
// 校验是否更新正确
|
||||||
|
NotifyTemplateDO notifyTemplate = notifyTemplateMapper.selectById(reqVO.getId()); // 获取最新的
|
||||||
|
assertPojoEquals(reqVO, notifyTemplate);
|
||||||
|
verify(notifyProducer).sendNotifyTemplateRefreshMessage();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testUpdateNotifyTemplate_notExists() {
|
||||||
|
// 准备参数
|
||||||
|
NotifyTemplateUpdateReqVO reqVO = randomPojo(NotifyTemplateUpdateReqVO.class);
|
||||||
|
|
||||||
|
// 调用, 并断言异常
|
||||||
|
assertServiceException(() -> notifyTemplateService.updateNotifyTemplate(reqVO), NOTIFY_TEMPLATE_NOT_EXISTS);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testDeleteNotifyTemplate_success() {
|
||||||
|
// mock 数据
|
||||||
|
NotifyTemplateDO dbNotifyTemplate = randomPojo(NotifyTemplateDO.class);
|
||||||
|
notifyTemplateMapper.insert(dbNotifyTemplate);// @Sql: 先插入出一条存在的数据
|
||||||
|
// 准备参数
|
||||||
|
Long id = dbNotifyTemplate.getId();
|
||||||
|
|
||||||
|
// 调用
|
||||||
|
notifyTemplateService.deleteNotifyTemplate(id);
|
||||||
|
// 校验数据不存在了
|
||||||
|
assertNull(notifyTemplateMapper.selectById(id));
|
||||||
|
verify(notifyProducer).sendNotifyTemplateRefreshMessage();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testDeleteNotifyTemplate_notExists() {
|
||||||
|
// 准备参数
|
||||||
|
Long id = randomLongId();
|
||||||
|
|
||||||
|
// 调用, 并断言异常
|
||||||
|
assertServiceException(() -> notifyTemplateService.deleteNotifyTemplate(id), NOTIFY_TEMPLATE_NOT_EXISTS);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testGetNotifyTemplatePage() {
|
||||||
|
// mock 数据
|
||||||
|
NotifyTemplateDO dbNotifyTemplate = randomPojo(NotifyTemplateDO.class, o -> { // 等会查询到
|
||||||
|
o.setName("芋头");
|
||||||
|
o.setCode("test_01");
|
||||||
|
o.setStatus(CommonStatusEnum.ENABLE.getStatus());
|
||||||
|
o.setCreateTime(buildTime(2022, 2, 3));
|
||||||
|
});
|
||||||
|
notifyTemplateMapper.insert(dbNotifyTemplate);
|
||||||
|
// 测试 name 不匹配
|
||||||
|
notifyTemplateMapper.insert(cloneIgnoreId(dbNotifyTemplate, o -> o.setName("投")));
|
||||||
|
// 测试 code 不匹配
|
||||||
|
notifyTemplateMapper.insert(cloneIgnoreId(dbNotifyTemplate, o -> o.setCode("test_02")));
|
||||||
|
// 测试 status 不匹配
|
||||||
|
notifyTemplateMapper.insert(cloneIgnoreId(dbNotifyTemplate, o -> o.setStatus(CommonStatusEnum.DISABLE.getStatus())));
|
||||||
|
// 测试 createTime 不匹配
|
||||||
|
notifyTemplateMapper.insert(cloneIgnoreId(dbNotifyTemplate, o -> o.setCreateTime(buildTime(2022, 1, 5))));
|
||||||
|
// 准备参数
|
||||||
|
NotifyTemplatePageReqVO reqVO = new NotifyTemplatePageReqVO();
|
||||||
|
reqVO.setName("芋");
|
||||||
|
reqVO.setCode("est_01");
|
||||||
|
reqVO.setStatus(CommonStatusEnum.ENABLE.getStatus());
|
||||||
|
reqVO.setCreateTime(buildBetweenTime(2022, 2, 1, 2022, 2, 5));
|
||||||
|
|
||||||
|
// 调用
|
||||||
|
PageResult<NotifyTemplateDO> pageResult = notifyTemplateService.getNotifyTemplatePage(reqVO);
|
||||||
|
// 断言
|
||||||
|
assertEquals(1, pageResult.getTotal());
|
||||||
|
assertEquals(1, pageResult.getList().size());
|
||||||
|
assertPojoEquals(dbNotifyTemplate, pageResult.getList().get(0));
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,66 @@
|
|||||||
|
import request from '@/config/axios'
|
||||||
|
import qs from 'qs'
|
||||||
|
|
||||||
|
export interface NotifyMessageVO {
|
||||||
|
id: number
|
||||||
|
userId: number
|
||||||
|
userType: number
|
||||||
|
templateId: number
|
||||||
|
templateCode: string
|
||||||
|
templateNickname: string
|
||||||
|
templateContent: string
|
||||||
|
templateType: number
|
||||||
|
templateParams: string
|
||||||
|
readStatus: boolean
|
||||||
|
readTime: Date
|
||||||
|
}
|
||||||
|
|
||||||
|
export interface NotifyMessagePageReqVO extends PageParam {
|
||||||
|
userId?: number
|
||||||
|
userType?: number
|
||||||
|
templateCode?: string
|
||||||
|
templateType?: number
|
||||||
|
createTime?: Date[]
|
||||||
|
}
|
||||||
|
|
||||||
|
export interface NotifyMessageMyPageReqVO extends PageParam {
|
||||||
|
readStatus?: boolean
|
||||||
|
createTime?: Date[]
|
||||||
|
}
|
||||||
|
|
||||||
|
// 查询站内信消息列表
|
||||||
|
export const getNotifyMessagePageApi = async (params: NotifyMessagePageReqVO) => {
|
||||||
|
return await request.get({ url: '/system/notify-message/page', params })
|
||||||
|
}
|
||||||
|
|
||||||
|
// 查询站内信消息详情
|
||||||
|
export const getNotifyMessageApi = async (id: number) => {
|
||||||
|
return await request.get({ url: '/system/notify-message/get?id=' + id })
|
||||||
|
}
|
||||||
|
|
||||||
|
// 获得我的站内信分页
|
||||||
|
export const getMyNotifyMessagePage = async (params: NotifyMessageMyPageReqVO) => {
|
||||||
|
return await request.get({ url: '/system/notify-message/my-page', params })
|
||||||
|
}
|
||||||
|
|
||||||
|
// 批量标记已读
|
||||||
|
export const updateNotifyMessageRead = async (ids) => {
|
||||||
|
return await request.put({
|
||||||
|
url: '/system/notify-message/update-read?' + qs.stringify({ ids: ids }, { indices: false })
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
// 标记所有站内信为已读
|
||||||
|
export const updateAllNotifyMessageRead = async () => {
|
||||||
|
return await request.put({ url: '/system/notify-message/update-all-read' })
|
||||||
|
}
|
||||||
|
|
||||||
|
// 获取当前用户的最新站内信列表
|
||||||
|
export const getUnreadNotifyMessageListApi = async () => {
|
||||||
|
return await request.get({ url: '/system/notify-message/get-unread-list' })
|
||||||
|
}
|
||||||
|
|
||||||
|
// 获得当前用户的未读站内信数量
|
||||||
|
export const getUnreadNotifyMessageCountApi = async () => {
|
||||||
|
return await request.get({ url: '/system/notify-message/get-unread-count' })
|
||||||
|
}
|
||||||
@ -0,0 +1,55 @@
|
|||||||
|
import request from '@/config/axios'
|
||||||
|
|
||||||
|
export interface NotifyTemplateVO {
|
||||||
|
id: number
|
||||||
|
name: string
|
||||||
|
code: string
|
||||||
|
content: string
|
||||||
|
type: number
|
||||||
|
params: string
|
||||||
|
status: number
|
||||||
|
remark: string
|
||||||
|
}
|
||||||
|
|
||||||
|
export interface NotifyTemplatePageReqVO extends PageParam {
|
||||||
|
name?: string
|
||||||
|
code?: string
|
||||||
|
status?: number
|
||||||
|
createTime?: Date[]
|
||||||
|
}
|
||||||
|
|
||||||
|
export interface NotifySendReqVO {
|
||||||
|
userId: number
|
||||||
|
templateCode: string
|
||||||
|
templateParams: Map<String, Object>
|
||||||
|
}
|
||||||
|
|
||||||
|
// 查询站内信模板列表
|
||||||
|
export const getNotifyTemplatePageApi = async (params: NotifyTemplatePageReqVO) => {
|
||||||
|
return await request.get({ url: '/system/notify-template/page', params })
|
||||||
|
}
|
||||||
|
|
||||||
|
// 查询站内信模板详情
|
||||||
|
export const getNotifyTemplateApi = async (id: number) => {
|
||||||
|
return await request.get({ url: '/system/notify-template/get?id=' + id })
|
||||||
|
}
|
||||||
|
|
||||||
|
// 新增站内信模板
|
||||||
|
export const createNotifyTemplateApi = async (data: NotifyTemplateVO) => {
|
||||||
|
return await request.post({ url: '/system/notify-template/create', data })
|
||||||
|
}
|
||||||
|
|
||||||
|
// 修改站内信模板
|
||||||
|
export const updateNotifyTemplateApi = async (data: NotifyTemplateVO) => {
|
||||||
|
return await request.put({ url: '/system/notify-template/update', data })
|
||||||
|
}
|
||||||
|
|
||||||
|
// 删除站内信模板
|
||||||
|
export const deleteNotifyTemplateApi = async (id: number) => {
|
||||||
|
return await request.delete({ url: '/system/notify-template/delete?id=' + id })
|
||||||
|
}
|
||||||
|
|
||||||
|
// 发送站内信
|
||||||
|
export const sendNotifyApi = (data: NotifySendReqVO) => {
|
||||||
|
return request.post({ url: '/system/notify-template/send-notify', data })
|
||||||
|
}
|
||||||
@ -0,0 +1,52 @@
|
|||||||
|
import request from '@/utils/request'
|
||||||
|
import qs from 'qs'
|
||||||
|
|
||||||
|
// 获得我的站内信分页
|
||||||
|
export function getNotifyMessagePage(query) {
|
||||||
|
return request({
|
||||||
|
url: '/system/notify-message/page',
|
||||||
|
method: 'get',
|
||||||
|
params: query
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
// 获得我的站内信分页
|
||||||
|
export function getMyNotifyMessagePage(query) {
|
||||||
|
return request({
|
||||||
|
url: '/system/notify-message/my-page',
|
||||||
|
method: 'get',
|
||||||
|
params: query
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
// 批量标记已读
|
||||||
|
export function updateNotifyMessageRead(ids) {
|
||||||
|
return request({
|
||||||
|
url: '/system/notify-message/update-read?' + qs.stringify({ids: ids}, { indices: false }),
|
||||||
|
method: 'put'
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
// 标记所有站内信为已读
|
||||||
|
export function updateAllNotifyMessageRead() {
|
||||||
|
return request({
|
||||||
|
url: '/system/notify-message/update-all-read',
|
||||||
|
method: 'put'
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
// 获取当前用户的最新站内信列表
|
||||||
|
export function getUnreadNotifyMessageList() {
|
||||||
|
return request({
|
||||||
|
url: '/system/notify-message/get-unread-list',
|
||||||
|
method: 'get'
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
// 获得当前用户的未读站内信数量
|
||||||
|
export function getUnreadNotifyMessageCount() {
|
||||||
|
return request({
|
||||||
|
url: '/system/notify-message/get-unread-count',
|
||||||
|
method: 'get'
|
||||||
|
})
|
||||||
|
}
|
||||||
@ -0,0 +1,64 @@
|
|||||||
|
import request from '@/utils/request'
|
||||||
|
|
||||||
|
// 创建站内信模板
|
||||||
|
export function createNotifyTemplate(data) {
|
||||||
|
return request({
|
||||||
|
url: '/system/notify-template/create',
|
||||||
|
method: 'post',
|
||||||
|
data: data
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
// 更新站内信模板
|
||||||
|
export function updateNotifyTemplate(data) {
|
||||||
|
return request({
|
||||||
|
url: '/system/notify-template/update',
|
||||||
|
method: 'put',
|
||||||
|
data: data
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
// 删除站内信模板
|
||||||
|
export function deleteNotifyTemplate(id) {
|
||||||
|
return request({
|
||||||
|
url: '/system/notify-template/delete?id=' + id,
|
||||||
|
method: 'delete'
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
// 获得站内信模板
|
||||||
|
export function getNotifyTemplate(id) {
|
||||||
|
return request({
|
||||||
|
url: '/system/notify-template/get?id=' + id,
|
||||||
|
method: 'get'
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
// 获得站内信模板分页
|
||||||
|
export function getNotifyTemplatePage(query) {
|
||||||
|
return request({
|
||||||
|
url: '/system/notify-template/page',
|
||||||
|
method: 'get',
|
||||||
|
params: query
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
// 创建站内信模板
|
||||||
|
export function sendNotify(data) {
|
||||||
|
return request({
|
||||||
|
url: '/system/notify-template/send-notify',
|
||||||
|
method: 'post',
|
||||||
|
data: data
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
// 导出站内信模板 Excel
|
||||||
|
export function exportNotifyTemplateExcel(query) {
|
||||||
|
return request({
|
||||||
|
url: '/system/notify-template/export-excel',
|
||||||
|
method: 'get',
|
||||||
|
params: query,
|
||||||
|
responseType: 'blob'
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
@ -0,0 +1,179 @@
|
|||||||
|
<template>
|
||||||
|
<div class="app-container">
|
||||||
|
<doc-alert title="站内信配置" url="https://doc.iocoder.cn/notify/" />
|
||||||
|
<!-- 搜索工作栏 -->
|
||||||
|
<el-form :model="queryParams" ref="queryForm" size="small" :inline="true" v-show="showSearch" label-width="68px">
|
||||||
|
<el-form-item label="用户编号" prop="userId">
|
||||||
|
<el-input v-model="queryParams.userId" placeholder="请输入用户编号" clearable @keyup.enter.native="handleQuery"/>
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item label="用户类型" prop="userType">
|
||||||
|
<el-select v-model="queryParams.userType" placeholder="请选择用户类型" clearable size="small">
|
||||||
|
<el-option v-for="dict in this.getDictDatas(DICT_TYPE.USER_TYPE)"
|
||||||
|
:key="dict.value" :label="dict.label" :value="dict.value"/>
|
||||||
|
</el-select>
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item label="模板编码" prop="templateCode">
|
||||||
|
<el-input v-model="queryParams.templateCode" placeholder="请输入模板编码" clearable @keyup.enter.native="handleQuery"/>
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item label="模版类型" prop="templateType">
|
||||||
|
<el-select v-model="queryParams.templateType" placeholder="请选择模版类型" clearable size="small">
|
||||||
|
<el-option v-for="dict in this.getDictDatas(DICT_TYPE.SYSTEM_NOTIFY_TEMPLATE_TYPE)"
|
||||||
|
:key="dict.value" :label="dict.label" :value="dict.value"/>
|
||||||
|
</el-select>
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item label="创建时间" prop="createTime">
|
||||||
|
<el-date-picker v-model="queryParams.createTime" style="width: 240px" value-format="yyyy-MM-dd HH:mm:ss" type="daterange"
|
||||||
|
range-separator="-" start-placeholder="开始日期" end-placeholder="结束日期" :default-time="['00:00:00', '23:59:59']" />
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item>
|
||||||
|
<el-button type="primary" icon="el-icon-search" @click="handleQuery">搜索</el-button>
|
||||||
|
<el-button icon="el-icon-refresh" @click="resetQuery">重置</el-button>
|
||||||
|
</el-form-item>
|
||||||
|
</el-form>
|
||||||
|
|
||||||
|
<!-- 操作工具栏 -->
|
||||||
|
<el-row :gutter="10" class="mb8">
|
||||||
|
<right-toolbar :showSearch.sync="showSearch" @queryTable="getList"></right-toolbar>
|
||||||
|
</el-row>
|
||||||
|
|
||||||
|
<!-- 列表 -->
|
||||||
|
<el-table v-loading="loading" :data="list">
|
||||||
|
<el-table-column label="编号" align="center" prop="id" />
|
||||||
|
<el-table-column label="用户编号" align="center" prop="userId" />
|
||||||
|
<el-table-column label="用户类型" align="center" prop="userType">
|
||||||
|
<template v-slot="scope">
|
||||||
|
<dict-tag :type="DICT_TYPE.USER_TYPE" :value="scope.row.userType" />
|
||||||
|
</template>
|
||||||
|
</el-table-column>
|
||||||
|
<el-table-column label="模板编码" align="center" prop="templateCode" />
|
||||||
|
<el-table-column label="发送人名称" align="center" prop="templateNickname" />
|
||||||
|
<el-table-column label="模版内容" align="center" prop="templateContent" />
|
||||||
|
<el-table-column label="模版类型" align="center" prop="templateType">
|
||||||
|
<template v-slot="scope">
|
||||||
|
<dict-tag :type="DICT_TYPE.SYSTEM_NOTIFY_TEMPLATE_TYPE" :value="scope.row.templateType" />
|
||||||
|
</template>
|
||||||
|
</el-table-column>
|
||||||
|
<el-table-column label="是否已读" align="center" prop="readStatus">
|
||||||
|
<template v-slot="scope">
|
||||||
|
<dict-tag :type="DICT_TYPE.INFRA_BOOLEAN_STRING" :value="scope.row.readStatus" />
|
||||||
|
</template>
|
||||||
|
</el-table-column>
|
||||||
|
<el-table-column label="阅读时间" align="center" prop="readTime" width="180">
|
||||||
|
<template v-slot="scope">
|
||||||
|
<span>{{ parseTime(scope.row.readTime) }}</span>
|
||||||
|
</template>
|
||||||
|
</el-table-column>
|
||||||
|
<el-table-column label="创建时间" align="center" prop="createTime" width="180">
|
||||||
|
<template v-slot="scope">
|
||||||
|
<span>{{ parseTime(scope.row.createTime) }}</span>
|
||||||
|
</template>
|
||||||
|
</el-table-column>
|
||||||
|
<el-table-column label="操作" align="center" class-name="small-padding fixed-width">
|
||||||
|
<template v-slot="scope">
|
||||||
|
<el-button size="mini" type="text" icon="el-icon-view" @click="handleView(scope.row)"
|
||||||
|
v-hasPermi="['system:notify-message:query']">详细</el-button>
|
||||||
|
</template>
|
||||||
|
</el-table-column>
|
||||||
|
</el-table>
|
||||||
|
<!-- 分页组件 -->
|
||||||
|
<pagination v-show="total > 0" :total="total" :page.sync="queryParams.pageNo" :limit.sync="queryParams.pageSize"
|
||||||
|
@pagination="getList"/>
|
||||||
|
|
||||||
|
<!-- 站内信详细-->
|
||||||
|
<el-dialog :title="title" :visible.sync="open" width="700px" v-dialogDrag append-to-body>
|
||||||
|
<el-form ref="form" :model="form" label-width="160px">
|
||||||
|
<el-row>
|
||||||
|
<el-col :span="24">
|
||||||
|
<el-form-item label="日志主键：">{{ form.id }}</el-form-item>
|
||||||
|
<el-form-item label="发送时间：">{{ parseTime(form.createTime) }}</el-form-item>
|
||||||
|
<el-form-item label="用户编号：">{{ form.userId }}</el-form-item>
|
||||||
|
<el-form-item label="用户类型：">
|
||||||
|
<dict-tag :type="DICT_TYPE.USER_TYPE" :value="form.userType"/>
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item label="模板编号：">{{ form.templateId }}</el-form-item>
|
||||||
|
<el-form-item label="模板编码：">{{ form.templateCode }}</el-form-item>
|
||||||
|
<el-form-item label="模板类型：">
|
||||||
|
<dict-tag :type="DICT_TYPE.SYSTEM_NOTIFY_TEMPLATE_TYPE" :value="form.templateType" />
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item label="模版发送人名称：">{{ form.templateNickname }}</el-form-item>
|
||||||
|
<el-form-item label="邮件内容：">{{ form.templateContent }}</el-form-item>
|
||||||
|
<el-form-item label="模版参数：">{{ form.templateParams }}</el-form-item>
|
||||||
|
<el-form-item label="是否已读：">
|
||||||
|
<dict-tag :type="DICT_TYPE.INFRA_BOOLEAN_STRING" :value="form.readStatus" />
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item label="阅读时间：">{{ parseTime(form.readTime) }}</el-form-item>
|
||||||
|
</el-col>
|
||||||
|
</el-row>
|
||||||
|
</el-form>
|
||||||
|
<div slot="footer" class="dialog-footer">
|
||||||
|
<el-button @click="open = false">关 闭</el-button>
|
||||||
|
</div>
|
||||||
|
</el-dialog>
|
||||||
|
</div>
|
||||||
|
</template>
|
||||||
|
|
||||||
|
<script>
|
||||||
|
import { getNotifyMessagePage } from "@/api/system/notify/message";
|
||||||
|
|
||||||
|
export default {
|
||||||
|
name: "NotifyMessage",
|
||||||
|
data() {
|
||||||
|
return {
|
||||||
|
// 遮罩层
|
||||||
|
loading: true,
|
||||||
|
// 显示搜索条件
|
||||||
|
showSearch: true,
|
||||||
|
// 总条数
|
||||||
|
total: 0,
|
||||||
|
// 站内信消息列表
|
||||||
|
list: [],
|
||||||
|
// 弹出层标题
|
||||||
|
title: "站内信详细",
|
||||||
|
// 是否显示弹出层
|
||||||
|
open: false,
|
||||||
|
// 查询参数
|
||||||
|
queryParams: {
|
||||||
|
pageNo: 1,
|
||||||
|
pageSize: 10,
|
||||||
|
userId: null,
|
||||||
|
userType: null,
|
||||||
|
templateCode: null,
|
||||||
|
templateType: null,
|
||||||
|
createTime: [],
|
||||||
|
},
|
||||||
|
// 表单参数
|
||||||
|
form: {},
|
||||||
|
};
|
||||||
|
},
|
||||||
|
created() {
|
||||||
|
this.getList();
|
||||||
|
},
|
||||||
|
methods: {
|
||||||
|
/** 查询列表 */
|
||||||
|
getList() {
|
||||||
|
this.loading = true;
|
||||||
|
// 执行查询
|
||||||
|
getNotifyMessagePage(this.queryParams).then(response => {
|
||||||
|
this.list = response.data.list;
|
||||||
|
this.total = response.data.total;
|
||||||
|
this.loading = false;
|
||||||
|
});
|
||||||
|
},
|
||||||
|
/** 搜索按钮操作 */
|
||||||
|
handleQuery() {
|
||||||
|
this.queryParams.pageNo = 1;
|
||||||
|
this.getList();
|
||||||
|
},
|
||||||
|
/** 重置按钮操作 */
|
||||||
|
resetQuery() {
|
||||||
|
this.resetForm("queryForm");
|
||||||
|
this.handleQuery();
|
||||||
|
},
|
||||||
|
/** 详细按钮操作 */
|
||||||
|
handleView(row) {
|
||||||
|
this.open = true;
|
||||||
|
this.form = row;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
};
|
||||||
|
</script>
|
||||||
@ -0,0 +1,139 @@
|
|||||||
|
<template>
|
||||||
|
<div class="app-container">
|
||||||
|
<doc-alert title="站内信配置" url="https://doc.iocoder.cn/notify/" />
|
||||||
|
|
||||||
|
<!-- 搜索工作栏 -->
|
||||||
|
<el-form :model="queryParams" ref="queryForm" size="small" :inline="true" v-show="showSearch" label-width="68px">
|
||||||
|
<el-form-item label="是否已读" prop="readStatus">
|
||||||
|
<el-select v-model="queryParams.readStatus" placeholder="请选择状态" clearable>
|
||||||
|
<el-option v-for="dict in this.getDictDatas(DICT_TYPE.INFRA_BOOLEAN_STRING)"
|
||||||
|
:key="dict.value" :label="dict.label" :value="dict.value"/>
|
||||||
|
</el-select>
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item label="发送时间" prop="createTime">
|
||||||
|
<el-date-picker v-model="queryParams.createTime" style="width: 240px" value-format="yyyy-MM-dd HH:mm:ss" type="daterange"
|
||||||
|
range-separator="-" start-placeholder="开始日期" end-placeholder="结束日期" :default-time="['00:00:00', '23:59:59']" />
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item>
|
||||||
|
<el-button type="primary" icon="el-icon-search" @click="handleQuery">搜索</el-button>
|
||||||
|
<el-button icon="el-icon-refresh" @click="resetQuery">重置</el-button>
|
||||||
|
</el-form-item>
|
||||||
|
</el-form>
|
||||||
|
|
||||||
|
<!-- 操作工具栏 -->
|
||||||
|
<el-row :gutter="10" class="mb8">
|
||||||
|
<el-col :span="1.5">
|
||||||
|
<el-button type="primary" plain icon="el-icon-plus" size="mini" @click="handleUpdateList">标记已读</el-button>
|
||||||
|
</el-col>
|
||||||
|
<el-col :span="1.5">
|
||||||
|
<el-button type="primary" plain icon="el-icon-plus" size="mini" @click="handleUpdateAll">全部已读</el-button>
|
||||||
|
</el-col>
|
||||||
|
<right-toolbar :showSearch.sync="showSearch" @queryTable="getList"></right-toolbar>
|
||||||
|
</el-row>
|
||||||
|
|
||||||
|
<!-- 列表 -->
|
||||||
|
<el-table v-loading="loading" ref="tables" :data="list">
|
||||||
|
<el-table-column type="selection" width="55" />
|
||||||
|
<el-table-column label="发送人" align="center" prop="templateNickname" width="120" />
|
||||||
|
<el-table-column label="发送时间" align="center" prop="createTime" width="180">
|
||||||
|
<template slot-scope="scope">
|
||||||
|
<span>{{ parseTime(scope.row.createTime) }}</span>
|
||||||
|
</template>
|
||||||
|
</el-table-column>
|
||||||
|
<el-table-column label="类型" align="center" prop="templateType" width="80">
|
||||||
|
<template v-slot="scope">
|
||||||
|
<dict-tag :type="DICT_TYPE.SYSTEM_NOTIFY_TEMPLATE_TYPE" :value="scope.row.templateType" />
|
||||||
|
</template>
|
||||||
|
</el-table-column>
|
||||||
|
<el-table-column label="内容" align="center" prop="templateContent" />
|
||||||
|
<el-table-column label="是否已读" align="center" prop="readStatus" width="80">
|
||||||
|
<template slot-scope="scope">
|
||||||
|
<dict-tag :type="DICT_TYPE.INFRA_BOOLEAN_STRING" :value="scope.row.readStatus"/>
|
||||||
|
</template>
|
||||||
|
</el-table-column>
|
||||||
|
<el-table-column label="操作" align="center" class-name="small-padding fixed-width" width="150">
|
||||||
|
<template slot-scope="scope">
|
||||||
|
<el-button v-show="!scope.row.readStatus" size="mini" type="text" icon="el-icon-check" @click="handleUpdateSingle(scope.row)">已读</el-button>
|
||||||
|
</template>
|
||||||
|
</el-table-column>
|
||||||
|
</el-table>
|
||||||
|
<!-- 分页组件 -->
|
||||||
|
<pagination v-show="total > 0" :total="total" :page.sync="queryParams.pageNo" :limit.sync="queryParams.pageSize"
|
||||||
|
@pagination="getList"/>
|
||||||
|
|
||||||
|
</div>
|
||||||
|
</template>
|
||||||
|
|
||||||
|
<script>
|
||||||
|
import {getMyNotifyMessagePage, updateAllNotifyMessageRead, updateNotifyMessageRead} from "@/api/system/notify/message";
|
||||||
|
|
||||||
|
export default {
|
||||||
|
name: "myNotify",
|
||||||
|
data() {
|
||||||
|
return {
|
||||||
|
// 遮罩层
|
||||||
|
loading: true,
|
||||||
|
// 显示搜索条件
|
||||||
|
showSearch: true,
|
||||||
|
// 总条数
|
||||||
|
total: 0,
|
||||||
|
// 我的站内信列表
|
||||||
|
list: [],
|
||||||
|
// 查询参数
|
||||||
|
queryParams: {
|
||||||
|
pageNo: 1,
|
||||||
|
pageSize: 10,
|
||||||
|
readStatus: null,
|
||||||
|
createTime: []
|
||||||
|
},
|
||||||
|
};
|
||||||
|
},
|
||||||
|
created() {
|
||||||
|
this.getList();
|
||||||
|
},
|
||||||
|
methods: {
|
||||||
|
/** 查询列表 */
|
||||||
|
getList() {
|
||||||
|
this.loading = true;
|
||||||
|
// 执行查询
|
||||||
|
getMyNotifyMessagePage(this.queryParams).then(response => {
|
||||||
|
this.list = response.data.list;
|
||||||
|
this.total = response.data.total;
|
||||||
|
this.loading = false;
|
||||||
|
});
|
||||||
|
},
|
||||||
|
/** 搜索按钮操作 */
|
||||||
|
handleQuery() {
|
||||||
|
this.queryParams.pageNo = 1;
|
||||||
|
this.getList();
|
||||||
|
},
|
||||||
|
/** 重置按钮操作 */
|
||||||
|
resetQuery() {
|
||||||
|
this.resetForm("queryForm");
|
||||||
|
this.handleQuery();
|
||||||
|
},
|
||||||
|
handleUpdateList() {
|
||||||
|
let list = this.$refs["tables"].selection;
|
||||||
|
if (list.length === 0) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
this.handleUpdate(list.map(v => v.id))
|
||||||
|
},
|
||||||
|
handleUpdateSingle(row) {
|
||||||
|
this.handleUpdate([row.id])
|
||||||
|
},
|
||||||
|
handleUpdate(ids) {
|
||||||
|
updateNotifyMessageRead(ids).then(response => {
|
||||||
|
this.$modal.msgSuccess("标记已读成功！");
|
||||||
|
this.getList();
|
||||||
|
});
|
||||||
|
},
|
||||||
|
handleUpdateAll(){
|
||||||
|
updateAllNotifyMessageRead().then(response => {
|
||||||
|
this.$modal.msgSuccess("全部已读成功！");
|
||||||
|
this.getList();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
</script>
|
||||||
@ -0,0 +1,340 @@
|
|||||||
|
<template>
|
||||||
|
<div class="app-container">
|
||||||
|
<doc-alert title="站内信配置" url="https://doc.iocoder.cn/notify/" />
|
||||||
|
|
||||||
|
<!-- 搜索工作栏 -->
|
||||||
|
<el-form :model="queryParams" ref="queryForm" size="small" :inline="true" v-show="showSearch" label-width="68px">
|
||||||
|
<el-form-item label="模板名称" prop="name">
|
||||||
|
<el-input v-model="queryParams.name" placeholder="请输入模板名称" clearable @keyup.enter.native="handleQuery"/>
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item label="模版编码" prop="code">
|
||||||
|
<el-input v-model="queryParams.code" placeholder="请输入模版编码" clearable @keyup.enter.native="handleQuery"/>
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item label="状态" prop="status">
|
||||||
|
<el-select v-model="queryParams.status" placeholder="请选择状态" clearable size="small">
|
||||||
|
<el-option v-for="dict in this.getDictDatas(DICT_TYPE.COMMON_STATUS)"
|
||||||
|
:key="dict.value" :label="dict.label" :value="dict.value"/>
|
||||||
|
</el-select>
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item label="创建时间" prop="createTime">
|
||||||
|
<el-date-picker v-model="queryParams.createTime" style="width: 240px" value-format="yyyy-MM-dd HH:mm:ss" type="daterange"
|
||||||
|
range-separator="-" start-placeholder="开始日期" end-placeholder="结束日期" :default-time="['00:00:00', '23:59:59']" />
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item>
|
||||||
|
<el-button type="primary" icon="el-icon-search" @click="handleQuery">搜索</el-button>
|
||||||
|
<el-button icon="el-icon-refresh" @click="resetQuery">重置</el-button>
|
||||||
|
</el-form-item>
|
||||||
|
</el-form>
|
||||||
|
|
||||||
|
<!-- 操作工具栏 -->
|
||||||
|
<el-row :gutter="10" class="mb8">
|
||||||
|
<el-col :span="1.5">
|
||||||
|
<el-button type="primary" plain icon="el-icon-plus" size="mini" @click="handleAdd"
|
||||||
|
v-hasPermi="['system:notify-template:create']">新增</el-button>
|
||||||
|
</el-col>
|
||||||
|
<right-toolbar :showSearch.sync="showSearch" @queryTable="getList"></right-toolbar>
|
||||||
|
</el-row>
|
||||||
|
|
||||||
|
<!-- 列表 -->
|
||||||
|
<el-table v-loading="loading" :data="list">
|
||||||
|
<el-table-column label="模板编码" align="center" prop="code" />
|
||||||
|
<el-table-column label="模板名称" align="center" prop="name" />
|
||||||
|
<el-table-column label="类型" align="center" prop="type">
|
||||||
|
<template v-slot="scope">
|
||||||
|
<dict-tag :type="DICT_TYPE.SYSTEM_NOTIFY_TEMPLATE_TYPE" :value="scope.row.type" />
|
||||||
|
</template>
|
||||||
|
</el-table-column>
|
||||||
|
<el-table-column label="发送人名称" align="center" prop="nickname" />
|
||||||
|
<el-table-column label="模板内容" align="center" prop="content" width="300" />
|
||||||
|
<el-table-column label="开启状态" align="center" prop="status">
|
||||||
|
<template slot-scope="scope">
|
||||||
|
<dict-tag :type="DICT_TYPE.COMMON_STATUS" :value="scope.row.status"/>
|
||||||
|
</template>
|
||||||
|
</el-table-column>
|
||||||
|
<el-table-column label="备注" align="center" prop="remark" />
|
||||||
|
<el-table-column label="创建时间" align="center" prop="createTime" width="180">
|
||||||
|
<template slot-scope="scope">
|
||||||
|
<span>{{ parseTime(scope.row.createTime) }}</span>
|
||||||
|
</template>
|
||||||
|
</el-table-column>
|
||||||
|
<el-table-column label="操作" align="center" class-name="small-padding fixed-width" width="150">
|
||||||
|
<template slot-scope="scope">
|
||||||
|
<el-button size="mini" type="text" icon="el-icon-share" @click="handleSendNotify(scope.row)"
|
||||||
|
v-hasPermi="['system:notify-template:send-notify']">测试</el-button>
|
||||||
|
<el-button size="mini" type="text" icon="el-icon-edit" @click="handleUpdate(scope.row)"
|
||||||
|
v-hasPermi="['system:notify-template:update']">修改</el-button>
|
||||||
|
<el-button size="mini" type="text" icon="el-icon-delete" @click="handleDelete(scope.row)"
|
||||||
|
v-hasPermi="['system:notify-template:delete']">删除</el-button>
|
||||||
|
</template>
|
||||||
|
</el-table-column>
|
||||||
|
</el-table>
|
||||||
|
<!-- 分页组件 -->
|
||||||
|
<pagination v-show="total > 0" :total="total" :page.sync="queryParams.pageNo" :limit.sync="queryParams.pageSize"
|
||||||
|
@pagination="getList"/>
|
||||||
|
|
||||||
|
<!-- 对话框(添加 / 修改) -->
|
||||||
|
<el-dialog :title="title" :visible.sync="open" width="500px" append-to-body>
|
||||||
|
<el-form ref="form" :model="form" :rules="rules" label-width="140px">
|
||||||
|
<el-form-item label="模版编码" prop="code">
|
||||||
|
<el-input v-model="form.code" placeholder="请输入模版编码" />
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item label="模板名称" prop="name">
|
||||||
|
<el-input v-model="form.name" placeholder="请输入模版名称" />
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item label="发件人名称" prop="nickname">
|
||||||
|
<el-input v-model="form.nickname" placeholder="请输入发件人名称" />
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item label="模板内容" prop="content">
|
||||||
|
<el-input type="textarea" v-model="form.content" placeholder="请输入模板内容" />
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item label="类型" prop="type">
|
||||||
|
<el-select v-model="form.type" placeholder="请选择类型">
|
||||||
|
<el-option v-for="dict in this.getDictDatas(DICT_TYPE.SYSTEM_NOTIFY_TEMPLATE_TYPE)"
|
||||||
|
:key="dict.value" :label="dict.label" :value="parseInt(dict.value)" />
|
||||||
|
</el-select>
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item label="开启状态" prop="status">
|
||||||
|
<el-radio-group v-model="form.status">
|
||||||
|
<el-radio v-for="dict in this.getDictDatas(DICT_TYPE.COMMON_STATUS)"
|
||||||
|
:key="dict.value" :label="parseInt(dict.value)">{{dict.label}}</el-radio>
|
||||||
|
</el-radio-group>
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item label="备注" prop="remark">
|
||||||
|
<el-input v-model="form.remark" placeholder="请输入备注" />
|
||||||
|
</el-form-item>
|
||||||
|
</el-form>
|
||||||
|
<div slot="footer" class="dialog-footer">
|
||||||
|
<el-button type="primary" @click="submitForm">确 定</el-button>
|
||||||
|
<el-button @click="cancel">取 消</el-button>
|
||||||
|
</div>
|
||||||
|
</el-dialog>
|
||||||
|
|
||||||
|
<!-- 对话框(发送站内信) -->
|
||||||
|
<el-dialog title="发送站内信" :visible.sync="sendNotifyOpen" width="500px" append-to-body>
|
||||||
|
<el-form ref="sendNotifyForm" :model="sendNotifyForm" :rules="sendNotifyRules" label-width="140px">
|
||||||
|
<el-form-item label="模板内容" prop="content">
|
||||||
|
<el-input v-model="sendNotifyForm.content" type="textarea" placeholder="请输入模板内容" readonly />
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item label="接收人" prop="userId">
|
||||||
|
<el-select v-model="sendNotifyForm.userId" placeholder="请输入接收人" clearable style="width: 100%">
|
||||||
|
<el-option v-for="item in users" :key="parseInt(item.id)" :label="item.nickname" :value="parseInt(item.id)" />
|
||||||
|
</el-select>
|
||||||
|
</el-form-item>
|
||||||
|
<el-form-item v-for="param in sendNotifyForm.params" :key="param" :label="'参数 {' + param + '}'" :prop="'templateParams.' + param">
|
||||||
|
<el-input v-model="sendNotifyForm.templateParams[param]" :placeholder="'请输入 ' + param + ' 参数'" />
|
||||||
|
</el-form-item>
|
||||||
|
</el-form>
|
||||||
|
<div slot="footer" class="dialog-footer">
|
||||||
|
<el-button type="primary" @click="submitSendNotifyForm">确 定</el-button>
|
||||||
|
<el-button @click="cancelSendNotify">取 消</el-button>
|
||||||
|
</div>
|
||||||
|
</el-dialog>
|
||||||
|
|
||||||
|
</div>
|
||||||
|
</template>
|
||||||
|
|
||||||
|
<script>
|
||||||
|
import { createNotifyTemplate, updateNotifyTemplate, deleteNotifyTemplate, getNotifyTemplate, getNotifyTemplatePage,
|
||||||
|
sendNotify } from "@/api/system/notify/template";
|
||||||
|
import {listSimpleUsers} from "@/api/system/user";
|
||||||
|
import {CommonStatusEnum} from "@/utils/constants";
|
||||||
|
|
||||||
|
export default {
|
||||||
|
name: "NotifyTemplate",
|
||||||
|
data() {
|
||||||
|
return {
|
||||||
|
// 遮罩层
|
||||||
|
loading: true,
|
||||||
|
// 显示搜索条件
|
||||||
|
showSearch: true,
|
||||||
|
// 总条数
|
||||||
|
total: 0,
|
||||||
|
// 短信模板列表
|
||||||
|
list: [],
|
||||||
|
// 弹出层标题
|
||||||
|
title: "",
|
||||||
|
// 是否显示弹出层
|
||||||
|
open: false,
|
||||||
|
// 查询参数
|
||||||
|
queryParams: {
|
||||||
|
pageNo: 1,
|
||||||
|
pageSize: 10,
|
||||||
|
status: null,
|
||||||
|
code: null,
|
||||||
|
title: null,
|
||||||
|
createTime: []
|
||||||
|
},
|
||||||
|
// 表单参数
|
||||||
|
form: {},
|
||||||
|
// 表单校验
|
||||||
|
rules: {
|
||||||
|
name: [{ required: true, message: "模板名称不能为空", trigger: "blur" }],
|
||||||
|
code: [{ required: true, message: "模版编码不能为空", trigger: "blur" }],
|
||||||
|
nickname: [{ required: true, message: "发件人名称不能为空", trigger: "blur" }],
|
||||||
|
content: [{ required: true, message: "模版内容不能为空", trigger: "blur" }],
|
||||||
|
type: [{ required: true, message: "类型不能为空", trigger: "change" }],
|
||||||
|
status: [{ required: true, message: "状态不能为空", trigger: "blur" }],
|
||||||
|
},
|
||||||
|
// 用户列表
|
||||||
|
users: [],
|
||||||
|
// 发送短信
|
||||||
|
sendNotifyOpen: false,
|
||||||
|
sendNotifyForm: {
|
||||||
|
params: [], // 模板的参数列表
|
||||||
|
},
|
||||||
|
sendNotifyRules: {
|
||||||
|
userId: [{ required: true, message: "接收人不能为空", trigger: "blur" }],
|
||||||
|
templateCode: [{ required: true, message: "模版编码不能为空", trigger: "blur" }],
|
||||||
|
templateParams: { }
|
||||||
|
}
|
||||||
|
};
|
||||||
|
},
|
||||||
|
created() {
|
||||||
|
this.getList();
|
||||||
|
// 获得用户列表
|
||||||
|
listSimpleUsers().then(response => {
|
||||||
|
this.users = response.data;
|
||||||
|
})
|
||||||
|
},
|
||||||
|
methods: {
|
||||||
|
/** 查询列表 */
|
||||||
|
getList() {
|
||||||
|
this.loading = true;
|
||||||
|
// 执行查询
|
||||||
|
getNotifyTemplatePage(this.queryParams).then(response => {
|
||||||
|
this.list = response.data.list;
|
||||||
|
this.total = response.data.total;
|
||||||
|
this.loading = false;
|
||||||
|
});
|
||||||
|
},
|
||||||
|
/** 取消按钮 */
|
||||||
|
cancel() {
|
||||||
|
this.open = false;
|
||||||
|
this.reset();
|
||||||
|
},
|
||||||
|
/** 表单重置 */
|
||||||
|
reset() {
|
||||||
|
this.form = {
|
||||||
|
id: undefined,
|
||||||
|
name: undefined,
|
||||||
|
code: undefined,
|
||||||
|
nickname: undefined,
|
||||||
|
content: undefined,
|
||||||
|
type: undefined,
|
||||||
|
params: undefined,
|
||||||
|
status: CommonStatusEnum.ENABLE,
|
||||||
|
remark: undefined,
|
||||||
|
};
|
||||||
|
this.resetForm("form");
|
||||||
|
},
|
||||||
|
/** 搜索按钮操作 */
|
||||||
|
handleQuery() {
|
||||||
|
this.queryParams.pageNo = 1;
|
||||||
|
this.getList();
|
||||||
|
},
|
||||||
|
/** 重置按钮操作 */
|
||||||
|
resetQuery() {
|
||||||
|
this.resetForm("queryForm");
|
||||||
|
this.handleQuery();
|
||||||
|
},
|
||||||
|
/** 新增按钮操作 */
|
||||||
|
handleAdd() {
|
||||||
|
this.reset();
|
||||||
|
this.open = true;
|
||||||
|
this.title = "添加站内信模板";
|
||||||
|
},
|
||||||
|
/** 修改按钮操作 */
|
||||||
|
handleUpdate(row) {
|
||||||
|
this.reset();
|
||||||
|
const id = row.id;
|
||||||
|
getNotifyTemplate(id).then(response => {
|
||||||
|
this.form = response.data;
|
||||||
|
this.open = true;
|
||||||
|
this.title = "修改站内信模板";
|
||||||
|
});
|
||||||
|
},
|
||||||
|
/** 提交按钮 */
|
||||||
|
submitForm() {
|
||||||
|
this.$refs["form"].validate(valid => {
|
||||||
|
if (!valid) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
// 修改的提交
|
||||||
|
if (this.form.id != null) {
|
||||||
|
updateNotifyTemplate(this.form).then(response => {
|
||||||
|
this.$modal.msgSuccess("修改成功");
|
||||||
|
this.open = false;
|
||||||
|
this.getList();
|
||||||
|
});
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
// 添加的提交
|
||||||
|
createNotifyTemplate(this.form).then(response => {
|
||||||
|
this.$modal.msgSuccess("新增成功");
|
||||||
|
this.open = false;
|
||||||
|
this.getList();
|
||||||
|
});
|
||||||
|
});
|
||||||
|
},
|
||||||
|
/** 删除按钮操作 */
|
||||||
|
handleDelete(row) {
|
||||||
|
const id = row.id;
|
||||||
|
this.$modal.confirm('是否确认删除站内信模板编号为"' + id + '"的数据项?').then(function() {
|
||||||
|
return deleteNotifyTemplate(id);
|
||||||
|
}).then(() => {
|
||||||
|
this.getList();
|
||||||
|
this.$modal.msgSuccess("删除成功");
|
||||||
|
}).catch(() => {});
|
||||||
|
},
|
||||||
|
/** 发送站内信按钮 */
|
||||||
|
handleSendNotify(row) {
|
||||||
|
this.resetSendNotify(row);
|
||||||
|
// 设置参数
|
||||||
|
this.sendNotifyForm.content = row.content;
|
||||||
|
this.sendNotifyForm.params = row.params;
|
||||||
|
this.sendNotifyForm.templateCode = row.code;
|
||||||
|
this.sendNotifyForm.templateParams = row.params.reduce(function(obj, item) {
|
||||||
|
obj[item] = undefined;
|
||||||
|
return obj;
|
||||||
|
}, {});
|
||||||
|
// 根据 row 重置 rules
|
||||||
|
this.sendNotifyRules.templateParams = row.params.reduce(function(obj, item) {
|
||||||
|
obj[item] = { required: true, message: '参数 ' + item + " 不能为空", trigger: "change" };
|
||||||
|
return obj;
|
||||||
|
}, {});
|
||||||
|
// 设置打开
|
||||||
|
this.sendNotifyOpen = true;
|
||||||
|
},
|
||||||
|
/** 重置发送站内信的表单 */
|
||||||
|
resetSendNotify() {
|
||||||
|
// 根据 row 重置表单
|
||||||
|
this.sendNotifyForm = {
|
||||||
|
content: undefined,
|
||||||
|
params: undefined,
|
||||||
|
userId: undefined,
|
||||||
|
templateCode: undefined,
|
||||||
|
templateParams: {}
|
||||||
|
};
|
||||||
|
this.resetForm("sendNotifyForm");
|
||||||
|
},
|
||||||
|
/** 取消发送站内信 */
|
||||||
|
cancelSendNotify() {
|
||||||
|
this.sendNotifyOpen = false;
|
||||||
|
this.resetSendNotify();
|
||||||
|
},
|
||||||
|
/** 提交按钮 */
|
||||||
|
submitSendNotifyForm() {
|
||||||
|
this.$refs["sendNotifyForm"].validate(valid => {
|
||||||
|
if (!valid) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
// 添加的提交
|
||||||
|
sendNotify(this.sendNotifyForm).then(response => {
|
||||||
|
this.$modal.msgSuccess("提交发送成功！发送结果，见发送日志编号：" + response.data);
|
||||||
|
this.sendNotifyOpen = false;
|
||||||
|
});
|
||||||
|
});
|
||||||
|
},
|
||||||
|
}
|
||||||
|
};
|
||||||
|
</script>
|
||||||
Loading…
Reference in New Issue