客户关系管理系统(CRM)

package com.accp.dao.jb_crm_team0.Imp; import java.util.ArrayList; import java.util.List; import java.util.Map; import org.apache.commons.lang.StringUtils; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.hibernate.Query; import org.hibernate.Session; import org.hibernate.Criteria; import org.hibernate.LockMode; import org.hibernate.criterion.Expression; import org.hibernate.criterion.Projection; import org.hibernate.criterion.Projections; import org.hibernate.impl.CriteriaImpl; import org.springframework.context.ApplicationContext; import org.springframework.orm.hibernate3.support.HibernateDaoSupport; import com.accp.dao.jb_crm_team0.Inf.ICstCustomerDAO; import com.accp.dao.jb_crm_team0.Inf.ICstManagerDAO; import com.accp.entity.jb_crm_team0.CstCustomer; import com.accp.entity.jb_crm_team0.CstManager; import com.accp.hib.HibernateSessionFactory; import com.accp.util.PageResult; import com.accp.struts.form.CustomerForm; import com.accp.struts.form.ReportForm; public class CstCustomerDAO extends HibernateDaoSupport implements ICstCustomerDAO { private static final Log log = LogFactory.getLog(CstCustomerDAO.class); private ICstManagerDAO cstManDao = null; public ICstManagerDAO getCstManDao() { return cstManDao; } public void setCstManDao(ICstManagerDAO cstManDao) { this.cstManDao = cstManDao; } protected void initDao() { // do nothing } public List<CstCustomer> findAllCustomer() { try { String queryString = "from CstCustomer"; return getHibernateTemplate().find(queryString); } catch (RuntimeException re) { log.error("find all failed", re); throw re; } } public PageResult findAll(Map paramMap) { PageResult pgr = new PageResult(); // 参数 String start = (String) paramMap.get("start"); String limit = (String) paramMap.get("limit"); String no = (String) paramMap.get("custNo"); String name = (String) paramMap.get("custName"); String manName = (String) paramMap.get("custManName"); String level = (String) paramMap.get("custLevel"); String region = (String) paramMap.get("custRegion"); System.out.println("第一条" + start); System.out.println("最后一条" + limit); // 按客户名称查找出客户编号，再通过主外键关系查出相应数据 List<CstManager> lists = cstManDao.findByManName(manName); Long[] manId = new Long[lists.size()]; for (int i = 0; i < manId.length; i++) { manId[i] = lists.get(i).getManId(); System.out.println("aaaaaaaaaaaaa" + manId[i]); } try { Criteria c = getSession().createCriteria(CstCustomer.class); // 条件查询 c.add(Expression.eq("custStatus", "1"));// 查询状态为1的客户 if (StringUtils.isNotEmpty(no)) { c.add(Expression.like("custNo", "%" + no + "%"));// 编号 } if (StringUtils.isNotEmpty(name)) { c.add(Expression.like("custName", "%" + name + "%"));// 客户名称 } if (manId.length > 0) { c.add(Expression.in("cstManager.manId", manId)); } if (StringUtils.isNotEmpty(level)) { c.add(Expression.eq("custLevel", level));// 客户等级 } if (StringUtils.isNotEmpty(region)) { c.add(Expression.like("custRegion", "%" + region + "%"));// 地区 } // 总记录条数 Projection entityProjection = ((CriteriaImpl) c).getProjection(); c.setProjection(Projections.rowCount()).uniqueResult(); int rowCount = ((Number) c.uniqueResult()).intValue(); pgr.setRowCount(rowCount); c.setProjection(entityProjection); // 分页 if (start != null) { c.setFirstResult(Integer.parseInt(start)); } if (limit != null) { c.setMaxResults(Integer.parseInt(limit)); } // 把查询到的数据放到List<customerForm>里面,方便在CustomerAction中转换成json数据 List<CstCustomer> list = c.list(); List<CustomerForm> fList = new ArrayList<CustomerForm>(); CustomerForm custForm = null; for (CstCustomer customer : list) { custForm = new CustomerForm(); custForm.setCustNo(customer.getCustNo()); custForm.setCustName(customer.getCustName()); custForm.setCustRegion(customer.getCustRegion()); custForm.setCustManagerName(customer.getCstManager().getManName()); // 对客户等级进行判断 Integer cstL = customer.getCustLevel(); String cstLevel; if (cstL == 1) { cstLevel = "普通客户"; } else if (cstL == 2) { cstLevel = "重点开发客户"; } else if (cstL == 3) { cstLevel = "大客户"; } else if (cstL == 4) { cstLevel = "合作伙伴"; } else { cstLevel = "战略合作伙伴"; } custForm.setCustLevel(cstLevel); // 对客户满意度进行判断 Integer cstS = customer.getCustSatisfy(); String cstSatisfy; if (cstS == 1) { cstSatisfy = "☆"; } else if (cstS == 2) { cstSatisfy = "☆☆"; } else if (cstS == 3) { cstSatisfy = "☆☆☆"; } else if (cstS == 4) { cstSatisfy = "☆☆☆☆"; } else { cstSatisfy = "☆☆☆☆"; } custForm.setCustSatisfy(cstSatisfy); // 对客户信用度进行判断 Integer cstC = customer.getCustSatisfy(); String cstCredit; if (cstC == 1) { cstCredit = "☆"; } else if (cstC == 2) { cstCredit = "☆☆"; } else if (cstC == 3) { cstCredit = "☆☆☆"; } else if (cstC == 4) { cstCredit = "☆☆☆☆"; } else { cstCredit = "☆☆☆☆"; } custForm.setCustCredit(cstCredit); custForm.setCustAddr(customer.getCustAddr()); custForm.setCustZip(customer.getCustZip()); custForm.setCustTel(customer.getCustTel()); custForm.setCustFax(customer.getCustFax()); custForm.setCustWebsite(customer.getCustWebsite()); custForm.setCustLicenceNo(customer.getCustLicenceNo()); custForm.setCustChieftain(customer.getCustChieftain()); custForm.setCustBankroll(customer.getCustBankroll()); custForm.setCustTurnover(customer.getCustTurnover()); custForm.setCustBank(customer.getCustBank()); custForm.setCustBankAccount(customer.getCustBankAccount()); custForm.setCustLocalTaxNo(customer.getCustLocalTaxNo()); custForm.setCustNationalTaxNo(customer.getCustNationalTaxNo()); custForm.setCustStatus(customer.getCustStatus()); fList.add(custForm); } pgr.setData(fList); } catch (RuntimeException re) { log.error("find all failed", re); throw re; } return pgr; } // 查询客户构成 public PageResult finCustStructure(String type) { PageResult pgr = new PageResult(); Session session = HibernateSessionFactory.getSession(); String hql = ""; // 根据报表方式进行查询 if ("cstLevel".equals(type)) { System.out.println("按客户等级查询"); hql = "select (select b.dictItem from BasDict b where dictType='客户等级' " + "and b.dictValue=c.custLevel) as " + "等级,count(*) from CstCustomer c group by c.custLevel "; } else if ("cstSatisfy".equals(type)) { System.out.println("按客户满意度查询"); hql = "select c.custSatisfy,count(*) from CstCustomer c group by c.custSatisfy"; } else if ("cstCredit".equals(type)) { System.out.println("按客户信用度查询"); hql = "select c.custCredit,count(*) from CstCustomer c group by c.custCredit"; } Query query = session.createQuery(hql); List<Object[]> list = query.list(); List<ReportForm> fList = new ArrayList<ReportForm>(); ReportForm reptForm = null; for (Object[] obj : list) { reptForm = new ReportForm(); if (obj[0] != null) { if (type.equals("cstLevel")) { reptForm.setCustLevel(obj[0].toString()); } else if (type.equals("cstSatisfy")) { reptForm .setCustSatisfy(Integer.parseInt(obj[0].toString())); } else if (type.equals("cstCredit")) { rept