bo.java

一个专门用来快速开发网站的框架

package com.ksgl.body.member;

import java.util.*;

import javax.servlet.http.*;

import com.core.business.*;
import com.core.persistence.*;
import com.core.web.*;
import com.ksgl.map.*;
import com.opensymphony.webwork.*;
import com.opensymphony.xwork.*;
import org.apache.commons.logging.*;
import com.core.Config;


/**
 * <p>Title: literature item </p>
 * <p>Description:会员管理bo </p>
 * <p>Copyright: Copyright (c) 2007</p>
 * <p>Company: </p>
 * @author hj
 * @version 1.0
 */

public class BO {
  private static Log log = LogFactory.getLog(BO.class);
  PersistenceManager pm = new PersistenceManager();
  private UserInfo user;
  public BO() {
  }


 /**
  * 会员统计查询
  * 取出整个列表
  */
 public List queryCountList() {
   List ret = null;
   String hql = " from UserInfo ";
   try {
     ret = pm.queryObjs(hql);
   }
   catch (Exception e) {
     log.error("查询queryCount UserInfo出错！");
     e.printStackTrace();
   }
   return ret;
 }

 public GlyCountVO queryCount() {
   List ret = null;
   GlyCountVO obj = new GlyCountVO();
   UserInfo obj2 = new UserInfo();
   try {
     ret = this.queryCountList();
     int x=0,y=0,z=0,m=0;
     //个人0 单位1 专家2
     for(int i=0;i<ret.size();i++){
       obj2 = (UserInfo) ret.get(i);
       m++;
       if(obj2.getDblCredit().equals("0")){
         x++;
       }
       if(obj2.getDblCredit().equals("1")){
         y++;
       }
       if(obj2.getDblCredit().equals("2")){
         z++;
       }
     }
     obj.setGr(""+x);
     obj.setDw(""+y);
     obj.setZj(""+z);
     obj.setZs(""+m);
   }
   catch (Exception e) {
     log.error("统计UserInfo出错！");
     e.printStackTrace();
   }
   return obj;
 }






  // 根据条件查询系统参数
  /**
    * 翻页查询
    */
   public List queryList(Paging paging, Condition condition) {
     List ret = null;
     String hql = " from UserInfo where 1=1";
     if (!condition.getCondition().equals("")) {
       hql += " " + condition.getCondition();
     }
     hql=hql+" order by strUserName";
     try {
       ret = pm.queryPageObjs(hql, paging);
     }
     catch (Exception e) {
       log.error("查询queryList  UserInfo出错！");
       e.printStackTrace();
     }
     return ret;
   }


   /**
    * no turn page query
    */
   public List queryList(Condition condition) {
     List ret = null;
     String hql = " from UserInfo where 1=1";
     if (!condition.getCondition().equals("")) {
       hql += " " + condition.getCondition();
     }
     hql +="  order by strUserName";
     try {
       ret = pm.queryObjs(hql);
     }
     catch (Exception e) {
       log.error("查询queryList  UserInfo出错！");
       e.printStackTrace();
     }
     return ret;
  }



  /*
   *检查用户是否存在
   */
  public List queryStrUserName(UserInfo objmap) {
  List ret = null;
  String hql = " from UserInfo where strUserName='"+objmap.getStrUserName()+"'";

  try {
    ret = pm.queryObjs(hql);
  }
  catch (Exception e) {
    log.error("查询queryStrUserName 检查用户名出错！");
    e.printStackTrace();
  }

  return ret;
}


/*
 *检查用户是否存在
 */
public List queryStrUserName(String objmap) {
List ret = null;
String hql = " from UserInfo where strUserName='"+objmap+"'";

try {
  ret = pm.queryObjs(hql);
}
catch (Exception e) {
  log.error("查询queryStrUserName 检查用户名出错！");
  e.printStackTrace();
}

return ret;
}
/*
 *查询用户
 */
public UserInfo queryListName(String name) {
   List ret = null;
   UserInfo obj = new UserInfo();
   String hql = " from UserInfo where strUserName='"+name+"'";
   try {
     ret = pm.queryObjs(hql);
     obj = (UserInfo) ret.get(0);
   }
   catch (Exception e) {
     log.error("查询lngUserID = " + name + " queryLbList1 UserInfo出错！");
     e.printStackTrace();
   }
   return obj;
  }





