settle.java

农业银行ATM对帐查询系统后台类包的源代码,实现了FTP,数据库管理等等功能

package boco.javabean.atmsettle;

import java.util.*;
import java.sql.*;
import com.sybase.jdbc2.jdbc.SybDriver;
import java.io.*;
public class settle {
    //定义变量
    String url;
    Connection conn;
    Statement stmt;
    private Vector vReqId        = new Vector();
    private Vector vRespSeqNo    = new Vector();
    private Vector vReqSeqNo     = new Vector();
    private Vector vAccDate      = new Vector();
    private Vector vAmt          = new Vector();
    private Vector vAtmTransCode = new Vector();
    private Vector vAtmAccNo     = new Vector();
    private Vector vAtmAmt       = new Vector();
    private Vector vErrNo        = new Vector();
    private Vector vTransCode    = new Vector();
    private Vector vAccNo        = new Vector();
    private Vector vTransStatus  = new Vector();
    private Vector vSettleStatus = new Vector();
    private Vector vAtmId        = new Vector();
    private Vector vAtmType      = new Vector();
    private Vector vAtmLogo      = new Vector();
    private Vector vAtmName      = new Vector();
    private Vector vAps          = new Vector();
    String sql1="";
    //构造函数，初始化变量
    public settle() {
        	//修改后程序（从属性文件当中读取连接数据库信息）
	InputStream is=getClass().getResourceAsStream("/db.properties") ;
        Properties dbProps = new Properties();
        try{
	    dbProps.load(is) ;
        }
        catch(Exception e){
	    System.err.println("不能读取属性文件") ;
        }
	String urlXml=dbProps.getProperty("atm.monitor") ;
        url=dbProps.getProperty("aibsconn.url") ;
	String drivers=dbProps.getProperty("aibsconn.drivers") ;
	String user = dbProps.getProperty("aibsconn.user") ;
	String password = dbProps.getProperty("aibsconn.password") ;
	try{

            Class.forName(drivers).newInstance() ;
            Properties SysProps = System.getProperties();
            SysProps.put("user",user);
            SysProps.put("password",password);
            conn= DriverManager.getConnection(url, SysProps);
            stmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
        }
	/*url =" jdbc:sybase:Tds:196.168.1.32:9999/apdb";
        try{
            Class.forName("com.sybase.jdbc2.jdbc.SybDriver").newInstance() ;
            Properties SysProps = System.getProperties();
            SysProps.put("user","apdbo");
            SysProps.put("password","apdbop");
            conn= DriverManager.getConnection(url, SysProps);
            stmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
        }*/
        catch(Exception ex){
            System.out.print(ex.getMessage()) ;
        }
    }
    //主机成功交易明细
    public void settleatmj(String transdate,String atmj){
        try{
            //"select * from atmsettle where reqid='"+atmid+"'and pin='"+oprpin+"'";
            sql1="select * from atmj where accdate = '"+transdate+"' and reqid = '"+ atmj+"'";
            //System.out.println(sql);
            ResultSet rs=stmt.executeQuery(sql1);
            while(rs.next()) {
                //:test:System.out.println(rs.getString(1)+rs.getString(2)+rs.getString(3)+rs.getString(4)+rs.getString(5)+rs.getString(6)+rs.getString(7)+rs.getString(8)+rs.getString(9));
                vAccDate.addElement(rs.getString(1));
                vReqId.addElement(rs.getString(2));
                vReqSeqNo.addElement(rs.getString(3));
                vRespSeqNo.addElement(rs.getString(4));
                vTransCode.addElement(rs.getString(5));
                vAccNo.addElement(rs.getString(6));
                vAmt.addElement(rs.getString(7));
                vTransStatus.addElement(rs.getString(8));
                vSettleStatus.addElement(rs.getString(9));
            }
            rs.close();
            stmt.close();
            conn.close();
        }
        catch(Exception ex){
            System.out.print(ex.getMessage()) ;
        }
    }
    //对帐出错明细
    public void settleatmerr(String transdate,String atmerr){
        try{
            //"select * from atmsettle where reqid='"+atmid+"'and pin='"+oprpin+"'";
            sql1="select * from atmsettleerr where accdate like '%"+transdate+"%' and reqid like '%"+ atmerr+"%'";
            //System.out.println(sql);
            ResultSet rs=stmt.executeQuery(sql1);
            while(rs.next()) {
                //:test:System.out.println(rs.getString(1)+rs.getString(2)+rs.getString(3)+rs.getString(4)+rs.getString(5)+rs.getString(6)+rs.getString(7)+rs.getString(8)+rs.getString(9)+rs.getString(10)+"p"+rs.getString(11));
                vReqId.addElement(rs.getString(1));
                vRespSeqNo.addElement(rs.getString(2));
                vReqSeqNo.addElement(rs.getString(3));
                vAccDate.addElement(rs.getString(4));
                vTransCode.addElement(rs.getString(5));
                vAccNo.addElement(rs.getString(6));
                vAmt.addElement(rs.getString(7));
                vAtmTransCode.addElement(rs.getString(8));
                vAtmAccNo.addElement(rs.getString(9));
                vAtmAmt.addElement(rs.getString(10));
                vErrNo.addElement(rs.getString(11));
            }
            rs.close();
            stmt.close();
            conn.close();
        }
        catch(Exception ex){
            System.out.print(ex.getMessage()) ;
        }
    }
    //根据行所号查询ATM编号
    public void getAtm(String branch){
        try{
            //"select * from atmsettle where reqid='"+atmid+"'and pin='"+oprpin+"'";
            sql1="select DevNo,DevName from DevBaseInfo where Branch ='"+branch+"'";
            //System.out.println(sql);
            ResultSet rs=stmt.executeQuery(sql1);
            while(rs.next()) {
                //:test:System.out.println(rs.getString(1)+rs.getString(2)+rs.getString(3)+rs.getString(4)+rs.getString(5)+rs.getString(6)+rs.getString(7)+rs.getString(8)+rs.getString(9)+rs.getString(10)+"p"+rs.getString(11));
                vAtmId.addElement(rs.getString(1));
                vAtmName.addElement(rs.getString(2));
            }
            rs.close();
            stmt.close();
            conn.close();
        }
        catch(Exception ex){
            System.out.print(ex.getMessage()) ;
        }
    }
    //取冲正结果
    public String getaps(String RespSeqNo){
        try{
            //"select * from atmsettle where reqid='"+atmid+"'and pin='"+oprpin+"'";
            sql1="select  status from aps where respseqno ='"+RespSeqNo+"'";
            //System.out.println(sql);
            ResultSet rs=stmt.executeQuery(sql1);
            if(rs.next()) {
                return(rs.getString(1));
            }
            rs.close();
            stmt.close();
            conn.close();
        }
        catch(Exception ex){
            System.out.print(ex.getMessage()) ;
        }
        return("");
    }
    //取得所有数据源信息
    public Vector getAllReqId(){
      return vReqId;
    }
    public Vector getAllRespSeqNo(){
      return vRespSeqNo;
    }
    public Vector getAllReqSeqNo(){
      return vReqSeqNo;
    }
    public Vector getAllAccDate(){
      return vAccDate;
    }
    public Vector getAllAmt(){
      return vAmt;
    }
    public Vector getAllAtmTransCode(){
      return vAtmTransCode;
    }
    public Vector getAllAtmAccNo(){
      return vAtmAccNo;
    }
    public Vector getAllAtmAmt(){
      return vAtmAmt;
    }
    public Vector getAllErrNo(){
        return vErrNo;
    }
    public Vector getAllTransCode(){
      return vTransCode;
    }
    public Vector getAllAccNo(){
      return vAccNo;
    }
    public Vector getAllTransStatus(){
      return vTransStatus;
    }
    public Vector getAllSettleStatus(){
      return vSettleStatus;
    }
    public Vector getAllAtmId(){
        return vAtmId;
    }
    public Vector getAllAtmType(){
        return vAtmType;
    }
    public Vector getAllAtmLogo(){
        return vAtmLogo;
    }
    public Vector getAllAtmName(){
        return vAtmName;
    }
    public String getsql(){
        return sql1;
    }
    public static void main(String args[]){
        /*settle set1 = new settle();
        set1.getAtm("1234");
        Vector vAtm = set1.getAllAtmId();
        Vector vLogo= set1.getAllAtmLogo();
        Vector vType= set1.getAllAtmType();
        System.out.println(vAtm.size());
        for(int i=0;i<vAtm.size();i++){
            System.out.println(vAtm.elementAt(i)+"***"+vLogo.elementAt(i)+"**"+vType.elementAt(i));
            //System.out.println("111");
        }*/
    }
}