package rtask

import (
	"go_dreamfactory/comm"
	"go_dreamfactory/pb"

	"google.golang.org/protobuf/proto"
)

func (this *apiComp) ChooseCheck(session comm.IUserSession, req *pb.RtaskChooseReq) (code pb.ErrorCode) {
	if req.ChooseId == 0 || req.RtaskId == 0 {
		code = pb.ErrorCode_ReqParameterError
	}
	return
}

func (this *apiComp) Choose(session comm.IUserSession, req *pb.RtaskChooseReq) (code pb.ErrorCode, data proto.Message) {
	if code = this.ChooseCheck(session, req); code != pb.ErrorCode_Success {
		return
	}

	// 获取玩家的任务
	// rtask := &pb.DBRtask{}
	// if err := this.moduleRtask.modelRtask.Get(session.GetUserId(), rtask); err != nil {
	// 	return
	// }

	// // 获取当前任务配置
	// conf := this.moduleRtask.configure.getRtaskById(req.RtaskId)
	// if conf == nil {
	// 	code = pb.ErrorCode_ConfigNoFound
	// 	return
	// }

	// // 获取支线任务配置
	// sideConf := this.moduleRtask.configure.getRtaskSidById(req.RtaskSubId)
	// if sideConf == nil {
	// 	code = pb.ErrorCode_ConfigNoFound
	// 	return
	// }

	// //获取选项配置
	// chooseCnf := this.moduleRtask.configure.getRtaskChooseCfg(req.ChooseId)
	// if chooseCnf == nil {
	// 	code = pb.ErrorCode_ConfigNoFound
	// 	return
	// }

	// // 校验限定条件
	// if chooseCnf.PreTid != 0 {
	// 	if err, ok := this.moduleRtask.modelRtask.checkCondi(session.GetUserId(), chooseCnf.PreTid); !ok {
	// 		this.moduleRtask.Errorf("no reach condi err: %v", err)
	// 		code = pb.ErrorCode_RtaskCondiNoReach
	// 		return
	// 	}
	// }

	// var (
	// 	frtaskArr *pb.FrtaskIds //完成的任务
	// 	ok        bool
	// )

	// if frtaskArr, ok = rtask.FrtaskIds[conf.Group]; !ok {
	// 	frtaskArr = &pb.FrtaskIds{}
	// }

	// //验证该任务是否已完成
	// if _, ok := utils.Findx(frtaskArr.RtaskIds, req.RtaskId); ok {
	// 	code = pb.ErrorCode_RtaskFinished
	// 	return
	// }

	// if chooseCnf.NextTid != 0 {
	// 	// 校验完成条件
	// 	for _, v := range sideConf.EndTid {
	// 		if v == -1 {
	// 			continue
	// 		}
	// 		if err, ok := this.moduleRtask.modelRtask.checkCondi(session.GetUserId(), v); !ok {
	// 			if err != nil {
	// 				this.moduleRtask.Error(err.Error())
	// 			}
	// 			code = pb.ErrorCode_RtaskCondiNoReach
	// 			return
	// 		}
	// 	}
	// 	// 更新完成的任务
	// 	frtaskArr.RtaskIds = append(frtaskArr.RtaskIds, req.RtaskId)
	// 	if rtask.FrtaskIds == nil {
	// 		rtask.FrtaskIds = make(map[int32]*pb.FrtaskIds)
	// 	}
	// 	rtask.FrtaskIds[conf.Group] = frtaskArr
	// 	update := map[string]interface{}{
	// 		"frtaskIds": rtask.FrtaskIds,
	// 	}
	// 	if err := this.moduleRtask.modelRtask.Change(session.GetUserId(), update); err != nil {
	// 		code = pb.ErrorCode_SystemError
	// 		return
	// 	}

	// 	// userexpand update
	// 	if err := this.moduleRtask.modelRtask.updateUserRtaskId(session.GetUserId(), req.RtaskId); err != nil {
	// 		this.moduleRtask.Errorf("update user rtaskId err %v", err)
	// 	}

	// 	// 发奖励
	// 	for _, v := range sideConf.Reward {
	// 		if v.ChooseId == req.ChooseId {
	// 			code = this.moduleRtask.DispenseRes(session, v.Reward, true)
	// 		}
	// 	}

	// 	rsp := &pb.RtaskFinishPush{
	// 		RtaskId: req.RtaskId,
	// 	}
	// 	if err := session.SendMsg(string(this.moduleRtask.GetType()), "finish", rsp); err != nil {
	// 		code = pb.ErrorCode_SystemError
	// 	}
	// }

	rsp := &pb.RtaskChooseResp{
		RtaskId:  req.RtaskId,
		ChooseId: req.ChooseId,
	}
	if err := session.SendMsg(string(this.moduleRtask.GetType()), RtaskSubTypeChoose, rsp); err != nil {
		code = pb.ErrorCode_SystemError
	}
	return
}