CRM客户关系管理系统源码+数据库

package org.java.dao; import java.util.List; import javax.security.auth.message.callback.PrivateKeyCallback.Request; import org.hibernate.Criteria; import org.hibernate.Query; import org.hibernate.Session; import org.hibernate.Transaction; import org.hibernate.criterion.Example; import org.hibernate.criterion.MatchMode; import org.hibernate.criterion.Order; import org.hibernate.criterion.Projections; import org.hibernate.criterion.Restrictions; import org.java.entity.CstActivity; import org.java.entity.CstCustomer; import org.java.entity.CstLinkman; import org.java.entity.CstLost; import org.java.entity.Orders; import org.java.entity.OrdersLine; import org.java.entity.Product; import org.java.entity.SysUser; import org.java.util.HibernateSessionFactory; import org.java.util.Pagination; public class CustDao_fkp { /**************************************************************/ public void addOrders(Orders orders){ Session ses = HibernateSessionFactory.getSession(); Transaction tran = ses.beginTransaction(); ses.save(orders); tran.commit(); ses.close(); } public void addOrdersLine(OrdersLine line){ Session ses = HibernateSessionFactory.getSession(); Transaction tran = ses.beginTransaction(); ses.save(line); tran.commit(); ses.close(); } //获取产品集合 public List<Product> findProducts(){ Session ses = HibernateSessionFactory.getSession(); String hql = "from Product order by prodId"; Query query = ses.createQuery(hql); List<Product> list = query.list(); ses.close(); return list; } //获得产品对象 public Product findProdByPid(Long pid){ Session ses = HibernateSessionFactory.getSession(); Product prod = (Product) ses.get(Product.class, pid); ses.close(); return prod; } /******************************************************/ public List<CstCustomer> findAll(CstCustomer cust,Pagination p){ Session ses = HibernateSessionFactory.getSession(); Criteria cri = ses.createCriteria(CstCustomer.class); cri.addOrder(Order.desc("custLevel")); cust = cust==null?new CstCustomer():cust; /************* 实例查询 **********/ Example exa = Example.create(cust); exa.excludeProperty("custName"); if(cust.getCustNo()!=null){ cri.add(Restrictions.idEq(cust.getCustNo())); } if(cust.getCustName()!=null){ cri.add(Restrictions.ilike("custName", cust.getCustName(),MatchMode.ANYWHERE)); } if (cust.getSysUser()!=null) { if(cust.getSysUser().getUserId()!=null){ cri.add(Restrictions.eq("sysUser.userId", cust.getSysUser().getUserId())); } } //正常用户 cust.setCustStatus(1L); /************* 分页 **********/ Integer start = (p.getIndex()-1)*p.getSize(); cri.setFirstResult(start); cri.setMaxResults(p.getSize()); cri.add(exa); List<CstCustomer> list = cri.list(); ses.close(); return list; } public Integer getCount(CstCustomer cust){ Session ses = HibernateSessionFactory.getSession(); Criteria cri = ses.createCriteria(CstCustomer.class); cust = cust==null? new CstCustomer():cust; /************* 实例查询 **********/ Example exa = Example.create(cust); exa.excludeProperty("custName"); if(cust.getCustNo()!=null){ cri.add(Restrictions.idEq(cust.getCustNo())); } if(cust.getCustName()!=null){ cri.add(Restrictions.ilike("custName", cust.getCustName(),MatchMode.ANYWHERE)); } if (cust.getSysUser()!=null) { if(cust.getSysUser().getUserId()!=null){ cri.add(Restrictions.eq("sysUser.userId", cust.getSysUser().getUserId())); } } //正常用户 cust.setCustStatus(1L); cri.add(exa); /****** 设置查询方式，聚合查询 *******/ cri.setProjection(Projections.count("custNo")); Integer count = (Integer) cri.uniqueResult(); ses.close(); return count; } public CstCustomer findById(String id){ Session ses = HibernateSessionFactory.getSession(); CstCustomer cst = (CstCustomer) ses.get(CstCustomer.class, id); ses.close(); return cst; } public CstCustomer findByName(String name){ Session ses = HibernateSessionFactory.getSession(); String sql = "from CstCustomer where custName like :name"; Query query = ses.createQuery(sql); query.setString("name", "%"+name+"%"); List<CstCustomer> list = query.list(); CstCustomer c = list.get(0); ses.close(); return c; } public void del(String id) { Session ses = HibernateSessionFactory.getSession(); Transaction trans = ses.beginTransaction(); //未级联字表 有关联表的不能删除 //ses.delete(ses.get(CstCustomer.class,id));//先根据主键找到对象，然后再执行删除操作 CstCustomer cst= (CstCustomer) ses.get(CstCustomer.class,id); cst.setCustStatus(3L); ses.update(cst); trans.commit(); ses.close(); } public void edit(CstCustomer c,Long id) { SysUser u = new UserDao_wlj().getUserById(id); Session ses = HibernateSessionFactory.getSession(); Transaction trans = ses.beginTransaction(); c.setSysUser(u); ses.update(c); trans.commit(); ses.close(); } public void add(CstCustomer c) { Session ses = HibernateSessionFactory.getSession(); Transaction trans = ses.beginTransaction(); ses.save(c); trans.commit(); ses.close(); } /************联系人***************/ public List<CstLinkman> findLinkman(String id) { Session ses = HibernateSessionFactory.getSession(); String sql = "from CstLinkman where cstCustomer.custNo = :id"; Query query = ses.createQuery(sql); query.setString("id", id); List<CstLinkman> list = query.list(); ses.close(); return list; } public CstLinkman findLman(Long id) { Session ses = HibernateSessionFactory.getSession(); String sql = "from CstLinkman where lkmId = :id"; Query query = ses.createQuery(sql); query.setParameter("id", id); CstLinkman c = (CstLinkman) query.uniqueResult(); ses.close(); return c; } public void delLman(Long id){ Session ses = HibernateSessionFactory.getSession(); Transaction trans = ses.beginTransaction(); ses.delete(ses.get(CstLinkman.class, id)); trans.commit(); ses.close(); } public void updLman(CstLinkman clk,String id){ Session ses = HibernateSessionFactory.getSession(); Transaction trans = ses.beginTransaction(); CstCustomer cst = (CstCustomer) ses.get(CstCustomer.class, id); // System.out.println(cst.getCustNo()+"\t"+cst.getCustName()); clk.setCstCustomer(cst); ses.update(clk); trans.commit(); ses.close(); } public void addLman(CstLinkman clk,String id){ Session ses = HibernateSessionFactory.getSession(); Transaction trans = ses.beginTransaction(); CstCustomer cst = (CstCustomer) ses.get(CstCustomer.class, id); clk.setCstCustomer(cst); ses.save(clk); trans.commit(); ses.close(); } /************交往***************/ public List<CstActivity> findCay(String id){ Session ses = HibernateSessionFactory.getSession(); String sql = "from CstActivity where cstCustomer.custNo = :id"; Query query = ses.createQuery(sql); query.setString("id", id); List<CstActivity> list = query.list(); ses.close(); return list; } public CstActivity findOneCay(Long id) { Session ses = HibernateSessionFactory.getSession(); String sql = "from CstActivity where atvId = :id"; Query query = ses.createQuery(sql); query.setParameter("id", id); CstActivity c = (CstActivity) query.uniqueResult(); ses.close(); return c; } public void delCay(Long id){ Session ses = HibernateSessionFactory.getSession(); Transaction trans = ses.beginTransaction(); ses.delete(ses.get(CstActivity.class, id)); trans.commit(); ses.close(); } public void updCay(CstActivity cay,S