webgisframe.java

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

                    System.out.println("the recieve status: "+Status);
  //041113122929596,位置,,913L51332,,,,0000000000000400$GPRMC 041555.000 A 3055.7595 N 10846.5406 E 22.0 240 131104  *FF

                    if ( (CarPlate.equals(getCarPlate)) && (Status .equals("位置")) ){
                      String RightMsg = Pack.substring(comma7+1, Pack.length());
                      outWriter.println(RightMsg); //从VB端接受车辆信息传给Apple

                      sMsg = getTime() + "从" + server + "接收" + RightMsg;

            //    System.out.println(sMsg);
                      ListGpsMessage.add(sMsg);
                      sMsg = getTime() + ss + "已转发";
                      ListGpsMessage.add(sMsg);
                      in = inReader.readLine();

            //                            outGps.close();
            //                            inGps.close();
                      System.out.println("close the connection.");
                      //关闭与服务器的连接
            //                            tcpSocketGps.close();
                    }
                    Begin = ss.indexOf(">", Begin + 1);
                    End = ss.indexOf("<", End + 1);
                     }
                    }
                  }
                          catch (Exception e )
                          {
                            System.out.println (e);
                            break;
                          }
                       }
         else if(s.equals("4"))
                {
              int port= 2588;
                    try{
                      System.out.println ("Connecting to " +server);

                     // 与服务器建立连接
                     Socket tcpSocketGps = new Socket(server, port);
                     //超时1分30秒
                     tcpSocketGps.setSoTimeout(360000);
                     //建立输入输出流
                     PrintStream outGps = new PrintStream( tcpSocketGps.getOutputStream()) ;
                     DataInputStream inGps = new DataInputStream(tcpSocketGps.getInputStream());

                    byte[] buffer = new byte[1024];
                    int bytesRead=0;

                    String m_gps = in.substring(2,in.length());
                    outGps.println(m_gps);
                    sMsg=getTime()+"连接到"+server+"发送"+m_gps;
                    ListGpsMessage.add(sMsg);
                    bytesRead=inGps.read(buffer);
                    ss = new String (buffer, 0, bytesRead);
                    outWriter.println(ss);

                    outGps.close();
                    inGps.close();
                    System.out.println("close the connection.");
                    //关闭与服务器的连接
                    tcpSocketGps.close();



                       }catch(Exception ee){}
                      }
                     }
                     catch(Exception e)
                     {
                       e.printStackTrace();
                       break;
                     }

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
               }
               outWriter.println("BYE client ("+intNumber+")");
               outMessage.close();
               tcpSocket.close();
               sMsg=getTime()+"断开"+server+"的连接";
               ListGpsMessage.add(sMsg);
               Conn.close();
               System.out.println("client ("+intNumber+") closed");

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

      }
   /*//////////////////////////////////////////////////////////////////////////////////////////////////
  查询数据库
///////////////////////////////////////////////////////////////////////////////////////////////////*/
  public Vector getSearchResultCarInfo(String strSQL){
    //strSQL="select * from track where carnumber='13801135733' and TO_CHAR(createdatime,'YYYY-MM-DD')='2003-06-24'";
    Vector v = new Vector();
    try{
      double i=131;
      String s="111";
      i=Double.valueOf(s).doubleValue();

      java.sql.ResultSet RS = Stmt.executeQuery(strSQL);
      System.out.println(strSQL);
      while(RS.next()){
        v.addElement(ConvertString(RS.getString("cardid")));
        v.addElement(ConvertString(RS.getString("carlicenceno")));
        v.addElement(ConvertString(RS.getString("username")));
        v.addElement(ConvertString(RS.getString("carmobileno")));
        v.addElement(ConvertString(RS.getString("phoneno")));
 //       System.out.println(RS.getString("cardid")+"*"+RS.getString("phoneno")+"*");
        v.addElement(ConvertString(RS.getString("latestsend")));
        v.addElement(ConvertString(RS.getString("speed")));
        v.addElement(ConvertString(RS.getString("status")));
        v.addElement(ConvertString(RS.getString("gpsstyle")));
        v.addElement(ConvertString(RS.getString("carcolor")));
        v.addElement(ConvertString(RS.getString("registerdate")));
        //System.out.println(RS.getString("cardid"));
 //       System.out.println(RS.getString("SPEED")+":"+RS.getString("CreateDatime"));
      }
      RS.close();
    }catch(Exception e){
      e.printStackTrace();
    }

    return v;
  }
