Files
ASP.NET/ProjectOrientedSessions/Session08/Session08 Backend.md
T
AminandGitHub ffaff64666 Update Session08 Backend.md
updated the part about getting travels
2025-07-01 16:23:10 +03:30

15 KiB
Raw Blame History

Session 8

Profile + some fixes to database

Fixes

  • Check for missing .ValueGeneratedOnAdd() in all entity configurations in Infrastructure/Configurations.

  • Adjust the database setup according to the second version of ERD

    • Some aggregates are added/modified to generate the new database

    • New ERD: Here

    • Note: Pay attention to the changes in logic and implementation of Person table (Id number is not unique anymore). So remove this code in PersonConfiguration:

      builder.HasIndex(p => p.IdNumber)
          .IsUnique();
      
  • Add actual data in TicketStatus, Gender, TransactionTypes

    • You can either add the data in DbContext or the database itself
  • Add data in Seat, Person, TicketOrder, Transaction, Ticket for test. It is recommended to write python code for generating data for Seat table, according to the data already stored in Transportation and related Vehicle data. There is also a SeatGenerator in this repository, as well.

  • Fix claim extraction (sub → standardize JWT claim mapping). (IUserContext implmentation)

First, create an interface in Application layer:

public interface IUserContext
{
long GetUserId();
}

Then, implement it in WebAPI in Auth folder:

public class UserContext : IUserContext
{
    private readonly IHttpContextAccessor _httpContextAccessor;

    public UserContext(IHttpContextAccessor httpContextAccessor)
    {
        _httpContextAccessor = httpContextAccessor;
    }

    public long GetUserId()
    {
        var userIdStr = _httpContextAccessor.HttpContext?.User?.FindFirst(ClaimTypes.NameIdentifier)?.Value;
        if (long.TryParse(userIdStr, out var userId))
        {
            return userId;
        }
        throw new InvalidOperationException("User ID is not available or invalid.");
    }
}

Finally, register things in Program.cs

// register user context
builder.Services.AddHttpContextAccessor();
builder.Services.AddScoped<IUserContext, UserContext>();

Profile Page (Account Info Tab)

  • Create ProfileDto to represent combined data for account, person, bank detail, balance.
public class ProfileDto
{
    // from account
    public string AccountPhoneNumber { get; set; }
    public string Email { get; set; }
    public decimal Balance { get; set; }

    // from person
    public string FirstName { get; set; }
    public string LastName { get; set; }
    public string IdNumber { get; set; }
    public string PersonPhoneNumber { get; set; }
    public DateTime? BirthDate { get; set; }

    // from bank-account
    public string IBAN { get; set; }
    public string BankAccountNumber { get; set; }
    public int CardNumber { get; set; }
}

