package com.shlanbao.tzsc.pms.sys.user.controller;
|
|
import java.text.ParseException;
|
import java.util.*;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpSession;
|
|
import com.shlanbao.tzsc.base.mapping.MdEquipment;
|
import com.shlanbao.tzsc.init.BaseParams;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
import com.alibaba.fastjson.JSON;
|
import com.shlanbao.tzsc.base.controller.BaseController;
|
import com.shlanbao.tzsc.base.dao.SchStatFaultDaoI;
|
import com.shlanbao.tzsc.base.dao.SysUserDaoI;
|
import com.shlanbao.tzsc.base.mapping.SchStatFault;
|
import com.shlanbao.tzsc.base.mapping.SysModelPermis;
|
import com.shlanbao.tzsc.base.model.DataGrid;
|
import com.shlanbao.tzsc.base.model.Json;
|
import com.shlanbao.tzsc.base.model.PageParams;
|
import com.shlanbao.tzsc.base.model.SessionInfo;
|
import com.shlanbao.tzsc.base.model.Tree;
|
import com.shlanbao.tzsc.pms.md.fixCode.beans.FixCodeBean;
|
import com.shlanbao.tzsc.pms.md.fixCode.service.FixCodeServiceI;
|
import com.shlanbao.tzsc.pms.qm.check.service.impl.QmCheckMassServiceImpl;
|
import com.shlanbao.tzsc.pms.qm.onlineCheck.bean.QMOnlineCheckBean;
|
import com.shlanbao.tzsc.pms.qm.onlineCheck.service.QMOnlineCheckService;
|
import com.shlanbao.tzsc.pms.qm.onlineCheck.service.impl.QmOnlineCheckServiceImpl;
|
import com.shlanbao.tzsc.pms.sys.org.service.OrgServiceI;
|
import com.shlanbao.tzsc.pms.sys.resource.service.ResourceServiceI;
|
import com.shlanbao.tzsc.pms.sys.role.beans.RoleBean;
|
import com.shlanbao.tzsc.pms.sys.role.service.RoleServiceI;
|
import com.shlanbao.tzsc.pms.sys.user.beans.UserBean;
|
import com.shlanbao.tzsc.pms.sys.user.service.ModelPermisServiceI;
|
import com.shlanbao.tzsc.pms.sys.user.service.UserServiceI;
|
import com.shlanbao.tzsc.pms.sys.user.service.schStatFaultServiceI;
|
import com.shlanbao.tzsc.utils.tools.MD5Util;
|
import com.shlanbao.tzsc.utils.tools.WebContextUtil;
|
|
import net.sf.json.JSONArray;
|
/**
|
* 用户管理控制器
|
* <li>@author Leejean
|
* <li>@create 2014-6-27下午02:56:31
|
*/
|
@Controller
|
@RequestMapping("/pms/sysUser")
|
public class UserController extends BaseController{
|
private static final ResourceBundle bundle = ResourceBundle.getBundle("config");
|
@Autowired
|
private UserServiceI userService;
|
@Autowired
|
private OrgServiceI orgService;
|
@Autowired
|
private ResourceServiceI resourceService;
|
@Autowired
|
private RoleServiceI roleService;
|
|
@Autowired
|
private ModelPermisServiceI modelService;
|
|
@Autowired
|
private QMOnlineCheckService service;
|
|
@Autowired
|
private FixCodeServiceI fixService;
|
@Autowired
|
private schStatFaultServiceI schService;
|
|
/**
|
* 首页
|
* @author Leejean
|
* @create 2014-8-14下午07:03:44
|
* @return
|
*/
|
@RequestMapping("/index")
|
public String index(HttpServletRequest request){
|
try {
|
String pms_websocket = bundle.getString("pms_websocket");
|
String wct_websocket = bundle.getString("wct_websocket");
|
if(pms_websocket!=null){
|
request.setAttribute("pms_websocket",pms_websocket);
|
}
|
if(wct_websocket!=null){
|
request.setAttribute("wct_websocket",wct_websocket);
|
}
|
|
return "/pms/index";
|
} catch (Exception e) {
|
log.error(message, e);
|
}
|
return "/error/noResource";
|
}
|
/**
|
* 退出
|
* @author Leejean
|
* @create 2014-8-14下午07:03:44
|
* @return
|
*/
|
@RequestMapping("/exit")
|
public String exit(HttpSession session){
|
try {
|
session.invalidate();
|
return "/pms/sys/user/login";
|
} catch (Exception e) {
|
log.error(message, e);
|
}
|
return "/error/noResource";
|
}
|
/**
|
* 用户登录
|
* @author Leejean
|
* @create 2014-6-27下午03:00:36
|
*/
|
@ResponseBody
|
@RequestMapping("/login")
|
public Json login(UserBean userBean,HttpSession session,HttpServletRequest request){
|
Json json=new Json();
|
try {
|
userBean=userService.login(userBean);
|
if(userBean!=null){
|
String uid=userBean.getId();
|
json.setMsg("登录成功!");
|
json.setSuccess(true);
|
|
SessionInfo sessionInfo=new SessionInfo();
|
sessionInfo.setUser(userBean);
|
sessionInfo.setIp(WebContextUtil.getRemoteIp(request));
|
//得到用户的机构
|
List<Tree> organizations=orgService.getOrgsByUser(userBean.getId());
|
sessionInfo.setOrganizations(JSON.toJSONString(organizations));
|
|
//得到用户的角色
|
List<RoleBean> roles=roleService.getRolesByUser(uid);
|
sessionInfo.setRoles(roles);
|
|
//得到用户的权限(显示成树，拥有的权限才会checked=true)
|
List<Tree> resources = resourceService.getResByUser(uid);
|
sessionInfo.setResources(JSON.toJSONString(resources));
|
|
Map<String,String> resourcesMap = new HashMap<String,String>();
|
for (Tree tree : resources) {
|
if(tree.isChecked()){
|
if(tree.getAttributes()!=null){
|
resourcesMap.put(tree.getAttributes().toString(),tree.getText() );
|
}
|
|
}
|
}
|
sessionInfo.setResourcesMap(resourcesMap);
|
|
WebContextUtil.saveObjToSession(session,"sessionInfo", sessionInfo,60*60*8);//保存8小时
|
List <SysModelPermis> list = modelService.getDefaultSysModel(userBean.getId(), roles.get(0).getId());
|
FixCodeBean fcb = new FixCodeBean();
|
fcb.setUpcode("SYZSMK001");
|
List<FixCodeBean> fixList = fixService.queryFixCode(fcb);
|
if(list.size()<=0)
|
{
|
if(fixList.size()>0){
|
for(int i=0;i<fixList.size();i++){
|
fcb = (FixCodeBean)fixList.get(i);
|
if("YZSMK0001001".equals(fcb.getType())){
|
SysModelPermis sp = new SysModelPermis();
|
sp.setRoleId(roles.get(0).getId());
|
sp.setUserId(userBean.getId());
|
sp.setMdFixCodeId(fcb.getId());
|
sp.setCreateTime(new Date());
|
sp.setRemark("默认添加");
|
modelService.insertDefaultSysModel(sp);
|
}
|
}
|
}
|
|
|
}
|
request.setAttribute("sysModelList", list);
|
request.setAttribute("fixList", fixList);
|
}else{
|
json.setMsg("账号密码错误或该用户已被禁用,请重新登录!");
|
}
|
} catch (Exception e) {
|
log.error("用户登录", e);
|
}
|
return json;
|
}
|
|
/**
|
* 锁定用户登录
|
* @author Leejean
|
* @create 2014-7-10下午01:47:16
|
*/
|
@ResponseBody
|
@RequestMapping("/lockUser")
|
public void lockUser(HttpSession session){
|
try {
|
SessionInfo sessionInfo=(SessionInfo)session.getAttribute("sessionInfo");
|
sessionInfo.setIslock(true);
|
} catch (Exception e) {
|
log.error("锁定用户登录", e);
|
}
|
}
|
/**
|
* 用户登录解锁
|
* @author Leejean
|
* @create 2014-7-10下午02:06:47
|
*/
|
@ResponseBody
|
@RequestMapping("/breakLock")
|
public Json breakLock(UserBean userBean,HttpSession session){
|
Json json=new Json();
|
try {
|
SessionInfo sessionInfo=(SessionInfo)session.getAttribute("sessionInfo");
|
if(sessionInfo.getUser().getPwd().equals(MD5Util.SHA256(userBean.getPwd()))){
|
sessionInfo.setIslock(false);
|
json.setMsg("解锁成功");
|
json.setSuccess(true);
|
}else{
|
json.setMsg("密码错误");
|
}
|
} catch (Exception e) {
|
log.error(message, e);
|
}
|
return json;
|
}
|
/**
|
* 修改密码
|
* @author Leejean
|
* @create 2014-7-10下午02:16:36
|
*/
|
@ResponseBody
|
@RequestMapping("/editPwd")
|
public Json editPwd(UserBean userBean,HttpSession session){
|
Json json=new Json();
|
try {
|
SessionInfo sessionInfo=(SessionInfo)session.getAttribute("sessionInfo");
|
UserBean user=sessionInfo.getUser();
|
if(user.getPwd().equals(MD5Util.SHA256(userBean.getOldpwd()))){
|
userService.editPwd(user.getId(),userBean.getPwd());
|
json.setMsg("修改成功");
|
user.setPwd(MD5Util.SHA256(userBean.getPwd()));
|
json.setSuccess(true);
|
}else{
|
json.setMsg("输入的原始密码错误");
|
}
|
} catch (Exception e) {
|
log.error("修改密码异常", e);
|
}
|
return json;
|
}
|
/**
|
* 查询系统用户
|
*/
|
@ResponseBody
|
@RequestMapping("/getAllUser")
|
public DataGrid getAllUser(UserBean userBean,PageParams pageParams){
|
try {
|
return userService.querySysUser(userBean,pageParams);
|
} catch (Exception e) {
|
log.error(message, e);
|
}
|
return null;
|
}
|
@RequestMapping("/goToUserAddJsp")
|
public String goToAddUserJsp(){
|
return "/pms/sys/user/userAdd";
|
}
|
/**
|
* 新建用户
|
*/
|
@ResponseBody
|
@RequestMapping("/addSysUser")
|
public Json addSysUser(UserBean userBean){
|
Json json=new Json();
|
try {
|
userService.addSysUser(userBean);
|
json.setMsg("新增用户成功!");
|
json.setSuccess(true);
|
} catch (Exception e) {
|
log.error(message, e);
|
json.setMsg("新增用户失败!");
|
json.setSuccess(false);
|
}
|
return json;
|
}
|
/**
|
* 编辑用户
|
*/
|
@ResponseBody
|
@RequestMapping("/editSysUser")
|
public Json editSysUser(UserBean userBean){
|
Json json=new Json();
|
try {
|
userService.editSysUser(userBean);
|
json.setMsg("编辑用户成功!");
|
json.setSuccess(true);
|
} catch (Exception e) {
|
log.error(message, e);
|
json.setMsg("编辑用户失败!");
|
json.setSuccess(false);
|
}
|
return json;
|
}
|
/**
|
* 删除用户
|
*/
|
@ResponseBody
|
@RequestMapping("/deleteSysUser")
|
public Json deleteSysUser(String id){
|
Json json=new Json();
|
try {
|
userService.deleteSysUser(id);
|
json.setMsg("删除用户成功!");
|
json.setSuccess(true);
|
} catch (Exception e) {
|
log.error(message, e);
|
json.setMsg("删除用户失败!");
|
json.setSuccess(false);
|
}
|
return json;
|
}
|
/**
|
* 批量删除用户
|
*/
|
@ResponseBody
|
@RequestMapping("/batchDeleteSysUser")
|
public Json batchDeleteSysUser(String ids){
|
Json json=new Json();
|
try {
|
userService.batchDeleteSysUser(ids);
|
json.setMsg("批量删除用户成功!");
|
json.setSuccess(true);
|
} catch (Exception e) {
|
log.error(message, e);
|
json.setMsg("批量删除用户失败!");
|
json.setSuccess(false);
|
}
|
return json;
|
}
|
/**
|
* 跳转到用户编辑页面
|
* @author Leejean
|
* @create 2014-8-14下午07:03:44
|
* @return
|
*/
|
@RequestMapping("/goToUserEditJsp")
|
public String goToUserEditJsp(String id,HttpServletRequest request){
|
try {
|
request.setAttribute("checkedUser", userService.getSysUserById(id));
|
} catch (Exception e) {
|
log.error("跳转到用户编辑页面失败", e);
|
}
|
return "/pms/sys/user/userEdit";
|
}
|
/**
|
* 重置密码
|
* @author Leejean
|
* @create 2014-8-18下午08:36:38
|
* @param id 用户id
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/resetPwd")
|
public Json resetPwd(String id){
|
Json json=new Json();
|
try {
|
userService.editSysUser(new UserBean(id,MD5Util.SHA256("123456")));
|
json.setMsg("重置密码为:123456,为了账户安全,请尽早修改密码!");
|
json.setSuccess(true);
|
} catch (Exception e) {
|
log.error(message, e);
|
json.setMsg("批量删除用户失败!");
|
json.setSuccess(false);
|
}
|
return json;
|
}
|
/**
|
* 重置密码
|
* @author Leejean
|
* @create 2014-8-18下午08:36:38
|
* @param id 用户id
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/enableOrUnenableSysUser")
|
public Json enableOrUnenableSysUser(UserBean userBean){
|
Json json=new Json();
|
try {
|
userService.editSysUser(userBean);
|
json.setMsg("操作成功!");
|
json.setSuccess(true);
|
} catch (Exception e) {
|
log.error(message, e);
|
json.setMsg("操作失败!");
|
json.setSuccess(false);
|
}
|
return json;
|
}
|
/*****************用户-角色******************/
|
/**
|
* 跳转到用户角色分配页面
|
* @author Leejean
|
* @create 2014-8-18下午09:51:14
|
* @param id
|
* @param request
|
* @return
|
*/
|
@RequestMapping("/goToUserAssignRoleJsp")
|
public String goToUserAssignRoleJsp(String id,String name,HttpServletRequest request){
|
try {
|
request.setCharacterEncoding("utf-8");
|
request.setAttribute("checkedUserId", id);
|
request.setAttribute("checkedUserName",name);
|
} catch (Exception e) {
|
log.error("跳转到用户角色分配页面失败", e);
|
}
|
return "/pms/sys/user/assignRole";
|
}
|
/**
|
* 给用户分配角色
|
* @author Leejean
|
* @create 2014-8-19下午03:28:55
|
* @param id 用户id
|
* @param ids 授权角色Ids
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/assignRole")
|
public Json assignRole(String id,String ids){
|
Json json=new Json();
|
try {
|
roleService.assignRole(id,ids);
|
json.setMsg("角色分配成功!");
|
json.setSuccess(true);
|
} catch (Exception e) {
|
log.error(message, e);
|
json.setMsg("操作分配失败!");
|
json.setSuccess(false);
|
}
|
return json;
|
}
|
/**
|
* 获得用户角色
|
* @author Leejean
|
* @create 2014-8-18下午08:36:38
|
* @param id 用户id
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/getRolesByUser")
|
public List<RoleBean> getRolesByUser(String id){
|
try {
|
return roleService.getRolesByUser(id);
|
} catch (Exception e) {
|
log.error(message, e);
|
}
|
return null;
|
}
|
/**
|
* 跳转到用户批量角色分配页面
|
* @author Leejean
|
* @create 2014-8-18下午09:51:14
|
* @param id
|
* @param request
|
* @return
|
*/
|
@RequestMapping("/goToUserBatchAssignRoleJsp")
|
public String goToUserBatchAssignRoleJsp(String ids,String names,HttpServletRequest request){
|
try {
|
request.setAttribute("checkedUserIds", ids);
|
request.setAttribute("checkedUserNames",names);
|
} catch (Exception e) {
|
log.error("跳转到用户角色分配页面失败", e);
|
}
|
return "/pms/sys/user/batchAssignRole";
|
}
|
/**
|
* 用户角色批量分配
|
* @author Leejean
|
* @create 2014-8-19下午07:22:22
|
* @param uids 用户ids
|
* @param rids 角色ids
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/batchAssignRole")
|
public Json batchAssignRole(String uids,String rids){
|
Json json=new Json();
|
try {
|
roleService.batchAssignRole(uids,rids);
|
json.setMsg("用户角色批量分配成功!");
|
json.setSuccess(true);
|
} catch (Exception e) {
|
log.error(message, e);
|
json.setMsg("用户角色批量分配失败!");
|
json.setSuccess(false);
|
}
|
return json;
|
}
|
/*****************用户-机构******************/
|
/**
|
* 跳转到用户组织机构分配页面
|
* @author Leejean
|
* @create 2014-8-18下午09:50:25
|
* @param id
|
* @param request
|
* @return
|
*/
|
@RequestMapping("/goToUserAssignOrgJsp")
|
public String goToUserAssignOrgJsp(String id,HttpServletRequest request){
|
try {
|
request.setAttribute("checkedUserId", id);
|
} catch (Exception e) {
|
log.error("跳转到用户组织机构分配页面失败", e);
|
}
|
return "/pms/sys/user/assignOrg";
|
}
|
/**
|
* 获得用户的机构
|
* @author Leejean
|
* @create 2014-8-18下午08:36:38
|
* @param id 用户id
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/getOrgsByUser")
|
public List<Tree> getOrgsByUser(String id){
|
try {
|
return orgService.getOrgsByUser(id);
|
} catch (Exception e) {
|
log.error(message, e);
|
}
|
return null;
|
}
|
|
/**
|
* 给用户分配组织机构
|
* @author Leejean
|
* @create 2014-8-20上午09:27:20
|
* @param id 用户id
|
* @param ids 组织机构id
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/assignOrg")
|
public Json assignOrg(String id,String ids){
|
Json json=new Json();
|
try {
|
orgService.assignOrg(id,ids);
|
json.setMsg("分配组织机构成功!");
|
json.setSuccess(true);
|
} catch (Exception e) {
|
log.error(message, e);
|
json.setMsg("分配组织机构失败!");
|
json.setSuccess(false);
|
}
|
return json;
|
}
|
/**
|
* 跳转到用户组织机构批量分配页面
|
* @author Leejean
|
* @create 2014-8-18下午09:50:25
|
* @param id
|
* @param request
|
* @return
|
*/
|
@RequestMapping("/goToUserBatchAssignOrgJsp")
|
public String goToUserBatchAssignOrgJsp(String id,HttpServletRequest request){
|
try {
|
//request.setAttribute("checkedUserId", id);
|
} catch (Exception e) {
|
log.error("跳转到用户组织机构批量分配页面", e);
|
}
|
return "/pms/sys/user/batchAssignOrg";
|
}
|
/**
|
* 用户组织机构批量分配
|
* @author Leejean
|
* @create 2014-8-19下午07:22:22
|
* @param uids 用户ids
|
* @param oids 角色ids
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/batchAssignOrg")
|
public Json batchAssignOrg(String uids,String oids){
|
Json json=new Json();
|
try {
|
orgService.batchAssignOrg(uids,oids);
|
json.setMsg("用户组织机构批量分配成功!");
|
json.setSuccess(true);
|
} catch (Exception e) {
|
log.error(message, e);
|
json.setMsg("用户组织机构分配失败!");
|
json.setSuccess(false);
|
}
|
return json;
|
}
|
|
/**
|
* 跳转到统计图编辑页面
|
* @author Rengj
|
* @create 2016-12-23下午13:50:25
|
* @param id
|
* @param request
|
* @return
|
*/
|
@RequestMapping("/goToUserModelJsp")
|
public String goToUserModelJsp(HttpServletRequest request){
|
List list= service.getProdJson();
|
request.setAttribute("Json", JSONArray.fromObject(list));
|
return "/pms/sys/user/model/modelEdit";
|
}
|
|
/**
|
* 跳转到统计图编辑页面
|
* @author Rengj
|
* @create 2016-12-23下午13:50:25
|
* @param id
|
* @param request
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/updateModelPremis")
|
public Json updateModelPremis(String mdFixCodeId,String remark,HttpSession session){
|
Json json=new Json();
|
//得到用户的角色
|
SessionInfo sessionInfo = (SessionInfo) session.getAttribute("sessionInfo");
|
String[] ids = mdFixCodeId.split(",");
|
String[] param = remark.split(",");
|
try {
|
for(int i=0;i<ids.length;i++){
|
List<SysModelPermis> sysModelList = modelService.getSysModel(sessionInfo.getUser().getId(),sessionInfo.getRoles().get(0).getId(), ids[i]);
|
if(sysModelList.size()>0 && "del".equals(param[i])){
|
for(int j = 0;j<sysModelList.size();j++ ){
|
SysModelPermis sp = (SysModelPermis)sysModelList.get(j);
|
modelService.deleteSysModel(sp.getId());
|
}
|
}else if(sysModelList.size()<=0 && "save".equals(param[i])){
|
SysModelPermis smp =new SysModelPermis();
|
smp.setUserId(sessionInfo.getUser().getId());
|
smp.setRoleId(sessionInfo.getRoles().get(0).getId());
|
smp.setMdFixCodeId(ids[i]);
|
smp.setCreateTime(new Date());
|
smp.setRemark("界面添加");
|
modelService.insertDefaultSysModel(smp);
|
}
|
}
|
json.setMsg("首页统计显示维护成功!");
|
json.setSuccess(true);
|
} catch (Exception e) {
|
log.error(message, e);
|
json.setMsg("首页统计显示维护失败!");
|
json.setSuccess(false);
|
}
|
return json;
|
}
|
|
|
/**
|
* 首页统计显示权限
|
* @author Rengj
|
* @create 2016-12-26上午9:50:25
|
* @param id
|
* @param request
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/getModel")
|
public String getModelPremis(HttpSession session,HttpServletRequest request){
|
List list =new ArrayList();
|
try {
|
FixCodeBean fcb = new FixCodeBean();
|
fcb.setUpcode("SYZSMK001");
|
List<FixCodeBean> fixList = fixService.queryFixCode(fcb);
|
//得到用户的角色
|
SessionInfo sessionInfo = (SessionInfo) session.getAttribute("sessionInfo");
|
List <SysModelPermis> sysModellist = modelService.getDefaultSysModel(sessionInfo.getUser().getId(),sessionInfo.getRoles().get(0).getId());
|
String param = request.getParameter("param");
|
for(int j=0; j<fixList.size();j++){
|
fcb = (FixCodeBean) fixList.get(j);
|
if(!"edit".equals(param)){
|
for(int i=0;i<sysModellist.size();i++){
|
SysModelPermis smp = (SysModelPermis)sysModellist.get(i);
|
if(smp.getMdFixCodeId().equals(fcb.getId())){
|
list.add(fcb);
|
}
|
}
|
}else{
|
list.add(fcb);
|
}
|
}
|
|
} catch (Exception e) {
|
log.error(message, e);
|
}
|
return JSON.toJSONString(list);
|
}
|
/**
|
* 生产实绩故障数据统
|
* @author Rengj
|
* @create 2016-12-26下午12:42:22
|
* @return string
|
*/
|
@ResponseBody
|
@RequestMapping("/getSchStatfaultJson")
|
public String getJson() throws Exception{
|
List<?> list= schService.getSchStatFault();
|
List<SchStatFault> schStatlist = new ArrayList<SchStatFault>();
|
for(int i=0;i<list.size();i++){
|
Object[] o = (Object[]) list.get(i);
|
SchStatFault sf =new SchStatFault();
|
sf.setName(o[0].toString());
|
sf.setTime(Double.parseDouble(o[1].toString()));
|
sf.setTimes(Long.parseLong(o[2].toString()));
|
sf.setFlag(Long.parseLong(o[3].toString()));
|
schStatlist.add(sf);
|
}
|
return JSON.toJSONString(schStatlist);
|
}
|
}
|
