From 6886f3d9f7e9848fd47da92637f28f46554179a7 Mon Sep 17 00:00:00 2001
From: kaiyu <404897439@qq.com>
Date: Fri, 18 Jun 2021 08:55:41 +0800
Subject: [PATCH] screen-api           增加kafka消费者以及websocket搭建

---
 screen-manage/src/main/java/com/moral/api/service/impl/MonitorPointServiceImpl.java |   19 +++++++++++++++----
 1 files changed, 15 insertions(+), 4 deletions(-)

diff --git a/screen-manage/src/main/java/com/moral/api/service/impl/MonitorPointServiceImpl.java b/screen-manage/src/main/java/com/moral/api/service/impl/MonitorPointServiceImpl.java
index cfc91b9..a589883 100644
--- a/screen-manage/src/main/java/com/moral/api/service/impl/MonitorPointServiceImpl.java
+++ b/screen-manage/src/main/java/com/moral/api/service/impl/MonitorPointServiceImpl.java
@@ -103,9 +103,9 @@
         int totalNumber = monitorPointMapper.selectCount(wrapper);
         String orderType = map.get("orderType").toString();
         if (orderType.equals(Constants.ORDER_ASC)){
-            wrapper.orderByAsc("create_time");
+            wrapper.orderByAsc("update_time");
         }else {
-            wrapper.orderByDesc("create_time");
+            wrapper.orderByDesc("update_time");
         }
         Page resultPage = monitorPointMapper.selectPage(page,wrapper);
         List<MonitorPoint> monitorPoints = resultPage.getRecords();
@@ -286,9 +286,9 @@
         int totalNumber = monitorPointMapper.selectCount(wrapper);
         String orderType = map.get("orderType").toString();
         if (orderType.equals(Constants.ORDER_ASC)){
-            wrapper.orderByAsc("create_time");
+            wrapper.orderByAsc("update_time");
         }else {
-            wrapper.orderByDesc("create_time");
+            wrapper.orderByDesc("update_time");
         }
         Page resultPage = monitorPointMapper.selectPage(page,wrapper);
         List<MonitorPoint> monitorPoints = resultPage.getRecords();
@@ -347,6 +347,17 @@
         return resultMap;
     }
 
+    @Override
+    public List<MonitorPoint> getMonitorPointsByOrganizationId(Integer organizationId) {
+        QueryWrapper<MonitorPoint> monitorPointQueryWrapper = new QueryWrapper<>();
+        MonitorPoint monitorPoint = new MonitorPoint();
+        monitorPoint.setOrganizationId(organizationId);
+        monitorPoint.setIsDelete(Constants.NOT_DELETE);
+        monitorPointQueryWrapper.setEntity(monitorPoint);
+        List<MonitorPoint> monitorPoints = monitorPointMapper.selectList(monitorPointQueryWrapper);
+        return monitorPoints;
+    }
+
     /**
      * @Description: ���������������
      * @Param: [areaArr, menu]menuMap���key���menuid���value���menu

--
Gitblit v1.8.0