From f9935b2a7187e10d77a5ccae8aea5f13c9c6bd27 Mon Sep 17 00:00:00 2001 From: huangfeng Date: Wed, 8 May 2024 09:32:30 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E5=A2=9E=E5=8A=A0Ota=E5=8D=87=E7=BA=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/CmdController.java | 2 +- .../impl/CmdServiceImpl.java | 37 +++++++++++++++++++ 2 files changed, 38 insertions(+), 1 deletion(-) diff --git a/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/CmdController.java b/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/CmdController.java index 38c424c..37a33f9 100644 --- a/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/CmdController.java +++ b/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/CmdController.java @@ -38,7 +38,7 @@ public class CmdController extends BaseController { map.put("yw_cmd_start_frpc", "开启frpc"); map.put("yw_cmd_stop_frpc", "停止frpc"); map.put("i1_cmd_stop_aging_test", "停止老化测试"); - map.put("updOta", "Ota升级"); + map.put("yw_upd_ota", "Ota升级"); return ResponseReult.success(map); } diff --git a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/CmdServiceImpl.java b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/CmdServiceImpl.java index 3be1bb3..666bb93 100644 --- a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/CmdServiceImpl.java +++ b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/CmdServiceImpl.java @@ -184,6 +184,9 @@ public class CmdServiceImpl implements CmdService { case "upgrade": this.upgrade(model); break; + case "yw_upd_ota": + this.updota(model); + break; case "yw_cmd_start_frpc": this.startfrpc(model); break; @@ -561,4 +564,38 @@ public class CmdServiceImpl implements CmdService { cmdsMapper.insert(cmd); } } + + private void updota(CmdModel model) { + if (CollectionUtils.isEmpty(model.getTermIds())) { + throw new ApiException("termIds不能为空"); + } else if (StringUtils.isBlank(model.getUrl())) { + throw new ApiException("url不能为空"); + } else if (StringUtils.isBlank(model.getMd5())) { + throw new ApiException("md5不能为空"); + } else if (StringUtils.isBlank(model.getFn())) { + throw new ApiException("fn不能为空"); + } + String name = "yw_upd_ota"; + + for (Integer termId : model.getTermIds()) { + MntnCmdsExample example = new MntnCmdsExample(); + MntnCmdsExample.Criteria criteria = example.createCriteria(); + criteria.andTermIdEqualTo(termId); + criteria.andNameEqualTo(name); + cmdsMapper.deleteByExample(example); + + HashMap map = new HashMap<>(); + map.put("url", model.getUrl()); + map.put("md5", model.getMd5()); + map.put("fileName", model.getFn()); + String json = JSONUtil.object2Json(map); + + MntnCmds cmd = new MntnCmds(); + cmd.setTermId(termId); + cmd.setName(name); + cmd.setCmd(json); + cmd.setCreateTime(new Date()); + cmdsMapper.insert(cmd); + } + } }