dlgfindalarm.java

实现网络GPS定位车辆的位置

    DlgFindAlarm adaptee;

    DlgFindAlarm_BeginYear_actionAdapter(DlgFindAlarm adaptee)
    {
      this.adaptee = adaptee;
    }

    public void actionPerformed(ActionEvent e) {
      adaptee.BeginYear_actionPerformed(e);
    }
  }

  class DlgFindAlarm_jButton1_actionAdapter
      implements java.awt.event.ActionListener {
    DlgFindAlarm adaptee;

    DlgFindAlarm_jButton1_actionAdapter(DlgFindAlarm adaptee) {
      this.adaptee = adaptee;
    }

    public void actionPerformed(ActionEvent e) {
      adaptee.jButton1_actionPerformed(e);
    }
  }

  class DlgFindAlarm_jButton2_actionAdapter
      implements java.awt.event.ActionListener {
    DlgFindAlarm adaptee;

    DlgFindAlarm_jButton2_actionAdapter(DlgFindAlarm adaptee) {
      this.adaptee = adaptee;
    }

    public void actionPerformed(ActionEvent e) {
      adaptee.jButton2_actionPerformed(e);
    }
  }
/*//////////////////////////////////////////////////////////////////////////////////////////////////
转换字符
///////////////////////////////////////////////////////////////////////////////////////////////////*/
         public static String convertToChinese(String chineseStr)
         {
           if(chineseStr != null)
           {
             try
             {
             chineseStr = new String(chineseStr.getBytes("ISO-8859-1"), "GBK");
             }
             catch(Exception e)
             {
               e.printStackTrace();
             }
           }
           return chineseStr;
  }
  ///////////////Vector methord
  public Vector ReturnS(String sql)
              {
                String s=sql;
                int bytesRead;
                long i;
                Vector rowdata = new Vector();
                Socket tcpSocket;
                try{
                  //服务器地址
                  String server="219.237.4.30";
                  //String server="192.168.0.176";
                  //断口号
                  int port= 6688;

                  System.out.println ("Connecting to " +server);
                  // 与服务器建立连接
                  tcpSocket = new Socket(InetAddress.getByName(server), port);
                  //超时限制
                   tcpSocket.setSoTimeout(360000);
                  //建立输入输出流
                  PrintStream out = new PrintStream( tcpSocket.getOutputStream()) ;
                  DataInputStream in = new DataInputStream(tcpSocket.getInputStream());
                  //连接初试化
                  out.println("FindAlarmMessage");
                  String m_AlertMessage="";
                  m_AlertMessage= in.readLine(); //new String(buffer, 0, bytesRead);
                  System.out.println("fuck m_AlertMessage: "+m_AlertMessage);
                  //发送轨迹Sql
                  out.println(s);
                  String m_Alarm= in.readLine();
                  System.out.println(m_Alarm+"P");
                  int m_count = Integer.valueOf(m_Alarm).intValue();
                  System.out.println("mmmmmmmmmmmmm m_count: "+m_count);
                  m_count=m_count/5;
                  System.out.println("nnnnnnnnnnnnn m_count: "+m_count);
//                  System.out.println("the fucking fucking M_count is :"+m_count);
//                  String row[]=new String[5];
                  int j=0;
                  //System.out.println("xy=:"+m_count);
                  if (m_count >0)
                      {
                      for (i = 0; i < m_count; i++) {
                    j=0;
                    m_AlertMessage= in.readLine();
                    System.out.println("here is what i get : "+m_AlertMessage);
                    //m_AlertMessage = in.readLine();
                    int index1 = m_AlertMessage.indexOf("$");
                    String m_cardid = m_AlertMessage.substring(0, index1);
                    //row[j++]=m_cardid;
                    rowdata.add(m_cardid);
                    System.out.println(m_cardid);


                    int index2 = m_AlertMessage.indexOf("$", index1 + 1);
                    String m_username = m_AlertMessage.substring(index1 + 1, index2);
                    m_username=convertToChinese(m_username);
                    //row[j++]=m_username;
                    rowdata.add(m_username);
                    System.out.println(m_username);

                    int index3 = m_AlertMessage.indexOf("$", index2 + 1);
                    String m_Car_no = m_AlertMessage.substring(index2 + 1, index3);
                    m_Car_no=convertToChinese(m_Car_no);
                    //row[j++]=m_Car_no;
                    rowdata.add(m_Car_no);
                    System.out.println(m_Car_no);

                    //double speed =(  Double.parseDouble(m_speed)));
                    int index4 = m_AlertMessage.indexOf("$", index3 + 1);
                    String m_info_date = m_AlertMessage.substring(index3 + 1, index4);
                    //row[j++]=m_info_date;
                    rowdata.add(m_info_date);
                    System.out.println(m_info_date);

                    //int index5=m_AlertMessage.indexOf("$",index4+1);
                    String m_alert_type = m_AlertMessage.substring(index4 + 1, m_AlertMessage.length());
                    //row[j++]=m_alert_type;
                    m_alert_type=convertToChinese(m_alert_type);
                    rowdata.add(m_alert_type);
                    System.out.println(m_alert_type);

                    srcdata.add(rowdata);

//                    this.jTable.repaint();
//                    this.jTable.updateUI();

//                    DlgFindAlarm.tableModel.addRow(row);



                    String sCarStatus = "车辆报警信息：";   // + m_CarTel + " 经度" + m_x + " 纬度" + m_y +
                    //    " 速度" + m_speed + " 公里/小时" + " 时间" + m_createdatime;
                    //ListCarInfomation.add(sCarStatus);
                    lCarStatus.setText(sCarStatus);

                  }
                  this.jTable.repaint();
                  this.jTable.updateUI();
                  }
                  else
                  {
                    lCarStatus.setText("对不起，该车辆没有报警记录。");
                  }

                    //v = (Vector)in.readObject();

                  out.println("EXIT");
                  in.close();
                  out.close();
                  tcpSocket.close() ;
                  return srcdata;
              }
              catch (Exception e )
               {
                     System.out.println (e);
                     return srcdata;
               }

       }
   }
  /*
//////////////////////////////////////////////////////////////////////////////////////////////////
//  报警历史记录查询线程。连接WebGps服务得到车辆历史报警记录
///////////////////////////////////////////////////////////////////////////////////////////////////
  class tcpServerFindAlarmThread extends Thread{
      private   String Sql;
      public String in_str;
      JLabel lCarStatus = new JLabel();
      //MCanvas m_map;
      private String m_tool="0";
      String myurl;
      String m_tel;

      public tcpServerFindAlarmThread(JLabel AlarLabel,String Alar_Cardid,String m_Sql,String url){
        //m_tel=tel;
        Sql=m_Sql;
        myurl=url;
        //m_map=m_mapx;
        lCarStatus=AlarLabel;
      }
      public void run(){
          try{
           this.ReturnS("");

          }catch(Exception e){
              System.out.println(e);
          }
      }

//////////////////////////////////////////////////////////////////////////////////////////////////
//  在线程中与连接WebGps Socket服务得到GPS车辆报警记录
///////////////////////////////////////////////////////////////////////////////////////////////////

  public Vector ReturnS(String Tel)
  {
    String s="";
    int bytesRead;
    long i;
    Vector v = new Vector();
    Socket tcpSocket;
    try{
      //服务器地址
      String server="211.101.210.163";
      //String server="192.168.0.176";
      //断口号
      int port= 6688;

      System.out.println ("Connecting to " +server);
      // 与服务器建立连接
      tcpSocket = new Socket(InetAddress.getByName(server), port);
      //超时限制
       tcpSocket.setSoTimeout(360000);
      //建立输入输出流
      PrintStream out = new PrintStream( tcpSocket.getOutputStream()) ;
      DataInputStream in = new DataInputStream(tcpSocket.getInputStream());
      //连接初试化
      out.println("FindAlarmMessage");
      String m_AlertMessage="";
      m_AlertMessage= in.readLine(); //new String(buffer, 0, bytesRead);
      System.out.println(m_AlertMessage);
      //发送轨迹Sql
      out.println(Sql);
      String m_Alarm= in.readLine();
      System.out.println(m_Alarm+"P");
      int m_count = Integer.valueOf(m_Alarm).intValue();
      m_count=m_count/5;
      String row[]=new String[5];
      int j=0;
      //System.out.println("xy=:"+m_count);
      if (m_count >0)
          {
          for (i = 0; i < m_count; i++) {
        j=0;
        m_AlertMessage= convertToChinese(in.readLine());
        //m_AlertMessage = in.readLine();
        int index1 = m_AlertMessage.indexOf("$");
        String m_cardid = m_AlertMessage.substring(0, index1);
        row[j++]=m_cardid;
        System.out.println(m_cardid);


        int index2 = m_AlertMessage.indexOf("$", index1 + 1);
        String m_username = m_AlertMessage.substring(index1 + 1, index2);
        row[j++]=m_username;
        System.out.println(m_username);

        int index3 = m_AlertMessage.indexOf("$", index2 + 1);
        String m_Car_no = m_AlertMessage.substring(index2 + 1, index3);
        row[j++]=m_Car_no;
        System.out.println(m_Car_no);

        //double speed =(  Double.parseDouble(m_speed)));
        int index4 = m_AlertMessage.indexOf("$", index3 + 1);
        String m_info_date = m_AlertMessage.substring(index3 + 1, index4);
        row[j++]=m_info_date;
        System.out.println(m_info_date);

        //int index5=m_AlertMessage.indexOf("$",index4+1);
        String m_alert_type = m_AlertMessage.substring(index4 + 1, m_AlertMessage.length());
        row[j++]=m_alert_type;
        System.out.println(m_alert_type);


        DlgFindAlarm.tableModel.addRow(row);
        System.out.println("the fucking rowcount is this :"+DlgFindAlarm.tableModel.getRowCount());


        String sCarStatus = "车辆报警信息：";   // + m_CarTel + " 经度" + m_x + " 纬度" + m_y +
        //    " 速度" + m_speed + " 公里/小时" + " 时间" + m_createdatime;
        //ListCarInfomation.add(sCarStatus);
        lCarStatus.setText(sCarStatus);

      }
      }
      else
      {
        lCarStatus.setText("对不起，该车辆没有报警记录。");
      }

        //v = (Vector)in.readObject();

      out.println("EXIT");
      in.close();
      out.close();
      tcpSocket.close() ;
      return v;
  }
  catch (Exception e )
   {
         System.out.println (e);
         return v;
   }

  }
//////////////////////////////////////////////////////////////////////////////////////////////////
//转换字符
///////////////////////////////////////////////////////////////////////////////////////////////////
         public static String convertToChinese(String chineseStr)
         {
           if(chineseStr != null)
           {
             try
             {
             chineseStr = new String(chineseStr.getBytes("ISO-8859-1"), "GBK");
             }
             catch(Exception e)
             {
               e.printStackTrace();
             }
           }
           return chineseStr;
       }

  }
  */



//class DlgFindAlarm_jButton1_actionAdapter implements java.awt.event.ActionListener {
//  DlgFindAlarm adaptee;

//  DlgFindAlarm_jButton1_actionAdapter(DlgFindAlarm adaptee) {
//    this.adaptee = adaptee;
//  }
//  public void actionPerformed(ActionEvent e) {
//    adaptee.jButton1_actionPerformed(e);
//  }
//}
/*
class DlgFindAlarm_jButton2_actionAdapter implements java.awt.event.ActionListener {
  DlgFindAlarm adaptee;

  DlgFindAlarm_jButton2_actionAdapter(DlgFindAlarm adaptee) {
    this.adaptee = adaptee;
  }
  public void actionPerformed(ActionEvent e) {
    adaptee.jButton2_actionPerformed(e);
  }
}
*/