Kansai Electric Power usage meter (Denki-yohou)
Dependencies: mbed mbed-rtos EthernetInterface
関西電力 でんき予報メーター
関電のでんき予報のリアルタイム値(使用電力状況データ CSV )をもとに、mbedのLEDを点灯させます。
そのほかの情報はこちらへ: http://mbed.org/users/okini3939/notebook/denki-yohou/
Import programdenki-yohou_b
Kansai Electric Power usage meter (Denki-yohou)
- LED1 動作中表示
- LED2 70%以上
- LED3 85%以上
- LED4 95%以上
新しい Ethernet Interface ライブラリと、独自の Tiny HTTP クライアント ライブラリを使っています。
CSVの解析処理をはしょって改行を頼りにしているので、CSVファイルの構造が変わるとうまく動かなくなります。
東電でも同様に使えると思います。
TinyHTTP_b.cpp
- Committer:
- okini3939
- Date:
- 2012-07-02
- Revision:
- 1:10bd46941b8b
- Parent:
- 0:2a2f00cbc761
File content as of revision 1:10bd46941b8b:
/* * mbed Tiny HTTP Client for Ethernet Interface Library * Copyright (c) 2012 Hiroshi Suga * Released under the MIT License: http://mbed.org/license/mit */ /** @file * @brief Tiny HTTP Client */ #include "mbed.h" #include "EthernetInterface.h" #include "TinyHTTP_b.h" #include <ctype.h> //#define DEBUG static TCPSocket *http; static onHttpReceiveFunc onHttpReceive; // Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com) int base64enc(const char *input, unsigned int length, char *output, int len) { static const char base64[] = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/"; unsigned int c, c1, c2, c3; if (len < ((((length-1)/3)+1)<<2)) return -1; for(unsigned int i = 0, j = 0; i<length; i+=3,j+=4) { c1 = ((((unsigned char)*((unsigned char *)&input[i])))); c2 = (length>i+1)?((((unsigned char)*((unsigned char *)&input[i+1])))):0; c3 = (length>i+2)?((((unsigned char)*((unsigned char *)&input[i+2])))):0; c = ((c1 & 0xFC) >> 2); output[j+0] = base64[c]; c = ((c1 & 0x03) << 4) | ((c2 & 0xF0) >> 4); output[j+1] = base64[c]; c = ((c2 & 0x0F) << 2) | ((c3 & 0xC0) >> 6); output[j+2] = (length>i+1)?base64[c]:'='; c = (c3 & 0x3F); output[j+3] = (length>i+2)?base64[c]:'='; } output[(((length-1)/3)+1)<<2] = '\0'; return 0; } // Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com) int urlencode(char *str, char *buf, int len) { static const char to_hex[] = "0123456789ABCDEF"; // char *pstr = str, *buf = (char*)malloc(strlen(str) * 3 + 1), *pbuf = buf; char *pstr = str, *pbuf = buf; if (len < (strlen(str) * 3 + 1)) return -1; while (*pstr) { if (isalnum(*pstr) || *pstr == '-' || *pstr == '_' || *pstr == '.' || *pstr == '~') { *pbuf++ = *pstr; } else if (*pstr == ' ') { *pbuf++ = '+'; } else { *pbuf++ = '%'; *pbuf++ = to_hex[(*pstr >> 4) & 0x0f]; *pbuf++ = to_hex[*pstr & 0x0f]; } pstr++; } *pbuf = '\0'; return 0; } void createauth (char *user, char *pwd, char *buf, int len) { char tmp[80]; strncpy(buf, "Authorization: Basic ", len); snprintf(tmp, sizeof(tmp), "%s:%s", user, pwd); base64enc(tmp, strlen(tmp), &buf[strlen(buf)], len - strlen(buf)); strncat(buf, "\r\n", len - strlen(buf)); } int httpRequest (int method, char *host, int port, char *uri, char *head, char *body, onHttpReceiveFunc func) { char buf[1500]; int i, ret = -1; http = new TCPSocket; onHttpReceive = func; if (http->connect(host, port, HTTP_TIMEOUT)) goto exit; #ifdef DEBUG printf("connected\r\n"); #endif // send request if (method == METHOD_POST) { http->send("POST ", 5, HTTP_TIMEOUT); } else { http->send("GET ", 4, HTTP_TIMEOUT); } http->send(uri, strlen(uri), HTTP_TIMEOUT); http->send(" HTTP/1.1\r\nHost: ", 17, HTTP_TIMEOUT); http->send(host, strlen(host), HTTP_TIMEOUT); http->send("\r\n", 2, HTTP_TIMEOUT); http->send("Connection: close\r\n", 19, HTTP_TIMEOUT); if (head) { http->send(head, strlen(head), HTTP_TIMEOUT); } if (method == METHOD_POST) { sprintf(buf, "Content-Length: %d\r\n", strlen(body)); http->send(buf, strlen(buf), HTTP_TIMEOUT); } http->send("\r\n", 2, HTTP_TIMEOUT); // post method if (method == METHOD_POST && body) { http->send(body, strlen(body), HTTP_TIMEOUT); } #ifdef DEBUG printf("wait for response\r\n"); #endif // recv for (;;) { i = http->receive(buf, sizeof(buf) - 1, HTTP_TIMEOUT); if (i == 0) break; if (onHttpReceive != NULL) onHttpReceive(buf, i); #ifdef DEBUG printf(buf); #endif } ret = 0; exit: http->close(); delete http; return ret; }