src/sample/XXX.Plugin.Tdengine/Controller/TaosController.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using Newtonsoft.Json;
using System.Net.Http.Json;
using System.Text;

namespace XXX.Plugin.Tdengine
{
    /// <summary>
    /// 
    /// </summary>
    [ApiController]
    [Route("[controller]")]
    public class TaosController : ControllerBase
    {
        private readonly IHostEnvironment _hostEnvironment;
        private readonly ILogger<TaosController> _logger;
        private readonly ITaosService _taosService;
        private readonly ITaosProxy _taosProxy;
        private readonly IHttpClientFactory _httpClientFactory;

        /// <summary>
        /// 
        /// </summary>
        /// <param name="hostEnvironment"></param>
        /// <param name="logger"></param>
        /// <param name="taosService"></param>
        /// <param name="taosProxy"></param>
        /// <param name="httpClientFactory"></param>
        public TaosController(
            IHostEnvironment hostEnvironment,
            ILogger<TaosController> logger,
            ITaosService taosService,
            ITaosProxy taosProxy,
            IHttpClientFactory httpClientFactory
            )
        {
            _hostEnvironment = hostEnvironment;
            _logger = logger;
            _taosService = taosService;
            _taosProxy = taosProxy;
            _httpClientFactory = httpClientFactory;
        }

        /// <summary>
        /// 数据插入方便测试demo
        /// </summary>
        /// <returns></returns>
        [HttpGet("inserttest")]
        [ProducesResponseType(200, Type = typeof(ResponseResult))]
        public async Task<IActionResult> InsertAsync()
        {
            await _taosService.InsertTestAsync();
            return Ok();
        }

        /// <summary>
        /// 数据插入
        /// </summary>
        /// <param name="taosAo"></param>
        /// <param name="dbKey"></param>
        /// <returns></returns>