EquipmentDataRecordHandleBackgroundService.cs
2.79 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
using HHECS.DAQShared.Models;
namespace HHECS.DAQServer.Services
{
public class EquipmentDataRecordHandleBackgroundService //: BackgroundService
{
private readonly IFreeSql _freeSql;
private readonly DataCacheService _dataCacheService;
private readonly ILogger<EquipmentDataRecordHandleBackgroundService> _logger;
private readonly int _limit = 1000;
//public EquipmentDataRecordHandleBackgroundService(IFreeSql freeSql, DataCacheService dataCacheService, ILogger<EquipmentDataRecordHandleBackgroundService> logger)
//{
// _freeSql = freeSql;
// _dataCacheService = dataCacheService;
// _logger = logger;
//}
//protected override async Task ExecuteAsync(CancellationToken stoppingToken)
//{
// var equipmentDataRecordTemps = new List<EquipmentDataRecord>();
// while (!stoppingToken.IsCancellationRequested)
// {
// try
// {
// //队列数量小于设定值，则等待
// if (_dataCacheService.EquipmentDataRecordQueue.Count < _limit)
// {
// //每两秒执行一次
// await Task.Delay(2000, stoppingToken);
// }
// if (equipmentDataRecordTemps.Count < _limit)
// {
// for (int i = 0; i < _limit; i++)
// {
// if (_dataCacheService.EquipmentDataRecordQueue.IsEmpty)
// {
// break;
// }
// if (equipmentDataRecordTemps.Count == _limit)
// {
// break;
// }
// _dataCacheService.EquipmentDataRecordQueue.TryDequeue(out var data);
// equipmentDataRecordTemps.Add(data);
// }
// }
// if (equipmentDataRecordTemps.Count > 0)
// {
// using var equipmentDataRecordRepository = _freeSql.GetRepository<EquipmentDataRecord>();
// equipmentDataRecordRepository.Insert(equipmentDataRecordTemps);
// _logger.LogInformation($"[设备记录数据表]成功新增{equipmentDataRecordTemps.Count}条数据！");
// equipmentDataRecordTemps.Clear();
// }
// }
// catch (Exception ex)
// {
// _logger.LogError($"[{nameof(EquipmentDataRecordHandleBackgroundService)}]线程异常：{ex.Message}");
// }
// }
//}
}
}