using MqttnetServerWin; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using static MainForm.ClassFile.XiaomiAPI_AGV.XiaomiAGVMQTT_Loading; namespace MainForm.ClassFile.XiaomiAPI_AGV { /// /// 小米AGV Mqtt类 /// public class XiaomiAGVMQTT_Base { #region 变量 /// /// AGV 接收信息用的订阅号 /// public static string AgvTopic = "iiot_tm_comm_control_up/tm/up/control/agv"; /// /// 设备 接收信息用的订阅号 /// public static string DeviceTopic = "iiot_tm_comm_control_down/tm/down/control/{0}"; #endregion 变量 /// /// 装备 订阅 agv报文 /// /// /// 设备号 public static ResultData_MQTT DeviceTopicAGV(ref MQTTHelper mqttHelper, string portCode) { string deviceTopic = string.Format(DeviceTopic, portCode); ResultData_MQTT result = mqttHelper.SubscribeAsync_Client(deviceTopic).Result; return result; } /// /// AGV发送来的报文 - 实体 /// public class FromAGV { /// /// 事件;非必填 /// public string things { set; get; } = null; /// /// 服务内容 /// public FromAGVService service { set; get; } = new FromAGVService(); /// /// 时间戳;13位 /// public string time { set; get; } = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds().ToString(); /// /// 服务内容 /// public class FromAGVService { /// /// Id 等于 时间戳time /// public string callId { set; get; } = string.Empty; /// /// 任务标识符 /// control/outgoing 出料请求 /// control/outgoing/finish 出料完成 /// public string identifier { set; get; } = string.Empty; /// /// 接驳台信息 /// public string inputItems { set; get; } = string.Empty; } } } }