Shuhan Jin-homework with adult step commit

ParkingLotApi/Controllers/ParkingLotsController.cs

@@ -0,0 +1,81 @@
+using Microsoft.AspNetCore.Mvc;
+using ParkingLotApi.Dtos;
+using ParkingLotApi.Exceptions;
+using ParkingLotApi.Models;
+using ParkingLotApi.Services;
+
+namespace ParkingLotApi.Controllers
+{
+    [ApiController]
+    [Route("[controller]")] //Ĭ��ParkingLotsController��controllerǰ����ַ���·��
+    public class ParkingLotsController : ControllerBase
+    {
+        private readonly ParkingLotsService _parkingLotsService;
+        public ParkingLotsController(ParkingLotsService parkingLotsService) //��ParkingLotsServiceע�빹�캯��
+        {
+            _parkingLotsService = parkingLotsService;
+        }
+
+        [HttpPost]
+        public async Task<ActionResult<ParkingLotDto>> AddParkingLotAsync([FromBody] ParkingLotDto parkingLotDto)
+        {
+            //try
+            //{
+            return StatusCode(StatusCodes.Status201Created, await _parkingLotsService.AddAsync(parkingLotDto));
+            //}
+            //catch (InvalidCapacityException ex)
+            //{
+            //    return BadRequest();
+            //}
+
+            //if (parkingLotDto.Capacity < 10)
+            //{
+            //    return BadRequest();
+            //}
+            // return null;
+        }
+
+        [HttpDelete]
+        public async Task<ActionResult> DeleteParkingLotAsync(string id)
+        {
+            await _parkingLotsService.DeleteAsync(id);
+            return NoContent();
+        }
+
+        [HttpGet]
+        public async Task<ActionResult<List<ParkingLot>>> GetOnePageAsync([FromQuery] int? pageIndex)
+        {
+            if (pageIndex == null)
+            {
+                pageIndex = 1;
+                return Ok(await _parkingLotsService.GetOnePageAsync((int)pageIndex));
+            }
+            else
+            {
+                return Ok(await _parkingLotsService.GetOnePageAsync((int)pageIndex));
+            }
+        }
+
+        [HttpGet("{id}")]
+        public async Task<ActionResult> GetParkingLotByIdAsync(string id)
+        {
+            var parkingLot = await _parkingLotsService.GetByIdAsync(id);
+            if (parkingLot == null)
+            {
+                return NotFound();
+            }
+            return Ok(parkingLot);
+        }
+
+        [HttpPut("{id}")]
+        public async Task<ActionResult> GetParkingLotByIdAsync(string id, int capacity)
+        {
+            var updatedParkingLot = await _parkingLotsService.UpdateParkingLotCapacityAsync(capacity, id);
+            if (updatedParkingLot == null)
+            {
+                return NotFound();
+            }
+            return Ok(updatedParkingLot);
+        }
+    }
+}

ParkingLotApi/Dtos/ParkingLotDto.cs

@@ -0,0 +1,20 @@
+using ParkingLotApi.Models;
+
+namespace ParkingLotApi.Dtos;
+
+public class ParkingLotDto
+{
+    public string Name { get; set; } //ctrl+d自动向下复制一行
+    public int Capacity { get; set; }
+    public string Location { get; set; }
+
+    internal ParkingLot ToEntity()
+    {
+        return new ParkingLot()
+        {
+            Name = Name,
+            Capacity = Capacity,
+            Location = Location
+        };
+    }
+}

ParkingLotApi/Exceptions/InvalidCapacityException.cs

@@ -0,0 +1,7 @@
+namespace ParkingLotApi.Exceptions
+{
+    public class InvalidCapacityException : Exception
+    {
+
+    }
+}

ParkingLotApi/Filters/InvalidCapacityExceptionFilter.cs

@@ -0,0 +1,24 @@
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.AspNetCore.Mvc.Filters;
+using ParkingLotApi.Exceptions;
+
+namespace ParkingLotApi.Filters
+{
+    public class InvalidCapacityExceptionFilter : IActionFilter, IOrderedFilter
+    {
+        int IOrderedFilter.Order => int.MaxValue - 10;
+
+        void IActionFilter.OnActionExecuted(ActionExecutedContext context) //excute when controller method return
+        {
+            if (context.Exception is InvalidCapacityException invalidCapacityException)
+            {
+                context.Result = new BadRequestResult();
+                context.ExceptionHandled = true;
+            }
+        }
+
+        void IActionFilter.OnActionExecuting(ActionExecutingContext context) //excute before controller method run
+        {
+        }
+    }
+}

