From: azao <821478748@qq.com>
Date: Sat, 11 Oct 2025 03:34:52 +0000 (+0800)
Subject: 修改K8IOT和DMP初始化框架，将连接放在init部分
X-Git-Url: http://git.snicker.com.cn/?a=commitdiff_plain;h=0960f9fbb1010aa2188dbd7194f80f602e68256c;p=mirrors%2FASR1603_G5.git

修改K8IOT和DMP初始化框架，将连接放在init部分
---

diff --git a/2.sdk/project/K8/sdk/services/microPython/ports/quectel/core/ai_VC.py b/2.sdk/project/K8/sdk/services/microPython/ports/quectel/core/ai_VC.py
index f1f59973..c782eae3 100644
--- a/2.sdk/project/K8/sdk/services/microPython/ports/quectel/core/ai_VC.py
+++ b/2.sdk/project/K8/sdk/services/microPython/ports/quectel/core/ai_VC.py
@@ -1379,7 +1379,10 @@ class AI_VC(Abstract):
         self.VC_taskid  = ""
         self.VC_server = 2 #0柒牌正式服务器，1：测试服务器1,2：测试服务器2
         
-
+        EventMesh.publish("connect_iot_socket")#连接IOT
+        print("IOT连接成功")
+        EventMesh.publish("login_IOT")#登录IOT
+        EventMesh.publish("send_unbind_dev_to_iot")#开启IOT心跳包
         self.server_ip = EventMesh.publish("get_storage_config","server_ip")#
         if self.server_ip == None:
             if self.VC_server == 1:# 
@@ -2033,6 +2036,7 @@ class AI_VC(Abstract):
         self.session_id = ""
 
         self.draw_result = 0#抽签结果
+        self.dmp_update()#dmp初始化推送
         EventMesh.subscribe("AI_key_press", self.AI_key_press)
         EventMesh.subscribe("AI_key_double_press", self.AI_key_double_press)
         EventMesh.subscribe("AI_key_release", self.AI_key_release)
diff --git a/2.sdk/project/K8/sdk/services/microPython/ports/quectel/core/main_init.py b/2.sdk/project/K8/sdk/services/microPython/ports/quectel/core/main_init.py
index dc4e50e7..4955079b 100644
--- a/2.sdk/project/K8/sdk/services/microPython/ports/quectel/core/main_init.py
+++ b/2.sdk/project/K8/sdk/services/microPython/ports/quectel/core/main_init.py
@@ -198,15 +198,8 @@ def main_init():
             usys.print_exception(e) 
             import protocol as pro
         try:
-            app.append_manager(pro.IOT_socket_SendCmdManager())
-            pcr = pro.ProtoColResolver()
-            pcr.add_support(pro.IOT_post_device_stateProtoCol())
-            pcr.add_support(pro.IOT_FindDeviceProtoCol())
-            # pcr.add_support(pro.IOTWeb_alarm_configProtoCol())
-            # pcr.add_support(pro.IOTWeb_alarm_listProtoCol())
-            sm = pro.SockMangager()
-
-            sm.add_support_resolver(pcr)
+            app.append_manager(pro.IOT_socket_SendCmdManager())#IOT发送信息的类
+            sm = pro.SockMangager()#负责socket连接iot部分的代码以及事件订阅
             app.append_manager(sm)
             print("init_IOT.0:{}".format(utime.localtime()))   
             
@@ -217,20 +210,7 @@ def main_init():
             app.append_manager(_ai.AI_VC())
         except Exception as e:
             usys.print_exception(e) 
-        try:
-            EventMesh.publish("dmp_update")#dmp推送
-        except Exception as e:
-            usys.print_exception(e) 
-        try:
-            EventMesh.publish("connect_iot_socket")#连接IOT
-            print("IOT连接成功")
-        except Exception as e:
-            usys.print_exception(e)       
-        try:
-            EventMesh.publish("login_IOT")#登录IOT
-            EventMesh.publish("send_unbind_dev_to_iot")#开启IOT心跳包
-        except Exception as e:
-            usys.print_exception(e)     
+
         
     except Exception as e:
         usys.print_exception(e)