From 6e734d7297e2a1be9cddc377a6e1c0cdb3c22438 Mon Sep 17 00:00:00 2001 From: cjl <276999030@qq.com> Date: Fri, 10 Nov 2023 11:44:59 +0800 Subject: [PATCH] fix:补充提交 --- screen-manage/src/main/java/com/moral/api/service/impl/HistorySecondCruiserServiceImpl.java | 103 ++++++++++++--------------------------------------- 1 files changed, 24 insertions(+), 79 deletions(-) diff --git a/screen-manage/src/main/java/com/moral/api/service/impl/HistorySecondCruiserServiceImpl.java b/screen-manage/src/main/java/com/moral/api/service/impl/HistorySecondCruiserServiceImpl.java index 92da268..7387fc3 100644 --- a/screen-manage/src/main/java/com/moral/api/service/impl/HistorySecondCruiserServiceImpl.java +++ b/screen-manage/src/main/java/com/moral/api/service/impl/HistorySecondCruiserServiceImpl.java @@ -2,6 +2,7 @@ import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.moral.api.entity.HistorySecondCruiser; import com.moral.api.entity.ManageCoordinateDetail; import com.moral.api.entity.Sensor; @@ -10,28 +11,20 @@ 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.pojo.dto.cruiser.CruiserListDTO; 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.*; import java.util.concurrent.TimeUnit; import java.util.regex.Matcher; import java.util.regex.Pattern; @@ -172,82 +165,34 @@ @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(); + List<CruiserListDTO> list = historySecondCruiserMapper.cruiserList(params); + List<CruiserDTO> cruiserInfo = new ArrayList<>(); 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; - } + for(CruiserListDTO c : list){ + String date = new StringBuilder().append(c.getFlyLon()).append("_").append(c.getFlyLat()).toString(); + if(c.getState().equals(0)){ + CruiserDTO cruiserDTO = new CruiserDTO(); + cruiserDTO.setTime(c.getTime()); + cruiserDTO.setFlyLat(c.getFlyLat()); + cruiserDTO.setFlyLon(c.getFlyLon()); + cruiserDTO.setData(date); + cruiserDTO.setState("1"); + cruiserInfo.add(cruiserDTO); + }else { + ManageCoordinateDetail detail = new ManageCoordinateDetail(); + detail.setId(c.getId()); + detail.setCoordinateId(c.getCoordinateId()); + detail.setLongitude(c.getFlyLon()); + detail.setLatitude(c.getFlyLat()); + detail.setState(c.getState().toString()); + detail.setCode(date); + rsList1.add(detail); } - } rsMap.put("rsData",cruiserInfo); rsMap.put("data",rsList1); rsMap.put("message","���"+cruiserInfo.size()+"������������������"+"���������"+(cruiserInfo.size()+rsList1.size())+"���"); return rsMap; } - } -- Gitblit v1.8.0