上傳檔案到 ''

main.py

@@ -153,17 +153,20 @@ async def record_tower(request: Request,data : models.record_tower_data,key:str)
     loc_dt = datetime.today() 
     loc_dt_format = loc_dt.strftime("%Y-%m-%d %H:%M:%S")
     db = dataset.connect('mysql://choozmo:pAssw0rd@db.ptt.cx:3306/Water_tower?charset=utf8mb4')
-    cmd ="SELECT * FROM device"
-    cmd2={}
-    check = False
+    # cmd ="SELECT * FROM device"
+    dict_tmp =  data.__dict__
+    # check = False
     # for row in db.query(cmd):
     #     if row['id']== tower_id:
     #         check = True 
-    if check :
+    # if check :
         
-        result={'msg':"success"}
-    else:
-        result = {'msg':"no device"}
+    #     result={'msg':"success"}
+    # else:
+    #     result = {'msg':"no device"}
+    dict_tmp['id']=pymysql.NULL
+    result = db['record_tower'].insert(dict(dict_tmp))
+    result={'msg':"success"}
     return json.dumps(result,ensure_ascii=False)
 
 @app.post('/record_dcs')
@@ -174,15 +177,18 @@ async def record_dcs(request: Request,data : models.record_tower_data,key:str):
     loc_dt = datetime.today() 
     loc_dt_format = loc_dt.strftime("%Y-%m-%d %H:%M:%S")
     db = dataset.connect('mysql://choozmo:pAssw0rd@db.ptt.cx:3306/Water_tower?charset=utf8mb4')
-    cmd ="SELECT * FROM device"
-    cmd2={}
-    check = False
+    dict_tmp =  data.__dict__
+    # cmd ="SELECT * FROM device"
+    # cmd2={}
+    # check = False
     
-    if check :
+    # if check :
         
-        result={'msg':"success"}
-    else:
-        result = {'msg':"no device"}
+    #     result={'msg':"success"}
+    # else:
+    #     result = {'msg':"no device"}
+    result = db['record_dcs'].insert(dict(dict_tmp))
+    result={'msg':"success"}
     return json.dumps(result,ensure_ascii=False)
 
 @app.post('/record_diagnosis')