diff --git a/app/task.py b/app/task.py index 69d4791..0e3d8a5 100644 --- a/app/task.py +++ b/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) - - # 在开发计划中创建记录 diff --git a/app/utils/utils.py b/app/utils/utils.py index 818f69e..fada157 100644 --- a/app/utils/utils.py +++ b/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)