package logic

import (
	"HttpServer/conf"
	"HttpServer/redishandler"
	"common/logger"
	"common/redis"
	"fmt"
	"io/ioutil"
	"strconv"
	"time"

	//"log"
	"net/http"
)

//定时处理倒计时
func StartHttpTicker() {

}

func StartHttpServe() {
	startServerHttpServe()
}

//just for test
func Testsendhttp() {
	logger.Info("start Testsendhttp")
	result, err := redishandler.GetRedisClient().HGetAllKeys(redis.USER_DATA_KEY)
	if err != nil {
		logger.Error("TestDDt failed err=%v",err)
		return
	}

	right := 0
	for _, v := range result {

		ss := v.([]byte)
		oneuid := string(ss)

		//读取数据
		data, err := GetUserInfo(oneuid)
		if err != nil || data == nil {
			logger.Error("Testsendhttp GetUserInfo failed err=%v", err)
			continue
		}

		nowt := int(time.Now().Unix())

		if nowt-data.LastGetTime > 5*86400 {
			right++

			info, _ := redishandler.GetRedisClient().HGet(redis.USER_DATA_KEY, oneuid)

			redishandler.GetRedisClient().HDel(redis.USER_DATA_KEY, oneuid)

			logger.Info("RIGHTUUID=%v,info=%v", oneuid, info)
		}
	}

	logger.Info("FINAL++++++++++++++++++++++++++++res=%v",right)
}

func CheckErr(err error) {
	if err != nil {
		panic(err)
	}
}

func startServerHttpServe() {
	//-------------------------------------------------------------
	//http.HandleFunc("/catcafe/ClearData", ClearData)	//情况账号的测试接口
	//http.HandleFunc("/catcafe/AddWhiteList", AddWhiteList)	//情况账号的测试接口
	//http.HandleFunc("/catcafe/QueryAllAccount", QueryAllAccount)	//查询所有账号的等级信息等数据
	//-------------------------------------------------------------

	http.HandleFunc("/eliminatestar/test", Testapi)    //测试接口
	http.HandleFunc("/eliminatestar/clear", ClearData) //清除账号
	//----------------------------------------------------------------------------------------
	http.HandleFunc("/daycs/getcurproperty", Getcurproperty)   //请求当前物资
	http.HandleFunc("/daycs/fetchproterybox", Fetchproterybox) //请求领取物资宝箱
	http.HandleFunc("/daycs/uploadgunlv", Uploadgunlv)         //上报当前枪支等级
	http.HandleFunc("/daycs/addgold", Addgold)                 //增加金币接口(过关加金币用)
	http.HandleFunc("/daycs/quersigndata", Quersigndata)       //获取签到数据
	http.HandleFunc("/daycs/dosign", Dosign)                   //签到
	http.HandleFunc("/daycs/getopenid", Getopenid)             //获取openid
	http.HandleFunc("/daycs/userlogin", Userlogin)             //登录
	http.HandleFunc("/daycs/updatedata", Updatedata)           //更新数据
	http.HandleFunc("/daycs/getStampTime", GetStampTime)       //登录

	err := http.ListenAndServe(conf.GetServerHttpAddrConf(), nil)
	CheckErr(err)
}

func GetStampTime(w http.ResponseWriter, r *http.Request) {
	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

	s := string(result)
	//logger.Info("GetStampTime , body:%v", s)

	HandlerGetStampTime(w, s)
}

func Updatedata(w http.ResponseWriter, r *http.Request) {
	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

	s := string(result)
	logger.Info("Updatedata , body:%v", s)

	HandlerUpdatedata(w, s)
}

func Userlogin(w http.ResponseWriter, r *http.Request) {
	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

	s := string(result)
	logger.Info("Userlogin , body:%v", s)

	HandlerUserlogin(w, s)
}

func Getopenid(w http.ResponseWriter, r *http.Request) {
	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

	s := string(result)
	logger.Info("Getopenid , body:%v", s)

	HandlerGetopenid(w, s)
}

func Dosign(w http.ResponseWriter, r *http.Request) {
	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

	s := string(result)
	logger.Info("Dosign , body:%v", s)

	HandlerDosign(w, s)
}

func Quersigndata(w http.ResponseWriter, r *http.Request) {
	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

	s := string(result)
	logger.Info("Quersigndata , body:%v", s)

	HandlerQuersigndata(w, s)
}

func Addgold(w http.ResponseWriter, r *http.Request) {
	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

	s := string(result)
	logger.Info("Addgold , body:%v", s)

	HandlerAddgold(w, s)
}

func Uploadgunlv(w http.ResponseWriter, r *http.Request) {
	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

	s := string(result)
	logger.Info("Uploadgunlv , body:%v", s)

	HandlerUploadgunlv(w, s)
}

func Fetchproterybox(w http.ResponseWriter, r *http.Request) {
	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

	s := string(result)
	logger.Info("Fetchproterybox , body:%v", s)

	HandlerFetchproterybox(w, s)
}

func ClearData(w http.ResponseWriter, r *http.Request) {

	Uuid := 0
	if len(r.Header) > 0 {
		Uuid, _ = strconv.Atoi(r.Header.Get("Uuid"))
	}

	if Uuid == 0 {
		SetHeader(w)
		//logger.Error("Uuid is nil!")
		return
	}
	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

	s := string(result)
	logger.Info("ClearData , body:%v,uuid=%v", s, Uuid)

	redishandler.GetRedisClient().HDel(redis.USER_DATA_KEY, strconv.Itoa(Uuid))

	fmt.Fprint(w, "success!")
}

func Testapi(w http.ResponseWriter, r *http.Request) {

	fmt.Fprint(w, "success")
}

func Getcurproperty(w http.ResponseWriter, r *http.Request) {
	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

	s := string(result)
	logger.Info("Getcurproperty , body:%v", s)

	HandlerGetcurproperty(w, s)
}

/*func Getnewlevelreward(w http.ResponseWriter, r *http.Request) {

	Uuid := 0
	if len(r.Header) > 0 {
		Uuid, _ = strconv.Atoi(r.Header.Get("Uuid"))
	}

	if Uuid == 0 {
		SetHeader(w)
		//logger.Error("Uuid is nil!")
		return
	}
	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

	s := string(result)
	logger.Info("Getnewlevelreward , body:%v,uuid=%v", s, Uuid)

	HandlerGetnewlevelreward(w, s, Uuid)
}*/