message/handler/activity/task.go

package activity

import (
	"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) {
	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"])
	//增加积分
	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,
	})

}