diff --git a/pkg/ws/types.go b/pkg/ws/types.go index e99db1f..b030aa6 100644 --- a/pkg/ws/types.go +++ b/pkg/ws/types.go @@ -12,13 +12,15 @@ const ( RedisKeyTaskLights = "task:lights:" RedisChannelQRPush = "ws:qr:push" - StatusPending = 1 // 待扫码 - StatusScanned = 2 // 已扫码未登录 - StatusLogined = 3 // 已扫码已登录 + StatusPending = 1 // 待扫码 + StatusScanned = 2 // 已扫码未登录 + StatusLogined = 3 // 已扫码已登录 + StatusUsePosition = 4 //使用位置 WsTypeLogin = 1 // 同意登录 WsTypeScanned = 2 // 拒绝授权 / 拒绝登录 WsTypeScan = 3 // 进入扫码页通知 + WsUsePosition = 4 //使用位置 SessionTTL = 5 * time.Minute diff --git a/rpc/equipment/equipment.pb b/rpc/equipment/equipment.pb index 24792fb..9f39d9c 100644 Binary files a/rpc/equipment/equipment.pb and b/rpc/equipment/equipment.pb differ diff --git a/rpc/equipment/equipment.proto b/rpc/equipment/equipment.proto index 0329f6c..4b84413 100644 --- a/rpc/equipment/equipment.proto +++ b/rpc/equipment/equipment.proto @@ -48,6 +48,11 @@ message IdStringRequest { string mask_id = 1; } +message StoreIdStringRequest { + string mask_id = 1; + int64 user_id = 2; +} + message StatusRequest { int64 id = 1; int32 status = 2; @@ -429,6 +434,21 @@ service Equipment { }; }; + // 门店端获取授权列表 + rpc AuthorizationStoreItems(EmptyRequest) returns(Response){ + option (google.api.http) = { + post: "/api/v3/device/authorization/store/items" + body: "*" + }; + }; + + rpc ApiStoreCheckMask(StoreIdStringRequest) returns(Response){ + option (google.api.http) = { + post: "/api/v3/device/store/check/mask" + body: "*" + }; + }; + rpc AuthorizationCode(EmptyRequest) returns(Response){ option (google.api.http) = { post: "/api/v3/device/authorization/code" diff --git a/rpc/equipment/pb/equipment.pb.go b/rpc/equipment/pb/equipment.pb.go index e67e790..503f3ea 100644 --- a/rpc/equipment/pb/equipment.pb.go +++ b/rpc/equipment/pb/equipment.pb.go @@ -438,6 +438,58 @@ func (x *IdStringRequest) GetMaskId() string { return "" } +type StoreIdStringRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + MaskId string `protobuf:"bytes,1,opt,name=mask_id,json=maskId,proto3" json:"mask_id,omitempty"` + UserId int64 `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *StoreIdStringRequest) Reset() { + *x = StoreIdStringRequest{} + mi := &file_equipment_equipment_proto_msgTypes[6] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *StoreIdStringRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*StoreIdStringRequest) ProtoMessage() {} + +func (x *StoreIdStringRequest) ProtoReflect() protoreflect.Message { + mi := &file_equipment_equipment_proto_msgTypes[6] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use StoreIdStringRequest.ProtoReflect.Descriptor instead. +func (*StoreIdStringRequest) Descriptor() ([]byte, []int) { + return file_equipment_equipment_proto_rawDescGZIP(), []int{6} +} + +func (x *StoreIdStringRequest) GetMaskId() string { + if x != nil { + return x.MaskId + } + return "" +} + +func (x *StoreIdStringRequest) GetUserId() int64 { + if x != nil { + return x.UserId + } + return 0 +} + type StatusRequest struct { state protoimpl.MessageState `protogen:"open.v1"` Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` @@ -449,7 +501,7 @@ type StatusRequest struct { func (x *StatusRequest) Reset() { *x = StatusRequest{} - mi := &file_equipment_equipment_proto_msgTypes[6] + mi := &file_equipment_equipment_proto_msgTypes[7] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -461,7 +513,7 @@ func (x *StatusRequest) String() string { func (*StatusRequest) ProtoMessage() {} func (x *StatusRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[6] + mi := &file_equipment_equipment_proto_msgTypes[7] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -474,7 +526,7 @@ func (x *StatusRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead. func (*StatusRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{6} + return file_equipment_equipment_proto_rawDescGZIP(), []int{7} } func (x *StatusRequest) GetId() int64 { @@ -519,7 +571,7 @@ type MaskItemsRequest struct { func (x *MaskItemsRequest) Reset() { *x = MaskItemsRequest{} - mi := &file_equipment_equipment_proto_msgTypes[7] + mi := &file_equipment_equipment_proto_msgTypes[8] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -531,7 +583,7 @@ func (x *MaskItemsRequest) String() string { func (*MaskItemsRequest) ProtoMessage() {} func (x *MaskItemsRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[7] + mi := &file_equipment_equipment_proto_msgTypes[8] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -544,7 +596,7 @@ func (x *MaskItemsRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use MaskItemsRequest.ProtoReflect.Descriptor instead. func (*MaskItemsRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{7} + return file_equipment_equipment_proto_rawDescGZIP(), []int{8} } func (x *MaskItemsRequest) GetPage() int32 { @@ -650,7 +702,7 @@ type BeansItemsRequest struct { func (x *BeansItemsRequest) Reset() { *x = BeansItemsRequest{} - mi := &file_equipment_equipment_proto_msgTypes[8] + mi := &file_equipment_equipment_proto_msgTypes[9] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -662,7 +714,7 @@ func (x *BeansItemsRequest) String() string { func (*BeansItemsRequest) ProtoMessage() {} func (x *BeansItemsRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[8] + mi := &file_equipment_equipment_proto_msgTypes[9] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -675,7 +727,7 @@ func (x *BeansItemsRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use BeansItemsRequest.ProtoReflect.Descriptor instead. func (*BeansItemsRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{8} + return file_equipment_equipment_proto_rawDescGZIP(), []int{9} } func (x *BeansItemsRequest) GetPage() int32 { @@ -717,7 +769,7 @@ type ApiBindAddRequest struct { func (x *ApiBindAddRequest) Reset() { *x = ApiBindAddRequest{} - mi := &file_equipment_equipment_proto_msgTypes[9] + mi := &file_equipment_equipment_proto_msgTypes[10] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -729,7 +781,7 @@ func (x *ApiBindAddRequest) String() string { func (*ApiBindAddRequest) ProtoMessage() {} func (x *ApiBindAddRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[9] + mi := &file_equipment_equipment_proto_msgTypes[10] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -742,7 +794,7 @@ func (x *ApiBindAddRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ApiBindAddRequest.ProtoReflect.Descriptor instead. func (*ApiBindAddRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{9} + return file_equipment_equipment_proto_rawDescGZIP(), []int{10} } func (x *ApiBindAddRequest) GetHostNickname() string { @@ -780,7 +832,7 @@ type InternalBindAddRequest struct { func (x *InternalBindAddRequest) Reset() { *x = InternalBindAddRequest{} - mi := &file_equipment_equipment_proto_msgTypes[10] + mi := &file_equipment_equipment_proto_msgTypes[11] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -792,7 +844,7 @@ func (x *InternalBindAddRequest) String() string { func (*InternalBindAddRequest) ProtoMessage() {} func (x *InternalBindAddRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[10] + mi := &file_equipment_equipment_proto_msgTypes[11] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -805,7 +857,7 @@ func (x *InternalBindAddRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use InternalBindAddRequest.ProtoReflect.Descriptor instead. func (*InternalBindAddRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{10} + return file_equipment_equipment_proto_rawDescGZIP(), []int{11} } func (x *InternalBindAddRequest) GetUserId() int64 { @@ -863,7 +915,7 @@ type InternalBindInfoRequest struct { func (x *InternalBindInfoRequest) Reset() { *x = InternalBindInfoRequest{} - mi := &file_equipment_equipment_proto_msgTypes[11] + mi := &file_equipment_equipment_proto_msgTypes[12] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -875,7 +927,7 @@ func (x *InternalBindInfoRequest) String() string { func (*InternalBindInfoRequest) ProtoMessage() {} func (x *InternalBindInfoRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[11] + mi := &file_equipment_equipment_proto_msgTypes[12] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -888,7 +940,7 @@ func (x *InternalBindInfoRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use InternalBindInfoRequest.ProtoReflect.Descriptor instead. func (*InternalBindInfoRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{11} + return file_equipment_equipment_proto_rawDescGZIP(), []int{12} } func (x *InternalBindInfoRequest) GetUserId() int64 { @@ -937,7 +989,7 @@ type ApiBindInfoRequest struct { func (x *ApiBindInfoRequest) Reset() { *x = ApiBindInfoRequest{} - mi := &file_equipment_equipment_proto_msgTypes[12] + mi := &file_equipment_equipment_proto_msgTypes[13] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -949,7 +1001,7 @@ func (x *ApiBindInfoRequest) String() string { func (*ApiBindInfoRequest) ProtoMessage() {} func (x *ApiBindInfoRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[12] + mi := &file_equipment_equipment_proto_msgTypes[13] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -962,7 +1014,7 @@ func (x *ApiBindInfoRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ApiBindInfoRequest.ProtoReflect.Descriptor instead. func (*ApiBindInfoRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{12} + return file_equipment_equipment_proto_rawDescGZIP(), []int{13} } func (x *ApiBindInfoRequest) GetId() int64 { @@ -996,7 +1048,7 @@ type ApiBindUpdateRequest struct { func (x *ApiBindUpdateRequest) Reset() { *x = ApiBindUpdateRequest{} - mi := &file_equipment_equipment_proto_msgTypes[13] + mi := &file_equipment_equipment_proto_msgTypes[14] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1008,7 +1060,7 @@ func (x *ApiBindUpdateRequest) String() string { func (*ApiBindUpdateRequest) ProtoMessage() {} func (x *ApiBindUpdateRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[13] + mi := &file_equipment_equipment_proto_msgTypes[14] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1021,7 +1073,7 @@ func (x *ApiBindUpdateRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ApiBindUpdateRequest.ProtoReflect.Descriptor instead. func (*ApiBindUpdateRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{13} + return file_equipment_equipment_proto_rawDescGZIP(), []int{14} } func (x *ApiBindUpdateRequest) GetId() int64 { @@ -1049,7 +1101,7 @@ type ApiEditNameRequest struct { func (x *ApiEditNameRequest) Reset() { *x = ApiEditNameRequest{} - mi := &file_equipment_equipment_proto_msgTypes[14] + mi := &file_equipment_equipment_proto_msgTypes[15] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1061,7 +1113,7 @@ func (x *ApiEditNameRequest) String() string { func (*ApiEditNameRequest) ProtoMessage() {} func (x *ApiEditNameRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[14] + mi := &file_equipment_equipment_proto_msgTypes[15] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1074,7 +1126,7 @@ func (x *ApiEditNameRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ApiEditNameRequest.ProtoReflect.Descriptor instead. func (*ApiEditNameRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{14} + return file_equipment_equipment_proto_rawDescGZIP(), []int{15} } func (x *ApiEditNameRequest) GetHostCode() string { @@ -1108,7 +1160,7 @@ type AuthorizationBindRequest struct { func (x *AuthorizationBindRequest) Reset() { *x = AuthorizationBindRequest{} - mi := &file_equipment_equipment_proto_msgTypes[15] + mi := &file_equipment_equipment_proto_msgTypes[16] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1120,7 +1172,7 @@ func (x *AuthorizationBindRequest) String() string { func (*AuthorizationBindRequest) ProtoMessage() {} func (x *AuthorizationBindRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[15] + mi := &file_equipment_equipment_proto_msgTypes[16] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1133,7 +1185,7 @@ func (x *AuthorizationBindRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use AuthorizationBindRequest.ProtoReflect.Descriptor instead. func (*AuthorizationBindRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{15} + return file_equipment_equipment_proto_rawDescGZIP(), []int{16} } func (x *AuthorizationBindRequest) GetStoreId() int64 { @@ -1159,7 +1211,7 @@ type AuthorizationCancelRequest struct { func (x *AuthorizationCancelRequest) Reset() { *x = AuthorizationCancelRequest{} - mi := &file_equipment_equipment_proto_msgTypes[16] + mi := &file_equipment_equipment_proto_msgTypes[17] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1171,7 +1223,7 @@ func (x *AuthorizationCancelRequest) String() string { func (*AuthorizationCancelRequest) ProtoMessage() {} func (x *AuthorizationCancelRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[16] + mi := &file_equipment_equipment_proto_msgTypes[17] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1184,7 +1236,7 @@ func (x *AuthorizationCancelRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use AuthorizationCancelRequest.ProtoReflect.Descriptor instead. func (*AuthorizationCancelRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{16} + return file_equipment_equipment_proto_rawDescGZIP(), []int{17} } func (x *AuthorizationCancelRequest) GetStoreId() int64 { @@ -1204,7 +1256,7 @@ type AuthorizationControlRequest struct { func (x *AuthorizationControlRequest) Reset() { *x = AuthorizationControlRequest{} - mi := &file_equipment_equipment_proto_msgTypes[17] + mi := &file_equipment_equipment_proto_msgTypes[18] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1216,7 +1268,7 @@ func (x *AuthorizationControlRequest) String() string { func (*AuthorizationControlRequest) ProtoMessage() {} func (x *AuthorizationControlRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[17] + mi := &file_equipment_equipment_proto_msgTypes[18] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1229,7 +1281,7 @@ func (x *AuthorizationControlRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use AuthorizationControlRequest.ProtoReflect.Descriptor instead. func (*AuthorizationControlRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{17} + return file_equipment_equipment_proto_rawDescGZIP(), []int{18} } func (x *AuthorizationControlRequest) GetStoreId() int64 { @@ -1256,7 +1308,7 @@ type ApiUnBindRequest struct { func (x *ApiUnBindRequest) Reset() { *x = ApiUnBindRequest{} - mi := &file_equipment_equipment_proto_msgTypes[18] + mi := &file_equipment_equipment_proto_msgTypes[19] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1268,7 +1320,7 @@ func (x *ApiUnBindRequest) String() string { func (*ApiUnBindRequest) ProtoMessage() {} func (x *ApiUnBindRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[18] + mi := &file_equipment_equipment_proto_msgTypes[19] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1281,7 +1333,7 @@ func (x *ApiUnBindRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ApiUnBindRequest.ProtoReflect.Descriptor instead. func (*ApiUnBindRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{18} + return file_equipment_equipment_proto_rawDescGZIP(), []int{19} } func (x *ApiUnBindRequest) GetHostCode() string { @@ -1306,7 +1358,7 @@ type EmptyRequest struct { func (x *EmptyRequest) Reset() { *x = EmptyRequest{} - mi := &file_equipment_equipment_proto_msgTypes[19] + mi := &file_equipment_equipment_proto_msgTypes[20] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1318,7 +1370,7 @@ func (x *EmptyRequest) String() string { func (*EmptyRequest) ProtoMessage() {} func (x *EmptyRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[19] + mi := &file_equipment_equipment_proto_msgTypes[20] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1331,7 +1383,7 @@ func (x *EmptyRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use EmptyRequest.ProtoReflect.Descriptor instead. func (*EmptyRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{19} + return file_equipment_equipment_proto_rawDescGZIP(), []int{20} } type ApiBindExpiryRequest struct { @@ -1345,7 +1397,7 @@ type ApiBindExpiryRequest struct { func (x *ApiBindExpiryRequest) Reset() { *x = ApiBindExpiryRequest{} - mi := &file_equipment_equipment_proto_msgTypes[20] + mi := &file_equipment_equipment_proto_msgTypes[21] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1357,7 +1409,7 @@ func (x *ApiBindExpiryRequest) String() string { func (*ApiBindExpiryRequest) ProtoMessage() {} func (x *ApiBindExpiryRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[20] + mi := &file_equipment_equipment_proto_msgTypes[21] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1370,7 +1422,7 @@ func (x *ApiBindExpiryRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ApiBindExpiryRequest.ProtoReflect.Descriptor instead. func (*ApiBindExpiryRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{20} + return file_equipment_equipment_proto_rawDescGZIP(), []int{21} } func (x *ApiBindExpiryRequest) GetHostCode() string { @@ -1404,7 +1456,7 @@ type ApiBindExpiryGetRequest struct { func (x *ApiBindExpiryGetRequest) Reset() { *x = ApiBindExpiryGetRequest{} - mi := &file_equipment_equipment_proto_msgTypes[21] + mi := &file_equipment_equipment_proto_msgTypes[22] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1416,7 +1468,7 @@ func (x *ApiBindExpiryGetRequest) String() string { func (*ApiBindExpiryGetRequest) ProtoMessage() {} func (x *ApiBindExpiryGetRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[21] + mi := &file_equipment_equipment_proto_msgTypes[22] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1429,7 +1481,7 @@ func (x *ApiBindExpiryGetRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ApiBindExpiryGetRequest.ProtoReflect.Descriptor instead. func (*ApiBindExpiryGetRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{21} + return file_equipment_equipment_proto_rawDescGZIP(), []int{22} } func (x *ApiBindExpiryGetRequest) GetHostCode() string { @@ -1456,7 +1508,7 @@ type ApiBeansItemsRequest struct { func (x *ApiBeansItemsRequest) Reset() { *x = ApiBeansItemsRequest{} - mi := &file_equipment_equipment_proto_msgTypes[22] + mi := &file_equipment_equipment_proto_msgTypes[23] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1468,7 +1520,7 @@ func (x *ApiBeansItemsRequest) String() string { func (*ApiBeansItemsRequest) ProtoMessage() {} func (x *ApiBeansItemsRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[22] + mi := &file_equipment_equipment_proto_msgTypes[23] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1481,7 +1533,7 @@ func (x *ApiBeansItemsRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ApiBeansItemsRequest.ProtoReflect.Descriptor instead. func (*ApiBeansItemsRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{22} + return file_equipment_equipment_proto_rawDescGZIP(), []int{23} } func (x *ApiBeansItemsRequest) GetPage() int32 { @@ -1508,7 +1560,7 @@ type ApiBeansAddRequest struct { func (x *ApiBeansAddRequest) Reset() { *x = ApiBeansAddRequest{} - mi := &file_equipment_equipment_proto_msgTypes[23] + mi := &file_equipment_equipment_proto_msgTypes[24] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1520,7 +1572,7 @@ func (x *ApiBeansAddRequest) String() string { func (*ApiBeansAddRequest) ProtoMessage() {} func (x *ApiBeansAddRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[23] + mi := &file_equipment_equipment_proto_msgTypes[24] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1533,7 +1585,7 @@ func (x *ApiBeansAddRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ApiBeansAddRequest.ProtoReflect.Descriptor instead. func (*ApiBeansAddRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{23} + return file_equipment_equipment_proto_rawDescGZIP(), []int{24} } func (x *ApiBeansAddRequest) GetImage() string { @@ -1570,7 +1622,7 @@ type ApiMaskAddRequest struct { func (x *ApiMaskAddRequest) Reset() { *x = ApiMaskAddRequest{} - mi := &file_equipment_equipment_proto_msgTypes[24] + mi := &file_equipment_equipment_proto_msgTypes[25] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1582,7 +1634,7 @@ func (x *ApiMaskAddRequest) String() string { func (*ApiMaskAddRequest) ProtoMessage() {} func (x *ApiMaskAddRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[24] + mi := &file_equipment_equipment_proto_msgTypes[25] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1595,7 +1647,7 @@ func (x *ApiMaskAddRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ApiMaskAddRequest.ProtoReflect.Descriptor instead. func (*ApiMaskAddRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{24} + return file_equipment_equipment_proto_rawDescGZIP(), []int{25} } func (x *ApiMaskAddRequest) GetFacialMaskId() string { @@ -1701,7 +1753,7 @@ type ApiMaskUseRequest struct { func (x *ApiMaskUseRequest) Reset() { *x = ApiMaskUseRequest{} - mi := &file_equipment_equipment_proto_msgTypes[25] + mi := &file_equipment_equipment_proto_msgTypes[26] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1713,7 +1765,7 @@ func (x *ApiMaskUseRequest) String() string { func (*ApiMaskUseRequest) ProtoMessage() {} func (x *ApiMaskUseRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[25] + mi := &file_equipment_equipment_proto_msgTypes[26] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1726,7 +1778,7 @@ func (x *ApiMaskUseRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ApiMaskUseRequest.ProtoReflect.Descriptor instead. func (*ApiMaskUseRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{25} + return file_equipment_equipment_proto_rawDescGZIP(), []int{26} } func (x *ApiMaskUseRequest) GetFacialMaskId() string { @@ -1817,7 +1869,7 @@ type ApiMaskUsedItemsRequest struct { func (x *ApiMaskUsedItemsRequest) Reset() { *x = ApiMaskUsedItemsRequest{} - mi := &file_equipment_equipment_proto_msgTypes[26] + mi := &file_equipment_equipment_proto_msgTypes[27] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1829,7 +1881,7 @@ func (x *ApiMaskUsedItemsRequest) String() string { func (*ApiMaskUsedItemsRequest) ProtoMessage() {} func (x *ApiMaskUsedItemsRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[26] + mi := &file_equipment_equipment_proto_msgTypes[27] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1842,7 +1894,7 @@ func (x *ApiMaskUsedItemsRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ApiMaskUsedItemsRequest.ProtoReflect.Descriptor instead. func (*ApiMaskUsedItemsRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{26} + return file_equipment_equipment_proto_rawDescGZIP(), []int{27} } func (x *ApiMaskUsedItemsRequest) GetFacialMaskId() string { @@ -1877,7 +1929,7 @@ type BindExpiryRequest struct { func (x *BindExpiryRequest) Reset() { *x = BindExpiryRequest{} - mi := &file_equipment_equipment_proto_msgTypes[27] + mi := &file_equipment_equipment_proto_msgTypes[28] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1889,7 +1941,7 @@ func (x *BindExpiryRequest) String() string { func (*BindExpiryRequest) ProtoMessage() {} func (x *BindExpiryRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[27] + mi := &file_equipment_equipment_proto_msgTypes[28] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1902,7 +1954,7 @@ func (x *BindExpiryRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use BindExpiryRequest.ProtoReflect.Descriptor instead. func (*BindExpiryRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{27} + return file_equipment_equipment_proto_rawDescGZIP(), []int{28} } func (x *BindExpiryRequest) GetId() int64 { @@ -1936,7 +1988,7 @@ type InternalUserInfoRequest struct { func (x *InternalUserInfoRequest) Reset() { *x = InternalUserInfoRequest{} - mi := &file_equipment_equipment_proto_msgTypes[28] + mi := &file_equipment_equipment_proto_msgTypes[29] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1948,7 +2000,7 @@ func (x *InternalUserInfoRequest) String() string { func (*InternalUserInfoRequest) ProtoMessage() {} func (x *InternalUserInfoRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[28] + mi := &file_equipment_equipment_proto_msgTypes[29] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1961,7 +2013,7 @@ func (x *InternalUserInfoRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use InternalUserInfoRequest.ProtoReflect.Descriptor instead. func (*InternalUserInfoRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{28} + return file_equipment_equipment_proto_rawDescGZIP(), []int{29} } func (x *InternalUserInfoRequest) GetUserId() int64 { @@ -1987,7 +2039,7 @@ type InternalResponse struct { func (x *InternalResponse) Reset() { *x = InternalResponse{} - mi := &file_equipment_equipment_proto_msgTypes[29] + mi := &file_equipment_equipment_proto_msgTypes[30] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1999,7 +2051,7 @@ func (x *InternalResponse) String() string { func (*InternalResponse) ProtoMessage() {} func (x *InternalResponse) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[29] + mi := &file_equipment_equipment_proto_msgTypes[30] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2012,7 +2064,7 @@ func (x *InternalResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use InternalResponse.ProtoReflect.Descriptor instead. func (*InternalResponse) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{29} + return file_equipment_equipment_proto_rawDescGZIP(), []int{30} } func (x *InternalResponse) GetId() int64 { @@ -2033,7 +2085,7 @@ type SetExpiryRequest struct { func (x *SetExpiryRequest) Reset() { *x = SetExpiryRequest{} - mi := &file_equipment_equipment_proto_msgTypes[30] + mi := &file_equipment_equipment_proto_msgTypes[31] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2045,7 +2097,7 @@ func (x *SetExpiryRequest) String() string { func (*SetExpiryRequest) ProtoMessage() {} func (x *SetExpiryRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[30] + mi := &file_equipment_equipment_proto_msgTypes[31] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2058,7 +2110,7 @@ func (x *SetExpiryRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use SetExpiryRequest.ProtoReflect.Descriptor instead. func (*SetExpiryRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{30} + return file_equipment_equipment_proto_rawDescGZIP(), []int{31} } func (x *SetExpiryRequest) GetId() int64 { @@ -2091,7 +2143,7 @@ type UserBindRequest struct { func (x *UserBindRequest) Reset() { *x = UserBindRequest{} - mi := &file_equipment_equipment_proto_msgTypes[31] + mi := &file_equipment_equipment_proto_msgTypes[32] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2103,7 +2155,7 @@ func (x *UserBindRequest) String() string { func (*UserBindRequest) ProtoMessage() {} func (x *UserBindRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[31] + mi := &file_equipment_equipment_proto_msgTypes[32] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2116,7 +2168,7 @@ func (x *UserBindRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use UserBindRequest.ProtoReflect.Descriptor instead. func (*UserBindRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{31} + return file_equipment_equipment_proto_rawDescGZIP(), []int{32} } func (x *UserBindRequest) GetId() int64 { @@ -2136,7 +2188,7 @@ type ApiVersionRequest struct { func (x *ApiVersionRequest) Reset() { *x = ApiVersionRequest{} - mi := &file_equipment_equipment_proto_msgTypes[32] + mi := &file_equipment_equipment_proto_msgTypes[33] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2148,7 +2200,7 @@ func (x *ApiVersionRequest) String() string { func (*ApiVersionRequest) ProtoMessage() {} func (x *ApiVersionRequest) ProtoReflect() protoreflect.Message { - mi := &file_equipment_equipment_proto_msgTypes[32] + mi := &file_equipment_equipment_proto_msgTypes[33] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2161,7 +2213,7 @@ func (x *ApiVersionRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ApiVersionRequest.ProtoReflect.Descriptor instead. func (*ApiVersionRequest) Descriptor() ([]byte, []int) { - return file_equipment_equipment_proto_rawDescGZIP(), []int{32} + return file_equipment_equipment_proto_rawDescGZIP(), []int{33} } func (x *ApiVersionRequest) GetType() int32 { @@ -2215,7 +2267,10 @@ const file_equipment_equipment_proto_rawDesc = "" + "\tIdRequest\x12\x0e\n" + "\x02id\x18\x01 \x01(\x03R\x02id\"*\n" + "\x0fIdStringRequest\x12\x17\n" + - "\amask_id\x18\x01 \x01(\tR\x06maskId\"O\n" + + "\amask_id\x18\x01 \x01(\tR\x06maskId\"H\n" + + "\x14StoreIdStringRequest\x12\x17\n" + + "\amask_id\x18\x01 \x01(\tR\x06maskId\x12\x17\n" + + "\auser_id\x18\x02 \x01(\x03R\x06userId\"O\n" + "\rStatusRequest\x12\x0e\n" + "\x02id\x18\x01 \x01(\x03R\x02id\x12\x16\n" + "\x06status\x18\x02 \x01(\x05R\x06status\x12\x16\n" + @@ -2345,7 +2400,7 @@ const file_equipment_equipment_proto_rawDesc = "" + "\x02id\x18\x01 \x01(\x03R\x02id\"A\n" + "\x11ApiVersionRequest\x12\x12\n" + "\x04type\x18\x01 \x01(\x05R\x04type\x12\x18\n" + - "\aversion\x18\x02 \x01(\tR\aversion2\xbd\x1c\n" + + "\aversion\x18\x02 \x01(\tR\aversion2\xb2\x1e\n" + "\tEquipment\x12Y\n" + "\x05Items\x12\x17.equipment.ItemsRequest\x1a\x13.equipment.Response\"\"\x82\xd3\xe4\x93\x02\x1c:\x01*\x12\x17/admin/v3/version/items\x12T\n" + "\x04Info\x12\x14.equipment.IdRequest\x1a\x13.equipment.Response\"!\x82\xd3\xe4\x93\x02\x1b:\x01*\x12\x16/admin/v3/version/info\x12\\\n" + @@ -2383,7 +2438,9 @@ const file_equipment_equipment_proto_rawDesc = "" + "\x11AuthorizationBind\x12#.equipment.AuthorizationBindRequest\x1a\x13.equipment.Response\",\x82\xd3\xe4\x93\x02&:\x01*\"!/api/v3/device/authorization/bind\x12\x81\x01\n" + "\x13AuthorizationCancel\x12%.equipment.AuthorizationCancelRequest\x1a\x13.equipment.Response\".\x82\xd3\xe4\x93\x02(:\x01*\"#/api/v3/device/authorization/cancel\x12\x84\x01\n" + "\x14AuthorizationControl\x12&.equipment.AuthorizationControlRequest\x1a\x13.equipment.Response\"/\x82\xd3\xe4\x93\x02):\x01*\"$/api/v3/device/authorization/control\x12q\n" + - "\x12AuthorizationItems\x12\x17.equipment.EmptyRequest\x1a\x13.equipment.Response\"-\x82\xd3\xe4\x93\x02':\x01*\"\"/api/v3/device/authorization/items\x12o\n" + + "\x12AuthorizationItems\x12\x17.equipment.EmptyRequest\x1a\x13.equipment.Response\"-\x82\xd3\xe4\x93\x02':\x01*\"\"/api/v3/device/authorization/items\x12|\n" + + "\x17AuthorizationStoreItems\x12\x17.equipment.EmptyRequest\x1a\x13.equipment.Response\"3\x82\xd3\xe4\x93\x02-:\x01*\"(/api/v3/device/authorization/store/items\x12u\n" + + "\x11ApiStoreCheckMask\x12\x1f.equipment.StoreIdStringRequest\x1a\x13.equipment.Response\"*\x82\xd3\xe4\x93\x02$:\x01*\"\x1f/api/v3/device/store/check/mask\x12o\n" + "\x11AuthorizationCode\x12\x17.equipment.EmptyRequest\x1a\x13.equipment.Response\",\x82\xd3\xe4\x93\x02&:\x01*\"!/api/v3/device/authorization/code\x12I\n" + "\x0fInternalBindAdd\x12!.equipment.InternalBindAddRequest\x1a\x13.equipment.Response\x12K\n" + "\x10InternalBindInfo\x12\".equipment.InternalBindInfoRequest\x1a\x13.equipment.Response\x12R\n" + @@ -2402,7 +2459,7 @@ func file_equipment_equipment_proto_rawDescGZIP() []byte { return file_equipment_equipment_proto_rawDescData } -var file_equipment_equipment_proto_msgTypes = make([]protoimpl.MessageInfo, 33) +var file_equipment_equipment_proto_msgTypes = make([]protoimpl.MessageInfo, 34) var file_equipment_equipment_proto_goTypes = []any{ (*Response)(nil), // 0: equipment.Response (*CreateRequest)(nil), // 1: equipment.CreateRequest @@ -2410,109 +2467,114 @@ var file_equipment_equipment_proto_goTypes = []any{ (*ItemsRequest)(nil), // 3: equipment.ItemsRequest (*IdRequest)(nil), // 4: equipment.IdRequest (*IdStringRequest)(nil), // 5: equipment.IdStringRequest - (*StatusRequest)(nil), // 6: equipment.StatusRequest - (*MaskItemsRequest)(nil), // 7: equipment.MaskItemsRequest - (*BeansItemsRequest)(nil), // 8: equipment.BeansItemsRequest - (*ApiBindAddRequest)(nil), // 9: equipment.ApiBindAddRequest - (*InternalBindAddRequest)(nil), // 10: equipment.InternalBindAddRequest - (*InternalBindInfoRequest)(nil), // 11: equipment.InternalBindInfoRequest - (*ApiBindInfoRequest)(nil), // 12: equipment.ApiBindInfoRequest - (*ApiBindUpdateRequest)(nil), // 13: equipment.ApiBindUpdateRequest - (*ApiEditNameRequest)(nil), // 14: equipment.ApiEditNameRequest - (*AuthorizationBindRequest)(nil), // 15: equipment.AuthorizationBindRequest - (*AuthorizationCancelRequest)(nil), // 16: equipment.AuthorizationCancelRequest - (*AuthorizationControlRequest)(nil), // 17: equipment.AuthorizationControlRequest - (*ApiUnBindRequest)(nil), // 18: equipment.ApiUnBindRequest - (*EmptyRequest)(nil), // 19: equipment.EmptyRequest - (*ApiBindExpiryRequest)(nil), // 20: equipment.ApiBindExpiryRequest - (*ApiBindExpiryGetRequest)(nil), // 21: equipment.ApiBindExpiryGetRequest - (*ApiBeansItemsRequest)(nil), // 22: equipment.ApiBeansItemsRequest - (*ApiBeansAddRequest)(nil), // 23: equipment.ApiBeansAddRequest - (*ApiMaskAddRequest)(nil), // 24: equipment.ApiMaskAddRequest - (*ApiMaskUseRequest)(nil), // 25: equipment.ApiMaskUseRequest - (*ApiMaskUsedItemsRequest)(nil), // 26: equipment.ApiMaskUsedItemsRequest - (*BindExpiryRequest)(nil), // 27: equipment.BindExpiryRequest - (*InternalUserInfoRequest)(nil), // 28: equipment.InternalUserInfoRequest - (*InternalResponse)(nil), // 29: equipment.InternalResponse - (*SetExpiryRequest)(nil), // 30: equipment.SetExpiryRequest - (*UserBindRequest)(nil), // 31: equipment.UserBindRequest - (*ApiVersionRequest)(nil), // 32: equipment.ApiVersionRequest + (*StoreIdStringRequest)(nil), // 6: equipment.StoreIdStringRequest + (*StatusRequest)(nil), // 7: equipment.StatusRequest + (*MaskItemsRequest)(nil), // 8: equipment.MaskItemsRequest + (*BeansItemsRequest)(nil), // 9: equipment.BeansItemsRequest + (*ApiBindAddRequest)(nil), // 10: equipment.ApiBindAddRequest + (*InternalBindAddRequest)(nil), // 11: equipment.InternalBindAddRequest + (*InternalBindInfoRequest)(nil), // 12: equipment.InternalBindInfoRequest + (*ApiBindInfoRequest)(nil), // 13: equipment.ApiBindInfoRequest + (*ApiBindUpdateRequest)(nil), // 14: equipment.ApiBindUpdateRequest + (*ApiEditNameRequest)(nil), // 15: equipment.ApiEditNameRequest + (*AuthorizationBindRequest)(nil), // 16: equipment.AuthorizationBindRequest + (*AuthorizationCancelRequest)(nil), // 17: equipment.AuthorizationCancelRequest + (*AuthorizationControlRequest)(nil), // 18: equipment.AuthorizationControlRequest + (*ApiUnBindRequest)(nil), // 19: equipment.ApiUnBindRequest + (*EmptyRequest)(nil), // 20: equipment.EmptyRequest + (*ApiBindExpiryRequest)(nil), // 21: equipment.ApiBindExpiryRequest + (*ApiBindExpiryGetRequest)(nil), // 22: equipment.ApiBindExpiryGetRequest + (*ApiBeansItemsRequest)(nil), // 23: equipment.ApiBeansItemsRequest + (*ApiBeansAddRequest)(nil), // 24: equipment.ApiBeansAddRequest + (*ApiMaskAddRequest)(nil), // 25: equipment.ApiMaskAddRequest + (*ApiMaskUseRequest)(nil), // 26: equipment.ApiMaskUseRequest + (*ApiMaskUsedItemsRequest)(nil), // 27: equipment.ApiMaskUsedItemsRequest + (*BindExpiryRequest)(nil), // 28: equipment.BindExpiryRequest + (*InternalUserInfoRequest)(nil), // 29: equipment.InternalUserInfoRequest + (*InternalResponse)(nil), // 30: equipment.InternalResponse + (*SetExpiryRequest)(nil), // 31: equipment.SetExpiryRequest + (*UserBindRequest)(nil), // 32: equipment.UserBindRequest + (*ApiVersionRequest)(nil), // 33: equipment.ApiVersionRequest } var file_equipment_equipment_proto_depIdxs = []int32{ 3, // 0: equipment.Equipment.Items:input_type -> equipment.ItemsRequest 4, // 1: equipment.Equipment.Info:input_type -> equipment.IdRequest 1, // 2: equipment.Equipment.Create:input_type -> equipment.CreateRequest 2, // 3: equipment.Equipment.Edit:input_type -> equipment.EditRequest - 6, // 4: equipment.Equipment.Status:input_type -> equipment.StatusRequest - 7, // 5: equipment.Equipment.MaskItems:input_type -> equipment.MaskItemsRequest - 8, // 6: equipment.Equipment.BeansItems:input_type -> equipment.BeansItemsRequest - 27, // 7: equipment.Equipment.BindExpiry:input_type -> equipment.BindExpiryRequest - 31, // 8: equipment.Equipment.UserBind:input_type -> equipment.UserBindRequest - 24, // 9: equipment.Equipment.ApiMaskAdd:input_type -> equipment.ApiMaskAddRequest - 19, // 10: equipment.Equipment.ApiBindItems:input_type -> equipment.EmptyRequest - 18, // 11: equipment.Equipment.ApiUnBind:input_type -> equipment.ApiUnBindRequest - 9, // 12: equipment.Equipment.ApiBindAdd:input_type -> equipment.ApiBindAddRequest - 20, // 13: equipment.Equipment.ApiBindExpiry:input_type -> equipment.ApiBindExpiryRequest - 21, // 14: equipment.Equipment.ApiBindExpiryGet:input_type -> equipment.ApiBindExpiryGetRequest - 23, // 15: equipment.Equipment.ApiBeansAdd:input_type -> equipment.ApiBeansAddRequest - 19, // 16: equipment.Equipment.ApiBeansLast:input_type -> equipment.EmptyRequest - 22, // 17: equipment.Equipment.ApiBeansItems:input_type -> equipment.ApiBeansItemsRequest - 25, // 18: equipment.Equipment.ApiMaskUse:input_type -> equipment.ApiMaskUseRequest - 26, // 19: equipment.Equipment.ApiMaskUsedItems:input_type -> equipment.ApiMaskUsedItemsRequest - 25, // 20: equipment.Equipment.ApiMaskStoreUse:input_type -> equipment.ApiMaskUseRequest - 26, // 21: equipment.Equipment.ApiMaskStoreUseItems:input_type -> equipment.ApiMaskUsedItemsRequest - 32, // 22: equipment.Equipment.ApiVersion:input_type -> equipment.ApiVersionRequest - 12, // 23: equipment.Equipment.ApiBindInfo:input_type -> equipment.ApiBindInfoRequest - 13, // 24: equipment.Equipment.ApiBindUpdate:input_type -> equipment.ApiBindUpdateRequest + 7, // 4: equipment.Equipment.Status:input_type -> equipment.StatusRequest + 8, // 5: equipment.Equipment.MaskItems:input_type -> equipment.MaskItemsRequest + 9, // 6: equipment.Equipment.BeansItems:input_type -> equipment.BeansItemsRequest + 28, // 7: equipment.Equipment.BindExpiry:input_type -> equipment.BindExpiryRequest + 32, // 8: equipment.Equipment.UserBind:input_type -> equipment.UserBindRequest + 25, // 9: equipment.Equipment.ApiMaskAdd:input_type -> equipment.ApiMaskAddRequest + 20, // 10: equipment.Equipment.ApiBindItems:input_type -> equipment.EmptyRequest + 19, // 11: equipment.Equipment.ApiUnBind:input_type -> equipment.ApiUnBindRequest + 10, // 12: equipment.Equipment.ApiBindAdd:input_type -> equipment.ApiBindAddRequest + 21, // 13: equipment.Equipment.ApiBindExpiry:input_type -> equipment.ApiBindExpiryRequest + 22, // 14: equipment.Equipment.ApiBindExpiryGet:input_type -> equipment.ApiBindExpiryGetRequest + 24, // 15: equipment.Equipment.ApiBeansAdd:input_type -> equipment.ApiBeansAddRequest + 20, // 16: equipment.Equipment.ApiBeansLast:input_type -> equipment.EmptyRequest + 23, // 17: equipment.Equipment.ApiBeansItems:input_type -> equipment.ApiBeansItemsRequest + 26, // 18: equipment.Equipment.ApiMaskUse:input_type -> equipment.ApiMaskUseRequest + 27, // 19: equipment.Equipment.ApiMaskUsedItems:input_type -> equipment.ApiMaskUsedItemsRequest + 26, // 20: equipment.Equipment.ApiMaskStoreUse:input_type -> equipment.ApiMaskUseRequest + 27, // 21: equipment.Equipment.ApiMaskStoreUseItems:input_type -> equipment.ApiMaskUsedItemsRequest + 33, // 22: equipment.Equipment.ApiVersion:input_type -> equipment.ApiVersionRequest + 13, // 23: equipment.Equipment.ApiBindInfo:input_type -> equipment.ApiBindInfoRequest + 14, // 24: equipment.Equipment.ApiBindUpdate:input_type -> equipment.ApiBindUpdateRequest 5, // 25: equipment.Equipment.ApiCheckMask:input_type -> equipment.IdStringRequest - 14, // 26: equipment.Equipment.ApiEditName:input_type -> equipment.ApiEditNameRequest - 15, // 27: equipment.Equipment.AuthorizationBind:input_type -> equipment.AuthorizationBindRequest - 16, // 28: equipment.Equipment.AuthorizationCancel:input_type -> equipment.AuthorizationCancelRequest - 17, // 29: equipment.Equipment.AuthorizationControl:input_type -> equipment.AuthorizationControlRequest - 19, // 30: equipment.Equipment.AuthorizationItems:input_type -> equipment.EmptyRequest - 19, // 31: equipment.Equipment.AuthorizationCode:input_type -> equipment.EmptyRequest - 10, // 32: equipment.Equipment.InternalBindAdd:input_type -> equipment.InternalBindAddRequest - 11, // 33: equipment.Equipment.InternalBindInfo:input_type -> equipment.InternalBindInfoRequest - 28, // 34: equipment.Equipment.InternalUserAdd:input_type -> equipment.InternalUserInfoRequest - 28, // 35: equipment.Equipment.InternalUserEditNumber:input_type -> equipment.InternalUserInfoRequest - 0, // 36: equipment.Equipment.Items:output_type -> equipment.Response - 0, // 37: equipment.Equipment.Info:output_type -> equipment.Response - 0, // 38: equipment.Equipment.Create:output_type -> equipment.Response - 0, // 39: equipment.Equipment.Edit:output_type -> equipment.Response - 0, // 40: equipment.Equipment.Status:output_type -> equipment.Response - 0, // 41: equipment.Equipment.MaskItems:output_type -> equipment.Response - 0, // 42: equipment.Equipment.BeansItems:output_type -> equipment.Response - 0, // 43: equipment.Equipment.BindExpiry:output_type -> equipment.Response - 0, // 44: equipment.Equipment.UserBind:output_type -> equipment.Response - 0, // 45: equipment.Equipment.ApiMaskAdd:output_type -> equipment.Response - 0, // 46: equipment.Equipment.ApiBindItems:output_type -> equipment.Response - 0, // 47: equipment.Equipment.ApiUnBind:output_type -> equipment.Response - 0, // 48: equipment.Equipment.ApiBindAdd:output_type -> equipment.Response - 0, // 49: equipment.Equipment.ApiBindExpiry:output_type -> equipment.Response - 0, // 50: equipment.Equipment.ApiBindExpiryGet:output_type -> equipment.Response - 0, // 51: equipment.Equipment.ApiBeansAdd:output_type -> equipment.Response - 0, // 52: equipment.Equipment.ApiBeansLast:output_type -> equipment.Response - 0, // 53: equipment.Equipment.ApiBeansItems:output_type -> equipment.Response - 0, // 54: equipment.Equipment.ApiMaskUse:output_type -> equipment.Response - 0, // 55: equipment.Equipment.ApiMaskUsedItems:output_type -> equipment.Response - 0, // 56: equipment.Equipment.ApiMaskStoreUse:output_type -> equipment.Response - 0, // 57: equipment.Equipment.ApiMaskStoreUseItems:output_type -> equipment.Response - 0, // 58: equipment.Equipment.ApiVersion:output_type -> equipment.Response - 0, // 59: equipment.Equipment.ApiBindInfo:output_type -> equipment.Response - 0, // 60: equipment.Equipment.ApiBindUpdate:output_type -> equipment.Response - 0, // 61: equipment.Equipment.ApiCheckMask:output_type -> equipment.Response - 0, // 62: equipment.Equipment.ApiEditName:output_type -> equipment.Response - 0, // 63: equipment.Equipment.AuthorizationBind:output_type -> equipment.Response - 0, // 64: equipment.Equipment.AuthorizationCancel:output_type -> equipment.Response - 0, // 65: equipment.Equipment.AuthorizationControl:output_type -> equipment.Response - 0, // 66: equipment.Equipment.AuthorizationItems:output_type -> equipment.Response - 0, // 67: equipment.Equipment.AuthorizationCode:output_type -> equipment.Response - 0, // 68: equipment.Equipment.InternalBindAdd:output_type -> equipment.Response - 0, // 69: equipment.Equipment.InternalBindInfo:output_type -> equipment.Response - 29, // 70: equipment.Equipment.InternalUserAdd:output_type -> equipment.InternalResponse - 29, // 71: equipment.Equipment.InternalUserEditNumber:output_type -> equipment.InternalResponse - 36, // [36:72] is the sub-list for method output_type - 0, // [0:36] is the sub-list for method input_type + 15, // 26: equipment.Equipment.ApiEditName:input_type -> equipment.ApiEditNameRequest + 16, // 27: equipment.Equipment.AuthorizationBind:input_type -> equipment.AuthorizationBindRequest + 17, // 28: equipment.Equipment.AuthorizationCancel:input_type -> equipment.AuthorizationCancelRequest + 18, // 29: equipment.Equipment.AuthorizationControl:input_type -> equipment.AuthorizationControlRequest + 20, // 30: equipment.Equipment.AuthorizationItems:input_type -> equipment.EmptyRequest + 20, // 31: equipment.Equipment.AuthorizationStoreItems:input_type -> equipment.EmptyRequest + 6, // 32: equipment.Equipment.ApiStoreCheckMask:input_type -> equipment.StoreIdStringRequest + 20, // 33: equipment.Equipment.AuthorizationCode:input_type -> equipment.EmptyRequest + 11, // 34: equipment.Equipment.InternalBindAdd:input_type -> equipment.InternalBindAddRequest + 12, // 35: equipment.Equipment.InternalBindInfo:input_type -> equipment.InternalBindInfoRequest + 29, // 36: equipment.Equipment.InternalUserAdd:input_type -> equipment.InternalUserInfoRequest + 29, // 37: equipment.Equipment.InternalUserEditNumber:input_type -> equipment.InternalUserInfoRequest + 0, // 38: equipment.Equipment.Items:output_type -> equipment.Response + 0, // 39: equipment.Equipment.Info:output_type -> equipment.Response + 0, // 40: equipment.Equipment.Create:output_type -> equipment.Response + 0, // 41: equipment.Equipment.Edit:output_type -> equipment.Response + 0, // 42: equipment.Equipment.Status:output_type -> equipment.Response + 0, // 43: equipment.Equipment.MaskItems:output_type -> equipment.Response + 0, // 44: equipment.Equipment.BeansItems:output_type -> equipment.Response + 0, // 45: equipment.Equipment.BindExpiry:output_type -> equipment.Response + 0, // 46: equipment.Equipment.UserBind:output_type -> equipment.Response + 0, // 47: equipment.Equipment.ApiMaskAdd:output_type -> equipment.Response + 0, // 48: equipment.Equipment.ApiBindItems:output_type -> equipment.Response + 0, // 49: equipment.Equipment.ApiUnBind:output_type -> equipment.Response + 0, // 50: equipment.Equipment.ApiBindAdd:output_type -> equipment.Response + 0, // 51: equipment.Equipment.ApiBindExpiry:output_type -> equipment.Response + 0, // 52: equipment.Equipment.ApiBindExpiryGet:output_type -> equipment.Response + 0, // 53: equipment.Equipment.ApiBeansAdd:output_type -> equipment.Response + 0, // 54: equipment.Equipment.ApiBeansLast:output_type -> equipment.Response + 0, // 55: equipment.Equipment.ApiBeansItems:output_type -> equipment.Response + 0, // 56: equipment.Equipment.ApiMaskUse:output_type -> equipment.Response + 0, // 57: equipment.Equipment.ApiMaskUsedItems:output_type -> equipment.Response + 0, // 58: equipment.Equipment.ApiMaskStoreUse:output_type -> equipment.Response + 0, // 59: equipment.Equipment.ApiMaskStoreUseItems:output_type -> equipment.Response + 0, // 60: equipment.Equipment.ApiVersion:output_type -> equipment.Response + 0, // 61: equipment.Equipment.ApiBindInfo:output_type -> equipment.Response + 0, // 62: equipment.Equipment.ApiBindUpdate:output_type -> equipment.Response + 0, // 63: equipment.Equipment.ApiCheckMask:output_type -> equipment.Response + 0, // 64: equipment.Equipment.ApiEditName:output_type -> equipment.Response + 0, // 65: equipment.Equipment.AuthorizationBind:output_type -> equipment.Response + 0, // 66: equipment.Equipment.AuthorizationCancel:output_type -> equipment.Response + 0, // 67: equipment.Equipment.AuthorizationControl:output_type -> equipment.Response + 0, // 68: equipment.Equipment.AuthorizationItems:output_type -> equipment.Response + 0, // 69: equipment.Equipment.AuthorizationStoreItems:output_type -> equipment.Response + 0, // 70: equipment.Equipment.ApiStoreCheckMask:output_type -> equipment.Response + 0, // 71: equipment.Equipment.AuthorizationCode:output_type -> equipment.Response + 0, // 72: equipment.Equipment.InternalBindAdd:output_type -> equipment.Response + 0, // 73: equipment.Equipment.InternalBindInfo:output_type -> equipment.Response + 30, // 74: equipment.Equipment.InternalUserAdd:output_type -> equipment.InternalResponse + 30, // 75: equipment.Equipment.InternalUserEditNumber:output_type -> equipment.InternalResponse + 38, // [38:76] is the sub-list for method output_type + 0, // [0:38] is the sub-list for method input_type 0, // [0:0] is the sub-list for extension type_name 0, // [0:0] is the sub-list for extension extendee 0, // [0:0] is the sub-list for field type_name @@ -2529,7 +2591,7 @@ func file_equipment_equipment_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: unsafe.Slice(unsafe.StringData(file_equipment_equipment_proto_rawDesc), len(file_equipment_equipment_proto_rawDesc)), NumEnums: 0, - NumMessages: 33, + NumMessages: 34, NumExtensions: 0, NumServices: 1, }, diff --git a/rpc/equipment/pb/equipment_grpc.pb.go b/rpc/equipment/pb/equipment_grpc.pb.go index 0f95c33..e561280 100644 --- a/rpc/equipment/pb/equipment_grpc.pb.go +++ b/rpc/equipment/pb/equipment_grpc.pb.go @@ -19,42 +19,44 @@ import ( const _ = grpc.SupportPackageIsVersion9 const ( - Equipment_Items_FullMethodName = "/equipment.Equipment/Items" - Equipment_Info_FullMethodName = "/equipment.Equipment/Info" - Equipment_Create_FullMethodName = "/equipment.Equipment/Create" - Equipment_Edit_FullMethodName = "/equipment.Equipment/Edit" - Equipment_Status_FullMethodName = "/equipment.Equipment/Status" - Equipment_MaskItems_FullMethodName = "/equipment.Equipment/MaskItems" - Equipment_BeansItems_FullMethodName = "/equipment.Equipment/BeansItems" - Equipment_BindExpiry_FullMethodName = "/equipment.Equipment/BindExpiry" - Equipment_UserBind_FullMethodName = "/equipment.Equipment/UserBind" - Equipment_ApiMaskAdd_FullMethodName = "/equipment.Equipment/ApiMaskAdd" - Equipment_ApiBindItems_FullMethodName = "/equipment.Equipment/ApiBindItems" - Equipment_ApiUnBind_FullMethodName = "/equipment.Equipment/ApiUnBind" - Equipment_ApiBindAdd_FullMethodName = "/equipment.Equipment/ApiBindAdd" - Equipment_ApiBindExpiry_FullMethodName = "/equipment.Equipment/ApiBindExpiry" - Equipment_ApiBindExpiryGet_FullMethodName = "/equipment.Equipment/ApiBindExpiryGet" - Equipment_ApiBeansAdd_FullMethodName = "/equipment.Equipment/ApiBeansAdd" - Equipment_ApiBeansLast_FullMethodName = "/equipment.Equipment/ApiBeansLast" - Equipment_ApiBeansItems_FullMethodName = "/equipment.Equipment/ApiBeansItems" - Equipment_ApiMaskUse_FullMethodName = "/equipment.Equipment/ApiMaskUse" - Equipment_ApiMaskUsedItems_FullMethodName = "/equipment.Equipment/ApiMaskUsedItems" - Equipment_ApiMaskStoreUse_FullMethodName = "/equipment.Equipment/ApiMaskStoreUse" - Equipment_ApiMaskStoreUseItems_FullMethodName = "/equipment.Equipment/ApiMaskStoreUseItems" - Equipment_ApiVersion_FullMethodName = "/equipment.Equipment/ApiVersion" - Equipment_ApiBindInfo_FullMethodName = "/equipment.Equipment/ApiBindInfo" - Equipment_ApiBindUpdate_FullMethodName = "/equipment.Equipment/ApiBindUpdate" - Equipment_ApiCheckMask_FullMethodName = "/equipment.Equipment/ApiCheckMask" - Equipment_ApiEditName_FullMethodName = "/equipment.Equipment/ApiEditName" - Equipment_AuthorizationBind_FullMethodName = "/equipment.Equipment/AuthorizationBind" - Equipment_AuthorizationCancel_FullMethodName = "/equipment.Equipment/AuthorizationCancel" - Equipment_AuthorizationControl_FullMethodName = "/equipment.Equipment/AuthorizationControl" - Equipment_AuthorizationItems_FullMethodName = "/equipment.Equipment/AuthorizationItems" - Equipment_AuthorizationCode_FullMethodName = "/equipment.Equipment/AuthorizationCode" - Equipment_InternalBindAdd_FullMethodName = "/equipment.Equipment/InternalBindAdd" - Equipment_InternalBindInfo_FullMethodName = "/equipment.Equipment/InternalBindInfo" - Equipment_InternalUserAdd_FullMethodName = "/equipment.Equipment/InternalUserAdd" - Equipment_InternalUserEditNumber_FullMethodName = "/equipment.Equipment/InternalUserEditNumber" + Equipment_Items_FullMethodName = "/equipment.Equipment/Items" + Equipment_Info_FullMethodName = "/equipment.Equipment/Info" + Equipment_Create_FullMethodName = "/equipment.Equipment/Create" + Equipment_Edit_FullMethodName = "/equipment.Equipment/Edit" + Equipment_Status_FullMethodName = "/equipment.Equipment/Status" + Equipment_MaskItems_FullMethodName = "/equipment.Equipment/MaskItems" + Equipment_BeansItems_FullMethodName = "/equipment.Equipment/BeansItems" + Equipment_BindExpiry_FullMethodName = "/equipment.Equipment/BindExpiry" + Equipment_UserBind_FullMethodName = "/equipment.Equipment/UserBind" + Equipment_ApiMaskAdd_FullMethodName = "/equipment.Equipment/ApiMaskAdd" + Equipment_ApiBindItems_FullMethodName = "/equipment.Equipment/ApiBindItems" + Equipment_ApiUnBind_FullMethodName = "/equipment.Equipment/ApiUnBind" + Equipment_ApiBindAdd_FullMethodName = "/equipment.Equipment/ApiBindAdd" + Equipment_ApiBindExpiry_FullMethodName = "/equipment.Equipment/ApiBindExpiry" + Equipment_ApiBindExpiryGet_FullMethodName = "/equipment.Equipment/ApiBindExpiryGet" + Equipment_ApiBeansAdd_FullMethodName = "/equipment.Equipment/ApiBeansAdd" + Equipment_ApiBeansLast_FullMethodName = "/equipment.Equipment/ApiBeansLast" + Equipment_ApiBeansItems_FullMethodName = "/equipment.Equipment/ApiBeansItems" + Equipment_ApiMaskUse_FullMethodName = "/equipment.Equipment/ApiMaskUse" + Equipment_ApiMaskUsedItems_FullMethodName = "/equipment.Equipment/ApiMaskUsedItems" + Equipment_ApiMaskStoreUse_FullMethodName = "/equipment.Equipment/ApiMaskStoreUse" + Equipment_ApiMaskStoreUseItems_FullMethodName = "/equipment.Equipment/ApiMaskStoreUseItems" + Equipment_ApiVersion_FullMethodName = "/equipment.Equipment/ApiVersion" + Equipment_ApiBindInfo_FullMethodName = "/equipment.Equipment/ApiBindInfo" + Equipment_ApiBindUpdate_FullMethodName = "/equipment.Equipment/ApiBindUpdate" + Equipment_ApiCheckMask_FullMethodName = "/equipment.Equipment/ApiCheckMask" + Equipment_ApiEditName_FullMethodName = "/equipment.Equipment/ApiEditName" + Equipment_AuthorizationBind_FullMethodName = "/equipment.Equipment/AuthorizationBind" + Equipment_AuthorizationCancel_FullMethodName = "/equipment.Equipment/AuthorizationCancel" + Equipment_AuthorizationControl_FullMethodName = "/equipment.Equipment/AuthorizationControl" + Equipment_AuthorizationItems_FullMethodName = "/equipment.Equipment/AuthorizationItems" + Equipment_AuthorizationStoreItems_FullMethodName = "/equipment.Equipment/AuthorizationStoreItems" + Equipment_ApiStoreCheckMask_FullMethodName = "/equipment.Equipment/ApiStoreCheckMask" + Equipment_AuthorizationCode_FullMethodName = "/equipment.Equipment/AuthorizationCode" + Equipment_InternalBindAdd_FullMethodName = "/equipment.Equipment/InternalBindAdd" + Equipment_InternalBindInfo_FullMethodName = "/equipment.Equipment/InternalBindInfo" + Equipment_InternalUserAdd_FullMethodName = "/equipment.Equipment/InternalUserAdd" + Equipment_InternalUserEditNumber_FullMethodName = "/equipment.Equipment/InternalUserEditNumber" ) // EquipmentClient is the client API for Equipment service. @@ -97,6 +99,9 @@ type EquipmentClient interface { AuthorizationControl(ctx context.Context, in *AuthorizationControlRequest, opts ...grpc.CallOption) (*Response, error) // 用户端获取授权列表 AuthorizationItems(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Response, error) + // 门店端获取授权列表 + AuthorizationStoreItems(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Response, error) + ApiStoreCheckMask(ctx context.Context, in *StoreIdStringRequest, opts ...grpc.CallOption) (*Response, error) AuthorizationCode(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Response, error) InternalBindAdd(ctx context.Context, in *InternalBindAddRequest, opts ...grpc.CallOption) (*Response, error) InternalBindInfo(ctx context.Context, in *InternalBindInfoRequest, opts ...grpc.CallOption) (*Response, error) @@ -424,6 +429,26 @@ func (c *equipmentClient) AuthorizationItems(ctx context.Context, in *EmptyReque return out, nil } +func (c *equipmentClient) AuthorizationStoreItems(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Response, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Response) + err := c.cc.Invoke(ctx, Equipment_AuthorizationStoreItems_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *equipmentClient) ApiStoreCheckMask(ctx context.Context, in *StoreIdStringRequest, opts ...grpc.CallOption) (*Response, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Response) + err := c.cc.Invoke(ctx, Equipment_ApiStoreCheckMask_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + func (c *equipmentClient) AuthorizationCode(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Response, error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(Response) @@ -514,6 +539,9 @@ type EquipmentServer interface { AuthorizationControl(context.Context, *AuthorizationControlRequest) (*Response, error) // 用户端获取授权列表 AuthorizationItems(context.Context, *EmptyRequest) (*Response, error) + // 门店端获取授权列表 + AuthorizationStoreItems(context.Context, *EmptyRequest) (*Response, error) + ApiStoreCheckMask(context.Context, *StoreIdStringRequest) (*Response, error) AuthorizationCode(context.Context, *EmptyRequest) (*Response, error) InternalBindAdd(context.Context, *InternalBindAddRequest) (*Response, error) InternalBindInfo(context.Context, *InternalBindInfoRequest) (*Response, error) @@ -624,6 +652,12 @@ func (UnimplementedEquipmentServer) AuthorizationControl(context.Context, *Autho func (UnimplementedEquipmentServer) AuthorizationItems(context.Context, *EmptyRequest) (*Response, error) { return nil, status.Error(codes.Unimplemented, "method AuthorizationItems not implemented") } +func (UnimplementedEquipmentServer) AuthorizationStoreItems(context.Context, *EmptyRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method AuthorizationStoreItems not implemented") +} +func (UnimplementedEquipmentServer) ApiStoreCheckMask(context.Context, *StoreIdStringRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method ApiStoreCheckMask not implemented") +} func (UnimplementedEquipmentServer) AuthorizationCode(context.Context, *EmptyRequest) (*Response, error) { return nil, status.Error(codes.Unimplemented, "method AuthorizationCode not implemented") } @@ -1218,6 +1252,42 @@ func _Equipment_AuthorizationItems_Handler(srv interface{}, ctx context.Context, return interceptor(ctx, in, info, handler) } +func _Equipment_AuthorizationStoreItems_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(EmptyRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(EquipmentServer).AuthorizationStoreItems(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Equipment_AuthorizationStoreItems_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(EquipmentServer).AuthorizationStoreItems(ctx, req.(*EmptyRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _Equipment_ApiStoreCheckMask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(StoreIdStringRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(EquipmentServer).ApiStoreCheckMask(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Equipment_ApiStoreCheckMask_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(EquipmentServer).ApiStoreCheckMask(ctx, req.(*StoreIdStringRequest)) + } + return interceptor(ctx, in, info, handler) +} + func _Equipment_AuthorizationCode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(EmptyRequest) if err := dec(in); err != nil { @@ -1439,6 +1509,14 @@ var Equipment_ServiceDesc = grpc.ServiceDesc{ MethodName: "AuthorizationItems", Handler: _Equipment_AuthorizationItems_Handler, }, + { + MethodName: "AuthorizationStoreItems", + Handler: _Equipment_AuthorizationStoreItems_Handler, + }, + { + MethodName: "ApiStoreCheckMask", + Handler: _Equipment_ApiStoreCheckMask_Handler, + }, { MethodName: "AuthorizationCode", Handler: _Equipment_AuthorizationCode_Handler, diff --git a/rpc/percutaneous/pb/percutaneous.pb.go b/rpc/percutaneous/pb/percutaneous.pb.go index 0231d65..d837c53 100644 --- a/rpc/percutaneous/pb/percutaneous.pb.go +++ b/rpc/percutaneous/pb/percutaneous.pb.go @@ -514,6 +514,102 @@ func (x *AddUserQRRequest) GetHostCode() string { return "" } +type SetPositionRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + Position int32 `protobuf:"varint,2,opt,name=position,proto3" json:"position,omitempty"` + SessionId string `protobuf:"bytes,4,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *SetPositionRequest) Reset() { + *x = SetPositionRequest{} + mi := &file_percutaneous_percutaneous_proto_msgTypes[9] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *SetPositionRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*SetPositionRequest) ProtoMessage() {} + +func (x *SetPositionRequest) ProtoReflect() protoreflect.Message { + mi := &file_percutaneous_percutaneous_proto_msgTypes[9] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use SetPositionRequest.ProtoReflect.Descriptor instead. +func (*SetPositionRequest) Descriptor() ([]byte, []int) { + return file_percutaneous_percutaneous_proto_rawDescGZIP(), []int{9} +} + +func (x *SetPositionRequest) GetPosition() int32 { + if x != nil { + return x.Position + } + return 0 +} + +func (x *SetPositionRequest) GetSessionId() string { + if x != nil { + return x.SessionId + } + return "" +} + +type GetWsCodeRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + Type int32 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *GetWsCodeRequest) Reset() { + *x = GetWsCodeRequest{} + mi := &file_percutaneous_percutaneous_proto_msgTypes[10] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *GetWsCodeRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*GetWsCodeRequest) ProtoMessage() {} + +func (x *GetWsCodeRequest) ProtoReflect() protoreflect.Message { + mi := &file_percutaneous_percutaneous_proto_msgTypes[10] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use GetWsCodeRequest.ProtoReflect.Descriptor instead. +func (*GetWsCodeRequest) Descriptor() ([]byte, []int) { + return file_percutaneous_percutaneous_proto_rawDescGZIP(), []int{10} +} + +func (x *GetWsCodeRequest) GetType() int32 { + if x != nil { + return x.Type + } + return 0 +} + type EmptyRequest struct { state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields @@ -522,7 +618,7 @@ type EmptyRequest struct { func (x *EmptyRequest) Reset() { *x = EmptyRequest{} - mi := &file_percutaneous_percutaneous_proto_msgTypes[9] + mi := &file_percutaneous_percutaneous_proto_msgTypes[11] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -534,7 +630,7 @@ func (x *EmptyRequest) String() string { func (*EmptyRequest) ProtoMessage() {} func (x *EmptyRequest) ProtoReflect() protoreflect.Message { - mi := &file_percutaneous_percutaneous_proto_msgTypes[9] + mi := &file_percutaneous_percutaneous_proto_msgTypes[11] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -547,7 +643,7 @@ func (x *EmptyRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use EmptyRequest.ProtoReflect.Descriptor instead. func (*EmptyRequest) Descriptor() ([]byte, []int) { - return file_percutaneous_percutaneous_proto_rawDescGZIP(), []int{9} + return file_percutaneous_percutaneous_proto_rawDescGZIP(), []int{11} } type WsStreamRequest struct { @@ -559,7 +655,7 @@ type WsStreamRequest struct { func (x *WsStreamRequest) Reset() { *x = WsStreamRequest{} - mi := &file_percutaneous_percutaneous_proto_msgTypes[10] + mi := &file_percutaneous_percutaneous_proto_msgTypes[12] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -571,7 +667,7 @@ func (x *WsStreamRequest) String() string { func (*WsStreamRequest) ProtoMessage() {} func (x *WsStreamRequest) ProtoReflect() protoreflect.Message { - mi := &file_percutaneous_percutaneous_proto_msgTypes[10] + mi := &file_percutaneous_percutaneous_proto_msgTypes[12] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -584,7 +680,7 @@ func (x *WsStreamRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use WsStreamRequest.ProtoReflect.Descriptor instead. func (*WsStreamRequest) Descriptor() ([]byte, []int) { - return file_percutaneous_percutaneous_proto_rawDescGZIP(), []int{10} + return file_percutaneous_percutaneous_proto_rawDescGZIP(), []int{12} } func (x *WsStreamRequest) GetRawBody() []byte { @@ -629,17 +725,25 @@ const file_percutaneous_percutaneous_proto_rawDesc = "" + "\thost_code\x18\x01 \x01(\tR\bhostCode\x12\x1c\n" + "\tbluetooth\x18\x02 \x01(\tR\tbluetooth\"/\n" + "\x10AddUserQRRequest\x12\x1b\n" + - "\thost_code\x18\x01 \x01(\tR\bhostCode\"\x0e\n" + + "\thost_code\x18\x01 \x01(\tR\bhostCode\"O\n" + + "\x12setPositionRequest\x12\x1a\n" + + "\bposition\x18\x02 \x01(\x05R\bposition\x12\x1d\n" + + "\n" + + "session_id\x18\x04 \x01(\tR\tsessionId\"&\n" + + "\x10getWsCodeRequest\x12\x12\n" + + "\x04type\x18\x01 \x01(\x05R\x04type\"\x0e\n" + "\fEmptyRequest\",\n" + "\x0fWsStreamRequest\x12\x19\n" + - "\braw_body\x18\x01 \x01(\fR\arawBody2\xe4\x05\n" + + "\braw_body\x18\x01 \x01(\fR\arawBody2\xca\a\n" + "\fPercutaneous\x12o\n" + "\tWifiCheck\x12\x1e.percutaneous.WifiCheckRequest\x1a\x16.percutaneous.Response\"*\x82\xd3\xe4\x93\x02$:\x01*\x12\x1f/api/v3/percutaneous/wifi/check\x12i\n" + "\aWifiSet\x12\x1c.percutaneous.WifiSetRequest\x1a\x16.percutaneous.Response\"(\x82\xd3\xe4\x93\x02\":\x01*\"\x1d/api/v3/percutaneous/wifi/set\x12\\\n" + "\x03Use\x12\x18.percutaneous.UseRequest\x1a\x16.percutaneous.Response\"#\x82\xd3\xe4\x93\x02\x1d:\x01*\"\x18/api/v3/percutaneous/use\x12i\n" + "\aUsedLog\x12\x1c.percutaneous.UsedLogRequest\x1a\x16.percutaneous.Response\"(\x82\xd3\xe4\x93\x02\":\x01*\x12\x1d/api/v3/percutaneous/used/log\x12i\n" + "\aAddUser\x12\x1c.percutaneous.AddUserRequest\x1a\x16.percutaneous.Response\"(\x82\xd3\xe4\x93\x02\":\x01*\x12\x1d/api/v3/percutaneous/add/user\x12o\n" + - "\tUserItems\x12\x1e.percutaneous.UserItemsRequest\x1a\x16.percutaneous.Response\"*\x82\xd3\xe4\x93\x02$:\x01*\x12\x1f/api/v3/percutaneous/user/items\x12S\n" + + "\tUserItems\x12\x1e.percutaneous.UserItemsRequest\x1a\x16.percutaneous.Response\"*\x82\xd3\xe4\x93\x02$:\x01*\x12\x1f/api/v3/percutaneous/user/items\x12u\n" + + "\vsetPosition\x12 .percutaneous.setPositionRequest\x1a\x16.percutaneous.Response\",\x82\xd3\xe4\x93\x02&:\x01*\x12!/api/v3/percutaneous/use/position\x12m\n" + + "\tgetWsCode\x12\x1e.percutaneous.getWsCodeRequest\x1a\x16.percutaneous.Response\"(\x82\xd3\xe4\x93\x02\":\x01*\x12\x1d/api/v3/percutaneous/get/code\x12S\n" + "\x0fWsAddUserStream\x12\x1d.percutaneous.WsStreamRequest\x1a\x1d.percutaneous.WsStreamRequest(\x010\x01B\x10Z\x0e./percutaneousb\x06proto3" var ( @@ -654,19 +758,21 @@ func file_percutaneous_percutaneous_proto_rawDescGZIP() []byte { return file_percutaneous_percutaneous_proto_rawDescData } -var file_percutaneous_percutaneous_proto_msgTypes = make([]protoimpl.MessageInfo, 11) +var file_percutaneous_percutaneous_proto_msgTypes = make([]protoimpl.MessageInfo, 13) var file_percutaneous_percutaneous_proto_goTypes = []any{ - (*WifiCheckRequest)(nil), // 0: percutaneous.WifiCheckRequest - (*WifiSetRequest)(nil), // 1: percutaneous.WifiSetRequest - (*UseRequest)(nil), // 2: percutaneous.UseRequest - (*UsedLogRequest)(nil), // 3: percutaneous.UsedLogRequest - (*Response)(nil), // 4: percutaneous.Response - (*AddUserRequest)(nil), // 5: percutaneous.AddUserRequest - (*UserItemsRequest)(nil), // 6: percutaneous.UserItemsRequest - (*LoginQRRequest)(nil), // 7: percutaneous.LoginQRRequest - (*AddUserQRRequest)(nil), // 8: percutaneous.AddUserQRRequest - (*EmptyRequest)(nil), // 9: percutaneous.EmptyRequest - (*WsStreamRequest)(nil), // 10: percutaneous.WsStreamRequest + (*WifiCheckRequest)(nil), // 0: percutaneous.WifiCheckRequest + (*WifiSetRequest)(nil), // 1: percutaneous.WifiSetRequest + (*UseRequest)(nil), // 2: percutaneous.UseRequest + (*UsedLogRequest)(nil), // 3: percutaneous.UsedLogRequest + (*Response)(nil), // 4: percutaneous.Response + (*AddUserRequest)(nil), // 5: percutaneous.AddUserRequest + (*UserItemsRequest)(nil), // 6: percutaneous.UserItemsRequest + (*LoginQRRequest)(nil), // 7: percutaneous.LoginQRRequest + (*AddUserQRRequest)(nil), // 8: percutaneous.AddUserQRRequest + (*SetPositionRequest)(nil), // 9: percutaneous.setPositionRequest + (*GetWsCodeRequest)(nil), // 10: percutaneous.getWsCodeRequest + (*EmptyRequest)(nil), // 11: percutaneous.EmptyRequest + (*WsStreamRequest)(nil), // 12: percutaneous.WsStreamRequest } var file_percutaneous_percutaneous_proto_depIdxs = []int32{ 0, // 0: percutaneous.Percutaneous.WifiCheck:input_type -> percutaneous.WifiCheckRequest @@ -675,16 +781,20 @@ var file_percutaneous_percutaneous_proto_depIdxs = []int32{ 3, // 3: percutaneous.Percutaneous.UsedLog:input_type -> percutaneous.UsedLogRequest 5, // 4: percutaneous.Percutaneous.AddUser:input_type -> percutaneous.AddUserRequest 6, // 5: percutaneous.Percutaneous.UserItems:input_type -> percutaneous.UserItemsRequest - 10, // 6: percutaneous.Percutaneous.WsAddUserStream:input_type -> percutaneous.WsStreamRequest - 4, // 7: percutaneous.Percutaneous.WifiCheck:output_type -> percutaneous.Response - 4, // 8: percutaneous.Percutaneous.WifiSet:output_type -> percutaneous.Response - 4, // 9: percutaneous.Percutaneous.Use:output_type -> percutaneous.Response - 4, // 10: percutaneous.Percutaneous.UsedLog:output_type -> percutaneous.Response - 4, // 11: percutaneous.Percutaneous.AddUser:output_type -> percutaneous.Response - 4, // 12: percutaneous.Percutaneous.UserItems:output_type -> percutaneous.Response - 10, // 13: percutaneous.Percutaneous.WsAddUserStream:output_type -> percutaneous.WsStreamRequest - 7, // [7:14] is the sub-list for method output_type - 0, // [0:7] is the sub-list for method input_type + 9, // 6: percutaneous.Percutaneous.setPosition:input_type -> percutaneous.setPositionRequest + 10, // 7: percutaneous.Percutaneous.getWsCode:input_type -> percutaneous.getWsCodeRequest + 12, // 8: percutaneous.Percutaneous.WsAddUserStream:input_type -> percutaneous.WsStreamRequest + 4, // 9: percutaneous.Percutaneous.WifiCheck:output_type -> percutaneous.Response + 4, // 10: percutaneous.Percutaneous.WifiSet:output_type -> percutaneous.Response + 4, // 11: percutaneous.Percutaneous.Use:output_type -> percutaneous.Response + 4, // 12: percutaneous.Percutaneous.UsedLog:output_type -> percutaneous.Response + 4, // 13: percutaneous.Percutaneous.AddUser:output_type -> percutaneous.Response + 4, // 14: percutaneous.Percutaneous.UserItems:output_type -> percutaneous.Response + 4, // 15: percutaneous.Percutaneous.setPosition:output_type -> percutaneous.Response + 4, // 16: percutaneous.Percutaneous.getWsCode:output_type -> percutaneous.Response + 12, // 17: percutaneous.Percutaneous.WsAddUserStream:output_type -> percutaneous.WsStreamRequest + 9, // [9:18] is the sub-list for method output_type + 0, // [0:9] is the sub-list for method input_type 0, // [0:0] is the sub-list for extension type_name 0, // [0:0] is the sub-list for extension extendee 0, // [0:0] is the sub-list for field type_name @@ -701,7 +811,7 @@ func file_percutaneous_percutaneous_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: unsafe.Slice(unsafe.StringData(file_percutaneous_percutaneous_proto_rawDesc), len(file_percutaneous_percutaneous_proto_rawDesc)), NumEnums: 0, - NumMessages: 11, + NumMessages: 13, NumExtensions: 0, NumServices: 1, }, diff --git a/rpc/percutaneous/pb/percutaneous_grpc.pb.go b/rpc/percutaneous/pb/percutaneous_grpc.pb.go index fff8242..754ee9a 100644 --- a/rpc/percutaneous/pb/percutaneous_grpc.pb.go +++ b/rpc/percutaneous/pb/percutaneous_grpc.pb.go @@ -25,6 +25,8 @@ const ( Percutaneous_UsedLog_FullMethodName = "/percutaneous.Percutaneous/UsedLog" Percutaneous_AddUser_FullMethodName = "/percutaneous.Percutaneous/AddUser" Percutaneous_UserItems_FullMethodName = "/percutaneous.Percutaneous/UserItems" + Percutaneous_SetPosition_FullMethodName = "/percutaneous.Percutaneous/setPosition" + Percutaneous_GetWsCode_FullMethodName = "/percutaneous.Percutaneous/getWsCode" Percutaneous_WsAddUserStream_FullMethodName = "/percutaneous.Percutaneous/WsAddUserStream" ) @@ -38,6 +40,9 @@ type PercutaneousClient interface { UsedLog(ctx context.Context, in *UsedLogRequest, opts ...grpc.CallOption) (*Response, error) AddUser(ctx context.Context, in *AddUserRequest, opts ...grpc.CallOption) (*Response, error) UserItems(ctx context.Context, in *UserItemsRequest, opts ...grpc.CallOption) (*Response, error) + // 使用指南 + SetPosition(ctx context.Context, in *SetPositionRequest, opts ...grpc.CallOption) (*Response, error) + GetWsCode(ctx context.Context, in *GetWsCodeRequest, opts ...grpc.CallOption) (*Response, error) // 添加用户 WsAddUserStream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[WsStreamRequest, WsStreamRequest], error) } @@ -110,6 +115,26 @@ func (c *percutaneousClient) UserItems(ctx context.Context, in *UserItemsRequest return out, nil } +func (c *percutaneousClient) SetPosition(ctx context.Context, in *SetPositionRequest, opts ...grpc.CallOption) (*Response, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Response) + err := c.cc.Invoke(ctx, Percutaneous_SetPosition_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *percutaneousClient) GetWsCode(ctx context.Context, in *GetWsCodeRequest, opts ...grpc.CallOption) (*Response, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Response) + err := c.cc.Invoke(ctx, Percutaneous_GetWsCode_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + func (c *percutaneousClient) WsAddUserStream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[WsStreamRequest, WsStreamRequest], error) { cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) stream, err := c.cc.NewStream(ctx, &Percutaneous_ServiceDesc.Streams[0], Percutaneous_WsAddUserStream_FullMethodName, cOpts...) @@ -133,6 +158,9 @@ type PercutaneousServer interface { UsedLog(context.Context, *UsedLogRequest) (*Response, error) AddUser(context.Context, *AddUserRequest) (*Response, error) UserItems(context.Context, *UserItemsRequest) (*Response, error) + // 使用指南 + SetPosition(context.Context, *SetPositionRequest) (*Response, error) + GetWsCode(context.Context, *GetWsCodeRequest) (*Response, error) // 添加用户 WsAddUserStream(grpc.BidiStreamingServer[WsStreamRequest, WsStreamRequest]) error mustEmbedUnimplementedPercutaneousServer() @@ -163,6 +191,12 @@ func (UnimplementedPercutaneousServer) AddUser(context.Context, *AddUserRequest) func (UnimplementedPercutaneousServer) UserItems(context.Context, *UserItemsRequest) (*Response, error) { return nil, status.Error(codes.Unimplemented, "method UserItems not implemented") } +func (UnimplementedPercutaneousServer) SetPosition(context.Context, *SetPositionRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method SetPosition not implemented") +} +func (UnimplementedPercutaneousServer) GetWsCode(context.Context, *GetWsCodeRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method GetWsCode not implemented") +} func (UnimplementedPercutaneousServer) WsAddUserStream(grpc.BidiStreamingServer[WsStreamRequest, WsStreamRequest]) error { return status.Error(codes.Unimplemented, "method WsAddUserStream not implemented") } @@ -295,6 +329,42 @@ func _Percutaneous_UserItems_Handler(srv interface{}, ctx context.Context, dec f return interceptor(ctx, in, info, handler) } +func _Percutaneous_SetPosition_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(SetPositionRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(PercutaneousServer).SetPosition(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Percutaneous_SetPosition_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(PercutaneousServer).SetPosition(ctx, req.(*SetPositionRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _Percutaneous_GetWsCode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(GetWsCodeRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(PercutaneousServer).GetWsCode(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Percutaneous_GetWsCode_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(PercutaneousServer).GetWsCode(ctx, req.(*GetWsCodeRequest)) + } + return interceptor(ctx, in, info, handler) +} + func _Percutaneous_WsAddUserStream_Handler(srv interface{}, stream grpc.ServerStream) error { return srv.(PercutaneousServer).WsAddUserStream(&grpc.GenericServerStream[WsStreamRequest, WsStreamRequest]{ServerStream: stream}) } @@ -333,6 +403,14 @@ var Percutaneous_ServiceDesc = grpc.ServiceDesc{ MethodName: "UserItems", Handler: _Percutaneous_UserItems_Handler, }, + { + MethodName: "setPosition", + Handler: _Percutaneous_SetPosition_Handler, + }, + { + MethodName: "getWsCode", + Handler: _Percutaneous_GetWsCode_Handler, + }, }, Streams: []grpc.StreamDesc{ { diff --git a/rpc/percutaneous/percutaneous.pb b/rpc/percutaneous/percutaneous.pb index 758dd31..ede54b0 100644 Binary files a/rpc/percutaneous/percutaneous.pb and b/rpc/percutaneous/percutaneous.pb differ diff --git a/rpc/percutaneous/percutaneous.proto b/rpc/percutaneous/percutaneous.proto index 9d1c4f3..ddd2cf3 100644 --- a/rpc/percutaneous/percutaneous.proto +++ b/rpc/percutaneous/percutaneous.proto @@ -53,6 +53,15 @@ message AddUserQRRequest { string host_code = 1; } +message setPositionRequest { + int32 position =2; + string session_id =4; +} + +message getWsCodeRequest { + int32 type =1; +} + message EmptyRequest { } @@ -100,6 +109,20 @@ service Percutaneous { body: "*" }; } + // 使用指南 + rpc setPosition(setPositionRequest) returns (Response) { + option (google.api.http) = { + get: "/api/v3/percutaneous/use/position" + body: "*" + }; + } + + rpc getWsCode(getWsCodeRequest) returns (Response) { + option (google.api.http) = { + get: "/api/v3/percutaneous/get/code" + body: "*" + }; + } // 添加用户 rpc WsAddUserStream(stream WsStreamRequest) returns (stream WsStreamRequest); diff --git a/services/equipment/equipmentclient/equipment.go b/services/equipment/equipmentclient/equipment.go index 28d2f7f..1974826 100644 --- a/services/equipment/equipmentclient/equipment.go +++ b/services/equipment/equipmentclient/equipment.go @@ -46,6 +46,7 @@ type ( Response = equipment.Response SetExpiryRequest = equipment.SetExpiryRequest StatusRequest = equipment.StatusRequest + StoreIdStringRequest = equipment.StoreIdStringRequest UserBindRequest = equipment.UserBindRequest Equipment interface { @@ -85,6 +86,9 @@ type ( AuthorizationControl(ctx context.Context, in *AuthorizationControlRequest, opts ...grpc.CallOption) (*Response, error) // 用户端获取授权列表 AuthorizationItems(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Response, error) + // 门店端获取授权列表 + AuthorizationStoreItems(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Response, error) + ApiStoreCheckMask(ctx context.Context, in *StoreIdStringRequest, opts ...grpc.CallOption) (*Response, error) AuthorizationCode(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Response, error) InternalBindAdd(ctx context.Context, in *InternalBindAddRequest, opts ...grpc.CallOption) (*Response, error) InternalBindInfo(ctx context.Context, in *InternalBindInfoRequest, opts ...grpc.CallOption) (*Response, error) @@ -265,6 +269,17 @@ func (m *defaultEquipment) AuthorizationItems(ctx context.Context, in *EmptyRequ return client.AuthorizationItems(ctx, in, opts...) } +// 门店端获取授权列表 +func (m *defaultEquipment) AuthorizationStoreItems(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Response, error) { + client := equipment.NewEquipmentClient(m.cli.Conn()) + return client.AuthorizationStoreItems(ctx, in, opts...) +} + +func (m *defaultEquipment) ApiStoreCheckMask(ctx context.Context, in *StoreIdStringRequest, opts ...grpc.CallOption) (*Response, error) { + client := equipment.NewEquipmentClient(m.cli.Conn()) + return client.ApiStoreCheckMask(ctx, in, opts...) +} + func (m *defaultEquipment) AuthorizationCode(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Response, error) { client := equipment.NewEquipmentClient(m.cli.Conn()) return client.AuthorizationCode(ctx, in, opts...) diff --git a/services/equipment/internal/dao/authorizationRecord.go b/services/equipment/internal/dao/authorizationRecord.go index 4c00e82..cbd842e 100644 --- a/services/equipment/internal/dao/authorizationRecord.go +++ b/services/equipment/internal/dao/authorizationRecord.go @@ -35,3 +35,16 @@ type AuthorizationRecordItems struct { DistrictArr []int64 `json:"district_arr"` UsageCount int32 `json:"usage_count"` } + +type AuthorizationRecordStoreItems struct { + Id int64 `json:"id"` + UserId int64 `json:"user_id"` // 用户ID + Status int32 `json:"status"` // 2未授权 1 已授权 + Open int32 `json:"open"` // 是否开启展示,1为默认开启,2为关闭 + Username string `json:"username"` + Mobile string `json:"mobile"` + Avatar string `json:"avatar"` + Birthday string `json:"birthday"` + Gender int32 `json:"gender"` + UsageCount int32 `json:"usage_count"` +} diff --git a/services/equipment/internal/logic/apiStoreCheckMaskLogic.go b/services/equipment/internal/logic/apiStoreCheckMaskLogic.go new file mode 100644 index 0000000..6929f19 --- /dev/null +++ b/services/equipment/internal/logic/apiStoreCheckMaskLogic.go @@ -0,0 +1,106 @@ +package logic + +import ( + "context" + "lone-services/pkg/modelbase" + "lone-services/pkg/utils" + "lone-services/services/equipment/internal/dao" + "lone-services/services/equipment/internal/model" + "lone-services/services/equipment/validator" + "strconv" + + "lone-services/rpc/equipment/pb" + "lone-services/services/equipment/internal/svc" + + "github.com/zeromicro/go-zero/core/logx" +) + +type ApiStoreCheckMaskLogic struct { + ctx context.Context + svcCtx *svc.ServiceContext + logx.Logger + BaseLogic +} + +func NewApiStoreCheckMaskLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ApiStoreCheckMaskLogic { + return &ApiStoreCheckMaskLogic{ + ctx: ctx, + svcCtx: svcCtx, + Logger: logx.WithContext(ctx), + } +} + +func (l *ApiStoreCheckMaskLogic) ApiStoreCheckMask(in *equipment.StoreIdStringRequest) (*equipment.Response, error) { + var v validator.MaskStoreCheckValidator + if fail := l.checkParams(in, &v); fail != nil { + return fail, nil + } + + adminInfo := utils.GetUserFromCtx(l.ctx) + if adminInfo.ID < utils.NumberOne { + return l.fail(utils.ErrorNoLoginInfo) + } + + var info dao.MaskInfo + w := modelbase.Params{ + Eq: map[string]string{ + "facial_mask_id": in.MaskId}, + } + + modelObj := model.MaskModel{}.Init() + err := modelObj.GetOne(w, &info) + if err != nil { + l.Logger.Error(err) + return l.fail(utils.Fail) + } + if info.Id < utils.NumberOne { + return l.fail(utils.ErrorNotFund) + } + + if info.IsUse == utils.NumberOne { + return l.fail(utils.SetError(utils.Fail, "该面膜已经使用过")) + } + + if info.IsOnTrial != utils.NumberOne { + return l.ok(utils.NumberOne) + } + + w = modelbase.Params{Eq: map[string]string{ + "facial_mask_id": in.MaskId, + "user_id": strconv.FormatInt(in.UserId, utils.NumberTen), + }} + + var items []dao.MaskUsageRecordInfo + count, err := model.MaskUsageRecordModel{}.Init().Count(w, &items) + + if err != nil { + l.Logger.Error(err) + return l.fail(utils.Fail) + } + if count < utils.NumberOne { + return l.ok(utils.NumberOne) + } + + var user dao.MaskUserInfo + w = modelbase.Params{Eq: map[string]string{ + "user_id": strconv.FormatInt(in.UserId, utils.NumberTen), + }} + err = model.MaskUserModel{}.Init().GetOne(w, &user) + if err != nil { + l.Logger.Error(err) + return l.fail(utils.Fail) + } + if user.Id < utils.NumberOne { + return l.fail(utils.SetError(utils.ErrorNotFund, "用户不存在")) + } + + if user.OnTrialNum < utils.NumberOne { + return l.fail(utils.SetError(utils.Fail, "用户已经试用过")) + } + + if count >= int64(user.OnTrialNum) { + return l.fail(utils.SetError(utils.Fail, "用户已经试用过")) + } + + return l.ok(utils.NumberOne) +} diff --git a/services/equipment/internal/logic/authorizationStoreItemsLogic.go b/services/equipment/internal/logic/authorizationStoreItemsLogic.go new file mode 100644 index 0000000..7544eb0 --- /dev/null +++ b/services/equipment/internal/logic/authorizationStoreItemsLogic.go @@ -0,0 +1,105 @@ +package logic + +import ( + "context" + "lone-services/pkg/modelbase" + "lone-services/pkg/utils" + "lone-services/services/equipment/internal/dao" + "lone-services/services/equipment/internal/model" + "strconv" + + "lone-services/rpc/equipment/pb" + "lone-services/services/equipment/internal/svc" + + "github.com/zeromicro/go-zero/core/logx" +) + +type AuthorizationStoreItemsLogic struct { + ctx context.Context + svcCtx *svc.ServiceContext + logx.Logger + BaseLogic +} + +func NewAuthorizationStoreItemsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *AuthorizationStoreItemsLogic { + return &AuthorizationStoreItemsLogic{ + ctx: ctx, + svcCtx: svcCtx, + Logger: logx.WithContext(ctx), + } +} + +// 门店端获取授权列表 +func (l *AuthorizationStoreItemsLogic) AuthorizationStoreItems(in *equipment.EmptyRequest) (*equipment.Response, error) { + adminInfo := utils.GetUserFromCtx(l.ctx) + if adminInfo.ID < utils.NumberOne { + return l.fail(utils.ErrorNoLoginInfo) + } + + w := modelbase.Params{Eq: map[string]string{ + "store_id": strconv.Itoa(int(adminInfo.ID))}} + var info []dao.AuthorizationRecordInfo + err := model.AuthorizationRecordModel{}.Init().Items(w, &info) + if err != nil { + l.Logger.Error(err) + return l.fail(utils.Fail) + } + + ids := make(map[int64]int64) + for _, v := range info { + ids[v.UserId] = v.UserId + } + var items []dao.AuthorizationRecordStoreItems + if len(ids) < utils.NumberOne { + return l.ok(items) + } + idsSlice := make([]int64, 0, len(ids)) + for k := range ids { + idsSlice = append(idsSlice, k) + } + + userItems := svc.GetUsers(idsSlice, l.svcCtx.UserSvcName) + + userIdItems := make(map[int64]dao.AuthorizationRecordStoreItems) + for _, val := range userItems { + ww := modelbase.Params{Eq: map[string]string{ + "store_id": strconv.Itoa(int(adminInfo.ID)), + "user_id": strconv.Itoa(int(adminInfo.ID))}} + storeNumber, err := model.AuthorizationRecordModel{}.Init().CountNumber(ww) + if err != nil { + l.Logger.Error(err) + } + + mobile := utils.StringEmpty + if val.Mobile != utils.StringEmpty { + tmp, phoneErr := utils.DecryptPhone(val.Mobile) + if phoneErr != nil { + l.Logger.Error(err) + } + mobile = tmp + } + + userIdItems[val.Id] = dao.AuthorizationRecordStoreItems{ + Username: val.Name, + Mobile: mobile, + Avatar: val.Avatar, + Birthday: val.Birthday, + Gender: int32(val.Gender), + UsageCount: int32(storeNumber), + } + + } + + for _, v := range info { + item, ok := userIdItems[v.UserId] + if !ok { + continue + } + item.Id = v.Id + item.Open = v.Open + item.Status = v.Status + item.UserId = v.UserId + items = append(items, item) + } + return l.ok(items) +} diff --git a/services/equipment/internal/server/equipmentServer.go b/services/equipment/internal/server/equipmentServer.go index 6f4dcd2..28a613c 100644 --- a/services/equipment/internal/server/equipmentServer.go +++ b/services/equipment/internal/server/equipmentServer.go @@ -183,6 +183,17 @@ func (s *EquipmentServer) AuthorizationItems(ctx context.Context, in *equipment. return l.AuthorizationItems(in) } +// 门店端获取授权列表 +func (s *EquipmentServer) AuthorizationStoreItems(ctx context.Context, in *equipment.EmptyRequest) (*equipment.Response, error) { + l := logic.NewAuthorizationStoreItemsLogic(ctx, s.svcCtx) + return l.AuthorizationStoreItems(in) +} + +func (s *EquipmentServer) ApiStoreCheckMask(ctx context.Context, in *equipment.StoreIdStringRequest) (*equipment.Response, error) { + l := logic.NewApiStoreCheckMaskLogic(ctx, s.svcCtx) + return l.ApiStoreCheckMask(in) +} + func (s *EquipmentServer) AuthorizationCode(ctx context.Context, in *equipment.EmptyRequest) (*equipment.Response, error) { l := logic.NewAuthorizationCodeLogic(ctx, s.svcCtx) return l.AuthorizationCode(in) diff --git a/services/equipment/internal/svc/grpcService.go b/services/equipment/internal/svc/grpcService.go index c1e9db2..23846eb 100644 --- a/services/equipment/internal/svc/grpcService.go +++ b/services/equipment/internal/svc/grpcService.go @@ -65,3 +65,20 @@ func GetStores(ids []int64, name string) []*store.InfoResponse { return items.Items } + +func GetUsers(ids []int64, name string) []*user.UserBriefItem { + cli, err := GetRpcClient(name) + if err != nil { + logx.Error(err) + return nil + } + + client := user.NewUserClient(cli.Conn()) + items, err := client.InternalUsersByIds(context.Background(), &user.InternalUsersByIdsReq{Ids: ids}) + if err != nil { + logx.Errorf("get store err: %v", err) + return nil + } + + return items.Items +} diff --git a/services/equipment/validator/mask.go b/services/equipment/validator/mask.go index 5553861..7e07e31 100644 --- a/services/equipment/validator/mask.go +++ b/services/equipment/validator/mask.go @@ -97,3 +97,16 @@ func (p MaskIdValidator) GetMessage() validate.ValidatorMessages { "MaskId.required": "缺少ID", } } + +type MaskStoreCheckValidator struct { + MaskId string `form:"mask_id" json:"mask_id" validate:"required"` + UserId int64 `form:"user_id" json:"user_id" validate:"required"` +} + +// GetMessage 提示消息 +func (p MaskStoreCheckValidator) GetMessage() validate.ValidatorMessages { + return validate.ValidatorMessages{ + "MaskId.required": "缺少ID", + "UserId.required": "缺少渠道ID", + } +} diff --git a/services/percutaneous/internal/dao/group.go b/services/percutaneous/internal/dao/group.go index bf37edf..5c7fb0a 100644 --- a/services/percutaneous/internal/dao/group.go +++ b/services/percutaneous/internal/dao/group.go @@ -4,6 +4,8 @@ import ( "lone-services/pkg/utils" ) +const WsCode = "ws-code" + type Group struct { Id int64 `gorm:"column:id;type:int;not null;autoIncrement" json:"id"` HostUserId int64 `gorm:"column:host_user_id;type:int;default:NULL" json:"host_user_id"` // 设备所有者ID diff --git a/services/percutaneous/internal/logic/getWsCodeLogic.go b/services/percutaneous/internal/logic/getWsCodeLogic.go new file mode 100644 index 0000000..d76217b --- /dev/null +++ b/services/percutaneous/internal/logic/getWsCodeLogic.go @@ -0,0 +1,43 @@ +package logic + +import ( + "context" + "fmt" + "lone-services/pkg/utils" + "lone-services/rpc/percutaneous/pb" + "lone-services/services/percutaneous/internal/dao" + "lone-services/services/percutaneous/internal/svc" + + "github.com/zeromicro/go-zero/core/logx" +) + +type GetWsCodeLogic struct { + ctx context.Context + svcCtx *svc.ServiceContext + logx.Logger + BaseLogic +} + +func NewGetWsCodeLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetWsCodeLogic { + return &GetWsCodeLogic{ + ctx: ctx, + svcCtx: svcCtx, + Logger: logx.WithContext(ctx), + } +} + +func (l *GetWsCodeLogic) GetWsCode(in *percutaneous.GetWsCodeRequest) (*percutaneous.Response, error) { + adminInfo := utils.GetUserFromCtx(l.ctx) + if adminInfo.ID < utils.NumberOne { + return l.fail(utils.ErrorNoLoginInfo) + } + + Type := "app" + if in.Type == utils.NumberOne { + Type = "operation" + } + + key := utils.MD5Encrypt(fmt.Sprintf("%d%s%s", adminInfo.ID, dao.WsCode, Type)) + + return l.ok(key) +} diff --git a/services/percutaneous/internal/logic/setPositionLogic.go b/services/percutaneous/internal/logic/setPositionLogic.go new file mode 100644 index 0000000..f13f8b4 --- /dev/null +++ b/services/percutaneous/internal/logic/setPositionLogic.go @@ -0,0 +1,47 @@ +package logic + +import ( + "context" + "lone-services/pkg/utils" + pkgws "lone-services/pkg/ws" + + "lone-services/rpc/percutaneous/pb" + "lone-services/services/percutaneous/internal/svc" + + "github.com/zeromicro/go-zero/core/logx" +) + +type SetPositionLogic struct { + ctx context.Context + svcCtx *svc.ServiceContext + logx.Logger + BaseLogic +} + +func NewSetPositionLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SetPositionLogic { + return &SetPositionLogic{ + ctx: ctx, + svcCtx: svcCtx, + Logger: logx.WithContext(ctx), + } +} + +// 使用指南 +func (l *SetPositionLogic) SetPosition(in *percutaneous.SetPositionRequest) (*percutaneous.Response, error) { + adminInfo := utils.GetUserFromCtx(l.ctx) + if adminInfo.ID < utils.NumberOne { + return l.fail(utils.ErrorNoLoginInfo) + } + + if _, err := pkgws.GetSession(l.ctx, in.SessionId); err != nil { + l.Errorf("set position session: %v", err) + return l.fail(utils.ErrorQRcodeExp) + } + + data := map[string]int{"ws_type": pkgws.WsTypeScan} + if err := pkgws.Publish(l.ctx, in.SessionId, pkgws.Success(data)); err != nil { + l.Errorf("qrcode scan publish: %v", err) + } + + return &percutaneous.Response{}, nil +} diff --git a/services/percutaneous/internal/server/percutaneousServer.go b/services/percutaneous/internal/server/percutaneousServer.go index d62d2cc..e064d9b 100644 --- a/services/percutaneous/internal/server/percutaneousServer.go +++ b/services/percutaneous/internal/server/percutaneousServer.go @@ -53,6 +53,17 @@ func (s *PercutaneousServer) UserItems(ctx context.Context, in *percutaneous.Use return l.UserItems(in) } +// 使用指南 +func (s *PercutaneousServer) SetPosition(ctx context.Context, in *percutaneous.SetPositionRequest) (*percutaneous.Response, error) { + l := logic.NewSetPositionLogic(ctx, s.svcCtx) + return l.SetPosition(in) +} + +func (s *PercutaneousServer) GetWsCode(ctx context.Context, in *percutaneous.GetWsCodeRequest) (*percutaneous.Response, error) { + l := logic.NewGetWsCodeLogic(ctx, s.svcCtx) + return l.GetWsCode(in) +} + // 添加用户 func (s *PercutaneousServer) WsAddUserStream(stream percutaneous.Percutaneous_WsAddUserStreamServer) error { l := logic.NewWsAddUserStreamLogic(stream.Context(), s.svcCtx) diff --git a/services/percutaneous/percutaneousclient/percutaneous.go b/services/percutaneous/percutaneousclient/percutaneous.go index fbdc901..cfa323c 100644 --- a/services/percutaneous/percutaneousclient/percutaneous.go +++ b/services/percutaneous/percutaneousclient/percutaneous.go @@ -14,17 +14,19 @@ import ( ) type ( - AddUserQRRequest = percutaneous.AddUserQRRequest - AddUserRequest = percutaneous.AddUserRequest - EmptyRequest = percutaneous.EmptyRequest - LoginQRRequest = percutaneous.LoginQRRequest - Response = percutaneous.Response - UseRequest = percutaneous.UseRequest - UsedLogRequest = percutaneous.UsedLogRequest - UserItemsRequest = percutaneous.UserItemsRequest - WifiCheckRequest = percutaneous.WifiCheckRequest - WifiSetRequest = percutaneous.WifiSetRequest - WsStreamRequest = percutaneous.WsStreamRequest + AddUserQRRequest = percutaneous.AddUserQRRequest + AddUserRequest = percutaneous.AddUserRequest + EmptyRequest = percutaneous.EmptyRequest + GetWsCodeRequest = percutaneous.GetWsCodeRequest + LoginQRRequest = percutaneous.LoginQRRequest + Response = percutaneous.Response + SetPositionRequest = percutaneous.SetPositionRequest + UseRequest = percutaneous.UseRequest + UsedLogRequest = percutaneous.UsedLogRequest + UserItemsRequest = percutaneous.UserItemsRequest + WifiCheckRequest = percutaneous.WifiCheckRequest + WifiSetRequest = percutaneous.WifiSetRequest + WsStreamRequest = percutaneous.WsStreamRequest Percutaneous interface { WifiCheck(ctx context.Context, in *WifiCheckRequest, opts ...grpc.CallOption) (*Response, error) @@ -33,6 +35,9 @@ type ( UsedLog(ctx context.Context, in *UsedLogRequest, opts ...grpc.CallOption) (*Response, error) AddUser(ctx context.Context, in *AddUserRequest, opts ...grpc.CallOption) (*Response, error) UserItems(ctx context.Context, in *UserItemsRequest, opts ...grpc.CallOption) (*Response, error) + // 使用指南 + SetPosition(ctx context.Context, in *SetPositionRequest, opts ...grpc.CallOption) (*Response, error) + GetWsCode(ctx context.Context, in *GetWsCodeRequest, opts ...grpc.CallOption) (*Response, error) // 添加用户 WsAddUserStream(ctx context.Context, opts ...grpc.CallOption) (percutaneous.Percutaneous_WsAddUserStreamClient, error) } @@ -78,6 +83,17 @@ func (m *defaultPercutaneous) UserItems(ctx context.Context, in *UserItemsReques return client.UserItems(ctx, in, opts...) } +// 使用指南 +func (m *defaultPercutaneous) SetPosition(ctx context.Context, in *SetPositionRequest, opts ...grpc.CallOption) (*Response, error) { + client := percutaneous.NewPercutaneousClient(m.cli.Conn()) + return client.SetPosition(ctx, in, opts...) +} + +func (m *defaultPercutaneous) GetWsCode(ctx context.Context, in *GetWsCodeRequest, opts ...grpc.CallOption) (*Response, error) { + client := percutaneous.NewPercutaneousClient(m.cli.Conn()) + return client.GetWsCode(ctx, in, opts...) +} + // 添加用户 func (m *defaultPercutaneous) WsAddUserStream(ctx context.Context, opts ...grpc.CallOption) (percutaneous.Percutaneous_WsAddUserStreamClient, error) { client := percutaneous.NewPercutaneousClient(m.cli.Conn()) diff --git a/services/ws/internal/logic/connectLogic.go b/services/ws/internal/logic/connectLogic.go index 5ecef8a..9755f0f 100644 --- a/services/ws/internal/logic/connectLogic.go +++ b/services/ws/internal/logic/connectLogic.go @@ -91,6 +91,12 @@ func (l *ConnectLogic) pushSnapshot(c *svc.Client, sess *pkgws.Session) error { } else { data = nil } + case pkgws.StatusUsePosition: + if len(sess.Data) > 0 && string(sess.Data) != "null" { + data = sess.Data + } else { + data = nil + } default: data = nil }