wip:订单监控中奖人员有新数据后清缓存

etc/config.yaml

@@ -114,7 +114,7 @@ productCode:
 orderMonitor:
   dateSpecial: 2022-10-19         # 特殊奖品活动日期 (第111名活动日期)
   openCron: "0 0 6 * * *"         # 每天6点开启
-  selectCron: "0 */5 * * * *"    # 查询订单的表达式  每五分钟查询一次
+  selectCron: "0 */5 7-23 * * *"    # 查询订单的表达式  每五分钟查询一次
   winNumberDaily: 11       # 每天第xx个付款获得奖品1
   winNumbersSpecial: 111   # 第xxx个付款获得特殊奖品
 

task/ordermonitor.go

@@ -4,6 +4,7 @@ import (
 	"app.yhyue.com/moapp/jybase/common"
 	"app.yhyue.com/moapp/jybase/date"
 	"app.yhyue.com/moapp/jybase/go-logger/logger"
+	"app.yhyue.com/moapp/jybase/redis"
 	"app.yhyue.com/moapp/message/config"
 	"app.yhyue.com/moapp/message/db"
 	"app.yhyue.com/moapp/message/handler/activity"
@@ -53,6 +54,9 @@ func init() {
 
 // SelectOrderTask 订单监控
 func SelectOrderTask() {
+	if !monitorConfig.Switch {
+		logger.Info("订单监控开关未打开，不再启动定时任务")
+	}
 	// 活动已结束 不再启动定时任务
 	if time.Now().After(activity.MembershipDay.Ed) {
 		logger.Info("活动时间已结束，不再启动定时任务")
@@ -314,6 +318,8 @@ WHERE order_status = 1 and create_time >=? and create_time<?` + productTypeStr +
 
 // 保存中奖人员信息
 func saveWinnerInfo(data map[string]interface{}) bool {
+	// 清缓存
+	redis.Del(activity.BidderPlanRedis, activity.WinnerInfoKey)
 	logger.Info("save winner info ")
 	return db.Mysql.Insert(TableWinnerInfo2210, data) > 0
 }