From 34c5df174a03341fa469a5196410205cebc26b82 Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Thu, 29 Feb 2024 10:03:34 +0800
Subject: [PATCH] Merge branch 'dev' of http://blit.7drlb.com:8888/r/moral into wb

---
 screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java |  126 ++++++++++++++++++++++++++++-------------
 1 files changed, 85 insertions(+), 41 deletions(-)

diff --git a/screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java b/screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java
index f1ae4d1..2d779fd 100644
--- a/screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java
+++ b/screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java
@@ -557,13 +557,16 @@
         long diff = end.getTime() - start.getTime(); //������������
         long hour = (diff / nh)+1; //������������������������
 
-
+        Map<String, List<OnlineRateVo>> collectList=new HashMap<>();
         List<OnlineRateVo> OnlineRateVoList = deviceMapper.getLists(onlineRatePageCond.getOrganizationId(),onlineRatePageCond.getState());
         if (!ObjectUtils.isEmpty(OnlineRateVoList)){
+
             for (OnlineRateVo onlineRateVo : OnlineRateVoList) {
                 List<HistoryHourly> valueByMacAndTime = historyHourlyService.getValueByMacAndTime(onlineRateVo.getMac(), start, end);
                 ArrayList<Date> dates = new ArrayList<>();
+                //������������
                 ArrayList<Date> dates1 = new ArrayList<>();
+                //������������
                 ArrayList<Date> dates2 = new ArrayList<>();
                 ArrayList<Integer> list = new ArrayList<>();
                 Date start1 = DateUtils.getDate(startTime, DateUtils.yyyy_MM_dd_HH_EN);
@@ -601,18 +604,30 @@
                         }
                         start1 = DateUtils.getDateAddHour(start1,1);
                     }
-                    if (!ObjectUtils.isEmpty(dates2)){
-                        onlineRateVo.setStartTime(DateUtils.dateToDateString(dates2.get(dates2.size()-1)));
-                    }
                     if (!ObjectUtils.isEmpty(dates1)){
-                        onlineRateVo.setEndTime(DateUtils.dateToDateString(dates1.get(dates1.size()-1)));
+                        if (dates1.size()>dates2.size()){
+                            onlineRateVo.setEndTime(DateUtils.dateToDateString(dates1.get(dates1.size()-1)));
+                            onlineRateVo.setStartTime("-");
+                            onlineRateVo.setHourState("0");
+                        }else {
+                            onlineRateVo.setStartTime(DateUtils.dateToDateString(dates2.get(dates2.size()-1)));
+                            onlineRateVo.setEndTime(DateUtils.dateToDateString(dates1.get(dates1.size()-1)));
+                            onlineRateVo.setHourState("1");
+                        }
+                    }else {
+                        onlineRateVo.setHourState("1");
                     }
-//               it.setEndTime(DateUtils.dateToDateString(dates1.get(dates1.size()-1)));
+//                    if (!ObjectUtils.isEmpty(dates2)){
+//                        onlineRateVo.setStartTime(DateUtils.dateToDateString(dates2.get(dates2.size()-1)));
+//                    }
+//                    if (!ObjectUtils.isEmpty(dates1)){
+//                        onlineRateVo.setEndTime(DateUtils.dateToDateString(dates1.get(dates1.size()-1)));
+//                    }
                     onlineRateVo.setNum(dates1.size()+"");
                     onlineRateVo.setOnlineTime(collects.size());
                     double number = (double) collects.size() / hour * 100;
                     String result = String.format("%.2f", number);
-                    onlineRateVo.setOnlineRate(result+"%");
+                    onlineRateVo.setOnlineRate(result);
                 }
             }
 
@@ -670,7 +685,10 @@
                 }
             });
         }*/
