using CoreCms.Net.Configuration;
using CoreCms.Net.DTO;
using CoreCms.Net.IRepository.UnitOfWork;
using CoreCms.Net.IServices;
using CoreCms.Net.Loging;
using CoreCms.Net.Model.Entities.baifenbingfa.DistributionSendOder;
using InitQ.Abstractions;
using InitQ.Attributes;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace CoreCms.Net.RedisMQ
{
    /// <summary>
    ///  供应商配送订单分配记录
    /// </summary>
    public class DistributionSendOderMQ: IRedisSubscribe
    {
        private readonly IUnitOfWork _unitOfWork;
        public DistributionSendOderMQ(IUnitOfWork unitOfWork)
        {
            _unitOfWork= unitOfWork;

        }

        /// <summary>
        /// 增加一个记录
        /// </summary>
        /// <param name="message"></param>
        [Subscribe(RedisMessageQueueKey.AddDistributionSendOderMQ)]
        public async void AddDistributionSendOder(string message)
        {
            var Param = JsonConvert.DeserializeObject<DistributionSendOder>(message);
            if(Param == null) {

                NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.RedisMessageQueue, "AddDistributionSendOder 增加一个记录 处理失败", $"转换模型失败===》 {message}");
                return;
            }
            Param.createTime = DateTime.Now;
            Param.createBy = "系统队列";
           
            await _unitOfWork.GetDbClient().Insertable(Param).ExecuteCommandAsync();

        }

        /// <summary>
        /// 修改状态
        /// </summary>
        /// <param name="message"></param>
        [Subscribe(RedisMessageQueueKey.ActiveDistributionSendOderMQ)]
        public async void ActiveDistributionSendOder(string message)
        {
            var Param = JsonConvert.DeserializeObject<ActiveDistributionSendOderMQ>(message);
            if (Param == null)
            {

                NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.RedisMessageQueue, "ActiveDistributionSendOder 修改状态 处理失败", $"转换模型失败===》 {message}");
                return;
            }

          var oder=await   _unitOfWork.GetDbClient().Queryable<DistributionSendOder>().Where(x => x.deliveryID == Param.deliveryID && x.userID == Param.userID).FirstAsync();
            oder.upDataTime = DateTime.Now;
            oder.upDataBy = "ActiveDistributionSendOder 队列";
            oder.description = Param.Dec;
            oder.sendDistributionAccept= Param.SendOderActive;
         
            await _unitOfWork.GetDbClient().Updateable(Param).ExecuteCommandAsync();

        }


    }
}