using System.IO;
using System.Threading.Tasks;
using YiSha.Business.AutoJob.IService;
using YiSha.Enum;
using YiSha.IBusiness.SystemManage;
using YiSha.Util;
using YiSha.Util.Model;

namespace YiSha.Business.AutoJob.Service
{
    public class DatabasesBackupJobService : IDatabasesBackupJobService
    {
        private IDatabaseTableBLL _databaseTableBLL;
        public DatabasesBackupJobService(IDatabaseTableBLL databaseTableBLL)
        {
            _databaseTableBLL = databaseTableBLL;
        }

        public async Task<TData> Start(DBConnectTypeEnum dbConnectType)
        {
            TData obj = new TData();
            string backupPath = GlobalContext.SystemConfig.DBBackup;
            if (string.IsNullOrEmpty(backupPath))
            {
                backupPath = Path.Combine(GlobalContext.HostingEnvironment.ContentRootPath, "Database");
            }
            else
            {
                backupPath = Path.Combine(GlobalContext.HostingEnvironment.ContentRootPath, backupPath);
            }

            if (!Directory.Exists(backupPath))
            {
                Directory.CreateDirectory(backupPath);
            }

            string info = await _databaseTableBLL.DatabaseBackup(backupPath, dbConnectType);

            obj.Tag = 1;
            obj.Message = "备份路径：" + info;
            return obj;
        }
    }
}