103 lines
3.8 KiB
C#
103 lines
3.8 KiB
C#
namespace Microsoft.eShopOnContainers.Services.Ordering.API.Application.Queries
|
|
{
|
|
using Dapper;
|
|
using Microsoft.Extensions.Configuration;
|
|
using System.Data.SqlClient;
|
|
using System.Threading.Tasks;
|
|
using System;
|
|
using System.Dynamic;
|
|
using System.Collections.Generic;
|
|
|
|
public class OrderQueries
|
|
:IOrderQueries
|
|
{
|
|
private string _connectionString = string.Empty;
|
|
|
|
public OrderQueries(string constr)
|
|
{
|
|
_connectionString = !string.IsNullOrWhiteSpace(constr) ? constr : throw new ArgumentNullException(nameof(constr));
|
|
}
|
|
|
|
|
|
public async Task<dynamic> GetOrderAsync(int id)
|
|
{
|
|
using (var connection = new SqlConnection(_connectionString))
|
|
{
|
|
connection.Open();
|
|
|
|
var result = await connection.QueryAsync<dynamic>(
|
|
@"select o.[Id] as ordernumber,o.OrderDate as date, o.Description as description, os.Name as status,
|
|
oi.ProductName as productname, oi.Units as units, oi.UnitPrice as unitprice, oi.PictureUrl as pictureurl,
|
|
a.Street as street, a.City as city, a.Country as country, a.State as state, a.ZipCode as zipcode
|
|
FROM ordering.Orders o
|
|
INNER JOIN ordering.Address a ON o.AddressId = a.Id
|
|
LEFT JOIN ordering.Orderitems oi ON o.Id = oi.orderid
|
|
LEFT JOIN ordering.orderstatus os on o.OrderStatusId = os.Id
|
|
WHERE o.Id=@id"
|
|
, new { id }
|
|
);
|
|
|
|
if (result.AsList().Count == 0)
|
|
throw new KeyNotFoundException();
|
|
|
|
return MapOrderItems(result);
|
|
}
|
|
}
|
|
|
|
public async Task<IEnumerable<dynamic>> GetOrdersAsync()
|
|
{
|
|
using (var connection = new SqlConnection(_connectionString))
|
|
{
|
|
connection.Open();
|
|
|
|
return await connection.QueryAsync<dynamic>(@"SELECT o.[Id] as ordernumber,o.[OrderDate] as [date],os.[Name] as [status],SUM(oi.units*oi.unitprice) as total
|
|
FROM [ordering].[Orders] o
|
|
LEFT JOIN[ordering].[orderitems] oi ON o.Id = oi.orderid
|
|
LEFT JOIN[ordering].[orderstatus] os on o.OrderStatusId = os.Id
|
|
GROUP BY o.[Id], o.[OrderDate], os.[Name]");
|
|
}
|
|
}
|
|
|
|
public async Task<IEnumerable<dynamic>> GetCardTypesAsync()
|
|
{
|
|
using (var connection = new SqlConnection(_connectionString))
|
|
{
|
|
connection.Open();
|
|
|
|
return await connection.QueryAsync<dynamic>("SELECT * FROM ordering.cardtypes");
|
|
}
|
|
}
|
|
|
|
private dynamic MapOrderItems(dynamic result)
|
|
{
|
|
dynamic order = new ExpandoObject();
|
|
|
|
order.ordernumber = result[0].ordernumber;
|
|
order.date = result[0].date;
|
|
order.status = result[0].status;
|
|
order.description = result[0].description;
|
|
order.street = result[0].street;
|
|
order.city = result[0].city;
|
|
order.zipcode = result[0].zipcode;
|
|
order.country = result[0].country;
|
|
|
|
order.orderitems = new List<dynamic>();
|
|
order.total = 0;
|
|
|
|
foreach (dynamic item in result)
|
|
{
|
|
dynamic orderitem = new ExpandoObject();
|
|
orderitem.productname = item.productname;
|
|
orderitem.units = item.units;
|
|
orderitem.unitprice = item.unitprice;
|
|
orderitem.pictureurl = item.pictureurl;
|
|
|
|
order.total += item.units * item.unitprice;
|
|
order.orderitems.Add(orderitem);
|
|
}
|
|
|
|
return order;
|
|
}
|
|
}
|
|
}
|