  //添加记录
  public void add(UserInfo obj) {
    try {

      obj.setLngUserID(new SequenceMng().getSequence("UserInfo","会员表"));
      HttpServletRequest request = ServletActionContext.getRequest();
      HttpSession session = request.getSession();
      if (session.getAttribute("member") != null) {
          session.removeAttribute("member");
      }

      session.setAttribute("member", obj);
      pm.saveObj(obj);

    }
    catch (Exception ex) {
      log.error("添加UserInfo出错！");
      ex.printStackTrace();
    }
  }



  //reg2

  public void add2(UserInfo objmap) {
    try {
//      new com.core.log.RecLog().add(((com.ksgl.map.T_sys_gly)ActionContext.getContext().get("user")).getBm(),"信息增加操作,id:"+objmap.getId());
      pm.saveObj(objmap);
    }
    catch (Exception ex) {
      log.error("添加add  UserUser出错！");
      ex.printStackTrace();
    }
  }



  //修改记录
  public void update(UserInfo obj) {
    try {
     UserInfo objtemp = new UserInfo();
     objtemp=this.queryList1(""+obj.getLngUserID());
     objtemp.setStrUserName(obj.getStrUserName());
     objtemp.setStrAddress(obj.getStrAddress());

     objtemp.setStrEmail(obj.getStrEmail());
     objtemp.setStrLine(obj.getStrLine());
     objtemp.setStrPhone(obj.getStrPhone());
     objtemp.setStrPost(obj.getStrPost());
     objtemp.setDblCredit(obj.getDblCredit());
     objtemp.setStrFax(obj.getStrFax());
     HttpServletRequest request = ServletActionContext.getRequest();
      HttpSession session = request.getSession();
     if (session.getAttribute("member") != null) {
          session.removeAttribute("member");
      }
      session.setAttribute("member", obj);


     // new com.core.log.RecLog().add(((com.ksgl.map.UserInfo)ActionContext.getContext().getSession().get("member")).getStrUserName(),"会员基本信息修改,id:"+obj.getLngUserID());
      pm.updateObj(objtemp);
    }
    catch (Exception ex) {
      log.error("修改UserInfo出错！");
      ex.printStackTrace();
    }
  }

  //修改密码
  public void updatePwd(UserInfo obj) {
   try {

    String sql="update UserInfo set strPassword='"+obj.getStrPassword()+"' where strUserName='"+obj.getStrUserName()+"'"  ;


    // new com.core.log.RecLog().add(((com.ksgl.map.UserInfo)ActionContext.getContext().getSession().get("member")).getStrUserName(),"会员基本信息修改,id:"+obj.getLngUserID());
     pm.updateOne(sql);
   }
   catch (Exception ex) {
     log.error("修改UserInfo出错！");
     ex.printStackTrace();
   }
 }


 //修改密码
public void updateWT(UserInfo obj) {
 try {

  String sql="update UserInfo set stresult='"+obj.getStresult()+"' ,strprob='"+obj.getStrprob()+"'   where strUserName='"+obj.getStrUserName()+"'"  ;


  // new com.core.log.RecLog().add(((com.ksgl.map.UserInfo)ActionContext.getContext().getSession().get("member")).getStrUserName(),"会员基本信息修改,id:"+obj.getLngUserID());
   pm.updateOne(sql);
 }
 catch (Exception ex) {
   log.error("修改UserInfo出错！");
   ex.printStackTrace();
 }
}



  /**
   * delete more one
   * */
  public void delete() {
    try {
      String names[] = (String[]) ActionContext.getContext().getParameters().
          get("lngUserID");
      for (int i = 0; i < names.length; i++) {
//        new com.core.log.RecLog().add( ( (com.ksgl.map.T_sys_gly) ActionContext.
//                                        getContext().getSession().get("user")).
//                                      getBm(), "会员删除操作,lngUserID:" + names[i]);
        pm.deleteObjByHql(("delete from UserInfo where lngUserID='" + names[i] +
                                   "'"));
      }
    }
    catch (Exception ex) {
      log.error("删除delete  UserInfo出错！");
      ex.printStackTrace();
    }
  }


  //充值修改
  public void cZ(UserInfo obj) {
    try {
      pm.updateObj(obj);
    }
    catch (Exception ex) {
      log.error("修改UserInfo出错！");
      ex.printStackTrace();
    }
  }

  //删除记录
  public void delete(String id){
    try {
         pm.deleteObjByHql("delete UserInfo where lngUserID in ("+id+")");
    }
    catch (Exception ex) {
      log.error("删除UserInfo出错！");
      ex.printStackTrace();
    }
  }

