package com.fgkj.services;
|
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.servlet.ServletContext;
|
import javax.servlet.http.Cookie;
|
|
import com.fgkj.actions.ActionUtil;
|
import com.fgkj.dao.BaseDAO;
|
import com.fgkj.dao.BaseDAOFactory;
|
import com.fgkj.dao.impl.User_infImpl;
|
import com.fgkj.dto.Batt_User_Permit;
|
import com.fgkj.dto.Page;
|
import com.fgkj.dto.ServiceModel;
|
import com.fgkj.dto.UserClient;
|
import com.fgkj.dto.User_battgroup_baojigroup;
|
import com.fgkj.dto.User_battgroup_baojigroup_battgroup;
|
import com.fgkj.dto.User_inf;
|
import com.fgkj.dto.User_permitgroup;
|
|
public class User_infService extends ActionUtil {
|
private ServiceModel model;
|
private User_permitgroupService upservice;
|
private BaseDAO dao;
|
|
public User_infService() {
|
model = new ServiceModel();
|
dao = BaseDAOFactory.getBaseDAO(BaseDAO.USER_INF);
|
upservice = new User_permitgroupService();
|
}
|
//web版登录直接访问（只验证账号不验证密码）
|
public ServiceModel login_direct(Object obj) {
|
User_inf uinf = (User_inf) obj;
|
List list = dao.serchByCondition(uinf);
|
if (list == null || list.size() < 1) {
|
model.setMsg(this.getText("Username_error"));
|
} else {
|
User_inf u = (User_inf) list.get(0);
|
uinf.setUSnId(u.getUSnId());
|
model.setCode(1);
|
model.setMsg("index.jsp");
|
//model.setMsg("index-outline.jsp");
|
// 将登陆成功的用户存入session
|
ActionUtil.getSession().setAttribute("user", u);
|
|
//设置session不活动时间为30分
|
ActionUtil.getSession().setMaxInactiveInterval(60*30);
|
ActionUtil.getSession().setAttribute("ip",ActionUtil.getRequest().getRemoteAddr());
|
User_permitgroupService upgs=new User_permitgroupService();
|
ServiceModel model1=upgs.serchItem(u);
|
//System.out.println(model.getData());
|
if(model1.getCode()==1){
|
ActionUtil.getSession().setAttribute("permits", ActionUtil.tojson(model1.getData()));
|
}else{
|
model.setCode(0);
|
model.setMsg("还未分配权限");
|
}
|
//将新登录的用户存入application
|
setApplication(u);
|
}
|
return model;
|
}
|
//5.1用户管理(添加)
|
public ServiceModel add(Object obj) {
|
int flag=((User_infImpl)dao).addJudge(obj);
|
//System.out.println(flag);
|
if(flag!=0){
|
Boolean bl=dao.add(obj);
|
if(bl){
|
model.setCode(1);
|
model.setMsg("添加成功!");
|
}
|
else{
|
model.setCode(0);
|
model.setMsg("添加失败!");
|
}
|
}else{
|
model.setCode(0);
|
model.setMsg("用户名存在，请重新输入!");
|
}
|
return model;
|
}
|
|
// 5.1用户管理(编辑)
|
public ServiceModel update(Object obj) {
|
Boolean bl = false;
|
bl=dao.update(obj);
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功");
|
}else{
|
model.setCode(0);
|
model.setMsg("修改失败");
|
}
|
return model;
|
}
|
|
// 5.1用户管理(删除)
|
public ServiceModel delete(Object obj) {
|
Boolean bl = dao.del(obj);
|
//System.out.println(obj);
|
if (bl) {
|
model.setCode(1);
|
model.setMsg("删除成功!");
|
} else {
|
model.setMsg("删除失败!");
|
}
|
return model;
|
}
|
|
public ServiceModel serchByCondition(Object obj) {
|
List list = dao.serchByCondition(obj);
|
/*
|
* for (Object object : list) { System.out.println(object); }
|
*/
|
|
if (list != null && list.size() > 0) {
|
model.setCode(1);
|
model.setData(list);
|
}
|
// System.out.println(model);
|
return model;
|
}
|
//5.1查询所有员工信息
|
public ServiceModel searchAll() {
|
List<User_inf> list = dao.searchAll();
|
if (list != null && list.size() > 0) {
|
model.setCode(1);
|
model.setData(list);
|
}
|
return model;
|
}
|
|
// 根据battgroupid查对应的包机人
|
public ServiceModel searchByBattGroupId(Object obj) {
|
model = new ServiceModel();
|
List<User_inf> list = ((User_infImpl) dao).searchByBattGroupId(obj);
|
// System.out.println(list.size());
|
/*
|
* for(User_inf u:list){ System.out.println(u); }
|
*/
|
if (list != null && list.size() > 0) {
|
model.setCode(1);
|
model.setData(list);
|
// battgroupid对应的所有包机人姓名和id
|
String uStrN = "";
|
String uStrI = "";
|
for (int i = 0; i < list.size(); i++) {
|
uStrN += ",";
|
uStrI += ",";
|
uStrN += list.get(i).getUName().toString();
|
uStrI += list.get(i).getUId().toString();
|
}
|
uStrN = uStrN.substring(1, uStrN.length());
|
uStrI = uStrI.substring(1, uStrI.length());
|
model.setMsg(uStrN);
|
model.setMsgO(uStrI);
|
} else {
|
model.setCode(0);
|
}
|
// System.out.println(model.getMsg());
|
// System.out.println(model);
|
return model;
|
}
|
|
// 3.1根据uid查用户信息(uname)
|
public ServiceModel serchuName(Object obj) {
|
model = new ServiceModel();
|
List list = ((User_infImpl) dao).serchUname(obj);
|
if (list != null && list.size() > 0) {
|
model.setCode(1);
|
model.setData(list);
|
} else {
|
model.setCode(0);
|
}
|
// System.out.println(model);
|
return model;
|
}
|
|
// 5.1查询员工的所有信息
|
public ServiceModel searchAll(Object obj) {
|
// System.out.println((Batt_User_Permit)obj);
|
model = new ServiceModel();
|
Batt_User_Permit bup = new Batt_User_Permit();
|
User_permitgroup usergroup = new User_permitgroup();
|
List<Batt_User_Permit> list = ((User_infImpl) dao).searchAll(obj);// 存放的是员工信息
|
if (list != null && list.size() > 0) {
|
model.setCode(1);
|
for (int i = 0; i < list.size(); i++) {
|
ServiceModel model1 = upservice.serchByCondition(list.get(i).getUinf());// 存放权限
|
// System.out.println(model1.getMsgN());
|
if (model1.getCode() > 0) {
|
list.get(i).getUinf().setPermitgroupName(model1.getMsgN());
|
} else {
|
list.get(i).getUinf().setPermitgroupName("");
|
}
|
}
|
model.setData(list);
|
}
|
// System.out.println(model);
|
return model;
|
}
|
|
// 5.3根据uid查所在的包机组
|
public ServiceModel serchByInfo(Object obj) {
|
model = new ServiceModel();
|
List<User_battgroup_baojigroup> list = dao.serchByInfo(obj);
|
// System.out.println(list.size());
|
// for(User_battgroup_baojigroup u:list){
|
// System.out.println(u);
|
// }
|
if (list != null && list.size() > 0) {
|
model.setCode(1);
|
model.setData(list);
|
|
} else {
|
model.setCode(0);
|
}
|
// System.out.println(model);
|
return model;
|
}
|
|
// 用户登录
|
public ServiceModel login(Object obj) {
|
User_inf uinf = (User_inf) obj;
|
//String usnId64 = (String) ActionUtil.DecryptionBase64(uinf.getUpassword());
|
//String usnIdMd5 = (String) ActionUtil.EncryptionMD5(usnId64);
|
// System.out.println(uinf.getUSnId()+" "+usnId64+" "+usnIdMd5+" :service");
|
//uinf.setUpassword(usnIdMd5);
|
List list = dao.serchByCondition(uinf);
|
if (list == null || list.size() < 1) {
|
model.setMsg(this.getText("Username_error"));
|
// System.out.println("用户名不存在");
|
} else {
|
User_inf u = (User_inf) list.get(0);
|
//System.out.println(uinf.getUpassword());
|
// System.out.println(uinf.getUSnId()+"=="+u.getUNote());
|
if (!uinf.getUpassword().equals(u.getUpassword())) {
|
//System.out.println("密码错误"+uinf.getUpassword()+"=="+u.getUpassword());
|
model.setMsg(getText("Password_error"));
|
} else {
|
//uinf.setUSnId(u.getUSnId());
|
model.setCode(1);
|
model.setMsg("index.jsp");
|
//model.setMsg("index-outline.jsp");
|
|
setMyCookie("user",u,30,uinf.getUId() == 1); //用户记住密码功能
|
|
// 将登陆成功的用户存入session
|
u.setUSnId("");
|
u.setUpassword("");
|
ActionUtil.getSession().setAttribute("user", u);
|
|
//设置session不活动时间为30分
|
ActionUtil.getSession().setMaxInactiveInterval(60*30);
|
ActionUtil.getSession().setAttribute("ip",ActionUtil.getRequest().getRemoteAddr());
|
User_permitgroupService upgs=new User_permitgroupService();
|
ServiceModel model1=upgs.serchItem(u);
|
//System.out.println(model.getData());
|
if(model1.getCode()==1){
|
ActionUtil.getSession().setAttribute("permits", ActionUtil.tojson(model1.getData()));
|
}else{
|
model.setCode(0);
|
model.setMsg("还未分配权限");
|
}
|
//将新登录的用户存入application
|
setApplication(u);
|
}
|
}
|
return model;
|
}
|
|
// 将所有登陆的用户的信息存到application中
|
public void setApplication(User_inf user) {
|
ServletContext application = ActionUtil.getApplication();
|
Map<String, UserClient> map = (Map) application.getAttribute("users");
|
if (map == null) {
|
map = new HashMap<String, UserClient>();
|
} else {
|
UserClient client = map.get(user.getUName());
|
if (client != null) {
|
map.remove(user.getUName());
|
}
|
}
|
Long login_time = new Date().getTime();
|
ActionUtil.getSession().setAttribute("login_time", login_time);
|
map.put(user.getUName(), new UserClient(ActionUtil.getRequest().getRemoteAddr(),user,login_time));
|
application.setAttribute("users", map);
|
}
|
|
/**
|
* 保存指定的cookie值
|
* @param key cookie 键
|
* @param obj 值
|
* @param timelong 保存时长(秒)
|
* @param flag 是否保存
|
*/
|
public void setMyCookie(String key,Object obj,long timelong,boolean flag){
|
Cookie c = null;
|
if(flag){
|
//记住密码
|
c = new Cookie(key, ActionUtil.EncryptionBase64(ActionUtil.getGson().toJson(obj)).toString());
|
}else{
|
c = new Cookie(key, "");
|
}
|
//让Cookie保留30天
|
c.setMaxAge(30*24*60*60);
|
ActionUtil.getResponse().addCookie(c);
|
}
|
|
/**
|
* 开始查看application中是否有另一用使用该账号登陆
|
*
|
* @return
|
*/
|
|
public ServiceModel checkUser() {
|
Map<String, UserClient> map = (Map) ActionUtil.getApplication().getAttribute("users");
|
// System.out.println(map);
|
if (map != null && map.size() > 0) {
|
User_inf user = (User_inf) ActionUtil.getSession().getAttribute("user");
|
Long login_time = (Long) ActionUtil.getSession().getAttribute("login_time");
|
if (user != null && login_time != null) {
|
UserClient client = map.get(user.getUName());
|
if (client != null) {
|
if (login_time == client.getLogin_times()) {
|
model.setCode(0);
|
}else {
|
model.setCode(1);
|
model.setMsg(getText("The landing on the account in another host, please log in again"));
|
}
|
}else {
|
model.setCode(1);
|
model.setMsg(getText("You are not logged in, please log in"));
|
}
|
} else {
|
model.setCode(1);
|
model.setMsg(getText("You are not logged in, please log in"));
|
}
|
} else {
|
model.setCode(1);
|
model.setMsg(getText("You are not logged in, please log in"));
|
}
|
return model;
|
}
|
|
//修改用户密码
|
public ServiceModel updatePassword(Object obj){
|
User_inf uinf=(User_inf) obj;
|
uinf.setUpassword((String)ActionUtil.EncryptionMD5(uinf.getUSnId()));
|
//System.out.println(uinf);
|
Boolean bl=((User_infImpl)dao).updatePassword(uinf);
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功!");
|
}
|
else{
|
model.setMsg("修改失败!");
|
}
|
return model;
|
}
|
|
//根据员工信息和员工编号去匹配合适的员工
|
public ServiceModel searchByNameOrId(Object obj){
|
List<User_inf> list=((User_infImpl)dao).searchByNameOrId(obj);
|
|
if(list!=null&&list.size()>0){
|
model.setCode(1);
|
model.setData(list);
|
model.setMsg("查询成功!");
|
}
|
else{
|
model.setCode(0);
|
model.setMsg("查询失败!");
|
}
|
return model;
|
}
|
|
//重置用户密码
|
public ServiceModel resetPassword(Object obj){
|
Boolean bl=((User_infImpl)dao).resetPassword(obj);
|
if(bl){
|
model.setCode(1);
|
model.setMsg("修改成功!");
|
}
|
else{
|
model.setMsg("修改失败!");
|
}
|
return model;
|
}
|
public static void main(String[] args) {
|
User_infService us = new User_infService();
|
User_inf u = new User_inf();
|
u.setUName("a");
|
u.setUEmployeeId("a");
|
u.setUId(1003);
|
Batt_User_Permit bup = new Batt_User_Permit();
|
Page page = new Page();
|
page.setPageSize(10);
|
page.setPageCurr(1);
|
bup.setPage(page);
|
bup.setUinf(u);
|
|
//User_battgroup_baojigroup_battgroup ub = new User_battgroup_baojigroup_battgroup();
|
// ub.setBattGroupId(1000012);
|
// us.searchByBattGroupId(ub);
|
// us.serchByInfo(u);
|
// System.out.println(us.searchAll(bup).getData());
|
us.searchByNameOrId(bup);
|
}
|
}
|
