TEAMModelOS/TEAMModeBI/Controllers/BIServer/BiServersController.cs

using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using TEAMModelOS.Models;
using TEAMModelOS.SDK.DI;
using Microsoft.Extensions.Options;
using Microsoft.Extensions.Configuration;
using System.Text.Json;
using System.Net.Http;
using TEAMModelOS.SDK.Extension;
using System.Text;
using System.Net;
using HTEXLib.COMM.Helpers;
using System.Net.Http.Json;

namespace TEAMModeBI.Controllers.BIServer
{
    [Route("biservers")]
    [ApiController]
    public class BiServersController : ControllerBase
    {
        //钉钉信息发送
        private readonly DingDing _dingDing;
        //数据库连接
        public AzureCosmosFactory _azureCosmos;
        private readonly Option _option;
        //读取配置信息
        private readonly IConfiguration _configuration;

        private readonly IHttpClientFactory _http;

        public BiServersController(AzureCosmosFactory azureCosmos, DingDing dingDing, IOptionsSnapshot<Option> option, IConfiguration configuration, IHttpClientFactory http)
        {
            _azureCosmos = azureCosmos;
            _dingDing = dingDing;
            _option = option?.Value;
            _configuration = configuration;
            _http = http;
        }

        /// <summary>
        /// 依据手机号查询醍摩豆基础信息
        /// </summary>
        /// <param name="jsonElment"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("get-mobileuserinfo")]
        public async Task<IActionResult> SendMobileGetUserIfo(JsonElement jsonElment) 
        {
            try
            {
                if (!jsonElment.TryGetProperty("mobile", out JsonElement _mobile)) return BadRequest();
                HttpClient httpClient = new HttpClient();
                List<JsonElement> mbs = new List<JsonElement>() { _mobile };
                string url = _configuration.GetValue<string>("HaBookAuth:CoreId:userinfo");
                var content = new StringContent(mbs.ToJsonString(), Encoding.UTF8, "application/json");

                HttpResponseMessage responseMessage = await httpClient.PostAsync(url, content);
                userInfo userInfo = new userInfo();
                userInfo.mobile = $"{_mobile}";
                if (responseMessage.StatusCode == HttpStatusCode.OK)
                {
                    string responseBody = await responseMessage.Content.ReadAsStringAsync();
                    List<JsonElement> json_id = responseBody.ToObject<List<JsonElement>>();                    
                    if (json_id.IsNotEmpty())
                    {
                        userInfo.tmdid = json_id[0].GetProperty("id").ToString();
                        userInfo.tmdname = json_id[0].GetProperty("name").ToString();
                    }
                    return Ok(new { state = 200, userInfo });
                }
                else return Ok(new { responseMessage.StatusCode });

            }
            catch (Exception ex)
            {
                await _dingDing.SendBotMsg($"BI, {_option} /biservers/get-mobileuserinfo  \n {ex.Message} {ex.StackTrace}", GroupNames.AI智慧學校申請通知群);
                return BadRequest();
            }
        }

        /// <summary>
        /// 发送验证码
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("send-sms")]
        public async Task<IActionResult> send_sms(JsonElement jsonElement)
        {
            try
            {
                if (!jsonElement.TryGetProperty("country", out JsonElement country)) return BadRequest();
                if (!jsonElement.TryGetProperty("to", out JsonElement to)) return BadRequest();
                if (!jsonElement.TryGetProperty("lang", out JsonElement lang)) return BadRequest();
                if (!jsonElement.TryGetProperty("HasUser", out JsonElement HasUser)) return BadRequest();

                string smsurl = _configuration.GetValue<string>("HaBookAuth:CoreAPI");
                HttpClient httpClient = _http.CreateClient();
                HttpResponseMessage responseMessage = await httpClient.PostAsJsonAsync($"{smsurl}/service/sandsms/pin", jsonElement);
                if (responseMessage.StatusCode == HttpStatusCode.OK)
                {
                    string str_json = await responseMessage.Content.ReadAsStringAsync();
                    if (string.IsNullOrEmpty($"{str_json}"))
                    {
                        return Ok(new { status = 200, message = "发送成功" });
                    }
                    else
                    {
                        return Ok(str_json);
                    }
                }
                else
                {
                    return Ok(new { status = 0, message = "发送失败！" });
                }
            }
            catch (Exception ex)
            {
                return Ok(new { status = 0, message = $"发送失败！{ex.Message}" });
            }
        }

        /// <summary>
        /// 验证码和手机的验证
        /// </summary>
        /// <param name="jsonElement"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("verfiypin")]
        public async Task<IActionResult> VerifiyPIN(JsonElement jsonElement)
        {
            try
            {
                if (!jsonElement.TryGetProperty("mobile", out JsonElement mobile)) return BadRequest();
                if (!jsonElement.TryGetProperty("Authorization_Pin", out JsonElement sms)) return BadRequest();

                string smsurl = _configuration.GetValue<string>("HaBookAuth:CoreAPI");
                HttpClient httpClient = new HttpClient();
                var temp_job = new { Authorization_Pin = sms };
                //var content = new StringContent(temp_job.ToJsonString(), Encoding.UTF8, "application/json");
                HttpResponseMessage responseMessage = await httpClient.PostAsJsonAsync($"{smsurl}/service/verifiy/pin", temp_job);

                if (responseMessage.StatusCode == HttpStatusCode.OK)
                {
                    string responseBody = await responseMessage.Content.ReadAsStringAsync();
                    var json = responseBody.ToObject<JsonElement>();
                    json.TryGetProperty("resule", out JsonElement jsone);
                    if (!string.IsNullOrEmpty($"{jsone}"))
                    {
                        string[] mobules = $"{jsone}".Split("-");
                        string temp_mobile = mobules.Length >= 2 ? mobules[1] : mobules[0];
                        if (mobile.ToString().Equals(temp_mobile))
                        {
                            return Ok(new { status = 200, message = "手机号和验证码验证都过了" });
                        }
                        else
                        {
                            return Ok(new { status = 5, message = "手机号码不正确" });
                        }
                    }
                    else
                    {
                        return Ok(json);
                    }
                }
                else
                {
                    return Ok(new { status = 0, message = "发送状态错误" });
                }
            }
            catch (Exception ex)
            {
                return Ok(new { status = 0, message = $"发送状态错误{ex.Message}" });
            }
        }



        public record userInfo
        {
            public string mobile { get; set; }
            public string tmdid { get; set; }
            public string tmdname { get; set; }

        }

    }
}