ParkingLotApi/Models/ParkingLot.cs

@@ -0,0 +1,16 @@
+using MongoDB.Bson;
+using MongoDB.Bson.Serialization.Attributes;
+
+namespace ParkingLotApi.Models
+{
+    public class ParkingLot
+    {
+        [BsonId]
+        [BsonRepresentation(BsonType.ObjectId)]
+        public string? Id { get; set; }
+
+        public string Name { get; set; }
+        public int Capacity { get; set; }
+        public string Location { get; set; }
+    }
+}

ParkingLotApi/Models/ParkingLotDatabaseSettings.cs

@@ -0,0 +1,9 @@
+namespace ParkingLotApi.Models
+{
+    public class ParkingLotDatabaseSettings
+    {
+        public string ConnectionString { get; set; } = null!;
+        public string DatabaseName { get; set; } = null!;
+        public string CollectionName { get; set; } = null!;
+    }
+}

ParkingLotApi/ParkingLotApi.csproj

@@ -8,6 +8,8 @@
 
   <ItemGroup>
     <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="7.0.13" />
+    <PackageReference Include="MongoDB.Bson" Version="2.22.0" />
+    <PackageReference Include="MongoDB.Driver" Version="2.22.0" />
     <PackageReference Include="Swashbuckle.AspNetCore" Version="6.5.0" />
   </ItemGroup>
 

ParkingLotApi/Program.cs

@@ -1,16 +1,29 @@
+using ParkingLotApi.Exceptions;
+using ParkingLotApi.Filters;
+using ParkingLotApi.Models;
+using ParkingLotApi.Repository;
+using ParkingLotApi.Services;
+
 var builder = WebApplication.CreateBuilder(args);
 
 // Add services to the container.
 
-builder.Services.AddControllers();
+builder.Services.AddControllers(options =>
+{
+    options.Filters.Add<InvalidCapacityExceptionFilter>(); //inject filter in program
+});
 // Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
 builder.Services.AddEndpointsApiExplorer();
 builder.Services.AddSwaggerGen();
+builder.Services.AddScoped<ParkingLotsService>();
+builder.Services.AddSingleton<IParkingLotsRepository, ParkingLotsRepository>(); //singleton bc ϣ��ֻ��һ������
+builder.Services.Configure<ParkingLotDatabaseSettings>
+    (builder.Configuration.GetSection("ParkingLotStoreDatabase")); //ParkingLotStoreDatabase is defined in appsettings.json
 
 var app = builder.Build();
 
 // Configure the HTTP request pipeline.
