From 41f01abcbf2c5fd6f63da15a0dabeb34ceb9c3ec Mon Sep 17 00:00:00 2001
From: zhanzhiqin <895896009@qq.com>
Date: 星期三, 03 八月 2022 15:33:50 +0800
Subject: [PATCH] 大气设备

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/service/AirEquipmentService.java |   55 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 55 insertions(+), 0 deletions(-)

diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/AirEquipmentService.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/AirEquipmentService.java
index 0cc94e5..d15a52d 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/AirEquipmentService.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/AirEquipmentService.java
@@ -18,6 +18,7 @@
 import com.sandu.ximon.admin.security.SecurityUtils;
 import com.sandu.ximon.admin.utils.RedisUtils;
 import com.sandu.ximon.admin.utils.StoreOperationRecordsUtils;
+import com.sandu.ximon.admin.utils.StringUtil;
 import com.sandu.ximon.admin.vo.EquipmentInfomation;
 import com.sandu.ximon.dao.bo.AirEquipmentBo;
 import com.sandu.ximon.dao.domain.AirEquipment;
@@ -146,6 +147,9 @@
      * 鏌ヨ澶ф皵璁惧蹇冭烦鍖呮椂闂�
      */
     public String QueryHeartBeatTime(String mac) {
+        if (StringUtil.strIsNullOrEmpty(mac)) {
+            throw new BusinessException("鐏潌mac鍙傛暟閿欒锛�");
+        }
         AirEquipment airEquipment = SpringContextHolder.getBean(AirEquipmentService.class).
                 getOne(Wrappers.lambdaQuery(AirEquipment.class).eq(AirEquipment::getMac, mac).last("limit 1"));
 
@@ -178,6 +182,13 @@
      * @param time
      */
     public String setHeartBeatTime(String mac, Integer time) {
+        if (StringUtil.strIsNullOrEmpty(mac)) {
+            throw new BusinessException("鐏潌mac鍙傛暟閿欒锛�");
+        }
+        if (time == null) {
+            throw new BusinessException("蹇冭烦鍖呴棿闅旀椂闂翠笉鑳戒负绌猴紒");
+        }
+
         if (time < 30) {
             throw new BusinessException("蹇冭烦鍖呴棿闅旀椂闂翠笉鑳藉皯浜�30s锛�");
         }
@@ -210,6 +221,10 @@
      * @return
      */
     public A5AtmosphereQuerySensorInfoReportInnerFrame.SensorInfoPackage QuerySensorInfo(String mac) {
+        if (StringUtil.strIsNullOrEmpty(mac)) {
+            throw new BusinessException("鐏潌mac鍙傛暟閿欒锛�");
+        }
+
         AirEquipment airEquipment = SpringContextHolder.getBean(AirEquipmentService.class).
                 getOne(Wrappers.lambdaQuery(AirEquipment.class).eq(AirEquipment::getMac, mac).last("limit 1"));
 
@@ -240,6 +255,9 @@
      * @return
      */
     public void QueryVersion(String mac) {
+        if (StringUtil.strIsNullOrEmpty(mac)) {
+            throw new BusinessException("鐏潌mac鍙傛暟閿欒锛�");
+        }
         //TODO
         AirEquipment airEquipment = SpringContextHolder.getBean(AirEquipmentService.class).
                 getOne(Wrappers.lambdaQuery(AirEquipment.class).eq(AirEquipment::getMac, mac).last("limit 1"));
@@ -265,6 +283,10 @@
      * @return
      */
     public String Reboot(String mac) {
+        if (StringUtil.strIsNullOrEmpty(mac)) {
+            throw new BusinessException("鐏潌mac鍙傛暟閿欒锛�");
+        }
+
         AirEquipment airEquipment = SpringContextHolder.getBean(AirEquipmentService.class).
                 getOne(Wrappers.lambdaQuery(AirEquipment.class).eq(AirEquipment::getMac, mac).last("limit 1"));
         if (airEquipment == null) {
@@ -286,4 +308,37 @@
             throw new BusinessException("鏁版嵁鏍￠獙寮傚父锛�");
         }
     }
+
+    /**
+     * 璁剧疆鏁版嵁淇鍊�
+     *
+     * @param mac             鐏潌MAC
+     * @param type            鏁版嵁淇璁惧绫诲瀷
+     * @param valueOfReal     浼犳劅鍣ㄦ暟鍊�
+     * @param valueOfStandard 鏍囧噯浠櫒鏁板��
+     */
+    public void ModifiedData(String mac, String type, Double valueOfReal, Double valueOfStandard) {
+        //TODO
+        if (StringUtil.strIsNullOrEmpty(mac)) {
+            throw new BusinessException("鐏潌mac鍙傛暟閿欒锛�");
+        }
+        if (StringUtil.strIsNullOrEmpty(type)) {
+            throw new BusinessException("鏁版嵁淇璁惧绫诲瀷閿欒锛�");
+        }
+        if (valueOfReal == null || valueOfStandard == null) {
+            throw new BusinessException("浼犳劅鍣ㄦ暟鍊兼垨鏍囧噯浠櫒鏁板�奸敊璇紒");
+        }
+        AirEquipment airEquipment = SpringContextHolder.getBean(AirEquipmentService.class).
+                getOne(Wrappers.lambdaQuery(AirEquipment.class).eq(AirEquipment::getMac, mac).last("limit 1"));
+        if (airEquipment == null) {
+            throw new BusinessException("澶ф皵璁惧涓嶅瓨鍦紒");
+        }
+        AtmosphereModifiedDataReqInnerFrame atmosphereModifiedDataReqInnerFrame = new AtmosphereModifiedDataReqInnerFrame(type, valueOfReal, valueOfStandard);
+        A5Frame a5Frame = new A5Frame(A5OrderEnum.REQUEST_ATMOSPHERE_DATA.getCode(), atmosphereModifiedDataReqInnerFrame);
+        System.out.println(a5Frame + "          --------a5Frame");
+        CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(mac, a5Frame);
+        System.out.println(commonFrame + "         -----------commonFrame");
+
+
+    }
 }

--
Gitblit v1.9.3