linkmanmanageimp.java

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

package com.jn0801.company;

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.company.dao.LinkmanBean;
import com.jn0801.company.dao.LinkmanLogBean;
import com.jn0801.tools.DBConnection;
import com.jn0801.tools.PageDAO;

public class LinkmanManageIMP extends HibernateDaoSupport implements
		LinkmanManageIFC {
	
	/**
	 * 查询集团联系人信息
	 * 
	 * @param id
	 *            编号
	 * @return 结果集
	 */
	public LinkmanBean searchByID(Long id){
		LinkmanBean bean = new LinkmanBean();
		Connection conn = null;
		Statement stmt = null;
		ResultSet rs = null;
		String sql = "select * from companylinkmaninfo where nid ="+id;
		try {
			conn = DBConnection.getConnection();
			stmt = conn.createStatement();
			rs = stmt.executeQuery(sql);			
			while(rs.next()){
				bean.setNid(rs.getLong("nid"));
				bean.setCompanyid(rs.getString("companyid"));
				bean.setCompanyname(rs.getString("companyname"));
				bean.setLinkman(rs.getString("linkman"));
				bean.setLinkmanduty(rs.getString("linkmanduty"));
				bean.setContacttype(rs.getString("contacttype"));
			}
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}finally{
			DBConnection.close(rs, null, stmt, conn);
		}
		
		return bean;
	}

	/**
	 * 查询集团联系人信息
	 * 
	 * @param info
	 *            集团联系人资料
	 * @param request
	 *            客户端请求
	 * @return 查询到的结果集
	 */
	public List searchInfo(Companylinkmaninfo info, HttpServletRequest request) {

		int count = 0;
		PageDAO pageDAO = new PageDAO(request);
		pageDAO.setPagesize(20);
		count = getCount(info);// 获取总记录数
		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);

		Connection conn = null;
		Statement stmt = null;
		ResultSet rs = null;
		List list = new ArrayList();
		StringBuffer sql = new StringBuffer();
		sql.append("select * from (");
		sql.append("select a.*,rownum as myrow from companylinkmaninfo a where rownum<=" + maxResult);
		sql.append(") where myrow>=" + firstResult);
		if (info.getNid() != 0) {
			sql.append("and nid =" + info.getNid());
		}
		if (info.getCompanyid() != null && !info.getCompanyid().equals("")) {
			sql.append("and companyid like '%" + info.getCompanyid()+ "%'");
		}
		if (info.getCompanyname() != null && !info.getCompanyname().equals("")) {
			sql.append(" and companyname like '%" + info.getCompanyname()
					+ "%'");
		}
		if (info.getLinkman() != null && !info.getLinkman().equals("")) {
			sql.append(" and linkman like '%" + info.getLinkman()
					+ "%'");
		}
		try {
			conn = DBConnection.getConnection();
			stmt = conn.createStatement();
			rs = stmt.executeQuery(sql.toString());
			while (rs.next()) {
				LinkmanBean bean = new LinkmanBean();
				bean.setNid(rs.getLong("nid"));
				bean.setCompanyid(rs.getString("companyid"));
				bean.setCompanyname(rs.getString("companyname"));
				bean.setLinkman(rs.getString("linkman"));
				bean.setLinkmanduty(rs.getString("linkmanduty"));
				bean.setContacttype(rs.getString("contacttype"));
				list.add(bean);
			}
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		} finally {
			DBConnection.close(rs, null, stmt, conn);
		}
		return list;
	}

	private int getCount(Companylinkmaninfo info) {
		int i = 0;
		Connection conn = null;
		Statement stmt = null;
		ResultSet rs = null;
		StringBuffer sql = new StringBuffer();
		sql.append("select count(nid) from companylinkmaninfo where 1=1");
		if (info.getNid() != 0) {
			sql.append(" and nid=" + info.getNid());
		}
		if (info.getCompanyname() != null && !info.getCompanyname().equals("")) {
			sql.append(" and companyname like '%" + info.getCompanyname()
					+ "%'");
		}
		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 info
	 *            集团联系人资料
	 * @param log
	 *            集团联系人日志资料
	 * @return 成功返回 ture 失败返回 false；
	 */
	public boolean addInfo(Companylinkmaninfo info,Companylinkmanlog log){
		boolean flag = false;
		try {
			this.getHibernateTemplate().save(info);
			this.getHibernateTemplate().save(log);
			flag = true;
		} catch (Exception e) {
			e.printStackTrace();			
		}
		return flag;
	}
	
	/**
	 * 修改集团联系人信息
	 * 
	 * @param info
	 *            集团联系人资料
	 * @param log
	 *            集团联系人日志资料
	 * @return 成功返回 ture 失败返回 false；
	 */
	public boolean modInfo(Companylinkmaninfo info,Companylinkmanlog log){
		boolean flag = false;
		try {
			this.getHibernateTemplate().update(info);
			this.getHibernateTemplate().save(log);
			flag = true;
		} catch (Exception e) {
			e.printStackTrace();
		}
		return flag;
	}
	
	/**
	 * 刪除集团联系人信息
	 * 
	 * @param nid
	 *            集团联系人资料的编号
	 * @param log
	 *            集团联系人日志资料
	 * @return 成功返回 ture 失败返回 false；
	 */
	public boolean removeInfo(Long nid,Companylinkmanlog log){
		boolean flag = false;
		try {
			Companylinkmaninfo info2 = (Companylinkmaninfo) this.getHibernateTemplate().load(Companylinkmaninfo.class, nid);
			this.getHibernateTemplate().delete(info2);
			this.getHibernateTemplate().save(log);
			flag = true;
		} catch (Exception e) {
			e.printStackTrace();
		}
		return flag;
	}

}