using System.Data;
using Newtonsoft.Json;
using Tiobon.Core.Common;
using Tiobon.Core.Common.Caches;
using Tiobon.Core.IRepository.Base;
using Tiobon.Core.IServices;
using Tiobon.Core.Model;
using Tiobon.Core.Model.Models;
using Tiobon.Core.Services.BASE;

namespace Tiobon.Core.Services
{
    /// <summary>
    /// 课件 (服务)
    /// </summary>
    public class Ghre_CourseWareServices : BaseServices<Ghre_CourseWare, Ghre_CourseWareDto, InsertGhre_CourseWareInput, EditGhre_CourseWareInput>, IGhre_CourseWareServices
    {
        private readonly IBaseRepository<Ghre_CourseWare> _dal;
        private IGhre_CourseServices _ghre_CourseServices;

        public Ghre_CourseWareServices(ICaching caching, IGhre_CourseServices ghre_CourseServices, IBaseRepository<Ghre_CourseWare> dal)
        {
            this._dal = dal;
            base.BaseDal = dal;
            base._caching = caching;
            _ghre_CourseServices = ghre_CourseServices;
        }

        public override async Task<long> Add(InsertGhre_CourseWareInput entity)
        {
            if (entity.CourseIds2.Any())
            {
                entity.CourseIds = JsonConvert.SerializeObject(entity.CourseIds2);
                var courses = await _ghre_CourseServices.Query(x => entity.CourseIds2.Contains(x.Id));
                entity.CourseNames = string.Join(",", courses.Select(x => x.CourseName));
            }
            return await base.Add(entity);
        }

        public override async Task<bool> Update(long Id, EditGhre_CourseWareInput editModel)
        {
            if (editModel.CourseIds2.Any())
            {
                editModel.CourseIds = JsonConvert.SerializeObject(editModel.CourseIds2);
                var courses = await _ghre_CourseServices.Query(x => editModel.CourseIds2.Contains(x.Id));
                editModel.CourseNames = string.Join(",", courses.Select(x => x.CourseName));
            }
            return await base.Update(Id, editModel);
        }

        public override async Task<ServiceFormResult> QueryForm(QueryForm body)
        {
            var result = await base.QueryForm(body);
            string courseIds = result.result.DT_TableDataT1[0].CourseIds;
            if (!string.IsNullOrWhiteSpace(courseIds))
                result.result.DT_TableDataT1[0].CourseIds2 = JsonConvert.DeserializeObject<List<long>>(courseIds);

            else result.result.DT_TableDataT1[0].CourseIds2 = new List<long>();
            return result;

        }

        public override async Task<ServicePageResult<Ghre_CourseWareDto>> QueryFilterPage(QueryBody body)
        {
            var result = await base.QueryFilterPage(body);
            result.result.DT_TableDataT1.ForEach(x =>
            {
                if (!string.IsNullOrWhiteSpace(x.CourseIds))
                    x.CourseIds2 = JsonConvert.DeserializeObject<List<long>>(x.CourseIds);
            });

            return result;

        }
    }
}