Skip to content

Commit e50eeb7

Browse files
PrimeTimeTranPrimeTimeTran
committedJun 2, 2023
Add Price Service
1 parent 1801fbe commit e50eeb7

File tree

14 files changed

+390
-34
lines changed

14 files changed

+390
-34
lines changed
 

‎API/Controllers/PriceController.cs

+93
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,93 @@
1+
using Microsoft.AspNetCore.Mvc;
2+
using Microsoft.AspNetCore.Authorization;
3+
using Common.Models;
4+
using Services.Interfaces;
5+
using System;
6+
7+
namespace API.Controllers
8+
{
9+
[Authorize]
10+
[ApiController]
11+
[Route("prices")]
12+
public class PriceController : ControllerBase
13+
{
14+
private readonly ILogger<PriceController> _logger;
15+
private readonly IPriceService _priceService;
16+
17+
public PriceController(ILogger<PriceController> logger, IPriceService priceService)
18+
{
19+
_logger = logger;
20+
_priceService = priceService;
21+
}
22+
23+
[HttpGet]
24+
public IActionResult GetAll()
25+
{
26+
try
27+
{
28+
var prices = _priceService.GetAll();
29+
return Ok(prices);
30+
}
31+
catch (Exception ex)
32+
{
33+
Console.WriteLine(ex.ToString()); // Output the exception details
34+
return StatusCode(500, "An error occurred while fetching prices.");
35+
}
36+
}
37+
38+
[HttpGet("{id}")]
39+
public IActionResult GetById(int id)
40+
{
41+
try
42+
{
43+
return Ok(_priceService.GetPriceById(id));
44+
}
45+
catch (KeyNotFoundException)
46+
{
47+
return NotFound();
48+
}
49+
}
50+
51+
[HttpPost]
52+
public IActionResult Create([FromBody] PriceDTO dto)
53+
{
54+
try
55+
{
56+
PriceDTO price = _priceService.Add(dto);
57+
return CreatedAtAction(nameof(GetById), new { id = price.Id }, price);
58+
}
59+
catch (Exception ex)
60+
{
61+
return StatusCode(500, "An error occurred while creating the price.");
62+
}
63+
}
64+
65+
[HttpPut("{id}")]
66+
public IActionResult Update(int id, [FromBody] PriceDTO dto)
67+
{
68+
try
69+
{
70+
PriceDTO price = _priceService.Update(id, dto);
71+
return Ok(price);
72+
}
73+
catch (KeyNotFoundException)
74+
{
75+
return NotFound();
76+
}
77+
}
78+
79+
[HttpDelete("{id}")]
80+
public IActionResult Delete(int id)
81+
{
82+
try
83+
{
84+
_priceService.Delete(id);
85+
return NoContent();
86+
}
87+
catch (KeyNotFoundException)
88+
{
89+
return NotFound();
90+
}
91+
}
92+
}
93+
}

‎API/Program.cs

+3
Original file line numberDiff line numberDiff line change
@@ -35,12 +35,15 @@
3535
});
3636

3737
builder.Services.AddScoped<IStockService, StockService>();
38+
builder.Services.AddScoped<IPriceService, PriceService>();
3839
builder.Services.AddScoped<IUnitOfWork, UnitOfWork>();
3940

4041
var mapperConfig = new MapperConfiguration(config =>
4142
{
4243
config.CreateMap<Stock, StockDTO>();
4344
config.CreateMap<StockDTO, Stock>();
45+
config.CreateMap<Price, PriceDTO>();
46+
config.CreateMap<PriceDTO, Price>();
4447
});
4548

4649
// Create an instance of IMapper using the configured mapper configuration

‎Common/Models/PriceDTO.cs

