adjust event data
continuous-integration/drone/push Build is passing

This commit is contained in:
jianxin committed 2024-04-10 14:18:15 +08:00
1 parent 4faa3f07ab
commit 27ff70ba57
2 files changed
+298 -85

No files matched your search

+292 -80
View File
@@ -4,8 +4,11 @@ import http
import requests
import lark_oapi as lark
import lark_oapi as lark
from lark_oapi.api.docx.v1 import *
import lark_oapi as lark
from lark_oapi.api.contact.v3 import *
from lark_oapi.api.wiki.v2 import *
def search_department(client):
@@ -69,11 +72,199 @@ def batch_send_message(token):
print(res)
if __name__ == "__main__":
def create_doc(client, space_id, parent_node_token, title):
# client = lark.Client.builder() \
# .app_id("YOUR_APP_ID") \
# .app_secret("YOUR_APP_SECRET") \
# .log_level(lark.LogLevel.DEBUG) \
# .build()
# 构造请求对象
request: CreateSpaceNodeRequest = (
CreateSpaceNodeRequest.builder()
.space_id(space_id)
.request_body(
Node.builder()
.obj_type("docx")
.parent_node_token(parent_node_token)
.node_type("origin")
.title(title)
.build()
)
.build()
)
# 发起请求
option = (
lark.RequestOption.builder()
.user_access_token("u-drqxH7LHd2AECUzpR7iaIyh42SzMh0Dxgww0lgA024O4")
.build()
)
response: CreateSpaceNodeResponse = client.wiki.v2.space_node.create(
request, option
)
# 处理失败返回
if not response.success():
lark.logger.error(
f"client.wiki.v2.space_node.create failed, code: {response.code}, msg: {response.msg}, log_id: {response.get_log_id()}"
)
return
# 处理业务结果
lark.logger.info(lark.JSON.marshal(response.data, indent=4))
def get_doc_block(client, document_id):
# 创建client
# 使用 user_access_token 需开启 token 配置, 并在 request_option 中配置 token
# 构造请求对象
request: ListDocumentBlockRequest = (
ListDocumentBlockRequest.builder()
.document_id(document_id)
.page_size(500)
.document_revision_id(-1)
.build()
)
# 发起请求
option = (
lark.RequestOption.builder()
.user_access_token("u-drqxH7LHd2AECUzpR7iaIyh42SzMh0Dxgww0lgA024O4")
.build()
)
response: ListDocumentBlockResponse = client.docx.v1.document_block.list(
request, option
)
# 处理失败返回
if not response.success():
lark.logger.error(
f"client.docx.v1.document_block.list failed, code: {response.code}, msg: {response.msg}, log_id: {response.get_log_id()}"
)
return
# 处理业务结果
lark.logger.info(lark.JSON.marshal(response.data, indent=4))
def create_doc_block(
client,
document_id,
block_id,
background="",
features="",
):
# 构造请求对象
request: CreateDocumentBlockChildrenRequest = (
CreateDocumentBlockChildrenRequest.builder()
.document_id(document_id)
.block_id(block_id)
.document_revision_id(-1)
.request_body(
CreateDocumentBlockChildrenRequestBody.builder()
.children(
[
Block.builder()
.block_type(4)
.heading2(
Text.builder()
.elements(
[
TextElement.builder()
.text_run(TextRun.builder().content("需求背景").build())
.build(),
]
)
.build()
)
.build(),
Block.builder()
.block_type(2)
.text(
Text.builder()
.style(TextStyle.builder().build())
.elements(
[
TextElement.builder()
.text_run(TextRun.builder().content(background).build())
.build(),
]
)
.build()
)
.build(),
Block.builder()
.block_type(4)
.heading2(
Text.builder()
.elements(
[
TextElement.builder()
.text_run(TextRun.builder().content("需求功能").build())
.build(),
]
)
.build()
)
.build(),
Block.builder()
.block_type(2)
.text(
Text.builder()
.style(TextStyle.builder().build())
.elements(
[
TextElement.builder()
.text_run(TextRun.builder().content(features).build())
.build(),
]
)
.build()
)
.build(),
]
)
.index(0)
.build()
)
.build()
)
# 发起请求
option = (
lark.RequestOption.builder()
.user_access_token("u-drqxH7LHd2AECUzpR7iaIyh42SzMh0Dxgww0lgA024O4")
.build()
)
response: CreateDocumentBlockChildrenResponse = (
client.docx.v1.document_block_children.create(request, option)
)
# 处理失败返回
if not response.success():
lark.logger.error(
f"client.docx.v1.document_block_children.create failed, code: {response.code}, msg: {response.msg}, log_id: {response.get_log_id()}"
)
return
# 处理业务结果
lark.logger.info(lark.JSON.marshal(response.data, indent=4))
if __name__ == "__main__":
app_id = os.environ["APP_ID"]
app_secret = os.environ["APP_SECRET"]
data = {
"title": '[{"type":"text","text":"测试"}]',
"background": '[{"type":"text","text":"测试"}]',
"features": '[{"type":"text","text":"测试"}]',
}
client = (
lark.Client.builder()
.app_id(app_id)
@@ -81,97 +272,118 @@ if __name__ == "__main__":
.log_level(lark.LogLevel.DEBUG)
.build()
)
# folder_token = "ADkFwlLhmiLcqAk3QXLcZnHAnHf"
title = "测试"
space_id = "7268552249415319554"
parent_node_token = "ADkFwlLhmiLcqAk3QXLcZnHAnHf"
# create_doc(client, space_id, parent_node_token, title)
doc_id = "N81ldXDuuoxtXZxUz55coxApnOh"
# get_doc_block(client, doc_id)
detail_url = (
"https://ying-dao.feishu.cn/wiki/EdHQwOhV9iLuh7kZTkwcX6OfnIe?from=from_copylink"
)
block_id = "N81ldXDuuoxtXZxUz55coxApnOh"
create_demand_url = (
"https://ying-dao.feishu.cn/share/base/form/shrcnEI7Hhnhfdh0OXTyQcwGzEb"
)
create_doc_block(client, doc_id, block_id)
app_list = [
"精选联盟批量邀约: 该在精选联盟设置筛选条件后并对达人批量邀约的功能",
"快手达人批量邀约: 在快手设置筛选条件后并对达人批量邀约的功能",
"视频号达人批量邀约: 在视频后台设置筛选条件并对达人批量邀约的功能",
]
pass
# client = (
# lark.Client.builder()
# .app_id(app_id)
# .app_secret(app_secret)
# .log_level(lark.LogLevel.DEBUG)
# .build()
# )
# detail_url = (
# "https://ying-dao.feishu.cn/wiki/EdHQwOhV9iLuh7kZTkwcX6OfnIe?from=from_copylink"
# )
# create_demand_url = (
# "https://ying-dao.feishu.cn/share/base/form/shrcnEI7Hhnhfdh0OXTyQcwGzEb"
# )
activity_list = [
"批量数据抓取(Java): Java单次表格数据抓取,Java多页连续表格数据抓取",
"网页扩展操作: 智能日期选择器,滚动元素至可视区域,隐藏元素,显示元素...",
"PostgreSQL 扩展: 执行sql语句,建立连接,添加数据记录,批量添加记录...",
"天猫字体解密扩展: 获取天猫价格解密字典, 解密天猫价格内容",
]
# app_list = [
# "企微群发消息: 在文件传输助手中根据群名单逐条转发信息",
# "TEMU商品复制上架: TEMU商品多店铺一键铺货",
# "Instagram关键词抓取红人信息: 根据条件抓取红人邮箱以及其他基本信息",
# "TikTok关键词抓取红人信息: 根据条件筛选符合条件的红人,获取红人信息",
# "查集装箱实际到港时间-6大航司: 根据船公司和提单号在对应的官网查询到港时间",
# "精选联盟批量邀约: 该在精选联盟设置筛选条件后并对达人批量邀约的功能",
# "快手达人批量邀约: 在快手设置筛选条件后并对达人批量邀约的功能",
# "视频号达人批量邀约: 在视频后台设置筛选条件并对达人批量邀约的功能",
# ]
# activity_list = [
# "云码验证码扩展: 通用轨迹验证, 通用单图滑块验证, 京东-旋转验证码",
# "Excel 扩展操作: 设置筛选器",
# "批量数据抓取(Java): Java单次表格数据抓取,Java多页连续表格数据抓取",
# "网页扩展操作: 智能日期选择器,滚动元素至可视区域,隐藏元素,显示元素...",
# "PostgreSQL 扩展: 执行sql语句,建立连接,添加数据记录,批量添加记录...",
# "天猫字体解密扩展: 获取天猫价格解密字典, 解密天猫价格内容",
# ]
# # app_list = [
# # "企微群发消息: 在文件传输助手中根据群名单逐条转发信息",
# # "TEMU商品复制上架: TEMU商品多店铺一键铺货",
# # "Instagram关键词抓取红人信息: 根据条件抓取红人邮箱以及其他基本信息",
# # "TikTok关键词抓取红人信息: 根据条件筛选符合条件的红人,获取红人信息",
# # "查集装箱实际到港时间-6大航司: 根据船公司和提单号在对应的官网查询到港时间",
# # ]
app_text = "\n".join(f"🔹{item}" for item in app_list).strip()
activity_text = "\n".join(f"🔸{item}" for item in activity_list).strip()
# # activity_list = [
# # "云码验证码扩展: 通用轨迹验证, 通用单图滑块验证, 京东-旋转验证码",
# # "Excel 扩展操作: 设置筛选器",
# # ]
# 解决方案实施中心 4gge82cgb18f52af
# 电商事业部 8a612b6c9184b118
# 技术支持部 d7g1374b1238d267
# 杭州内容组 9fg37g65b1b5b24e
# Uerid 7g3756f4
# "user_ids": [
# "7g3756f4",
# ],
pyload = {
"department_ids": ["4gge82cgb18f52af", "8a612b6c9184b118", "d7g1374b1238d267"],
"user_ids": [],
"msg_type": "interactive",
"card": {
"type": "template",
"data": {
"template_id": "ctp_AAikuuqPwN0o",
"template_variable": {
"app_text": app_text,
"activity_text": activity_text,
"detail_url": {
"pc_url": "",
"android_url": "",
"ios_url": "",
"url": detail_url,
},
"create_demand_url": {
"pc_url": "",
"android_url": "",
"ios_url": "",
"url": create_demand_url,
},
},
},
},
}
# app_text = "\n".join(f"🔹{item}" for item in app_list).strip()
# activity_text = "\n".join(f"🔸{item}" for item in activity_list).strip()
# 构造请求对象
request: lark.BaseRequest = (
lark.BaseRequest.builder()
.http_method(lark.HttpMethod.POST)
.uri("/open-apis/message/v4/batch_send/")
.token_types({lark.AccessTokenType.TENANT})
.body(pyload)
.build()
)
# # 解决方案实施中心 4gge82cgb18f52af
# # 电商事业部 8a612b6c9184b118
# # 技术支持部 d7g1374b1238d267
# # 杭州内容组 9fg37g65b1b5b24e
# # Uerid 7g3756f4
# # "user_ids": [
# # "7g3756f4",
# # ],
# pyload = {
# "department_ids": ["4gge82cgb18f52af", "8a612b6c9184b118", "d7g1374b1238d267"],
# "user_ids": [],
# "msg_type": "interactive",
# "card": {
# "type": "template",
# "data": {
# "template_id": "ctp_AAikuuqPwN0o",
# "template_variable": {
# "app_text": app_text,
# "activity_text": activity_text,
# "detail_url": {
# "pc_url": "",
# "android_url": "",
# "ios_url": "",
# "url": detail_url,
# },
# "create_demand_url": {
# "pc_url": "",
# "android_url": "",
# "ios_url": "",
# "url": create_demand_url,
# },
# },
# },
# },
# }
# 发起请求
response: lark.BaseResponse = client.request(request)
# # 构造请求对象
# request: lark.BaseRequest = (
# lark.BaseRequest.builder()
# .http_method(lark.HttpMethod.POST)
# .uri("/open-apis/message/v4/batch_send/")
# .token_types({lark.AccessTokenType.TENANT})
# .body(pyload)
# .build()
# )
# 处理失败返回
if not response.success():
lark.logger.error(
f"client.request failed, code: {response.code}, msg: {response.msg}, log_id: {response.get_log_id()}"
)
# # 发起请求
# response: lark.BaseResponse = client.request(request)
# 处理业务结果
lark.logger.info(str(response.raw.content, lark.UTF_8))
# # 处理失败返回
# if not response.success():
# lark.logger.error(
# f"client.request failed, code: {response.code}, msg: {response.msg}, log_id: {response.get_log_id()}"
# )
# # 处理业务结果
# lark.logger.info(str(response.raw.content, lark.UTF_8))