From 577e5505da8328083e7a962647ac53df60c84194 Mon Sep 17 00:00:00 2001
From: "David P.G" <pgw1315@163.com>
Date: Thu, 3 Jul 2025 08:39:48 +0800
Subject: [PATCH] =?UTF-8?q?=E7=BB=99Mqtt=E6=B7=BB=E5=8A=A0=E5=B1=9E?=
 =?UTF-8?q?=E6=80=A7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 Data/Entities/DbMqtt.cs | 73 +++++++++++++++++++++++++++++++++++++++--
 Enums/MqttPlatform.cs   | 11 +++++++
 Models/Mqtt.cs          | 71 ++++++++++++++++++++++++++++++++++++++-
 3 files changed, 152 insertions(+), 3 deletions(-)
 create mode 100644 Enums/MqttPlatform.cs

diff --git a/Data/Entities/DbMqtt.cs b/Data/Entities/DbMqtt.cs
index 5364531..6adef89 100644
--- a/Data/Entities/DbMqtt.cs
+++ b/Data/Entities/DbMqtt.cs
@@ -1,9 +1,78 @@
-using SqlSugar;
+using PMSWPF.Enums;
+using SqlSugar;
+using SqlSugar.DbConvert;
 
 namespace PMSWPF.Data.Entities;
 
 public class DbMqtt
 {
-    [SugarColumn(IsPrimaryKey = true, IsIdentity = true)] //数据库是自增才配自增 
+    [SugarColumn(IsPrimaryKey = true, IsIdentity = true)] //数据库是自增才配自增
     public int Id { get; set; }
+
+    /// <summary>
+    /// MQTT主机
+    /// </summary>
+    public string Host { get; set; }
+
+    /// <summary>
+    /// MQTT主机端口
+    /// </summary>
+    public int Port { get; set; }
+
+    /// <summary>
+    /// 是否启用
+    /// </summary>
+    public bool IsActive { get; set; }
+
+    /// <summary>
+    /// Mqtt平台
+    /// </summary>
+    [SugarColumn(ColumnDataType = "varchar(20)", SqlParameterDbType = typeof(EnumToStringConvert))]
+    public MqttPlatform Platform { get; set; }
+
+
+    /// <summary>
+    /// MQTT客户端名字
+    /// </summary>
+    public string Name { get; set; }
+
+    /// <summary>
+    /// MQTT客户端登录用户名
+    /// </summary>
+    public string UserName { get; set; }
+
+    /// <summary>
+    /// MQTT客户端登录密码
+    /// </summary>
+    public string PassWord { get; set; } //变量状态 
+
+    /// <summary>
+    /// MQTT客户端ID
+    /// </summary>
+    public string ClientID { get; set; }
+
+    /// <summary>
+    /// MQTT发布主题
+    /// </summary>
+    public string PublishTopic { get; set; }
+
+    /// <summary>
+    /// MQTT订阅主题
+    /// </summary>
+    public string SubTopics { get; set; }
+
+    /// <summary>
+    /// 是否设置为默认MQTT客户端
+    /// </summary>
+    public int IsDefault { get; set; }
+
+    /// <summary>
+    /// 连接时间
+    /// </summary>
+    public DateTime ConnTime { get; set; }
+
+    /// <summary>
+    /// MQTT备注
+    /// </summary>
+    public string Remark { get; set; } = String.Empty;
 }
\ No newline at end of file
diff --git a/Enums/MqttPlatform.cs b/Enums/MqttPlatform.cs
new file mode 100644
index 0000000..96e9532
--- /dev/null
+++ b/Enums/MqttPlatform.cs
@@ -0,0 +1,11 @@
+using System.ComponentModel;
+
+namespace PMSWPF.Enums;
+
+public enum MqttPlatform
+{
+    [Description("艾莫迅")]
+    Amsamotion,
+    [Description("有人云")]
+    USR
+}
\ No newline at end of file
diff --git a/Models/Mqtt.cs b/Models/Mqtt.cs
index 9ae0512..54b05b7 100644
--- a/Models/Mqtt.cs
+++ b/Models/Mqtt.cs
@@ -1,5 +1,74 @@
-namespace PMSWPF.Models;
+using PMSWPF.Enums;
+
+namespace PMSWPF.Models;
 
 public class Mqtt
 {
+    public int Id { get; set; }
+
+    /// <summary>
+    /// MQTT主机
+    /// </summary>
+    public string Host { get; set; }
+
+    /// <summary>
+    /// MQTT主机端口
+    /// </summary>
+    public int Port { get; set; }
+
+    /// <summary>
+    /// 是否启用
+    /// </summary>
+    public bool IsActive { get; set; }
+
+    /// <summary>
+    /// Mqtt平台
+    /// </summary>
+    public MqttPlatform Platform { get; set; }
+
+
+    /// <summary>
+    /// MQTT客户端名字
+    /// </summary>
+    public string Name { get; set; }
+
+    /// <summary>
+    /// MQTT客户端登录用户名
+    /// </summary>
+    public string UserName { get; set; }
+
+    /// <summary>
+    /// MQTT客户端登录密码
+    /// </summary>
+    public string PassWord { get; set; } //变量状态 
+
+    /// <summary>
+    /// MQTT客户端ID
+    /// </summary>
+    public string ClientID { get; set; }
+
+    /// <summary>
+    /// MQTT发布主题
+    /// </summary>
+    public string PublishTopic { get; set; }
+
+    /// <summary>
+    /// MQTT订阅主题
+    /// </summary>
+    public string SubTopics { get; set; }
+
+    /// <summary>
+    /// 是否设置为默认MQTT客户端
+    /// </summary>
+    public int IsDefault { get; set; }
+
+    /// <summary>
+    /// 连接时间
+    /// </summary>
+    public DateTime ConnTime { get; set; }
+
+    /// <summary>
+    /// MQTT备注
+    /// </summary>
+    public string Remark { get; set; } = String.Empty;
 }
\ No newline at end of file