TEAMModelOS/TEAMModelGrpc/Services/VolumeService.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.DI;
using TEAMModelOS.Service.Models;
using TEAMModelOS.Service.Services.Interface;

namespace TEAMModelGrpc.Services
{
    public class VolumeService :IGrpcService
    {
        private readonly AzureCosmosFactory azureCosmosDBRepository;
        private IVolumeService volumeService;

        public VolumeService(AzureCosmosFactory azureCosmosDBRepository, IVolumeService volumeService)
        {
            this.azureCosmosDBRepository = azureCosmosDBRepository;
            this.volumeService = volumeService;
        }

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

            List<Volume> volumes = new List<Volume>();
            await foreach (Volume syllabusNode in requestStream.ReadAllAsync())
            {
                List<Volume> volume = await volumeService.SaveOrUpdateVolume(syllabusNode);
                volumes.AddRange(volume);
            }
            volumes.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<Volume> responseStream, ServerCallContext context) {

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

            List<Volume> syllabusVolumes = await azureCosmosDBRepository.FindByDict<Volume>(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)
        {
            List<IdPk> idPks = await azureCosmosDBRepository.DeleteAll<Volume>(listPid.idPks);
            listPid.idPks = idPks;
            return listPid;
        }

    }
}