src/osm/jp/ConvBusstop.java

   1 package osm.jp;\r
   2 import osm.jp.api.HttpPOST;\r
   3 \r
   4 import javax.xml.parsers.*;\r
   5 import javax.xml.transform.TransformerException;\r
   6 \r
   7 import org.w3c.dom.*;\r
   8 import org.xml.sax.*;\r
   9 \r
  10 import java.io.*;\r
  11 import java.sql.Connection;\r
  12 import java.sql.PreparedStatement;\r
  13 import java.sql.ResultSet;\r
  14 import java.sql.SQLException;\r
  15 import java.sql.Statement;\r
  16 import java.text.SimpleDateFormat;\r
  17 import java.util.ArrayList;\r
  18 import java.util.Calendar;\r
  19 import java.util.Date;\r
  20 \r
  21 import jp.co.areaweb.tools.database.*;\r
  22 \r
  23 public class ConvBusstop {\r
  24 \r
  25         String filter = "";\r
  26         String urlStr = "";\r
  27 \r
  28         public static final boolean DB_INIT = false;\r
  29 \r
  30         // 近くのバス停を探す範囲（バス停を中心としたNEER×２ｍ四方の領域\r
  31         static final int NEER = 150;\r
  32         static boolean nocheck = false;\r
  33 \r
  34         /**\r
  35          * メイン\r
  36          *\r
  37          *      java -cp .:ConvBusstop.jar:hayashi_0225.jar:hsqldb_2.2.9.jar osm.jp.ConvBusstop <option>\r
  38          *              OPTION: -nocheck        OSMデータ上に既存のバス停が存在するかどうかをチェックしない\r
  39          *              OPTION: -check  OSMデータ上に既存のバス停が存在するかどうかをチェックする\r
  40          *\r
  41          * @throws IOException\r
  42          * @throws SQLException\r
  43          * @throws ClassNotFoundException\r
  44          * @throws FileNotFoundException\r
  45          * @throws TransformerException\r
  46          * @throws SAXException\r
  47          * @throws ParserConfigurationException */\r
  48         public static void main(String[] args) throws FileNotFoundException, ClassNotFoundException, SQLException, IOException, ParserConfigurationException, SAXException, TransformerException\r
  49         {\r
  50                 int index = 0;\r
  51                 if (args.length > index) {\r
  52                         if (args[index].equals("-check")) {\r
  53                                 ConvBusstop.nocheck = false;\r
  54                                 index++;\r
  55                         }\r
  56                         else if (args[index].equals("-nocheck")) {\r
  57                                 ConvBusstop.nocheck = true;\r
  58                                 index++;\r
  59                         }\r
  60                 }\r
  61 \r
  62                 /**\r
  63                  * アプリケーション [ConvBusstop]\r
  64                  * > java -jar ConvBusstop.jar <オプション>\r
  65                  *      オプション： -exp 実行する直前にデータベースを初期化する（省略可能）\r
  66                  */\r
  67                 File dbdir = new File("database");\r
  68                 if (!dbdir.isDirectory()) {\r
  69                         dbdir.mkdir();\r
  70                 }\r
  71 \r
  72                 Connection con = DatabaseTool.openDb("database");\r
  73                 ConvBusstop.initDb(con);\r
  74 \r
  75                 try {\r
  76                         /**\r
  77                          * バス停データ変換のメイン処理\r
  78                          */\r
  79                         int fcounter = 0;\r
  80                         if (args.length > index) {\r
  81                                 File iFile = new File(args[index]);\r
  82                                 fcounter++;\r
  83                                 inputFile(con, iFile);\r
  84                         }\r
  85                         else {\r
  86                                 File dir = new File(".");\r
  87                                 File[] files = dir.listFiles();\r
  88                                 for (File iFile : files) {\r
  89                                         if (checkFile(iFile)) {\r
  90                                                 fcounter++;\r
  91                                                 ConvBusstop.clearDb(con);\r
  92                                                 inputFile(con, iFile);\r
  93                                         }\r
  94                                 }\r
  95                         }\r
  96                         System.out.println("["+ fcounter +"]つのファイルをインポートしました。");\r
  97                         \r
  98                         /**\r
  99                          * 既存のOSMバス停を読み込む\r
 100                          *              --> 'existing.xml'\r
 101                          */\r
 102                         if (!ConvBusstop.nocheck && (fcounter > 0)) {\r
 103                                 /*\r
 104                                  * 既存のOSMデータファイルがなければ、新たにダウンロードする。\r
 105                                  * OSMデータファイルがあるときは、ダウンロードしないでそれを使う。\r
 106                                  */\r
 107                                 File existingFile = new File("existing.xml");\r
 108                                 if (!existingFile.isFile()) {\r
 109                                         /**\r
 110                                          * インポートしたデータの緯度経度範囲を読み取る\r
 111                                          */\r
 112                                         double maxLat = -90.0D;\r
 113                                         double minLat = 90.0D;\r
 114                                         double maxLon = -180.0D;\r
 115                                         double minLon = 180.0D;\r
 116                                         PreparedStatement ps8 = con.prepareStatement("SELECT lat,lon FROM bus_stop");\r
 117                                         ResultSet rset8 = ps8.executeQuery();\r
 118                                         while (rset8.next()) {\r
 119                                                 Double lat = rset8.getDouble("lat");\r
 120                                                 Double lon = rset8.getDouble("lon");\r
 121 \r
 122                                                 if (lat > maxLat) {\r
 123                                                         maxLat = lat;\r
 124                                                 }\r
 125                                                 if (lon > maxLon) {\r
 126                                                         maxLon = lon;\r
 127                                                 }\r
 128                                                 if (lat < minLat) {\r
 129                                                         minLat = lat;\r
 130                                                 }\r
 131                                                 if (lon < minLon) {\r
 132                                                         minLon = lon;\r
 133                                                 }\r
 134                                         }\r
 135                                         rset8.close();\r
 136                                         \r
 137                                         /**\r
 138                                          * OSM OverPassAPI を使って、既存のOSMバス停のデータを取得して、「existing.xml」に出力する\r
 139                                          */\r
 140                                         HttpPOST.getCapabilities(minLat, maxLat, minLon, maxLon);\r
 141                                 }\r
 142                                 readExistingFile(con, existingFile);\r
 143                                 \r
 144                                 PreparedStatement ps1 = con.prepareStatement("SELECT idref,name,lat,lon FROM bus_stop");\r
 145                                 PreparedStatement ps2 = con.prepareStatement("SELECT count(idref) FROM existing_data where (lat > ?) and (lat < ?) and (lon > ?) and (lon < ?)");\r
 146                                 PreparedStatement ps3 = con.prepareStatement("UPDATE bus_stop SET fixed=? WHERE idref=?");\r
 147                                 PreparedStatement ps4 = con.prepareStatement("SELECT count(idref) FROM existing_data where (lat > ?) and (lat < ?) and (lon > ?) and (lon < ?) and (name = ?)");\r
 148                                 ResultSet rset1 = ps1.executeQuery();\r
 149                                 while (rset1.next()) {\r
 150                                         String idref = rset1.getString("idref");\r
 151                                         String name = rset1.getString("name");\r
 152                                         Double lat = rset1.getDouble("lat");\r
 153                                         Double lon = rset1.getDouble("lon");\r
 154                                         \r
 155                                         // 指定の緯度経度を中心とする半径150x2m四方の矩形領域\r
 156                                         System.out.print(idref + "("+ name + ") ....");\r
 157                                         RectArea rect = new RectArea(lat, lon, NEER);           // 300m 四方\r
 158                                         ps2.setDouble(1, rect.minlat);\r
 159                                         ps2.setDouble(2, rect.maxlat);\r
 160                                         ps2.setDouble(3, rect.minlon);\r
 161                                         ps2.setDouble(4, rect.maxlon);\r
 162                                         ResultSet rset2 = ps2.executeQuery();\r
 163                                         if (rset2.next()) {\r
 164                                                 int count = rset2.getInt(1);\r
 165                                                 if (count > 0) {\r
 166                                                         System.out.println("."+ count);\r
 167                                                         ps3.setInt(1, count);\r
 168                                                         ps3.setString(2, idref);\r
 169                                                         ps3.executeUpdate();\r
 170                                                 }\r
 171                                                 else {\r
 172                                                         // 指定の緯度経度を中心とする半径150x4m四方の矩形領域\r
 173                                                         System.out.print("***");\r
 174                                                         rect = new RectArea(lat, lon, NEER*2);          // 600m 四方\r
 175                                                         ps4.setDouble(1, rect.minlat);\r
 176                                                         ps4.setDouble(2, rect.maxlat);\r
 177                                                         ps4.setDouble(3, rect.minlon);\r
 178                                                         ps4.setDouble(4, rect.maxlon);\r
 179                                                         ps4.setString(5, name);\r
 180                                                         ResultSet rset4 = ps4.executeQuery();\r
 181                                                         if (rset4.next()) {\r
 182                                                                 count = rset4.getInt(1);\r
 183                                                                 System.out.println(".."+ count);\r
 184                                                                 ps3.setInt(1, count);\r
 185                                                                 ps3.setString(2, idref);\r
 186                                                                 ps3.executeUpdate();\r
 187                                                         }\r
 188                                                         rset4.close();\r
 189                                                 }\r
 190                                         }\r
 191                                         rset2.close();\r
 192                                 }\r
 193                                 rset1.close();\r
 194                                 ps3.close();\r
 195                                 ps2.close();\r
 196                                 ps1.close();\r
 197                         }\r
 198                         \r
 199                         // ローカルデータベース内の情報を出力する\r
 200                         if (args.length > index) {\r
 201                                 File iFile = new File(args[index]);\r
 202                                 String iStr = iFile.getName();\r
 203                                 outputDb(con, iStr.substring(0, iStr.length() - 4));\r
 204                         }\r
 205                         else {\r
 206                                 File dir = new File(".");\r
 207                                 File[] files = dir.listFiles();\r
 208                                 for (File iFile : files) {\r
 209                                         if (checkFile(iFile)) {\r
 210                                                 String iStr = iFile.getName();\r
 211                                                 outputDb(con, iStr.substring(0, iStr.length() - 4));\r
 212                                         }\r
 213                                 }\r
 214                         }\r
 215                         \r
 216                         // ローカルデータベース内の情報を「busstop.xml」に出力する\r
 217                         int counter = outputDb(con);\r
 218 \r
 219                         System.out.println("["+ counter +"] 変換完了しました。");\r
 220                 }\r
 221                 finally {\r
 222                         DatabaseTool.closeDb(con);\r
 223                 }\r
 224         }\r
 225 \r
 226         static String[] shiftArgs(String[] args) {\r
 227                 String[] values = new String[args.length - 1];\r
 228                 for (int i=1; i < args.length; i++) {\r
 229                         values[i - 1] = new String(args[i]);\r
 230                 }\r
 231                 return values;\r
 232         }\r
 233 \r
 234         public static void readExistingFile (Connection con, File existingFile) throws FileNotFoundException, ClassNotFoundException, SQLException, IOException, ParserConfigurationException, SAXException {\r
 235                 int iCounter = 0;\r
 236 \r
 237                 DocumentBuilderFactory factory;\r
 238                 DocumentBuilder        builder;\r
 239                 Node root;\r
 240 \r
 241                 iCounter = 0;\r
 242                 factory = DocumentBuilderFactory.newInstance();\r
 243                 builder = factory.newDocumentBuilder();\r
 244                 factory.setIgnoringElementContentWhitespace(true);\r
 245                 factory.setIgnoringComments(true);\r
 246                 factory.setValidating(true);\r
 247                 root    = builder.parse(existingFile);\r
 248 \r
 249                 iCounter += readExistingNodes(con, root);\r
 250                 System.out.println("既存バス停数["+ iCounter +"]");\r
 251         }\r
 252         \r
 253         static int readExistingNodes(Connection con, Node node) throws IOException, SQLException {\r
 254                 int iCounter = 0;\r
 255                 \r
 256                 NodeList nodes = node.getChildNodes();\r
 257                 for (int i = 0; i < nodes.getLength(); i++) {\r
 258                         Node node2 = nodes.item(i);\r
 259                         if (node2.getNodeName().equals("node")) {\r
 260                                 iCounter++;\r
 261                                 importExistingNode(con, node2);\r
 262                         }\r
 263                         else {\r
 264                                 iCounter += readExistingNodes(con, node2);\r
 265                         }\r
 266                 }\r
 267                 return iCounter;\r
 268         }\r
 269 \r
 270         static void importExistingNode(Connection con, Node node) throws IOException, SQLException {\r
 271                 String idrefStr = "";\r
 272                 String latStr = "";\r
 273                 String lonStr = "";\r
 274                 String nameStr = "";\r
 275                 PreparedStatement ps5 = con.prepareStatement("INSERT INTO existing_data (idref,lat,lon, name) VALUES (?,?,?,?)");\r
 276 \r
 277                 NamedNodeMap nodeMap = node.getAttributes();\r
 278                 if (null != nodeMap) {\r
 279                         for (int j=0; j < nodeMap.getLength(); j++) {\r
 280                                 if (nodeMap.item(j).getNodeName().equals("id")) {\r
 281                                         idrefStr = nodeMap.item(j).getNodeValue();\r
 282                                 }\r
 283                                 else if (nodeMap.item(j).getNodeName().equals("lat")) {\r
 284                                         latStr = nodeMap.item(j).getNodeValue();\r
 285                                 }\r
 286                                 else if (nodeMap.item(j).getNodeName().equals("lon")) {\r
 287                                         lonStr = nodeMap.item(j).getNodeValue();\r
 288                                 }\r
 289                         }\r
 290                         \r
 291                         NodeList nodes = node.getChildNodes();\r
 292                         for (int i = 0; i < nodes.getLength(); i++) {\r
 293                                 Node node2 = nodes.item(i);\r
 294                                 if (node2.getNodeName().equals("tag")) {\r
 295                                         NamedNodeMap nodeMap2 = node2.getAttributes();\r
 296                                         if (null != nodeMap2) {\r
 297                                                 String key = null;\r
 298                                                 String value = null;\r
 299                                                 for (int j=0; j < nodeMap2.getLength(); j++) {\r
 300                                                         if (nodeMap2.item(j).getNodeName().equals("k")) {\r
 301                                                                 key = nodeMap2.item(j).getNodeValue();\r
 302                                                         }\r
 303                                                         else if (nodeMap2.item(j).getNodeName().equals("v")) {\r
 304                                                                 value = nodeMap2.item(j).getNodeValue();\r
 305                                                         }\r
 306                                                 }\r
 307                                                 \r
 308                                                 if ((key != null) && key.toLowerCase().equals("name") && (value != null)) {\r
 309                                                         nameStr = value;\r
 310                                                         break;\r
 311                                                 }\r
 312                                         }\r
 313                                 }\r
 314                         }\r
 315 \r
 316                         // idref と nameStr をデータベースに格納する\r
 317                         System.out.println("import existing_data : "+ idrefStr +" ("+ latStr +","+ lonStr+")"+ nameStr);\r
 318                         ps5.setString(1, idrefStr);\r
 319                         ps5.setDouble(2, Double.parseDouble(latStr));\r
 320                         ps5.setDouble(3, Double.parseDouble(lonStr));\r
 321                         ps5.setString(4, nameStr);\r
 322                         ps5.executeUpdate();\r
 323                         ps5.close();\r
 324                 }\r
 325         }\r
 326         \r
 327         /**\r
 328          * ソースファイルを読み取ってローカルベータベースへ記録する\r
 329          * @param con\r
 330          * @param iFile\r
 331          * @throws FileNotFoundException\r
 332          * @throws ClassNotFoundException\r
 333          * @throws SQLException\r
 334          * @throws IOException\r
 335          * @throws ParserConfigurationException \r
 336          * @throws SAXException \r
 337          */\r
 338         public static void inputFile (Connection con, File iFile) throws FileNotFoundException, ClassNotFoundException, SQLException, IOException, ParserConfigurationException, SAXException {\r
 339                 int iCounter = 0;\r
 340                 String timeStampStr = null;\r
 341 \r
 342                 String iStr = iFile.getName();\r
 343                 File dir = new File(iStr.substring(0, iStr.length() - 4));\r
 344                 dir.mkdir();\r
 345 \r
 346                 DocumentBuilderFactory factory;\r
 347                 DocumentBuilder        builder;\r
 348                 Node root;\r
 349 \r
 350                 iCounter = 0;\r
 351                 factory = DocumentBuilderFactory.newInstance();\r
 352                 builder = factory.newDocumentBuilder();\r
 353                 factory.setIgnoringElementContentWhitespace(true);\r
 354                 factory.setIgnoringComments(true);\r
 355                 factory.setValidating(true);\r
 356                 root    = builder.parse(iStr);\r
 357 \r
 358                 iCounter += showNodes(con, root, iStr.substring(0, iStr.length() - 4), timeStampStr);\r
 359                 System.out.println("バス停数["+ iCounter +"]");\r
 360         }\r
 361 \r
 362         public static void clearDb(Connection con) throws SQLException {\r
 363                 Statement stmt = con.createStatement();\r
 364                 long count = stmt.executeUpdate("delete from bus_stop");\r
 365                 System.out.println("'Database.bus_stop'から "+ count +" 件のデータを削除しました。");\r
 366             \r
 367             count = stmt.executeUpdate("delete from existing_data");\r
 368             System.out.println("'Database.existing_data'から "+ count +" 件のデータを削除しました。");\r
 369 \r
 370             count = stmt.executeUpdate("delete from bus_course");\r
 371             System.out.println("'Database.bus_course'から "+ count +" 件のデータを削除しました。");\r
 372 \r
 373             count = stmt.executeUpdate("delete from bus_ref");\r
 374             System.out.println("'Database.bus_ref'から "+ count +" 件のデータを削除しました。");\r
 375             stmt.close();\r
 376         }\r
 377 \r
 378         public static void initDb(Connection con) throws SQLException {\r
 379                 String createSt;\r
 380 \r
 381                 // 'table.BUS_STOP'を新規に作る\r
 382                 DbBusstop.create(con);\r
 383 \r
 384                 createSt = "CREATE TABLE existing_data (idref VARCHAR(12) NOT NULL, name VARCHAR(128), lat DOUBLE, lon DOUBLE, CONSTRAINT existing_pk PRIMARY KEY(idref, lat, lon));";\r
 385                 DbBusstop.create(con, createSt);\r
 386                 \r
 387                 createSt = "CREATE TABLE bus_course (code int, type int, corp VARCHAR(128) NOT NULL, course VARCHAR(512), ifile VARCHAR(128), CONSTRAINT bus_course_pk PRIMARY KEY(code));";\r
 388                 DbBusstop.create(con, createSt);\r
 389 \r
 390                 createSt = "CREATE TABLE bus_ref (idref VARCHAR(12), code INT);";\r
 391                 DbBusstop.create(con, createSt);\r
 392         }\r
 393 \r
 394 \r
 395         /**\r
 396          * ローカルデータベース内の情報を出力する\r
 397          * @param con\r
 398          * @param iCode\r
 399          * @throws IOException\r
 400          * @throws SQLException\r
 401          */\r
 402         public static void outputDb(Connection con, String iCode) throws IOException, SQLException {\r
 403                 SimpleDateFormat timeStampFmt = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss'Z'");\r
 404                 String timeStampStr = timeStampFmt.format(new Date(Calendar.getInstance().getTimeInMillis()));\r
 405                 File dir = new File(iCode);\r
 406                 dir.mkdir();\r
 407 \r
 408                 BufferedWriter ow = null;\r
 409                 BufferedWriter gw = null;\r
 410                 BufferedWriter hw = null;\r
 411                 BufferedWriter ww = null;\r
 412 \r
 413                 // HTML header\r
 414                 File htmlFile = new File(iCode  +".html");\r
 415                 hw = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(htmlFile), "UTF-8"));\r
 416                 hw.write("<!DOCTYPE html>");\r
 417                 hw.newLine();\r
 418                 hw.write("<html><head><meta charset=\"utf-8\" /></head>");\r
 419                 hw.newLine();\r
 420                 hw.write("<body><table border='1'>");\r
 421                 hw.newLine();\r
 422                 hw.write("<tr>");\r
 423                 hw.write("<td>type</td>");\r
 424                 hw.write("<td>corp</td>");\r
 425                 hw.write("<td>course</td>");\r
 426                 hw.write("<td>GPX</td>");\r
 427                 hw.write("<td>SAMPLE</td>");\r
 428                 hw.write("<td>バス停数</td>");\r
 429                 hw.write("<td>未入力</td>");\r
 430                 hw.write("<td>既存</td>");\r
 431                 hw.write("</tr>");\r
 432                 hw.newLine();\r
 433 \r
 434                 // Wiki header\r
 435                 File wikiFile = new File(iCode  +".wiki.txt");\r
 436                 ww = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(wikiFile), "UTF-8"));\r
 437                 ww.write("= バス路線毎のマッピング状況 =");\r
 438                 ww.newLine();\r
 439                 ww.newLine();\r
 440                 \r
 441                 String maeCorp = "";\r
 442                 boolean firstCorp = true;\r
 443                 \r
 444                 PreparedStatement ps7 = con.prepareStatement("SELECT code,type,corp,course,ifile FROM bus_course WHERE ifile=? ORDER BY type,corp,course");\r
 445                 PreparedStatement ps9 = con.prepareStatement("SELECT idref FROM bus_ref WHERE code=?");\r
 446                 PreparedStatement ps8 = con.prepareStatement("SELECT name,lat,lon,fixed FROM bus_stop WHERE idref=?");\r
 447                 ps7.setString(1, iCode);\r
 448                 ResultSet rset7 = ps7.executeQuery();\r
 449                 while (rset7.next()) {\r
 450                         int code = rset7.getInt(1);\r
 451                         int type = rset7.getInt(2);\r
 452                         String corp = rset7.getString(3);\r
 453                         String course = rset7.getString(4);\r
 454                         \r
 455 \r
 456                         File osmFile = new File(dir, iCode + String.format("_%1$08d", code) +".osm");\r
 457                         File gpxFile = new File(dir, iCode + String.format("_%1$08d", code) +".gpx");\r
 458                         File osmSample = new File(dir, iCode + String.format("_s%1$08d", code) +".osm");\r
 459 \r
 460                         System.out.println("course = "+ course);\r
 461                         int stopCount = 0;\r
 462                         int fixedCount = 0;\r
 463                         int unfixedCount = 0;\r
 464 \r
 465                         // index file header\r
 466                         hw.write("<tr>");\r
 467                         hw.write("<td>"+ type +"</td>");\r
 468                         hw.write("<td>"+ corp +"</td>");\r
 469                         hw.write("<td><a href='"+ dir.getName() +"/"+ osmFile.getName() +"'>"+ course +"</a></td>");\r
 470                         hw.write("<td><a href='"+ dir.getName() +"/"+ gpxFile.getName() +"'>"+ gpxFile.getName() +"</a></td>");\r
 471                         hw.write("<td><a href='"+ dir.getName() +"/"+ osmSample.getName() +"'>"+ osmSample.getName() +"</a></td>");\r
 472                         hw.newLine();\r
 473 \r
 474                         //--------------------------------------------\r
 475                         //      Wiki見出し２: 運行会社\r
 476                         //------------\r
 477                         if (!maeCorp.equals(corp)) {\r
 478                                 if (firstCorp == false) {\r
 479                                         ww.write("|}");\r
 480                                         ww.newLine();\r
 481                                         ww.newLine();\r
 482                                 }\r
 483                                 firstCorp = false;\r
 484                                 \r
 485                                 ww.write("=== "+ corp +" ===");\r
 486                                 ww.newLine();\r
 487                                 ww.newLine();\r
 488 \r
 489                                 ww.write(":{{JA:Tag|network||"+ corp +"}}");\r
 490                                 ww.newLine();\r
 491                                 ww.write(":{{JA:Tag|operator||"+ corp +"}}");\r
 492                                 ww.newLine();\r
 493                                 ww.newLine();\r
 494 \r
 495                                 ww.write("{| class=\"wikitable sortable\" style=\"table-layout: fixed; width: 100%\"");\r
 496                                 ww.newLine();\r
 497                                 ww.write("!style=\"width: 100px\"| ref");\r
 498                                 ww.newLine();\r
 499                                 ww.write("!class=\"unsortable\" style=\"width: 152px\"| 編集状況(マスタ)");\r
 500                                 ww.newLine();\r
 501                                 ww.write("!class=\"unsortable\" style=\"width: 152px\"| 編集状況(往路)");\r
 502                                 ww.newLine();\r
 503                                 ww.write("!class=\"unsortable\" style=\"width: 152px\"| 編集状況(復路)");\r
 504                                 ww.newLine();\r
 505                                 ww.write("!class=\"unsortable\"| 備考");\r
 506                                 ww.newLine();\r
 507 \r
 508                                 maeCorp = new String(corp);\r
 509                         }\r
 510                         \r
 511                         // Wiki\r
 512                         ww.write("|-");\r
 513                         ww.newLine();\r
 514                         ww.write("| "+ course +" ");            // ref\r
 515                         ww.write("|| {{State Route|r=0}} {{relation|0|tools=no}} ");                    // 編集状況 (マスタ)\r
 516                         ww.write("|| {{State Route|r=0|h=0}} {{relation|0|tools=no}} ");                // 編集状況 (往路)\r
 517                         ww.write("|| {{State Route|r=0|h=0}} {{relation|0|tools=no}} ");                // 編集状況 (復路)\r
 518                         ww.write("|| ");                // 備考\r
 519                         ww.newLine();\r
 520 \r
 521 \r
 522                         // OSM file header\r
 523                         ow = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(osmFile), "UTF-8"));\r
 524                         ow.write("<?xml version=\"1.0\" encoding=\"UTF-8\" ?>");\r
 525                         ow.newLine();\r
 526                         ow.write("<osm version=\"0.6\" generator=\"ConvBusstop\">");\r
 527                         ow.newLine();\r
 528 \r
 529                         // GPX file header\r
 530                         gw = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(gpxFile), "UTF-8"));\r
 531                         gw.write("<?xml version=\"1.0\" encoding=\"UTF-8\" ?>");\r
 532                         gw.newLine();\r
 533                         gw.write("<gpx xmlns=\"http://www.topografix.com/GPX/1/1\" version=\"1.1\" creator=\"osmtracker-android\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xsi:schemaLocation=\"http://www.topografix.com/GPX/1/1 http://www.topografix.com/GPX/1/1/gpx.xsd \">");\r
 534                         gw.newLine();\r
 535 \r
 536                         double maxLat = -180.0;\r
 537                         double minLat = 180.0;\r
 538                         double maxLon = -180.0;\r
 539                         double minLon = 180.0;\r
 540 \r
 541                         ps9.setInt(1, code);\r
 542                         ResultSet rset9 = ps9.executeQuery();\r
 543                         while (rset9.next()) {\r
 544                                 String idref = rset9.getString(1);\r
 545 \r
 546                                 ps8.setString(1, idref);\r
 547                                 ResultSet rset8 = ps8.executeQuery();\r
 548                                 if (rset8.next()) {\r
 549                                         stopCount++;\r
 550                                         String name = rset8.getString(1);\r
 551                                         Double lat = rset8.getDouble(2);\r
 552                                         Double lon = rset8.getDouble(3);\r
 553                                         int fixed = rset8.getInt(4);\r
 554 \r
 555                                         if (lat > maxLat) {\r
 556                                                 maxLat = lat;\r
 557                                         }\r
 558                                         if (lon > maxLon) {\r
 559                                                 maxLon = lon;\r
 560                                         }\r
 561                                         if (lat < minLat) {\r
 562                                                 minLat = lat;\r
 563                                         }\r
 564                                         if (lon < minLon) {\r
 565                                                 minLon = lon;\r
 566                                         }\r
 567                                         \r
 568                                         System.out.println("\tway point = "+ idref +", lat="+ lat +", lon="+ lon +", name="+ name);\r
 569                                         fixedCount += fixed;\r
 570                                         if (fixed == 0) {\r
 571                                                 unfixedCount++;\r
 572 \r
 573                                                 // OSM node\r
 574                                                 int nodeid = Integer.parseInt(idref.substring(1)) * -1;\r
 575                                                 String osm_node = nodeBusstop(nodeid, name, lat, lon, timeStampStr);\r
 576                                                 ow.write(osm_node);\r
 577                                                 ow.newLine();\r
 578 \r
 579                                                 // TEXT node\r
 580                                                 //File txtFile = new File(dir, iCode + idref +".txt");\r
 581                                                 //BufferedWriter gw2 = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(txtFile), "UTF-8"));\r
 582                                                 //gw2.write(osm_node);\r
 583                                                 //gw2.newLine();\r
 584                                                 //gw2.close();\r
 585 \r
 586                                                 // GPX waypoint\r
 587                                                 gw.write("<wpt lat=\""+ lat +"\" lon=\""+ lon +"\">\n");\r
 588                                                 gw.write(" <time>"+ timeStampStr +"Z</time>\n");\r
 589                                                 gw.write(" <name><![CDATA["+ name +"]]></name>\n");\r
 590                                                 //gw.write(" <link href=\""+ txtFile.getName() +"\"><text>"+ idref +"</text></link>\n");\r
 591                                                 gw.write("</wpt>\n");\r
 592                                                 gw.newLine();\r
 593                                         }\r
 594                                 }\r
 595                                 rset8.close();\r
 596                         }\r
 597                         rset9.close();\r
 598 \r
 599                         // INDEX file\r
 600                         hw.write("<td>"+ stopCount +"</td>");\r
 601                         hw.write("<td>"+ unfixedCount +"</td>");\r
 602                         hw.write("<td>"+ fixedCount +"</td>");\r
 603                         hw.write("</tr>");\r
 604                         hw.newLine();\r
 605 \r
 606                         // OSM file header\r
 607                         BufferedWriter ow2 = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(osmSample), "UTF-8"));\r
 608                         ow2.write("<?xml version=\"1.0\" encoding=\"UTF-8\" ?>");\r
 609                         ow2.newLine();\r
 610                         ow2.write("<osm version=\"0.5\" generator=\"ConvBusstop\">");\r
 611                         ow2.newLine();\r
 612 \r
 613                         ow2.write(nodeBusstop(code, "SAMPLE", ((maxLat+minLat)/2), ((maxLon+minLon)/2), timeStampStr));\r
 614                         ow2.newLine();\r
 615                         ow2.write("</osm>");\r
 616                         ow2.newLine();\r
 617                         ow2.close();\r
 618 \r
 619                         // OSM file footer\r
 620                         ow.write("</osm>");\r
 621                         ow.newLine();\r
 622                         ow.close();\r
 623 \r
 624                         // GPX file footer\r
 625                         gw.write("</gpx>");\r
 626                         gw.newLine();\r
 627                         gw.close();\r
 628                 }\r
 629                 rset7.close();\r
 630 \r
 631                 // Wiki footer\r
 632                 ww.close();\r
 633 \r
 634                 // index file footer\r
 635                 hw.write("</table></body></html>");\r
 636                 hw.newLine();\r
 637                 hw.close();\r
 638         }\r
 639 \r
 640         public static int outputDb(Connection con) throws IOException, SQLException {\r
 641                 File osmFile = new File("busstop.osm");\r
 642                 int counter = 0;\r
 643 \r
 644                 SimpleDateFormat timeStampFmt = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss'Z'");\r
 645                 String timeStampStr = timeStampFmt.format(new Date(Calendar.getInstance().getTimeInMillis()));\r
 646                 BufferedWriter ow = null;\r
 647                 \r
 648                 // OSM file header\r
 649                 ow = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(osmFile), "UTF-8"));\r
 650                 ow.write("<?xml version=\"1.0\" encoding=\"UTF-8\" ?>");\r
 651                 ow.newLine();\r
 652                 ow.write("<osm version=\"0.6\" generator=\"ConvBusstop\">");\r
 653                 ow.newLine();\r
 654                 \r
 655                 PreparedStatement ps8 = con.prepareStatement("SELECT idref,name,lat,lon,fixed FROM bus_stop");\r
 656                 ResultSet rset8 = ps8.executeQuery();\r
 657                 while (rset8.next()) {\r
 658                         String idref = rset8.getString("idref");\r
 659                         String name = rset8.getString("name");\r
 660                         Double lat = rset8.getDouble("lat");\r
 661                         Double lon = rset8.getDouble("lon");\r
 662                         int fixed = rset8.getInt("fixed");\r
 663                         \r
 664                         if (ConvBusstop.nocheck || (fixed < 1)) {\r
 665                                 // OSM node\r
 666                                 counter++;\r
 667                                 int nodeid = Integer.parseInt(idref.substring(1)) * -1;\r
 668                                 String osm_node = nodeBusstop(nodeid, name, lat, lon, timeStampStr);\r
 669                                 System.out.println(osm_node);\r
 670                                 ow.write(osm_node);\r
 671                                 ow.newLine();\r
 672                         }\r
 673                 }\r
 674                 rset8.close();\r
 675 \r
 676                 // OSM file footer\r
 677                 ow.write("</osm>");\r
 678                 ow.newLine();\r
 679                 ow.close();\r
 680                 return counter;\r
 681         }\r
 682         \r
 683         public static String nodeBusstop(int code, String name, Double lat, Double lon, String timeStampStr) {\r
 684                 String osm_node = ("<node id=\""+ code +"\" timestamp=\""+ timeStampStr +"Z\" lat=\""+ lat +"\" lon=\""+ lon +"\">\n");\r
 685                 osm_node += "<tag k=\"name\" v=\""+ name +"\"/>\n";\r
 686                 osm_node += "<tag k=\"fixme\" v=\"platform/stop_positionを選択して、正しい位置に移動させてください\"/>\n";\r
 687                 osm_node += "<tag k=\"source\" v=\"KSJ2\"/>\n";\r
 688                 osm_node += "<tag k=\"source_ref\" v=\"http://nlftp.mlit.go.jp/ksj/gml/datalist/KsjTmplt-P11.html\"/>\n";\r
 689                 osm_node += "<tag k=\"created_by\" v=\"National-Land-Numerical-Information_MLIT_Japan\"/>\n";\r
 690                 osm_node += "<tag k=\"note\" v=\"National-Land Numerical Information (Bus stop) 2012, MLIT Japan\"/>\n";\r
 691                 osm_node += "<tag k=\"note:ja\" v=\"国土数値情報（バス停留所）平成２４年　国土交通省\"/>\n";\r
 692                 osm_node += "<tag k=\"public_transport\" v=\"platform\"/>\n";\r
 693                 osm_node += "<tag k=\"public_transport\" v=\"stop_position\"/>\n";\r
 694                 osm_node += "<tag k=\"highway\" v=\"bus_stop\"/>\n";\r
 695                 osm_node += "<tag k=\"bus\" v=\"yes\"/>\n";\r
 696                 osm_node += "</node>\n";\r
 697                 return osm_node;\r
 698         }\r
 699 \r
 700         /**\r
 701          *\r
 702          * @param con\r
 703          * @param node\r
 704          * @param iFileName             // ソースファイル名（拡張子を含まない）\r
 705          * @param timeStampStr\r
 706          * @return\r
 707          * @throws IOException\r
 708          * @throws SQLException\r
 709          */\r
 710         public static int showNodes(Connection con, Node node, String iFileName, String timeStampStr) throws IOException, SQLException {\r
 711                 int iCounter = 0;\r
 712                 NamedNodeMap nodeMap = node.getAttributes();\r
 713                 if ( null != nodeMap ) {\r
 714                         for ( int j=0; j < nodeMap.getLength(); j++ ) {\r
 715                                 if (nodeMap.item(j).getNodeName().equals("timeStamp")) {\r
 716                                         timeStampStr = nodeMap.item(j).getNodeValue();\r
 717                                 }\r
 718                         }\r
 719                 }\r
 720 \r
 721                 NodeList nodes = node.getChildNodes();\r
 722                 for (int i=0; i<nodes.getLength(); i++) {\r
 723                         Node node2 = nodes.item(i);\r
 724                         if (node2.getNodeName().equals("jps:GM_Point")) {\r
 725                                 showGmPoint(con, node2);\r
 726                         }\r
 727                         else if (node2.getNodeName().equals("gml:Point")) {\r
 728                                 showGmlPoint(con, node2);\r
 729                         }\r
 730 \r
 731                         else if (node2.getNodeName().equals("ksj:ED01")) {\r
 732                                 iCounter++;\r
 733                                 showED01(con, node2, iFileName);\r
 734                         }\r
 735                         else if (node2.getNodeName().equals("ksj:BusStop")) {\r
 736                                 iCounter++;\r
 737                                 showBusStop(con, node2, iFileName);\r
 738                         }\r
 739 \r
 740                         else {\r
 741                                 iCounter += showNodes(con, node2, iFileName, timeStampStr);\r
 742                         }\r
 743                 }\r
 744                 return iCounter;\r
 745         }\r
 746 \r
 747         /**\r
 748          *\r
 749          * @param con\r
 750          * @param node\r
 751          * @param iFileName             // ソースファイル名（拡張子を含まない）\r
 752          * @throws IOException\r
 753          * @throws SQLException\r
 754          */\r
 755         public static void showED01(Connection con, Node node, String iFileName) throws IOException, SQLException {\r
 756                 String idrefStr = "";\r
 757                 String nameStr = "";\r
 758                 PreparedStatement ps1 = con.prepareStatement("SELECT idref FROM bus_stop WHERE idref=?");\r
 759                 PreparedStatement ps2 = con.prepareStatement("INSERT INTO bus_stop (idref,name,ifile) VALUES (?,?,?)");\r
 760                 PreparedStatement ps3 = con.prepareStatement("SELECT code FROM bus_course WHERE course=? AND corp=? AND ifile=?");\r
 761                 PreparedStatement ps4 = con.prepareStatement("INSERT INTO bus_course (code,type,corp,course,ifile) VALUES (?,?,?,?,?)");\r
 762                 PreparedStatement ps5 = con.prepareStatement("INSERT INTO bus_ref (idref,code) VALUES (?,?)");\r
 763                 PreparedStatement ps6 = con.prepareStatement("SELECT max(code) FROM bus_course WHERE ifile=?");\r
 764 \r
 765                 ArrayList<String[]> bris = new ArrayList<String[]>();\r
 766                 NodeList nodes = node.getChildNodes();\r
 767                 for (int i=0; i < nodes.getLength(); i++) {\r
 768                         Node node2 = nodes.item(i);\r
 769                         if (node2.getNodeName().equals("ksj:POS")) {\r
 770                                 NamedNodeMap nodeMap = node2.getAttributes();\r
 771                                 if (null != nodeMap) {\r
 772                                         for ( int j=0; j < nodeMap.getLength(); j++ ) {\r
 773                                                 if (nodeMap.item(j).getNodeName().equals("idref")) {\r
 774                                                         idrefStr = nodeMap.item(j).getNodeValue();\r
 775                                                         System.out.println("found idref='"+ idrefStr +"'");\r
 776                                                         break;\r
 777                                                 }\r
 778                                         }\r
 779                                 }\r
 780                         }\r
 781                         else if (node2.getNodeName().equals("ksj:BSN")) {\r
 782                                 nameStr = node2.getTextContent();\r
 783                         }\r
 784                         else if (node2.getNodeName().equals("ksj:BRI")) {\r
 785                                 String[] rtn = anaComm(node2);\r
 786                                 if (rtn != null) {\r
 787                                         bris.add(rtn);\r
 788                                 }\r
 789                         }\r
 790                 }\r
 791 \r
 792                 // idref と nameStr をデータベースに格納する\r
 793                 boolean insert = true;\r
 794                 ps1.setString(1, idrefStr);\r
 795                 ResultSet rset = ps1.executeQuery();\r
 796                 if (rset.next()) {\r
 797                         insert = false;\r
 798                 }\r
 799                 rset.close();\r
 800 \r
 801                 if (insert) {\r
 802                         ps2.setString(1, idrefStr);\r
 803                         ps2.setString(2, nameStr);\r
 804                         ps2.setString(3, iFileName);\r
 805                         System.out.println("INSERT INTO bus_stop (idref,name,ifile) VALUES ('"+ idrefStr +"','"+ nameStr +"','"+ iFileName +"')");\r
 806                         ps2.executeUpdate();\r
 807                 }\r
 808 \r
 809                 for (String[] rtn : bris) {\r
 810                         int code = 0;\r
 811                         ps3.setString(1, rtn[1]);\r
 812                         ps3.setString(2, rtn[2]);\r
 813                         ps3.setString(3, iFileName);\r
 814                         rset = ps3.executeQuery();\r
 815                         if (rset.next()) {\r
 816                                 code = rset.getInt(1);\r
 817                         }\r
 818                         rset.close();\r
 819 \r
 820                         if (code == 0) {\r
 821                                 ps6.setString(1, iFileName);\r
 822                                 ResultSet rset6 = ps6.executeQuery();\r
 823                                 if (rset6.next()) {\r
 824                                         code = rset6.getInt(1);\r
 825                                 }\r
 826                                 rset6.close();\r
 827                                 code++;\r
 828 \r
 829                                 System.out.println("code="+code);\r
 830                                 ps4.setInt(1, code);\r
 831                                 ps4.setInt(2, Integer.parseInt(rtn[0]));\r
 832                                 ps4.setString(3, rtn[2]);\r
 833                                 ps4.setString(4, rtn[1]);\r
 834                                 ps4.setString(5, iFileName);\r
 835                                 ps4.executeUpdate();\r
 836                         }\r
 837 \r
 838                         ps5.setString(1, idrefStr);\r
 839                         ps5.setInt(2, code);\r
 840                         ps5.executeUpdate();\r
 841                 }\r
 842 \r
 843                 ps1.close();\r
 844                 ps2.close();\r
 845                 ps3.close();\r
 846                 ps4.close();\r
 847                 ps5.close();\r
 848         }\r
 849 \r
 850         /**\r
 851          * <ksj:BusStop gml:id="ED01_1">\r
 852          *      <ksj:position xlink:href="#n1"/>\r
 853          *      <ksj:busStopName>城堀</ksj:busStopName>\r
 854          *      <ksj:busRouteInformation>\r
 855          *              <ksj:BusRouteInformation>\r
 856          *                      <ksj:busType>1</ksj:busType>\r
 857          *                      <ksj:busOperationCompany>箱根登山バス</ksj:busOperationCompany>\r
 858          *                      <ksj:busLineName>小01</ksj:busLineName>\r
 859          *              </ksj:BusRouteInformation>\r
 860          *      </ksj:busRouteInformation>\r
 861          *      <ksj:busRouteInformation>\r
 862          *              <ksj:BusRouteInformation>\r
 863          *                      <ksj:busType>1</ksj:busType>\r
 864          *                      <ksj:busOperationCompany>箱根登山バス</ksj:busOperationCompany>\r
 865          *                      <ksj:busLineName>湯07</ksj:busLineName>\r
 866          *              </ksj:BusRouteInformation>\r
 867          *      </ksj:busRouteInformation>\r
 868          *      <ksj:busRouteInformation>\r
 869          *              <ksj:BusRouteInformation>\r
 870          *                      <ksj:busType>1</ksj:busType>\r
 871          *                      <ksj:busOperationCompany>箱根登山バス</ksj:busOperationCompany>\r
 872          *                      <ksj:busLineName>湯11</ksj:busLineName>\r
 873          *              </ksj:BusRouteInformation>\r
 874          *      </ksj:busRouteInformation>\r
 875          * </ksj:BusStop>\r
 876          *\r
 877          * @param con\r
 878          * @param node\r
 879          * @param iFileName             // ソースファイル名（拡張子を含まない）\r
 880          * @throws IOException\r
 881          * @throws SQLException\r
 882          */\r
 883         public static void showBusStop(Connection con, Node node, String iFileName) throws IOException, SQLException {\r
 884                 String idrefStr = "";\r
 885                 String nameStr = "";\r
 886                 PreparedStatement ps2 = con.prepareStatement("UPDATE bus_stop SET name=?,ifile=? WHERE idref=?");\r
 887                 PreparedStatement ps3 = con.prepareStatement("SELECT code FROM bus_course WHERE course=? AND corp=? AND ifile=?");\r
 888                 PreparedStatement ps4 = con.prepareStatement("INSERT INTO bus_course (code,type,corp,course,ifile) VALUES (?,?,?,?,?)");\r
 889                 PreparedStatement ps5 = con.prepareStatement("INSERT INTO bus_ref (idref,code) VALUES (?,?)");\r
 890                 PreparedStatement ps6 = con.prepareStatement("SELECT max(code) FROM bus_course WHERE ifile=?");\r
 891 \r
 892                 ArrayList<String[]> bris = new ArrayList<String[]>();\r
 893                 NodeList nodes = node.getChildNodes();\r
 894                 for (int i=0; i < nodes.getLength(); i++) {\r
 895                         Node node2 = nodes.item(i);\r
 896                         if (node2.getNodeName().equals("ksj:position")) {\r
 897                                 NamedNodeMap nodeMap = node2.getAttributes();\r
 898                                 if (null != nodeMap) {\r
 899                                         for ( int j=0; j < nodeMap.getLength(); j++ ) {\r
 900                                                 if (nodeMap.item(j).getNodeName().equals("xlink:href")) {\r
 901                                                         idrefStr = nodeMap.item(j).getNodeValue();\r
 902                                                         idrefStr = idrefStr.substring(1);\r
 903                                                         System.out.println("found idref='"+ idrefStr +"'");\r
 904                                                         break;\r
 905                                                 }\r
 906                                         }\r
 907                                 }\r
 908                         }\r
 909                         else if (node2.getNodeName().equals("ksj:busStopName")) {\r
 910                                 nameStr = node2.getTextContent();\r
 911                         }\r
 912                         else if (node2.getNodeName().equals("ksj:busRouteInformation")) {\r
 913                                 String[] rtn = anaCommJGD(node2);\r
 914                                 if (rtn != null) {\r
 915                                         bris.add(rtn);\r
 916                                 }\r
 917                         }\r
 918                 }\r
 919 \r
 920                 // idref と nameStr をデータベースに格納する\r
 921                 ps2.setString(1, nameStr);\r
 922                 ps2.setString(2, iFileName);\r
 923                 ps2.setString(3, idrefStr);\r
 924                 ps2.executeUpdate();\r
 925 \r
 926                 for (String[] rtn : bris) {\r
 927                         int code = 0;\r
 928                         ps3.setString(1, rtn[1]);\r
 929                         ps3.setString(2, rtn[2]);\r
 930                         ps3.setString(3, iFileName);\r
 931                         ResultSet rset = ps3.executeQuery();\r
 932                         if (rset.next()) {\r
 933                                 code = rset.getInt(1);\r
 934                         }\r
 935                         rset.close();\r
 936 \r
 937                         if (code == 0) {\r
 938                                 ps6.setString(1, iFileName);\r
 939                                 ResultSet rset6 = ps6.executeQuery();\r
 940                                 if (rset6.next()) {\r
 941                                         code = rset6.getInt(1);\r
 942                                 }\r
 943                                 rset6.close();\r
 944                                 code++;\r
 945 \r
 946                                 System.out.println("course="+ code +" : "+ rtn[0] +" : "+ rtn[1] +" : "+ rtn[2] );\r
 947                                 ps4.setInt(1, code);\r
 948                                 ps4.setInt(2, Integer.parseInt(rtn[0]));\r
 949                                 ps4.setString(3, rtn[2]);\r
 950                                 ps4.setString(4, rtn[1]);\r
 951                                 ps4.setString(5, iFileName);\r
 952                                 ps4.executeUpdate();\r
 953                         }\r
 954 \r
 955                         ps5.setString(1, idrefStr);\r
 956                         ps5.setInt(2, code);\r
 957                         ps5.executeUpdate();\r
 958                 }\r
 959 \r
 960                 ps2.close();\r
 961                 ps3.close();\r
 962                 ps4.close();\r
 963                 ps5.close();\r
 964         }\r
 965 \r
 966         public static String[] anaComm(Node briNode) {\r
 967                 String[] rtn = new String[3];\r
 968                 rtn[0] = "";    // corp type\r
 969                 rtn[1] = "";    // course name\r
 970                 rtn[2] = "";    // corp name\r
 971 \r
 972                 NodeList nodes = briNode.getChildNodes();\r
 973                 for (int i=0; i < nodes.getLength(); i++) {\r
 974                         Node node2 = nodes.item(i);\r
 975                         if (node2.getNodeName().equals("ksj:BSC")) {\r
 976                                 rtn[0] = node2.getTextContent();\r
 977                         }\r
 978                         else if (node2.getNodeName().equals("ksj:BLN")) {\r
 979                                 rtn[1] = node2.getTextContent();\r
 980                         }\r
 981                         else if (node2.getNodeName().equals("ksj:BOC")) {\r
 982                                 rtn[2] = node2.getTextContent();\r
 983                         }\r
 984                 }\r
 985                 return rtn;\r
 986         }\r
 987 \r
 988         /**\r
 989          *\r
 990          *      <ksj:busRouteInformation>\r
 991          *              <ksj:BusRouteInformation>\r
 992          *                      <ksj:busType>1</ksj:busType>\r
 993          *                      <ksj:busOperationCompany>箱根登山バス</ksj:busOperationCompany>\r
 994          *                      <ksj:busLineName>小01</ksj:busLineName>\r
 995          *              </ksj:BusRouteInformation>\r
 996          *      </ksj:busRouteInformation>\r
 997          *\r
 998          * @param briNode\r
 999          * @return\r
1000          */\r
1001         public static String[] anaCommJGD(Node briNode) {\r
1002                 String[] rtn = new String[3];\r
1003                 int vcnt = 0;\r
1004 \r
1005                 NodeList nodes2 = briNode.getChildNodes();\r
1006                 for (int i=0; i < nodes2.getLength(); i++) {\r
1007                         Node node2 = nodes2.item(i);\r
1008                         if (node2.getNodeName().equals("ksj:BusRouteInformation")) {\r
1009                                 NodeList nodes3 = node2.getChildNodes();\r
1010                                 for (int j=0; j < nodes3.getLength(); j++) {\r
1011                                         Node node3 = nodes3.item(j);\r
1012                                         if (node3.getNodeName().equals("ksj:busType")) {\r
1013                                                 rtn[0] = new String(node3.getTextContent());\r
1014                                                 vcnt++;\r
1015                                         }\r
1016                                         else if (node3.getNodeName().equals("ksj:busLineName")) {\r
1017                                                 rtn[1] = new String(node3.getTextContent());\r
1018                                                 vcnt++;\r
1019                                         }\r
1020                                         else if (node3.getNodeName().equals("ksj:busOperationCompany")) {\r
1021                                                 rtn[2] = new String(node3.getTextContent());\r
1022                                                 vcnt++;\r
1023                                         }\r
1024                                 }\r
1025                         }\r
1026                 }\r
1027 \r
1028                 if (vcnt > 0) {\r
1029                         return rtn;\r
1030                 }\r
1031                 return null;\r
1032         }\r
1033 \r
1034         public static void showGmPoint(Connection con, Node node) throws IOException, SQLException {\r
1035                 String positionStr = "";\r
1036                 String latStr = "";\r
1037                 String lonStr = "";\r
1038                 String idStr = "";\r
1039 \r
1040                 NamedNodeMap nodeMap = node.getAttributes();\r
1041                 if ( null != nodeMap ) {\r
1042                         for ( int j=0; j<nodeMap.getLength(); j++ ) {\r
1043                                 if (nodeMap.item(j).getNodeName().equals("id")) {\r
1044                                         idStr = nodeMap.item(j).getNodeValue();\r
1045                                 }\r
1046                         }\r
1047                 }\r
1048 \r
1049                 NodeList nodes = node.getChildNodes();\r
1050                 for (int i=0; i < nodes.getLength(); i++) {\r
1051                         Node node2 = nodes.item(i);\r
1052                         if (node2.getNodeName().equals("jps:GM_Point.position")) {\r
1053                                 NodeList nodes3 = node2.getChildNodes();\r
1054                                 for (int j=0; j < nodes3.getLength(); j++) {\r
1055                                         Node node3 = nodes3.item(j);\r
1056                                         if (node3.getNodeName().equals("jps:DirectPosition")) {\r
1057                                                 NodeList nodes4 = node3.getChildNodes();\r
1058                                                 for (int k=0; k < nodes4.getLength(); k++) {\r
1059                                                         Node node4 = nodes4.item(k);\r
1060                                                         if (node4.getNodeName().equals("DirectPosition.coordinate")) {\r
1061                                                                 positionStr = node4.getTextContent();\r
1062                                                                 String[] str4Ary = positionStr.split(" ");\r
1063                                                                 latStr = str4Ary[0];\r
1064                                                                 lonStr = str4Ary[1];\r
1065                                                                 break;\r
1066                                                         }\r
1067                                                 }\r
1068                                                 break;\r
1069                                         }\r
1070                                 }\r
1071 \r
1072                                 PreparedStatement ps6 = con.prepareStatement("UPDATE bus_stop SET lat=?,lon=?,fixed=? WHERE idref=?");\r
1073                                 double lat = Double.parseDouble(latStr);\r
1074                                 double lon = Double.parseDouble(lonStr);\r
1075                                 ps6.setDouble(1, lat);\r
1076                                 ps6.setDouble(2, lon);\r
1077                                 // ps6.setInt(3, (ConvBusstop.nocheck ? 0 : HttpGET.getMap(lat, lon, NEER)));\r
1078                                 ps6.setInt(3, 0);\r
1079                                 ps6.setString(4, idStr);\r
1080                                 System.out.println("UPDATE bus_stop("+ idStr +") lat="+ lat +", lon="+ lon +", fixed=0");\r
1081                                 ps6.executeUpdate();\r
1082                                 ps6.close();\r
1083                         }\r
1084                 }\r
1085         }\r
1086 \r
1087         /**\r
1088          * <gml:Point gml:id="n1">\r
1089          *      <gml:pos>35.14591397 139.10569573</gml:pos>\r
1090          * </gml:Point>\r
1091          *\r
1092          * @param con\r
1093          * @param node\r
1094          * @throws IOException\r
1095          * @throws SQLException\r
1096          */\r
1097         public static void showGmlPoint(Connection con, Node node) throws IOException, SQLException {\r
1098                 String positionStr = "";\r
1099                 String latStr = "";\r
1100                 String lonStr = "";\r
1101                 String idStr = "";\r
1102 \r
1103                 NamedNodeMap nodeMap = node.getAttributes();\r
1104                 if ( null != nodeMap ) {\r
1105                         for ( int j=0; j<nodeMap.getLength(); j++ ) {\r
1106                                 if (nodeMap.item(j).getNodeName().equals("gml:id")) {\r
1107                                         idStr = nodeMap.item(j).getNodeValue();\r
1108                                 }\r
1109                         }\r
1110                 }\r
1111 \r
1112                 NodeList nodes = node.getChildNodes();\r
1113                 for (int i=0; i < nodes.getLength(); i++) {\r
1114                         Node node2 = nodes.item(i);\r
1115                         if (node2.getNodeName().equals("gml:pos")) {\r
1116                                 positionStr = node2.getTextContent().trim();\r
1117                                 String[] str4Ary = positionStr.split(" ");\r
1118                                 latStr = str4Ary[0];\r
1119                                 lonStr = str4Ary[1];\r
1120                                 \r
1121                                 PreparedStatement ps6 = con.prepareStatement("INSERT INTO bus_stop (lat,lon,fixed,idref) VALUES (?,?,?,?)");\r
1122                                 double lat = Double.parseDouble(latStr);\r
1123                                 double lon = Double.parseDouble(lonStr);\r
1124                                 System.out.println("INSERT INTO bus_stop (lat,lon,fixed,idref) VALUES ('"+ latStr +"','"+ lonStr +"','0','"+ idStr +"')");\r
1125 \r
1126                                 ps6.setDouble(1, lat);\r
1127                                 ps6.setDouble(2, lon);\r
1128                                 //ps6.setInt(3, (ConvBusstop.nocheck ? 0 : HttpGET.getMap(lat, lon, NEER)));\r
1129                                 ps6.setInt(3, 0);\r
1130                                 ps6.setString(4, idStr);\r
1131                                 ps6.executeUpdate();\r
1132                                 ps6.close();\r
1133                         }\r
1134                 }\r
1135         }\r
1136 \r
1137         static boolean checkFile(File f) {\r
1138                 String name = f.getName();\r
1139                 if (!name.startsWith("P11-")) {\r
1140                         return false;\r
1141                 }\r
1142                 if (!name.toUpperCase().endsWith(".XML")) {\r
1143                         return false;\r
1144                 }\r
1145                 return true;\r
1146         }\r
1147 }