TEAMModelOS/TEAMModelGrpc/Services/ClassroomService.cs

using Grpc.Core;
using Grpc.Extension.Abstract;
using Microsoft.AspNetCore.Authorization;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using TEAMModelGrpc.Models;
using TEAMModelOS.SDK.Helper.Common.CollectionHelper;
using TEAMModelOS.SDK.DI;
using TEAMModelOS.Service.Models;

namespace TEAMModelGrpc.Services
{
    public class ClassroomService : IGrpcService
    {
        public readonly AzureCosmosFactory cosmosrepository;

        public ClassroomService(AzureCosmosFactory cosmosrepository)
        {
            this.cosmosrepository = cosmosrepository;
        }

        /// <summary>
        /// 保存教室
        /// </summary>
        /// <param name="requestStream"></param>
        /// <param name="responseStream"></param>
        /// <param name="context"></param>
        /// <returns></returns>
        [Authorize]
        public async Task SaveOrUpdateVolume(IAsyncStreamReader<Classroom> requestStream, IServerStreamWriter<Classroom> responseStream, ServerCallContext context)
        {

            List<Classroom> classrooms = new List<Classroom>();
            await foreach (Classroom classroom in requestStream.ReadAllAsync())
            {
                if (classroom.id != null)
                {
                    classrooms.Add( await cosmosrepository.SaveOrUpdate(classroom));
                }
                else
                {
                    ClassStudent students = new ClassStudent();
                    students.code = classroom.code;
                    students.id = classroom.classroomCode;
                    await cosmosrepository.SaveOrUpdate(students);
                    classrooms.Add(await cosmosrepository.SaveOrUpdate(classroom));

                }
            }
            classrooms.ForEach(x => {
                responseStream.WriteAsync(x);
            });
        }


        /// <summary>
        /// 查询教室
        /// </summary>
        /// <param name="request"></param>
        /// <param name="responseStream"></param>
        /// <param name="context"></param>
        /// <returns></returns>
        [Authorize]
        public async Task FindVolume(Dict request, IServerStreamWriter<Classroom> responseStream, ServerCallContext context)
        {

            Dictionary<string, object> dict = request.ToDict();
            List<Classroom> syllabusVolumes = await cosmosrepository.FindByDict<Classroom>(dict);
            syllabusVolumes.ForEach(x => {
                responseStream.WriteAsync(x);
            });
        }


        /// <summary>
        /// 删除教室
        /// </summary>
        /// <param name="listPid"></param>
        /// <param name="context"></param>
        /// <returns></returns>
        [Authorize]
        public async Task<ListPid> Delete(ListPid listPid, ServerCallContext context)
        {
            await cosmosrepository.DeleteAll<Classroom>(listPid.idPks);
            if (listPid.idPks.IsNotEmpty())
            {
                List<ClassStudent> students = new List<ClassStudent>();
                foreach (IdPk classroom in listPid.idPks)
                {
                    List<ClassStudent> ClassStudents = await cosmosrepository.FindByDict<ClassStudent>(new Dictionary<string, object> { { "id", classroom.id }, { "code", classroom.pk } });
                    students.AddRange(ClassStudents);
                }
                if (students.Count > 0)
                {
                    await cosmosrepository.DeleteAll<ClassStudent>(students);
                }
                listPid.idPks = await cosmosrepository.DeleteAll<Classroom>(listPid.idPks);
            }
            return listPid;
        }
    }
}