/***********************************************************************
 *            Project: baifenBinfa
 *        ProjectName: 百分兵法管理系统                               
 *                Web: http://chuanyin.com                     
 *             Author:                                        
 *              Email:                               
 *         CreateTime: 202403/02   
 *        Description: 暂无
 ***********************************************************************/

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using CoreCms.Net.Auth.HttpContextUser;
using CoreCms.Net.Caching.AutoMate.RedisCache;
using CoreCms.Net.Configuration;
using CoreCms.Net.DTO;
using CoreCms.Net.IRepository;
using CoreCms.Net.IRepository.UnitOfWork;
using CoreCms.Net.IServices;
using CoreCms.Net.Loging;
using CoreCms.Net.Model.Entities;
using CoreCms.Net.Model.Entities.baifenbingfa.DistributionSendOder;
using CoreCms.Net.Model.ViewModels.Api;
using CoreCms.Net.Model.ViewModels.DTO;
using CoreCms.Net.Model.ViewModels.UI;
using CoreCms.Net.Utility.Helper;
using Essensoft.Paylink.Alipay.Domain;
using Flurl.Http;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using static SKIT.FlurlHttpClient.Wechat.Api.Models.CgibinExpressDeliveryOpenMessageGetDeliveryListResponse.Types;


namespace CoreCms.Net.Services
{
    /// <summary>
    /// 发货单表 接口实现
    /// </summary>
    public class CoreCmsBillDeliveryServices : BaseServices<CoreCmsBillDelivery>, ICoreCmsBillDeliveryServices
    {
        private readonly ICoreCmsBillDeliveryRepository _dal;
        private readonly ICoreCmsStoreServices _storeServices;
        private readonly ICoreCmsBillDeliveryItemServices _billDeliveryItemServices;
        private readonly ICoreCmsOrderLogServices _orderLogServices;
        private readonly ICoreCmsSettingServices _settingServices;
        private readonly IUnitOfWork _unitOfWork;
        private readonly IServiceProvider _serviceProvider;
        private readonly IRedisOperationRepository _redisOperationRepository;
        private readonly ICoreCmsDistributionRepository _coreCmsDistributionRepository;

        private readonly IHttpContextUser _user;


        public CoreCmsBillDeliveryServices(
            IUnitOfWork unitOfWork,
            IServiceProvider serviceProvider
            , ICoreCmsBillDeliveryRepository dal
            , ICoreCmsStoreServices storeServices
            , ICoreCmsBillDeliveryItemServices billDeliveryItemServices
            , ICoreCmsOrderLogServices orderLogServices
            , ICoreCmsSettingServices settingServices
            , IRedisOperationRepository redisOperationRepository,
                ICoreCmsDistributionRepository coreCmsDistributionRepository
            , IHttpContextUser user)
        {
            this._dal = dal;
            base.BaseDal = dal;
            _unitOfWork = unitOfWork;
            _serviceProvider = serviceProvider;
            _storeServices = storeServices;
            _billDeliveryItemServices = billDeliveryItemServices;
            _orderLogServices = orderLogServices;
            _settingServices = settingServices;
            _redisOperationRepository = redisOperationRepository;
            _coreCmsDistributionRepository = coreCmsDistributionRepository;
            _user = user;

        }


