useraddaction.java

文章管理系统 用Java开发,以Struts为框架,以Jdbc链接Mysql数据库。系统属性:系统属性设置、留言管理、友情链接管理、网站调查、公告管理 关于我们、版权声明、联系我们

package com.yhcms.manage.admin.action;

import java.util.List;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.log4j.Logger;
import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;
import org.apache.struts.action.ActionMessage;
import org.apache.struts.action.ActionMessages;

import com.yhcms.db.DBConnException;
import com.yhcms.manage.admin.bean.AdminUser;
import com.yhcms.manage.admin.dao.GroupDaoIm;
import com.yhcms.manage.admin.dao.UserDaoIm;
import com.yhcms.manage.admin.form.UserAddForm;
import com.yhcms.manage.admin.itface.GroupDao;
import com.yhcms.manage.admin.itface.UserDao;
/**
 * <p>Title:系统后台增加用户提交Action</p>
 * <li>增加用户模块</li>
 * <br><b>CopyRight: yyhweb[由由华网]</b>
 * @author stephen
 * @version YH-2.0
 */
public class UserAddAction extends Action{
	public ActionForward execute(ActionMapping actionmapping,ActionForm form,
			HttpServletRequest request,HttpServletResponse response){
		Logger yhlog = Logger.getLogger(LoginAction.class.getName());
		ActionMessages errors = new ActionMessages();
		//	 取消操作
		if(isCancelled(request))
			return actionmapping.findForward("Cancel");
		
		UserAddForm userform = (UserAddForm)form;
		String action = "";
		int userid = 0;
		String password1 = "";
		String username = "";
		
		userid = userform.getId();
		username = userform.getUsername();
		password1 = userform.getPassword1();
		action = userform.getAction();
		int usergroup = userform.getUsergroup();
		// 用户和组数据模块
		GroupDao gdao = GroupDaoIm.getInstance();
		UserDao udao = UserDaoIm.getInstance();
		// 当发生错误信息要在此页面报错,而此页面的初始化需要gList 和curUser.
		List gList = null;          
		AdminUser curUser = null; 
		// groupid 和name 要一起添加一个新的组里
		String groupname = "";  
		AdminUser adminUser = new AdminUser();
		adminUser.setGroupid(usergroup);
		adminUser.setPassword(password1);
		adminUser.setUsername(username);
		try {
			groupname = gdao.getGroupById(usergroup).getName();
			adminUser.setGroupname(groupname);  // 设置组名

			//  当页面跳转到Failure页面时,需要用到gList 和 curUser
			gList = gdao.getAllGroup();         
			curUser = (AdminUser) request.getAttribute("curUser");
			if(curUser == null){
				curUser = new AdminUser();
			}
			
			if((action==null)||(!action.equals("update"))){
				//	用户已经存在,则跳转到failure页面
				if(udao.isAdminUser(adminUser,1)>0){
					yhlog.info("When add a user,the user '"+username+"' is exist.");
					errors.add("admin.user.add.exist",new ActionMessage("admin.user.add.exist"));
					saveErrors(request,errors);
					request.setAttribute("curUser",curUser);
					request.setAttribute("gList",gList);
					return actionmapping.findForward("Failure");
				}
				//	增加用户
				if(udao.addAdminUser(adminUser)){
					return actionmapping.findForward("Success");
				}else{
					yhlog.info("When add a user '"+username+"' unsuccessfully.");
					errors.add("admin.user.add.fail",new ActionMessage("admin.user.add.fail"));
					saveErrors(request,errors);
				}
			}else{
				//	更新用户
				adminUser.setId(userid);
				if(udao.updateAdminUser(adminUser)){
					return actionmapping.findForward("Success");
				}else{
					yhlog.info("When update a user '"+username+"' unsuccessfully.");
					errors.add("admin.user.update.fail",new ActionMessage("admin.user.update.fail"));
					saveErrors(request,errors);
				}
			}
			
		} catch (DBConnException e) {
			yhlog.info("When add a user '"+username+"',throw an Exception!");
			errors.add("admin.user.add.exp",new ActionMessage("admin.user.add.exp"));
			saveErrors(request,errors);
		}
		request.setAttribute("curUser",curUser);
		request.setAttribute("gList",gList);
		return actionmapping.findForward("Failure");
	}

}