一、背景
公司碰到了一个数据迁移业务,就是把客户平台的GPS坐标迁移到自己平台,自己平台使用的是百度坐标,这就需要转换了,我是将客户公司的gps经纬度字段以及主键id导出为csv文件,这个csv文件每行三个字段,写一个脚本读取csv文件,根据每行拿到的GPS经纬度请求百度坐标转换接口,获取返回的百度经纬度,生成一个每行五个字段的csv文件,即(id,GPS经度,GPS纬度,百度经度,百度纬度)五个字段,将生成的csv文件导入自己平台数据库生成临时文件,写sql刷新自己的数据的百度经纬度字段。
二、主要实现
1、访问 http://lbsyun.baidu.com/index.php?title=webapi/guide/changeposition 查看百度如何进行转换,接口如下。由api接口可知,我们读取csv中的GPS经纬度替换coords参数,from的参数我用的是1,代表WGS84坐标,使用其他的坐标请查看百度api,to的参数我用的是5,表示要转换为百度经纬度坐标,ak需要自己去百度申请。
http://api.map.baidu.com/geoconv/v1/?coords=114.21892734521,29.575429778924&from=1&to=5&ak=你的密钥
2、读取每一行原始csv文件时,我们就请求坐标转换接口,返回百度经纬度坐标,组成包括(id,GPS经度,GPS纬度,百度经度,百度纬度)五个字段的bean加入到集合中,方便后续写入新的csv文件。方法如下:
(1)方法参数datas为转换后的数据集合
(2)goalPath为原始的只有GPS坐标的csv文件
public static void readCSV(List<ResultBean> datas, String goalPath) { try (CSVReader csvReader = new CSVReaderBuilder(new BufferedReader(new InputStreamReader(new FileInputStream(new File(goalPath)), "utf-8"))).build()) { Iterator<String[]> iterator = csvReader.iterator(); iterator.next(); while (iterator.hasNext()) { String[] next = iterator.next(); if (next[1] == null || "".equals(next[1]) || next[2] == null || "".equals(next[2])) { ResultBean bean = new ResultBean(next[0], next[1], next[2], null, null); datas.add(bean); } else { String address = m.format(new Object[]{next[1], next[2]}); ResponseEntity<BaiDuReturnBean> result = restTemplate.getForEntity(address, BaiDuReturnBean.class); if ("0".equals(result.getBody().getStatus())) { Object x = result.getBody().getResult().get(0).get("x"); Object y = result.getBody().getResult().get(0).get("y"); ResultBean bean = new ResultBean(next[0], next[1], next[2], String.valueOf(x), String.valueOf(y)); datas.add(bean); } else { ResultBean bean = new ResultBean(next[0], next[1], next[2], null, null); datas.add(bean); } } } } catch (Exception e) { e.printStackTrace(); } }
3、该ResultBean就是封装的集合中的bean 代码如下:包含(id,GPS经度,GPS纬度,百度经度,百度纬度)五个字段,见注释。
static class ResultBean { //客户主键id private String external_id; //GPS经纬度 private String v_longitude; private String v_latitude; //百度经纬度 private String longitude; private String latitude; public ResultBean(String external_id, String v_longitude, String v_latitude, String longitude, String latitude) { this.external_id = external_id; this.v_longitude = v_longitude; this.v_latitude = v_latitude; this.longitude = longitude; this.latitude = latitude; } public String getExternal_id() { return external_id; } public String getV_longitude() { return v_longitude; } public String getV_latitude() { return v_latitude; } public String getLongitude() { return longitude; } public String getLatitude() { return latitude; } }
4、上面方法中,有两个变量是全局变量,如下
(1)m为百度请求的接口模板,上面方法对模板中的经纬度进行了替换
(2) restTemplate来发送get请求百度坐标转换接口
private static MessageFormat m = new MessageFormat("http://api.map.baidu.com/geoconv/v1/?coords={0},{1}&from=1&to=5&ak=60LLHS"); private static RestTemplate restTemplate = new RestTemplate();
5、BaiDuReturnBean是对请求百度接口返回值进行解析,
(1)请求百度接口返回为json格式,如下
{ "status": 0, "result": [ { "x": 114.2307519546763, "y": 29.57908428837437 } ] }
根据返回值可知,返回status的字符串,和result的list下面是包含x和y的map,所以需要以下格式的bean进行解析
static class BaiDuReturnBean { String status; List<Map<String, Object>> result; public String getStatus() { return status; } public void setStatus(String status) { this.status = status; } public List<Map<String, Object>> getResult() { return result; } public void setResult(List<Map<String, Object>> result) { this.result = result; } }
6、除了通过新建符合条件的bean解析json返回值,我们也可以用下面的方式进行解析。通过JacksonJsonParser进行解析
RestTemplate restTemplate = new RestTemplate(); String address = "http://api.map.baidu.com/geoconv/v1/?coords=114.21892734521,29.575429778924&from=1&to=5&ak=QqHS"; ResponseEntity result = restTemplate.getForEntity(address, String.class); String body = (String) result.getBody(); Map<String, Object> map = new JacksonJsonParser().parseMap(body); System.out.println(map.get("status")); List<Map> result1 = (List) map.get("result"); Object x = result1.get(0).get("x"); System.out.println(x);
7、最后我们通过调用写方法将转换后的bean集合写入新的csv中
(1)datas为转换后的坐标集合
(2)sourcePath为要生成的csv文件路径
public static void writeCSV(List<ResultBean> datas, String sourcePath) { CsvWriter csvWriter = new CsvWriter(new File(sourcePath)); for (ResultBean data : datas) { csvWriter.write(new String[]{data.getExternal_id(), data.getV_longitude(), data.getV_latitude(), data.getLongitude(), data.getLatitude()}); } csvWriter.close(); }
三、总结
以上就是关于GPS坐标转换为百度坐标的示例,要是觉得调用一次百度接口转换一个速度慢,可以一次最多转换100个,多组坐标以“;”分隔。希望能够对你的思路有帮助。公号java基础笔记,有需要可以关注。