Home Automation Project: CPI Data

// This #include statement was automatically added by the Particle IDE.
#include <ArduinoJson.h>

// This #include statement was automatically added by the Particle IDE.
#include <neopixel.h>

// This #include statement was automatically added by the Particle IDE.
#include <Stepper.h>


const int stepsPerRevolution = 2048;  // change this to fit the number of steps per revolution
// for your motor

//initializing neopixel strip
#if (PLATFORM_ID == 32)
// MOSI pin MO
#define PIXEL_PIN SPI1
// MOSI pin D2
// #define PIXEL_PIN SPI1
#else // #if (PLATFORM_ID == 32)
#define PIXEL_PIN D2
#endif
#define PIXEL_COUNT 7
#define PIXEL_TYPE WS2812B

#define IN1 3
#define IN2 4
#define IN3 5
#define IN4 6

SerialLogHandler logHandler(LOG_LEVEL_INFO);

String startDate = "2020-01-01";
String refDate = "";

int period = 86400000;
unsigned long time_now = 0;


Adafruit_NeoPixel strip(PIXEL_COUNT, PIXEL_PIN, PIXEL_TYPE);

// initialize the stepper library on pins 8 through 11:
Stepper myStepper(stepsPerRevolution, IN1, IN3, IN2, IN4);

 long oldCPI = 0;

void setup() {
    
    
     Particle.subscribe(String(System.deviceID()) + "/hook-response/cpiData", myHandler);  // Hook response
    Serial.begin(9600);
    

      
    strip.begin();
    strip.setBrightness(50);
    for(int i = 0; i<7;i++){
        strip.setPixelColor(i,255,255,255);
    }
    strip.show();
  // set the speed at 17 rpm:
  myStepper.setSpeed(17);
  // initialize the serial port:
  Serial.begin(9600);
  
 
}

void loop() {
    
    time_now = millis();
  
  StaticJsonDocument<128> doc;  
  
  doc["start_date"] = startDate;

  
  std::string jsonPayload;
  serializeJson(doc, jsonPayload);

  
  Particle.publish("cpiData", jsonPayload.c_str(), PRIVATE);
  
  while(millis() < time_now + period){
    }


}

void myHandler(const char *event, const char *data) {
  // Handle the integration response
  String dataStr = String(data);
 
  
  String refCPI = dataStr.substring(35,38);
  refDate = dataStr.substring(61,71);
  
  //Serial.println(data);
  Serial.println(refCPI);
  Serial.println("refCPI");
  Serial.println(refDate);
  
  startDate = refDate;
  
 long currCPI = refCPI.toInt();
 
 if(currCPI>250)
 {
     if(oldCPI>300)
    {
         for(int i = 2;i<5;i++)
         {
             strip.setPixelColor(i,255,255,255);
         }
        strip.show();
        myStepper.step(stepsPerRevolution/3);
     
    }
    else
    {
        for(int i = 0; i<2;i++)
      {
         strip.setPixelColor(i,0,0,0);
      }
        strip.show();
         myStepper.step(-stepsPerRevolution/3); 
    }
    
 }
     if(currCPI>300)
 {
     if(oldCPI>350)
    {
         for(int i = 2;i<5;i++)
         {
             strip.setPixelColor(i,255,255,255);
         }
        strip.show();
        myStepper.step(stepsPerRevolution/3);
     
    }
    else{
     for(int i = 2; i<5;i++)
     {
         strip.setPixelColor(i,0,0,0);
     }
     strip.show();
    myStepper.step(-stepsPerRevolution/3); 
    
    }
 }
    oldCPI = currCPI;
   
  
}