yxm
2024-07-01 fc2adc3521931c2f7bc5b2f3a3d94ebf407828d6
skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/impl/TbAttResBaseServiceImpl.java
@@ -10,6 +10,7 @@
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.core.tool.utils.StringUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -243,7 +244,6 @@
      CompletableFuture<List<Map<String,Object>>> tbAttResWaterBlock = getTbInfo("tb_att_res_water_block",resGuid,executor);
      CompletableFuture<List<Map<String,Object>>> tbAttResWaterDelivery = getTbInfo("tb_att_res_water_delivery",resGuid,executor);
      CompletableFuture<List<Map<String,Object>>> tbFileStorageLocation = getTbInfo("tb_file_storage_location",resGuid,executor);
      CompletableFuture<List<Map<String,Object>>> tbResStagCapDisc = getTbInfo("tb_res_stag_cap_disc",resGuid,executor);
      //等待所有任务执行完成
      try {
         CompletableFuture.allOf(
@@ -260,8 +260,7 @@
            tbAttResSafetyMonitor,
            tbAttResStagChar,
            tbAttResWaterBlock,
            tbAttResWaterDelivery,
            tbResStagCapDisc
            tbAttResWaterDelivery
         ).get();
         // 数据处理
         list.addAll(tbAttResBaseInfo.get());
@@ -278,7 +277,6 @@
         list.addAll(tbAttResWaterBlock.get());
         list.addAll(tbAttResWaterDelivery.get());
         list.addAll(tbFileStorageLocation.get());
         list.addAll(tbResStagCapDisc.get());
      } catch (InterruptedException e) {
         e.printStackTrace();
      } catch (ExecutionException e) {
@@ -354,4 +352,99 @@
      //更新
      return updateById(tbAttResBase);
   }
   @Override
   public String initTbData() {
      //初始化基础信心
      Integer tbAttresBase = initTbAttResBase();
      //初始化水文特征
      Integer  tbAttResStagChar = initTbAttResStagChar();
      //初始化挡水建筑物
      Integer  tbAttResWaterBlock= initTbAttResWaterBlock();
      //初始化正常溢洪道
      Integer tbAttResRsbNorspi= initTbAttResRsbNorspi();
      //初始化泄洪洞
      Integer tbAttResRsbSpillway= initTbAttResRsbSpillway();
      //初始化非常溢洪道
      Integer tbAttResRsbVerspi=initTbAttResRsbVerspi();
      //初始化输水建筑物
      Integer tbAttResWaterDelivery=initTbAttResWaterDelivery();
      //初始化电站
      Integer tbAttResPowerStation=initTbAttResPowerStation();
      //初始化管理体制
      Integer tbAttResMgrSysB=initTbAttResMgrSysB();
      //初始化除险加固
      Integer tbAttResSafetyMonitor=initTbAttResSafetyMonitor();
      String message = StringUtil.format(
         "基础信息更新数量为{}," +
            "水文特征更新数量为{}," +
            "挡水建筑物更新数量为{}," +
            "正常溢洪道更新数量为{}," +
            "泄洪洞更新数量为{}," +
            "非常溢洪道更新数量为{}," +
            "输水建筑物更新数量为{}," +
            "电站更新数量为{}," +
            "管理体制更新数量为{}," +
            "除险加固更新数量为{}",tbAttresBase,tbAttResStagChar,tbAttResWaterBlock,tbAttResRsbNorspi,tbAttResRsbSpillway,tbAttResRsbVerspi,tbAttResWaterDelivery,tbAttResPowerStation,tbAttResMgrSysB,tbAttResSafetyMonitor
      );
      return message;
   }
   private Integer initTbAttResSafetyMonitor() {
      return baseMapper.initTbAttResSafetyMonitor();
   }
   private Integer initTbAttResMgrSysB() {
      return baseMapper.initTbAttResMgrSysB();
   }
   private Integer initTbAttResPowerStation() {
      return baseMapper.initTbAttResPowerStation();
   }
   private Integer initTbAttResWaterDelivery() {
      return baseMapper.initTbAttResWaterDelivery();
   }
   private Integer initTbAttResRsbVerspi() {
      return baseMapper.initTbAttResRsbVerspi();
   }
   private Integer initTbAttResRsbSpillway() {
      return baseMapper.initTbAttResRsbSpillway();
   }
   private Integer initTbAttResRsbNorspi() {
      return baseMapper.initTbAttResRsbNorspi();
   }
   private Integer initTbAttResWaterBlock() {
      return baseMapper.initTbAttResWaterBlock();
   }
   /**
    * 初始化填报水文特征表
    */
   private Integer initTbAttResStagChar() {
      return baseMapper.initTbAttResStagChar();
   }
   /**
    * 初始化水库基础信息填报表
    */
   private Integer initTbAttResBase() {
      Integer i = baseMapper.initTbAttResBase();
      return i;
   }
}