diff --git a/backend/Skyeye-sys-dev/skyeye-service-manager/src/main/java/com/zhangy/skyeye/sar/controller/SarControlController.java b/backend/Skyeye-sys-dev/skyeye-service-manager/src/main/java/com/zhangy/skyeye/sar/controller/SarControlController.java index 8da12ee..0812a95 100644 --- a/backend/Skyeye-sys-dev/skyeye-service-manager/src/main/java/com/zhangy/skyeye/sar/controller/SarControlController.java +++ b/backend/Skyeye-sys-dev/skyeye-service-manager/src/main/java/com/zhangy/skyeye/sar/controller/SarControlController.java @@ -29,4 +29,26 @@ public class SarControlController { controlInfoService.sendUdp(param); return Result.successData("发送成功"); } + + /** + * 发送开机控制指令 + * @param ip + * @return + */ + @RequestMapping("/turnon") + public Result turnOn(@RequestBody String ip) { + controlInfoService.turnOn(ip); + return Result.successData("发送成功"); + } + + /** + * 发送控制指令 + * @param ip + * @return + */ + @RequestMapping("/endall") + public Result endAll(@RequestBody String ip) { + controlInfoService.endAll(ip); + return Result.successData("发送成功"); + } } diff --git a/backend/Skyeye-sys-dev/skyeye-service-manager/src/main/java/com/zhangy/skyeye/sar/service/ISarControlService.java b/backend/Skyeye-sys-dev/skyeye-service-manager/src/main/java/com/zhangy/skyeye/sar/service/ISarControlService.java index 9ba19af..fb0caa3 100644 --- a/backend/Skyeye-sys-dev/skyeye-service-manager/src/main/java/com/zhangy/skyeye/sar/service/ISarControlService.java +++ b/backend/Skyeye-sys-dev/skyeye-service-manager/src/main/java/com/zhangy/skyeye/sar/service/ISarControlService.java @@ -43,6 +43,13 @@ public interface ISarControlService { */ void connect(String ip); + /** + * turn on sar + * + * @param ip + */ + void turnOn(String ip); + /** * 结束所有任务 * diff --git a/backend/Skyeye-sys-dev/skyeye-service-manager/src/main/java/com/zhangy/skyeye/sar/service/impl/SarControlServiceImpl.java b/backend/Skyeye-sys-dev/skyeye-service-manager/src/main/java/com/zhangy/skyeye/sar/service/impl/SarControlServiceImpl.java index 23d5112..4141cd8 100644 --- a/backend/Skyeye-sys-dev/skyeye-service-manager/src/main/java/com/zhangy/skyeye/sar/service/impl/SarControlServiceImpl.java +++ b/backend/Skyeye-sys-dev/skyeye-service-manager/src/main/java/com/zhangy/skyeye/sar/service/impl/SarControlServiceImpl.java @@ -1,5 +1,6 @@ package com.zhangy.skyeye.sar.service.impl; +import com.zhangy.skyeye.common.extend.exception.ServiceException; import com.zhangy.skyeye.common.extend.util.JsonUtil; import com.zhangy.skyeye.jm.dto.JmJobDTO; import com.zhangy.skyeye.jm.dto.JmSarStatusDTO; @@ -84,8 +85,22 @@ public class SarControlServiceImpl implements ISarControlService { udpSendContext.execute(param); } + @Override + public void turnOn(String ip) { + if (!redisUtil.hHasKey(CacheKey.SAR_CONNECTED, ip) || !redisUtil.hasKey(CacheKey.getSarConnect(ip))) { + throw new ServiceException("请先加电并连接sar"); + } + + SarControlParamDTO param = new SarControlParamDTO(ip, SarControlTypeEnum.TURNON); + udpSendContext.execute(param); + } + @Override public void endAll(String ip) { + if (!redisUtil.hHasKey(CacheKey.SAR_CONNECTED, ip) || !redisUtil.hasKey(CacheKey.getSarConnect(ip))) { + throw new ServiceException("请先加电并连接sar"); + } + SarControlParamDTO param = new SarControlParamDTO(ip, SarControlTypeEnum.ENDALL); udpSendContext.execute(param); }