消息

handler/activity/lotteryDrawTask.go

@@ -181,6 +181,7 @@ func LotteryDrawTask(msg *model.Message) {
 		"update_date": time.Now().Format(date.Date_Full_Layout),
 		"create_date": time.Now().Format(date.Date_Full_Layout),
 	}
+	var tf bool
 	for i := 0; i < taskInfo.Qualification; i++ {
 		if id := db.Mysql.Insert(tableTaskUser, insertMap); id < 0 {
 			logger.Info(fmt.Sprintf("保存任务记录异常：%v", msgBody))
@@ -190,26 +191,29 @@ func LotteryDrawTask(msg *model.Message) {
 					taskInfo.ActivityName, msgBody.Phone, msgBody.PositionId, msgBody.TaskInfoId, taskInfo.Name)
 				util.SendMsgByWXURL(content, webhookURL)
 			}
+		} else {
+			tf = true
 		}
 	}
-	logger.Info("  sse  中奖信息通知：", msg)
-
-	var userName = msgBody.NickName
-	if msgBody.Phone != "" {
-		var PhoneReg = regexp.MustCompile(`^(100\d{8}|1[3-9]\d{9})$`)
-		if PhoneReg.MatchString(msgBody.Phone) {
-			phone := []rune(msgBody.Phone)
-			userName = string(phone[0:3]) + "****" + string(phone[(len(phone)-4):])
+	if tf {
+		logger.Info("  sse  中奖信息通知：", msg)
+		var userName = msgBody.NickName
+		if msgBody.Phone != "" {
+			var PhoneReg = regexp.MustCompile(`^(100\d{8}|1[3-9]\d{9})$`)
+			if PhoneReg.MatchString(msgBody.Phone) {
+				phone := []rune(msgBody.Phone)
+				userName = string(phone[0:3]) + "****" + string(phone[(len(phone)-4):])
+			}
 		}
+		util.SseBroadcast.SendToUsers(model.SseMessage{
+			Name:     taskInfo.Name,
+			User:     encrypt.SE.EncodeString(msgBody.UserId),
+			State:    model.TaskTarget,
+			Time:     time.Now().Format(date.Date_Full_Layout),
+			Remark:   fmt.Sprintf("%s 完成 %s 任务。", userName, taskInfo.Name),
+			ActiveId: encrypt.SE.EncodeString(strconv.FormatInt(msgBody.ActiveId, 10)),
+		})
 	}
-	util.SseBroadcast.SendToUsers(model.SseMessage{
-		Name:     taskInfo.Name,
-		User:     encrypt.SE.EncodeString(msgBody.UserId),
-		State:    model.TaskTarget,
-		Time:     time.Now().Format(date.Date_Full_Layout),
-		Remark:   fmt.Sprintf("%s 完成 %s 任务。", userName, taskInfo.Name),
-		ActiveId: encrypt.SE.EncodeString(strconv.FormatInt(msgBody.ActiveId, 10)),
-	})
 }
 
 type lotteryBody struct {