package tests

import (
	"fengkuangGameServerJob/dao"
	"fengkuangGameServerJob/service"
	"fmt"
	"testing"
	"time"
)

//测试获取到期的任务
func TestGetDueMission(t *testing.T) {
	mountService := service.NewMountMissionService()
	fmt.Println(mountService)
	//mission := missionsInfo[0]
	////1.获取配置信息
	//confs, err := mountService.ParseMissionConf()
	//util.CheckErr(err)
	//conf := confs[mission.MissionAddrId]
	//
	//mountService.HandlerSingleMission(mission, conf)
}

//测试获取任务配置
func TestGetMissionConf(t *testing.T) {
	//mountService := service.NewMountMissionService()
	//mountService.ParseMissionConf()

	service.GetMountMissionConf()
}

func TestGetDueMissionIds(t *testing.T) {
	nowUnix := time.Now().Unix()
	missionIdsStr, err := dao.GetDueMission(nowUnix)
	fmt.Println(err)
	fmt.Println(missionIdsStr)
}


func TestMissionRedisPipe(t *testing.T) {
	pipeTx := dao.Redis().TxPipeline()
	//3.1 更新当前任务的score(即结束时间戳)
	dao.SetMission(pipeTx, "2", 22)
	//3.2 把资源变动信息放入日志队列中
	logs := []string{"aaa", "bbb"}
	dao.AddResourceChangeLog(pipeTx, logs)
	_, err := pipeTx.Exec()
	fmt.Println(err)
}