feat:更新

config/config.go

@@ -5,7 +5,6 @@ import (
 	qrpc "app.yhyue.com/moapp/message/model"
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/os/gcfg"
-	"time"
 )
 
 type config struct {
@@ -70,11 +69,11 @@ type pushConfig struct {
 }
 
 type OrderMonitorConfig struct {
-	StartTime  time.Time // 活动开始时间
-	EndTime    time.Time //  活动结束时间
-	Date111    string    // 第111名活动日期
-	OpenCron   string    // 每天开启订单查询的任务
-	SelectCron string    // 每5分钟查询一次
+	DateSpecial       string // 特别奖品活动日期
+	OpenCron          string // 每天开启订单查询的任务
+	SelectCron        string // 每5分钟查询一次
+	WinNumberDaily    int    // 每天第xx个付款获得奖品
+	WinNumbersSpecial int    // 第xxx个付款获得特殊奖品
 }
 
 //var Config *config

etc/config.yaml

@@ -73,8 +73,8 @@ jyactivity: # 临时活动
   name: 剑鱼超级会员节
   code: membershipDay
   dateRange: #活动时间
-    t1: 2022-10-01 00:00:00 #预热活动
-    t2: 2022-11-01 00:00:00 #活动开始
+    t1: 2022-05-25 00:00:00 #预热活动
+    t2: 2022-10-19 00:00:00 #活动开始
     ed: 2022-11-12 00:00:00 #活动结束
   missions: #任务列表
     buysubvip: #购买超级订阅
@@ -112,8 +112,8 @@ productCode:
 
 # 订单监控
 orderMonitor :
-  startTime: 2022-10-18 00:00:00  # 活动开始时间
-  endTime: 2022-11-14 00:00:00    # 活动结束时间
-  date111: 2022-10-18             # 第111名活动日期
+  dateSpecial: 2022-10-19         # 特殊奖品活动日期 (第111名活动日期)
   openCron: "0 0 6 * * *"         # 每天6点开启
-  selectCron: "0 */5 6-22 * * *"    # 查询订单的表达式  6点到22点 每五分钟查询一次
+  selectCron: "0 */5 6-22 * * *"    # 查询订单的表达式  6点到22点 每五分钟查询一次
+  winNumberDaily: 11       # 每天第xx个付款获得奖品
+  winNumbersSpecial: 111   # 第xxx个付款获得特殊奖品

task/ordermonitor.go

@@ -5,13 +5,13 @@ import (
 	"app.yhyue.com/moapp/jybase/go-logger/logger"
 	"app.yhyue.com/moapp/message/config"
 	"app.yhyue.com/moapp/message/db"
+	"app.yhyue.com/moapp/message/handler/activity"
 	"context"
 	"fmt"
 	"github.com/gogf/gf/v2/os/gcfg"
 	"github.com/gogf/gf/v2/os/gcron"
 	"github.com/gogf/gf/v2/os/gctx"
 	"github.com/gogf/gf/v2/os/gtime"
-	"log"
 	"time"
 )
 
@@ -31,18 +31,18 @@ var (
 func init() {
 	// 获取配置信息
 	monitorConfig = config.OrderMonitorConfig{
-		StartTime:  gtime.NewFromStrLayout(gcfg.Instance().MustGet(gctx.New(), "orderMonitor.startTime").String(), "2006-01-02T15:04:05Z").Time,
-		EndTime:    gtime.NewFromStrLayout(gcfg.Instance().MustGet(gctx.New(), "orderMonitor.endTime").String(), "2006-01-02T15:04:05Z").Time,
-		Date111:    gcfg.Instance().MustGet(gctx.New(), "orderMonitor.date111").String(),
-		OpenCron:   gcfg.Instance().MustGet(gctx.New(), "orderMonitor.openCron").String(),
-		SelectCron: gcfg.Instance().MustGet(gctx.New(), "orderMonitor.selectCron").String(),
+		DateSpecial:       date.FormatDate(&gtime.NewFromStrLayout(gcfg.Instance().MustGet(gctx.New(), "orderMonitor.dateSpecial").String(), "2006-01-02T15:04:05Z").Time, date.Date_Short_Layout),
+		OpenCron:          gcfg.Instance().MustGet(gctx.New(), "orderMonitor.openCron").String(),
+		SelectCron:        gcfg.Instance().MustGet(gctx.New(), "orderMonitor.selectCron").String(),
+		WinNumberDaily:    gcfg.Instance().MustGet(gctx.New(), "orderMonitor.winNumberDaily").Int(),
+		WinNumbersSpecial: gcfg.Instance().MustGet(gctx.New(), "orderMonitor.winNumbersSpecial").Int(),
 	}
 }
 
 // SelectOrderTask 订单监控
 func SelectOrderTask() {
 	// 活动已结束 不再启动定时任务
-	if time.Now().After(monitorConfig.EndTime) {
+	if time.Now().After(activity.MembershipDay.Ed) {
 		return
 	}
 	var (
@@ -52,46 +52,47 @@ func SelectOrderTask() {
 	// 订单查询任务
 	_, err = gcron.Add(ctx, monitorConfig.SelectCron, monitor, "selectJob")
 	if err != nil {
-		log.Println("定时任务selectJob添加失败", err)
+		logger.Error("定时任务selectJob添加失败", err)
 	}
 
-	if time.Now().Before(monitorConfig.StartTime) { // 活动未开始
+	if time.Now().Before(activity.MembershipDay.T2) { // 活动未开始
 		gcron.Stop("selectJob") // 停掉订单查询任务  等后边的定时任务开启
-		log.Println("任务1stop")
+		logger.Info("selectJob stop")
 	}
 	// 开启定时任务
 	_, err = gcron.Add(ctx, monitorConfig.OpenCron, func(ctx context.Context) {
 		now := time.Now()
-		if now.After(monitorConfig.EndTime) { // 活动已结束 移除掉任务
-			log.Println("活动结束，移除任务")
+		if now.After(activity.MembershipDay.Ed) { // 活动已结束 移除掉任务
+			logger.Info("活动结束，移除任务")
 			gcron.Remove("openCronJob")
 			gcron.Remove("selectJob")
 		}
 		// 活动时间范围内 开启订单查询的定时任务
-		if now.After(monitorConfig.StartTime) && now.Before(monitorConfig.EndTime) {
+		_, inTime, _ := activity.MembershipDay.InActivity()
+		if inTime {
 			flag11 = false // 重置
 			flag111 = false
-			log.Println("开启任务")
 			gcron.Start("selectJob")
+			logger.Info("开启 selectJob 任务")
 		}
 	}, "openCronJob")
 	if err != nil {
-		log.Println("定时任务openCronJob失败", err)
+		logger.Error("定时任务openCronJob失败", err)
 	}
-	log.Println("任务2启动成功")
+	logger.Info("openCronJob 启动成功")
 }
 
 //  订单监控
 func monitor(ctx context.Context) {
-	log.Println("查询")
-	now := time.Now()
-	if now.After(monitorConfig.StartTime) && now.Before(monitorConfig.EndTime) {
+	logger.Info("开始本轮订单查询")
+	_, inTime, _ := activity.MembershipDay.InActivity()
+	if inTime {
 		//  查订单表
 		// 查第11个
 		if !flag11 {
-			rs := selectOrder(11)
+			rs := selectOrder(monitorConfig.WinNumberDaily)
 			if rs != nil { // 查到了
-				logger.Info("查询到第11个人员")
+				logger.Info(fmt.Sprintf("查询到第%d个人员", monitorConfig.WinNumberDaily))
 				data := map[string]interface{}{
 					"phone":      rs["user_phone"],
 					"userid":     rs["user_id"],
@@ -101,18 +102,18 @@ func monitor(ctx context.Context) {
 				}
 				if saveWinnerInfo(data) {
 					flag11 = true
-					logger.Error("中奖信息保存成功:", data)
+					logger.Info("中奖信息保存成功:", data)
 				} else {
 					logger.Error("中奖信息保存失败:", data)
 				}
 			}
 		}
-		// 需要查第111个  日期范围内
-		log.Println(1222, date.NowFormat(date.Date_Short_Layout), monitorConfig.Date111, 333)
-		if date.NowFormat(date.Date_Short_Layout) == monitorConfig.Date111 {
-			rs111 := selectOrder(111)
+		// 需要查第111个  日期范围内  特殊日期
+		if date.NowFormat(date.Date_Short_Layout) == monitorConfig.DateSpecial {
+			logger.Info(fmt.Sprintf("开始查询第%v个人员", monitorConfig.WinNumbersSpecial))
+			rs111 := selectOrder(monitorConfig.WinNumbersSpecial)
 			if rs111 != nil {
-				logger.Info("查询到第111个人员")
+				logger.Info(fmt.Sprintf("查询到第%v个人员", monitorConfig.WinNumbersSpecial))
 				saveData := map[string]interface{}{
 					"phone":      rs111["user_phone"],
 					"userid":     rs111["user_id"],
@@ -127,23 +128,23 @@ func monitor(ctx context.Context) {
 				}
 			}
 		} else {
-			logger.Info("未到11日,不需要查第111名")
+			logger.Info(fmt.Sprintf("未到%s日,不需要查第%v名", monitorConfig.DateSpecial, monitorConfig.WinNumbersSpecial))
 			flag111 = true
 		}
 		if flag111 && flag11 {
-			logger.Info("已查询到 暂停任务")
+			logger.Info("今日已查询到 暂停任务")
 			gcron.Stop("selectJob")
+			logger.Info("selectJob stop")
 		}
 	}
 }
 
 // 查订单表
 func selectOrder(num int) map[string]interface{} {
-	sql := "SELECT user_phone,user_id,pay_time FROM `dataexport_order` a WHERE a.order_status = 1 and is_backstage_order=0 AND TO_DAYS(create_time) = to_days(now()) ORDER BY a.pay_time   limit ?;"
-	fmt.Println(sql)
-	rs := db.Mysql.SelectBySql(sql, num)
-	if rs != nil && len(*rs) == num {
-		return (*rs)[num-1]
+	sql := "SELECT user_phone,user_id,pay_time FROM `dataexport_order` WHERE product_type in ('VIP订阅','大会员','数据流量包') and pay_time !=null and order_status = 1 and is_backstage_order=0 AND TO_DAYS(create_time) = to_days(now()) ORDER BY pay_time   limit ?,1;"
+	rs := db.Mysql.SelectBySql(sql, num-1)
+	if rs != nil && len(*rs) == 1 {
+		return (*rs)[0]
 	}
 	logger.Info("未查到", rs)
 	return nil