Merge pull request #681 from bcgov/yj

feat(dss-359)

Author: ychung-mot

database/ddl/STR_DSS_Views_Sprint_15.sql

@@ -0,0 +1,19 @@
+/* Sprint 15 View Changes to STR DSS */
+
+drop view if exists dss_platform_vw;
+
+CREATE OR REPLACE VIEW dss_platform_vw AS 
+SELECT do2.organization_id
+, do2.organization_cd
+, do2.organization_nm
+, do2.managing_organization_id
+, do2.upd_dtm
+, do2.upd_user_guid
+, docp.organization_contact_person_id as notice_of_takedown_contact_id
+, docp.email_address_dsc as notice_of_takedown_contact_email
+, docp2.organization_contact_person_id as takedown_request_contact_id
+, docp2.email_address_dsc as takedown_request_contact_email
+FROM dss_organization do2
+left join dss_organization_contact_person docp on docp.contacted_through_organization_id = do2.organization_id and docp.email_message_type = 'Notice of Takedown'
+left join dss_organization_contact_person docp2 on docp2.contacted_through_organization_id = do2.organization_id and docp2.email_message_type = 'Takedown Request'
+where do2.organization_type = 'Platform';

server/StrDss.Api/Controllers/OrganizationsController.cs

@@ -77,5 +77,15 @@ public async Task<ActionResult<StrRequirementsDto>> GetStrRequirements(double lo
 
             return Ok(await _orgService.GetStrRequirements(longitude, latitude));
         }
+
+
+        [ApiAuthorize()]
+        [HttpGet("platforms")]
+        public async Task<ActionResult> GetPlatforms(int pageSize = 10, int pageNumber = 1, string orderBy = "OrganizationNm", string direction = "asc")
+        {
+            var platforms = await _orgService.GetPlatforms(pageSize, pageNumber, orderBy, direction);
+            return Ok(platforms);
+        }
+
     }
 }

server/StrDss.Data/Entities/DssDbContext.cs

@@ -31,6 +31,8 @@ public DssDbContext(DbContextOptions<DssDbContext> options)
 
     public virtual DbSet<DssPhysicalAddress> DssPhysicalAddresses { get; set; }
 
+    public virtual DbSet<DssPlatformVw> DssPlatformVws { get; set; }
+
     public virtual DbSet<DssRentalListing> DssRentalListings { get; set; }
 
     public virtual DbSet<DssRentalListingContact> DssRentalListingContacts { get; set; }
@@ -658,6 +660,32 @@ protected override void OnModelCreating(ModelBuilder modelBuilder)
                 .HasConstraintName("dss_physical_address_fk_replaced_by");
         });
 
+        modelBuilder.Entity<DssPlatformVw>(entity =>
+        {
+            entity
+                .HasNoKey()
+                .ToView("dss_platform_vw");
+
+            entity.Property(e => e.ManagingOrganizationId).HasColumnName("managing_organization_id");
+            entity.Property(e => e.NoticeOfTakedownContactEmail)
+                .HasMaxLength(320)
+                .HasColumnName("notice_of_takedown_contact_email");
+            entity.Property(e => e.NoticeOfTakedownContactId).HasColumnName("notice_of_takedown_contact_id");
+            entity.Property(e => e.OrganizationCd)
+                .HasMaxLength(25)
+                .HasColumnName("organization_cd");
+            entity.Property(e => e.OrganizationId).HasColumnName("organization_id");
+            entity.Property(e => e.OrganizationNm)
+                .HasMaxLength(250)
+                .HasColumnName("organization_nm");
+            entity.Property(e => e.TakedownRequestContactEmail)
+                .HasMaxLength(320)
+                .HasColumnName("takedown_request_contact_email");
+            entity.Property(e => e.TakedownRequestContactId).HasColumnName("takedown_request_contact_id");
+            entity.Property(e => e.UpdDtm).HasColumnName("upd_dtm");
+            entity.Property(e => e.UpdUserGuid).HasColumnName("upd_user_guid");
+        });
+
         modelBuilder.Entity<DssRentalListing>(entity =>
         {
             entity.HasKey(e => e.RentalListingId).HasName("dss_rental_listing_pk");

server/StrDss.Data/Entities/DssPlatformVw.cs

@@ -0,0 +1,27 @@
+using System;
+using System.Collections.Generic;
+
+namespace StrDss.Data.Entities;
+
+public partial class DssPlatformVw
+{
+    public long? OrganizationId { get; set; }
+
+    public string? OrganizationCd { get; set; }
+
+    public string? OrganizationNm { get; set; }
+
+    public long? ManagingOrganizationId { get; set; }
+
+    public DateTime? UpdDtm { get; set; }
+
+    public Guid? UpdUserGuid { get; set; }
+
+    public long? NoticeOfTakedownContactId { get; set; }
+
+    public string? NoticeOfTakedownContactEmail { get; set; }
+
+    public long? TakedownRequestContactId { get; set; }
+
+    public string? TakedownRequestContactEmail { get; set; }
+}

server/StrDss.Data/Mappings/EntityToModelProfile.cs

@@ -52,6 +52,7 @@ public EntityToModelProfile()
 
             CreateMap<DssBusinessLicence, BizLicenceSearchDto>();
             CreateMap<DssOrganization, PlatformCreateDto>();
+            CreateMap<DssPlatformVw, PlatformViewDto>();
         }
     }
 }

