Merge pull request '#13159199 Запрет на редактирование завершенных скважин для инженеров' (#106) from feature/ban_adding_data into dev

Reviewed-on: http://test.digitaldrilling.ru:8080/DDrilling/AsbCloudServer/pulls/106

AsbCloudApp/Services/IProcessMapService.cs

@@ -6,9 +6,9 @@ using System.Threading.Tasks;
 namespace AsbCloudApp.Services
 {
     /// <summary>
-    /// Сервис формирования РТК
+    /// Сервис РТК
     /// </summary>
-    public interface IProcessMapReportService
+    public interface IProcessMapService
     {
         /// <summary>
         /// Получение моделей РТК

AsbCloudDb/Migrations/20230913063219_Add_New_Permissions.cs

@@ -0,0 +1,53 @@
+using Microsoft.EntityFrameworkCore.Migrations;
+
+#nullable disable
+
+namespace AsbCloudDb.Migrations
+{
+    public partial class Add_New_Permissions : Migration
+    {
+        protected override void Up(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.InsertData(
+                table: "t_permission",
+                columns: new[] { "id", "description", "name" },
+                values: new object[,]
+                {
+                    { 525, "Разрешение на редактирование РТК у завершенной скважины", "ProcessMap.editCompletedWell" },
+                    { 526, "Разрешение на редактирование операций у завершенной скважины", "WellOperation.editCompletedWell" }
+                });
+
+            migrationBuilder.InsertData(
+                table: "t_relation_user_role_permission",
+                columns: new[] { "id_permission", "id_user_role" },
+                values: new object[,]
+                {
+                    { 525, 1 },
+                    { 526, 1 }
+                });
+        }
+
+        protected override void Down(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.DeleteData(
+                table: "t_relation_user_role_permission",
+                keyColumns: new[] { "id_permission", "id_user_role" },
+                keyValues: new object[] { 525, 1 });
+
+            migrationBuilder.DeleteData(
+                table: "t_relation_user_role_permission",
+                keyColumns: new[] { "id_permission", "id_user_role" },
+                keyValues: new object[] { 526, 1 });
+
+            migrationBuilder.DeleteData(
+                table: "t_permission",
+                keyColumn: "id",
+                keyValue: 525);
+
+            migrationBuilder.DeleteData(
+                table: "t_permission",
+                keyColumn: "id",
+                keyValue: 526);
+        }
+    }
+}

AsbCloudDb/Migrations/AsbCloudDbContextModelSnapshot.cs

@@ -2163,6 +2163,18 @@ namespace AsbCloudDb.Migrations
                             Id = 522,
                             Description = "Разрешить удаление всех настроек пользователя",
                             Name = "UserSettings.delete"
+                        },
+                        new
+                        {
+                            Id = 525,
+                            Description = "Разрешение на редактирование РТК у завершенной скважины",
+                            Name = "ProcessMap.editCompletedWell"
+                        },
+                        new
+                        {
+                            Id = 526,
+                            Description = "Разрешение на редактирование операций у завершенной скважины",
+                            Name = "WellOperation.editCompletedWell"
                         });
                 });
 
@@ -3750,6 +3762,16 @@ namespace AsbCloudDb.Migrations
                         {
                             IdUserRole = 1,
                             IdPermission = 522
+                        },
+                        new
+                        {
+                            IdUserRole = 1,
+                            IdPermission = 525
+                        },
+                        new
+                        {
+                            IdUserRole = 1,
+                            IdPermission = 526
                         });
                 });
 

AsbCloudDb/Model/DefaultData/EntityFillerPermission.cs

@@ -156,6 +156,9 @@
             new() { Id = 521, Name = "HelpPage.edit", Description = "Разрешить создание справок по страницам"},
 
             new() { Id = 522, Name = "UserSettings.delete", Description = "Разрешить удаление всех настроек пользователя"},
