package growtask

import (
	"fmt"
	"go_dreamfactory/comm"
	"go_dreamfactory/pb"
)

// 子任务奖励领取

func (this *apiComp) ReceiveCheck(session comm.IUserSession, req *pb.GrowtaskReceiveReq) (errdata *pb.ErrorData) {
	if req.TaskId == 0 {
		errdata = &pb.ErrorData{
			Code:  pb.ErrorCode_ReqParameterError,
			Title: pb.ErrorCode_ReqParameterError.ToString(),
		}
	}
	return
}

func (this *apiComp) Receive(session comm.IUserSession, req *pb.GrowtaskReceiveReq) (errdata *pb.ErrorData) {
	var (
		reward []*pb.UserAtno
	)

	if errdata = this.ReceiveCheck(session, req); errdata != nil {
		return
	}

	uid := session.GetUserId()

	// 领取
	if err := this.module.modelGrowtask.receive(uid, req.TaskId); err != nil {
		errdata = &pb.ErrorData{
			Code:  pb.ErrorCode_GrowtaskReceive,
			Title: pb.ErrorCode_GrowtaskReceive.ToString(),
		}
		return
	}

	//发奖
	ggt, err := this.module.configure.getGrowtaskCfg()
	if err != nil {
		errdata = &pb.ErrorData{
			Code:    pb.ErrorCode_ConfigNoFound,
			Title:   pb.ErrorCode_ConfigNoFound.ToString(),
			Message: err.Error(),
		}
		return
	}
	if ggt == nil {
		errdata = &pb.ErrorData{
			Code:    pb.ErrorCode_ConfigNoFound,
			Title:   pb.ErrorCode_ConfigNoFound.ToString(),
			Message: err.Error(),
		}
		return
	}

	if conf, ok := ggt.GetDataMap()[req.TaskId]; !ok {
		errdata = &pb.ErrorData{
			Code:    pb.ErrorCode_ConfigNoFound,
			Title:   pb.ErrorCode_ConfigNoFound.ToString(),
			Message: fmt.Sprintf("no found %d", req.TaskId),
		}
		return
	} else {
		if errdata, reward = this.module.DispenseAtno(session, conf.Reward, true); errdata != nil {
			this.module.Errorf("子任务奖励发放失败 taskId:%v uid:%v", req.TaskId, uid)
			return
		}
	}

	session.SendMsg(string(this.module.GetType()), GrowtaskSubTypeReceive, &pb.GrowtaskReceiveResp{
		TaskId: req.TaskId,
		Reward: reward,
	})

	go this.module.AsynHandleSession(session.Clone(), func(session comm.IUserSession) {
		this.module.WriteUserLog(session.GetUserId(), req, comm.GMResAddType, "GrowtaskReceiveReq", reward)
	})
	return
}