accountaction.java

java电信经典-学习例子源代码

package netctoss.user.actions;
/*
 * 负责帐务帐号的处理
 * */
import java.util.Date;

import global.TimeTools;
import global.ValidatorTool;

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

import netctoss.dao.PricingsDAO;
import netctoss.dao.UsersDAO;
import netctoss.entities.Pricings;
import netctoss.entities.Users;
import netctoss.fee.forms.PricingForm;
import netctoss.rights.forms.RightForm;
import netctoss.user.forms.AccountForm;

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 org.apache.struts.actions.DispatchAction;

public class AccountAction extends DispatchAction {
	private boolean validate(AccountForm  form,ActionMessages errors)
	{
		if(ValidatorTool.validateNull("name", form.getName(), errors, "用户姓名必须输入")) return true;
		if(ValidatorTool.validateNull("loginname", form.getLoginname(), errors, "登录名必须输入")) return true;
		if(ValidatorTool.validateNull("loginpassword", form.getLoginpassword(), errors, "密码必须输入")) return true;
		if(ValidatorTool.validateNull("status",form.getStatus().toString(), errors, "状态必须输入")) return true;
		if(ValidatorTool.validateNull("sex", form.getSex().toString(), errors, "性别必须输入")) return true;
		if(ValidatorTool.validateNull("paymenttpye", form.getPaymenttpye(), errors, "支付方式必须输入")) return true;
		
		return false;
	}
	//　处理帐务帐号的增，删，修操作
	public ActionForward insert(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) throws Exception {
		AccountForm  fm=(AccountForm)form;
		ActionMessages errors=new ActionMessages();
		System.out.println("插入数据");
		try{
			UsersDAO dao=new UsersDAO();
			Users user=new Users();
			if(validate(fm,errors)){//验证没有通过 			
				errors.add("user.insert", new ActionMessage("user.insert.failure",TimeTools.getNowTime("HH:mm:ss")));
				this.saveErrors(request, errors);
				return mapping.findForward("goaddnewacc");
			}	
			user.setId(0);
			user.setCareer(fm.getCareer());
			user.setCompany(fm.getCompany());
			user.setEmail(fm.getEmail());
			user.setLoginname(fm.getLoginname());
			user.setLoginpassword(fm.getLoginpassword());
			user.setName(fm.getName());
			user.setNationality(fm.getNationality());
			user.setPaymenttpye(fm.getPaymenttpye());
			user.setPhone(fm.getPhone());
			user.setSex(fm.getSex());
			user.setStatus(fm.getStatus());
			user.setZip(fm.getZip());
			user.setErolldate(new Date());
			dao.save(user);
			dao.getSession().flush();	
			form.reset(mapping, request);
			errors.add("user.insert", new ActionMessage("user.oper.success",TimeTools.getNowTime("HH:mm:ss")));
		}
		catch(Exception e){
			//e.printStackTrace();
			errors.add("user.insert", new ActionMessage("user.oper.failure",TimeTools.getNowTime("HH:mm:ss")));
		}
		this.saveErrors(request, errors);
		
		return mapping.findForward("goaddnewacc");
	}
	public ActionForward update(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) throws Exception {
		//得到数据,并保存
		AccountForm  fm=(AccountForm)form;
		ActionMessages errors=new ActionMessages();
		try{
			UsersDAO dao=new UsersDAO();
			Users user=dao.findById(fm.getId());
			if(validate(fm,errors)){//验证没有通过 			
				errors.add("user.insert", new ActionMessage("user.insert.failure",TimeTools.getNowTime("HH:mm:ss")));
				this.saveErrors(request, errors);
				request.setAttribute("form", form);
				return mapping.findForward("goupdateacc");
			}	
			user.setCareer(fm.getCareer());
			user.setCompany(fm.getCompany());
			user.setEmail(fm.getEmail());
			user.setLoginname(fm.getLoginname());
			user.setLoginpassword(fm.getLoginpassword());
			user.setName(fm.getName());
			user.setNationality(fm.getNationality());
			user.setPaymenttpye(fm.getPaymenttpye());
			user.setPhone(fm.getPhone());
			user.setSex(fm.getSex());
			user.setStatus(fm.getStatus());
			user.setZip(fm.getZip());
			user.setErolldate(new Date());
			dao.save(user);
			dao.getSession().flush();			
			errors.add("user.insert", new ActionMessage("user.oper.success",TimeTools.getNowTime("HH:mm:ss")));
		}
		catch(Exception e){
			errors.add("user.insert", new ActionMessage("user.oper.failure",TimeTools.getNowTime("HH:mm:ss")));
		}
		this.saveErrors(request, errors);
		return mapping.findForward("goupdateacc");
	}
	public ActionForward delete(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) throws Exception {
		AccountForm  fm=(AccountForm)form;
		ActionMessages errors=new ActionMessages();
		try{
			UsersDAO dao=new UsersDAO();
			Users user=dao.findById(fm.getId());
			dao.delete(user);
			dao.getSession().flush();			
			errors.add("user.insert", new ActionMessage("user.oper.success",TimeTools.getNowTime("HH:mm:ss")));
		}
		catch(Exception e){
			errors.add("user.insert", new ActionMessage("user.oper.failure",TimeTools.getNowTime("HH:mm:ss")));
		}
		this.saveErrors(request, errors);
		return mapping.findForward("godeleteacc");
	}
	public ActionForward showUpdate(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) throws Exception {
		//显示修改页面　
		AccountForm  fm=(AccountForm)form;		
		//查询指定ＩＤ的用户
		UsersDAO dao=new UsersDAO();
		Users user=dao.findById(fm.getId());
		//生成指定的表单
		
		request.setAttribute("user", user);
		//如果要关联显示用户开通的业务,则需要使用user对象了
		fm.setCareer(user.getCareer());
		fm.setCompany(user.getCompany());
		fm.setEmail(user.getEmail());
		fm.setLoginname(user.getLoginname());
		fm.setLoginpassword(user.getLoginpassword());
		fm.setName(user.getName());
		fm.setNationality(user.getNationality());
		fm.setPaymenttpye(user.getPaymenttpye());
		fm.setPhone(user.getPhone());
		fm.setSex(user.getSex());
		fm.setStatus(user.getStatus());
		fm.setZip(user.getZip());
		return mapping.findForward("goupdateacc");
		
	}
}