上传修改

Provider/SqlSugarConfig.cs

@@ -10,26 +10,44 @@ namespace Hopetry.Provider
 {
     public class SqlSugarConfig
     {
-        public static SqlSugarClient GetSqlSugarScope()
+        //public static SqlSugarClient GetSqlSugarScope()
+        //{
+        //    return new SqlSugarClient(new ConnectionConfig()
+        //    {
+        //        ConnectionString = @"DataSource=minio.db;Journal Mode=WAL;", // 数据库路径
+        //        DbType = DbType.Sqlite, // 数据库类型
+        //        IsAutoCloseConnection = true, // 自动释放
+        //        InitKeyType = InitKeyType.Attribute // 从实体特性中读取主键信息
+        //    },
+        //    db =>
+        //    {
+        //        // 配置AOP
+        //        db.Aop.OnLogExecuting = (sql, pars) =>
+        //        {
+        //            //Console.WriteLine(sql); // 输出SQL
+        //            Console.WriteLine(UtilMethods.GetSqlString(DbType.SqlServer, sql, pars));
+
+        //        };
+        //    });
+
+        //}
+
+        public static SqlSugarScope GetSqlSugarScope()
         {
-            return new SqlSugarClient(new ConnectionConfig()
+            return new SqlSugarScope(new ConnectionConfig()
             {
-                ConnectionString = @"DataSource=minio.db;Journal Mode=WAL;", // 数据库路径
+                ConnectionString = @"DataSource=minio.db;Journal Mode=WAL;Pooling=true;Max Pool Size=100;",
-                DbType = DbType.Sqlite, // 数据库类型
+                DbType = DbType.Sqlite,
-                IsAutoCloseConnection = true, // 自动释放
+                IsAutoCloseConnection = true,
-                InitKeyType = InitKeyType.Attribute // 从实体特性中读取主键信息
+                InitKeyType = InitKeyType.Attribute
             },
             db =>
             {
-                // 配置AOP
                 db.Aop.OnLogExecuting = (sql, pars) =>
                 {
-                    //Console.WriteLine(sql); // 输出SQL
                     Console.WriteLine(UtilMethods.GetSqlString(DbType.SqlServer, sql, pars));
-
                 };
             });
-
         }
 
     }

Services/FileUploadService.cs

@@ -12,11 +12,13 @@ namespace Hopetry.Services
 {
     public class FileUploadService
     {
-        private readonly SqlSugarClient _db;
+        private static readonly SqlSugarScope _db = SqlSugarConfig.GetSqlSugarScope();
+        private static readonly object _dbLock = new object();
+
 
         public FileUploadService()
         {
-            _db = SqlSugarConfig.GetSqlSugarScope();
+            //_db = SqlSugarConfig.GetSqlSugarScope();
         }
 
         // 示例：查询所有文件信息
@@ -40,10 +42,13 @@ namespace Hopetry.Services
         // 示例：更新文件信息(上传完成更新)
         public bool UpdateFileComplete(string id,bool flag)
         {
-            return _db.Updateable<FUpload>()
+            lock (_dbLock)
-                .SetColumns(r=> new FUpload { IsComplete = flag, CompleteTime=DateTime.Now })
+            {
-                .Where(r=>r.Id==id)
+                return _db.Updateable<FUpload>()
+                .SetColumns(r => new FUpload { IsComplete = flag, CompleteTime = DateTime.Now })
+                .Where(r => r.Id == id)
                 .ExecuteCommand() > 0;
+            }
         }
 
         // 示例：删除文件信息

ViewModel/Send/SendViewModel.cs

@@ -690,13 +690,6 @@ namespace HeBianGu.App.Disk
                     ut.Value3 = $"上传失败";
                     _uploadService.UpdateFileComplete(ut.Value4.ToString(), false);
                 }                           
-                
-                if (uploadTask.IsFaulted)
-                {
-                    ut.Value3 = $"上传失败";
-                    _uploadService.UpdateFileComplete(ut.Value4.ToString(), false);
-                    throw uploadTask.Exception;    
-                }                  
             }
             catch (Exception ex)
             {

global.json

@@ -5,10 +5,17 @@
   //  "SecretKey": "z92lrsD0uNdkYM5OPgnTrAQuVsLPIDXfIskTAGp8",
   //  "BucketName": "drone"
   //}
-    "Minio": {
+  //"Minio": {
-      "Endpoint": "box.wisestcity.com:9106",
+  //  "Endpoint": "box.wisestcity.com:9106",
-      "AccessKey": "V5QWBmTY3YNTiBDmLTjK",
+  //  "AccessKey": "V5QWBmTY3YNTiBDmLTjK",
-      "SecretKey": "z92lrsD0uNdkYM5OPgnTrAQuVsLPIDXfIskTAGp8",
+  //  "SecretKey": "z92lrsD0uNdkYM5OPgnTrAQuVsLPIDXfIskTAGp8",
-      "BucketName": "drone"
+  //  "BucketName": "drone"
-    }
+  //}
+
+  "Minio": {
+    "Endpoint": "192.168.10.163:9016",
+    "AccessKey": "minioadmin",
+    "SecretKey": "minioadmin",
+    "BucketName": "demo"
+  }
 }