businessinfoimp.java

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

package com.jn0801.clubmanage;

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

import javax.servlet.http.HttpServletRequest;

import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

import com.jn0801.clubmanage.dto.BusinessInfoBean;
import com.jn0801.tools.DBConnection;
import com.jn0801.tools.PageDAO;

public class BusinessInfoIMP extends HibernateDaoSupport implements
		BusinessInfoIFC {

	/**
	 * 添加商家基本资料
	 * 
	 * @param bsInfo
	 *            商家基本资料
	 * @return 修改是否成功 成功返回 true 失败返回 false；
	 */
	public boolean addBsInfo(Businessbasicinfotable bsInfo) {
		boolean tag = false;
		try {
			this.getHibernateTemplate().save(bsInfo);
			tag = true;
		} catch (Exception e) {
			e.printStackTrace();
			tag = false;
		}
		return tag;
	}

	/**
	 * 根据条件查询商家记录数
	 * 
	 * @param bsInfo
	 *            商家基本资料
	 * @return 返回查询到的商家总记录数
	 */
	public int getCount(Businessbasicinfotable bsInfo) {
		int i = 0;
		Connection conn = null;
		Statement stmt = null;
		ResultSet rs = null;
		StringBuffer sql = new StringBuffer();
		sql.append("select count(nid) from BUSINESSBASICINFOTABLE where 1=1");
		if (bsInfo.getNid() != 0) {
			sql.append(" and nid=" + bsInfo.getNid());
		}
		if (bsInfo.getBsname() != null && !bsInfo.getBsname().equals("")) {
			sql.append(" and bsName like '%" + bsInfo.getBsname() + "%'");
		}
		try {
			conn = DBConnection.getConnection();
			stmt = conn.createStatement();
			rs = stmt.executeQuery(sql.toString());
			if (rs.next()) {
				i = rs.getInt(1);
			}

		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		} finally {
			DBConnection.close(rs, null, stmt, conn);
		}
		return i;
	}

	/**
	 * 修改商家基本资料
	 * 
	 * @param bsInfo
	 *            修改好的商家基本资料
	 * @return 修改是否成功 成功返回 true 失败返回 false；
	 */
	public boolean modBsInfo(Businessbasicinfotable bsInfo) {
		boolean tag = false;
		try {
			this.getHibernateTemplate().update(bsInfo);
			tag = true;
		} catch (Exception e) {
			e.printStackTrace();
		}
		return tag;
	}

	/**
	 * 刪除商家基本资料
	 * 
	 * @param nid
	 *            商家的编号
	 * @return 刪除是否成功 成功返回 true 失败返回 false；
	 */
	public boolean removeBsInfo(Long nid) {
		boolean tag = false;
		Connection conn = null;
		Statement stmt = null;
		ResultSet rs = null;
		StringBuffer sql = new StringBuffer();
		sql.append("delete from BUSINESSBASICINFOTABLE where nid=" + nid);
		String str = sql.toString();
		try {
			conn = DBConnection.getConnection();
			stmt = conn.createStatement();
			rs = stmt.executeQuery(sql.toString());

			if (rs.next())
				tag = true;

			return tag;
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
			return tag;
		} finally {
			DBConnection.close(rs, null, stmt, conn);
		}
	}

	/**
	 * 根据编号查询商家资料
	 * 
	 * @param nid
	 *            商家编号
	 * @return 返回查询到的商家资料
	 */
	public BusinessInfoBean searchByID(Long nid) {
		BusinessInfoBean bsinfoBean = new BusinessInfoBean();
		Connection conn = null;
		Statement stmt = null;
		ResultSet rs = null;
		String sql = "select * from BUSINESSBASICINFOTABLE where nid=" + nid;

		try {
			conn = DBConnection.getConnection();
			stmt = conn.createStatement();
			rs = stmt.executeQuery(sql);
			if (rs.next()) {
				bsinfoBean.setNid(rs.getLong("nid"));
				bsinfoBean.setPartnertype(rs.getString("partnertype"));
				bsinfoBean.setBslevel(rs.getLong("bslevel"));
				bsinfoBean.setBsshortname(rs.getString("bsshortname"));
				bsinfoBean.setBsname(rs.getString("bsname"));
				bsinfoBean.setBskind(rs.getString("bskind"));
				bsinfoBean.setBsaddress(rs.getString("bsaddress"));
				bsinfoBean.setCorporation(rs.getString("corporation"));
				bsinfoBean.setBsemployee(rs.getLong("bsemployee"));
				bsinfoBean.setBsloginfund(rs.getString("bsloginfund"));
				bsinfoBean.setBsworkstate(rs.getString("bsworkstate"));
				bsinfoBean.setRulersex(rs.getString("rulersex"));
				bsinfoBean.setBslinkman(rs.getString("bslinkman"));
				bsinfoBean.setRulername(rs.getString("rulername"));
				bsinfoBean.setRulerposition(rs.getString("rulerposition"));
				bsinfoBean.setRelationtype(rs.getString("relationtype"));
				bsinfoBean.setBsaddtime(rs.getString("bsaddtime"));
				bsinfoBean.setLogout(rs.getLong("logout"));
			}
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		} finally {
			DBConnection.close(rs, null, stmt, conn);
		}
		return bsinfoBean;
	}

	/**
	 * 查询商家
	 * 
	 * @param bsInfo
	 *            商家基本资料
	 * @param request
	 *            客户端请求
	 * @return 返回查询到的商家列表
	 */
	public List<BusinessInfoBean> searchBsInfo(Businessbasicinfotable bsInfo,
			HttpServletRequest request) {

		int count = 0;
		PageDAO pageDAO = new PageDAO(request);
		pageDAO.setPagesize(20);
		count = getCount(bsInfo);// 获取总记录数
		pageDAO.setRscount(count);
		int currentPage = pageDAO.getCurrentPage();
		int pagecount = pageDAO.getPageCount();// 获取一共有多少页
		int pageSize = pageDAO.getPagesize();// 获取每页显示多少条记录
		int maxResult = currentPage * pageSize;// 获取结束行
		int firstResult = (currentPage - 1) * pageSize + 1;
		String pageTool = pageDAO.pagetool(PageDAO.BbsText);// 构建工具条
		request.setAttribute("pageTool", pageTool);

		List<BusinessInfoBean> list = new ArrayList<BusinessInfoBean>();
		Connection conn = null;
		Statement stmt = null;
		ResultSet rs = null;
		StringBuffer sql = new StringBuffer();
		sql.append("select * from (");
		sql
				.append("select a.*,rownum as myrow from BUSINESSBASICINFOTABLE a where rownum<="
						+ maxResult);
		sql.append(") where myrow>=" + firstResult);
		if (bsInfo.getNid() != 0) {
			sql.append(" and nid=" + bsInfo.getNid());
		}
		if (bsInfo.getBsname() != null && !bsInfo.getBsname().equals("")) {
			sql.append(" and bsname like '%" + bsInfo.getBsname() + "%'");
		}
		System.out.println(sql.toString());
		try {
			conn = DBConnection.getConnection();
			stmt = conn.createStatement();
			rs = stmt.executeQuery(sql.toString());

			while (rs.next()) {
				BusinessInfoBean bsinfoBean = new BusinessInfoBean();
				bsinfoBean.setNid(rs.getLong("nid"));
				bsinfoBean.setPartnertype(rs.getString("partnertype"));
				bsinfoBean.setBslevel(rs.getLong("bslevel"));
				bsinfoBean.setBsshortname(rs.getString("bsshortname"));
				bsinfoBean.setBsname(rs.getString("bsname"));
				bsinfoBean.setBskind(rs.getString("bskind"));
				bsinfoBean.setBsaddress(rs.getString("bsaddress"));
				bsinfoBean.setCorporation(rs.getString("corporation"));
				bsinfoBean.setBsemployee(rs.getLong("bsemployee"));
				bsinfoBean.setBsloginfund(rs.getString("bsloginfund"));
				bsinfoBean.setBsworkstate(rs.getString("bsworkstate"));
				bsinfoBean.setRulersex(rs.getString("rulersex"));
				bsinfoBean.setBslinkman(rs.getString("bslinkman"));
				bsinfoBean.setRulername(rs.getString("rulername"));
				bsinfoBean.setRulerposition(rs.getString("rulerposition"));
				bsinfoBean.setRelationtype(rs.getString("relationtype"));
				bsinfoBean.setBsaddtime(rs.getString("bsaddtime"));
				bsinfoBean.setLogout(rs.getLong("logout"));
				list.add(bsinfoBean);
			}

			return list;

		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
			return list;
		} finally {
			DBConnection.close(rs, null, stmt, conn);
		}

	}
}