Скрипт для счётчика

instalator

как? `

! ````
if (cmd.substring(0, 1) == "S") {
if (cmd.substring(1, 2) == "N") {
num = cmd.substring(cmd.lastIndexOf('N') + 1).toInt();
}
else if (cmd.substring(1, 2) == "S") {
save();
}
else if (cmd.substring(1, 2) == "C") {
cnt = atol(cmd.substring(cmd.lastIndexOf('C') + 1).c_str());
}
else if (cmd.substring(1, 2) == "B") {
bounce = cmd.substring(cmd.lastIndexOf('B') + 1).toInt();
}
save();
}
cmd = "";
strComplete = false;
}

т.о. чтобы задать bounce надо в уарт послать B1000 например.

или чтобы задать данные счетчика то - C51423

Как объединить этот код

….........

и код вот этот...

>! ````
>! void serialEvent() {
  while (Serial.available() > 0) {
    char inChar = (char)Serial.read();
    cmd += inChar;
    if (inChar == '\n') {
      strComplete = true;
    }
  }
}
if (strComplete) {
    digitalWrite(LED, !digitalRead(LED));
    cmd.toCharArray(buffer, 100);
    cnt = atoi(strtok(buffer, ";"));
    pwr = atoi(strtok(NULL, ";"));
    amp = atoi(strtok(NULL, ";"));
    bounce = atoi(strtok(NULL, ";"));
    num = atoi(strtok(NULL, ";"));
    error = atoi(strtok(NULL, ";"));
    client.publish(topic_raw, StrToChar(cmd));
    cmd = "";
    strComplete = false;
  }
>! ````

Тут мы как раз получаем данные из уарт и парсим их, а дальше делай что хочешь

smoker_vvo

ой мамочки…. У меня есть немного вопросов касаемо счетчика:

1. тип оборудования Arduino Uno + Mega 2560

2. Скетч Count - на УНО завелся без проблем, показания получаю.

3. Как правильно состыковать УНО и МЕГА, сделано так TX & RX Uno соединены с RX(0) & TX(1) Mega, ни чего нет на Меге.

4. Самое противное, при заливке скетча MQTT на 2560 получаю странную картину - постоянно мигает светодиод L и Мега ни как не реагирует на поступающие данные, и не пингуется по своему адресу. в кодах ни чего не менял кроме ip адресов

Куда рыть далее???

smoker_vvo

по умолчанию считаю что в обоих скетчах - UART уже прописан. или я не прав?

smoker_vvo

Пардон, не UNO а NANO

smoker_vvo

и еще в Count и MQTT есть такие строки

Count

#define PWR_CTRL A0

MQTT

#define PWR_CTRL A2 //Контроль напряжения

прошу пояснить их назначение и схемку подключения

instalator

~~@smoker_vvo:~~

ой мамочки…. У меня есть немного вопросов касаемо счетчика:

1. тип оборудования Arduino Uno + Mega 2560

2. Скетч Count - на УНО завелся без проблем, показания получаю.

3. Как правильно состыковать УНО и МЕГА, сделано так TX & RX Uno соединены с RX(0) & TX(1) Mega, ни чего нет на Меге.

4. Самое противное, при заливке скетча MQTT на 2560 получаю странную картину - постоянно мигает светодиод L и Мега ни как не реагирует на поступающие данные, и не пингуется по своему адресу. в кодах ни чего не менял кроме ip адресов

Куда рыть далее??? ` убери из кода ватчдог либо залей оптибут в мегу.

instalator

~~@smoker_vvo:~~

и еще в Count и MQTT есть такие строки

Count

#define PWR_CTRL A0

MQTT

#define PWR_CTRL A2 //Контроль напряжения

прошу пояснить их назначение и схемку подключения ` контроль питания на порту. При пропадании питания сохраняются данные в епром

smoker_vvo

Вачдог…

Это

void reboot() {

save();

delay(500);

wdt_enable(WDTO_1S);

for (;;) {}

}

smoker_vvo

для контроля питания, что то подавать надо, или это аппаратно решено??

smoker_vvo

Сразу скажу, не селен я в программировании, все что делаю сам для ардуины - это просто результат ДООЛГОГО разбирательства чужих кодов, делаю на уровне подсознания…..

instalator

~~@smoker_vvo:~~

Вачдог…

Это

void reboot() {
  save();
  delay(500);
  wdt_enable(WDTO_1S);
  for (;;) {}
}
```` `

Тут тоже. В начале кода еще ищи команду wdt_enable.

Либо прошей загрузчик https://github.com/instalator/optiboot, в котором исправлен баг с ватчдогом.

smoker_vvo

А вот тут и возникла проблема… Не заливаются скетчи.... любая попытка заканчивается ошибкой закачки скетча.... И бешеный светодиод......

instalator

~~@smoker_vvo:~~

А вот тут и возникла проблема… Не заливаются скетчи.... любая попытка заканчивается ошибкой закачки скетча.... И бешеный светодиод...... `
Прошей загрузчик оптибут или шей ее через программатор

smoker_vvo

Ну тогда давай рекомендации что и как делать, через что прошивать, у меня голова опухла от обилия информации о прошивке оптибута

instalator

~~@smoker_vvo:~~

Ну тогда давай рекомендации что и как делать, через что прошивать, у меня голова опухла от обилия информации о прошивке оптибута `

