package logic import ( "HttpServer/conf" "HttpServer/redishandler" "common/redis" "encoding/json" "strconv" "time" "common/logger" //"encoding/json" "fmt" "io/ioutil" //"log" "net/http" ) //定时处理倒计时 func StartHttpTicker() { ticker := time.NewTicker(time.Second * time.Duration(30)) go func() { for range ticker.C { //处理倒计时 for uid, vv := range m_userInfo.Items() { uinfo, _ := vv.(*UserData) for k, val := range uinfo.PosInfo { if val.Countdown != 0 { if val.Countdown > 30 { uinfo.PosInfo[k].Countdown -= 30 //val.Countdown -= 30 } else { uinfo.PosInfo[k].Countdown = 0 //倒计时结束增加红包 rdcfg := GetRedCatConfig(val.Catlv) if rdcfg == nil { logger.Error("countdown 0 getredcfgfailed lv=%v", val.Catlv) continue } uinfo.Redbag += int(rdcfg.Money * 100) //此处记录红包对应流水,后期可能统一记录 logger.Info("user get redbage uuid=%v,num=%v", uid, int(rdcfg.Money*100)) } } } nuoday := time.Now().Day() //跨天了 if uinfo.CatShopInfo.DayNum != nuoday { uinfo.CatShopInfo.ThisIsWatch = 8 uinfo.CatShopInfo.DayNum = nuoday //处理一下当日任务数据 uinfo.Taskinfo.BuyCatTime = 0 uinfo.Taskinfo.MergeTime = 0 uinfo.Taskinfo.PlayWithTime = 0 uinfo.Taskinfo.StartOnline = make(map[int]int64) uinfo.Taskinfo.WatchAddTime = 0 Maplock.RLock() uinfo.Taskinfo.CompleteId = make(map[int]int) uinfo.Taskinfo.HaveComplete = make(map[int]int) Maplock.RUnlock() } if uinfo.CatShopInfo.IsPlaying == 1 && uinfo.CatShopInfo.LeftTime > 0 { if uinfo.CatShopInfo.LeftTime > 30 { uinfo.CatShopInfo.LeftTime -= 30 } else { uinfo.CatShopInfo.LeftTime = 0 } } SaveUinfoToredis(uinfo, int(uid)) } } }() } func StartHttpServe() { startServerHttpServe() } type QueryInviteReq struct { Uuid int `json:"uuid"` } type FetchReward struct { Gameid string `json:"gameid"` Channel string `json:"channel"` Tasktype int `json:"tasktype"` Taskid int `json:"taskid"` } type UserCaiPiaoInfo struct { CatId int //猫ID UserId int //uuid ChooseNum int //选择号码 } //当期奖池信息 type CurDuboCatList struct { CurRound int //当前轮次 CurNum int //当前人数 FakeNum int //当期不开奖号码 如果0表示当期真实开奖 List []UserCaiPiaoInfo //当期彩池人数 } //just for test func Testsendhttp() { logger.Info("start DoCatStatic") result, err := redishandler.GetRedisClient().HGetAllKeys("CATSERVER_USER_USER_INFO") if err != nil { logger.Error("TestDDt failed err=%v",err) return } for _, v := range result { ss := v.([]byte) oneuidstr := string(ss) oneuid,_ := strconv.Atoi(oneuidstr) //读取数据 data := GetUserInfo(oneuid) if data == nil { logger.Error("Testsendhttp GetUserInfo failed err=%v", err) continue } logger.Info("CATUUID=%v,HIGESTCATLV=%v,LASTLOGINTIME=%v",oneuid,data.Highestlv,data.LastLoginTime) } } func CheckErr(err error) { if err != nil { panic(err) } } 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) 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_INFO, strconv.Itoa(Uuid)) m_userInfo.Delete(uint32(Uuid)) fmt.Fprint(w, "success") } func TestaddCat(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("TestaddCat , body:%v,uuid=%v", s, Uuid) HandlerTestaddCat(w, s, Uuid) } func Clearsigndata(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Clearsigndata , body:%v,uuid=%v", s, Uuid) HandlerClearsigndata(w, s, Uuid) } func ChangeCoin(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("ChangeCoin , body:%v,uuid=%v", s, Uuid) HandlerChangeCoin(w, s, Uuid) } func startServerHttpServe() { //test http.HandleFunc("/cat/test/cleardata", Cleardata) //清号 http.HandleFunc("/cat/test/addCat", TestaddCat) //增加猫 http.HandleFunc("/cat/test/changeCoin", ChangeCoin) //增加猫 http.HandleFunc("/cat/test/clearsigndata", Clearsigndata) //清除签到状态 //testend http.HandleFunc("/cat/login", UserLogin) //登录 http.HandleFunc("/cat/getuserdata", GetUserData) //拉取用户数据 //http.HandleFunc("/cat/getuserdata", GetUserData) //拉取用户数据 http.HandleFunc("/cat/exchangetwoPos", ExchangePos) //交换位置 http.HandleFunc("/cat/clickcatbox", ClickCatBox) //请求点击猫箱子 http.HandleFunc("/cat/upgradecatbox", UpgradeCatBox) //请求点击猫箱子 http.HandleFunc("/cat/acclecte", AcclecteGold) //请求点击猫箱子 http.HandleFunc("/cat/automerge", AutoMerge) //请求自动合成 http.HandleFunc("/cat/generatebox", GenerateBox) //请求点击猫箱子 http.HandleFunc("/cat/clickrandgift", ClickRandGift) //请求点击猫箱子 http.HandleFunc("/cat/querybuycat", QueryBuyCat) //请求商店购买信息 http.HandleFunc("/cat/dobuycat", DoBuyCat) //购买猫 http.HandleFunc("/cat/querwarehouse", QueryWareHouse) //请求仓库信息 http.HandleFunc("/cat/putcattowarehouse", PutCattoWareHouse) //将合成界面的猫放入仓库 http.HandleFunc("/cat/takecatoutfromwarehouse", TakeCatoutfromWareHouse) //将仓库的猫取出 http.HandleFunc("/cat/acclecteboxrate", AcclecteBoxRate) //请求点击猫箱子 http.HandleFunc("/cat/queryautomergeinfo", QueryAutomergeInfo) //请求点击猫箱子 http.HandleFunc("/cat/querycatroominfo", QueryCatRoomInfo) //请求点击猫箱子 http.HandleFunc("/cat/buycatroom", BuyCatRoom) //请求点击猫箱子 http.HandleFunc("/cat/upcattoroom", UpCattoRoom) //请求点击猫箱子 http.HandleFunc("/cat/querycatshopinfo", QueryCatShopInfo) //请求点击猫箱子 http.HandleFunc("/cat/catshoplay", CatShoPlay) //请求点击猫箱子 http.HandleFunc("/cat/getcatshopreward", GetCatShopReward) //请求点击猫箱子 http.HandleFunc("/cat/acclectecatstory", AcclecteCatStory) //请求点击猫箱子 http.HandleFunc("/cat/updateuserinfo", UpdateUserInfo) //请求点击猫箱子 http.HandleFunc("/cat/queryplayerrank", QueryPlayerRank) //请求点击猫箱子 //http.HandleFunc("/cat/querycompletetask", QueryCompleteTask) //请求点击猫箱子 //http.HandleFunc("/cat/querycompleteachievement", QueryCompleteAchievement) //请求点击猫箱子 //http.HandleFunc("/cat/gettaskreward", GetTaskReward) //请求点击猫箱子 //http.HandleFunc("/cat/getachievereward", GetAchieveReward) //请求点击猫箱子 //http.HandleFunc("/cat/startonlinetask", StartOnlineTask) //请求开始在线时长任务 http.HandleFunc("/cat/getofflinereward", GetOfflineReward) //请求开始在线时长任务 http.HandleFunc("/cat/quertlvredbag", Quertlvredbag) // 查询等级红包数据 http.HandleFunc("/cat/fetchlvredbag", Fetchlvredbag) // 请求领取等级红包 http.HandleFunc("/cat/getrandredbag", Getrandredbag) //领取随机红包 http.HandleFunc("/cat/uploadusercost", Uploadusercost) // 上报玩家消耗次数(摇一摇) http.HandleFunc("/cat/shakeaddgold", Shakeaddgold) // 摇一摇增加金币 http.HandleFunc("/cat/addcatgold", Addcatgold) // 增加金币 http.HandleFunc("/cat/recovery", Recovery) //回收猫 http.HandleFunc("/cat/quersigndata", Quersigndata) //获取签到数据 http.HandleFunc("/cat/dosign", Dosign) //签到 http.HandleFunc("/cat/queregginfo", Queregginfo) //获取扭蛋信息 http.HandleFunc("/cat/twistegg", Twistegg) //扭蛋 http.HandleFunc("/cat/addfreeeggtime", Addfreeeggtime) //增加免费扭蛋次数 http.HandleFunc("/cat/doubletwistegg", Doubletwistegg) //扭蛋双倍领取 http.HandleFunc("/cat/onlinentf", Onlinentf) //在线通知 http.HandleFunc("/cat/updatetaskandachieve", Updatetaskandachieve) //上报任务事件进度 http.HandleFunc("/cat/querytaskinfo", Querytaskinfo) //拉取任务或者成就列表 http.HandleFunc("/cat/gettaskreward", Gettaskreward) //领取任务或者成就奖励 http.HandleFunc("/cat/queryvideoloveprocess", Queryvideoloveprocess) //获取视频爱心次数 http.HandleFunc("/cat/getvideolove", Getvideolove) //领取视频爱心 http.HandleFunc("/cat/queryworkinfo", Queryworkinfo) //请求打工数据 http.HandleFunc("/cat/startwork", Startwork) //请求打工 http.HandleFunc("/cat/getworkreward", Getworkreward) //请求打工奖励 //提现的接口 http.HandleFunc("/cat/querygetcashinfo", Querygetcashinfo) // 请求提现档位信息 http.HandleFunc("/cat/getcash", Getcash) // 请求提现 http.HandleFunc("/cat/getcashrecord", Getcashrecord) // 请求提现 err := http.ListenAndServe(conf.GetServerHttpAddrConf(), nil) CheckErr(err) } func Quertlvredbag(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Quertlvredbag , body:%v,uuid=%v", s, Uuid) HandlerQuertlvredbag(w, s, Uuid) } func Getcashrecord(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Getcashrecord , body:%v,uuid=%v", s, Uuid) HandlerGetcashrecord(w, s, Uuid) } func Getcash(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Getcash , body:%v,uuid=%v", s, Uuid) HandlerGetcash(w, s, Uuid) } func Querygetcashinfo(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Querygetcashinfo , body:%v,uuid=%v", s, Uuid) HandlerQuerygetcashinfo(w, s, Uuid) } func Queryworkinfo(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Queryworkinfo , body:%v,uuid=%v", s, Uuid) HandlerQueryworkinfo(w, s, Uuid) } func Getvideolove(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Getvideolove , body:%v,uuid=%v", s, Uuid) HandlerGetvideolove(w, s, Uuid) } func Queryvideoloveprocess(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Queryvideoloveprocess , body:%v,uuid=%v", s, Uuid) HandlerQueryvideoloveprocess(w, s, Uuid) } func Getworkreward(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Getworkreward , body:%v,uuid=%v", s, Uuid) HandlerGetworkreward(w, s, Uuid) } func Startwork(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Startwork , body:%v,uuid=%v", s, Uuid) HandlerStartwork(w, s, Uuid) } func Gettaskreward(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Gettaskreward , body:%v,uuid=%v", s, Uuid) HandlerGettaskreward(w, s, Uuid) } func Querytaskinfo(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Querytaskinfo , body:%v,uuid=%v", s, Uuid) HandlerQuerytaskinfo(w, s, Uuid) } func Updatetaskandachieve(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Updatetaskandachieve , body:%v,uuid=%v", s, Uuid) HandlerUpdatetaskandachieve(w, s, Uuid) } func Onlinentf(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Onlinentf , body:%v,uuid=%v", s, Uuid) HandlerOnlinentf(w, s, Uuid) } func Doubletwistegg(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Doubletwistegg , body:%v,uuid=%v", s, Uuid) HandlerDoubletwistegg(w, s, Uuid) } func Addfreeeggtime(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Addfreeeggtime , body:%v,uuid=%v", s, Uuid) HandlerAddfreeeggtime(w, s, Uuid) } func Twistegg(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Twistegg , body:%v,uuid=%v", s, Uuid) HandlerTwistegg(w, s, Uuid) } func Queregginfo(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Queregginfo , body:%v,uuid=%v", s, Uuid) HandlerQueregginfo(w, s, Uuid) } func Dosign(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Dosign , body:%v,uuid=%v", s, Uuid) HandlerDosign(w, s, Uuid) } func Quersigndata(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Quersigndata , body:%v,uuid=%v", s, Uuid) HandlerQuersigndata(w, s, Uuid) } func Recovery(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Recovery , body:%v,uuid=%v", s, Uuid) HandlerRecovery(w, s, Uuid) } func Addcatgold(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Addcatgold , body:%v,uuid=%v", s, Uuid) HandlerAddcatgold(w, s, Uuid) } func Shakeaddgold(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Shakeaddgold , body:%v,uuid=%v", s, Uuid) HandlerShakeaddgold(w, s, Uuid) } func Uploadusercost(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Uploadusercost , body:%v,uuid=%v", s, Uuid) HandlerUploadusercost(w, s, Uuid) } func Getrandredbag(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Getrandredbag , body:%v,uuid=%v", s, Uuid) HandlerGetrandredbag(w, s, Uuid) } func Fetchlvredbag(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("Fetchlvredbag , body:%v,uuid=%v", s, Uuid) HandlerFetchlvredbag(w, s, Uuid) } func GetOfflineReward(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("GetOfflineReward , body:%v,uuid=%v", s, Uuid) HandlerGetOfflineReward(w, s, Uuid) } func StartOnlineTask(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("StartOnlineTask , body:%v,uuid=%v", s, Uuid) HandlerStartOnlineTask(w, s, Uuid) } func QueryCompleteTask(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("QueryCompleteTask , body:%v,uuid=%v", s, Uuid) HandlerQueryCompleteTask(w, s, Uuid) } func QueryCompleteAchievement(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("QueryCompleteAchievement , body:%v,uuid=%v", s, Uuid) HandlerQueryCompleteAchievement(w, s, Uuid) } func GetTaskReward(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("GetTaskReward , body:%v,uuid=%v", s, Uuid) HandlerGetTaskReward(w, s, Uuid) } func GetAchieveReward(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("GetAchieveReward , body:%v,uuid=%v", s, Uuid) HandlerGetAchieveReward(w, s, Uuid) } func UpdateUserInfo(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("UpdateUserInfo , body:%v,uuid=%v", s, Uuid) HandlerUpdateUserInfo(w, s, Uuid) } func QueryPlayerRank(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("QueryPlayerRank , body:%v,uuid=%v", s, Uuid) HandlerQueryPlayerRank(w, s, Uuid) } func AcclecteCatStory(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("AcclecteCatStory , body:%v,uuid=%v", s, Uuid) HandlerAcclecteCatStory(w, s, Uuid) } func QueryCatShopInfo(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("QueryCatShopInfo , body:%v,uuid=%v", s, Uuid) HandlerQueryCatShopInfo(w, s, Uuid) } func CatShoPlay(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("CatShoPlay , body:%v,uuid=%v", s, Uuid) HandlerCatShoPlay(w, s, Uuid) } func GetCatShopReward(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("GetCatShopReward , body:%v,uuid=%v", s, Uuid) HandlerGetCatShopReward(w, s, Uuid) } func QueryCatRoomInfo(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("QueryCatRoomInfo , body:%v,uuid=%v", s, Uuid) HandlerQueryCatRoomInfo(w, s, Uuid) } func BuyCatRoom(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("BuyCatRoom , body:%v,uuid=%v", s, Uuid) HandlerBuyCatRoom(w, s, Uuid) } func UpCattoRoom(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("UpCattoRoom , body:%v,uuid=%v", s, Uuid) HandlerUpCattoRoom(w, s, Uuid) } func QueryAutomergeInfo(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("QueryAutomergeInfo , body:%v,uuid=%v", s, Uuid) HandlerQueryAutomergeInfo(w, s, Uuid) } func QueryWareHouse(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("QueryWareHouse , body:%v,uuid=%v", s, Uuid) HandlerQueryWareHouse(w, s, Uuid) } func PutCattoWareHouse(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("PutCattoWareHouse , body:%v,uuid=%v", s, Uuid) HandlerPutCattoWareHouse(w, s, Uuid) } func TakeCatoutfromWareHouse(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("TakeCatoutfromWareHouse , body:%v,uuid=%v", s, Uuid) HandlerTakeCatoutfromWareHouse(w, s, Uuid) } func DoBuyCat(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("DoBuyCat , body:%v,uuid=%v", s, Uuid) HandlerDoBuyCat(w, s, Uuid) } func QueryBuyCat(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("QueryBuyCat , body:%v,uuid=%v", s, Uuid) HandlerQueryBuyCat(w, s, Uuid) } func ClickRandGift(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("ClickRandGift , body:%v,uuid=%v", s, Uuid) HandlerClickRandGift(w, s, Uuid) } func AutoMerge(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("AutoMerge , body:%v,uuid=%v", s, Uuid) HandlerAutoMerge(w, s, Uuid) } func ClickCatBox(w http.ResponseWriter, r *http.Request) { Uuid := 0 if len(r.Header) > 0 { Uuid, _ = strconv.Atoi(r.Header.Get("Uuid")) } if Uuid == 0 { logger.Error("ClickCatBox uuid is nil") SetHeader(w) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("ClickCatBox , body:%v,uuid=%v", s, Uuid) HandlerClickCatBox(w, s, Uuid) } func GenerateBox(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("GenerateBox , body:%v,uuid=%v", s, Uuid) HandlerGenerateBox(w, s, Uuid) } func UpgradeCatBox(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("UpgradeCatBox , body:%v,uuid=%v", s, Uuid) HandlerUpgradeCatBox(w, s, Uuid) } func AcclecteBoxRate(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("AcclecteBoxRate , body:%v,uuid=%v", s, Uuid) HandlerAcclecteBoxRate(w, s, Uuid) } func AcclecteGold(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("AcclecteGold , body:%v,uuid=%v", s, Uuid) HandlerAcclecteGold(w, s, Uuid) } func ExchangePos(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("ExchangePos uuid is nil") var resp ExchangePosResp resp.Code = 999 //回包 respstr, _ := json.Marshal(&resp) fmt.Fprint(w, string(respstr)) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("ExchangePos , body:%v,uuid=%v", s, Uuid) HandlerExchangePos(w, s, Uuid) } func GetUserData(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) return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) //logger.Info("GetUserData , body:%v,uuid=%v", s, Uuid) HandlerGetUserData(w, s, Uuid) } 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 { SetHeader(w) var resp UserLoginResp resp.Code = -1 resp.Message = "uuid is nil" respstr, _ := json.Marshal(&resp) fmt.Fprint(w, string(respstr)) logger.Error("UserLogin uuid=0! failed!") return } result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("UserLogin , body:%v,uuid=%v", s, Uuid) HandlerLogin(w, s, Uuid) } func ReviewAllianceHandler(w http.ResponseWriter, r *http.Request) { //defer utils.PrintPanicStack() result, _ := ioutil.ReadAll(r.Body) r.Body.Close() s := string(result) logger.Info("ReviewAllianceHandler , body:%v", s) //go HandleReviewedAlliance(s) fmt.Fprint(w, "Success!") }