Update README.md

增加烧录说明引用

README.md

@@ -60,7 +60,9 @@ TC1 排插硬件分 A1 A2 两个版本, 本固件仅支持 **A1 版本**. A1 A2
 - [x] 后台可自定义设备名称，此名称将会同至ha mqtt作为mqtt中插座名称的前缀
 - [x] 后台可自定义按键连击，长按等功能
 - [x] 定时开关现在支持更多操作项，与按键功能自定义一样
-
+- [x] 现在可以上传本地文件来更新固件，同时可以在最新发布的固件说明中参考使用我搭建的文件服务来在线更新
+# 固件烧录
+- 参考原始固件代码提供者[a2633063](https://github.com/a2633063/zTC1/wiki/固件烧录)大佬提供的说明
 # 编译固件
 
 - windows环境，先安装python2.7,下载安装的时候添加环境变量到Path，默认安装路径需要添加两个环境变量C:\Python27；C:\Python27\Scripts

TC1/http_server/web/index.html

@@ -438,20 +438,6 @@
                         <th>循环</th>
                         <th>操作</th>
                     </tr>
-                    <tr>
-                        <td>02-15 07:11</td>
-                        <td>1</td>
-                        <td>0</td>
-                        <td>0</td>
-                        <td><a>删除</a></td>
-                    </tr>
-                    <tr>
-                        <td>2020-02-15<br>07:11:08</td>
-                        <td>1</td>
-                        <td>0</td>
-                        <td>6</td>
-                        <td><a>删除</a></td>
-                    </tr>
                 </table>
             </div>
 
@@ -610,23 +596,23 @@
                 <table class="mdl-data-table mdl-js-data-table">
                     <tr>
                         <th>版本</th>
-                        <th id="info_version">v1.0.33</th>
+                        <th id="info_version"></th>
                     </tr>
                     <tr>
                         <td>IP</td>
-                        <td id="info_ip">192.168.33.222</td>
+                        <td id="info_ip"></td>
                     </tr>
                     <tr>
                         <td>子网掩码</td>
-                        <td id="info_mask">255.255.255.0</td>
+                        <td id="info_mask"></td>
                     </tr>
                     <tr>
                         <td>网关</td>
-                        <td id="info_gateway">192.168.33.1</td>
+                        <td id="info_gateway"></td>
                     </tr>
                     <tr>
                         <td>启动时间</td>
-                        <td id="uptime">10:13:43</td>
+                        <td id="uptime"></td>
                     </tr>
                 </table>
                 <div class="mdl-card__actions mdl-card--border" style="display: flex; align-items: center; flex-wrap: wrap;">
@@ -638,7 +624,7 @@
                         </svg>
                     </i>
                     <!-- <span>2020-02-22</span> -->
-                    <a class="mdl-button" id="st-date">2020-02-22</a>
+                    <a class="mdl-button" id="st-date"></a>
                 </div>
             </div>
 

TC1/mqtt_server/user_mqtt_client.c

@@ -108,10 +108,23 @@ OSStatus UserMqttDeInit(void) {
     return err;
 }
 
+void clear_mqtt_msg_send_queue(void) {
+if(mqtt_msg_send_queue == NULL){
+return;
+}
+    void *msg = NULL;
+    while (mico_rtos_is_queue_empty(&mqtt_msg_send_queue) == false) {
+        if (mico_rtos_pop_from_queue(&mqtt_msg_send_queue, &msg, 0) == kNoErr) {
+            if (msg) free(msg);  // 释放消息内存，避免泄漏
+        }
+    }
+}
+
 /* Application entrance */
 OSStatus UserMqttInit(void) {
     OSStatus err = kNoErr;
-
+if(mqtt_msg_send_queue != NULL)
+    return err;
     sprintf(topic_set, MQTT_CLIENT_SUB_TOPIC1);
     sprintf(topic_state, MQTT_CLIENT_PUB_TOPIC, str_mac);
     //TODO size:0x800
@@ -146,13 +159,32 @@ OSStatus UserMqttInit(void) {
 static OSStatus UserMqttClientRelease(Client *c, Network *n) {
     OSStatus err = kNoErr;
 
-    if (c->isconnected) MQTTDisconnect(c);
+    if (c == NULL || n == NULL) return kParamErr;
 
-    n->disconnect(n);  // close connection
+    if (c->isconnected) {
+        MQTTDisconnect(c);
+        c->isconnected = 0;
+    }
 
-    if (MQTT_SUCCESS != MQTTClientDeinit(c)) { mqtt_log("MQTTClientDeinit failed!");
+    if (c->buf) {
+        free(c->buf);
+        c->buf = NULL;
+    }
+
+    if (c->readbuf) {
+        free(c->readbuf);
+        c->readbuf = NULL;
+    }
+
+    if (n->disconnect) {
+        n->disconnect(n);
+    }
+
+    if (MQTT_SUCCESS != MQTTClientDeinit(c)) {
+        mqtt_log("MQTTClientDeinit failed!");
         err = kDeletedErr;
     }
+
     return err;
 }
 
@@ -187,6 +219,9 @@ static OSStatus MqttMsgPublish(Client *c, const char *topic, char qos, char reta
 }
 
 void registerMqttEvents(void) {
+if(timer_status !=0){
+    mico_stop_timer(&timer_handle);
+    }
     timer_status = 0;
     mico_start_timer(&timer_handle);
 }
@@ -212,6 +247,8 @@ void MqttClientThread(mico_thread_arg_t arg) {
 
     /* create msg send queue event fd */
     msg_send_event_fd = mico_create_event_fd(mqtt_msg_send_queue);
+    mico_init_timer(&timer_handle, 150, UserMqttTimerFunc, &arg);
+
     require_action(msg_send_event_fd >= 0, exit,
                    mqtt_log("ERROR: create msg send queue event fd failed!!!"));
     mqtt_thread_should_exit = false;
@@ -238,7 +275,8 @@ void MqttClientThread(mico_thread_arg_t arg) {
         if (rc == MQTT_SUCCESS) break;
 
         //mqtt_log("ERROR: MQTT network connect err=%d, reconnect after 3s...", rc);
-    }mqtt_log("MQTT network connect success!");
+    }
+    mqtt_log("MQTT network connect success!");
 
     /* 2. init mqtt client */
     //c.heartbeat_retry_max = 2;
@@ -259,7 +297,7 @@ void MqttClientThread(mico_thread_arg_t arg) {
     rc = MQTTConnect(&c, &connectData);
     require_noerr_string(rc, MQTT_reconnect, "ERROR: MQTT client connect err.");
 
-    mqtt_log("MQTT client connect success!");
+    mqtt_log("MQTT client connect success, result: %d ", rc);
 
     UserLedSet(RelayOut() && user_config->power_led_enabled);
 
@@ -279,7 +317,6 @@ void MqttClientThread(mico_thread_arg_t arg) {
     UserMqttSendTotalSocketState();
     UserMqttSendChildLockState();
 
-    mico_init_timer(&timer_handle, 150, UserMqttTimerFunc, &arg);
     registerMqttEvents();
     /* 5. client loop for recv msg && keepalive */
     while (!mqtt_thread_should_exit) {
@@ -308,13 +345,12 @@ void MqttClientThread(mico_thread_arg_t arg) {
                 err = MqttMsgPublish(&c, p_send_msg->topic, p_send_msg->qos, p_send_msg->retained,
                                      (const unsigned char *) p_send_msg->data,
                                      p_send_msg->datalen);
-
+                free(p_send_msg);
+                p_send_msg = NULL;
                 require_noerr_string(err, MQTT_reconnect, "ERROR: MQTT publish data err");
 
                 //mqtt_log("MQTT publish data success! send_topic=[%s], msg=[%ld].", p_send_msg->topic, p_send_msg->datalen);
                 no_mqtt_msg_exchange = false;
-                free(p_send_msg);
-                p_send_msg = NULL;
             }
         }
 
@@ -330,7 +366,7 @@ void MqttClientThread(mico_thread_arg_t arg) {
 mqtt_log("Disconnect MQTT client, and reconnect after 5s, reason: mqtt_rc = %d, err = %d", rc, err);
 
     timer_status = 100;
-
+    clear_mqtt_msg_send_queue();
     UserMqttClientRelease(&c, &n);
     isconnect = false;
     UserLedSet(-1);
@@ -435,7 +471,9 @@ void ProcessHaCmd(char *cmd) {
         childLockEnabled = on;
         UserMqttSendChildLockState();
         mico_system_context_update(sys_config);
-    }else if (strcmp(cmd, "reboot") == 0) {
+    }else if (strcmp(cmd, "reboot") == ' ') {
+        sscanf(cmd, "reboot %s", mac);
+        if (strcmp(mac, str_mac)) return;
         MicoSystemReboot();  // 立即重启设备
     }
 }
@@ -590,13 +628,13 @@ void UserMqttHassAutoRebootButton(void) {
                 "\"uniq_id\":\"tc1_%s_reboot\","
                 "\"object_id\":\"tc1_%s_reboot\","
                 "\"cmd_t\":\"device/ztc1/set\","
-                "\"pl_prs\":\"reboot\","
+                "\"pl_prs\":\"reboot %s\","
                 "\"device\":{"
                 "\"identifiers\":[\"tc1_%s\"],"
                 "\"name\":\"%s\","
                 "\"model\":\"TC1\","
                 "\"manufacturer\":\"PHICOMM\"}}",
-                str_mac,str_mac,str_mac, sys_config->micoSystemConfig.name);
+                str_mac,str_mac,str_mac,str_mac, sys_config->micoSystemConfig.name);
         UserMqttSendTopic(topic_buf, send_buf, 1);
     }
     if (send_buf) free(send_buf);

TC1/ota_server/ota_server.h

@@ -32,7 +32,7 @@
 #define __ota_server_H
 
 #define OTA_DEBUG     (1)
-#define OTA_USE_HTTPS (0)
+#define OTA_USE_HTTPS (1)
 
 #define OTA_MD5_LENTH 32
 #define OTA_SEND_HEAD_SIZE 256
@@ -109,34 +109,34 @@ typedef struct _ota_server_context_t{
   * @return   kNoErr        : on success.
   * @return   kGeneralErr   : if an error occurred
   */
-OSStatus OtaServerStart(char *url, char *md5, ota_server_cb_fn call_back);
+OSStatus ota_server_start( char *url, char *md5, ota_server_cb_fn call_back );
 
 
 /** @brief    Get OTA server state
  *
  *  @return   OTA_CONTROL_E  : state
  */
-OTA_CONTROL_E OtaServerStateGet(void);
+OTA_CONTROL_E ota_server_state_get( void );
 
 
 /** @brief    Pause OTA server daemons
  *
  *  @return   No
  */
-void OtaServerPause(void);
+void ota_server_pause( void );
 
 
 /** @brief    Continue OTA server daemons
  *
  *  @return   No
  */
-void OtaServerContinue(void);
+void ota_server_continue( void );
 
 
 /** @brief    Stop OTA server daemons
  *
  *  @return   No
  */
-void OtaServerStop(void);
+void ota_server_stop( void );
 
 #endif

TC1/ota_server/user_ota.c

@@ -36,6 +36,6 @@ void UserOtaStart(char *url, char *md5)
 {
     ota_progress = 0;
     ota_log("ready to ota:%s",url);
-    OtaServerStart(url, md5, OtaServerStatusHandler);
+    ota_server_start(url, md5, OtaServerStatusHandler);
 }
 

mico-os/libraries/daemons/http_server/httpd_handle.c

@@ -135,12 +135,24 @@ int httpd_send_chunk(int conn, const char *buf, int len)
 int httpd_send(int conn, const char *buf, int len)
 {
     int num;
+    struct timeval t;
+    fd_set writefds;
+
+    t.tv_sec = 0;
+    t.tv_usec = 200*1000;
+
     do {
 #ifdef CONFIG_ENABLE_HTTPS
         if (httpd_is_https_active())
 			num = tls_send(httpd_tls_handle, buf, len);
 		else
 #endif /* ENABLE_HTTPS */
+        FD_ZERO( &writefds );
+        FD_SET( conn, &writefds );
+
+        select( conn + 1, NULL, &writefds, NULL, &t );
+        if( FD_ISSET( conn, &writefds) )
+        {
             num = send(conn, buf, len, 0);
             if (num < 0) {
                 httpd_d("send() failed: %d" ,conn);
@@ -148,6 +160,7 @@ int httpd_send(int conn, const char *buf, int len)
             }
             len -= num;
             buf += num;
+        }
     } while (len > 0);
 
 
@@ -156,12 +169,29 @@ int httpd_send(int conn, const char *buf, int len)
 
 int httpd_recv(int fd, void *buf, size_t n, int flags)
 {
+    int len = 0;
+    struct timeval t;
+    fd_set readfds;
+
+    FD_ZERO( &readfds );
+    FD_SET( fd, &readfds );
+
+    t.tv_sec = 0;
+    t.tv_usec = 200*1000;
+
 #ifdef CONFIG_ENABLE_HTTPS
     if (httpd_is_https_active())
 		return tls_recv(httpd_tls_handle, buf, n);
 	else
 #endif /* ENABLE_HTTPS */
     return recv(fd, buf, n, flags);
+    select( fd + 1, &readfds, NULL, NULL, &t );
+
+    if( FD_ISSET( fd, &readfds) )
+    {
+        len =  recv( fd, buf, n, flags );
+    }
+    return len;
 }
 
 int httpd_send_hdr_from_code(int sock, int stat_code,

mico-os/libraries/utilities/HTTPUtils.c

@@ -172,7 +172,8 @@ OSStatus SocketReadHTTPBody( int inSock, HTTPHeader_t *inHeader )
 
                     if( readResult  > 0 ) inHeader->extraDataLen += readResult;
                     else { err = kConnectionErr; goto exit; }
-          (inHeader->onReceivedDataCallback)(inHeader, inHeader->extraDataLen - readResult, (uint8_t *)inHeader->extraDataPtr, readResult, inHeader->userContext);
+                    err = (inHeader->onReceivedDataCallback)(inHeader, inHeader->extraDataLen - readResult, (uint8_t *)inHeader->extraDataPtr, readResult, inHeader->userContext);
+                    if( err != kNoErr ) goto exit;
                 }
 
                 err = kNoErr;
@@ -185,10 +186,11 @@ OSStatus SocketReadHTTPBody( int inSock, HTTPHeader_t *inHeader )
                                     *(inHeader->extraDataPtr + inHeader->contentLength + 1 ) == '\n',
                                     exit, err = kMalformedErr);
 
-          (inHeader->onReceivedDataCallback)(inHeader,  pos, 
+                    err = (inHeader->onReceivedDataCallback)(inHeader,  pos,
                                                              (uint8_t *)inHeader->extraDataPtr,
                             inHeader->contentLength,
                             inHeader->userContext);
+                    if( err != kNoErr ) goto exit;
                     pos+=inHeader->contentLength;
 
                     /* Move next chunk to chunked data buffer header point */
@@ -204,10 +206,11 @@ OSStatus SocketReadHTTPBody( int inSock, HTTPHeader_t *inHeader )
                     require_action( *(inHeader->chunkedDataBufferPtr + inHeader->extraDataLen - 1) == '\r' ,
                                     exit, err = kMalformedErr);
 
-          (inHeader->onReceivedDataCallback)(inHeader,  pos, 
+                    err = (inHeader->onReceivedDataCallback)(inHeader,  pos,
                                                              (uint8_t *)inHeader->extraDataPtr,
                             inHeader->extraDataLen - chunckheaderLen-1,
                             inHeader->userContext);
+                    if( err != kNoErr ) goto exit;
                     pos+=inHeader->extraDataLen - chunckheaderLen-1;
                     selectResult = select( inSock + 1, &readSet, NULL, NULL, NULL );
                     require_action( selectResult >= 1, exit, err = kNotReadableErr );
@@ -222,10 +225,11 @@ OSStatus SocketReadHTTPBody( int inSock, HTTPHeader_t *inHeader )
                 }
                 else{
                     /* Callback , read , callback , read CRLF */
-          (inHeader->onReceivedDataCallback)(inHeader, pos, 
+                    err = (inHeader->onReceivedDataCallback)(inHeader, pos,
                                                              (uint8_t *)inHeader->extraDataPtr,
                             inHeader->extraDataLen - chunckheaderLen,
                             inHeader->userContext);
+                    if( err != kNoErr ) goto exit;
                     pos += inHeader->extraDataLen - chunckheaderLen;
 
                     while ( inHeader->extraDataLen < inHeader->contentLength + chunckheaderLen  ){
@@ -244,10 +248,11 @@ OSStatus SocketReadHTTPBody( int inSock, HTTPHeader_t *inHeader )
                         if( readResult  > 0 ) inHeader->extraDataLen += readResult;
                         else { err = kConnectionErr; goto exit; }
 
-            (inHeader->onReceivedDataCallback)(inHeader, pos, 
+                        err = (inHeader->onReceivedDataCallback)(inHeader, pos,
                                                                  (uint8_t *)inHeader->extraDataPtr,
                                 readResult,
                                 inHeader->userContext);
+                        if( err != kNoErr ) goto exit;
                         pos += readResult;
                     }
 
@@ -373,7 +378,8 @@ OSStatus SocketReadHTTPSBody( mico_ssl_t ssl, HTTPHeader_t *inHeader )
 
                     if( readResult  > 0 ) inHeader->extraDataLen += readResult;
                     else { err = kConnectionErr; goto exit; }
-          (inHeader->onReceivedDataCallback)(inHeader, inHeader->extraDataLen - readResult, (uint8_t *)inHeader->extraDataPtr, readResult, inHeader->userContext);
+                    err = (inHeader->onReceivedDataCallback)(inHeader, inHeader->extraDataLen - readResult, (uint8_t *)inHeader->extraDataPtr, readResult, inHeader->userContext);
+                    if( err != kNoErr ) goto exit;
                 }
 
                 err = kNoErr;
@@ -386,10 +392,11 @@ OSStatus SocketReadHTTPSBody( mico_ssl_t ssl, HTTPHeader_t *inHeader )
                                     *(inHeader->extraDataPtr + inHeader->contentLength + 1 ) == '\n',
                                     exit, err = kMalformedErr);
 
-          (inHeader->onReceivedDataCallback)(inHeader,  pos, 
+                    err = (inHeader->onReceivedDataCallback)(inHeader,  pos,
                                                              (uint8_t *)inHeader->extraDataPtr,
                             inHeader->contentLength,
                             inHeader->userContext);
+                    if( err != kNoErr ) goto exit;
                     pos+=inHeader->contentLength;
 
                     /* Move next chunk to chunked data buffer header point */
@@ -405,10 +412,11 @@ OSStatus SocketReadHTTPSBody( mico_ssl_t ssl, HTTPHeader_t *inHeader )
                     require_action( *(inHeader->chunkedDataBufferPtr + inHeader->extraDataLen - 1) == '\r' ,
                                     exit, err = kMalformedErr);
 
-          (inHeader->onReceivedDataCallback)(inHeader,  pos, 
+                    err = (inHeader->onReceivedDataCallback)(inHeader,  pos,
                                                              (uint8_t *)inHeader->extraDataPtr,
                             inHeader->extraDataLen - chunckheaderLen-1,
                             inHeader->userContext);
+                    if( err != kNoErr ) goto exit;
                     pos+=inHeader->extraDataLen - chunckheaderLen-1;
                     selectResult = select( inSock + 1, &readSet, NULL, NULL, NULL );
                     require_action( selectResult >= 1, exit, err = kNotReadableErr );
@@ -423,10 +431,11 @@ OSStatus SocketReadHTTPSBody( mico_ssl_t ssl, HTTPHeader_t *inHeader )
                 }
                 else{
                     /* Callback , read , callback , read CRLF */
-          (inHeader->onReceivedDataCallback)(inHeader, pos, 
+                    err = (inHeader->onReceivedDataCallback)(inHeader, pos,
                                                              (uint8_t *)inHeader->extraDataPtr,
                             inHeader->extraDataLen - chunckheaderLen,
                             inHeader->userContext);
+                    if( err != kNoErr ) goto exit;
                     pos += inHeader->extraDataLen - chunckheaderLen;
 
                     while ( inHeader->extraDataLen < inHeader->contentLength + chunckheaderLen  ){
@@ -445,10 +454,11 @@ OSStatus SocketReadHTTPSBody( mico_ssl_t ssl, HTTPHeader_t *inHeader )
                         if( readResult  > 0 ) inHeader->extraDataLen += readResult;
                         else { err = kConnectionErr; goto exit; }
 
-            (inHeader->onReceivedDataCallback)(inHeader, pos, 
+                        err = (inHeader->onReceivedDataCallback)(inHeader, pos,
                                                                  (uint8_t *)inHeader->extraDataPtr,
                                 readResult,
                                 inHeader->userContext);
+                        if( err != kNoErr ) goto exit;
                         pos += readResult;
                     }
 
@@ -492,8 +502,10 @@ OSStatus SocketReadHTTPSBody( mico_ssl_t ssl, HTTPHeader_t *inHeader )
 
     while ( inHeader->extraDataLen < inHeader->contentLength )
     {
+        if ( !ssl_pending(ssl) ) {
             selectResult = select( inSock + 1, &readSet, NULL, NULL, (struct timeval *)&t );
             require_action( selectResult >= 1, exit, err = kNotReadableErr );
+        }
 
         if(inHeader->isCallbackSupported == true){
             /* We has extra data, and we give these data to application by onReceivedDataCallback function */
@@ -1264,4 +1276,3 @@ void PrintHTTPHeader( HTTPHeader_t *inHeader )
     http_utils_log("Content length: %ld", (uint32_t)(inHeader->contentLength));
     http_utils_log("Persistent: %s", YesOrNo( inHeader->persistent ));
 }
-

mico-os/libraries/utilities/HTTPUtils.h

@@ -40,6 +40,8 @@
 #include "URLUtils.h"
 #include "stdbool.h"
 
+#define Boolean bool
+
 #define kHTTPPostMethod     "POST"
 
 // Status-Code    =
@@ -202,4 +204,3 @@ OSStatus CreateHTTPMessageWithHost( const char *methold, const char *url,
                                     uint8_t **outMessage, size_t *outMessageSize );
 
 #endif // __HTTPUtils_h__
-