蓄水量日报

guoshilong

2023-11-24 6a58ea0db0bc74f70933ca266d375afd0c287aae

 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztods/service/impl/SkxsQkTjServiceImpl.java

@@ -18,6 +18,7 @@
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.core.tool.utils.BeanUtil;
import org.springblade.core.tool.utils.StringUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
@@ -29,6 +30,8 @@
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collector;
import java.util.stream.Collectors;

/**
 * @ClassName SkxsQkTjServiceImpl
@@ -153,7 +156,7 @@
    * @param skxsQkTj
    */
   @Override
   public void saveOrUpdateData(SkxsQkTjVO skxsQkTj) {
   public String saveOrUpdateData(SkxsQkTjVO skxsQkTj) {
      // 参数拼接
      StringBuilder builder = new StringBuilder("?");
      builder.append("pageNo=1").append("&pageSize=1000");
@@ -181,8 +184,14 @@
         // 加入集合
         list.add(qkTj);
      }
      //手动去重（需要服务去重）
      List<SkxsQkTj> distinceList = list.stream().collect(Collectors.collectingAndThen(Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(p -> p.getResCode()))), ArrayList::new));
      // 批量插入
      saveBatch(list);
      saveBatch(distinceList);


      return "中台数据数量："+jsonArray.size()+"，数据库插入数量："+distinceList.size();

   }

   /**
@@ -214,7 +223,7 @@
      skxs.setLastYearWs(jsonArray.getJSONObject(i).getDouble("last_year_cap"));
      skxs.setHisWs(jsonArray.getJSONObject(i).getDouble("avg_cap"));
      skxs.setUpMonthWs(jsonArray.getJSONObject(i).getDouble("last_month_cap"));
      skxs.setTotalWsDif(jsonArray.getJSONObject(i).getString("diff_his"));
      skxs.setTotalWsDif(jsonArray.getJSONObject(i).getDouble("diff_his"));
   }

   /**