TEAMModelOS/TEAMModelAPI/Controllers/School/TeacherController.cs

using Azure.Cosmos;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Options;
using System;
using System.Collections.Generic;
using System.IdentityModel.Tokens.Jwt;
using System.IO;
using System.Linq;
using System.Text;
using System.Text.Json;
using System.Threading.Tasks;
using TEAMModelOS.Models;
using TEAMModelOS.Models.Dto;
using TEAMModelOS.SDK.Models;
using TEAMModelOS.SDK;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.SDK.DI.AzureCosmos.Inner;
using TEAMModelOS.SDK.Extension;
using TEAMModelOS.SDK.Helper.Common.StringHelper;
using System.Dynamic;
using Azure;
using TEAMModelOS.SDK.Models.Cosmos.Common;
using Azure.Messaging.ServiceBus;
using Microsoft.Extensions.Configuration;
using TEAMModelOS.Filter;
using Azure.Storage.Blobs.Models;
using HTEXLib.COMM.Helpers;
using Microsoft.AspNetCore.Authorization;
using System.Net.Http;

namespace TEAMModelAPI.Controllers
{
    [Route("school")]
    [ApiController]
    public class TeacherController : ControllerBase
    {
        private AzureCosmosFactory _azureCosmos;
        private readonly DingDing _dingDing;
        private readonly Option _option;
        private readonly AzureServiceBusFactory _serviceBus;
        private readonly AzureStorageFactory _azureStorage;
        public IConfiguration _configuration { get; set; }
        private readonly CoreAPIHttpService _coreAPIHttpService;
        public TeacherController(CoreAPIHttpService coreAPIHttpService, AzureCosmosFactory azureCosmos, DingDing dingDing, IOptionsSnapshot<Option> option, AzureServiceBusFactory serviceBus, AzureStorageFactory azureStorage, IConfiguration configuration)
        {
            _azureCosmos = azureCosmos;
            _dingDing = dingDing;
            _option = option?.Value;
            _serviceBus = serviceBus;
            _configuration = configuration;
            _azureStorage = azureStorage;
            _coreAPIHttpService = coreAPIHttpService;
        }

        /// <summary>
        ///  获取学校教师列表
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("get-teacher-list")]
        [ApiToken(Auth = "1501", Name = "学校教师列表", RW = "R", Limit = false)]
        public async Task<IActionResult> GetTeacherList(JsonElement json)
        {
            
            json.TryGetProperty("searchKey", out JsonElement _searchKey);
            List<CoreUser> coreUsers = new List<CoreUser>();
            IEnumerable<string> unexist = null ;
            if (_searchKey.ValueKind.Equals(JsonValueKind.Array))
            {
                List<string> searchKey= _searchKey.ToObject<List<string>>();
                var keys = searchKey.Where(x => !string.IsNullOrWhiteSpace(x));
                var content = new StringContent(keys.ToJsonString(), Encoding.UTF8, "application/json");
                string ujson = await _coreAPIHttpService.GetUserInfos(content);
                if (!string.IsNullOrWhiteSpace(ujson))
                {
                    coreUsers = ujson.ToObject<List<CoreUser>>();
                }
                if (coreUsers.Any())
                {
                    unexist = searchKey.Except(coreUsers.Select(x => x.searchKey));
                }
                else {
                    return Ok(new { error = 1, msg = "没有找到对应的教师信息！" });
                }
            }
           
         
            var (id, school) = HttpContext.GetApiTokenInfo();
            List<SchoolTeacher> teachers = new List<SchoolTeacher>();
            string insql = "";
            if (coreUsers.Any()) {
                 insql = $" and c.id in  ({string.Join(",", coreUsers.Select(x => $"'{ x.id}'"))}) ";
            }
            string sql = $"select c.id,c.name ,c.picture,c.job ,c.subjectIds,c.roles from c where c.status='join' {insql}";
            await foreach (var item in _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School").GetItemQueryIterator<SchoolTeacher>
                (queryText: sql, requestOptions: new QueryRequestOptions { PartitionKey = new PartitionKey($"Teacher-{school}") }))
            {
                teachers.Add(item);
            }
            var teacherIds=   coreUsers.Select(x => x.id).Except(teachers.Select(x => x.id));
            List<CoreUser> unjoined = coreUsers.FindAll(x => teacherIds.Contains(x.id));
            List<dynamic> tchs= new List<dynamic>(); 
            teachers.Select(x => new { x.id, x.name, x.picture, x.job, x.subjectIds, x.roles }).ToList().ForEach(x => {
                var  coreUser= coreUsers.Find(c=>c.id.Equals(x.id));
                if (coreUser != null) {
                    tchs.Add(new {x.id,x.name,x.picture,x.job,x.subjectIds,x.roles,coreUser.searchKey });
                }
            });
            return Ok(new
            {
                teachers = tchs,
                unjoined= unjoined.Select(x => new {x.id,x.name,x.picture,x.searchKey}),
                unexist= unexist
            }); 
        }
        /// <summary>
        /// 获取学校教师信息
        /// </summary>
        /// <returns></returns>
        [ProducesDefaultResponseType]
        [HttpPost("get-teacher-info")]
        [ApiToken(Auth = "1502", Name = "学校教师信息", RW = "R", Limit = false)]
        public async Task<IActionResult> GetTeacherInfo(JsonElement json)
        {
            json.TryGetProperty("tmdid", out JsonElement _tmdid);
            var (id, school) = HttpContext.GetApiTokenInfo();
            Azure.Response responseSchoolTch = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "School")
                .ReadItemStreamAsync($"{_tmdid}", new PartitionKey($"Teacher-{school}"));
            Azure.Response responseTch = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, "Teacher")
                 .ReadItemStreamAsync($"{_tmdid}", new PartitionKey($"Base"));
            Teacher teacher = null;
            if (responseTch.Status == 200)
            {
                teacher = JsonDocument.Parse(responseTch.Content).RootElement.Deserialize<Teacher>();
            }
            else
            {
                return Ok(new { error = 3, msg = "账号未创建！" });
            }
            if (responseSchoolTch.Status == 200 && teacher != null)
            {
                SchoolTeacher schoolTeacher = JsonDocument.Parse(responseSchoolTch.Content).RootElement.Deserialize<SchoolTeacher>();
                if (schoolTeacher.status.Equals("join"))
                {
                    return Ok(new { teacher.id, teacher.name, teacher.picture, schoolTeacher.job, schoolTeacher.status, schoolTeacher.roles, schoolTeacher.subjectIds, school = teacher.schools?.Find(x => x.schoolId.Equals(school)) });
                }
                else
                {
                    return Ok(new { error = 2, msg = "教师未加入学校！" });
                }

            }
            else
            {
                return Ok(new { error = 1, msg = "教师未就职该学校！" });
            }
        }

    }
}