businessaction.java

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

package netctoss.user.actions;
/*
 * 负责业务帐号的处理
 * */
import global.TimeTools;
import global.ValidatorTool;

import java.util.Date;
import java.util.List;

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

import netctoss.dao.PricingsDAO;
import netctoss.dao.UsersDAO;
import netctoss.dao.UserservicesDAO;
import netctoss.entities.Pricings;
import netctoss.entities.Users;
import netctoss.entities.Userservices;
import netctoss.user.forms.AccountForm;
import netctoss.user.forms.BusinessForm;

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 BusinessAction extends DispatchAction {
	private boolean validate(BusinessForm  form,ActionMessages errors)
	{
		if(ValidatorTool.validateNull("loginname", form.getLoginname(), errors, "登录名必须输入")) return true;
		if(ValidatorTool.validateNull("loginpassword", form.getLoginpassword(), errors, "密码必须输入")) return true;
		return false;
	}
	
	//　处理业务帐号的增，删，修操作
	public ActionForward insert(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) throws Exception {
		//得到传递的数据
		BusinessForm  fm=(BusinessForm)form;
		//构造一个对象并保存
		ActionMessages errors=new ActionMessages();
		try{
			UserservicesDAO  dao=new UserservicesDAO();
			Userservices  ser=new Userservices();
			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("goaddnewbuss");
			}	
			ser.setId(0);
			ser.setLoginname(fm.getLoginname());
			ser.setEnrolldate(new Date());
			ser.setLabip(fm.getLabip());
			ser.setLoginpassword(fm.getLoginpassword());
			ser.setStatus(fm.getStatus());
			
			UsersDAO daouser=new UsersDAO();
			PricingsDAO  daopr=new PricingsDAO();
			Users user=daouser.findById(fm.getUserid());
			Pricings  pr=daopr.findById(fm.getPriceid());
			ser.setUserid(user);
			ser.setPriceid(pr);
			dao.save(ser);
			dao.getSession().flush();	
			form.reset(mapping, request);
			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("goaddnewbuss");
	}
	public ActionForward update(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) throws Exception {
		//保存数据
		//得到传递的数据
		BusinessForm  fm=(BusinessForm)form;
		//构造一个对象并保存
		ActionMessages errors=new ActionMessages();
		try{
			UserservicesDAO  dao=new UserservicesDAO();
			Userservices  ser=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("goupdatebuss");
			}	
			ser.setLoginname(fm.getLoginname());
			ser.setLabip(fm.getLabip());
			ser.setLoginpassword(fm.getLoginpassword());
			ser.setStatus(fm.getStatus());			
			PricingsDAO  daopr=new PricingsDAO();			
			Pricings  pr=daopr.findById(fm.getPriceid());			
			ser.setPriceid(pr);
			dao.save(ser);
			dao.getSession().flush();	
			dao.getSession().clear();
			//恢复原状
			request.setAttribute("form", fm);//业务帐号信息
			request.setAttribute("ur", ser);//业务帐号信息
			PricingsDAO daopricing=new PricingsDAO(); 
			//查询所有的资费
			List lstpricings=daopricing.findAll();		
			request.setAttribute("lstpricings", lstpricings);//资费
			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("goupdatebuss");
	}
	public ActionForward delete(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) throws Exception {
		//删除数据
		BusinessForm  fm=(BusinessForm)form;
		//找到数据
		UserservicesDAO dao=new UserservicesDAO();
		Userservices  ur=dao.findById(fm.getId());
		dao.delete(ur);
		dao.getSession().flush();
		
		return mapping.findForward("godeletebuss");
	}
	public ActionForward showUpdate(ActionMapping mapping, ActionForm form,
			HttpServletRequest request, HttpServletResponse response) throws Exception {
		BusinessForm  fm=(BusinessForm)form;
		try{
			//得到资费方式，用户名不能修改．
			PricingsDAO daopricing=new PricingsDAO(); 
			//查询所有的资费
			List lstpricings=daopricing.findAll();		
			//得到当前用户的业务信息
			UserservicesDAO  dao=new UserservicesDAO();
			Userservices  ur=dao.findById(fm.getId());		
			//对form再保存，便于struts自动显示		
			fm.setLoginname(ur.getLoginname());
			fm.setLabip(ur.getLabip());
			fm.setLoginpassword(ur.getLoginpassword());
			fm.setStatus(ur.getStatus());
			fm.setUserid(ur.getUserid().getId());
			fm.setPriceid(ur.getPriceid().getId());
			request.setAttribute("form", fm);//业务帐号信息
			request.setAttribute("ur", ur);//业务帐号信息
			request.setAttribute("lstpricings", lstpricings);//资费
		}
		catch(Exception e){
		}
		return mapping.findForward("goupdatebuss");
	}
}