Skip to content

蒋波涛 / tianditudownloader

Go to a project
Toggle navigation
Toggle navigation pinning
2d4330ad by chiangbt
Options

first commit

0 parents
Expand all
Inline Side-by-side
Showing 22 changed files with 434 additions and 0 deletions
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="CompilerConfiguration">
<option name="DEFAULT_COMPILER" value="Javac" />
<resourceExtensions />
<wildcardResourcePatterns>
<entry name="!?*.java" />
<entry name="!?*.form" />
<entry name="!?*.class" />
<entry name="!?*.groovy" />
<entry name="!?*.scala" />
<entry name="!?*.flex" />
<entry name="!?*.kt" />
<entry name="!?*.clj" />
</wildcardResourcePatterns>
<annotationProcessing>
<profile default="true" name="Default" enabled="false">
<processorPath useClasspath="true" />
</profile>
</annotationProcessing>
</component>
</project>
<html>Simple <b>Java</b> application that includes a class with <code>main()</code> method</html>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Encoding" useUTFGuessing="true" native2AsciiForPropertiesFiles="false" />
</project>
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="EntryPointsManager">
<entry_points version="2.0" />
</component>
<component name="ProjectKey">
<option name="state" value="project://63537948-39a4-48a0-9c97-34259a0fa913" />
</component>
<component name="ProjectRootManager" version="2" languageLevel="JDK_1_8" project-jdk-name="1.8" project-jdk-type="JavaSDK">
<output url="file://$PROJECT_DIR$/out" />
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ProjectModuleManager">
<modules>
<module fileurl="file://$PROJECT_DIR$/TiandituDownloader.iml" filepath="$PROJECT_DIR$/TiandituDownloader.iml" />
</modules>
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="VcsDirectoryMappings">
<mapping directory="" vcs="" />
</component>
</project>
<?xml version="1.0" encoding="UTF-8"?>
<module type="JAVA_MODULE" version="4">
<component name="NewModuleRootManager" inherit-compiler-output="true">
<exclude-output />
<content url="file://$MODULE_DIR$">
<sourceFolder url="file://$MODULE_DIR$/src" isTestSource="false" />
</content>
<orderEntry type="inheritedJdk" />
<orderEntry type="sourceFolder" forTests="false" />
<orderEntry type="module-library">
<library>
<CLASSES>
<root url="jar://$USER_HOME$/Downloads/sqlite-jdbc-3.21.0-2.jar!/" />
</CLASSES>
<JAVADOC />
<SOURCES />
</library>
</orderEntry>
</component>
</module>
\ No newline at end of file
No preview for this file type
No preview for this file type
No preview for this file type
No preview for this file type
No preview for this file type
public class CalEnv {
private int startX;
private int startY;
public CalEnv(int startX, int startY) {
this.startX = startX;
this.startY = startY;
}
public int getStartX() {
return startX;
}
public void setStartX(int startX) {
this.startX = startX;
}
public int getStartY() {
return startY;
}
public void setStartY(int startY) {
this.startY = startY;
}
}
import java.sql.SQLException;
public class Main {
public static void main(String[] args) throws SQLException {
System.out.println("Hello World!");
TiandituDownload tiandituDownload = new TiandituDownload("my.db");
Point pt = new Point(29.76,106.64);
Point pt2 = new Point(35.33, 108.12);
// tiandituDownload.Download(pt, pt2, 9, TianDiTuTiledMapServiceType.IMG_C);
tiandituDownload.Download(pt, pt2, 2,9, TianDiTuTiledMapServiceType.IMG_C);
}
}
public class Point {
private double lat;
private double lng;
public Point(){
}
public Point(double lat, double lng){
this.lat = lat;
this.lng = lng;
}
public double getLat() {
return lat;
}
public void setLat(double lat) {
this.lat = lat;
}
public double getLng() {
return lng;
}
public void setLng(double lng) {
this.lng = lng;
}
}
import java.util.Random;
/**
* Created by jiangbotao on 2018/3/23.
*/
public class TDTUrl {
private TianDiTuTiledMapServiceType _tiandituMapServiceType;
private int _level;
private int _col;
private int _row;
public TDTUrl(int level, int col, int row, TianDiTuTiledMapServiceType tiandituMapServiceType) {
this._level = level;
this._col = col;
this._row = row;
this._tiandituMapServiceType = tiandituMapServiceType;
}
public String generatUrl() {
StringBuilder url = new StringBuilder("http://t");
Random random = new Random();
int subdomain = (random.nextInt(6) + 1);
url.append(subdomain);
switch (this._tiandituMapServiceType) {
case VEC_C:
url.append(".tianditu.com/DataServer?T=vec_c&X=").append(this._col).append("&Y=").append(this._row).append("&L=").append(this._level);
break;
case CVA_C:
url.append(".tianditu.com/DataServer?T=cva_c&X=").append(this._col).append("&Y=").append(this._row).append("&L=").append(this._level);
break;
case CIA_C:
url.append(".tianditu.com/DataServer?T=cia_c&X=").append(this._col).append("&Y=").append(this._row).append("&L=").append(this._level);
break;
case IMG_C:
url.append(".tianditu.com/DataServer?T=img_c&X=").append(this._col).append("&Y=").append(this._row).append("&L=").append(this._level);
break;
case VEC_W:
url.append(".tianditu.com/DataServer?T=vec_w&X=").append(this._col).append("&Y=").append(this._row).append("&L=").append(this._level);
break;
case CVA_W:
url.append(".tianditu.com/DataServer?T=cva_w&X=").append(this._col).append("&Y=").append(this._row).append("&L=").append(this._level);
break;
case CIA_W:
url.append(".tianditu.com/DataServer?T=cia_w&X=").append(this._col).append("&Y=").append(this._row).append("&L=").append(this._level);
break;
case IMG_W:
url.append(".tianditu.com/DataServer?T=img_w&X=").append(this._col).append("&Y=").append(this._row).append("&L=").append(this._level);
break;
default:
return null;
}
return url.toString();
}
}
/**
* Created by jiangbotao on 2018/3/23.
*/
public enum TianDiTuTiledMapServiceType {
/**
* 矢量数据,CGCS2000
* */
VEC_C,
/**
* 影像数据
* */
IMG_C,
/**
* 矢量注记
* */
CVA_C,
/**
* 影像注记
* */
CIA_C,
/**
* 矢量数据，web墨卡托4326
*/
VEC_W,
/**
* 影像数据
* */
IMG_W,
/**
* 矢量注记
* */
CVA_W,
/**
* 影像注记
* */
CIA_W;
}
import java.io.BufferedInputStream;
import java.io.ByteArrayOutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.sql.*;
public class TiandituDownload {
double[] res = {
1.40625,
0.703125,
0.3515625,
0.17578125,
0.087890625,
0.0439453125,
0.02197265625,
0.010986328125,
0.0054931640625,
0.00274658203125,
0.001373291015625,
0.0006866455078125,
0.00034332275390625,
0.000171661376953125,
8.58306884765629E-05,
4.29153442382814E-05,
2.14576721191407E-05,
1.07288360595703E-05,
5.36441802978515E-06,
2.68220901489258E-06,
1.34110450744629E-06
};
double[] scale = {
400000000,
295497598.5708346,
147748799.285417,
73874399.6427087,
36937199.8213544,
18468599.9106772,
9234299.95533859,
4617149.97766929,
2308574.98883465,
1154287.49441732,
577143.747208662,
288571.873604331,
144285.936802165,
72142.9684010827,
36071.4842005414,
18035.7421002707,
9017.87105013534,
4508.93552506767,
2254.467762533835,
1127.2338812669175,
563.616940
};
int minLevel = 1;
int maxLevel = 2;
// 保存数据的sqlite文件路径
String dbpath;
Connection conn = null;
Statement stmt = null;
public TiandituDownload(String dbpath){
this.dbpath =dbpath;
}
private CalEnv calculateEnv(Point originPoint, int level){
int startX = (int) Math.floor((originPoint.getLng() + 180)/(256 * res[level]));
int startY = (int) Math.floor((90 - originPoint.getLat())/(256 * res[level]));
if(startX<0)startX = 0;
if(startY<0)startY = 0;
return new CalEnv(startX, startY);
}
private void Download(Point minPoint, Point maxPoint, int level, TianDiTuTiledMapServiceType type){
try{
CalEnv startEnv = calculateEnv(minPoint, level);
CalEnv stopEnv = calculateEnv(maxPoint, level);
// System.out.println(startEnv.getStartX() + ":" +startEnv.getStartY());
// System.out.println(stopEnv.getStartX() + ":" +stopEnv.getStartY());
PreparedStatement preparedStatement;
ResultSet rs;
for(int i = startEnv.getStartX(); i <= stopEnv.getStartX(); i++){
for(int j = stopEnv.getStartY(); j<= startEnv.getStartY(); j++){
boolean hasData = false;
try{
// 查询瓦片是否存在
String querySQL = "select * from " + type + " where TILELEVEL = " + level + " and TILECOL = " + i + " and TILEROW = " + j;
rs = stmt.executeQuery(querySQL);
while(rs.next()){
hasData = true;
}
// 如果不存在
if(!hasData){
String url = new TDTUrl(level, i, j, type).generatUrl();
// 获得地图瓦片
byte[] img = getTile(url);
System.out.println("正在下载 "+url);
// 将数据写入sqlite
String insertSQL = "INSERT INTO "+ type + "(TILELEVEL,TILECOL,TILEROW,TILEDATA) VALUES (?,?,?,?)";
preparedStatement = conn.prepareStatement(insertSQL);
preparedStatement.setInt(1, level);
preparedStatement.setInt(2, i);
preparedStatement.setInt(3, j);
preparedStatement.setBytes(4, img);
preparedStatement.execute();
}
}catch (Exception e){
System.out.println(e.getMessage());
}
}
conn.commit();
}
}catch (Exception e){
System.out.println(e.getMessage());
}
}
public void Download(Point minPoint, Point maxPoint, int minLevel, int maxLevel, TianDiTuTiledMapServiceType type) throws SQLException {
try {
Class.forName("org.sqlite.JDBC");
conn = DriverManager.getConnection("jdbc:sqlite:" + this.dbpath);
conn.setAutoCommit(false);
stmt = conn.createStatement();
// 新建数据表
String sql = "CREATE TABLE IF NOT EXISTS " + type +
"(TILELEVEL INT," +
"TILECOL INT," +
"TILEROW INT," +
"TILEDATA BLOB)";
stmt.executeUpdate(sql);
stmt.close();
for(int m = minLevel; m<= maxLevel; m++){
this.Download(minPoint, maxPoint, m, type);
}
conn.close();
System.out.println("下载完成");
}catch (Exception e){
}
}
protected byte[] getTile(String url) throws Exception {
byte[] result = null;
try {
// 如果没有就直接从web上读取
ByteArrayOutputStream bos = new ByteArrayOutputStream();
URL sjwurl = new URL(url);
HttpURLConnection httpUrl = null;
BufferedInputStream bis = null;
byte[] buf = new byte[1024];
httpUrl = (HttpURLConnection) sjwurl.openConnection();
httpUrl.connect();
bis = new BufferedInputStream(httpUrl.getInputStream());
while (true) {
int bytes_read = bis.read(buf);
if (bytes_read > 0) {
bos.write(buf, 0, bytes_read);
} else {
break;
}
}
bis.close();
httpUrl.disconnect();
result = bos.toByteArray();
} catch (Exception ex) {
ex.printStackTrace();
}
return result;
}
}