pipIrr-platform/pipIrr-global/src/main/resources/mapper/RmWeatherHistoryMapper.xml
@@ -90,7 +90,7 @@ <!--根据指定条件查询温度的最大值与最小值--> <select id="selectMaxMinTemperature" resultType="com.dy.pipIrrGlobal.voRm.VoWeatherMaxMinTmp"> SELECT max(air_temperature) maxTmp, min(air_temperature) minTmp SELECT max(air_temperature) maxAirTemperature, min(air_temperature) minAirTemperature FROM rm_weather_history tb <where> <if test="weatherId != null"> pipIrr-platform/pipIrr-web/pipIrr-web-model/src/main/java/com/dy/pipIrrModel/modelCalculate/ModelCalculator.java
@@ -1,5 +1,6 @@ package com.dy.pipIrrModel.modelCalculate; import com.dy.common.multiDataSource.DataSourceContext; import com.dy.common.util.DateTime; import com.dy.pipIrrGlobal.pojoMd.MdEt0; import com.dy.pipIrrGlobal.voMd.VoCrops; @@ -32,6 +33,7 @@ } public void execute(){ String orgTag = DataSourceContext.get() ; List<VoCrops> crops = this.sv.selectAllCrops() ; if(crops != null && crops.size() > 0){ for (VoCrops crop : crops) { @@ -47,6 +49,7 @@ } } } orgTag = DataSourceContext.get() ; } private void executeOnCrop(VoCrops vo, VoWeather voWeather) throws Exception{ String yesterday_ymd = DateTime.yesterday_yyyy_MM_dd(Integer.parseInt(DateTime.yyyy()), Integer.parseInt(DateTime.MM()), Integer.parseInt(DateTime.dd())) ; //昨天 @@ -57,7 +60,7 @@ if(tmps != null && tmps.size() > 0){ VoWeatherMaxMinTmp voMmTmp = tmps.get(0);//只能有一条记录 Double et0 = this.calculateEt0(yesterday_ymd, vo, voWeather, voMmTmp, factor) ;//计算蒸腾数据 this.saveEt0(yesterday_ymd, vo, voWeather, voMmTmp, factor, et0) ; Integer count = this.saveEt0(yesterday_ymd, vo, voWeather, voMmTmp, factor, et0) ; } } } @@ -120,11 +123,12 @@ return et0 ; } private void saveEt0(String yesterday_ymd, VoCrops vo, VoWeather voWeather, VoWeatherMaxMinTmp voMmTmp, Double factor, Double et0)throws Exception{ private Integer saveEt0(String yesterday_ymd, VoCrops vo, VoWeather voWeather, VoWeatherMaxMinTmp voMmTmp, Double factor, Double et0)throws Exception{ MdEt0 po = this.sv.selectByCropWeatherDt(vo.id, voWeather.id, yesterday_ymd); if(po != null){ if(po == null){ Date yesterday = DateTime.dateFrom_yyyy_MM_dd(yesterday_ymd) ; this.sv.saveEt0(vo.id, voWeather.id, yesterday, voMmTmp.maxAirTemperature, voMmTmp.minAirTemperature, factor, et0) ; return this.sv.saveEt0(vo.id, voWeather.id, yesterday, voMmTmp.maxAirTemperature, voMmTmp.minAirTemperature, factor, et0) ; } return null ; } } pipIrr-platform/pipIrr-web/pipIrr-web-model/src/main/java/com/dy/pipIrrModel/modelCalculate/ModelCalculatorSv.java
@@ -11,7 +11,6 @@ import com.dy.pipIrrGlobal.voPr.VoWeather; import com.dy.pipIrrGlobal.voRm.VoWeatherMaxMinTmp; import lombok.extern.slf4j.Slf4j; import org.apache.ibatis.annotations.Param; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -77,7 +76,6 @@ po.minTmp = minAirTemperature ; po.factor = factor ; po.et0 = et0 ; this.mdEt0Dao.insert(po) ; return 0 ; return this.mdEt0Dao.insert(po) ; } } pipIrr-platform/pipIrr-web/pipIrr-web-model/src/main/java/com/dy/pipIrrModel/vapor/VaporCtrl.java
@@ -6,7 +6,6 @@ import com.dy.common.webUtil.BaseResponseUtils; import com.dy.common.webUtil.ResultCodeMsg; import com.dy.pipIrrGlobal.pojoMd.MdEt0; import com.dy.pipIrrGlobal.voRm.VoManure; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.media.Content; import io.swagger.v3.oas.annotations.media.Schema; @@ -75,7 +74,7 @@ */ @GetMapping(path = "oneCropsSomeEt0") @SsoAop() public BaseResponse<List<VoManure>> oneCropsSomeEt0(VaporQo qo){ public BaseResponse<List<MdEt0>> oneCropsSomeEt0(VaporQo qo){ try { if(qo.cropId == null){ return BaseResponseUtils.buildFail("作物id不能为空") ;