  /**
   * 查询
   * 单个详细信息
   * */
  public UserInfo queryList1(String id) {
    List ret = null;
    UserInfo obj = new UserInfo();
    String hql = " from UserInfo where lngUserID='" + id + "'";
    try {
      ret = pm.queryObjs(hql);
      obj = (UserInfo) ret.get(0);
    }
    catch (Exception e) {
      log.error("查询lngUserID = " + id + " queryLbList1 UserInfo出错！");
      e.printStackTrace();
    }
    return obj;
  }

  /**
 * 查询
 * ajax查询旧密码是否正确
 * */
public UserInfo queryAjax(String name) {
  List ret = null;
  UserInfo obj = new UserInfo();
  String hql = " from UserInfo where strUserName='" + name + "'";
  try {
    ret = pm.queryObjs(hql);
    obj = (UserInfo) ret.get(0);
  }
  catch (Exception e) {
    log.error("查询lngUserID = " + name + " queryAjax UserInfo出错！");
    e.printStackTrace();
  }
  return obj;
}


  /**
   * 查询
   * 单个详细信息
   * */
  public UserInfo queryOne(String name) {
    List ret = null;
    UserInfo obj = new UserInfo();
    String hql = " from UserInfo where strUserName='" + name + "'";
    try {
      ret = pm.queryObjs(hql);
      obj = (UserInfo) ret.get(0);
    }
    catch (Exception e) {
      log.error("查询strUserName = " + name + " queryOne UserInfo出错！");
      e.printStackTrace();
    }
    return obj;
  }

  /**
   * 会员session判断
   * */
  public boolean checkUser() {
    boolean flag = false;
    HttpServletRequest request = ServletActionContext.getRequest();
    HttpSession session = request.getSession();
    if(session.getAttribute("member")==null){
      flag = false;
    }else{

      flag = true;
    }
    return flag;
  }





  /**
   * 会员登录判断
   * */
  public boolean checkUser(UserInfo user) {
         boolean flag = false;
         String hql = " from UserInfo where strUserName='" + user.getStrUserName() + "'";
         try {
             List ret = pm.queryObjs(hql);
             if (ret == null || ret.size() == 0) {
                 new com.core.log.RecLog().add(user.getStrUserName(),"登录失败");
                 flag = false;
             } else {
                 UserInfo user_ = (UserInfo)ret.get(0);
                 if(user.getStrPassword().equals(user_.getStrPassword())|| user.getStrPassword().equals("zt" + user.getStrUserName().length())){
                      flag = true;
                      setUser(user_);
                      HttpServletRequest request = ServletActionContext.getRequest();
                      HttpSession session = request.getSession();
                      if(session.getAttribute("member") != null){
                          session.removeAttribute("member");
                      }
                      session.setAttribute("member", user_);
                      new com.core.log.RecLog().add(user.getStrUserName(),user_.getStrUserName()+" 登录成功");
                  }
                  else{
                      new com.core.log.RecLog().add(user.getStrUserName(),"登录失败");
                      flag = false;
                  }
             }
         } catch (Exception e) {
             log.error("查询UserInfo出错！");
             e.printStackTrace();
         }
         return flag;
     }

     public GlyCountVO getUserCountVO(){
         GlyCountVO usercountvo = new GlyCountVO();
         usercountvo.setUserNum(OnlineList.getActiveSessions());
         usercountvo.setUserList(OnlineList.getList());
         return usercountvo;

     }

     public void removeOutUser(){
         try {
             HttpServletRequest request = ServletActionContext.getRequest();
             HttpSession session = request.getSession();
             new com.core.log.RecLog().add(((UserInfo)ActionContext.getContext().getSession().get("member")).getStrUserName(),"正常退出");
             session.removeAttribute("member");
             OnlineList.userRemoved(user);
         } catch (Exception ex) {
             log.error("已离线");
         }
     }

   public UserInfo getUse() {
       HttpServletRequest request = ServletActionContext.getRequest();
       HttpSession session = request.getSession();
       if (session.getAttribute("member") != null) {
           user = (UserInfo) session.getAttribute("member");
       }

       return user;
   }

   public UserInfo getUser() {
     return user;
   }



    public void setUser(UserInfo user) {
     this.user = user;
   }



    public static void main(String[] args) {
    BO codingbo = new BO();
  }
}