wip:订单监控调整

task/ordermonitor.go

@@ -23,8 +23,7 @@ const (
 )
 
 var (
-	flag11        = false // 是否需要查询第11个名单
-	flag111       = false // 是否需查询第111个名单
+	flag          = false // 是否已经查询到
 	monitorConfig config.OrderMonitorConfig
 )
 
@@ -70,8 +69,7 @@ func SelectOrderTask() {
 		// 活动时间范围内 开启订单查询的定时任务
 		_, inTime, _ := activity.MembershipDay.InActivity()
 		if inTime {
-			flag11 = false // 重置
-			flag111 = false
+			flag = false // 重置
 			gcron.Start("selectJob")
 			logger.Info("开启 selectJob 任务")
 		}
@@ -87,28 +85,7 @@ func monitor(ctx context.Context) {
 	logger.Info("开始本轮订单查询")
 	_, inTime, _ := activity.MembershipDay.InActivity()
 	if inTime {
-		//  查订单表
-		// 查第11个
-		if !flag11 {
-			rs := selectOrder(monitorConfig.WinNumberDaily)
-			if rs != nil { // 查到了
-				logger.Info(fmt.Sprintf("查询到第%d个人员", monitorConfig.WinNumberDaily))
-				data := map[string]interface{}{
-					"phone":      rs["user_phone"],
-					"userid":     rs["user_id"],
-					"winnerdate": rs["pay_time"],
-					"mold":       Mold1,
-					"createdate": date.NowFormat(date.Date_Full_Layout),
-				}
-				if saveWinnerInfo(data) {
-					flag11 = true
-					logger.Info("中奖信息保存成功:", data)
-				} else {
-					logger.Error("中奖信息保存失败:", data)
-				}
-			}
-		}
-		// 需要查第111个  日期范围内  特殊日期
+		// 如果需要查第111个  日期范围内  特殊日期
 		if date.NowFormat(date.Date_Short_Layout) == monitorConfig.DateSpecial {
 			logger.Info(fmt.Sprintf("开始查询第%v个人员", monitorConfig.WinNumbersSpecial))
 			rs111 := selectOrder(monitorConfig.WinNumbersSpecial)
@@ -122,16 +99,32 @@ func monitor(ctx context.Context) {
 					"createdate": date.NowFormat(date.Date_Full_Layout),
 				}
 				if saveWinnerInfo(saveData) {
-					flag111 = true
+					flag = true
+					logger.Info("中奖信息保存成功:", saveData)
 				} else {
 					logger.Error("中奖信息保存失败:", saveData)
 				}
 			}
 		} else {
-			logger.Info(fmt.Sprintf("未到%s日,不需要查第%v名", monitorConfig.DateSpecial, monitorConfig.WinNumbersSpecial))
-			flag111 = true
+			rs := selectOrder(monitorConfig.WinNumberDaily)
+			if rs != nil { // 查到了
+				logger.Info(fmt.Sprintf("查询到第%d个人员", monitorConfig.WinNumberDaily))
+				data := map[string]interface{}{
+					"phone":      rs["user_phone"],
+					"userid":     rs["user_id"],
+					"winnerdate": rs["pay_time"],
+					"mold":       Mold1,
+					"createdate": date.NowFormat(date.Date_Full_Layout),
+				}
+				if saveWinnerInfo(data) {
+					flag = true
+					logger.Info("中奖信息保存成功:", data)
+				} else {
+					logger.Error("中奖信息保存失败:", data)
+				}
+			}
 		}
-		if flag111 && flag11 {
+		if flag {
 			logger.Info("今日已查询到 暂停任务")
 			gcron.Stop("selectJob")
 			logger.Info("selectJob stop")