public String ConvertString(String s)
{
  if(s == null)
    return s="";
  else
    return s;
}
 /*//////////////////////////////////////////////////////////////////////////////////////////////////
  查询车辆信息数据库
///////////////////////////////////////////////////////////////////////////////////////////////////*/
  public Vector getSearchResult(String strSQL){
    //strSQL="select * from track where carnumber='13801135733' and TO_CHAR(createdatime,'YYYY-MM-DD')='2003-06-24'";
    Vector v = new Vector();
    try{

      java.sql.ResultSet RS = Stmt.executeQuery(strSQL);
      while(RS.next()){
        v.addElement(RS.getString("TRACKLONGITUDE"));
        v.addElement(RS.getString("TRACKLATITUDE"));
        v.addElement(RS.getString("SPEED"));
        v.addElement(RS.getString("CreateDatime"));
 //       System.out.println(RS.getString("TRACKLATITUDE") +":"+RS.getString("TRACKLONGITUDE"));
 //       System.out.println(RS.getString("SPEED")+":"+RS.getString("CreateDatime"));
      }
      RS.close();
    }catch(Exception e){
      e.printStackTrace();
    }

    return v;
  }
      private String getTime()
      {
       Date currentTime=new Date();
       //SimpleDateFormat dateFormat=new SimpleDateFormat("yyyy MMMM dd,EEEE, HH:mm:ss");
       SimpleDateFormat dateFormat=new SimpleDateFormat("yyyy\\MM\\dd HH:mm:ss ");
       String timeString=dateFormat.format(currentTime);
       return timeString;
      }
     public void WriteFile(String sMessage)
     {
      try{
// 在StringWriter 上建立一个PrintWriter。
      StringWriter sw = new StringWriter();
      PrintWriter pw = new PrintWriter(sw);
// 输出一些东西到StringWriter
      pw.println(sMessage);
// 得到被写入的字符串
      String str = sw.toString();
// 显式它
      System.out.print(str);
// 将字符串输出到文件，使用 UTF-8 编码
      FileOutputStream fos =new FileOutputStream(FileName);
      OutputStreamWriter osw =new OutputStreamWriter(fos, "UTF-8");
      BufferedWriter bw =new BufferedWriter(osw);
      bw.write(str);
      bw.close();
    }
    catch (Exception e)
    {
     System.out.println(e);
     }
   }


  }
  private String getTime()
  {
    Date currentTime=new Date();
    //SimpleDateFormat dateFormat=new SimpleDateFormat("yyyy MMMM dd,EEEE, HH:mm:ss");
    SimpleDateFormat dateFormat=new SimpleDateFormat("yyyyMMddHHmmss");
    String timeString=dateFormat.format(currentTime);
    return timeString;
  }
  private String getDateTime()
  {
   Date currentTime=new Date();
   //SimpleDateFormat dateFormat=new SimpleDateFormat("yyyy MMMM dd,EEEE, HH:mm:ss");
   SimpleDateFormat dateFormat=new SimpleDateFormat("yyyy\\MM\\dd HH:mm:ss ");
   String timeString=dateFormat.format(currentTime);
   return timeString;
  }
 public void WriteMyFile(String sMessage)
 {
  try{
// 输出一些东西到StringWriter
  pw.println(sMessage);
  System.out.println(sMessage);
// 得到被写入的字符串
  String str = sw.toString();
// 显式它
  System.out.print(str);
// 将字符串输出到文件，使用 UTF-8 编码
  bw.write(str);
}
catch (Exception e)
{
 System.out.println(e);
 }
}

void WriteFile(String sMessage)
{
try
  {
  FileWriter file = new FileWriter(FileName,true);
  PrintWriter out = new PrintWriter(file);
  out.println(sMessage);
  out.close();
  file.close();
  } catch (IOException e)
  {
   System.out.println("错了!");
   e.printStackTrace();
  }
}
}


/*
// 在StringWriter 上建立一个PrintWriter。
StringWriter sw = new StringWriter();
PrintWriter pw = new PrintWriter(sw);
// 输出一些东西到StringWriter
pw.println("This is a test\u4321");
int n = 37;
pw.println("The square of " + n + " is " + (n * n));
// 得到被写入的字符串
String str = sw.toString();
// 显式它
System.out.print(str);
// 将字符串输出到文件，使用 UTF-8 编码

FileOutputStream fos =
new FileOutputStream("c:\\test.txt");
OutputStreamWriter osw =
new OutputStreamWriter(fos, "UTF-8");
BufferedWriter bw =
new BufferedWriter(osw);
bw.write(str);
bw.close();
// 读回字符串并检查
FileInputStream fis=new FileInputStream("out.txt");
InputStreamReader isr =new InputStreamReader(fis, "UTF-8");
BufferedReader br =new BufferedReader(isr);
String s1 = br.readLine();
String s2 = br.readLine();
br.close();
String linesep = System.getProperty("line.separator");
if (!str.equals(s1 + linesep + s2 + linesep))
System.err.println("equals check failed");*/