handler.go 1.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. package handler
  2. import (
  3. "bet24.com/servers/micros/remotemessage/handler/remotemessage"
  4. pb "bet24.com/servers/micros/remotemessage/proto"
  5. "context"
  6. "fmt"
  7. )
  8. var instance *ServiceHandler
  9. func GetInstance() *ServiceHandler {
  10. if instance == nil {
  11. instance = newHandler()
  12. }
  13. return instance
  14. }
  15. func Dump(cmd, param1, param2 string) {
  16. GetInstance().dump(cmd, param1, param2)
  17. }
  18. func newHandler() *ServiceHandler {
  19. ret := new(ServiceHandler)
  20. ret.ctor()
  21. return ret
  22. }
  23. type ServiceHandler struct{}
  24. func (h *ServiceHandler) ctor() {
  25. }
  26. func (d *ServiceHandler) dump(cmd, param1, param2 string) {
  27. remotemessage.Dump(cmd, param1)
  28. }
  29. func (h *ServiceHandler) SayHello(ctx context.Context, req *pb.Request, rsp *pb.Response) error {
  30. rsp.Data = fmt.Sprintf("Hello from %s:%s", pb.ServiceName, req.Name)
  31. return nil
  32. }
  33. func (h *ServiceHandler) SetUserToken(ctx context.Context, req *pb.Request, rsp *pb.Response) error {
  34. remotemessage.SetUserToken(req.UserId, req.DeviceType, req.Token)
  35. return nil
  36. }
  37. func (h *ServiceHandler) SendRemoteMessage(ctx context.Context, req *pb.Request, rsp *pb.Response) error {
  38. remotemessage.SendRemoteMessage(req.UserIds, req.Title, req.Content)
  39. return nil
  40. }