From de375ddfac39f69e2ead889e4233f1053d35413b Mon Sep 17 00:00:00 2001 From: wuzeyu <1223318623@qq.com> Date: 星期三, 18 十二月 2024 17:23:24 +0800 Subject: [PATCH] 部署梅江系统 --- pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/intake/IntakeSv.java | 126 ++++++++++++++++++++++++++++------------- 1 files changed, 85 insertions(+), 41 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 1b116c0..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 @@ -329,7 +329,7 @@ Integer openType = qo.getOpenType(); String openTypeName = ""; if (openType == null){ - openTypeName = "鏈煡"; + openTypeName = "涓嶇煡閬撴偍瑕佹煡閭g寮�闃�绫诲瀷"; }else { switch (openType) { case 1: @@ -342,13 +342,13 @@ openTypeName = "鐢ㄦ埛杩滅▼寮�闃�"; break; case 11: - openTypeName = "寮�鍏抽榾鍗″紑闃�"; + openTypeName = "宸℃鍗″紑闃�"; break; case 13: - openTypeName = "寮�鍏抽榾鍗″紑闃�"; + openTypeName = "宸℃鍗″紑闃�"; break; default: - openTypeName = "鏈煡"; + openTypeName = "涓嶇煡閬撴偍瑕佹煡閭g寮�闃�绫诲瀷"; } } @@ -374,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); @@ -764,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