clubmanageimp.java

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

package com.jn0801.clubnetinfo;

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 com.jn0801.login.systemuser.SystemuserBean;
import com.jn0801.tools.DBConnection;
import com.jn0801.tools.PageDAO;


public class ClubManageImp implements ClubManageInf {

	public List<ClubManageBean> serchClub() {
		// TODO 自动生成方法存根
		return null;
	}
	
	/**
	 * 查寻俱乐部网点信息
	 * 返回list
	 */
	public List<ClubManageBean> listClubInfo(String clubname,HttpServletRequest request) {

		List<ClubManageBean> list = new ArrayList<ClubManageBean>();
		Connection conn = null;
		Statement stmt = null;
		ResultSet rs = null;
		String sql = "";
		
		//开始分页
		PageDAO pagedao = new PageDAO(request);
		pagedao.setPagesize(10);
		// 获取每页多少条
		int pagesize = pagedao.getPagesize();
		//获取总记录数
		sql = "select count(1) from clubInfoManage where 1=1 ";
		if (clubname != null && !clubname.trim().equals(""))
			sql = sql + " and phone like '%" + clubname + "%'";
		//总记录数
		int rscount = 0;
		try {
			
			conn = DBConnection.getConnection();
			stmt = conn.createStatement();
			rs = stmt.executeQuery(sql);
			
			while(rs.next()){
				rscount = rs.getInt(1);
			}
			
			//设置总记录数
			pagedao.setRscount(rscount);
			//获取总页数
			int pagecount = pagedao.getPageCount();
			// 获取当前页
			int currentpage = pagedao.getCurrentPage();
			//构建工具栏
			String pagetool = pagedao.pagetool(PageDAO.BbsText);
			request.setAttribute("pagetool", pagetool);
			//计算起始行和结束行
			int pastart = (currentpage-1)*pagesize+1; 
			int paend = currentpage*pagesize;
			
			
			sql = "select * from ("; 
			sql = sql + "select s.*,rownum as myrow from clubInfoManage s where 1=1 ";
			
			if (clubname != null && !clubname.trim().equals(""))
				sql = sql + " and phone like '%" + clubname + "%'";
			
			sql = sql + " and rownum <= " + paend;
			sql = sql + ")";
			sql = sql + " where myrow >= " + pastart;
			
			rs = stmt.executeQuery(sql);
			
			while (rs.next()) {

				ClubManageBean userBean = new ClubManageBean();
				userBean.setNid(rs.getInt("nid"));
				userBean.setAddress(rs.getString("address"));
				userBean.setClubname(rs.getString("clubname"));
				userBean.setFunction(rs.getString("function"));
				userBean.setLevels(rs.getString("levels"));
				userBean.setManage(rs.getString("manage"));
				userBean.setPhone(rs.getString("phone"));
				userBean.setServicetype(rs.getString("servicetype"));
				
				list.add(userBean);

			}

		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				if (rs != null)
					rs.close();
				if (stmt != null)
					stmt.close();
				if (conn != null)
					conn.close();
			} catch (Exception e) {
				e.printStackTrace();
			}

		}

