Pārlūkot izejas kodu

debug清除所有在线模拟器所有故障。

tom 2 nedēļas atpakaļ
vecāks
revīzija
45c0682e22

+ 6 - 0
ruoyi-sim/src/main/java/com/ruoyi/sim/controller/HardwareCommDebugController.java

@@ -60,6 +60,12 @@ public class HardwareCommDebugController extends BaseController {
         return commSendService.debugClearAllFaultBySimNum(simNum);
     }
 
+    @GetMapping(value = "/debugClearAllOnlineSimAllFault/")
+    @ApiOperation("debug清除所有在线模拟器所有故障")
+    public AjaxResult debugClearAllOnlineSimAllFault() {
+        return commSendService.debugClearAllOnlineSimAllFault();
+    }
+
     @GetMapping(value = "/debugWriteOneFault/{simNum}/{bindHardwareMsg}")
     @ApiOperation("debug下发一个故障")
     public AjaxResult debugWriteOneFault(@PathVariable("simNum") final String simNum,

+ 7 - 0
ruoyi-sim/src/main/java/com/ruoyi/sim/service/impl/CommSendService.java

@@ -333,6 +333,13 @@ public class CommSendService {
         return send(sm, null, RETRY_COUNT_CLEAR_ONE_FAULT, SLEEP_LONG);
     }
 
+    public AjaxResult debugClearAllOnlineSimAllFault() {
+        simService.listAllOnline().forEach(s -> {
+            AjaxResult ar = debugClearAllFaultBySimNum(s.getSimNum());
+        });
+        return AjaxResult.success("清除成功,清除所有在线模拟器所有故障!");
+    }
+
     /**
      * debug清除所有故障
      *

+ 10 - 0
ruoyi-sim/src/main/java/com/ruoyi/sim/service/impl/SimService.java

@@ -147,6 +147,16 @@ public class SimService {
         return list;
     }
 
+    public List<Sim> listAllOnline() {
+        List<Sim> list = new ArrayList<>();
+        listAll()
+                .stream()
+                .filter(Objects::nonNull)
+                .filter(s -> Sim.State.ONLINE.equals(s.getSimState()))
+                .forEach(list::add);
+        return list;
+    }
+
     public List<Sim> listAllEnableBySimType(String simType) {
         List<Sim> list = new ArrayList<>();
         listAll()