moral.git - Gitblit

			@@ -1,11 +1,16 @@
			package com.moral.api.service.impl;

			import com.alibaba.fastjson.JSONArray;
			import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
			import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
			import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
			import com.moral.api.entity.ManageAccount;
			import com.moral.api.entity.ManageCoordinate;
			import com.moral.api.entity.ManageCoordinateDetail;
			import com.moral.api.entity.SpecialDevice;
			import com.moral.api.mapper.HistorySecondCruiserMapper;
			import com.moral.api.mapper.ManageCoordinateDetailMapper;
			import com.moral.api.mapper.SpecialDeviceMapper;
			import com.moral.api.pojo.dto.cruiser.CruiserDTO;
			import com.moral.api.pojo.redisBean.AccountInfoDTO;
			import com.moral.api.service.ManageCoordinateDetailService;
			@@ -23,6 +28,8 @@
			import org.springframework.web.context.request.RequestContextHolder;
			import org.springframework.web.context.request.ServletRequestAttributes;
			import javax.servlet.http.HttpServletRequest;

			import java.awt.geom.Point2D;
			import java.util.*;
			import java.util.concurrent.TimeUnit;
			import java.util.regex.Matcher;
			@@ -43,6 +50,9 @@

			@Autowired
			private RedisTemplate redisTemplate;

			@Autowired
			private SpecialDeviceMapper specialDeviceMapper;
			/**
			* 新增经纬度
			* @param params
			@@ -271,4 +281,158 @@
			}
			return 200;
			}

			/**
			* 所有数据批量添加
			*
			* @param params
			*/
			@Override
			public void queryAll(Map<String, Object> params) {
			//获取路段信息
			List<ManageCoordinate> coordinates = specialDeviceMapper.selectCoordinate(params.get("mac").toString());
			//获取走航车数据
			List<CruiserDTO> cruiserInfo = historySecondCruiserMapper.getCruiserInfo(params);
			cruiserInfo = cruiserInfo.stream().distinct().collect(Collectors.toList());
			List<ManageCoordinateDetail> result = new ArrayList<>();
			for (ManageCoordinate coordinate : coordinates) {
			String value = coordinate.getValue();
			if (!ObjectUtils.isEmpty(value)){
			List<Map<String, Object>> parse = (List<Map<String, Object>>) JSONArray.parse(value);

			for (int i = 0; i < cruiserInfo.size(); i++) {
			CruiserDTO cruiserDTO = cruiserInfo.get(i);
			if (ObjectUtils.isEmpty(cruiserDTO)){
			continue;
			}
			Double flyLat = cruiserDTO.getFlyLat();
			Double flyLon = cruiserDTO.getFlyLon();
			if (ObjectUtils.isEmpty(flyLat)\|\|ObjectUtils.isEmpty(flyLon)){
			continue;
			}
			boolean inPolygon = isInPolygon(flyLon, flyLat, parse);
			if (inPolygon){
			LambdaQueryWrapper<ManageCoordinateDetail> wr = new LambdaQueryWrapper<>();
			wr.eq(ManageCoordinateDetail::getLongitude,flyLon);
			wr.eq(ManageCoordinateDetail::getLatitude,flyLat);
			List<ManageCoordinateDetail> manageCoordinateDetails = manageCoordinateDetailMapper.selectList(wr);
			if (ObjectUtils.isEmpty(manageCoordinateDetails)){
			ManageCoordinateDetail rsDTO = new ManageCoordinateDetail();
			rsDTO.setLatitude(flyLat);
			rsDTO.setLongitude(flyLon);
			rsDTO.setState("2");
			rsDTO.setCreateTime(new Date());
			rsDTO.setUpdateTime(new Date());
			rsDTO.setCoordinateId(coordinate.getCoordinateId());
			result.add(rsDTO);
			cruiserInfo.remove(i);
			i--;
			}
			}
			}

			}
			}
			if(!CollectionUtils.isEmpty(result)){
			this.saveBatch(result);
			}



			}


			/**
			* 判断当前位置是否在多边形区域内
			* @param
			* @param mapList 区域顶点
			* @return
			*/
			public static boolean isInPolygon(Double X,Double Y,List<Map<String, Object>> mapList){


			Point2D.Double point = new Point2D.Double(X, Y);
			List<Point2D.Double> pointList= new ArrayList<Point2D.Double>();

			for (Map<String, Object> param : mapList) {
			//纬度
			String lat = param.get("lat").toString();
			//经度
			String lng = param.get("lng").toString();
			Point2D.Double polygonPoint = new Point2D.Double(Double.parseDouble(lng),Double.parseDouble(lat));
			pointList.add(polygonPoint);
			}
			return IsPtInPoly(point,pointList);

			}

			/**
			* 判断点是否在多边形内，如果点位于多边形的顶点或边上，也算做点在多边形内，直接返回true
			* @param point 检测点
			* @param pts 多边形的顶点
			* @return 点在多边形内返回true,否则返回false
			*/
			public static boolean IsPtInPoly(Point2D.Double point, List<Point2D.Double> pts){

			int N = pts.size();
			boolean boundOrVertex = true; //如果点位于多边形的顶点或边上，也算做点在多边形内，直接返回true
			int intersectCount = 0;//cross points count of x
			double precision = 2e-10; //浮点类型计算时候与0比较时候的容差
			Point2D.Double p1, p2;//neighbour bound vertices
			Point2D.Double p = point; //当前点

			p1 = pts.get(0);//left vertex
			for(int i = 1; i <= N; ++i){//check all rays
			if(p.equals(p1)){
			return boundOrVertex;//p is an vertex
			}

			p2 = pts.get(i % N);
			if(p.x < Math.min(p1.x, p2.x) \|\| p.x > Math.max(p1.x, p2.x)){
			p1 = p2;
			continue;
			}

			if(p.x > Math.min(p1.x, p2.x) && p.x < Math.max(p1.x, p2.x)){
			if(p.y <= Math.max(p1.y, p2.y)){
			if(p1.x == p2.x && p.y >= Math.min(p1.y, p2.y)){
			return boundOrVertex;
			}

			if(p1.y == p2.y){
			if(p1.y == p.y){
			return boundOrVertex;
			}else{//before ray
			++intersectCount;
			}
			}else{
			double xinters = (p.x - p1.x) * (p2.y - p1.y) / (p2.x - p1.x) + p1.y;
			if(Math.abs(p.y - xinters) < precision){
			return boundOrVertex;
			}

			if(p.y < xinters){
			++intersectCount;
			}
			}
			}
			}else{
			if(p.x == p2.x && p.y <= p2.y){
			Point2D.Double p3 = pts.get((i+1) % N);
			if(p.x >= Math.min(p1.x, p3.x) && p.x <= Math.max(p1.x, p3.x)){
			++intersectCount;
			}else{
			intersectCount += 2;
			}
			}
			}
			p1 = p2;
			}

			if(intersectCount % 2 == 0){//偶数在多边形外
			return false;
			} else { //奇数在多边形内
			return true;
			}
			}
			}