-if (app.Environment.IsDevelopment())
+if (app.Environment.IsDevelopment()) //only open swagger under development enviroment
 {
     app.UseSwagger();
     app.UseSwaggerUI();
@@ -22,4 +35,6 @@
 
 app.MapControllers();
 
-app.Run();
+app.Run();
+
+public partial class Program { } //or add StartUp.cs

ParkingLotApi/Repository/IParkingLotsRepository.cs

@@ -0,0 +1,13 @@
+using ParkingLotApi.Models;
+
+namespace ParkingLotApi.Repository
+{
+    public interface IParkingLotsRepository
+    {
+        Task<ParkingLot> CreateParkingLot(ParkingLot parkingLot);
+        Task DeleteParkingLot(string ParkingLotId);
+        Task<List<ParkingLot>> GetAllParkingLots();
+        Task<ParkingLot> GetById(string ParkingLotId);
+        Task<ParkingLot> UpdateParkingLot(string ParkingLotId, ParkingLot updatedParkingLot);
+    }
+}

ParkingLotApi/Repository/ParkingLotsRepository.cs

@@ -0,0 +1,49 @@
+using Microsoft.Extensions.Options;
+using MongoDB.Driver;
+using ParkingLotApi.Models;
+
+namespace ParkingLotApi.Repository
+{
+    public class ParkingLotsRepository : IParkingLotsRepository //alt+enter implement members in interface
+
+    {
+        private readonly IMongoCollection<ParkingLot> _parkingLotCollection; //连mongodb数据库
+
+        public ParkingLotsRepository(IOptions<ParkingLotDatabaseSettings> parkingLotDatabaseSettings)
+        {
+            var mongoClient = new MongoClient(parkingLotDatabaseSettings.Value.ConnectionString); //connections tring连接到数据库url
+            var mongoDatabase = mongoClient.GetDatabase(parkingLotDatabaseSettings.Value.DatabaseName); //通过客户端连接相应数据库
+
+            _parkingLotCollection = mongoDatabase.GetCollection<ParkingLot>(parkingLotDatabaseSettings.Value.CollectionName); //用database取相应collection
+
+            //从数据存储的地方获取collection
+        }
+
+        public async Task<ParkingLot> CreateParkingLot(ParkingLot parkingLot) //repo是最底层的，所以用parkinglot,Dto是外界和controller的对象
+        {
+            await _parkingLotCollection.InsertOneAsync(parkingLot);
+            return await _parkingLotCollection.Find(a => a.Name == parkingLot.Name).FirstAsync(); //find created item by name
+        }
+
+        public async Task DeleteParkingLot(string ParkingLotId) //没有给return的值就不用return await
+        {
+            await _parkingLotCollection.DeleteOneAsync(p => p.Id == ParkingLotId);
+        }
+
+        public async Task<List<ParkingLot>> GetAllParkingLots()
+        {
+            return await _parkingLotCollection.Find(_ => true).ToListAsync();
+        }
+
+        public async Task<ParkingLot> GetById(string ParkingLotId)
+        {
+            return await _parkingLotCollection.Find(p => p.Id == ParkingLotId).FirstAsync();
+        }
+
+        public async Task<ParkingLot> UpdateParkingLot(string ParkingLotId, ParkingLot updatedParkingLot)
+        {
+            await _parkingLotCollection.ReplaceOneAsync(p => p.Id == ParkingLotId, updatedParkingLot);
+            return await GetById(ParkingLotId);
+        }
+    }
+}

ParkingLotApi/Services/ParkingLotsService.cs

@@ -0,0 +1,66 @@
+using ParkingLotApi.Dtos;
+using ParkingLotApi.Exceptions;
+using ParkingLotApi.Models;
+using ParkingLotApi.Repository;
+
+namespace ParkingLotApi.Services
+{
+    public class ParkingLotsService
+    {
+        private readonly IParkingLotsRepository parkingLotsRepository;
+        public ParkingLotsService(IParkingLotsRepository parkingLotsRepository)
+        {
+            this.parkingLotsRepository = parkingLotsRepository;
+        }
+
+        public async Task<ParkingLot> AddAsync(ParkingLotDto parkingLotDto) //Task<返回值的类型>
+        {
+            if (parkingLotDto.Capacity < 10)
+            {
+                throw new InvalidCapacityException();
+            }
+
+            return await parkingLotsRepository.CreateParkingLot(parkingLotDto.ToEntity());
+            //用外界传进来的dto，return parkinglot给repo
+        }
+
+        public async Task DeleteAsync(string parkingLotId)
+        {
+            await parkingLotsRepository.DeleteParkingLot(parkingLotId);
+        }
+
+        public async Task<List<ParkingLot>> GetOnePageAsync(int pageIndex)
+        {
+            List<ParkingLot> allParkingLots = await parkingLotsRepository.GetAllParkingLots();
+            int pageSize = 15;
+            int startIndex = (pageIndex - 1) * pageSize;
+            return allParkingLots.Skip(startIndex).Take(pageSize).ToList();
+        }
+
+        public async Task<ParkingLot> GetByIdAsync(string parkingLotId)
+        {
+            return await parkingLotsRepository.GetById(parkingLotId);
+        }
+
+        public async Task<ParkingLot> UpdateParkingLotCapacityAsync(int capacity, string parkingLotId)
+        {
+            if (capacity < 10)
+            {
+                throw new InvalidCapacityException();
+            }
+
+            var parkingLot = await parkingLotsRepository.GetById(parkingLotId);
+            var updatedParkingLot = new ParkingLot()
+            {
+                Capacity = capacity,
+                Id = parkingLot.Id,
+                Name = parkingLot.Name,
+                Location = parkingLot.Location
+            };
+
+            return await parkingLotsRepository.UpdateParkingLot(parkingLotId, updatedParkingLot);
+
+        }
+
+    }
+}

ParkingLotApi/appsettings.json

@@ -5,5 +5,11 @@
       "Microsoft.AspNetCore": "Warning"
     }
   },
-  "AllowedHosts": "*"
+  "AllowedHosts": "*",
+  "ParkingLotStoreDatabase": {
+    "ConnectionString": "mongodb://localhost:27017",
+    "DatabaseName": "ParkingLots",
+    "CollectionName": "ParkingLot"
+  }
 }
+