using Microsoft.Data.SqlClient;
using Model.ModelDto.ArchivingDto;
using Model.ModelVm.SysVm;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using WMS.DAL;
using WMS.Entity.ArchiveEntry;
using WMS.Entity.Context;
using WMS.Entity.SysEntity;
using WMS.IBLL.ILogServer;
using WMS.IBLL.ISysServer;

namespace WMS.BLL.SysServer
{
    public class ArchivingServer:DbHelper<ArchivingLog>, IArchivingServer
    {
        private static readonly SqlSugarScope Db = DataContext.Db;
        public ArchivingServer() : base(Db)
        {
        }
        private readonly IOperationSysServer _operation; //操作日志
        /// <summary>
        /// 获取数据归档操作日志
        /// </summary>
        /// <param name="page"></param>
        /// <param name="limit"></param>
        /// <param name="count"></param>
        /// <returns></returns>
        public List<ArchivingLogDto> GetArchivingLogList(int page, int limit, out int count)
        {
            try
            {
                var item = Expressionable.Create<ArchivingLog>()
                     .And(it => it.IsDel == "0")
                     .ToExpression();//注意 这一句 不能少
                var total = 0;
                var list = GetAllWhereAsync(item)
                    .LeftJoin<SysUserInfor>((it, users) => it.CreateUser == users.Id)
                    .Select((it, users) => new ArchivingLogDto()
                    {
                        Id = it.Id,
                        Status = it.Status,
                        Demo = it.Demo,
                        CreateTime = it.CreateTime.ToString("yyyy-MM-dd HH:mm:ss"),
                        CreateUserName = users.RealName,
                    })
                    .OrderByDescending(it => it.CreateTime)
                    .ToOffsetPage(page, limit, ref total);

                count = total;
                return list.OrderByDescending(m => m.CreateTime).ToList();
            }
            catch (Exception e)
            {
                throw new Exception(e.Message);
            }
        }
        /// <summary>
        /// 数据归档
        /// </summary>
        /// <param name="TimeStr"></param>
        /// <param name="userId"></param>
        public void DataArchive(string TimeStr,int userId)
        {
            try
            {
                if (string.IsNullOrEmpty(TimeStr))
                {
                    throw new Exception("请选择30天前日期进行操作");
                }
                if (Convert.ToDateTime(TimeStr) > DateTime.Now.AddDays(-30))
                {
                    throw new Exception("请选择30天前日期进行操作");
                }
                string insertSql = $@"EXEC DataArchiving '{TimeStr}';";
                //执行数据归档存储过程-插入
                 Db.Ado.SqlQuery<int>(insertSql).FirstOrDefault();

                string deleteSql = $@"EXEC DataArchivingDelete;";
                //执行数据归档存储过程-删除
                Db.Ado.SqlQuery<int>(deleteSql).FirstOrDefault();

                ArchivingLog log = new ArchivingLog();
                log.Status = "0";
                log.Demo = $"成功进行了数据归档操作";
                log.CreateUser = userId;
                //插入归档日志
                Db.Insertable(log).ExecuteCommand();
                //记录操作日志
                _operation.InsertOperation("系统设置", "数据归档", "", "处理", $"将{TimeStr}之前的数据进行数据归档", userId);
            }
            catch (Exception e)
            {
                ArchivingLog log = new ArchivingLog();
                log.Status = "1";
                log.Demo = $"归档数据操作失败：{e.Message}";
                log.CreateUser = userId;
                //插入归档日志
                Db.Insertable(log).ExecuteCommand();
                throw new Exception(e.Message);
            }
        }
    }
}