        /// <summary>
        /// 批量发货，可以支持多个订单合并发货，单个订单拆分发货等。
        /// </summary>
        /// <param name="orderId">英文逗号分隔的订单号</param>
        /// <param name="logiCode">物流公司编码</param>
        /// <param name="logiNo">物流单号</param>
        /// <param name="items">发货明细</param>
        /// <param name="storeId">店铺收货地址</param>
        /// <param name="shipName">收货人姓名</param>
        /// <param name="shipMobile">收货人电话</param>
        /// <param name="shipAreaId">省市区id</param>
        /// <param name="shipAddress">收货地址</param>
        /// <param name="memo">发货描述</param>
        /// <param name="deliveryCompanyId">第三方对接物流编码</param>
        /// <param name="sendDistributionID">送货供应商ID</param>
        /// <returns></returns>
        public async Task<WebApiCallBack> BatchShip(string[] orderId, string logiCode, string logiNo, Dictionary<int, int> items, int storeId = 0, string shipName = "", string shipMobile = "", int shipAreaId = 0, string shipAddress = "", string memo = "", string deliveryCompanyId = "", int? sendDistributionID = null)
        {
            using var container = _serviceProvider.CreateScope();
            var jm = new WebApiCallBack();
            if(sendDistributionID > 0)
            {
                jm.msg = "经销商发货不支持批量发货";
                return jm;
            }
            var orderService = container.ServiceProvider.GetService<ICoreCmsOrderServices>();
            var stockServices = container.ServiceProvider.GetService<ICoreCmsStockServices>();
            //获取订单详情
            var dInfoResult = await orderService.GetOrderShipInfo(orderId);
            if (!dInfoResult.status)
            {
                return dInfoResult;
            }
            var dInfo = dInfoResult.data as AdminOrderShipResult;
            var orders = dInfo.orders;

            //校验门店自提和普通订单收货地址是否填写
            if (storeId != 0)
            {
                var storeModel = await _storeServices.QueryByIdAsync(storeId);
                if (storeModel == null)
                {
                    jm.msg = GlobalErrorCodeVars.Code10000;
                    jm.data = 1000;
                    jm.code = 1000;
                    return jm;
                }
                shipName = storeModel.storeName;
                shipMobile = storeModel.mobile;
                shipAreaId = storeModel.areaId;
                shipAddress = storeModel.address;
            }
            if (string.IsNullOrEmpty(shipName) || string.IsNullOrEmpty(shipMobile) || string.IsNullOrEmpty(shipAddress) || shipAreaId == 0)
            {
                jm.msg = "收货地址信息不全";
                jm.otherData = new
                {
                    shipName,
                    shipMobile,
                    shipAddress,
                    shipAreaId
                };
                return jm;
            }
            var billDelivery = new CoreCmsBillDelivery();
            billDelivery.orderId = string.Join(",", orderId);
            billDelivery.deliveryId = CommonHelper.GetSerialNumberType((int)GlobalEnumVars.SerialNumberType.发货单编号);
            billDelivery.logiCode = logiCode;
            billDelivery.logiNo = logiNo;
            billDelivery.shipAreaId = shipAreaId;
            billDelivery.shipAddress = shipAddress;
            billDelivery.shipName = shipName;
            billDelivery.shipMobile = shipMobile;
            billDelivery.status = (int)GlobalEnumVars.BillDeliveryStatus.Already;
            billDelivery.memo = memo;
            billDelivery.createTime = DateTime.Now;
            billDelivery.thirdPartylogiCode = deliveryCompanyId;

            //设置发货明细
            var bdRel = new List<CoreCmsBillDeliveryItem>();

            //校验发货内容
            var tNum = 0;
            foreach (var item in items)
            {
                var orderItem = dInfo.items.Find(p => p.productId == item.Key);
                if (orderItem == null)
                {
                    //发货的商品不在发货明细里，肯定有问题
                    jm.msg = GlobalErrorCodeVars.Code10000;
                    return jm;
                }
                //判断总发货数量
                tNum = tNum + item.Value;

                if ((orderItem.nums - orderItem.sendNums - (orderItem.reshipNums - orderItem.reshipedNums)) < item.Value)
                {
                    jm.msg = orderItem.name + "发超了";
                    return jm;
                }

                //构建发货单明细
                var bdItem = new CoreCmsBillDeliveryItem();
                bdItem.deliveryId = billDelivery.deliveryId;
                bdItem.productId = orderItem.productId;
                bdItem.goodsId = orderItem.goodsId;
                bdItem.bn = orderItem.bn;
                bdItem.sn = orderItem.sn;
                bdItem.weight = orderItem.weight;
                bdItem.name = orderItem.name;
                bdItem.addon = !string.IsNullOrEmpty(orderItem.addon) ? orderItem.addon : "";
                bdItem.nums = item.Value;
                bdRel.Add(bdItem);
            }
            if (tNum < 1)
            {
                jm.msg = "请至少发一件商品!";
                return jm;
            }
            //事务处理开始


            //插入发货单主体表
            await _dal.InsertAsync(billDelivery);

            //插入发货单明细表
            await _billDeliveryItemServices.InsertAsync(bdRel);

            //订单更新发货状态，发送各种消息
            foreach (var order in orders)
            {
                await OrderShip(order, items, billDelivery, storeId);
            }

            var stock = new CoreCmsStock
            {
                manager = 0,
                id = billDelivery.deliveryId,
                createTime = DateTime.Now,
                type = (int)GlobalEnumVars.StockType.DeliverGoods,
                memo = "订单发货操作，发货单号：" + billDelivery.deliveryId
            };

            await stockServices.InsertAsync(stock);

            jm.status = true;
            jm.msg = "发货成功";


            return jm;
        }


