Fork: 0
coverage / osmCoverage
Transfer to URL with SHA Find file
Newer
Older
osmCoverage / src / osm / jp / api / OsmExist.java
@hayashi hayashi on 5 Jun 2018 9 KB xxx
Raw Blame History 
  1. package osm.jp.api;
  2.  
  3. import java.io.*;
  4. import java.sql.Connection;
  5. import java.text.SimpleDateFormat;
  6. import java.util.ArrayList;
  7. import java.util.Calendar;
  8. import javax.xml.parsers.DocumentBuilder;
  9. import javax.xml.parsers.DocumentBuilderFactory;
  10. import org.w3c.dom.Document;
  11. import org.w3c.dom.Node;
  12.  
  13. public abstract class OsmExist extends Osmdb {
  14.     public ArrayList<OsmnodeNode> nodelist = new ArrayList<>();
  15.  
  16.  
  17.     public OsmExist(Connection hsqldb, String tableName) {
  18.         super(hsqldb, tableName);
  19.     }
  20.     
  21.     /*
  22.     Test data:
  23.     ノード: エネオス (2015835273)  場所: 35.4367770, 139.403571TABLE_NAME0
  24.     ノード: ENEOS (1769261234) 場所: 35.4330583, 139.4006876 brand=no
  25.     ノード: 出光 (3877535257) 場所: 45.3985390, 141.6882450 brand=no
  26.     
  27.     select osm_id,amenity,brand,disused,name,
  28.         ST_Y(ST_Transform(way,4326)) as lat,
  29.         ST_X(ST_Transform(way,4326)) as lon
  30.     from planet_osm_point
  31.     where amenity='fuel';
  32.     
  33.     
  34.     ウェイ: 出光 (161877397) ノード
  35.                                 1738352013
  36.                                 1738351984
  37.                                 1738352019
  38.                                 1738352024
  39.                                 1738352017
  40.                                 1738352013
  41.     select osm_id,amenity,brand,name,way_area,
  42.             ST_Astext(ST_Transform(way,4326)) ,
  43.             ST_Y(ST_Transform(ST_Centroid(way),4326)) as lat,
  44.             ST_X(ST_Transform(ST_Centroid(way),4326)) as lon
  45.     from planet_osm_polygon 
  46.     where amenity='fuel';
  47.     
  48.     161877397;"fuel";"出光";"出光";1415.14;"POLYGON((139.402982078119 35.4372453832977,139.403208992559 35.4373490207424,139.4033330499 35.4371591650393,139.403407160911 35.4370741177365,139.403148446109 35.4369273706731,139.402982078119 35.4372453832977))"
  49.     ST_Centroid(way)
  50.     
  51.     */
  52.     /**
  53.      * 
  54.      * <pre>{@code 
  55.      *  (
  56.      *    node[disused:amenity=fuel](35.42,139.39,35.45,139.42);
  57.      *    way[amenity=fuel](35.42,139.39,35.45,139.42);
  58.      *    node[amenity=fuel](35.42,139.39,35.45,139.42);
  59.      *    (way[amenity=fuel](35.42,139.39,35.45,139.42);>;);
  60.      *  );
  61.      *  out;
  62.      * }</pre>
  63.      * 
  64.      * <pre>{@code 
  65.      *  select osm_id,amenity,brand,disused,name from planet_osm_point where amenity='fuel';
  66.      * }</pre>
  67.      *
  68.      * <pre>{@code 
  69.      *  select osm_id,amenity,brand,name,way_area,ST_Astext(ST_Transform(way,4326)) from planet_osm_polygon where amenity='fuel';
  70.      * 
  71.      * 168977587;"fuel";"JA";"兼城SS";1378;"POLYGON((127.692529751123 26.1483225993078,127.692852156479 26.1482644594179,127.692800683013 26.1478020809547,127.692690280065 26.1478324815483,127.692623984397 26.1480452048431,127.692529751123 26.1483225993078))"
  72.      * 
  73.      * 
  74.      *  select id,nodes,tags from planet_osm_ways;
  75.      * }</pre>
  76.      * 
  77.      * @param hsqldb
  78.      * @param osmdb
  79.      * @param features
  80.      * @return XML
  81.      * @throws Exception
  82.      */
  83.     /**
  84.      * File(HttpPOST.EXIST_FILE)を読み取って、データベースに反映させる。<br>
  85.      * その際に、OSMノードを評価し、scoreを算定する
  86.      * 
  87.      * @param features
  88.      * @param boxes
  89.      * @throws Exception
  90.      */
  91.     public void getJapanCapabilities(ArrayList<Feature> features, Japan[] boxes) throws Exception {
  92.         
  93.         /*
  94.             ```
  95.             (node(changed:"2018-05-20T09:00:00Z")(34.0,138.0,36.0,140.0);)->.a;
  96.             (node(newer:"2018-05-20T09:00:00Z")(34.0,138.0,36.0,140.0);)->.b;
  97.             (way(changed:"2018-05-20T09:00:00Z")(34.0,138.0,36.0,140.0);)->.c;
  98.             (way(newer:"2018-05-20T09:00:00Z")(34.0,138.0,36.0,140.0);)->.d;
  99.             (
  100.              node.a.b["amenity"="fuel"];
  101.              node.a.b["disused:amenity"="fuel"];
  102.              node.a.b["abandoned:amenity"="fuel"];
  103.              node.a.b["demolished:amenity"="fuel"];
  104.              node.a.b["historic:amenity"="fuel"];
  105.              node.a.b["was:amenity"="fuel"];
  106.              node.a.b["removed:amenity"="fuel"];
  107.              node.a.b["no:amenity"="fuel"];
  108.              way.c.d["amenity"="fuel"];
  109.              way.c.d["disused:amenity"="fuel"];
  110.              way.c.d["abandoned:amenity"="fuel"];
  111.              way.c.d["demolished:amenity"="fuel"];
  112.              way.c.d["historic:amenity"="fuel"];
  113.              way.c.d["was:amenity"="fuel"];
  114.              way.c.d["removed:amenity"="fuel"];
  115.              way.c.d["no:amenity"="fuel"];
  116.             );
  117.             (._;>;);
  118.             out meta;
  119.             ```
  120.         */
  121.         Calendar now = Calendar.getInstance();
  122.         now.add(Calendar.DATE, -7);     // before 1 week
  123.         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
  124.         String startDate = sdf.format(now.getTime()) +"T09:00:00Z";
  125.         
  126.         StringBuilder sb = new StringBuilder();
  127.         for (Japan box : boxes) {
  128.             String boxq = String.format("(%2.1f,%3.1f,%2.1f,%3.1f)", box.minLat, box.minLon, box.maxLat, box.maxLon);
  129.             sb.append(String.format("(node(changed:\"%s\")%s;)->.a;\n", startDate, boxq));
  130.             sb.append(String.format("(node(newer:\"%s\")%s;)->.b;\n", startDate, boxq));
  131.             sb.append(String.format("(way(changed:\"%s\")%s;)->.c;\n", startDate, boxq));
  132.             sb.append(String.format("(way(newer:\"%s\")%s;)->.d;\n", startDate, boxq));
  133.             sb.append("(");
  134.             int point = 0;
  135.             for (Feature f : features) {
  136.                 if (f.node == Feature.NODE) {
  137.                     sb.append("node.a.b");
  138.                 }
  139.                 else if (f.node == Feature.AREA) {
  140.                     sb.append("way.c.d");
  141.                 }
  142.                 sb.append(String.format("[\"%s\"=\"%s\"];\n", f.key, f.v));
  143.                 point += f.point;
  144.             }
  145.             sb.append(");\n");
  146.             sb.append("(._;>;);\n");
  147.             sb.append("out body;");
  148.  
  149.             /*--------------------------------------------
  150.                 Overpass API を実行して XMLを受信する
  151.             ---------------------------------------------*/
  152.             HttpPOST.getQuery(sb.toString());
  153.             File xmlFile = new File(HttpPOST.EXIST_FILE);
  154.  
  155.             /*--------------------------------------------
  156.                 受信したXMLファイルをパースする
  157.             ---------------------------------------------*/
  158.             DocumentBuilderFactory documentBuilderFactory = DocumentBuilderFactory.newInstance();
  159.             DocumentBuilder documentBuilder = documentBuilderFactory.newDocumentBuilder();
  160.             Document document = documentBuilder.parse(xmlFile);
  161.             Node osmNode = document.getDocumentElement();
  162.             Node itemNodes = osmNode.getFirstChild();
  163.             while(itemNodes != null) {
  164.                 String nodeName = itemNodes.getNodeName();
  165.                 switch (nodeName) {
  166.                 case "node":
  167.                     OsmnodeNode osmnode = new OsmnodeNode(itemNodes);
  168.                     nodelist.add(osmnode);
  169.                     if (osmnode.tags.size() > 0) {
  170.                         insertExistingNode(osmnode.id, Double.parseDouble(osmnode.latStr), Double.parseDouble(osmnode.lonStr), score(point, osmnode.tags), "", osmnode.isRemoved());
  171.                     }
  172.                     break;
  173.                 case "way":
  174.                     OsmnodeArea osmway = new OsmnodeArea(itemNodes);
  175.                     osmway.setPosition(nodelist);
  176.                     if (osmway.tags.size() > 0) {
  177.                         insertExistingNode(osmway.id, Double.parseDouble(osmway.latStr), Double.parseDouble(osmway.lonStr), score(point, osmway.tags), "", osmway.isRemoved());
  178.                     }
  179.                     break;
  180.                 }
  181.                 itemNodes = itemNodes.getNextSibling();
  182.             }
  183.         }
  184.         
  185.     }
  186.     
  187.     /**
  188.      * 
  189.      * @param point
  190.      * @param tags
  191.      * @return 
  192.      */
  193.     int score(int point, ArrayList<OsmnodeTag> tags) {
  194.         int score = 50;
  195.         if (tags == null) {
  196.             return 0;
  197.         }
  198.         
  199.         boolean brandYes = false;
  200.         boolean busYes = false;
  201.         boolean fixmeYes = false;
  202.         boolean nameYes = false;
  203.         for (OsmnodeTag tag : tags) {
  204.             if (tag.key.startsWith("fixme")) {
  205.                 fixmeYes = true;
  206.             }
  207.             else if (tag.key.equals("bus")) {
  208.                 if (tag.value.equals("yes")) {
  209.                     busYes = true;
  210.                 }
  211.             }
  212.             else if (tag.key.equals("brand")) {
  213.                 brandYes = true;
  214.             }
  215.             else if (tag.key.startsWith("name")) {
  216.                 nameYes = true;
  217.             }
  218.         }
  219.         
  220.         if (((point & POINT_NO_BRAND) != 0) && !brandYes) {
  221.             score = 1;
  222.         }
  223.         if (((point & POINT_NO_NAME) != 0) && !nameYes) {
  224.             score = 1;
  225.         }
  226.         if (((point & POINT_FIXME) != 0) && fixmeYes) {
  227.             score = 1;
  228.         }
  229.         if (((point & POINT_BUS_NO) != 0) && !busYes) {
  230.             score = 0;
  231.         }
  232.         return score;
  233.     }
  234. }