http://blog.instalator.ru/archives/798

smoker_vvo

Доброго времени…

Появилось время заниматься проектом дальше. и вот какие проблемы, если с WDT я поступил грубо, просто закоментил его, то с ethernetom вообще ни чего не могу понять. Учитывая что у тебя была другая карта, использую библиотеку для своей.... и ничего не работает....

1. ping - ни чего нет

2. соответсвенно в IOBе то же тишина.

заливал другие скетчи - с сетевой проблем нет.

вот код :

! ```
#include <spi.h> #include <ethernet.h> #include <pubsubclient.h> #include <eeprom.h> //#include <avr wdt.h=""> ! #define PWR_CTRL A2 //Контроль напряжения #define LED 9 //Светодиод #define CHK_ADR 100 #define CNT_ADR 10 #define PWR_ADR 20 #define POLL_ADR 30 #define RATIO_ADR 40 ! const char* topic_err = "myhome/elcounter/error"; const char* topic_cnt = "myhome/elcounter/count"; const char* topic_pwr = "myhome/elcounter/power"; const char* topic_amp = "myhome/elcounter/amp"; const char* topic_save = "myhome/elcounter/save"; const char* topic_correction = "myhome/elcounter/correction"; const char* topic_connection = "myhome/elcounter/connection"; const char* topic_ip = "myhome/elcounter/config/ip"; const char* topic_polling = "myhome/elcounter/config/polling"; const char* topic_bounce = "myhome/elcounter/config/bounce"; const char* topic_num = "myhome/elcounter/config/num"; const char* topic_reset = "myhome/elcounter/config/reset"; const char* topic_raw = "myhome/elcounter/RAW"; const char* subscr = "myhome/elcounter/#"; ! byte mac[] = { 0xDE, 0xAD, 0xBE, 0xE4, 0xDE, 0x35 }; byte ip[] = { 192, 168, 0, 89}; byte server[] = { 192, 168, 0, 15}; ! unsigned long cnt = 0; unsigned long prev_cnt = 2; unsigned long pwr = 0; unsigned long prev_pwr = 2; int amp = 0; int prev_amp = 2; int num = 0; int prev_num; int bounce = 10; int prev_bounce; int chk = 0; int chk_S = 0; unsigned long prevMillis = 0; unsigned long prevMillis_cnt = 0; int poll = 5000; bool error = 0; String cmd = ""; bool strComplete = false; char buf [50]; char buffer[100]; char s[16]; ! //////////////////////////////////////////////////////////////////////////// void callback(char* topic, byte* payload, unsigned int length) { payload[length] = '\0'; String strTopic = String(topic); String strPayload = String((char*)payload); callback_iobroker(strTopic, strPayload); } ! EthernetClient ethClient; PubSubClient client(server, 1883, callback, ethClient); ! void setup() { MCUSR = 0; // wdt_disable(); Serial.println("WDT_disable"); cmd.reserve(100); delay(10000); Serial.begin(57600); Serial.println("Starting......"); ! if (EEPROM.read(1) != 99) { //Если первый запуск EEPROM.write(1, 99); for (int i = 0 ; i < 4; i++) { EEPROM.write(110 + i, ip[i]); } for (int i = 0 ; i < 4; i++) { EEPROM.write(120 + i, server[i]); } } else { chk = EEPROMReadInt(CHK_ADR); cnt = EEPROMReadLong(CNT_ADR); poll = EEPROMReadInt(POLL_ADR); chk_S = poll - 500; if (chk != chk_S) { error = 2; } for (int i = 0; i < 4; i++) { ip[i] = EEPROM.read(110 + i); } for (int i = 0; i < 4; i++) { server[i] = EEPROM.read(120 + i); } } ! pinMode(LED, OUTPUT); ! // client.setServer(server, 1883); // client.setCallback(callback); Ethernet.begin(mac, ip); delay(200); //wdt_enable(WDTO_8S); Serial.println("WDTO_8S"); if (client.connect("elcounter")) { digitalWrite(LED, LOW); Public(); } } ! void serialEvent() { while (Serial.available() > 0) { char inChar = (char)Serial.read(); cmd += inChar; if (inChar == '\n') { strComplete = true; } } } ! void callback_iobroker(String strTopic, String strPayload) { if (strTopic == topic_correction) { cnt = atol((strPayload).c_str()); Serial.print("SC"); Serial.println(cnt); client.publish(topic_correction, "0"); } else if (strTopic == topic_save) { if (strPayload == "true") { Serial.println("SS"); save(); client.publish(topic_save, "false"); } } else if (strTopic == topic_polling) { poll = strPayload.toInt(); if (poll < 1000) { poll = 1000; } else if (poll > 32767) { poll = 32767; } EEPROMWriteInt(POLL_ADR, poll); //Интервал публикации client.publish(topic_polling, IntToChar(poll)); } else if (strTopic == topic_reset) { if (strPayload == "true") { client.publish(topic_reset, "false"); // reboot(); Serial.println("Reboot"); } } else if (strTopic == topic_bounce) { bounce = strPayload.toInt(); if (bounce < 0) { bounce = 0; } else if (bounce > 10000) { bounce = 10000; } Serial.print("SB"); Serial.println(bounce); client.publish(topic_bounce, IntToChar(bounce)); } else if (strTopic == topic_num) { num = strPayload.toInt(); if (num < 0) { num = 0; } else if (num > 32767) { num = 32767; } Serial.print("SN"); Serial.println(num); client.publish(topic_num, IntToChar(num)); } } ! void save() { chk = poll - 500; EEPROMWriteLong(CNT_ADR, cnt); //Пишем показания счетчика в eeprom из переменной EEPROMWriteInt(POLL_ADR, poll); //Интервал публикации EEPROMWriteInt(CHK_ADR, chk); //чек } ! void reboot() { save(); delay(500); // wdt_enable(WDTO_1S); Serial.println("void reboot"); for (;;) {} } ! char* StrToChar (String str) { int length = str.length(); str.toCharArray(buf, length + 1); return buf; } ! void EEPROMWriteLong(int p_address, unsigned long p_value) { byte four = (p_value & 0xFF); byte three = ((p_value >> 8) & 0xFF); byte two = ((p_value >> 16) & 0xFF); byte one = ((p_value >> 24) & 0xFF); EEPROM.write(p_address, four); EEPROM.write(p_address + 1, three); EEPROM.write(p_address + 2, two); EEPROM.write(p_address + 3, one); } ! unsigned long EEPROMReadLong(int p_address) { long four = EEPROM.read(p_address); long three = EEPROM.read(p_address + 1); long two = EEPROM.read(p_address + 2); long one = EEPROM.read(p_address + 3); return ((four << 0) & 0xFF) + ((three << 8) & 0xFFFF) + ((two << 16) & 0xFFFFFF) + ((one << 24) & 0xFFFFFFFF); } ! void EEPROMWriteInt(int p_address, int p_value) { byte lowByte = ((p_value >> 0) & 0xFF); byte highByte = ((p_value >> 8) & 0xFF); EEPROM.write(p_address, lowByte); EEPROM.write(p_address + 1, highByte); } unsigned int EEPROMReadInt(int p_address) { byte lowByte = EEPROM.read(p_address); byte highByte = EEPROM.read(p_address + 1); return ((lowByte << 0) & 0xFF) + ((highByte << 8) & 0xFF00); } ! char* IntToChar (unsigned long a) { sprintf(buf, "%lu", a); return buf; } ! void Public() { sprintf(s, "%d.%d.%d.%d", ip[0], ip[1], ip[2], ip[3]); client.publish(topic_err, " "); client.publish(topic_cnt, IntToChar(cnt)); client.publish(topic_pwr, IntToChar(pwr)); client.publish(topic_amp, IntToChar(amp)); client.publish(topic_save, "false"); client.publish(topic_correction, "0"); client.publish(topic_connection, "true"); client.publish(topic_ip, s); client.publish(topic_polling, IntToChar(poll)); client.publish(topic_bounce, IntToChar(bounce)); client.publish(topic_num, IntToChar(num)); client.publish(topic_reset, "false"); client.subscribe(subscr); } void reconnect() { int a = 0; while (!client.connected()) { a++; digitalWrite(LED, !digitalRead(LED)); //wdt_reset(); Serial.println("WDT reset"); if (client.connect("elcounter")) { digitalWrite(LED, LOW); Public(); } else { delay(10000); } if (a >= 10) { // wdt_enable(WDTO_1S); Serial.println("WDTO_1S"); } } } ! void loop() { // wdt_reset(); Serial.println("WDT_reset"); client.loop(); if (!client.connected()) { reconnect(); } ! if (analogRead(PWR_CTRL) < 1000) { digitalWrite(LED, LOW); save(); delay(10000); } ! if (strComplete) { digitalWrite(LED, !digitalRead(LED)); cmd.toCharArray(buffer, 100); cnt = atoi(strtok(buffer, ";")); pwr = atoi(strtok(NULL, ";")); amp = atoi(strtok(NULL, ";")); bounce = atoi(strtok(NULL, ";")); num = atoi(strtok(NULL, ";")); error = atoi(strtok(NULL, ";")); client.publish(topic_raw, StrToChar(cmd)); cmd = ""; strComplete = false; } ! if (millis() - prevMillis >= poll) { // wdt_reset(); Serial.println("WDT_reset"); prevMillis = millis(); if (cnt != prev_cnt || pwr != prev_pwr || amp != prev_amp) { prev_cnt = cnt; prev_pwr = pwr; prev_amp = amp; client.publish(topic_cnt, IntToChar(cnt)); client.publish(topic_pwr, IntToChar(pwr)); client.publish(topic_amp, IntToChar(amp)); } if (num != prev_num || bounce != prev_bounce) { prev_num = num; prev_bounce = bounce; client.publish(topic_num, IntToChar(num)); client.publish(topic_bounce, IntToChar(bounce)); } if (error > 0) { client.publish(topic_err, "err"); } else { client.publish(topic_err, " "); } } }</avr></eeprom.h></pubsubclient.h></ethernet.h></spi.h>
код с моими правками[/i][/i][/i][/i]

instalator

~~@smoker_vvo:~~

Доброго времени…

Появилось время заниматься проектом дальше. и вот какие проблемы, если с WDT я поступил грубо, просто закоментил его, то с ethernetom вообще ни чего не могу понять. Учитывая что у тебя была другая карта, использую библиотеку для своей.... и ничего не работает....

1. ping - ни чего нет

2. соответсвенно в IOBе то же тишина.

заливал другие скетчи - с сетевой проблем нет.

вот код :

! `#include <spi.h> #include <ethernet.h> #include <pubsubclient.h> #include <eeprom.h> //#include <avr wdt.h=""> ! #define PWR_CTRL A2 //Контроль напряжения #define LED 9 //Светодиод #define CHK_ADR 100 #define CNT_ADR 10 #define PWR_ADR 20 #define POLL_ADR 30 #define RATIO_ADR 40 ! const char* topic_err = "myhome/elcounter/error"; const char* topic_cnt = "myhome/elcounter/count"; const char* topic_pwr = "myhome/elcounter/power"; const char* topic_amp = "myhome/elcounter/amp"; const char* topic_save = "myhome/elcounter/save"; const char* topic_correction = "myhome/elcounter/correction"; const char* topic_connection = "myhome/elcounter/connection"; const char* topic_ip = "myhome/elcounter/config/ip"; const char* topic_polling = "myhome/elcounter/config/polling"; const char* topic_bounce = "myhome/elcounter/config/bounce"; const char* topic_num = "myhome/elcounter/config/num"; const char* topic_reset = "myhome/elcounter/config/reset"; const char* topic_raw = "myhome/elcounter/RAW"; const char* subscr = "myhome/elcounter/#"; ! byte mac[] = { 0xDE, 0xAD, 0xBE, 0xE4, 0xDE, 0x35 }; byte ip[] = { 192, 168, 0, 89}; byte server[] = { 192, 168, 0, 15}; ! unsigned long cnt = 0; unsigned long prev_cnt = 2; unsigned long pwr = 0; unsigned long prev_pwr = 2; int amp = 0; int prev_amp = 2; int num = 0; int prev_num; int bounce = 10; int prev_bounce; int chk = 0; int chk_S = 0; unsigned long prevMillis = 0; unsigned long prevMillis_cnt = 0; int poll = 5000; bool error = 0; String cmd = ""; bool strComplete = false; char buf [50]; char buffer[100]; char s[16]; ! //////////////////////////////////////////////////////////////////////////// void callback(char* topic, byte* payload, unsigned int length) { payload[length] = '\0'; String strTopic = String(topic); String strPayload = String((char*)payload); callback_iobroker(strTopic, strPayload); } ! EthernetClient ethClient; PubSubClient client(server, 1883, callback, ethClient); ! void setup() { MCUSR = 0; // wdt_disable(); Serial.println("WDT_disable"); cmd.reserve(100); delay(10000); Serial.begin(57600); Serial.println("Starting......"); ! if (EEPROM.read(1) != 99) { //Если первый запуск EEPROM.write(1, 99); for (int i = 0 ; i < 4; i++) { EEPROM.write(110 + i, ip[i]); } for (int i = 0 ; i < 4; i++) { EEPROM.write(120 + i, server[i]); } } else { chk = EEPROMReadInt(CHK_ADR); cnt = EEPROMReadLong(CNT_ADR); poll = EEPROMReadInt(POLL_ADR); chk_S = poll - 500; if (chk != chk_S) { error = 2; } for (int i = 0; i < 4; i++) { ip[i] = EEPROM.read(110 + i); } for (int i = 0; i < 4; i++) { server[i] = EEPROM.read(120 + i); } } ! pinMode(LED, OUTPUT); ! // client.setServer(server, 1883); // client.setCallback(callback); Ethernet.begin(mac, ip); delay(200); //wdt_enable(WDTO_8S); Serial.println("WDTO_8S"); if (client.connect("elcounter")) { digitalWrite(LED, LOW); Public(); } } ! void serialEvent() { while (Serial.available() > 0) { char inChar = (char)Serial.read(); cmd += inChar; if (inChar == '\n') { strComplete = true; } } } ! void callback_iobroker(String strTopic, String strPayload) { if (strTopic == topic_correction) { cnt = atol((strPayload).c_str()); Serial.print("SC"); Serial.println(cnt); client.publish(topic_correction, "0"); } else if (strTopic == topic_save) { if (strPayload == "true") { Serial.println("SS"); save(); client.publish(topic_save, "false"); } } else if (strTopic == topic_polling) { poll = strPayload.toInt(); if (poll < 1000) { poll = 1000; } else if (poll > 32767) { poll = 32767; } EEPROMWriteInt(POLL_ADR, poll); //Интервал публикации client.publish(topic_polling, IntToChar(poll)); } else if (strTopic == topic_reset) { if (strPayload == "true") { client.publish(topic_reset, "false"); // reboot(); Serial.println("Reboot"); } } else if (strTopic == topic_bounce) { bounce = strPayload.toInt(); if (bounce < 0) { bounce = 0; } else if (bounce > 10000) { bounce = 10000; } Serial.print("SB"); Serial.println(bounce); client.publish(topic_bounce, IntToChar(bounce)); } else if (strTopic == topic_num) { num = strPayload.toInt(); if (num < 0) { num = 0; } else if (num > 32767) { num = 32767; } Serial.print("SN"); Serial.println(num); client.publish(topic_num, IntToChar(num)); } } ! void save() { chk = poll - 500; EEPROMWriteLong(CNT_ADR, cnt); //Пишем показания счетчика в eeprom из переменной EEPROMWriteInt(POLL_ADR, poll); //Интервал публикации EEPROMWriteInt(CHK_ADR, chk); //чек } ! void reboot() { save(); delay(500); // wdt_enable(WDTO_1S); Serial.println("void reboot"); for (;;) {} } ! char* StrToChar (String str) { int length = str.length(); str.toCharArray(buf, length + 1); return buf; } ! void EEPROMWriteLong(int p_address, unsigned long p_value) { byte four = (p_value & 0xFF); byte three = ((p_value >> 8) & 0xFF); byte two = ((p_value >> 16) & 0xFF); byte one = ((p_value >> 24) & 0xFF); EEPROM.write(p_address, four); EEPROM.write(p_address + 1, three); EEPROM.write(p_address + 2, two); EEPROM.write(p_address + 3, one); } ! unsigned long EEPROMReadLong(int p_address) { long four = EEPROM.read(p_address); long three = EEPROM.read(p_address + 1); long two = EEPROM.read(p_address + 2); long one = EEPROM.read(p_address + 3); return ((four << 0) & 0xFF) + ((three << 8) & 0xFFFF) + ((two << 16) & 0xFFFFFF) + ((one << 24) & 0xFFFFFFFF); } ! void EEPROMWriteInt(int p_address, int p_value) { byte lowByte = ((p_value >> 0) & 0xFF); byte highByte = ((p_value >> 8) & 0xFF); EEPROM.write(p_address, lowByte); EEPROM.write(p_address + 1, highByte); } unsigned int EEPROMReadInt(int p_address) { byte lowByte = EEPROM.read(p_address); byte highByte = EEPROM.read(p_address + 1); return ((lowByte << 0) & 0xFF) + ((highByte << 8) & 0xFF00); } ! char* IntToChar (unsigned long a) { sprintf(buf, "%lu", a); return buf; } ! void Public() { sprintf(s, "%d.%d.%d.%d", ip[0], ip[1], ip[2], ip[3]); client.publish(topic_err, " "); client.publish(topic_cnt, IntToChar(cnt)); client.publish(topic_pwr, IntToChar(pwr)); client.publish(topic_amp, IntToChar(amp)); client.publish(topic_save, "false"); client.publish(topic_correction, "0"); client.publish(topic_connection, "true"); client.publish(topic_ip, s); client.publish(topic_polling, IntToChar(poll)); client.publish(topic_bounce, IntToChar(bounce)); client.publish(topic_num, IntToChar(num)); client.publish(topic_reset, "false"); client.subscribe(subscr); } void reconnect() { int a = 0; while (!client.connected()) { a++; digitalWrite(LED, !digitalRead(LED)); //wdt_reset(); Serial.println("WDT reset"); if (client.connect("elcounter")) { digitalWrite(LED, LOW); Public(); } else { delay(10000); } if (a >= 10) { // wdt_enable(WDTO_1S); Serial.println("WDTO_1S"); } } } ! void loop() { // wdt_reset(); Serial.println("WDT_reset"); client.loop(); if (!client.connected()) { reconnect(); } ! if (analogRead(PWR_CTRL) < 1000) { digitalWrite(LED, LOW); save(); delay(10000); } ! if (strComplete) { digitalWrite(LED, !digitalRead(LED)); cmd.toCharArray(buffer, 100); cnt = atoi(strtok(buffer, ";")); pwr = atoi(strtok(NULL, ";")); amp = atoi(strtok(NULL, ";")); bounce = atoi(strtok(NULL, ";")); num = atoi(strtok(NULL, ";")); error = atoi(strtok(NULL, ";")); client.publish(topic_raw, StrToChar(cmd)); cmd = ""; strComplete = false; } ! if (millis() - prevMillis >= poll) { // wdt_reset(); Serial.println("WDT_reset"); prevMillis = millis(); if (cnt != prev_cnt || pwr != prev_pwr || amp != prev_amp) { prev_cnt = cnt; prev_pwr = pwr; prev_amp = amp; client.publish(topic_cnt, IntToChar(cnt)); client.publish(topic_pwr, IntToChar(pwr)); client.publish(topic_amp, IntToChar(amp)); } if (num != prev_num || bounce != prev_bounce) { prev_num = num; prev_bounce = bounce; client.publish(topic_num, IntToChar(num)); client.publish(topic_bounce, IntToChar(bounce)); } if (error > 0) { client.publish(topic_err, "err"); } else { client.publish(topic_err, " "); } } }</avr></eeprom.h></pubsubclient.h></ethernet.h></spi.h>` код с моими правками Вроде все норм по сети, в логе тишина? ! byte ip[] = { 192, 168, 0, 89}; айпи самой ардуины ! byte server[] = { 192, 168, 0, 15}; айпи mqtt сервера[/i][/i][/i][/i] `

