blame | history | patch | commit | commitdiff | ignore whitespace
jinpengyong
2023-11-10 c8cc61e84189d8f986f7c4657d543408021b3da0 
 screen-manage/src/main/java/com/moral/api/service/impl/ManageCoordinateDetailServiceImpl.java


@@ -1,20 +1,5 @@


package com.moral.api.service.impl;




import lombok.extern.slf4j.Slf4j;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.web.context.request.RequestContextHolder;


import org.springframework.web.context.request.ServletRequestAttributes;




import java.util.ArrayList;


import java.util.Date;


import java.util.List;


import java.util.Map;


import java.util.Objects;




import javax.servlet.http.HttpServletRequest;




import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.moral.api.entity.ManageAccount;


@@ -25,8 +10,25 @@


import com.moral.api.pojo.redisBean.AccountInfoDTO;


import com.moral.api.service.ManageCoordinateDetailService;


import com.moral.api.util.RoadUtils;


import com.moral.constant.RedisConstants;


import com.moral.util.DateUtils;


import com.moral.util.TokenUtils;


import com.sun.org.apache.regexp.internal.RE;


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.transaction.annotation.Transactional;


import org.springframework.util.CollectionUtils;


import org.springframework.util.ObjectUtils;


import org.springframework.web.context.request.RequestContextHolder;


import org.springframework.web.context.request.ServletRequestAttributes;




import javax.servlet.http.HttpServletRequest;


import java.util.*;


import java.util.concurrent.TimeUnit;


import java.util.regex.Matcher;


import java.util.regex.Pattern;


import java.util.stream.Collectors;






@Service


@@ -39,6 +41,9 @@




    @Autowired


    private HistorySecondCruiserMapper historySecondCruiserMapper;




    @Autowired


    private RedisTemplate redisTemplate;


    /**


     * 新增经纬度


     * @param params


@@ -55,10 +60,15 @@


        String userName = manageAccount.getUserName();




        int coordinateId = Integer.parseInt(params.get("coordinateId").toString());


        List<ManageCoordinateDetail> manageCoordinateDetails = (List<ManageCoordinateDetail>) params.get("data");


        for (ManageCoordinateDetail manageCoordinateDetail : manageCoordinateDetails) {


            if (manageCoordinateDetail.getState().equals("1")){


                String code = manageCoordinateDetail.getCode();


        List<Map<String, Object>> data = (List<Map<String, Object>>) params.get("data");




        for (Map<String, Object> datum : data) {




            String code = datum.get("code").toString();


            String state = datum.get("state").toString();




            if (state.equals("2")){


                ManageCoordinateDetail manageCoordinateDetail = new ManageCoordinateDetail();


                String[] rs = code.split("_");


                manageCoordinateDetail.setCoordinateId(coordinateId);


                manageCoordinateDetail.setLongitude(Double.parseDouble(rs[0]));


@@ -72,24 +82,19 @@


                wrapper.eq("latitude",manageCoordinateDetail.getLatitude());


                Integer integer = manageCoordinateDetailMapper.selectCount(wrapper);


                if (integer>=1){


                    return null;


                    return 1;


                }


                 manageCoordinateDetailMapper.insert(manageCoordinateDetail);




                manageCoordinateDetailMapper.insert(manageCoordinateDetail);


            }else {


                 manageCoordinateDetailMapper.deleteById(manageCoordinateDetail.getId());


                Object id1 = datum.get("id");


                if (ObjectUtils.isEmpty(id1)){


                    return 2;


                }


                manageCoordinateDetailMapper.deleteById(Integer.parseInt(id1.toString()));




            }


        }


        return 200;


    }




    /**


     * 删除经纬度点


     * @param id


     */


    @Override


    public void deleteCoordinate(Integer id)  {


        manageCoordinateDetailMapper.deleteById(id);


    }






