intergralruledaoimpl.java

自己制作的联通CRM,支持客户分类,管理,升级,积分管理等等..

package com.jn0801.intergral.rule;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

import com.jn0801.tools.DBConnection;
import com.jn0801.tools.PageDAO;

public class IntergralRuleDaoImpl extends HibernateDaoSupport implements
		IntergralRuleDao {

	/**
	 * 根据条件列出积分规则
	 * 
	 * @param location
	 * @param servertype
	 * @param request
	 * @return
	 */
	public List listIntergralRule(String location, String servertype,
			HttpServletRequest request) {
		List<Map<String, Object>> intergralRuleList = new ArrayList<Map<String, Object>>();
		Connection connection = null;
		Statement statement = null;
		ResultSet resultSet = null;
		PageDAO pageDAO = null;
		String sql = "";
		try {
			connection = DBConnection.getConnection();
			statement = connection.createStatement();
			pageDAO = new PageDAO(request);
			sql = "select count(1) as rscount from intergralrule where 1=1 ";
			if (location != null && !"0".equals(location)) {
				sql = sql + " and location='" + location + "'";
			}
			if (servertype != null && !"0".equals(servertype)) {
				sql = sql + " and servertype='" + servertype + "'";
			}
			int rscount = pageDAO.getRsCountForSQL(sql);
			int pagesize = 10;
			pageDAO.setPagesize(pagesize);
			pageDAO.setRscount(rscount);
			pageDAO.getPageCount();
			int currentpage = pageDAO.getCurrentPage();
			String pagetool = pageDAO.pagetool(PageDAO.BbsText);
			request.setAttribute("pagetool", pagetool);

			sql = "select * from (select ruleid,location,servertype,minintergral,rate,rownum rn from intergralrule where 1=1";
			if (location != null && !"0".equals(location)) {
				sql = sql + " and location='" + location + "'";
			}
			if (servertype != null && !"0".equals(servertype)) {
				sql = sql + " and servertype='" + servertype + "'";
			}
			sql = sql + " and rownum <=" + currentpage * pagesize + ") t ";
			sql = sql + " where t.rn >=" + ((currentpage - 1) * pagesize + 1);

			resultSet = statement.executeQuery(sql);
			while (resultSet.next()) {
				Map<String, Object> map = new HashMap<String, Object>();
				map.put("ruleid", resultSet.getObject(1));
				map.put("location", resultSet.getObject(2));
				map.put("servertype", resultSet.getObject(3));
				map.put("minintergral", resultSet.getObject(4));
				map.put("rate", resultSet.getObject(5));
				intergralRuleList.add(map);
			}

		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			DBConnection.close(resultSet, null, statement, connection);
		}
		return intergralRuleList;
	}

	/**
	 * 此方法根据条件找出积分规则
	 * 
	 * @param location
	 * @param servertype
	 * @return
	 */
	public IntergralRule findIntergralRule(String location, String servertype) {
		IntergralRule intergralRule = null;
		String sql = "select * from intergralrule where location='" + location
				+ "' and servertype='" + servertype + "'";
		Connection connection = null;
		try {
			connection = DBConnection.getConnection();
			QueryRunner queryRunner = new QueryRunner();
			intergralRule = (IntergralRule) queryRunner.query(connection, sql,
					new BeanHandler(IntergralRule.class));
			if (intergralRule == null) {
				intergralRule = new IntergralRule();
				intergralRule.setLocation("默认");
				intergralRule.setMinintergral("2000");
				intergralRule.setRate("0.05");
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return intergralRule;
	}

	/**
	 * 此方法修改积分规则
	 * 
	 * @param intergralRuleForm
	 */
	public void modifyIntergralRule(IntergralRuleForm intergralRuleForm) {
		Long ruleid = intergralRuleForm.getRuleid();
		String minintergral = intergralRuleForm.getMinintergral();
		String rate = intergralRuleForm.getRate();
		IntergralRule intergralRule = (IntergralRule) this
				.getHibernateTemplate().get(IntergralRule.class, ruleid);
		intergralRule.setMinintergral(minintergral);
		intergralRule.setRate(rate);
		this.getHibernateTemplate().update(intergralRule);
	}

	/**
	 * 此方法删除积分规则
	 * 
	 * @param ruleid
	 */
	public void deleteIntergralRule(Long ruleid) {
		IntergralRule intergralRule = (IntergralRule) this
				.getHibernateTemplate().get(IntergralRule.class, ruleid);
		this.getHibernateTemplate().delete(intergralRule);
	}
}