updateflow.java

采用JAVA开发

package com.gctech.sms.voice.api;

import com.suntek.jjcomm.util.*;
import java.sql.*;

public class UpdateFlow
{
  public static final int icbPort = 8000;
  public static final int ctrOAMSStation = 247;
  public static final String icbIPAddr = "10.1.3.31";

  public static final String billdburl =
      "jdbc:oracle:thin:@10.1.2.132:1521:bill";
  public static final String billdbusername = "bill";
  public static final String billdbpassword = "bill";

  public static final String spnum = "0066";
  public static final int flowid = 7601;

  public UpdateFlow()
  {
  }

  public static void run()
  {
    String doctorId = "6999";
    String serviceNum = "116960" + doctorId;

    Connection conn = null;
    try
    {
      System.out.println("begin");
      Class.forName("oracle.jdbc.driver.OracleDriver");
      conn = DriverManager.getConnection(billdburl,billdbusername,
                                         billdbpassword);
      String sql = null;
      PreparedStatement prepStmt = null;
      ResultSet rs = null;

      //--------- dispense service by suntek class ----------

      String ipsArray[] =
          {
          "10"};
      /* get taskid seq */
      int taskId = 0;
      sql = "select SEQ_SL_ID.nextval from dual";
      prepStmt = conn.prepareStatement(sql);
      prepStmt.execute(sql);
      rs = prepStmt.getResultSet();
      if(rs.next())
      {
        taskId = rs.getInt(1);
      }
      else
      {
        throw new Exception("get taskid seq Fail");
      }
      rs.close();
      prepStmt.close();

      JJCommUtil jjCommUtil = new JJCommUtil(icbIPAddr,icbPort,
                                             ctrOAMSStation);
      JJCmdPacket cmdPacket = jjCommUtil.getCmdPacket();
      cmdPacket.setCommand(7);
      cmdPacket.setSPID(spnum);
      cmdPacket.setTaskID(taskId);
      cmdPacket.setServType(116);
      cmdPacket.setServItem(serviceNum);
      cmdPacket.setServName(serviceNum);
      cmdPacket.setServRate(5);
      cmdPacket.setServStatus(1);
      cmdPacket.setFlowID(flowid);
      cmdPacket.setFlowName("\u00BD\u00A1\u00BF\u00B5\u05B1\u0368\u00B3\u00B51");
      cmdPacket.setFlowCode("7601.COD");
      cmdPacket.setFlowIni("7601.INI");
      cmdPacket.setInitFlow(1);
      if(!cmdPacket.isCmdPacketValid())
      {
        throw new Exception("despense packet invalid");
      }
      for(int i = 0;i < ipsArray.length;i++)
      {
        if(!jjCommUtil.dispenseServ(ipsArray[i]))
        {
          System.out.println(jjCommUtil.getResMsg());
          continue;
        }
      }
      System.out.println("end");
    }
    catch(Exception e)
    {
      try
      {
        conn.rollback();
      }
      catch(SQLException e1)
      {

        e1.printStackTrace();
      }

      e.printStackTrace();
    }
    finally
    {
      try
      {
        if(conn != null)
        {
          conn.close();
        }
      }
      catch(SQLException e1)
      {

        e1.printStackTrace();
      }
    }

  }

  public static void main(String[] args)
  {
    UpdateFlow updateFlow1 = new UpdateFlow();
  }

}