using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using wispro.sp.entity;
using wispro.sp.share;

namespace wispro.sp.api.Controllers
{
    [Route("api/[controller]/[action]")]
    [ApiController]
    [Authorize]
    public class PerformanceItemController : ControllerBase
    {
        spDbContext Context;

        public PerformanceItemController(spDbContext context)
        {
            Context = context;
        }
        public ApiSaveResponse New(PerformanceItem item)
        {
            ApiSaveResponse ret = new ApiSaveResponse();
            using (Context.Database.BeginTransaction())
            {
                try
                {

                    if (!string.IsNullOrEmpty(item.Customer.Name))
                    {
                        var temCustomer = Context.Customers.Where<Customer>(c => c.Name == item.Customer.Name).FirstOrDefault();

                        if (temCustomer == null)
                        {
                            Context.Customers.Add(item.Customer);
                            Context.SaveChanges();
                        }
                        else
                        {
                            item.Customer = temCustomer;
                        }

                        item.CustomerId = item.Customer.Id;
                    }
                    else
                    {
                        item.Customer = null;
                    }

                    List<PerformanceItem> items = Context.PerformanceItems.Where<PerformanceItem>(x =>
                        x.CaseNo == item.CaseNo && x.DoItem == item.DoItem && x.DoItem != "提出报告").ToList();

                    if (items.Count > 0)
                    {
                        ret.Success = false;
                        ret.ErrorMessage = $"案件【{item.CaseNo}】处理事项【{item.DoItem }】已存在！";
                    }
                    else
                    {
                        Context.PerformanceItems.Add(item);
                    }

                    Context.SaveChanges();

                    foreach(ItemStaff itemStaff in item.ItemStaffs)
                    {
                        itemStaff.ItemId = item.Id;

                        if(itemStaff.DoPersonId ==0 && itemStaff.DoPerson != null)
                        {
                            var temStaff = Context.Staffs.FirstOrDefault<Staff>(s => s.Name == itemStaff.DoPerson.Name);

                            if(temStaff != null)
                            {
                                itemStaff.DoPersonId = temStaff.Id;
                                itemStaff.DoPerson = null;
                            }
                            else
                            {
                                Context.Staffs.Add(itemStaff.DoPerson);
                                Context.SaveChanges();
                                itemStaff.DoPersonId = itemStaff.DoPerson.Id;
                            }
                        }
                    }

                    Context.ItemStaffs.AddRange(item.ItemStaffs);

                    Context.Database.CommitTransaction();
                }
                catch (Exception ex)
                {
                    ret.Success = false;
                    ret.ErrorMessage = ex.Message;
                    Context.Database.RollbackTransaction();
                }
            }
            

            return ret;
        }

        public ListApiResponse<PerformanceItem> Query(int pageIndex,int pageSize)
        {
            if (!User.Identity.IsAuthenticated)
            {
               
            }

            ListApiResponse<PerformanceItem> ret = new ListApiResponse<PerformanceItem>();
            var results = Context.PerformanceItems
                .Where<PerformanceItem>(s => s.ItemStaffs
                    .Where<ItemStaff>(iStaff => iStaff.DoPerson.Name == User.Identity.Name).Count() > 0 && s.Month == 7 && s.Year == 2021);

            ret.TotalCount = results.Count();

            List<PerformanceItem> retList = results
                .Include(pi=>pi.ItemStaffs).ThenInclude(iStaff=>iStaff.DoPerson)
                .Include(pi=>pi.Reviewer)
                .Include(pi=>pi.Customer)
                .OrderByDescending(o=>o.Id)
                .Skip<PerformanceItem>((pageIndex - 1) * pageSize).Take(pageSize).ToList<PerformanceItem>();

            ret.Results = retList;

            return ret;
        }

        public ListApiResponse<PerformanceItem> QueryFilter(QueryFilter queryFilter)
        {

            ListApiResponse<PerformanceItem> ret = new ListApiResponse<PerformanceItem>();
            ret.TotalCount = Context.PerformanceItems.Count<PerformanceItem>();

            List<PerformanceItem> retList = Context.PerformanceItems
                //.Where<PerformanceItem>(s => s.ItemStaffs
                //    .Where<ItemStaff>(iStaff => iStaff.DoPerson.Name == "李申").Count() > 0 && s.Month== 7 && s.Year == 2021)
                .Include(pi => pi.ItemStaffs).ThenInclude(iStaff => iStaff.DoPerson)
                .Include(pi => pi.Reviewer)
                .Include(pi => pi.Customer)
                .OrderByDescending(o => o.Id)
                .Skip<PerformanceItem>((queryFilter.pageIndex - 1) * queryFilter.pageSize).Take(queryFilter.pageSize).ToList<PerformanceItem>();

            //Context.PerformanceItems.Where<PerformanceItem>(p=>p.ItemStaffs.Where<ItemStaff>)
            ret.Results = retList;

            return ret;
        }


    }
}