初始化

啊鑫

2024-07-09 0552fcc8cb73fc3021e2915129f55a42ed3f20e5

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
#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");
        }
    }
}