using AutoMapper;
using Model.ModelDto.LogDto;
using Model.ModelDto.SysDto;
using Model.ModelVm.SysVm;
using Newtonsoft.Json;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
using Utility;
using WMS.DAL;
using WMS.Entity.Context;
using WMS.Entity.LogEntity;
using WMS.Entity.SysEntity;
using WMS.IBLL.ILogServer;
using WMS.IBLL.ISysServer;

namespace WMS.BLL.SysServer
{
    public class InterfaceServer : IInterfaceServer
    {
        private static readonly SqlSugarScope Db = DataContext.Db;

        private readonly IOperationSysServer _operation; //操作日志
        private readonly UserManager _userManager;
        private readonly IMapper _mapper;
        public InterfaceServer(IOperationSysServer operation, IMapper mapper, UserManager userManager)
        {
            _operation = operation;
            _userManager = userManager;
            _mapper = mapper;//automapper
        }
        /// <summary>
        /// 获取接口列表
        /// </summary>
        /// <param name="model"></param>
        /// <param name="count"></param>
        /// <returns></returns>
        public async Task<SqlSugarPagedList> GetInterfaceList(InterfaceVm model)
        {
            return await Db.Queryable<SysInterface>()
                           .LeftJoin<SysUserInfor>((a, b) => a.CreateUser == b.Id)
                           .LeftJoin<SysUserInfor>((a, b, c) => a.UpdateUser == c.Id)
                           .Where(a => a.IsDel == "0")
                           .WhereIF(!string.IsNullOrEmpty(model.InterfaceNo), a => a.InterfaceNo.Contains(model.InterfaceNo))
                           .WhereIF(!string.IsNullOrEmpty(model.InterfaceName), a => a.InterfaceName.Contains(model.InterfaceName))
                           .WhereIF(!string.IsNullOrEmpty(model.Direction), a => a.Direction == model.Direction)
                           .OrderBy(a => a.Id)
                           .Select<InterfaceDto>((a, b, c) => new InterfaceDto()
                           {
                               Id = a.Id,
                               CreateUserName = b.RealName,
                               UpdateUserName = c.RealName,
                           }, true)
                           .ToPagedListAsync(model.Page, model.Limit);
        }
        /// <summary>
        /// 获取接口明细列表
        /// </summary>
        /// <param name="model"></param>
        /// <param name="count"></param>
        /// <returns></returns>
        public async Task<SqlSugarPagedList> GetInterfaceDetailList(InterfaceDetailVm model)
        {
            return await Db.Queryable<SysInterfaceDetail>()
                           .LeftJoin<SysUserInfor>((a, b) => a.CreateUser == b.Id)
                           .LeftJoin<SysUserInfor>((a, b, c) => a.UpdateUser == c.Id)
                           .Where(a => a.IsDel == "0")
                           .WhereIF(!string.IsNullOrEmpty(model.InterfaceNo), a => a.InterfaceNo == model.InterfaceNo)
                           .Select<InterfaceDetailDto>((a, b, c) => new InterfaceDetailDto()
                           {
                               Id = a.Id,
                               CreateUserName = b.RealName,
                               UpdateUserName = c.RealName,
                           }, true)
                           .ToPagedListAsync(model.Page, model.Limit);
        }

        /// <summary>
        /// 添加接口信息
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public async Task AddInterface(InterfaceVm model)
        {
            if (await Db.Queryable<SysInterface>().AnyAsync(s => s.InterfaceNo == model.InterfaceNo))
            {
                throw Oops.Bah("接口编号已存在，请勿重复添加");
            }
            SysInterface modInterface = _mapper.Map<SysInterface>(model);
            modInterface.CreateUser = _userManager.UserId;
            modInterface.CreateTime = DateTime.Now;
            await Db.Insertable<SysInterface>(modInterface).ExecuteCommandAsync();

            List<SysInterfaceDetail> listDetails = new List<SysInterfaceDetail>();
            foreach (InterfaceDetailVm detailModel in model.InterfaceDetail)
            {
                SysInterfaceDetail modDetail = _mapper.Map<SysInterfaceDetail>(detailModel);
                modDetail.CreateTime = modInterface.CreateTime;
                modDetail.CreateUser = _userManager.UserId;
                listDetails.Add(modDetail);
            }
            await Db.Insertable(listDetails).ExecuteCommandAsync();

        }

