BallOfMud.cs

public class OrderProcessingModule
{
	public void Process(OrderStatusMessage orderStatusMessage)
	{
		string connectionString = ConfigurationManager.ConnectionStrings["Main"].ConnectionString;
		Order order = null;

		using(var connection = new SqlConnection(connectionString))
		{
			order = FetchData(orderStatusMessage, connection);
		}

		if(order.IsInterational)
		{
			ProcessInternationalOrder(order);
		}
		else if(order.LineItems.Count() > 10)
		{
			ProcessLargeDomesticOrder(order);
		}
		else
		{
			ProcessRegularDomesticOrder(order);
		}

		if(order.IsReadyToShip())
		{
			var gateway = new ShippingGateway();
			var message = CreateShipmentMessageForOrder(order);
			gateway.SendShipment(message);
		}
	}

	private ShipmentMessage CreateShipmentMessageForOrder(Order order)
	{
		throw new NotImplementedException();
	}

	private Order FetchData(OrderStatusMessage orderStatusMessage, SqlConnection connection)
	{
		using(var cmd = connection.CreateCommand())
		{
			cmd.CommandText = "SELECT * FROM Order WHERE OrderId = @OrderId";
			cmd.Parameters.AddWithValue("@OrderId", orderStatusMessage.OrderId);

			using(var reader = cmd.ExecuteReader())
			{
				if (!reader.NextResult())
				{
					return null;
				}

				var order = new Order();
				order.OrderId = reader.GetInt32(reader.GetOrdinal("OrderId"));

				return order;
			}
		}
	}

	private void ProcessInternationalOrder(Order order)
	{
		
	}

	private void ProcessLargeDomesticOrder(Order order)
	{
		
	}

	private void ProcessRegularDomesticOrder(Order order)
	{
		
	}
}