From 4efc605092f68311876299290a33697ebbfd3a5d Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期三, 25 六月 2025 15:28:16 +0800
Subject: [PATCH] 水肥、气象、墒情数据处理：最新数据、历史数据、墒情日数据
---
pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/dbSv/DbSv.java | 254 ++++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 240 insertions(+), 14 deletions(-)
diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/dbSv/DbSv.java b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/dbSv/DbSv.java
index 4c6687c..a07d3ea 100644
--- a/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/dbSv/DbSv.java
+++ b/pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/dbSv/DbSv.java
@@ -1,16 +1,13 @@
package com.dy.rtuMw.server.rtuData.dbSv;
import com.dy.common.util.NumUtil;
-import com.dy.pipIrrGlobal.daoPr.PrControllerMapper;
-import com.dy.pipIrrGlobal.daoPr.PrControllerTrampMapper;
+import com.dy.pipIrrGlobal.daoPr.*;
import com.dy.pipIrrGlobal.daoRm.*;
import com.dy.pipIrrGlobal.daoSe.SeClientCardMapper;
import com.dy.pipIrrGlobal.daoSe.SeVirtualCardMapper;
-import com.dy.pipIrrGlobal.pojoPr.PrController;
-import com.dy.pipIrrGlobal.pojoPr.PrControllerTramp;
+import com.dy.pipIrrGlobal.pojoPr.*;
import com.dy.pipIrrGlobal.pojoRm.*;
import com.dy.pipIrrGlobal.pojoSe.SeClient;
-import com.dy.pipIrrGlobal.pojoSe.SeClientCard;
import com.dy.pipIrrGlobal.voSe.VoCardInfo1;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -69,9 +66,30 @@
private RmTimingReportLastMapper rmTimingReportLastDao; // 瀹氱偣涓婃姤鏈�鏂版暟鎹瓺AO
@Autowired
- private RmOnHourReportHistoryMapper rmOnHourReportHistoryDao; // 鏁寸偣涓婃姤鍘嗗彶鏁版嵁DAO
+ private RmOnHourReportHistoryMapper rmOnHourReportHistoryDao; // 瀹氱偣涓婃姤鍘嗗彶鏁版嵁DAO
@Autowired
- private RmOnHourReportLastMapper rmOnHourReportLastDao; // 鏁寸偣涓婃姤鏈�鏂版暟鎹瓺AO
+ private RmOnHourReportLastMapper rmOnHourReportLastDao; // 瀹氱偣涓婃姤鏈�鏂版暟鎹瓺AO
+
+ @Autowired
+ private PrStManureMapper prStManureDao; //姘磋偉鏈篋AO
+ @Autowired
+ private PrStSoilMapper prStSoilDao; //澧掓儏绔橠AO
+ @Autowired
+ private PrStWeatherMapper prStWeatherDao; //姘旇薄绔橠AO
+ @Autowired
+ private RmManureLastMapper rmManureLastDao; //姘磋偉DAO
+ @Autowired
+ private RmManureHistoryMapper rmManureHistoryDao; //姘磋偉DAO
+ @Autowired
+ private RmSoilLastMapper rmSoilLastDao; //澧掓儏DAO
+ @Autowired
+ private RmSoilHistoryMapper rmSoilHistoryDao; //澧掓儏DAO
+ @Autowired
+ private RmSoilDayMapper rmSoilDayDao; //澧掓儏DAO
+ @Autowired
+ private RmWeatherLastMapper rmWeatherLastDao; //姘旇薄DAO
+ @Autowired
+ private RmWeatherHistoryMapper rmWeatherHistoryDao; //姘旇薄DAO
//@Autowired
@@ -99,6 +117,7 @@
vo = new SeClient() ;
vo.setId(Long.parseLong(map.get("clientId").toString()));
vo.setName(map.get("clientName").toString());
+ vo.setAddress(map.get("clientAddress").toString());
}
}
return vo ;
@@ -117,6 +136,7 @@
vo = new SeClient() ;
vo.setId(Long.parseLong(map.get("clientId").toString()));
vo.setName(map.get("clientName").toString());
+ vo.setAddress(map.get("clientAddress").toString());
}
}
return vo ;
@@ -153,6 +173,9 @@
*/
@Transactional(rollbackFor = Exception.class)
public void savePrConctrollerTramp(PrControllerTramp po){
+ if(po.getOrgTag().trim().length() > 2) {
+ po.setOrgTag("DY");
+ }
this.prControllerTrampMapperDao.insert(po) ;
}
/**
@@ -212,8 +235,8 @@
* @param intakeId
*/
@Transactional(rollbackFor = Exception.class)
- public void updateVirCardNoUseState(Long intakeId){
- this.seVirtualCardDao.updateVcCardNoUseStateByIntakeId(intakeId); ;
+ public void updateVirCardNoUseState(Long intakeId, Date now){
+ this.seVirtualCardDao.updateVcCardNoUseStateByIntakeId(intakeId, now) ;
}
@@ -266,12 +289,12 @@
/////////////////////////////////////////////////
//
- // 鏁寸偣涓婃姤瀹炴椂鏁版嵁鍔熻兘(鍙湪闈虫�荤殑鍗忚鏈夋鏁版嵁)
+ // 瀹氱偣涓婃姤瀹炴椂鏁版嵁鍔熻兘(鍙湪闈虫�荤殑鍗忚鏈夋鏁版嵁)
//
////////////////////////////////////////////////
/**
- * 淇濆瓨鎺у埗鍣ㄦ暣鐐逛笂鎶ュ巻鍙叉暟鎹�
+ * 淇濆瓨鎺у埗鍣ㄥ畾鐐逛笂鎶ュ巻鍙叉暟鎹�
* @param po
*/
@Transactional(rollbackFor = Exception.class)
@@ -280,7 +303,7 @@
}
/**
- * 鏍规嵁闃�鎺у櫒鍦板潃鑾峰彇鏁寸偣涓婃姤鏈�鏂版暟鎹�
+ * 鏍规嵁闃�鎺у櫒鍦板潃鑾峰彇瀹氱偣涓婃姤鏈�鏂版暟鎹�
* @param intakeId
* @return
*/
@@ -294,7 +317,7 @@
}
/**
- * 淇濆瓨鎺у埗鍣ㄦ暣鐐逛笂鎶ユ渶鏂版暟鎹�
+ * 淇濆瓨鎺у埗鍣ㄥ畾鐐逛笂鎶ユ渶鏂版暟鎹�
* @param po
*/
@Transactional(rollbackFor = Exception.class)
@@ -303,7 +326,7 @@
}
/**
- * 淇濆瓨鎺у埗鍣ㄦ暣鐐逛笂鎶ョ姜琛屾暟鎹�
+ * 淇濆瓨鎺у埗鍣ㄥ畾鐐逛笂鎶ョ姜琛屾暟鎹�
* @param po
*/
@Transactional(rollbackFor = Exception.class)
@@ -690,6 +713,209 @@
seVirtualCardDao.updateMoney(id,remainMoney);
}
+
+ //////////////////////////////////////////////////////
+ //
+ // 姘磋偉鏁版嵁鐩稿叧
+ //
+ //////////////////////////////////////////////////////
+ /**
+ * 閫氳繃FBox搴忓垪鍙峰緱鍒版按鑲ユ満瀹炰綋
+ * @param fboxId FBox搴忓垪鍙�
+ * @param no 缂栧彿
+ * @return 姘磋偉鏈哄疄浣�
+ */
+ public PrStManure getStManureByFBoxIdAndNo(String fboxId, Integer no){
+ List<PrStManure> list = this.prStManureDao.selectStPoByFBoxIdAndNo(fboxId, no) ;
+ if(list != null && list.size() > 0){
+ return list.get(0) ;
+ }
+ return null ;
+ }
+ /**
+ * 鏌ヨ涓婃姤鏈�鏂版暟鎹�
+ * @param stManureId
+ * @return
+ */
+ public RmManureLast getRmManureLast(Long stManureId) {
+ List<RmManureLast> list = this.rmManureLastDao.selectRmManureLast(stManureId) ;
+ if(list != null && list.size() > 0){
+ return list.get(0) ;
+ }
+ return null ;
+ }
+ /**
+ * 淇濆瓨鏈�鏂拌褰�
+ * @param po
+ */
+ @Transactional(rollbackFor = Exception.class)
+ public void saveRmManureHistory(RmManureHistory po) {
+ this.rmManureHistoryDao.insert(po);
+ }
+
+ /**
+ * 淇濆瓨鏈�鏂拌褰�
+ * @param po
+ */
+ @Transactional(rollbackFor = Exception.class)
+ public void saveRmManureLast(RmManureLast po) {
+ this.rmManureLastDao.insert(po);
+ }
+ /**
+ * 鏇存柊鏈�鏂拌褰�
+ * @param po
+ */
+ @Transactional(rollbackFor = Exception.class)
+ public void updateRmManureLast(RmManureLast po){
+ this.rmManureLastDao.updateByPrimaryKey(po) ;
+ }
+
+
+ //////////////////////////////////////////////////////
+ //
+ // 澧掓儏鏁版嵁鐩稿叧
+ //
+ //////////////////////////////////////////////////////
+ /**
+ * 閫氳繃FBox搴忓垪鍙峰緱鍒板鎯呯珯瀹炰綋
+ * @param fboxId FBox搴忓垪鍙�
+ * @param no 缂栧彿
+ * @return 姘磋偉鏈哄疄浣�
+ */
+ public PrStSoil getStSoilByFBoxIdAndNo(String fboxId, Integer no){
+ List<PrStSoil> list = this.prStSoilDao.selectStPoByFBoxIdAndNo(fboxId, no) ;
+ if(list != null && list.size() > 0){
+ return list.get(0) ;
+ }
+ return null ;
+ }
+ /**
+ * 鏌ヨ涓婃姤鏈�鏂版暟鎹�
+ * @param stSoilId
+ * @return
+ */
+ public RmSoilLast getRmSoilLast(Long stSoilId) {
+ List<RmSoilLast> list = this.rmSoilLastDao.selectRmSoilLast(stSoilId) ;
+ if(list != null && list.size() > 0){
+ return list.get(0) ;
+ }
+ return null ;
+ }
+ /**
+ * 淇濆瓨鏈�鏂拌褰�
+ * @param po
+ */
+ @Transactional(rollbackFor = Exception.class)
+ public void saveRmSoilHistory(RmSoilHistory po) {
+ this.rmSoilHistoryDao.insert(po);
+ }
+
+ /**
+ * 淇濆瓨鏈�鏂拌褰�
+ * @param po
+ */
+ @Transactional(rollbackFor = Exception.class)
+ public void saveRmSoilLast(RmSoilLast po) {
+ this.rmSoilLastDao.insert(po);
+ }
+ /**
+ * 鏇存柊鏈�鏂拌褰�
+ * @param po
+ */
+ @Transactional(rollbackFor = Exception.class)
+ public void updateRmSoilLast(RmSoilLast po){
+ this.rmSoilLastDao.updateByPrimaryKey(po) ;
+ }
+
+ /**
+ * 鏌ヨ涓婃姤鏃ユ暟鎹�
+ * @param stSoilId
+ * @return
+ */
+ @Transactional(rollbackFor = Exception.class)
+ public RmSoilDay getRmSoilDay(Long stSoilId, Integer nowYmd) {
+ List<RmSoilDay> list = this.rmSoilDayDao.selectRmSoilDay(stSoilId, nowYmd) ;
+ if(list != null && list.size() > 0){
+ return list.get(0) ;
+ }
+ return null ;
+ }
+ /**
+ * 淇濆瓨鏃ヨ褰�
+ * @param po
+ */
+ @Transactional(rollbackFor = Exception.class)
+ public void saveRmSoilDay(RmSoilDay po) {
+ this.rmSoilDayDao.insert(po);
+ }
+ /**
+ * 鏇存柊鏃ヨ褰�
+ * @param po
+ */
+ @Transactional(rollbackFor = Exception.class)
+ public void updateRmSoilDay(RmSoilDay po){
+ this.rmSoilDayDao.updateByPrimaryKey(po) ;
+ }
+
+
+
+ //////////////////////////////////////////////////////
+ //
+ // 姘旇薄鏁版嵁鐩稿叧
+ //
+ //////////////////////////////////////////////////////
+ /**
+ * 閫氳繃FBox搴忓垪鍙峰緱鍒版皵璞＄珯瀹炰綋
+ * @param fboxId FBox搴忓垪鍙�
+ * @param no 缂栧彿
+ * @return 姘磋偉鏈哄疄浣�
+ */
+ public PrStWeather getStWeatherByFBoxIdAndNo(String fboxId, Integer no){
+ List<PrStWeather> list = this.prStWeatherDao.selectStPoByFBoxIdAndNo(fboxId, no) ;
+ if(list != null && list.size() > 0){
+ return list.get(0) ;
+ }
+ return null ;
+ }
+
+ /**
+ * 鏌ヨ涓婃姤鏈�鏂版暟鎹�
+ * @param stWeatherId
+ * @return
+ */
+ public RmWeatherLast getRmWeatherLast(Long stWeatherId) {
+ List<RmWeatherLast> list = this.rmWeatherLastDao.selectRmWeatherLast(stWeatherId) ;
+ if(list != null && list.size() > 0){
+ return list.get(0) ;
+ }
+ return null ;
+ }
+ /**
+ * 淇濆瓨鏈�鏂拌褰�
+ * @param po
+ */
+ @Transactional(rollbackFor = Exception.class)
+ public void saveRmWeatherHistory(RmWeatherHistory po) {
+ this.rmWeatherHistoryDao.insert(po);
+ }
+
+ /**
+ * 淇濆瓨鏈�鏂拌褰�
+ * @param po
+ */
+ @Transactional(rollbackFor = Exception.class)
+ public void saveRmWeatherLast(RmWeatherLast po) {
+ this.rmWeatherLastDao.insert(po);
+ }
+ /**
+ * 鏇存柊鏈�鏂拌褰�
+ * @param po
+ */
+ @Transactional(rollbackFor = Exception.class)
+ public void updateRmWeatherLast(RmWeatherLast po){
+ this.rmWeatherLastDao.updateByPrimaryKey(po) ;
+ }
+
//////////////////////////////////////////////////////
//
// 鍛戒护鏃ュ織鐩稿叧
--
Gitblit v1.8.0