registaction.java

网上商城

package store;
import java.sql.*;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.validator.DynaValidatorForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;
import org.apache.struts.action.ActionError;
import org.apache.struts.action.ActionErrors;

public class RegistAction extends Action {
public ActionForward execute(
ActionMapping mapping,
ActionForm form,
HttpServletRequest request,
HttpServletResponse response)
throws Exception {
  DynaValidatorForm userform =(DynaValidatorForm) form;
  String username=(String) userform.get("username");
  String password=(String) userform.get("password");
  String newpsw=(String) userform.get("newpsw");
  String name=(String)userform.get("name");
  name=new String(name.getBytes("ISO-8859-1"));
  String tel=(String) userform.get("tel");
  String address=(String) userform.get("address");
  address=new String(address.getBytes("ISO-8859-1"));
  String email=(String) userform.get("email");
  String action=(String) userform.get("action");
  String customerid=(String) userform.get("userid");
  ActionErrors errors=new ActionErrors ();
  DBConn conn=new DBConn();
  PreparedStatement pstmt=null;
  String pageforward="failed";
  boolean flag=true;
  if(action.equals("1")){
    CheckUser CU=new CheckUser();

    flag=CU.userExist(username,conn);
    if(flag){
    ActionError err= new ActionError ("error.username.exist");
    errors.add(ActionErrors.GLOBAL_ERROR,err);
    pageforward="error";
    }

  }
  if(action.equals("1")&&(!flag)){

    String sql="INSERT INTO customer VALUE(?,?,?,?,?,?,?)";
    pstmt=conn.getPstmt(sql);
    pstmt.setInt(1,0);
    pstmt.setString(2,username);
    pstmt.setString(3,password);
    pstmt.setString(4,name);
    pstmt.setString(5,tel);
    pstmt.setString(6,address);
    pstmt.setString(7,email);
    int su= pstmt.executeUpdate();
    if(su>0){
      pageforward="reg_success";
    }
    pstmt.close();
  }
  if(action.equals("2")){
    String sql1="UPDATE customer SET name=?,tel=?,address=?,email=?"+
                 " WHERE id="+customerid;
    pstmt=conn.getPstmt(sql1);
    pstmt.setString(1,name);
    pstmt.setString(2,tel);
    pstmt.setString(3,address);
    pstmt.setString(4,email);
    int su= pstmt.executeUpdate();
    if(su>0){
      pageforward="reg_success";
    }
    pstmt.close();
  }
  if(action.equals("3")){
    UserInfo UI=new UserInfo();
    String pass=UI.getPassword(Integer.parseInt(customerid),conn);
    if(password.equals(pass)){
      String sql2 = "UPDATE customer SET password=? WHERE id=" + customerid;
      pstmt=conn.getPstmt(sql2);
      pstmt.setString(1,newpsw);
      int u=pstmt.executeUpdate();
      if(u>0)
        pageforward="reg_success";
      pstmt.close();
    }
    else{
      ActionError error= new ActionError ("error.password.notmatch");
      errors.add(ActionErrors.GLOBAL_ERROR,error);
      pageforward="error";
    }
  }

  conn.DBclose();
  this.saveErrors(request,errors);
  return mapping.findForward(pageforward);
 }
}