        /// <summary>
        ///     发货，单个订单发货
        /// </summary>
        /// <param name="orderId">英文逗号分隔的订单号</param>
        /// <param name="logiCode">物流公司编码</param>
        /// <param name="logiNo">物流单号</param>
        /// <param name="items">发货明细</param>
        /// <param name="storeId">店铺收货地址</param>
        /// <param name="shipName">收货人姓名</param>
        /// <param name="shipMobile">收货人电话</param>
        /// <param name="shipAreaId">省市区id</param>
        /// <param name="shipAddress">收货地址</param>
        /// <param name="memo">发货描述</param>
        /// <param name="deliveryCompanyId">第三方对接物流编码</param>
        /// <param name="sendDistributionID">经销商送货ID</param>
        /// <returns></returns>
        public async Task<WebApiCallBack> Ship(string orderId, string logiCode, string logiNo, Dictionary<int, int> items, int storeId = 0, string shipName = "", string shipMobile = "", int shipAreaId = 0, string shipAddress = "", string memo = "", string deliveryCompanyId = "",int? sendDistributionID=null)
        {
            using var container = _serviceProvider.CreateScope();
            var jm = new WebApiCallBack();
            
            var orderService = container.ServiceProvider.GetService<ICoreCmsOrderServices>();
            //获取订单详情
            var dInfoResult = await orderService.GetOrderShipInfo(orderId);
            if (!dInfoResult.status)
            {
                return dInfoResult;
            }
            var dInfo = dInfoResult.data as AdminOrderShipOneResult;
            var orderInfo = dInfo.orderInfo;

            //校验门店自提和普通订单收货地址是否填写
            if (storeId != 0)
            {
                var storeModel = await _storeServices.QueryByIdAsync(storeId);
                if (storeModel == null)
                {
                    jm.msg = GlobalErrorCodeVars.Code10000;
                    jm.data = 1000;
                    jm.code = 1000;
                    return jm;
                }
                shipName = storeModel.storeName;
                shipMobile = storeModel.mobile;
                shipAreaId = storeModel.areaId;
                shipAddress = storeModel.address;
            }
            if (string.IsNullOrEmpty(shipName) || string.IsNullOrEmpty(shipMobile) || string.IsNullOrEmpty(shipAddress) || shipAreaId == 0)
            {
                jm.msg = "收货地址信息不全";
                jm.otherData = new
                {
                    shipName,
                    shipMobile,
                    shipAddress,
                    shipAreaId
                };
                return jm;
            }
            var billDelivery = new CoreCmsBillDelivery();
            billDelivery.orderId = string.Join(",", orderId);
            billDelivery.deliveryId = CommonHelper.GetSerialNumberType((int)GlobalEnumVars.SerialNumberType.发货单编号);
            billDelivery.logiCode = logiCode;
            billDelivery.logiNo = logiNo;
            billDelivery.shipAreaId = shipAreaId;
            billDelivery.shipAddress = shipAddress;
            billDelivery.shipName = shipName;
            billDelivery.shipMobile = shipMobile;
            billDelivery.status = (int)GlobalEnumVars.BillDeliveryStatus.Already;
            billDelivery.memo = memo;
            billDelivery.createTime = DateTime.Now;
            billDelivery.thirdPartylogiCode = deliveryCompanyId;
         
            if(sendDistributionID>0)
            {
              var a=  _coreCmsDistributionRepository.QueryById(sendDistributionID);
                if(a==null)
                {
                    jm.msg = "经销商不存在";
                    return jm;
                }
                billDelivery.sendDistributionUserID= a.userId;  
                billDelivery.sendDistributionID = sendDistributionID;
                billDelivery.sendDistributionAccept = sendDistributionAcceptType.NoAccted;
                var mQ = new DistributionSendOder
                {
                   
                    sendDistributionAccept = sendDistributionAcceptType.NoAccted,
                    distributionID = (int)sendDistributionID,
                    sendMangerID = _user.ID,
                    deliveryID = billDelivery.deliveryId,
                     sendTime = DateTime.Now, 
                      userID= a.userId


                };
                //记录操作记录
                await _redisOperationRepository.ListLeftPushAsync(RedisMessageQueueKey.AddDistributionSendOderMQ, JsonConvert.SerializeObject(mQ));
            }
            //设置发货明细
            var bdRel = new List<CoreCmsBillDeliveryItem>();

            //校验发货内容
            var tNum = 0;
            foreach (var item in items)
            {
                var orderItem = dInfo.items.Find(p => p.productId == item.Key);
                if (orderItem == null)
                {
                    //发货的商品不在发货明细里，肯定有问题
                    jm.msg = GlobalErrorCodeVars.Code10000;
                    return jm;
                }
                //判断总发货数量
                tNum = tNum + item.Value;

                if ((orderItem.nums - orderItem.sendNums - (orderItem.reshipNums - orderItem.reshipedNums)) < item.Value)
                {
                    jm.msg = orderItem.name + "发超了";
                    return jm;
                }

                //构建发货单明细
                var bdItem = new CoreCmsBillDeliveryItem();
                bdItem.deliveryId = billDelivery.deliveryId;
                bdItem.orderId = orderItem.orderId;
                bdItem.productId = orderItem.productId;
                bdItem.goodsId = orderItem.goodsId;
                bdItem.bn = orderItem.bn;
                bdItem.sn = orderItem.sn;
                bdItem.weight = orderItem.weight;
                bdItem.name = orderItem.name;
                bdItem.addon = !string.IsNullOrEmpty(orderItem.addon) ? orderItem.addon : "";
                bdItem.nums = orderItem.nums;
                bdRel.Add(bdItem);
            }
            if (tNum < 1)
            {
                jm.msg = "请至少发生一件商品!";
                return jm;
            }
            //事务处理开始


            //插入发货单主体表
         await _dal.InsertAsync(billDelivery);
           
       
            

            //插入发货单明细表
            await _billDeliveryItemServices.InsertAsync(bdRel);

            //订单更新发货状态，发送各种消息
            await OrderShip(orderInfo, items, billDelivery, storeId);

            jm.status = true;
            jm.msg = "发货成功";

            return jm;
        }



