moral.git - Gitblit

			@@ -1,24 +1,40 @@
			package com.moral.api.service.impl;

			import com.alibaba.fastjson.JSONObject;
			import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
			import com.moral.api.entity.HistorySecondCruiser;
			import com.moral.api.entity.ManageCoordinateDetail;
			import com.moral.api.entity.Sensor;
			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.service.DeviceService;
			import com.moral.api.service.HistorySecondCruiserService;
			import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
			import com.moral.api.service.SpecialDeviceService;
			import com.moral.api.util.RoadUtils;
			import com.moral.constant.Constants;
			import com.moral.constant.RedisConstants;
			import com.moral.util.DateUtils;

			import lombok.extern.slf4j.Slf4j;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.data.redis.core.RedisTemplate;
			import org.springframework.stereotype.Service;
			import org.springframework.util.CollectionUtils;
			import org.springframework.util.ObjectUtils;

			import java.sql.Wrapper;
			import java.util.ArrayList;
			import java.util.Date;
			import java.util.HashMap;
			import java.util.List;
			import java.util.Map;
			import java.util.concurrent.TimeUnit;
			import java.util.regex.Matcher;
			import java.util.regex.Pattern;
			import java.util.stream.Collectors;

			/**
			@@ -29,6 +45,7 @@
			* @author moral
			* @since 2021-09-02
			*/
			@Slf4j
			@Service
			public class HistorySecondCruiserServiceImpl extends ServiceImpl<HistorySecondCruiserMapper, HistorySecondCruiser> implements HistorySecondCruiserService {

			@@ -37,6 +54,10 @@

			@Autowired
			private SpecialDeviceService specialDeviceService;
			@Autowired
			private SpecialDeviceMapper specialDeviceMapper;
			@Autowired
			private ManageCoordinateDetailMapper manageCoordinateDetailMapper;

			@Autowired
			private RedisTemplate redisTemplate;
			@@ -78,4 +99,155 @@
			historySecondCruiser.setBatch(batchTime);
			historySecondCruiserMapper.insert(historySecondCruiser);
			}

			/**
			* 获取所有走航车信息
			* @return
			*/
			@Override
			public List<SpecialDevice> selectCruisers() {
			QueryWrapper<SpecialDevice> wrapper = new QueryWrapper<>();
			wrapper.select("name","mac");
			wrapper.eq("is_delete",Constants.NOT_DELETE);
			List<SpecialDevice> specialDevices = specialDeviceMapper.selectList(wrapper);
			return specialDevices;
			}

			/**
			* 查看走航车轨迹
			* @param params
			* @return
			*/
			@Override
			public Map<String,Object> getCruiserInFo(Map<String, Object> params) {
			HashMap<String, Object> map = new HashMap<>();
			String mac = params.get("mac").toString();
			String time1 = params.get("time1").toString();
			params.put("dateFormat", "%Y-%m-%d %H:%i:%s");
			ArrayList<Object> list = new ArrayList<>();
			List<CruiserDTO> data = (List<CruiserDTO>) redisTemplate.opsForHash().get(RedisConstants.DATE_COORDINATE, mac + time1);
			// List<CruiserDTO> data = (List<CruiserDTO>) redisTemplate.opsForValue().get(mac + time1);
			if (ObjectUtils.isEmpty(data)){
			data = historySecondCruiserMapper.getCruiserInfo(params);
			data = data.stream().distinct().collect(Collectors.toList());
			data.removeIf(o->{
			if (ObjectUtils.isEmpty(o.getFlyLon()) \|\| ObjectUtils.isEmpty(o.getFlyLat())) {
			return true;
			}
			double lon = o.getFlyLon();
			double lat = o.getFlyLat();
			double[] doubles = RoadUtils.transformWGS84ToBD09(lon, lat);
			Matcher matcher = Pattern.compile("\\d*\\.\\d{8}").matcher(""+doubles[0]);
			matcher.find();
			String s = matcher.group();
			Matcher matcher1 = Pattern.compile("\\d*\\.\\d{8}").matcher(""+doubles[1]);
			matcher1.find();
			String s1 = matcher1.group();
			o.setFlyLon(Double.parseDouble(s));
			o.setFlyLat(Double.parseDouble(s1));
			o.setData(lon+"_"+lat);
			// o.setFlyLon(doubles[0]);
			// o.setFlyLat(doubles[1]);
			if (lon < 70 \|\| lon > 150 \|\| lat < 20 \|\| lat > 60) {
			return true;
			}
			return false;
			});

			redisTemplate.opsForHash().put(RedisConstants.DATE_COORDINATE,mac+time1,data);
			//设置过期时间
			redisTemplate.opsForHash().getOperations().expire(RedisConstants.DATE_COORDINATE,600, TimeUnit.SECONDS);

			}

			// redisTemplate.opsForValue().set(mac+time1,rsCruiser,600, TimeUnit.SECONDS);

			map.put("rsData",data);
			map.put("data",list);
			log.info(data.size()+"");
			log.info(data.size()+"");
			return map;
			}

			@Override
			public Map<String, Object> getCruiserCompare(Map<String, Object> params) {
			HashMap<String,Object> rsMap = new HashMap<>();
			String mac = params.get("mac").toString();
			String time1 = params.get("time1").toString();
			ArrayList<ManageCoordinateDetail> rsList1 = new ArrayList<>();
			params.put("dateFormat", "%Y-%m-%d %H:%i:%s");
			List<ManageCoordinateDetail> manageCoordinateDetails = manageCoordinateDetailMapper.selectList(null);
			List<CruiserDTO> cruiserInfo = (List<CruiserDTO>) redisTemplate.opsForHash().get(RedisConstants.DATE_COORDINATE, mac + time1);

			if (ObjectUtils.isEmpty(cruiserInfo)){
			cruiserInfo = historySecondCruiserMapper.getCruiserInfo(params);
			cruiserInfo = cruiserInfo.stream().distinct().collect(Collectors.toList());
			cruiserInfo.removeIf(o->{
			if (ObjectUtils.isEmpty(o.getFlyLon()) \|\| ObjectUtils.isEmpty(o.getFlyLat())) {
			return true;
			}
			double lon = o.getFlyLon();
			double lat = o.getFlyLat();
			double[] doubles = RoadUtils.transformWGS84ToBD09(lon, lat);
			Matcher matcher = Pattern.compile("\\d*\\.\\d{8}").matcher(""+doubles[0]);
			matcher.find();
			String s = matcher.group();
			Matcher matcher1 = Pattern.compile("\\d*\\.\\d{8}").matcher(""+doubles[1]);
			matcher1.find();
			String s1 = matcher1.group();
			o.setFlyLon(Double.parseDouble(s));
			o.setFlyLat(Double.parseDouble(s1));
			o.setData(lon+"_"+lat);
			// o.setFlyLon(doubles[0]);
			// o.setFlyLat(doubles[1]);
			if (lon < 70 \|\| lon > 150 \|\| lat < 20 \|\| lat > 60) {
			return true;
			}
			return false;
			});

			redisTemplate.opsForHash().put(RedisConstants.DATE_COORDINATE,mac+time1,cruiserInfo);
			//设置过期时间
			redisTemplate.opsForHash().getOperations().expire(RedisConstants.DATE_COORDINATE,6000, TimeUnit.SECONDS);

			}
			// List<CruiserDTO> cruiserInfo = historySecondCruiserMapper.getCruiserInfo(params);
			log.info(""+cruiserInfo.size());
			if (ObjectUtils.isEmpty(manageCoordinateDetails)){
			rsMap.put("rsData",cruiserInfo);
			rsMap.put("data",rsList1);
			return rsMap;
			}
			for (int i=cruiserInfo.size()-1;i>0;i--) {
			CruiserDTO cruiserDTO = cruiserInfo.get(i);
			String data = cruiserDTO.getData();
			String[] rs = data.split("_");
			String flyLon = rs[0];
			String flyLat = rs[1];
			// double lonDouble = Double.parseDouble(flyLon);
			// double latDouble = Double.parseDouble(flyLat);
			for (ManageCoordinateDetail manageCoordinateDetail : manageCoordinateDetails) {
			String latitude = manageCoordinateDetail.getLatitude().toString();
			String longitude = manageCoordinateDetail.getLongitude().toString();
			// double lonDouble1 = Double.parseDouble(longitude);
			// double latDouble1 = Double.parseDouble(latitude);
			// if (latDouble1==latDouble && lonDouble==lonDouble1){
			if (flyLon.equals(longitude) && flyLat.equals(latitude)){
			manageCoordinateDetail.setCode(data);
			manageCoordinateDetail.setLongitude(cruiserDTO.getFlyLon());
			manageCoordinateDetail.setLatitude(cruiserDTO.getFlyLat());
			rsList1.add(manageCoordinateDetail);
			cruiserInfo.remove(i);
			break;
			}
			}

			}
			rsMap.put("rsData",cruiserInfo);
			rsMap.put("data",rsList1);
			rsMap.put("message","有"+cruiserInfo.size()+"个不在里面，"+"一共有"+(cruiserInfo.size()+rsList1.size())+"个");
			return rsMap;
			}


			}