czg_team
/
data_copy
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

copy 完删除数据

This commit is contained in:
GYJ 2025-03-20 10:58:00 +08:00
parent f85fff80be
commit b7c5049e13
4 changed files with 20 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
db/copy_data.go
View File

@ -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) {

8
db/db_manager.go
View File

@ -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)
}
}

13
go.mod
View File

@ -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
)

1
go.sum
View File

@ -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=