Simplification
This commit is contained in:
@@ -323,7 +323,7 @@ class MiseAEchelle
|
|||||||
float minEntree;
|
float minEntree;
|
||||||
float minSortie;
|
float minSortie;
|
||||||
float maxEntree;
|
float maxEntree;
|
||||||
float maxSortie;
|
float maxSortie;
|
||||||
};
|
};
|
||||||
|
|
||||||
/* READ */
|
/* READ */
|
||||||
@@ -409,19 +409,3 @@ void analogWrite(unsigned int p, double value)
|
|||||||
|
|
||||||
_digital[p].dvalue = value;
|
_digital[p].dvalue = value;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* ********************************************************
|
|
||||||
* Console *
|
|
||||||
* *
|
|
||||||
******************************************************** */
|
|
||||||
void ConsoleInit()
|
|
||||||
{
|
|
||||||
setlocale(LC_ALL, ""); // Activer le support des caractères Unicode
|
|
||||||
setlocale(LC_NUMERIC, "C");
|
|
||||||
initscr(); // Initialise ncurses
|
|
||||||
raw(); // Mode brut, sans besoin de validation par Entrée
|
|
||||||
keypad(stdscr, TRUE); // Active les touches spéciales comme ESC
|
|
||||||
nodelay(stdscr, TRUE); // Mode non-bloquant pour getch()
|
|
||||||
noecho(); // Ne pas afficher les touches appuyées
|
|
||||||
curs_set(0); // Masquer le curseur
|
|
||||||
}
|
|
||||||
|
|||||||
570
main.cpp
570
main.cpp
@@ -1,5 +1,7 @@
|
|||||||
|
#include <iostream>
|
||||||
|
#include <iomanip>
|
||||||
|
|
||||||
#include <unistd.h>
|
#include <unistd.h>
|
||||||
#include <ncurses.h>
|
|
||||||
#include <math.h>
|
#include <math.h>
|
||||||
#include <locale.h>
|
#include <locale.h>
|
||||||
#include <array>
|
#include <array>
|
||||||
@@ -12,11 +14,33 @@
|
|||||||
#include <prometheus/registry.h>
|
#include <prometheus/registry.h>
|
||||||
#include <prometheus/exposer.h>
|
#include <prometheus/exposer.h>
|
||||||
|
|
||||||
|
#include <curl/curl.h>
|
||||||
|
#include <string>
|
||||||
|
|
||||||
|
#include <thread>
|
||||||
|
#include <atomic>
|
||||||
|
#include <queue>
|
||||||
|
#include <mutex>
|
||||||
|
#include <condition_variable>
|
||||||
|
#include <csignal>
|
||||||
|
#include <chrono>
|
||||||
|
#include <cstring>
|
||||||
|
#undef timeout
|
||||||
|
#include "mqtt/async_client.h"
|
||||||
|
|
||||||
|
#include <nlohmann/json.hpp>
|
||||||
|
using json = nlohmann::json;
|
||||||
|
|
||||||
// Constantes de fonctionnement
|
// Constantes de fonctionnement
|
||||||
#define LEVEL_MIN 2
|
#define LEVEL_MIN 2
|
||||||
#define FLOW_PER_PUMP 150
|
#define FLOW_PER_PUMP 150
|
||||||
|
|
||||||
WINDOW *window;
|
/* Configuration MQTT */
|
||||||
|
const std::string ADDRESS = "tcp://rabbitmq:1883";
|
||||||
|
const std::string CLIENTID = "CppClientTP";
|
||||||
|
const std::string TOPIC = "geii/ordre/#";
|
||||||
|
const int QOS = 1;
|
||||||
|
const int CYCLE_MS = 100;
|
||||||
|
|
||||||
int etape = 0; // Étape du grafcet : début Automatique
|
int etape = 0; // Étape du grafcet : début Automatique
|
||||||
int bp_mode, bp_mode_fm;
|
int bp_mode, bp_mode_fm;
|
||||||
@@ -26,308 +50,91 @@ unsigned short sensor_max, sensor_high, sensor_low, sensor_min;
|
|||||||
|
|
||||||
float TankInitalValue = 7;
|
float TankInitalValue = 7;
|
||||||
|
|
||||||
TemporisationRetardMontee tempo1(500);
|
|
||||||
TemporisationRetardMontee tempo2(1000);
|
|
||||||
TemporisationRetardMontee tempo3(1500);
|
|
||||||
TemporisationRetardMontee tempo4(2000);
|
|
||||||
|
|
||||||
// Prometheus
|
// Prometheus
|
||||||
// ************************************************************
|
// ************************************************************
|
||||||
|
|
||||||
// ************************************************************
|
// ************************************************************
|
||||||
|
|
||||||
|
class callback : public virtual mqtt::callback {
|
||||||
|
public:
|
||||||
|
void message_arrived(mqtt::const_message_ptr msg) override {
|
||||||
|
std::string payload = msg->to_string();
|
||||||
|
|
||||||
|
if (payload == "p1") {
|
||||||
|
pompe1 = !pompe1;
|
||||||
|
} else if (payload == "p2") {
|
||||||
|
pompe2 = !pompe2;
|
||||||
|
} else if (payload == "p3") {
|
||||||
|
pompe3 = !pompe3;
|
||||||
|
} else if (payload == "p4") {
|
||||||
|
pompe4 = !pompe4;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
int main()
|
int main()
|
||||||
{
|
{
|
||||||
/* Initialisation */
|
/* Initialisation */
|
||||||
ConsoleInit();
|
|
||||||
AffichageWindow();
|
|
||||||
|
|
||||||
InitPrometheus();
|
InitPrometheus();
|
||||||
ProcessInitKeyboard();
|
|
||||||
ProcessInitIO();
|
ProcessInitIO();
|
||||||
ProcessInitValues();
|
ProcessInitValues();
|
||||||
|
|
||||||
|
mqtt::async_client client(ADDRESS, CLIENTID);
|
||||||
|
callback cb;
|
||||||
|
client.set_callback(cb);
|
||||||
|
|
||||||
|
mqtt::connect_options connOpts;
|
||||||
|
connOpts.set_clean_session(true);
|
||||||
|
connOpts.set_user_name("admin");
|
||||||
|
connOpts.set_password("geii2025");
|
||||||
|
try {
|
||||||
|
client.connect(connOpts)->wait();
|
||||||
|
client.start_consuming();
|
||||||
|
client.subscribe(TOPIC, QOS)->wait();
|
||||||
|
} catch (const mqtt::exception &exc) {
|
||||||
|
std::cerr << "Erreur MQTT: " << exc.what() << "\n";
|
||||||
|
return 1;
|
||||||
|
}
|
||||||
|
|
||||||
while (1)
|
while (1)
|
||||||
{
|
{
|
||||||
int ch = getch(); // Lit l'entrée du clavier sans bloquer
|
|
||||||
|
|
||||||
// **** Break loop if escape key (27) is pressed
|
|
||||||
if (ch == 27 || _digital[OUT_END].ivalue) {
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
// **** Beep
|
|
||||||
if (_digital[OUT_BEEP].ivalue)
|
|
||||||
{
|
|
||||||
beep();
|
|
||||||
_digital[OUT_BEEP].ivalue = false;
|
|
||||||
}
|
|
||||||
|
|
||||||
Process();
|
Process();
|
||||||
|
|
||||||
LireClavier(ch);
|
sensor_min = digitalRead(IN_SENSOR_MIN);
|
||||||
LireEntree();
|
sensor_low = digitalRead(IN_SENSOR_LOW);
|
||||||
EvolutionGrafcet();
|
sensor_high = digitalRead(IN_SENSOR_HIGH);
|
||||||
Actions();
|
sensor_max = digitalRead(IN_SENSOR_MAX);
|
||||||
|
|
||||||
|
digitalWrite(OUT_PUMP_1, (pompe1 == 1));
|
||||||
|
digitalWrite(OUT_PUMP_2, (pompe2 == 1));
|
||||||
|
digitalWrite(OUT_PUMP_3, (pompe3 == 1));
|
||||||
|
digitalWrite(OUT_PUMP_4, (pompe4 == 1));
|
||||||
|
|
||||||
ProcessPrometheus();
|
ProcessPrometheus();
|
||||||
|
ProcessMQTT(&client);
|
||||||
ProcessException();
|
ProcessException();
|
||||||
|
|
||||||
usleep(100000);
|
usleep(100000);
|
||||||
}
|
}
|
||||||
|
|
||||||
endwin(); // Termine ncurses et rétablit le terminal
|
try {
|
||||||
puts("Fin du programme");
|
client.unsubscribe(TOPIC)->wait();
|
||||||
|
client.stop_consuming();
|
||||||
|
client.disconnect()->wait();
|
||||||
|
} catch(const mqtt::exception &exc){
|
||||||
|
std::cerr << "Erreur déconnexion MQTT: " << exc.what() << std::endl;
|
||||||
|
}
|
||||||
|
|
||||||
|
std::cout << "Fin du programme" << std::endl;
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Programme
|
|
||||||
*/
|
|
||||||
void LireEntree()
|
|
||||||
{
|
|
||||||
int input;
|
|
||||||
input = digitalRead(IN_KEYBOARD_A);
|
|
||||||
bp_mode_fm = (input > bp_mode);
|
|
||||||
bp_mode = input;
|
|
||||||
|
|
||||||
sensor_min = digitalRead(IN_SENSOR_MIN);
|
|
||||||
sensor_low = digitalRead(IN_SENSOR_LOW);
|
|
||||||
sensor_high = digitalRead(IN_SENSOR_HIGH);
|
|
||||||
sensor_max = digitalRead(IN_SENSOR_MAX);
|
|
||||||
}
|
|
||||||
|
|
||||||
void EvolutionGrafcet()
|
|
||||||
{
|
|
||||||
int etape_futur = etape;
|
|
||||||
|
|
||||||
if (etape < 10 && bp_mode_fm)
|
|
||||||
{
|
|
||||||
etape_futur = 10;
|
|
||||||
pompe1 = pompe2 = pompe3 = pompe4 = 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape <= 2 && _digital[IN_KEYBOARD_1].raising)
|
|
||||||
{
|
|
||||||
pompe1 = !pompe1;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape <= 2 && _digital[IN_KEYBOARD_2].raising)
|
|
||||||
{
|
|
||||||
pompe2 = !pompe2;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape <= 2 && _digital[IN_KEYBOARD_3].raising)
|
|
||||||
{
|
|
||||||
pompe3 = !pompe3;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape <= 2 && _digital[IN_KEYBOARD_4].raising)
|
|
||||||
{
|
|
||||||
pompe4 = !pompe4;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 0 && !sensor_min)
|
|
||||||
{
|
|
||||||
etape_futur = 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 1)
|
|
||||||
{
|
|
||||||
etape_futur = 2;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 2 && sensor_min)
|
|
||||||
{
|
|
||||||
etape_futur = 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape >= 10 && bp_mode_fm)
|
|
||||||
{
|
|
||||||
etape_futur = 0;
|
|
||||||
pompe1 = pompe2 = pompe3 = pompe4 = 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (sensor_max)
|
|
||||||
{
|
|
||||||
pompe1 = pompe2 = pompe3 = pompe4 = 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Automatique */
|
|
||||||
if (etape == 10 && !sensor_low && !sensor_high)
|
|
||||||
{
|
|
||||||
etape_futur = 11;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 11 && sensor_high)
|
|
||||||
{
|
|
||||||
etape_futur = 10;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 11 && tempo1.getSortie())
|
|
||||||
{
|
|
||||||
etape_futur = 12;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 12 && sensor_high)
|
|
||||||
{
|
|
||||||
etape_futur = 13;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 12 && tempo2.getSortie())
|
|
||||||
{
|
|
||||||
etape_futur = 14; // Allumer le moteur 2
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 13 && tempo1.getSortie())
|
|
||||||
{
|
|
||||||
etape_futur = 10;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 13 && !sensor_low && !sensor_high)
|
|
||||||
{
|
|
||||||
etape_futur = 12;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 14 && sensor_high)
|
|
||||||
{
|
|
||||||
etape_futur = 15;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 14 && tempo3.getSortie())
|
|
||||||
{
|
|
||||||
etape_futur = 16;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 15 && tempo1.getSortie())
|
|
||||||
{
|
|
||||||
etape_futur = 13;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 15 && !sensor_low && !sensor_high)
|
|
||||||
{
|
|
||||||
etape_futur = 14;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 16 && sensor_high)
|
|
||||||
{
|
|
||||||
etape_futur = 17;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 16 && tempo4.getSortie())
|
|
||||||
{
|
|
||||||
etape_futur = 18;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 17 && tempo1.getSortie())
|
|
||||||
{
|
|
||||||
etape_futur = 15;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 17 && !sensor_low && !sensor_high)
|
|
||||||
{
|
|
||||||
etape_futur = 16;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 18 && sensor_high)
|
|
||||||
{
|
|
||||||
etape_futur = 19;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 19 && tempo1.getSortie())
|
|
||||||
{
|
|
||||||
etape_futur = 17;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (etape == 19 && !sensor_low && !sensor_high)
|
|
||||||
{
|
|
||||||
etape_futur = 18;
|
|
||||||
}
|
|
||||||
|
|
||||||
/* Fin de mode automatique */
|
|
||||||
|
|
||||||
if (etape != etape_futur)
|
|
||||||
{
|
|
||||||
etape = etape_futur;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
void Actions()
|
|
||||||
{
|
|
||||||
digitalWrite(OUT_DISPLAY_GRAFCET, etape);
|
|
||||||
digitalWrite(OUT_DISPLAY_MODE, etape >= 10);
|
|
||||||
digitalWrite(OUT_PUMP_1, !sensor_max && (pompe1 == 1 || etape >= 12));
|
|
||||||
digitalWrite(OUT_PUMP_2, !sensor_max && (pompe2 == 1 || etape >= 14));
|
|
||||||
digitalWrite(OUT_PUMP_3, !sensor_max && (pompe3 == 1 || etape >= 16));
|
|
||||||
digitalWrite(OUT_PUMP_4, !sensor_max && (pompe4 == 1 || etape >= 18));
|
|
||||||
// digitalWrite(OUT_BEEP, etape == 1);
|
|
||||||
|
|
||||||
if (etape >= 11)
|
|
||||||
{
|
|
||||||
tempo1.activation();
|
|
||||||
tempo2.activation();
|
|
||||||
tempo3.activation();
|
|
||||||
tempo4.activation();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Process
|
* Process
|
||||||
*/
|
*/
|
||||||
void ProcessInitKeyboard()
|
|
||||||
{
|
|
||||||
_keyboard[0].vKey = '1';
|
|
||||||
_keyboard[0].input = IN_KEYBOARD_1;
|
|
||||||
|
|
||||||
_keyboard[1].vKey = '2';
|
|
||||||
_keyboard[1].input = IN_KEYBOARD_2;
|
|
||||||
|
|
||||||
_keyboard[2].vKey = '3';
|
|
||||||
_keyboard[2].input = IN_KEYBOARD_3;
|
|
||||||
|
|
||||||
_keyboard[3].vKey = '4';
|
|
||||||
_keyboard[3].input = IN_KEYBOARD_4;
|
|
||||||
|
|
||||||
_keyboard[4].vKey = 'a';
|
|
||||||
_keyboard[4].input = IN_KEYBOARD_A;
|
|
||||||
|
|
||||||
_keyboard[5].vKey = 'x';
|
|
||||||
_keyboard[5].input = IN_KEYBOARD_X;
|
|
||||||
|
|
||||||
_keyboard[6].vKey = '6';
|
|
||||||
_keyboard[6].input = IN_KEYBOARD_7;
|
|
||||||
|
|
||||||
_keyboard[7].vKey = '7';
|
|
||||||
_keyboard[7].input = IN_KEYBOARD_8;
|
|
||||||
|
|
||||||
_keyboard[8].vKey = '8';
|
|
||||||
_keyboard[8].input = IN_KEYBOARD_9;
|
|
||||||
|
|
||||||
_keyboard[9].vKey = '9';
|
|
||||||
_keyboard[9].input = IN_KEYBOARD_0;
|
|
||||||
|
|
||||||
for (int i = 0; i < NB_KEYBOARD; i++)
|
|
||||||
{
|
|
||||||
_digital[_keyboard[i].input].mode = OP_DIGITAL_READ;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
void ProcessInitIO()
|
void ProcessInitIO()
|
||||||
{
|
{
|
||||||
pinMode(IN_KEYBOARD_1, IO_INPUT | DIGITAL);
|
|
||||||
pinMode(IN_KEYBOARD_2, IO_INPUT | DIGITAL);
|
|
||||||
pinMode(IN_KEYBOARD_3, IO_INPUT | DIGITAL);
|
|
||||||
pinMode(IN_KEYBOARD_4, IO_INPUT | DIGITAL);
|
|
||||||
pinMode(IN_KEYBOARD_A, IO_INPUT | DIGITAL);
|
|
||||||
|
|
||||||
pinMode(IN_KEYBOARD_7, IO_INPUT | DIGITAL);
|
|
||||||
pinMode(IN_KEYBOARD_8, IO_INPUT | DIGITAL);
|
|
||||||
pinMode(IN_KEYBOARD_9, IO_INPUT | DIGITAL);
|
|
||||||
pinMode(IN_KEYBOARD_0, IO_INPUT | DIGITAL);
|
|
||||||
pinMode(IN_KEYBOARD_X, IO_INPUT | DIGITAL);
|
|
||||||
|
|
||||||
pinMode(IN_SENSOR_MIN, IO_INPUT | DIGITAL);
|
pinMode(IN_SENSOR_MIN, IO_INPUT | DIGITAL);
|
||||||
pinMode(IN_SENSOR_LOW, IO_INPUT | DIGITAL);
|
pinMode(IN_SENSOR_LOW, IO_INPUT | DIGITAL);
|
||||||
pinMode(IN_SENSOR_HIGH, IO_INPUT | DIGITAL);
|
pinMode(IN_SENSOR_HIGH, IO_INPUT | DIGITAL);
|
||||||
@@ -495,25 +302,6 @@ void Process()
|
|||||||
_digital[IN_TANK_MIN].dvalue = _digital[IN_TANK_LEVEL].dvalue;
|
_digital[IN_TANK_MIN].dvalue = _digital[IN_TANK_LEVEL].dvalue;
|
||||||
}
|
}
|
||||||
|
|
||||||
// **** KEYBOARD
|
|
||||||
if (_digital[IN_KEYBOARD_X].raising)
|
|
||||||
{
|
|
||||||
_digital[IN_SENSOR_LOW].mode = _digital[IN_SENSOR_LOW].mode ^ 0x01;
|
|
||||||
}
|
|
||||||
|
|
||||||
for (int i = IN_KEYBOARD_7; i <= IN_KEYBOARD_0; i++)
|
|
||||||
{
|
|
||||||
if (_digital[i].raising)
|
|
||||||
{
|
|
||||||
unsigned char p = i + (OUT_PUMP_1 - IN_KEYBOARD_7);
|
|
||||||
_digital[p].mode ^= 0x01;
|
|
||||||
if (!(_digital[p].mode & 0x01)) {
|
|
||||||
_digital[p].ivalue = 0;
|
|
||||||
_digital[p].dvalue = 0.0;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// **** SENSOR
|
// **** SENSOR
|
||||||
int test;
|
int test;
|
||||||
|
|
||||||
@@ -557,8 +345,6 @@ void Process()
|
|||||||
_digital[IN_SENSOR_HIGH].ivalue = test;
|
_digital[IN_SENSOR_HIGH].ivalue = test;
|
||||||
}
|
}
|
||||||
|
|
||||||
Affichage();
|
|
||||||
|
|
||||||
t_backup = t;
|
t_backup = t;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -575,8 +361,6 @@ double SimulConsoBrown(double valeur_precedente)
|
|||||||
float mu = 0.01 * -((((int)t_elapsed / 30) % 2) * 2 - 1); // Taux de croissance (1%)
|
float mu = 0.01 * -((((int)t_elapsed / 30) % 2) * 2 - 1); // Taux de croissance (1%)
|
||||||
float sigma = 0.05; // Volatilité (5%)
|
float sigma = 0.05; // Volatilité (5%)
|
||||||
|
|
||||||
mvprintw(8, 40, "(µ %.1f %% ; σ %.1f %%) ", mu * 100, sigma * 100);
|
|
||||||
|
|
||||||
// Nombre aléatoire compris dans [-1 +1]
|
// Nombre aléatoire compris dans [-1 +1]
|
||||||
float rand_std_normal = ((double)rand() / RAND_MAX) * 2.0 - 1.0;
|
float rand_std_normal = ((double)rand() / RAND_MAX) * 2.0 - 1.0;
|
||||||
|
|
||||||
@@ -591,185 +375,6 @@ double SimulConsoBrown(double valeur_precedente)
|
|||||||
* Affichage dans la console
|
* Affichage dans la console
|
||||||
*/
|
*/
|
||||||
|
|
||||||
/**
|
|
||||||
* Initialisation, affichage des parties statiques
|
|
||||||
*/
|
|
||||||
void AffichageWindow()
|
|
||||||
{
|
|
||||||
window = subwin(stdscr, 19, 62, 0, 0);
|
|
||||||
|
|
||||||
box(window, 0, 0);
|
|
||||||
|
|
||||||
// Titre
|
|
||||||
mvwprintw(window, 1, 2, "Château d'eau (11/2024)");
|
|
||||||
|
|
||||||
// I/O
|
|
||||||
// Ligne du haut
|
|
||||||
mvwaddch(window, 2, 0, ACS_LTEE);
|
|
||||||
mvwhline(window, 2, 1, 0, 60);
|
|
||||||
mvwaddch(window, 2, 61, ACS_RTEE);
|
|
||||||
|
|
||||||
// Ligne du bas
|
|
||||||
mvwaddch(window, 7, 0, ACS_LTEE);
|
|
||||||
mvwhline(window, 7, 1, 0, 60);
|
|
||||||
mvwaddch(window, 7, 61, ACS_RTEE);
|
|
||||||
|
|
||||||
// Séparation verticale
|
|
||||||
mvwaddch(window, 2, 18, ACS_TTEE);
|
|
||||||
mvwvline(window, 3, 18, 0, 4);
|
|
||||||
mvwaddch(window, 7, 18, ACS_BTEE);
|
|
||||||
|
|
||||||
// Input : Boutons poussoirs
|
|
||||||
mvwprintw(window, 3, 2, "BP 1");
|
|
||||||
mvwprintw(window, 4, 2, "BP 2");
|
|
||||||
mvwprintw(window, 5, 2, "BP 3");
|
|
||||||
mvwprintw(window, 6, 2, "BP 4");
|
|
||||||
|
|
||||||
// Output : Moteurs pompes
|
|
||||||
mvwprintw(window, 3, 20, "Pompe 1");
|
|
||||||
mvwprintw(window, 4, 20, "Pompe 2");
|
|
||||||
mvwprintw(window, 5, 20, "Pompe 3");
|
|
||||||
mvwprintw(window, 6, 20, "Pompe 4");
|
|
||||||
|
|
||||||
// Mesures
|
|
||||||
mvwprintw(window, 8, 2, "Debit en sortie");
|
|
||||||
mvwprintw(window, 9, 2, "Debit en entrée");
|
|
||||||
mvwprintw(window, 10, 2, "Volume dans le réservoir");
|
|
||||||
|
|
||||||
// Graphe
|
|
||||||
|
|
||||||
// Ligne du haut
|
|
||||||
mvwaddch(window, 11, 0, ACS_LTEE);
|
|
||||||
mvwhline(window, 11, 1, 0, 60);
|
|
||||||
mvwaddch(window, 11, 61, ACS_RTEE);
|
|
||||||
|
|
||||||
// Ligne du bas
|
|
||||||
mvwaddch(window, 13, 0, ACS_LTEE);
|
|
||||||
mvwhline(window, 13, 1, 0, 60);
|
|
||||||
mvwaddch(window, 13, 61, ACS_RTEE);
|
|
||||||
|
|
||||||
// Graduations
|
|
||||||
for (int i = 1 ; i < 11; i++) {
|
|
||||||
mvwaddch(window, 11, 6 * i, ACS_TTEE);
|
|
||||||
mvwaddch(window, 13, 6 * i, ACS_BTEE);
|
|
||||||
}
|
|
||||||
|
|
||||||
mvwaddch(window, 13, 2 * 6, ACS_PLUS);
|
|
||||||
mvwaddch(window, 13, 6 * 6, ACS_PLUS);
|
|
||||||
mvwaddch(window, 13, 7 * 6, ACS_PLUS);
|
|
||||||
mvwaddch(window, 13, 57, ACS_TTEE); //9.5 x 6
|
|
||||||
|
|
||||||
mvwvline(window, 12, 6 * 10, 0, 1);
|
|
||||||
|
|
||||||
// Légende
|
|
||||||
mvwaddch(window, 16, 0, ACS_LTEE);
|
|
||||||
mvwhline(window, 16, 1, 0, 60);
|
|
||||||
mvwaddch(window, 16, 61, ACS_RTEE);
|
|
||||||
|
|
||||||
mvwprintw(window, 14, 2 * 6 - 1, "min");
|
|
||||||
mvwprintw(window, 14, 6 * 6 - 2, "low");
|
|
||||||
mvwprintw(window, 14, 7 * 6, "high");
|
|
||||||
mvwprintw(window, 14, 56, "max");
|
|
||||||
|
|
||||||
// Informations
|
|
||||||
mvwprintw(window, 17, 2, "Mode");
|
|
||||||
|
|
||||||
mvwaddch(window, 16, 18, ACS_TTEE);
|
|
||||||
mvwaddch(window, 18, 18, ACS_BTEE);
|
|
||||||
mvwvline(window, 17, 18, 0, 1);
|
|
||||||
mvwprintw(window, 17, 20, "Grafcet");
|
|
||||||
|
|
||||||
mvwaddch(window, 16, 31, ACS_TTEE);
|
|
||||||
mvwaddch(window, 18, 31, ACS_BTEE);
|
|
||||||
mvwvline(window, 17, 31, 0, 1);
|
|
||||||
mvwprintw(window, 17, 33, "min");
|
|
||||||
|
|
||||||
mvwprintw(window, 17, 46, "max");
|
|
||||||
|
|
||||||
wrefresh(window);
|
|
||||||
}
|
|
||||||
|
|
||||||
void Affichage()
|
|
||||||
{
|
|
||||||
mvwprintw(window, 1, 50, "%5.1f s", t_elapsed);
|
|
||||||
|
|
||||||
for (int i = OUT_PUMP_1; i <= OUT_PUMP_4; i++)
|
|
||||||
{
|
|
||||||
mvwprintw(window, (short)(i - OUT_PUMP_1 + 3), 30, " %c %5.1f s %dx", _digital[i].mode & 0x01 ? _digital[i].ivalue ? 'M' : '.' : 'X', _digital[i].duration, _digital[i].nb);
|
|
||||||
}
|
|
||||||
|
|
||||||
for (int i = IN_KEYBOARD_1; i <= IN_KEYBOARD_4; i++)
|
|
||||||
{
|
|
||||||
mvwprintw(window, (short)(i + 3), 10, _digital[_keyboard[i].input].ivalue ? "1" : "0");
|
|
||||||
}
|
|
||||||
|
|
||||||
mvwprintw(window, 8, 28, "%3d l/s", (int)_digital[IN_FLOW_OUT].dvalue);
|
|
||||||
mvwprintw(window, 9, 28, "%3d l/s", (int)_digital[IN_FLOW_IN].dvalue);
|
|
||||||
mvwprintw(window, 10, 29, "%5.2lf m3 (%+d l/s)", _digital[IN_TANK_LEVEL].dvalue, (int)_digital[IN_FLOW_DIF].dvalue);
|
|
||||||
|
|
||||||
AffichageGraphe(12, 1, _digital[IN_TANK_LEVEL].dvalue * 6);
|
|
||||||
|
|
||||||
/*
|
|
||||||
if (_digital[IN_SENSOR_LOW].mode & 0x01)
|
|
||||||
{
|
|
||||||
mvwprintw(window, 15, 1, " (%dx) (%dx) (%dx) (%dx)", _digital[IN_SENSOR_MIN].nb, _digital[IN_SENSOR_LOW].nb, _digital[IN_SENSOR_HIGH].nb, _digital[IN_SENSOR_MAX].nb);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
mvwprintw(window, 15, 1, " (%dx) X (%dx) (%dx) (%dx)", _digital[IN_SENSOR_MIN].nb, _digital[IN_SENSOR_LOW].nb, _digital[IN_SENSOR_HIGH].nb, _digital[IN_SENSOR_MAX].nb);
|
|
||||||
}
|
|
||||||
*/
|
|
||||||
mvwprintw(window, 14, 15, "%d", _digital[IN_SENSOR_MIN].ivalue);
|
|
||||||
mvwprintw(window, 14, 38, "%d", _digital[IN_SENSOR_LOW].ivalue);
|
|
||||||
mvwprintw(window, 14, 47, "%d", _digital[IN_SENSOR_HIGH].ivalue);
|
|
||||||
mvwprintw(window, 14, 60, "%d", _digital[IN_SENSOR_MAX].ivalue);
|
|
||||||
|
|
||||||
mvwprintw(window, 15, 11, "(%dx) %s", _digital[IN_SENSOR_MIN].nb, _digital[IN_SENSOR_MIN].mode & 0x01 ? " " : "D");
|
|
||||||
mvwprintw(window, 15, 34, "(%dx) %s", _digital[IN_SENSOR_LOW].nb, _digital[IN_SENSOR_LOW].mode & 0x01 ? " " : "D");
|
|
||||||
mvwprintw(window, 15, 42, "(%dx) %s", _digital[IN_SENSOR_HIGH].nb, _digital[IN_SENSOR_HIGH].mode & 0x01 ? " " : "D");
|
|
||||||
mvwprintw(window, 15, 56, "(%dx)", _digital[IN_SENSOR_MAX].nb);
|
|
||||||
|
|
||||||
// Informations complémentaires
|
|
||||||
mvwprintw(window, 17, 2, _digital[OUT_DISPLAY_MODE].ivalue ? "Automatique" : "Manuel ");
|
|
||||||
mvwprintw(window, 17, 28, "%d", _digital[OUT_DISPLAY_GRAFCET].ivalue);
|
|
||||||
mvwprintw(window, 17, 38, "%4.2lf m3", _digital[IN_TANK_MIN].dvalue);
|
|
||||||
mvwprintw(window, 17, 51, "%4.2lf m3", _digital[IN_TANK_MAX].dvalue);
|
|
||||||
|
|
||||||
wrefresh(window);
|
|
||||||
}
|
|
||||||
|
|
||||||
void AffichageGraphe(int y, int x, double value)
|
|
||||||
{
|
|
||||||
int entier = (int)(value);
|
|
||||||
int i;
|
|
||||||
|
|
||||||
for (i = 0; i < entier; i++)
|
|
||||||
{
|
|
||||||
mvwaddwstr(window, y, x + i, L"█"); // U+2588
|
|
||||||
}
|
|
||||||
|
|
||||||
int frac = (int)((value - entier) * 4);
|
|
||||||
if (frac > 3) // 0.75 -> 0.99
|
|
||||||
{
|
|
||||||
mvwaddwstr(window, y, x + i, L"▊"); // U+258A
|
|
||||||
entier += 1;
|
|
||||||
}
|
|
||||||
if (frac > 2) // 0.5 -> 0.99
|
|
||||||
{
|
|
||||||
mvwaddwstr(window, y, x + i, L"▌"); // U+258C
|
|
||||||
entier += 1;
|
|
||||||
}
|
|
||||||
else if (frac > 1) // 0.25 -> 0.49
|
|
||||||
{
|
|
||||||
mvwaddwstr(window, y, x + i, L"▎"); //U+258E
|
|
||||||
entier += 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
for (int i = entier; i < 59; i++)
|
|
||||||
{
|
|
||||||
mvwprintw(window, y, x + i, " ");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Prometheus
|
* Prometheus
|
||||||
@@ -787,5 +392,22 @@ void ProcessPrometheus()
|
|||||||
|
|
||||||
void ProcessMQTT(mqtt::async_client* client)
|
void ProcessMQTT(mqtt::async_client* client)
|
||||||
{
|
{
|
||||||
|
json obj = {
|
||||||
|
{"entree", _digital[IN_FLOW_IN].dvalue},
|
||||||
|
{"sortie", _digital[IN_FLOW_OUT].dvalue},
|
||||||
|
{"tank", _digital[IN_TANK_LEVEL].dvalue},
|
||||||
|
{"pompe1", _digital[IN_FLOW_1].dvalue},
|
||||||
|
{"pompe2", _digital[IN_FLOW_2].dvalue},
|
||||||
|
{"pompe3", _digital[IN_FLOW_3].dvalue},
|
||||||
|
{"pompe4", _digital[IN_FLOW_4].dvalue},
|
||||||
|
{"min", _digital[IN_SENSOR_MIN].ivalue},
|
||||||
|
{"low", _digital[IN_SENSOR_LOW].ivalue},
|
||||||
|
{"high", _digital[IN_SENSOR_HIGH].ivalue},
|
||||||
|
{"max", _digital[IN_SENSOR_MAX].ivalue},
|
||||||
|
};
|
||||||
|
|
||||||
|
std::string payload = obj.dump();
|
||||||
|
auto msg = mqtt::make_message("geii/telemetry", payload);
|
||||||
|
msg->set_qos(1);
|
||||||
|
client->publish(msg);
|
||||||
}
|
}
|
||||||
|
|||||||
25
main.hpp
25
main.hpp
@@ -1,15 +1,8 @@
|
|||||||
#undef timeout
|
#undef timeout
|
||||||
#include "mqtt/async_client.h"
|
#include "mqtt/async_client.h"
|
||||||
|
|
||||||
void ConsoleInit();
|
|
||||||
|
|
||||||
void LireClavier(int ch);
|
|
||||||
void LireEntree();
|
|
||||||
void EvolutionGrafcet();
|
|
||||||
void Actions();
|
|
||||||
void RemiseZeroInput();
|
void RemiseZeroInput();
|
||||||
|
|
||||||
void ProcessInitKeyboard();
|
|
||||||
void ProcessInitIO();
|
void ProcessInitIO();
|
||||||
void ProcessInitValues();
|
void ProcessInitValues();
|
||||||
double ProcessMoteur(int i);
|
double ProcessMoteur(int i);
|
||||||
@@ -24,24 +17,6 @@ void ProcessMQTT(mqtt::async_client* client);
|
|||||||
double SimulConsoSinusoidale(long t);
|
double SimulConsoSinusoidale(long t);
|
||||||
double SimulConsoBrown(double valeur_precedente);
|
double SimulConsoBrown(double valeur_precedente);
|
||||||
|
|
||||||
void AffichageWindow();
|
|
||||||
void Affichage();
|
|
||||||
void AffichageGraphe(int y, int x, double value);
|
|
||||||
|
|
||||||
// KEYBOARD INPUT
|
|
||||||
|
|
||||||
#define IN_KEYBOARD_1 0
|
|
||||||
#define IN_KEYBOARD_2 1
|
|
||||||
#define IN_KEYBOARD_3 2
|
|
||||||
#define IN_KEYBOARD_4 3
|
|
||||||
#define IN_KEYBOARD_A 4
|
|
||||||
|
|
||||||
#define IN_KEYBOARD_X 5
|
|
||||||
#define IN_KEYBOARD_7 6
|
|
||||||
#define IN_KEYBOARD_8 7
|
|
||||||
#define IN_KEYBOARD_9 8
|
|
||||||
#define IN_KEYBOARD_0 9
|
|
||||||
|
|
||||||
// DIGITAL INPUT
|
// DIGITAL INPUT
|
||||||
|
|
||||||
#define IN_SENSOR_MIN 10
|
#define IN_SENSOR_MIN 10
|
||||||
|
|||||||
Reference in New Issue
Block a user