framewebalarm.java

来自「实现网络GPS定位车辆的位置」· Java 代码 · 共 585 行 · 第 1/2 页

                        String s;
                        s=in.substring(0,1);
                        System.out.println(in);
                        if(!s.equals("1"))
                        {
                        sMsg=getTime()+in+"已接收";
                        ListGpsMessage.add(sMsg);
                        //System.out.println(in);
                        }
                       if( s.equals("1"))//查询报警信息
                        {
                          String AlarmType = "";
                          String AlarmNum = "";
                          String tel = "";
                          String strSQL = "";
                          String m_cardid = "";
                          String m_username = "";
                          String m_car_no = "";
                          String Alar_message = "";
                          boolean IsInsertFlag = false;

                          Vector vAlarmMessage = new Vector();
                          try {
                            java.sql.ResultSet RS = Stmt.executeQuery(
                                "select gpsmessage from gpsmessage where flag=0");
                            //System.out.println(RS.getString("gpsmessage"));
                            //while  (RS.next()){
                            if (RS.next())
                            {
                              Alar_message = RS.getString("gpsmessage");
                              vAlarmMessage.addElement(RS.getString("gpsmessage"));
                              ListGpsMessage.add(getTime() + "收到报警：" +
                                                 RS.getString("gpsmessage"));

                              WriteFile(getTime() + "收到报警：" + RS.getString("gpsmessage"));
                              Stmt.execute("update gpsmessage set flag=1");
                              //System.out.println(RS.getString("gpsmessage"));
                            }
                          }
                            catch (Exception e)
                           {
                              e.printStackTrace();
                           }

            ///////////////////////////////////////////////////////////////////////////////
            //解字符串gpsmessage,然后插入Table Alert_HST
            ///////////////////////////////////////////////////////////////////////////////

                            //Alar_message=RS.getString("gpsmessage");
                            AlarmNum = Alar_message.substring(47, 50);
                            if (AlarmNum.equals("004"))
                            {
                              AlarmType = "剪线报警";
                              IsInsertFlag = true;
                            }
                            else if (AlarmNum.equals("010"))
                            {
                              AlarmType = "倾角报警";
                              IsInsertFlag = true;

                            }
                            else
                            {
                              AlarmType = "劫警";
                              IsInsertFlag = true;
                            }
                            System.out.println(AlarmType);
                            tel = Alar_message.substring(0, 11);
                            System.out.println(tel);
                            if (IsInsertFlag)
                            {
                             try {

                                strSQL =
                                    "select cardid, username,carlicenceno from carmaster where webtype='1' and carmobileno='" +
                                    tel + "'";
                                java.sql.ResultSet Alar_Result = Stmt.executeQuery(strSQL);
                                if (Alar_Result.next()) {
                                  m_cardid = Alar_Result.getString("cardid");
                                  System.out.println(m_cardid);
                                  m_username = Alar_Result.getString("username");
                                  System.out.println(m_username);
                                  m_car_no = Alar_Result.getString("carlicenceno");
                                  System.out.println(m_car_no);

                                  Alar_Result.close();
                                  try
                                  {

                                    strSQL =
                                        "insert into alert_hst (cardid,user_name,car_no,alert_type,info_date)values('" +
                                        m_cardid + "','" + m_username + "','" + m_car_no +
                                        "','" + AlarmType + "',sysdate)";
                                    System.out.println(strSQL);
                                    Stmt.executeQuery(strSQL);

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

                            ////////////////////////////////////////////////////////////////////////////
                            //     报警信息插入完毕！！！
                            ///////////////////////////////////////////////////////////////////////////

                                }

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

                            String m_result = "null";
                            if (vAlarmMessage.size() != 0)
                              m_result = vAlarmMessage.elementAt(0).toString();
                            outMessage.println(m_result);
                        }
                     }
                     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 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\\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");*/