From 5bf55e27f391d063619e2cc3f41c77be65c69e58 Mon Sep 17 00:00:00 2001
From: lijiayao <13831655+xiao-yao-charge-forward@user.noreply.gitee.com>
Date: Sat, 6 Apr 2024 09:59:38 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BB=A3=E7=A0=81=E4=B8=A2=E5=A4=B1?=
 =?UTF-8?q?=E6=89=BE=E5=9B=9E?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../server/service/impl/FenceServiceImpl.java | 32 ++++++++++++++-----
 1 file changed, 24 insertions(+), 8 deletions(-)

diff --git a/couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/impl/FenceServiceImpl.java b/couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/impl/FenceServiceImpl.java
index 732e658..a81e11b 100644
--- a/couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/impl/FenceServiceImpl.java
+++ b/couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/impl/FenceServiceImpl.java
@@ -38,40 +38,56 @@ public class FenceServiceImpl extends ServiceImpl<FenceMapper, Fence> implements
      */
     @Autowired
     private StringRedisTemplate redisTemplate;
+    /**
+     * 远程调用队列服务
+     */
+    @Autowired
+    private RemoteFenceService remoteFenceService;
 
     @Override
     public List<Fence> pageQuery(FenceConfig fenceConfig) {
-        List<Fence> list= fenceMapper.pageQuery(fenceConfig);
+        List<Fence> list = fenceMapper.pageQuery(fenceConfig);
         return list;
     }
 
     @Override
     public void changeFenceStatus(FenceUpdateRequest fenceUpdateRequest) {
 
+        String username = SecurityUtils.getUsername();
+        fenceUpdateRequest.setCrateName(username);
         fenceMapper.changeFence(fenceUpdateRequest);
+        /**
+         * 电子围栏发送改变
+         */
+        redisTemplate.opsForValue().set("changeFenceStatus", JSON.toJSONString(fenceUpdateRequest), 10, TimeUnit.MINUTES);
 
+        remoteFenceService.fenceQueue(fenceUpdateRequest);
     }
 
     /**
      * 业务实现:添加围栏
+     *
      * @param request
      * @param fenceRequest
      */
     @Override
     public void fenceInsert(HttpServletRequest request, FenceRequest fenceRequest) {
-
+        String username = SecurityUtils.getUsername();
+        fenceRequest.setCrateName(username);
         //先添加围栏
-        int a= fenceMapper.insertFence(fenceRequest);
+        fenceMapper.insertFence(fenceRequest);
         String[] logoIds = fenceRequest.getLogoIds();
         String[] parts = new String[0];
         for (String logoId : logoIds) {
             //把前台传入的字符串分割成数组
-          parts = logoId.split(",");
-          //再添加围栏和标识中间表
-          fenAndLogoService.addBach(fenceRequest.getFenceId(),parts);
-
+            parts = logoId.split(",");
+            //再添加围栏和标识中间表
+            fenAndLogoService.addBach(fenceRequest.getFenceId(), parts);
         }
-
+        /**
+        * 电子围栏发送改变
+        */
+        redisTemplate.opsForValue().set("fenceInsert", JSON.toJSONString(fenceRequest), 10, TimeUnit.MINUTES);
     }
 
     @Override