use std::fmt::Debug;
use std::marker::PhantomData;
use solverforge_core::domain::PlanningSolution;
use solverforge_scoring::Director;
use crate::heuristic::r#move::{ListMoveImpl, ListSwapMove};
use super::entity::EntitySelector;
use super::move_selector::MoveSelector;
use super::nearby_list_change::CrossEntityDistanceMeter;
pub struct NearbyListSwapMoveSelector<S, V, D, ES> {
entity_selector: ES,
distance_meter: D,
max_nearby: usize,
list_len: fn(&S, usize) -> usize,
list_get: fn(&S, usize, usize) -> Option<V>,
list_set: fn(&mut S, usize, usize, V),
variable_name: &'static str,
descriptor_index: usize,
_phantom: PhantomData<(fn() -> S, fn() -> V)>,
}
impl<S, V: Debug, D, ES: Debug> Debug for NearbyListSwapMoveSelector<S, V, D, ES> {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
f.debug_struct("NearbyListSwapMoveSelector")
.field("entity_selector", &self.entity_selector)
.field("distance_meter", &"<distance_meter>")
.field("max_nearby", &self.max_nearby)
.field("variable_name", &self.variable_name)
.field("descriptor_index", &self.descriptor_index)
.finish()
}
}
impl<S, V, D, ES> NearbyListSwapMoveSelector<S, V, D, ES> {
#[allow(clippy::too_many_arguments)]
pub fn new(
entity_selector: ES,
distance_meter: D,
max_nearby: usize,
list_len: fn(&S, usize) -> usize,
list_get: fn(&S, usize, usize) -> Option<V>,
list_set: fn(&mut S, usize, usize, V),
variable_name: &'static str,
descriptor_index: usize,
) -> Self {
Self {
entity_selector,
distance_meter,
max_nearby,
list_len,
list_get,
list_set,
variable_name,
descriptor_index,
_phantom: PhantomData,
}
}
}
impl<S, V, D, ES> MoveSelector<S, ListSwapMove<S, V>> for NearbyListSwapMoveSelector<S, V, D, ES>
where
S: PlanningSolution,
V: Clone + PartialEq + Send + Sync + Debug + 'static,
D: CrossEntityDistanceMeter<S>,
ES: EntitySelector<S>,
{
fn iter_moves<'a, SD: Director<S>>(
&'a self,
score_director: &'a SD,
) -> impl Iterator<Item = ListSwapMove<S, V>> + 'a {
let solution = score_director.working_solution();
let list_len = self.list_len;
let list_get = self.list_get;
let list_set = self.list_set;
let variable_name = self.variable_name;
let descriptor_index = self.descriptor_index;
let max_nearby = self.max_nearby;
let entities: Vec<usize> = self
.entity_selector
.iter(score_director)
.map(|r| r.entity_index)
.collect();
let route_lens: Vec<usize> = entities.iter().map(|&e| list_len(solution, e)).collect();
let mut moves = Vec::new();
let mut seen: std::collections::HashSet<(usize, usize, usize, usize)> =
std::collections::HashSet::new();
for (src_idx, &src_entity) in entities.iter().enumerate() {
let src_len = route_lens[src_idx];
if src_len == 0 {
continue;
}
for src_pos in 0..src_len {
let mut candidates: Vec<(usize, usize, f64)> = Vec::new();
for dst_pos in src_pos + 1..src_len {
let dist = self
.distance_meter
.distance(solution, src_entity, src_pos, src_entity, dst_pos);
if dist.is_finite() {
candidates.push((src_entity, dst_pos, dist));
}
}
for (dst_idx, &dst_entity) in entities.iter().enumerate() {
if dst_idx <= src_idx {
continue;
}
let dst_len = route_lens[dst_idx];
if dst_len == 0 {
continue;
}
for dst_pos in 0..dst_len {
let dist = self
.distance_meter
.distance(solution, src_entity, src_pos, dst_entity, dst_pos);
if dist.is_finite() {
candidates.push((dst_entity, dst_pos, dist));
}
}
}
candidates
.sort_by(|a, b| a.2.partial_cmp(&b.2).unwrap_or(std::cmp::Ordering::Equal));
candidates.truncate(max_nearby);
for (dst_entity, dst_pos, _) in candidates {
let key = if (src_entity, src_pos) < (dst_entity, dst_pos) {
(src_entity, src_pos, dst_entity, dst_pos)
} else {
(dst_entity, dst_pos, src_entity, src_pos)
};
if seen.insert(key) {
moves.push(ListSwapMove::new(
src_entity,
src_pos,
dst_entity,
dst_pos,
list_len,
list_get,
list_set,
variable_name,
descriptor_index,
));
}
}
}
}
moves.into_iter()
}
fn size<SD: Director<S>>(&self, score_director: &SD) -> usize {
let solution = score_director.working_solution();
let list_len = self.list_len;
let total_elements: usize = self
.entity_selector
.iter(score_director)
.map(|r| list_len(solution, r.entity_index))
.sum();
total_elements * self.max_nearby / 2 }
}
pub struct ListMoveNearbyListSwapSelector<S, V, D, ES> {
inner: NearbyListSwapMoveSelector<S, V, D, ES>,
}
impl<S, V: Debug, D, ES: Debug> Debug for ListMoveNearbyListSwapSelector<S, V, D, ES> {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
f.debug_struct("ListMoveNearbyListSwapSelector")
.field("inner", &self.inner)
.finish()
}
}
impl<S, V, D, ES> ListMoveNearbyListSwapSelector<S, V, D, ES> {
pub fn new(inner: NearbyListSwapMoveSelector<S, V, D, ES>) -> Self {
Self { inner }
}
}
impl<S, V, D, ES> MoveSelector<S, ListMoveImpl<S, V>>
for ListMoveNearbyListSwapSelector<S, V, D, ES>
where
S: PlanningSolution,
V: Clone + PartialEq + Send + Sync + Debug + 'static,
D: CrossEntityDistanceMeter<S>,
ES: EntitySelector<S>,
{
fn iter_moves<'a, SD: Director<S>>(
&'a self,
score_director: &'a SD,
) -> impl Iterator<Item = ListMoveImpl<S, V>> + 'a {
self.inner
.iter_moves(score_director)
.map(ListMoveImpl::ListSwap)
}
fn size<SD: Director<S>>(&self, score_director: &SD) -> usize {
self.inner.size(score_director)
}
}