📄 pzztctrl.java
字号:
package edu.whut.cwts.pg.fafang;
import java.util.*;
import edu.whut.cwts.pg.db.*;
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 zddm,int length)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();
long pzqh=Long.valueOf(pzqz.getPzqh()).longValue();
long pzzh=Long.valueOf(pzqz.getPzzh()).longValue();
String sql="exec newpp "+pzzl+","+pzqh+","+pzzh+",'"+date+"','"+zddm+"','"+length+"'";
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("pzzl"),rs.getString("pzhm")));
}
conn.close();
return result;
}
//用户票据下发后，系统中的票据状态变化。特别重要的是可能出现跨级发放，此时中间的时间也要相应修改
public static boolean updatepjff(Pzqz pzqz,Department deptfirst,Department deptsecond)throws SQLException
{
String pzzl=pzqz.getPzzl();
String pzqh=pzqz.getPzqh();
String pzzh=pzqz.getPzzh();
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;
}
}
sql=sql+"syzt='"+levelsecond+"',";
sql=sql+"zddm='"+deptsecond.getZddm()+"' where pzzl='"+pzzl+"' and zddm='"+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;
}
}
//票据发放到人状态变化
public static boolean updatepjfftor(Pzqz pzqz,String dpr)throws SQLException
{
String pzzl=pzqz.getPzzl();
String pzqh=pzqz.getPzqh();
String pzzh=pzqz.getPzzh();
ConnectDB conn=new ConnectDB();
Timestamp ts=new Timestamp(System.currentTimeMillis());
String date=ts.toString();
String sql="update pjztb set d_r_f='"+date+"',syzt='4', dprdm='"+dpr+"' where pzzl='"+pzzl+"' 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 ArrayList getAviablePz(String zddm)
{
if(DepartmentCtrl.getLevel(zddm)==1||DepartmentCtrl.getLevel(zddm)==2)
{
String sql="select pzzl,pzmc from pzmc";
ArrayList pzlist=new ArrayList();
Com
}
if(DepartmentCtrl.getLevel(zddm)==3||DepartmentCtrl.getLevel(zddm)==5||DepartmentCtrl.getLevel(zddm)==7)
{
}
if(DepartmentCtrl.getLevel(zddm)==4||DepartmentCtrl.getLevel(zddm)==6)
{
}
}*/
/*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();
}
}*/
public static void main(String args[])
{
/*try{
updatepjff("1","0000000001","0000000010",new Department("0 ","处"),new Department("100000","征收科"));
}
catch(SQLException e)
{
e.printStackTrace();
}*/
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -