1

13693261870

2023-04-26 d254c34b538e190fd5a9355d757f64bd495bdda9

 src/main/java/com/yssh/service/impl/SuYuanServiceImpl.java

@@ -1,5 +1,6 @@
package com.yssh.service.impl;

import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Date;
@@ -54,6 +55,8 @@
   
   @Autowired
   private FeedbackMapper feedbackMapper;

   private SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMddHH");
   
   //@Transactional
   @Override
@@ -122,7 +125,11 @@
      }
      List<DistanceSuYuan> list = suYuanMapper.getDistanceSuYuan(dictRecord.getTableName(), ids3d);
      AtomicInteger i = new AtomicInteger(0);
      list.stream().forEach(s->{s.setName(checkPoint.getName());i.getAndIncrement();s.setVocsName(checkPoint.getName()+ "-" + i.longValue());});
      list.stream().forEach(s -> {
         s.setName(checkPoint.getName());
         i.getAndIncrement();
         s.setVocsName(checkPoint.getName() + "-" + i.longValue());
      });
      if (StringUtils.isNotEmpty(list)) {
         Collections.sort(list);
         DistanceSuYuan max = list.get(0);
@@ -151,7 +158,11 @@
      }
      List<DistanceSuYuan> list = suYuanMapper.getDistanceSuYuan(dictRecord.getTableName(), ids3d);
      AtomicInteger i = new AtomicInteger(0);
      list.stream().forEach(s->{s.setName(checkPoint.getName());i.getAndIncrement();s.setVocsName(checkPoint.getName()+ "-" + i.longValue());});
      list.stream().forEach(s -> {
         s.setName(checkPoint.getName());
         i.getAndIncrement();
         s.setVocsName(checkPoint.getName() + "-" + i.longValue());
      });
      if (StringUtils.isNotEmpty(list)) {
         Collections.sort(list);
         DistanceSuYuan max = list.get(0);
@@ -180,7 +191,11 @@
      }
      List<DistanceSuYuan> list = suYuanMapper.getDistanceSuYuan(dictRecord.getTableName(), ids3d);
      AtomicInteger i = new AtomicInteger(0);
      list.stream().forEach(s->{s.setName(checkPoint.getName());i.getAndIncrement();s.setVocsName(checkPoint.getName()+ "-" + i.longValue());});
      list.stream().forEach(s -> {
         s.setName(checkPoint.getName());
         i.getAndIncrement();
         s.setVocsName(checkPoint.getName() + "-" + i.longValue());
      });
      if (StringUtils.isNotEmpty(list)) {
         Collections.sort(list);
         DistanceSuYuan max = list.get(0);
@@ -209,7 +224,11 @@
      }
      List<DistanceSuYuan> list = suYuanMapper.getDistanceSuYuan(dictRecord.getTableName(), ids3d);
      AtomicInteger i = new AtomicInteger(0);
      list.stream().forEach(s->{s.setName(checkPoint.getName());i.getAndIncrement();s.setVocsName(checkPoint.getName()+ "-" + i.longValue());});
      list.stream().forEach(s -> {
         s.setName(checkPoint.getName());
         i.getAndIncrement();
         s.setVocsName(checkPoint.getName() + "-" + i.longValue());
      });
      if (StringUtils.isNotEmpty(list)) {
         Collections.sort(list);
         DistanceSuYuan max = list.get(0);
@@ -230,8 +249,19 @@
      }
      List<DictRecord> recordList = dictRecordMapper.selectDictRecordList(new DictRecord());
      List<String> tableNames = new ArrayList<String>();
      recordList.stream().forEach(s -> {tableNames.add(s.getTableName());});
      recordList.stream().forEach(s -> {
         tableNames.add(s.getTableName());
      });
      return suYuanMapper.getMonitorData(tableNames, checkPoint.getX() + "_" + checkPoint.getY() + "_" + checkPoint.getZ());
   }

   @Override
   public int updateVocsName(Date date, String id, String vocsName) {
      String table = "su_yuan_" + dateFormat.format(new Date());
      if (isTableExists(table) == 0) {
         return 0;
      }

      return suYuanMapper.updateVocsName(table, id, vocsName);
   }
}