+            
+            new (){ Id = 525, Name = "ProcessMap.editCompletedWell", Description = "Разрешение на редактирование РТК у завершенной скважины"},
+            new (){ Id = 526, Name = "WellOperation.editCompletedWell", Description = "Разрешение на редактирование операций у завершенной скважины"}
         };
     }
 }

AsbCloudDb/Model/DefaultData/EntityFillerRelationUserRolePermission.cs

@@ -58,7 +58,6 @@ namespace AsbCloudDb.Model.DefaultData
                 new (){ IdUserRole = 2005, IdPermission = 247}, new (){ IdUserRole = 2005, IdPermission = 205}, new (){ IdUserRole = 2005, IdPermission = 204},
                 new (){ IdUserRole = 2006, IdPermission = 243}, new (){ IdUserRole = 2006, IdPermission = 205}, new (){ IdUserRole = 2006, IdPermission = 204},
                 new (){ IdUserRole = 2007, IdPermission = 241}, new (){ IdUserRole = 2007, IdPermission = 205}, new (){ IdUserRole = 2007, IdPermission = 204},
-                //new (){ IdUserRole = 1, IdPermission = 500}, new (){ IdUserRole = 1, IdPermission = 501}, new (){ IdUserRole = 1, IdPermission = 502}, new (){ IdUserRole = 1, IdPermission = 503}, new (){ IdUserRole = 1, IdPermission = 504}, new (){ IdUserRole = 1, IdPermission = 505}, new (){ IdUserRole = 1, IdPermission = 506}, new (){ IdUserRole = 1, IdPermission = 510}, new (){ IdUserRole = 1, IdPermission = 511}, new (){ IdUserRole = 1, IdPermission = 512}, new (){ IdUserRole = 1, IdPermission = 513}, new (){ IdUserRole = 1, IdPermission = 514}, new (){ IdUserRole = 1, IdPermission = 515},
             };
             var allPermissions = (new EntityFillerPermission()).GetData();
             foreach ( var permission in allPermissions)

AsbCloudInfrastructure/DependencyInjection.cs

@@ -144,7 +144,7 @@ namespace AsbCloudInfrastructure
             services.AddTransient<IFileCategoryService, FileCategoryService>();
             services.AddTransient<ILimitingParameterService, LimitingParameterService>();
             services.AddTransient<IProcessMapReportMakerService, ProcessMapReportMakerService>();
-            services.AddTransient<IProcessMapReportService, ProcessMapReportService>();
+            services.AddTransient<IProcessMapService, ProcessMapService>();
             services.AddTransient<WellInfoService>();
             services.AddTransient<IHelpPageService, HelpPageService>();
 

AsbCloudInfrastructure/Services/ProcessMap/ProcessMapReportMakerService.cs

@@ -17,9 +17,9 @@ namespace AsbCloudInfrastructure.Services.ProcessMap
 
         const int headerRowsCount = 5;
 
-        private readonly IProcessMapReportService processMapService;
+        private readonly IProcessMapService processMapService;
 
-        public ProcessMapReportMakerService(IProcessMapReportService processMapService)
+        public ProcessMapReportMakerService(IProcessMapService processMapService)
         {
             this.processMapService = processMapService;
         }

AsbCloudInfrastructure/Services/ProcessMap/ProcessMapService.cs