		return list;
	}
	/**
	 * 实现网点俱乐部的修改
	 */
	
	public boolean updateclub(ClubManageBean bean){
		
		boolean  flag= false;
		Connection conn= null;
		Statement stmt = null;
		StringBuffer sql = new StringBuffer();
		sql.append("update clubInfoManage set ");
		sql.append("clubname = '"+bean.getClubname()+"',");
		sql.append("address = '"+bean.getAddress()+"',");
		sql.append("function = '"+bean.getFunction()+"',");
		sql.append("levels = '"+bean.getLevels()+"',");
		sql.append("manage = '"+bean.getManage()+"',");
		sql.append("phone = '"+bean.getPhone()+"',");
		sql.append("servicetype='"+bean.getServicetype()+"' where nid="+bean.getNid());


		try {
			conn = DBConnection.getConnection();
			stmt = conn.createStatement();
			
			if(stmt.executeUpdate(sql.toString())>0){
				flag = true;
			}
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}finally{
			try {
				stmt.close();
				conn.close();
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
		}
		
		
		return flag;
	}
	
	/**
	 * 实现俱乐部网点添加操作
	 */
	public boolean insertclubinfo(ClubManageBean bean){
		boolean flag= false;
		
		StringBuffer sql = new StringBuffer();
		if(bean != null)
		{
			sql.append("insert into clubInfoManage(");
			sql.append("nid,clubname,address,phone,ma" +
					"nage,servicetype,function,levels)values(");
			sql.append("SEQ_CLUB_NET.Nextval,");
			sql.append("'"+bean.getClubname()+"',");
			sql.append("'"+bean.getAddress()+"',");
			sql.append("'"+bean.getPhone()+"',");
			sql.append("'"+bean.getManage()+"',");
			sql.append("'"+bean.getServicetype()+"',");
			sql.append("'"+bean.getFunction()+"',");
			sql.append("'"+bean.getLevels()+"')");
		}
		
		Connection conn =null;
		Statement stmt = null;
		try {
			conn= DBConnection.getConnection();
			stmt = conn.createStatement();
			if(stmt.executeUpdate(sql.toString())>0){
				flag = true;
			}
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}finally{
			try {
				stmt.close();
				conn.close();
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
		}
		
		return flag;
	}
	/**
	 * 按编号查询出俱乐部的所有信息
	 */
	
	public ClubManageBean serchclubinfo(int nid){
		ClubManageBean bean = null;
		String sql="select * from clubInfoManage where nid = "+nid;
		Connection conn = null;
		Statement stmt = null;
		ResultSet rs = null;

		try {
			conn = DBConnection.getConnection();
			stmt = conn.createStatement();
			rs = stmt.executeQuery(sql);
			while(rs.next()){
				bean = new ClubManageBean();
				bean.setNid(nid);
				bean.setAddress(rs.getString("address"));
				bean.setClubname(rs.getString("clubname"));
				bean.setFunction(rs.getString("function"));
				bean.setLevels(rs.getString("levels"));
				bean.setManage(rs.getString("manage"));
				bean.setPhone(rs.getString("phone"));
				bean.setServicetype(rs.getString("servicetype"));
				
			}
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		} finally{
			
			try {
				rs.close();
				stmt.close();
				conn.close();
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
		}
		
		return bean;
		
	}
	
	/**\
	 *实现俱乐部网点查询功能
	 *使用模糊查询
	 * @param suser
	 * @return
	 */
	public List<ClubManageBean> selectname(String suser){
		ArrayList<ClubManageBean> userlist = new ArrayList<ClubManageBean>();
		StringBuffer sql = new StringBuffer();
		sql.append("select * from clubInfoManage where clubname like '%"+suser+"%'");
		 
		Connection conn = null;
		Statement stmt = null;
		ResultSet rs =null;
		
		
		try {
			conn = DBConnection.getConnection();
			stmt = conn.createStatement();
			rs = stmt.executeQuery(sql.toString());
			
			while (rs.next()){
				ClubManageBean bean = new ClubManageBean();
				bean.setNid(rs.getInt("nid"));
				bean.setAddress(rs.getString("address"));
				bean.setClubname(rs.getString("clubname"));
				bean.setFunction(rs.getString("function"));
				bean.setLevels(rs.getString("levels"));
				bean.setManage(rs.getString("manage"));
				bean.setPhone(rs.getString("phone"));
				bean.setServicetype(rs.getString("servicetype"));
				userlist.add(bean);
			}
		} catch (SQLException e) { 
			e.printStackTrace();
		}finally{
			try {
				rs.close();
				stmt.close();
				conn.close();
			} catch (SQLException e) { 
				e.printStackTrace();
			}
		} 
		return userlist; 
	}
	
	/**
	 * 按俱乐部名称进行查询
	 */
	public  ClubManageBean serchallclubname(String name){
		
		boolean flag= false;
		
		ClubManageBean bean = new ClubManageBean();
		String sql = "select clubname from clubInfoManage where clubname='"+name+"'";
		
		Connection conn = null;
		Statement stmt = null;
		ResultSet rs=null;
		 
		try {
			conn = DBConnection.getConnection();
			stmt = conn.createStatement();
			rs = stmt.executeQuery(sql);
			if(rs.next()){
				bean.setClubname(rs.getString("clubname"));
				return bean;
			}
		} catch (SQLException e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}finally{
			try {
				rs.close();
				stmt.close();
				conn.close();
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
		}
		return null;
	}
	
	/**
	 * 实现网点信息删除功能
	 */
	public boolean delete(int nid){
		
		boolean flag= false;
		String sql = "delete from clubInfoManage where nid="+nid;
		
		Connection conn = null;