dealwithimp.java

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

package com.jn0801.DealWithOperation;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.Map.Entry;
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.tools.DBConnection;
import com.jn0801.tools.PageDAO;

/**
 * 处理接口实现类
 * @author student
 *
 */
public class DealWithIMP extends HibernateDaoSupport implements DealWithIFC {


	public boolean listExist(long dealerid, long nid,long emnid) {
			
		String hql="Select a From acceptorresult a where 1=1";
		
		if(dealerid !=0 )
		{
			hql=hql+" and dealerid="+dealerid;
		}
		if(nid !=0 )
		{
			hql=hql+" and gnid="+nid;
		}	
		if(emnid !=0 )
		{
			hql=hql+" and acceptid="+emnid;
		}
		
		List list=this.getHibernateTemplate().find(hql);
		
		if(list.size()>0)
		{
			return true;
		}else
		{
			return false;
		}	
	}
	
	/**
	 * 查询返回List
	 * @param dealwithform
	 * @param request
	 * @return
	 */
	public List<Map> listdata(DealWithOperationForm dealwithform, HttpServletRequest request) {
		
		List<Map> list=new ArrayList<Map>();		
		Statement st=null;
		ResultSet rs=null;
		Connection conn=null;
		//工单序号
		long nid=0;
		long userid=0;
		long emnid=0;
		if(dealwithform.getNid()!=null)
		{
			nid=dealwithform.getNid();
		}		
		if(dealwithform.getEmnid()!=null)
		{
			emnid=dealwithform.getEmnid();
		}	
		if(dealwithform.getUserid()!=null)
		{
			//用户ID
			userid=dealwithform.getUserid();
		}
	
		String nmax=dealwithform.getNmax();
		String nmin=dealwithform.getNmin();
		//用户地址
		String address=dealwithform.getAddress();
		//起始时间
		String starttime=dealwithform.getStarttime();
		//终止时间
		String endtime=dealwithform.getEndtime();
		//是否处理
		String dealmark=dealwithform.getDealmark();
		//处理人
		String lastdealer=dealwithform.getLastdealer();
		
		
		System.out.println(dealmark+".....dealmark");
		
		if(nmin!=null && !nmin.equals(""))
		{
			int nminnum=Integer.parseInt(nmin);
		}
		
		int startpage=0;
		int endpage=0;
		int rscount=0;
		
		StringBuffer sql=new StringBuffer();
		
		PageDAO pagedao=new PageDAO(request);

		sql.append("select count(*) from acceptoperation where 1=1");
		if(nid!=0)
		{
			sql.append(" and nid="+nid);
		}
		if(starttime!=null && endtime!=null  && !starttime.equals("") && !endtime.equals(""))
		{
			sql.append(" and accepttime <='"+endtime+"'");
			sql.append(" and accepttime >='"+starttime+"'");
		}
		if(lastdealer!=null && !lastdealer.equals("") )
		{
			sql.append(" and lastdealer="+lastdealer);
		}
		if(emnid!=0)
		{
			sql.append(" and emnid="+emnid);
		}
		if(userid!=0)
		{
			sql.append(" and userid="+userid);
		}
		if(address!=null && address.equals(""))
		{
			sql.append(" and address='"+address+"");
		}
		if(dealmark!=null && !dealmark.equals(""))
		{
			sql.append(" and dealmark='"+dealmark+"'");
		}
		if(nmax!=null && !nmax.equals(""))
		{
			sql.append(" and nmax='"+nmax+"'");
		}
		if(nmin!=null && !nmin.equals(""))
		{
			sql.append(" and nmin='"+nmin+"'");
		}
		try {
			conn=DBConnection.getConnection();
			st=conn.createStatement();
			rs=st.executeQuery(sql.toString());
			
			System.out.println(sql+"..sql");
			//获取总记录数
			while(rs.next())
			{
				rscount=rs.getInt(1);
				System.out.println(rscount);
			}
		
			pagedao.setRscount(rscount);
			
			//设置每页要显示的条目
			pagedao.setPagesize(10);
			
			//获取每页多少条
			int pagesize = pagedao.getPagesize();
			
			//获取总页数
			int pagecount = pagedao.getPageCount();
	
			//获取当前页
	
			int currentpage=pagedao.getCurrentPage();
			
			System.out.println(currentpage+"...currentpage");
			//构建工具栏
			String pagetool =pagedao.pagetool(PageDAO.BbsText);
			request.setAttribute("pagetool", pagetool);
			
			//获取起始行
			startpage=(currentpage-1)*pagesize+1;
			//获取结束行
			endpage=(currentpage)*pagesize;
			
			
			StringBuffer sql1=new StringBuffer();

			sql1.append("select * from (select a.nid,a.userid,a.address,a.nmax,a.nmin,a.dredgestate,a.sid,a.dealmark,a.lastdealer,rownum as myrow from acceptoperation a");
			sql1.append(" where 1=1");
			if(nid!=0)
			{
				sql1.append(" and nid="+nid);
			}
			if(starttime!=null && endtime!=null  && !starttime.equals("") && !endtime.equals(""))
			{
				sql1.append(" and accepttime <='"+endtime+"'");
				sql1.append(" and accepttime >='"+starttime+"'");
			}
			if(lastdealer!=null && !lastdealer.equals("") )
			{
				sql1.append(" and lastdealer="+lastdealer);
			}
			if(emnid!=0)
			{
				sql1.append(" and emnid="+emnid);
			}
			if(userid!=0)
			{
				sql1.append(" and userid="+userid);
			}
			if(address!=null && address.equals(""))
			{
				sql1.append(" and address='"+address+"");
			}
			if(dealmark!=null && !dealmark.equals(""))
			{
				sql1.append(" and dealmark='"+dealmark+"'");
			}
			if(nmax!=null && !nmax.equals(""))
			{
				sql1.append(" and nmax='"+nmax+"'");
			}
			if(nmin!=null && !nmin.equals(""))
			{
				sql1.append(" and nmin='"+nmin+"'");
			}					
			sql1.append(" and rownum<="+endpage);
			sql1.append(") ");
			sql1.append("where myrow>="+startpage);	
				
			
			System.out.println(sql1);
			rs=st.executeQuery(sql1.toString());
			
		
			ResultSetMetaData mrs = rs.getMetaData();	
			int nRowNum = mrs.getColumnCount();
				
			while(rs.next())
			{
				Map tempmap=new HashMap();
				for(int i=1;i<nRowNum;i++)
				{					
					Object key = mrs.getColumnName(i).toLowerCase();
					Object value = rs.getObject(key.toString());				
					tempmap.put(key, value);						
				}
				list.add(tempmap);
			}			
				
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}finally
		{
			DBConnection.close(rs,null,st,conn);
		}

		return list;
		
	}
	/**
	 * 事物式处理数据插入
	 * @param acceptoresult
	 * @return
	 */
	public boolean insertdwoperation(acceptorresult acceptoresult) {
		long nid=acceptoresult.getGnid();
		long dealerid=acceptoresult.getDealerid();
		String dmark=acceptoresult.getDmark();

	
		
		final String hql="update Acceptoperation set lastdealer="+dealerid+",dealmark='"+dmark+"' where nid="+nid;		
		this.getHibernateTemplate().save(acceptoresult);		
		this.getHibernateTemplate().execute(new HibernateCallback()
		{

			public Object doInHibernate(Session session) throws HibernateException, SQLException {			
				Query query=session.createQuery(hql);
				int i=query.executeUpdate();
				if(i!=1)
				{
					return false;
				}
				return true;
			}
			
		});
		return true;
	}


	/**
	 * 查询返回历史明细
	 * @param nid
	 * @return
	 */
	public List<acceptorresult> searchdwhistory(long nid) {
		
		String hql="Select a From acceptorresult a where gnid="+nid;
		
		List<acceptorresult> list=this.getHibernateTemplate().find(hql);
			
		return list;
	}

}