earthquakelayer.java

openmap java写的开源数字地图程序. 用applet实现,可以像google map 那样放大缩小地图.

// **********************************************************************
// 
// <copyright>
// 
//  BBN Technologies
//  10 Moulton Street
//  Cambridge, MA 02138
//  [phone]
// 
//  Copyright (C) BBNT Solutions LLC. All rights reserved.
// 
// </copyright>
// **********************************************************************
// 
// $Source: /cvs/distapps/openmap/src/openmap/com/bbn/openmap/layer/EarthquakeLayer.java,v $
// $RCSfile: EarthquakeLayer.java,v $
// $Revision: 1.5.2.2 $
// $Date: 2005/08/09 19:21:28 $
// $Author: dietrick $
// 
// **********************************************************************

package com.bbn.openmap.layer;

import java.awt.Color;
import java.awt.Component;
import java.awt.GridBagConstraints;
import java.awt.GridBagLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.MouseEvent;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.NoSuchElementException;
import java.util.Properties;
import java.util.StringTokenizer;
import java.util.Vector;

import javax.swing.JButton;
import javax.swing.JPanel;

import com.bbn.openmap.event.MapMouseListener;
import com.bbn.openmap.omGraphics.OMGraphic;
import com.bbn.openmap.omGraphics.OMGraphicList;
import com.bbn.openmap.omGraphics.OMPoint;
import com.bbn.openmap.omGraphics.OMText;
import com.bbn.openmap.util.Debug;
import com.bbn.openmap.util.PaletteHelper;
import com.bbn.openmap.util.PropUtils;

/**
 * Get data about recent earthquakes from the USGS finger sites and
 * display it.
 * <p>
 * Debugging information is printed when the OpenMap Viewer is launch
 * with -Ddebug.earthquake flag.
 * <P>
 * 
 * <pre>
 * 
 *  
 *   # Properties for the Earthquake Layer
 *   earthquake.sites=&lt;finger site&gt; &lt;finger site&gt; ...
 *   # in seconds
 *   earthquake.queryinterval=300
 *   
 *  
 * </pre>
 */