You can also find another version of this DTO in Here

  • Add GetProfileAsync in AccountRepository and expose via AccountController.

    • First, map dto to aggregate
    CreateMap<Account, ProfileDto>()
    .ForMember(dest => dest.PhoneNumber, opt => opt.MapFrom(src => src.PhoneNumber))
    .ForMember(dest => dest.Email, opt => opt.MapFrom(src => src.Email))
    .ForMember(dest => dest.Balance, opt => opt.MapFrom(src => src.Balance))
    .ForMember(dest => dest.FirstName, opt => opt.MapFrom(src => src.Person != null ? src.Person.FirstName : ""))
    .ForMember(dest => dest.LastName, opt => opt.MapFrom(src => src.Person != null ? src.Person.LastName : ""))
    .ForMember(dest => dest.IdNumber, opt => opt.MapFrom(src => src.Person != null ? src.Person.IdNumber : ""))
    .ForMember(dest => dest.BirthDate, opt => opt.MapFrom(src => src.Person != null ? src.Person.BirthDate : (DateTime?) null))
    .ForMember(dest => dest.IBAN, opt => opt.MapFrom(src => src.BankAccount != null ? src.BankAccount.IBAN : ""))
    .ForMember(dest => dest.BankAccountNumber, opt => opt.MapFrom(src => src.BankAccount != null ? src.BankAccount.BankAccountNumber : ""))
    .ForMember(dest => dest.CardNumber, opt => opt.MapFrom(src => src.BankAccount != null ? src.BankAccount.CardNumber : ""));
    
    • Then, add the equivalent methods for AccountRepository, AccountService and AccountController
    public class AccountRepository : BaseRepository<AlibabaDbContext, Account, long>, IAccountRepository
    {
        public AccountRepository(AlibabaDbContext context) : base(context)
        {
    
        }
    
        public async Task<Account> GetByPhoneNumberAsync(string phoneNumber)
        {
    	    var user = await DbSet.Include(a => a.AccountRoles).ThenInclude(x => x.Role).FirstOrDefaultAsync(x => x.PhoneNumber == phoneNumber);
    	    return user;
        }
    
        public async Task<Account> GetProfileAsync(long accountId)
        {
            var profile = await DbSet
                .Include(a => a.Person)
                .Include(a => a.BankAccount)
                .FirstOrDefaultAsync(a => a.Id == accountId);
    
            return profile;
        }
    }
    
    
    public class AccountService : IAccountService
    {
        private readonly IAccountRepository _accountRepository;
        private readonly IMapper _mapper;
    
        public async Task<Result<ProfileDto>> GetProfileAsync(long accountId)
        {
            var result = await _accountRepository.GetProfileAsync(accountId);
            if (result == null)
            {
                return Result<ProfileDto>.NotFound(null);
            }
    
            return Result<ProfileDto>.Success(_mapper.Map<ProfileDto>(result));
        }
    }
    
    [ApiController]
    [Route("api/[controller]")]
    public class AccountController : ControllerBase
    {
        private readonly IUserContext _userContext;
        private readonly IAccountService _accountService;
    
        public AccountController(IUserContext userContext, IAccountService accountService)
        {
            _userContext = userContext;
            _accountService = accountService;
        }
    
        [HttpGet("profile")]
        public async Task<IActionResult> GetProfile()
        {
            // get account-id from token
            long userId = _userContext.GetUserId();
            // check for user-id to be valid
            if (userId <= 0)
            {
                return Unauthorized();
            }
    
            var result = await _accountService.GetProfileAsync(userId);
            if (result.IsSuccess)
            {
                return Ok(result.Data);
            }
    
            return result.Status switch
            {
                ResultStatus.Unauthorized => Unauthorized(result.ErrorMessage),
                ResultStatus.NotFound => NotFound(result.ErrorMessage),
                ResultStatus.ValidationError => BadRequest(result.ErrorMessage),
                _ => StatusCode(500, result.ErrorMessage)
            };
        }
    }
    

    Note: You should add neccessary interfaces and implement them

  • Implement:

    • Edit Email (with validation): EditEmailDto, service method, and controller endpoint.
    public class EditEmailDto
    {
        [EmailAddress(ErrorMessage = "Invalid email address format")]
        public string NewEmail { get; set; }
    }
    
    • Edit Password: EditPasswordDto, service and controller.
    public class EditPasswordDto
    {
        [Required(ErrorMessage = "Old password is required")]
        public string OldPassword { get; set; }
    
        [Required(ErrorMessage = "New password is required")]
        [MinLength(8, ErrorMessage = "At least 8 chars")]
        public string NewPassword { get; set; }
    
        [Compare("Password", ErrorMessage = "Password doesn't match")]
        public string ConfirmNewPassword { get; set; }
    }
    
    • Edit Person Info: PersonDto, and endpoint to upsert personal data.
    public class PersonDto
    {
        public long Id { get; set; }
        public long CreatorId { get; set; }
    
        [Required(ErrorMessage = "Firstname is required")]
        public string FirstName { get; set; }
    
        [Required(ErrorMessage = "Lastname is required")]
        public string LastName { get; set; }
    
        [Required(ErrorMessage = "National Id number is required")]
        [RegularExpression(@"^\d{10}$", ErrorMessage = "National ID number must be exactly 10 digits")]
        public string IdNumber { get; set; }
    
        [Required(ErrorMessage = "Gender is required")]
        public short GenderId { get; set; }
    
        [Required(ErrorMessage = "Phone number is required")]
        public string PhoneNumber { get; set; }
    
        [Required(ErrorMessage = "Birth date is required")]
        public DateTime BirthDate { get; set; }
    }
    
    • Edit BankAccountDetail: UpsertBankAccountDetailDto and relevant logic.
    public class UpsertBankAccountDto
    {
        [MinLength(24)]
        [MaxLength(24)]
        public string? IBAN { get; set; }
    
        [MinLength(16)]
        [MaxLength(16)]
        public string? CardNumber { get; set; }
    
        [MinLength(8)]
        public string? BankAccountNumber { get; set; }
    }
    
  • Add mapping for all Dtos and check related properties like CreatorAccountId.

List of Travelers

  • Add GetMyPeople endpoint in AccountController. To do so, first add essential methods in PersonRepository, AccountService and related interfaces.

  • Implement UpsertAccountPerson and UpsertPerson. Note that they should be considered separated.

public async Task<Result<long>> UpsertAccountPersonAsync(long accountId, PersonDto dto)
{
    var account = await _accountRepository.GetByIdAsync(accountId);
    if (account == null)
    {
        throw new Exception("Account not found");
    }
    
    // if account is not null, update its person
    Person person;
    if (account.PersonId.HasValue)
    {
        person = await _personRepository.GetByIdAsync(account.PersonId.Value);
        if (person == null)
        {
            return Result<long>.Error(0, "No person found for this account");
        }

        _mapper.Map(dto, person);
        person.CreatorId = account.Id;
        person.Id = account.PersonId.Value;
        _personRepository.Update(person);
    }
    else
    {
        person = _mapper.Map<Person>(dto);
        person.CreatorId = account.Id;
        await _personRepository.InsertAsync(person);
    }
    await _unitOfWork.CompleteAsync();

    account.PersonId = person.Id;
    _accountRepository.Update(account);
    await _unitOfWork.CompleteAsync();

    return Result<long>.Success(person.Id);
}

