diff --git a/business/jxstore/misc/misc.go b/business/jxstore/misc/misc.go index e48a7c47a..01478ebe0 100644 --- a/business/jxstore/misc/misc.go +++ b/business/jxstore/misc/misc.go @@ -2,6 +2,7 @@ package misc import ( "git.rosy.net.cn/jx-callback/business/jxstore/partner/pdd" + "git.rosy.net.cn/jx-callback/business/model/dao" bidaServer "git.rosy.net.cn/jx-callback/business/q_bida" "time" @@ -22,6 +23,9 @@ var ( stationTimeList = []string{ "11:35:00", } + startDeleteTime = []string{ + "04:00:00", + } ) func Init() { @@ -39,6 +43,11 @@ func Init() { cms.InitStation(jxcontext.AdminCtx) }, stationTimeList) + // 定时删除打印信息 + ScheduleTimerFunc("DeleteTimeOutPrintMsg", func() { + dao.DeletePrintMsg() + }, stationTimeList) + // 每两小时更新一下订单信息UpdateOrderStatus ScheduleTimerFuncByInterval(func() { bidaServer.UpdateOrderStatus() diff --git a/business/model/dao/dao_print.go b/business/model/dao/dao_print.go index 386685044..67f00afc4 100644 --- a/business/model/dao/dao_print.go +++ b/business/model/dao/dao_print.go @@ -1,8 +1,10 @@ package dao import ( + "gim-master/pkg/db" "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/business/model" + "git.rosy.net.cn/jx-callback/globals" "time" ) @@ -83,3 +85,14 @@ func GetPrinter(db *DaoDB, printNo string) (print *model.Printer, err error) { err = GetRow(db, &print, sql, sqlParams) return print, err } + +// DeletePrintMsg 删除超过一个月时间的打印订单信息 +func DeletePrintMsg() { + sql := ` DELETE FROM print_msg WHERE created_at < ?` + num, err := ExecuteSQL(db.DB, sql, []interface{}{time.Now().AddDate(0, -1, 0)}...) + if err != nil { + globals.SugarLogger.Debugf("定时删除超过一个月的打印信息错误:%v", err) + } + globals.SugarLogger.Debugf("定时删除超过一个月的打印信息:%d 条", num) + return +}