public class EarthquakeLayer extends OMGraphicHandlerLayer implements
        MapMouseListener {

    public final static transient String fingerSitesProperty = "sites";
    public final static transient String queryIntervalProperty = "queryInterval";

    /**
     * Sites to finger user the user `quake'.
     */
    protected String fingerSites[] = { "scec.gps.caltech.edu",
            "geophys.washington.edu", "giseis.alaska.edu", "mbmgsun.mtech.edu",
            "quake.eas.slu.edu" };

    // Old sites
    //      "gldfs.cr.usgs.gov",
    //      "andreas.wr.usgs.gov",
    //      "seismo.unr.edu",
    //      "eqinfo.seis.utah.edu",
    //      "sisyphus.idbsu.edu",
    //      "info.seismo.usbr.gov",
    //      "vtso.geol.vt.edu",
    //      "tako.wr.usgs.gov",
    //      "ldeo.columbia.edu"

    /**
     * Sites that are actively being queried.
     */
    protected boolean activeSites[] = new boolean[fingerSites.length];

    /** Default to 5 minutes. */
    private long fetchIntervalMillis = 300 * 1000;

    // lat-lon data of the earthquakes
    protected float llData[] = new float[0];

    // floating information about the earthquakes
    protected String infoData[] = new String[0];
    // floating information about the earthquakes
    protected String drillData[] = new String[0];

    private long lastDataFetchTime = 0;
    protected Color lineColor = Color.red;
    protected boolean showingInfoLine = false;

    /** The layer GUI. */
    protected JPanel gui = null;

    /**
     * Construct an EarthquakeLayer.
     */
    public EarthquakeLayer() {
        activeSites[0] = true;
        setProjectionChangePolicy(new com.bbn.openmap.layer.policy.ListResetPCPolicy(this));
    }

    /**
     * Fetch data from finger sites, if needed, generate the
     * OMGraphics with the current projection regardless.
     */
    public synchronized OMGraphicList prepare() {
        if (needToRefetchData()) {
            parseData(getEarthquakeData());
        }
        return generateGraphics();
    }

    /**
     * Fetches data if it hasn't been fetched in a while.
     */
    protected boolean needToRefetchData() {
        long now = System.currentTimeMillis();
        long last = lastDataFetchTime;

        if ((last + fetchIntervalMillis) < now) {
            lastDataFetchTime = now;
            return true;
        }
        return false;
    }

    /**
     * Create the graphics.
     */
    protected OMGraphicList generateGraphics() {
        OMGraphicList omgraphics = new OMGraphicList();
        OMPoint circ;
        OMText text;

        int circle_r = 2;
        int circle_h = 5;

        for (int i = 0, j = 0; i < llData.length; i += 2, j++) {

            // grouping
            OMGraphicList group = new OMGraphicList(2);

            // XY-Circle at LatLonPoint
            circ = new OMPoint(llData[i], llData[i + 1], circle_r);
            circ.setOval(true);
            circ.setFillPaint(lineColor);
            group.add(circ);

            // Info
            text = new OMText(llData[i], llData[i + 1], 0, circle_h + 10, infoData[j], java.awt.Font.decode("SansSerif"), OMText.JUSTIFY_CENTER);
            text.setLinePaint(lineColor);
            group.add(text);

            group.setAppObject(new Integer(j));//remember index
            omgraphics.add(group);
        }

        omgraphics.generate(getProjection(), false);
        return omgraphics;
    }

    /**
     * Parse the finger site data.
     * 
     * @param data Vector
     */
    protected void parseData(Vector data) {
        int nLines = data.size();
        llData = new float[2 * nLines];
        infoData = new String[nLines];
        drillData = new String[nLines];

        for (int i = 0, j = 0, k = 0; i < nLines; i++) {
            String line = (String) data.elementAt(i);

            // Read a line of input and break it down
            StringTokenizer tokens = new StringTokenizer(line);
            String sdate = tokens.nextToken();
            String stime = tokens.nextToken();
            String slat = tokens.nextToken();
            String slon = tokens.nextToken();
            if (slon.startsWith("NWSE"))// handle ` ' in LatLon data
                slon = tokens.nextToken();
            String sdep = tokens.nextToken();
            if (sdep.startsWith("NWSE"))// handle ` ' in LatLon data
                sdep = tokens.nextToken();
            String smag = tokens.nextToken();
            String q = tokens.nextToken();
            String scomment = tokens.nextToken("\r\n");
            if (q.length() > 1) {
                scomment = q + " " + scomment;
            }

            infoData[j] = smag;
            drillData[j++] = sdate + " " + stime + " (UTC)  " + slat + " "
                    + slon + " " + smag + " " + scomment;

            // Remove NESW from lat and lon before converting to float
            int west = slon.indexOf("W");
            int south = slat.indexOf("S");

            if (west >= 0)
                slon = slon.replace('W', '\0');
            else
                slon = slon.replace('E', '\0');
            if (south >= 0)
                slat = slat.replace('S', '\0');
            else
                slat = slat.replace('N', '\0');
            slon = slon.trim();
            slat = slat.trim();

            float flat = 0, flon = 0;
            try {
                flat = new Float(slat).floatValue();
                flon = new Float(slon).floatValue();
            } catch (NumberFormatException e) {
                Debug.error("EarthquakeLayer.parseData(): " + e + " line: "
                        + line);
            }

            // replace West and South demarcations with minus sign
            if (south >= 0)
                flat = -flat;
            if (west >= 0)
                flon = -flon;

            llData[k++] = flat;
            llData[k++] = flon;
        }
    }

    /**
     * Get the earthquake data from the USGS. Should be called in a
     * SwingWorker thread, or you will freeze the application.
     * 
     * @return Vector containing information from the websites.
     */
    protected Vector getEarthquakeData() {
        Vector linesOfData = new Vector();
        Socket quakefinger = null;
        PrintWriter output = null;
        BufferedReader input = null;
        String line;

        for (int i = 0; i < activeSites.length; i++) {
            // skip sites which aren't on the active list
            if (!activeSites[i])
                continue;

            try {
                if (Debug.debugging("earthquake")) {
                    Debug.output("Opening socket connection to "
                            + fingerSites[i]);
                }
                quakefinger = new Socket(fingerSites[i], 79);//open
                // connection
                // to
                // finger
                // port
                quakefinger.setSoTimeout(120 * 1000);// 2 minute
                // timeout
                output = new PrintWriter(new OutputStreamWriter(quakefinger.getOutputStream()), true);
                input = new BufferedReader(new InputStreamReader(quakefinger.getInputStream()), 1);
                output.println("/W quake");// use `/W' flag for long
                // output
            } catch (IOException e) {
                Debug.error("EarthquakeLayer.getEarthquakeData(): "
                        + "can't open or write to socket: " + e);
                continue;
            }

            try {
                // add data lines to list
                while ((line = input.readLine()) != null) {
                    if (Debug.debugging("earthquake")) {
                        Debug.output("EarthquakeLayer.getEarthQuakeData(): "
                                + line);
                    }
                    if (line.length() == 0)
                        continue;
                    if (!Character.isDigit(line.charAt(0)))
                        continue;

                    line = hackY2K(line);
                    if (line == null)
                        continue;
                    linesOfData.addElement(line);
                }
            } catch (IOException e) {
                Debug.error("EarthquakeLayer.getEarthquakeData(): "
                        + "can't read from the socket: " + e);
                if (cancelled) {
                    return null;
                }