Rework de la lib dolibarr

This commit is contained in:
Nicolas SANS 2024-02-09 08:31:10 +01:00
parent 23258e2682
commit d2dec55110
7 changed files with 32 additions and 71 deletions

View File

@ -22,7 +22,7 @@ build_flags =
-D STEPER_ACC=200 -D STEPER_ACC=200
;-D STEPER_PAS=755.906 ; = 65mm ;-D STEPER_PAS=755.906 ; = 65mm
-D STEPER_PAS=58 ; = 5mm -D STEPER_PAS=58 ; = 5mm
-D STEPER_SPEED=1000 ; 12000 -D STEPER_SPEED=2700 ;1000 ; 2500
;;;;;;;;;;;;;;;;;;;;;; ;;;;;;;;;;;;;;;;;;;;;;
;;; App config ;;; ;;; App config ;;;
;;;;;;;;;;;;;;;;;;;;;; ;;;;;;;;;;;;;;;;;;;;;;
@ -33,7 +33,8 @@ build_flags =
;;;;;;;;;;;;;;;;;;;;;; ;;;;;;;;;;;;;;;;;;;;;;
;;; Servo config ;;; ;;; Servo config ;;;
;;;;;;;;;;;;;;;;;;;;;; ;;;;;;;;;;;;;;;;;;;;;;
-D RIGHT_POS=18 -D RIGHT_POS=14 ;18
-D MIDDLE_POS=32 -D MIDDLE_POS=30 ;32
-D LEFT_POS=52 -D LEFT_POS=52
-D CONVOYER_LEN=150 ;mm
-D CONVOYER_LEN=80 ;mm

View File

@ -21,6 +21,7 @@ public:
void checkNfc(); void checkNfc();
void checkServo(); void checkServo();
void checkWifi(); void checkWifi();
void moveStepper();
private: private:
DolibarrClient *client; DolibarrClient *client;
ServoMotorComponent *servo; ServoMotorComponent *servo;

View File

