X-Git-Url: https://git.llucax.com/z.facultad/75.42/plaqui.git/blobdiff_plain/c9cc3f7ba2112294c69c111082223da91554c095..737add2e0a2495a40a01fbe4fb344062008e0924:/Client/src/principal.cpp?ds=sidebyside diff --git a/Client/src/principal.cpp b/Client/src/principal.cpp index 062aa4b..9fabc78 100644 --- a/Client/src/principal.cpp +++ b/Client/src/principal.cpp @@ -1,39 +1,303 @@ - - #include "principal.h" #include +#include +#include +#include "item_codo.h" +#include "item_conduct.h" +#include "item_exclusa.h" +#include "item_tank.h" +#include "item_pump.h" +#include "item_union.h" +#include "item_drain.h" +#include "item_not.h" +#include "item_or.h" +#include "item_and.h" +#include +#include + +#define INFINITO 99999999 Principal::Principal(BaseObjectType *co, const Glib::RefPtr &rg):Gtk::Window(co),refXml(rg) { - Gtk::MenuItem *conect=0, *exit=0, *about=0; + Gtk::MenuItem *conect=0, *exit=0, *about=0, *mnu_prop=0, *mnu_disconnect=0, *server_stop=0; + Gtk::MenuItem *mnu_simular=0, *mnu_pausar=0; + Gtk::Button *bar_connect=0, *close_about=0; + Gtk::Image *plaqui_logo; + Gtk::Label *lbl_plaqui_version; + + txt_view = 0; + work_place = 0; + lbl_cap_flujo = lbl_cap_extra = lbl_extra = lbl_nombre = lbl_color = lbl_flujo = 0; + btn_simulate = btn_pause = 0; + + anim_frames[0] = Gdk::Pixbuf::create_from_file(PACKAGE_DATA_DIR"/plaqui-client/pixmaps/anim_0.png"); + anim_frames[1] = Gdk::Pixbuf::create_from_file(PACKAGE_DATA_DIR"/plaqui-client/pixmaps/anim_1.png"); + anim_frames[2] = Gdk::Pixbuf::create_from_file(PACKAGE_DATA_DIR"/plaqui-client/pixmaps/anim_2.png"); + anim_frames[3] = Gdk::Pixbuf::create_from_file(PACKAGE_DATA_DIR"/plaqui-client/pixmaps/anim_3.png"); + anim_frames[4] = Gdk::Pixbuf::create_from_file(PACKAGE_DATA_DIR"/plaqui-client/pixmaps/anim_4.png"); + anim_frames[5] = Gdk::Pixbuf::create_from_file(PACKAGE_DATA_DIR"/plaqui-client/pixmaps/anim_5.png"); + anim_frames[6] = Gdk::Pixbuf::create_from_file(PACKAGE_DATA_DIR"/plaqui-client/pixmaps/anim_6.png"); + anim_frames[7] = Gdk::Pixbuf::create_from_file(PACKAGE_DATA_DIR"/plaqui-client/pixmaps/anim_7.png"); + current_frame = 0; + + plaqui_logo = anim = 0; + lbl_plaqui_version = 0; + rg->get_widget("lbl_plaqui_version", lbl_plaqui_version); + rg->get_widget("plaqui_logo", plaqui_logo); + plaqui_logo->set(PACKAGE_DATA_DIR"/plaqui-client/pixmaps/logo.png"); + + rg->get_widget("plaqui_logo", plaqui_logo); + // Calculo número de revisión. + std::string rev = "$Rev$"; + rev = rev.substr(6, rev.length() - 8); + std::string s = "PlaQui Client versión " VERSION " (revisión "; + s += rev + ")"; + lbl_plaqui_version->set_text(Glib::locale_to_utf8(s)); + + rg->get_widget("anim_frames", anim); + anim->set(anim_frames[current_frame]); + + rg->get_widget("close_about", close_about); + rg->get_widget("dlgAbout", dlg_about); + rg->get_widget("mnu_pausar", mnu_pausar); + rg->get_widget("btn_pausa", btn_pause); + rg->get_widget("mnu_simular", mnu_simular); + rg->get_widget("btn_simular", btn_simulate); + rg->get_widget("btn_activar", btn_activar); + rg->get_widget("color_preview", color_preview); + rg->get_widget("lbl_nombre", lbl_nombre); + rg->get_widget("lbl_extra", lbl_extra); + rg->get_widget("lbl_cap_extra", lbl_cap_extra); + rg->get_widget("lbl_cap_flujo", lbl_cap_flujo); + rg->get_widget("lbl_flujo", lbl_flujo); rg->get_widget("mnu_file_connect", conect); + rg->get_widget("mnu_file_disconnect", mnu_disconnect); rg->get_widget("mnu_file_exit", exit); rg->get_widget("mnu_help_about", about); + rg->get_widget("mnu_server_stop", server_stop); + rg->get_widget("mnu_prop", mnu_prop); + rg->get_widget_derived("dlg_property", dlg_property); rg->get_widget_derived("dlgConectar", dlg_conectar); + rg->get_widget("txt_view", txt_view); + rg->get_widget("bar_connect", bar_connect); + rg->get_widget("work_place", work_place); + rg->get_widget("ico_conected", ico_conected); + work_place->signal_expose_event().connect( SigC::slot(*this, &Principal::on_workplace_expose_event) ); + dlg_property->get_ok_button()->signal_clicked().connect( SigC::slot(*this, &Principal::on_dlg_property_ok) ); dlg_conectar->get_ok_button()->signal_clicked().connect( SigC::slot(*this, &Principal::on_dlg_connect_ok) ); + mnu_prop->signal_activate().connect( SigC::slot(*this, &Principal::on_mnu_property)); + mnu_disconnect->signal_activate().connect( SigC::slot(*this, &Principal::on_mnu_file_disconnect)); + server_stop->signal_activate().connect( SigC::slot(*this, &Principal::on_mnu_server_stop_activate)); conect->signal_activate().connect( SigC::slot(*this, &Principal::on_mnu_file_connect)); + bar_connect->signal_clicked().connect( SigC::slot(*this, &Principal::on_mnu_file_connect)); exit->signal_activate().connect( SigC::slot(*this, &Principal::on_mnu_file_exit)); about->signal_activate().connect( SigC::slot(*this, &Principal::on_mnu_help_about)); + btn_activar->signal_clicked().connect( SigC::slot(*this, &Principal::on_btn_activar_clicked) ); + mnu_simular->signal_activate().connect( SigC::slot(*this, &Principal::on_btn_simulate_clicked) ); + btn_simulate->signal_clicked().connect( SigC::slot(*this, &Principal::on_btn_simulate_clicked) ); + mnu_pausar->signal_activate().connect( SigC::slot(*this, &Principal::on_btn_pause_clicked) ); + btn_pause->signal_clicked().connect( SigC::slot(*this, &Principal::on_btn_pause_clicked) ); + close_about->signal_clicked().connect( SigC::slot(*dlg_about, &Gtk::Widget::hide) ); + + conexion = NULL; + is_xml_loaded = false; + last_selected = NULL; + paused = true; + update_ui.connect( SigC::slot(*this, &Principal::update_items_prop ) ); + load_xml_dispatch.connect( SigC::slot(*this, &Principal::loadXML ) ); + gc = Gdk::GC::create(get_window()); + color_low = Gdk::Color("blue"); + color_high = Gdk::Color("red"); + Gtk::Widget::get_default_colormap()->alloc_color(color_low); + Gtk::Widget::get_default_colormap()->alloc_color(color_high); + txt_view->set_editable(false); } Principal::~Principal() { } +void Principal::on_realize() +{ + Gtk::Window::on_realize(); +} + +bool Principal::on_workplace_expose_event(GdkEventExpose *e) +{ + Glib::RefPtr window = work_place->get_window(); + + int x1, y1, x2, y2; + // Dibujo las lineas + std::map::iterator i; + for(i=mapItems.begin(); i!=mapItems.end(); i++) { + if (dynamic_cast(i->second) || dynamic_cast(i->second) || dynamic_cast(i->second)) { + x1 = i->second->x + i->second->in_x; + y1 = i->second->y + i->second->in_y; + std::list::iterator linea; + for(linea=i->second->in_lines.begin(); linea!=i->second->in_lines.end(); linea++) { + ViewItem *tmp = find_item(linea->dst); + /* Si este item es un tanque */ + if (linea->is_tank) { + if (linea->is_tank_lower) { + x2 = tmp->x + tmp->out_x; + y2 = tmp->y + tmp->out_y; + if (dynamic_cast(tmp)->get_out_inf()) { + gc->set_foreground(color_high); + } else { + gc->set_foreground(color_low); + } + } else { + x2 = tmp->x + tmp->in_x; + y2 = tmp->y + tmp->in_y; + if (dynamic_cast(tmp)->get_out_sup()) { + gc->set_foreground(color_high); + } else { + gc->set_foreground(color_low); + } + } + } else { + x2 = tmp->x + tmp->out_x; + y2 = tmp->y + tmp->out_y; + if (tmp->get_open()) { + gc->set_foreground(color_high); + } else { + gc->set_foreground(color_low); + } + } + gc->set_line_attributes(3, Gdk::LINE_SOLID, Gdk::CAP_NOT_LAST, Gdk::JOIN_MITER); + window->draw_line(gc, x2+tmp->item_offset_x, y2+tmp->item_offset_y, x2+tmp->item_offset_x, y1+i->second->offset_y); + window->draw_line(gc, x2+tmp->item_offset_x, y1+i->second->offset_y, x1+i->second->offset_x, y1+i->second->offset_y); + window->draw_line(gc, x1, y1, x1+i->second->offset_x, y1+i->second->offset_y); + window->draw_line(gc, x2, y2, x2+tmp->item_offset_x, y2+tmp->item_offset_y); + } + x1 = i->second->x + i->second->out_x; + y1 = i->second->y + i->second->out_y; + for(linea=i->second->out_lines.begin(); linea!=i->second->out_lines.end(); linea++) { + ViewItem *tmp = find_item(linea->dst); + x2 = tmp->x + tmp->in_x; + y2 = tmp->y + tmp->in_y; + if (i->second->get_open()) { + gc->set_foreground(color_high); + } else { + gc->set_foreground(color_low); + } + gc->set_line_attributes(3, Gdk::LINE_SOLID, Gdk::CAP_NOT_LAST, Gdk::JOIN_MITER); + window->draw_line(gc, x1+i->second->offset_x, y1+i->second->offset_y, x1+i->second->offset_x, y2+tmp->item_offset_y); + window->draw_line(gc, x1+i->second->offset_x, y2+tmp->item_offset_y, x2+tmp->item_offset_x, y2+tmp->item_offset_y); + window->draw_line(gc, x1, y1, x1+i->second->offset_x, y1+i->second->offset_y); + window->draw_line(gc, x2, y2, x2+tmp->item_offset_x, y2+tmp->item_offset_y); + } + } + } +} + +ViewItem *Principal::find_item(std::string &_name) +{ + std::map::iterator i; + for(i=mapItems.begin(); i!=mapItems.end(); i++) { + if (i->second->get_name() == _name) { + return i->second; + } + } + return NULL; +} + void Principal::on_dlg_connect_ok() { - std::cout << "Conectando ..." << std::endl; - std::cout << dlg_conectar->get_server_name() << ":" << dlg_conectar->get_server_port() << std::endl; + if (conexion == NULL) { + // Creo la conexion + try { + conexion = new PlaQui::Server::ControlClient(dlg_conectar->get_server_name(), dlg_conectar->get_server_port()); + } + catch (...) { + txt_view->get_buffer()->insert(txt_view->get_buffer()->begin(), "NO SE PUDO CONECTAR\n"); + //delete conexion; XXX Si no me equivoco, si falla el + //constructor, no se reserva la memoria (el delete no va). + delete conexion; + conexion = NULL; + dlg_conectar->hide(); + return; + } + + // Conecto las señales + conexion->signal_ok_received().connect( SigC::slot(*this, &Principal::on_conexion_ok) ); + conexion->signal_error().connect( SigC::slot(*this, &Principal::on_conexion_fatal_error) ); + conexion->signal_error_received().connect( SigC::slot(*this, &Principal::on_conexion_error) ); + conexion->signal_finished().connect( SigC::slot(*this, &Principal::on_conexion_finished) ); + conexion->signal_frame_received().connect(SigC::slot(*this, &Principal::on_conexion_frame)); + // Lanzo la conexion! + conexion->run(); + txt_view->get_buffer()->insert(txt_view->get_buffer()->begin(),"CONNECTED\n"); + ico_conected->set( Gtk::Stock::YES , Gtk::IconSize(Gtk::ICON_SIZE_LARGE_TOOLBAR)); + + // Pido la planta por defecto + PlaQui::Server::Command c("plant", "get"); + c.add_arg("default"); + conexion->send(c); + } dlg_conectar->hide(); } void Principal::on_mnu_file_exit() { + on_mnu_file_disconnect(); + if (conexion) { + conexion->finish(); + } + // Espera a que termine realmente. + while (conexion) { + Glib::usleep(100000); // 0,1 segundo + } Gtk::Main::quit(); } +bool Principal::on_delete_event(GdkEventAny *e) +{ + on_mnu_file_exit(); + return false; +} + +void Principal::on_mnu_server_stop_activate() +{ + if (conexion == NULL) return; + + PlaQui::Server::Command c("server", "stop"); + conexion->send(c); +} + +void Principal::on_btn_activar_clicked() +{ + if ((conexion == NULL) || (last_selected == NULL)) return; + + PlaQui::Server::Command c("plant", "set"); + c.add_arg("default"); + c.add_arg(last_selected->get_name()); + c.add_arg("open"); + + if (last_selected->get_open()) + c.add_arg("false"); + else + c.add_arg("true"); + + conexion->send(c); +} + +void Principal::on_mnu_file_disconnect() +{ + if (conexion == NULL) return; + + PlaQui::Server::Command c("transmission", "stop"); + c.add_arg(conexion->get_host()); + c.add_arg("7528"); + conexion->send(c); + PlaQui::Server::Command c2("connection", "stop"); + c2.add_arg(conexion->get_host()); + c2.add_arg(conexion->get_port()); + conexion->send(c2); +} + void Principal::on_mnu_file_connect() { dlg_conectar->show(); @@ -41,33 +305,667 @@ void Principal::on_mnu_file_connect() void Principal::on_mnu_help_about() { - // preparo para leer el archivo ChangeLog -/* Glib::RefPtr xml; - Glib::ustring line; - Glib::RefPtr log_buffer; - Glib::RefPtr log_io; + dlg_about->run(); +} + +bool Principal::on_item_clicked(GdkEventButton *e, ViewItem *i) +{ + Glib::ustring s; + s = "Selecciono "+i->get_name()+"\n"; + txt_view->get_buffer()->insert(txt_view->get_buffer()->begin(), s); + + last_selected = i; + update_items_prop(); +} + +void Principal::update_items_prop() +{ + if (last_selected != NULL) { + lbl_nombre->set_text(last_selected->get_name()); + lbl_flujo->set_text(last_selected->get_actual_flow()); + lbl_extra->set_text(last_selected->get_extra()); + + lbl_cap_flujo->set_text(last_selected->get_cap_flow()); + lbl_cap_extra->set_text(last_selected->get_cap_extra()); + + color_preview->modify_bg(Gtk::STATE_NORMAL, last_selected->get_color()); + color_preview->queue_draw(); + } + + if (!paused) { + current_frame++; + if (current_frame > 7) { + current_frame = 0; + } + anim->set(anim_frames[current_frame]); + } + + // Mando a redibujar a todos los items + std::map::iterator i; + for(i=mapItems.begin(); i!=mapItems.end(); i++) { + i->second->queue_draw(); + } + work_place->queue_draw(); +} + +void Principal::on_conexion_frame(const std::string &frame) +{ + if (conexion != NULL) { + read_status_xml(frame); + } +} - log_buffer = Gtk::TextBuffer::create(); - log_io = Glib::IOChannel::create_from_file("../ChangeLog", "r"); - while (log_io->read_line(line) != Glib::IO_STATUS_EOF) { - log_buffer->insert_at_cursor(line); +void Principal::on_conexion_finished() +{ + txt_view->get_buffer()->insert(txt_view->get_buffer()->begin(),"HANG UP\n"); + ico_conected->set( Gtk::Stock::NO , Gtk::IconSize(Gtk::ICON_SIZE_LARGE_TOOLBAR)); + conexion = NULL; + // Elimino la planta + std::map::iterator i; + for(i=mapItems.begin(); i!=mapItems.end(); i++) { + delete i->second; } + mapItems.clear(); + is_xml_loaded = false; +} - try { - xml = Gnome::Glade::Xml::create("client.glade", "dlgAbout"); +void Principal::on_conexion_ok(const std::string &body) +{ + /* lo paso a la carga del XML */ + /* verifico que body este completo */ + if ((body.find("")>0) && (body.find("")>0)) { + xml_body = body; + load_xml_dispatch(); + } else { + Glib::ustring s; + s = "\n"+Glib::locale_to_utf8(body)+"\n\n"; + txt_view->get_buffer()->insert(txt_view->get_buffer()->begin(),s); } - catch(const Gnome::Glade::XmlError &ex) { - std::cerr << ex.what() << std::endl; +} + +void Principal::on_conexion_fatal_error(const PlaQui::Server::ControlClient::Error& code, const std::string& desc) +{ + std::stringstream a; + std::string s; + a << code; + a >> s; + Glib::ustring st; + st = "Error de red nro. "+s+": "+desc+"\n"; + txt_view->get_buffer()->insert(txt_view->get_buffer()->begin(),st); +} + +void Principal::on_conexion_error(unsigned code, const std::string& desc) +{ + std::stringstream a; + std::string s; + a << code; + a >> s; + Glib::ustring st; + st = "El server dice que hay error nro. "+s+": "+desc+"\n"; + txt_view->get_buffer()->insert(txt_view->get_buffer()->begin(),st); +} + +void Principal::loadXML() +{ + // ya lo cargue + if (is_xml_loaded) return; + + /* Parseo de ejemplo de un XML desde archivo */ + xmlDocPtr document; + document = xmlParseMemory(xml_body.c_str(),xml_body.size()); + if (document == NULL) { + std::cout << "EEERRRRRRROOOOOOOOOO" << std::endl; return; } - Gtk::Window *dlg = 0; - Gtk::Button *btn_cerrar = 0; - Gtk::TextView *txt_changelog = 0; - xml->get_widget("dlgAbout", dlg); - xml->get_widget("btn_close", btn_cerrar); - xml->get_widget("txt_changelog", txt_changelog); - btn_cerrar->signal_clicked().connect(SigC::slot(*dlg, &Gtk::Dialog::hide)); - txt_changelog->set_buffer(log_buffer); - dlg->show();*/ + is_xml_loaded = true; + /* bien, el archivo se parseo bien! */ + xmlNodePtr nodo, items; + nodo = document->children; + + if (strcmp((char *)nodo->name, "planta") == 0) { + items = nodo->children; + while (items != NULL) { + if (items->type == XML_ELEMENT_NODE) { + if (xmlStrcmp(items->name, BAD_CAST"bomba")==0) { + loadBomba(items); + } else if (xmlStrcmp(items->name, BAD_CAST"codo")==0) { + loadCodo(items); + } else if (xmlStrcmp(items->name, BAD_CAST"tubo")==0) { + loadConduct(items); + } else if (xmlStrcmp(items->name, BAD_CAST"exclusa")==0) { + loadExclusa(items); + } else if (xmlStrcmp(items->name, BAD_CAST"tanque")==0) { + loadTank(items); + } else if (xmlStrcmp(items->name, BAD_CAST"empalme")==0) { + loadUnion(items); + } else if (xmlStrcmp(items->name, BAD_CAST"drenaje")==0) { + loadDrain(items); + } else if (xmlStrcmp(items->name, BAD_CAST"and")==0) { + loadAnd(items); + } else if (xmlStrcmp(items->name, BAD_CAST"or")==0) { + loadOr(items); + } else if (xmlStrcmp(items->name, BAD_CAST"not")==0) { + loadNot(items); + } + + } + items = items->next; + } + } + + xmlFreeDoc(document); + + // Ya cargado el XML, mando un msg para empezar a recibir los frames! + PlaQui::Server::Command c("transmission", "start"); + c.add_arg("default"); + c.add_arg(conexion->get_host()); + c.add_arg("7528"); + conexion->send(c); +} + +void Principal::loadNot(xmlNodePtr nodo) +{ + std::string name = (char *)xmlGetProp(nodo, BAD_CAST"nombre"); + std::string id = (char *)xmlGetProp(nodo, BAD_CAST"id"); + int orientacion=0, x, y; + t_Linea linea; + + ViewNot *p; + nodo = nodo->children; + while (nodo != NULL) { + if (nodo->type == XML_ELEMENT_NODE) { + if (xmlStrcmp(nodo->name, BAD_CAST"orientacion") == 0) { + orientacion = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + p = new ViewNot(name, orientacion); + } else if (xmlStrcmp(nodo->name, BAD_CAST"x") == 0) { + x = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"y") == 0) { + y = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"salida") == 0) { + linea.dst = (char *)XML_GET_CONTENT(nodo->children); + p->out_lines.push_back(linea); + } else if (xmlStrcmp(nodo->name, BAD_CAST"entrada") == 0) { + linea.dst = (char *)XML_GET_CONTENT(nodo->children); + linea.is_tank = false; + if (dynamic_cast(find_item(linea.dst)) != NULL) { + linea.is_tank = true; + linea.is_tank_lower = false; + if (xmlStrcmp(xmlGetProp(nodo, BAD_CAST"id"), BAD_CAST"inferior")==0) + linea.is_tank_lower = true; + } + p->in_lines.push_back(linea); + } + } + nodo = nodo->next; + } + + p->signal_button_press_event().connect(SigC::bind( SigC::slot(*this, &Principal::on_item_clicked), p) ); + p->set_position(x,y); + work_place->put(*p, x, y); + p->show(); + // los agrego al hash + mapItems[name] = p; +} + +void Principal::loadOr(xmlNodePtr nodo) +{ + std::string name = (char *)xmlGetProp(nodo, BAD_CAST"nombre"); + std::string id = (char *)xmlGetProp(nodo, BAD_CAST"id"); + int orientacion=0, x, y; + t_Linea linea; + + ViewOr *p; + + nodo = nodo->children; + while (nodo != NULL) { + if (nodo->type == XML_ELEMENT_NODE) { + if (xmlStrcmp(nodo->name, BAD_CAST"orientacion") == 0) { + orientacion = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + p = new ViewOr(name, orientacion); + } else if (xmlStrcmp(nodo->name, BAD_CAST"x") == 0) { + x = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"y") == 0) { + y = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"salida") == 0) { + linea.dst = (char *)XML_GET_CONTENT(nodo->children); + p->out_lines.push_back(linea); + } else if (xmlStrcmp(nodo->name, BAD_CAST"entrada") == 0) { + linea.dst = (char *)XML_GET_CONTENT(nodo->children); + linea.is_tank = false; + if (dynamic_cast(find_item(linea.dst)) != NULL) { + linea.is_tank = true; + linea.is_tank_lower = false; + if (xmlStrcmp(xmlGetProp(nodo, BAD_CAST"id"), BAD_CAST"inferior")==0) + linea.is_tank_lower = true; + } + p->in_lines.push_back(linea); + } + } + nodo = nodo->next; + } + + p->signal_button_press_event().connect(SigC::bind( SigC::slot(*this, &Principal::on_item_clicked), p) ); + p->set_position(x,y); + work_place->put(*p, x, y); + p->show(); + // los agrego al hash + mapItems[name] = p; +} + +void Principal::loadAnd(xmlNodePtr nodo) +{ + std::string name = (char *)xmlGetProp(nodo, BAD_CAST"nombre"); + std::string id = (char *)xmlGetProp(nodo, BAD_CAST"id"); + int orientacion=0, x, y; + float flujo; + xmlNodePtr inicial = nodo; + t_Linea linea; + ViewAnd *p; + + nodo = nodo->children; + while (nodo != NULL) { + if (nodo->type == XML_ELEMENT_NODE) { + if (xmlStrcmp(nodo->name, BAD_CAST"orientacion") == 0) { + orientacion = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + p = new ViewAnd(name, orientacion); + } else if (xmlStrcmp(nodo->name, BAD_CAST"x") == 0) { + x = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"y") == 0) { + y = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"salida") == 0) { + linea.dst = (char *)XML_GET_CONTENT(nodo->children); + p->out_lines.push_back(linea); + } else if (xmlStrcmp(nodo->name, BAD_CAST"entrada") == 0) { + linea.dst = (char *)XML_GET_CONTENT(nodo->children); + linea.is_tank = false; + if (dynamic_cast(find_item(linea.dst)) != NULL) { + linea.is_tank = true; + linea.is_tank_lower = false; + if (xmlStrcmp(xmlGetProp(nodo, BAD_CAST"id"), BAD_CAST"inferior")==0) + linea.is_tank_lower = true; + } + p->in_lines.push_back(linea); + } + } + nodo = nodo->next; + } + + p->signal_button_press_event().connect(SigC::bind( SigC::slot(*this, &Principal::on_item_clicked), p) ); + p->set_position(x,y); + work_place->put(*p, x, y); + p->show(); + // los agrego al hash + mapItems[name] = p; +} + +void Principal::loadBomba(xmlNodePtr nodo) +{ + Glib::ustring name = (char *)xmlGetProp(nodo, BAD_CAST"nombre"); + int orientacion=0, x, y; + + nodo = nodo->children; + while (nodo != NULL) { + if (nodo->type == XML_ELEMENT_NODE) { + if (xmlStrcmp(nodo->name, BAD_CAST"orientacion") == 0) { + orientacion = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"x") == 0) { + x = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"y") == 0) { + y = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } + } + nodo = nodo->next; + } + + // listo, ya recolecte todos los datos, ahora creo el objeto! + ViewPump *b = new ViewPump(name, orientacion); + b->signal_button_press_event().connect(SigC::bind( SigC::slot(*this, &Principal::on_item_clicked), b) ); + b->set_position(x,y); + work_place->put(*b, x, y); + b->show(); + // los agrego al hash + mapItems[name] = b; +} + +void Principal::loadCodo(xmlNodePtr nodo) +{ + std::string name = (char *)xmlGetProp(nodo, BAD_CAST"nombre"); + int orientacion=0, x, y; + + nodo = nodo->children; + while (nodo != NULL) { + if (nodo->type == XML_ELEMENT_NODE) { + if (xmlStrcmp(nodo->name, BAD_CAST"orientacion") == 0) { + orientacion = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"x") == 0) { + x = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"y") == 0) { + y = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } + } + nodo = nodo->next; + } + + // listo, ya recolecte todos los datos, ahora creo el objeto! + ViewItem *b = new ViewCodo(name, orientacion); + b->signal_button_press_event().connect(SigC::bind( SigC::slot(*this, &Principal::on_item_clicked), b) ); + b->set_position(x,y); + work_place->put(*b, x, y); + b->show(); + // los agrego al hash + mapItems[name] = b; +} + +void Principal::loadConduct(xmlNodePtr nodo) +{ + Glib::ustring name = (char *)xmlGetProp(nodo, BAD_CAST"nombre"); + int orientacion=0, x, y; + + nodo = nodo->children; + while (nodo != NULL) { + if (nodo->type == XML_ELEMENT_NODE) { + if (xmlStrcmp(nodo->name, BAD_CAST"orientacion") == 0) { + orientacion = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"x") == 0) { + x = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"y") == 0) { + y = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } + } + nodo = nodo->next; + } + + // listo, ya recolecte todos los datos, ahora creo el objeto! + ViewConduct *b = new ViewConduct(name, orientacion); + b->signal_button_press_event().connect(SigC::bind( SigC::slot(*this, &Principal::on_item_clicked), b) ); + b->set_position(x,y); + work_place->put(*b, x, y); + b->show(); + // los agrego al hash + mapItems[name] = b; +} + +void Principal::loadExclusa(xmlNodePtr nodo) +{ + Glib::ustring name = (char *)xmlGetProp(nodo, BAD_CAST"nombre"); + int orientacion=0, x, y; + + nodo = nodo->children; + while (nodo != NULL) { + if (nodo->type == XML_ELEMENT_NODE) { + if (xmlStrcmp(nodo->name, BAD_CAST"orientacion") == 0) { + orientacion = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"x") == 0) { + x = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"y") == 0) { + y = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } + } + nodo = nodo->next; + } + + // listo, ya recolecte todos los datos, ahora creo el objeto! + ViewExclusa *b = new ViewExclusa(name, orientacion); + b->signal_button_press_event().connect(SigC::bind( SigC::slot(*this, &Principal::on_item_clicked), b) ); + b->set_position(x,y); + work_place->put(*b, x, y); + b->show(); + // los agrego al hash + mapItems[name] = b; +} + +void Principal::loadTank(xmlNodePtr nodo) +{ + Glib::ustring name = (char *)xmlGetProp(nodo, BAD_CAST"nombre"); + int orientacion=0, x, y; + + nodo = nodo->children; + while (nodo != NULL) { + if (nodo->type == XML_ELEMENT_NODE) { + if (xmlStrcmp(nodo->name, BAD_CAST"orientacion") == 0) { + orientacion = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"x") == 0) { + x = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"y") == 0) { + y = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } + } + nodo = nodo->next; + } + + // listo, ya recolecte todos los datos, ahora creo el objeto! + ViewTank *b = new ViewTank(name, orientacion); + b->signal_button_press_event().connect(SigC::bind( SigC::slot(*this, &Principal::on_item_clicked), b) ); + b->set_position(x,y); + work_place->put(*b, x, y); + b->show(); + // los agrego al hash + mapItems[name] = b; +} + +void Principal::loadUnion(xmlNodePtr nodo) +{ + Glib::ustring name = (char *)xmlGetProp(nodo, BAD_CAST"nombre"); + int orientacion=0, x, y; + + nodo = nodo->children; + while (nodo != NULL) { + if (nodo->type == XML_ELEMENT_NODE) { + if (xmlStrcmp(nodo->name, BAD_CAST"orientacion") == 0) { + orientacion = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"x") == 0) { + x = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"y") == 0) { + y = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } + } + nodo = nodo->next; + } + + // listo, ya recolecte todos los datos, ahora creo el objeto! + ViewUnion *b = new ViewUnion(name, orientacion); + b->signal_button_release_event().connect(SigC::bind( SigC::slot(*this, &Principal::on_item_clicked), b) ); + b->set_position(x,y); + work_place->put(*b, x, y); + b->show(); + // los agrego al hash + mapItems[name] = b; +} + +void Principal::loadDrain(xmlNodePtr nodo) +{ + Glib::ustring name = (char *)xmlGetProp(nodo, BAD_CAST"nombre"); + int orientacion=0, x, y; + + nodo = nodo->children; + while (nodo != NULL) { + if (nodo->type == XML_ELEMENT_NODE) { + if (xmlStrcmp(nodo->name, BAD_CAST"orientacion") == 0) { + orientacion = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"x") == 0) { + x = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } else if (xmlStrcmp(nodo->name, BAD_CAST"y") == 0) { + y = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } + } + nodo = nodo->next; + } + + // listo, ya recolecte todos los datos, ahora creo el objeto! + ViewDrain *b = new ViewDrain(name, orientacion); + b->signal_button_release_event().connect(SigC::bind( SigC::slot(*this, &Principal::on_item_clicked), b) ); + b->set_position(x,y); + work_place->put(*b, x, y); + b->show(); + // los agrego al hash + mapItems[name] = b; +} + +void Principal::read_status_xml(const std::string &frame) +{ + std::string item_name; + xmlDocPtr document; + document = xmlParseMemory(frame.c_str(),frame.size()); + if (document == NULL) { + std::cout << "read_status_xml::no se creo documento" << std::endl; + return; + } + + xmlNodePtr nodo, items, props; + nodo = document->children; + float tmp; + bool tmp_b; + + if (strcmp((char *)nodo->name, "plantstatus") == 0) { + items = nodo->children; + while (items != NULL) { + if (items->type == XML_ELEMENT_NODE) { + tmp = -1; + item_name = ""; + if (xmlStrcmp(items->name, BAD_CAST"float")==0) { + tmp = get_float_from_xml(items->children); + item_name = (char *)xmlGetProp(items, BAD_CAST"name"); + mapItems[item_name]->set_actual_flow(tmp); + } else if (xmlStrcmp(items->name, BAD_CAST"exclusa")==0) { + tmp_b = get_bool_from_xml(items->children); + item_name = (char *)xmlGetProp(items, BAD_CAST"name"); + mapItems[item_name]->set_open(tmp_b); + } else if (xmlStrcmp(items->name, BAD_CAST"pump")==0) { + tmp_b = get_bool_from_xml(items->children); + item_name = (char *)xmlGetProp(items, BAD_CAST"name"); + mapItems[item_name]->set_open(tmp_b); + } else if (xmlStrcmp(items->name, BAD_CAST"logic")==0) { + tmp_b = get_bool_from_xml(items->children); + item_name = (char *)xmlGetProp(items, BAD_CAST"name"); + mapItems[item_name]->set_open(tmp_b); + } else if (xmlStrcmp(items->name, BAD_CAST"color")==0) { + item_name = (char *)xmlGetProp(items, BAD_CAST"name"); + mapItems[item_name]->set_color( get_rgb_from_xml(items->children) ); + } else if (xmlStrcmp(items->name, BAD_CAST"tank")==0) { + xmlNodePtr nodo_tmp = items->children; + float cap, lit; + cap = lit = -1; + bool b_inf, b_sup; + while (nodo_tmp != NULL) { + if (nodo_tmp->type == XML_ELEMENT_NODE) { + if (xmlStrcmp(nodo_tmp->name, BAD_CAST"capacity")==0) + cap = atof( (char *)XML_GET_CONTENT(nodo_tmp->children) ); + else if (xmlStrcmp(nodo_tmp->name, BAD_CAST"litros")==0) + lit= atof( (char *)XML_GET_CONTENT(nodo_tmp->children) ); + else if (xmlStrcmp(nodo_tmp->name, BAD_CAST"salida")==0) { + if (xmlStrcmp(xmlGetProp(items, BAD_CAST"id"), BAD_CAST"inferior")==0) { + b_inf = get_bool_from_xml(nodo_tmp->children); + } else { + b_sup = get_bool_from_xml(nodo_tmp->children); + } + } + } + nodo_tmp = nodo_tmp->next; + } + item_name = (char *)xmlGetProp(items, BAD_CAST"name"); + mapItems[item_name]->set_actual_flow(cap); + mapItems[item_name]->set_extra(lit); + dynamic_cast(mapItems[item_name])->set_out_sup(b_sup); + dynamic_cast(mapItems[item_name])->set_out_inf(b_inf); + } + } + items = items->next; + } + + xmlFreeDoc(document); + // Actualizo la UI + update_ui(); + } +} + +Gdk::Color Principal::get_rgb_from_xml(xmlNodePtr nodo) +{ + gushort r,g,b; + while (nodo != NULL) { + if (nodo->type == XML_ELEMENT_NODE) { + if (xmlStrcmp(nodo->name, BAD_CAST"r")==0) + r = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + if (xmlStrcmp(nodo->name, BAD_CAST"g")==0) + g = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + if (xmlStrcmp(nodo->name, BAD_CAST"b")==0) + b = atoi( (char *)XML_GET_CONTENT(nodo->children) ); + } + nodo = nodo->next; + } + r = static_cast(65535 * (r / 255.0f)); + g = static_cast(65535 * (g / 255.0f)); + b = static_cast(65535 * (b / 255.0f)); + Gdk::Color c; + c.set_rgb(r,g,b); + + return c; +} + +float Principal::get_float_from_xml(xmlNodePtr nodo) +{ + float tmp = -1; + while (nodo != NULL) { + if (nodo->type == XML_ELEMENT_NODE) { + if (xmlStrcmp(nodo->name, BAD_CAST"actual_flow")==0) { + tmp = atof( (char *)XML_GET_CONTENT(nodo->children) ); + break; + } + } + nodo = nodo->next; + } + if (tmp == INFINITO) tmp = 0; + return tmp; +} + +bool Principal::get_bool_from_xml(xmlNodePtr nodo) +{ + std::string tmp; + while (nodo != NULL) { + if (nodo->type == XML_ELEMENT_NODE) { + if (xmlStrcmp(nodo->name, BAD_CAST"active")==0) { + tmp = (char *)XML_GET_CONTENT(nodo->children); + break; + } + } + nodo = nodo->next; + } + return tmp == "true"; +} + +void Principal::on_mnu_property() +{ + dlg_property->show(); +} + +void Principal::on_dlg_property_ok() +{ + if (conexion) { + PlaQui::Server::Command c("plant", "set_frequency"); + c.add_arg("default"); + c.add_arg( dlg_property->get_velocity() ); + + conexion->send(c); + } + dlg_property->hide(); +} + +void Principal::on_btn_simulate_clicked() +{ + if (conexion == NULL) return; + + PlaQui::Server::Command c("plant", "start"); + c.add_arg("default"); + conexion->send(c); + paused = false; +} + +void Principal::on_btn_pause_clicked() +{ + if (conexion == NULL) return; + + PlaQui::Server::Command c("plant", "stop"); + c.add_arg("default"); + conexion->send(c); + paused = true; }