fix: 注释掉测量数据插入逻辑

This commit is contained in:
TsMask
2025-04-11 11:06:01 +08:00
parent ad81d04db1
commit bfc87669a9

View File

@@ -1124,12 +1124,12 @@ func PostMeasurementFromNF(w http.ResponseWriter, r *http.Request) {
layout := time.RFC3339 layout := time.RFC3339
measurement.Date = GetDateFromTimeString(layout, measurement.StartTime) measurement.Date = GetDateFromTimeString(layout, measurement.StartTime)
measurement.StartTime = GetDateTimeFromTimeString(layout, measurement.StartTime) measurement.StartTime = GetDateTimeFromTimeString(layout, measurement.StartTime)
tx := db.DB("").Table("nbi_pm").Create(measurement) // tx := db.DB("").Table("nbi_pm").Create(measurement)
if tx.Error != nil && tx.RowsAffected <= 0 { // if tx.Error != nil && tx.RowsAffected <= 0 {
log.Error("Failed to insert nbi_pm:", err) // log.Error("Failed to insert nbi_pm:", err)
services.ResponseInternalServerError500DatabaseOperationFailed(w) // services.ResponseInternalServerError500DatabaseOperationFailed(w)
return // return
} // }
services.ResponseStatusOK204NoContent(w) services.ResponseStatusOK204NoContent(w)
} }
@@ -1204,12 +1204,12 @@ func GetMeasurementFromNF(w http.ResponseWriter, r *http.Request) {
layout := time.RFC3339 layout := time.RFC3339
measurement.Date = GetDateFromTimeString(layout, measurement.StartTime) measurement.Date = GetDateFromTimeString(layout, measurement.StartTime)
measurement.StartTime = GetDateTimeFromTimeString(layout, measurement.StartTime) measurement.StartTime = GetDateTimeFromTimeString(layout, measurement.StartTime)
tx := db.DB("").Table("nbi_pm").Create(measurement) // tx := db.DB("").Table("nbi_pm").Create(measurement)
if tx.Error != nil && tx.RowsAffected <= 0 { // if tx.Error != nil && tx.RowsAffected <= 0 {
log.Error("Failed to insert nbi_pm:", err) // log.Error("Failed to insert nbi_pm:", err)
services.ResponseInternalServerError500DatabaseOperationFailed(w) // services.ResponseInternalServerError500DatabaseOperationFailed(w)
return // return
} // }
default: default:
log.Debug("response body:", string(response.Body())) log.Debug("response body:", string(response.Body()))
body := new(map[string]interface{}) body := new(map[string]interface{})