public async Task<Result<long>> UpsertPersonAsync(long accountId, PersonDto dto)
{
    var account = await _accountRepository.GetByIdAsync(accountId);
    if (account == null)
    {
        throw new Exception("Account not found");
    }

    Person person = (await _personRepository.FindAsync(p => p.IdNumber == dto.IdNumber && p.CreatorId == accountId)).FirstOrDefault();
    if (person != null)
    {
        if (dto.Id > 0 && dto.Id != person.Id)
        {
            return Result<long>.Error(0, "A person with this id number exists");
        }
        _mapper.Map(dto, person);
        person.CreatorId = accountId;
        _personRepository.Update(person);
    }
    else
    {
        person = _mapper.Map<Person>(dto);
        person.CreatorId = accountId;
        await _personRepository.InsertAsync(person);
    }
    await _unitOfWork.CompleteAsync();

    return Result<long>.Success(person.Id);
}
[HttpPost("account-person")]
public async Task<IActionResult> UpsertAccountPerson([FromBody] PersonDto dto)
{
    long accountId = _userContext.GetUserId();
    if (accountId <= 0)
    {
        return Unauthorized();
    }

    var result = await _personService.UpsertAccountPersonAsync(accountId, dto);
    return result.Status switch
    {
        ResultStatus.Success => NoContent(),
        ResultStatus.Unauthorized => Unauthorized(result.ErrorMessage),
        ResultStatus.NotFound => NotFound(result.ErrorMessage),
        ResultStatus.ValidationError => BadRequest(result.ErrorMessage),
        _ => StatusCode(500, result.ErrorMessage)
    };
}

[HttpPost("person")]
public async Task<IActionResult> UpsertPerson([FromBody] PersonDto dto)
{
    long accountId = _userContext.GetUserId();
    if (accountId <= 0)
    {
        return Unauthorized();
    }

    var result = await _personService.UpsertPersonAsync(accountId, dto);
    return result.Status switch
    {
        ResultStatus.Success => NoContent(),
        ResultStatus.Unauthorized => Unauthorized(result.ErrorMessage),
        ResultStatus.NotFound => NotFound(result.ErrorMessage),
        ResultStatus.ValidationError => BadRequest(result.ErrorMessage),
        _ => StatusCode(500, result.ErrorMessage)
    };
}

My Travels Tab

  • Create TicketOrderSummaryDto (includes cities, vehicle name, price, etc.).
public class TicketOrderSummaryDto
{
    public long Id { get; set; }
    public string SerialNumber { get; set; }
    public DateTime BoughtAt { get; set; }

    // transaction
    public decimal Price { get; set; }

    // transportation
    public DateTime TravelStartDate { get; set; }
    public DateTime? TravelEndDate { get; set; }

    // city
    public string FromCity { get; set; }
    public string ToCity { get; set; }

    // company
    public string CompanyName { get; set; }

    // vehicle data
    public short VehicleTypeId { get; set; }
    public string VehicleName { get; set; }
}
  • Add GetTravels in AccountService, and expose GetMyTravels in controller.

First, update interfaces and TicketOrderRepository, add the mappings and then go for the other things

In AccountService:

public async Task<Result<List<TicketOrderSummaryDto>>> GetTravelsAsync(long accountId)
{
    var result = await _ticketOrderRepository.GetAllByBuyerId(accountId);
    if (result == null)
    {
        return Result<List<TicketOrderSummaryDto>>.NotFound(null);
    }

    return Result<List<TicketOrderSummaryDto>>.Success(_mapper.Map<List<TicketOrderSummaryDto>>(result));
}

In AccountController:

[HttpGet("my-travels")]
public async Task<IActionResult> GetMyTravels()
{
    long buyerId = _userContext.GetUserId();
    if (buyerId <= 0)
    {
        return Unauthorized();
    }

    var result =  await _accountService.GetTravelsAsync(buyerId);
    if (result.IsSuccess)
    {
        return Ok(result.Data);
    }

    return result.Status switch
    {
        ResultStatus.Unauthorized => Unauthorized(result.ErrorMessage),
        ResultStatus.NotFound => NotFound(result.ErrorMessage),
        ResultStatus.ValidationError => BadRequest(result.ErrorMessage),
        _ => StatusCode(500, result.ErrorMessage)
    };
}

My Transactions Tab

  • Create TransactionDto and mapping.
  • Add method to get transactions by AccountId.
  • Expose GetMyTransactions in AccountController.
  • Add modal to simulate balance top-up (manual input).
  • Format amount text based on transaction type: green (+) for income, red () for expense.