1

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

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
+}