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

Dependencies:   ChaNFSSD EthernetNetIf I2CLEDDisp Agentbed ChaNFSUSB ILinterpreter mbed BMP085 WeatherMeters ConfigFile ChaNFS I2CLCD

Committer:
okini3939
Date:
Wed Oct 12 02:18:00 2011 +0000
Revision:
5:90f840432195
Parent:
2:a3e5edf84f74
Child:
6:898c306f7990

        

Who changed what in which revision?

UserRevisionLine numberNew contents of line
okini3939 1:6c7141895545 1 /*
okini3939 1:6c7141895545 2 * Weather Station - mbed Weather Platform
okini3939 1:6c7141895545 3 * Copyright (c) 2011 Hiroshi Suga
okini3939 1:6c7141895545 4 * Released under the MIT License: http://mbed.org/license/mit
okini3939 1:6c7141895545 5 */
okini3939 1:6c7141895545 6
okini3939 1:6c7141895545 7 /** @file
okini3939 1:6c7141895545 8 * @brief Weather Station
okini3939 1:6c7141895545 9 */
okini3939 1:6c7141895545 10
okini3939 0:bdb53686c194 11 #include "mbed.h"
okini3939 0:bdb53686c194 12 #include "weather.h"
okini3939 2:a3e5edf84f74 13 #include "SDFileSystem.h"
okini3939 2:a3e5edf84f74 14 #ifdef USE_USB
okini3939 0:bdb53686c194 15 #include "MSCFileSystem.h"
okini3939 2:a3e5edf84f74 16 #endif
okini3939 0:bdb53686c194 17 #include "ConfigFile.h"
okini3939 0:bdb53686c194 18
okini3939 0:bdb53686c194 19 static SDFileSystem sd(p5, p6, p7, p8, "sd");
okini3939 0:bdb53686c194 20 static LocalFileSystem *local;
okini3939 2:a3e5edf84f74 21 #ifdef USE_USB
okini3939 0:bdb53686c194 22 static MSCFileSystem *usb;
okini3939 2:a3e5edf84f74 23 #endif
okini3939 1:6c7141895545 24 static DigitalIn sd_ins(p27);
okini3939 2:a3e5edf84f74 25 struct Config conf;
okini3939 0:bdb53686c194 26 static char filename[30] = "";
okini3939 0:bdb53686c194 27
okini3939 0:bdb53686c194 28 int write_log (const char *buf) {
okini3939 0:bdb53686c194 29 FILE *fp;
okini3939 0:bdb53686c194 30
okini3939 0:bdb53686c194 31 if (filename[0] == 0) return 0;
okini3939 1:6c7141895545 32 #ifdef USE_SD_INS
okini3939 1:6c7141895545 33 if (sd_ins != 0) return -1;
okini3939 1:6c7141895545 34 #endif
okini3939 0:bdb53686c194 35
okini3939 2:a3e5edf84f74 36 LED_FILE_ACT_ON;
okini3939 0:bdb53686c194 37 fp = fopen(filename, "a");
okini3939 0:bdb53686c194 38 if (fp) {
okini3939 0:bdb53686c194 39 fprintf(fp, buf);
okini3939 5:90f840432195 40 fprintf(fp, "\r\n");
okini3939 0:bdb53686c194 41 fclose(fp);
okini3939 0:bdb53686c194 42 } else {
okini3939 2:a3e5edf84f74 43 LED_FILE_ACT_OFF;
okini3939 0:bdb53686c194 44 return -1;
okini3939 0:bdb53686c194 45 }
okini3939 2:a3e5edf84f74 46 LED_FILE_ACT_OFF;
okini3939 0:bdb53686c194 47 return 0;
okini3939 0:bdb53686c194 48 }
okini3939 0:bdb53686c194 49
okini3939 0:bdb53686c194 50 int init_file () {
okini3939 0:bdb53686c194 51 int seq = 0;
okini3939 2:a3e5edf84f74 52 char dir[8];
okini3939 0:bdb53686c194 53 FILE *fp;
okini3939 0:bdb53686c194 54
okini3939 2:a3e5edf84f74 55 if (conf.filetype) {
okini3939 2:a3e5edf84f74 56 if (conf.filetype == 1) {
okini3939 2:a3e5edf84f74 57 strcpy(dir, "/sd/");
okini3939 0:bdb53686c194 58 } else
okini3939 2:a3e5edf84f74 59 if (conf.filetype == 2) {
okini3939 2:a3e5edf84f74 60 #ifdef USE_USB
okini3939 0:bdb53686c194 61 usb = new MSCFileSystem("usb");
okini3939 2:a3e5edf84f74 62 strcpy(dir, "/usb/");
okini3939 2:a3e5edf84f74 63 #endif
okini3939 0:bdb53686c194 64 }
okini3939 0:bdb53686c194 65
okini3939 0:bdb53686c194 66 // seq num
okini3939 2:a3e5edf84f74 67 strcpy(filename, dir);
okini3939 0:bdb53686c194 68 strcat(filename, "weather.seq");
okini3939 2:a3e5edf84f74 69 LED_FILE_ACT_ON;
okini3939 0:bdb53686c194 70 fp = fopen(filename, "r");
okini3939 0:bdb53686c194 71 if (fp) {
okini3939 0:bdb53686c194 72 fscanf(fp, "%d", &seq);
okini3939 0:bdb53686c194 73 fclose(fp);
okini3939 0:bdb53686c194 74 }
okini3939 0:bdb53686c194 75 seq ++;
okini3939 0:bdb53686c194 76
okini3939 0:bdb53686c194 77 // save seq num
okini3939 0:bdb53686c194 78 fp = fopen(filename, "w");
okini3939 0:bdb53686c194 79 if (fp) {
okini3939 0:bdb53686c194 80 fprintf(fp, "%d", seq);
okini3939 0:bdb53686c194 81 fclose(fp);
okini3939 0:bdb53686c194 82 }
okini3939 2:a3e5edf84f74 83 LED_FILE_ACT_OFF;
okini3939 0:bdb53686c194 84
okini3939 0:bdb53686c194 85 // csv filename
okini3939 2:a3e5edf84f74 86 sprintf(filename, "%sw%05d.csv", dir, seq);
okini3939 0:bdb53686c194 87 pc.printf("CSV Filename: %s\r\n", filename);
okini3939 0:bdb53686c194 88 }
okini3939 0:bdb53686c194 89 return 0;
okini3939 0:bdb53686c194 90 }
okini3939 0:bdb53686c194 91
okini3939 0:bdb53686c194 92 char* chop (char *s) {
okini3939 0:bdb53686c194 93 int i;
okini3939 0:bdb53686c194 94
okini3939 0:bdb53686c194 95 for (i = strlen(s) - 1; i >= 0; i --) {
okini3939 0:bdb53686c194 96 if (s[i] == ' ' || s[i] == '\n' || s[i] == '\r') {
okini3939 0:bdb53686c194 97 s[i] = 0;
okini3939 0:bdb53686c194 98 } else {
okini3939 0:bdb53686c194 99 break;
okini3939 0:bdb53686c194 100 }
okini3939 0:bdb53686c194 101 }
okini3939 0:bdb53686c194 102 return s;
okini3939 0:bdb53686c194 103 }
okini3939 2:a3e5edf84f74 104
okini3939 2:a3e5edf84f74 105 int init_conf () {
okini3939 2:a3e5edf84f74 106 ConfigFile cfg;
okini3939 2:a3e5edf84f74 107 int i;
okini3939 2:a3e5edf84f74 108 char buf[CF_VALUE_SIZE], key[CF_KEY_SIZE];
okini3939 2:a3e5edf84f74 109 int ip0, ip1, ip2, ip3;
okini3939 2:a3e5edf84f74 110
okini3939 2:a3e5edf84f74 111 memset(&conf, 0, sizeof(conf));
okini3939 2:a3e5edf84f74 112 conf.interval = 60;
okini3939 2:a3e5edf84f74 113 strcpy(conf.csv_mesg, CSV_MESG);
okini3939 2:a3e5edf84f74 114
okini3939 2:a3e5edf84f74 115 #ifdef USE_SD_INS
okini3939 2:a3e5edf84f74 116 sd_ins.mode(PullUp);
okini3939 2:a3e5edf84f74 117 #endif
okini3939 2:a3e5edf84f74 118
okini3939 2:a3e5edf84f74 119 // open config
okini3939 2:a3e5edf84f74 120 LED_FILE_ACT_ON;
okini3939 2:a3e5edf84f74 121 #ifdef USE_SD_INS
okini3939 2:a3e5edf84f74 122 if (sd_ins == 0 && cfg.read("/sd/" CONFIG_FILE)) {
okini3939 2:a3e5edf84f74 123 #else
okini3939 2:a3e5edf84f74 124 if (cfg.read("/sd/" CONFIG_FILE)) {
okini3939 2:a3e5edf84f74 125 #endif
okini3939 2:a3e5edf84f74 126 // from sd
okini3939 2:a3e5edf84f74 127
okini3939 2:a3e5edf84f74 128 strcpy(conf.dir, "/sd/");
okini3939 2:a3e5edf84f74 129 LED_FILE_ACT_OFF;
okini3939 2:a3e5edf84f74 130
okini3939 2:a3e5edf84f74 131 } else {
okini3939 2:a3e5edf84f74 132 local = new LocalFileSystem("local");
okini3939 2:a3e5edf84f74 133 if (cfg.read("/local/" CONFIG_FILE)) {
okini3939 2:a3e5edf84f74 134 // from usb
okini3939 2:a3e5edf84f74 135
okini3939 2:a3e5edf84f74 136 strcpy(conf.dir, "/local/");
okini3939 2:a3e5edf84f74 137 LED_FILE_ACT_OFF;
okini3939 2:a3e5edf84f74 138
okini3939 2:a3e5edf84f74 139 } else {
okini3939 2:a3e5edf84f74 140 // none
okini3939 2:a3e5edf84f74 141 LED_FILE_ACT_OFF;
okini3939 2:a3e5edf84f74 142 return -1;
okini3939 2:a3e5edf84f74 143 }
okini3939 2:a3e5edf84f74 144 }
okini3939 2:a3e5edf84f74 145
okini3939 2:a3e5edf84f74 146 // load config
okini3939 2:a3e5edf84f74 147 if (cfg.getValue("INTERVAL", buf, sizeof_1(buf))) {
okini3939 2:a3e5edf84f74 148 conf.interval = atoi(buf);
okini3939 2:a3e5edf84f74 149 }
okini3939 2:a3e5edf84f74 150 if (cfg.getValue("BAUD", buf, sizeof_1(buf))) {
okini3939 2:a3e5edf84f74 151 conf.baud = atoi(buf);
okini3939 2:a3e5edf84f74 152 }
okini3939 2:a3e5edf84f74 153
okini3939 2:a3e5edf84f74 154 if (cfg.getValue("FILE", buf, sizeof_1(buf))) {
okini3939 2:a3e5edf84f74 155 chop(buf);
okini3939 2:a3e5edf84f74 156 if (strcmp(buf, "SD") == 0) {
okini3939 2:a3e5edf84f74 157 conf.filetype = 1;
okini3939 2:a3e5edf84f74 158 } else
okini3939 2:a3e5edf84f74 159 if (strcmp(buf, "USB") == 0) {
okini3939 2:a3e5edf84f74 160 conf.filetype = 2;
okini3939 2:a3e5edf84f74 161 }
okini3939 2:a3e5edf84f74 162 }
okini3939 2:a3e5edf84f74 163 if (cfg.getValue("CSV_MESG", conf.csv_mesg, sizeof_1(conf.csv_mesg))) {
okini3939 2:a3e5edf84f74 164 chop(conf.csv_mesg);
okini3939 2:a3e5edf84f74 165 }
okini3939 2:a3e5edf84f74 166
okini3939 2:a3e5edf84f74 167 if (cfg.getValue("IPADDRESS", buf, sizeof_1(buf))) {
okini3939 2:a3e5edf84f74 168 if (strncmp(buf, "DHCP", 4) == 0) {
okini3939 2:a3e5edf84f74 169 conf.ipaddr = IpAddr(255, 255, 255, 255);
okini3939 2:a3e5edf84f74 170 } else {
okini3939 2:a3e5edf84f74 171 sscanf(buf, "%d.%d.%d.%d", &ip0, &ip1, &ip2, &ip3);
okini3939 2:a3e5edf84f74 172 conf.ipaddr = IpAddr(ip0, ip1, ip2, ip3);
okini3939 2:a3e5edf84f74 173 }
okini3939 2:a3e5edf84f74 174 }
okini3939 2:a3e5edf84f74 175 if (cfg.getValue("NETMASK", buf, sizeof_1(buf))) {
okini3939 2:a3e5edf84f74 176 sscanf(buf, "%d.%d.%d.%d", &ip0, &ip1, &ip2, &ip3);
okini3939 2:a3e5edf84f74 177 conf.netmask = IpAddr(ip0, ip1, ip2, ip3);
okini3939 2:a3e5edf84f74 178 }
okini3939 2:a3e5edf84f74 179 if (cfg.getValue("GATEWAY", buf, sizeof_1(buf))) {
okini3939 2:a3e5edf84f74 180 sscanf(buf, "%d.%d.%d.%d", &ip0, &ip1, &ip2, &ip3);
okini3939 2:a3e5edf84f74 181 conf.gateway = IpAddr(ip0, ip1, ip2, ip3);
okini3939 2:a3e5edf84f74 182 }
okini3939 2:a3e5edf84f74 183 if (cfg.getValue("NAMESERVER", buf, sizeof_1(buf))) {
okini3939 2:a3e5edf84f74 184 sscanf(buf, "%d.%d.%d.%d", &ip0, &ip1, &ip2, &ip3);
okini3939 2:a3e5edf84f74 185 conf.nameserver = IpAddr(ip0, ip1, ip2, ip3);
okini3939 2:a3e5edf84f74 186 }
okini3939 2:a3e5edf84f74 187
okini3939 2:a3e5edf84f74 188 cfg.getValue("NTPSERVER", conf.ntpserver, sizeof_1(conf.ntpserver));
okini3939 2:a3e5edf84f74 189 chop(conf.ntpserver);
okini3939 2:a3e5edf84f74 190 cfg.getValue("SNMP_COMMNAME", conf.snmp_commname, sizeof_1(conf.snmp_commname));
okini3939 2:a3e5edf84f74 191 chop(conf.snmp_commname);
okini3939 2:a3e5edf84f74 192
okini3939 2:a3e5edf84f74 193 cfg.getValue("PACHUBE_APIKEY", conf.pachube_apikey, sizeof_1(conf.pachube_apikey));
okini3939 2:a3e5edf84f74 194 chop(conf.pachube_apikey);
okini3939 2:a3e5edf84f74 195 cfg.getValue("PACHUBE_FEEDID", conf.pachube_feedid, sizeof_1(conf.pachube_feedid));
okini3939 2:a3e5edf84f74 196 chop(conf.pachube_feedid);
okini3939 2:a3e5edf84f74 197 if (cfg.getValue("PACHUBE_MESG", conf.pachube_mesg, sizeof_1(conf.pachube_mesg))) {
okini3939 2:a3e5edf84f74 198 chop(conf.pachube_mesg);
okini3939 2:a3e5edf84f74 199 } else {
okini3939 2:a3e5edf84f74 200 strcpy(conf.pachube_mesg, PACHUBE_MESG);
okini3939 2:a3e5edf84f74 201 }
okini3939 2:a3e5edf84f74 202
okini3939 2:a3e5edf84f74 203 cfg.getValue("TWITTER_USER", conf.twitter_user, sizeof_1(conf.twitter_user));
okini3939 2:a3e5edf84f74 204 chop(conf.twitter_user);
okini3939 2:a3e5edf84f74 205 cfg.getValue("TWITTER_PWD", conf.twitter_pwd, sizeof_1(conf.twitter_pwd));
okini3939 2:a3e5edf84f74 206 chop(conf.twitter_pwd);
okini3939 2:a3e5edf84f74 207 cfg.getValue("TWITTER_MESG", conf.twitter_mesg[0], sizeof_1(conf.twitter_mesg[0]));
okini3939 2:a3e5edf84f74 208 chop(conf.twitter_mesg[0]);
okini3939 2:a3e5edf84f74 209 for (i = 0; i < CF_TWITTER_NUM; i ++) {
okini3939 2:a3e5edf84f74 210 sprintf(key, "TWITTER_MESG[%d]", i);
okini3939 2:a3e5edf84f74 211 cfg.getValue(key, conf.twitter_mesg[i], sizeof_1(conf.twitter_mesg[i]));
okini3939 2:a3e5edf84f74 212 chop(conf.twitter_mesg[i]);
okini3939 2:a3e5edf84f74 213 }
okini3939 2:a3e5edf84f74 214
okini3939 2:a3e5edf84f74 215 cfg.getValue("STATIONS_ID", conf.stations_id, sizeof_1(conf.stations_id));
okini3939 2:a3e5edf84f74 216 chop(conf.stations_id);
okini3939 2:a3e5edf84f74 217 cfg.getValue("STATIONS_PIN", conf.stations_pin, sizeof_1(conf.stations_pin));
okini3939 2:a3e5edf84f74 218 chop(conf.stations_pin);
okini3939 2:a3e5edf84f74 219
okini3939 2:a3e5edf84f74 220 if (cfg.getValue("LCD_TYPE", buf, sizeof_1(buf))) {
okini3939 2:a3e5edf84f74 221 conf.lcdtype = (enum I2CLCDType)atoi(buf);
okini3939 2:a3e5edf84f74 222 } else {
okini3939 2:a3e5edf84f74 223 conf.lcdtype = LCD16x2;
okini3939 2:a3e5edf84f74 224 }
okini3939 2:a3e5edf84f74 225 if (cfg.getValue("LCD_CONF", buf, sizeof_1(buf))) {
okini3939 2:a3e5edf84f74 226 conf.lcdconf = (enum I2CLCDConfig)atoi(buf);
okini3939 2:a3e5edf84f74 227 } else {
okini3939 2:a3e5edf84f74 228 conf.lcdconf = LCDCFG_3V;
okini3939 2:a3e5edf84f74 229 }
okini3939 2:a3e5edf84f74 230 if (cfg.getValue("LCD_MESG", conf.lcd_mesg, sizeof_1(conf.lcd_mesg))) {
okini3939 2:a3e5edf84f74 231 chop(conf.lcd_mesg);
okini3939 2:a3e5edf84f74 232 }
okini3939 2:a3e5edf84f74 233 if (cfg.getValue("LEDDISP_MESG", conf.leddisp_mesg, sizeof_1(conf.leddisp_mesg))) {
okini3939 2:a3e5edf84f74 234 chop(conf.leddisp_mesg);
okini3939 2:a3e5edf84f74 235 }
okini3939 2:a3e5edf84f74 236
okini3939 2:a3e5edf84f74 237 if (cfg.getValue("XBEE", buf, sizeof_1(buf))) {
okini3939 2:a3e5edf84f74 238 conf.xbeebaud = atoi(buf);
okini3939 2:a3e5edf84f74 239 }
okini3939 2:a3e5edf84f74 240
okini3939 2:a3e5edf84f74 241 if (cfg.getValue("INPUT", buf, sizeof(buf))) {
okini3939 2:a3e5edf84f74 242 conf.inputtype = (enum eINPUTTYPE)atoi(buf);
okini3939 2:a3e5edf84f74 243 }
okini3939 2:a3e5edf84f74 244
okini3939 2:a3e5edf84f74 245 if (cfg.getValue("OFFSET[P]", buf, sizeof_1(buf))) {
okini3939 2:a3e5edf84f74 246 offset.pres = atof(buf);
okini3939 2:a3e5edf84f74 247 }
okini3939 2:a3e5edf84f74 248 if (cfg.getValue("OFFSET[T]", buf, sizeof_1(buf))) {
okini3939 2:a3e5edf84f74 249 offset.temp = atof(buf);
okini3939 2:a3e5edf84f74 250 }
okini3939 2:a3e5edf84f74 251 if (cfg.getValue("OFFSET[H]", buf, sizeof_1(buf))) {
okini3939 2:a3e5edf84f74 252 offset.humi = atof(buf);
okini3939 2:a3e5edf84f74 253 }
okini3939 2:a3e5edf84f74 254
okini3939 2:a3e5edf84f74 255 #ifdef USE_EMAIL
okini3939 2:a3e5edf84f74 256 cfg.getValue("SMTPSERVER", conf.smtphost, sizeof_1(conf.smtphost));
okini3939 2:a3e5edf84f74 257 chop(conf.smtphost);
okini3939 2:a3e5edf84f74 258 if (cfg.getValue("SMTPPORT", buf, sizeof_1(buf))) {
okini3939 2:a3e5edf84f74 259 conf.smtpport = atoi(buf);
okini3939 2:a3e5edf84f74 260 } else {
okini3939 2:a3e5edf84f74 261 conf.smtpport = 25;
okini3939 2:a3e5edf84f74 262 }
okini3939 2:a3e5edf84f74 263 cfg.getValue("SMTPUSER", conf.smtpuser, sizeof_1(conf.smtpuser));
okini3939 2:a3e5edf84f74 264 chop(conf.smtpuser);
okini3939 2:a3e5edf84f74 265 cfg.getValue("SMTPPWD", conf.smtppwd, sizeof_1(conf.smtppwd));
okini3939 2:a3e5edf84f74 266 chop(conf.smtppwd);
okini3939 2:a3e5edf84f74 267 cfg.getValue("MAIL_FROM", conf.mailfrom, sizeof_1(conf.mailfrom));
okini3939 2:a3e5edf84f74 268 chop(conf.mailfrom);
okini3939 2:a3e5edf84f74 269 for (i = 0; i < CF_MAIL_NUM; i ++) {
okini3939 2:a3e5edf84f74 270 snprintf(key, sizeof_1(key), "MAIL_MESG[%d]", i);
okini3939 2:a3e5edf84f74 271 cfg.getValue(key, conf.mailmesg[i], sizeof_1(conf.mailmesg[i]));
okini3939 2:a3e5edf84f74 272 chop(conf.mailmesg[i]);
okini3939 2:a3e5edf84f74 273 snprintf(key, sizeof_1(key), "MAIL_TO[%d]", i);
okini3939 2:a3e5edf84f74 274 cfg.getValue(key, conf.mailto[i], sizeof_1(conf.mailto[i]));
okini3939 2:a3e5edf84f74 275 chop(conf.mailto[i]);
okini3939 2:a3e5edf84f74 276 }
okini3939 2:a3e5edf84f74 277 #endif
okini3939 2:a3e5edf84f74 278
okini3939 2:a3e5edf84f74 279 #ifdef DEBUG
okini3939 2:a3e5edf84f74 280 pc.printf("Configration: %d\r\n", cfg.getCount());
okini3939 2:a3e5edf84f74 281 #endif
okini3939 2:a3e5edf84f74 282 return 0;
okini3939 2:a3e5edf84f74 283 }