插件锁

src/Shentun.ColumnReferencePlugIns/PlugInsBase.cs

@@ -128,20 +128,20 @@ namespace Shentun.Peis.PlugIns
                 throw new ArgumentException("数据连接设置中的DbType不能为空");
             }
             InterfaceDbType = InterfaceDbType.ToLower();
-            Logger.LogInformation("数据库类型:" + InterfaceDbType);
+            //Logger.LogInformation("数据库类型:" + InterfaceDbType);
             if (InterfaceDbType == "sqlserver")
             {
-                Logger.LogInformation("调用sqlserver:" + InterfaceDbType);
+                //Logger.LogInformation("调用sqlserver:" + InterfaceDbType);
                 conn = new SqlConnection(InterfaceConnctionStr);
             }
             else if (InterfaceDbType == "postgres")
             {
-                Logger.LogInformation("调用postgres:" + InterfaceDbType);
+                //Logger.LogInformation("调用postgres:" + InterfaceDbType);
                 conn = new NpgsqlConnection(InterfaceConnctionStr);
             }
             else if (InterfaceDbType == "oracle")
             {
-                Logger.LogInformation("调用oracle:" + InterfaceDbType);
+                //Logger.LogInformation("调用oracle:" + InterfaceDbType);
                 conn = new OracleConnection(InterfaceConnctionStr);
             }
             else

src/Shentun.Peis.HttpApi.Host/Schedulers/ChargeRequestInterfaceQueryWorker.cs

@@ -28,8 +28,8 @@ namespace Shentun.Peis.Schedulers
         public virtual void DoWork(Guid interfaceId)
         {
             if (_isRunning) return;
-            lock (lockObject)
-            {
+            //lock (lockObject)
+            //{
                 _isRunning = true;
                 try
                 {
@@ -78,7 +78,7 @@ namespace Shentun.Peis.Schedulers
                 }
                 _isRunning = false;
                 return;
-            }
+            //}
         }
         public void DoWork()
         {

src/Shentun.Peis.HttpApi.Host/Schedulers/ImportLisResultInterfaceWorker.cs

@@ -26,8 +26,8 @@ namespace Shentun.Peis.Schedulers
         public virtual void DoWork(Guid interfaceId)
         {
             if (_isRunning) return;
-            lock (lockObject)
-            {
+            //lock (lockObject)
+            //{
                 _isRunning = true;
                 try
                 {
@@ -76,7 +76,7 @@ namespace Shentun.Peis.Schedulers
                 }
                 _isRunning = false;
                 return;
-            }
+            //}
         }
         public void DoWork()
         {

src/Shentun.Peis.HttpApi.Host/Schedulers/ImportPacsResultInterfaceWorker.cs

@@ -26,8 +26,8 @@ namespace Shentun.Peis.Schedulers
         public virtual void DoWork(Guid interfaceId)
         {
             if (_isRunning) return;
-            lock (lockObject)
-            {
+            //lock (lockObject)
+            //{
                 _isRunning = true;
                 try
                 {
@@ -76,7 +76,7 @@ namespace Shentun.Peis.Schedulers
                 }
                 _isRunning = false;
                 return;
-            }
+            //}
         }
 
         public void DoWork()

src/Shentun.Peis.HttpApi.Host/Schedulers/ImportPatientRegisterInterfaceWorker.cs

@@ -22,8 +22,8 @@ namespace Shentun.Peis.Schedulers
         public virtual void DoWork(Guid interfaceId)
         {
             if (_isRunning) return;
-            lock (lockObject)
-            {
+            //lock (lockObject)
+            //{
                 _isRunning = true;
                 try
                 {
@@ -71,7 +71,7 @@ namespace Shentun.Peis.Schedulers
                 }
                 _isRunning = false;
                 return;
-            }
+            //}
         }
         public void DoWork()
         {

test/Shentun.Peis.Application.Tests/ImportLisResultAppServiceTest.cs

@@ -77,7 +77,7 @@ namespace Shentun.Peis
             {
                 await _appService.ImportResultByPatientRegisterIdAsync(new PatientRegisterIdInputDto()
                 {
-                    PatientRegisterId = new Guid("3a128196-ec34-aa17-0a04-b4bb6bafc752")
+                    PatientRegisterId = new Guid("3a127c60-bf8f-e6d9-9db0-817d217e0ff1")
                 });
                 await unitOfWork.CompleteAsync();
             }