jiagongcai

main.py

@@ -453,6 +453,10 @@ async def cankao():
 async def read_qufei(r: Info):
     return await db.getQufei(client, r.name)
 
+@app.post("/jiagongcai/")
+async def read_jiagongcai(r: Info):
+    return await db.getJiagongcai(client, r.name)
+
 @app.get("/dexilie/{value}/{id}")
 @cache(expire=86400)
 async def read_dexilie(value: int, id: str):

subdir/db.py

@@ -1368,6 +1368,16 @@ async def searchde(client, zhuanye, text):
             break
     return result
 
+async def getJiagongcai(client, id):
+    db = client["baojia"]
+    collection = db["Dwgc"]
+    result = []
+    async for post in collection.find({'biao_id': id}, {'rcjhz': 0}):
+       for entry in post['fbrgycl']:
+           result.append(entry)
+    return result
+
+