service

Documentation

Index

• func CheckUserDeliveryInfo(ctx context.Context, req *users.CheckUserDeliveryInfoRequest) (retCode int)
• func CheckUserExist(ctx context.Context, countryCode, phone string) (bool, int)
• func CheckUserIdentity(ctx context.Context, req *users.CheckUserIdentityRequest) int
• func CheckUserState(ctx context.Context, req *users.CheckUserStateRequest) (retCode int)
• func FindUserInfo(ctx context.Context, req *users.FindUserInfoRequest) (result []*users.UserInfoMain, retCode int)
• func GenAccountId() string
• func GenInviterCode() string
• func GetMerchantsMaterial(ctx context.Context, req *users.GetMerchantsMaterialRequest) (*mysql.Merchant, int)
• func GetUserAccountId(ctx context.Context, req *users.GetUserAccountIdRequest) (result []*users.UserAccountInfo, retCode int)
• func GetUserDeliveryInfo(ctx context.Context, req *users.GetUserDeliveryInfoRequest) ([]*users.UserDeliveryInfo, int)
• func GetUserInfo(ctx context.Context, uid int) (*mysql.User, int)
• func GetUserInfoByInviteCode(ctx context.Context, inviteCode string) (*mysql.User, int)
• func GetUserInfoByPhone(ctx context.Context, countryCode, phone string) (*mysql.User, int)
• func ListUserInfo(ctx context.Context, req *users.ListUserInfoRequest) (result []*users.MobilePhone, retCode int)
• func LoginUser(ctx context.Context, req *users.LoginUserRequest) (string, int)
• func MerchantsMaterial(ctx context.Context, req *users.MerchantsMaterialRequest) (int, int)
• func ModifyUserDeliveryInfo(ctx context.Context, req *users.ModifyUserDeliveryInfoRequest) int
• func PasswordReset(ctx context.Context, req *users.PasswordResetRequest) int
• func RegisterUser(ctx context.Context, req *users.RegisterRequest) (args.RegisterResult, int)
• func UpdateUserLoginState(ctx context.Context, req *users.UpdateUserLoginStateRequest) int
• func UserAccountCharge(ctx context.Context, req *users.UserAccountChargeRequest) (retCode int)
• type PushMsgTag
• type PushNoticeService
  • func NewPushNoticeService(server *queue.MachineryQueue, tag PushMsgTag) *PushNoticeService
  • func (p *PushNoticeService) GetTaskState(taskId string) (*tasks.TaskState, error)
  • func (p *PushNoticeService) PushMessage(ctx context.Context, args interface{}) (string, int)

Functions

func CheckUserDeliveryInfo

func CheckUserDeliveryInfo(ctx context.Context, req *users.CheckUserDeliveryInfoRequest) (retCode int)

func CheckUserExist

func CheckUserExist(ctx context.Context, countryCode, phone string) (bool, int)

func CheckUserIdentity

func CheckUserIdentity(ctx context.Context, req *users.CheckUserIdentityRequest) int

func CheckUserState

func CheckUserState(ctx context.Context, req *users.CheckUserStateRequest) (retCode int)

func FindUserInfo

func FindUserInfo(ctx context.Context, req *users.FindUserInfoRequest) (result []*users.UserInfoMain, retCode int)

func GenAccountId

func GenAccountId() string

func GenInviterCode

func GenInviterCode() string

func GetMerchantsMaterial

func GetMerchantsMaterial(ctx context.Context, req *users.GetMerchantsMaterialRequest) (*mysql.Merchant, int)

func GetUserAccountId

func GetUserAccountId(ctx context.Context, req *users.GetUserAccountIdRequest) (result []*users.UserAccountInfo, retCode int)

func GetUserDeliveryInfo

func GetUserDeliveryInfo(ctx context.Context, req *users.GetUserDeliveryInfoRequest) ([]*users.UserDeliveryInfo, int)

func GetUserInfo

func GetUserInfo(ctx context.Context, uid int) (*mysql.User, int)

func GetUserInfoByInviteCode

func GetUserInfoByInviteCode(ctx context.Context, inviteCode string) (*mysql.User, int)

func GetUserInfoByPhone

func GetUserInfoByPhone(ctx context.Context, countryCode, phone string) (*mysql.User, int)

func ListUserInfo

func ListUserInfo(ctx context.Context, req *users.ListUserInfoRequest) (result []*users.MobilePhone, retCode int)

func LoginUser

func LoginUser(ctx context.Context, req *users.LoginUserRequest) (string, int)

func MerchantsMaterial

func MerchantsMaterial(ctx context.Context, req *users.MerchantsMaterialRequest) (int, int)

func ModifyUserDeliveryInfo

func ModifyUserDeliveryInfo(ctx context.Context, req *users.ModifyUserDeliveryInfoRequest) int

func PasswordReset

func PasswordReset(ctx context.Context, req *users.PasswordResetRequest) int

func RegisterUser

func RegisterUser(ctx context.Context, req *users.RegisterRequest) (args.RegisterResult, int)

func UpdateUserLoginState

func UpdateUserLoginState(ctx context.Context, req *users.UpdateUserLoginStateRequest) int

func UserAccountCharge

func UserAccountCharge(ctx context.Context, req *users.UserAccountChargeRequest) (retCode int)

Types

type PushMsgTag

type PushMsgTag struct {
	DeliveryTag    string
	DeliveryErrTag string
	RetryCount     int
	RetryTimeout   int
}

type PushNoticeService

type PushNoticeService struct {
	// contains filtered or unexported fields
}

func NewPushNoticeService

func NewPushNoticeService(server *queue.MachineryQueue, tag PushMsgTag) *PushNoticeService

func (*PushNoticeService) GetTaskState

func (p *PushNoticeService) GetTaskState(taskId string) (*tasks.TaskState, error)

func (*PushNoticeService) PushMessage

func (p *PushNoticeService) PushMessage(ctx context.Context, args interface{}) (string, int)