From 9f3c4a33279f10ed420d604765487558ab0744f0 Mon Sep 17 00:00:00 2001
From: zhubaomin <zhubaomin>
Date: 星期五, 11 四月 2025 11:42:21 +0800
Subject: [PATCH] 获取已完成灌溉计划接口增加分页功能
---
pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/largeScreen/Ls4StatisticsSv.java | 173 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 173 insertions(+), 0 deletions(-)
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/largeScreen/Ls4StatisticsSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/largeScreen/Ls4StatisticsSv.java
new file mode 100644
index 0000000..e1a279a
--- /dev/null
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/largeScreen/Ls4StatisticsSv.java
@@ -0,0 +1,173 @@
+package com.dy.pipIrrStatistics.largeScreen;
+
+import com.alibaba.fastjson2.JSON;
+import com.alibaba.fastjson2.JSONObject;
+import com.dy.common.mw.protocol.Command;
+import com.dy.common.mw.protocol.CommandBackParam;
+import com.dy.common.util.DateTime;
+import com.dy.common.util.IDLongGenerator;
+import com.dy.common.webUtil.BaseResponse;
+import com.dy.pipIrrGlobal.daoLargeScreen.Ls4StatisticsMapper;
+import com.dy.pipIrrGlobal.rtuMw.CodeLocal;
+import com.dy.pipIrrGlobal.rtuMw.Web2RtuMw;
+import com.dy.pipIrrGlobal.voLargeScreen.VoBaseInfo;
+import com.dy.pipIrrGlobal.voLargeScreen.VoCurrentInfo;
+import com.dy.pipIrrGlobal.voLargeScreen.VoMonitorInfo;
+import com.dy.pipIrrGlobal.voSpecial.VoTopXClient;
+import com.dy.pipIrrGlobal.voSpecial.VoTopXIntake;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.core.env.Environment;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Author: liurunyu
+ * @Date: 2025/2/6 10:33
+ * @Description
+ */
+@Slf4j
+@Service
+public class Ls4StatisticsSv extends Web2RtuMw {
+ private Environment env;
+ private RestTemplate restTemplate;
+ private Ls4StatisticsMapper dao ;
+
+ @Autowired
+ private void setEnvironment(Environment env){
+ this.env = env;
+ }
+ @Autowired
+ private void setRestTemplate(RestTemplate restTemplate){
+ this.restTemplate = restTemplate;
+ }
+ @Autowired
+ private void setDao(Ls4StatisticsMapper dao){
+ this.dao = dao;
+ }
+
+ /**
+ * 鍩烘湰淇℃伅缁熻
+ * @return
+ */
+ public VoBaseInfo baseInfo(){
+ VoBaseInfo vo = new VoBaseInfo() ;
+ vo.totalCountOfTown = this.dao.totalCountOfDistrict(3) ;
+ vo.totalCountOfVillage = this.dao.totalCountOfDistrict(4) ;
+ vo.totalCountOfBlock = this.dao.totalCountOfBlock() ;
+ vo.totalCountOfDivide = this.dao.totalCountOfDivide() ;
+ vo.totalCountOfIntake = this.dao.totalCountOfIntake() ;
+ vo.totalCountOfIntakeWithController = this.dao.totalCountOfIntakeWithController() ;
+ vo.totalCountOfIntakeWithoutController = this.dao.totalCountOfIntakeWithoutController() ;
+ vo.totalCountOfController = this.dao.totalCountOfController() ;
+ vo.totalCountOfControllerTramp = this.dao.totalCountOfControllerTramp() ;
+ return vo ;
+ }
+
+ /**
+ * 褰撳墠淇℃伅缁熻
+ * @return
+ */
+ public VoCurrentInfo currentInfo() throws Exception{
+ Integer totalCountOfIntake = this.dao.totalCountOfIntake() ;
+ Date dtAtXHourBefore = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(DateTime.lastXHour_yyyy_MM_dd_HH_mm_ss(24)) ;//X涓皬鏃跺墠
+ VoCurrentInfo vo = new VoCurrentInfo() ;
+ Integer[] result = this.queryMwOnAndOffLine() ;
+ vo.cTotalCountOfOnLine = result[0] ;
+ vo.cTotalCountOfOffLine = totalCountOfIntake - vo.cTotalCountOfOnLine;
+ vo.cTotalCountOfOffLine = vo.cTotalCountOfOffLine < 0 ? 0 : vo.cTotalCountOfOffLine ;
+
+ vo.cTotalCountOfOpenValve = this.dao.totalCountOfOpenValve(dtAtXHourBefore) ;
+ vo.cTotalCountOfCloseValve = this.dao.totalCountOfCloseValve(dtAtXHourBefore) ;
+ vo.cTotalCountOfUnknownValve = totalCountOfIntake - vo.cTotalCountOfOpenValve - vo.cTotalCountOfCloseValve;
+ vo.cTotalCountOfUnknownValve = vo.cTotalCountOfUnknownValve < 0 ? 0 : vo.cTotalCountOfUnknownValve ;
+
+ vo.cTotalCountOfAlarm = this.dao.totalCountOfAlarm(dtAtXHourBefore) ;
+ vo.cTotalCountOfNoAlarm = this.dao.totalCountOfNoAlarm(dtAtXHourBefore) ;
+ vo.cTotalCountOfUnknownAlarm = totalCountOfIntake - vo.cTotalCountOfAlarm - vo.cTotalCountOfNoAlarm;
+ vo.cTotalCountOfUnknownAlarm = vo.cTotalCountOfUnknownAlarm < 0 ? 0 : vo.cTotalCountOfUnknownAlarm ;
+ return vo ;
+ }
+
+ /**
+ * 鐩戞祴淇℃伅缁熻
+ * @return
+ */
+ public VoMonitorInfo monitorInfo(Date fromDt){
+ VoMonitorInfo vo = new VoMonitorInfo() ;
+ vo.mTotalCountOfReport = this.dao.mTotalCountOfReport(fromDt) ;
+ vo.mTotalCountOfNoReport = this.dao.mTotalCountOfNoReport(fromDt) ;
+ vo.mTotalCountOfNeverReport = this.dao.mTotalCountOfNeverReport() ;
+
+ vo.mTotalCountOfOpenValve = this.dao.mTotalCountOfOpenValve(fromDt) ;
+ vo.mTotalCountOfCloseValve = this.dao.mTotalCountOfCloseValve(fromDt) ;
+ vo.mTotalCountOfNeverOpenValve = this.dao.mTotalCountOfNeverOpenValve() ;
+
+ vo.mTotalCountOfAlarm = this.dao.mTotalCountOfAlarm(fromDt) ;
+ vo.mTotalCountOfNoAlarm = this.dao.mTotalCountOfNoAlarm(fromDt) ;
+ vo.mTotalCountOfNeverAlarm = this.dao.mTotalCountOfNeverAlarm() ;
+
+ return vo ;
+ }
+
+ /**
+ * 鏌ヨ鍙栨按鍙ｅ湪绾垮拰绂荤嚎缁熻
+ * @return
+ */
+ private Integer[] queryMwOnAndOffLine() {
+ Integer[] result = new Integer[]{0,0} ;
+ //鍚戦�氫俊涓棿浠跺彂鍏冲懡浠わ紝鏌ヨRTU鍦ㄧ嚎缁熻鎯呭喌
+ Command com = this.createInnerCommand(CodeLocal.onLineStatistics);
+ String rqUrl = this.get2MwRequestUrl(this.env, ContextComSend) ;
+ BaseResponse res = this.sendPostRequest2Mw(restTemplate, rqUrl, com) ;
+ if(res != null){
+ if(res.isSuccess()){
+ Command reCom = JSON.parseObject(res.getContent() == null ? null : JSON.toJSONString(res.getContent()), Command.class) ;
+ CommandBackParam bakParam = JSON.parseObject((reCom== null || reCom.param == null) ? null : JSON.toJSONString(reCom.param), CommandBackParam.class) ;
+ if(bakParam != null){
+ if(bakParam.getSuccess().booleanValue() && reCom.getAttachment() != null){
+ //閫氫俊涓棿浠舵垚鍔熻繑鍥炲懡浠ょ粨鏋�
+ JSONObject comRes = (JSONObject) JSON.toJSON(reCom.getAttachment());
+ result[0] = comRes.getInteger("onLineNum") ;
+ result[1] = comRes.getInteger("offLineNum") ;
+ }
+ }else{
+ log.error("閫氫俊涓棿浠惰繑鍥炲唴閮ㄥ懡浠ょ粨鏋滀腑涓嶅寘鍚獵ommandBackParam绫诲瀷鍙傛暟");
+ }
+ }else{
+ log.error("閫氫俊涓棿浠惰繑鍥炲唴閮ㄥ懡浠ゆ墽琛屽け璐�" + (res.getMsg() == null? "" : ("锛�" + res.getMsg()))) ;
+ }
+ }else{
+ log.error("閫氫俊涓棿浠惰繑鍥炲唴閮ㄥ懡浠ょ粨鏋滀负null");
+ }
+ return result ;
+ }
+
+
+
+ /**
+ * 鏄ㄦ棩鍐滄埛鐢ㄦ按鍓�5鍚嶇粺璁�
+ * @return 鏁版嵁闆嗗悎
+ */
+ public List<VoTopXClient> top5ClientYesterday() {
+ int[] yesterday = DateTime.yyyy_MM_dd_2_ymdGroup(DateTime.lastXDay_yyyy_MM_dd(1)) ;
+ Long idStart = IDLongGenerator.generateOneDayStartId(yesterday[0], yesterday[1], yesterday[2]) ;
+ Long idEnd = IDLongGenerator.generateOneDayEndId(yesterday[0], yesterday[1], yesterday[2]) ;
+ return this.dao.topXClientAtCertainDay(idStart, idEnd, 5) ;
+ }
+
+ /**
+ * 鏄ㄦ棩鍙栨按鍙ｇ敤姘村墠5鍚嶇粺璁�
+ * @return 鏁版嵁闆嗗悎
+ */
+ public List<VoTopXIntake> top5IntakeYesterday() {
+ int[] yesterday = DateTime.yyyy_MM_dd_2_ymdGroup(DateTime.lastXDay_yyyy_MM_dd(1)) ;
+ Long idStart = IDLongGenerator.generateOneDayStartId(yesterday[0], yesterday[1], yesterday[2]) ;
+ Long idEnd = IDLongGenerator.generateOneDayEndId(yesterday[0], yesterday[1], yesterday[2]) ;
+ return this.dao.topXIntakeAtCertainDay(idStart, idEnd, 5) ;
+ }
+
+}
--
Gitblit v1.8.0