        /// <summary>
        /// 给订单发货
        /// </summary>
        /// <param name="orderInfo">订单信息</param>
        /// <param name="items">总的发货包裹内容</param>
        /// <param name="deliveryInfo">发货单信息</param>
        /// <param name="storeId">门店自提还是普通订单，0是普通订单，其他是门店自提</param>
        private async Task<bool> OrderShip(CoreCmsOrder orderInfo, Dictionary<int, int> items, CoreCmsBillDelivery deliveryInfo, int storeId = 0)
        {
            using var container = _serviceProvider.CreateScope();
            var orderService = container.ServiceProvider.GetService<ICoreCmsOrderServices>();
            var billLadingService = container.ServiceProvider.GetService<ICoreCmsBillLadingServices>();
            var messageCenterServices = container.ServiceProvider.GetService<ICoreCmsMessageCenterServices>();
            var logisticsServices = container.ServiceProvider.GetService<ICoreCmsLogisticsServices>();
            var stockLogServices = container.ServiceProvider.GetService<ICoreCmsStockLogServices>();
            var stockServices = container.ServiceProvider.GetService<ICoreCmsStockServices>();

            var stockLogs = new List<CoreCmsStockLog>();

            var itemList = new Dictionary<int, int>();
            foreach (var item in orderInfo.items)
            {
                if (items.ContainsKey(item.productId))
                {
                    var maxNum = item.nums - item.reshipNums - item.sendNums;
                    if (maxNum > 0) //如果此条订单明细需要发货的话
                    {
                        var sendNum = maxNum;
                        if (items[item.productId] > maxNum)
                        {
                            //足够发此条记录的话
                            itemList.Add(item.productId, maxNum);
                            items[item.productId] = items[item.productId] - maxNum;
                        }
                        else
                        {
                            //此条订单都发不满的情况下
                            itemList.Add(item.productId, items[item.productId]);
                            sendNum = items[item.productId];
                        }

                        var sLog = new CoreCmsStockLog
                        {
                            stockId = deliveryInfo.deliveryId,
                            productId = item.productId,
                            goodsId = item.goodsId,
                            nums = -sendNum,
                            sn = item.sn,
                            bn = item.bn,
                            goodsName = item.name,
                            spesDesc = item.addon,
                            createTime = DateTime.Now
                        };
                        stockLogs.Add(sLog);
                    }
                }
            }
            //如果有发货信息，就去给订单更新发货状态
            if (itemList.Keys.Count <= 0)
            {
                return false;
            }
            var res = await orderService.EditShipStatus(orderInfo.orderId, itemList);

            //如果是门店自提，生成提货单
            if (storeId != 0)
            {
                await billLadingService.AddData(orderInfo.orderId, storeId, orderInfo.shipName, orderInfo.shipMobile);
            }

            if (res.status == true)
            {
                //添加操作日志
                var log = new CoreCmsOrderLog();
                log.orderId = orderInfo.orderId;
                log.userId = orderInfo.userId;
                log.type = (int)GlobalEnumVars.OrderLogTypes.LOG_TYPE_SHIP;
                log.msg = "订单发货操作，发货单号：" + deliveryInfo.deliveryId;
                log.data = JsonConvert.SerializeObject(deliveryInfo);
                log.createTime = DateTime.Now;
                await _orderLogServices.InsertAsync(log);

                var logistics = await logisticsServices.QueryByClauseAsync(p => p.logiCode == deliveryInfo.logiCode);
                deliveryInfo.logiName = logistics != null ? logistics.logiName : deliveryInfo.logiCode;
                //添加库存出库日志

                if (stockLogs.Any())
                {
                    //var stock = new CoreCmsStock
                    //{
                    //    manager = 0,
                    //    id = deliveryInfo.deliveryId,
                    //    createTime = DateTime.Now,
                    //    type = (int)GlobalEnumVars.StockType.DeliverGoods,
                    //    memo = log.msg
                    //};
                    //await stockServices.InsertAsync(stock);
                    await stockLogServices.InsertAsync(stockLogs);
                }

                //发送消息
                await messageCenterServices.SendMessage(orderInfo.userId, GlobalEnumVars.PlatformMessageTypes.DeliveryNotice.ToString(), JObject.FromObject(deliveryInfo));
            }
            return true;
        }


