调整连接逻辑

Ys.Scada.Backend/Controllers/DataSourceController.cs

@@ -183,6 +183,8 @@ namespace Ys.Scada.Backend.Controllers
                 throw new CustomException("数据不存在");
             if (dataSource.Status == 1)
                 return OK();
+
+            await _manager.TestConnect(dataSource);
             await _manager.Create(dataSource);
             await _fsql.Update<DataSource>(dataSource.Id)
                 .Set(o => o.Status, 1)

Ys.Scada.Manager/DataSourceManager.cs

@@ -80,14 +80,14 @@ namespace Ys.Scada.Manager
             Remove(key);
             return Task.CompletedTask;
         }
-        public Task Create(DataSource dataSource)
+        public  Task Create(DataSource dataSource)
         {
             switch (dataSource.Type.ToLower())
             {
                 case "rabbitmq":
                     {
                         var cts = new CancellationTokenSource();
-                        _ = Task.Factory.StartNew(() =>
+                        _  =  Task.Factory.StartNew(() =>
                         {
                             try
                             {