pzztctrl.java

文件的上传和下载的实现,用JAva编写,非常简单

package edu.whut.cwts.pg.hexiao;

import java.util.*;
import java.sql.*;


/**
 * @author Administrator
 *
 */
public class PzztCtrl {
	
	public int add(Pzzt pzzt)
	{
		return 0;
	}
	
	public int update(Pzzt pzzt)
	{
		return 0;
	}
	
	public int remove(Pzzt pzzt)
	{
		return 0;
	}
	
	//查询某单张票据是否已存在系统中
	/*private static boolean ch_isexist_Ticket(String pzzl,int pzhm)throws SQLException
	{
		String sql="select * from pjztb where pzzl="+pzzl+"and pzhm="+pzhm;
		ConnectDB conn=new ConnectDB();
		
		if(conn.executeQuery(sql).next()==true)
			{
			conn.close();
			Assert.p("票据存在");
			return true;
			}
		Assert.p("票据不存在");
		conn.close();
		return false;
	}*/
	
	//添加票据时查询所添加的票据段是否已存在部分票据在系统中
	/*public static boolean ch_isexist_Iickets(String pzzl,int pzqh,int pzzh)throws SQLException
	{
		
		for(int i=pzqh;i<=pzzh;i++)
		{
			if(ch_isexist_Ticket(pzzl,i)==true)
				{Assert.pl("系统中存在此票据段");
				return true;
				}
			else
				 continue;
		}
		Assert.pl("系统中不存在此票据段");

		return false;
	}*/
	
	public static boolean ch_isexist_Iickets(Pzqz pzqz)throws SQLException
	{
		String sql="select * from pjztb where pzzl='"+pzqz.getPzzl()+"' and pzhm between '"+pzqz.getPzqh()+"' and '"+pzqz.getPzzh()+"'";
		/*for(int i=pzqh;i<=pzzh;i++)
		{
			if(ch_isexist_Ticket(pzzl,i)==true)
				{Assert.pl("系统中存在此票据段");
				return true;
				}
			else
				 continue;
		}
		Assert.pl("系统中不存在此票据段");

		return false;*/
		
        ConnectDB conn=new ConnectDB();
		
		if(conn.executeQuery(sql).next()==true)
			{
			conn.close();
			Assert.p("系统中存在部分票据，不能插入");
			return true;
			}
		Assert.p("票据不存在，能够插入");
		conn.close();
		return false;		
	}
	
/*	//征稽处造票程序.新增票据时候，请一定要保证dprdm和站点代码要求都从yhxxb中提取
	//最好直接利用用户登陆时候保存的用户实体bean来获取，而不是让用户来输入
	//调用存储过程
	public static int add(String pzzl,int pzqh,int pzzh,String dprdm,String zddm)throws SQLException
	{
		ConnectDB conn=new ConnectDB();
	    if(!ch_isexist_Iickets(pzzl,pzqh,pzzh))
	    {
	    //String sql="exec newp 2,1,100,'2005-12-29 10:53:52',001,002";
	    Timestamp ts=new Timestamp(System.currentTimeMillis()); 
	    String date=ts.toString(); 
	    String sql="exec newp "+pzzl+","+pzqh+","+pzzh+",'"+date+"','"+dprdm+"','"+zddm+"'";
	    Assert.p(sql);
		int j=conn.executeUpdate(sql);  //此处调用存储过程，不返回受到影响的记录数，仅仅返回1
		if(j!=0)
		Assert.p("受到影响记录数为"+j+"新增票据已成功"); 
		else
		{
			Assert.p("检查下是否存在此用户或者站点代码错");
		}
		conn.close();
		return j;
	    }
	    else
	    {
	    	Assert.p("添加票段已部分存在添加数据不成功");
	    	return 0;
	    }
	} */
	
	public static int add(Pzqz pzqz,String dprdm,String zddm)throws SQLException
	{
		ConnectDB conn=new ConnectDB();
	    //String sql="exec newp 2,1,100,'2005-12-29 10:53:52',001,002";
	    Timestamp ts=new Timestamp(System.currentTimeMillis()); 
	    String date=ts.toString();
	    String pzzl=pzqz.getPzzl();
	    int pzqh=Integer.valueOf(pzqz.getPzqh()).intValue();
	    int pzzh=Integer.valueOf(pzqz.getPzzh()).intValue();
	    String sql="exec newpp "+pzzl+","+pzqh+","+pzzh+",'"+date+"','"+dprdm+"','"+zddm+"'";
	    Assert.p(sql);
		int j=conn.executeUpdate(sql);  //此处调用存储过程，不返回受到影响的记录数，仅仅返回1
		if(j!=0)
		{
			Assert.p("受到影响记录数为"+j+"新增票据已成功"); 
		}
		else
		{
			Assert.p("检查下是否存在此用户或者站点代码错");
		}
		conn.close();
		return j;
		
	   }
	
	
	
