on.nemtina/persistence
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

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

Merged
on.nemtina merged 14 commits from TechMessages into master 2024-12-04 16:51:51 +05:00
Conversation 0 Commits 14 Files Changed 46 +9 -11
5 changed files with 9 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 2228c84139 - Show all commits

7
Persistence.API/Controllers/SetpointController.cs
View File

@ -101,10 +101,11 @@ public class SetpointController : ControllerBase, ISetpointApi
/// <param name="token"></param> /// <param name="token"></param>
/// <returns></returns> /// <returns></returns>
[HttpPost] [HttpPost]
[ProducesResponseType(typeof(int), (int)HttpStatusCode.OK)] [ProducesResponseType(typeof(int), (int)HttpStatusCode.Created)]
public async Task<IActionResult> Add(Guid setpointKey, object newValue, Guid idUser, CancellationToken token) public async Task<IActionResult> Add(Guid setpointKey, object newValue, CancellationToken token)
{ {
await setpointRepository.Add(setpointKey, newValue, idUser, token); var userId = User.GetUserId<Guid>();
await setpointRepository.Add(setpointKey, newValue, userId, token);
on.nemtina commented 2024-12-03 12:43:42 +05:00
Outdated
Review
Copy Link

Вроде бы договорились 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
rs.efremov commented 2024-12-04 10:59:22 +05:00
Outdated
Review
Copy Link

  1. setpointRepository.Save ничего не возвращает т.к. количество сохраненных записей всегда будет == 1

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

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

6
Persistence.API/Controllers/TechMessagesController.cs
View File

@ -110,12 +110,8 @@ public class TechMessagesController : ControllerBase
public async Task<IActionResult> AddRange([FromBody] IEnumerable<TechMessageDto> dtos, CancellationToken token) public async Task<IActionResult> AddRange([FromBody] IEnumerable<TechMessageDto> dtos, CancellationToken token)
{ {
var userId = User.GetUserId<Guid>(); var userId = User.GetUserId<Guid>();
foreach (var dto in dtos)
{
dto.UserId = userId;
}
var result = await techMessagesRepository.AddRange(dtos, token); var result = await techMessagesRepository.AddRange(dtos, userId, token);
return CreatedAtAction(nameof(AddRange), result); return CreatedAtAction(nameof(AddRange), result);
} }

3
Persistence.Repository/Repositories/TechMessagesRepository.cs
View File

@ -88,7 +88,7 @@ namespace Persistence.Repository.Repositories
return result; return result;
} }
public async Task<int> AddRange(IEnumerable<TechMessageDto> dtos, CancellationToken token) public async Task<int> AddRange(IEnumerable<TechMessageDto> dtos, Guid userId, CancellationToken token)
on.nemtina commented 2024-11-28 17:06:01 +05:00
Outdated
Review
Copy Link

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

60 минут - лучше в отдельное поле вынести
👍 1
{ {
var entities = new List<TechMessage>(); var entities = new List<TechMessage>();
on.nemtina commented 2024-11-28 17:05:22 +05:00
Review
Copy Link

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

ToArrayAsync и туда внутрь еще токен передать....
👍 1
@ -100,6 +100,7 @@ namespace Persistence.Repository.Repositories
?? await CreateDrillingSystem(dto.System, token); ?? await CreateDrillingSystem(dto.System, token);
on.nemtina commented 2024-11-28 17:14:46 +05:00
Outdated
Review
Copy Link

Здесь тоже можно убрать ?? [], так как внутри systems не может быть null.
Чтобы гарантированно это обозначить, можно написать так: return systems!

Здесь тоже можно убрать ``` ?? []```, так как внутри systems не может быть null. Чтобы гарантированно это обозначить, можно написать так: return systems!
👍 1
entity.SystemId = systemId; entity.SystemId = systemId;
entity.UserId = userId;
entities.Add(entity); entities.Add(entity);
} }
on.nemtina commented 2024-11-28 17:25:04 +05:00
Outdated
Review
Copy Link

Здесь можно дополнительную переменную не создавать

Здесь можно дополнительную переменную не создавать
Бfffffезымянный.png
24 KiB
Бfffffезымянный.png
👍 1

2
Persistence/API/ISetpointApi.cs
View File

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

2
Persistence/Repositories/ITechMessagesRepository.cs
View File

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