use eframe::egui;
use eframe::egui::mutex::RwLock;
use eframe::egui::vec2;
use eframe::egui::Align2;
use eframe::egui::Button;
use eframe::egui::Color32;
use eframe::egui::Label;
use eframe::egui::Link;
use eframe::egui::RichText;
use eframe::egui::ScrollArea;
use eframe::egui::Stroke;
use eframe::egui::TextEdit;
use egui_flex::item;
use egui_flex::Flex;
use serde::Deserialize;
use serde::Serialize;
use std::collections::BTreeMap;
use std::fs::File;
use std::io::Read;
use std::io::Write;
use std::iter::zip;
use std::sync::Arc;
use std::sync::OnceLock;
use crate::tabs::activities::Activity;
use super::activities::activities;
use super::activities::activity_form::classes_ui::set_classes_filter;
use super::activities::activity_form::filtered_classes;
use super::activities::activity_form::filtering_classes;
use super::activities::save_activities;
use super::lectures::get_lectures;
use super::limitations::limitations_ui::classes_sched;
use super::limitations::limitations_ui::ClassLimitation;
use super::limitations::limitations_ui::{
classes_limitations, save_classes_limitations, save_teachers_limitations, teachers_limitations,
};
use super::teachers::get_teachers;
#[derive(Clone, Serialize, Deserialize)]
pub struct Class {
pub id: i32,
pub name: String,
short_name: String,
}
pub fn selected_class() -> &'static Arc<RwLock<Option<i32>>> {
static SELECTED: OnceLock<Arc<RwLock<Option<i32>>>> = OnceLock::new();
SELECTED.get_or_init(|| Arc::new(RwLock::new(None)))
}
pub fn get_classes() -> &'static Arc<RwLock<BTreeMap<i32, Class>>> {
static CLASSES: OnceLock<Arc<RwLock<BTreeMap<i32, Class>>>> = OnceLock::new();
CLASSES.get_or_init(|| Arc::new(RwLock::new(read_classes())))
}
pub fn del_classes_state() -> &'static Arc<RwLock<Vec<bool>>> {
static TEACHERS: OnceLock<Arc<RwLock<Vec<bool>>>> = OnceLock::new();
TEACHERS.get_or_init(|| Arc::new(RwLock::new(vec![false; filtered_classes().read().len()])))
}
pub fn classes_acts() -> &'static Arc<RwLock<BTreeMap<i32, Vec<Activity>>>> {
static CLASSES: OnceLock<Arc<RwLock<BTreeMap<i32, Vec<Activity>>>>> = OnceLock::new();
CLASSES.get_or_init(|| Arc::new(RwLock::new(create_classes_acts())))
}
pub fn create_classes_acts() -> BTreeMap<i32, Vec<Activity>> {
let acts = &*activities().read();
let mut map = BTreeMap::new();
for c in &*get_classes().read() {
let mut c_acts = acts
.values()
.filter(|a| a.classes.iter().any(|ac| ac == &c.1.id) || a.classes.is_empty())
.map(|a| a.clone())
.collect::<Vec<Activity>>();
c_acts.sort_by(|a, b| a.lecture.cmp(&b.lecture));
map.insert(c.1.id, c_acts);
}
map
}
pub fn class_name() -> &'static Arc<RwLock<String>> {
static NAME: OnceLock<Arc<RwLock<String>>> = OnceLock::new();
NAME.get_or_init(|| Arc::new(RwLock::new("".to_string())))
}
fn class_short_name() -> &'static Arc<RwLock<String>> {
static SHORT_NAME: OnceLock<Arc<RwLock<String>>> = OnceLock::new();
SHORT_NAME.get_or_init(|| Arc::new(RwLock::new("".to_string())))
}
pub fn set_selected_class(id: i32) {
let class = Arc::clone(selected_class());
std::thread::spawn(move || {
*class.write() = Some(id);
});
}
fn update_class_form() -> &'static Arc<RwLock<bool>> {
static SHORT_NAME: OnceLock<Arc<RwLock<bool>>> = OnceLock::new();
SHORT_NAME.get_or_init(|| Arc::new(RwLock::new(false)))
}
fn update_class(ui: &mut eframe::egui::Ui) {
egui::Window::new("Select Class")
.open(&mut *update_class_form().write())
.resizable([true, true])
.show(ui.ctx(), |ui| {
ui.add(TextEdit::singleline(&mut *class_name().write()));
ui.add(TextEdit::singleline(&mut *class_short_name().write()));
if ui.add(Button::new("Güncelle")).clicked() {
if let Some(t) = get_classes()
.write()
.get_mut(&selected_class().read().unwrap())
{
t.name = class_name().read().clone();
t.short_name = class_short_name().read().clone();
save_classes();
}
}
});
}
pub fn classes_page(ui: &mut eframe::egui::Ui) {
ui.vertical_centered(|ui| {
if ui
.add_sized(
vec2(250., 30.),
TextEdit::singleline(&mut *class_name().write()).hint_text("Sınıf Adını Gir"),
)
.changed()
{
set_classes_filter();
};
ui.add_sized(
vec2(250., 30.),
TextEdit::singleline(&mut *class_short_name().write()).hint_text("Kısa Adı"),
);
if ui.add_sized(vec2(250., 30.), Button::new("Ekle")).clicked() {
add_class();
}
});
ui.separator();
flex_classes_ui(ui);
}
fn flex_classes_ui(ui: &mut eframe::egui::Ui) {
update_class(ui);
Flex::horizontal()
.gap(vec2(20., 20.))
.wrap(true)
.show(ui, |flex| {
let del_states = del_classes_state().read().clone();
let del_states = del_states.iter().enumerate();
for (del_state, class) in zip(del_states, filtered_classes().read().iter()) {
let frame = egui::Frame::default()
.stroke(Stroke::new(0.3, Color32::GRAY))
.rounding(5.)
.inner_margin(5.);
flex.add_flex(
item().grow(1.).frame(frame),
Flex::vertical().align_items_content(Align2::CENTER_TOP),
|flex| {
flex.add(item(), Label::new(&class.name));
if *del_state.1 {
flex.add_flex(
item().grow(1.),
Flex::horizontal()
.align_items(egui_flex::FlexAlign::Center)
.wrap(false),
|flex| {
if flex
.add(
item(),
Link::new(RichText::new("Sil").color(Color32::RED)),
)
.clicked()
{
del_class(class.id, del_state.0);
};
if flex
.add(item().grow(1.), Link::new("Vazgeç"))
.clicked()
{
std::thread::spawn(move || {
if let Some(state) =
del_classes_state().write().get_mut(del_state.0)
{
*state = false;
}
});
};
},
);
} else {
if flex
.add(
item().grow(1.),
Link::new(RichText::new("Sil").color(Color32::DARK_RED)),
)
.clicked()
{
std::thread::spawn(move || {
if let Some(state) =
del_classes_state().write().get_mut(del_state.0)
{
*state = true;
}
});
}
if flex.add(item(), Link::new("Düzenle")).clicked() {
let c = class.clone();
set_selected_class(c.id);
std::thread::spawn(move || {
*class_name().write() = c.name.clone();
*class_short_name().write() = c.short_name.clone();
*update_class_form().write() = true;
});
}
}
},
);
}
});
}
pub fn classes_lists_ui(ui: &mut eframe::egui::Ui) {
ScrollArea::vertical().show(ui, |ui| {
ui.add_space(30.);
ui.separator();
ui.vertical_centered(|ui| {
if ui
.add_sized(
vec2(250., 30.),
TextEdit::singleline(&mut *class_name().write()).hint_text("Filtrele"),
)
.changed()
{
set_classes_filter();
};
let classes = &*filtered_classes().read();
for c in classes {
let fill_color = if selected_class().read().is_some_and(|i| i == c.id) {
Color32::BLUE
} else {
Color32::default()
};
let stroke_color = if selected_class().read().is_some_and(|i| i == c.id) {
Color32::LIGHT_BLUE
} else {
Color32::LIGHT_GRAY
};
let button = egui::Frame::none()
.fill(fill_color)
.inner_margin(10.)
.outer_margin(2.)
.rounding(5.0)
.stroke(Stroke::new(1., stroke_color))
.show(ui, |ui| {
ui.label(&c.name);
})
.response;
let button = button
.interact(egui::Sense::click())
.on_hover_cursor(egui::CursorIcon::PointingHand);
if button.clicked() {
set_selected_class(c.id);
}
}
});
});
}
fn save_classes() {
std::thread::spawn(move || {
let classes = get_classes().read();
let js = serde_json::to_string(&*classes);
match js {
Ok(j) => {
let mut f = File::create("./db/classes.json").unwrap();
f.write_all(j.as_bytes()).unwrap();
}
Err(_) => {}
}
});
}
fn read_classes() -> BTreeMap<i32, Class> {
let f = File::open("./db/classes.json");
if let Ok(mut f) = f {
let mut content: String = String::new();
f.read_to_string(&mut content).unwrap();
let cls: BTreeMap<i32, Class> = serde_json::from_str(content.as_str()).unwrap();
return cls;
}
BTreeMap::new()
}
fn add_class() {
let len = find_new_id();
let class = Class {
id: len,
name: class_name().write().clone(),
short_name: class_short_name().write().clone(),
};
std::thread::spawn(move || {
get_classes().write().insert(len, class);
*class_name().write() = "".to_string();
*class_short_name().write() = "".to_string();
set_classes_filter();
let c_lims = ClassLimitation::new(len);
classes_limitations().write().insert(len, c_lims);
save_classes_limitations();
save_classes();
del_classes_state().write().push(false);
});
}
fn del_class(index: i32, state: usize) {
std::thread::spawn(move || {
let classes = get_classes();
classes.write().remove(&index);
save_classes();
classes_limitations().write().remove(&index);
save_classes_limitations();
del_class_acts(index);
*filtered_classes().write() = filtering_classes();
classes_sched().write().remove(&index);
classes_acts().write().remove(&index);
del_classes_state().write().remove(state);
});
}
fn del_class_acts(index: i32) {
if let Some(c_acts) = classes_acts().read().get(&index) {
for a in c_acts {
activities().write().remove(&a.id);
}
}
classes_acts().write().remove(&index);
save_activities();
}
fn find_new_id() -> i32 {
let len = get_classes().read().len() as i32;
for i in 1..len + 1 {
if !get_classes().read().contains_key(&i) {
return i;
}
}
len + 1
}
pub fn validates_c_lims() {
std::thread::spawn(move || {
let classes = &*get_classes().read();
let lims = &mut *classes_limitations().write();
lims.retain(|id, _lim| classes.contains_key(id));
save_classes_limitations();
});
}
pub fn validates_t_lims() {
std::thread::spawn(move || {
let teachers = &*get_teachers().read();
let lims = &mut *teachers_limitations().write();
lims.retain(|id, _lim| teachers.contains_key(id));
save_teachers_limitations();
validates_c_acts();
});
}
pub fn validates_c_acts() {
std::thread::spawn(move || {
let classes = &*get_classes().read();
let acts = &mut *activities().write();
acts.retain(|_id, act| act.classes.iter().all(|ac| classes.contains_key(ac)));
save_activities();
validates_t_acts();
});
}
pub fn validates_t_acts() {
std::thread::spawn(move || {
let teachers = &*get_teachers().read();
let acts = &mut *activities().write();
acts.retain(|_id, act| act.teachers.iter().all(|ac| teachers.contains_key(ac)));
save_activities();
validates_l_acts();
});
}
pub fn validates_l_acts() {
std::thread::spawn(move || {
let lectures = &*get_lectures().read();
let acts = &mut *activities().write();
acts.retain(|_id, act| lectures.contains_key(&act.lecture));
save_activities();
});
}