You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
277 lines
11 KiB
Java
277 lines
11 KiB
Java
5 years ago
|
package com.manage.controller;
|
||
|
|
|
||
|
|
import com.alibaba.fastjson.JSON;
|
||
|
|
import com.manage.annotation.OptionalLog;
|
||
|
|
import com.manage.dao.Power_NoticeMapper;
|
||
|
|
import com.manage.entity.Power_Notice;
|
||
|
|
import com.manage.entity.Power_User;
|
||
|
|
import com.manage.service.cache.CacheManager;
|
||
|
|
import com.manage.service.ipml.Power_NoticeServiceImpl;
|
||
|
|
import com.manage.util.Msg;
|
||
|
|
import com.manage.util.PageHelper;
|
||
|
|
import com.manage.vo.*;
|
||
|
|
import org.apache.commons.lang3.StringUtils;
|
||
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
||
|
|
import org.springframework.stereotype.Controller;
|
||
|
|
import org.springframework.ui.Model;
|
||
|
|
import org.springframework.web.bind.annotation.RequestMapping;
|
||
|
|
import org.springframework.web.bind.annotation.ResponseBody;
|
||
|
|
|
||
|
|
import javax.servlet.http.HttpServletRequest;
|
||
|
|
import javax.servlet.http.HttpServletResponse;
|
||
|
|
import java.util.*;
|
||
|
|
|
||
|
|
@Controller
|
||
|
|
@RequestMapping("notice/")
|
||
|
|
public class Power_NoticeController {
|
||
|
|
@Autowired
|
||
|
|
private Power_NoticeServiceImpl noticeService;
|
||
|
|
@Autowired
|
||
|
|
private Power_NoticeMapper noticeMapper;
|
||
|
|
@OptionalLog(module = "查看",methods = "通知管理页面")
|
||
|
|
@RequestMapping(value = "pageUI")
|
||
|
|
public String notice(HttpServletRequest request, Model model){
|
||
|
|
noticeService.loadSys(request,model);
|
||
|
|
model.addAttribute("user",(Power_User)request.getSession().getAttribute("CURRENT_USER"));
|
||
|
|
CacheManager.addExcCount("noExc");
|
||
|
|
return "/noticeDir/noticePage";
|
||
|
|
}
|
||
|
|
|
||
|
|
@RequestMapping(value = "selectAll",produces = "application/json; charset=utf-8")
|
||
|
|
@ResponseBody
|
||
|
|
public PageHelper<Power_NoticeVo> selectAll(Power_NoticeVo notice, HttpServletRequest request) {
|
||
|
|
PageHelper<Power_NoticeVo>pageHelper = new PageHelper<Power_NoticeVo>();
|
||
|
|
Power_User user = (Power_User)request.getSession().getAttribute("CURRENT_USER");
|
||
|
|
List<Power_NoticeVo>power_notices = new ArrayList<Power_NoticeVo>();
|
||
|
|
List<Power_NoticeVo> getTatal = new ArrayList<Power_NoticeVo>();
|
||
|
|
try {
|
||
|
|
/*if(user.getRoleId() == 0){
|
||
|
|
power_notices = this.noticeMapper.selectSysByAdmin(null,null,notice);
|
||
|
|
}else{
|
||
|
|
power_notices = this.noticeMapper.selectSysByAdmin(user.getRoleId(),user.getUserId(),notice);
|
||
|
|
}*/
|
||
|
|
if(user.getRoleId() == 0){
|
||
|
|
getTatal = this.noticeMapper.getTotal(null,null,notice);
|
||
|
|
power_notices = this.noticeMapper.selectALlByPower(null,null,notice);
|
||
|
|
}else{
|
||
|
|
getTatal = this.noticeMapper.getTotal(user.getRoleId(),user.getUserId(),notice);
|
||
|
|
power_notices = this.noticeMapper.selectALlByPower(user.getRoleId(),user.getUserId(),notice);
|
||
|
|
}
|
||
|
|
pageHelper.setTotal(getTatal.size());
|
||
|
|
//查询当前页实体对象
|
||
|
|
pageHelper.setRows(power_notices);
|
||
|
|
CacheManager.addExcCount("noExc");
|
||
|
|
return pageHelper;
|
||
|
|
}catch (Exception e){
|
||
|
|
CacheManager.addExcCount("exc");
|
||
|
|
e.printStackTrace();
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
public List<Power_Notice> putChildren(List<Power_Notice> moduleList, Power_NoticeVo notice,Power_User user) {
|
||
|
|
if (moduleList.size() > 0) {
|
||
|
|
for (Power_Notice mod2 : moduleList) {
|
||
|
|
HashMap param = new HashMap();
|
||
|
|
notice.setParentId(mod2.getNoticeId());
|
||
|
|
List<Power_Notice> res2 = new ArrayList<>();
|
||
|
|
if(user.getRoleId() == -100 || user.getRoleId() == 0){
|
||
|
|
res2 = this.noticeMapper.selectNoticeListByParentId(notice,null);
|
||
|
|
}else{
|
||
|
|
res2 = this.noticeMapper.selectNoticeListByParentId(notice,user.getUserId());
|
||
|
|
}
|
||
|
|
if (res2.size() > 0) {
|
||
|
|
res2 = putChildren(res2,notice,user);
|
||
|
|
}
|
||
|
|
mod2.setChildren(res2);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return moduleList;
|
||
|
|
}
|
||
|
|
|
||
|
|
@RequestMapping(value = "getNoticeTypeTree",produces = {"text/json;charset=UTF-8"})
|
||
|
|
@ResponseBody
|
||
|
|
public String getNoticeTypeTree(){
|
||
|
|
try {
|
||
|
|
List<PowerTree> treeList = noticeService.getNoticeTypeTree();
|
||
|
|
CacheManager.addExcCount("noExc");
|
||
|
|
return JSON.toJSONString(treeList);
|
||
|
|
}catch (Exception e){
|
||
|
|
CacheManager.addExcCount("exc");
|
||
|
|
e.printStackTrace();
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
@RequestMapping(value = "checkTypeSysFlagOrTypeSysName")
|
||
|
|
@ResponseBody
|
||
|
|
public Msg checkTypeSysFlag(String noticeTypeFlag,String noticeTypeName){
|
||
|
|
try {
|
||
|
|
if(StringUtils.isNoneBlank(noticeTypeFlag) || StringUtils.isNotBlank(noticeTypeName)) {
|
||
|
|
Power_Notice powerNotice = noticeService.checkTypeSysFlagOrTypeSysName(noticeTypeFlag, noticeTypeName);
|
||
|
|
CacheManager.addExcCount("noExc");
|
||
|
|
if (null != powerNotice) {
|
||
|
|
return Msg.fail();
|
||
|
|
} else {
|
||
|
|
return Msg.success();
|
||
|
|
}
|
||
|
|
}else{
|
||
|
|
return Msg.fail("查询出错,请联系系统管理员!");
|
||
|
|
}
|
||
|
|
}catch (Exception e){
|
||
|
|
CacheManager.addExcCount("exc");
|
||
|
|
e.printStackTrace();
|
||
|
|
return Msg.fail("查询出错,请联系系统管理员!");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
@RequestMapping(value = "update")
|
||
|
|
@ResponseBody
|
||
|
|
public Msg udpate(Power_Notice powerNotice,HttpServletRequest request){
|
||
|
|
try {
|
||
|
|
//保存类别
|
||
|
|
if(StringUtils.isNotBlank(powerNotice.getNoticeTypeFlag())){
|
||
|
|
//验证用户名
|
||
|
|
Power_Notice typeNotice = noticeService.checkTypeSysFlagOrTypeSysName(powerNotice.getNoticeTypeFlag(), null);
|
||
|
|
Power_Notice nameNotice = noticeService.checkTypeSysFlagOrTypeSysName(null,powerNotice.getNoticeTypeName());
|
||
|
|
//添加类别
|
||
|
|
if (null == powerNotice.getNoticeId()) {
|
||
|
|
if(null != typeNotice){
|
||
|
|
return Msg.fail("类别标志已存在!");
|
||
|
|
}
|
||
|
|
if(null != nameNotice){
|
||
|
|
return Msg.fail("类别名称已存在!");
|
||
|
|
}
|
||
|
|
noticeService.update(powerNotice,request);
|
||
|
|
} else {
|
||
|
|
//修改类别
|
||
|
|
if(null != typeNotice && !typeNotice.getNoticeId().equals(powerNotice.getNoticeId())){
|
||
|
|
return Msg.fail("类别标志已存在!");
|
||
|
|
}
|
||
|
|
if(null != nameNotice && !nameNotice.getNoticeId().equals(powerNotice.getNoticeId())){
|
||
|
|
return Msg.fail("类别名称已存在!");
|
||
|
|
}
|
||
|
|
noticeService.update(powerNotice,request);
|
||
|
|
}
|
||
|
|
}else{
|
||
|
|
//保存通知
|
||
|
|
noticeService.update(powerNotice,request);
|
||
|
|
}
|
||
|
|
CacheManager.addExcCount("noExc");
|
||
|
|
return Msg.success();
|
||
|
|
}catch (Exception e){
|
||
|
|
e.printStackTrace();
|
||
|
|
CacheManager.addExcCount("exc");
|
||
|
|
return Msg.fail("查询出错,请联系系统管理员!");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
@OptionalLog(module = "删除",methods = "通知管理",fieldName = "noticeContent",fieldName1="noticeTypeName",tableName = "power_notice")
|
||
|
|
@RequestMapping(value = "delete")
|
||
|
|
@ResponseBody
|
||
|
|
public Msg delete(Integer noticeId){
|
||
|
|
try {
|
||
|
|
noticeService.delete(noticeId);
|
||
|
|
CacheManager.addExcCount("noExc");
|
||
|
|
return Msg.success();
|
||
|
|
}catch (Exception e){
|
||
|
|
CacheManager.addExcCount("exc");
|
||
|
|
e.printStackTrace();
|
||
|
|
return Msg.fail();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
/************************************************通知操作***************************************************/
|
||
|
|
@RequestMapping(value = "getUserNameListByNoticeTypeId")
|
||
|
|
@ResponseBody
|
||
|
|
public Msg getUserNameListByNoticeTypeId(Integer noticeTypeId, HttpServletRequest request){
|
||
|
|
try {
|
||
|
|
List<Power_UserVo> userList = noticeService.getUserNameListByNoticeTypeId(noticeTypeId, request);
|
||
|
|
CacheManager.addExcCount("noExc");
|
||
|
|
return Msg.success().add("userList",userList);
|
||
|
|
}catch (Exception e){
|
||
|
|
CacheManager.addExcCount("exc");
|
||
|
|
e.printStackTrace();
|
||
|
|
return Msg.fail("查询出错,请联系系统管理员!");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
@RequestMapping(value = "selectNoticeByNoticeId")
|
||
|
|
@ResponseBody
|
||
|
|
public Msg selectNoticeByNoticeId(Integer noticeId){
|
||
|
|
try {
|
||
|
|
Power_Notice powerNotice = noticeMapper.selectByPrimaryKey(noticeId);
|
||
|
|
CacheManager.addExcCount("noExc");
|
||
|
|
return Msg.success().add("powerNotice",powerNotice);
|
||
|
|
}catch (Exception e){
|
||
|
|
CacheManager.addExcCount("exc");
|
||
|
|
e.printStackTrace();
|
||
|
|
return Msg.fail("查询出错,请联系系统管理员!");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
@OptionalLog(module = "导出excel",methods = "通知管理")
|
||
|
|
@RequestMapping(value = "export")
|
||
|
|
@ResponseBody
|
||
|
|
public void export(Power_NoticeVo powerNoticeVo,String noticeIds, HttpServletResponse response, HttpServletRequest request){
|
||
|
|
try {
|
||
|
|
noticeService.export(powerNoticeVo,noticeIds,response,request);
|
||
|
|
CacheManager.addExcCount("noExc");
|
||
|
|
}catch (Exception e){
|
||
|
|
CacheManager.addExcCount("exc");
|
||
|
|
e.printStackTrace();
|
||
|
|
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
@RequestMapping(value = "updateNoticeReadFlag")
|
||
|
|
@ResponseBody
|
||
|
|
public Msg updateNoticeReadFlag(Integer noticeId){
|
||
|
|
try {
|
||
|
|
noticeService.updateNoticeReadFlag(noticeId);
|
||
|
|
CacheManager.addExcCount("noExc");
|
||
|
|
return Msg.success();
|
||
|
|
}catch (Exception e){
|
||
|
|
CacheManager.addExcCount("exc");
|
||
|
|
e.printStackTrace();
|
||
|
|
return Msg.fail("修改出错了,请联系系统管理员!");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @MethodName getUnReadCount
|
||
|
|
* @Description: 根据用户获取未读通知数量
|
||
|
|
* @Param 无
|
||
|
|
* @Returnt Msg
|
||
|
|
* @Author: 曾文和
|
||
|
|
* @CreateDate: 2019-10-17
|
||
|
|
* @UpdateUser: 曾文和
|
||
|
|
* @UpdateDate: 2019-10-17
|
||
|
|
* @UpdateRemark: 更新说明
|
||
|
|
* @Version: 1.2.2
|
||
|
|
*/
|
||
|
|
@RequestMapping("getUnReadCount")
|
||
|
|
@ResponseBody
|
||
|
|
public Msg getUnReadCount(HttpServletRequest request){
|
||
|
|
try {
|
||
|
|
//获取登录者信息
|
||
|
|
Power_UserVo user = (Power_UserVo)request.getSession().getAttribute("CURRENT_USER");
|
||
|
|
Integer userId = null;
|
||
|
|
//系统管理员userId为null,非系统管理员传入userId
|
||
|
|
if(user.getRoleId() != 0){
|
||
|
|
userId = user.getRoleId();
|
||
|
|
}
|
||
|
|
int unReadCount = noticeService.getUnReadCount(userId);
|
||
|
|
CacheManager.addExcCount("noExc");
|
||
|
|
return Msg.success().add("unReadCount",unReadCount);
|
||
|
|
}catch (Exception e){
|
||
|
|
CacheManager.addExcCount("exc");
|
||
|
|
e.printStackTrace();
|
||
|
|
return Msg.fail(e.getMessage());
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|