package logic

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

	//"log"
	"net/http"
)

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

}

func StartHttpServe() {
	startServerHttpServe()
}

//just for test
func Testsendhttp() {

}

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

func startServerHttpServe() {
	//-------------------------------------------------------------
	http.HandleFunc("/catcafe/ClearData", ClearData)	//情况账号的测试接口

	//-------------------------------------------------------------
	http.HandleFunc("/catcafe/login", UserLogin)                                    //游客登录
	http.HandleFunc("/catcafe/user/regeister", Regeister)                                    //账号注册
	http.HandleFunc("/catcafe/user/accountlogin", AccounLogin)                                    //账号登录
	http.HandleFunc("/catcafe/wechatlogin", Wechatlogin)                                    //微信登录
	http.HandleFunc("/catcafe/user/saveUserData", SaveUserData)                                    //保存用户数据
	http.HandleFunc("/catcafe/data/saveData", SaveData)                                    //保存游戏自定义数据
	http.HandleFunc("/catcafe/data/getData", GetData)                                    //获取自定义数据
	http.HandleFunc("/catcafe/team/textCheck", TextCheck)                                    //敏感词检测
	http.HandleFunc("/catcafe/team/createTeam", CreateTeam)                                    //创建队伍
	http.HandleFunc("/catcafe/team/updateTeamData", UpdateTeamData)                            //修改队伍信息
	http.HandleFunc("/catcafe/team/joinTeam", JoinTeam)                            //主动加入队伍
	http.HandleFunc("/catcafe/team/joinTeamByInvite", JoinTeamByInvite)                            //被邀请加入队伍
	http.HandleFunc("/catcafe/team/quitTeam", QuitTeam)                            //被邀请加入队伍
	http.HandleFunc("/catcafe/team/updateTeamBuild", UpdateTeamBuild)                            //升级队伍建筑等级
	http.HandleFunc("/catcafe/team/addTeamBuff", AddTeamBuff)                            //添加BUFF时间
	http.HandleFunc("/catcafe/team/getTeamBuff", GetTeamBuff)                            //获取BUFF时间
	http.HandleFunc("/catcafe/team/getTeamData", GetTeamData)                            //获取玩家队伍信息
	http.HandleFunc("/catcafe/team/getDataByUserId", GetDataByUserId)                            //获取队伍成员的详细数据
	http.HandleFunc("/catcafe/team/getTeamList", GetTeamList)                            //查询队伍列表
	http.HandleFunc("/catcafe/team/searchTeam", SearchTeam)                            //根据名称搜索队伍
	http.HandleFunc("/catcafe/friend/setFriendRequest", SetFriendRequest)                            //申请添加好友
	http.HandleFunc("/catcafe/friend/getList", GetFriendList)                            //获取好友列表
	http.HandleFunc("/catcafe/friend/getAuditList", GetAuditList)                            //获取待审核好友列表
	http.HandleFunc("/catcafe/friend/getRecommendList", GetRecommendList)                            //获取推荐好友列表
	http.HandleFunc("/catcafe/friend/handleFriendRequest", HandleFriendRequest)                            //处理好友请求
	http.HandleFunc("/catcafe/friend/delFriend", DelFriend)                            //删除好友
	http.HandleFunc("/catcafe/friend/QueryPlayerData", QueryPlayerData)                            //根据用户id获取用户信息  好友用


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

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

	query := r.URL.Query()
	uuid := query.Get("uuid")
	logger.Info("ClearData , uuid:%v", uuid)
	if uuid == "" {
		fmt.Fprint(w, "uuid is nil,please check")
		return
	}
	uuidnum,_ := strconv.Atoi(uuid)
	/*coin,err := mysql.TestClearData(uuidnum)
	if err != nil {
		logger.Error("ClearData err=%v",err)
	}

	fmt.Fprint(w, "ClearData coin=%v",coin)*/

	//首先检查白名单
	rkey := "CATCAFE_REDIS_CAN_RESETDATA_LIST"
	vv,err := redishandler.GetRedisClient().HGetAllValues(rkey)
	if err != nil {
		fmt.Fprint(w,"获取白名单失败！，请检查")
	}

	for _,val := range vv {
		bytestr := string(val.([]byte))
		logger.Info("ClearData white list str=%v",bytestr)
	}
	return

	err = mysql.DoClearData(uuidnum)
	if err != nil {
		fmt.Fprint(w, "清除数据失败了，错误码%v",err)
	}

	//下面清楚redis
	rediskey := "cat:cafe:data:where:data_uid:" + uuid
	exist,_ := redishandler.GetRedisClient().Exists(rediskey)
	if exist {
		//存在，即删除
		err = redishandler.GetRedisClient().Delete(rediskey)
		if err != nil {
			fmt.Fprint(w, "清除数据失败了，错误码%v",err)
		}
	}

	fmt.Fprint(w, "清除数据成功了，恭喜！uuid=%v",uuid)

	//HandleRegeister(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleRegeister(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleAccounLogin(w,s)
}


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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleWechatlogin(w,s)
}


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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleQueryPlayerData(w,s)
}


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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleDelFriend(w,s)
}


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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleHandleFriendRequest(w,s)
}


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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleGetRecommendList(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleGetAuditList(w,s)
}


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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleGetFriendList(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleSetFriendRequest(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleSearchTeam(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleGetTeamList(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleGetDataByUserId(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleGetTeamData(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleGetTeamBuff(w,s)
}


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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleAddTeamBuff(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleUpdateTeamBuild(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleQuitTeam(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleJoinTeamByInvite(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleJoinTeam(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleUpdateTeamData(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleCreateTeam(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleTextCheck(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleSaveUserData(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandlesaveData(w,s)
}

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

	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandlegetData(w,s)
}


func UserLogin(w http.ResponseWriter, r *http.Request) {
	//logger.Info("%%%%%%%%%%%%%%%%path=%v", *r.URL)
	//for k, v := range r.Header {
	//	logger.Info("*********************key=%v,value=%v", k, v)
	//}

	//w.Header().Add("Access-Control-Allow-Headers", "")
	//w.Header().Set("Access-Control-Allow-Headers", "Authorization, Content-Length, X-CSRF-Token, Token,session,X_Requested_With,Accept, Origin, Host, Connection, Accept-Encoding, Accept-Language,DNT, X-CustomHeader, Keep-Alive, User-Agent, X-Requested-With, If-Modified-Since, Cache-Control, Content-Type, Pragma")

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

	if Uuid == 0 {
		return
	}*/
	result, _ := ioutil.ReadAll(r.Body)
	r.Body.Close()

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

	HandleUserLogin(w,s)
}