using JiepeiWMS.IServices;
using JiepeiWMS.Model.Models;
using JiepeiWMS.Services.BASE;
using JiepeiWMS.IRepository.Base;
using System.Threading.Tasks;
using JiepeiWMS.IRepository.UnitOfWork;
using JiepeiWMS.Common;
using JiepeiWMS.Common.HttpRestSharp;
using JiepeiWMS.Model.BllModels;
using System;
using JiepeiWMS.Extends;
using System.Linq;

namespace JiepeiWMS.Services
{
    public class WMSupplierServices : BaseServices<WMSupplier>, IWMSupplierServices
    {
        private readonly IBaseRepository<WMSupplier> _dal;
        private readonly IBaseRepository<WMSupplier_Type> _daltype;
        private readonly IUnitOfWork _DB;
        public WMSupplierServices(IBaseRepository<WMSupplier> dal, IBaseRepository<WMSupplier_Type> daltype, IUnitOfWork DB)
        {
            this._dal = dal;
            this._daltype = daltype;
            base.BaseDal = dal;
            _DB = DB;

        }
        /// <summary>
        /// 供应商添加
        /// </summary>
        /// <param name="Model"></param>
        /// <param name="UserId"></param>
        /// <returns></returns>
        public async Task<string> AddSupplierInfo(WMSupplier Model, int UserId)
        {
            _DB.BeginTran();
            try
            {
                if (Model == null)
                {
                    throw new Exception("模型为空，无法添加数据！");
                }

                //同步到OA系统
                var apioahost = Appsettings.app("AppSettings", "ApiOAHost");
                var result = HttpHelper.PostApi<ApiFinanceResult>(apioahost + "/api/Supplier/SaveOrUpdateSupplier", new
                {
                    appsecret = "kw3j5k32ur38rnerkKJHk83",
                    timestamp = DateTime.Now._ToTimestamp(),
                    SupName = Model.Name,
                    SupShortName = Model.ShortName,
                    OrgCode = Model.UnifiedCode,
                    SupCharge = Model.LegalRepresentative,
                    SupPhone = Model.Phone,
                    SupEmail = Model.PostalCode,
                    SupAddress = Model.Address,
                    SupTypeId = Model.ArrayType
                });
                if (result == null || result.Code != 1)
                {
                    _DB.RollbackTran();
                    return result == null || string.IsNullOrEmpty(result.Message) ? "请求OA供应商接口失败" : result.Message;
                }
                //返回值OA的供应商id
                Model.OASupplierId = Convert.ToInt32(result.Data.OaSupId);
                Model.UnifiedCode = result.Data.OaSupCode;
                var Id = await _dal.Add(Model);
                //循环往供应商类型中间表插入数据
                for (int i = 0, c = Model.ArrayType.Length; i < c; i++)
                {
                    if (Id > 0)
                    {
                        var WMSupplierTypeId = Model.ArrayType[i];
                        WMSupplier_Type wt = new WMSupplier_Type();
                        wt.WMSupplierId = Id;
                        wt.WMSupplierTypeId = WMSupplierTypeId;
                        wt.IsDeleted = false;
                        var TypeId = await _daltype.Add(wt);
                    }

                }
                _DB.CommitTran();

            }
            catch (Exception ex)
            {

                _DB.RollbackTran();
                return ex.ToString();
            }

            return string.Empty;
        }


        /// <summary>
        /// 更新供应商OASupplierId
        /// </summary>
        /// <param name="Model">模型</param>
        /// <param name="UserId">操作人id</param>
        /// <returns></returns>
        public async Task<string> EditSupplierInfo()
        {
            try
            {
                var SupplierIdList = (await _daltype.Query()).Select(x => x.WMSupplierId).Distinct();
                var Listmodel = await BaseDal.Query(w => SupplierIdList.Contains(w.Id));
                //var Listmodel = await BaseDal.Query(w => w.OASupplierId == 0);
                foreach (var item in Listmodel)
                {
                    //将分类id转为数组
                    var supid = (await _daltype.Query(d => d.WMSupplierId == item.Id)).Select(d => d.Id.ToString()).ToArray();
                    //同步到OA系统
                    var apioahost = Appsettings.app("AppSettings", "ApiOAHost");
                    var result = HttpHelper.PostApi<ApiFinanceResult>(apioahost + "/api/Supplier/SaveOrUpdateSupplier", new
                    {
                        appsecret = "kw3j5k32ur38rnerkKJHk83",
                        timestamp = DateTime.Now._ToTimestamp(),
                        OaSupId = item.OASupplierId,
                        SupName = item.Name,
                        SupShortName = item.ShortName,
                        OrgCode = item.UnifiedCode,
                        SupCharge = item.LegalRepresentative,
                        SupPhone = item.Phone,
                        SupEmail = item.PostalCode,
                        SupAddress = item.Address,
                        SupTypeId = supid,
                    });
                    if (result == null || result.Code != 1)
                    {
                        throw new Exception("请求OA供应商接口失败，result值：" + result + ";");
                    }
                    //返回值OA的参数并赋值
                    item.OASupplierId = Convert.ToInt32(result.Data.OaSupId);
                    item.UnifiedCode = !string.IsNullOrWhiteSpace(result.Data.OaSupCode) ? result.Data.OaSupCode : item.UnifiedCode;
                    item.Name = !string.IsNullOrWhiteSpace(result.Data.OaSupName) ? result.Data.OaSupName : item.Name;
                    var OAId = BaseDal.ExecuteSqlCommand(@"update dbo.WMSupplier set OASupplierId=" + item.OASupplierId + ",UnifiedCode='" + item.UnifiedCode + "',Name='" + item.Name + "' where Id =" + item.Id + "");
                }
            }
            catch (Exception ex)
            {
                _DB.RollbackTran();
                return ex.ToString();
            }
            return string.Empty;
        }
    }
}