WeatherPlatform - mbed Weather Platform firmware http://mbed.org/us…

Users » okini3939 » Code » WeatherPlatform

Suga koubou / Mbed 2 deprecated WeatherPlatform

mbed Weather Platform firmware http://mbed.org/users/okini3939/notebook/mbed-weather-platform-firmware/

Dependencies: EthernetNetIf SDHCFileSystem I2CLEDDisp Agentbed NTPClient_NetServices mbed BMP085 HTTPClient ConfigFile I2CLCD

main.cpp@6:060cb9725ce3, 2011-01-12 (annotated)

Committer:: okini3939
Date:: Wed Jan 12 14:16:20 2011 +0000
Revision:: 6:060cb9725ce3
Parent:: 5:9fa79cb5ec98
Child:: 7:0d3484dc13a9

Who changed what in which revision?

User	Revision	Line number	New contents of line
okini3939	0:4265d973a98f	1	/*
okini3939	0:4265d973a98f	2	* mbed Weather Platform
okini3939	6:060cb9725ce3	3	* Copyright (c) 2011 Hiroshi Suga
okini3939	0:4265d973a98f	4	* Released under the MIT License: http://mbed.org/license/mit
okini3939	0:4265d973a98f	5	*/
okini3939	1:86d4b7431fbe	6
okini3939	1:86d4b7431fbe	7	/** @file
okini3939	1:86d4b7431fbe	8	* @brief mbed Weather Platform
okini3939	0:4265d973a98f	9	*/
okini3939	3:60f5f6d5f765	10
okini3939	6:060cb9725ce3	11	#define VERSION "mbed Weather Platform 0.1.2 (C) 2011 Suga koubou Co.,Ltd."
okini3939	3:60f5f6d5f765	12	#define USE_I2CLEDDISP // I2C LED Display
okini3939	3:60f5f6d5f765	13	//#define NONBLOCKING // ethernet function non-bloking
okini3939	3:60f5f6d5f765	14
okini3939	0:4265d973a98f	15	#include "mbed.h"
okini3939	0:4265d973a98f	16	#include "BMP085.h"
okini3939	0:4265d973a98f	17	#include "SHT.h"
okini3939	0:4265d973a98f	18	#include "WeatherMeters.h"
okini3939	0:4265d973a98f	19	#include "ConfigFile.h"
okini3939	0:4265d973a98f	20	#include "SDFileSystem.h"
okini3939	2:4125fe2283ef	21	#include "MSCFileSystem.h"
okini3939	0:4265d973a98f	22	#include "EthernetNetIf.h"
okini3939	0:4265d973a98f	23	#include "NTPClient.h"
okini3939	0:4265d973a98f	24	#include "HTTPClient.h"
okini3939	5:9fa79cb5ec98	25	#include "Agentbed.h"
okini3939	0:4265d973a98f	26
okini3939	3:60f5f6d5f765	27	#ifdef USE_I2CLEDDISP
okini3939	3:60f5f6d5f765	28	#include "I2CLEDDisp.h"
okini3939	3:60f5f6d5f765	29	#endif
okini3939	0:4265d973a98f	30
okini3939	0:4265d973a98f	31	Serial pc(USBTX, USBRX);
okini3939	0:4265d973a98f	32	int seq = 0;
okini3939	0:4265d973a98f	33	char filename[20];
okini3939	0:4265d973a98f	34	ConfigFile conf;
okini3939	1:86d4b7431fbe	35	DigitalOut led1(LED1), led2(LED2), led3(LED3), led4(LED4);
okini3939	0:4265d973a98f	36	SDFileSystem sd(p5, p6, p7, p8, "sd");
okini3939	2:4125fe2283ef	37	MSCFileSystem *usb;
okini3939	0:4265d973a98f	38
okini3939	0:4265d973a98f	39	// Sensors
okini3939	0:4265d973a98f	40	float pres, temp, humi, light, anemo, vane, rain, uv, moist, temp2;
okini3939	0:4265d973a98f	41	I2C i2c(p9, p10);
okini3939	0:4265d973a98f	42	BMP085 bmp085(i2c, BMP085_oss4);
okini3939	0:4265d973a98f	43	SHT sht15(p12, p11, SHT_high); // sclock, data
okini3939	0:4265d973a98f	44	WeatherMeters wmeters(p21, p15, p22); // anemo, vane, rain
okini3939	0:4265d973a98f	45	AnalogIn ailight(p16), aimoist(p18), aiuv(p17);
okini3939	0:4265d973a98f	46
okini3939	3:60f5f6d5f765	47	#ifdef USE_I2CLEDDISP
okini3939	3:60f5f6d5f765	48	I2CLEDDisp leddisp(i2c);
okini3939	3:60f5f6d5f765	49	Ticker ticker;
okini3939	3:60f5f6d5f765	50	int ledpos, ledflg;
okini3939	3:60f5f6d5f765	51	char ledbuf[100];
okini3939	3:60f5f6d5f765	52	#endif
okini3939	3:60f5f6d5f765	53
okini3939	0:4265d973a98f	54	// Ethernet
okini3939	0:4265d973a98f	55	EthernetNetIf *eth;
okini3939	0:4265d973a98f	56	NTPClient *ntp;
okini3939	1:86d4b7431fbe	57	HTTPClient clientP, clientT;
okini3939	0:4265d973a98f	58	DigitalOut led_g(p25), led_y(p26);
okini3939	0:4265d973a98f	59	DigitalIn eth_link(P1_25), eth_speed(P1_26);
okini3939	0:4265d973a98f	60
okini3939	5:9fa79cb5ec98	61	extern AgentbedClass Agentbed;
okini3939	5:9fa79cb5ec98	62	extern uint32_t locUpTime;
okini3939	5:9fa79cb5ec98	63
okini3939	1:86d4b7431fbe	64	void writefile (char *);
okini3939	1:86d4b7431fbe	65	void pachube (char *);
okini3939	1:86d4b7431fbe	66	void twitter ();
okini3939	5:9fa79cb5ec98	67	void weatherstations ();
okini3939	1:86d4b7431fbe	68	void ntpdate ();
okini3939	1:86d4b7431fbe	69	int check_action (char);
okini3939	5:9fa79cb5ec98	70	void pduReceived ();
okini3939	0:4265d973a98f	71
okini3939	0:4265d973a98f	72	float get_photo (AnalogIn &ain) {
okini3939	0:4265d973a98f	73	float f;
okini3939	0:4265d973a98f	74
okini3939	0:4265d973a98f	75	f = ain * 5.0 / 1000; // A
okini3939	0:4265d973a98f	76	return f / 0.0000026; // lx
okini3939	0:4265d973a98f	77	}
okini3939	0:4265d973a98f	78
okini3939	0:4265d973a98f	79	float get_moist (AnalogIn &ain) {
okini3939	0:4265d973a98f	80	float f;
okini3939	0:4265d973a98f	81
okini3939	0:4265d973a98f	82	f = ain * 5.0; // V
okini3939	2:4125fe2283ef	83	f = f / ((3.3 - f) / 10.0); // k ohm
okini3939	2:4125fe2283ef	84	if (f < 0) f = 0;
okini3939	2:4125fe2283ef	85	return f;
okini3939	0:4265d973a98f	86	}
okini3939	0:4265d973a98f	87
okini3939	0:4265d973a98f	88	float get_uv (AnalogIn &ain) {
okini3939	0:4265d973a98f	89	float f;
okini3939	0:4265d973a98f	90
okini3939	0:4265d973a98f	91	f = ain * 5.0 / 100000; // A
okini3939	2:4125fe2283ef	92	f = f / 0.000384; // mW/cm2
okini3939	2:4125fe2283ef	93	if (f < 0) f = 0;
okini3939	2:4125fe2283ef	94	return f;
okini3939	0:4265d973a98f	95	}
okini3939	0:4265d973a98f	96
okini3939	3:60f5f6d5f765	97	#ifdef USE_I2CLEDDISP
okini3939	3:60f5f6d5f765	98	void ledscroll () {
okini3939	3:60f5f6d5f765	99	int i, addr, len;
okini3939	3:60f5f6d5f765	100
okini3939	3:60f5f6d5f765	101	len = strlen(ledbuf);
okini3939	3:60f5f6d5f765	102	leddisp.locate(0, 0);
okini3939	3:60f5f6d5f765	103	for (i = 0; i < 4; i ++) {
okini3939	3:60f5f6d5f765	104	addr = ledpos + i;
okini3939	3:60f5f6d5f765	105	if (addr >= 0 && addr < len) {
okini3939	3:60f5f6d5f765	106	leddisp.putc(ledbuf[addr]);
okini3939	3:60f5f6d5f765	107	} else {
okini3939	3:60f5f6d5f765	108	leddisp.putc(' ');
okini3939	3:60f5f6d5f765	109	}
okini3939	3:60f5f6d5f765	110	}
okini3939	3:60f5f6d5f765	111	ledpos ++;
okini3939	3:60f5f6d5f765	112	if (ledpos >= len + 4) {
okini3939	3:60f5f6d5f765	113	ledpos = -4;
okini3939	3:60f5f6d5f765	114	}
okini3939	3:60f5f6d5f765	115	}
okini3939	3:60f5f6d5f765	116	#endif
okini3939	3:60f5f6d5f765	117
okini3939	1:86d4b7431fbe	118	void action (char *buf) {
okini3939	1:86d4b7431fbe	119	if (check_action('H')) {
okini3939	1:86d4b7431fbe	120	led4 = 1;
okini3939	0:4265d973a98f	121	}
okini3939	1:86d4b7431fbe	122	if (check_action('L')) {
okini3939	1:86d4b7431fbe	123	led4 = 0;
okini3939	0:4265d973a98f	124	}
okini3939	1:86d4b7431fbe	125	if (check_action('P')) {
okini3939	1:86d4b7431fbe	126	if (conf.ipaddr[0] && conf.pachube_apikey[0] && conf.pachube_feedid[0]) {
okini3939	1:86d4b7431fbe	127	pachube(buf);
okini3939	1:86d4b7431fbe	128	}
okini3939	0:4265d973a98f	129	}
okini3939	1:86d4b7431fbe	130	if (check_action('T')) {
okini3939	1:86d4b7431fbe	131	if (conf.ipaddr[0] && conf.twitter_user[0] && conf.twitter_pwd[0]) {
okini3939	1:86d4b7431fbe	132	twitter();
okini3939	1:86d4b7431fbe	133	}
okini3939	1:86d4b7431fbe	134	}
okini3939	5:9fa79cb5ec98	135	if (check_action('S')) {
okini3939	5:9fa79cb5ec98	136	if (conf.ipaddr[0] && conf.stations_id[0] && conf.stations_pin[0]) {
okini3939	5:9fa79cb5ec98	137	weatherstations();
okini3939	5:9fa79cb5ec98	138	}
okini3939	5:9fa79cb5ec98	139	}
okini3939	0:4265d973a98f	140	}
okini3939	0:4265d973a98f	141
okini3939	0:4265d973a98f	142	void init () {
okini3939	0:4265d973a98f	143	FILE *fp;
okini3939	0:4265d973a98f	144
okini3939	6:060cb9725ce3	145	conf.load("/sd/weather.cfg");
okini3939	0:4265d973a98f	146
okini3939	2:4125fe2283ef	147	pc.printf("Interval: %d sec\r\n", conf.interval);
okini3939	2:4125fe2283ef	148
okini3939	0:4265d973a98f	149	if (conf.ipaddr[0]) {
okini3939	0:4265d973a98f	150	// use ethernet
okini3939	0:4265d973a98f	151
okini3939	0:4265d973a98f	152	eth_link.mode(PullUp);
okini3939	0:4265d973a98f	153	eth_speed.mode(PullUp);
okini3939	0:4265d973a98f	154	led_g = eth_link ? 1 : 0;
okini3939	0:4265d973a98f	155	led_y = eth_speed ? 1 : 0;
okini3939	0:4265d973a98f	156	if (conf.ipaddr[0] == 255) {
okini3939	0:4265d973a98f	157	// dhcp
okini3939	0:4265d973a98f	158	eth = new EthernetNetIf;
okini3939	0:4265d973a98f	159	} else {
okini3939	0:4265d973a98f	160	// static
okini3939	0:4265d973a98f	161	eth = new EthernetNetIf(conf.ipaddr, conf.netmask, conf.gateway, conf.nameserver);
okini3939	0:4265d973a98f	162	}
okini3939	0:4265d973a98f	163
okini3939	0:4265d973a98f	164	EthernetErr ethErr = eth->setup();
okini3939	0:4265d973a98f	165	if(ethErr) {
okini3939	0:4265d973a98f	166	// error
okini3939	0:4265d973a98f	167	conf.ipaddr = IpAddr(0, 0, 0, 0);
okini3939	0:4265d973a98f	168	} else
okini3939	0:4265d973a98f	169	if (conf.ipaddr[0] == 255) {
okini3939	0:4265d973a98f	170	// succeed dhcp
okini3939	0:4265d973a98f	171	conf.ipaddr = eth->getIp();
okini3939	0:4265d973a98f	172	}
okini3939	0:4265d973a98f	173	pc.printf("Ethernet: %d.%d.%d.%d\r\n", eth->getIp()[0], eth->getIp()[1], eth->getIp()[2], eth->getIp()[3]);
okini3939	0:4265d973a98f	174
okini3939	5:9fa79cb5ec98	175	if (conf.ipaddr[0]) {
okini3939	5:9fa79cb5ec98	176
okini3939	5:9fa79cb5ec98	177	if (conf.ntpserver[0]) {
okini3939	5:9fa79cb5ec98	178	// ntp
okini3939	5:9fa79cb5ec98	179	pc.printf("Ntp: %s\r\n", conf.ntpserver);
okini3939	5:9fa79cb5ec98	180	ntpdate();
okini3939	5:9fa79cb5ec98	181	}
okini3939	0:4265d973a98f	182
okini3939	0:4265d973a98f	183	clientP = new HTTPClient;
okini3939	1:86d4b7431fbe	184	clientT = new HTTPClient;
okini3939	5:9fa79cb5ec98	185
okini3939	5:9fa79cb5ec98	186	if (conf.snmp_commname[0]) {
okini3939	5:9fa79cb5ec98	187	Agentbed.begin(conf.snmp_commname, "None", SNMP_DEFAULT_PORT, eth);
okini3939	5:9fa79cb5ec98	188	Agentbed.onPduReceive(pduReceived);
okini3939	5:9fa79cb5ec98	189	pc.printf("Snmp community name: %s\r\n", conf.snmp_commname);
okini3939	5:9fa79cb5ec98	190	}
okini3939	0:4265d973a98f	191	}
okini3939	0:4265d973a98f	192	}
okini3939	0:4265d973a98f	193
okini3939	0:4265d973a98f	194	if (conf.filetype) {
okini3939	0:4265d973a98f	195	// seq num
okini3939	2:4125fe2283ef	196
okini3939	2:4125fe2283ef	197	if (conf.filetype == 1) {
okini3939	2:4125fe2283ef	198	strcpy(filename, "/sd");
okini3939	2:4125fe2283ef	199	} else
okini3939	2:4125fe2283ef	200	if (conf.filetype == 2) {
okini3939	2:4125fe2283ef	201	usb = new MSCFileSystem("usb");
okini3939	2:4125fe2283ef	202	strcpy(filename, "/usb");
okini3939	2:4125fe2283ef	203	}
okini3939	2:4125fe2283ef	204	strcat(filename, "/weather.seq");
okini3939	2:4125fe2283ef	205
okini3939	2:4125fe2283ef	206	// load
okini3939	2:4125fe2283ef	207	fp = fopen(filename, "r");
okini3939	0:4265d973a98f	208	if (fp) {
okini3939	0:4265d973a98f	209	fscanf(fp, "%d", &seq);
okini3939	0:4265d973a98f	210	fclose(fp);
okini3939	0:4265d973a98f	211	}
okini3939	0:4265d973a98f	212	seq ++;
okini3939	2:4125fe2283ef	213	// save
okini3939	2:4125fe2283ef	214	fp = fopen(filename, "w");
okini3939	0:4265d973a98f	215	if (fp) {
okini3939	0:4265d973a98f	216	fprintf(fp, "%d", seq);
okini3939	0:4265d973a98f	217	fclose(fp);
okini3939	2:4125fe2283ef	218	// csv filename
okini3939	0:4265d973a98f	219	if (conf.filetype == 1) {
okini3939	0:4265d973a98f	220	sprintf(filename, "/sd/w%05d.csv", seq);
okini3939	0:4265d973a98f	221	} else
okini3939	0:4265d973a98f	222	if (conf.filetype == 2) {
okini3939	0:4265d973a98f	223	sprintf(filename, "/usb/w%05d.csv", seq);
okini3939	0:4265d973a98f	224	}
okini3939	0:4265d973a98f	225	pc.printf("Filename: %s\r\n", filename);
okini3939	0:4265d973a98f	226	led2 = 1;
okini3939	0:4265d973a98f	227	}
okini3939	0:4265d973a98f	228	}
okini3939	0:4265d973a98f	229	}
okini3939	0:4265d973a98f	230
okini3939	0:4265d973a98f	231	int main () {
okini3939	0:4265d973a98f	232	Timer timer;
okini3939	0:4265d973a98f	233	time_t sec;
okini3939	0:4265d973a98f	234	char buf[100];
okini3939	0:4265d973a98f	235
okini3939	0:4265d973a98f	236	led1 = 1;
okini3939	3:60f5f6d5f765	237	#ifdef USE_I2CLEDDISP
okini3939	3:60f5f6d5f765	238	ledflg = 0;
okini3939	3:60f5f6d5f765	239	ledpos = -4;
okini3939	3:60f5f6d5f765	240	strcpy(ledbuf, VERSION);
okini3939	3:60f5f6d5f765	241	ticker.attach(&ledscroll, 0.4);
okini3939	3:60f5f6d5f765	242	#endif
okini3939	0:4265d973a98f	243	init();
okini3939	0:4265d973a98f	244	pc.printf(VERSION "\r\n\r\n");
okini3939	0:4265d973a98f	245
okini3939	0:4265d973a98f	246	if (conf.filetype) {
okini3939	0:4265d973a98f	247	strcpy(buf, "date,pres(hPa),temp(`C),humi(%%),anemo(m/s),vane(`),rain(mm),light(lx),uv(mW/cm2),moist(kohm),\r\n");
okini3939	0:4265d973a98f	248	writefile(buf);
okini3939	0:4265d973a98f	249	}
okini3939	0:4265d973a98f	250
okini3939	3:60f5f6d5f765	251	#ifdef USE_I2CLEDDISP
okini3939	3:60f5f6d5f765	252	ledpos = -4;
okini3939	3:60f5f6d5f765	253	sec = time(NULL);
okini3939	3:60f5f6d5f765	254	strftime(ledbuf, sizeof(ledbuf), "%H:%M", localtime(&sec));
okini3939	3:60f5f6d5f765	255	sprintf(&ledbuf[5], " %ds %s", conf.interval, filename);
okini3939	3:60f5f6d5f765	256	if (conf.ipaddr[0]) {
okini3939	3:60f5f6d5f765	257	sprintf(&ledbuf[strlen(ledbuf)], " %d.%d.%d.%d", conf.ipaddr[0], conf.ipaddr[1], conf.ipaddr[2], conf.ipaddr[3]);
okini3939	3:60f5f6d5f765	258	if (conf.pachube_apikey[0] && conf.pachube_feedid[0]) {
okini3939	3:60f5f6d5f765	259	strcat(ledbuf, " P");
okini3939	3:60f5f6d5f765	260	}
okini3939	3:60f5f6d5f765	261	if (conf.twitter_user[0] && conf.twitter_pwd[0]) {
okini3939	3:60f5f6d5f765	262	strcat(ledbuf, " T");
okini3939	3:60f5f6d5f765	263	}
okini3939	3:60f5f6d5f765	264	}
okini3939	3:60f5f6d5f765	265	#endif
okini3939	3:60f5f6d5f765	266
okini3939	0:4265d973a98f	267	timer.start();
okini3939	0:4265d973a98f	268	#ifdef NONBLOCKING
okini3939	0:4265d973a98f	269	while (timer.read() < 5) {
okini3939	0:4265d973a98f	270	Net::poll();
okini3939	0:4265d973a98f	271	}
okini3939	0:4265d973a98f	272	timer.reset();
okini3939	0:4265d973a98f	273	#endif
okini3939	3:60f5f6d5f765	274
okini3939	0:4265d973a98f	275	while(1) {
okini3939	0:4265d973a98f	276	led1 = 0;
okini3939	0:4265d973a98f	277
okini3939	0:4265d973a98f	278	sec = time(NULL);
okini3939	0:4265d973a98f	279	strftime(buf, sizeof(buf), "%Y-%m-%d %H:%M:%S", localtime(&sec));
okini3939	0:4265d973a98f	280
okini3939	0:4265d973a98f	281	// sensors
okini3939	0:4265d973a98f	282	bmp085.update();
okini3939	0:4265d973a98f	283	pres = bmp085.get_pressure();
okini3939	0:4265d973a98f	284	temp2 = bmp085.get_temperature();
okini3939	0:4265d973a98f	285
okini3939	0:4265d973a98f	286	sht15.update(SHT_high);
okini3939	0:4265d973a98f	287	temp = sht15.get_temperature();
okini3939	0:4265d973a98f	288	humi = sht15.get_humidity();
okini3939	0:4265d973a98f	289
okini3939	0:4265d973a98f	290	anemo = wmeters.get_windspeed();
okini3939	0:4265d973a98f	291	vane = wmeters.get_windvane();
okini3939	0:4265d973a98f	292	rain = wmeters.get_raingauge();
okini3939	0:4265d973a98f	293
okini3939	0:4265d973a98f	294	light = get_photo(ailight);
okini3939	0:4265d973a98f	295	moist = get_moist(aimoist);
okini3939	0:4265d973a98f	296	uv = get_uv(aiuv);
okini3939	0:4265d973a98f	297
okini3939	0:4265d973a98f	298	sprintf(&buf[strlen(buf)], ",%.2f,%.2f,%.2f,%.2f,%.2f,%.2f,%.2f,%.2f,%.2f,%.2f\r\n", pres, temp, humi, anemo, vane, rain, light, uv, moist, temp2);
okini3939	0:4265d973a98f	299	pc.printf(buf);
okini3939	0:4265d973a98f	300	if (conf.filetype) {
okini3939	0:4265d973a98f	301	// csv
okini3939	0:4265d973a98f	302	writefile(buf);
okini3939	0:4265d973a98f	303	}
okini3939	3:60f5f6d5f765	304
okini3939	1:86d4b7431fbe	305	action(&buf[20]);
okini3939	3:60f5f6d5f765	306
okini3939	3:60f5f6d5f765	307	#ifdef USE_I2CLEDDISP
okini3939	3:60f5f6d5f765	308	if (ledflg) {
okini3939	3:60f5f6d5f765	309	ledpos = -4;
okini3939	3:60f5f6d5f765	310	strftime(ledbuf, sizeof(ledbuf), "%H:%M", localtime(&sec));
okini3939	3:60f5f6d5f765	311	sprintf(&ledbuf[5], " %dhPa %d\x1b %d%% %dm/s %d' %dmm/h", (int)pres, (int)temp, (int)humi, (int)anemo, (int)vane, (int)rain);
okini3939	0:4265d973a98f	312	}
okini3939	3:60f5f6d5f765	313	ledflg = 1;
okini3939	3:60f5f6d5f765	314	#endif
okini3939	0:4265d973a98f	315	led1 = 1;
okini3939	0:4265d973a98f	316
okini3939	0:4265d973a98f	317	while (timer.read() < conf.interval) {
okini3939	0:4265d973a98f	318	// wait(1);
okini3939	0:4265d973a98f	319	// pc.putc('.');
okini3939	0:4265d973a98f	320	led_g = eth_link ? 1 : 0;
okini3939	0:4265d973a98f	321	led_y = eth_speed ? 1 : 0;
okini3939	0:4265d973a98f	322	Net::poll();
okini3939	0:4265d973a98f	323	}
okini3939	0:4265d973a98f	324	timer.reset();
okini3939	5:9fa79cb5ec98	325	locUpTime = locUpTime + (conf.interval * 100);
okini3939	0:4265d973a98f	326	}
okini3939	0:4265d973a98f	327	}

Repository toolbox

Export to desktop IDE

Build repository

Repository details

Type:	Program
Mbed OS support:	Mbed 2 deprecated
Created:	10 Dec 2010
Imports:	27
Forks:	0
Commits:	20
Dependents:	0
Dependencies:	13
Followers:	2

main.cpp@6:060cb9725ce3, 2011-01-12 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning