Add cvrp_reload.py
This commit is contained in:
319
examples/python/cvrp_reload.py
Executable file
319
examples/python/cvrp_reload.py
Executable file
@@ -0,0 +1,319 @@
|
||||
#!/usr/bin/env python
|
||||
# This Python file uses the following encoding: utf-8
|
||||
# Copyright 2015 Tin Arm Engineering AB
|
||||
# Copyright 2018 Google LLC
|
||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
||||
# you may not use this file except in compliance with the License.
|
||||
# You may obtain a copy of the License at
|
||||
#
|
||||
# http://www.apache.org/licenses/LICENSE-2.0
|
||||
#
|
||||
# Unless required by applicable law or agreed to in writing, software
|
||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
# See the License for the specific language governing permissions and
|
||||
# limitations under the License.
|
||||
"""Capacitated Vehicle Routing Problem (CVRP).
|
||||
|
||||
This is a sample using the routing library python wrapper to solve a CVRP
|
||||
problem.
|
||||
A description of the problem can be found here:
|
||||
http://en.wikipedia.org/wiki/Vehicle_routing_problem.
|
||||
|
||||
Distances are in meters.
|
||||
"""
|
||||
|
||||
from __future__ import print_function
|
||||
from six.moves import xrange
|
||||
from ortools.constraint_solver import pywrapcp
|
||||
from ortools.constraint_solver import routing_enums_pb2
|
||||
|
||||
###########################
|
||||
# Problem Data Definition #
|
||||
###########################
|
||||
def create_data_model():
|
||||
"""Stores the data for the problem"""
|
||||
data = {}
|
||||
_capacity = 15
|
||||
# Locations in block unit
|
||||
_locations = [
|
||||
(4, 4), # depot
|
||||
(4, 4), # unload depot_prime
|
||||
(4, 4), # unload depot_second
|
||||
(4, 4), # unload depot_fourth
|
||||
(4, 4), # unload depot_fourth
|
||||
(4, 4), # unload depot_fifth
|
||||
(2, 0), (8, 0), # locations to visit
|
||||
(0, 1), (1, 1),
|
||||
(5, 2), (7, 2),
|
||||
(3, 3), (6, 3),
|
||||
(5, 5), (8, 5),
|
||||
(1, 6), (2, 6),
|
||||
(3, 7), (6, 7),
|
||||
(0, 8), (7, 8)]
|
||||
# Compute locations in meters using the block dimension defined as follow
|
||||
# Manhattan average block: 750ft x 264ft -> 228m x 80m
|
||||
# here we use: 114m x 80m city block
|
||||
# src: https://nyti.ms/2GDoRIe "NY Times: Know Your distance"
|
||||
data["locations"] = [(l[0] * 114, l[1] * 80) for l in _locations]
|
||||
data["num_locations"] = len(data["locations"])
|
||||
data["demands"] = \
|
||||
[0, # depot
|
||||
-_capacity,
|
||||
-_capacity,
|
||||
-_capacity,
|
||||
-_capacity,
|
||||
-_capacity,
|
||||
1, 1, # 1, 2
|
||||
2, 4, # 3, 4
|
||||
2, 4, # 5, 6
|
||||
8, 8, # 7, 8
|
||||
1, 2, # 9,10
|
||||
1, 2, # 11,12
|
||||
4, 4, # 13, 14
|
||||
8, 8] # 15, 16
|
||||
data["time_per_demand_unit"] = 5 # 5 minutes/unit
|
||||
data["time_windows"] = \
|
||||
[(0, 0), # depot
|
||||
(0, 1000),
|
||||
(0, 1000),
|
||||
(0, 1000),
|
||||
(0, 1000),
|
||||
(0, 1000),
|
||||
(75, 8500), (75, 8500), # 1, 2
|
||||
(60, 7000), (45, 5500), # 3, 4
|
||||
(0, 8000), (50, 6000), # 5, 6
|
||||
(0, 1000), (10, 2000), # 7, 8
|
||||
(0, 1000), (75, 8500), # 9, 10
|
||||
(85, 9500), (5, 1500), # 11, 12
|
||||
(15, 2500), (10, 2000), # 13, 14
|
||||
(45, 5500), (30, 4000)] # 15, 16
|
||||
data["num_vehicles"] = 3
|
||||
data["vehicle_capacity"] = _capacity
|
||||
data["vehicle_speed"] = 5*60/3.6 # Travel speed: 5km/h to convert in m/min
|
||||
data["depot"] = 0
|
||||
return data
|
||||
|
||||
#######################
|
||||
# Problem Constraints #
|
||||
#######################
|
||||
def manhattan_distance(position_1, position_2):
|
||||
"""Computes the Manhattan distance between two points"""
|
||||
return (
|
||||
abs(position_1[0] - position_2[0]) + abs(position_1[1] - position_2[1]))
|
||||
|
||||
def create_distance_evaluator(data):
|
||||
"""Creates callback to return distance between points."""
|
||||
_distances = {}
|
||||
# precompute distance between location to have distance callback in O(1)
|
||||
for from_node in xrange(data["num_locations"]):
|
||||
_distances[from_node] = {}
|
||||
for to_node in xrange(data["num_locations"]):
|
||||
if from_node == to_node:
|
||||
_distances[from_node][to_node] = 0
|
||||
else:
|
||||
_distances[from_node][to_node] = (
|
||||
manhattan_distance(data["locations"][from_node],
|
||||
data["locations"][to_node]))
|
||||
|
||||
def distance_evaluator(from_node, to_node):
|
||||
"""Returns the manhattan distance between the two nodes"""
|
||||
return _distances[from_node][to_node]
|
||||
|
||||
return distance_evaluator
|
||||
|
||||
def add_distance_dimension(routing, distance_evaluator):
|
||||
"""Add Global Span constraint"""
|
||||
distance = 'Distance'
|
||||
routing.AddDimension(
|
||||
distance_evaluator,
|
||||
0, # null slack
|
||||
10000, # maximum distance per vehicle
|
||||
True, # start cumul to zero
|
||||
distance)
|
||||
distance_dimension = routing.GetDimensionOrDie(distance)
|
||||
# Try to minimize the max distance among vehicles.
|
||||
# /!\ It doesn't mean the standard deviation is minimized
|
||||
distance_dimension.SetGlobalSpanCostCoefficient(100)
|
||||
|
||||
def create_demand_evaluator(data):
|
||||
"""Creates callback to get demands at each location."""
|
||||
_demands = data["demands"]
|
||||
|
||||
def demand_evaluator(from_node, to_node):
|
||||
"""Returns the demand of the current node"""
|
||||
del to_node
|
||||
return _demands[from_node]
|
||||
|
||||
return demand_evaluator
|
||||
|
||||
def add_capacity_constraints(routing, data, demand_evaluator):
|
||||
"""Adds capacity constraint"""
|
||||
vehicle_capacity = data["vehicle_capacity"]
|
||||
capacity = 'Capacity'
|
||||
routing.AddDimension(
|
||||
demand_evaluator,
|
||||
0, # Null slack
|
||||
vehicle_capacity,
|
||||
True, # start cumul to zero
|
||||
capacity)
|
||||
|
||||
# Add Slack for reseting to zero unload depot nodes.
|
||||
# e.g. vehicle with load 10/15 arrives at node 1 (depot unload)
|
||||
# so we have CumulVar = 10(current load) + -15(unload) + 5(slack) = 0.
|
||||
capacity_dimension = routing.GetDimensionOrDie(capacity)
|
||||
for node_index in [1, 2, 3, 4, 5]:
|
||||
index = routing.NodeToIndex(node_index)
|
||||
capacity_dimension.SlackVar(index).SetRange(0, vehicle_capacity)
|
||||
routing.AddDisjunction([node_index], 0)
|
||||
|
||||
def create_time_evaluator(data):
|
||||
"""Creates callback to get total times between locations."""
|
||||
def service_time(data, node):
|
||||
"""Gets the service time for the specified location."""
|
||||
return abs(data["demands"][node]) * data["time_per_demand_unit"]
|
||||
|
||||
def travel_time(data, from_node, to_node):
|
||||
"""Gets the travel times between two locations."""
|
||||
if from_node == to_node:
|
||||
travel_time = 0
|
||||
else:
|
||||
travel_time = manhattan_distance(
|
||||
data["locations"][from_node],
|
||||
data["locations"][to_node]) / data["vehicle_speed"]
|
||||
return travel_time
|
||||
|
||||
_total_time = {}
|
||||
# precompute total time to have time callback in O(1)
|
||||
for from_node in xrange(data["num_locations"]):
|
||||
_total_time[from_node] = {}
|
||||
for to_node in xrange(data["num_locations"]):
|
||||
if from_node == to_node:
|
||||
_total_time[from_node][to_node] = 0
|
||||
else:
|
||||
_total_time[from_node][to_node] = int(
|
||||
service_time(data, from_node) +
|
||||
travel_time(data, from_node, to_node))
|
||||
|
||||
def time_evaluator(from_node, to_node):
|
||||
"""Returns the total time between the two nodes"""
|
||||
return _total_time[from_node][to_node]
|
||||
|
||||
return time_evaluator
|
||||
|
||||
def add_time_window_constraints(routing, data, time_evaluator):
|
||||
"""Add Time windows constraint"""
|
||||
time = 'Time'
|
||||
horizon = 1500
|
||||
routing.AddDimension(
|
||||
time_evaluator,
|
||||
horizon, # allow waiting time
|
||||
horizon, # maximum time per vehicle
|
||||
False, # don't force start cumul to zero since we are giving TW to start nodes
|
||||
time)
|
||||
time_dimension = routing.GetDimensionOrDie(time)
|
||||
# Add time window constraints for each location except depot
|
||||
# and "copy" the slack var in the solution object (aka Assignment) to print it
|
||||
for location_idx, time_window in enumerate(data["time_windows"]):
|
||||
if location_idx == 0:
|
||||
continue
|
||||
index = routing.NodeToIndex(location_idx)
|
||||
time_dimension.CumulVar(index).SetRange(time_window[0], time_window[1])
|
||||
routing.AddToAssignment(time_dimension.SlackVar(index))
|
||||
# Add time window constraints for each vehicle start node
|
||||
# and "copy" the slack var in the solution object (aka Assignment) to print it
|
||||
for vehicle_id in xrange(data["num_vehicles"]):
|
||||
index = routing.Start(vehicle_id)
|
||||
time_dimension.CumulVar(index).SetRange(data["time_windows"][0][0],
|
||||
data["time_windows"][0][1])
|
||||
routing.AddToAssignment(time_dimension.SlackVar(index))
|
||||
# Warning: Slack var is not defined for vehicle's end node
|
||||
#routing.AddToAssignment(time_dimension.SlackVar(self.routing.End(vehicle_id)))
|
||||
|
||||
###########
|
||||
# Printer #
|
||||
###########
|
||||
def print_solution(data, routing, assignment):
|
||||
"""Prints assignment on console"""
|
||||
print('Objective: {}'.format(assignment.ObjectiveValue()))
|
||||
total_distance = 0
|
||||
total_load = 0
|
||||
total_time = 0
|
||||
capacity_dimension = routing.GetDimensionOrDie('Capacity')
|
||||
time_dimension = routing.GetDimensionOrDie('Time')
|
||||
dropped = []
|
||||
for order in xrange(0, routing.nodes()):
|
||||
index = routing.NodeToIndex(order)
|
||||
if assignment.Value(routing.NextVar(index)) == index:
|
||||
dropped.append(order)
|
||||
print('dropped orders: {}'.format(dropped))
|
||||
|
||||
for vehicle_id in xrange(data["num_vehicles"]):
|
||||
index = routing.Start(vehicle_id)
|
||||
plan_output = 'Route for vehicle {}:\n'.format(vehicle_id)
|
||||
distance = 0
|
||||
while not routing.IsEnd(index):
|
||||
load_var = capacity_dimension.CumulVar(index)
|
||||
time_var = time_dimension.CumulVar(index)
|
||||
plan_output += ' {0} Load({1}) Time({2},{3}) ->'.format(
|
||||
routing.IndexToNode(index),
|
||||
assignment.Value(load_var),
|
||||
assignment.Min(time_var),
|
||||
assignment.Max(time_var))
|
||||
previous_index = index
|
||||
index = assignment.Value(routing.NextVar(index))
|
||||
distance += routing.GetArcCostForVehicle(previous_index, index,
|
||||
vehicle_id)
|
||||
load_var = capacity_dimension.CumulVar(index)
|
||||
time_var = time_dimension.CumulVar(index)
|
||||
plan_output += ' {0} Load({1}) Time({2},{3})\n'.format(
|
||||
routing.IndexToNode(index),
|
||||
assignment.Value(load_var),
|
||||
assignment.Min(time_var),
|
||||
assignment.Max(time_var))
|
||||
plan_output += 'Distance of the route: {}m\n'.format(distance)
|
||||
plan_output += 'Load of the route: {}\n'.format(assignment.Value(load_var))
|
||||
plan_output += 'Time of the route: {}min\n'.format(assignment.Value(time_var))
|
||||
print(plan_output)
|
||||
total_distance += distance
|
||||
total_load += assignment.Value(load_var)
|
||||
total_time += assignment.Value(time_var)
|
||||
print('Total Distance of all routes: {}m'.format(total_distance))
|
||||
print('Total Load of all routes: {}'.format(total_load))
|
||||
print('Total Time of all routes: {}min'.format(total_time))
|
||||
|
||||
########
|
||||
# Main #
|
||||
########
|
||||
def main():
|
||||
"""Entry point of the program"""
|
||||
# Instantiate the data problem.
|
||||
data = create_data_model()
|
||||
|
||||
# Create Routing Model
|
||||
routing = pywrapcp.RoutingModel(
|
||||
data["num_locations"],
|
||||
data["num_vehicles"],
|
||||
data["depot"])
|
||||
# Define weight of each edge
|
||||
distance_evaluator = create_distance_evaluator(data)
|
||||
routing.SetArcCostEvaluatorOfAllVehicles(distance_evaluator)
|
||||
# Add Distance constraint to minimize the longuest route
|
||||
add_distance_dimension(routing, distance_evaluator)
|
||||
# Add Capacity constraint
|
||||
demand_evaluator = create_demand_evaluator(data)
|
||||
add_capacity_constraints(routing, data, demand_evaluator)
|
||||
# Add Time Window constraint
|
||||
time_evaluator = create_time_evaluator(data)
|
||||
add_time_window_constraints(routing, data, time_evaluator)
|
||||
|
||||
# Setting first solution heuristic (cheapest addition).
|
||||
search_parameters = pywrapcp.RoutingModel.DefaultSearchParameters()
|
||||
search_parameters.first_solution_strategy = (
|
||||
routing_enums_pb2.FirstSolutionStrategy.PATH_CHEAPEST_ARC) # pylint: disable=no-member
|
||||
# Solve the problem.
|
||||
assignment = routing.SolveWithParameters(search_parameters)
|
||||
print_solution(data, routing, assignment)
|
||||
|
||||
if __name__ == '__main__':
|
||||
main()
|
||||
Reference in New Issue
Block a user