        /// <summary>
        /// 物流信息查询根据快递编码和单号查询(快递100)未使用
        /// </summary>
        /// <param name="code">查询的快递公司的编码， 一律用小写字母（如：yuantong）</param>
        /// <param name="no">查询的快递单号， 单号的最大长度是32个字符</param>
        /// <returns></returns>
        public async Task<WebApiCallBack> GetLogistic(string code, string no)
        {
            var jm = new WebApiCallBack();

            //快递100分配给贵司的的公司编号, 请在企业管理后台查看
            var allConfigs = await _settingServices.GetConfigDictionaries();
            var customer = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.Kuaidi100Customer);
            //签名， 用于验证身份， 按param + key + customer 的顺序进行MD5加密（注意加密后字符串一定要转大写）， 不需要加上“+”号， 如{“com”: “yuantong”, “num”: “500306190180”, “from”: “广东省深圳市”, “to”: “北京市朝阳区”}xxxxxxxxxxxxyyyyyyyyyyy yyyyyyyyyyyyyyyyyyyyy
            var key = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.Kuaidi100Key);

            if (string.IsNullOrEmpty(customer) || string.IsNullOrEmpty(key))
            {
                jm.msg = "快递查询接口公司编码及授权key获取失败";
            }

            var param = new KuaiDi100ApiPostParam();
            param.com = code.ToLowerInvariant();
            param.num = no;
            param.phone = "";
            param.from = "";
            param.to = "";
            param.resultv2 = 1;
            var jsonParamData = JsonConvert.SerializeObject(param);

            //签名加密
            var str = jsonParamData + key + customer;
            var signStr = CommonHelper.Md5For32(str).ToUpper();
            //实时查询请求地址
            var postUrl = "http://poll.kuaidi100.com/poll/query.do";

            var postData = new
            {
                customer,
                param = jsonParamData,
                sign = signStr
            };

            var result = await postUrl.PostUrlEncodedAsync(postData).ReceiveJson<KuaiDi100ApiPostResult>();
            if (result.status == "200")
            {
                jm.status = true;
                jm.data = result;
            }
            else
            {
                jm.status = false;
                jm.msg = !string.IsNullOrEmpty(result.message) ? result.message : "暂无消息";
            }

            return jm;
        }


        /// <summary>
        /// 发货单统计7天统计
        /// </summary>
        /// <returns></returns>
        public async Task<List<StatisticsOut>> Statistics()
        {
            return await _dal.Statistics();

        }

    }
}