TEAMModelOS/TEAMModelGrpc/Services/CourseService.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.Module.AzureCosmosDBV3;
using TEAMModelOS.Service.Models;

namespace TEAMModelGrpc.Services
{
    public class CourseService : IGrpcService
    {
        public IAzureCosmosDBV3Repository _cosmos;

        public CourseService(IAzureCosmosDBV3Repository cosmosDBV3Repository)
        {
            this._cosmos = cosmosDBV3Repository;
        }


        /// <summary>
        /// 查询课程
        /// </summary>
        /// <param name="request"></param>
        /// <param name="responseStream"></param>
        /// <param name="context"></param>
        /// <returns></returns>
        [Authorize]
        public async Task FindCourseByDict(Dict request, IServerStreamWriter<Course> responseStream, ServerCallContext context)
        {

            Dictionary<string, object> keyValuePairs = new Dictionary<string, object>();
            keyValuePairs = request.ToDict();

            List<Course> course = await _cosmos.FindByDict<Course>(keyValuePairs);
            course.ForEach(x =>
            {
                responseStream.WriteAsync(x);
            });


        }

        /// <summary>
        /// 保存课程
        /// </summary>
        /// <param name="requestStream"></param>
        /// <param name="responseStream"></param>
        /// <param name="context"></param>
        /// <returns></returns>
        [Authorize]
        public async Task SaveCourse(IAsyncStreamReader<Course> requestStream, IServerStreamWriter<Course> responseStream, ServerCallContext context)
        {
            //Dictionary<string, object> keyValuePairs = new Dictionary<string, object>();
            //keyValuePairs = request.ToDict();
            List<Course> knowledges = new List<Course>();
            await foreach (var message in requestStream.ReadAllAsync())
            {
                knowledges.Add(message);
            }

            await _cosmos.SaveOrUpdateAll(knowledges);

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


        /// <summary>
        /// 删除课程
        /// </summary>
        /// <param name="listPid"></param>
        /// <param name="context"></param>
        /// <returns></returns>
        [Authorize]
        public async Task<ListPid> DeleteCourse(ListPid listPid, ServerCallContext context)
        {
            List<IdPk> idPks = await _cosmos.DeleteAll<Course>(listPid.idPks);
            listPid.idPks = idPks;
            return listPid;
        }
    }
}