companyimp.java

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

package com.jn0801.company;

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

import javax.servlet.http.HttpServletRequest;

import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.springframework.orm.hibernate3.HibernateCallback;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

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

/**
 * 集团功能实现类
 * 
 * @author student
 * 
 */
public class CompanyIMP extends HibernateDaoSupport implements CompanyIFC {

	/**
	 * 增加新的集团客户信息 同时写入日志信息
	 * 
	 * @param companyBean
	 * @return
	 */
	
	public boolean savecompany(CompanyBean companyBean, int userid) {
		boolean flag = false;

		Date date = new Date();
		SimpleDateFormat simple = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		String LogTime = simple.format(date.getTime());

		CompanyLog companylog = new CompanyLog();
		companylog.setCompanyid(companyBean.getCompanyid());
		companylog.setUserid(String.valueOf(userid));
		companylog.setLogtime(LogTime);
		companylog.setLogtype("save");
		companylog.setLogcon("");

		System.out.println(companyBean.getServicemanager()+"....useridnnn");
		try {
			this.getHibernateTemplate().save(companyBean);
			this.getHibernateTemplate().save(companylog);

			flag = true;
		} catch (Exception e) {

		}

		return flag;
	}

	/**
	 * 更新集团客户信息
	 * 
	 * @param companyBean
	 * @return
	 */
	public boolean updatecompany(CompanyBean companyBean) {
		boolean flag = false;
		try {
			this.getHibernateTemplate().update(companyBean);
			flag = true;

		} catch (Exception e) {

		}

		return flag;
	}

	/**
	 * 显示全部集团客户列表
	 * 
	 * @param companyBean
	 * @param request
	 * @return
	 */
	public List<CompanyBean> listallcompany(HttpServletRequest request) {
		CompanyBean companyBean = new CompanyBean();
		companyBean.setCompanystate("录入");
		companyBean.setServicemanager("");
		return listcompany(companyBean, request);
	}

	/**
	 * 根据传进来的参数显示集团客户列表
	 * 
	 * @param companyBean
	 * @param request
	 * @return
	 */
	public List<CompanyBean> listcompany(CompanyBean companyBean,
			HttpServletRequest request) {
		int count = 0;
		PageDAO pageDAO = new PageDAO(request);
		pageDAO.setPagesize(20);
		companyBean.setCompanystate("'潜在','正式'");
		count = getCount(companyBean);// 获取总记录数
		pageDAO.setRscount(count);
		int currentPage = pageDAO.getCurrentPage();
		int pagecount = pageDAO.getPageCount();// 获取一共有多少页
		int pageSize = pageDAO.getPagesize();// 获取每页显示多少条记录
		int maxResult = currentPage * pageSize;// 获取结束行
		int startResult = (currentPage - 1) * pageSize + 1;// 获取起始行
		String pageTool = pageDAO.pagetool(PageDAO.BbsText);// 构建工具条
		request.setAttribute("pageTool", pageTool);

		Connection con = null;
		Statement stmt = null;
		ResultSet rs = null;
		List<CompanyBean> list = new ArrayList<CompanyBean>();
		StringBuffer sql = new StringBuffer();

		sql.append("select * from (");
		sql
				.append("select a.*,b.sname as typename,rownum as myrow from companytable a inner join typecode b");
		sql.append(" on a.callingtype = b.scode where 1=1");
		sql.append(" and a.islogout=0");
		if (companyBean.getCompanystate() != null
				&& !companyBean.getCompanystate().equals("录入")) {
			sql.append(" and a.companystate in ('潜在','正式')");
		}
		if (companyBean.getNid() != null && companyBean.getNid() != -1) {
			sql.append(" and a.nid=" + companyBean.getNid());
		}

		if (companyBean.getServicemanager() != null
				&& !companyBean.getServicemanager().equals("")) {

			sql.append(" and a.servicemanager="
					+ companyBean.getServicemanager());
		}
		if (companyBean.getCompanyid() != null
				&& !companyBean.getCompanyid().equals("")) {
			sql.append(" and a.companyid='" + companyBean.getCompanyid() + "'");
		}
		if (companyBean.getCompanyname() != null
				&& !companyBean.getCompanyname().equals("")) {
			sql.append(" and a.companyname like'%" + companyBean.getCompanyname()
					+ "%'");
		}
		if (companyBean.getCompanylevel() != null
				&& !companyBean.getCompanylevel().equals("")) {
			sql.append(" and a.companylevel='" + companyBean.getCompanylevel()
					+ "'");
		}
		sql.append(" and rownum<=" + maxResult);
		sql.append(") where myrow>=" + startResult);

		try {
			con = DBConnection.getConnection();
			stmt = con.createStatement();
			rs = stmt.executeQuery(sql.toString());

			while (rs.next()) {
				CompanyBean company = new CompanyBean();
				company.setNid(rs.getLong("nid"));
				company.setCompanyid(rs.getString("companyid"));
				company.setCompanyname(rs.getString("companyname"));
				company.setCallingtype(rs.getString("typename"));
				company.setCompanylevel(rs.getString("companylevel"));
				company.setAddress(rs.getString("address"));
				company.setPhone(rs.getString("phone"));
				company.setDeputy(rs.getString("deputy"));
				company.setCompanystate(rs.getString("companystate"));
				company.setIslogout(rs.getString("islogout"));
				company.setUltimouser(rs.getString("ultimouser"));
				company.setUltimoearning(rs.getString("ultimoearning"));
				company.setServicemanager(rs.getString("servicemanager"));
				company.setTurntime(rs.getString("turntime"));
				list.add(company);
			}

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			DBConnection.close(rs, null, stmt, con);
		}

		return list;
	}