        /// <summary>
        /// 编辑接口信息
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public async Task EditInterface(InterfaceVm model)
        {
            SysInterface modInterface = _mapper.Map<SysInterface>(model);
            modInterface.UpdateUser = _userManager.UserId;
            modInterface.UpdateTime = DateTime.Now;
            await Db.Updateable(modInterface)
                .UpdateColumns(s => new { s.InterfaceName, s.Direction, s.TransmissionMode, s.Remark, s.Url, s.DataSources, s.UpdateTime, s.UpdateUser })
                .ExecuteCommandAsync();

            var listDetails = await Db.Queryable<SysInterfaceDetail>().Where(s => s.InterfaceNo == model.InterfaceNo && s.IsDel == "0").ToListAsync();
            foreach (SysInterfaceDetail dbDetailModel in listDetails)
            {
                if (!model.InterfaceDetail.Any(s => s.Id == dbDetailModel.Id))
                {
                    await Db.Updateable<SysInterfaceDetail>()
                    .SetColumns(s => s.IsDel == "1")
                    .SetColumns(s => s.UpdateTime == DateTime.Now)
                    .SetColumns(s => s.UpdateUser == _userManager.UserId)
                    .Where(s => s.Id == dbDetailModel.Id && s.IsDel == "0")
                    .ExecuteCommandAsync();
                }
            }

            // 处理修改和添加的明细
            foreach (InterfaceDetailVm detailModel in model.InterfaceDetail)
            {
                if (detailModel.Id == 0 || detailModel.Id == null)
                {
                    var modDetail = _mapper.Map<SysInterfaceDetail>(detailModel);
                    modDetail.CreateTime = DateTime.Now;
                    modDetail.CreateUser = _userManager.UserId;
                    modDetail.UpdateUser = _userManager.UserId;
                    modDetail.UpdateTime = DateTime.Now;
                    await Db.Insertable(modDetail).ExecuteCommandAsync();
                }
                else
                {
                    int rowNum = listDetails.Count(it => it.Id == detailModel.Id
                                         && it.ExtField == detailModel.ExtField
                                         && it.MapField == detailModel.MapField
                                         && it.Field == detailModel.Field
                                         && it.FieldType == detailModel.FieldType
                                         && it.DataType == detailModel.DataType
                                         && it.IsNull == detailModel.IsNull
                                         && it.Remark == detailModel.Remark
                                         && it.FieldFather == detailModel.FieldFather);
                    if (rowNum > 0)
                    {
                        continue;
                    }
                    var modDetail = _mapper.Map<SysInterfaceDetail>(detailModel);
                    modDetail.UpdateUser = _userManager.UserId;
                    modDetail.UpdateTime = DateTime.Now;
                    await Db.Updateable<SysInterfaceDetail>(modDetail)
                        .UpdateColumns(s => new { s.ExtField, s.MapField, s.Field, s.FieldFather, s.FieldType, s.DataType, s.IsNull, s.Remark, s.UpdateUser, s.UpdateTime })
                        .ExecuteCommandAsync();
                }
            }
        }

        /// <summary>
        /// 删除接口信息
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public async Task DelInterface(InterfaceVm model)
        {
            await Db.Updateable<SysInterface>()
                    .SetColumns(s => s.IsDel == "1")
                    .SetColumns(s => s.UpdateTime == DateTime.Now)
                    .SetColumns(s => s.UpdateUser == _userManager.UserId)
                    .Where(s => s.InterfaceNo == model.InterfaceNo && s.IsDel == "0")
                    .ExecuteCommandAsync();

            await Db.Updateable<SysInterfaceDetail>()
                    .SetColumns(s => s.IsDel == "1")
                    .SetColumns(s => s.UpdateTime == DateTime.Now)
                    .SetColumns(s => s.UpdateUser == _userManager.UserId)
                    .Where(s => s.InterfaceNo == model.InterfaceNo && s.IsDel == "0")
                    .ExecuteCommandAsync();
        }

        /// <summary>
        /// 删除接口明细信息
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public async Task DelInterfaceDetail(InterfaceDetailVm model)
        {
            await Db.Updateable<SysInterfaceDetail>()
                    .SetColumns(s => s.IsDel == "1")
                    .SetColumns(s => s.UpdateTime == DateTime.Now)
                    .SetColumns(s => s.UpdateUser == _userManager.UserId)
                    .Where(s => s.Id == model.Id)
                    .ExecuteCommandAsync();
        }

        //public void ceshi()
        //{
        //    string interfaceNo = "A0001";
        //    string param = "'ASN2023110200002'";
        //    RespondResult(interfaceNo, param);
        //}

