TEAMModelOS/TEAMModelOS/Controllers/Syllabus/VolumeController.cs

using Microsoft.AspNetCore.Mvc;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using TEAMModelOS.Service.Models.Core;
using TEAMModelOS.Service.Models.Syllabus;
using TEAMModelOS.SDK.Context.Exception;
using TEAMModelOS.SDK.Extension.DataResult.JsonRpcRequest;
using TEAMModelOS.SDK.Extension.DataResult.JsonRpcResponse;
using TEAMModelOS.SDK.Extension.SnowFlake;
using TEAMModelOS.SDK.Helper.Common.CollectionHelper;
using TEAMModelOS.SDK.Helper.Security.ShaHash;
using TEAMModelOS.SDK.Module.AzureCosmosDB.Interfaces;
using TEAMModelOS.Controllers;
using TEAMModelOS.SDK;
using TEAMModelOS.SDK.Module.AzureCosmosDBV3;
using TEAMModelOS.Service.Services.Syllabus.Interface;

namespace TEAMModelOS.Controllers.Syllabus
{
    [Route("api/[controller]")]
    [ApiController]
    public class VolumeController : BaseController
    {
        private IAzureCosmosDBV3Repository azureCosmosDBRepository;
        private IVolumeService volumeService;

        public VolumeController(IAzureCosmosDBV3Repository azureCosmosDBRepository, IVolumeService volumeService)
        {
            this.azureCosmosDBRepository = azureCosmosDBRepository;
            this.volumeService = volumeService;
        }


        /// <summary>
        /// 新增册别
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost("SaveOrUpdate")]
        public async Task<BaseJosnRPCResponse> SaveOrUpdate(JosnRPCRequest<SyllabusVolume> request)
        {
            JsonRPCResponseBuilder builder = JsonRPCResponseBuilder.custom();
            List<SyllabusVolume> volume = await volumeService.SaveOrUpdateVolume(request.@params);
            return builder.Data(volume.IsEmpty() ? null : volume[0]).build();
        }

       
        /// <summary>
        /// 删除册别
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost("Delete")]
        public async Task<BaseJosnRPCResponse> Delete(JosnRPCRequest<SyllabusVolume> request)
        {
            JsonRPCResponseBuilder builder = JsonRPCResponseBuilder.custom();
            bool flag = false;
            if (!string.IsNullOrEmpty(request.@params.id))
            {
                //if (request.@params.type == 0)
                //{
                    request.@params.status = 0;
                    List<SyllabusVolume> volumes = new List<SyllabusVolume>
                    {
                        request.@params
                    };
                    await azureCosmosDBRepository.SaveOrUpdateAll<SyllabusVolume>(volumes);
                    flag = true;
                //}
                //else
                //{
                //    await azureCosmosDBRepository.DeleteAsync<Volume>(request.@params.id, request.@params.schoolCode);
                //    await azureCosmosDBRepository.DeleteAll<SyllabusNode>(new Dictionary<string, object>() { { "volumeCode", request.@params.id } });
                //    flag = true;
                //}
            }
            return builder.Data(flag).build();
        }


        /// <summary>
        /// 查找册别
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost("Find")]
        public async Task<BaseJosnRPCResponse> Find(JosnRPCRequest<Dictionary<string, object>> request)
        {
            JsonRPCResponseBuilder builder = JsonRPCResponseBuilder.custom();
            List<SyllabusVolume> volumes ;
            if (request.@params.TryGetValue("scopeCode", out _))
            {
                volumes = await azureCosmosDBRepository.FindByDict<SyllabusVolume>(request.@params);
            }
            else
            {
                throw new BizException("scopeCode is  null!");
            }
            return builder.Data(volumes).build();
        }
    }
}