package com.fgkj.services;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Locale;
|
import java.util.Map;
|
import java.util.ResourceBundle;
|
|
import javax.servlet.ServletContext;
|
import javax.servlet.http.HttpSession;
|
|
import org.apache.commons.io.FileUtils;
|
|
import com.fgkj.actions.ActionUtil;
|
import com.fgkj.dao.BaseDAO;
|
import com.fgkj.dao.BaseDAOFactory;
|
import com.fgkj.dao.impl.UserDAOImpl;
|
import com.fgkj.dto.Roles;
|
import com.fgkj.dto.ServiceModel;
|
import com.fgkj.dto.User;
|
import com.fgkj.dto.UserClient;
|
import com.fgkj.dto.UserRole;
|
import com.fgkj.report.FileUtil;
|
import com.opensymphony.xwork2.ActionSupport;
|
import com.opensymphony.xwork2.LocaleProvider;
|
import com.opensymphony.xwork2.TextProvider;
|
import com.opensymphony.xwork2.util.ValueStack;
|
|
public class UserService extends ActionUtil{
|
private BaseDAO dao;
|
private ServiceModel model;
|
|
public UserService(){
|
dao = BaseDAOFactory.getBaseDAO(BaseDAO.USER);
|
model = new ServiceModel();
|
}
|
|
// 添加员工
|
public ServiceModel addUser(User user) {
|
if (dao.add(user)) {
|
user = (User) dao.serchByCondition(user).get(0);
|
dao = BaseDAOFactory.getBaseDAO(BaseDAO.USERROLE);
|
UserRole userrole = new UserRole(user, new Roles(user.getPid()));
|
if (dao.add(userrole)) {
|
model.setCode(1);
|
model.setMsg("添加成功");
|
}
|
} else {
|
model.setMsg("添加失败");
|
}
|
return model;
|
}
|
|
public ServiceModel delUser(User user) {
|
if (dao.del(user)) {
|
model.setCode(1);
|
model.setMsg("删除成功");
|
} else {
|
model.setMsg("删除失败");
|
}
|
return model;
|
}
|
|
public ServiceModel updateUser(User user) {
|
if (dao.update(user)) {
|
dao = BaseDAOFactory.getBaseDAO(BaseDAO.USERROLE);
|
boolean flag = dao.update(new UserRole(user, new Roles(user.getPid())));
|
if (flag) {
|
model.setCode(1);
|
model.setMsg("修改成功");
|
}
|
} else {
|
model.setMsg("修改成功");
|
}
|
return model;
|
}
|
|
public ServiceModel findUser(User user) {
|
List list = dao.serchByCondition(user);
|
if (list != null && list.size() > 0) {
|
model.setData(list);
|
model.setCode(1);
|
} else {
|
model.setMsg("查询失败");
|
}
|
return model;
|
}
|
|
public ServiceModel findUserAll() {
|
List list = dao.searchAll();
|
if (list != null && list.size() > 0) {
|
FileUtil.WriterFile(list);
|
model.setCode(1);
|
model.setData(list);
|
}
|
return model;
|
}
|
|
public ServiceModel findByInfo(Object obj) {
|
User user = (User) obj;
|
List list = dao.serchByInfo(user);
|
if (list == null || list.size() < 1) {
|
model.setMsg("没有匹配的员工");
|
} else {
|
model.setData(list);
|
model.setCode(1);
|
}
|
return model;
|
}
|
|
public ServiceModel updatePass(Object obj) {
|
boolean flag = new UserDAOImpl().updatePass(obj);
|
if (!flag) {
|
model.setMsg("修改失败");
|
} else {
|
model.setCode(1);
|
List list = dao.serchByCondition(obj);
|
if (list != null && list.size() > 0) {
|
User u = (User) list.get(0);
|
ActionUtil.getSession().setAttribute("user", u);
|
}
|
}
|
return model;
|
}
|
|
public ServiceModel findByAge(int currentPage, int PageSize) {
|
List list = new UserDAOImpl().serchByPage(currentPage, PageSize);
|
if (list != null && list.size() > 0) {
|
model.setCode(1);
|
model.setData(list);
|
} else {
|
model.setMsg("查询失败");
|
}
|
return model;
|
}
|
|
// public ServiceModel login(Object obj) {
|
// User user = (User) obj;
|
// List list = dao.serchByCondition(user);
|
// if (list == null || list.size() < 1) {
|
// model.setMsg(this.getText("Username_error"));
|
// // System.out.println("用户名不存在");
|
// } else {
|
// User u = (User) list.get(0);
|
//
|
// if (!user.getUpass().equals(u.getUpass())) {
|
// model.setMsg(getText("Password_error"));
|
// } else {
|
// model.setCode(1);
|
// // 将登陆成功的用户存入session
|
// ActionUtil.getSession().setAttribute("user", u);
|
// ActionUtil.getSession().setAttribute("ip",
|
// ActionUtil.getRequest().getRemoteAddr());
|
// // 将新登录的用户存入application
|
// setApplication(u);
|
// }
|
// }
|
// return model;
|
// }
|
|
// public void setApplication(User 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());
|
// }
|
// }
|
// //map.put(user.getUname(), new UserClient(ActionUtil.getRequest().getRemoteAddr(), user));
|
// application.setAttribute("users", map);
|
// }
|
|
/**
|
* 开始查看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 user = (User) ActionUtil.getSession().getAttribute("user");
|
if(user!=null){
|
UserClient client = map.get(user.getUname());
|
if(client!=null){
|
if (!ActionUtil.getRequest().getRemoteAddr().equals(client.getIp())) {
|
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"));
|
}
|
return model;
|
}
|
}
|
