bo.java~20~

来自「一个专门用来快速开发网站的框架」· JAVA~20~ 代码 · 共 187 行

package com.ksgl.system.accounts;

import com.core.web.Condition;
import com.opensymphony.xwork.ActionContext;
import org.apache.commons.logging.LogFactory;
import org.apache.commons.logging.Log;
import com.core.web.Paging;
import com.core.persistence.PersistenceManager;
import java.util.List;
import com.ksgl.map.UserInfo;
import com.ksgl.map.t_sys_accounts;

import com.ksgl.map.t_sys_notice;
import com.ksgl.map.UserInfo;
import com.ksgl.map.T_sys_gly;
import com.core.business.SequenceMng;
import com.core.persistence.PersistenceManager;

import org.apache.commons.logging.LogFactory;
import org.apache.commons.logging.Log;
import com.opensymphony.xwork.ActionContext;
import com.opensymphony.webwork.ServletActionContext;
import com.core.Config;
import com.core.web.*;
import javax.servlet.http.*;
import com.core.log.RecLog;

/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2007</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */
public class BO {
  private static Log log = LogFactory.getLog(BO.class);
  PersistenceManager pm = new PersistenceManager();
  public BO() {
  }

  /**
   * 翻页查询
   * add session
   */
  public List queryListSess(Paging paging, Condition condition) {
    List ret = null;
    String hql = " from t_sys_accounts where 1=1";
    hql += " and name='" +
        ( (UserInfo) ActionContext.getContext().getSession().get("member")).
        getStrUserName() + "'";
    if (!condition.getCondition().equals("")) {
      hql += " " + condition.getCondition();
    }
    hql = hql + " order by updatetime desc";
    try {
      ret = pm.queryPageObjs(hql, paging);
    }
    catch (Exception e) {
      log.error("查询queryList  t_sys_accounts出错！");
      e.printStackTrace();
    }
    return ret;
  }

  /**
   * add
   * */
  public void add(t_sys_accounts objmap) {
    try {
      objmap.setId(new SequenceMng().getSequence("t_sys_accounts", "会员充值信息表"));
      objmap.setUpdatetime(Config.getNowTime_long());
      objmap.setNr("管理员为你充值成功！");
      objmap.setIp( ( (com.ksgl.map.T_sys_gly) ActionContext.getContext().
                     getSession().get("user")).getBm());
      new com.core.log.RecLog().add( ( (com.ksgl.map.T_sys_gly)
                                      ActionContext.getContext().
                                      getSession().get("user")).getBm(),
                                    "会员充值增加操作,id:" + objmap.getId());
      pm.saveObj(objmap);
      UserInfo objmap1 = new UserInfo();
      com.ksgl.body.member.BO bo1 = new com.ksgl.body.member.BO();
      objmap1=bo1.queryOne(objmap.getName());
      objmap1=bo1.queryList1(""+objmap1.getLngUserID());
      objmap1.setLngUserID(objmap1.getLngUserID());
      objmap1.setDblCurrAmount(""+(Double.parseDouble(objmap.getServer())+Double.parseDouble(objmap1.getDblCurrAmount())));
      bo1.cZ(objmap1);
    }
    catch (Exception ex) {
      log.error("添加add  t_sys_accounts出错！");
      ex.printStackTrace();
    }
  }

  /**
   * update one
   * */

  public void update(t_sys_accounts objmap) {
    try {
      new com.core.log.RecLog().add( ( (com.ksgl.map.T_sys_gly)
                                      ActionContext.getContext().
                                      getSession().get("user")).getBm(),
                                    "会员充值修改操作,id:" + objmap.getId());
      objmap.setIp( ( (com.ksgl.map.T_sys_gly)
                     ActionContext.getContext().
                     getSession().get("user")).getBm());
      objmap.setUpdatetime(Config.getNowTime_long());
      pm.updateObj(objmap);
    }
    catch (Exception ex) {
      log.error("修改update t_sys_accounts出错！");
      ex.printStackTrace();
    }
  }

  /**
   * 翻页查询
   * admin manager
   */
  public List queryList(Paging paging, Condition condition) {
    List ret = null;
    String hql = " from t_sys_accounts where 1=1";
    if (! ( (T_sys_gly) ActionContext.getContext().getSession().get("user")).
        getLbbm().equals("0")) {
      hql += " and ip='" +
          ( (T_sys_gly) ActionContext.getContext().getSession().get("user")).
          getBm() + "'";
    }
    if (!condition.getCondition().equals("")) {
      hql += " " + condition.getCondition();
    }
    hql = hql + " order by updatetime desc";
    try {
      ret = pm.queryPageObjs(hql, paging);
    }
    catch (Exception e) {
      log.error("查询queryList  t_sys_accounts出错！");
      e.printStackTrace();
    }
    return ret;
  }

  /**
   * delete more one
   * */
  public void delete() {
    try {
      String names[] = (String[]) ActionContext.getContext().getParameters().
          get("id");
      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(), "会员充值删除操作,id:" + names[i]);
        pm.deleteObjs(pm.queryObjs(" from t_sys_accounts where id='" + names[i] +
                                   "'"));
      }
    }
    catch (Exception ex) {
      log.error("删除delete  t_sys_accounts出错！");
      ex.printStackTrace();
    }
  }

  /**
   * query one
   * */
  public t_sys_accounts queryOne(String id) {
    List ret = null;
    t_sys_accounts t_sys_accounts = new t_sys_accounts();
    String hql = " from t_sys_accounts where id='" + id + "'";
    try {
      ret = pm.queryObjs(hql);
      t_sys_accounts = (t_sys_accounts) ret.get(0);
    }
    catch (Exception e) {
      log.error("查询id = " + id + " queryOne t_sys_accounts出错！");
      e.printStackTrace();
    }
    return t_sys_accounts;
  }

}