-        return OnlineRateVoList;
+        if (!ObjectUtils.isEmpty(OnlineRateVoList)){
+            collectList = OnlineRateVoList.stream().collect(Collectors.groupingBy(OnlineRateVo::getHourState));
+        }
+        return ObjectUtils.isEmpty(onlineRatePageCond.getHourState())?OnlineRateVoList:collectList.get(onlineRatePageCond.getHourState());
     }
 
     /**
@@ -728,11 +746,21 @@
                         }
                     }else {
                         if (flag){
-                            EndDates.add(start);
-                            flag=false;
+                            Date date = new Date();
+                            String dateString = DateUtils.dateToDateString(date, DateUtils.yyyy_MM_dd_HH_EN);
+                            Date date1 = DateUtils.getDate(dateString, DateUtils.yyyy_MM_dd_HH_EN);
+                            if (!date1.equals(start)){
+                                EndDates.add(start);
+                                flag=false;
+                            }
                         }
                         map.put(DateUtils.dateToDateString(start),0);
                     }
+                    start = DateUtils.getDateAddHour(start,1);
+                }
+            }else {
+                while (DateUtils.isTimeBeforE(end,start)){
+                    map.put(DateUtils.dateToDateString(start),0);
                     start = DateUtils.getDateAddHour(start,1);
                 }
             }
@@ -757,13 +785,7 @@
 
                         }
                     }
-//                    if (!ObjectUtils.isEmpty(StartDates)){
-//                        long l = EndDates.get(i).getTime() - StartDates.get(i).getTime();
-//                        onlineRateLogsForm.setMun(Long.toString(l/nh));
-//                        StartDates.remove(i);
-//                    }else {
-//                        onlineRateLogsForm.setMun("-");
-//                    }
+
                     onlineRateLogsForm.setDate("������");
                     OrfList.add(onlineRateLogsForm);
                 }
@@ -781,11 +803,9 @@
             rsMap.put("tabulation",OrfList);
             //���������������������
             int endNumber = map.size() - dates.size();
-            double number = (double) dates.size() / map.size() * 100;
-            String result = String.format("%.2f", number);
             rsMap.put("pieChart1",endNumber);
             rsMap.put("pieChart2",dates.size());
-            rsMap.put("code","���"+map.size()+"���������"+"������"+dates.size()+"���������"+"���������"+(result.equals("NaN")?"0":result));
+            rsMap.put("sum",map.size());
 
         } else if (type.equals("day")){
             Date start = DateUtils.getDate(startTime, DateUtils.yyyy_MM_dd_EN);
@@ -815,7 +835,11 @@
                         }
                         map.put(DateUtils.dateToDateString(start),0);
                     }
-//                    start = DateUtils.getDateAddHour(start,24);
+                    start = DateUtils.getDateOfDay(start,1);
+                }
+            }else {
+                while (DateUtils.isTimeBeforE(end,start)){
+                    map.put(DateUtils.dateToDateString(start),0);
                     start = DateUtils.getDateOfDay(start,1);
                 }
             }
@@ -839,12 +863,6 @@
                             onlineRateLogsForm.setMun(Long.toString(Math.abs(l/nd)));
                         }
                     }
-//                    if (!ObjectUtils.isEmpty(StartDates)){
-//                        long l = EndDates.get(i).getTime() - StartDates.get(i).getTime();
-//                        onlineRateLogsForm.setMun(Long.toString(l/nd));
-//                    }else {
-//                        onlineRateLogsForm.setMun("-");
-//                    }
                     onlineRateLogsForm.setDate("���");
                     OrfList.add(onlineRateLogsForm);
                 }
@@ -858,20 +876,24 @@
                 list2.add(Integer.parseInt(map.get(string).toString()));
             }
 
-
             rsMap.put("lineChart1",list1);
             rsMap.put("lineChart2",list2);
             rsMap.put("tabulation",OrfList);
             //���������������
             int endNumber = map.size() - dates.size();
-            double number = (double) dates.size() / map.size() * 100;
-            String result = String.format("%.2f", number);
             rsMap.put("pieChart1",endNumber);
             rsMap.put("pieChart2",dates.size());
-            rsMap.put("code","���"+map.size()+"������"+"������"+dates.size()+"������"+"���������"+(result.equals("NaN")?"0":result));
+            rsMap.put("sum",map.size());
         }else {
             Date start = DateUtils.getDate(startTime,DateUtils.yyyy_MM_dd_HH_mm_EN);
             Date end = DateUtils.getDate(endTime, DateUtils.yyyy_MM_dd_HH_mm_EN);
+            Date date = new Date();
+            String dateString = DateUtils.dateToDateString(date, DateUtils.yyyy_MM_dd_HH_mm_EN);
+            Date date1 = DateUtils.getDate(dateString, DateUtils.yyyy_MM_dd_HH_mm_EN);
+            if (end.equals(date1)){
+                String dateOfMin = DateUtils.getDateOfMin(dateString, -1, DateUtils.yyyy_MM_dd_HH_mm_EN);
+                end = DateUtils.getDate(dateOfMin, DateUtils.yyyy_MM_dd_HH_mm_EN);
+            }
             List<HistoryMinutely> historyMinutelys = historyHourlyService.getHistoryMinutely(mac, start, end);
             if (!ObjectUtils.isEmpty(historyMinutelys)){
                 //������������
@@ -897,7 +919,11 @@
                         }
                         map.put(DateUtils.dateToDateString(start),0);
                     }
-//                    start = DateUtils.getDateAddHour(start,24);
+                    start = DateUtils.getDateOfMin(start,1);
+                }
+            }else {
+                while (DateUtils.isTimeBeforE(end,start)){
+                    map.put(DateUtils.dateToDateString(start),0);
                     start = DateUtils.getDateOfMin(start,1);
                 }
             }
@@ -921,12 +947,6 @@
                             onlineRateLogsForm.setMun(Long.toString(Math.abs(l/nm)));
                         }
                     }
-//                    if (!ObjectUtils.isEmpty(StartDates)){
-//                        long l = EndDates.get(i).getTime() - StartDates.get(i).getTime();
-//                        onlineRateLogsForm.setMun(Long.toString(l/nm));
-//                    }else {
-//                        onlineRateLogsForm.setMun("-");
-//                    }
                     onlineRateLogsForm.setDate("������");
                     OrfList.add(onlineRateLogsForm);
                 }
@@ -944,16 +964,40 @@
             rsMap.put("tabulation",OrfList);
             //���������������
             int endNumber = map.size() - dates.size();
-            double number = (double) dates.size() / map.size() * 100;
-            String result = String.format("%.2f", number);
             rsMap.put("pieChart1",endNumber);
             rsMap.put("pieChart2",dates.size());
-            rsMap.put("code","���"+map.size()+"���������"+"������"+dates.size()+"���������"+"���������"+(result.equals("NaN")?"0":result));
+            rsMap.put("sum",map.size());
         }
         return rsMap;
     }
 
     @Override
+    public Map<String,Object> getStart(Integer organizationId) {
+        HashMap<String, Object> map = new HashMap<>();
+        List<OnlineRateVo> lists = deviceMapper.getLists(organizationId, null);
+        if (!ObjectUtils.isEmpty(lists)){
+            Map<String, List<OnlineRateVo>> collect = lists.stream().collect(Collectors.groupingBy(OnlineRateVo::getState));
+            int size1 = lists.size();
+            List<OnlineRateVo> onlineRateVos = collect.get("0");
+            int i ;
+            if (!ObjectUtils.isEmpty(onlineRateVos)){
+                int size = onlineRateVos.size();
+                 i = size1 - size;
+            }else {
+                 i= size1;
+            }
+            //������
+            map.put("sum",lists.size());
+            //������
+            map.put("online",i);
+            double number = (double) i / size1 * 100;
+            String result = String.format("%.2f", number);
+            map.put("onlineRate",result);
+        }
+        return map;
+    }
+
+    @Override
     public Map<String, Object> detailV1(String mac, String startTime, String endTime, String type) {
         HashMap<String, Object> rsMap = new HashMap<>();
         Map<String, Object> map = new TreeMap<>(

--
Gitblit v1.8.0