From 2ceb7fc62b4c9cbd59729398d7d85c979b0e22ce Mon Sep 17 00:00:00 2001
From: liuhaonan <31457034@qq.com>
Date: 星期一, 16 五月 2022 13:54:22 +0800
Subject: [PATCH] 日志

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskService.java |   49 +++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 43 insertions(+), 6 deletions(-)

diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskService.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskService.java
index 3dfff8f..a158b9f 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskService.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskService.java
@@ -30,7 +30,6 @@
 import com.sandu.ximon.admin.utils.StoreOperationRecordsUtils;
 import com.sandu.ximon.admin.utils.TaskOrderUtil;
 import com.sandu.ximon.dao.bo.LightTaskStatusAndPole;
-import com.sandu.ximon.dao.domain.Light;
 import com.sandu.ximon.dao.domain.LightTask;
 import com.sandu.ximon.dao.domain.LightTaskPoleRelation;
 import com.sandu.ximon.dao.domain.Pole;
@@ -84,8 +83,7 @@
         lightTask.setOpenOrder(param.getOpenOrder());
         lightTask.setControlOrder(param.getControlOrder());
         lightTask.setCreateUser(SecurityUtils.getUsername());
-        String framePayload = buildControlFramePayload(param.getOpenOrder(), param.getCloseOrder(), param.getControlOrder(), week);
-        lightTask.setFramePayload(framePayload);
+        lightTask.setFramePayload(buildControlFramePayload(param.getOpenOrder(), param.getCloseOrder(), param.getControlOrder(), week));
         if (!save(lightTask)) {
             throw new BusinessException("淇濆瓨璺伅浠诲姟澶辫触");
         }
@@ -131,9 +129,7 @@
 
             String content1 = "{浠诲姟ID锛�" + lightTask.getTaskId()
                     + "锛� 浠诲姟鍚嶏細" + lightTask.getTaskName()
-                    + "}锛寋鍐呭抚鎸囦护" + lightTask.getFramePayload()
-                    + "锛� 鐏潌ID锛�" + param.getPoleIdList().toString()
-                    + "锛� 鎺у埗鐨勭伅澶村湴鍧�锛�" + param.getLightAddress()
+                    + "},"+" 鐏潌ID锛�" + param.getPoleIdList().toString()
                     + " }";
             StoreOperationRecordsUtils.storeOperationData(poleCodeList.toString(), null, "涓嬪彂璺伅浠诲姟", content1, poleCodeList.toString());
             /**
@@ -169,6 +165,27 @@
             throw new BusinessException("缂栬緫浠诲姟澶辫触");
         }
 
+        /**
+         * 缂栬緫璺伅浠诲姟鏃ュ織璁板綍寮�濮�
+         */
+        List<String> poleCodeList = new ArrayList<>();
+        if (CollectionUtil.isNotEmpty(param.getPoleIdList())) {
+            List<Pole> poleList = SpringContextHolder.getBean(PoleService.class).listByIds(param.getPoleIdList());
+            if (CollectionUtil.isNotEmpty(poleList)) {
+                poleCodeList = poleList.stream().map(Pole::getDeviceCode).collect(Collectors.toList());
+            }
+        }
+        String content = "{浠诲姟ID锛�" + taskId
+                + "锛� 浠诲姟鍚嶏細" + lightTask.getTaskName()
+                + "}锛寋鍐呭抚鎸囦护" + lightTask.getFramePayload()
+                + "锛� 鐏潌ID锛�" + param.getPoleIdList().toString()
+                + "锛� 鎺у埗鐨勭伅澶村湴鍧�锛�" + param.getLightAddress()
+                + " }";
+        StoreOperationRecordsUtils.storeOperationData(poleCodeList.toString(), null, "缂栬緫璺伅浠诲姟", content, poleCodeList.toString());
+        /**
+         * 缂栬緫璺伅浠诲姟鏃ュ織璁板綍缁撴潫
+         */
+
         List<Long> poleIdList = param.getPoleIdList();
         if (CollectionUtil.isNotEmpty(poleIdList)) {
 
@@ -182,6 +199,19 @@
 
             // 涓�涓伅鏉嗗彧鑳戒娇鐢ㄤ竴涓换鍔★紝鏂颁换鍔¤瑕嗙洊鏃т换鍔�
             lightTaskPoleRelationService.remove(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getPoleId, poleIdList).ne(LightTaskPoleRelation::getTaskId, lightTask.getTaskId()));
+
+            /**
+             * 涓嬪彂璺伅浠诲姟鏃ュ織璁板綍寮�濮�
+             */
+
+            String content1 = "{浠诲姟ID锛�" + lightTask.getTaskId()
+                    + "锛� 浠诲姟鍚嶏細" + lightTask.getTaskName()
+                    + "},"+" 鐏潌ID锛�" + param.getPoleIdList().toString()
+                    + " }";
+            StoreOperationRecordsUtils.storeOperationData(poleCodeList.toString(), null, "涓嬪彂璺伅浠诲姟", content1, poleCodeList.toString());
+            /**
+             * 涓嬪彂璺伅浠诲姟鏃ュ織璁板綍缁撴潫
+             */
         }
 
         return true;
@@ -382,6 +412,13 @@
                     Wrappers.lambdaUpdate(LightTaskPoleRelation.class).eq(LightTaskPoleRelation::getPoleId, param.getPoleId())
                             .eq(LightTaskPoleRelation::getTaskId, param.getTaskId()));
         }
+
+        /**
+         * 涓嬪彂鍗曠伅浠诲姟-鏃ュ織
+         */
+        String content = "涓嬪彂鍗曠伅浠诲姟";
+
+
         return true;
     }
 }

--
Gitblit v1.9.3