@ -4,6 +4,8 @@
#include <iostream> #include <iostream>
#include "M5LCD.h" #include "M5LCD.h"
HTTPClient *client = new HTTPClient();
DolibarrClient::DolibarrClient(struct DolibarrConfig dolibarr_config) : dolibarr(dolibarr_config) { DolibarrClient::DolibarrClient(struct DolibarrConfig dolibarr_config) : dolibarr(dolibarr_config) {
#if defined(DEBUG) #if defined(DEBUG)
Serial.println(" --- Dolibarr configuration --- "); Serial.println(" --- Dolibarr configuration --- ");
@ -14,7 +16,6 @@ DolibarrClient::DolibarrClient(struct DolibarrConfig dolibarr_config) : dolibarr
} }
HTTPClient *DolibarrClient::build_url(const String& url) const { HTTPClient *DolibarrClient::build_url(const String& url) const {
auto *client = new HTTPClient();
String clientUrl = this->dolibarr.url + url; String clientUrl = this->dolibarr.url + url;
client->begin(clientUrl); client->begin(clientUrl);
client->addHeader("Content-Type", "application/json"); client->addHeader("Content-Type", "application/json");
@ -25,40 +26,12 @@ HTTPClient *DolibarrClient::build_url(const String& url) const {
return client; return client;
} }
int DolibarrClient::login() const {
HTTPClient *client = this->build_url(API_LOGIN_URL);
int httpResponseCode = client->GET();
if (httpResponseCode > 0) {
DynamicJsonDocument doc(384);
DeserializationError error = deserializeJson(doc, client->getString().c_str());
if (error) {
Serial.println("ERROR: ");
Serial.println(error.c_str());
delete client;
return -1;
}
delete client;
return 0;
}
delete client;
return -1;
}
String replace_id(const char *str, const char *id) { String replace_id(const char *str, const char *id) {
String url(str); String url(str);
url.replace("{id}", id); url.replace("{id}", id);
return url; return url;
} }
std::vector<models::Product> *DolibarrClient::list_products() const {
HTTPClient *client = this->build_url(API_LIST_PRODUCT_URL);
if (client->GET() == HTTP_CODE_OK) {
}
return nullptr;
}
models::Product DolibarrClient::get_product_by_factory_id(const char* factory_id) const { models::Product DolibarrClient::get_product_by_factory_id(const char* factory_id) const {
HTTPClient *client = this->build_url(replace_id("/products?sortorder=ASC&limit=1&sqlfilters=(t.accountancy_code_sell:like:'{id}')", factory_id).c_str()); HTTPClient *client = this->build_url(replace_id("/products?sortorder=ASC&limit=1&sqlfilters=(t.accountancy_code_sell:like:'{id}')", factory_id).c_str());
if (client->GET() == HTTP_CODE_OK) { if (client->GET() == HTTP_CODE_OK) {
@ -67,7 +40,6 @@ models::Product DolibarrClient::get_product_by_factory_id(const char* factory_id
if (error) { if (error) {
Serial.println("ERROR: "); Serial.println("ERROR: ");
Serial.println(error.c_str()); Serial.println(error.c_str());
delete client;
return {}; return {};
} }
for (auto obj : doc.as<JsonArray>()) { for (auto obj : doc.as<JsonArray>()) {
@ -80,13 +52,10 @@ models::Product DolibarrClient::get_product_by_factory_id(const char* factory_id
product.accountancy_code_sell = obj["accountancy_code_sell"].as<std::string>(); product.accountancy_code_sell = obj["accountancy_code_sell"].as<std::string>();
product.accountancy_code_sell_export = obj["accountancy_code_sell_export"].as<std::string>(); product.accountancy_code_sell_export = obj["accountancy_code_sell_export"].as<std::string>();
product.fk_default_warehouse = obj["fk_default_warehouse"].as<std::string>(); product.fk_default_warehouse = obj["fk_default_warehouse"].as<std::string>();
delete client;
return product; return product;
} }
delete client;
return {}; return {};
} }
delete client;
return {}; return {};
} }
@ -96,7 +65,6 @@ models::Product *DolibarrClient::get_product_by_id(const char* id_product) const
DynamicJsonDocument doc(6144); DynamicJsonDocument doc(6144);
DeserializationError error = deserializeJson(doc, client->getString().c_str()); DeserializationError error = deserializeJson(doc, client->getString().c_str());
if (error) { if (error) {
delete client;
return nullptr; return nullptr;
} }
auto *product = new models::Product(); auto *product = new models::Product();
@ -107,10 +75,8 @@ models::Product *DolibarrClient::get_product_by_id(const char* id_product) const
product->label = doc["label"].as<std::string>(); product->label = doc["label"].as<std::string>();
product->accountancy_code_sell = doc["accountancy_code_sell"].as<std::string>(); product->accountancy_code_sell = doc["accountancy_code_sell"].as<std::string>();
product->accountancy_code_sell_export = doc["accountancy_code_sell_export"].as<std::string>(); product->accountancy_code_sell_export = doc["accountancy_code_sell_export"].as<std::string>();
delete client;
return product; return product;
} }
delete client;
return nullptr; return nullptr;
} }
@ -122,7 +88,6 @@ std::vector<models::Warehouse> *DolibarrClient::list_warehouse() const {
if (error) { if (error) {
Serial.println("ERROR: "); Serial.println("ERROR: ");
Serial.println(error.c_str()); Serial.println(error.c_str());
delete client;
return nullptr; return nullptr;
} }
auto *warehouses = new std::vector<models::Warehouse>(); auto *warehouses = new std::vector<models::Warehouse>();
@ -132,10 +97,8 @@ std::vector<models::Warehouse> *DolibarrClient::list_warehouse() const {
warehouse.label = obj["label"].as<std::string>(); warehouse.label = obj["label"].as<std::string>();
warehouses->push_back(warehouse); warehouses->push_back(warehouse);
} }
delete client;
return warehouses; return warehouses;
} }
delete client;
return nullptr; return nullptr;
} }
@ -151,7 +114,6 @@ int DolibarrClient::create_movement(models::CreateProductStock stock) const {
serializeJson(doc, result); serializeJson(doc, result);
Serial.println(result.c_str()); Serial.println(result.c_str());
if (client->POST(result.c_str()) == HTTP_CODE_OK) { if (client->POST(result.c_str()) == HTTP_CODE_OK) {
delete client;
return 0; return 0;
} }
return -1; return -1;

View File

@ -20,9 +20,7 @@ class DolibarrClient {
public: public:
DolibarrClient(DolibarrConfig dolibarr_config); DolibarrClient(DolibarrConfig dolibarr_config);
~DolibarrClient() = default; ~DolibarrClient() = default;
int login() const;
std::vector<models::Warehouse> *list_warehouse() const; std::vector<models::Warehouse> *list_warehouse() const;
std::vector<models::Product> *list_products() const;
models::Product *get_product_by_id(const char* id_product) const; models::Product *get_product_by_id(const char* id_product) const;
models::Product get_product_by_factory_id(const char* uuid) const; models::Product get_product_by_factory_id(const char* uuid) const;
int create_movement(models::CreateProductStock stock) const; int create_movement(models::CreateProductStock stock) const;

View File

@ -4,7 +4,7 @@
* M5LCD classe * M5LCD classe
*/ */
M5LCD::M5LCD() : _current_page(0), _logs() , _debug_loc_y(0), _components_status({COMPONENT_KO, COMPONENT_KO, COMPONENT_KO, COMPONENT_KO, COMPONENT_KO}) { M5LCD::M5LCD() : _current_page(0), _logs() , _debug_loc_y(0), _components_status({COMPONENT_KO, COMPONENT_KO, COMPONENT_KO, COMPONENT_KO, COMPONENT_OK}) {
this->_product_id = std::string(""); this->_product_id = std::string("");
this->_product_label = std::string(""); this->_product_label = std::string("");
this->_last_nfc = std::string(""); this->_last_nfc = std::string("");

View File

@ -6,6 +6,8 @@
#include "NfcReader.h" #include "NfcReader.h"
#include <Ticker.h> #include <Ticker.h>
TaskHandle_t task1;
uint32_t derniereExecution = 0; uint32_t derniereExecution = 0;
const uint32_t intervalle = 1000; const uint32_t intervalle = 1000;
std::vector<models::Warehouse> *warehouses; std::vector<models::Warehouse> *warehouses;
@ -78,6 +80,7 @@ Program::Program() {
lcdScreen->add_log("Initialize M5LCD component...."); lcdScreen->add_log("Initialize M5LCD component....");
this->nfcReader = new NfcReader(NFC_ADDR); this->nfcReader = new NfcReader(NFC_ADDR);
this->servo = new ServoMotorComponent(2, 1, 1); this->servo = new ServoMotorComponent(2, 1, 1);
this->servo->setDesiredPosition(MIDDLE);
this->grbl = new GRBL(STEPMOTOR_I2C_ADDR); this->grbl = new GRBL(STEPMOTOR_I2C_ADDR);
Wire.begin(21, 22); Wire.begin(21, 22);
grbl->init(STEPER_SPEED, STEPER_PAS, STEPER_ACC); grbl->init(STEPER_SPEED, STEPER_PAS, STEPER_ACC);
@ -85,6 +88,11 @@ Program::Program() {
initialize_wifi(wifi_c); initialize_wifi(wifi_c);
} }
void Program::moveStepper() {
Serial.printf("moveStepper\n");
this->grbl->mouveForward(5);
}
void Program::loop() { void Program::loop() {
lcdScreen->update(); lcdScreen->update();
@ -96,18 +104,13 @@ void Program::loop() {
derniereExecution = maintenant; derniereExecution = maintenant;
} }
this->servo->refresh(); this->servo->refresh();
String nfcId = this->nfcReader->ReadNfc(); String nfcId = this->nfcReader->ReadNfc();
//si qqc
if(nfcId != "0"){ if(nfcId != "0"){
if (lcdScreen->get_components().wifi != COMPONENT_OK) { if (lcdScreen->get_components().wifi != COMPONENT_OK) {
lcdScreen->add_log("Wifi not connected !"); lcdScreen->add_log("Wifi not connected !");
lcdScreen->set_nfc_message("Cannot send wifi request !"); lcdScreen->set_nfc_message("Cannot send wifi request !");
return; return;
} }
//j'arrète le stepper
//this->grbl->stop(); //FIXME: implemente
//j'affiche le tag lue
Serial.print("new colis in comming : "); Serial.print("new colis in comming : ");
lcdScreen->add_log("new colis detected: "); lcdScreen->add_log("new colis detected: ");
lcdScreen->add_log(nfcId.c_str()); lcdScreen->add_log(nfcId.c_str());
@ -116,10 +119,6 @@ void Program::loop() {
Serial.printf("Product: %s\n%s", product.label.c_str(), product.accountancy_code_sell_export.c_str()); Serial.printf("Product: %s\n%s", product.label.c_str(), product.accountancy_code_sell_export.c_str());
lcdScreen->set_product_label(product.label); lcdScreen->set_product_label(product.label);
lcdScreen->set_product_id(product.id); lcdScreen->set_product_id(product.id);
/*if (product.fk_default_warehouse == product.accountancy_code_sell_export) {
Serial.printf("Product already in the good warehouse !\n");
return;
}*/
auto ware = std::find_if(warehouses->begin(), warehouses->end(), [&product](models::Warehouse w) {return w.id == product.accountancy_code_sell_export;}); auto ware = std::find_if(warehouses->begin(), warehouses->end(), [&product](models::Warehouse w) {return w.id == product.accountancy_code_sell_export;});
if (ware.base() == nullptr) { if (ware.base() == nullptr) {
Serial.printf("Warehouse not found !\n"); Serial.printf("Warehouse not found !\n");
@ -150,10 +149,10 @@ void Program::loop() {
this->servo->setDesiredPosition(Position::MIDDLE); this->servo->setDesiredPosition(Position::MIDDLE);
lcdScreen->set_servo_message("MIDDLE"); lcdScreen->set_servo_message("MIDDLE");
} }
this->grbl->mouveForward(CONVOYER_LEN); //this->grbl->mouveForward(CONVOYER_LEN);
} else { } else {
if(this->grbl->isIddle()){ /*if(this->grbl->isIddle()){
this->grbl->mouveForward(5); this->grbl->mouveForward(5);
} }*/
} }
} }