using NetTaste;
using Newtonsoft.Json;
using Org.BouncyCastle.Ocsp;
using SqlSugar.Extensions;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection.Emit;
using System.Text;
using System.Threading.Tasks;
using WIDESEA_DTO.Basic;
using WIDESEA_IBasicService;
using WIDESEA_Model.Models;
using WIDESEA_Model.Models.Basic;

namespace WIDESEA_BasicService
{
    public class ErpApiService : IErpApiService
    {
        private readonly IHttpClientFactory _httpClientFactory;
        private readonly ISupplierInfoService _supplierInfoService;
        private readonly IMaterialUnitService _materialUnitService;
        private readonly IMaterielInfoService _materielInfoService;

        public ErpApiService(IHttpClientFactory httpClientFactory, ISupplierInfoService supplierInfoService, IMaterialUnitService materialUnitService, IMaterielInfoService materielInfoService)
        {
            _httpClientFactory = httpClientFactory;
            _supplierInfoService = supplierInfoService;
            _materialUnitService = materialUnitService;
            _materielInfoService = materielInfoService;
        }

        /// <summary>
        /// 获取token
        /// </summary>
        /// <returns></returns>
        public async Task<string> GetTokenAsync()
        {
            var request = new TokenRequest { appId = "BG_SYSTEM", secretKey = "7e9239c1e132462a9cf03bfa342a044aMTcxODE5MzgxODI4Mw" };
            var response = await PostAsync<TokenRequest, TokenResponse>("auth/getAccessToken", request, includeToken: false);
            var _token = response?.data?.access_token;
            return _token ?? "";

        }

        /// <summary>
        /// 获取供应商信息
        /// </summary>
        /// <param name="vendorCode"></param>
        /// <returns></returns>
        public async Task GetSuppliersAsync(string vendorCode = null)
        {
            var req = new SupplierRequest { vendorCode = vendorCode };
            var result = await PostAsync<SupplierRequest, SupplierResponse>("erp/getVendorInfo", req, includeToken: true);
            if (result != null && result.data != null && result.data.Any())
            {
                var dblists = _supplierInfoService.Repository.QueryData();
                var excepts = dblists.Select(O => O.SupplierCode).Except(result.data.Select(o => o.vendorCode));
                foreach (var except in excepts)
                {
                    var first = dblists.FirstOrDefault(o => o.SupplierCode == except);
                    if (first != null)
                    {
                        _supplierInfoService.Repository.DeleteData(first);
                    }
                }
                foreach (var item in result.data)
                {
                    var first = dblists.FirstOrDefault(o => o.SupplierCode == item.vendorCode);
                    if (first != null)
                    {
                        first.SupplierCode = item.vendorCode;
                        first.SupplierName = item.vendorName;
                        first.SupplierShortName = item.vendorShortName;
                        first.Status = item.effective.ObjToInt();
                        first.CreateDate = item.createDate.ObjToDate();
                        first.ModifyDate = item.modifyDate.ObjToDate();
                        _supplierInfoService.Repository.UpdateData(first);
                    }
                    else
                    {
                        Dt_SupplierInfo dt_SupplierInfo = new()
                        {
                            SupplierCode = item.vendorCode,
                            SupplierName = item.vendorName,
                            SupplierShortName = item.vendorShortName,
                            Status = item.effective.ObjToInt(),
                            CreateDate = item.createDate.ObjToDate(),
                            Creater = "ERP",
                            Modifier = "ERP",
                            ModifyDate = item.modifyDate.ObjToDate()
                        };
                        _supplierInfoService.Repository.AddData(dt_SupplierInfo);
                    }
                }
            }

        }