	/**
	 * 根据传进来的参数显示潜在集团客户列表
	 * 
	 * @param companyBean
	 * @param request
	 * @return
	 */
	public List<CompanyBean> potentialcompany(CompanyBean companyBean,
			HttpServletRequest request) {
		int count = 0;
		PageDAO pageDAO = new PageDAO(request);
		pageDAO.setPagesize(20);
		companyBean.setCompanystate("'潜在'");
		count = getCount(companyBean);// 获取总记录数
		pageDAO.setRscount(count);
		int currentPage = pageDAO.getCurrentPage();
		int pagecount = pageDAO.getPageCount();// 获取一共有多少页
		int pageSize = pageDAO.getPagesize();// 获取每页显示多少条记录
		int maxResult = currentPage * pageSize;// 获取结束行
		int startResult = (currentPage - 1) * pageSize + 1;// 获取起始行
		String pageTool = pageDAO.pagetool(PageDAO.BbsText);// 构建工具条
		request.setAttribute("pageTool", pageTool);

		Connection con = null;
		Statement stmt = null;
		ResultSet rs = null;
		List<CompanyBean> list = new ArrayList<CompanyBean>();
		StringBuffer sql = new StringBuffer();

		sql.append("select * from (");
		sql.append("select a.*,b.sname as typename,rownum as myrow from companytable a inner join typecode b");
		sql.append(" on a.callingtype = b.scode where 1=1");
		sql.append(" and a.islogout=0");
		if (companyBean.getCompanystate() != null) {
			sql.append(" and companystate in ('潜在')");
		}
		if (companyBean.getNid() != null && companyBean.getNid() != -1) {
			sql.append(" and nid=" + companyBean.getNid());
		}

		if (companyBean.getServicemanager() != null
				&& !companyBean.getServicemanager().equals("")) {

			sql
					.append(" and servicemanager="
							+ companyBean.getServicemanager());
		}
		sql.append(" and rownum<=" + maxResult);
		sql.append(") where myrow>=" + startResult);

		try {
			con = DBConnection.getConnection();
			stmt = con.createStatement();
			rs = stmt.executeQuery(sql.toString());

			while (rs.next()) {
				CompanyBean company = new CompanyBean();
				company.setNid(rs.getLong("nid"));
				company.setCompanyid(rs.getString("companyid"));
				company.setCompanyname(rs.getString("companyname"));
				company.setCallingtype(rs.getString("typename"));
				company.setCompanylevel(rs.getString("companylevel"));
				company.setAddress(rs.getString("address"));
				company.setPhone(rs.getString("phone"));
				company.setDeputy(rs.getString("deputy"));
				company.setCompanystate(rs.getString("companystate"));
				company.setIslogout(rs.getString("islogout"));
				company.setUltimouser(rs.getString("ultimouser"));
				company.setUltimoearning(rs.getString("ultimoearning"));
				company.setServicemanager(rs.getString("servicemanager"));
				company.setTurntime(rs.getString("turntime"));
				list.add(company);
			}

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			DBConnection.close(rs, null, stmt, con);
		}

		return list;
	}

