using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using RiskControl.NewService.Entity.RCY;
using RiskControl.NewService.Extension;
using SqlSugar;

namespace RiskControl.NewService.Service
{
    /// <summary>
    /// 仁产研
    /// </summary>
    public class RcyService : DbContext
    {
        /// <summary>
        /// 景气矩阵
        /// </summary>
        /// <param name="pageIndex"></param>
        /// <param name="pageSize"></param>
        /// <param name="orderByFieldName"></param>
        /// <param name="orderByType"></param>
        /// <returns></returns>
        public async Task<Page<RcyJqjz>> GetJqjzPage(int pageIndex, int pageSize, string orderByFieldName,
            string orderByType)
        {
            var res = await RiskControlRRDb.Queryable<RcyJqjz>()
                .OrderByIF(string.IsNullOrWhiteSpace(orderByFieldName), a => a.Zml, OrderByType.Desc)
                .OrderByIF(!string.IsNullOrWhiteSpace(orderByFieldName), $"{orderByFieldName} {orderByType}")
                .ToPageAsync(pageIndex, pageSize);
            return res;
        }

        /// <summary>
        /// 景气矩阵
        /// </summary>
        /// <returns></returns>
        public async Task<List<RcyJqjz>> GetJqjzList()
        {
            var res = await RiskControlRRDb.Queryable<RcyJqjz>()
                .ToListAsync();
            return res;
        }

        /// <summary>
        /// 上市地位
        /// </summary>
        /// <param name="pageIndex"></param>
        /// <param name="pageSize"></param>
        /// <param name="orderByFieldName"></param>
        /// <param name="orderByType"></param>
        /// <returns></returns>
        public async Task<Page<RcySsdw>> GetSsdwPage(int pageIndex, int pageSize, string orderByFieldName,
            string orderByType)
        {
            var res = await RiskControlRRDb.Queryable<RcySsdw>()
                .OrderByIF(string.IsNullOrWhiteSpace(orderByFieldName), a => a.Jpettm, OrderByType.Desc)
                .OrderByIF(!string.IsNullOrWhiteSpace(orderByFieldName), $"{orderByFieldName} {orderByType}")
                .ToPageAsync(pageIndex, pageSize);
            return res;
        }

        /// <summary>
        /// 上市地位
        /// </summary>
        /// <returns></returns>
        public async Task<List<RcySsdw>> GetSsdwList()
        {
            var res = await RiskControlRRDb.Queryable<RcySsdw>()
                .ToListAsync();
            return res;
        }

        /// <summary>
        /// 公司详情
        /// </summary>
        /// <param name="pageIndex"></param>
        /// <param name="pageSize"></param>
        /// <param name="orderByFieldName"></param>
        /// <param name="orderByType"></param>
        /// <returns></returns>
        public async Task<Page<RcyGsxq>> GetGsxqPage(int pageIndex, int pageSize, string orderByFieldName,
            string orderByType)
        {
            var res = await RiskControlRRDb.Queryable<RcyGsxq>()
                .OrderByIF(string.IsNullOrWhiteSpace(orderByFieldName), a => a.Ygs, OrderByType.Desc)
                .OrderByIF(!string.IsNullOrWhiteSpace(orderByFieldName), $"{orderByFieldName} {orderByType}")
                .ToPageAsync(pageIndex, pageSize);
            return res;
        }

        /// <summary>
        /// 公司详情
        /// </summary>
        /// <returns></returns>
        public async Task<List<RcyGsxq>> GetGsxqList()
        {
            var res = await RiskControlRRDb.Queryable<RcyGsxq>()
                .ToListAsync();
            return res;
        }

        /// <summary>
        /// 产业地图
        /// </summary>
        /// <returns></returns>
        public async Task<object> GetGsxqMapData()
        {
            var res = await RiskControlRRDb.Queryable<RcyGsxq>()
                .GroupBy(a => a.Sf)
                .Select(a => new {Name = a.Sf, Value = SqlFunc.AggregateCount(a.Sf)})
                .ToListAsync();
            return res;
        }

        public async Task<Page<ChainIncomeCost>> GetChainIncomeCostPage(int pageIndex, int pageSize,
            string[] exchangeCodes)
        {
            var res = await RiskControlRRDb.Queryable<ChainIncomeCost>()
                .WhereIF(exchangeCodes.Length > 0, a => exchangeCodes.Contains(a.ExchangeCode))
                .ToPageAsync(pageIndex, pageSize);

            return res;
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="type">income,cost,grossmargin</param>
        /// <returns></returns>
        public async Task<object> GetChainIncomeCostChart(string type)
        {
            var data = await RiskControlRRDb.Queryable<ChainIncomeCost>()
                .Where(a => a.CompanyName == "总计")
                .FirstAsync();
            var props = typeof(ChainIncomeCost).GetProperties();
            var dict = new SortedDictionary<int, double>();
            foreach (var p in props.Where(a=>a.Name.ToLower().StartsWith(type.ToLower())))
            {
                var year =int.Parse(p.Name.ToLower().Replace(type.ToLower(), ""));
                var val = (double?) p.GetValue(data);
                if(val != null)
                    dict.Add(year,(double)val);
            }

            var res = new List<object>();
            var index = 0;
            foreach (var kv in dict)
            {
                var obj = new {year = kv.Key, value = kv.Value, rate = index == 0 ? (double?)null : (kv.Value - dict[kv.Key-1])/ dict[kv.Key - 1] *100};
                res.Add(obj);
                index++;
            }

            return res;
        }

    }
}