smoker_vvo

А не может быть связанным как то с удаленным конфигом сетевого адреса??

const char* topic_ip = "myhome/elcounter/config/ip";

Заливал этот код в Дуню - все работает…

! ```
`#include <spi.h> // Ethernet shield
#include <ethernet.h> // Ethernet shield
#include <pubsubclient.h> // MQTT
#include <servo.h>
#include <dht.h>
#include <onewire.h>
#include <dallastemperature.h>
Servo servo;
! byte mac[] = { 0xC1, 0x7C, 0x38, 0x41, 0x89, 0x35 };
byte server[] = { 192, 168, 0, 11 }; //IP Брокера
byte ip[] = { 192, 168, 0, 89 }; //IP Клиента (Arduino)
! ////////////////////////////////////////////////////////////////////////////
void callback(char* topic, byte* payload, unsigned int length) {
payload[length] = '\0';
// Serial.print(topic);
// Serial.print("=");
String strTopic = String(topic);
String strPayload = String((char*)payload);
// Serial.println(strPayload);
callback_iobroker(strTopic, strPayload);
}
! EthernetClient ethClient;
PubSubClient client(server, 1883, callback, ethClient);
#define id_connect "myhome-temp"
#define id_connect "myhome-status"
#define Prefix_subscribe "myhome/Temp/"
#define Prefix_subscribe "myhome/Status/"
! ///////////////Объявляем порты ввода-вывода
#define ServoPin 3 //Порт к которому подключен сервопривод
! const int start_DI_pin []= {2, 4, 5}; // Порты Ввода
int n_DI_pin = sizeof(start_DI_pin) / sizeof(start_DI_pin[0])-1; //Вычисляем длинну массива
! const int start_DO_pin []= {6, 7}; //Порты Вывода
int n_DO_pin = sizeof(start_DO_pin) / sizeof(start_DO_pin[0])-1; //Вычисляем длинну массива
! int DI[] = {0, 0, 0};
int old_DI[] = {0, 0, 0};
! ///////////////////////////Переменные для работы с освещением//////////////////////////////////////
int ServoAngle = 100; //Угол сервопривода при включении
int flag = 0;
int flag2 = 0;
int pause = 0;
! //------------------------------------------- Sensors -------------------------------------------//
const int MQ7_Pin = A0; // Куда подключили MQ7
//int MQ7Value = 0;
int MQ7Value = analogRead(MQ7_Pin);

