package com.stylefeng.guns.modular.system.util;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.stylefeng.guns.core.util.ToolUtil;
|
//import com.stylefeng.guns.modular.system.model.GDFence;
|
//import com.stylefeng.guns.modular.system.service.IGDFenceService;
|
import com.stylefeng.guns.modular.system.service.IGDInterfaceService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.http.HttpEntity;
|
import org.springframework.http.HttpHeaders;
|
import org.springframework.http.MediaType;
|
import org.springframework.http.client.ClientHttpRequestFactory;
|
import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
|
import org.springframework.stereotype.Component;
|
import org.springframework.web.client.RestTemplate;
|
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
/**
|
* 电子围栏工具类
|
*/
|
@Component
|
public class GDMapElectricFenceUtil {
|
|
@Autowired
|
private RestTemplate restTemplate;
|
|
@Autowired
|
private IGDInterfaceService gdInterfaceService;
|
|
private String key = "86b7352a4b7dcd688f7308c8c61d043b";
|
|
private JSONArray jsonArray = new JSONArray();
|
|
|
@Bean
|
public ClientHttpRequestFactory simpleClientHttpRequestFactory() {
|
// SimpleClientHttpRequestFactory factory=new SimpleClientHttpRequestFactory();
|
// 上一行被注释掉的是Spring自己的实现，下面是依赖了httpclient包后的实现
|
HttpComponentsClientHttpRequestFactory factory = new HttpComponentsClientHttpRequestFactory();
|
factory.setConnectTimeout(5000);
|
factory.setReadTimeout(5000);
|
return factory;
|
}
|
|
/**
|
* 创建电子围栏
|
* @param id
|
* @param points
|
* @return
|
*/
|
public List<String> createFence(String id, String points){
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(new Date());
|
calendar.set(Calendar.DAY_OF_MONTH, calendar.get(Calendar.DAY_OF_MONTH) + 1);
|
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
|
String format = simpleDateFormat.format(calendar.getTime());
|
|
|
//开始调用高德接口创建围栏
|
String[] s = points.split("_");
|
List<String> resoult = new ArrayList<>();
|
for(int i = 0; i < s.length; i++){
|
String[] split = s[i].split(";");
|
JSONObject json = new JSONObject();
|
json.put("name", id);
|
if(split.length == 2){
|
json.put("center", split[0]);
|
json.put("radius", split[1]);
|
}else{
|
json.put("points", s[i]);
|
}
|
json.put("enable", "true");
|
json.put("valid_time", format);
|
json.put("repeat", "Mon,Tues,Wed,Thur,Fri,Sat,Sun");
|
json.put("alert_condition", "enter;leave");
|
json.put("desc", id);
|
|
HttpHeaders headers = new HttpHeaders();
|
MediaType type = MediaType.parseMediaType("application/json; charset=UTF-8");
|
headers.setContentType(type);
|
headers.add("Accept", MediaType.APPLICATION_JSON.toString());
|
HttpEntity<String> formEntity = new HttpEntity<>(json.toString(), headers);
|
|
String url = "https://restapi.amap.com/v4/geofence/meta?key=" + key;
|
String js = restTemplate.postForObject(url, formEntity, String.class);
|
JSONObject jsonObject = JSON.parseObject(js);
|
JSONObject data = jsonObject.getJSONObject("data");
|
String status = data.getString("status");
|
|
gdInterfaceService.saveData("https://restapi.amap.com/v4/geofence/meta", "创建电子围栏");
|
|
// if(status.equals("0")){//创建成功
|
// GDFence gdFence = new GDFence();
|
// gdFence.setGdfenceId(UUIDUtil.getRandomCode());
|
// gdFence.setGid(data.getString("gid"));
|
// gdFence.setPoints(s[i]);
|
// gdFence.setLineElectricfenceIds(id);
|
// gdFenceService.insert(gdFence);
|
// }
|
//
|
// if(status.equals("106")){//创建点电子围栏已经存在(只有坐标完全相同的电子围栏才会报重复)
|
// try {
|
// GDFence data1 = gdFenceService.getData(s[i]);
|
// int index = data1.getLineElectricfenceIds().indexOf(id);
|
// if(index < 0){
|
// data1.setLineElectricfenceIds(data1.getLineElectricfenceIds() + "," + id);
|
// gdFenceService.updateById(data1);
|
// }
|
// } catch (Exception e) {
|
// e.printStackTrace();
|
// }
|
// }
|
// resoult.add(js);
|
}
|
return resoult;
|
}
|
|
|
|
|
/**
|
* 创建电子围栏
|
* @param id 围栏名称----绘制的数据id值
|
* @param points 多边形围栏坐标
|
*/
|
public List<String> createElectricFenc(String id, String points){
|
List<String> fence = this.createFence(id, points);
|
List<String> gids = new ArrayList<>();
|
for(String f : fence){
|
JSONObject jsonObject = JSON.parseObject(f);
|
JSONObject data = jsonObject.getJSONObject("data");
|
String status = data.getString("status");
|
if(status.equals("0")){
|
gids.add(data.getString("gid"));
|
}
|
}
|
return gids;
|
}
|
|
|
/**
|
* 查询以创建的所有电子围栏
|
*/
|
public String findElectricFenc(String center, String radius, String points){
|
String url = "https://restapi.amap.com/v4/geofence/meta?key=" + key;
|
String forObject = restTemplate.getForObject(url, String.class);
|
JSONObject jsonObject = JSON.parseObject(forObject);
|
JSONObject data = jsonObject.getJSONObject("data");
|
|
gdInterfaceService.saveData("https://restapi.amap.com/v4/geofence/meta", "查询电子围栏");
|
|
if(ToolUtil.isNotEmpty(center)){//圆形电子围栏
|
JSONArray rs_list = data.getJSONArray("rs_list");
|
for(int i = 0; i < rs_list.size(); i++){
|
String c = rs_list.getJSONObject(i).getString("center");
|
Double r = rs_list.getJSONObject(i).getDouble("radius");
|
if(c.equals(center) && radius.equals(String.valueOf(r))){
|
return rs_list.getJSONObject(i).getString("gid");
|
}
|
}
|
}else{
|
JSONArray rs_list = data.getJSONArray("rs_list");
|
for(int i = 0; i < rs_list.size(); i++){
|
String p = rs_list.getJSONObject(i).getString("points");
|
if(points.equals(p)){
|
return rs_list.getJSONObject(i).getString("gid");
|
}
|
}
|
}
|
return null;
|
}
|
|
|
/**
|
* 查询所有绘制好的电子围栏
|
* @return
|
*/
|
public JSONArray findAllElectricFenc(int page){
|
if(page == 1){
|
jsonArray = new JSONArray();
|
}
|
String url = "https://restapi.amap.com/v4/geofence/meta?key=" + key + "&page_no=" + page + "&page_size=" + 30;
|
String forObject = restTemplate.getForObject(url, String.class);
|
JSONObject jsonObject = JSON.parseObject(forObject);
|
JSONObject data = jsonObject.getJSONObject("data");
|
JSONArray rs_list = data.getJSONArray("rs_list");
|
jsonArray.addAll(rs_list);
|
|
gdInterfaceService.saveData("https://restapi.amap.com/v4/geofence/meta", "查询电子围栏");
|
|
//判断是否有分页
|
int total_record = data.getIntValue("total_record");
|
if(total_record > jsonArray.size()){
|
//有分页，递归调用自己
|
page++;
|
this.findAllElectricFenc(page);
|
}
|
return jsonArray;
|
}
|
|
|
/**
|
* 批量更新电子围栏（失效的数据）
|
* @param jsonArray
|
* @throws ParseException
|
*/
|
public void updateElectricFenc(JSONArray jsonArray) throws ParseException{
|
//批量更新查询出的失效的电子围栏，围栏失效日期在当前日期之后的数据
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
for(int i = 0; i < jsonArray.size(); i++){
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(new Date());
|
calendar.set(Calendar.HOUR_OF_DAY, 8);
|
calendar.set(Calendar.MINUTE, 0);
|
calendar.set(Calendar.SECOND, 0);
|
calendar.set(Calendar.MILLISECOND, 0);
|
long timeInMillis1 = calendar.getTimeInMillis();
|
|
String valid_time = jsonObject.getString("valid_time");
|
Date parse = sdf.parse(valid_time);
|
Calendar cale = Calendar.getInstance();
|
cale.setTime(parse);
|
cale.set(Calendar.HOUR_OF_DAY, 8);
|
cale.set(Calendar.MINUTE, 0);
|
cale.set(Calendar.SECOND, 0);
|
cale.set(Calendar.MILLISECOND, 0);
|
long timeInMillis = cale.getTimeInMillis();
|
if(timeInMillis1 >= timeInMillis){
|
String gid = jsonObject.getString("gid");
|
String id = jsonObject.getString("name");
|
String center = jsonObject.getString("center");
|
String radius = jsonObject.getString("radius");
|
String points = jsonObject.getString("points");
|
this.updateElectricFenc(gid, id, center, radius, points);
|
}
|
|
}
|
}
|
|
|
|
/**
|
* 更新电子围栏
|
* @param gid
|
* @param id
|
* @param center
|
* @param radius
|
* @param points
|
*/
|
public void updateElectricFenc(String gid, String id, String center, String radius, String points) throws ParseException {
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(new Date());
|
calendar.set(Calendar.DAY_OF_MONTH, calendar.get(Calendar.DAY_OF_MONTH) + 1);
|
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
|
String format = simpleDateFormat.format(calendar.getTime());
|
|
//开始调用高德接口创建围栏
|
JSONObject json = new JSONObject();
|
json.put("name", id);
|
if(ToolUtil.isNotEmpty(center)){
|
json.put("center", center);
|
json.put("radius", radius);
|
}else{
|
json.put("points", points);
|
}
|
json.put("valid_time", format);
|
json.put("repeat", "Mon,Tues,Wed,Thur,Fri,Sat,Sun");
|
json.put("alert_condition", "enter;leave");
|
json.put("desc", id + "围栏更新描述");
|
|
HttpHeaders headers = new HttpHeaders();
|
MediaType type = MediaType.parseMediaType("application/json; charset=UTF-8");
|
headers.setContentType(type);
|
headers.add("Accept", MediaType.APPLICATION_JSON.toString());
|
HttpEntity<String> formEntity = new HttpEntity<>(json.toString(), headers);
|
|
String url = "https://restapi.amap.com/v4/geofence/meta?key=" + key + "&gid=" + gid;
|
String s = restTemplate.patchForObject(url, formEntity, String.class);
|
System.out.println(s);
|
|
gdInterfaceService.saveData("https://restapi.amap.com/v4/geofence/meta", "更新电子围栏");
|
}
|
|
|
/**
|
* 电子围栏监控
|
* @param diu 设备唯一标识符，作为记录依据，不影响判断结果。Android设备一般使用imei号码，iOS一般使用idfv号，其余设备可根据业务自定义。
|
* @param locations 数据为坐标数据和坐标产生的时间戳数据，至少包含一个坐标对和时间戳。
|
* 1、传入1个点时，直接判断交互关系。
|
* 2、当传入多个点时，可以通过前后时间判断动态交互关系。
|
* 格式: x1,y1,unix_ts1;x2,y2,unix_ts2
|
* 动态交互判断方法：第一个点作为当前时间的点，然后从其余点中选出在当前点之前10s～1小时范围内的最早点，用这两个时间点的位置判断设备与围栏的动态交互关系。若数据无效交互关系默认返回leave。
|
* @return
|
*/
|
public List<String> monitorElectricFenc(String diu, String locations){
|
if(ToolUtil.isEmpty(diu)){
|
diu = "B78F99DD-2496-4A43-843B-172CDA2D9798";
|
}
|
locations = locations + "," + (new Date().getTime() / 1000);
|
String url = "https://restapi.amap.com/v4/geofence/status?key=" + key + "&diu=" + diu + "&locations=" + locations;
|
String forObject = restTemplate.getForObject(url, String.class);
|
JSONObject jsonObject = JSON.parseObject(forObject);
|
List<String> ids = new ArrayList<>();
|
JSONObject data = jsonObject.getJSONObject("data");
|
int status = data.getIntValue("status");
|
if(0 == status){
|
JSONArray fencingEventList = data.getJSONArray("fencing_event_list");
|
for(int i = 0; i < fencingEventList.size(); i++){
|
String clientStatus = fencingEventList.getJSONObject(i).getString("client_status");
|
if(clientStatus.equals("in")){//包含给定坐标的电子围栏
|
JSONObject fence_info = fencingEventList.getJSONObject(i).getJSONObject("fence_info");//获取电子围栏信息
|
String gid = fence_info.getString("fence_gid");
|
ids.add(gid);
|
}
|
}
|
}
|
System.out.println("检测：" + forObject);
|
|
gdInterfaceService.saveData("https://restapi.amap.com/v4/geofence/status", "电子围栏监控");
|
return ids;
|
}
|
|
|
/**
|
* 删除电子围栏
|
* @param gid
|
* @return
|
*/
|
public boolean deleteElectricFenc(String gid){
|
restTemplate.delete("https://restapi.amap.com/v4/geofence/meta?key={1}&gid={2}", key, gid);
|
System.out.println("删除：" );
|
|
gdInterfaceService.saveData("https://restapi.amap.com/v4/geofence/meta", "删除电子围栏");
|
|
return true;
|
}
|
|
|
/**
|
* 获取两点的距离
|
* @param origins 起点坐标
|
* @param destination 终点坐标
|
* @param type 计算类型：0：直线距离 1：驾车导航距离（仅支持国内坐标）。
|
* @return
|
*/
|
public Map<String, String> getDistance(String origins, String destination, Integer type){
|
String url = "https://restapi.amap.com/v3/distance?key=" + key + "&origins=" + origins + "&destination=" + destination +
|
"&type=" + type;
|
String forObject = restTemplate.getForObject(url, String.class);
|
JSONObject jsonObject = JSON.parseObject(forObject);
|
String status = jsonObject.getString("status");
|
|
gdInterfaceService.saveData("https://restapi.amap.com/v3/distance", "查询两点间的距离");
|
|
if(status.equals("1")){
|
JSONArray results = jsonObject.getJSONArray("results");
|
JSONObject jsonObject1 = results.getJSONObject(0);
|
Map<String, String> map = new HashMap<>();
|
map.put("distance", jsonObject1.getString("distance"));//距离（米）
|
map.put("duration", jsonObject1.getString("duration"));//预计时间（秒）
|
return map;
|
}else{
|
System.err.println(forObject);
|
}
|
return null;
|
}
|
|
|
/**
|
* 获取路径规划
|
* @param origins 起点坐标
|
* @param destination 终点坐标
|
* @param waypoints 途经点
|
* @return
|
*/
|
public Map<String, String> getDriving(String origins, String destination, String waypoints){
|
String url = "https://restapi.amap.com/v3/direction/driving?key=" + key + "&origin=" + origins + "&destination=" + destination +
|
"&waypoints=" + waypoints + "&extensions=base&strategy=0";
|
String forObject = restTemplate.getForObject(url, String.class);
|
JSONObject jsonObject = JSON.parseObject(forObject);
|
String status = jsonObject.getString("status");
|
|
gdInterfaceService.saveData("https://restapi.amap.com/v3/direction/driving", "获取路径规划");
|
|
if(status.equals("1")){
|
JSONObject route = jsonObject.getJSONObject("route");
|
JSONArray results = route.getJSONArray("paths");
|
JSONObject jsonObject1 = results.getJSONObject(0);
|
Map<String, String> map = new HashMap<>();
|
map.put("distance", jsonObject1.getString("distance"));//距离（米）
|
map.put("duration", jsonObject1.getString("duration"));//预计时间（秒）
|
return map;
|
}
|
return null;
|
}
|
|
|
}
|
