|
@@ -6,7 +6,7 @@ from fastapi.responses import HTMLResponse, RedirectResponse, JSONResponse
|
|
|
from fastapi.middleware.cors import CORSMiddleware
|
|
|
|
|
|
from fastapi.staticfiles import StaticFiles
|
|
|
-
|
|
|
+from pydantic import BaseModel
|
|
|
# fastapi view function parameters
|
|
|
from typing import List, Optional
|
|
|
import json
|
|
@@ -125,6 +125,36 @@ async def login_for_access_token(request: Request, form_data: OAuth2PasswordRequ
|
|
|
async def login(request: Request):
|
|
|
return templates.TemplateResponse(name='rigister_test.html', context={'request': request})
|
|
|
|
|
|
+class DataObjects(BaseModel):
|
|
|
+ CreateTime:str
|
|
|
+ DeviceCode: str
|
|
|
+ Key: str
|
|
|
+ Value: str
|
|
|
+
|
|
|
+class P_Multiple(BaseModel):
|
|
|
+ Token: str
|
|
|
+ DataObjects: List[DataObjects]
|
|
|
+# description: Optional[str] = None
|
|
|
+# price: float
|
|
|
+# tax: Optional[float] = None
|
|
|
+
|
|
|
+db2 = dataset.connect('mysql://choozmo:pAssw0rd@db.ptt.cx:3306/Water_tower?charset=utf8mb4')
|
|
|
+table_record_tower = db2['record_tower']
|
|
|
+
|
|
|
+@app.post('/addRecord_Parameter_Multiple')
|
|
|
+async def register(item: P_Multiple):
|
|
|
+ global table_record_tower
|
|
|
+# print(item.Token)
|
|
|
+# print(item.DataObjects)
|
|
|
+ for d in item.DataObjects:
|
|
|
+# print(d.Key)
|
|
|
+# print(d.Value)
|
|
|
+ table_record_tower.insert({'key':d.Key,'value':d.Value,'Createtime':d.CreateTime,'device_id':d.DeviceCode})
|
|
|
+
|
|
|
+# print(item)
|
|
|
+
|
|
|
+ return "OK"
|
|
|
+
|
|
|
|
|
|
@app.post('/register')
|
|
|
async def register(request: Request, form_data: OAuth2PasswordRequestForm = Depends()):
|