#region

using System;
using System.Collections.Generic;
using System.Data.Common;
using CSFramework.DB;
using CSFrameworkV5.Common;
using CSFrameworkV5.Models.DbEntity;

#endregion

namespace CSFrameworkV5.DataAccess
{
    public class dalFileUpload
    {
        public byte[] GetUpgrader(string upgraderName, string serverVer)
        {
            upgraderName = Globals.RemoveInjection(upgraderName);
            serverVer = Globals.RemoveInjection(serverVer);

            var p1 =
                DatabaseProvider.SystemDatabase.CreateParameter("UpgraderName",
                    upgraderName);
            var p2 =
                DatabaseProvider.SystemDatabase.CreateParameter("VersionNo",
                    serverVer);
            var list = new List<DbParameter>();
            list.Add(p1);
            list.Add(p2);

            var dt = DatabaseProvider.SystemDatabase.GetTop(1,
                "sys_UpgraderVersion", "FileBody", list,
                "UploadTime DESC");
            if (dt != null && dt.Rows.Count > 0)
                return (byte[])dt.Rows[0]["FileBody"];

            return null;
        }

        internal int GetUpgraderPackages(string currentVersionID)
        {
            var p = DatabaseProvider.SystemDatabase.ParamSymboName;
            var sql =
                $"SELECT COUNT(1) FROM sys_PackageTable WHERE VersionNo>{p}VersionNo";
            var cmd = DatabaseProvider.SystemDatabase.CreateCommand(sql);
            cmd.AddParam("VersionNo", currentVersionID);
            var o = DatabaseProvider.SystemDatabase.ExecuteScalar(cmd.Command);
            return ConvertEx.ToInt(o);
        }

        public string GetUpgraderVersion(string upgraderName)
        {
            upgraderName = Globals.RemoveInjection(upgraderName);

            var p1 =
                DatabaseProvider.SystemDatabase.CreateParameter("UpgraderName",
                    upgraderName);
            var list = new List<DbParameter>();
            list.Add(p1);

            var dt = DatabaseProvider.SystemDatabase.GetTop(1,
                "sys_UpgraderVersion", "VersionNo", list,
                "UploadTime DESC");
            if (dt != null && dt.Rows.Count > 0)
                return ConvertEx.ToString(dt.Rows[0]["VersionNo"]);

            return "";
        }

        public void UploadUpgrader(string upgraderName, byte[] body,
            string version, DateTime uploadTime, string user)
        {
            var m = new sys_UpgraderVersion
            {
                UpgraderName = upgraderName,
                FileBody = body,
                UploadTime = uploadTime,
                UploadUser = user,
                VersionNo = version
            };

            var update = new DbDataUpdate(DatabaseProvider.SystemDatabase);
            update.AddObject(m, "isid");
        }
    }
}