wip:当日已存在中奖信息不再保存

task/ordermonitor.go

@@ -98,11 +98,16 @@ func monitor(ctx context.Context) {
 					"mold":       Mold2,
 					"createdate": date.NowFormat(date.Date_Full_Layout),
 				}
-				if saveWinnerInfo(saveData) {
+				if existWinnerInfo() {
+					logger.Info("当日已存在中奖信息")
 					flag = true
-					logger.Info("中奖信息保存成功:", saveData)
 				} else {
-					logger.Error("中奖信息保存失败:", saveData)
+					if saveWinnerInfo(saveData) {
+						flag = true
+						logger.Info("中奖信息保存成功:", saveData)
+					} else {
+						logger.Error("中奖信息保存失败:", saveData)
+					}
 				}
 			}
 		} else {
@@ -116,11 +121,16 @@ func monitor(ctx context.Context) {
 					"mold":       Mold1,
 					"createdate": date.NowFormat(date.Date_Full_Layout),
 				}
-				if saveWinnerInfo(data) {
+				if existWinnerInfo() {
+					logger.Info("当日已存在中奖信息")
 					flag = true
-					logger.Info("中奖信息保存成功:", data)
 				} else {
-					logger.Error("中奖信息保存失败:", data)
+					if saveWinnerInfo(data) {
+						flag = true
+						logger.Info("中奖信息保存成功:", data)
+					} else {
+						logger.Error("中奖信息保存失败:", data)
+					}
 				}
 			}
 		}
@@ -166,3 +176,7 @@ func saveWinnerInfo(data map[string]interface{}) bool {
 	logger.Info("save winner info ")
 	return db.Mysql.Insert(TableWinnerInfo2210, data) > 0
 }
+func existWinnerInfo() bool {
+	logger.Info("save winner info ")
+	return db.Mysql.CountBySql("SELECT count(id) as count FROM jianyu.winner_info_22_10 where TO_DAYS(createdate) = TO_DAYS(NOW());") > 0
+}