xiaomiMes/MainForm/ClassFile/XiaomiAPI_AGV/XiaomiAGVMQTT_Base.cs

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
{
    /// <summary>
    /// 小米AGV Mqtt类
    /// </summary>
    public class XiaomiAGVMQTT_Base
    {
        #region 变量
        /// <summary>
        /// AGV 接收信息用的订阅号
        /// </summary>
        public static string AgvTopic = "iiot_tm_comm_control_up/tm/up/control/agv";

        /// <summary>
        /// 设备 接收信息用的订阅号
        /// </summary>
        public static string DeviceTopic = "iiot_tm_comm_control_down/tm/down/control/{0}";
        #endregion 变量

        /// <summary>
        /// 装备 订阅 agv报文
        /// </summary>
        /// <param name="mqttHelper"></param>
        /// <param name="portCode">设备号</param>
        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;
        }

        /// <summary>
        /// AGV发送来的报文 - 实体
        /// </summary>
        public class FromAGV
        {
            /// <summary>
            /// 事件；非必填
            /// </summary>
            public string things { set; get; } = null;

            /// <summary>
            /// 服务内容
            /// </summary>
            public FromAGVService service { set; get; } = new FromAGVService();

            /// <summary>
            /// 时间戳；13位
            /// </summary>
            public string time { set; get; } = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds().ToString();

            /// <summary>
            /// 服务内容
            /// </summary>
            public class FromAGVService
            {
                /// <summary>
                /// Id 等于 时间戳time
                /// </summary>
                public string callId { set; get; } = string.Empty;

                /// <summary>
                /// 任务标识符
                /// control/outgoing 出料请求
                /// control/outgoing/finish 出料完成
                /// </summary>
                public string identifier { set; get; } = string.Empty;

                /// <summary>
                /// 接驳台信息
                /// </summary>
                public string inputItems { set; get; } = string.Empty;
            }
        }
    }
}