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;
}
}
}
}