fix some bugs

app/task.py

@@ -31,32 +31,36 @@ def parse_history_message(data):
         if sender_id != sender_id_item:
             continue
 
-        item_content = json.loads(item.get("body").get("content"))
+        try:
+            item_content = json.loads(item.get("body").get("content"))
 
-        message_id = item.get("message_id")
+            message_id = item.get("message_id")
 
-        if item_content.get("text"):
-            message_content_data.append(item_content.get("text"))
+            if item_content.get("text"):
+                message_content_data.append(item_content.get("text"))
 
-        if item_content.get("content"):
-            message_content_content_data = item_content.get("content")
+            if item_content.get("content"):
+                message_content_content_data = item_content.get("content")
 
-            tmp_content_data = []
-            for message_content_content_item in message_content_content_data:
-                for message_content_content_item_item in message_content_content_item:
-                    tmp_content_data.append(message_content_content_item_item)
+                tmp_content_data = []
+                for message_content_content_item in message_content_content_data:
+                    for message_content_content_item_item in message_content_content_item:
+                        tmp_content_data.append(message_content_content_item_item)
 
-            for tmp_content_data_item in tmp_content_data:
-                print(tmp_content_data_item)
-                if tmp_content_data_item.get("tag") == "text":
-                    message_content_data.append(tmp_content_data_item.get("text"))
-                if tmp_content_data_item.get("tag") == "img":
-                    message_images_data.append(
-                        {
-                            "message_id": message_id,
-                            "image_id": tmp_content_data_item.get("image_key"),
-                        }
-                    )
+                for tmp_content_data_item in tmp_content_data:
+                    print(tmp_content_data_item)
+                    if tmp_content_data_item.get("tag") == "text":
+                        message_content_data.append(tmp_content_data_item.get("text"))
+                    if tmp_content_data_item.get("tag") == "img":
+                        message_images_data.append(
+                            {
+                                "message_id": message_id,
+                                "image_id": tmp_content_data_item.get("image_key"),
+                            }
+                        )
+        except Exception as e:
+            print(e)
+            continue
 
     print(message_content_data)
     print(message_images_data)
@@ -294,7 +298,11 @@ def process_new_robot(app_id, app_secret, action_data):
         robot_uuid = new_blank_activity(name, user_id)
         catagory_table_record["分类"] = "官方指令"
         catagory_table_record["UUID"] = robot_uuid
+        # 在开发计划中创建记录
 
+        table_id = "tblvjiV4HB31FMgb"
+        catagory_table_record = {"RobotUuid": robot_uuid}
+        add_record(client, bitable_token, table_id, catagory_table_record)
     else:
         # 其他选项不创建记录
         return
@@ -311,5 +319,3 @@ def process_new_robot(app_id, app_secret, action_data):
         .build()
     )
     add_record(client, bitable_token, table_id, catagory_table_record)
-
-    # 在开发计划中创建记录

app/utils/utils.py

@@ -285,7 +285,7 @@ def get_record_creator_name_by_id(client, bitable_token, table_id, record_id):
 
     # 处理业务结果
     creator_customer = response.data.record.fields["创建人-售后专用"]
-    if  not creator_customer:
+    if not creator_customer:
         return []
     return [item.get("name") for item in creator_customer]
 
@@ -312,3 +312,9 @@ if __name__ == "__main__":
         .log_level(lark.LogLevel.DEBUG)
         .build()
     )
+
+    table_id = "tblvjiV4HB31FMgb"
+
+    catagory_table_record = {"RobotUuid": "2d8182fb-ecf1-4931-991a-543312384b6b"}
+
+    add_record(client, bitable_token, table_id, catagory_table_record)