Update README.md

增加烧录说明引用
Merge branch 'dev_file_ota'
2026-05-12 03:04:45 +08:00 · 2025-05-08 17:02:34 +08:00 · 2025-04-28 16:19:53 +08:00 · 2025-04-19 15:36:15 +08:00 · 2025-04-09 17:27:30 +08:00 · 2025-04-09 17:06:49 +08:00
8 changed files with 1416 additions and 1372 deletions
--- a/README.md
+++ b/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
--- a/TC1/ota_server/ota_server.h
+++ b/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
--- a/TC1/ota_server/user_ota.c
+++ b/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);
 }

--- a/mico-os/libraries/daemons/http_server/httpd_handle.c
+++ b/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,
--- a/mico-os/libraries/utilities/HTTPUtils.c
+++ b/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 ));
 }
-
--- a/mico-os/libraries/utilities/HTTPUtils.h
+++ b/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__
-
Author	SHA1	Message	Date
oopuuu	8496e8cfd6	Update README.md 增加烧录说明引用	2025-05-08 17:02:34 +08:00
nhkefus	ade64139cb	Merge branch 'dev_file_ota' # Conflicts: # TC1/http_server/app_httpd.c # TC1/http_server/web/index.html # TC1/mqtt_server/user_mqtt_client.c # TC1/ota_server/ota_server.c # mico-os/libraries/daemons/http_server/httpd.c	2025-04-28 16:19:53 +08:00
oopuuu	e352b74e19	Update README.md	2025-04-19 15:36:15 +08:00
nhkefus	55a5f93148	调试用	2025-04-09 17:27:30 +08:00
nhkefus	86b78d8a4e	调试用	2025-04-09 17:06:49 +08:00
nhkefus	d8099ad499	调试用	2025-04-09 16:59:16 +08:00
nhkefus	4aca161327	调试用	2025-04-09 15:11:52 +08:00
nhkefus	67aa42fdd9	调试用	2025-04-09 14:54:46 +08:00
Your Name	6e3a48cba6	修复自定义名称过长可能导致系统崩溃的问题	2025-04-08 23:00:40 +08:00
nhkefus	fea21ab02a	更新了一些新版SDK中 ota和http相关的代码，不知道有没有用	2025-04-08 13:29:35 +08:00
nhkefus	49847dc77c	尝试增加https下载ota文件的功能，增加后台直接上传ota bin文件来升级的功能	2025-04-03 16:05:55 +08:00