@@ -12,14 +12,14 @@ using System.Threading.Tasks;
 namespace AsbCloudInfrastructure.Services.ProcessMap
 {
 
-    public partial class ProcessMapReportService : IProcessMapReportService
+    public partial class ProcessMapService : IProcessMapService
     {
         private readonly IWellService wellService;
         private readonly IWellOperationRepository wellOperationRepository;
         private readonly IProcessMapPlanRepository processMapPlanRepository;
         private readonly ITelemetryDataSaubService telemetryDataSaubService;
 
-        public ProcessMapReportService(
+        public ProcessMapService(
             IWellService wellService,
             IWellOperationRepository wellOperationRepository,
             IProcessMapPlanRepository processMapPlanRepository,

AsbCloudWebApi/Controllers/ProcessMapController.cs

@@ -27,8 +27,9 @@ namespace AsbCloudWebApi.Controllers
         private readonly ITelemetryService telemetryService;
         private readonly IHubContext<TelemetryHub> telemetryHubContext;
         private readonly IProcessMapReportMakerService processMapReportService;
-        private readonly IProcessMapReportService processMapService;
+        private readonly IProcessMapService processMapService;
         private readonly IProcessMapPlanImportService processMapPlanImportService;
+        private readonly IUserRepository userRepository;
 
         private const string SirnalRMethodGetDataName = "UpdateProcessMap";
 
@@ -36,10 +37,11 @@ namespace AsbCloudWebApi.Controllers
             IWellService wellService,
             IProcessMapPlanRepository repository,
             IProcessMapReportMakerService processMapReportService,
-            IProcessMapReportService processMapService,
+            IProcessMapService processMapService,
             ITelemetryService telemetryService,
             IHubContext<TelemetryHub> telemetryHubContext,
-            IProcessMapPlanImportService processMapPlanImportService)
+            IProcessMapPlanImportService processMapPlanImportService,
+            IUserRepository userRepository)
             : base(wellService, repository)
         {
             this.telemetryService = telemetryService;
@@ -47,6 +49,7 @@ namespace AsbCloudWebApi.Controllers
             this.processMapReportService = processMapReportService;
             this.processMapService = processMapService;
             this.processMapPlanImportService = processMapPlanImportService;
+            this.userRepository = userRepository;
 
         }
 
@@ -139,6 +142,9 @@ namespace AsbCloudWebApi.Controllers
         [HttpPost]
         public override async Task<ActionResult<int>> InsertAsync([FromBody] ProcessMapPlanDto value, CancellationToken token)
         {
+            if (!await CanUserEditProcessMapAsync(value.IdWell, token))
+                return Forbid();
+            
             value.IdUser = User.GetUserId() ?? -1;
             var result = await base.InsertAsync(value, token);
             await NotifyUsersBySignalR(value.IdWell, token);
@@ -154,6 +160,9 @@ namespace AsbCloudWebApi.Controllers
         [HttpPut]
         public override async Task<ActionResult<int>> UpdateAsync([FromBody] ProcessMapPlanDto value, CancellationToken token)
         {
+            if (!await CanUserEditProcessMapAsync(value.IdWell, token))
+                return Forbid();
+            
             value.IdUser = User.GetUserId() ?? -1;
             var result = await base.UpdateAsync(value, token);
             await NotifyUsersBySignalR(value.IdWell, token);
@@ -188,10 +197,13 @@ namespace AsbCloudWebApi.Controllers
             CancellationToken cancellationToken)
         {
             int? idUser = User.GetUserId();
-
+            
             if (idUser is null)
                 return Forbid();
             
+            if (!await CanUserEditProcessMapAsync(idWell, cancellationToken))
+                return Forbid();
+            
             if (Path.GetExtension(file.FileName).ToLower() != ".xlsx")
                 return BadRequest("Требуется xlsx файл.");
             
@@ -238,7 +250,22 @@ namespace AsbCloudWebApi.Controllers
             var fileName = $"РТК-план по скважине {well.Caption} куст {well.Cluster}.xlsx";
             return File(stream, "application/octet-stream", fileName);
         }
-        
+
+        private async Task<bool> CanUserEditProcessMapAsync(int idWell, CancellationToken token)
+        {
+            var idUser = User.GetUserId();
+
+            if (!idUser.HasValue)
+                return false;
+            
+            var well = await wellService.GetOrDefaultAsync(idWell, token);
+
+            if (well is null)
+                return false;
+            
+            return well.IdState != 2 || userRepository.HasPermission(idUser.Value, "ProcessMap.editCompletedWell");
+        }
+
         private async Task NotifyUsersBySignalR(int idWell, CancellationToken token)
         {
             var dtos = await service.GetAllAsync(idWell, null, token);

AsbCloudWebApi/Controllers/WellOperationController.cs

@@ -26,12 +26,16 @@ namespace AsbCloudWebApi.Controllers
         private readonly IWellOperationRepository operationRepository;
         private readonly IWellService wellService;
         private readonly IWellOperationImportService wellOperationImportService;
+        private readonly IUserRepository userRepository;
 
-        public WellOperationController(IWellOperationRepository operationService, IWellService wellService, IWellOperationImportService wellOperationImportService)
+        public WellOperationController(IWellOperationRepository operationService, IWellService wellService, 
+            IWellOperationImportService wellOperationImportService,
+            IUserRepository userRepository)
         {
             this.operationRepository = operationService;
             this.wellService = wellService;
             this.wellOperationImportService = wellOperationImportService;
+            this.userRepository = userRepository;
         }
 
         /// <summary>
@@ -199,7 +203,10 @@ namespace AsbCloudWebApi.Controllers
                 [FromBody] IEnumerable<WellOperationDto> values,
                 CancellationToken token)
         {
-            if (!await CanUserAccessToWellAsync(idWell, token).ConfigureAwait(false))
+            if (!await CanUserAccessToWellAsync(idWell, token))
+                return Forbid();
+            
+            if (!await CanUserEditWellOperationsAsync(idWell, token))
                 return Forbid();
 
             foreach (var value in values)
@@ -229,7 +236,10 @@ namespace AsbCloudWebApi.Controllers
         public async Task<IActionResult> UpdateAsync(int idWell, int idOperation,
             [FromBody] WellOperationDto value, CancellationToken token)
         {
-            if (!await CanUserAccessToWellAsync(idWell, token).ConfigureAwait(false))
+            if (!await CanUserAccessToWellAsync(idWell, token))
+                return Forbid();
+            
+            if (!await CanUserEditWellOperationsAsync(idWell, token))
                 return Forbid();
 
             value.IdWell = idWell;
@@ -254,8 +264,10 @@ namespace AsbCloudWebApi.Controllers
         [ProducesResponseType(typeof(int), (int)System.Net.HttpStatusCode.OK)]
         public async Task<IActionResult> DeleteAsync(int idWell, int idOperation, CancellationToken token)
         {
-            if (!await CanUserAccessToWellAsync(idWell,
-                token).ConfigureAwait(false))
+            if (!await CanUserAccessToWellAsync(idWell, token))
+                return Forbid();
+            
+            if (!await CanUserEditWellOperationsAsync(idWell, token))
                 return Forbid();
 
             var result = await operationRepository.DeleteAsync(new int[] { idOperation }, token)
@@ -286,6 +298,12 @@ namespace AsbCloudWebApi.Controllers
             if (idCompany is null || idUser is null)
                 return Forbid();
 
+            if (!await CanUserAccessToWellAsync(idWell, token))
+                return Forbid();
+            
+            if (!await CanUserEditWellOperationsAsync(idWell, token))
+                return Forbid();
+
             if (!await wellService.IsCompanyInvolvedInWellAsync((int)idCompany,
                 idWell, token).ConfigureAwait(false))
                 return Forbid();
@@ -376,6 +394,21 @@ namespace AsbCloudWebApi.Controllers
             return File(stream, "application/octet-stream", fileName);
         }
 
+        private async Task<bool> CanUserEditWellOperationsAsync(int idWell, CancellationToken token)
+        {
+            var idUser = User.GetUserId();
+
+            if (!idUser.HasValue)
+                return false;
+            
+            var well = await wellService.GetOrDefaultAsync(idWell, token);
+
+            if (well is null)
+                return false;
+
+            return well.IdState != 2 || userRepository.HasPermission(idUser.Value, "WellOperation.editCompletedWell");
+        }
+
         private async Task<bool> CanUserAccessToWellAsync(int idWell, CancellationToken token)
         {
             int? idCompany = User.GetCompanyId();