aboutsummaryrefslogtreecommitdiff
path: root/software/main/main.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'software/main/main.cpp')
-rw-r--r--software/main/main.cpp488
1 files changed, 488 insertions, 0 deletions
diff --git a/software/main/main.cpp b/software/main/main.cpp
new file mode 100644
index 0000000..a7147bb
--- /dev/null
+++ b/software/main/main.cpp
@@ -0,0 +1,488 @@
+/*
+ * main.cpp
+ *
+ * Created on: 26.02.2022
+ * Author: steffen
+ * SPDX-FileCopyrightText: 2022 MDC Service <info@mdc-service.de>
+ * SPDX-License-Identifier: GPL-3.0-or-later
+ */
+
+
+#include "main.h"
+#include "sdkconfig.h"
+
+#include "SimplePgSQL.h"
+#include "MU80X.h"
+#include "HMI.h"
+#include "etc.h"
+#include "uart.h"
+#include "iic.h"
+#include "config.h"
+
+// PGSQL
+#define PGBufferSize 16384
+#define PGCharset "utf-8"
+#define PGUser "mega"
+#define PGPassword "osteoglossum"
+static PGconnection *PGconn;
+static unsigned char PGbuffer[PGBufferSize];
+
+// ETC
+const char *TAG = "SCALADIS";
+//static int cnt = 0;
+//static int protcnt = 0;
+static int serlen;
+static int network_connected = 0;
+MU80X *UHF;
+HMI *LCD;
+
+
+unsigned long long ReadAuth(void);
+
+/** ETH */
+/**
+ * eth_event_handler: Ethernet event handler
+ *
+ * @param arg argument pointer
+ * @param event_base type of the event
+ * @param event_id id of the event
+ * @param event_data event data pointer
+ */
+static void eth_event_handler(void *arg, esp_event_base_t event_base, int32_t event_id, void *event_data) {
+ uint8_t mac_addr[6] = { 0 };
+ /* we can get the ethernet driver handle from event data */
+ esp_eth_handle_t eth_handle = *(esp_eth_handle_t*) event_data;
+
+ switch (event_id) {
+ case ETHERNET_EVENT_CONNECTED:
+ esp_eth_ioctl(eth_handle, ETH_CMD_G_MAC_ADDR, mac_addr);
+ ESP_LOGI(TAG, "Eth Link Up");
+ ESP_LOGI(TAG, "Eth MAC %02x:%02x:%02x:%02x:%02x:%02x", mac_addr[0], mac_addr[1], mac_addr[2], mac_addr[3], mac_addr[4], mac_addr[5]);
+ break;
+ case ETHERNET_EVENT_DISCONNECTED:
+ ESP_LOGI(TAG, "Eth Link Down");
+ break;
+ case ETHERNET_EVENT_START:
+ ESP_LOGI(TAG, "Eth Started");
+ break;
+ case ETHERNET_EVENT_STOP:
+ ESP_LOGI(TAG, "Eth Stopped");
+ break;
+ default:
+ break;
+ }
+}
+
+/**
+ * got_ip_event_handler: event called after received the IP address
+ *
+ * @param arg argument pointer
+ * @param event_base type of the event
+ * @param event_id id of the event
+ * @param event_data event data pointer
+ */
+static void got_ip_event_handler(void *arg, esp_event_base_t event_base, int32_t event_id, void *event_data) {
+ ip_event_got_ip_t *event = (ip_event_got_ip_t*) event_data;
+ const esp_netif_ip_info_t *ip_info = &event->ip_info;
+
+ ESP_LOGI(TAG, "Ethernet Got IP Address");
+ ESP_LOGI(TAG, "~~~~~~~~~~~");
+ ESP_LOGI(TAG, "ETHIP :" IPSTR, IP2STR(&ip_info->ip));
+ ESP_LOGI(TAG, "ETHMASK:" IPSTR, IP2STR(&ip_info->netmask));
+ ESP_LOGI(TAG, "ETHGW :" IPSTR, IP2STR(&ip_info->gw));
+ ESP_LOGI(TAG, "~~~~~~~~~~~");
+ network_connected = 1;
+}
+
+/**
+ * ETH_init: initalize Ethernet
+ *
+ * @param dhcp to use DHCP, set this to 0
+ */
+static void ETH_init(int dhcp) {
+ ESP_ERROR_CHECK(esp_netif_init());
+ ESP_ERROR_CHECK(esp_event_loop_create_default());
+
+ // Create new default instance of esp-netif for Ethernet
+ esp_netif_config_t cfg = ESP_NETIF_DEFAULT_ETH();
+ esp_netif_t *eth_netif = esp_netif_new(&cfg);
+
+ // Init MAC and PHY configs to default
+ eth_mac_config_t mac_config = ETH_MAC_DEFAULT_CONFIG();
+ eth_phy_config_t phy_config = ETH_PHY_DEFAULT_CONFIG();
+
+ phy_config.phy_addr = CONFIG_EXAMPLE_ETH_PHY_ADDR;
+ phy_config.reset_gpio_num = CONFIG_EXAMPLE_ETH_PHY_RST_GPIO;
+ mac_config.smi_mdc_gpio_num = CONFIG_EXAMPLE_ETH_MDC_GPIO;
+ mac_config.smi_mdio_gpio_num = CONFIG_EXAMPLE_ETH_MDIO_GPIO;
+ esp_eth_mac_t *mac = esp_eth_mac_new_esp32(&mac_config);
+ esp_eth_phy_t *phy = esp_eth_phy_new_lan87xx(&phy_config);
+ esp_eth_config_t config = ETH_DEFAULT_CONFIG(mac, phy);
+ esp_eth_handle_t eth_handle = NULL;
+ ESP_ERROR_CHECK(esp_eth_driver_install(&config, &eth_handle));
+ ESP_ERROR_CHECK(esp_netif_attach(eth_netif, esp_eth_new_netif_glue(eth_handle)));
+
+ if (dhcp == 0) {
+ strcpy(netip, (char*) "192.168.178.32");
+ strcpy(netgw, (char*) "192.168.178.1");
+ strcpy(netma, (char*) "255.255.255.0");
+ strcpy(srvip, (char*) "192.168.178.32");
+ srvpo = 5432;
+ boxid = 1;
+ subbx = 1;
+ ReadConfig();
+
+ esp_netif_ip_info_t ip_info;
+ memset(&ip_info, 0, sizeof(esp_netif_ip_info_t));
+ esp_netif_str_to_ip4((const char*) netip, &ip_info.ip);
+ esp_netif_str_to_ip4((const char*) netgw, &ip_info.gw);
+ esp_netif_str_to_ip4((const char*) netma, &ip_info.netmask);
+ esp_netif_set_ip_info(eth_netif, &ip_info);
+ }
+ ESP_ERROR_CHECK(esp_eth_start(eth_handle));
+}
+
+/** UHF */
+/**
+ * UHF_init: initalize the Chafon UHF RFID reader
+ *
+ */
+void UHF_init(void) {
+ int res;
+ UHF = new MU80X(UHF_UART_CHANNEL);
+ res = UHF->iSetRFRegion();
+ res = UHF->iSetPower(30);
+ UHF->DumpBuffer(UHF->RecvBuf, res);
+ UHF->iClearBuffer();
+}
+
+/**
+ * UHF_loop: need to be called regularly, to get notified if RFID-tags inventory change
+ *
+ */
+void UHF_loop(void) {
+ int i;
+ unsigned long long ID;
+ for (i = 0; i < 1000; i++) {
+ if ((ID=ReadAuth())>0) {
+ printf("ID:%lld",ID);fflush(stdout);
+ }
+ UHF->iBufferInventory(7, 0, 10);
+ printf("%d -> Tags in Buffer:%d Tags seen:%d\n", i, UHF->TagsInBuffer,UHF->TagsSeen);
+ fflush(stdout);
+ vTaskDelay(10);
+ };
+ while (0) {
+ vTaskDelay(100);
+ };
+}
+
+/**
+ * ReadAuth: read authentification
+ *
+ * @returns Value of the authbuff.
+ */
+unsigned long long ReadAuth(void) {
+ char authbuff[1024];
+ char *pos;
+ int received = 0;
+ int timeout = 60;
+ serlen = uart_read_bytes(RDR_UART_CHANNEL, authbuff, 256, 1);
+ if (serlen > 0) {
+
+ pos = strchr(authbuff, '\n');
+ if (pos) {
+ *pos = '\0';
+ }
+
+ if (strncmp(authbuff, "CONFIG", 6) == 0) { // we have to receive the init file
+ printf("Ready to receive config file !\n");
+ fflush(stdout);
+ while ((received == 0) & (timeout > 0)) {
+ serlen = uart_read_bytes(RDR_UART_CHANNEL, authbuff, 1023, 100);
+ if (serlen) {
+ authbuff[serlen] = 0;
+ WriteConfig(authbuff);
+ received = 1;
+ } else {
+ vTaskDelay(100);
+ timeout--;
+ printf("TO:%d\n", timeout);
+ fflush(stdout);
+ }
+ }
+ }
+ }
+ authbuff[serlen]=0;
+ printf("SERLEN:%d->%s\n", serlen,authbuff);
+ fflush(stdout);
+ return sscanf("%X",authbuff);
+}
+
+/** GPIO **/
+/**
+ * IO_init: initalize the GPIO
+ *
+ */
+void IO_init(void) {
+ // outputs
+
+#define GPO_BIT_MASK (1ULL << PHY_PWR)
+ gpio_config_t o_conf;
+ o_conf.intr_type = GPIO_INTR_DISABLE;
+ o_conf.mode = GPIO_MODE_OUTPUT;
+ o_conf.pin_bit_mask = GPO_BIT_MASK;
+ o_conf.pull_down_en = GPIO_PULLDOWN_ENABLE;
+ o_conf.pull_up_en = GPIO_PULLUP_DISABLE;
+ gpio_config(&o_conf);
+ gpio_set_level((gpio_num_t) PHY_PWR, 1);
+
+ // inputs
+ /*
+ #define GPI_BIT_MASK ((1ULL << SWITCH)|(1ULL << SWITCH))
+ gpio_config_t i_conf;
+ i_conf.intr_type = GPIO_INTR_DISABLE;
+ i_conf.mode = GPIO_MODE_INPUT;
+ i_conf.pin_bit_mask = GPI_BIT_MASK;
+ i_conf.pull_down_en = GPIO_PULLDOWN_DISABLE;
+ i_conf.pull_up_en = GPIO_PULLUP_DISABLE;
+ gpio_config(&i_conf);
+ */
+}
+
+/** GPIO **/
+/**
+ * HMI_init: initalize the HMI
+ *
+ */
+void HMI_init(void) {
+ LCD = new HMI(LCD_UART_CHANNEL);
+}
+
+/** PGSQL **/
+/**
+ * PGInit: initalize the PostgreSQL connection
+ *
+ */
+void PGInit(void) {
+ PGconn = new PGconnection(0,PGbuffer,PGBufferSize);
+}
+
+
+/**
+ * getInfo: functional loop
+ *
+ */
+int getInfo(char *info) {
+ int rc, i;
+ int pgstat = 0;
+ int cnt = 1000;
+ char *msg;
+ char lbuf[1024];
+ rc = PGconn->PGsetDbLogin(srvip, srvpo, dbnam, PGUser, PGPassword, PGCharset);
+ printf("Login result:%d\n", rc);
+ if (rc < 1)
+ return -1;
+ pgstat = 1;
+ while (cnt > 0) {
+
+ if (pgstat == 1) { // we are connected to srv/db, now we need to rcv the msgs from srv
+ rc = PGconn->PGstatus();
+ printf("Status:%d\n", rc);
+ fflush(stdout);
+ if (rc == CONNECTION_BAD || rc == CONNECTION_NEEDED) {
+ printf("ERROR: %s", PGconn->PGgetMessage());
+ pgstat = -1;
+ } else if (rc == CONNECTION_OK) {
+ pgstat = 2;
+ printf("Ready to submit qry\n");
+ }
+ }
+
+ if (pgstat == 2) {
+ sprintf(lbuf, "SELECT name,gname FROM accounts WHERE id=(cast(x'%s' AS int));", info);
+ rc = PGconn->PGexecute(lbuf);
+ printf("EXEC result:%d\n", rc);
+// vTaskDelay(1);
+ if (rc == 0) {
+ pgstat = 3;
+ } else {
+ cnt = 0;
+ }
+ }
+ if (pgstat == 3) {
+ rc = PGconn->PGgetData();
+ // printf("RC:%d\n",rc);fflush(stdout);
+ if (rc < 0) {
+ printf("Get Data Error:%d\n", rc);
+ fflush(stdout);
+ } else if (rc > 0) {
+ if (rc & PG_RSTAT_HAVE_COLUMNS) {
+ printf("We got columns !\n");
+ fflush(stdout);
+ int cols = PGconn->PGnfields();
+ printf("Cols: %d\n", cols);
+ fflush(stdout);
+ /*
+ for (i = 0; i < cols; i++) {
+ if (i) printf(" | ");
+ printf(" %s ",PGconn->PGgetColumn(i));
+ }
+ */
+ printf("\n==========\n");
+ fflush(stdout);
+ } else if (rc & PG_RSTAT_HAVE_ROW) {
+ // printf("We got rows !\n");fflush (stdout);
+ for (i = 0; i < PGconn->PGnfields(); i++) {
+ // if (i) printf(" | ");
+ // msg = PGconn->PGgetValue(i);
+ sprintf(lbuf, "Info:\r\n%s\r\n%s", PGconn->PGgetValue(1), PGconn->PGgetValue(0));
+ // if (!msg) msg = (char *) "NULL";
+ // printf(" %s", msg);fflush(stdout);
+ }
+ // printf("\n");fflush(stdout);
+ } else if (rc & PG_RSTAT_HAVE_SUMMARY) {
+ printf("Rows affected: ");
+ printf("%d\n", PGconn->PGntuples());
+ } else if (rc & PG_RSTAT_HAVE_MESSAGE) {
+ printf("We got msg !\n");
+ fflush(stdout);
+ msg = PGconn->PGgetMessage();
+ if (!msg)
+ msg = (char*) "NULL";
+ printf("MSG: %s\n", msg);
+ fflush(stdout);
+ }
+ if (rc & PG_RSTAT_READY) {
+ printf("We made it !\n");
+ fflush(stdout);
+ cnt = 0;
+ break;
+ }
+ }
+ } // pgstat==3
+ vTaskDelay(1);
+ cnt--;
+ } // while (cnt>0)
+ PGconn->PGclose();
+ return rc;
+}
+
+/**
+ * init: initialize all modules
+ *
+ */
+static void init(void) {
+// int res;
+// printf("UART-Init:\n\n");
+// UART_init();
+// printf("IO-Init:\n\n");
+// IO_init();
+// printf("ETH-Init:\n\n");
+// ETH_init(0);
+// printf("UHF-Init:\n\n");
+// UHF_init();
+// printf("HMI-Init:\n\n");
+// HMI_init();
+ printf("I2C-Init:\n\n");
+ ESP_ERROR_CHECK(I2C_init());
+// printf("ADC-Init:\n\n");
+// ESP_ERROR_CHECK(ADC_init());
+ ESP_LOGI(TAG, "I2C initialized successfully");
+
+}
+
+/**
+ * main_loop:
+ *
+ */
+static void main_loop() {
+ int res1 = 0, res2 = 0;
+ printf("Main loop\n");
+ fflush(stdout);
+// res1 = LCD->iSendProt(6, (char*) "page 0", 1);
+ printf("res:%d\n", res1);
+ fflush(stdout);
+// int door=1;
+
+// UHF_loop();
+// EditConfig();
+// UHF_loop();
+
+ while (1) {
+// ADCReadAll();
+
+ I2C_buf[0] = 0x02; // write data to output port 1
+ I2C_buf[1] = 0x55; // write data to output port 1
+ I2C_buf[2] = 0xAA; // write data to output port 1
+ res1 = i2c_master_write_to_device(I2C_MASTER_NUM, I2C_PORTEXP1, I2C_buf, 3, I2C_MASTER_TIMEOUT_MS / portTICK_PERIOD_MS);
+ // printf("\nI2C wrote 0x%02X%02X: %d\n", I2C_buf[0], I2C_buf[1], res1);
+// I2C_buf[0] = 0x00; // lese 3 bytes
+// res2 = i2c_master_read_from_device(I2C_MASTER_NUM, I2C_PORTEXP1, I2C_buf, 1, I2C_MASTER_TIMEOUT_MS / portTICK_PERIOD_MS);
+
+ printf("\nMaster wrote %d %d %02X\n", res1,res2,I2C_buf[0]);
+
+
+ vTaskDelay(500 / portTICK_PERIOD_MS);
+ I2C_buf[0] = 0x02; // write data to output port 1
+ I2C_buf[1] = 0xAA; // write data to output port 1
+ I2C_buf[2] = 0x55; // write data to output port 1
+ res1 = i2c_master_write_to_device(I2C_MASTER_NUM, I2C_PORTEXP1, I2C_buf, 3, I2C_MASTER_TIMEOUT_MS / portTICK_PERIOD_MS);
+ // printf("\nI2C wrote 0x%02X%02X: %d\n", I2C_buf[0], I2C_buf[1], res1);
+// I2C_buf[0] = 0x00; // lese 3 bytes
+// res2 = i2c_master_read_from_device(I2C_MASTER_NUM, I2C_PORTEXP1, I2C_buf, 1, I2C_MASTER_TIMEOUT_MS / portTICK_PERIOD_MS);
+
+ printf("\nMaster wrote %d %d %02X\n", res1,res2,I2C_buf[0]);
+
+
+ vTaskDelay(500 / portTICK_PERIOD_MS);
+ }
+
+ while (0) {
+ printf("Closed 1:%d\n",DoorIsClosed(LOCK1R));fflush(stdout);
+ printf("Closed 2:%d\n",DoorIsClosed(LOCK2R));fflush(stdout);
+ printf("Closed 3:%d\n",DoorIsClosed(LOCK3R));fflush(stdout);
+ printf("Closed 4:%d\n",DoorIsClosed(LOCK4R));fflush(stdout);
+ /*
+ res1 = i2c_master_write_to_device(I2C_MASTER_NUM, I2C_PORTEXP, I2C_buf, 2, I2C_MASTER_TIMEOUT_MS / portTICK_PERIOD_MS);
+ printf("\nI2C wrote 0x%02X%02X: %d\n", I2C_buf[0], I2C_buf[1], res1);
+
+ vTaskDelay(1);
+
+ I2C_buf[0] = 0x05;
+ I2C_buf[1] = 0x00;
+ res1 = i2c_master_write_to_device(I2C_MASTER_NUM, I2C_PORTEXP, I2C_buf, 2, I2C_MASTER_TIMEOUT_MS / portTICK_PERIOD_MS);
+ printf("\nI2C wrote 0x%02X%02X: %d\n", I2C_buf[0], I2C_buf[1], res1);
+
+ I2C_buf[0] = 0x80; // Setze CMD read port 0
+ I2C_buf[1] = 0x00;
+ I2C_buf[2] = 0x00;
+ res1 = i2c_master_write_to_device(I2C_MASTER_NUM, I2C_PORTEXP, I2C_buf, 1, I2C_MASTER_TIMEOUT_MS / portTICK_PERIOD_MS);
+ printf("\nI2C wrote 0x%02X%02X: %d\n", I2C_buf[0], I2C_buf[1], res1);
+ I2C_buf[0] = 0x00; // lese 3 bytes
+ res2 = i2c_master_read_from_device(I2C_MASTER_NUM, I2C_PORTEXP, I2C_buf, 3, I2C_MASTER_TIMEOUT_MS / portTICK_PERIOD_MS);
+ printf("\nI2C read 0x %02X %02X %02X: %d\n", I2C_buf[0], I2C_buf[1], I2C_buf[2], res2);
+ vTaskDelay(2000 / portTICK_PERIOD_MS);
+ printf(" #:S%d R:%d ", res1, res2);
+ fflush(stdout);
+ */
+
+ vTaskDelay(10000 / portTICK_PERIOD_MS);
+ DoorOpen(1);
+// vTaskDelay(10);
+ DoorOpen(2);
+ vTaskDelay(10);
+ DoorOpen(3);
+ vTaskDelay(10);
+ DoorOpen(4);
+ vTaskDelay(10);
+ printf("\n\n\n");fflush(stdout);
+ }
+}
+
+extern "C" {
+void app_main(void) {
+ init();
+ main_loop();
+}
+}
generated by cgit v1.2.3 (git 2.25.1) at 2026-01-16 04:58:38 +0000