服务端的TigerApi 框架,基于.NET6 2024 版本
Cloud Zhang
2024-05-09 ed21ef7fb3b91194bf7741eff2c509da1b774a93
Tiger.Api/Controllers/Test/TestController.R.cs
@@ -18,6 +18,7 @@
using Tiger.Model.Sharetronic.Shelf;
using Newtonsoft.Json.Linq;
using Tiger.Api.iBiz;
using System.Net;
namespace Tiger.Api.Controllers.Test
{
@@ -231,46 +232,6 @@
            return Ok($"设置{param}成功");
        }
        /// <summary>
        /// SendMQTTAsync
        /// </summary>
        /// <param name="action"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<IActionResult> SendMQTTAsync([FromBody] ApiAction action)
        {
            string msg = "";
            await Task.Run(() =>
            {
                msg = action.ID;
                MQTTHelper.Send("TestSendMQTT001", new MQTTMessage()
                {
                    Type = "TestSendMQTT001",
                    Content = "TestSendMQTT001,测试消息!",
                    Data = "",
                    DataType = typeof(String).Name,
                    IsSuccessed = true,
                });
            });
            return Ok(MQTTHelper.Send(action.GetResponse(msg)));
        }
        /// <summary>
        /// DeleteMQTTTopicAsync
        /// </summary>
        /// <param name="action"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<IActionResult> DeleteMQTTTopicAsync([FromBody] ApiAction action)
        {
            string msg = "";
            await Task.Run(() =>
            {
                msg = MQTTHelper.DeleteTopic(action.ID) ? "删除Topic成功" : "删除Topic失败";
            });
            return Ok(action.GetResponse(msg));
        }
        [HttpPost]
        public async Task<IActionResult> TestTask([FromBody] ApiAction action)
        {
@@ -320,7 +281,6 @@
    [Route("api/[controller]/[action]")]
    public partial class _TestController : ControllerBase
    {
        [HttpGet]
        public async Task<IActionResult> DoSomething(int duration)
        {
@@ -336,4 +296,61 @@
            return Ok($"{begin:mmssfff} completed");
        }
    }
    /// <summary>
    /// MQTT测试控制器
    /// </summary>
    [ApiController]
    [Route("api/[controller]/[action]")]
    public partial class _MqttTestController : ControllerBase
    {
        [HttpGet]
        public async Task<IActionResult> DoSomething1(int duration)
        {
            var begin = DateTime.Now;
            return Ok($"{begin:mmssfff} completed");
        }
        /// <summary>
        /// SendMQTTAsync
        /// </summary>
        /// <param name="action"></param>
        /// <returns></returns>
        //[HttpPost]
        //public async Task<IActionResult> SendMQTTAsync([FromBody] ApiAction action)
        //{
        //    string msg = "";
        //    await Task.Run(() =>
        //    {
        //        msg = action.ID;
        //        MQTTHelper.Send("TestSendMQTT001", new MQTTMessage()
        //        {
        //            Type = "TestSendMQTT001",
        //            Content = "TestSendMQTT001,测试消息!",
        //            Data = "",
        //            DataType = typeof(String).Name,
        //            IsSuccessed = true,
        //        });
        //    });
        //    return Ok(MQTTHelper.Send(action.GetResponse(msg)));
        //}
        /// <summary>
        /// DeleteMQTTTopicAsync
        /// </summary>
        /// <param name="action"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<IActionResult> DeleteMQTTTopicAsync([FromBody] ApiAction action)
        {
            string msg = "";
            await Task.Run(() =>
            {
                //msg = MQTTHelper.DeleteTopic(action.ID) ? "删除Topic成功" : "删除Topic失败";
            });
            return Ok(action.GetResponse(msg));
        }
    }
}