package activity

import (
	"fmt"
	"go_dreamfactory/comm"
	"go_dreamfactory/pb"
	"go_dreamfactory/sys/configure"
	cfg "go_dreamfactory/sys/configure/structs"
)

//参数校验
func (this *apiComp) GetRewardCheck(session comm.IUserSession, req *pb.ActivityGetRewardReq) (errdata *pb.ErrorData) {
	if req.Oid == "" {
		errdata = &pb.ErrorData{
			Code:  pb.ErrorCode_ReqParameterError,
			Title: pb.ErrorCode_ReqParameterError.ToString(),
		}
	}
	return
}

func (this *apiComp) GetReward(session comm.IUserSession, req *pb.ActivityGetRewardReq) (errdata *pb.ErrorData) {
	if errdata = this.GetRewardCheck(session, req); errdata != nil {
		return
	}
	var (
		activity *pb.DBHuodong // 活动详细信息
		err      error
		reward   []*cfg.Gameatn
		atno     []*pb.UserAtno
	)
	//key := fmt.Sprintf("%s-%s", session.GetUserId(), req.Oid)
	data, err := this.module.modelhdData.getHddataByOid(session.GetUserId(), req.Oid)
	if err != nil {
		errdata = &pb.ErrorData{
			Code:  pb.ErrorCode_DBError,
			Title: pb.ErrorCode_DBError.ToString(),
		}
		return
	}
	if activity, err = this.module.modelhdList.getHdListByHdId(req.Oid); err == nil {
		curTime := configure.Now().Unix()
		if activity.Stime > curTime || curTime > activity.Etime { //不在活动时间范围内
			errdata = &pb.ErrorData{
				Code:  pb.ErrorCode_ActivityNotIntime,
				Title: pb.ErrorCode_ActivityNotIntime.ToString(),
			}
			return
		}
	} else {
		errdata = &pb.ErrorData{
			Code:    pb.ErrorCode_ActivityInvalid, // 找不到活动数据
			Title:   pb.ErrorCode_ActivityInvalid.ToString(),
			Message: fmt.Sprintf("not found activity oid:%s", req.Oid),
		}
		return
	}

	if data.Val < req.Val { //没达到领奖条件
		errdata = &pb.ErrorData{
			Code:  pb.ErrorCode_ActivityCantReward,
			Title: pb.ErrorCode_ActivityCantReward.ToString(),
		}
		return
	}
	if data.Gotarr != nil {
		if _, ok := data.Gotarr[req.Val]; ok { // 重复领奖
			errdata = &pb.ErrorData{
				Code:  pb.ErrorCode_ActivityRepatReward,
				Title: pb.ErrorCode_ActivityRepatReward.ToString(),
			}
			return
		}
	}

	for range activity.Data.Prize {
		if len(activity.Data.Prize) > int(req.Val) {
			for _, v2 := range activity.Data.Prize[req.Val].Prize {
				reward = append(reward, &cfg.Gameatn{
					A: v2.A,
					T: v2.T,
					N: v2.N,
				})
			}
			if errdata, atno = this.module.DispenseAtno(session, reward, true); errdata != nil {
				return
			}
			break
		}
	}
	data.Gotarr[req.Val] = 1
	update := make(map[string]interface{})
	update["gotarr"] = data.Gotarr
	this.module.modelhdData.ModifyActivityList(session.GetUserId(), data.Id, update)
	session.SendMsg(string(this.module.GetType()), "getreward", &pb.ActivityGetRewardResp{
		Data: data,
		Atno: atno,
	})

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