Program.cs
3.84 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
using HHECS.DAQHandle;
using HHECS.DAQHandle.Common.Utils;
using HHECS.DAQHandle.EquipmentHandle;
using HHECS.DAQHandle.Models;
using System.Configuration;
using System.Diagnostics;
using System.Security.Cryptography;
using static FreeSql.Internal.GlobalFilter;
var warehouseCode = ConfigurationManager.AppSettings["WarehouseCode"];
if (string.IsNullOrWhiteSpace(warehouseCode))
{
SystemLog.PrintWarn("仓库编号未配置！");
return;
}
var equipmentTypes = ConfigurationManager.AppSettings["EquipmentType"].Split(',')
.Where(x => !string.IsNullOrWhiteSpace(x)).Select(x => Convert.ToInt32(x)).ToList();
if (equipmentTypes == null || equipmentTypes.Count == 0)
{
SystemLog.PrintWarn("设备类型未配置！");
return;
}
var context = DbContextFactory.CreateDbContext();
while (true)
{
try
{
var equipmentInfos = context.Equipment.Where(x => equipmentTypes.Contains(x.EquipmentTypeId)).Include(x => x.EquipmentType).ToList(x => new
{
EquipmentTypeCode = x.EquipmentType.Code,
EquipmentCode = x.Code,
EquipmentName = x.Name,
EquipmentId = x.Id
});
//var allEquipmentDataRecords = context.EquipmentDataRecord.Where(x => equipmentInfos.Any(y => y.EquipmentCode == x.EquipmentCode) && !x.IsHandle).ToList();
var allEquipmentDataRecords = context.EquipmentDataRecord
.Where(x => x.EquipmentCode.StartsWith("SRM") && !x.IsHandle)
.OrderBy(x => x.Timestamp)
.Take(100).ToList();
allEquipmentDataRecords.ForEach(x =>
{
var equipment = equipmentInfos.Find(y => x.EquipmentCode == y.EquipmentCode);
if (equipment != null)
{
x.EquipmentTypeCode = equipment.EquipmentTypeCode;
x.EquipmentName = equipment.EquipmentName;
x.EquipmentId = equipment.EquipmentId;
}
else
{
SystemLog.PrintError($"记录{x.Id}对应的设备不存在");
}
});
var tasks = new List<Task>();
foreach (var item in equipmentInfos.GroupBy(x => x.EquipmentTypeCode))
{
tasks.Add(Task.Run(() =>
{
Stopwatch stopwatch = Stopwatch.StartNew();
IAnalysis? handle = item.Key switch
{
"SingleForkSRM" => new SingleSRMAnalysis(),
//"SingleForkSSRM" => new SingleSRMAnalysis(),
"DoubleForkSRM" => new SingleSRMAnalysis(),
"SingleForkSSRMV132" => new SingleSRMAnalysis(),
"B1" => new DoubleSRMAnalysis(),
"C1" => new AGVAnalysis(),
"D1" => new RobotAnalysis(),
_ => null
};
//未知类型，则跳过
if (handle is null)
{
SystemLog.PrintWarn($"未实现设备类型[{item.Key}]对应的处理方法");
return;
}
var equipmentSNs = item.Select(x => x.EquipmentCode).ToList();
var equipmentDataRecords = allEquipmentDataRecords.Where(x => equipmentSNs.Contains(x.EquipmentCode)).ToList();
handle.Execute(equipmentDataRecords);
stopwatch.Stop();
SystemLog.PrintInfo($"设备类型[{item.Key}]解析完成，数量{equipmentDataRecords.Count}，耗时{stopwatch.ElapsedMilliseconds}ms");
}));
}
Task.WaitAll(tasks.ToArray());
await Task.Delay(100);
Console.WriteLine($"————————————————————————————————————————————————————————");
}
catch (Exception ex)
{
SystemLog.PrintError($"程序异常：{ex.Message}");
}
}