using CoreCms.Net.Configuration;
using CoreCms.Net.IRepository.UnitOfWork;
using CoreCms.Net.IServices;
using CoreCms.Net.Repository.UnitOfWork;
using CoreCms.Net.Utility.Extensions;
using EC_SeckillInfo;
using Essensoft.Paylink.Alipay.Domain;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace CoreCms.Net.Task
{
    /// <summary>
    /// 自动关闭CY配送单，防止定位信息无效增长
    /// </summary>
    public class AutoCloseCYPeiSongJobs
    {

        private readonly ISqlSugarClient _CyDbClient;


        public AutoCloseCYPeiSongJobs(IUnitOfWork unitOfWork)
        {
            _CyDbClient = unitOfWork.GetDbClient().GetConnection(AppSettingsConstVars.CYDbDbID);
        }
        public async System.Threading.Tasks.Task Execute()
        {
          var ListData=  await  _CyDbClient.Queryable<CoreDeliverOrder>().Where(x => x.OrderState == CoreDeliverOrderType.Start).ToListAsync();

            await _CyDbClient.AsTenant().BeginTranAsync();
            try
            {
                foreach (var item in ListData)
                {
                  if(  item.StartTime.Value.AddDays(AppSettingsConstVars.CyDeliverOverTime.ToInt32OrDefault(5))<DateTime.Now)
                    {
                        item.OverTime= DateTime.Now;
                        item.OrderState = CoreDeliverOrderType.OverTime;
                        item.UpDataBy = "定时任务";
                        item.UpdataTime = DateTime.Now;
                        item.Remarke = "系统超时完结处理";
                      await   _CyDbClient.Updateable(item).ExecuteCommandAsync();
                    }
                }
                await _CyDbClient.AsTenant().CommitTranAsync();
            }
            catch (Exception)
            {
                await _CyDbClient.AsTenant().RollbackTranAsync();
                throw;
            }
        

        }
    }
}