message/handler/activity/task.go

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"
	"github.com/gogf/gf/v2/util/gconv"
)

/*
新手任务/限时任务
*/

// 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)
	//修改任务状态
	db.Tidb.Update("integral_task_detail", map[string]interface{}{
		"user_id":     baseUserId,
		"position_id": positionId,
		"type":        types,
	}, map[string]interface{}{
		"status": 1,
	})

}