async record request

This commit is contained in:
2024-01-04 18:37:01 +08:00
parent fc5a8d55fa
commit 97926087bb

View File

@@ -147,9 +147,14 @@ func main() {
log.Println("Record result:", record.Status, record.Response) log.Println("Record result:", record.Status, record.Response)
record.ElapsedTime = time.Now().Sub(record.CreatedAt) record.ElapsedTime = time.Now().Sub(record.CreatedAt)
// async record request
go func() {
if db.Create(&record).Error != nil { if db.Create(&record).Error != nil {
log.Println("Error to save record:", record) log.Println("Error to save record:", record)
} }
}()
if record.Status != 200 { if record.Status != 200 {
errMessage := fmt.Sprintf("IP: %s request %s error %d with %s", record.IP, record.Model, record.Status, record.Response) errMessage := fmt.Sprintf("IP: %s request %s error %d with %s", record.IP, record.Model, record.Status, record.Response)
go sendFeishuMessage(errMessage) go sendFeishuMessage(errMessage)