const int foto_Pin = A1; // устанавливаем входную ногу для Фоторезистора
//unsigned int fotoValue = 0; // цифровое значение фоторезистора
unsigned int fotoValue = analogRead(foto_Pin);

! #define ONE_WIRE_BUS 8
//#define TEMPERATURE_PRECISION 9
OneWire oneWire(ONE_WIRE_BUS);
DallasTemperature DS_sensors(&oneWire);
// 28 80 E9 3A 04 00 00 10
//T0:28 88 AD D7 02 00 00 42
//T1:28 14 A5 D7 02 00 00 B0
//T2:28 72 26 7B 04 00 00 2E
//T3:28 CA 1A 3B 04 00 00 CD
//T4:28 E6 D5 D7 02 00 00 C1
//T5:28 16 B4 7A 04 00 00 8A
//T6:28 2B 86 D7 02 00 00 CF
//T7:28 AB 9D D7 02 00 00 29
DeviceAddress addr_T1 = { 0x28, 0x80, 0xE9, 0x3A, 0x4, 0x0, 0x0, 0x10 };//кладовка
DeviceAddress addr_T2 = { 0x28, 0x88, 0xAD, 0xD7, 0x2, 0x0, 0x0, 0x42 };//кухня
DeviceAddress addr_T3 = { 0x28, 0x14, 0xA5, 0xD7, 0x2, 0x0, 0x0, 0xB0 };//детская
DeviceAddress addr_T4 = { 0x28, 0x72, 0x26, 0x7B, 0x4, 0x0, 0x0, 0x2E };//гараж
DeviceAddress addr_T5 = { 0x28, 0xCA, 0x1A, 0x3B, 0x4, 0x0, 0x0, 0xCD };//ванная
DeviceAddress addr_T6 = { 0x28, 0xE6, 0xD5, 0xD7, 0x2, 0x0, 0x0, 0xC1 };//улица
DeviceAddress addr_T7 = { 0x28, 0x16, 0xB4, 0x7A, 0x4, 0x0, 0x0, 0x8A };//спальня2
DeviceAddress addr_T8 = { 0x28, 0x2B, 0x86, 0xD7, 0x2, 0x0, 0x0, 0xCF };//зал
DeviceAddress addr_T9 = { 0x28, 0xAB, 0x9D, 0xD7, 0x2, 0x0, 0x0, 0x29 };//мансарда
! float T1=0;
float T2=0;
float T3=0;
float T4=0;
float T5=0;
float T6=0;
float T7=0;
float T8=0;
float T9=0;
! //dht DHT;
//#define DHT22_PIN 9
//float Hout = 0;
//float Tout = 0;
! ////////////////////////////////////////////////////////////////////////////
//void callback(char* topic, byte* payload, unsigned int length) {
// payload[length] = '\0';
// Serial.print(topic);
// Serial.print("=");
// String strTopic = String(topic);
// String strPayload = String((char*)payload);
// Serial.println(strPayload);
// callback_iobroker(strTopic, strPayload);
//}
////////////////////////////////////////////////////////////////////////////
void setup() {
Serial.begin(57600);
Serial.println("start");

Serial.print("Locating devices...");
DS_sensors.begin();
Serial.print("Found ");
Serial.print(DS_sensors.getDeviceCount(), DEC);
Serial.println(" devices.");

! // report parasite power requirements
Serial.print("Parasite power is: ");
if (DS_sensors.isParasitePowerMode()) Serial.println("ON");
else Serial.println("OFF");

//Объявляем порты Digital inputs/outputs

for(int i=0 ;i<=n_DI_pin; i++) { pinMode (start_DI_pin [i], INPUT); }
digitalWrite(5, HIGH); //Насос скважины
digitalWrite(4, HIGH); //Электрика
for(int i=0 ;i<=n_DO_pin; i++) { pinMode (start_DO_pin [i], OUTPUT); }

! Ethernet.begin(mac, ip);
if (client.connect(id_connect)) {
getSensors();
control();
//client.publish("myhome/Kitchen/Change_Counter", "0");
//client.publish("myhome/Kitchen/Temp_room", "0");
//client.publish("myhome/Kitchen/Humidity_room", "0");
client.publish("myhome/Temp/Kladovka", "0");
client.publish("myhome/Temp/Kitchen", "0");
client.publish("myhome/Temp/Detskaya", "0");
client.publish("myhome/Temp/Garage", "0");
client.publish("myhome/Temp/Street", "0");
client.publish("myhome/Temp/Spalnya2", "0");
client.publish("myhome/Temp/Zal", "0");
client.publish("myhome/Temp/Mansarda", "0");
client.publish("myhome/Temp/Vannaya", "0");

//client.publish("myhome/Kitchen/Lux", "0");
//client.publish("myhome/Kitchen/Servo", "0");
client.publish("myhome/Temp/MQ7", "0");

client.publish("myhome/Status/Power", "0");
client.publish("myhome/Status/Pompe", "0");

client.subscribe("myhome/Temp/#");
client.subscribe("myhome/Status/#");

}
}
/////////////////////////////////////////////////////////////////////////
void loop() {
client.loop();
control();
getSensors();
if (!client.connected()) {
if (client.connect(id_connect)) {
control();
getSensors();
client.subscribe("myhome/Temp/#");
}
}
}</dallastemperature.h></onewire.h></dht.h></servo.h></pubsubclient.h></ethernet.h></spi.h>`

! и все пингуется, а вот заливаю счетчик - и фиг-вам.... пинг не проходит....[/i][/i]

smoker_vvo

В свое время натыкался на проблемы с СД картами и W5100

instalator

~~@smoker_vvo:~~

А не может быть связанным как то с удаленным конфигом сетевого адреса??

const char* topic_ip = "myhome/elcounter/config/ip";

Заливал этот код в Дуню - все работает…

! ```
`#include <spi.h> // Ethernet shield
#include <ethernet.h> // Ethernet shield
#include <pubsubclient.h> // MQTT
#include <servo.h>
#include <dht.h>
#include <onewire.h>
#include <dallastemperature.h>
Servo servo;
! byte mac[] = { 0xC1, 0x7C, 0x38, 0x41, 0x89, 0x35 };
byte server[] = { 192, 168, 0, 11 }; //IP Брокера
byte ip[] = { 192, 168, 0, 89 }; //IP Клиента (Arduino)
! ////////////////////////////////////////////////////////////////////////////
void callback(char* topic, byte* payload, unsigned int length) {
payload[length] = '\0';
// Serial.print(topic);
// Serial.print("=");
String strTopic = String(topic);
String strPayload = String((char*)payload);
// Serial.println(strPayload);
callback_iobroker(strTopic, strPayload);
}
! EthernetClient ethClient;
PubSubClient client(server, 1883, callback, ethClient);
#define id_connect "myhome-temp"
#define id_connect "myhome-status"
#define Prefix_subscribe "myhome/Temp/"
#define Prefix_subscribe "myhome/Status/"
! ///////////////Объявляем порты ввода-вывода
#define ServoPin 3 //Порт к которому подключен сервопривод
! const int start_DI_pin []= {2, 4, 5}; // Порты Ввода
int n_DI_pin = sizeof(start_DI_pin) / sizeof(start_DI_pin[0])-1; //Вычисляем длинну массива
! const int start_DO_pin []= {6, 7}; //Порты Вывода
int n_DO_pin = sizeof(start_DO_pin) / sizeof(start_DO_pin[0])-1; //Вычисляем длинну массива
! int DI[] = {0, 0, 0};
int old_DI[] = {0, 0, 0};
! ///////////////////////////Переменные для работы с освещением//////////////////////////////////////
int ServoAngle = 100; //Угол сервопривода при включении
int flag = 0;
int flag2 = 0;
int pause = 0;
! //------------------------------------------- Sensors -------------------------------------------//
const int MQ7_Pin = A0; // Куда подключили MQ7
//int MQ7Value = 0;
int MQ7Value = analogRead(MQ7_Pin);

const int foto_Pin = A1; // устанавливаем входную ногу для Фоторезистора
//unsigned int fotoValue = 0; // цифровое значение фоторезистора
unsigned int fotoValue = analogRead(foto_Pin);

! #define ONE_WIRE_BUS 8
//#define TEMPERATURE_PRECISION 9
OneWire oneWire(ONE_WIRE_BUS);
DallasTemperature DS_sensors(&oneWire);
// 28 80 E9 3A 04 00 00 10
//T0:28 88 AD D7 02 00 00 42
//T1:28 14 A5 D7 02 00 00 B0
//T2:28 72 26 7B 04 00 00 2E
//T3:28 CA 1A 3B 04 00 00 CD
//T4:28 E6 D5 D7 02 00 00 C1
//T5:28 16 B4 7A 04 00 00 8A
//T6:28 2B 86 D7 02 00 00 CF
//T7:28 AB 9D D7 02 00 00 29
DeviceAddress addr_T1 = { 0x28, 0x80, 0xE9, 0x3A, 0x4, 0x0, 0x0, 0x10 };//кладовка
DeviceAddress addr_T2 = { 0x28, 0x88, 0xAD, 0xD7, 0x2, 0x0, 0x0, 0x42 };//кухня
DeviceAddress addr_T3 = { 0x28, 0x14, 0xA5, 0xD7, 0x2, 0x0, 0x0, 0xB0 };//детская
DeviceAddress addr_T4 = { 0x28, 0x72, 0x26, 0x7B, 0x4, 0x0, 0x0, 0x2E };//гараж
DeviceAddress addr_T5 = { 0x28, 0xCA, 0x1A, 0x3B, 0x4, 0x0, 0x0, 0xCD };//ванная
DeviceAddress addr_T6 = { 0x28, 0xE6, 0xD5, 0xD7, 0x2, 0x0, 0x0, 0xC1 };//улица
DeviceAddress addr_T7 = { 0x28, 0x16, 0xB4, 0x7A, 0x4, 0x0, 0x0, 0x8A };//спальня2
DeviceAddress addr_T8 = { 0x28, 0x2B, 0x86, 0xD7, 0x2, 0x0, 0x0, 0xCF };//зал
DeviceAddress addr_T9 = { 0x28, 0xAB, 0x9D, 0xD7, 0x2, 0x0, 0x0, 0x29 };//мансарда
! float T1=0;
float T2=0;
float T3=0;
float T4=0;
float T5=0;
float T6=0;
float T7=0;
float T8=0;
float T9=0;
! //dht DHT;
//#define DHT22_PIN 9
//float Hout = 0;
//float Tout = 0;
! ////////////////////////////////////////////////////////////////////////////
//void callback(char* topic, byte* payload, unsigned int length) {
// payload[length] = '\0';
// Serial.print(topic);
// Serial.print("=");
// String strTopic = String(topic);
// String strPayload = String((char*)payload);
// Serial.println(strPayload);
// callback_iobroker(strTopic, strPayload);
//}
////////////////////////////////////////////////////////////////////////////
void setup() {
Serial.begin(57600);
Serial.println("start");

Serial.print("Locating devices...");
DS_sensors.begin();
Serial.print("Found ");
Serial.print(DS_sensors.getDeviceCount(), DEC);
Serial.println(" devices.");

! // report parasite power requirements
Serial.print("Parasite power is: ");
if (DS_sensors.isParasitePowerMode()) Serial.println("ON");
else Serial.println("OFF");
//Объявляем порты Digital inputs/outputs
for(int i=0 ;i<=n_DI_pin; i++) { pinMode (start_DI_pin [i], INPUT); }
digitalWrite(5, HIGH); //Насос скважины
digitalWrite(4, HIGH); //Электрика
for(int i=0 ;i<=n_DO_pin; i++) { pinMode (start_DO_pin [i], OUTPUT); }

! Ethernet.begin(mac, ip);
if (client.connect(id_connect)) {
getSensors();
control();
//client.publish("myhome/Kitchen/Change_Counter", "0");
//client.publish("myhome/Kitchen/Temp_room", "0");
//client.publish("myhome/Kitchen/Humidity_room", "0");
client.publish("myhome/Temp/Kladovka", "0");
client.publish("myhome/Temp/Kitchen", "0");
client.publish("myhome/Temp/Detskaya", "0");
client.publish("myhome/Temp/Garage", "0");
client.publish("myhome/Temp/Street", "0");
client.publish("myhome/Temp/Spalnya2", "0");
client.publish("myhome/Temp/Zal", "0");
client.publish("myhome/Temp/Mansarda", "0");
client.publish("myhome/Temp/Vannaya", "0");
//client.publish("myhome/Kitchen/Lux", "0");
//client.publish("myhome/Kitchen/Servo", "0");
client.publish("myhome/Temp/MQ7", "0");

client.publish("myhome/Status/Power", "0");
client.publish("myhome/Status/Pompe", "0");

client.subscribe("myhome/Temp/#");
client.subscribe("myhome/Status/#");
}
}
/////////////////////////////////////////////////////////////////////////
void loop() {
client.loop();
control();
getSensors();
if (!client.connected()) {
if (client.connect(id_connect)) {
control();
getSensors();
client.subscribe("myhome/Temp/#");
}
}
}</dallastemperature.h></onewire.h></dht.h></servo.h></pubsubclient.h></ethernet.h></spi.h>`

! и все пингуется, а вот заливаю счетчик - и фиг-вам.... пинг не проходит....нет, вечером будет время проверю твой код[/i][/i]
``` `

Community Forum

NEWS

Скрипт для счётчика

Support us

814

32.4k

81.6k

1.3m