sakura.ioとArduinoとGROVEでクラウド温度計を作る(1)

#include "DHT.h"
#include "TM1637.h"
#include "SakuraIO.h"

#define DHTPIN 2
#define DHTTYPE DHT11

#define CLK 5
#define DIO 6

DHT dht(DHTPIN , DHTTYPE);
TM1637 tm1637(CLK , DIO);
SakuraIO_I2C sakuraio;

//---温度計の更新間隔(60秒)
const uint32_t UPDATE_TIME = 60;

//---温度の値
int8_t temperature = 0;

//---湿度の値
int8_t humidity = 0;

//---キューに追加した時間
uint32_t queued_time = 0;

//---Unixtime
uint32_t unixtime = 0;

///=======================================================================
//   +setup
///=======================================================================

void setup() {

	//---Serialポートを開く
	Serial.begin(9600);

	//---ディスプレイ初期化
	tm1637.init();

	//---温度計初期化
	dht.begin();

	//---ディスプレイ輝度（普通）
	tm1637.set(BRIGHT_TYPICAL);

	//---------------------------------------------
	//   +sakura.ioがオンラインになるまで待つ
	//---------------------------------------------

	Serial.println(F("Waiting to come online"));

	for(;;){
		if((sakuraio.getConnectionStatus() & 0x80) == 0x80) break;
		Serial.print(F("."));
		delay(1000);
	}

	Serial.println("");
}

///=======================================================================
//   +loop
///=======================================================================

void loop() {

	//---------------------------------------------
	//   +温度・湿度取得
	//---------------------------------------------

	float sensor_h = dht.readHumidity();
	float sensor_t = dht.readTemperature();

	//---エラー時
	if(isnan(sensor_t) || isnan(sensor_h)){

		Serial.println(F("Failed to read from DHT"));

		//---ディスプレイの消灯
		tm1637.clearDisplay();

		//---正常時
	}else{

		//---数値の温度に変換
		temperature = (int)sensor_t;
		humidity = (int)sensor_h;

		//---ディスプレイに表示
		tm1637.displayNum(temperature);

		//---------------------------------------------
		//   +sakura.ioがオンラインの時
		//---------------------------------------------

		if((sakuraio.getConnectionStatus() & 0x80) == 0x80){

			//---Unixtime
			uint32_t unixtime = (uint32_t)(sakuraio.getUnixtime()/1000UL);

			//---------------------
			//   +キューに追加
			//---------------------

			//---60秒間隔で温度・湿度をキューに追加する
			if(!queued_time || (unixtime - queued_time) >= UPDATE_TIME){

				//---キューに追加した時間
				queued_time = unixtime;

				Serial.print(F(" unixtime=")); Serial.println(unixtime);

				Serial.print(F(" 温度:")); Serial.print(temperature); Serial.print(F("℃"));
				Serial.print(F(" 湿度:")); Serial.print(humidity); Serial.println(F("% "));

				//---Queueに追加する
				EnQueue(temperature, humidity);
			}

			//---------------------------------------------
			//   +sakura.ioがオフラインの時
			//---------------------------------------------

		}else{

			Serial.println(F("sakura.io OFFLINE"));
		}
	}

	//---------------------
	//   +1秒ごとに実行
	//---------------------

	delay(1000);
}

///=======================================================================
//   +Queueに追加する
///=======================================================================
void EnQueue(int32_t p_sensor_t , int32_t p_sensor_h) {

	uint8_t ret;

	//---温度
	ret = sakuraio.enqueueTx((uint8_t)0, (int32_t)p_sensor_t);
	Serial.print(F(" Enqueue0=")); Serial.print(ret);

	//---湿度
	ret = sakuraio.enqueueTx((uint8_t)1, (int32_t)p_sensor_h);
	Serial.print(F(" Enqueue1=")); Serial.println(ret);

	//---------------------------------------------
	//   +sakura.ioに送信する
	//---------------------------------------------

	uint8_t avail;
	uint8_t queued;

	sakuraio.getTxQueueLength(&avail, &queued);

	Serial.print(F(" Tx Available=")); Serial.print(avail);
	Serial.print(F(" Queued=")); Serial.println(queued);

	//---30個以上でクリア
	if(queued >= 30){

		ret = sakuraio.clearTx();
		Serial.print(F(" Clear=")); Serial.println(ret);

		//---10個以上で送信
	}else if(queued >= 10){

		ret = sakuraio.send();
		Serial.print(F(" Send=")); Serial.println(ret);
	}
	
	Serial.println(F("-------------------------"));
}