expensecontrol.java

利用java编写的一个学生宿舍管理系统

/*
 *ExpenseControl.java
 *author:liuhaijing
 */
 
 package mydesign;
 
 import mydesign.*;
 import java.sql.*;
 import java.io.*;
 import java.util.*;//Vector在这个包里
 import mydesign.*;
 public class ExpenseControl
 {
 	
 	ResultSet rs=null;
 	String sql=null;
 	String sql1=null;
    DBConnect dbconnect=new DBConnect();
 	
 	public ExpenseControl()
 	{
 	}
 	
 	//设置底数
 	public void setExpense(Student student)
 	{
 		try
 		{
 			sql="update water set shangci='"+student.getIntime()+"' where donghao='"+student.getDonghao()+"' and houseid='"+student.getHouseid()+"';";
 			sql1="update electric set shangci='"+student.getIntime()+"' where donghao='"+student.getDonghao()+"' and houseid='"+student.getHouseid()+"';";
 			dbconnect.executeUpdate(sql);	
 			dbconnect.executeUpdate(sql1);	
 		}
 		catch(Exception ex)
 		{
 			System.out.print("ExpenseControl's SetExpense Bean error:"+ex.getMessage());
 		}
 	}

 	//水表登记
 	public void WriteExpense(String table,Expense expense)
 	{
 		try
 		{
 			sql="update "+table+" set dishu='"+expense.getDishu()+"',xianshu='"+expense.getXianshu()+"',shangci='"+expense.getShangci()+"',newdate='"+expense.getNewdate()+"',expense=expense+"+expense.getExpense()+" where donghao='"+expense.getDonghao()+"' and houseid='"+expense.getHouseid()+"';";
 			dbconnect.executeUpdate(sql);	
 		}
 		catch(Exception ex)
 		{
 			System.out.print("ExpenseControl's WriteExpense Bean error:"+ex.getMessage());
 		}
 	}
 			
 	public int getExpenseCount(String strsql)  //计算查询结果的行数
 	{
 		int i=0;
 		try
 		{
 			rs=dbconnect.executeQuery(strsql);
 			while(rs.next())
 			{
 				i=rs.getInt(1);
 			}
 		}
 		catch(Exception ex)
 		{
 			System.out.print("ExpenseControl's getHouseInfo error:"+ex.getMessage());
 		}
 		return i;
 	}
 			
 	public ArrayList getExpenseInfo(String strsql)  //得到查询结果
 	{	
 		ArrayList a=new ArrayList();
 		try
 		{
 			rs=dbconnect.executeQuery(strsql);
 			while(rs.next())
 			{
 				Expense expense=new Expense();
 				expense.setDonghao(rs.getString("donghao"));
 				expense.setHouseid(rs.getString("houseid"));
 				expense.setDishu(rs.getFloat("dishu"));
 				if(rs.getString("xianshu")!=null)
 				    expense.setXianshu(rs.getFloat("xianshu"));
 				if(rs.getString("shangci")!=null)
 				    expense.setShangci(rs.getDate("shangci"));
 				if(rs.getString("newdate")!=null)
 				    expense.setNewdate(rs.getDate("newdate"));
 				if(rs.getString("expense")!=null)
 				    expense.setExpense(rs.getFloat("expense"));
 				a.add(expense);
 			}
 		}
 		catch(Exception ex)
 		{
 			System.out.print("ExpenseControl's getHouseInfo error:"+ex.getMessage());
 		}
 		return a;
 	}
 			
 	public Expense getExpenseInfo(String table,String donghao,String houseid)  //得到查询结果
 	{	
 		Expense expense=new Expense();
 		try
 		{
 			sql="select * from "+table+" where donghao='"+donghao+"' and houseid='"+houseid+"';";
 			rs=dbconnect.executeQuery(sql);
 			if(rs.next())
 			{
 				expense.setDonghao(rs.getString("donghao"));
 				expense.setHouseid(rs.getString("houseid"));
 				expense.setDishu(rs.getFloat("dishu"));
 				if(rs.getString("xianshu")!=null)
 				    expense.setXianshu(rs.getFloat("xianshu"));
 				if(rs.getString("shangci")!=null)
 				    expense.setShangci(rs.getDate("shangci"));
 				if(rs.getString("newdate")!=null)
 				    expense.setNewdate(rs.getDate("newdate"));
 				if(rs.getString("expense")!=null)
 				    expense.setExpense(rs.getFloat("expense"));
 			}
 		}
 		catch(Exception ex)
 		{
 			System.out.print("ExpenseControl's getExpenseInfo error:"+ex.getMessage());
 		}
 		return expense;
 	}
		
 	public void UpdateExpense(String table,Expense expense) throws Exception   //修改房间信息
 	{
 		try
 		{
 			sql="update "+table+" set dishu='"+expense.getDishu()+"',xianshu='"+expense.getXianshu()+"',shangci='"+expense.getShangci()+"',newdate='"+expense.getNewdate()+"',expense='"+expense.getExpense()+"' where donghao='"+expense.getDonghao()+"' and houseid='"+expense.getHouseid()+"';";
 			dbconnect.executeUpdate(sql);
 			if(expense.getShangci().equals(java.sql.Date.valueOf("2000-01-01"))) sql="update "+table+" set shangci=default where donghao='"+expense.getDonghao()+"' and houseid='"+expense.getHouseid()+"';";
 			dbconnect.executeUpdate(sql);
 			if(expense.getNewdate().equals(java.sql.Date.valueOf("2000-01-01"))) sql="update "+table+" set newdate=default where donghao='"+expense.getDonghao()+"' and houseid='"+expense.getHouseid()+"';";
 			dbconnect.executeUpdate(sql);
 			if(expense.getExpense()==-1000) sql="update "+table+" set expense=default where donghao='"+expense.getDonghao()+"' and houseid='"+expense.getHouseid()+"';";
 			dbconnect.executeUpdate(sql);
 		}
 		catch(Exception ex)
 		{
 			System.out.print("ExpenseControl's UpdateExpense Error:"+ex.getMessage());
 		}
 	}
 	
 	public PageBean listData(int page,SearchExpense searchexpense) throws Exception 	//获得指定页面的数据，并且封装在PageBean中返回
 	{
 		try
 		{
			int count=getExpenseCount(searchexpense.strSQL1);
 			ArrayList result=getExpenseInfo(searchexpense.strSQL);
			PageBean pagebean=new PageBean(count,result);
 			ArrayList v=new ArrayList();
 			int x=(pagebean.maxRowCount<page*pagebean.rowsPerPage?pagebean.maxRowCount:page*pagebean.rowsPerPage);
 			for(int i=pagebean.rowsPerPage*(page-1);i<x;i++)
 			{
 				v.add(result.get(i));
 			}
 			pagebean.curPage=page;
 			pagebean.data=v;
 			return pagebean;
 		}
 		catch(Exception ex)
 		{
 			ex.printStackTrace();
 			throw ex;
 		}
 	}
 	
 	//close
 	public void close()
 	{
 		dbconnect.close();
 	}
 }