Browse Source

更新视觉叫料

dev_DY_CC
赵新宇 12 months ago
parent
commit
678b569be2
  1. 25
      be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.InjectionMoldingTaskAgent/Incoming/InjectionMoldingRequestReader.cs
  2. 10
      be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.InjectionMoldingTaskAgent/Incoming/InjectionMoldingTaskIncomingBackgroundWorker.cs
  3. 3
      be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.InjectionMoldingTaskAgent/appsettings.json

25
be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.InjectionMoldingTaskAgent/Incoming/InjectionMoldingRequestReader.cs

@ -64,12 +64,17 @@ public class InjectionMoldingRequestReader : IReader
{ {
try try
{ {
var sleepTime = (_options.Value.AutoRemote.TimeCycle*60/ _options.Value.AutoRemote.Interval)-10; #if DEBUG
_options.Value.AutoRemote.TimeCycle = 1;
_options.Value.AutoRemote.Interval = 2;
#endif
// var sleepTime = (_options.Value.AutoRemote.TimeCycle*60/ _options.Value.AutoRemote.Interval)-10;
var invterval = _options.Value.AutoRemote.Interval; var invterval = _options.Value.AutoRemote.Interval;
var successTime = 0; var successTime = 0;
var guid = DateTime.Now.ToString("yyyyMMddHHmmssfff");
for (int i = 0; i <invterval; i++) for (int i = 0; i <invterval; i++)
@ -98,9 +103,17 @@ public class InjectionMoldingRequestReader : IReader
camralist.AddRange(idsList); camralist.AddRange(idsList);
} }
successTime++; successTime++;
sw.Stop();
_logger.LogInformation($"读取标识{guid}读取成功次数{successTime},耗时 {sw.ElapsedMilliseconds}毫秒");
Thread.Sleep(1000);
if (successTime == invterval) if (successTime == invterval)
{ {
sw = Stopwatch.StartNew();
_logger.LogInformation($"开始标识{guid}同步WMS开始");
List<UnCompletedRequestDto> inputdetail = new List<UnCompletedRequestDto>(); List<UnCompletedRequestDto> inputdetail = new List<UnCompletedRequestDto>();
foreach (var item in camralist) foreach (var item in camralist)
{ {
@ -166,14 +179,16 @@ public class InjectionMoldingRequestReader : IReader
} }
// 创建新的注塑请求并将数据写入数据库 // 创建新的注塑请求并将数据写入数据库
await _injectionRequest.CreateAsync(input).ConfigureAwait(false); await _injectionRequest.CreateAsync(input).ConfigureAwait(false);
} }
_logger.LogInformation($"标识{guid}同步WMS结束,耗时{sw.ElapsedMilliseconds }毫秒");
} }
else else
{ {
Thread.Sleep(sleepTime * 1000); Thread.Sleep(1000);
} }
sw.Stop();
_logger.LogInformation($"读取成功次数{successTime},耗时 ${sw.ElapsedMilliseconds / 1000 / 60}分钟");
} }

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

@ -23,7 +23,17 @@ public class InjectionMoldingTaskIncomingBackgroundWorker : AsyncPeriodicBackgro
IServiceScopeFactory serviceScopeFactory IServiceScopeFactory serviceScopeFactory
) : base(timer, serviceScopeFactory) ) : base(timer, serviceScopeFactory)
{ {
_options = options; _options = options;
#if DEBUG
_options.Value.AutoRemote.TimeCycle = 1;
_options.Value.AutoRemote.Interval = 2;
#endif
Timer.Period = options.Value.AutoRemote.TimeCycle * 60 * 1000; //default 10 minutes Timer.Period = options.Value.AutoRemote.TimeCycle * 60 * 1000; //default 10 minutes
} }

3
be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.InjectionMoldingTaskAgent/appsettings.json

@ -72,10 +72,7 @@
"Password": "", "Password": "",
"Token": "", "Token": "",
"AreaIDs": "1", "AreaIDs": "1",
"Interval" : "3", // interval "Interval" : "3", // interval
"TimeCycle" :"5" "TimeCycle" :"5"
}, },

Loading…
Cancel
Save