boguslawb
commented
8 years ago client code
#include <ESP8266WiFi.h>
#include <ESP8266mDNS.h>
#include <OneWire.h>
#include <DallasTemperature.h>
#include "jsondata.h"
const char *ssid = "****";
const char *password = "**";
int errorcount = 0;
bool isHeating = false;
float histereza = 1.0;
#define ONE_WIRE_BUS D2
OneWire oneWire(ONE_WIRE_BUS);
DallasTemperature sensors(&oneWire);
DeviceAddress thermometer;
void CheckHeater();
void SetError(int error);
void SetErrors(int error);
void StopHeater();
void StartHeater();
void connectWiFi();
WiFiClient client;
char hostString[16] = {0};
int hostcount;
bool isConnected = false;//Czy podłączono do sieci WiFi
void setup() {
Serial.begin(115200);
sensors.begin();
if (!sensors.getAddress(thermometer, 0)) Serial.println("Unable to find address for thermometer ds18b20 ");
sensors.setHighAlarmTemp(thermometer, 90);//alarm przy 90 stopniach
sensors.setLowAlarmTemp(thermometer, 0);
connectWiFi();
}
void loop() {
yield();
sensors.setResolution(9);
sensors.requestTemperatures(); // Send the command to get temperatures
Serial.print("Sensor temperature : ");
htdata.temperature = sensors.getTempC(thermometer);
Serial.println(htdata.temperature);
if (sensors.hasAlarm(thermometer))
{
Serial.println("ALARM: temperature not in range (0,90) ");
SetError(1);
return;
}
if (!isConnected) {
connectWiFi();
return;
}
if (hostcount==0){
hostcount = MDNS.queryService("htcontrol", "tcp");
}
if (hostcount==0) {
Serial.println("No control service found!");
SetError(202);
return;
}
htdata.name = "HT0";
serializeHTSensor();
Serial.print("Connecting to host ");
Serial.print(MDNS.hostname(0));
Serial.print(" (");
Serial.print(MDNS.IP(0));
Serial.print(":");
Serial.print(MDNS.port(0));
Serial.println(")");
unsigned long timeconn = millis();
if (!client.connect(MDNS.IP(0), MDNS.port(0))) {
Serial.println("connection failed");
SetErrors(205);
}
else
{
client.print(htsensor_json);
Serial.println(htsensor_json);
unsigned long timeout = millis();
while (client.available() == 0) {
if (millis() - timeout > 5000) {
Serial.println("Connection timeout");
client.stop();
SetErrors(204);
return;
}
}
// Read all the lines of the reply from server and print them to Serial
while(client.available()){
String line = client.readStringUntil('\r');
Serial.println(line);
if (line.length()>1){
line.toCharArray(house_json,200);
if (deserializeHouse()){
htdata.error = 0;//wyczyść status błędu
errorcount =0;
CheckHeater();
}
else
{
Serial.println("Error in house JSON received!");
SetError(203);
}
}
}
if (client.connected()) {
Serial.println("disconnecting from host.");
client.stop();
}
}
Serial.print("Time : ");
Serial.println(millis() - timeconn);
}
void connectWiFi(){
int count=0;
sprintf(hostString, "ESP_%06X", ESP.getChipId());
Serial.println();
Serial.print("Connecting to ");
Serial.println(ssid);
WiFi.persistent(false);
WiFi.mode(WIFI_STA);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
count++;
if (count>30) {
Serial.println();
Serial.print("Cannot connect to ");
Serial.println(ssid);
SetError(200);
return;
}
}
isConnected = true;
WiFi.hostname(hostString);
Serial.println("");
Serial.println("WiFi connected");
Serial.println("IP address: ");
Serial.println(WiFi.localIP());
Serial.print("Hostname: ");
Serial.println(hostString);
if (!MDNS.begin(hostString)) {
Serial.println("Error setting up MDNS responder!");
SetError(201);
}
//Serial.println("Sending mDNS query");
hostcount = MDNS.queryService("htcontrol", "tcp");
//Serial.println("mDNS query done");
if (hostcount == 0) {
Serial.println("No control service found");
SetError(202);
}
else {
Serial.printf("Found: %d TCP/IP services\n\r",hostcount);
}
}
void SetError(int error)
{
htdata.error = error;
StopHeater();
}
void SetErrors(int error)
{
if (errorcount <= 5)
{
errorcount++;
}
else
{
SetError(error);
}
}
void StopHeater()
{
if (isHeating)
{
Serial.println("Heater stopping...");
/* tutaj kod zatrzymujący grzanie */
htdata.status = 0; //zatrzymany
isHeating = false;
}
}
void StartHeater()
{
if (!isHeating || htdata.error==0)
{
Serial.println("Heater starting...");
/* tutaj kod uruchamiający grzanie */
htdata.status = 1;// uruchomiony
isHeating = true;
}
}
void CheckHeater()
{
/* Tryb pracy pieca
(0 - automatycznie,1 - grzanie wody, 2 - piec wyłączony)
*/
switch (house.rmode) {
case 0:
htdata.mode = 0;
if (house.temperature < house.requested + histereza) StartHeater();
else
StopHeater();
break;
case 1:
htdata.mode = 1;
if (htdata.temperature >= house.tmax || htdata.temperature <= house.tmin) StopHeater();
else
StartHeater();
break;
case 2:
StopHeater;
break;
default:
Serial.println("Nieznane żądanie trybu pracy!");
break;
}
}
tablatronix
devyte
KlaasjanN
d-a-v
mafe
rodri16
Basic Infos
Hardware
Hardware: Wemos D2 Mini ESP12F Core Version: ?2.1.0-rc2?
Description
It happens when Wificlient is abruptly disconnected (for example when power failure occurs). When power is restored connection to Wifi softAP seems established but TCP server do not work again : My question is how to detect such problem in server code and close client releasing TCP stack ? At least wdt reset would be nice
Settings in IDE
Module: Wemos D2 Mini Flash Size: ?4MB/1MB? CPU Frequency: ?80Mhz? Flash Mode: ?qio? Flash Frequency: ?40Mhz? Upload Using: ?OTA / SERIAL? Reset Method: ?ck / nodemcu?
Sketch
Debug Messages