remove app action
continuous-integration/drone/push Build is passing

This commit is contained in:
jianxin committed 2024-01-17 19:43:06 +08:00
1 parent 6b91a97fa0
commit 14e1f91658
1 file changed
+39 -39
+39 -39
View File
@@ -41,55 +41,55 @@ if not os.path.exists(cache_dir):
def do_p2_im_message_receive_v1(data: P2ImMessageReceiveV1) -> None:
print(lark.JSON.marshal(data))
record = {}
images = []
images_token = []
message_content = ""
message_type = data.event.message.message_type
content = json.loads(data.event.message.content)
# record = {}
# images = []
# images_token = []
# message_content = ""
# message_type = data.event.message.message_type
# content = json.loads(data.event.message.content)
if message_type == "post":
content = content["content"]
for item in chain.from_iterable(content):
if item.get("tag") == "text":
message_content += item["text"]
# if message_type == "post":
# content = content["content"]
# for item in chain.from_iterable(content):
# if item.get("tag") == "text":
# message_content += item["text"]
if item.get("tag") == "img":
images.append(item["image_key"])
# if item.get("tag") == "img":
# images.append(item["image_key"])
if message_type == "text":
message_content = content["text"].replace("@_user_1", "").strip()
# if message_type == "text":
# message_content = content["text"].replace("@_user_1", "").strip()
sender_id = data.event.sender.sender_id.open_id
record["问题概述"] = message_content
record["创建人"] = sender_id
message_id = data.event.message.message_id
# sender_id = data.event.sender.sender_id.open_id
# record["问题概述"] = message_content
# record["创建人"] = sender_id
# message_id = data.event.message.message_id
# 对 image_key 处理并并上传至多维表格
# # 对 image_key 处理并并上传至多维表格
for image in images:
image_path = get_message_resource(client, message_id, image, "image", cache_dir)
print("下载文件成功:", image, image_path)
file_token = upload_media(client, image_path, "bitable_image", bitable_token)
print("上传文件成功:", file_token)
images_token.append(file_token)
# for image in images:
# image_path = get_message_resource(client, message_id, image, "image", cache_dir)
# print("下载文件成功:", image, image_path)
# file_token = upload_media(client, image_path, "bitable_image", bitable_token)
# print("上传文件成功:", file_token)
# images_token.append(file_token)
if images:
record["附件"] = [{"file_token": image} for image in images_token]
# if images:
# record["附件"] = [{"file_token": image} for image in images_token]
record_id = add_record(client, bitable_token, table_id, record)
# record_id = add_record(client, bitable_token, table_id, record)
time.sleep(1)
# time.sleep(1)
update_data = {"创建人": {"id": sender_id}}
update_record(client, bitable_token, table_id, record_id, update_data)
# update_data = {"创建人": {"id": sender_id}}
# update_record(client, bitable_token, table_id, record_id, update_data)
# content = {"text": "反馈的问题已经记录到多维表格, 稍后有小伙伴跟进"}
# send_message(receive_id, content)
# # content = {"text": "反馈的问题已经记录到多维表格, 稍后有小伙伴跟进"}
# # send_message(receive_id, content)
# 回复群组的消息
content = f'{{"text": "反馈的问题已经记录到多维表格, 稍后有小伙伴跟进"}}'
send_group_message(client, message_id, content)
# # 回复群组的消息
# content = f'{{"text": "反馈的问题已经记录到多维表格, 稍后有小伙伴跟进"}}'
# send_group_message(client, message_id, content)
def do_customized_event(data: lark.CustomizedEvent) -> None:
@@ -101,15 +101,15 @@ handler = (
encrypt_key, verification_token, lark.LogLevel.DEBUG
)
.register_p2_im_message_receive_v1(do_p2_im_message_receive_v1)
.register_p1_customized_event("message", do_customized_event)
.build()
)
# .register_p1_customized_event("message", do_customized_event)
@app.route("/event", methods=["POST"])
def event():
print("receive event: ", time.time())
resp = handler.do(parse_req())
print(resp)
return parse_resp(resp)