From b7c5049e130206a788d9c8821263b7c2551a79aa Mon Sep 17 00:00:00 2001 From: GYJ <1157756119@qq.com> Date: Thu, 20 Mar 2025 10:58:00 +0800 Subject: [PATCH] =?UTF-8?q?copy=20=E5=AE=8C=E5=88=A0=E9=99=A4=E6=95=B0?= =?UTF-8?q?=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- db/copy_data.go | 6 ++++++ db/db_manager.go | 8 +++++--- go.mod | 13 ++++++++----- go.sum | 1 + 4 files changed, 20 insertions(+), 8 deletions(-) diff --git a/db/copy_data.go b/db/copy_data.go index 96f2a4f..ca8d433 100644 --- a/db/copy_data.go +++ b/db/copy_data.go @@ -21,6 +21,8 @@ func copyOrders(db *gorm.DB, timeNow time.Time) { db.Debug().Where("create_time >= ?", format).Delete(&data.OrdersCopy1{}) _execOrders(db, timeNow.Format("2006-01-02 15:04:05"), 0) + + db.Debug().Where("create_time < ?", format).Delete(&data.Orders{}) } func _execOrders(db *gorm.DB, timeNow string, index int) { @@ -58,6 +60,8 @@ func copyPayDetails(db *gorm.DB, timeNow time.Time) { db.Debug().Where("create_time >= ?", format).Delete(&data.PayDetailsCopy1{}) _execPayDetails(db, timeNow.Format("2006-01-02 15:04:05"), 0) + + db.Debug().Where("create_time < ?", format).Delete(&data.PayDetails{}) } func _execPayDetails(db *gorm.DB, timeNow string, index int) { @@ -95,6 +99,8 @@ func copyUserMoneyDetails(db *gorm.DB, timeNow time.Time) { db.Debug().Where("create_time >= ?", format).Delete(&data.UserMoneyDetailsCopy1{}) _execUserMoneyDetails(db, timeNow.Format("2006-01-02 15:04:05"), 0) + + db.Debug().Where("create_time < ?", format).Delete(&data.UserMoneyDetails{}) } func _execUserMoneyDetails(db *gorm.DB, timeNow string, index int) { diff --git a/db/db_manager.go b/db/db_manager.go index 3423360..6ca3814 100644 --- a/db/db_manager.go +++ b/db/db_manager.go @@ -25,11 +25,13 @@ func CopyData() { } timeNow := time.Now().Add(-30 * 24 * time.Hour) + format := timeNow.Format("2006-01-02") + parse, _ := time.Parse("2006-01-02", format) for _, db := range dbList { - copyOrders(db, timeNow) - copyPayDetails(db, timeNow) - copyUserMoneyDetails(db, timeNow) + copyOrders(db, parse) + copyPayDetails(db, parse) + copyUserMoneyDetails(db, parse) } } diff --git a/go.mod b/go.mod index 2162a2a..e097c0f 100644 --- a/go.mod +++ b/go.mod @@ -2,15 +2,18 @@ module video_data_copy go 1.23.4 +require ( + github.com/jinzhu/copier v0.4.0 + github.com/robfig/cron/v3 v3.0.1 + gopkg.in/yaml.v3 v3.0.1 + gorm.io/driver/mysql v1.5.7 + gorm.io/gorm v1.25.12 +) + require ( filippo.io/edwards25519 v1.1.0 // indirect github.com/go-sql-driver/mysql v1.9.0 // indirect - github.com/jinzhu/copier v0.4.0 // indirect github.com/jinzhu/inflection v1.0.0 // indirect github.com/jinzhu/now v1.1.5 // indirect - github.com/robfig/cron/v3 v3.0.1 // indirect golang.org/x/text v0.23.0 // indirect - gopkg.in/yaml.v3 v3.0.1 // indirect - gorm.io/driver/mysql v1.5.7 // indirect - gorm.io/gorm v1.25.12 // indirect ) diff --git a/go.sum b/go.sum index 8b3d97a..e9fdb82 100644 --- a/go.sum +++ b/go.sum @@ -13,6 +13,7 @@ github.com/robfig/cron/v3 v3.0.1 h1:WdRxkvbJztn8LMz/QEvLN5sBU+xKpSqwwUO1Pjr4qDs= github.com/robfig/cron/v3 v3.0.1/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro= golang.org/x/text v0.23.0 h1:D71I7dUrlY+VX0gQShAThNGHFxZ13dGLBHQLVl1mJlY= golang.org/x/text v0.23.0/go.mod h1:/BLNzu4aZCJ1+kcD0DNRotWKage4q2rGVAg4o22unh4= +gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=