package com.qxueyou.scc.controller;
|
|
import java.util.List;
|
import java.util.Map;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.CrossOrigin;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestMethod;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
import com.alibaba.druid.util.StringUtils;
|
import com.qxueyou.scc.base.model.Pager;
|
import com.qxueyou.scc.base.model.Result;
|
import com.qxueyou.scc.base.util.CollectionUtils;
|
import com.qxueyou.scc.base.util.QBeanUtils;
|
import com.qxueyou.scc.msg.model.MsgInfo;
|
import com.qxueyou.scc.msg.service.IMsgInfoService;
|
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
|
@Api(tags="消息管理接口")
|
@Controller
|
@CrossOrigin(origins="*",maxAge=3600)
|
@RequestMapping(value = "/msg/msg/")
|
public class MsgInfoController {
|
|
// 分页查询中，默认记录条数和页数
|
private static final int DEFAULT_PAGE_SIZE = 10;
|
private static final int DEFAULT_PAGE_NUM = 1;
|
|
@Autowired
|
IMsgInfoService msgInfoService;
|
|
/**
|
* 消息列表
|
*/
|
@ApiOperation(value = "获取消息列表")
|
@RequestMapping(value = "list", method = RequestMethod.GET)
|
public @ResponseBody Result list(Short type,Integer pageSize,Integer pageNum) {
|
pageSize = pageSize != null && pageSize > 0 ? pageSize : DEFAULT_PAGE_SIZE;
|
pageNum = pageNum != null && pageNum > 0 ? pageNum : DEFAULT_PAGE_NUM;
|
|
//消息数量
|
int totalCount = msgInfoService.listCount(type);
|
Pager pager = new Pager(pageSize,pageNum);
|
pager.setTotalCount(totalCount);
|
|
List<MsgInfo> list = msgInfoService.list(type,pageSize,pageNum);
|
|
List<Map<String, Object>> listResult =QBeanUtils.listBean2ListMap(list,
|
CollectionUtils.newStringMap("msgId", "msgId", "type", "type", "content", "content",
|
"readFlag","readFlag","createTime", "createTime"));
|
|
return new Result(true,"",CollectionUtils.newObjectMap("msgList",listResult,"page",pager));
|
}
|
|
/**
|
* 删除消息
|
* @param msgIds
|
* @return
|
*/
|
@ApiOperation(value = "删除消息")
|
@RequestMapping(value = "delete", method = RequestMethod.GET)
|
public @ResponseBody Result deleteUserMsg(String msgIds){
|
if(StringUtils.isEmpty(msgIds)){
|
return new Result(false,"参数错误！");
|
}
|
|
return this.msgInfoService.deleteUserMsg(msgIds.split(","));
|
}
|
|
/**
|
* 清空个人消息
|
*
|
* @return
|
*/
|
@ApiOperation(value = "清空消息")
|
@RequestMapping(value = "clear", method = RequestMethod.GET)
|
public @ResponseBody Result deleteAllUserMsg(Short type){
|
return this.msgInfoService.deleteAllUserMsg(type);
|
}
|
|
/**
|
* 修改已读标志位
|
* @param msgId
|
* @return
|
*/
|
@ApiOperation(value = "更新为已读")
|
@RequestMapping(value = "read", method = RequestMethod.GET)
|
public @ResponseBody Result updateReadFlag(String msgIds){
|
return this.msgInfoService.updateReadStatus(msgIds.split(","));
|
}
|
|
/**
|
* 全部已读
|
* @param msgId
|
* @return
|
*/
|
@ApiOperation(value = "全部更新为已读")
|
@RequestMapping(value = "readall", method = RequestMethod.GET)
|
public @ResponseBody Result updateAllUserReadFlag(Short type){
|
return this.msgInfoService.updateUserAllReadStatus(type);
|
}
|
|
|
/**
|
* 最近的提醒消息
|
* @param msgId
|
* @return
|
*/
|
@ApiOperation(value = "最近的一条提醒信息")
|
@RequestMapping(value = "last", method = RequestMethod.GET)
|
public @ResponseBody Result getLatest(){
|
return new Result(true,"",this.msgInfoService.readLastRemindMsg());
|
}
|
|
|
/**
|
* 最近的提醒消息
|
* @param msgId
|
* @return
|
*/
|
@ApiOperation(value = "按类型获取未读消息的数量")
|
@RequestMapping(value = "count", method = RequestMethod.GET)
|
public @ResponseBody Result queryUnReadMsgCountByType(){
|
return new Result(true,"",this.msgInfoService.queryUnReadMsgCountByType());
|
}
|
|
/**
|
* 查询未读消息总数
|
* @param msgId
|
* @return
|
*/
|
@ApiOperation(value = "查询用户未读消息总数")
|
@RequestMapping(value = "totalcount", method = RequestMethod.GET)
|
public @ResponseBody Result queryUnReadTotalCount(){
|
return new Result(true,"",CollectionUtils.newObjectMap("totalCount",this.msgInfoService.queryUnReadTotalCount()));
|
}
|
|
}
|
