#127 Хранение технологических сообщений #4

Merged
on.nemtina merged 14 commits from TechMessages into master 2024-12-04 16:51:51 +05:00
16 changed files with 23 additions and 23 deletions
Showing only changes of commit 7092324a54 - Show all commits

View File

@ -102,10 +102,10 @@ public class SetpointController : ControllerBase, ISetpointApi
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(int), (int)HttpStatusCode.OK)]
public async Task<IActionResult> Save(Guid setpointKey, object newValue, Guid idUser, CancellationToken token)
public async Task<IActionResult> Add(Guid setpointKey, object newValue, Guid idUser, CancellationToken token)
{
await setpointRepository.Save(setpointKey, newValue, idUser, token);
await setpointRepository.Add(setpointKey, newValue, idUser, token);
return Ok();
return CreatedAtAction(nameof(Add), true);

Вроде бы договорились CreatedAtAction возвращать?
А еще метод репозитория setpointRepository.Save ничего не возвращает, хотя в других подлобных методах возвращается int.

Вот, например:

var result = await techMessagesRepository.InsertRange(dtos, token);
return CreatedAtAction(nameof(InsertRange), result);

Еще название самого метода Save путает. По коду видно, что это именно вставка, а не просто сохранение...Но, может, так надо...

Вроде бы договорились CreatedAtAction возвращать? А еще метод репозитория setpointRepository.Save ничего не возвращает, хотя в других подлобных методах возвращается int. Вот, например: var result = await techMessagesRepository.InsertRange(dtos, token); return CreatedAtAction(nameof(InsertRange), result); Еще название самого метода Save путает. По коду видно, что это именно вставка, а не просто сохранение...Но, может, так надо...
  1. setpointRepository.Save ничего не возвращает т.к. количество сохраненных записей всегда будет == 1

  2. Для единообразия можно сделать "Add" "AddRange"

1) setpointRepository.Save ничего не возвращает т.к. количество сохраненных записей всегда будет == 1 2) Для единообразия можно сделать "Add" "AddRange"
}
}

View File

@ -107,7 +107,7 @@ public class TechMessagesController : ControllerBase
/// <returns></returns>
[HttpPost]
[ProducesResponseType(typeof(int), (int)HttpStatusCode.Created)]
public async Task<IActionResult> InsertRange([FromBody] IEnumerable<TechMessageDto> dtos, CancellationToken token)
public async Task<IActionResult> AddRange([FromBody] IEnumerable<TechMessageDto> dtos, CancellationToken token)
{
var userId = User.GetUserId<Guid>();
foreach (var dto in dtos)
@ -115,9 +115,9 @@ public class TechMessagesController : ControllerBase
dto.UserId = userId;
}
var result = await techMessagesRepository.InsertRange(dtos, token);
var result = await techMessagesRepository.AddRange(dtos, token);
return CreatedAtAction(nameof(InsertRange), result);
return CreatedAtAction(nameof(AddRange), result);
}
/// <summary>

View File

@ -66,9 +66,9 @@ public class TimeSeriesController<TDto> : ControllerBase, ITimeSeriesDataApi<TDt
/// <param name="token"></param>
/// <returns></returns>
[HttpPost]
public async Task<IActionResult> InsertRange(IEnumerable<TDto> dtos, CancellationToken token)
public async Task<IActionResult> AddRange(IEnumerable<TDto> dtos, CancellationToken token)
{
var result = await timeSeriesDataRepository.InsertRange(dtos, token);
var result = await timeSeriesDataRepository.AddRange(dtos, token);
return Ok(result);
}

View File

@ -32,9 +32,9 @@ public class TimestampedSetController : ControllerBase
/// <returns>кол-во затронутых записей</returns>
[HttpPost]
[ProducesResponseType(typeof(int), (int)HttpStatusCode.OK)]
public async Task<IActionResult> InsertRange([FromRoute]Guid idDiscriminator, [FromBody]IEnumerable<TimestampedSetDto> sets, CancellationToken token)
public async Task<IActionResult> AddRange([FromRoute]Guid idDiscriminator, [FromBody]IEnumerable<TimestampedSetDto> sets, CancellationToken token)
{
var result = await repository.InsertRange(idDiscriminator, sets, token);
var result = await repository.AddRange(idDiscriminator, sets, token);
return Ok(result);
}

View File

