TEAMModelOS/TEAMModelOS/Controllers/Syllabus/ResourceController.cs

using Microsoft.AspNetCore.Mvc;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using TEAMModelOS.SDK.Context.Exception;
using TEAMModelOS.SDK;
using TEAMModelOS.SDK.Helper.Common.CollectionHelper;
using TEAMModelOS.SDK.DI;

using TEAMModelOS.Service.Models;
using System.Text.Json;
using TEAMModelOS.SDK.Helper.Common.StringHelper;

namespace TEAMModelOS.Controllers
{
    [Route("api/[controller]")]
    [ApiController]
    public class ResourceController : BaseController
    {
        private AzureStorageFactory _table;
        private AzureCosmosFactory _cosmos;
        private SnowflakeId SnowflakeId;
        public ResourceController(AzureStorageFactory table, AzureCosmosFactory cosmos, SnowflakeId _SnowflakeId)
        {
            _table = table;
            _cosmos = cosmos;
            SnowflakeId = _SnowflakeId;
        }

        /// <summary>
        /// 保存或更新SyllabusResource
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost("upsertAll")]
        public async Task<BaseResponse> UpsertAll(List<Resource> request)
        {
            ResponseBuilder builder = ResponseBuilder.custom();
            if (request.IsNotEmpty())// != null )
            {
                List<Resource> resource = request;
                foreach (Resource item in resource)
                {
                    if (item.id == null)
                    {
                        item.id = SnowflakeId.NextId()+""; //item.sha1Code + "-" + item.extension + "-" + item.size;
                        
                    }
                }
                List<Resource> ts = await _cosmos.SaveOrUpdateAll(resource);
                builder.Data("保存或新增成功");
            }
            return builder.build();
        }


        /// <summary>
        /// 获取SyllabusResource
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost("find")]
        public async Task<BaseResponse> Find(JsonElement request)
        {
            // request.@params.TryAdd("PartitionKey", request.lang);
            ResponseBuilder builder = ResponseBuilder.custom();
            if (StringHelper.getKeyCount(request) > 0)
            {
                List<Resource> data = new List<Resource>();
                data = await _cosmos.FindByDict<Resource>(request);

                return builder.Data(data.OrderBy(m => m.createTime)).Extend(new Dictionary<string, object> { { "count", data.IsNotEmpty() ? data.Count : 0 } }).build();
            }
            else {

                return builder.Error(ResponseCode.PARAMS_ERROR, "参数异常！").build();
            }
              
        }


        /// <summary>
        /// 获取SyllabusResource
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost("findById")]
        public async Task<BaseResponse> FindSyllabusResourceById(List<string> request)
        {
            // request.@params.TryAdd("PartitionKey", request.lang);
            ResponseBuilder builder = ResponseBuilder.custom();
            if (request != null)
            {
                List<Resource> data = new List<Resource>();
                data = await _cosmos.FindByIds<Resource>(request);

                return builder.Data(data.OrderBy(m => m.createTime)).Extend(new Dictionary<string, object> { { "count", data.IsNotEmpty() ? data.Count : 0 } }).build();



            }
            else
            { return builder.Error(ResponseCode.PARAMS_ERROR, "参数异常！").build(); }
        }


        /// <summary>
        /// 删除 SyllabusResource
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost("delete")]
        public async Task<BaseResponse> DeleteSyllabusResource(JsonElement request)
        {
            ResponseBuilder builder = ResponseBuilder.custom();
            List<Resource> syllabusResources =  await Delete<Resource>(request, builder);
            foreach (Resource syllabusResource  in syllabusResources) {

                string blobUrl = syllabusResource.blobUrl;
                if (!string.IsNullOrEmpty(blobUrl))
                {
                  //  await _azureBlobDBRepository.Deleteblob(blobUrl);
                }
                string compressUrl = syllabusResource.compressUrl;
                if (!string.IsNullOrEmpty(compressUrl))
                {
                   // await _azureBlobDBRepository.Deleteblob(compressUrl);
                }
            }

            return builder.build();
        }

        private async Task<List<T>> Delete<T>(JsonElement request, ResponseBuilder builder)where T:ID
        {
            //Dictionary<string, object> dict = new Dictionary<string, object>();
            var emobj = request.EnumerateObject();
            int keys = 0;
            while (emobj.MoveNext())
            {
                keys++;
               //dict[emobj.Current.Name] = emobj.Current.Value;
            }
            if (keys > 0)
            {
                List<T> schoolBlocks = await _cosmos.FindByDict<T>(request);
                Type t = typeof(T);
                if (schoolBlocks.IsNotEmpty())
                {
                    await _cosmos.DeleteAll<T>(schoolBlocks);
                    builder.Data("删除成功");
                }

                return schoolBlocks;
            }
            else {
                  builder.Error(ResponseCode.PARAMS_ERROR, "参数异常！");
                return null;
            }

        }

        /// <summary>
        /// 查询 资源被引用次数
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost("reference")]
        public async Task<BaseResponse> Reference(JsonElement request)
        {
            ResponseBuilder builder = ResponseBuilder.custom();
            Dictionary<string, object> dict = new Dictionary<string, object>();
            var emobj = request.EnumerateObject();
            while (emobj.MoveNext())
            {
                dict[emobj.Current.Name] = emobj.Current.Value;
            }
            List<ResourceReference> data = new List<ResourceReference>();
            data = await _table.FindListByDict<ResourceReference>(dict);
            return builder.Data(data.OrderBy(m => m.CreateTime)).Extend(new Dictionary<string, object> { { "count", data.Count } }).build();
        }
    }
}