From 620a3be8596434a8796469a8213a0066c836a1d4 Mon Sep 17 00:00:00 2001
From: zhanzhiqin <895896009@qq.com>
Date: 星期四, 28 四月 2022 18:22:43 +0800
Subject: [PATCH] fix

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/controller/VnnoxController.java |   70 ++++++++++++++---------------------
 1 files changed, 28 insertions(+), 42 deletions(-)

diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/controller/VnnoxController.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/controller/VnnoxController.java
index 96b6c1c..ec4939c 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/controller/VnnoxController.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/controller/VnnoxController.java
@@ -20,6 +20,7 @@
 import com.sandu.ximon.dao.domain.PoleBinding;
 import com.sandu.ximon.dao.enums.AdministratorEnums;
 import com.sandu.ximon.dao.enums.MenuEnum;
+import com.sun.javafx.collections.MappingChange;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
@@ -73,8 +74,30 @@
      * @return
      */
     @PostMapping("/reboot")
-    public ResponseVO<Object> reboot(@RequestBody VnnoxParam vnnoxWebRequest) {
-        VnnoxResult vnnoxResult = vnnoxService.reboot(vnnoxWebRequest.getPlayerList());
+    public ResponseVO<Object> reboot(@RequestBody List<String> vnnoxWebRequest) {
+        VnnoxResult vnnoxResult = vnnoxService.reboot(vnnoxWebRequest);
+        return ResponseUtil.success(vnnoxResult);
+    }
+
+    /**
+     * 鍚屾鎾斁
+     */
+    @PostMapping("/syncPlay")
+    public ResponseVO<Object> syncPlay(@RequestBody Map map) {
+        List playIdlist = (List)map.get("playIdlist");
+        Integer option = (Integer) map.get("option");
+        VnnoxResult vnnoxResult = vnnoxService.syncPlay(playIdlist,option);
+        return ResponseUtil.success(vnnoxResult);
+    }
+
+    /**
+     * ntp瀵规椂
+     */
+    @PostMapping("/ntp")
+    public ResponseVO<Object> ntp(@RequestBody Map map) {
+        boolean enable = (boolean)map.get("enable");
+        List playIdlist = (List)map.get("playIdlist");
+        VnnoxResult vnnoxResult = vnnoxService.ntpSync(playIdlist,enable);
         return ResponseUtil.success(vnnoxResult);
     }
 
@@ -140,50 +163,13 @@
         if (!permissionConfig.check(MenuEnum.LED_LIST.getCode())) {
             return ResponseUtil.fail("缂哄皯瀵瑰簲鐢ㄦ埛鏉冮檺");
         }
-        PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
-        LambdaQueryWrapper<LedPlayerEntity> wrapper = Wrappers.lambdaQuery(LedPlayerEntity.class);
-        if (AdministratorEnums.CUSTOMER.getCode().equals(SecurityUtils.getAdministratorIdentity())) {
-            //wrapper.eq(LedPlayerEntity::get)
-            return ResponseUtil.success(""); //  todo
-        } else {
-            wrapper.like(LedPlayerEntity::getPlayerName, keyword)
-                    .or(
-                            querywrapper -> {
-                                querywrapper.like(LedPlayerEntity::getName, keyword);
-                            }
-                    ).or(
-                            sn->{
-                                sn.like(LedPlayerEntity::getSn,keyword);
-                            }
-                    );
-            List<LedPlayerEntity> list = ledPlayerEntityService.list(wrapper);
-            List<LedPlayerEntity> entities = vnnoxService.setCacheInfo(vnnoxAPIUtil.syncCurrentInfo(list));
-            entities.forEach(
-                    led -> {
-                        PoleBinding binding = bindingService.getOne(Wrappers.lambdaQuery(PoleBinding.class)
-                                .eq(PoleBinding::getDeviceType, 1).eq(PoleBinding::getDeviceCode, led.getSn()));
-                        if (binding != null) {
-                            led.setPoleId(poleService.getById(binding.getPoleId()).getId());
-                            led.setPoleName(poleService.getById(binding.getPoleId()).getPoleName());
-                        }
-                    }
-            );
-            return ResponseUtil.success(entities);
-        }
+        return ResponseUtil.successPage(ledPlayerEntityService.ledPlayerEntityList(baseConditionVO, keyword));
     }
 
     @GetMapping("/onLineList")
     public ResponseVO<Object> onLineList(BaseConditionVO baseConditionVO, @RequestParam(value = "keyword", required = false) String keyword) {
-//    public ResponseVO<Object> onLineList(BaseConditionVO baseConditionVO, @RequestParam(value = "keyword", required = false) String keyword) {
-        PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
-        LambdaQueryWrapper<LedPlayerEntity> wrapper = Wrappers.lambdaQuery(LedPlayerEntity.class);
 
-        if (AdministratorEnums.CUSTOMER.getCode().equals(SecurityUtils.getAdministratorIdentity())) {
-            //wrapper.eq(LedPlayerEntity::get)
-            return ResponseUtil.success(""); //  todo
-        } else {
-            wrapper.like(LedPlayerEntity::getPlayerName, keyword);
-            List<LedPlayerEntity> list = ledPlayerEntityService.list(wrapper);
+            List<LedPlayerEntity> list = ledPlayerEntityService.ledPlayerEntityList(baseConditionVO, keyword);
             List<LedPlayerEntity> entities = vnnoxService.setCacheInfo(vnnoxAPIUtil.syncCurrentInfo(list));
             List<LedPlayerEntity> online = new ArrayList<>();
             for (LedPlayerEntity ledPlayer : entities) {
@@ -192,7 +178,7 @@
                 }
             }
             return ResponseUtil.success(online);
-        }
+
     }
 
     @GetMapping("/getVnnoxInfo/{sn}")

--
Gitblit v1.9.3