using Bro.Common.Helper;
using Bro.M135.DBManager;
using System.Diagnostics;

namespace Bro.M141.Process
{
    public class OldDataClear
    {
        public Lazy<Manager_P_PRODUCT> managerLazy = new Lazy<Manager_P_PRODUCT>();
        public Manager_P_PRODUCT manager =>managerLazy.Value;

        static object _instanceLock = new object();
        static OldDataClear instance = null;
        public static OldDataClear Instance
        {
            get
            {
                if (instance == null)
                {
                    lock (_instanceLock)
                    {
                        if (instance == null)
                        {
                            instance = new OldDataClear();
                        }
                    }
                }
                return instance;
            }
        }

        volatile bool _isStarted = false;
        bool _isAllowDeleteOp = true;
        int _dayLimit = 0;

        public void SetAllowFlag(bool isAllowed, int dayLimit)
        {
            _isAllowDeleteOp = isAllowed;
            _dayLimit = dayLimit;
        }

        public void RunClearOldData(int dayLimit)
        {
            if (_isStarted)
                return;

            _dayLimit = dayLimit;
            _isStarted = true;

            Task.Run(() =>
            {
                while (_isStarted)
                {
                    if (_dayLimit <= 0)
                        continue;

                    if (_isAllowDeleteOp)
                    {
                        Stopwatch sw = new Stopwatch();
                        sw.Start();
                        bool isMigrationOK = manager.DeletOldData(DateTime.Now.Date.AddDays(0 - _dayLimit), 100, out int dataNums, out string msg, out bool isNoData);
                        sw.Stop();

                        if (!isMigrationOK)
                        {
                            CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Error, $"数据删除失败，{msg}");
                        }
                        else
                        {
                            if (dataNums > 0)
                            {
                                CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Assist, $"{dataNums}条产品数据删除完成，耗时{sw.ElapsedMilliseconds}ms");
                            }
                        }

                        if (isNoData)
                        {
                            _isAllowDeleteOp = false;
                        }
                    }

                    Task.Delay(3000).Wait();
                }
            });
        }
    }
}