添加校验

weixin/src/qfw/weixin/dao/logsdao.go

@@ -45,3 +45,9 @@ func SavePayBonusLogs(openid, billno, actname string, amount int) bool {
 		return false
 	}
 }
+
+//查找指定活动的中奖记录
+func FindWinningRecord(openid, activitycode string) bool {
+	ret := mongodb.FindOne("winningrecord", M{"s_openid": openid, "s_actcode": activitycode})
+	return ret != nil && len(*ret) > 0
+}

weixin/src/qfw/weixin/msgtxtchandler.go

@@ -63,9 +63,14 @@ func MsgTxtHandler(w ResponseWriter, r *Request) {
 		w.ReplyText("嗨，小星来陪你解闷。有什么开心的，不开心的说说来，大伙乐呵乐呵。\n输入q或Q离开。")
 		return
 	} else if r.Content == "抽奖" { //进入抽奖环节
-		targeturl := fmt.Sprintf("http://%s/activity/%s/%s", wf.SysConfig.Domain, wf.SysConfig.Activity["activitycode"], se.EncodeString(r.FromUserName))
-		log.Println("choujiang url:", targeturl)
-		w.ReplyNews([]Article{Article{PicUrl: wf.SysConfig.Activity["picurl"], Title: wf.SysConfig.Activity["title"], Url: targeturl}})
+		//查改用户是否已经抽过奖
+		if dao.FindWinningRecord(r.FromUserName, wf.SysConfig.Activity["activitycode"]) {
+			w.ReplyText("您已经参与过新用户抽奖活动，请关注我们的其他活动")
+		} else {
+			targeturl := fmt.Sprintf("http://%s/activity/%s/%s", wf.SysConfig.Domain, wf.SysConfig.Activity["activitycode"], se.EncodeString(r.FromUserName))
+			log.Println("choujiang url:", targeturl)
+			w.ReplyNews([]Article{Article{PicUrl: wf.SysConfig.Activity["picurl"], Title: wf.SysConfig.Activity["title"], Url: targeturl}})
+		}
 	} else {
 		//属于在线咨询，暂时直接中转到微信客服系统
 		w.Reply2CustomerService()