接口修改

be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.EosAgent/EosAgentModule.cs

@@ -166,7 +166,7 @@ public class EosAgentModule : AbpModule
     {
 
         context.AddBackgroundWorkerAsync<EosIncomingBackgroundWorker>();
-        //context.AddBackgroundWorkerAsync<EosOutgoingBackgroundWorker>();
+        context.AddBackgroundWorkerAsync<EosOutgoingBackgroundWorker>();
     }
 
 }

be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.EosAgent/Incoming/EosIncomingBackgroundWorker.cs

@@ -45,6 +45,11 @@ public class EosIncomingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase
             if (!confitem.Active)
             {
                 Logger.LogInformation($"{Incoming} 已关闭没有执行!");
+                if (confitem.Status == 0)
+                {
+                  await configManager.UpsertStatusAsync("EOS-IN").ConfigureAwait(false);
+                    Logger.LogInformation($"{Incoming} 运行已结束，更新接口运行状态!");
+                }
                 return;
             }
         }

be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.EosAgent/Outgoing/EosOutgoingBackgroundWorker.cs

@@ -46,6 +46,11 @@ public class EosOutgoingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase
             if (!confitem.Active)
             {
                 Logger.LogInformation($"{Outgoing} 已关闭没有执行!");
+                if (confitem.Status == 0)
+                {
+                    await configManager.UpsertStatusAsync("EOS-OUT").ConfigureAwait(false);
+                    Logger.LogInformation($"{Outgoing} 运行已结束，更新接口运行状态!");
+                }
                 return;
             }
         }

be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.InjectionMoldingTaskAgent/Incoming/InjectionMoldingTaskIncomingBackgroundWorker.cs

@@ -55,6 +55,11 @@ public class InjectionMoldingTaskIncomingBackgroundWorker : AsyncPeriodicBackgro
             if (!confitem.Active)
             {
                 Logger.LogInformation($"{Incoming} 已关闭没有执行!");
+                if (confitem.Status == 0)
+                {
+                    await configManager.UpsertStatusAsync("SJ-IN").ConfigureAwait(false);
+                    Logger.LogInformation($"{Incoming} 运行已结束，更新接口运行状态!");
+                }
                 return;
             }
         }

be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.MesAgent/Incoming/MesIncomingBackgroundWorker.cs

@@ -49,6 +49,11 @@ public class MesIncomingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase
             if (!confitem.Active)
             {
                 Logger.LogInformation($"{Incoming} 已关闭没有执行!");
+                if (confitem.Status == 0)
+                {
+                    await configManager.UpsertStatusAsync("MES-IN").ConfigureAwait(false);
+                    Logger.LogInformation($"{Incoming} 运行已结束，更新接口运行状态!");
+                }
                 return;
             }
         }

be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.MesAgent/MesAgentModule.cs

@@ -161,7 +161,7 @@ public class MesAgentModule : AbpModule
     {
 
         context.AddBackgroundWorkerAsync<MesIncomingBackgroundWorker>();
-        context.AddBackgroundWorkerAsync<MesOutgoingBackgroundWorker>();
+        //context.AddBackgroundWorkerAsync<MesOutgoingBackgroundWorker>();
     }
 }
 

be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.MesAgent/Outgoing/MesOutgoingBackgroundWorker.cs

@@ -47,7 +47,12 @@ public class MesOutgoingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase
             if (!confitem.Active)
             {
                 Logger.LogInformation($"{Outgoing} 已关闭没有执行!");
-                return;
+                if (confitem.Status == 0)
+                {
+                    await configManager.UpsertStatusAsync("MES-OUT").ConfigureAwait(false);
+                    Logger.LogInformation($"{Outgoing} 运行已结束，更新接口运行状态!");
+                    return;
+                }
             }
         }
 

be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.TyrpAgent/Incoming/TyrpIncomingBackgroundWorker.cs

@@ -51,6 +51,11 @@ public class TyrpIncomingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase
             if (!confitem.Active)
             {
                 Logger.LogInformation($"{Incoming} 已关闭没有执行!");
+                if (confitem.Status == 0)
+                {
+                    await configManager.UpsertStatusAsync("TYRP-IN").ConfigureAwait(false);
+                    Logger.LogInformation($"{Incoming} 运行已结束，更新接口运行状态!");
+                }
                 return;
             }
         }

