From 5459d7d124fc4c4eb93e8074354dd72c9527081e Mon Sep 17 00:00:00 2001
From: liuhaonan <konodioda2333@vip.qq.com>
Date: 星期二, 19 四月 2022 18:14:33 +0800
Subject: [PATCH] 首页

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightService.java |   70 ++++++++++++++++++++++++-----------
 1 files changed, 48 insertions(+), 22 deletions(-)

diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightService.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightService.java
index c650ff6..4903e14 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightService.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightService.java
@@ -1,6 +1,8 @@
 package com.sandu.ximon.admin.service;
 
 import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.date.DateTime;
+import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.HexUtil;
 import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
@@ -8,6 +10,8 @@
 import com.sandu.common.execption.BusinessException;
 import com.sandu.common.redis.RedisService;
 import com.sandu.common.service.impl.BaseServiceImpl;
+import com.sandu.common.util.SpringContextHolder;
+import com.sandu.ximon.admin.dto.LightTaskDto;
 import com.sandu.ximon.admin.manager.iot.frame.A5Frame;
 import com.sandu.ximon.admin.manager.iot.frame.inner.report.A5LightHeartbeatReportInnerFrame;
 import com.sandu.ximon.admin.manager.iot.frame.inner.request.A5LightBrightnessReqInnerFrame;
@@ -30,6 +34,7 @@
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
+import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
@@ -87,10 +92,7 @@
      * @return 杩斿洖缁勫悎鏁版嵁dto
      */
     public List<LightBo> listLight(int pageNo, int pageSize, String keyword) {
-        Long clientId=null;
-        if(SecurityUtils.getClientId()!=null){
-            clientId = SecurityUtils.getClientId();
-        }
+        Long clientId = SecurityUtils.getClientId();
 
         PageHelper.startPage(pageNo, pageSize);
 
@@ -103,12 +105,12 @@
             for (LightBo lightBo : listLight) {
                 deviceCodeList.forEach(code -> {
                             PoleBinding bind = bindingService.getPoleIdByMac(code);
-                            if (bind != null&&lightBo.getDeviceCode().equals(bind.getDeviceCode())) {
+                            if (bind != null && lightBo.getDeviceCode().equals(bind.getDeviceCode())) {
                                 Long poleId = bind.getPoleId();
-                                    Pole pole = poleService.getById(poleId);
-                                    lightBo.setPoleId(pole.getId());
-                                    lightBo.setPoleCode(pole.getDeviceCode());
-                                    lightBo.setPoleName(pole.getPoleName());
+                                Pole pole = poleService.getById(poleId);
+                                lightBo.setPoleId(pole.getId());
+                                lightBo.setPoleCode(pole.getDeviceCode());
+                                lightBo.setPoleName(pole.getPoleName());
                             }
                         }
                 );
@@ -126,6 +128,7 @@
 
     /**
      * 鑾峰彇鍗曚釜璺伅淇℃伅
+     *
      * @param deviceCode 璁惧鐮�
      * @return
      */
@@ -134,7 +137,7 @@
         Object o = redisService.get(LightKey.REPORT_MAC.key(deviceCode));
         if (o != null) {
             one.setOnlineStatus(1);
-        }else {
+        } else {
             one.setOnlineStatus(0);
         }
         return one;
@@ -197,31 +200,54 @@
 
     /**
      * 鍗曠伅鑺傝兘鐜�
+     *
+     * @return
      */
-    public List<Map<String, Object>> controlEnergySaving() {
+    public List<LightReportData> controlEnergySaving() {
+        Long clientId = SecurityUtils.getClientId();
+//        List<LightBo> listLight = baseMapper.listLight(clientId, null);
+//        List<String> deviceCodeList = listLight.stream().map(LightBo::getDeviceCode).collect(Collectors.toList());
 
-        List<LightBo> listLight = baseMapper.listLight(SecurityUtils.getUserId(), null);
+        List<LightTaskDto> lightTaskDtos = SpringContextHolder.getBean(LightTaskService.class).listLightTask(null, null);
+        lightTaskDtos.forEach(Task -> {
+
+
+                });
+
+
 
 
         return null;
     }
 
     /**
+     * 瑙f瀽寮�鍏崇伅鎸囦护
+     */
+    public void parseSwitchLightCommand(String command) {
+        char[] chars = command.toCharArray();
+        if(chars.length==7){
+            int hour = Integer.valueOf(command.substring(0,2));
+            int min = Integer.valueOf(command.substring(2,4));
+            int brightness = Integer.valueOf(command.substring(4,7));
+        }
+
+    }
+
+    /**
      * 鐢ㄦ埛鎷ユ湁鐨勮矾鐏�
+     *
+     * @return
      */
     public List<Light> listLight() {
-        List<LightBo> listLight = baseMapper.listLight(SecurityUtils.getUserId(), null);
-        if (CollectionUtil.isEmpty(listLight)) {
-            throw new BusinessException("娌℃湁璺伅鏁版嵁");
-        }
-        List<String> deviceCodeList = listLight.stream().map(LightBo::getDeviceCode).collect(Collectors.toList());
-        List<LightReportData> reportDataList = lightReportDataService.list(Wrappers.<LightReportData>lambdaQuery().in(LightReportData::getDeviceCode, deviceCodeList));
-        if (CollectionUtil.isEmpty(reportDataList)) {
-            throw new BusinessException("娌℃湁璺伅鏁版嵁");
+        List<LightBo> listLight;
+        if (SecurityUtils.getClientId() != null) {
+            listLight = baseMapper.listLight(SecurityUtils.getUserId(), null);
+        } else {
+            listLight = baseMapper.listLight(null, null);
         }
         List<Light> lightList = new ArrayList<>();
-        for (String deviceCode : deviceCodeList) {
-            Light light = getLight(deviceCode);
+        for (LightBo bean : listLight) {
+            Light light = getLight(bean.getDeviceCode());
             lightList.add(light);
         }
         return lightList;

--
Gitblit v1.9.3