#c# #mysql #service
Вопрос:
У меня есть служба, которая извлекает исторические данные и сохраняет их в таблице MySQL
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
while (!stoppingToken.IsCancellationRequested)
{
_logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now);
//Get Relevant Gateways
string GetRouters = "SELECT * FROM RouterModel;";
var Routers = await dataAccess.LoadData<RouterModel, dynamic>(GetRouters, new { }, _config.GetConnectionString("MainDB"));
string GetMeters = "SELECT * FROM PowerMeterModel;";
var Meters = await dataAccess.LoadData<PowerMeterModel, dynamic>(GetMeters, new { }, _config.GetConnectionString("MainDB"));
foreach (RouterModel Router in Routers)
{
if (Router.IsHavePowerMeters)
{
foreach (PowerMeterModel Meter in Meters.Where(x => x.IdGateway == Router.Id).ToList())
{
if (Meter.IsActive)
{
actionList.Add(new Action(() =>
{
GetHistory(Router, Meter);
_logger.LogInformation("Synced History meter:" Meter.SerialNumber.ToString());
}));
}
}
}
}
Parallel.Invoke(actionList.ToArray());
actionList.Clear();
_logger.LogWarning("*************** Sync loop is finished ***************");
await Task.Delay(60*1000, stoppingToken);
}
}
public async void GetHistory(RouterModel Router, PowerMeterModel Meter)
{
Web device = new() { IpAddress = Router.IpAddress, UserName = Meter.Username, Password = Meter.Password, Port = Meter.TcpPort };
StringBuilder SqlQuery = new();
StringBuilder TimeString = new();
ElnetMcMapping elnetMcMapping = new();
ElnetMcModel mcReadings = new();
if (Meter.ModelClass == nameof(ElnetMcModel).ToString())
{
for (int day = 1; day < 4; day )
{
List<List<double>> responeData = new();
DateTime date = todayDate.AddDays(-day);
for (int j = 0; j < elnetMcMapping.DataItems.Count; j = 8)
{
var items = elnetMcMapping.DataItems.Skip(j).Take(8);
device.Items = items.Select(x => x.Address.ToString()).ToList();
var responseString = device.GetElnetReadings(httpClient, 2, date);
if (responseString != null)
{
int check = responeData.Count;
responeData.AddRange(JsonConvert.DeserializeObject<List<List<double>>>(responseString));
}
else { return; }
}
for (int j = 0; j < elnetMcMapping.DataItems.Count; j ) { elnetMcMapping.DataItems[j].Value = responeData[j]; }
foreach (MetaData metaData in elnetMcMapping.DataItems)
{
Type type = mcReadings.GetType();
PropertyInfo prop = type.GetProperty(metaData.Label);
if (prop.PropertyType == typeof(decimal)) { prop.SetValue(mcReadings, Convert.ToDecimal(metaData.Value[0]) * metaData.Multiplier, null); }
else if (prop.PropertyType == typeof(string)) { prop.SetValue(mcReadings, metaData.Value[0].ToString(), null); }
else if (prop.PropertyType == typeof(int)) { prop.SetValue(mcReadings, int.Parse(metaData.Value[0].ToString()), null); }
else if (prop.PropertyType == typeof(DateTime)) { prop.SetValue(mcReadings, DateTime.Now, null); }
else { return; }
}
var propList = mcReadings.GetType().GetProperties().ToList();
SqlQuery.Append("INSERT INTO " Meter.DataTableName " (");
foreach (PropertyInfo prop in propList) { SqlQuery.Append(prop.Name ","); }
SqlQuery.Remove(SqlQuery.Length - 1, 1);
SqlQuery.Append(") VALUES (");
foreach (PropertyInfo prop in propList)
{
if (prop.PropertyType == typeof(DateTime))
{
DateTime dateTime = (DateTime)prop.GetValue(mcReadings);
SqlQuery.Append("'" dateTime.ToString("yyyy-MM-dd HH:mm:ss") "'" ",");
}
else { SqlQuery.Append(prop.GetValue(mcReadings).ToString() ","); }
}
SqlQuery.Remove(SqlQuery.Length - 1, 1);
SqlQuery.Append(");");
await dataAccess.SaveData(SqlQuery.ToString(), mcReadings, _config.GetConnectionString("PwrMeterDb"));
}
}
}
}
}
Приведенный выше код должен добавить только 4 строки MySQL, вместо этого я получаю 6, похоже, что весь метод начинается заново каждый раз, когда цикл for (int day = 1; day < 4; day ) изменяет свое значение.
Вместо этого получаем 4 строки (по одной на каждый день) Я получаю 6
Вместо этого получаем 5 строк (по одной на каждый день) Я получаю 10
Вместо этого получаем 6 строк (по одной на каждый день) Я получаю 15
Вместо этого получаем 7 строк (по одной на каждый день) Я получаю 21
Есть какие-нибудь идеи, что может быть не так ?
Комментарии:
1. Попробуйте поставить точки останова и отладить каждый результат и цикл sql.
2. @AliK не работает, в какой-то момент он просто перескакивает вперед после нескольких взаимодействий, и я получаю то, что получаю….
3. Также: Может быть, потратьте время и разделите эту миску спагетти на небольшие тестируемые функции, а затем: напишите тесты. Все ли части делают то, что, по-вашему, они делают?
4. Отключите циклическое выполнение во время отладки. Это испортит сеанс, если вы потратите больше времени, чем задержка.
5. У меня есть еще одна функция, почти идентичная, единственное, что я изменил, — это цикл, и он отлично работает для (int i = 0; i трехфазный; i )
Ответ №1:
Вы не очищаете SqlQuery StringBuilder объект в начале каждого цикла.
Итак, на первой итерации у него есть один INSERT запрос. На второй итерации у него есть две, в общей сложности три вставки. На третьей итерации их будет три, всего шесть. На четвертой итерации он содержит четыре вставки, в общей сложности десять. Это приводит к 1, 3, 6, 10, 15, 21 последовательность, которую вы наблюдаете.
Вызов SqlQuery.Clear() в начале каждого цикла.
Комментарии:
1. СПАСИБО, что заметили, не могу поверить, что я это пропустил, теперь это работает !