1 parent
6a697e897b
commit
9f6f32bede
1 file changed
+32
-1
+32
-1
@@ -7,6 +7,7 @@ from flask import Flask
|
|||||||
from dotenv import load_dotenv
|
from dotenv import load_dotenv
|
||||||
from lark_oapi.adapter.flask import *
|
from lark_oapi.adapter.flask import *
|
||||||
from lark_oapi.api.im.v1 import *
|
from lark_oapi.api.im.v1 import *
|
||||||
|
from lark_oapi.api.bitable.v1 import *
|
||||||
|
|
||||||
|
|
||||||
load_dotenv()
|
load_dotenv()
|
||||||
@@ -42,10 +43,40 @@ handler = (
|
|||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
|
def add_record(data):
|
||||||
|
# 构造请求对象
|
||||||
|
request: CreateAppTableRecordRequest = (
|
||||||
|
CreateAppTableRecordRequest.builder()
|
||||||
|
.app_token("JCZxwf3DJixwfqkPeroc8iubnah")
|
||||||
|
.table_id("tblwgGCDCE74Ugv6")
|
||||||
|
.request_body(AppTableRecord.builder().fields(data).build())
|
||||||
|
.build()
|
||||||
|
)
|
||||||
|
|
||||||
|
# 发起请求
|
||||||
|
response: CreateAppTableRecordResponse = client.bitable.v1.app_table_record.create(
|
||||||
|
request
|
||||||
|
)
|
||||||
|
|
||||||
|
# 处理失败返回
|
||||||
|
if not response.success():
|
||||||
|
lark.logger.error(
|
||||||
|
f"client.bitable.v1.app_table_record.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))
|
||||||
|
|
||||||
|
|
||||||
@app.route("/event", methods=["POST"])
|
@app.route("/event", methods=["POST"])
|
||||||
def event():
|
def event():
|
||||||
resp = handler.do(parse_req())
|
resp = handler.do(parse_req())
|
||||||
print(resp)
|
|
||||||
|
record = {}
|
||||||
|
record["创建人"] = record["event"]["message"]["content"]
|
||||||
|
record["问题概述"] = record["event"]["sender"]["sender_id"]["open_id"]
|
||||||
|
add_record(record)
|
||||||
return parse_resp(resp)
|
return parse_resp(resp)
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in new issue
Block a user