be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.TyrpAgent/Outgoing/TyrpOutgoingBackgroundWorker.cs

@@ -49,6 +49,11 @@ public class TyrpOutgoingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase
             if (!confitem.Active)
             {
                 Logger.LogInformation($"{Outgoing} 已关闭没有执行!");
+                if (confitem.Status == 0)
+                {
+                    await configManager.UpsertStatusAsync("TYRP-OUT").ConfigureAwait(false);
+                    Logger.LogInformation($"{Outgoing} 运行已结束，更新接口运行状态!");
+                }
                 return;
             }
         }

be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/AgentModule.cs

@@ -150,6 +150,6 @@ public class AgentModule : AbpModule
              ApplicationInitializationContext context)
     {
         context.AddBackgroundWorkerAsync<IncomingToWmsWorker>();
-       // context.AddBackgroundWorkerAsync<OutgoingFromWmsWorker>();
+        context.AddBackgroundWorkerAsync<OutgoingFromWmsWorker>();
     }
 }

be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/IncomingToWmsWorker.cs

@@ -65,6 +65,11 @@ public class IncomingToWmsWorker : AsyncPeriodicBackgroundWorkerBase
             if (!confitem.Active)
             {
                 Logger.LogInformation("Wms接收接口已关闭!");
+                if (confitem.Status == 0)
+                {
+                    await configManager.UpsertStatusAsync("WMS-IN").ConfigureAwait(false);
+                    Logger.LogInformation($"Wms接收接口运行已结束，更新接口运行状态!");
+                }
                 return;
             }
         }

be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/OutgoingFromWmsWorker.cs

@@ -45,6 +45,11 @@ public class OutgoingFromWmsWorker : AsyncPeriodicBackgroundWorkerBase
             if (!confitem.Active)
             {
                 Logger.LogInformation("Wms传出接口已关闭!");
+                if (confitem.Status == 0)
+                {
+                    await configManager.UpsertStatusAsync("WMS-OUT").ConfigureAwait(false);
+                    Logger.LogInformation($"Wms传出接口运行已结束，更新接口运行状态!");
+                }
                 return;
             }
         }

be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Domain/InterfaceConfig/IInterfaceConfigManager.cs

@@ -4,4 +4,5 @@ namespace Win_in.Sfs.Wms.DataExchange.Domain;
 public interface IInterfaceConfigManager
 {
     Task<InterfaceConfig> GetInterfaceConfig(string code);
+    Task UpsertStatusAsync(string itemcode);
 }

be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Domain/InterfaceConfig/IInterfaceConfigRepository.cs

@@ -5,4 +5,5 @@ namespace Win_in.Sfs.Wms.DataExchange.Domain;
 public interface IInterfaceConfigRepository
 {
     Task<InterfaceConfig> GetInterfaceConfig(string code);
+    Task UpsertStatusAsync(string code);
 }

be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Domain/InterfaceConfig/InterfaceConfig.cs

@@ -20,4 +20,8 @@ public class InterfaceConfig : SfsAggregateRootBase
     /// 等级
     /// </summary>
     public int Level { get; set; }
+    /// <summary>
+    /// 接口运行状态
+    /// </summary>
+    public int Status { get; set; }
 }

be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Domain/InterfaceConfig/InterfaceConfigManager.cs

@@ -22,4 +22,9 @@ public class InterfaceConfigManager : DomainService, IInterfaceConfigManager
     {
         return await _repository.GetInterfaceConfig(code).ConfigureAwait(false);
     }
+
+    public virtual async Task UpsertStatusAsync(string itemcode)
+    {
+        await _repository.UpsertStatusAsync(itemcode).ConfigureAwait(false);
+    }
 }

be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.EntityFrameworkCore/InterfaceConfig/InterfaceConfigEfCoreRepository.cs

@@ -21,5 +21,13 @@ public class InterfaceConfigEfCoreRepository : SfsEfCoreRepositoryBase<DataExcha
         var entitie = await dbSet.FirstOrDefaultAsync(p => p.Code == code).ConfigureAwait(false);
         return entitie;
     }
-
+    public virtual async Task UpsertStatusAsync(string code)
+    {
+        var dbSet = await GetDbSetAsync().ConfigureAwait(false);
+        var item = await dbSet.FirstOrDefaultAsync(p => p.Code == code).ConfigureAwait(false);
+        if (item != null)
+        {
+            item.Status = 1;
+        }
+    }
 }