include <ESP8266WiFi.h>

include <PubSubClient.h>

include <ArduinoJson.h>

include <Wire.h>

include "MAX30100_PulseOximeter.h"

include "Wire.h"

include "Adafruit_GFX.h"

include "OakOLED.h"

define REPORTING_PERIOD_MS 1000

OakOLED oled;

define WIFI_SSID "12345678"

define WIFI_PASSWD "12345678"

define PRODUCT_KEY "h6o8Si8IfHN"

define DEVICE_NAME "esp8266"

define DEVICE_SECRET "7533f31f2f04c432bf9ca96409acf1ba"

define REGION_ID "cn-shanghai"

define MQTT_SERVER PRODUCT_KEY ".iot-as-mqtt." REGION_ID ".aliyuncs.com"

define MQTT_PORT 1883

define MQTT_USRNAME DEVICE_NAME "&" PRODUCT_KEY

define CLIENT_ID "123456|securemode=2,signmethod=hmacsha1,timestamp=1652678096893|"

define MQTT_PASSWD "5DAF353B16B8E7A0732D90F26912C02B4A529C4F"

define ALINK_BODY_FORMAT "{\"id\":\"123\",\"version\":\"1.0\",\"method\":\"thing.event.property.post\",\"params\":%s}"

define ALINK_TOPIC_PROP_POST "/sys/" PRODUCT_KEY "/" DEVICE_NAME "/thing/event/property/post"

unsigned long lastMs = 0;
WiFiClient espClient;
PubSubClient client(espClient);

PulseOximeter pox;
uint32_t tsLastReport = 0;
const unsigned char bitmap [] PROGMEM=
{
0x00, 0x00, 0x00, 0x00, 0x01, 0x80, 0x18, 0x00, 0x0f, 0xe0, 0x7f, 0x00, 0x3f, 0xf9, 0xff, 0xc0,
0x7f, 0xf9, 0xff, 0xc0, 0x7f, 0xff, 0xff, 0xe0, 0x7f, 0xff, 0xff, 0xe0, 0xff, 0xff, 0xff, 0xf0,
0xff, 0xf7, 0xff, 0xf0, 0xff, 0xe7, 0xff, 0xf0, 0xff, 0xe7, 0xff, 0xf0, 0x7f, 0xdb, 0xff, 0xe0,
0x7f, 0x9b, 0xff, 0xe0, 0x00, 0x3b, 0xc0, 0x00, 0x3f, 0xf9, 0x9f, 0xc0, 0x3f, 0xfd, 0xbf, 0xc0,
0x1f, 0xfd, 0xbf, 0x80, 0x0f, 0xfd, 0x7f, 0x00, 0x07, 0xfe, 0x7e, 0x00, 0x03, 0xfe, 0xfc, 0x00,
0x01, 0xff, 0xf8, 0x00, 0x00, 0xff, 0xf0, 0x00, 0x00, 0x7f, 0xe0, 0x00, 0x00, 0x3f, 0xc0, 0x00,
0x00, 0x0f, 0x00, 0x00, 0x00, 0x06, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00
};

void onBeatDetected()
{
Serial.println("Beat!");
oled.drawBitmap( 60, 20, bitmap, 28, 28, 1);
oled.display();
}

//连接wifi
void wifiInit()
{

WiFi.mode(WIFI_STA);
WiFi.begin(WIFI_SSID, WIFI_PASSWD);
while (WiFi.status() != WL_CONNECTED)
{
    delay(1000);
    Serial.println("WiFi not Connect");
}
client.setServer(MQTT_SERVER, MQTT_PORT);   /* 连接WiFi之后，连接MQTT服务器 */

}
//mqtt连接
void mqttCheckConnect()
{

while (!client.connected())
{
     Serial.println("Connecting to MQTT Server ...");
    if (client.connect(CLIENT_ID, MQTT_USRNAME, MQTT_PASSWD))

    {

        Serial.println("MQTT Connected!");

    }
    else
    {
        Serial.print("MQTT Connect err:");
        Serial.println(client.state());
        delay(5000);
    }
}

}

void mqttIntervalPost()
{

char param[32];
char jsonBuf[128];
sprintf(param, "{\"heart\":%2f}", pox.getHeartRate());
sprintf(jsonBuf, ALINK_BODY_FORMAT, param);
sprintf(param, "{\"spo2\":%2f}", pox.getSpO2());
sprintf(jsonBuf, ALINK_BODY_FORMAT, param);
boolean d = client.publish(ALINK_TOPIC_PROP_POST, jsonBuf);

}

void setup()
{
Wire.begin(D2,D1);
Serial.begin(115200);

wifiInit();

oled.begin();
oled.clearDisplay();
oled.setTextSize(1);
oled.setTextColor(1);
oled.setCursor(0, 0);

oled.println("Initializing pulse oximeter..");
oled.display();
Serial.print("Initializing pulse oximeter..");

if (!pox.begin()) {
Serial.println("FAILED");
oled.clearDisplay();
oled.setTextSize(1);
oled.setTextColor(1);
oled.setCursor(0, 0);
oled.println("FAILED");
oled.display();
for(;;);
} else {
oled.clearDisplay();
oled.setTextSize(1);
oled.setTextColor(1);
oled.setCursor(0, 0);
oled.println("SUCCESS");
oled.display();
Serial.println("SUCCESS");
}
pox.setOnBeatDetectedCallback(onBeatDetected);
}

void loop()
{
pox.update();
if (millis() - tsLastReport > REPORTING_PERIOD_MS)
{

Serial.print("Heart BPM:");
Serial.print(pox.getHeartRate());
Serial.print("-----");
Serial.print("Oxygen Percent:");
Serial.print(pox.getSpO2());
Serial.println("\n");
oled.clearDisplay();
oled.setTextSize(1);
oled.setTextColor(1);
oled.setCursor(0,16);
oled.println(pox.getHeartRate());

oled.setTextSize(1);
oled.setTextColor(1);
oled.setCursor(0, 0);
oled.println("Heart BPM");

oled.setTextSize(1);
oled.setTextColor(1);
oled.setCursor(0, 30);
oled.println("Spo2");

oled.setTextSize(1);
oled.setTextColor(1);
oled.setCursor(0,45);
oled.println(pox.getSpO2());
oled.display();
tsLastReport = millis();

}
if (millis() - lastMs >= 5000)
{

    lastMs = millis();
    mqttCheckConnect(); 
    /* 上报 */
    mqttIntervalPost();

}

  client.loop();
delay(2000);

}