From d9a9d8a2dad1d1e57b184bf8f972a03d654d883a Mon Sep 17 00:00:00 2001
From: liuhaonan <31457034@qq.com>
Date: 星期五, 22 七月 2022 15:07:01 +0800
Subject: [PATCH] 优化

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java |   48 +++++++++++++++++++++++++++---------------------
 1 files changed, 27 insertions(+), 21 deletions(-)

diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java
index 0a387e4..c41fbda 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java
@@ -44,6 +44,7 @@
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.text.SimpleDateFormat;
 import java.util.*;
@@ -140,7 +141,7 @@
         StringBuilder sb = new StringBuilder();
         String date = new SimpleDateFormat("yyMMdd").format(new Date());
         sb.append(date);
-        String key = LightKey.POLE_SN.key(null);
+        String key = LightKey.POLE_SN.key(date);
         Long increment = redisService.incr(key, 1);
         String incrementStr = increment.toString();
         if (incrementStr.length() <= 4) {
@@ -174,7 +175,7 @@
         result.put("poleTotalCount", list.size());
 
         //璇虹摝
-        List<LedPlayerEntity> ledPlayerEntities = SpringContextHolder.getBean(LedPlayerEntityService.class).ledPlayerEntityList(null, null);
+        List<LedPlayerEntity> ledPlayerEntities = SpringContextHolder.getBean(LedPlayerEntityService.class).ledPlayerEntityList(null, null, null, null);
         int number = 0;
         for (LedPlayerEntity bean : ledPlayerEntities) {
             if (bean.getOnlineStatus() == 1) {
@@ -191,7 +192,7 @@
         broadcastTerminalV2Param.setWorkState(2);
         List<BroadcastTerminalV2EntityBo> broadcastTerminalList = SpringContextHolder.getBean(IpVolumeService.class).getBroadcastTerminalList(null, null, null, broadcastTerminalV2Param);
         for (BroadcastTerminalV2EntityBo bean : broadcastTerminalList) {
-            if (bean.getStatus() == 1 || bean.getStatus() == 0) {
+            if (bean.getStatus() != 0) {
                 number++;
             }
         }
@@ -203,9 +204,9 @@
         MonitorParam monitorParam = new MonitorParam();
         monitorParam.setEquipmentState(2);
         monitorParam.setBindingState(2);
-        List<MonitorBo> monitorBos = SpringContextHolder.getBean(MonitorService.class).listMonitorByKeyword(null,null,null, monitorParam).getList();
+        List<MonitorBo> monitorBos = SpringContextHolder.getBean(MonitorService.class).listMonitorByKeyword(null, null, null, monitorParam).getList();
         monitorParam.setEquipmentState(1);
-        List<MonitorBo> online = SpringContextHolder.getBean(MonitorService.class).listMonitorByKeyword(null,null,null, monitorParam).getList();
+        List<MonitorBo> online = SpringContextHolder.getBean(MonitorService.class).listMonitorByKeyword(null, null, null, monitorParam).getList();
         result.put("monitorOnlineCount", online.size());
         result.put("monitorTotalCount", monitorBos.size());
 
@@ -277,8 +278,8 @@
         result.put("LightPoleHeelingTotalCount", lightPoleHeelings.size());
 
         //鐔欒
-        List<PoleLightemitEntity> poleLightemitEntities = SpringContextHolder.getBean(PoleLightemitService.class).listLed(null, false);
-        List<PoleLightemitEntity> poleLightemitEntityOnlineList = SpringContextHolder.getBean(PoleLightemitService.class).listLed(null, true);
+        List<PoleLightemitEntity> poleLightemitEntities = SpringContextHolder.getBean(PoleLightemitService.class).listLed(null, null, null, false);
+        List<PoleLightemitEntity> poleLightemitEntityOnlineList = SpringContextHolder.getBean(PoleLightemitService.class).listLed(null, null, null, true);
 
         result.put("XiXunOnlineCount", poleLightemitEntityOnlineList.size());
         result.put("XiXunTotalCount", poleLightemitEntities.size());
@@ -605,9 +606,9 @@
     /**
      * 缁欑伅鏉嗘敞鍐屼笁鍏冪爜
      */
-    public boolean setMac(String baseMac) {
-        boolean setMac = false;
-        //String baseMac = "baseDevice";
+    @Transactional(rollbackFor = Exception.class)
+    public Map setMac(String baseMac) {
+
         A1Frame a1Frame = new A1Frame(A1OrderEnum.REQUEST_READ_DEVICE_UNIQUE_MAC.getCode(), new EmptyRequestInnerFrame());
         CommonFrame commonFrame = MainBoardInvokeSyncService.getInstance().sendRRPC(baseMac, a1Frame);
         //瀛樺偍鎸褰�
@@ -677,10 +678,6 @@
         StoreOperationRecordsUtils.storeInnerFrameData(baseMac, "閲嶅惎璁惧", build4, rebootFrame);
 
         if ("00".equals(rebootFrame.getPayload())) {
-            //  pole.setDeviceCode(uniqueMac);
-
-            // setMac = updateById(pole);
-
             System.out.println("閲嶅惎鎴愬姛");
         }
 
@@ -689,11 +686,8 @@
         if (pole == null) {
             pole = new Pole();
         }
-      /*  String type = uniqueMac.substring(uniqueMac.length() - 2, uniqueMac.length());
-        String Code = uniqueMac.substring(0, uniqueMac.length() - 2);*/
         pole.setDeviceCode(uniqueMac);
         pole.setPoleName(uniqueMac);
-        /*  int i = Integer.parseInt(strm);*/
         if ("00".equals(a1DeviceMacRespInnerFrame.getType())) {
             pole.setDeviceType(0);
         } else if ("01".equals(a1DeviceMacRespInnerFrame.getType())) {
@@ -701,20 +695,32 @@
         }
 
         pole.setPoleCode(generatePoleCode());
-//        setMac = save(pole);
 
         boolean result = saveOrUpdate(pole);
+
+        if (result) {
+            Light light = new Light();
+            light.setDeviceCode(uniqueMac);
+            light.setLightCount(2);
+            SpringContextHolder.getBean(LightService.class).save(light);
+        }
 
         /**
          * 瀹炰綋鐏潌娉ㄥ唽鏃ュ織璁板綍寮�濮�
          */
-        String content = "{鐏潌ID锛�" + pole.getId() + ",鐏潌缂栧彿锛�" + pole.getPoleCode() + ",鐏潌鍚嶇О锛�" + pole.getPoleName() + ",鐏潌绫诲瀷锛�" + pole.getDeviceType() + ",鐏潌MAC锛�" + pole.getDeviceCode() + " }";
-        StoreOperationRecordsUtils.storeOperationData(null, null, "瀹炰綋鐏潌娉ㄥ唽", content);
+//        String content = "{鐏潌ID锛�" + pole.getId() + ",鐏潌缂栧彿锛�" + pole.getPoleCode() + ",鐏潌鍚嶇О锛�" + pole.getPoleName() + ",鐏潌绫诲瀷锛�" + pole.getDeviceType() + ",鐏潌MAC锛�" + pole.getDeviceCode() + " }";
+//        StoreOperationRecordsUtils.storeOperationData(null, null, "瀹炰綋鐏潌娉ㄥ唽", content);
         /**
          * 瀹炰綋鐏潌娉ㄥ唽鏃ュ織璁板綍缁撴潫
          */
+        Map map = new HashMap();
+        if (true) {
+            map.put("mac", uniqueMac);
+        } else {
+            map.put("mac", -1);
+        }
 
-        return result;
+        return map;
     }
 
     public List<String> listDeviceCodeByIds(List<Long> poleIdList) {

--
Gitblit v1.9.3