108 lines
3.7 KiB
C#
Raw Normal View History

using MediatR;
2017-03-15 15:04:13 +01:00
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using Microsoft.eShopOnContainers.Services.Ordering.API.Application.Commands;
using Microsoft.eShopOnContainers.Services.Ordering.API.Application.Queries;
using Microsoft.eShopOnContainers.Services.Ordering.API.Infrastructure.Services;
using Ordering.API.Application.Commands;
using System;
using System.Collections.Generic;
using System.Net;
using System.Threading.Tasks;
namespace Microsoft.eShopOnContainers.Services.Ordering.API.Controllers
{
[Route("api/v1/[controller]")]
[Authorize]
public class OrdersController : Controller
{
private readonly IMediator _mediator;
private readonly IOrderQueries _orderQueries;
2016-12-22 13:20:12 +01:00
private readonly IIdentityService _identityService;
2016-12-22 13:20:12 +01:00
public OrdersController(IMediator mediator, IOrderQueries orderQueries, IIdentityService identityService)
{
2016-12-22 13:20:12 +01:00
_mediator = mediator ?? throw new ArgumentNullException(nameof(mediator));
_orderQueries = orderQueries ?? throw new ArgumentNullException(nameof(orderQueries));
_identityService = identityService ?? throw new ArgumentNullException(nameof(identityService));
}
[Route("cancel")]
[HttpPut]
[ProducesResponseType((int)HttpStatusCode.OK)]
[ProducesResponseType((int)HttpStatusCode.BadRequest)]
public async Task<IActionResult> CancelOrder([FromBody]CancelOrderCommand command, [FromHeader(Name = "x-requestid")] string requestId)
{
bool commandResult = false;
2017-03-03 12:03:31 +01:00
if (Guid.TryParse(requestId, out Guid guid) && guid != Guid.Empty)
{
var requestCancelOrder = new IdentifiedCommand<CancelOrderCommand, bool>(command, guid);
2017-06-12 13:52:23 +02:00
commandResult = await _mediator.Send(requestCancelOrder);
2017-03-03 12:03:31 +01:00
}
return commandResult ? (IActionResult)Ok() : (IActionResult)BadRequest();
}
[Route("ship")]
[HttpPut]
[ProducesResponseType((int)HttpStatusCode.OK)]
[ProducesResponseType((int)HttpStatusCode.BadRequest)]
public async Task<IActionResult> ShipOrder([FromBody]ShipOrderCommand command, [FromHeader(Name = "x-requestid")] string requestId)
{
bool commandResult = false;
if (Guid.TryParse(requestId, out Guid guid) && guid != Guid.Empty)
2017-03-03 12:10:30 +01:00
{
var requestShipOrder = new IdentifiedCommand<ShipOrderCommand, bool>(command, guid);
2017-06-12 13:52:23 +02:00
commandResult = await _mediator.Send(requestShipOrder);
2017-03-03 12:10:30 +01:00
}
return commandResult ? (IActionResult)Ok() : (IActionResult)BadRequest();
}
[Route("{orderId:int}")]
[HttpGet]
[ProducesResponseType((int)HttpStatusCode.OK)]
[ProducesResponseType((int)HttpStatusCode.NotFound)]
public async Task<IActionResult> GetOrder(int orderId)
{
try
{
2017-04-17 12:28:12 +02:00
var order = await _orderQueries
.GetOrderAsync(orderId);
return Ok(order);
}
catch (KeyNotFoundException)
{
return NotFound();
}
}
[Route("")]
[HttpGet]
public async Task<IActionResult> GetOrders()
{
var orderTask = _orderQueries.GetOrdersAsync();
var orders = await orderTask;
return Ok(orders);
}
[Route("cardtypes")]
[HttpGet]
public async Task<IActionResult> GetCardTypes()
{
2017-04-17 12:28:12 +02:00
var cardTypes = await _orderQueries
.GetCardTypesAsync();
return Ok(cardTypes);
2017-03-14 18:02:28 +01:00
}
}
}