Merge branch 'feature/v1.2.6' of https://app.yhyue.com/moapp/message into feature/v1.2.6

handler/activity/task.go

@@ -1,6 +1,10 @@
 package activity
 
 import (
+	"fmt"
+	"log"
+
+	"app.yhyue.com/moapp/jybase/go-logger/logger"
 	"app.yhyue.com/moapp/message/db"
 	"app.yhyue.com/moapp/message/model"
 	"app.yhyue.com/moapp/message/rpc"
@@ -13,11 +17,17 @@ import (
 
 // Task 完成任务
 func Task(msg *model.Message) {
+	log.Println(msg.E_body)
 	num := gconv.Int64(msg.E_body["num"])
 	code := gconv.Int64(msg.E_body["code"]) //1005
 	types := gconv.Int64(msg.E_body["type"])
 	baseUserId := gconv.Int64(msg.E_body["baseUserId"])
 	positionId := gconv.Int64(msg.E_body["positionId"])
+	//判断是否赠送过积分，送过则不送
+	if db.Mysql.CountBySql(`select count(1) from jypoints.integral_flow where userId =? and pointType =? and sort =1;`, msg.E_userId, code) > 0 {
+		logger.Info(fmt.Sprintf("用户%s已经增加过积分%v，不再增加积分。", msg.E_userId, code))
+		return
+	}
 	//增加积分
 	rpc.IntegralHarvest(msg.E_userId, num, code, msg.E_time)
 	//修改任务状态

handler/handler.go

@@ -32,7 +32,7 @@ var (
 		"jywx_activity_message":  VarPush.Jywx_activity_message,
 		"jywx_exhibition_active": activity.ExhibitionActive,
 		//任务
-		"bind_phone": activity.Task,
+		"task": activity.Task,
 	}
 )