diff --git a/db/copy_data.go b/db/copy_data.go index db6a316..78e892e 100644 --- a/db/copy_data.go +++ b/db/copy_data.go @@ -12,16 +12,18 @@ func copyOrders(db *gorm.DB, timeNow time.Time) { order := &data.Orders{} start := timeNow.Format("2006-01-02 15:04:05") first := db.Debug().Where("create_time < ?", timeNow.Format("2006-01-02 15:04:05")).Order("create_time asc").First(order) - - deleteTime := timeNow.Add(-1 * 24 * time.Hour).Format("2006-01-02 15:04:05") - if first.RowsAffected > 0 { - parse, err := time.Parse("2006-01-02T15:04:05Z07:00", order.CreateTime) - if err != nil { - fmt.Println("parse order create_time error:", err) - } - deleteTime = parse.Format("2006-01-02 15:04:05") - fmt.Println("copy orders from:", deleteTime) + if first.RowsAffected == 0 { + fmt.Println("no orders data") + return } + + parse, err := time.Parse("2006-01-02T15:04:05Z07:00", order.CreateTime) + if err != nil { + fmt.Println("parse order create_time error:", err) + } + deleteTime := parse.Format("2006-01-02 15:04:05") + fmt.Println("copy orders from:", deleteTime) + db.Debug().Where("create_time >= ?", deleteTime).Delete(&data.OrdersCopy1{}) _execOrders(db, timeNow.Format("2006-01-02 15:04:05"), 0) @@ -55,17 +57,18 @@ func copyPayDetails(db *gorm.DB, timeNow time.Time) { detail := &data.PayDetails{} start := timeNow.Format("2006-01-02 15:04:05") first := db.Model(detail).Where("create_time < ?", timeNow.Format("2006-01-02 15:04:05")).Order("create_time asc").First(detail) - - deleteTime := timeNow.Add(-1 * 24 * time.Hour).Format("2006-01-02 15:04:05") - if first.RowsAffected > 0 { - parse, err := time.Parse("2006-01-02T15:04:05Z07:00", detail.CreateTime) - if err != nil { - fmt.Println("parse pay_details create_time error:", err) - } - deleteTime = parse.Format("2006-01-02 15:04:05") - fmt.Println("copy pay_details from:", deleteTime) + if first.RowsAffected == 0 { + fmt.Println("no pay_details data") + return } + parse, err := time.Parse("2006-01-02T15:04:05Z07:00", detail.CreateTime) + if err != nil { + fmt.Println("parse pay_details create_time error:", err) + } + deleteTime := parse.Format("2006-01-02 15:04:05") + fmt.Println("copy pay_details from:", deleteTime) + db.Debug().Where("create_time >= ?", deleteTime).Delete(&data.PayDetailsCopy1{}) _execPayDetails(db, timeNow.Format("2006-01-02 15:04:05"), 0) @@ -99,17 +102,18 @@ func copyUserMoneyDetails(db *gorm.DB, timeNow time.Time) { detail := &data.UserMoneyDetails{} start := timeNow.Format("2006-01-02 15:04:05") first := db.Model(detail).Where("create_time < ?", timeNow.Format("2006-01-02 15:04:05")).Order("create_time asc").First(detail) - - deleteTime := timeNow.Add(-1 * 24 * time.Hour).Format("2006-01-02 15:04:05") - if first.RowsAffected > 0 { - parse, err := time.Parse("2006-01-02T15:04:05Z07:00", detail.CreateTime) - if err != nil { - fmt.Println("parse pay_details create_time error:", err) - } - deleteTime = parse.Format("2006-01-02 15:04:05") - fmt.Println("copy pay_details from:", deleteTime) + if first.RowsAffected == 0 { + fmt.Println("no user_money_details data") + return } + parse, err := time.Parse("2006-01-02T15:04:05Z07:00", detail.CreateTime) + if err != nil { + fmt.Println("parse pay_details create_time error:", err) + } + deleteTime := parse.Format("2006-01-02 15:04:05") + fmt.Println("copy pay_details from:", deleteTime) + db.Debug().Where("create_time >= ?", deleteTime).Delete(&data.UserMoneyDetailsCopy1{}) _execUserMoneyDetails(db, timeNow.Format("2006-01-02 15:04:05"), 0) diff --git a/video_data_copy_linux_amd64 b/video_data_copy_linux_amd64 index c6248bd..521ff16 100755 Binary files a/video_data_copy_linux_amd64 and b/video_data_copy_linux_amd64 differ