高德地圖---根據經緯度查詢所在城市全部的超市
原文請見於:https://blog.csdn.net/Java_wucao/article/details/77800891 內容部分沒有修改。java
AddressLngLatExchange：git
package dwz.web.gdmap;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.poi.hssf.usermodel.HSSFCell;
import org.apache.poi.hssf.usermodel.HSSFRow;
import org.apache.poi.hssf.usermodel.HSSFSheet;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import dwz.common.util.StringUtils;
import dwz.persistence.beans.gdmap.Shop;
import jxl.Cell;
import jxl.Workbook;
import jxl.read.biff.BiffException;
/**
* @author 做者姓名:cjw
* @version 建立時間：2018年4月19日 下午3:01:28 java 從高德地圖上爬取數據類
*/
public class AddressLngLatExchange {
private static final String KEY = "7ff46e1a64fade07c3cbc5eee118ad1d";
private static final String OUTPUT = "JSON";
private static final String GET_LNG_LAT_URL = "http://restapi.amap.com/v3/geocode/geo";
private static final String GET_LNG_PIO_URL = "http://restapi.amap.com/v3/place/polygon";
private static final Logger LOGGER = LoggerFactory.getLogger(AddressLngLatExchange.class);
// 獲取指定地點經緯度
public static String[] getLngLatFromOneAddr(String address) {
if (StringUtils.isBlank(address)) {
LOGGER.error("地址（" + address + "）爲null或者空");
return null;
}
Map<String, String> params = new HashMap<String, String>();
params.put("address", address);
params.put("output", OUTPUT);
params.put("key", KEY);
String result = HttpUtils.URLPost(GET_LNG_LAT_URL, params, "");
JSONObject jsonObject = JSONObject.parseObject(result);
String[] lngLatArr = new String[2];
// 拿到返回報文的status值，高德的該接口返回值有兩個：0-請求失敗，1-請求成功；
int status = Integer.valueOf(jsonObject.getString("status"));
if (status == 1) {
JSONArray jsonArray = jsonObject.getJSONArray("geocodes");
for (int i = 0; i < jsonArray.size(); i++) {
JSONObject json = jsonArray.getJSONObject(i);
String lngLat = json.getString("location");
lngLatArr = lngLat.split(",");
}
} else {
String errorMsg = jsonObject.getString("info");
LOGGER.error("地址（" + address + "）" + errorMsg);
}
return lngLatArr;
}
public static List<Shop> initialData(String lonLat, String keyword, List<Shop> shopListSon) {
if (StringUtils.isBlank(keyword)) {
LOGGER.error("地址（" + keyword + "）爲null或者空");
}
Map<String, String> params = new HashMap<String, String>();
try {
Thread.sleep(5000);
} catch (InterruptedException e1) {
e1.printStackTrace();
}
params.put("polygon", lonLat);// "118.21,29.11;120.30,30.33"
params.put("output", OUTPUT);
params.put("keywords", keyword);
params.put("offset", "20");
params.put("page", "1");
params.put("key", KEY);
String result = HttpUtils.URLGet(GET_LNG_PIO_URL, params, "UTF-8");
JSONObject jsonObject = JSONObject.parseObject(result);
int statusOne = Integer.valueOf(jsonObject.getString("status"));
// 第一次獲取數據時作的判斷
if (statusOne == 1) {
int count = Integer.valueOf(jsonObject.getString("count"));
int pageNumber = count / 20;
int remainder = count % 20;
if (remainder > 0)
pageNumber = pageNumber + 1;
for (int i = 1; i <= pageNumber; i++) {
params.put("page", String.valueOf(i));
result = HttpUtils.URLGet(GET_LNG_PIO_URL, params, "UTF-8");
JSONObject jsonObject2 = JSONObject.parseObject(result);
System.out.println("+++++++++" + result);
// 拿到返回報文的status值，高德的該接口返回值有兩個：0-請求失敗，1-請求成功；
int status = Integer.valueOf(jsonObject2.getString("status"));
if (status == 1) {
JSONArray jsonArray = jsonObject2.getJSONArray("pois");
if (jsonArray.size() > 0) {
for (int j = 0; j < jsonArray.size(); j++) {
Shop shop = new Shop();
JSONObject jsonObject1 = jsonArray.getJSONObject(j);
shop.setShopName(jsonObject1.getString("name"));
shop.setSpecificAddress(jsonObject1.getString("address"));
shop.setId(jsonObject1.getString("id"));
String[] initLonLat = jsonObject1.getString("location").split(",");
shop.setLongitude(initLonLat[0]);
shop.setLatitude(initLonLat[1]);
shopListSon.add(shop);
// DBObject doci = new BasicDBObject("shopId",
// "300"+i).append("shopName",
// "人生得意"+i).append("shopStatus",0).append("specificAddress","天堂"+i).append("gps",
// new Point(new Position(lon, lat)));
}
}
} else {
String errorMsg = jsonObject.getString("info");
LOGGER.error("地址（" + keyword + "）" + errorMsg);
}
}
}
return shopListSon;
}
// 從高德地圖上取數據
// public static void main(String[] args) {
// List<Shop> listShop =new ArrayList<>();
// //東經118°21′-120°30′，北緯29°11′-30°33′。杭州位置
// for(double i=118.20;i<=120.31;i=i+0.1){
// for(double j=29.10;j<=30.33;j=j+0.1){
// List<Shop> listShopSon =new ArrayList<>();
// double lonHead=i;
// double latHead=j;
// double lonTail=i+0.1;
// double latTail=j+0.1;
// String LonLat=lonHead+","+latHead+";"+lonTail+","+latTail;
// listShopSon =initialData(LonLat,"便利店",listShopSon);
// for(int n=0;n<listShopSon.size();n++){
// System.out.println("店鋪地址："+listShopSon.get(n).getSpecificAddress());
// }
// if(listShopSon.size()>0){
// listShop.addAll(listShopSon);
// }
// System.out.println("ListShop的大小："+listShop.size());
// double d =Distance(lonHead,latHead,lonTail,latTail);
// System.out.println("兩點距離"+d);
//
// }
//
// }
//
// System.out.println("ListShop的大小："+listShop.size());
// creatExcel(listShop);
// }
public static void main(String[] args) {
readFile("D:\\geode\\高德便利店地圖數據.xls");
}
// 寫入excel中
public static void creatExcel(List<Shop> shopList) {
HSSFWorkbook workbook = new HSSFWorkbook();
// 第二部，在workbook中建立一個sheet對應excel中的sheet
HSSFSheet sheet = workbook.createSheet("高德地圖數據");
// 第三部，在sheet表中添加表頭第0行，老版本的poi對sheet的行列有限制
HSSFRow row = sheet.createRow(0);
// 第四步，建立單元格，設置表頭
HSSFCell cell = row.createCell(0);
cell.setCellValue("店鋪id");
cell = row.createCell(1);
cell.setCellValue("店鋪名稱");
cell = row.createCell(2);
cell.setCellValue("店鋪地址");
cell = row.createCell(3);
cell.setCellValue("經度");
cell = row.createCell(4);
cell.setCellValue("緯度");
// 第五步，寫入實體數據，實際應用中這些數據從數據庫獲得,對象封裝數據，集合包對象。對象的屬性值對應表的每行的值
for (int i = 0; i < shopList.size(); i++) {
HSSFRow row1 = sheet.createRow(i + 1);
Shop shop = shopList.get(i);
// 建立單元格設值
row1.createCell(0).setCellValue(shop.getId());
row1.createCell(1).setCellValue(shop.getShopName());
row1.createCell(2).setCellValue(shop.getSpecificAddress());
row1.createCell(3).setCellValue(shop.getLongitude());
row1.createCell(4).setCellValue(shop.getLatitude());
}
// 將文件保存到指定的位置
try {
FileOutputStream fos = new FileOutputStream("D:\\geode\\高德便利店地圖數據.xls");
workbook.write(fos);
System.out.println("寫入成功");
fos.close();
} catch (IOException e) {
e.printStackTrace();
}
}
public static double Distance(double long1, double lat1, double long2, double lat2) {
double a, b, R;
R = 6371; // 地球半徑 6371km
lat1 = lat1 * Math.PI / 180.0;
lat2 = lat2 * Math.PI / 180.0;
a = lat1 - lat2;
b = (long1 - long2) * Math.PI / 180.0;
double d;
double sa2, sb2;
sa2 = Math.sin(a / 2.0);
sb2 = Math.sin(b / 2.0);
d = 2 * R * Math.asin(Math.sqrt(sa2 * sa2 + Math.cos(lat1) * Math.cos(lat2) * sb2 * sb2));
BigDecimal bigDecimal = new BigDecimal(d * 1000);
Double din = bigDecimal.setScale(2, BigDecimal.ROUND_HALF_UP).doubleValue();
return din;
}
public static List<Shop> readFile(String filename) {
List<Shop> shopList = new ArrayList<>();
Workbook wb = null;
Cell cell = null;
try {
File f = new File(filename);
InputStream in = new FileInputStream(f); // 建立輸入流
wb = Workbook.getWorkbook(in); // 獲取Excel文件對象
jxl.Sheet s = wb.getSheet(0); // 獲取文件的指定工做表，默認爲第一個
String value = null;
for (int i = 1; i < s.getRows(); i++) {// 表頭目錄不須要，從第一行開始
Shop shop = new Shop();
for (int j = 0; j < s.getColumns(); j++) {
cell = s.getCell(j, i);
value = cell.getContents();
if (j == 0) {
shop.setId(value);
} else if (j == 1) {
shop.setShopName(value);
} else if (j == 2) {
shop.setSpecificAddress(value);
} else if (j == 3) {
shop.setLongitude(value);
} else if (j == 4) {
shop.setLatitude(value);
}
// System.out.println("value："+value);
}
shopList.add(shop);
}
} catch (FileNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (BiffException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return shopList;
}
}
HttpUtils：web
package dwz.web.gdmap;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.util.Iterator;
import java.util.Map;
import java.util.Set；
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.HttpException;
import org.apache.commons.httpclient.HttpStatus;
import org.apache.commons.httpclient.MultiThreadedHttpConnectionManager;
import org.apache.commons.httpclient.methods.GetMethod;
import org.apache.commons.httpclient.methods.PostMethod;
import com.alibaba.druid.support.logging.Log;
import com.alibaba.druid.support.logging.LogFactory;
/**
* @author 做者姓名:cjw
* @version 建立時間：2018年4月19日 下午3:12:33 類說明
*/
public class HttpUtils {
private static Log log = LogFactory.getLog(HttpUtils.class);
/**
* 定義編碼格式 UTF-8
*/
public static final String URL_PARAM_DECODECHARSET_UTF8 = "UTF-8";
/**
* 定義編碼格式 GBK
*/
public static final String URL_PARAM_DECODECHARSET_GBK = "GBK";
private static final String URL_PARAM_CONNECT_FLAG = "&";
private static final String EMPTY = "";
private static MultiThreadedHttpConnectionManager connectionManager = null;
private static int connectionTimeOut = 25000;
private static int socketTimeOut = 25000;
private static int maxConnectionPerHost = 20;
private static int maxTotalConnections = 20;
private static HttpClient client;
static {
connectionManager = new MultiThreadedHttpConnectionManager();
connectionManager.getParams().setConnectionTimeout(connectionTimeOut);
connectionManager.getParams().setSoTimeout(socketTimeOut);
connectionManager.getParams().setDefaultMaxConnectionsPerHost(maxConnectionPerHost);
connectionManager.getParams().setMaxTotalConnections(maxTotalConnections);
client = new HttpClient(connectionManager);
}
/**
* POST方式提交數據
*
* @param url
* 待請求的URL
* @param params
* 要提交的數據
* @param enc
* 編碼
* @return 響應結果
* @throws IOException
* IO異常
*/
public static String URLPost(String url, Map<String, String> params, String enc) {
enc = URL_PARAM_DECODECHARSET_UTF8;
String response = EMPTY;
PostMethod postMethod = null;
try {
postMethod = new PostMethod(url);
postMethod.setRequestHeader("Content-Type", "application/x-www-form-urlencoded;charset=" + enc);
// 將表單的值放入postMethod中
Set<String> keySet = params.keySet();
for (String key : keySet) {
String value = params.get(key);
postMethod.addParameter(key, value);
}
// 執行postMethod
int statusCode = client.executeMethod(postMethod);
if (statusCode == HttpStatus.SC_OK) {
response = postMethod.getResponseBodyAsString();
} else {
log.error("響應狀態碼 = " + postMethod.getStatusCode());
}
} catch (HttpException e) {
log.error("發生致命的異常，多是協議不對或者返回的內容有問題", e);
e.printStackTrace();
} catch (IOException e) {
log.error("發生網絡異常", e);
e.printStackTrace();
} finally {
if (postMethod != null) {
postMethod.releaseConnection();
postMethod = null;
}
}
return response;
}
/**
* GET方式提交數據
*
* @param url
* 待請求的URL
* @param params
* 要提交的數據
* @param enc
* 編碼
* @return 響應結果
* @throws IOException
* IO異常
*/
public static String URLGet(String url, Map<String, String> params, String enc) {
String response = EMPTY;
GetMethod getMethod = null;
StringBuffer strtTotalURL = new StringBuffer(EMPTY);
if (strtTotalURL.indexOf("?") == -1) {
strtTotalURL.append(url).append("?").append(getUrl(params, enc));
} else {
strtTotalURL.append(url).append("&").append(getUrl(params, enc));
}
log.debug("GET請求URL = \n" + strtTotalURL.toString());
try {
getMethod = new GetMethod(strtTotalURL.toString());
getMethod.setRequestHeader("Content-Type", "application/x-www-form-urlencoded;charset=" + enc);
// 執行getMethod
int statusCode = client.executeMethod(getMethod);
if (statusCode == HttpStatus.SC_OK) {
response = getMethod.getResponseBodyAsString();
} else {
log.debug("響應狀態碼 = " + getMethod.getStatusCode());
}
} catch (HttpException e) {
log.error("發生致命的異常，多是協議不對或者返回的內容有問題", e);
e.printStackTrace();
} catch (IOException e) {
log.error("發生網絡異常", e);
e.printStackTrace();
} finally {
if (getMethod != null) {
getMethod.releaseConnection();
getMethod = null;
}
}
return response;
}
/**
* 據Map生成URL字符串
*
* @param map
* Map
* @param valueEnc
* URL編碼
* @return URL
*/
private static String getUrl(Map<String, String> map, String valueEnc) {
if (null == map || map.keySet().size() == 0) {
return (EMPTY);
}
StringBuffer url = new StringBuffer();
Set<String> keys = map.keySet();
for (Iterator<String> it = keys.iterator(); it.hasNext();) {
String key = it.next();
if (map.containsKey(key)) {
String val = map.get(key);
String str = val != null ? val : EMPTY;
try {
str = URLEncoder.encode(str, valueEnc);
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
url.append(key).append("=").append(str).append(URL_PARAM_CONNECT_FLAG);
}
}
String strURL = EMPTY;
strURL = url.toString();
if (URL_PARAM_CONNECT_FLAG.equals(EMPTY + strURL.charAt(strURL.length() - 1))) {
strURL = strURL.substring(0, strURL.length() - 1);
}
return (strURL);
}
}
Shop：數據庫
package dwz.persistence.beans.gdmap;
/**
* @author 做者姓名:cjw
* @version 建立時間：2018年4月19日 下午3:16:44 商店實體類
*/
public class Shop {
/**
* 店鋪id
*/
private String id;
/**
* 店鋪名稱
*/
private String shopName;
/**
* 店鋪地址
*/
private String specificAddress;
/**
* 經度
*/
private String longitude;
/**
* 緯度
*/
private String latitude;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getShopName() {
return shopName;
}
public void setShopName(String shopName) {
this.shopName = shopName;
}
public String getSpecificAddress() {
return specificAddress;
}
public void setSpecificAddress(String specificAddress) {
this.specificAddress = specificAddress;
}
public String getLongitude() {
return longitude;
}
public void setLongitude(String longitude) {
this.longitude = longitude;
}
public String getLatitude() {
return latitude;
}
public void setLatitude(String latitude) {
this.latitude = latitude;
}
public Shop(String id, String shopName, String specificAddress, String longitude, String latitude) {
super();
this.id = id;
this.shopName = shopName;
this.specificAddress = specificAddress;
this.longitude = longitude;
this.latitude = latitude;
}
public Shop() {
super();
}
@Override
public String toString() {
return "Shop [id=" + id + ", shopName=" + shopName + ", specificAddress=" + specificAddress + ", longitude="
+ longitude + ", latitude=" + latitude + "]";
}
}
上面的代碼有寫入excel和讀取excel的代碼。不過要注意一下 我用得jar包不一樣。寫入用的poi,讀取用的是jxl.
---------因此須要的jar包：
apache
最後的結果：json
相關文章
- 1. 百度地圖根據經緯度獲取該地點所在城市信息
- 2. 根據IP查詢所在城市接口（查詢用戶所在城市）
- 3. 根據經緯度查詢具體城市信息
- 4. php根據地址的經緯度查詢周圍的城市例子
- 5. 調用高德接口查詢經緯度(根據地址)
- 6. 高德地圖----根據城市位置查詢出當天的天氣
- 7. 根據gps經緯度查詢地點
- 8. 高德地圖根據關鍵字查詢，拾取座標經緯度。
- 9. 百度地圖api定位，根據經緯度顯示當前城市名
- 10. 百度地圖API 根據地址查詢經緯度
- 更多相關文章...
- • PHP 獲取圖像寬度與高度 - PHP參考手冊
- • ADO 查詢 - ADO 教程
- • TiDB 在摩拜單車在線數據業務的應用和實踐
- • 算法總結-二分查找法
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
歡迎關注本站公眾號,獲取更多信息
