上傳檔案到 ''

main.py

@@ -204,7 +204,7 @@ async def record_dcs(request: Request,tower_id:str,data : models.record_dcs_data
     return json.dumps(result,ensure_ascii=False)
 
 @app.post('/record_diagnosis')
-async def record_dcs(request: Request,data : models.record_diagnosis_data,key:str):
+async def record_diagnosis(request: Request,data : models.record_diagnosis_data,key:str):
     #data = models.tower_data(**await request.form())
     if key!="21232f297a57a5a743894a0e4a801fc3":
         return {'msg':'no access'}
@@ -213,8 +213,72 @@ async def record_dcs(request: Request,data : models.record_diagnosis_data,key:st
     db = dataset.connect('mysql://choozmo:pAssw0rd@db.ptt.cx:3306/Water_tower?charset=utf8mb4')
     dict_tmp =  data.__dict__
     dict_tmp['createTime']=loc_dt_format
-    db['record_diagnosis'].update(dict(dict_tmp),['vibration_id'])
-    result={'msg':'success insert'}
+    result = db['record_diagnosis'].update(dict(dict_tmp),['vibration_id'])
+    #print(result)
+    if result :
+        result={'msg':'success insert'}
+    else :
+        result={'msg':'fail to insert'}
+    return json.dumps(result,ensure_ascii=False)
+
+@app.post('/record_health')
+async def record_health(request: Request,data : models.record_health_data,key:str):
+    #data = models.tower_data(**await request.form())
+    if key!="21232f297a57a5a743894a0e4a801fc3":
+        return {'msg':'no access'}
+    db = dataset.connect('mysql://choozmo:pAssw0rd@db.ptt.cx:3306/Water_tower?charset=utf8mb4')
+    dict_tmp =  data.__dict__
+    result = db['record_health'].insert(dict(dict_tmp))
+    #print(result)
+    if result :
+        result={'msg':'success insert'}
+    else :
+        result={'msg':'fail to insert'}
+    return json.dumps(result,ensure_ascii=False)
+
+@app.post('/record_performance')
+async def record_performance(request: Request,data : models.record_performance_data,key:str):
+    #data = models.tower_data(**await request.form())
+    if key!="21232f297a57a5a743894a0e4a801fc3":
+        return {'msg':'no access'}
+    db = dataset.connect('mysql://choozmo:pAssw0rd@db.ptt.cx:3306/Water_tower?charset=utf8mb4')
+    dict_tmp =  data.__dict__
+    result = db['record_performance'].insert(dict(dict_tmp))
+    #print(result)
+    if result :
+        result={'msg':'success insert'}
+    else :
+        result={'msg':'fail to insert'}
+    return json.dumps(result,ensure_ascii=False)
+
+@app.post('/record_prediction')
+async def record_prediction(request: Request,data : models.record_prediction_data,key:str):
+    #data = models.tower_data(**await request.form())
+    if key!="21232f297a57a5a743894a0e4a801fc3":
+        return {'msg':'no access'}
+    db = dataset.connect('mysql://choozmo:pAssw0rd@db.ptt.cx:3306/Water_tower?charset=utf8mb4')
+    dict_tmp =  data.__dict__
+    result = db['record_prediction'].insert(dict(dict_tmp))
+    #print(result)
+    if result :
+        result={'msg':'success insert'}
+    else :
+        result={'msg':'fail to insert'}
+    return json.dumps(result,ensure_ascii=False)
+
+@app.post('/record_prediction_upd')
+async def record_prediction(request: Request,data : models.record_prediction_upd_data,key:str):
+    #data = models.tower_data(**await request.form())
+    if key!="21232f297a57a5a743894a0e4a801fc3":
+        return {'msg':'no access'}
+    db = dataset.connect('mysql://choozmo:pAssw0rd@db.ptt.cx:3306/Water_tower?charset=utf8mb4')
+    dict_tmp =  data.__dict__
+    result = db['record_prediction_upd'].insert(dict(dict_tmp))
+    #print(result)
+    if result :
+        result={'msg':'success insert'}
+    else :
+        result={'msg':'fail to insert'}
     return json.dumps(result,ensure_ascii=False)
 
 @app.get('/add_tower')

models.py

@@ -4,6 +4,8 @@ import datetime
 
 from pymysql import NULL
 
+from main import vibration
+
 SECRET_KEY = "df2f77bd544240801a048bd4293afd8eeb7fff3cb7050e42c791db4b83ebadcd"
 ALGORITHM = "HS256"
 
@@ -144,4 +146,69 @@ class record_diagnosis_data(BaseModel):
     DW_Gwear:float
     DW_GBending:float
     DW_GEccentricity:float
-    vibration_id:float
+    vibration_id:float
+
+class record_health_data(BaseModel):
+    time_stamp:str
+    CV_index:float
+    Vrms:float
+    Grms:float
+    RPM:float 
+    PeakToPeak:float
+    MeanAbsolute:float
+    Skewness:float
+    Kurtosis:float
+    WaveformFactor:float
+    CrestFactor:float
+    ImpulseFactor:float
+    StandardDeviation:float
+    MeanValue:float
+    Maximum:float
+    Minimum:float
+    IQR:float
+    vibration_id:str
+
+class record_performance_data(BaseModel):
+    creatTime:str
+    deviceCode:str
+    designWFR:float
+    designHP:float
+    designCurrent:float
+    designHWT:float
+    designCWT:float
+    designWBT:float
+    testWFR:float
+    testBHP:float
+    testCurrent:float
+    testHWT:float
+    testCWT:float
+    testWBT:float
+    testWindSpeed:float
+    testMakeupWFR:float
+    testMakeupCWT:float
+    testCorrectCWT:float
+    testCoolingRange:float
+    resPredictRate:float
+    resPredictWFR:float
+    resCorrectedWFR:float
+    resPerformance:float
+    coolingRangeData:str
+    coolingRangeChart:str
+    waterFlowRateChart:str
+
+class record_prediction_data(BaseModel):
+    time_stamp:str
+    valueType:str
+    predictType:str
+    timeInternal:int
+    alarmValue:float
+    calCount:int
+    remainCount:int
+    remark:str
+    vibration_id:str
+
+class record_prediction_upd_data(BaseModel):
+    time_stamp:str
+    valueType:str
+    predictData:str
+    vibration_id:str