湖北水库项目
blame | history | patch | commit | commitdiff | ignore whitespace
zhangk
2024-06-22 3570bc18d5daed8079dd67891062ad8585a4e696 
 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/word/service/impl/SjztmdServiceImpl.java


@@ -2,6 +2,7 @@




import cn.gistack.common.utils.SpringContextUtil;


import cn.gistack.sm.sjztmd.entity.*;


import cn.gistack.sm.sjztmd.vo.AttResWithRainfall;


import cn.gistack.sm.sjztmd.vo.StationExport;


import cn.gistack.sm.sjztmd.vo.ZtResultInfo;


import cn.gistack.sm.sjztmd.vo.StationParams;


@@ -17,6 +18,7 @@


import com.alibaba.fastjson.JSONObject;


import com.alibaba.fastjson.parser.Feature;


import com.baomidou.dynamic.datasource.annotation.DS;


import com.baomidou.mybatisplus.core.toolkit.Wrappers;


import lombok.AllArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.springblade.core.tool.utils.ObjectUtil;


@@ -42,14 +44,11 @@


public class SjztmdServiceImpl implements ISjztmdService {




   //总计


//   private final String RIBAO_SHEET1_TOTAL_URL = "/services/1234567890ABCDEFGHIJKLMN/ribao_sheet1/api?small_start_stag=0&small_end_stag=2&mid_start_stag=0&mid_end_stag=2&big_start_stag=0&big_end_stag=2";


   private final String RIBAO_SHEET1_TOTAL_URL = "/services/1234567890ABCDEFGHIJKLMN/ribao_sheet1/api?small_start_stag=0&mid_start_stag=0&big_start_stag=0";


   private final String RIBAO_SHEET1_OVER_NORM_POOL_STAG = "/services/1234567890ABCDEFGHIJKLMN/ribao/sheet1_over_norm_pool_stag/api?";


   //中大型水库


//   private final String RIBAO_SHEET2_ZDX_URL = "/services/1234567890ABCDEFGHIJKLMN/ribao/sheet2_zdx/api?mid_start_stag=0&mid_end_stag=2&big_start_stag=0&big_end_stag=2";


   private final String RIBAO_SHEET2_ZDX_URL = "/services/1234567890ABCDEFGHIJKLMN/ribao/sheet2_zdx/api?mid_start_stag=0&big_start_stag=0";


   //超汛明细


//   private final String RIBAO_SHEET3_OVER_STAG_LIST_URL = "/services/1234567890ABCDEFGHIJKLMN/ribao/sheet3_over_stag_list/api?small_start_stag=0&small_end_stag=2&mid_start_stag=0&mid_end_stag=2&big_start_stag=0&big_end_stag=2";


   private final String RIBAO_SHEET3_OVER_STAG_LIST_URL = "/services/1234567890ABCDEFGHIJKLMN/ribao/sheet3_over_stag_list/api?small_start_stag=0&mid_start_stag=0&big_start_stag=0";


   //省直管


   private final String SZ_INFO = "/services/1234567890ABCDEFGHIJKLMN/ribao/shengzh_new_rz/api";


@@ -67,7 +66,7 @@


   @Autowired


   private RestTemplate restTemplate;


   private final SjztMdMapper mapper;




   private final IAttResBaseService attResBase;


   private final ITbAttResBaseService attResBaseService;


   private final ITbAttResStagCharService attResStagCharService;


   private final ITbAttResWaterDeliveryService attResWaterDeliveryService;


@@ -78,7 +77,7 @@


   private final ITbAttResWaterBlockService attResWaterBlockService;


   private final ITbAttResRsbNorspiService attResRsbNorspiService;


   private final ITbAttResPowerStationService attResPowerStationService;




   private final IStResRainfallService stResRainfallService;


   private final ITbAttResProjectUtilizeService attResProjectUtilizeService;


   private final ITbAttResInformationProjectService attResInformationProjectService;




@@ -619,6 +618,28 @@




   }




   @Override


   public void getReservoirRainfallForecast(List<String> dayIndexList) {


      List<StResRainfall> stResRainfalls = new ArrayList<>();


      for (String dayIndex : dayIndexList) {


         List<AttResWithRainfall> attResByRainfall = attResBase.getAttResByRainfall(null, null, dayIndex);


         for (AttResWithRainfall attResWithRainfall : attResByRainfall) {


            StResRainfall stResRainfall = new StResRainfall();


            stResRainfall.setId(UUID.randomUUID().toString().replaceAll("-", ""));


            stResRainfall.setResCd(attResWithRainfall.getCode());


            stResRainfall.setDrp(attResWithRainfall.getRainfall());


            stResRainfall.setFileName(attResWithRainfall.getFileName());


            stResRainfall.setDayIndex(dayIndex);


            stResRainfall.setCreateTime(new Date());


            stResRainfalls.add(stResRainfall);


         }


      }


      if (!stResRainfalls.isEmpty()) {


         stResRainfallService.remove(Wrappers.<StResRainfall>query().lambda());


         stResRainfallService.saveBatch(stResRainfalls);


      }


   }






   @Override


   public List<DzkInfo> getDzkInfo(String isShow) {