From b352651d589a43d1f8ac94bd5a59ce1a332880b4 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=83=AD=E6=89=BF?= Date: Mon, 14 Apr 2025 17:16:25 +0800 Subject: [PATCH] =?UTF-8?q?feat:mqtt=E5=A2=9E=E5=8A=A0=E8=A3=85=E7=BD=AE?= =?UTF-8?q?=E6=97=B6=E9=97=B4=E8=A1=A8=E8=AF=BB=E5=8F=96=E5=92=8C=E8=AE=BE?= =?UTF-8?q?=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/MqttServiceImpl.java | 36 +++++++++++++++++++ 1 file changed, 36 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 20f3ccc..6b5ad11 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 @@ -2,6 +2,7 @@ package com.shxy.xymanager_service.impl; import com.shxy.xymanager_common.exception.ApiException; import com.shxy.xymanager_common.model.mqtt.MessageSend; +import com.shxy.xymanager_common.model.mqtt.ParamArray; import com.shxy.xymanager_common.model.mqtt.Paras; import com.shxy.xymanager_service.mqtt.MqttPublisherService; import com.shxy.xymanager_service.service.MqttService; @@ -10,6 +11,8 @@ import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; +import java.util.ArrayList; +import java.util.List; import java.util.Map; @@ -72,6 +75,39 @@ public class MqttServiceImpl implements MqttService { paras.setActionCommandParameter(preset); } break; + case "schedule": + Integer flag = Integer.parseInt(map.get("flag")); + Integer scheduleChannel = Integer.parseInt(map.get("channel")); + paras.setChannelNumber(scheduleChannel); + if (flag == 0) { + msg.setServiceId("PlatformQueryDataCommandLssueService"); + msg.setCmd("getCaptureTimesTaskInformation"); + } else { + msg.setServiceId("PlatformSettingParameterLssueService"); + msg.setCmd("setCaptureTimesTaskParameter"); + Integer group = Integer.parseInt(map.get("group")); + paras.setGroupNumber(group); + if (group == 3) { + List paramArrayList = new ArrayList<>(); + ParamArray paramArray1 = new ParamArray(); + paramArray1.setHour(Integer.parseInt(map.get("hour1"))); + paramArray1.setMinute(Integer.parseInt(map.get("min1"))); + paramArray1.setPresetPosition(Integer.parseInt(map.get("preset1"))); + paramArrayList.add(paramArray1); + ParamArray paramArray2 = new ParamArray(); + paramArray2.setHour(Integer.parseInt(map.get("hour2"))); + paramArray2.setMinute(Integer.parseInt(map.get("min2"))); + paramArray2.setPresetPosition(Integer.parseInt(map.get("preset2"))); + paramArrayList.add(paramArray2); + ParamArray paramArray3 = new ParamArray(); + paramArray3.setHour(Integer.parseInt(map.get("hour3"))); + paramArray3.setMinute(Integer.parseInt(map.get("min3"))); + paramArray3.setPresetPosition(Integer.parseInt(map.get("preset3"))); + paramArrayList.add(paramArray3); + paras.setParamArray(paramArrayList); + } + } + break; default: throw new ApiException(act + "暂时无法处理"); }