umspdatadeal.java

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

package boco.transmonitor.fmlsocket;

//******************************************************************************
//:功能:处理UMSP发送过来的144位字符流
//:时间:2002-07
//:作者:王建宾
//:特殊描述::test:为DEBUG时启用
//:程序描述:
//     注意:自动生成流水序号,强制插入UMSP业务类型"20",两个空栏位强制赋空值
//******************************************************************************

import java.net.*;
import java.io.*;
import xmlapp.*;
import org.w3c.dom.*;
import java.util.*;
import java.sql.*;
import boco.shabank.dbconnection.*;
public class umspDataDeal {
  //变量定义:字符总长144
  //中间业务流水号,18,交易日期(8)+交换平台的流水(10)
  String uaopTrnNo;
  //交易码,4
  String tranCode;
  //省市代码,2
  String proCode;
  //行号,4
  String branch;
  //帐务交易日期,8
  String tpeTrnDate;
  //帐务交易时间,6
  String tpeTrnTime;
  //帐务系统日志号,9
  String tpeTrnNo;
  //传票号,8
  String vchNo;
  //帐务返回码,4
  String retCode;
  //帐号1,20
  String accNum1;
  //金额1,19
  String trnAmt1;
  //帐号2,20
  String accNum2;
  //冲正结果,4
  String revResult;
  //帐务冲正日志号,9
  String revJrnNo;
  //冲正传票号,8
  String revVchNo;
  //交易类型,1,1-正交易;2-冲正;3-管理;4-查询
  String trnType;
  //业务种类
  String tradeType;
  //流水序号
  String transId;
  //连接数据库变量
  DBConnectionManager objDBConnection;
  Connection m_Connection;
  DBAccess db;
  ResultSet rs;
  String sql;
  String tmpSql;
  //汉字与ASCII码转换
  ChineseTransfer C2A;
  //定义结束
//***************************************************************************
//功能:处理解析传入umsp数据流
//方法:按长度截取
//***************************************************************************

  public umspDataDeal() {
    //变量初始化:
    uaopTrnNo = "";
    tranCode = "";
    proCode = "";
    branch = "";
    tpeTrnDate = "";
    tpeTrnTime = "";
    tpeTrnNo = "";
    vchNo = "";
    retCode = "";
    accNum1 = "";
    trnAmt1 = "";
    accNum2 = "";
    revResult = "";
    revJrnNo = "";
    revVchNo = "";
    trnType = "";
    tradeType = "";
    transId = "";
    tmpSql = "";
    rs = null;
    objDBConnection = null;
    m_Connection = null;
    db = null;
    sql = "";
    C2A = new ChineseTransfer();
    //初始化结束
  }
  public void umspDataDeal(String inUmspData){
    //解析字符流,赋给各变量
    uaopTrnNo = C2A.ChineseStringToAscii(inUmspData.substring(0,18).trim());
    //:test:System.out.println("中间业务流水号:"+uaopTrnNo);
    tranCode = C2A.ChineseStringToAscii(inUmspData.substring(18,22).trim());
    //:test:System.out.println("交易码:"+tranCode);
    proCode = inUmspData.substring(22,24).trim();
    //:test:System.out.println("省市代码:"+proCode);
    branch = inUmspData.substring(24,28).trim();
    //:test:System.out.println("行号:"+branch);
    tpeTrnDate = inUmspData.substring(28,36).trim();
    //:test:System.out.println("帐务交易日期:"+tpeTrnDate);
    tpeTrnTime = inUmspData.substring(36,42).trim();
    //:test:System.out.println("帐务交易时间:"+tpeTrnTime);
    tpeTrnNo = inUmspData.substring(42,51).trim();
    //:test:System.out.println("帐务系统日志号:"+tpeTrnNo);
    vchNo = inUmspData.substring(51,59).trim();
    //:test:System.out.println("传票号:"+vchNo);
    retCode = inUmspData.substring(59,63).trim();
    //:test:System.out.println("帐务返回码:"+retCode);
    accNum1 = inUmspData.substring(63,83).trim();
    //:test:System.out.println("帐号1:"+accNum1);
    trnAmt1 = inUmspData.substring(83,102).trim();
    //:test:System.out.println("金额1:"+trnAmt1);
    accNum2 = inUmspData.substring(102,122).trim();
    //:test:System.out.println("帐号2:"+accNum2);
    revResult = inUmspData.substring(122,126).trim();
    //:test:System.out.println("冲正结果:"+revResult);
    revJrnNo = inUmspData.substring(126,135).trim();
    //:test:System.out.println("帐务冲正日志号:"+revJrnNo);
    revVchNo = inUmspData.substring(135,143).trim();
    //:test:System.out.println("冲正传票号:"+revVchNo);
    trnType = inUmspData.substring(143,144).trim();
    //:test:System.out.println("交易类型:"+trnType);
    //解析结束
    //执行SQL插入transdetect表
    //取当前表中最大流水序号
    db=new DBAccess();
    try{
      objDBConnection=objDBConnection.getInstance() ;
      tmpSql = "select max(transid) from transdetect";
      m_Connection = objDBConnection.getConnection("access") ;
      rs = db.executeQuery(m_Connection,tmpSql);
      if(rs.next()){
        transId = Integer.toString(rs.getInt(1) + 1 );
        rs.close();
      }
      sql="insert into transdetect values(" + "'" + uaopTrnNo + "'," + "'" +
                tranCode + "'," + "'" + proCode + "'," + "'" + branch + "'," + "'" +
                tpeTrnDate + "'," + "'" + tpeTrnTime + "'," + "'" + tpeTrnNo + "'," + "'" +
                vchNo + "'," + "'" + retCode + "'," + "'" + accNum1 + "'," + "'" +
                trnAmt1 + "'," + "'" + accNum2 + "'," + "'" + revResult + "'," + "'" +
                revJrnNo + "'," + "'" + revVchNo + "'," + "'" + trnType + "'," + "''," +"''," + "'20'," + transId + ")";
      //:test:
      System.out.println("UMSP DATA DEAL SQL:"+sql);
      db.executeUpdate(m_Connection,sql);
      //释放连接池
      objDBConnection.freeConnection("access",m_Connection) ;
    }catch(Exception e){
      System.out.print("errorMsg=" + e.getMessage()) ;
    }
    //执行SQL结束
  }
  public static void main(String[] args) {
    umspDataDeal doUmsp = new umspDataDeal();
    doUmsp.umspDataDeal("123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456789012345678901234567890123456");
  }
}