	/**
	 * 根据传进来的参数显示未被分配集团客户列表
	 * 
	 * @param companyBean
	 * @param request
	 * @return
	 */
	public List<CompanyBean> Unallotcompany(CompanyBean companyBean,
			HttpServletRequest request) {
		int count = 0;
		PageDAO pageDAO = new PageDAO(request);
		pageDAO.setPagesize(20);
		companyBean.setCompanystate("'潜在','正式'");
		count = getCount(companyBean);// 获取总记录数
		pageDAO.setRscount(count);
		int currentPage = pageDAO.getCurrentPage();
		int pagecount = pageDAO.getPageCount();// 获取一共有多少页
		int pageSize = pageDAO.getPagesize();// 获取每页显示多少条记录
		int maxResult = currentPage * pageSize;// 获取结束行
		int startResult = (currentPage - 1) * pageSize + 1;// 获取起始行
		String pageTool = pageDAO.pagetool(PageDAO.BbsText);// 构建工具条
		request.setAttribute("pageTool", pageTool);

		Connection con = null;
		Statement stmt = null;
		ResultSet rs = null;
		List<CompanyBean> list = new ArrayList<CompanyBean>();
		StringBuffer sql = new StringBuffer();

		sql.append("select * from (");
		sql.append("select nid,companyid,companyname,");
		sql.append("callingtype,companylevel,address,phone,");
		sql
				.append("deputy,companystate,islogout,ultimouser,ultimoearning,servicemanager,turntime,");
		sql.append("rownum as myrow from companytable a where 1=1");

		if (companyBean.getCompanystate() != null
				&& !companyBean.getCompanystate().equals("录入")) {
			sql.append(" and companystate in ('潜在','正式')");
		}
		if (companyBean.getNid() != null && companyBean.getNid() != -1) {
			sql.append(" and nid=" + companyBean.getNid());
		}
		if (companyBean.getServicemanager() != null
				&& !companyBean.getServicemanager().equals("")) {
			if (companyBean.getServicemanager().equals("0")) {
				sql.append(" and servicemanager="
						+ companyBean.getServicemanager());
			}

		}
		sql.append(" and rownum<=" + maxResult);
		sql.append(") where myrow>=" + startResult);

		try {
			con = DBConnection.getConnection();
			stmt = con.createStatement();
			rs = stmt.executeQuery(sql.toString());

			while (rs.next()) {
				CompanyBean company = new CompanyBean();
				company.setNid(rs.getLong("nid"));
				company.setCompanyid(rs.getString("companyid"));
				company.setCompanyname(rs.getString("companyname"));
				company.setCallingtype(rs.getString("callingtype"));
				company.setCompanylevel(rs.getString("companylevel"));
				company.setAddress(rs.getString("address"));
				company.setPhone(rs.getString("phone"));
				company.setDeputy(rs.getString("deputy"));
				company.setCompanystate(rs.getString("companystate"));
				company.setIslogout(rs.getString("islogout"));
				company.setUltimouser(rs.getString("ultimouser"));
				company.setUltimoearning(rs.getString("ultimoearning"));
				company.setServicemanager(rs.getString("servicemanager"));
				company.setTurntime(rs.getString("turntime"));
				list.add(company);
			}

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			DBConnection.close(rs, null, stmt, con);
		}

		return list;
	}

	/**
	 * 根据集团ID显示集团的详细信息
	 * 
	 * @param nid
	 * @return
	 */
	public CompanyBean particular(Long nid) {
		Connection con = null;
		Statement stmt = null;
		ResultSet rs = null;
		String sql = "";
		CompanyBean company = new CompanyBean();
		sql = "select * from companytable where 1=1";
		if (nid != 0) {
			sql = sql + " and nid=" + nid;
		}
		try {
			con = DBConnection.getConnection();
			stmt = con.createStatement();
			rs = stmt.executeQuery(sql);
			while (rs.next()) {
				company.setNid(rs.getLong("nid"));
				company.setCompanyid(rs.getString("companyid"));
				company.setCompanyname(rs.getString("companyname"));
				company.setCallingtype(rs.getString("callingtype"));
				company.setCompanylevel(rs.getString("companylevel"));
				company.setAddress(rs.getString("address"));
				company.setPhone(rs.getString("phone"));
				company.setDeputy(rs.getString("deputy"));
				company.setCompanystate(rs.getString("companystate"));
				company.setIslogout(rs.getString("islogout"));
				company.setUltimouser(rs.getString("ultimouser"));
				company.setUltimoearning(rs.getString("ultimoearning"));
				company.setServicemanager(rs.getString("servicemanager"));
				company.setTurntime(rs.getString("turntime"));
			}

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			DBConnection.close(rs, null, stmt, con);
		}

		return company;
	}

	/**
	 * 根据条件查询集团的总记录数
	 * 
	 * @param companyBean
	 *            集团信息的javabean
	 * @return 总记录数
	 */
	public int getCount(CompanyBean companyBean) {
		Connection con = null;
		Statement stmt = null;
		ResultSet rs = null;
		int count = 0;
		StringBuffer sql = new StringBuffer();

		sql
				.append("select count(*) from companytable where 1=1 and islogout=0");

		if (companyBean.getCompanystate() != null) {
			sql.append(" and companystate in (" + companyBean.getCompanystate()
					+ ")");
		}
		if (companyBean.getServicemanager() != null
				&& !companyBean.getServicemanager().equals("")) {

			sql
					.append(" and servicemanager="
							+ companyBean.getServicemanager());
		}
		if (companyBean.getCompanyid() != null
				&& !companyBean.getCompanyid().equals("")) {
			sql.append(" and companyid='" + companyBean.getCompanyid() + "'");
		}
		if (companyBean.getCompanyname() != null
				&& !companyBean.getCompanyname().equals("")) {
			sql.append(" and companyname like'%" + companyBean.getCompanyname()
					+ "%'");
		}
		if (companyBean.getCompanylevel() != null
				&& !companyBean.getCompanylevel().equals("")) {
			sql.append(" and companylevel='" + companyBean.getCompanylevel()