        /// <summary>
        /// 获取物料单位转换
        /// </summary>
        /// <param name="vendorCode"></param>
        /// <returns></returns>
        public async Task GetMaterialUnitAsync(string itemNo = null)
        {
            var req = new MaterialUnitRequest { itemNo = itemNo };
            var result = await PostAsync<MaterialUnitRequest, MaterialUnitResponse>("erp/getMaterialUnit", req, true);
            if (result != null && result.data != null && result.data.Any())
            {
                var dblists = _materialUnitService.Repository.QueryData();
                var excepts = dblists.Select(O => O.ItemNo).Except(result.data.Select(o => o.itemNo));
                foreach (var except in excepts)
                {
                    var first = dblists.FirstOrDefault(o => o.ItemNo == except);
                    if (first != null)
                    {
                        _materialUnitService.Repository.DeleteData(first);
                    }
                }
                foreach (var item in result.data)
                {
                    var first = dblists.FirstOrDefault(o => o.ItemNo == item.itemNo);
                    if (first != null)
                    {
                        first.ItemNo = item.itemNo;
                        first.ProductName = item.productName;
                        first.FromUom = item.fromUom;
                        first.ToUom = item.toUom;
                        first.Ratio = item.ratio.ObjToDecimal();
                        first.Creater = "ERP";
                        first.Modifier = "ERP";
                        first.CreateDate = item.createDate.ObjToDate();
                        first.ModifyDate = item.modifyDate.ObjToDate();
                        _materialUnitService.Repository.UpdateData(first);
                    }
                    else
                    {
                        Dt_MaterialUnit dt_MaterialUnit = new()
                        {
                            ItemNo = item.itemNo,
                            ProductName = item.productName,
                            FromUom = item.fromUom,
                            ToUom = item.toUom,
                            Ratio = item.ratio.ObjToDecimal(),
                            CreateDate = item.createDate.ObjToDate(),
                            Creater = "ERP",
                            Modifier = "ERP",
                            ModifyDate = item.modifyDate.ObjToDate()
                        };
                        _materialUnitService.Repository.AddData(dt_MaterialUnit);
                    }
                }
            }

        }
        public async Task GetMaterialInfoAsync(MaterialRequest materialRequest)
        {
            var first = WIDESEA_Core.Helper.AppSettings.GetValue("FirstMaterialSync").ObjToBool();
            if (first)
            {
                var _token = await GetTokenAsync();
                for (int i = 1; i < 400; i++)
                {
                    materialRequest.pageNum = i;
                    materialRequest.pageSize = 5000;
                    var result = await PostAsync<MaterialRequest, MaterialResponse>("erp/getMaterialInfo", materialRequest, _token, true);
                    if (result != null && result.data != null && result.data.Any())
                    {
                        foreach (var item in result.data)
                        {
                            Dt_MaterielInfo dt_MaterielInfo = new Dt_MaterielInfo()
                            {
                                MaterielModel = item.productModel,
                                MaterielCode = item.itemNo,
                                MaterielName = item.productName,
                                MaterielSpec = item.spec,
                                productTypeDesc = item.productTypeDesc,
                                productFamilyName = item.productFamilyName,
                                productFamilyShortName = item.productFamilyShortName,
                                plcode = item.plcode,
                                pl = item.pl,
                                drawingNo = item.drawingNo,
                                mversion = item.mversion,
                                warehouseName = item.warehouseName,
                                usageUOM = item.usageUOM,
                                purchaseUOM = item.purchaseUOM,
                                inventoryUOM = item.inventoryUOM,
                                CreateDate = item.createDate.ObjToDate(),
                                ModifyDate = item.modifyDate.ObjToDate(),
                            };
                            _materielInfoService.Repository.AddData(dt_MaterielInfo);
                        }
                    }
                }
            }
            else
            {
                materialRequest.modifyDateStart = DateTime.Now.AddDays(-1).Date.ToString("yyyy-MM-dd") + " 00:00:01";
                materialRequest.modifyDateEnd = DateTime.Now.ToString("yyyy-MM-dd HH:mm")+ ":01";
                materialRequest.pageNum = 1;
                materialRequest.pageSize = 5000;

                var result = await PostAsync<MaterialRequest, MaterialResponse>("erp/getMaterialInfo", materialRequest, true, true);
                if (result != null && result.data != null && result.data.Any())
                {
                    foreach (var item in result.data)
                    {
                        var dbfirst = _materielInfoService.Repository.QueryData(x => x.MaterielModel == item.productModel && x.MaterielCode == item.itemNo).FirstOrDefault();
                        if (dbfirst != null)
                        {
                            dbfirst.MaterielModel = item.productModel;
                            dbfirst.MaterielCode = item.itemNo;
                            dbfirst.MaterielName = item.productName;
                            dbfirst.MaterielSpec = item.spec;
                            dbfirst.productTypeDesc = item.productTypeDesc;
                            dbfirst.productFamilyName = item.productFamilyName;
                            dbfirst.productFamilyShortName = item.productFamilyShortName;
                            dbfirst.plcode = item.plcode;
                            dbfirst.pl = item.pl;
                            dbfirst.drawingNo = item.drawingNo;
                            dbfirst.mversion = item.mversion;
                            dbfirst.warehouseName = item.warehouseName;
                            dbfirst.usageUOM = item.usageUOM;
                            dbfirst.purchaseUOM = item.purchaseUOM;
                            dbfirst.inventoryUOM = item.inventoryUOM;
                            dbfirst.CreateDate = item.createDate.ObjToDate();
                            dbfirst.ModifyDate = item.modifyDate.ObjToDate();
                            _materielInfoService.Repository.UpdateData(dbfirst);
                        }
                        else
                        {
                            Dt_MaterielInfo dt_MaterielInfo = new Dt_MaterielInfo()
                            {
                                MaterielModel = item.productModel,
                                MaterielCode = item.itemNo,
                                MaterielName = item.productName,
                                MaterielSpec = item.spec,
                                productTypeDesc = item.productTypeDesc,
                                productFamilyName = item.productFamilyName,
                                productFamilyShortName = item.productFamilyShortName,
                                plcode = item.plcode,
                                pl = item.pl,
                                drawingNo = item.drawingNo,
                                mversion = item.mversion,
                                warehouseName = item.warehouseName,
                                usageUOM = item.usageUOM,
                                purchaseUOM = item.purchaseUOM,
                                inventoryUOM = item.inventoryUOM,
                                CreateDate = item.createDate.ObjToDate(),
                                ModifyDate = item.modifyDate.ObjToDate(),
                            };
                            _materielInfoService.Repository.AddData(dt_MaterielInfo);
                        }

                    }
                }
            }


        }

