marco.pms.api/Marco.Pms.Services/Controllers/MarketController.cs

using AutoMapper;
using Marco.Pms.DataAccess.Data;
using Marco.Pms.Helpers.Utility;
using Marco.Pms.Model.Dtos.Util;
using Marco.Pms.Model.Mapper;
using Marco.Pms.Model.Master;
using Marco.Pms.Model.TenantModels;
using Marco.Pms.Model.Utilities;
using Marco.Pms.Model.ViewModels.Tenant;
using MarcoBMS.Services.Service;
using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore;

namespace Marco.Pms.Services.Controllers
{
    [Route("api/[controller]")]
    [ApiController]
    public class MarketController : ControllerBase
    {
        private readonly IDbContextFactory<ApplicationDbContext> _dbContextFactory;
        private readonly FeatureDetailsHelper _featureDetailsHelper;
        private readonly IServiceScopeFactory _serviceScopeFactory;
        private readonly IEmailSender _emailSender;
        private readonly IConfiguration _configuration;
        public MarketController(IDbContextFactory<ApplicationDbContext> dbContextFactory,
            IServiceScopeFactory serviceScopeFactory,
            IEmailSender emailSender,
            IConfiguration configuration,
            FeatureDetailsHelper featureDetailsHelper)
        {
            _dbContextFactory = dbContextFactory ?? throw new ArgumentNullException(nameof(dbContextFactory));
            _serviceScopeFactory = serviceScopeFactory ?? throw new ArgumentNullException(nameof(serviceScopeFactory));
            _emailSender = emailSender ?? throw new ArgumentNullException(nameof(emailSender));
            _configuration = configuration ?? throw new ArgumentNullException(nameof(configuration));
            _featureDetailsHelper = featureDetailsHelper ?? throw new ArgumentNullException(nameof(featureDetailsHelper));
        }

        [HttpGet]
        [Route("industries")]
        public async Task<IActionResult> GetIndustries()
        {
            await using var _context = await _dbContextFactory.CreateDbContextAsync();

            var industries = await _context.Industries.ToListAsync();

            return Ok(ApiResponse<object>.SuccessResponse(industries, "Success.", 200));
        }

        [HttpPost("enquire")]
        public async Task<IActionResult> RequestDemo([FromBody] InquiryDto inquiryDto)
        {
            await using var _context = await _dbContextFactory.CreateDbContextAsync();

            Inquiries inquiry = inquiryDto.ToInquiriesFromInquiriesDto();
            _context.Inquiries.Add(inquiry);
            await _context.SaveChangesAsync();

            Industry industry = await _context.Industries.FirstOrDefaultAsync(i => i.Id == inquiryDto.IndustryId) ?? new Industry();
            if (industry != null && industry.Name != null)
            {
                InquiryEmailObject inquiryEmailObject = inquiryDto.ToInquiryEmailObjectFromInquiriesDto(industry.Name);
                string emails = _configuration["MailingList:RequestDemoReceivers"] ?? "";
                List<string> result = emails
                    .Split(';', StringSplitOptions.RemoveEmptyEntries)
                    .Select(item => item.Trim())
                    .ToList();
                await _emailSender.SendRequestDemoEmail(result, inquiryEmailObject);
                return Ok(ApiResponse<object>.SuccessResponse(new { }, "Email sent.", 200));
            }
            return NotFound(ApiResponse<object>.ErrorResponse("Industry not found.", "Industry not found.", 404));
        }

        [HttpGet("list/subscription-plan")]
        public async Task<IActionResult> GetSubscriptionPlanList([FromQuery] PLAN_FREQUENCY? frequency)
        {
            using var scope = _serviceScopeFactory.CreateScope();

            var _logger = scope.ServiceProvider.GetRequiredService<ILoggingService>();
            var _mapper = scope.ServiceProvider.GetRequiredService<IMapper>();
            _logger.LogInfo("GetSubscriptionPlanList called with frequency: {Frequency}", frequency ?? PLAN_FREQUENCY.MONTHLY);

            // Initialize the list to store subscription plan view models
            List<SubscriptionPlanVM> detailsVM = new List<SubscriptionPlanVM>();

            try
            {
                // Create DbContext
                await using var _context = await _dbContextFactory.CreateDbContextAsync();

                // Load subscription plans with optional frequency filtering
                IQueryable<SubscriptionPlanDetails> query = _context.SubscriptionPlanDetails.Include(sp => sp.Plan).Include(sp => sp.Currency);

                if (frequency.HasValue)
                {
                    query = query.Where(sp => sp.Frequency == frequency.Value);
                    _logger.LogInfo("Filtering subscription plans by frequency: {Frequency}", frequency);
                }
                else
                {
                    _logger.LogInfo("Fetching all subscription plans without frequency filter");
                }

                var subscriptionPlans = await query.ToListAsync();

                // Map and fetch feature details for each subscription plan
                foreach (var subscriptionPlan in subscriptionPlans)
                {
                    var response = _mapper.Map<SubscriptionPlanVM>(subscriptionPlan);

                    try
                    {
                        response.Features = await _featureDetailsHelper.GetFeatureDetails(subscriptionPlan.FeaturesId);
                    }
                    catch (Exception exFeature)
                    {
                        _logger.LogError(exFeature, "Failed to fetch features for FeaturesId: {FeaturesId}", subscriptionPlan.FeaturesId);
                        response.Features = null; // or set to a default/fallback value
                    }

                    detailsVM.Add(response);
                }

                _logger.LogInfo("Successfully fetched {Count} subscription plans", detailsVM.Count);

                return Ok(ApiResponse<object>.SuccessResponse(detailsVM, "List of plans fetched successfully", 200));
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, "Error occurred while fetching subscription plans");
                return StatusCode(500, ApiResponse<object>.ErrorResponse("An error occurred while fetching subscription plans."));
            }
        }
    }
}