@ -88,7 +88,7 @@ namespace Persistence.Repository.Repositories
return dtos;
}
public async Task Save(Guid setpointKey, object newValue, Guid idUser, CancellationToken token)
public async Task Add(Guid setpointKey, object newValue, Guid idUser, CancellationToken token)
{
var entity = new Setpoint()
{

View File

@ -88,7 +88,7 @@ namespace Persistence.Repository.Repositories
return result;
}
public async Task<int> InsertRange(IEnumerable<TechMessageDto> dtos, CancellationToken token)
public async Task<int> AddRange(IEnumerable<TechMessageDto> dtos, CancellationToken token)

60 минут - лучше в отдельное поле вынести

60 минут - лучше в отдельное поле вынести
{
var entities = new List<TechMessage>();
Review

ToArrayAsync и туда внутрь еще токен передать....

ToArrayAsync и туда внутрь еще токен передать....

View File

@ -48,9 +48,9 @@ public class TimeSeriesDataCachedRepository<TEntity, TDto> : TimeSeriesDataRepos
return items;
}
public override async Task<int> InsertRange(IEnumerable<TDto> dtos, CancellationToken token)
public override async Task<int> AddRange(IEnumerable<TDto> dtos, CancellationToken token)
{
var result = await base.InsertRange(dtos, token);
var result = await base.AddRange(dtos, token);
if (result > 0)
{

View File

@ -41,7 +41,7 @@ public class TimeSeriesDataRepository<TEntity, TDto> : ITimeSeriesDataRepository
return dtos;
}
public virtual async Task<int> InsertRange(IEnumerable<TDto> dtos, CancellationToken token)
public virtual async Task<int> AddRange(IEnumerable<TDto> dtos, CancellationToken token)
{
var entities = dtos.Select(d => d.Adapt<TEntity>());

View File

@ -20,7 +20,7 @@ public class TimestampedSetRepository : ITimestampedSetRepository
this.db = db;
}
public Task<int> InsertRange(Guid idDiscriminator, IEnumerable<TimestampedSetDto> sets, CancellationToken token)
public Task<int> AddRange(Guid idDiscriminator, IEnumerable<TimestampedSetDto> sets, CancellationToken token)
{
var entities = sets.Select(set => new TimestampedSet(idDiscriminator, set.Timestamp.ToUniversalTime(), set.Set));
var dbSet = db.Set<TimestampedSet>();

View File

@ -40,5 +40,5 @@ public interface ISetpointApi : ISyncApi<SetpointLogDto>
/// <param name="newValue">значение</param>
/// <param name="token"></param>
/// <returns></returns>
Task<IActionResult> Save(Guid setpointKey, object newValue, Guid userId, CancellationToken token);
Task<IActionResult> Add(Guid setpointKey, object newValue, Guid userId, CancellationToken token);
}

View File

@ -28,7 +28,7 @@ public interface ITimeSeriesDataApi<TDto> : ITimeSeriesBaseDataApi<TDto>
/// <param name="dtos"></param>
/// <param name="token"></param>
/// <returns></returns>
Task<IActionResult> InsertRange(IEnumerable<TDto> dtos, CancellationToken token);
Task<IActionResult> AddRange(IEnumerable<TDto> dtos, CancellationToken token);
}

View File

@ -74,7 +74,7 @@ namespace Persistence.Repositories;
// throw new NotImplementedException();
// }
// public async Task<int> InsertRange(int idUser, IEnumerable<TDto> dtos, CancellationToken token)
// public async Task<int> AddRange(int idUser, IEnumerable<TDto> dtos, CancellationToken token)
// {
// using var transaction = dbContext.Database.BeginTransaction();
// try

View File

@ -59,5 +59,5 @@ public interface ISetpointRepository
/// <returns></returns>
/// to do
/// id User учесть в соответствующем методе репозитория
Task Save(Guid setpointKey, object newValue, Guid idUser, CancellationToken token);
Task Add(Guid setpointKey, object newValue, Guid idUser, CancellationToken token);
}

View File

@ -22,7 +22,7 @@ namespace Persistence.Repositories
/// <param name="dtos"></param>
/// <param name="token"></param>
/// <returns></returns>
Task<int> InsertRange(IEnumerable<TechMessageDto> dtos, CancellationToken token);
Task<int> AddRange(IEnumerable<TechMessageDto> dtos, CancellationToken token);
/// <summary>
/// Получение списка уникальных названий систем АБ

View File

@ -15,5 +15,5 @@ public interface ITimeSeriesDataRepository<TDto> : ISyncRepository<TDto>, ITimeS
/// <param name="dtos"></param>
/// <param name="token"></param>
/// <returns></returns>
Task<int> InsertRange(IEnumerable<TDto> dtos, CancellationToken token);
Task<int> AddRange(IEnumerable<TDto> dtos, CancellationToken token);
}

View File

@ -55,5 +55,5 @@ public interface ITimestampedSetRepository
/// <param name="sets"></param>
/// <param name="token"></param>
/// <returns></returns>
Task<int> InsertRange(Guid idDiscriminator, IEnumerable<TimestampedSetDto> sets, CancellationToken token);
Task<int> AddRange(Guid idDiscriminator, IEnumerable<TimestampedSetDto> sets, CancellationToken token);
}