+36
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,36 @@
1+
namespace Common.Models;
2+
3+
public class PriceDTO
4+
{
5+
public int? Id { get; set; }
6+
public int? StockId { get; set; }
7+
public int? TransactionCount { get; set; }
8+
public DateTime? DateOfAggregation { get; set; }
9+
public decimal? o { get; set; } // open
10+
public decimal? l { get; set; } // low
11+
public decimal? h { get; set; } // high
12+
public decimal? c { get; set; } // close
13+
public decimal? v { get; set; } // volume
14+
public decimal? vwa { get; set; } // volume weighted average
15+
16+
// Parameterless constructor
17+
public PriceDTO()
18+
{
19+
}
20+
21+
public PriceDTO(int? id, int? stockId, int? transactionCount, DateTime? dateOfAggregation,
22+
decimal? open, decimal? low, decimal? high, decimal? close,
23+
decimal? volume, decimal? volumeWeightedAverage)
24+
{
25+
Id = id;
26+
StockId = stockId;
27+
TransactionCount = transactionCount;
28+
DateOfAggregation = dateOfAggregation;
29+
o = open;
30+
l = low;
31+
h = high;
32+
c = close;
33+
v = volume;
34+
vwa = volumeWeightedAverage;
35+
}
36+
}

‎DataAccess/Context/RSEContext.cs

+1
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@ namespace DataAccess.Context
66
public class RseContext : DbContext
77
{
88
public DbSet<Stock> Stocks { get; set; }
9+
public DbSet<Price> Prices { get; set; }
910
// Add DbSet properties for other entities
1011

1112
public RseContext(DbContextOptions<RseContext> options) : base(options)

‎DataAccess/Entities/Price.cs

+16
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
using System;
2+
3+
namespace DataAccess.Entities;
4+
public class Price
5+
{
6+
public int Id { get; set; }
7+
public int StockId { get; set; }
8+
public int TransactionCount { get; set; }
9+
public DateTime DateOfAggregation { get; set; }
10+
public decimal o { get; set; } // open
11+
public decimal l { get; set; } // lo
12+
public decimal h { get; set; } // hi
13+
public decimal c { get; set; } // close
14+
public decimal v { get; set; } // volume
15+
public decimal vwa { get; set; } // volume weighted average
16+
}

‎DataAccess/Repositories/IPriceRepository.cs

+15
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
using Common.Models;
2+
using DataAccess.Entities;
3+
using System.Collections.Generic;
4+
5+
namespace DataAccess.Repositories
6+
{
7+
public interface IPriceRepository
8+
{
9+
Price GetById(int id);
10+
IEnumerable<Price> GetAll();
11+
Price Add(PriceDTO price);
12+
Price Update(int id, PriceDTO price);
13+
void Delete(int id);
14+
}
15+
}

‎DataAccess/Repositories/PriceRepository.cs

+80
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,80 @@
1+
using AutoMapper;
2+
using DataAccess.Context;
3+
using DataAccess.Entities;
4+
using Common.Models;
5+
using System.Collections.Generic;
6+
using System.Linq;
7+
8+
namespace DataAccess.Repositories
9+
{
10+
public class PriceRepository : IPriceRepository
11+
{
12+
private readonly IMapper _mapper;
13+
private readonly RseContext _context;
14+
15+
public PriceRepository(RseContext context, IMapper mapper)
16+
{
17+
_mapper = mapper;
18+
_context = context;
19+
}
20+
21+
public IEnumerable<Price> GetAll()
22+
{
23+
var prices = _context.Prices;
24+
return prices;
25+
}
26+
27+
public Price GetById(int id)
28+
{
29+
return _context.Prices.FirstOrDefault(p => p.Id == id);
30+
}
31+
32+
public Price Add(PriceDTO priceDto)
33+
{
34+
Price price = _mapper.Map<Price>(priceDto);
35+
Price addedPrice = _context.Prices.Add(price).Entity;
36+
_context.SaveChanges();
37+
return addedPrice;
38+
}
39+
40+
public Price Update(int id, PriceDTO priceDto)
41+
{
42+
Price price = _context.Prices.Find(id);
43+
if (price == null)
44+
{
45+
// Handle not found scenario
46+
}
47+
48+
var priceProps = typeof(Price).GetProperties();
49+
var dtoProps = typeof(PriceDTO).GetProperties();
50+
51+
foreach (var prop in dtoProps)
52+
{
53+
if (prop.Name == "Id")
54+
continue;
55+
56+
var priceProp = priceProps.FirstOrDefault(p => p.Name == prop.Name);
57+
if (priceProp != null && prop.GetValue(priceDto) != null)
58+
{
59+
priceProp.SetValue(price, prop.GetValue(priceDto));
60+
}
61+
}
62+
63+
_context.SaveChanges();
64+
65+
return price;
66+
}
67+
68+
public void Delete(int id)
69+
{
70+
Price price = _context.Prices.Find(id);
71+
if (price == null)
72+
{
73+
// Handle not found scenario
74+
}
75+
76+
_context.Prices.Remove(price);
77+
_context.SaveChanges();
78+
}
79+
}
80+
}

‎DataAccess/UnitOfWork/IUnitOfWork.cs

+2
Original file line numberDiff line numberDiff line change
@@ -6,5 +6,7 @@ namespace DataAccess.UnitOfWork;
66
public interface IUnitOfWork : IDisposable
77
{
88
IStockRepository StockRepository { get; }
9+
IPriceRepository PriceRepository { get; }
10+
911
// void Save() {};
1012
}

‎DataAccess/UnitOfWork/UnitOfWork.cs

+14
Original file line numberDiff line numberDiff line change
@@ -9,12 +9,14 @@ public class UnitOfWork : IUnitOfWork
99
private readonly RseContext _context;
1010
private readonly IMapper _mapper;
1111
private IStockRepository _stockRepository;
12+
private IPriceRepository _priceRepository;
1213

1314
public UnitOfWork(RseContext context, IMapper mapper)
1415
{
1516
_mapper = mapper;
1617
_context = context;
1718
_stockRepository = new StockRepository(_context, _mapper);
19+
_priceRepository = new PriceRepository(_context, _mapper);
1820
}
1921

2022
public IStockRepository StockRepository
@@ -28,6 +30,18 @@ public IStockRepository StockRepository
2830
return _stockRepository;
2931
}
3032
}
33+
34+
public IPriceRepository PriceRepository
35+
{
36+
get
37+
{
38+
if (_priceRepository == null)
39+
{
40+
_priceRepository = new PriceRepository(_context, _mapper);
41+
}
42+
return _priceRepository;
43+
}
44+
}
3145

