From 676e99259dbbf341d9f164cc8fab14b907eb3885 Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期六, 28 十二月 2024 15:03:39 +0800
Subject: [PATCH] 完善

---
 pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/IntakeSv.java |  183 +++++++++++++++++++++++++++++----------------
 1 files changed, 119 insertions(+), 64 deletions(-)

diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/IntakeSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/IntakeSv.java
index 596eeea..98a7e5f 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/IntakeSv.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/IntakeSv.java
@@ -64,13 +64,16 @@
          */
         String timeStart = qo.getTimeStart();
         String timeStop = qo.getTimeStop();
-        if(timeStart != null) {
-            timeStart = timeStart + " 00:00:00";
-        }else {
-            timeStart = LocalDate.now() + " 00:00:00";
-        }
+
         if(timeStop != null) {
             timeStop = timeStop + " 23:59:59";
+            if(timeStart != null) {
+                timeStart = timeStart + " 00:00:00";
+            }else {
+                timeStart = LocalDate.now() + " 00:00:00";
+            }
+        }else {
+            timeStart = null;
         }
         qo.setTimeStart(timeStart);
         qo.setTimeStop(timeStop);
@@ -306,39 +309,47 @@
      */
     public VoCountOfOpenType getCountByOpenType(OpenTypeQO qo) {
         /**
-         * 琛ラ綈璧锋鏃堕棿锛屽鏋滃紑濮嬫椂闂翠负绌猴紝鍒欓粯璁や负褰撳墠鏃ユ湡
+         * 琛ラ綈璧锋鏃堕棿锛屽鏋滃紑濮嬫椂闂翠负绌猴紝鍒欓粯璁や负褰撳墠鏃ユ湡锛屽鏋滅粨鏉熸椂闂翠负绌猴紝鍒欐煡璇㈡椂闂翠负绌�
          */
         String timeStart = qo.getTimeStart();
         String timeStop = qo.getTimeStop();
-        if(timeStart != null) {
-            timeStart = timeStart + " 00:00:00";
-        }else {
-            timeStart = LocalDate.now() + " 00:00:00";
-        }
         if(timeStop != null) {
             timeStop = timeStop + " 23:59:59";
+            if(timeStart != null) {
+                timeStart = timeStart + " 00:00:00";
+            }else {
+                timeStart = LocalDate.now() + " 00:00:00";
+            }
+        }else {
+            timeStart = null;
         }
         qo.setTimeStart(timeStart);
         qo.setTimeStop(timeStop);
 
         Integer openType = qo.getOpenType();
         String openTypeName = "";
-        switch (openType) {
-            case 1:
-                openTypeName = "鍒峰崱寮�闃�";
-                break;
-            case 3:
-                openTypeName = "涓績绔欏紑闃�";
-                break;
-            case 8:
-                openTypeName = "鐢ㄦ埛杩滅▼寮�闃�";
-                break;
-            case 11:
-                openTypeName = "寮�鍏抽榾鍗″紑闃�";
-                break;
-            case 13:
-                openTypeName = "寮�鍏抽榾鍗″紑闃�";
-                break;
+        if (openType == null){
+            openTypeName = "涓嶇煡閬撴偍瑕佹煡閭g寮�闃�绫诲瀷";
+        }else {
+            switch (openType) {
+                case 1:
+                    openTypeName = "鍒峰崱寮�闃�";
+                    break;
+                case 3:
+                    openTypeName = "涓績绔欏紑闃�";
+                    break;
+                case 8:
+                    openTypeName = "鐢ㄦ埛杩滅▼寮�闃�";
+                    break;
+                case 11:
+                    openTypeName = "宸℃鍗″紑闃�";
+                    break;
+                case 13:
+                    openTypeName = "宸℃鍗″紑闃�";
+                    break;
+                default:
+                    openTypeName = "涓嶇煡閬撴偍瑕佹煡閭g寮�闃�绫诲瀷";
+            }
         }
 
         // 鐢熸垚鏌ヨ鍙傛暟
@@ -363,52 +374,59 @@
          */
         String timeStart = qo.getTimeStart();
         String timeStop = qo.getTimeStop();
-        if(timeStart != null) {
-            timeStart = timeStart + " 00:00:00";
-        }else {
-            timeStart = LocalDate.now() + " 00:00:00";
-        }
         if(timeStop != null) {
             timeStop = timeStop + " 23:59:59";
+            if(timeStart != null) {
+                timeStart = timeStart + " 00:00:00";
+            }else {
+                timeStart = LocalDate.now() + " 00:00:00";
+            }
+        }else {
+            timeStart = null;
         }
         qo.setTimeStart(timeStart);
         qo.setTimeStop(timeStop);
 
         Integer closeType = qo.getCloseType();
         String closeTypeName = "";
-        switch (closeType) {
-            case 2:
-                closeTypeName = "鍒峰崱鍏抽榾";
-                break;
-            case 4:
-                closeTypeName = "涓績绔欏叧闃�";
-                break;
-            case 5:
-                closeTypeName = "娆犺垂鍏抽榾";
-                break;
-            case 6:
-                closeTypeName = "娴侀噺璁℃晠闅滃叧闃�";
-                break;
-            case 7:
-                closeTypeName = "绱ф�ュ叧闃�";
-                break;
-            case 9:
-                closeTypeName = "鐢ㄦ埛杩滅▼鍏抽榾";
-                break;
-            case 10:
-                closeTypeName = "寮�鍏抽榾鍗″叧闃�";
-                break;
-            case 12:
-                closeTypeName = "榛戝悕鍗曞懡浠ゅ叧闃�";
-                break;
-            case 13:
-                closeTypeName = "杩滅▼瀹氭椂鍏抽榾";
-                break;
-            case 14:
-                closeTypeName = "杩滅▼瀹氶噺鍏抽榾";
-                break;
+        if (closeType == null){
+            closeTypeName = "涓嶇煡閬撴偍瑕佹煡閭g鍏抽榾绫诲瀷";
+        }else {
+            switch (closeType) {
+                case 2:
+                    closeTypeName = "鍒峰崱鍏抽榾";
+                    break;
+                case 4:
+                    closeTypeName = "涓績绔欏叧闃�";
+                    break;
+                case 5:
+                    closeTypeName = "娆犺垂鍏抽榾";
+                    break;
+                case 6:
+                    closeTypeName = "娴侀噺璁℃晠闅滃叧闃�";
+                    break;
+                case 7:
+                    closeTypeName = "绱ф�ュ叧闃�";
+                    break;
+                case 9:
+                    closeTypeName = "鐢ㄦ埛杩滅▼鍏抽榾";
+                    break;
+                case 10:
+                    closeTypeName = "宸℃鍗″叧闃�";
+                    break;
+                case 12:
+                    closeTypeName = "榛戝悕鍗曞懡浠ゅ叧闃�";
+                    break;
+                case 13:
+                    closeTypeName = "杩滅▼瀹氭椂鍏抽榾";
+                    break;
+                case 14:
+                    closeTypeName = "杩滅▼瀹氶噺鍏抽榾";
+                    break;
+                default:
+                    closeTypeName = "涓嶇煡閬撴偍瑕佹煡閭g鍏抽榾绫诲瀷";
+            }
         }
-
         // 鐢熸垚鏌ヨ鍙傛暟
         Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo) ;
         Integer closeTypeCount = Optional.ofNullable(rmOpenCloseValveLastMapper.getCountByCloseType(params)).orElse(0);
@@ -753,4 +771,41 @@
         rsVo.obj = rmLossDayLastMapper.getMonthLossAmount(params);
         return rsVo ;
     }
+
+    /**
+     * 鏈�杩戞湭鎶ユ暟鐨勫彇姘村彛
+     * @param qo
+     * @return
+     */
+    public QueryResultVo<List<VoIntakeUnReported>> getUnReportedIntakes(CommonQO qo) {
+        String timeStart = qo.getTimeStart();
+        String timeStop = qo.getTimeStop();
+        if(timeStart == "") {
+            timeStart = null;
+        }
+        if(timeStop == "") {
+            timeStop = null;
+        }
+        if(timeStart != null && timeStart != "") {
+            timeStart = timeStart + " 00:00:00";
+        }
+        qo.setTimeStart(timeStart);
+
+        if(timeStop != null && timeStop != "") {
+            timeStop = timeStop + " 23:59:59";
+        }
+        qo.setTimeStop(timeStop);
+
+
+        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo);
+        Long itemTotal = rmOnHourReportLastMapper.getUnReportedIntakesCount(params);
+
+        QueryResultVo<List<VoIntakeUnReported>> rsVo = new QueryResultVo<>() ;
+        rsVo.pageSize = qo.pageSize ;
+        rsVo.pageCurr = qo.pageCurr ;
+
+        rsVo.calculateAndSet(itemTotal, params);
+        rsVo.obj = rmOnHourReportLastMapper.getUnReportedIntakes(params);
+        return rsVo ;
+    }
 }

--
Gitblit v1.8.0