TEAMModelOS/TEAMModelOS.Service/Core/Implements/PeriodService.cs

using System;
using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks;
using TEAMModelOS.Model.Core.Models;
using TEAMModelOS.SDK.Context.Exception;
using TEAMModelOS.SDK.Module.AzureTable.Interfaces;
using TEAMModelOS.Service.Core.Interfaces;

namespace TEAMModelOS.Service.Core.Implements
{
   public class PeriodService : IPeriodService
    {
        IAzureTableDBRepository azureTableDBRepository;
        public PeriodService(IAzureTableDBRepository _azureTableDBRepository)
        {
            azureTableDBRepository = _azureTableDBRepository;
        }
     
        public async Task<int> DeleteAll(Dictionary<string, object> dict)
        {
            List<Period> periods=  await  azureTableDBRepository.FindListByDict<Period>(dict);
            periods=  await azureTableDBRepository.DeleteAll<Period>(periods);
            return periods.Count; 
        }

        public async Task<List<Period>> FindPeriodsByDict(Dictionary<string, object> dict)
        {
            if (dict != null && dict.Keys.Count > 0)
            {
                return await azureTableDBRepository.FindListByDict<Period>(dict);
            }
            else {
                return await azureTableDBRepository.FindAll<Period>();
            }
            
        }
        public async Task<List<SchoolPeriod>> FindSchoolPeriodsByDict(Dictionary<string, object> dict)
        {
            if (dict != null && dict.Count > 0)
            {
                return await azureTableDBRepository.FindListByDict<SchoolPeriod>(dict);

            }
            else
            {
                return null; 
                //throw new BizException("");
                //  return await azureTableDBRepository.FindAll<SchoolPeriod>();
            }
        }
        public async Task<Period> saveOrUpdate(Period period)
        {
            return  await azureTableDBRepository.SaveOrUpdate<Period>(period);
        }
    }
}