From 735db9579ac2e04230cd7398498c2a04f5e0c93d Mon Sep 17 00:00:00 2001 From: huangfeng Date: Wed, 16 Apr 2025 10:29:27 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20mqtt=E5=A2=9E=E5=8A=A0=E4=B8=8B?= =?UTF-8?q?=E5=8F=91=E8=AE=BE=E5=A4=87=E5=8D=87=E7=BA=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../xymanager_service/impl/MqttServiceImpl.java | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) diff --git a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/MqttServiceImpl.java b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/MqttServiceImpl.java index 196da16..0631c02 100644 --- a/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/MqttServiceImpl.java +++ b/xymanager_service/src/main/java/com/shxy/xymanager_service/impl/MqttServiceImpl.java @@ -121,6 +121,23 @@ public class MqttServiceImpl implements MqttService { paras.setTimingType(0); } break; + case "upgrade": + msg.setServiceId("UpgradeManagerAndConfigureFile"); + msg.setCmd("platformupgradeDevices"); + paras.setPassword(""); + paras.setChannelNumber(channel); + paras.setType(1); + paras.setCheckMode(0); + paras.setFileName(map.get("name")); + paras.setCheckValue(map.get("md5")); + if (map.containsKey("url")) { + paras.setUrl(map.get("url")); + } else if (map.containsKey("file")) { + str = map.get("file"); + str.replaceFirst("/home/xymp/upgrade", "http://61.169.135.146:40080/upgrade"); + paras.setUrl(str); + } + break; default: throw new ApiException(act + "暂时无法处理"); }