add creator-cs

app/task.py

@@ -50,13 +50,17 @@ def parse_history_message(data):
                 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")})
-
+                    message_images_data.append(
+                        {
+                            "message_id": message_id,
+                            "image_id": tmp_content_data_item.get("image_key"),
+                        }
+                    )
 
     print(message_content_data)
     print(message_images_data)
 
-    return message_content_data, message_images_data
+    return message_content_data, message_images_data, sender_id
 
 
 @shared_task(include_result=False)
@@ -133,7 +137,7 @@ def process_message_callback(
     history_message_data = get_messages(client, "thread", thread_id)
     lark.logger.info(f"history_message_data: {history_message_data}")
 
-    message_content_data, message_images_data = parse_history_message(
+    message_content_data, message_images_data, thread_sender_id = parse_history_message(
         history_message_data
     )
 
@@ -158,17 +162,20 @@ def process_message_callback(
         record["附件"] = [{"file_token": image} for image in images_token]
 
     record_id = add_record(client, bitable_token, table_id, record)
+
     lark.logger.debug(f"record_id: {record_id}")
-
     time.sleep(1)
 
-    # update_data = {"处理人": {"id": sender_id}}
-    # update_record(client, bitable_token, table_id, record_id, update_data)
-
     # 回复消息
     content = f'{{"text": "问题已经记录到多维表格, 及时更新工单状态💕"}}'
     send_group_message(client, message_id, content)
 
+    # 表格触发器会自动设置 "创建人-售后专用" 为创建者, 使用接口调整
+    time.sleep(2)
+
+    update_data = {"创建人-售后专用": [{"id": thread_sender_id}]}
+    update_record(client, bitable_token, table_id, record_id, update_data)
+
 
 @shared_task()
 def sync_xbot_activity_info():