Commit 3446a84f92b868de0c13afd06e84c0f3e18a6826
1 parent
f0162753
Exists in
master
提交
Showing
3 changed files
with
97 additions
and
0 deletions
Show diff stats
src/HttpServer/logic/datadef.go
| @@ -166,6 +166,26 @@ type UserloginResp struct { | @@ -166,6 +166,26 @@ type UserloginResp struct { | ||
| 166 | RetData UserloginData `json:"retData"` | 166 | RetData UserloginData `json:"retData"` |
| 167 | } | 167 | } |
| 168 | 168 | ||
| 169 | +type UpdatedataReq struct { | ||
| 170 | + Openid string `json:"openid"` | ||
| 171 | + PlayerData string `json:"playerData"` | ||
| 172 | +} | ||
| 173 | + | ||
| 174 | +type UpdatedataResp struct { | ||
| 175 | + ErrNum int `json:"errNum"` | ||
| 176 | + RetMsg string `json:"retMsg"` | ||
| 177 | +} | ||
| 178 | + | ||
| 179 | +type GetStampTimeData struct { | ||
| 180 | + Stamp int `json:"stamp"` | ||
| 181 | +} | ||
| 182 | + | ||
| 183 | +type GetStampTimeResp struct { | ||
| 184 | + ErrNum int `json:"errNum"` | ||
| 185 | + RetMsg string `json:"retMsg"` | ||
| 186 | + RetData GetStampTimeData `json:"retData"` | ||
| 187 | +} | ||
| 188 | + | ||
| 169 | //------------------------------------------------------------------------------------------------------ | 189 | //------------------------------------------------------------------------------------------------------ |
| 170 | 190 | ||
| 171 | type UserData struct { | 191 | type UserData struct { |
src/HttpServer/logic/httpserver.go
| @@ -51,11 +51,33 @@ func startServerHttpServe() { | @@ -51,11 +51,33 @@ func startServerHttpServe() { | ||
| 51 | http.HandleFunc("/daycs/dosign", Dosign) //签到 | 51 | http.HandleFunc("/daycs/dosign", Dosign) //签到 |
| 52 | http.HandleFunc("/daycs/getopenid", Getopenid) //获取openid | 52 | http.HandleFunc("/daycs/getopenid", Getopenid) //获取openid |
| 53 | http.HandleFunc("/daycs/userlogin", Userlogin) //登录 | 53 | http.HandleFunc("/daycs/userlogin", Userlogin) //登录 |
| 54 | + http.HandleFunc("/daycs/updatedata", Updatedata) //更新数据 | ||
| 55 | + http.HandleFunc("/daycs/getStampTime", GetStampTime) //登录 | ||
| 54 | 56 | ||
| 55 | err := http.ListenAndServe(conf.GetServerHttpAddrConf(), nil) | 57 | err := http.ListenAndServe(conf.GetServerHttpAddrConf(), nil) |
| 56 | CheckErr(err) | 58 | CheckErr(err) |
| 57 | } | 59 | } |
| 58 | 60 | ||
| 61 | +func GetStampTime(w http.ResponseWriter, r *http.Request) { | ||
| 62 | + result, _ := ioutil.ReadAll(r.Body) | ||
| 63 | + r.Body.Close() | ||
| 64 | + | ||
| 65 | + s := string(result) | ||
| 66 | + logger.Info("GetStampTime , body:%v", s) | ||
| 67 | + | ||
| 68 | + HandlerGetStampTime(w, s) | ||
| 69 | +} | ||
| 70 | + | ||
| 71 | +func Updatedata(w http.ResponseWriter, r *http.Request) { | ||
| 72 | + result, _ := ioutil.ReadAll(r.Body) | ||
| 73 | + r.Body.Close() | ||
| 74 | + | ||
| 75 | + s := string(result) | ||
| 76 | + logger.Info("Updatedata , body:%v", s) | ||
| 77 | + | ||
| 78 | + HandlerUpdatedata(w, s) | ||
| 79 | +} | ||
| 80 | + | ||
| 59 | func Userlogin(w http.ResponseWriter, r *http.Request) { | 81 | func Userlogin(w http.ResponseWriter, r *http.Request) { |
| 60 | result, _ := ioutil.ReadAll(r.Body) | 82 | result, _ := ioutil.ReadAll(r.Body) |
| 61 | r.Body.Close() | 83 | r.Body.Close() |
src/HttpServer/logic/logic.go
| @@ -8,8 +8,63 @@ import ( | @@ -8,8 +8,63 @@ import ( | ||
| 8 | "encoding/json" | 8 | "encoding/json" |
| 9 | "fmt" | 9 | "fmt" |
| 10 | "net/http" | 10 | "net/http" |
| 11 | + "time" | ||
| 11 | ) | 12 | ) |
| 12 | 13 | ||
| 14 | +func HandlerGetStampTime(w http.ResponseWriter, data string) { | ||
| 15 | + SetHeader(w) | ||
| 16 | + var resp GetStampTimeResp | ||
| 17 | + resp.ErrNum = 0 | ||
| 18 | + resp.RetMsg = "success" | ||
| 19 | + | ||
| 20 | + for { | ||
| 21 | + | ||
| 22 | + resp.RetData.Stamp = int(time.Now().Unix()) | ||
| 23 | + | ||
| 24 | + break | ||
| 25 | + } | ||
| 26 | + //回包 | ||
| 27 | + respstr, _ := json.Marshal(&resp) | ||
| 28 | + fmt.Fprint(w, string(respstr)) | ||
| 29 | +} | ||
| 30 | + | ||
| 31 | +func HandlerUpdatedata(w http.ResponseWriter, data string) { | ||
| 32 | + SetHeader(w) | ||
| 33 | + var resp UpdatedataResp | ||
| 34 | + resp.ErrNum = 0 | ||
| 35 | + resp.RetMsg = "success" | ||
| 36 | + var rdata UpdatedataReq | ||
| 37 | + err := json.Unmarshal([]byte(data), &rdata) | ||
| 38 | + for { | ||
| 39 | + if err != nil { | ||
| 40 | + logger.Info("json decode HandlerUpdatedata data failed:%v,for:%v", err, data) | ||
| 41 | + resp.RetMsg = "json解析失败" | ||
| 42 | + resp.ErrNum = ERROR_UNMASH_JSONFAILED | ||
| 43 | + break | ||
| 44 | + } | ||
| 45 | + | ||
| 46 | + uinfo, err := GetUserInfo(rdata.Openid) | ||
| 47 | + if err != nil { | ||
| 48 | + logger.Info(" HandlerDosign getdata failed:%v,for:%v", err, data) | ||
| 49 | + resp.RetMsg = "服务器读取数据失败" | ||
| 50 | + resp.ErrNum = ERROR_SERVER_FAILED | ||
| 51 | + break | ||
| 52 | + } | ||
| 53 | + | ||
| 54 | + uinfo.PlayerData = rdata.PlayerData | ||
| 55 | + | ||
| 56 | + err = SaveUserInfo(uinfo) | ||
| 57 | + if err != nil { | ||
| 58 | + logger.Error("HandlerUpdatedata failed err=%v", err) | ||
| 59 | + } | ||
| 60 | + | ||
| 61 | + break | ||
| 62 | + } | ||
| 63 | + //回包 | ||
| 64 | + respstr, _ := json.Marshal(&resp) | ||
| 65 | + fmt.Fprint(w, string(respstr)) | ||
| 66 | +} | ||
| 67 | + | ||
| 13 | func HandlerUserlogin(w http.ResponseWriter, data string) { | 68 | func HandlerUserlogin(w http.ResponseWriter, data string) { |
| 14 | SetHeader(w) | 69 | SetHeader(w) |
| 15 | var resp UserloginResp | 70 | var resp UserloginResp |