@@ -99,17 +104,83 @@


     * @return


     */


    @Override


    public Map<String, Object> selectCoordinate(Map<String, Object> params) {


    public Map<String,Object> selectCoordinate(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");


        String coordinateId = params.get("coordinateId").toString();


        QueryWrapper<ManageCoordinateDetail> queryWrapper = new QueryWrapper<>();


        queryWrapper.eq("coordinate_id",coordinateId);


        List<ManageCoordinateDetail> manageCoordinateDetails = manageCoordinateDetailMapper.selectList(queryWrapper);


        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);


        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;


                }


            }






        return null;


        }


        rsMap.put("rsData",cruiserInfo);


        rsMap.put("data",rsList1);


        return rsMap;


    }






@@ -125,27 +196,54 @@


        int coordinateId = Integer.parseInt(params.get("coordinateId").toString());


        QueryWrapper<ManageCoordinateDetail> queryWrapper = new QueryWrapper<>();


        queryWrapper.eq("coordinate_id",coordinateId);


        String time1 = params.remove("time1").toString();


        String time2 = params.remove("time2").toString();


        long l = DateUtils.compareDateStrDay(time1, time2);


        if (l>0){


            params.put("time1",time1);


            params.put("time2",time2);


        }else {


            params.put("time1",time2);


            params.put("time2",time1);


        }


        int j =0;


        List<ManageCoordinateDetail> manageCoordinateDetails = manageCoordinateDetailMapper.selectList(queryWrapper);


        List<CruiserDTO> cruiserInfo = historySecondCruiserMapper.getCruiserInfo(params);


        for (ManageCoordinateDetail manageCoordinateDetail : manageCoordinateDetails) {


            String latitude = manageCoordinateDetail.getLatitude().toString();


            String longitude = manageCoordinateDetail.getLongitude().toString();


        cruiserInfo = cruiserInfo.stream().distinct().collect(Collectors.toList());


        if (ObjectUtils.isEmpty(manageCoordinateDetails)){


            for (CruiserDTO cruiserDTO : cruiserInfo) {


                Double flyLat = cruiserDTO.getFlyLat();


                Double flyLon = cruiserDTO.getFlyLon();


                if (!latitude.equals(flyLat+"") || !longitude.equals(flyLon+"")){


                    ManageCoordinateDetail rsDTO = new ManageCoordinateDetail();


                    rsDTO.setLatitude(flyLat);


                    rsDTO.setLongitude(flyLon);


                    rsDTO.setState("2");


                    rsDTO.setCreateTime(new Date());


                    rsDTO.setUpdateTime(new Date());


                    rsDTO.setCoordinateId(coordinateId);


                    int insert = manageCoordinateDetailMapper.insert(rsDTO);


                    if (insert!=1){


                        return null;


                    }


                }


                ManageCoordinateDetail rsDTO = new ManageCoordinateDetail();


                rsDTO.setLatitude(flyLat);


                rsDTO.setLongitude(flyLon);


                rsDTO.setState("2");


                rsDTO.setCreateTime(new Date());


                rsDTO.setUpdateTime(new Date());


                rsDTO.setCoordinateId(coordinateId);


                manageCoordinateDetailMapper.insert(rsDTO);


                j++;


                log.info(j+"");


            }


        }else {


            Map<String,Integer> map = new HashMap<>(manageCoordinateDetails.size()+50);


            manageCoordinateDetails.forEach(it->map.put(it.getLatitude()+"_"+it.getLongitude(),it.getId()));


            List<ManageCoordinateDetail> result = new ArrayList<>();


            for (CruiserDTO cruiserDTO : cruiserInfo) {


                String fly = cruiserDTO.getFlyLat()+"_"+cruiserDTO.getFlyLon();


               if(!map.containsKey(fly)){


                   ManageCoordinateDetail rsDTO = new ManageCoordinateDetail();


                   rsDTO.setLatitude(cruiserDTO.getFlyLat());


                   rsDTO.setLongitude(cruiserDTO.getFlyLon());


                   rsDTO.setState("2");


                   rsDTO.setCreateTime(new Date());


                   rsDTO.setUpdateTime(new Date());


                   rsDTO.setCoordinateId(coordinateId);


                   result.add(rsDTO);


               }


            }


            if(!CollectionUtils.isEmpty(result)){


                this.saveBatch(result);


            }


        }


        return 200;