	//根据票据站点代码来获取本站点所在的级别，然后和使用状态相对比从而获取目前本站点拥有的可以下发的票据
	//未测试
	/*public static ArrayList getAviableTicket(String zddm,String pzzl)throws SQLException
	{
		String level=String.valueOf(Department.getLogicLevel(zddm));
		String sql="select * from pjztb where pzzl='"+pzzl+"'and syzt='"+level+"'and zddm="+zddm+"'";
		Assert.p(sql);
		ArrayList result=new ArrayList();
		ConnectDB conn=new ConnectDB();
		ResultSet rs=conn.executeQuery(sql);
		while(rs.next())
		{
			result.add(new Pzzt(rs.getString("pzzl"),rs.getString("pzhm"),rs.getString("syzt"),rs.getString("jxzt"),rs.getString("zfzt"),rs.getString("c_zpsj"),rs.getString("c_zx_f"),rs.getString("zx_z_f"),rs.getString("z_d_f"),rs.getString("d_r_f"),rs.getString("r_d_jxsj"),rs.getString("d_z_jxsj"),rs.getString("z_zx_jxsj"),rs.getString("zx_c_jxsj"),rs.getString("dprdm"),rs.getString("zddm")));
		}
		conn.close();
		return result;
	}*/
	
	//分析出本站点可用的票号段
/*	public static ArrayList getAviableTicket(String zddm,String pzzl)throws SQLException
	{
		String level=String.valueOf(DepartmentCtrl.getLogicLevel(zddm));
		String sql="select pzzl,pzhm from pjztb where pzzl='"+pzzl+"'and syzt='"+level+"'and zddm='"+zddm+"' order by pzhm";
		Assert.p(sql);
		ArrayList result=new ArrayList();
		ConnectDB conn=new ConnectDB();
		ResultSet rs=conn.executeQuery(sql);
		while(rs.next())
		{
			result.add(new Pzzt(rs.getString("pzhm"),rs.getString("pzzl")));
		}
		conn.close();
		return result;
	}*/
	

	
	//用户票据下发后，系统中的票据状态变化。特别重要的是可能出现跨级发放，此时中间的时间也要相应修改
	public static boolean updatepjff(String pzzl,int pzqh,int pzzh,Department deptfirst,Department deptsecond)throws SQLException
	{
		ConnectDB conn=new ConnectDB();
		Timestamp ts=new Timestamp(System.currentTimeMillis()); 
	    String date=ts.toString();
	    int levelfirst=DepartmentCtrl.getLogicLevel(deptfirst.getZddm());
	    int levelsecond=DepartmentCtrl.getLogicLevel(deptsecond.getZddm());
	    String sql="update pjztb set ";
	    for(levelfirst=levelfirst+1;levelfirst<=levelsecond;levelfirst++)
	    {
	    	switch(levelfirst)
	    	{
	    	case 1:
	    		sql=sql+"c_zx_f='"+date+"',";
	    		break;
	    	case 2:
	    		sql=sql+"zx_z_f='"+date+"',";
	    		break;
	    	case 3:
	    		sql=sql+"z_d_f='"+date+"',";
	    		break;
	    	case 4:
	    		sql=sql+"d_r_f='"+date+"',";
	    		break;	    	
	    	}	
	    }
	    sql=sql+"zddm='"+deptsecond.getZddm()+"' where pzzl='"+pzzl+"' and '"+deptfirst.getZddm()+"' and pzhm between '"+pzqh+"' and '"+pzzh+"'";
	    Assert.p(sql);
	    int flag=conn.executeUpdate(sql);
	    if(flag!=0)
	    {
	    	Assert.p("用户票据已正常下发");
	    	return true;
	    }
	    else
	    {
	    	Assert.p("没有票据下发");
	    	return false;
	    }
	    	
	    
	}
	
	//只查找目前已经缴销到下层的票，此时下级可以把这些票向直属上级缴销
	//注意作废票据也需要向上缴
	/**
	 * @param zddm
	 * @param pzzl
	 * @return
	 * @throws SQLException
	 */
	public static ArrayList findjxpj(String zddm,String pzzl)throws SQLException
	{
		
		String level=String.valueOf(DepartmentCtrl.getLogicLevel(zddm));
		String sql="select * from pjztb where pzzl='"+pzzl+"'and jxzt='"+level+"'";
		Assert.p(sql);
		ArrayList result=new ArrayList();
		ConnectDB conn=new ConnectDB();
		ResultSet rs=conn.executeQuery(sql);
		while(rs.next())
		{
			result.add(new Pzzt(rs.getString("pzzl"),rs.getString("pzhm"),rs.getString("syzt"),rs.getString("jxzt"),rs.getString("zfzt"),rs.getString("c_zpsj"),rs.getString("c_zx_f"),rs.getString("zx_z_f"),rs.getString("z_d_f"),rs.getString("d_r_f"),rs.getString("r_d_jxsj"),rs.getString("d_z_jxsj"),rs.getString("z_zx_jxsj"),rs.getString("zx_c_jxsj"),rs.getString("dprdm"),rs.getString("zddm")));
		}
		conn.close();
		return result; 
	}
	

  /*public static void main(String args[])
	{
    try
    {
	ArrayList ar=getAviableTicket("0      ","1");
	Iterator ito=ar.iterator();
	
		while(ito.hasNext())
		{
			Pzzt pzzt=(Pzzt)ito.next();
			System.out.println(pzzt.getPzzl()+"  "+pzzt.getPzhm());
		}
	
    }
    catch(SQLException e)
    {
    	e.printStackTrace();
    }
	
	}*/
}