191 lines
5.3 KiB
Go
191 lines
5.3 KiB
Go
|
package handler
|
||
|
|
|
||
|
|
//
|
||
|
|
//func (this *InnerHandler) CdkeyGet(msg *http.Message) {
|
||
|
|
// var req = new(proto.MsgCdkeyGetReq)
|
||
|
|
// var err = msg.Read(req)
|
||
|
|
// if err != nil {
|
||
|
|
// this.logger.Error("Read message error, ", err)
|
||
|
|
// _ = msg.Reply(proto.RawErrMessageError)
|
||
|
|
// return
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// if this.logger.IsDebugEnabled() {
|
||
|
|
// this.logger.Debugf("[%s] <- CdkeyGet, req: %s", msg.R.RemoteAddr, util.ToJsonString(req))
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// if req.Key == "" {
|
||
|
|
// this.logger.Error("Parameter error, req.Key == \"\"")
|
||
|
|
// _ = msg.Reply(proto.RawErrParameterError)
|
||
|
|
// return
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// cdkey, err := this.userManager.GetCdkey(req.Key)
|
||
|
|
// if err != nil {
|
||
|
|
// _ = msg.Reply(err)
|
||
|
|
// return
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// var ack = &proto.MsgCdkeyGetAck{}
|
||
|
|
// if cdkey != nil {
|
||
|
|
// ack.Cdkey = cdkey.BuildMsgCdkey()
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// if this.logger.IsDebugEnabled() {
|
||
|
|
// this.logger.Debugf("[%s] -> CdkeyGet, ack: %s", msg.R.RemoteAddr, util.ToJsonString(ack))
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// _ = msg.Reply(ack)
|
||
|
|
//}
|
||
|
|
//
|
||
|
|
//func (this *InnerHandler) CdkeyList(msg *http.Message) {
|
||
|
|
// var req = new(proto.MsgCdkeyListReq)
|
||
|
|
// var err = msg.Read(req)
|
||
|
|
// if err != nil {
|
||
|
|
// this.logger.Error("Read message error, ", err)
|
||
|
|
// _ = msg.Reply(proto.RawErrMessageError)
|
||
|
|
// return
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// if this.logger.IsDebugEnabled() {
|
||
|
|
// this.logger.Debugf("[%s] <- CdkeyList, req: %s", msg.R.RemoteAddr, util.ToJsonString(req))
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// if req.PageNo == 0 || req.PageSize == 0 || req.PageSize > 50 {
|
||
|
|
// this.logger.Error("Parameter error, req.PageNo == 0 || req.PageSize == 0")
|
||
|
|
// _ = msg.Reply(proto.RawErrParameterError)
|
||
|
|
// return
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// total, list, err := this.userManager.PageableQueryCdkey(req.PageNo, req.PageSize, req.Channel)
|
||
|
|
// if err != nil {
|
||
|
|
// _ = msg.Reply(err)
|
||
|
|
// return
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// var ack = &proto.MsgCdkeyListAck{Total: total, List: util.SliceConvert(list, func(cdkey *logic.Cdkey) *proto.Cdkey {
|
||
|
|
// return cdkey.BuildMsgCdkey()
|
||
|
|
// })}
|
||
|
|
//
|
||
|
|
// if this.logger.IsDebugEnabled() {
|
||
|
|
// this.logger.Debugf("[%s] -> CdkeyList, ack: %s", msg.R.RemoteAddr, util.ToJsonString(ack))
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// _ = msg.Reply(ack)
|
||
|
|
// return
|
||
|
|
//}
|
||
|
|
//
|
||
|
|
//func (this *InnerHandler) CdkeyAdd(msg *http.Message) {
|
||
|
|
// var req = new(proto.MsgCdkeyAddReq)
|
||
|
|
// var err = msg.Read(req)
|
||
|
|
// if err != nil {
|
||
|
|
// this.logger.Error("Read message error, ", err)
|
||
|
|
// _ = msg.Reply(proto.RawErrMessageError)
|
||
|
|
// return
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// if this.logger.IsDebugEnabled() {
|
||
|
|
// this.logger.Debugf("[%s] <- CdkeyAdd, req: %s", msg.R.RemoteAddr, util.ToJsonString(req))
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// if !proto.CheckChannel(req.Channel) {
|
||
|
|
// this.logger.Error("Channel error, channel: ", req.Channel)
|
||
|
|
// _ = msg.Reply(proto.RawErrChannelError)
|
||
|
|
// return
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// if req.Key == "" || len(req.ItemId) == 0 || len(req.ItemNum) != len(req.ItemId) {
|
||
|
|
// this.logger.Error("Parameter error, req.Key == \"\" || len(req.ItemId) == 0 || len(req.ItemNum) != len(req.ItemId)")
|
||
|
|
// _ = msg.Reply(proto.RawErrParameterError)
|
||
|
|
// return
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// cdkey, err := this.userManager.AddCdkey(req.Channel, req.Key, req.ValidDays, req.ItemId, req.ItemNum)
|
||
|
|
// if err != nil {
|
||
|
|
// _ = msg.Reply(err)
|
||
|
|
// return
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// var ack = &proto.MsgCdkeyAddAck{Cdkey: cdkey.BuildMsgCdkey()}
|
||
|
|
//
|
||
|
|
// if this.logger.IsDebugEnabled() {
|
||
|
|
// this.logger.Debugf("[%s] -> CdkeyAdd, ack: %s", msg.R.RemoteAddr, util.ToJsonString(ack))
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// _ = msg.Reply(ack)
|
||
|
|
//}
|
||
|
|
//
|
||
|
|
//func (this *InnerHandler) CdkeyGenerate(msg *http.Message) {
|
||
|
|
// var req = new(proto.MsgCdkeyGenerateReq)
|
||
|
|
// var err = msg.Read(req)
|
||
|
|
// if err != nil {
|
||
|
|
// this.logger.Error("Read message error, ", err)
|
||
|
|
// _ = msg.Reply(proto.RawErrMessageError)
|
||
|
|
// return
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// if this.logger.IsDebugEnabled() {
|
||
|
|
// this.logger.Debugf("[%s] <- CdkeyGenerate, req: %s", msg.R.RemoteAddr, util.ToJsonString(req))
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// if !proto.CheckChannel(req.Channel) {
|
||
|
|
// this.logger.Error("Channel error, channel: ", req.Channel)
|
||
|
|
// _ = msg.Reply(proto.RawErrChannelError)
|
||
|
|
// return
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// if req.Count == 0 || len(req.ItemId) == 0 || len(req.ItemNum) != len(req.ItemId) {
|
||
|
|
// this.logger.Error("Parameter error, req.Count == 0 || len(req.ItemId) == 0 || len(req.ItemNum) != len(req.ItemId)")
|
||
|
|
// _ = msg.Reply(proto.RawErrParameterError)
|
||
|
|
// return
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// list, err := this.userManager.GenerateCdkey(req.Channel, req.Count, req.ValidDays, req.ItemId, req.ItemNum)
|
||
|
|
// if err != nil {
|
||
|
|
// _ = msg.Reply(err)
|
||
|
|
// return
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// var ack = &proto.MsgCdkeyGenerateAck{List: util.SliceConvert(list, func(cdkey *logic.Cdkey) *proto.Cdkey {
|
||
|
|
// return cdkey.BuildMsgCdkey()
|
||
|
|
// })}
|
||
|
|
//
|
||
|
|
// if this.logger.IsDebugEnabled() {
|
||
|
|
// this.logger.Debugf("[%s] -> CdkeyGenerate, ack: %s", msg.R.RemoteAddr, util.ToJsonString(ack))
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// _ = msg.Reply(ack)
|
||
|
|
//}
|
||
|
|
//
|
||
|
|
//func (this *InnerHandler) CdkeyDelete(msg *http.Message) {
|
||
|
|
// var req = new(proto.MsgCdkeyDeleteReq)
|
||
|
|
// var err = msg.Read(req)
|
||
|
|
// if err != nil {
|
||
|
|
// this.logger.Error("Read message error, ", err)
|
||
|
|
// _ = msg.Reply(proto.RawErrMessageError)
|
||
|
|
// return
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// if this.logger.IsDebugEnabled() {
|
||
|
|
// this.logger.Debugf("[%s] <- CdkeyDelete, req: %s", msg.R.RemoteAddr, util.ToJsonString(req))
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// if len(req.Keys) == 0 {
|
||
|
|
// this.logger.Error("Parameter error, len(req.Keys) == 0")
|
||
|
|
// _ = msg.Reply(proto.RawErrParameterError)
|
||
|
|
// return
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// err = this.userManager.DeleteCdkey(req.Keys)
|
||
|
|
// if err != nil {
|
||
|
|
// _ = msg.Reply(err)
|
||
|
|
// return
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// if this.logger.IsDebugEnabled() {
|
||
|
|
// this.logger.Debugf("[%s] -> CdkeyDelete, ack: %s", msg.R.RemoteAddr, util.ToJsonString(nil))
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// _ = msg.Reply(nil)
|
||
|
|
//}
|