变更观测数据源

13693261870

2024-03-13 f6e0b62b719eeb948125c98cf6ceb249f70645f6

 src/main/java/com/yssh/service/SuYuanService.java

@@ -47,6 +47,15 @@
   @Resource
   private LocationService locService;

   @Resource
   private AlertConfigMapper alertConfigMapper;

   private static HashMap<String, String> sites = new HashMap<>();

   public double getJcyj() {
      return alertConfigMapper.getAll().get(0).getJcyj();
   }

   //@Transactional
   @Async("threadPoolTaskExecutor")
   public void insertSuYuanDatasAsync(List<SuYuan> lists, String time) throws Exception {
@@ -103,7 +112,7 @@
   }

   public Map<String, Object> selectSuYuan100(String name, Date date) {
      Map<String, Object> result = new HashMap<String, Object>();
      Map<String, Object> result = new HashMap<>();
      MonitorPointPosition checkPoint = commonService.select3dCheckPointByName(name);
      if (StringUtils.isNull(checkPoint)) {
         return null;
@@ -205,7 +214,7 @@
   }

   public Map<String, Object> selectSuYuan500(String name, Date date) {
      Map<String, Object> result = new HashMap<String, Object>();
      Map<String, Object> result = new HashMap<>();
      MonitorPointPosition checkPoint = commonService.select3dCheckPointByName(name);
      if (StringUtils.isNull(checkPoint)) {
         return null;
@@ -263,7 +272,7 @@
      calendar.add(Calendar.DATE, -7);
      String start = DateUtils.getYyyyMmDdHh(calendar.getTime());

      return suYuanMapper.getNewMonitorData(checkPoint.getName(), start, end);
      return qxshMapper.getNewMonitorData(checkPoint.getName(), start, end);
   }

   public int updateVocsName(Date date, String id, String vocsName) {
@@ -306,16 +315,44 @@
   }

   public String selectAddrByXY(double x, double y) {
      // 1米=0.0000089932
      List<Location> locations = locationMapper.selectByXY(x, y);
      if (null != locations && locations.size() > 0) {
         return locations.get(0).getName();
      }

      locations = locService.selectVocAddrs(x, y);
      /*locations = locService.selectVocAddrs(x, y);
      if (null != locations && locations.size() > 0) {
         return locations.get(0).getName();
      }
      }*/

      return null;
   }

   public String selectSuYuanIdByName(String name) {
      if (sites.containsKey(name)) {
         return sites.get(name);
      }

      MonitorPointPosition mpp = commonService.select3dCheckPointByName(name);
      if (null == mpp) {
         return null;
      }

      String suYuanId = mpp.getId().substring(0, mpp.getId().lastIndexOf("_") + 1) + "0";
      if (!sites.containsKey(name)) {
         sites.put(name, suYuanId);
      }

      return suYuanId;
   }

   /**
    * 根据ID查询快速溯源
    */
   public List<SuYuanFast> selectFastById(String id, Date date) {
      String time = DateUtils.getYyyyMmDdHhMmSs(date);

      return suYuanMapper.selectFastById(id, time);
   }
}