枪支定位数据查询修改

Administrator

2021-12-02 71ca853ee10f712055bd7b9a7eaf2c71c4d9b5c8

 src/main/java/org/springblade/modules/location/service/impl/LiveLocationServiceImpl.java

@@ -1,15 +1,27 @@
package org.springblade.modules.location.service.impl;

import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.json.JSONArray;
import org.json.JSONObject;
import org.springblade.common.utils.InvestigateUtil;
import org.springblade.modules.equipage.entity.Gun;
import org.springblade.modules.equipage.service.GunService;
import org.springblade.modules.location.entity.LiveLocation;
import org.springblade.modules.location.mapper.LiveLocationMapper;
import org.springblade.modules.location.service.LiveLocationService;
import org.springblade.modules.location.vo.GunLiveLocationVO;
import org.springblade.modules.location.vo.LiveLocationVo;
import org.springblade.modules.location.vo.LocusVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.Comparator;
import java.util.List;
import java.util.stream.Collectors;

/**
 * 实时位置服务实现类
@@ -17,6 +29,9 @@
 */
@Service
public class LiveLocationServiceImpl extends ServiceImpl<LiveLocationMapper, LiveLocation> implements LiveLocationService {

   @Autowired
   private GunService gunService;

   /**
    * 实时位置分页信息
@@ -45,6 +60,137 @@
    */
   @Override
   public List<LocusVo> getLocusInfoList(LiveLocationVo liveLocationVo) {

      return baseMapper.getLocusInfoList(liveLocationVo);
   }



   /**
    * 首页实时定位
    * @return
    */
   @Override
   public List<LiveLocationVo> getLiveLocationVoList(LiveLocationVo liveLocationVo) {
      //保安人员
      if (liveLocationVo.getType()==1){
         return baseMapper.getSecurityLocusInfoList(liveLocationVo);
      }
      //车辆
      if (liveLocationVo.getType()==2){
         return baseMapper.getCarLocusInfoList(liveLocationVo);
      }
      //枪支
      if (liveLocationVo.getType()==3){
         //获取枪支数据
         List<Gun> gunList = gunService.list();
         //创建集合
         List<LiveLocationVo> list = new ArrayList<>();
         if (gunList.size()>0){
            //遍历
            gunList.forEach(gun -> {
               //远程调用
               String body = InvestigateUtil.httpGetGunPosition(gun.getCardNo(),null,null,null,null,null);
//               System.out.println("body = " + body);
               if (null != body && !body.equals("")) {
                  JSONObject jsonObject = new JSONObject(body);
                  Object data = jsonObject.get("data");
                  JSONObject jsonData = new JSONObject(data.toString());
                  JSONArray res = jsonData.getJSONArray("res");
                  //转换string
                  String resToString = res.toString();
                  if (res.length() == 0) {
                  } else {
                     LiveLocationVo locationVo = new LiveLocationVo();
                     List<GunLiveLocationVO> gunLiveLocationVOS = JSON.parseArray(resToString, GunLiveLocationVO.class);
                     //按时间排序(降序)
                     List<GunLiveLocationVO> gunLiveLocationVOList =
                        gunLiveLocationVOS.stream().sorted(Comparator.comparing(GunLiveLocationVO::getDwsj).reversed()).collect(Collectors.toList());
                     GunLiveLocationVO gunLiveLocationVO = gunLiveLocationVOList.get(0);
                     //取出第一个
                     locationVo.setRecordTime(gunLiveLocationVO.getDwsj());
                     locationVo.setLinkman(gunLiveLocationVO.getHwy());
                     locationVo.setCardNo(gunLiveLocationVO.getHwysfzh());
                     locationVo.setNumber(gunLiveLocationVO.getQzbh());
                     locationVo.setQh(gunLiveLocationVO.getQh());
                     locationVo.setLongitude(gunLiveLocationVO.getDwjd().toString());
                     locationVo.setLatitude(gunLiveLocationVO.getDwwd().toString());
                     locationVo.setCompany(gunLiveLocationVO.getSzdw());
                     //存入集合
                     list.add(locationVo);
                  }
               }
            });
         }
         return list;
      }
      return baseMapper.selectSecurityAndCarAndGunLiveLocationPage(liveLocationVo);
   }

   /**
    * 获取实时位置信息
    * @param liveLocation
    * @return
    */
   @Override
   public LiveLocation getLiveLocationInfo(LiveLocation liveLocation) {
      return baseMapper.getLiveLocationInfo(liveLocation);
   }


   /**
    * 获取指令接收人的定位信息
    * @param liveLocationVo 定位数据信息
    * @return
    */
   @Override
   public List<LiveLocationVo> getDirectiveLiveLocationVoList(LiveLocationVo liveLocationVo) {
      ArrayList<LiveLocationVo> arrayList = new ArrayList<>();
      //人员
      if (liveLocationVo.getType()==1){
         String userIds = liveLocationVo.getUserIds();
         if (null!=userIds && userIds!=""){
            List<String> list = Arrays.asList(userIds.split(","));
            if (list.size()>0){
               list.forEach(userId->{
                  liveLocationVo.setWorkerId(userId);
                  LiveLocationVo directiveLiveLocationVo = baseMapper.getDirectiveLiveLocationVo(liveLocationVo);
                  //如果存在定位数据
                  if (null!=directiveLiveLocationVo){
                     arrayList.add(directiveLiveLocationVo);
                  }
               });
            }
         }
      }
      return arrayList;
   }

   /**
    * 获取指令接收人的轨迹数据
    * @param liveLocationVo 实时对象信息
    * @return
    */
   @Override
   public List<List<LocusVo>> getDirectiveLocusInfoList(LiveLocationVo liveLocationVo) {
      List<List<LocusVo>> arrayList = new ArrayList<>();
      //人员
      if (liveLocationVo.getType()==1){
         String userIds = liveLocationVo.getUserIds();
         if (null!=userIds && userIds!=""){
            List<String> list = Arrays.asList(userIds.split(","));
            if (list.size()>0){
               list.forEach(userId->{
                  liveLocationVo.setWorkerId(userId);
                  List<LocusVo> directiveLocusInfoList = baseMapper.getDirectiveLocusInfoList(liveLocationVo);
                  //如果存在轨迹数据
                  if (directiveLocusInfoList.size()>0){
                     arrayList.add(directiveLocusInfoList);
                  }
               });
            }
         }
      }
      return arrayList;
   }
}