server/StrDss.Data/Repositories/OrganizationRepository.cs

@@ -9,6 +9,7 @@
 using StrDss.Data.Entities;
 using StrDss.Model;
 using StrDss.Model.OrganizationDtos;
+using StrDss.Model.RentalReportDtos;
 
 namespace StrDss.Data.Repositories
 {
@@ -22,6 +23,7 @@ public interface IOrganizationRepository
         Task<long?> GetContainingOrganizationId(Point point);
         Task<long?> GetManagingOrgId(long orgId);
         Task<StrRequirementsDto?> GetStrRequirements(double longitude, double latitude);
+        Task<PagedDto<PlatformViewDto>> GetPlatforms(int pageSize, int pageNumber, string orderBy, string direction);
     }
     public class OrganizationRepository : RepositoryBase<DssOrganization>, IOrganizationRepository
     {
@@ -147,5 +149,20 @@ FROM dss_organization
 
             return strRequirement;
         }
+
+        public async Task<PagedDto<PlatformViewDto>> GetPlatforms(int pageSize, int pageNumber, string orderBy, string direction)
+        {
+            var query = _dbContext.DssPlatformVws.AsNoTracking().Where(x => x.ManagingOrganizationId == null);
+
+            var platforms = await Page<DssPlatformVw, PlatformViewDto>(query, pageSize, pageNumber, orderBy, direction);
+
+            foreach (var platform in platforms.SourceList)
+            {
+                platform.Subsidiaries = _mapper.Map <List<PlatformViewDto>>
+                    (await _dbContext.DssPlatformVws.AsNoTracking().Where(x => x.ManagingOrganizationId == platform.OrganizationId).ToListAsync());
+            }
+
+            return platforms;
+        }
     }
 }

server/StrDss.Model/OrganizationDtos/PlatformViewDto.cs

@@ -0,0 +1,21 @@
+namespace StrDss.Model.OrganizationDtos
+{
+    public class PlatformViewDto
+    {
+        public PlatformViewDto()
+        {
+            Subsidiaries = new List<PlatformViewDto>();
+        }
+
+        public long OrganizationId { get; set; }
+        public string OrganizationCd { get; set; } = null!;
+        public string OrganizationNm { get; set; } = null!;
+        public DateTime UpdDtm { get; set; }
+        public Guid? UpdUserGuid { get; set; }
+        public long NoticeOfTakedownContactId { get; set; }
+        public string NoticeOfTakedownContactEmail { get; set; }
+        public long TakedownRequestContactId { get; set; }
+        public string TakedownRequestContactEmail { get; set; }
+        public virtual ICollection<PlatformViewDto> Subsidiaries { get; set; }
+    }
+}

server/StrDss.Service/OrganizationService.cs

@@ -18,6 +18,7 @@ public interface IOrganizationService
         Task<OrganizationDto?> GetOrganizationByIdAsync(long id);
         Task<long?> GetContainingOrganizationId(Point point);
         Task<StrRequirementsDto?> GetStrRequirements(double longitude, double latitude);
+        Task<PagedDto<PlatformViewDto>> GetPlatforms(int pageSize, int pageNumber, string orderBy, string direction);
     }
     public class OrganizationService : ServiceBase, IOrganizationService
     {
@@ -59,5 +60,10 @@ public async Task<List<DropdownNumDto>> GetOrganizationsDropdownAsync(string? ty
         {
             return await _orgRepo.GetStrRequirements(longitude, latitude);
         }
+
+        public async Task<PagedDto<PlatformViewDto>> GetPlatforms(int pageSize, int pageNumber, string orderBy, string direction)
+        {
+            return await _orgRepo.GetPlatforms(pageSize, pageNumber, orderBy, direction);
+        }
     }
 }