        private async Task<TResponse> PostAsync<TRequest, TResponse>(string url, TRequest request, string _token, bool isNullSerialize = false)
        {
            var json = "";
            if (isNullSerialize)
            {
                json = JsonConvert.SerializeObject(request, new JsonSerializerSettings
                {
                    DefaultValueHandling = DefaultValueHandling.Ignore,
                    ContractResolver = new Newtonsoft.Json.Serialization.CamelCasePropertyNamesContractResolver()
                });
            }
            else
            {
                json = JsonConvert.SerializeObject(request);
            }

            var content = new StringContent(json, Encoding.UTF8, "application/json");
            var _client = _httpClientFactory.CreateClient("ERPUrl");
            _client.DefaultRequestHeaders.Clear();


            string timestamp = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
            string base64Header = Convert.ToBase64String(Encoding.UTF8.GetBytes(timestamp));
            _client.DefaultRequestHeaders.Add("X-Custom-Header", base64Header);

            _client.DefaultRequestHeaders.Add("ACCESS-TOKEN", _token);

            _client.DefaultRequestHeaders.Add("Accept", "application/json");

            using var response = await _client.PostAsync(url, content);
            string body = await response.Content.ReadAsStringAsync();

            if (!response.IsSuccessStatusCode)
            {
                throw new HttpRequestException(body);
            }

            return JsonConvert.DeserializeObject<TResponse>(body);
        }

        private async Task<TResponse> PostAsync<TRequest, TResponse>(string url, TRequest request, bool includeToken = true, bool isNullSerialize = false)
        {

            var json = "";
            if (isNullSerialize)
            {
                json = JsonConvert.SerializeObject(request, new JsonSerializerSettings
                {
                    DefaultValueHandling = DefaultValueHandling.Ignore,
                    ContractResolver = new Newtonsoft.Json.Serialization.CamelCasePropertyNamesContractResolver()
                });
            }
            else
            {
                json = JsonConvert.SerializeObject(request );
            }

            var content = new StringContent(json, Encoding.UTF8, "application/json");
            var _client = _httpClientFactory.CreateClient("ERPUrl");
            _client.DefaultRequestHeaders.Clear();


            string timestamp = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
            string base64Header = Convert.ToBase64String(Encoding.UTF8.GetBytes(timestamp));
            _client.DefaultRequestHeaders.Add("X-Custom-Header", base64Header);

            if (includeToken)
            {
                var _token = await GetTokenAsync();
                _client.DefaultRequestHeaders.Add("ACCESS-TOKEN", _token);
            }


            _client.DefaultRequestHeaders.Add("Accept", "application/json");

            using var response = await _client.PostAsync(url, content);
            string body = await response.Content.ReadAsStringAsync();

            if (!response.IsSuccessStatusCode)
            {

                throw new HttpRequestException(body);
            }

            return JsonConvert.DeserializeObject<TResponse>(body);
        }
    }
}