        /// <summary>
        /// 回传上游系统公共方法
        /// </summary>
        /// <param name="InterfaceNo">接口编号</param>
        /// <param name="param">存储过程参数</param>
        public void RespondResult(string InterfaceNo, string param)
        {
            try
            {
                var outDto = new Dictionary<string, object>();
                string sqlString = $@"select * from SysInterface where IsDel=0 and InterfaceNo='{InterfaceNo}'";
                //接口总信息
                var interfaceModel = Db.Ado.SqlQuery<SysInterface>(sqlString).FirstOrDefault();
                if (interfaceModel == null)
                {
                    throw new Exception("未查询到接口信息");
                }
                if (string.IsNullOrEmpty(interfaceModel.DataSources))
                {
                    throw new Exception("数据来源为空");
                }
                string detailSql = $@"select * from SysInterfaceDetail where IsDel=0 and InterfaceNo='{interfaceModel.InterfaceNo}'";
                //接口明细信息
                List<SysInterfaceDetail> _detailList = Db.Ado.SqlQuery<SysInterfaceDetail>(detailSql).ToList();
                if (_detailList.Count <= 0)
                {
                    throw new Exception("未查询到接口明细信息");
                }
                //执行存储过程查询数据
                string querySql = $@"EXEC {interfaceModel.DataSources} {param}";
                var requestDataList = Db.Ado.SqlQuery<RequestData>(querySql).ToList();
                //组织请求参数
                foreach (var item in _detailList)
                {
                    if (item.DataType == "0")//表头数据
                    {
                        var fileldFatherList = _detailList.Where(it => it.FieldFather == item.ExtField).ToList();//判找到该表头下的所有行
                        if (fileldFatherList.Count > 0)//判断该表头是否有行
                        {
                            var dicDetailList = new List<Dictionary<string, object>>();
                            foreach (var item2 in requestDataList)//行数据
                            {
                                var dicDetailModel = new Dictionary<string, object>();
                                foreach (var item3 in fileldFatherList)
                                {
                                    // 使用反射获取字段值
                                    string value = GetFieldValue(item2, item3.MapField);
                                    dicDetailModel.Add(item3.ExtField, value);
                                }
                                dicDetailList.Add(dicDetailModel);
                            }
                            outDto.Add(item.ExtField, dicDetailList);
                        }
                        else
                        {
                            var requestDataModel = requestDataList.FirstOrDefault();
                            // 使用反射获取字段值
                            string value = GetFieldValue(requestDataModel, item.MapField);

                            outDto.Add(item.ExtField, value);
                        }
                    }
                }
                //请求方式，0:Http+Xml  1:Http+Xml
                if (interfaceModel.TransmissionMode == "0")
                {
                    //请求参数
                    var jsonData = Newtonsoft.Json.JsonConvert.SerializeObject(outDto);
                    //发起请求
                    var response = Utility.Tools.HttpHelper.DoPost(interfaceModel.Url, jsonData, interfaceModel.InterfaceName, interfaceModel.Remark);
                }
                else
                {

                }
            }
            catch (Exception ex)
            {

            }
        }
        /// <summary>
        /// 通过字段名获取字段值
        /// </summary>
        /// <param name="obj"></param>
        /// <param name="fieldName"></param>
        /// <returns></returns>
        public static string GetFieldValue(object obj, string fieldName)
        {
            //使用反射获取字段值
            Type type = obj.GetType();
            PropertyInfo propertyInfo = type.GetProperty(fieldName);
            if (propertyInfo != null)
            {
                return propertyInfo.GetValue(obj) == null ? "" : propertyInfo.GetValue(obj).ToString();
            }
            return null;
        }
    }
    public class RequestData
    {
        public string Field1 { get; set; }
        public string Field2 { get; set; }
        public string Field3 { get; set; }
        public string Field4 { get; set; }
        public string Field5 { get; set; }
        public string Field6 { get; set; }
        public string Field7 { get; set; }
        public string Field8 { get; set; }
        public string Field9 { get; set; }
        public string Field10 { get; set; }
        public string Field11 { get; set; }
        public string Field12 { get; set; }
        public string Field13 { get; set; }
        public string Field14 { get; set; }
        public string Field15 { get; set; }
        public string Field16 { get; set; }
        public string Field17 { get; set; }
        public string Field18 { get; set; }
        public string Field19 { get; set; }
        public string Field20 { get; set; }
    }
}