3246
public void Save()
3347
{

‎Queries/reset.sql

+65-31
Original file line numberDiff line numberDiff line change
@@ -1,37 +1,36 @@
1-
-- Cleanse
21
DROP TABLE IF EXISTS Users;
32
DROP TABLE IF EXISTS Stocks;
43
DROP TABLE IF EXISTS Orders;
54
DROP TABLE IF EXISTS Prices;
65

7-
-- Users
86
CREATE TABLE Users (
97
Id INT PRIMARY KEY IDENTITY(1, 1),
108
FName VARCHAR(255) NOT NULL,
11-
LName VARCHAR(255) NOT NULL
9+
LName VARCHAR(255) NOT NULL,
1210
);
1311

1412
INSERT INTO Users (FName, LName)
1513
VALUES
1614
('Loi', 'Tran'),
17-
('Thao', 'Tran');
15+
('Tai', 'Tran'),
16+
('Thao', 'Tran'),
17+
('Hieu', 'Tran'),
18+
('Doug', 'Tran');
1819

19-
-- Orders
2020
CREATE TABLE Orders (
2121
Expires DATETIME,
22-
Shares INT NOT NULL,
2322
UserId INT NOT NULL,
24-
StopPrice DECIMAL(10, 2),
23+
Shares INT NOT NULL,
2524
OrderableId INT NOT NULL,
25+
StopPrice DECIMAL(10, 2),
2626
Type VARCHAR(20) NOT NULL,
2727
LimitPrice DECIMAL(10, 2),
2828
Status VARCHAR(20) NOT NULL,
2929
Id INT PRIMARY KEY IDENTITY(1, 1),
30-
OrderType VARCHAR(10) NOT NULL CHECK (OrderType IN ('Buy', 'Sell'))
31-
OrderableType VARCHAR(10) NOT NULL CHECK (OrderableType IN ('Stock', 'Option', 'Bond')),
30+
OrderType VARCHAR(10) NOT NULL CHECK (OrderType IN ('Buy', 'Sell')),
31+
OrderableType VARCHAR(10) NOT NULL CHECK (OrderableType IN ('Stock', 'Option', 'Bond'))
3232
);
3333

34-
-- Stocks
3534
CREATE TABLE Stocks (
3635
Id INT PRIMARY KEY IDENTITY(1, 1),
3736
Name NVARCHAR(30),
@@ -40,39 +39,74 @@ CREATE TABLE Stocks (
4039
Symbol NVARCHAR(20)
4140
);
4241

43-
-- Seed Stocks Data
4442
INSERT INTO Stocks (Name, Price, Quantity, Symbol)
4543
VALUES
46-
('ABC Company', 150.00, 100, 'ABC'),
47-
('XYZ Corporation', 75.50, 50, 'XYZ'),
48-
('DEF Inc.', 120.25, 75, 'DEF');
44+
('AT&T', 15.81, 75, 'T'),
45+
('Coinbase', 64.21, 100, 'COIN'),
46+
('Bank of America', 28.5, 100, 'BAC');
4947

50-
-- Seed Orders Data
5148
INSERT INTO Orders (UserId, OrderableId, OrderableType, Status, Type, StopPrice, LimitPrice, Shares, Expires, OrderType)
5249
VALUES
5350
(1, 1, 'Stock', 'Filled', 'Buy', NULL, 100.00, 10, '2023-05-31 12:00:00', 'Buy'),
5451
(2, 2, 'Option', 'Non-filled', 'Limit', NULL, 50.00, 5, '2023-06-01 15:30:00', 'Buy'),
5552
(1, 3, 'Bond', 'Cancelled', 'Stop Loss', 70.00, NULL, 8, '2023-06-02 10:45:00', 'Buy');
5653

57-
-- Prices
54+
5855
CREATE TABLE Prices (
56+
Id INT PRIMARY KEY IDENTITY(1, 1),
5957
StockId INT NOT NULL,
60-
DailyPrice DECIMAL(18, 2),
61-
HourlyPrice DECIMAL(18, 2),
62-
WeeklyPrice DECIMAL(18, 2),
63-
YearlyPrice DECIMAL(18, 2),
64-
MonthlyPrice DECIMAL(18, 2),
65-
FiveYearsPrice DECIMAL(18, 2),
6658
TransactionCount INT NOT NULL,
67-
FiveMinutePrice DECIMAL(18, 2),
68-
Volume DECIMAL(18, 2) NOT NULL,
69-
ThreeMonthsPrice DECIMAL(18, 2),
70-
Id INT PRIMARY KEY IDENTITY(1, 1),
71-
LowPrice DECIMAL(18, 2) NOT NULL,
72-
OpenPrice DECIMAL(18, 2) NOT NULL,
73-
ClosePrice DECIMAL(18, 2) NOT NULL,
74-
HighPrice DECIMAL(18, 2) NOT NULL,
7559
DateOfAggregation DATETIME NOT NULL,
76-
VolumeWeightedAverage DECIMAL(18, 2) NOT NULL
60+
o DECIMAL(18, 2) NOT NULL, -- open
61+
l DECIMAL(18, 2) NOT NULL, -- lo
62+
h DECIMAL(18, 2) NOT NULL, -- hi
63+
c DECIMAL(18, 2) NOT NULL, -- close
64+
v DECIMAL(18, 2) NOT NULL, -- volume
65+
vwa DECIMAL(18, 2) NOT NULL -- volume weighted average
7766
);
7867

68+
DECLARE @count INT = 0;
69+
DECLARE @weekAgo DATETIME = GETDATE() - 7;
70+
71+
DECLARE @price DECIMAL(10, 2) = 27.00;
72+
DECLARE @open DECIMAL(10, 2) = @price;
73+
DECLARE @lo DECIMAL(10, 2) = 0.0;
74+
DECLARE @hi DECIMAL(10, 2) = 0.0;
75+
DECLARE @close DECIMAL(10, 2) = 0.0;
76+
77+
WHILE @count < 30
78+
BEGIN
79+
SET @price = @price -0.10 + (RAND() * (.10 - (-0.10)));
80+
SET @close = @price;
81+
82+
SET @lo = @price -0.05 + (RAND() * (-0.1));
83+
SET @hi = @price -0.05 + (RAND() * (.1));
84+
85+
INSERT INTO Prices (
86+
StockId,
87+
TransactionCount,
88+
DateOfAggregation,
89+
o,
90+
l,
91+
v,
92+
h,
93+
c,
94+
vwa
95+
)
96+
VALUES (
97+
1,
98+
100,
99+
@weekAgo,
100+
@open,
101+
CASE WHEN @open < @lo THEN @open ELSE @lo END,
102+
1000,
103+
CASE WHEN @close > @hi THEN @close ELSE @hi END,
104+
@close,
105+
140
106+
);
107+
108+
SET @open = @close;
109+
110+
SET @count = @count + 1;
111+
SET @weekAgo = DATEADD(HOUR, 1, @weekAgo);
112+
END;

‎Services/Interfaces/IPriceService.cs

+12
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
using Common.Models;
2+
using System.Collections.Generic;
3+
4+
namespace Services.Interfaces;
5+
public interface IPriceService
6+
{
7+
PriceDTO GetPriceById(int id);
8+
PriceDTO Add(PriceDTO priceDto);
9+
PriceDTO Update(int id, PriceDTO priceDto);
10+
void Delete(int id);
11+
IEnumerable<PriceDTO> GetAll();
12+
}

‎Services/Interfaces/IStockService.cs

-1
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
using Common.Models;
22
using DataAccess.Entities;
33

4-
54
namespace Services.Interfaces;
65
public interface IStockService
76
{

‎Services/MappingProfile.cs

+4-2
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,9 @@ public class MappingProfile : Profile
88
{
99
public MappingProfile()
1010
{
11-
CreateMap<Stock, StockDTO>(); // Map Stock entity to StockDTO
12-
CreateMap<StockDTO, Stock>(); // Map StockDTO to Stock entity
11+
CreateMap<Stock, StockDTO>();
12+
CreateMap<StockDTO, Stock>();
13+
CreateMap<Price, PriceDTO>();
14+
CreateMap<PriceDTO, Price>();
1315
}
1416
}

‎Services/Services/PriceService.cs

+49
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,49 @@
1+
using AutoMapper;
2+
using Common.Models;
3+
using DataAccess.UnitOfWork;
4+
using Services.Interfaces;
5+
6+
namespace Services.Services
7+
{
8+
public class PriceService : IPriceService
9+
{
10+
private readonly IMapper _mapper;
11+
private readonly IUnitOfWork _unitOfWork;
12+
13+
public PriceService(IUnitOfWork unitOfWork, IMapper mapper)
14+
{
15+
_mapper = mapper;
16+
_unitOfWork = unitOfWork;
17+
}
18+
19+
public PriceDTO GetPriceById(int id)
20+
{
21+
var price = _unitOfWork.PriceRepository.GetById(id);
22+
return _mapper.Map<PriceDTO>(price);
23+
}
24+
25+
public PriceDTO Add(PriceDTO priceDto)
26+
{
27+
var price = _unitOfWork.PriceRepository.Add(priceDto);
28+
return _mapper.Map<PriceDTO>(price);
29+
}
30+
31+
public PriceDTO Update(int id, PriceDTO priceDto)
32+
{
33+
var price = _unitOfWork.PriceRepository.Update(id, priceDto);
34+
return _mapper.Map<PriceDTO>(price);
35+
}
36+
37+
public void Delete(int id)
38+
{
39+
_unitOfWork.PriceRepository.Delete(id);
40+
}
41+
42+
public IEnumerable<PriceDTO> GetAll()
43+
{
44+
var prices = _unitOfWork.PriceRepository.GetAll();
45+
var priceDTOs = _mapper.Map<IEnumerable<PriceDTO>>(prices);
46+
return priceDTOs;
47+
}
48+
}
49+
}

0 commit comments

Comments
 (0)
Please sign in to comment.