diff --git a/pkg/utils/status.go b/pkg/utils/status.go index 9e64dfd..b61eacc 100644 --- a/pkg/utils/status.go +++ b/pkg/utils/status.go @@ -122,7 +122,9 @@ var ( ErrorVerifyReview = Status{Code: 10011, Msg: "不能重复审核"} ErrorOrderOver = Status{Code: 11012, Msg: "订单已完结"} // 数据类 - ErrorDataIsExist = Status{Code: 11004, Msg: "数据已存在"} + ErrorDataIsExist = Status{Code: 11004, Msg: "数据已存在"} + ErrorBindError = Status{Code: 11016, Msg: "设备已绑定，请不要重复绑定"} + ErrorBindOtherError = Status{Code: 110167, Msg: "该设备已绑定其它用户，请不要重复绑定"} // 参数类 ErrorReasonParams = Status{Code: 10012, Msg: "原因不能为空"} @@ -159,8 +161,6 @@ var ( ErrorFirstTryErr = NewError(11008, "已购买过首次试用品") ErrorTryError = NewError(11009, "不满足购买条件") ErrorDataNotExist = NewError(11011, "数据不存在") - ErrorBindError = NewError(11012, "设备已绑定，请不要重复绑定") - ErrorBindOtherError = NewError(11013, "该设备已绑定其它用户，请不要重复绑定") ) func SetError(error Status, msg string) Status { diff --git a/rpc/equipment/equipment.pb b/rpc/equipment/equipment.pb index cc08249..23e1c8d 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 b49f5ce..448254c 100644 --- a/rpc/equipment/equipment.proto +++ b/rpc/equipment/equipment.proto @@ -50,6 +50,96 @@ message StatusRequest { string reason = 3; } +message MaskItemsRequest { + int32 page = 1; + int32 size =2; + int32 type =3; + string facial_mask_id = 4; + int32 is_on_trial = 5; + int32 model = 6; + int32 worker_group_id = 7; + string batch = 8; + int32 is_store = 9; + int32 use_scenario = 10; + int32 effect = 11; + repeated string time = 12; + int32 is_use = 13; +} + +message BeansItemsRequest { + int32 page = 1; + int32 size =2; + string name = 3; + repeated string time = 4; +} + +message ApiBindAddRequest { + string host_nickname = 1; + string host_code = 2; +} + +message ApiUnBindRequest { + string host_code = 1; +} + +message EmptyRequest { + +} + +message ApiBindExpiryRequest { + string host_code = 1; + int32 type = 2; +} +message ApiBindExpiryGetRequest { + string host_code = 1; +} +message ApiBeansItemsRequest { + int32 page = 1; + int32 size = 2; +} +message ApiBeansAddRequest { + string image = 1; + int64 id = 2; +} +message ApiMaskAddRequest { + string face_mask_id = 1; + string produce_time = 2; + int64 quality_guarantee_period= 3; + int32 is_on_trial = 4; + string model = 5; + string batch = 6; + int32 is_store = 7; + int32 is_online = 8; + int64 model_id = 9; + int32 use_scenario = 10; + int64 effect = 11; + int64 worker_group_id = 12; +} + +message ApiMaskUseRequest { + string facial_mask_id = 1; + string use_time = 2; + string host_code = 3; + string gear_position = 4; + string voltage = 5; + string electric_current = 6; + string efficiency = 7; + string resistance = 8; + string score = 9; + int32 store_id = 10; +} +message ApiMaskUsedItemsRequest { + string facial_mask_id = 1; + string use_time = 2; + string host_code = 3; +} + +message BindExpiryRequest { + int64 id =1; + string expiry =2; + string reason = 3; +} + service Equipment { rpc Items(ItemsRequest) returns(Response){ option (google.api.http) = { @@ -81,4 +171,108 @@ service Equipment { body: "*" }; }; + rpc MaskItems(MaskItemsRequest) returns(Response){ + option (google.api.http) = { + post: "/admin/v3/mask/items" + body: "*" + }; + }; + + rpc BeansItems(BeansItemsRequest) returns(Response){ + option (google.api.http) = { + post: "/admin/v3/beans/items" + body: "*" + }; + }; + + rpc BindExpiry(BindExpiryRequest) returns(Response){ + option (google.api.http) = { + post: "/admin/v3/device/expiry" + body: "*" + }; + }; + + /*******************API*************************/ + rpc ApiMaskAdd(ApiMaskAddRequest) returns(Response){ + option (google.api.http) = { + post: "/api/v3/mask/add" + body: "*" + }; + }; + + rpc ApiBindItems(EmptyRequest) returns(Response){ + option (google.api.http) = { + post: "/api/v3/device/items" + body: "*" + }; + }; + rpc ApiUnBind(ApiUnBindRequest) returns(Response){ + option (google.api.http) = { + post: "/api/v3/device/unbind" + body: "*" + }; + }; + rpc ApiBindAdd(ApiBindAddRequest) returns(Response){ + option (google.api.http) = { + post: "/api/v3/device/bind" + body: "*" + }; + }; + rpc ApiBindExpiry(ApiBindExpiryRequest) returns(Response){ + option (google.api.http) = { + post: "/api/v3/device/expiry" + body: "*" + }; + }; + + rpc ApiBindExpiryGet(ApiBindExpiryGetRequest) returns(Response){ + option (google.api.http) = { + post: "/api/v3/device/expiry/get" + body: "*" + }; + }; + + rpc ApiBeansAdd(ApiBeansAddRequest) returns(Response){ + option (google.api.http) = { + post: "/api/v3/beans/add" + body: "*" + }; + }; + rpc ApiBeansLast(EmptyRequest) returns(Response){ + option (google.api.http) = { + post: "/api/v3/beans/last" + body: "*" + }; + }; + rpc ApiBeansItems(ApiBeansItemsRequest) returns(Response){ + option (google.api.http) = { + post: "/api/v3/beans/items" + body: "*" + }; + }; + rpc ApiMaskUse(ApiMaskUseRequest) returns(Response){ + option (google.api.http) = { + post: "/api/v3/mask/use" + body: "*" + }; + }; + rpc ApiMaskUsedItems(ApiMaskUsedItemsRequest) returns(Response){ + option (google.api.http) = { + post: "/api/v3/mask/used/items" + body: "*" + }; + }; + rpc ApiMaskStoreUse(ApiMaskUseRequest) returns(Response){ + option (google.api.http) = { + post: "/api/v3/mask/store/use" + body: "*" + }; + }; + rpc ApiMaskStoreUseItems(ApiMaskUsedItemsRequest) returns(Response){ + option (google.api.http) = { + post: "/api/v3/mask/store/used/items" + body: "*" + }; + }; + } \ No newline at end of file diff --git a/rpc/equipment/pb/equipment.pb.go b/rpc/equipment/pb/equipment.pb.go index cbd6f8d..e60c832 100644 --- a/rpc/equipment/pb/equipment.pb.go +++ b/rpc/equipment/pb/equipment.pb.go @@ -454,6 +454,914 @@ func (x *StatusRequest) GetReason() string { return "" } +type MaskItemsRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + Page int32 `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"` + Size int32 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` + Type int32 `protobuf:"varint,3,opt,name=type,proto3" json:"type,omitempty"` + FacialMaskId string `protobuf:"bytes,4,opt,name=facial_mask_id,json=facialMaskId,proto3" json:"facial_mask_id,omitempty"` + IsOnTrial int32 `protobuf:"varint,5,opt,name=is_on_trial,json=isOnTrial,proto3" json:"is_on_trial,omitempty"` + Model int32 `protobuf:"varint,6,opt,name=model,proto3" json:"model,omitempty"` + WorkerGroupId int32 `protobuf:"varint,7,opt,name=worker_group_id,json=workerGroupId,proto3" json:"worker_group_id,omitempty"` + Batch string `protobuf:"bytes,8,opt,name=batch,proto3" json:"batch,omitempty"` + IsStore int32 `protobuf:"varint,9,opt,name=is_store,json=isStore,proto3" json:"is_store,omitempty"` + UseScenario int32 `protobuf:"varint,10,opt,name=use_scenario,json=useScenario,proto3" json:"use_scenario,omitempty"` + Effect int32 `protobuf:"varint,11,opt,name=effect,proto3" json:"effect,omitempty"` + Time []string `protobuf:"bytes,12,rep,name=time,proto3" json:"time,omitempty"` + IsUse int32 `protobuf:"varint,13,opt,name=is_use,json=isUse,proto3" json:"is_use,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *MaskItemsRequest) Reset() { + *x = MaskItemsRequest{} + mi := &file_equipment_equipment_proto_msgTypes[6] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *MaskItemsRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*MaskItemsRequest) ProtoMessage() {} + +func (x *MaskItemsRequest) 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 MaskItemsRequest.ProtoReflect.Descriptor instead. +func (*MaskItemsRequest) Descriptor() ([]byte, []int) { + return file_equipment_equipment_proto_rawDescGZIP(), []int{6} +} + +func (x *MaskItemsRequest) GetPage() int32 { + if x != nil { + return x.Page + } + return 0 +} + +func (x *MaskItemsRequest) GetSize() int32 { + if x != nil { + return x.Size + } + return 0 +} + +func (x *MaskItemsRequest) GetType() int32 { + if x != nil { + return x.Type + } + return 0 +} + +func (x *MaskItemsRequest) GetFacialMaskId() string { + if x != nil { + return x.FacialMaskId + } + return "" +} + +func (x *MaskItemsRequest) GetIsOnTrial() int32 { + if x != nil { + return x.IsOnTrial + } + return 0 +} + +func (x *MaskItemsRequest) GetModel() int32 { + if x != nil { + return x.Model + } + return 0 +} + +func (x *MaskItemsRequest) GetWorkerGroupId() int32 { + if x != nil { + return x.WorkerGroupId + } + return 0 +} + +func (x *MaskItemsRequest) GetBatch() string { + if x != nil { + return x.Batch + } + return "" +} + +func (x *MaskItemsRequest) GetIsStore() int32 { + if x != nil { + return x.IsStore + } + return 0 +} + +func (x *MaskItemsRequest) GetUseScenario() int32 { + if x != nil { + return x.UseScenario + } + return 0 +} + +func (x *MaskItemsRequest) GetEffect() int32 { + if x != nil { + return x.Effect + } + return 0 +} + +func (x *MaskItemsRequest) GetTime() []string { + if x != nil { + return x.Time + } + return nil +} + +func (x *MaskItemsRequest) GetIsUse() int32 { + if x != nil { + return x.IsUse + } + return 0 +} + +type BeansItemsRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + Page int32 `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"` + Size int32 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` + Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` + Time []string `protobuf:"bytes,4,rep,name=time,proto3" json:"time,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *BeansItemsRequest) Reset() { + *x = BeansItemsRequest{} + mi := &file_equipment_equipment_proto_msgTypes[7] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *BeansItemsRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*BeansItemsRequest) ProtoMessage() {} + +func (x *BeansItemsRequest) ProtoReflect() protoreflect.Message { + mi := &file_equipment_equipment_proto_msgTypes[7] + 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 BeansItemsRequest.ProtoReflect.Descriptor instead. +func (*BeansItemsRequest) Descriptor() ([]byte, []int) { + return file_equipment_equipment_proto_rawDescGZIP(), []int{7} +} + +func (x *BeansItemsRequest) GetPage() int32 { + if x != nil { + return x.Page + } + return 0 +} + +func (x *BeansItemsRequest) GetSize() int32 { + if x != nil { + return x.Size + } + return 0 +} + +func (x *BeansItemsRequest) GetName() string { + if x != nil { + return x.Name + } + return "" +} + +func (x *BeansItemsRequest) GetTime() []string { + if x != nil { + return x.Time + } + return nil +} + +type ApiBindAddRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + HostNickname string `protobuf:"bytes,1,opt,name=host_nickname,json=hostNickname,proto3" json:"host_nickname,omitempty"` + HostCode string `protobuf:"bytes,2,opt,name=host_code,json=hostCode,proto3" json:"host_code,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *ApiBindAddRequest) Reset() { + *x = ApiBindAddRequest{} + mi := &file_equipment_equipment_proto_msgTypes[8] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *ApiBindAddRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ApiBindAddRequest) ProtoMessage() {} + +func (x *ApiBindAddRequest) ProtoReflect() protoreflect.Message { + mi := &file_equipment_equipment_proto_msgTypes[8] + 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 ApiBindAddRequest.ProtoReflect.Descriptor instead. +func (*ApiBindAddRequest) Descriptor() ([]byte, []int) { + return file_equipment_equipment_proto_rawDescGZIP(), []int{8} +} + +func (x *ApiBindAddRequest) GetHostNickname() string { + if x != nil { + return x.HostNickname + } + return "" +} + +func (x *ApiBindAddRequest) GetHostCode() string { + if x != nil { + return x.HostCode + } + return "" +} + +type ApiUnBindRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + HostCode string `protobuf:"bytes,1,opt,name=host_code,json=hostCode,proto3" json:"host_code,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *ApiUnBindRequest) Reset() { + *x = ApiUnBindRequest{} + mi := &file_equipment_equipment_proto_msgTypes[9] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *ApiUnBindRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ApiUnBindRequest) ProtoMessage() {} + +func (x *ApiUnBindRequest) ProtoReflect() protoreflect.Message { + mi := &file_equipment_equipment_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 ApiUnBindRequest.ProtoReflect.Descriptor instead. +func (*ApiUnBindRequest) Descriptor() ([]byte, []int) { + return file_equipment_equipment_proto_rawDescGZIP(), []int{9} +} + +func (x *ApiUnBindRequest) GetHostCode() string { + if x != nil { + return x.HostCode + } + return "" +} + +type EmptyRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *EmptyRequest) Reset() { + *x = EmptyRequest{} + mi := &file_equipment_equipment_proto_msgTypes[10] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *EmptyRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*EmptyRequest) ProtoMessage() {} + +func (x *EmptyRequest) ProtoReflect() protoreflect.Message { + mi := &file_equipment_equipment_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 EmptyRequest.ProtoReflect.Descriptor instead. +func (*EmptyRequest) Descriptor() ([]byte, []int) { + return file_equipment_equipment_proto_rawDescGZIP(), []int{10} +} + +type ApiBindExpiryRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + HostCode string `protobuf:"bytes,1,opt,name=host_code,json=hostCode,proto3" json:"host_code,omitempty"` + Type int32 `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *ApiBindExpiryRequest) Reset() { + *x = ApiBindExpiryRequest{} + mi := &file_equipment_equipment_proto_msgTypes[11] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *ApiBindExpiryRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ApiBindExpiryRequest) ProtoMessage() {} + +func (x *ApiBindExpiryRequest) ProtoReflect() protoreflect.Message { + mi := &file_equipment_equipment_proto_msgTypes[11] + 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 ApiBindExpiryRequest.ProtoReflect.Descriptor instead. +func (*ApiBindExpiryRequest) Descriptor() ([]byte, []int) { + return file_equipment_equipment_proto_rawDescGZIP(), []int{11} +} + +func (x *ApiBindExpiryRequest) GetHostCode() string { + if x != nil { + return x.HostCode + } + return "" +} + +func (x *ApiBindExpiryRequest) GetType() int32 { + if x != nil { + return x.Type + } + return 0 +} + +type ApiBindExpiryGetRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + HostCode string `protobuf:"bytes,1,opt,name=host_code,json=hostCode,proto3" json:"host_code,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *ApiBindExpiryGetRequest) Reset() { + *x = ApiBindExpiryGetRequest{} + mi := &file_equipment_equipment_proto_msgTypes[12] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *ApiBindExpiryGetRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ApiBindExpiryGetRequest) ProtoMessage() {} + +func (x *ApiBindExpiryGetRequest) ProtoReflect() protoreflect.Message { + mi := &file_equipment_equipment_proto_msgTypes[12] + 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 ApiBindExpiryGetRequest.ProtoReflect.Descriptor instead. +func (*ApiBindExpiryGetRequest) Descriptor() ([]byte, []int) { + return file_equipment_equipment_proto_rawDescGZIP(), []int{12} +} + +func (x *ApiBindExpiryGetRequest) GetHostCode() string { + if x != nil { + return x.HostCode + } + return "" +} + +type ApiBeansItemsRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + Page int32 `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"` + Size int32 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *ApiBeansItemsRequest) Reset() { + *x = ApiBeansItemsRequest{} + mi := &file_equipment_equipment_proto_msgTypes[13] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *ApiBeansItemsRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ApiBeansItemsRequest) ProtoMessage() {} + +func (x *ApiBeansItemsRequest) ProtoReflect() protoreflect.Message { + mi := &file_equipment_equipment_proto_msgTypes[13] + 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 ApiBeansItemsRequest.ProtoReflect.Descriptor instead. +func (*ApiBeansItemsRequest) Descriptor() ([]byte, []int) { + return file_equipment_equipment_proto_rawDescGZIP(), []int{13} +} + +func (x *ApiBeansItemsRequest) GetPage() int32 { + if x != nil { + return x.Page + } + return 0 +} + +func (x *ApiBeansItemsRequest) GetSize() int32 { + if x != nil { + return x.Size + } + return 0 +} + +type ApiBeansAddRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + Image string `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"` + Id int64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *ApiBeansAddRequest) Reset() { + *x = ApiBeansAddRequest{} + mi := &file_equipment_equipment_proto_msgTypes[14] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *ApiBeansAddRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ApiBeansAddRequest) ProtoMessage() {} + +func (x *ApiBeansAddRequest) ProtoReflect() protoreflect.Message { + mi := &file_equipment_equipment_proto_msgTypes[14] + 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 ApiBeansAddRequest.ProtoReflect.Descriptor instead. +func (*ApiBeansAddRequest) Descriptor() ([]byte, []int) { + return file_equipment_equipment_proto_rawDescGZIP(), []int{14} +} + +func (x *ApiBeansAddRequest) GetImage() string { + if x != nil { + return x.Image + } + return "" +} + +func (x *ApiBeansAddRequest) GetId() int64 { + if x != nil { + return x.Id + } + return 0 +} + +type ApiMaskAddRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + FaceMaskId string `protobuf:"bytes,1,opt,name=face_mask_id,json=faceMaskId,proto3" json:"face_mask_id,omitempty"` + ProduceTime string `protobuf:"bytes,2,opt,name=produce_time,json=produceTime,proto3" json:"produce_time,omitempty"` + QualityGuaranteePeriod int64 `protobuf:"varint,3,opt,name=quality_guarantee_period,json=qualityGuaranteePeriod,proto3" json:"quality_guarantee_period,omitempty"` + IsOnTrial int32 `protobuf:"varint,4,opt,name=is_on_trial,json=isOnTrial,proto3" json:"is_on_trial,omitempty"` + Model string `protobuf:"bytes,5,opt,name=model,proto3" json:"model,omitempty"` + Batch string `protobuf:"bytes,6,opt,name=batch,proto3" json:"batch,omitempty"` + IsStore int32 `protobuf:"varint,7,opt,name=is_store,json=isStore,proto3" json:"is_store,omitempty"` + IsOnline int32 `protobuf:"varint,8,opt,name=is_online,json=isOnline,proto3" json:"is_online,omitempty"` + ModelId int64 `protobuf:"varint,9,opt,name=model_id,json=modelId,proto3" json:"model_id,omitempty"` + UseScenario int32 `protobuf:"varint,10,opt,name=use_scenario,json=useScenario,proto3" json:"use_scenario,omitempty"` + Effect int64 `protobuf:"varint,11,opt,name=effect,proto3" json:"effect,omitempty"` + WorkerGroupId int64 `protobuf:"varint,12,opt,name=worker_group_id,json=workerGroupId,proto3" json:"worker_group_id,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *ApiMaskAddRequest) Reset() { + *x = ApiMaskAddRequest{} + mi := &file_equipment_equipment_proto_msgTypes[15] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *ApiMaskAddRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ApiMaskAddRequest) ProtoMessage() {} + +func (x *ApiMaskAddRequest) ProtoReflect() protoreflect.Message { + mi := &file_equipment_equipment_proto_msgTypes[15] + 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 ApiMaskAddRequest.ProtoReflect.Descriptor instead. +func (*ApiMaskAddRequest) Descriptor() ([]byte, []int) { + return file_equipment_equipment_proto_rawDescGZIP(), []int{15} +} + +func (x *ApiMaskAddRequest) GetFaceMaskId() string { + if x != nil { + return x.FaceMaskId + } + return "" +} + +func (x *ApiMaskAddRequest) GetProduceTime() string { + if x != nil { + return x.ProduceTime + } + return "" +} + +func (x *ApiMaskAddRequest) GetQualityGuaranteePeriod() int64 { + if x != nil { + return x.QualityGuaranteePeriod + } + return 0 +} + +func (x *ApiMaskAddRequest) GetIsOnTrial() int32 { + if x != nil { + return x.IsOnTrial + } + return 0 +} + +func (x *ApiMaskAddRequest) GetModel() string { + if x != nil { + return x.Model + } + return "" +} + +func (x *ApiMaskAddRequest) GetBatch() string { + if x != nil { + return x.Batch + } + return "" +} + +func (x *ApiMaskAddRequest) GetIsStore() int32 { + if x != nil { + return x.IsStore + } + return 0 +} + +func (x *ApiMaskAddRequest) GetIsOnline() int32 { + if x != nil { + return x.IsOnline + } + return 0 +} + +func (x *ApiMaskAddRequest) GetModelId() int64 { + if x != nil { + return x.ModelId + } + return 0 +} + +func (x *ApiMaskAddRequest) GetUseScenario() int32 { + if x != nil { + return x.UseScenario + } + return 0 +} + +func (x *ApiMaskAddRequest) GetEffect() int64 { + if x != nil { + return x.Effect + } + return 0 +} + +func (x *ApiMaskAddRequest) GetWorkerGroupId() int64 { + if x != nil { + return x.WorkerGroupId + } + return 0 +} + +type ApiMaskUseRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + FacialMaskId string `protobuf:"bytes,1,opt,name=facial_mask_id,json=facialMaskId,proto3" json:"facial_mask_id,omitempty"` + UseTime string `protobuf:"bytes,2,opt,name=use_time,json=useTime,proto3" json:"use_time,omitempty"` + HostCode string `protobuf:"bytes,3,opt,name=host_code,json=hostCode,proto3" json:"host_code,omitempty"` + GearPosition string `protobuf:"bytes,4,opt,name=gear_position,json=gearPosition,proto3" json:"gear_position,omitempty"` + Voltage string `protobuf:"bytes,5,opt,name=voltage,proto3" json:"voltage,omitempty"` + ElectricCurrent string `protobuf:"bytes,6,opt,name=electric_current,json=electricCurrent,proto3" json:"electric_current,omitempty"` + Efficiency string `protobuf:"bytes,7,opt,name=efficiency,proto3" json:"efficiency,omitempty"` + Resistance string `protobuf:"bytes,8,opt,name=resistance,proto3" json:"resistance,omitempty"` + Score string `protobuf:"bytes,9,opt,name=score,proto3" json:"score,omitempty"` + StoreId int32 `protobuf:"varint,10,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *ApiMaskUseRequest) Reset() { + *x = ApiMaskUseRequest{} + mi := &file_equipment_equipment_proto_msgTypes[16] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *ApiMaskUseRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ApiMaskUseRequest) ProtoMessage() {} + +func (x *ApiMaskUseRequest) ProtoReflect() protoreflect.Message { + mi := &file_equipment_equipment_proto_msgTypes[16] + 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 ApiMaskUseRequest.ProtoReflect.Descriptor instead. +func (*ApiMaskUseRequest) Descriptor() ([]byte, []int) { + return file_equipment_equipment_proto_rawDescGZIP(), []int{16} +} + +func (x *ApiMaskUseRequest) GetFacialMaskId() string { + if x != nil { + return x.FacialMaskId + } + return "" +} + +func (x *ApiMaskUseRequest) GetUseTime() string { + if x != nil { + return x.UseTime + } + return "" +} + +func (x *ApiMaskUseRequest) GetHostCode() string { + if x != nil { + return x.HostCode + } + return "" +} + +func (x *ApiMaskUseRequest) GetGearPosition() string { + if x != nil { + return x.GearPosition + } + return "" +} + +func (x *ApiMaskUseRequest) GetVoltage() string { + if x != nil { + return x.Voltage + } + return "" +} + +func (x *ApiMaskUseRequest) GetElectricCurrent() string { + if x != nil { + return x.ElectricCurrent + } + return "" +} + +func (x *ApiMaskUseRequest) GetEfficiency() string { + if x != nil { + return x.Efficiency + } + return "" +} + +func (x *ApiMaskUseRequest) GetResistance() string { + if x != nil { + return x.Resistance + } + return "" +} + +func (x *ApiMaskUseRequest) GetScore() string { + if x != nil { + return x.Score + } + return "" +} + +func (x *ApiMaskUseRequest) GetStoreId() int32 { + if x != nil { + return x.StoreId + } + return 0 +} + +type ApiMaskUsedItemsRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + FacialMaskId string `protobuf:"bytes,1,opt,name=facial_mask_id,json=facialMaskId,proto3" json:"facial_mask_id,omitempty"` + UseTime string `protobuf:"bytes,2,opt,name=use_time,json=useTime,proto3" json:"use_time,omitempty"` + HostCode string `protobuf:"bytes,3,opt,name=host_code,json=hostCode,proto3" json:"host_code,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *ApiMaskUsedItemsRequest) Reset() { + *x = ApiMaskUsedItemsRequest{} + mi := &file_equipment_equipment_proto_msgTypes[17] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *ApiMaskUsedItemsRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*ApiMaskUsedItemsRequest) ProtoMessage() {} + +func (x *ApiMaskUsedItemsRequest) ProtoReflect() protoreflect.Message { + mi := &file_equipment_equipment_proto_msgTypes[17] + 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 ApiMaskUsedItemsRequest.ProtoReflect.Descriptor instead. +func (*ApiMaskUsedItemsRequest) Descriptor() ([]byte, []int) { + return file_equipment_equipment_proto_rawDescGZIP(), []int{17} +} + +func (x *ApiMaskUsedItemsRequest) GetFacialMaskId() string { + if x != nil { + return x.FacialMaskId + } + return "" +} + +func (x *ApiMaskUsedItemsRequest) GetUseTime() string { + if x != nil { + return x.UseTime + } + return "" +} + +func (x *ApiMaskUsedItemsRequest) GetHostCode() string { + if x != nil { + return x.HostCode + } + return "" +} + +type BindExpiryRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` + Expiry string `protobuf:"bytes,2,opt,name=expiry,proto3" json:"expiry,omitempty"` + Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *BindExpiryRequest) Reset() { + *x = BindExpiryRequest{} + mi := &file_equipment_equipment_proto_msgTypes[18] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *BindExpiryRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*BindExpiryRequest) ProtoMessage() {} + +func (x *BindExpiryRequest) ProtoReflect() protoreflect.Message { + mi := &file_equipment_equipment_proto_msgTypes[18] + 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 BindExpiryRequest.ProtoReflect.Descriptor instead. +func (*BindExpiryRequest) Descriptor() ([]byte, []int) { + return file_equipment_equipment_proto_rawDescGZIP(), []int{18} +} + +func (x *BindExpiryRequest) GetId() int64 { + if x != nil { + return x.Id + } + return 0 +} + +func (x *BindExpiryRequest) GetExpiry() string { + if x != nil { + return x.Expiry + } + return "" +} + +func (x *BindExpiryRequest) GetReason() string { + if x != nil { + return x.Reason + } + return "" +} + var File_equipment_equipment_proto protoreflect.FileDescriptor const file_equipment_equipment_proto_rawDesc = "" + @@ -493,13 +1401,110 @@ const file_equipment_equipment_proto_rawDesc = "" + "\rStatusRequest\x12\x0e\n" + "\x02id\x18\x01 \x01(\x03R\x02id\x12\x16\n" + "\x06status\x18\x02 \x01(\x05R\x06status\x12\x16\n" + - "\x06reason\x18\x03 \x01(\tR\x06reason2\xd0\x03\n" + + "\x06reason\x18\x03 \x01(\tR\x06reason\"\xe9\x02\n" + + "\x10MaskItemsRequest\x12\x12\n" + + "\x04page\x18\x01 \x01(\x05R\x04page\x12\x12\n" + + "\x04size\x18\x02 \x01(\x05R\x04size\x12\x12\n" + + "\x04type\x18\x03 \x01(\x05R\x04type\x12$\n" + + "\x0efacial_mask_id\x18\x04 \x01(\tR\ffacialMaskId\x12\x1e\n" + + "\vis_on_trial\x18\x05 \x01(\x05R\tisOnTrial\x12\x14\n" + + "\x05model\x18\x06 \x01(\x05R\x05model\x12&\n" + + "\x0fworker_group_id\x18\a \x01(\x05R\rworkerGroupId\x12\x14\n" + + "\x05batch\x18\b \x01(\tR\x05batch\x12\x19\n" + + "\bis_store\x18\t \x01(\x05R\aisStore\x12!\n" + + "\fuse_scenario\x18\n" + + " \x01(\x05R\vuseScenario\x12\x16\n" + + "\x06effect\x18\v \x01(\x05R\x06effect\x12\x12\n" + + "\x04time\x18\f \x03(\tR\x04time\x12\x15\n" + + "\x06is_use\x18\r \x01(\x05R\x05isUse\"c\n" + + "\x11BeansItemsRequest\x12\x12\n" + + "\x04page\x18\x01 \x01(\x05R\x04page\x12\x12\n" + + "\x04size\x18\x02 \x01(\x05R\x04size\x12\x12\n" + + "\x04name\x18\x03 \x01(\tR\x04name\x12\x12\n" + + "\x04time\x18\x04 \x03(\tR\x04time\"U\n" + + "\x11ApiBindAddRequest\x12#\n" + + "\rhost_nickname\x18\x01 \x01(\tR\fhostNickname\x12\x1b\n" + + "\thost_code\x18\x02 \x01(\tR\bhostCode\"/\n" + + "\x10ApiUnBindRequest\x12\x1b\n" + + "\thost_code\x18\x01 \x01(\tR\bhostCode\"\x0e\n" + + "\fEmptyRequest\"G\n" + + "\x14ApiBindExpiryRequest\x12\x1b\n" + + "\thost_code\x18\x01 \x01(\tR\bhostCode\x12\x12\n" + + "\x04type\x18\x02 \x01(\x05R\x04type\"6\n" + + "\x17ApiBindExpiryGetRequest\x12\x1b\n" + + "\thost_code\x18\x01 \x01(\tR\bhostCode\">\n" + + "\x14ApiBeansItemsRequest\x12\x12\n" + + "\x04page\x18\x01 \x01(\x05R\x04page\x12\x12\n" + + "\x04size\x18\x02 \x01(\x05R\x04size\":\n" + + "\x12ApiBeansAddRequest\x12\x14\n" + + "\x05image\x18\x01 \x01(\tR\x05image\x12\x0e\n" + + "\x02id\x18\x02 \x01(\x03R\x02id\"\x94\x03\n" + + "\x11ApiMaskAddRequest\x12 \n" + + "\fface_mask_id\x18\x01 \x01(\tR\n" + + "faceMaskId\x12!\n" + + "\fproduce_time\x18\x02 \x01(\tR\vproduceTime\x128\n" + + "\x18quality_guarantee_period\x18\x03 \x01(\x03R\x16qualityGuaranteePeriod\x12\x1e\n" + + "\vis_on_trial\x18\x04 \x01(\x05R\tisOnTrial\x12\x14\n" + + "\x05model\x18\x05 \x01(\tR\x05model\x12\x14\n" + + "\x05batch\x18\x06 \x01(\tR\x05batch\x12\x19\n" + + "\bis_store\x18\a \x01(\x05R\aisStore\x12\x1b\n" + + "\tis_online\x18\b \x01(\x05R\bisOnline\x12\x19\n" + + "\bmodel_id\x18\t \x01(\x03R\amodelId\x12!\n" + + "\fuse_scenario\x18\n" + + " \x01(\x05R\vuseScenario\x12\x16\n" + + "\x06effect\x18\v \x01(\x03R\x06effect\x12&\n" + + "\x0fworker_group_id\x18\f \x01(\x03R\rworkerGroupId\"\xcc\x02\n" + + "\x11ApiMaskUseRequest\x12$\n" + + "\x0efacial_mask_id\x18\x01 \x01(\tR\ffacialMaskId\x12\x19\n" + + "\buse_time\x18\x02 \x01(\tR\auseTime\x12\x1b\n" + + "\thost_code\x18\x03 \x01(\tR\bhostCode\x12#\n" + + "\rgear_position\x18\x04 \x01(\tR\fgearPosition\x12\x18\n" + + "\avoltage\x18\x05 \x01(\tR\avoltage\x12)\n" + + "\x10electric_current\x18\x06 \x01(\tR\x0felectricCurrent\x12\x1e\n" + + "\n" + + "efficiency\x18\a \x01(\tR\n" + + "efficiency\x12\x1e\n" + + "\n" + + "resistance\x18\b \x01(\tR\n" + + "resistance\x12\x14\n" + + "\x05score\x18\t \x01(\tR\x05score\x12\x19\n" + + "\bstore_id\x18\n" + + " \x01(\x05R\astoreId\"w\n" + + "\x17ApiMaskUsedItemsRequest\x12$\n" + + "\x0efacial_mask_id\x18\x01 \x01(\tR\ffacialMaskId\x12\x19\n" + + "\buse_time\x18\x02 \x01(\tR\auseTime\x12\x1b\n" + + "\thost_code\x18\x03 \x01(\tR\bhostCode\"S\n" + + "\x11BindExpiryRequest\x12\x0e\n" + + "\x02id\x18\x01 \x01(\x03R\x02id\x12\x16\n" + + "\x06expiry\x18\x02 \x01(\tR\x06expiry\x12\x16\n" + + "\x06reason\x18\x03 \x01(\tR\x06reason2\xab\x10\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" + "\x06Create\x12\x18.equipment.CreateRequest\x1a\x13.equipment.Response\"#\x82\xd3\xe4\x93\x02\x1d:\x01*\"\x18/admin/v3/version/create\x12V\n" + "\x04Edit\x12\x16.equipment.EditRequest\x1a\x13.equipment.Response\"!\x82\xd3\xe4\x93\x02\x1b:\x01*\"\x16/admin/v3/version/edit\x12\\\n" + - "\x06Status\x12\x18.equipment.StatusRequest\x1a\x13.equipment.Response\"#\x82\xd3\xe4\x93\x02\x1d:\x01*\"\x18/admin/v3/version/statusB\rZ\v./equipmentb\x06proto3" + "\x06Status\x12\x18.equipment.StatusRequest\x1a\x13.equipment.Response\"#\x82\xd3\xe4\x93\x02\x1d:\x01*\"\x18/admin/v3/version/status\x12^\n" + + "\tMaskItems\x12\x1b.equipment.MaskItemsRequest\x1a\x13.equipment.Response\"\x1f\x82\xd3\xe4\x93\x02\x19:\x01*\"\x14/admin/v3/mask/items\x12a\n" + + "\n" + + "BeansItems\x12\x1c.equipment.BeansItemsRequest\x1a\x13.equipment.Response\" \x82\xd3\xe4\x93\x02\x1a:\x01*\"\x15/admin/v3/beans/items\x12c\n" + + "\n" + + "BindExpiry\x12\x1c.equipment.BindExpiryRequest\x1a\x13.equipment.Response\"\"\x82\xd3\xe4\x93\x02\x1c:\x01*\"\x17/admin/v3/device/expiry\x12\\\n" + + "\n" + + "ApiMaskAdd\x12\x1c.equipment.ApiMaskAddRequest\x1a\x13.equipment.Response\"\x1b\x82\xd3\xe4\x93\x02\x15:\x01*\"\x10/api/v3/mask/add\x12]\n" + + "\fApiBindItems\x12\x17.equipment.EmptyRequest\x1a\x13.equipment.Response\"\x1f\x82\xd3\xe4\x93\x02\x19:\x01*\"\x14/api/v3/device/items\x12_\n" + + "\tApiUnBind\x12\x1b.equipment.ApiUnBindRequest\x1a\x13.equipment.Response\" \x82\xd3\xe4\x93\x02\x1a:\x01*\"\x15/api/v3/device/unbind\x12_\n" + + "\n" + + "ApiBindAdd\x12\x1c.equipment.ApiBindAddRequest\x1a\x13.equipment.Response\"\x1e\x82\xd3\xe4\x93\x02\x18:\x01*\"\x13/api/v3/device/bind\x12g\n" + + "\rApiBindExpiry\x12\x1f.equipment.ApiBindExpiryRequest\x1a\x13.equipment.Response\" \x82\xd3\xe4\x93\x02\x1a:\x01*\"\x15/api/v3/device/expiry\x12q\n" + + "\x10ApiBindExpiryGet\x12\".equipment.ApiBindExpiryGetRequest\x1a\x13.equipment.Response\"$\x82\xd3\xe4\x93\x02\x1e:\x01*\"\x19/api/v3/device/expiry/get\x12_\n" + + "\vApiBeansAdd\x12\x1d.equipment.ApiBeansAddRequest\x1a\x13.equipment.Response\"\x1c\x82\xd3\xe4\x93\x02\x16:\x01*\"\x11/api/v3/beans/add\x12[\n" + + "\fApiBeansLast\x12\x17.equipment.EmptyRequest\x1a\x13.equipment.Response\"\x1d\x82\xd3\xe4\x93\x02\x17:\x01*\"\x12/api/v3/beans/last\x12e\n" + + "\rApiBeansItems\x12\x1f.equipment.ApiBeansItemsRequest\x1a\x13.equipment.Response\"\x1e\x82\xd3\xe4\x93\x02\x18:\x01*\"\x13/api/v3/beans/items\x12\\\n" + + "\n" + + "ApiMaskUse\x12\x1c.equipment.ApiMaskUseRequest\x1a\x13.equipment.Response\"\x1b\x82\xd3\xe4\x93\x02\x15:\x01*\"\x10/api/v3/mask/use\x12o\n" + + "\x10ApiMaskUsedItems\x12\".equipment.ApiMaskUsedItemsRequest\x1a\x13.equipment.Response\"\"\x82\xd3\xe4\x93\x02\x1c:\x01*\"\x17/api/v3/mask/used/items\x12g\n" + + "\x0fApiMaskStoreUse\x12\x1c.equipment.ApiMaskUseRequest\x1a\x13.equipment.Response\"!\x82\xd3\xe4\x93\x02\x1b:\x01*\"\x16/api/v3/mask/store/use\x12y\n" + + "\x14ApiMaskStoreUseItems\x12\".equipment.ApiMaskUsedItemsRequest\x1a\x13.equipment.Response\"(\x82\xd3\xe4\x93\x02\":\x01*\"\x1d/api/v3/mask/store/used/itemsB\rZ\v./equipmentb\x06proto3" var ( file_equipment_equipment_proto_rawDescOnce sync.Once @@ -513,31 +1518,76 @@ func file_equipment_equipment_proto_rawDescGZIP() []byte { return file_equipment_equipment_proto_rawDescData } -var file_equipment_equipment_proto_msgTypes = make([]protoimpl.MessageInfo, 6) +var file_equipment_equipment_proto_msgTypes = make([]protoimpl.MessageInfo, 19) var file_equipment_equipment_proto_goTypes = []any{ - (*Response)(nil), // 0: equipment.Response - (*CreateRequest)(nil), // 1: equipment.CreateRequest - (*EditRequest)(nil), // 2: equipment.EditRequest - (*ItemsRequest)(nil), // 3: equipment.ItemsRequest - (*IdRequest)(nil), // 4: equipment.IdRequest - (*StatusRequest)(nil), // 5: equipment.StatusRequest + (*Response)(nil), // 0: equipment.Response + (*CreateRequest)(nil), // 1: equipment.CreateRequest + (*EditRequest)(nil), // 2: equipment.EditRequest + (*ItemsRequest)(nil), // 3: equipment.ItemsRequest + (*IdRequest)(nil), // 4: equipment.IdRequest + (*StatusRequest)(nil), // 5: equipment.StatusRequest + (*MaskItemsRequest)(nil), // 6: equipment.MaskItemsRequest + (*BeansItemsRequest)(nil), // 7: equipment.BeansItemsRequest + (*ApiBindAddRequest)(nil), // 8: equipment.ApiBindAddRequest + (*ApiUnBindRequest)(nil), // 9: equipment.ApiUnBindRequest + (*EmptyRequest)(nil), // 10: equipment.EmptyRequest + (*ApiBindExpiryRequest)(nil), // 11: equipment.ApiBindExpiryRequest + (*ApiBindExpiryGetRequest)(nil), // 12: equipment.ApiBindExpiryGetRequest + (*ApiBeansItemsRequest)(nil), // 13: equipment.ApiBeansItemsRequest + (*ApiBeansAddRequest)(nil), // 14: equipment.ApiBeansAddRequest + (*ApiMaskAddRequest)(nil), // 15: equipment.ApiMaskAddRequest + (*ApiMaskUseRequest)(nil), // 16: equipment.ApiMaskUseRequest + (*ApiMaskUsedItemsRequest)(nil), // 17: equipment.ApiMaskUsedItemsRequest + (*BindExpiryRequest)(nil), // 18: equipment.BindExpiryRequest } 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 - 5, // 4: equipment.Equipment.Status:input_type -> equipment.StatusRequest - 0, // 5: equipment.Equipment.Items:output_type -> equipment.Response - 0, // 6: equipment.Equipment.Info:output_type -> equipment.Response - 0, // 7: equipment.Equipment.Create:output_type -> equipment.Response - 0, // 8: equipment.Equipment.Edit:output_type -> equipment.Response - 0, // 9: equipment.Equipment.Status:output_type -> equipment.Response - 5, // [5:10] is the sub-list for method output_type - 0, // [0:5] 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 + 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 + 5, // 4: equipment.Equipment.Status:input_type -> equipment.StatusRequest + 6, // 5: equipment.Equipment.MaskItems:input_type -> equipment.MaskItemsRequest + 7, // 6: equipment.Equipment.BeansItems:input_type -> equipment.BeansItemsRequest + 18, // 7: equipment.Equipment.BindExpiry:input_type -> equipment.BindExpiryRequest + 15, // 8: equipment.Equipment.ApiMaskAdd:input_type -> equipment.ApiMaskAddRequest + 10, // 9: equipment.Equipment.ApiBindItems:input_type -> equipment.EmptyRequest + 9, // 10: equipment.Equipment.ApiUnBind:input_type -> equipment.ApiUnBindRequest + 8, // 11: equipment.Equipment.ApiBindAdd:input_type -> equipment.ApiBindAddRequest + 11, // 12: equipment.Equipment.ApiBindExpiry:input_type -> equipment.ApiBindExpiryRequest + 12, // 13: equipment.Equipment.ApiBindExpiryGet:input_type -> equipment.ApiBindExpiryGetRequest + 14, // 14: equipment.Equipment.ApiBeansAdd:input_type -> equipment.ApiBeansAddRequest + 10, // 15: equipment.Equipment.ApiBeansLast:input_type -> equipment.EmptyRequest + 13, // 16: equipment.Equipment.ApiBeansItems:input_type -> equipment.ApiBeansItemsRequest + 16, // 17: equipment.Equipment.ApiMaskUse:input_type -> equipment.ApiMaskUseRequest + 17, // 18: equipment.Equipment.ApiMaskUsedItems:input_type -> equipment.ApiMaskUsedItemsRequest + 16, // 19: equipment.Equipment.ApiMaskStoreUse:input_type -> equipment.ApiMaskUseRequest + 17, // 20: equipment.Equipment.ApiMaskStoreUseItems:input_type -> equipment.ApiMaskUsedItemsRequest + 0, // 21: equipment.Equipment.Items:output_type -> equipment.Response + 0, // 22: equipment.Equipment.Info:output_type -> equipment.Response + 0, // 23: equipment.Equipment.Create:output_type -> equipment.Response + 0, // 24: equipment.Equipment.Edit:output_type -> equipment.Response + 0, // 25: equipment.Equipment.Status:output_type -> equipment.Response + 0, // 26: equipment.Equipment.MaskItems:output_type -> equipment.Response + 0, // 27: equipment.Equipment.BeansItems:output_type -> equipment.Response + 0, // 28: equipment.Equipment.BindExpiry:output_type -> equipment.Response + 0, // 29: equipment.Equipment.ApiMaskAdd:output_type -> equipment.Response + 0, // 30: equipment.Equipment.ApiBindItems:output_type -> equipment.Response + 0, // 31: equipment.Equipment.ApiUnBind:output_type -> equipment.Response + 0, // 32: equipment.Equipment.ApiBindAdd:output_type -> equipment.Response + 0, // 33: equipment.Equipment.ApiBindExpiry:output_type -> equipment.Response + 0, // 34: equipment.Equipment.ApiBindExpiryGet:output_type -> equipment.Response + 0, // 35: equipment.Equipment.ApiBeansAdd:output_type -> equipment.Response + 0, // 36: equipment.Equipment.ApiBeansLast:output_type -> equipment.Response + 0, // 37: equipment.Equipment.ApiBeansItems:output_type -> equipment.Response + 0, // 38: equipment.Equipment.ApiMaskUse:output_type -> equipment.Response + 0, // 39: equipment.Equipment.ApiMaskUsedItems:output_type -> equipment.Response + 0, // 40: equipment.Equipment.ApiMaskStoreUse:output_type -> equipment.Response + 0, // 41: equipment.Equipment.ApiMaskStoreUseItems:output_type -> equipment.Response + 21, // [21:42] is the sub-list for method output_type + 0, // [0:21] 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 } func init() { file_equipment_equipment_proto_init() } @@ -551,7 +1601,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: 6, + NumMessages: 19, NumExtensions: 0, NumServices: 1, }, diff --git a/rpc/equipment/pb/equipment_grpc.pb.go b/rpc/equipment/pb/equipment_grpc.pb.go index a684109..0cfe4c5 100644 --- a/rpc/equipment/pb/equipment_grpc.pb.go +++ b/rpc/equipment/pb/equipment_grpc.pb.go @@ -19,11 +19,27 @@ 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_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_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" ) // EquipmentClient is the client API for Equipment service. @@ -35,6 +51,23 @@ type EquipmentClient interface { Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*Response, error) Edit(ctx context.Context, in *EditRequest, opts ...grpc.CallOption) (*Response, error) Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*Response, error) + MaskItems(ctx context.Context, in *MaskItemsRequest, opts ...grpc.CallOption) (*Response, error) + BeansItems(ctx context.Context, in *BeansItemsRequest, opts ...grpc.CallOption) (*Response, error) + BindExpiry(ctx context.Context, in *BindExpiryRequest, opts ...grpc.CallOption) (*Response, error) + // ******************API************************ + ApiMaskAdd(ctx context.Context, in *ApiMaskAddRequest, opts ...grpc.CallOption) (*Response, error) + ApiBindItems(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Response, error) + ApiUnBind(ctx context.Context, in *ApiUnBindRequest, opts ...grpc.CallOption) (*Response, error) + ApiBindAdd(ctx context.Context, in *ApiBindAddRequest, opts ...grpc.CallOption) (*Response, error) + ApiBindExpiry(ctx context.Context, in *ApiBindExpiryRequest, opts ...grpc.CallOption) (*Response, error) + ApiBindExpiryGet(ctx context.Context, in *ApiBindExpiryGetRequest, opts ...grpc.CallOption) (*Response, error) + ApiBeansAdd(ctx context.Context, in *ApiBeansAddRequest, opts ...grpc.CallOption) (*Response, error) + ApiBeansLast(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Response, error) + ApiBeansItems(ctx context.Context, in *ApiBeansItemsRequest, opts ...grpc.CallOption) (*Response, error) + ApiMaskUse(ctx context.Context, in *ApiMaskUseRequest, opts ...grpc.CallOption) (*Response, error) + ApiMaskUsedItems(ctx context.Context, in *ApiMaskUsedItemsRequest, opts ...grpc.CallOption) (*Response, error) + ApiMaskStoreUse(ctx context.Context, in *ApiMaskUseRequest, opts ...grpc.CallOption) (*Response, error) + ApiMaskStoreUseItems(ctx context.Context, in *ApiMaskUsedItemsRequest, opts ...grpc.CallOption) (*Response, error) } type equipmentClient struct { @@ -95,6 +128,166 @@ func (c *equipmentClient) Status(ctx context.Context, in *StatusRequest, opts .. return out, nil } +func (c *equipmentClient) MaskItems(ctx context.Context, in *MaskItemsRequest, opts ...grpc.CallOption) (*Response, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Response) + err := c.cc.Invoke(ctx, Equipment_MaskItems_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *equipmentClient) BeansItems(ctx context.Context, in *BeansItemsRequest, opts ...grpc.CallOption) (*Response, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Response) + err := c.cc.Invoke(ctx, Equipment_BeansItems_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *equipmentClient) BindExpiry(ctx context.Context, in *BindExpiryRequest, opts ...grpc.CallOption) (*Response, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Response) + err := c.cc.Invoke(ctx, Equipment_BindExpiry_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *equipmentClient) ApiMaskAdd(ctx context.Context, in *ApiMaskAddRequest, opts ...grpc.CallOption) (*Response, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Response) + err := c.cc.Invoke(ctx, Equipment_ApiMaskAdd_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *equipmentClient) ApiBindItems(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_ApiBindItems_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *equipmentClient) ApiUnBind(ctx context.Context, in *ApiUnBindRequest, opts ...grpc.CallOption) (*Response, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Response) + err := c.cc.Invoke(ctx, Equipment_ApiUnBind_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *equipmentClient) ApiBindAdd(ctx context.Context, in *ApiBindAddRequest, opts ...grpc.CallOption) (*Response, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Response) + err := c.cc.Invoke(ctx, Equipment_ApiBindAdd_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *equipmentClient) ApiBindExpiry(ctx context.Context, in *ApiBindExpiryRequest, opts ...grpc.CallOption) (*Response, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Response) + err := c.cc.Invoke(ctx, Equipment_ApiBindExpiry_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *equipmentClient) ApiBindExpiryGet(ctx context.Context, in *ApiBindExpiryGetRequest, opts ...grpc.CallOption) (*Response, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Response) + err := c.cc.Invoke(ctx, Equipment_ApiBindExpiryGet_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *equipmentClient) ApiBeansAdd(ctx context.Context, in *ApiBeansAddRequest, opts ...grpc.CallOption) (*Response, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Response) + err := c.cc.Invoke(ctx, Equipment_ApiBeansAdd_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *equipmentClient) ApiBeansLast(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_ApiBeansLast_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *equipmentClient) ApiBeansItems(ctx context.Context, in *ApiBeansItemsRequest, opts ...grpc.CallOption) (*Response, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Response) + err := c.cc.Invoke(ctx, Equipment_ApiBeansItems_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *equipmentClient) ApiMaskUse(ctx context.Context, in *ApiMaskUseRequest, opts ...grpc.CallOption) (*Response, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Response) + err := c.cc.Invoke(ctx, Equipment_ApiMaskUse_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *equipmentClient) ApiMaskUsedItems(ctx context.Context, in *ApiMaskUsedItemsRequest, opts ...grpc.CallOption) (*Response, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Response) + err := c.cc.Invoke(ctx, Equipment_ApiMaskUsedItems_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *equipmentClient) ApiMaskStoreUse(ctx context.Context, in *ApiMaskUseRequest, opts ...grpc.CallOption) (*Response, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Response) + err := c.cc.Invoke(ctx, Equipment_ApiMaskStoreUse_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *equipmentClient) ApiMaskStoreUseItems(ctx context.Context, in *ApiMaskUsedItemsRequest, opts ...grpc.CallOption) (*Response, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(Response) + err := c.cc.Invoke(ctx, Equipment_ApiMaskStoreUseItems_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + // EquipmentServer is the server API for Equipment service. // All implementations must embed UnimplementedEquipmentServer // for forward compatibility. @@ -104,6 +297,23 @@ type EquipmentServer interface { Create(context.Context, *CreateRequest) (*Response, error) Edit(context.Context, *EditRequest) (*Response, error) Status(context.Context, *StatusRequest) (*Response, error) + MaskItems(context.Context, *MaskItemsRequest) (*Response, error) + BeansItems(context.Context, *BeansItemsRequest) (*Response, error) + BindExpiry(context.Context, *BindExpiryRequest) (*Response, error) + // ******************API************************ + ApiMaskAdd(context.Context, *ApiMaskAddRequest) (*Response, error) + ApiBindItems(context.Context, *EmptyRequest) (*Response, error) + ApiUnBind(context.Context, *ApiUnBindRequest) (*Response, error) + ApiBindAdd(context.Context, *ApiBindAddRequest) (*Response, error) + ApiBindExpiry(context.Context, *ApiBindExpiryRequest) (*Response, error) + ApiBindExpiryGet(context.Context, *ApiBindExpiryGetRequest) (*Response, error) + ApiBeansAdd(context.Context, *ApiBeansAddRequest) (*Response, error) + ApiBeansLast(context.Context, *EmptyRequest) (*Response, error) + ApiBeansItems(context.Context, *ApiBeansItemsRequest) (*Response, error) + ApiMaskUse(context.Context, *ApiMaskUseRequest) (*Response, error) + ApiMaskUsedItems(context.Context, *ApiMaskUsedItemsRequest) (*Response, error) + ApiMaskStoreUse(context.Context, *ApiMaskUseRequest) (*Response, error) + ApiMaskStoreUseItems(context.Context, *ApiMaskUsedItemsRequest) (*Response, error) mustEmbedUnimplementedEquipmentServer() } @@ -129,6 +339,54 @@ func (UnimplementedEquipmentServer) Edit(context.Context, *EditRequest) (*Respon func (UnimplementedEquipmentServer) Status(context.Context, *StatusRequest) (*Response, error) { return nil, status.Error(codes.Unimplemented, "method Status not implemented") } +func (UnimplementedEquipmentServer) MaskItems(context.Context, *MaskItemsRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method MaskItems not implemented") +} +func (UnimplementedEquipmentServer) BeansItems(context.Context, *BeansItemsRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method BeansItems not implemented") +} +func (UnimplementedEquipmentServer) BindExpiry(context.Context, *BindExpiryRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method BindExpiry not implemented") +} +func (UnimplementedEquipmentServer) ApiMaskAdd(context.Context, *ApiMaskAddRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method ApiMaskAdd not implemented") +} +func (UnimplementedEquipmentServer) ApiBindItems(context.Context, *EmptyRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method ApiBindItems not implemented") +} +func (UnimplementedEquipmentServer) ApiUnBind(context.Context, *ApiUnBindRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method ApiUnBind not implemented") +} +func (UnimplementedEquipmentServer) ApiBindAdd(context.Context, *ApiBindAddRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method ApiBindAdd not implemented") +} +func (UnimplementedEquipmentServer) ApiBindExpiry(context.Context, *ApiBindExpiryRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method ApiBindExpiry not implemented") +} +func (UnimplementedEquipmentServer) ApiBindExpiryGet(context.Context, *ApiBindExpiryGetRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method ApiBindExpiryGet not implemented") +} +func (UnimplementedEquipmentServer) ApiBeansAdd(context.Context, *ApiBeansAddRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method ApiBeansAdd not implemented") +} +func (UnimplementedEquipmentServer) ApiBeansLast(context.Context, *EmptyRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method ApiBeansLast not implemented") +} +func (UnimplementedEquipmentServer) ApiBeansItems(context.Context, *ApiBeansItemsRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method ApiBeansItems not implemented") +} +func (UnimplementedEquipmentServer) ApiMaskUse(context.Context, *ApiMaskUseRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method ApiMaskUse not implemented") +} +func (UnimplementedEquipmentServer) ApiMaskUsedItems(context.Context, *ApiMaskUsedItemsRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method ApiMaskUsedItems not implemented") +} +func (UnimplementedEquipmentServer) ApiMaskStoreUse(context.Context, *ApiMaskUseRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method ApiMaskStoreUse not implemented") +} +func (UnimplementedEquipmentServer) ApiMaskStoreUseItems(context.Context, *ApiMaskUsedItemsRequest) (*Response, error) { + return nil, status.Error(codes.Unimplemented, "method ApiMaskStoreUseItems not implemented") +} func (UnimplementedEquipmentServer) mustEmbedUnimplementedEquipmentServer() {} func (UnimplementedEquipmentServer) testEmbeddedByValue() {} @@ -240,6 +498,294 @@ func _Equipment_Status_Handler(srv interface{}, ctx context.Context, dec func(in return interceptor(ctx, in, info, handler) } +func _Equipment_MaskItems_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(MaskItemsRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(EquipmentServer).MaskItems(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Equipment_MaskItems_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(EquipmentServer).MaskItems(ctx, req.(*MaskItemsRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _Equipment_BeansItems_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(BeansItemsRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(EquipmentServer).BeansItems(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Equipment_BeansItems_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(EquipmentServer).BeansItems(ctx, req.(*BeansItemsRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _Equipment_BindExpiry_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(BindExpiryRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(EquipmentServer).BindExpiry(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Equipment_BindExpiry_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(EquipmentServer).BindExpiry(ctx, req.(*BindExpiryRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _Equipment_ApiMaskAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ApiMaskAddRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(EquipmentServer).ApiMaskAdd(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Equipment_ApiMaskAdd_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(EquipmentServer).ApiMaskAdd(ctx, req.(*ApiMaskAddRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _Equipment_ApiBindItems_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).ApiBindItems(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Equipment_ApiBindItems_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(EquipmentServer).ApiBindItems(ctx, req.(*EmptyRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _Equipment_ApiUnBind_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ApiUnBindRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(EquipmentServer).ApiUnBind(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Equipment_ApiUnBind_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(EquipmentServer).ApiUnBind(ctx, req.(*ApiUnBindRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _Equipment_ApiBindAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ApiBindAddRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(EquipmentServer).ApiBindAdd(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Equipment_ApiBindAdd_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(EquipmentServer).ApiBindAdd(ctx, req.(*ApiBindAddRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _Equipment_ApiBindExpiry_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ApiBindExpiryRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(EquipmentServer).ApiBindExpiry(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Equipment_ApiBindExpiry_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(EquipmentServer).ApiBindExpiry(ctx, req.(*ApiBindExpiryRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _Equipment_ApiBindExpiryGet_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ApiBindExpiryGetRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(EquipmentServer).ApiBindExpiryGet(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Equipment_ApiBindExpiryGet_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(EquipmentServer).ApiBindExpiryGet(ctx, req.(*ApiBindExpiryGetRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _Equipment_ApiBeansAdd_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ApiBeansAddRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(EquipmentServer).ApiBeansAdd(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Equipment_ApiBeansAdd_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(EquipmentServer).ApiBeansAdd(ctx, req.(*ApiBeansAddRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _Equipment_ApiBeansLast_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).ApiBeansLast(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Equipment_ApiBeansLast_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(EquipmentServer).ApiBeansLast(ctx, req.(*EmptyRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _Equipment_ApiBeansItems_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ApiBeansItemsRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(EquipmentServer).ApiBeansItems(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Equipment_ApiBeansItems_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(EquipmentServer).ApiBeansItems(ctx, req.(*ApiBeansItemsRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _Equipment_ApiMaskUse_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ApiMaskUseRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(EquipmentServer).ApiMaskUse(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Equipment_ApiMaskUse_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(EquipmentServer).ApiMaskUse(ctx, req.(*ApiMaskUseRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _Equipment_ApiMaskUsedItems_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ApiMaskUsedItemsRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(EquipmentServer).ApiMaskUsedItems(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Equipment_ApiMaskUsedItems_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(EquipmentServer).ApiMaskUsedItems(ctx, req.(*ApiMaskUsedItemsRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _Equipment_ApiMaskStoreUse_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ApiMaskUseRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(EquipmentServer).ApiMaskStoreUse(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Equipment_ApiMaskStoreUse_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(EquipmentServer).ApiMaskStoreUse(ctx, req.(*ApiMaskUseRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _Equipment_ApiMaskStoreUseItems_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(ApiMaskUsedItemsRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(EquipmentServer).ApiMaskStoreUseItems(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: Equipment_ApiMaskStoreUseItems_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(EquipmentServer).ApiMaskStoreUseItems(ctx, req.(*ApiMaskUsedItemsRequest)) + } + return interceptor(ctx, in, info, handler) +} + // Equipment_ServiceDesc is the grpc.ServiceDesc for Equipment service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) @@ -267,6 +813,70 @@ var Equipment_ServiceDesc = grpc.ServiceDesc{ MethodName: "Status", Handler: _Equipment_Status_Handler, }, + { + MethodName: "MaskItems", + Handler: _Equipment_MaskItems_Handler, + }, + { + MethodName: "BeansItems", + Handler: _Equipment_BeansItems_Handler, + }, + { + MethodName: "BindExpiry", + Handler: _Equipment_BindExpiry_Handler, + }, + { + MethodName: "ApiMaskAdd", + Handler: _Equipment_ApiMaskAdd_Handler, + }, + { + MethodName: "ApiBindItems", + Handler: _Equipment_ApiBindItems_Handler, + }, + { + MethodName: "ApiUnBind", + Handler: _Equipment_ApiUnBind_Handler, + }, + { + MethodName: "ApiBindAdd", + Handler: _Equipment_ApiBindAdd_Handler, + }, + { + MethodName: "ApiBindExpiry", + Handler: _Equipment_ApiBindExpiry_Handler, + }, + { + MethodName: "ApiBindExpiryGet", + Handler: _Equipment_ApiBindExpiryGet_Handler, + }, + { + MethodName: "ApiBeansAdd", + Handler: _Equipment_ApiBeansAdd_Handler, + }, + { + MethodName: "ApiBeansLast", + Handler: _Equipment_ApiBeansLast_Handler, + }, + { + MethodName: "ApiBeansItems", + Handler: _Equipment_ApiBeansItems_Handler, + }, + { + MethodName: "ApiMaskUse", + Handler: _Equipment_ApiMaskUse_Handler, + }, + { + MethodName: "ApiMaskUsedItems", + Handler: _Equipment_ApiMaskUsedItems_Handler, + }, + { + MethodName: "ApiMaskStoreUse", + Handler: _Equipment_ApiMaskStoreUse_Handler, + }, + { + MethodName: "ApiMaskStoreUseItems", + Handler: _Equipment_ApiMaskStoreUseItems_Handler, + }, }, Streams: []grpc.StreamDesc{}, Metadata: "equipment/equipment.proto", diff --git a/services/equipment/equipmentclient/equipment.go b/services/equipment/equipmentclient/equipment.go index 510f886..9079f59 100644 --- a/services/equipment/equipmentclient/equipment.go +++ b/services/equipment/equipmentclient/equipment.go @@ -14,12 +14,25 @@ import ( ) type ( - CreateRequest = equipment.CreateRequest - EditRequest = equipment.EditRequest - IdRequest = equipment.IdRequest - ItemsRequest = equipment.ItemsRequest - Response = equipment.Response - StatusRequest = equipment.StatusRequest + ApiBeansAddRequest = equipment.ApiBeansAddRequest + ApiBeansItemsRequest = equipment.ApiBeansItemsRequest + ApiBindAddRequest = equipment.ApiBindAddRequest + ApiBindExpiryGetRequest = equipment.ApiBindExpiryGetRequest + ApiBindExpiryRequest = equipment.ApiBindExpiryRequest + ApiMaskAddRequest = equipment.ApiMaskAddRequest + ApiMaskUseRequest = equipment.ApiMaskUseRequest + ApiMaskUsedItemsRequest = equipment.ApiMaskUsedItemsRequest + ApiUnBindRequest = equipment.ApiUnBindRequest + BeansItemsRequest = equipment.BeansItemsRequest + BindExpiryRequest = equipment.BindExpiryRequest + CreateRequest = equipment.CreateRequest + EditRequest = equipment.EditRequest + EmptyRequest = equipment.EmptyRequest + IdRequest = equipment.IdRequest + ItemsRequest = equipment.ItemsRequest + MaskItemsRequest = equipment.MaskItemsRequest + Response = equipment.Response + StatusRequest = equipment.StatusRequest Equipment interface { Items(ctx context.Context, in *ItemsRequest, opts ...grpc.CallOption) (*Response, error) @@ -27,6 +40,23 @@ type ( Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*Response, error) Edit(ctx context.Context, in *EditRequest, opts ...grpc.CallOption) (*Response, error) Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*Response, error) + MaskItems(ctx context.Context, in *MaskItemsRequest, opts ...grpc.CallOption) (*Response, error) + BeansItems(ctx context.Context, in *BeansItemsRequest, opts ...grpc.CallOption) (*Response, error) + BindExpiry(ctx context.Context, in *BindExpiryRequest, opts ...grpc.CallOption) (*Response, error) + // API + ApiMaskAdd(ctx context.Context, in *ApiMaskAddRequest, opts ...grpc.CallOption) (*Response, error) + ApiBindItems(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Response, error) + ApiUnBind(ctx context.Context, in *ApiUnBindRequest, opts ...grpc.CallOption) (*Response, error) + ApiBindAdd(ctx context.Context, in *ApiBindAddRequest, opts ...grpc.CallOption) (*Response, error) + ApiBindExpiry(ctx context.Context, in *ApiBindExpiryRequest, opts ...grpc.CallOption) (*Response, error) + ApiBindExpiryGet(ctx context.Context, in *ApiBindExpiryGetRequest, opts ...grpc.CallOption) (*Response, error) + ApiBeansAdd(ctx context.Context, in *ApiBeansAddRequest, opts ...grpc.CallOption) (*Response, error) + ApiBeansLast(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Response, error) + ApiBeansItems(ctx context.Context, in *ApiBeansItemsRequest, opts ...grpc.CallOption) (*Response, error) + ApiMaskUse(ctx context.Context, in *ApiMaskUseRequest, opts ...grpc.CallOption) (*Response, error) + ApiMaskUsedItems(ctx context.Context, in *ApiMaskUsedItemsRequest, opts ...grpc.CallOption) (*Response, error) + ApiMaskStoreUse(ctx context.Context, in *ApiMaskUseRequest, opts ...grpc.CallOption) (*Response, error) + ApiMaskStoreUseItems(ctx context.Context, in *ApiMaskUsedItemsRequest, opts ...grpc.CallOption) (*Response, error) } defaultEquipment struct { @@ -64,3 +94,84 @@ func (m *defaultEquipment) Status(ctx context.Context, in *StatusRequest, opts . client := equipment.NewEquipmentClient(m.cli.Conn()) return client.Status(ctx, in, opts...) } + +func (m *defaultEquipment) MaskItems(ctx context.Context, in *MaskItemsRequest, opts ...grpc.CallOption) (*Response, error) { + client := equipment.NewEquipmentClient(m.cli.Conn()) + return client.MaskItems(ctx, in, opts...) +} + +func (m *defaultEquipment) BeansItems(ctx context.Context, in *BeansItemsRequest, opts ...grpc.CallOption) (*Response, error) { + client := equipment.NewEquipmentClient(m.cli.Conn()) + return client.BeansItems(ctx, in, opts...) +} + +func (m *defaultEquipment) BindExpiry(ctx context.Context, in *BindExpiryRequest, opts ...grpc.CallOption) (*Response, error) { + client := equipment.NewEquipmentClient(m.cli.Conn()) + return client.BindExpiry(ctx, in, opts...) +} + +// API +func (m *defaultEquipment) ApiMaskAdd(ctx context.Context, in *ApiMaskAddRequest, opts ...grpc.CallOption) (*Response, error) { + client := equipment.NewEquipmentClient(m.cli.Conn()) + return client.ApiMaskAdd(ctx, in, opts...) +} + +func (m *defaultEquipment) ApiBindItems(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Response, error) { + client := equipment.NewEquipmentClient(m.cli.Conn()) + return client.ApiBindItems(ctx, in, opts...) +} + +func (m *defaultEquipment) ApiUnBind(ctx context.Context, in *ApiUnBindRequest, opts ...grpc.CallOption) (*Response, error) { + client := equipment.NewEquipmentClient(m.cli.Conn()) + return client.ApiUnBind(ctx, in, opts...) +} + +func (m *defaultEquipment) ApiBindAdd(ctx context.Context, in *ApiBindAddRequest, opts ...grpc.CallOption) (*Response, error) { + client := equipment.NewEquipmentClient(m.cli.Conn()) + return client.ApiBindAdd(ctx, in, opts...) +} + +func (m *defaultEquipment) ApiBindExpiry(ctx context.Context, in *ApiBindExpiryRequest, opts ...grpc.CallOption) (*Response, error) { + client := equipment.NewEquipmentClient(m.cli.Conn()) + return client.ApiBindExpiry(ctx, in, opts...) +} + +func (m *defaultEquipment) ApiBindExpiryGet(ctx context.Context, in *ApiBindExpiryGetRequest, opts ...grpc.CallOption) (*Response, error) { + client := equipment.NewEquipmentClient(m.cli.Conn()) + return client.ApiBindExpiryGet(ctx, in, opts...) +} + +func (m *defaultEquipment) ApiBeansAdd(ctx context.Context, in *ApiBeansAddRequest, opts ...grpc.CallOption) (*Response, error) { + client := equipment.NewEquipmentClient(m.cli.Conn()) + return client.ApiBeansAdd(ctx, in, opts...) +} + +func (m *defaultEquipment) ApiBeansLast(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Response, error) { + client := equipment.NewEquipmentClient(m.cli.Conn()) + return client.ApiBeansLast(ctx, in, opts...) +} + +func (m *defaultEquipment) ApiBeansItems(ctx context.Context, in *ApiBeansItemsRequest, opts ...grpc.CallOption) (*Response, error) { + client := equipment.NewEquipmentClient(m.cli.Conn()) + return client.ApiBeansItems(ctx, in, opts...) +} + +func (m *defaultEquipment) ApiMaskUse(ctx context.Context, in *ApiMaskUseRequest, opts ...grpc.CallOption) (*Response, error) { + client := equipment.NewEquipmentClient(m.cli.Conn()) + return client.ApiMaskUse(ctx, in, opts...) +} + +func (m *defaultEquipment) ApiMaskUsedItems(ctx context.Context, in *ApiMaskUsedItemsRequest, opts ...grpc.CallOption) (*Response, error) { + client := equipment.NewEquipmentClient(m.cli.Conn()) + return client.ApiMaskUsedItems(ctx, in, opts...) +} + +func (m *defaultEquipment) ApiMaskStoreUse(ctx context.Context, in *ApiMaskUseRequest, opts ...grpc.CallOption) (*Response, error) { + client := equipment.NewEquipmentClient(m.cli.Conn()) + return client.ApiMaskStoreUse(ctx, in, opts...) +} + +func (m *defaultEquipment) ApiMaskStoreUseItems(ctx context.Context, in *ApiMaskUsedItemsRequest, opts ...grpc.CallOption) (*Response, error) { + client := equipment.NewEquipmentClient(m.cli.Conn()) + return client.ApiMaskStoreUseItems(ctx, in, opts...) +} diff --git a/services/equipment/internal/dao/beans.go b/services/equipment/internal/dao/beans.go new file mode 100644 index 0000000..ae654d8 --- /dev/null +++ b/services/equipment/internal/dao/beans.go @@ -0,0 +1,32 @@ +package dao + +import "lone-services/pkg/utils" + +type BeansCreate struct { + Id int64 `gorm:"column:id;type:int(11);primary_key;AUTO_INCREMENT" json:"id"` + UserId int64 `gorm:"column:user_id;type:int(11);NOT NULL" json:"user_id"` + UserName string `gorm:"column:user_name;type:varchar(255)" json:"user_name"` + UserNickName string `gorm:"column:user_nick_name;type:varchar(255)" json:"user_nick_name"` + FirstImage string `gorm:"column:first_image;type:varchar(255)" json:"first_image"` + FirstTime utils.CustomTime `gorm:"column:first_time;type:datetime" json:"first_time"` +} + +type BeansInfo struct { + Id int64 `gorm:"column:id;type:int(11);primary_key;AUTO_INCREMENT" json:"id"` + UserId int64 `gorm:"column:user_id;type:int(11);NOT NULL" json:"user_id"` + UserName string `gorm:"column:user_name;type:varchar(255)" json:"user_name"` + UserNickName string `gorm:"column:user_nick_name;type:varchar(255)" json:"user_nick_name"` + FirstImage string `gorm:"column:first_image;type:varchar(255)" json:"first_image"` + SecondImage string `gorm:"column:second_image;type:varchar(255)" json:"second_image"` + FirstTime utils.CustomTime `gorm:"column:first_time;type:datetime" json:"first_time"` + SecondTime utils.CustomTime `gorm:"column:second_time;type:datetime" json:"second_time"` + RefundStatus int32 `gorm:"column:refund_status;type:tinyint(1);default:1;comment:退款状态，默认1为没有退款，2为退款" json:"refund_status"` +} + +type BeansRefund struct { + Id int64 `gorm:"column:id;type:int(11);primary_key;AUTO_INCREMENT" json:"id"` + RefundStatus int32 `gorm:"column:refund_status;type:tinyint(1);default:1;comment:退款状态，默认1为没有退款，2为退款" json:"refund_status"` + Reason string `gorm:"column:reason;type:varchar(255);comment:禁用原因" json:"reason"` + AdminId int64 `gorm:"column:admin_id;type:int(11)" json:"admin_id"` + AdminName string `gorm:"column:admin_name;type:varchar(255)" json:"admin_name"` +} diff --git a/services/equipment/internal/dao/bind.go b/services/equipment/internal/dao/bind.go new file mode 100644 index 0000000..01ceac3 --- /dev/null +++ b/services/equipment/internal/dao/bind.go @@ -0,0 +1,40 @@ +package dao + +import ( + "lone-services/pkg/utils" +) + +type BindCreate struct { + Id int64 `gorm:"column:id;type:bigint(20);primary_key;AUTO_INCREMENT" json:"id"` + HostCode string `gorm:"column:host_code;type:varchar(64);comment:主机编号;NOT NULL" json:"host_code"` + HostNickname string `gorm:"column:host_nickname;type:varchar(128);comment:主机昵称;NOT NULL" json:"host_nickname"` + UserId int64 `gorm:"column:user_id;type:int(11);comment:用户ID;NOT NULL" json:"user_id"` + UserNickname string `gorm:"column:user_nickname;type:varchar(128);comment:用户昵称;NOT NULL" json:"user_nickname"` + Image string `gorm:"column:image;type:varchar(128);comment:图片地址;NOT NULL" json:"image"` + IsSpeciality int32 `gorm:"column:is_speciality;type:tinyint(1);default:0;comment:1是专业版;NOT NULL" json:"is_speciality"` + Status int32 `gorm:"column:status;type:tinyint(1);default:1;comment:状态，1为正常，2为禁用" json:"status"` + BindTime utils.CustomTime `gorm:"column:bind_time;type:datetime;comment:绑定时间" json:"bind_time"` +} + +type BindInfo struct { + Id int64 `gorm:"column:id;type:bigint(20);primary_key;AUTO_INCREMENT" json:"id"` + HostCode string `gorm:"column:host_code;type:varchar(64);comment:主机编号;NOT NULL" json:"host_code"` + HostNickname string `gorm:"column:host_nickname;type:varchar(128);comment:主机昵称;NOT NULL" json:"host_nickname"` + UserId int64 `gorm:"column:user_id;type:int(11);comment:用户ID;NOT NULL" json:"user_id"` + UserNickname string `gorm:"column:user_nickname;type:varchar(128);comment:用户昵称;NOT NULL" json:"user_nickname"` + Image string `gorm:"column:image;type:varchar(128);comment:图片地址;NOT NULL" json:"image"` + IsSpeciality int32 `gorm:"column:is_speciality;type:tinyint(1);default:0;comment:1是专业版;NOT NULL" json:"is_speciality"` + ExpiryTime string `gorm:"column:expiry_time;type:char(11);comment:过期时间" json:"expiry_time"` + Status uint8 `gorm:"column:status;type:tinyint(1);default:1;comment:状态，1为正常，2为禁用" json:"status"` + BindTime utils.CustomTime `gorm:"column:bind_time;type:datetime;comment:绑定时间" json:"bind_time"` + UpdatedAt utils.CustomTime `gorm:"column:updated_at;type:timestamp;default:CURRENT_TIMESTAMP;NOT NULL" json:"updated_at"` +} + +type BindExpiry struct { + Id int64 `gorm:"column:id;type:bigint(20);primary_key;AUTO_INCREMENT" json:"id"` + HostCode string `gorm:"column:host_code;type:varchar(64);comment:主机编号;NOT NULL" json:"host_code"` + ExpiryTime string `gorm:"column:expiry_time;type:char(11);comment:过期时间" json:"expiry_time"` + Reason string `gorm:"column:reason;type:varchar(255);comment:理由" json:"reason"` + AdminId int64 `gorm:"column:admin_id;type:int(11)" json:"admin_id"` + AdminName string `gorm:"column:admin_name;type:varchar(255)" json:"admin_name"` +} diff --git a/services/equipment/internal/dao/bindHistory.go b/services/equipment/internal/dao/bindHistory.go new file mode 100644 index 0000000..6d267a0 --- /dev/null +++ b/services/equipment/internal/dao/bindHistory.go @@ -0,0 +1,8 @@ +package dao + +type BindHistoryCreate struct { + Id int64 `gorm:"column:id;type:int(11);primary_key;AUTO_INCREMENT" json:"id"` + HostCode string `gorm:"column:host_code;type:varchar(128);comment:设备昵称;NOT NULL" json:"host_code"` + Status int32 `gorm:"column:status;type:tinyint(1);default:2;comment:1为绑定，2为解绑;NOT NULL" json:"status"` + UserId int64 `gorm:"column:user_id;type:int(11)" json:"user_id"` +} diff --git a/services/equipment/internal/dao/mask.go b/services/equipment/internal/dao/mask.go new file mode 100644 index 0000000..195ac82 --- /dev/null +++ b/services/equipment/internal/dao/mask.go @@ -0,0 +1,100 @@ +package dao + +import "lone-services/pkg/utils" + +const ( + FacialTypeOrdinary = 0 // 面膜类型 0普通型 + FacialTypeTry = 1 // 面膜类型 1试用型 + FacialTypeAll = 2 // 面膜类型 2通用型 + FacialTypeOnce = 3 // 面膜类型 3一次性型 +) + +type MaskInfo struct { + Id int64 `gorm:"column:id;type:bigint(20);primary_key;AUTO_INCREMENT" json:"id"` + FacialMaskId string `gorm:"column:facial_mask_id;type:varchar(64);comment:面膜id;NOT NULL" json:"facial_mask_id"` + HostCode string `gorm:"column:host_code;type:varchar(64);comment:使用的设备序列号;NOT NULL" json:"host_code"` + Openid string `gorm:"column:openid;type:varchar(128);comment:使用用户的id;NOT NULL" json:"openid"` + UseTime string `gorm:"column:use_time;type:varchar(64);comment:使用的时间;NOT NULL" json:"use_time"` + SecondUseTime string `gorm:"column:second_use_time;type:varchar(64);comment:第二次使用的时间，与第一次不能超过半小时" json:"second_use_time"` + Voltage string `gorm:"column:voltage;type:varchar(64);comment:电压;NOT NULL" json:"voltage"` + ElectricCurrent string `gorm:"column:electric_current;type:varchar(64);comment:电流;NOT NULL" json:"electric_current"` + GearPosition string `gorm:"column:gear_position;type:varchar(64);comment:档位;NOT NULL" json:"gear_position"` + Efficiency string `gorm:"column:efficiency;type:varchar(64);comment:效率;NOT NULL" json:"efficiency"` + Resistance string `gorm:"column:resistance;type:varchar(64);comment:阻值;NOT NULL" json:"resistance"` + Score string `gorm:"column:score;type:varchar(64);comment:评分;NOT NULL" json:"score"` + ProduceTime string `gorm:"column:produce_time;type:varchar(64);comment:生产日期;NOT NULL" json:"produce_time"` + QualityGuaranteePeriod int64 `gorm:"column:quality_guarantee_period;type:int(11);default:36;comment:保质期月份;NOT NULL" json:"quality_guarantee_period"` + IsUse int64 `gorm:"column:is_use;type:tinyint(1);default:2;comment:1是已使用;NOT NULL" json:"is_use"` + IsOnTrial int32 `gorm:"column:is_on_trial;type:tinyint(1);default:2;comment:1是试用 2是正常;NOT NULL" json:"is_on_trial"` + IsOnline int32 `gorm:"column:is_online;type:tinyint(1);comment:是否为线上，1为线上，2为线下" json:"is_online"` + StoreId int32 `gorm:"column:store_id;type:int(11);default:0;comment:门店ID;NOT NULL" json:"store_id"` + WorkerGroupId int64 `gorm:"column:worker_group_id;type:int(11);default:0;comment:组ID" json:"worker_group_id"` + ModelId int64 `gorm:"column:model_id;type:int(11);default:0" json:"model_id"` + Model string `gorm:"column:model;type:varchar(64);comment:面膜型号;NOT NULL" json:"model"` + Effect int64 `gorm:"column:effect;type:tinyint(4);comment:效果0=智能,1=美白,2=淡斑,3=抗衰,4=祛痘" json:"effect"` + UseScenario int32 `gorm:"column:use_scenario;type:tinyint(1);comment:使用场景，0为院线，1为家用" json:"use_scenario"` + IsStore int32 `gorm:"column:is_store;type:tinyint(1);default:1;comment:是否为门店产品，1为门店线下，2为线上" json:"is_store"` + Batch string `gorm:"column:batch;type:varchar(64);comment:批次;NOT NULL" json:"batch"` + AddType int32 `gorm:"column:add_type;type:tinyint(1);default:1;comment:添加方式：1为系统录入，2为异常录入" json:"add_type"` + Status int32 `gorm:"column:status;type:tinyint(1);default:1;comment:状态，1为正常，2为删除" json:"status"` +} + +type MaskCreate struct { + Id int64 `gorm:"column:id;type:bigint(20);primary_key;AUTO_INCREMENT" json:"id"` + FacialMaskId string `gorm:"column:facial_mask_id;type:varchar(64);comment:面膜id;NOT NULL" json:"facial_mask_id"` + ProduceTime string `gorm:"column:produce_time;type:varchar(64);comment:生产日期;NOT NULL" json:"produce_time"` + QualityGuaranteePeriod int64 `gorm:"column:quality_guarantee_period;type:int(11);default:36;comment:保质期月份;NOT NULL" json:"quality_guarantee_period"` + IsOnTrial int32 `gorm:"column:is_on_trial;type:tinyint(1);default:2;comment:1是试用 2是正常;NOT NULL" json:"is_on_trial"` + IsOnline int32 `gorm:"column:is_online;type:tinyint(1);comment:是否为线上，1为线上，2为线下" json:"is_online"` + WorkerGroupId int64 `gorm:"column:worker_group_id;type:int(11);default:0;comment:组ID" json:"worker_group_id"` + ModelId int64 `gorm:"column:model_id;type:int(11);default:0" json:"model_id"` + Effect int32 `gorm:"column:effect;type:tinyint(4);comment:效果0=智能,1=美白,2=淡斑,3=抗衰,4=祛痘" json:"effect"` + Model string `gorm:"column:model;type:varchar(64);comment:面膜型号;NOT NULL" json:"model"` + IsStore int32 `gorm:"column:is_store;type:tinyint(1);default:1;comment:是否为门店产品，1为门店线下，2为线上" json:"is_store"` + UseScenario int32 `gorm:"column:use_scenario;type:tinyint(1);comment:使用场景，0为院线，1为家用" json:"use_scenario"` + Batch string `gorm:"column:batch;type:varchar(64);comment:批次;NOT NULL" json:"batch"` +} + +type MaskStatus struct { + Id int64 `gorm:"column:id;type:bigint(20);primary_key;AUTO_INCREMENT" json:"id"` + Status int32 `gorm:"column:status;type:tinyint(1);default:1;comment:状态，1为正常，2为删除" json:"status"` +} + +type MaskAddInfo struct { + Id int64 `gorm:"column:id;type:bigint(20);primary_key;AUTO_INCREMENT" json:"id"` + FacialMaskId string `gorm:"column:facial_mask_id;type:varchar(64);comment:面膜id;NOT NULL" json:"facial_mask_id"` + IsOnTrial int32 `gorm:"column:is_on_trial;type:tinyint(1);default:2;comment:1是试用 2是正常;NOT NULL" json:"is_on_trial"` + IsOnline int32 `gorm:"column:is_online;type:tinyint(1);comment:是否为线上，1为线上，2为线下" json:"is_online"` + Effect int32 `gorm:"column:effect;type:tinyint(4);comment:效果0=智能,1=美白,2=淡斑,3=抗衰,4=祛痘" json:"effect"` + Model string `gorm:"column:model;type:varchar(64);comment:面膜型号;NOT NULL" json:"model"` + IsStore int32 `gorm:"column:is_store;type:tinyint(1);default:1;comment:是否为门店产品，1为门店线下，2为线上" json:"is_store"` + UseScenario int32 `gorm:"column:use_scenario;type:tinyint(1);comment:使用场景，0为院线，1为家用" json:"use_scenario"` + Batch string `gorm:"column:batch;type:varchar(64);comment:批次;NOT NULL" json:"batch"` + CreatedAt utils.CustomTime `gorm:"column:created_at;type:timestamp;default:CURRENT_TIMESTAMP" json:"created_at"` +} + +type MaskUseInfo struct { + Id int64 `gorm:"column:id;type:bigint(20);primary_key;AUTO_INCREMENT" json:"id"` + FacialMaskId string `gorm:"column:facial_mask_id;type:varchar(64);comment:面膜id;NOT NULL" json:"facial_mask_id"` + IsOnTrial int32 `gorm:"column:is_on_trial;type:tinyint(1);default:2;comment:1是试用 2是正常;NOT NULL" json:"is_on_trial"` + HostCode string `gorm:"column:host_code;type:varchar(64);comment:使用的设备序列号;NOT NULL" json:"host_code"` + Openid string `gorm:"column:openid;type:varchar(128);comment:使用用户的id;NOT NULL" json:"openid"` + UserId int64 `json:"user_id" gorm:"user_id"` // 使用的用户ID + UseTime string `gorm:"column:use_time;type:varchar(64);comment:使用的时间;NOT NULL" json:"use_time"` + SecondUseTime string `gorm:"column:second_use_time;type:varchar(64);comment:第二次使用的时间，与第一次不能超过半小时" json:"second_use_time"` + Voltage string `gorm:"column:voltage;type:varchar(64);comment:电压;NOT NULL" json:"voltage"` + ElectricCurrent string `gorm:"column:electric_current;type:varchar(64);comment:电流;NOT NULL" json:"electric_current"` + GearPosition string `gorm:"column:gear_position;type:varchar(64);comment:档位;NOT NULL" json:"gear_position"` + Efficiency string `gorm:"column:efficiency;type:varchar(64);comment:效率;NOT NULL" json:"efficiency"` + Resistance string `gorm:"column:resistance;type:varchar(64);comment:阻值;NOT NULL" json:"resistance"` + Score string `gorm:"column:score;type:varchar(64);comment:评分;NOT NULL" json:"score"` + IsUse int32 `gorm:"column:is_use;type:tinyint(1);default:2;comment:1是已使用;NOT NULL" json:"is_use"` + StoreId int64 `gorm:"column:store_id;type:int(11);default:0;comment:门店ID;NOT NULL" json:"store_id"` + IsStore int32 `gorm:"column:is_store;type:tinyint(1);default:1;comment:是否为门店产品，1为门店线下，2为线上" json:"is_store"` +} + +type MaskUsedInfo struct { + FacialMaskId string `gorm:"column:facial_mask_id;type:varchar(64);comment:面膜id;NOT NULL" json:"facial_mask_id"` + UseTime string `gorm:"column:use_time;type:varchar(64);comment:使用的时间;NOT NULL" json:"use_time"` + SecondUseTime string `gorm:"column:second_use_time;type:varchar(64);comment:第二次使用的时间，与第一次不能超过半小时" json:"second_use_time"` +} diff --git a/services/equipment/internal/logic/beansItemsLogic.go b/services/equipment/internal/logic/beansItemsLogic.go new file mode 100644 index 0000000..972a8e3 --- /dev/null +++ b/services/equipment/internal/logic/beansItemsLogic.go @@ -0,0 +1,59 @@ +package logic + +import ( + "context" + "fmt" + "lone-services/pkg/modelbase" + "lone-services/pkg/utils" + "lone-services/rpc/equipment/pb" + "lone-services/services/equipment/internal/dao" + "lone-services/services/equipment/internal/model" + "lone-services/services/equipment/internal/svc" + + "github.com/zeromicro/go-zero/core/logx" +) + +type BeansItemsLogic struct { + ctx context.Context + svcCtx *svc.ServiceContext + logx.Logger + BaseLogic +} + +func NewBeansItemsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *BeansItemsLogic { + return &BeansItemsLogic{ + ctx: ctx, + svcCtx: svcCtx, + Logger: logx.WithContext(ctx), + } +} + +func (l *BeansItemsLogic) BeansItems(in *equipment.BeansItemsRequest) (*equipment.Response, error) { + adminInfo := utils.GetUserFromCtx(l.ctx) + if adminInfo.ID < utils.NumberOne { + return l.fail(utils.ErrorNoLoginInfo) + } + var info []dao.BeansInfo + w := modelbase.Params{ + Size: int(in.Size), + Order: "id DESC", + Page: int(in.Page), + } + + if len(in.Time) > utils.NumberOne { + w.Between = map[string][2]string{"created_at": { + in.Time[utils.NumberZero], in.Time[utils.NumberOne]}} + } + if in.Name != utils.StringEmpty { + key := fmt.Sprintf("(user_name LIKE '%s' OR user_nick_name LIKE ?)", "%%"+in.Name+"%%") + w.Other = map[string]string{key: "%%" + in.Name + "%%"} + } + + items, err := model.BeansModel{}.Init().Page(w, &info) + if err != nil { + l.Logger.Error(err) + return l.fail(utils.Fail) + } + + return l.ok(items) +} diff --git a/services/equipment/internal/logic/bindExpiryLogic.go b/services/equipment/internal/logic/bindExpiryLogic.go new file mode 100644 index 0000000..2d0dca8 --- /dev/null +++ b/services/equipment/internal/logic/bindExpiryLogic.go @@ -0,0 +1,71 @@ +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 BindExpiryLogic struct { + ctx context.Context + svcCtx *svc.ServiceContext + logx.Logger + BaseLogic +} + +func NewBindExpiryLogic(ctx context.Context, svcCtx *svc.ServiceContext) *BindExpiryLogic { + return &BindExpiryLogic{ + ctx: ctx, + svcCtx: svcCtx, + Logger: logx.WithContext(ctx), + } +} + +func (l *BindExpiryLogic) BindExpiry(in *equipment.BindExpiryRequest) (*equipment.Response, error) { + var v validator.BindSetExpiryValidator + 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) + } + w := modelbase.Params{ + Eq: map[string]string{ + "id": strconv.FormatInt(in.Id, utils.NumberTen), + }, + } + + var info dao.BindExpiry + err := model.BindModel{}.Init().GetOne(w, &info) + if err != nil { + l.Logger.Error(err) + return l.fail(utils.Fail) + } + + if info.Id < utils.NumberOne { + return l.fail(utils.SetError(utils.Fail, "没有找到数据")) + } + + info.ExpiryTime = in.Expiry + info.AdminId = in.Id + info.AdminName = adminInfo.Name + info.Reason = in.Reason + _, err = model.BindModel{}.Init().Edit(w, &info) + + if err != nil { + l.Logger.Error(err) + return l.fail(utils.Fail) + } + + return l.ok(utils.NumberOne) +} diff --git a/services/equipment/internal/logic/maskItemsLogic.go b/services/equipment/internal/logic/maskItemsLogic.go new file mode 100644 index 0000000..9641866 --- /dev/null +++ b/services/equipment/internal/logic/maskItemsLogic.go @@ -0,0 +1,88 @@ +package logic + +import ( + "context" + "lone-services/pkg/modelbase" + "lone-services/pkg/utils" + "lone-services/rpc/equipment/pb" + "lone-services/services/equipment/internal/dao" + "lone-services/services/equipment/internal/model" + "lone-services/services/equipment/internal/svc" + "strconv" + + "github.com/zeromicro/go-zero/core/logx" +) + +type MaskItemsLogic struct { + ctx context.Context + svcCtx *svc.ServiceContext + logx.Logger + BaseLogic +} + +func NewMaskItemsLogic(ctx context.Context, svcCtx *svc.ServiceContext) *MaskItemsLogic { + return &MaskItemsLogic{ + ctx: ctx, + svcCtx: svcCtx, + Logger: logx.WithContext(ctx), + } +} + +func (l *MaskItemsLogic) MaskItems(in *equipment.MaskItemsRequest) (*equipment.Response, error) { + adminInfo := utils.GetUserFromCtx(l.ctx) + if adminInfo.ID < utils.NumberOne { + return l.fail(utils.ErrorNoLoginInfo) + } + var info []dao.MaskAddInfo + w := modelbase.Params{ + Size: int(in.Size), + Order: "id desc", + Page: int(in.Page), + } + w.Eq = make(map[string]string) + if in.FacialMaskId != utils.StringEmpty { + w.Eq["facial_mask_id"] = in.FacialMaskId + } + if in.Batch != utils.StringEmpty { + w.Eq["batch"] = in.Batch + } + if in.Model >= utils.NumberZero { + mm := "MM" + if in.Model == utils.NumberOne { + mm = "YT" + } + w.Eq["model"] = mm + } + if in.IsStore >= utils.NumberZero { + w.Eq["is_store"] = strconv.Itoa(int(in.IsStore)) + } + if in.IsOnTrial >= utils.NumberZero { + w.Eq["is_on_trial"] = strconv.Itoa(int(in.IsOnTrial)) + } + if in.UseScenario >= utils.NumberZero { + w.Eq["use_scenario"] = strconv.Itoa(int(in.UseScenario)) + } + if in.Effect >= utils.NumberZero { + w.Eq["effect"] = strconv.Itoa(int(in.Effect)) + } + + if in.IsUse >= utils.NumberZero { + w.Eq["is_use"] = strconv.Itoa(int(in.IsUse)) + } + + if in.WorkerGroupId >= utils.NumberZero { + w.Eq["worker_group_id"] = strconv.Itoa(int(in.WorkerGroupId)) + } + + if len(in.Time) > utils.NumberOne { + w.Between = map[string][2]string{"created_at": { + in.Time[utils.NumberZero], in.Time[utils.NumberOne]}} + } + items, err := model.MaskModel{}.Init().Page(w, &info) + if err != nil { + l.Logger.Error(err) + return l.fail(utils.Fail) + } + + return l.ok(items) +} diff --git a/services/equipment/internal/model/beans.go b/services/equipment/internal/model/beans.go new file mode 100644 index 0000000..580723e --- /dev/null +++ b/services/equipment/internal/model/beans.go @@ -0,0 +1,23 @@ +package model + +import ( + "lone-services/pkg/modelbase" + "lone-services/services/equipment/internal/dao" +) + +type BeansModel struct { + modelbase.Base +} + +func (m BeansModel) TableName() string { + return modelbase.Prefix() + "beans" +} + +func (m BeansModel) Init() BeansModel { + m.Table = m.TableName() + return m +} + +func (m BeansModel) Create(data *dao.BeansCreate) error { + return m.Base.Create(data) +} diff --git a/services/equipment/internal/model/bind.go b/services/equipment/internal/model/bind.go new file mode 100644 index 0000000..db55d5a --- /dev/null +++ b/services/equipment/internal/model/bind.go @@ -0,0 +1,23 @@ +package model + +import ( + "lone-services/pkg/modelbase" + "lone-services/services/equipment/internal/dao" +) + +type BindModel struct { + modelbase.Base +} + +func (m BindModel) TableName() string { + return modelbase.Prefix() + "bind" +} + +func (m BindModel) Init() BindModel { + m.Table = m.TableName() + return m +} + +func (m BindModel) Create(data *dao.BindCreate) error { + return m.Base.Create(data) +} diff --git a/services/equipment/internal/model/bindHistory.go b/services/equipment/internal/model/bindHistory.go new file mode 100644 index 0000000..35557bb --- /dev/null +++ b/services/equipment/internal/model/bindHistory.go @@ -0,0 +1,23 @@ +package model + +import ( + "lone-services/pkg/modelbase" + "lone-services/services/equipment/internal/dao" +) + +type BindHistoryModel struct { + modelbase.Base +} + +func (m BindHistoryModel) TableName() string { + return modelbase.Prefix() + "bind_history" +} + +func (m BindHistoryModel) Init() BindHistoryModel { + m.Table = m.TableName() + return m +} + +func (m BindHistoryModel) Create(data *dao.BindHistoryCreate) error { + return m.Base.Create(data) +} diff --git a/services/equipment/internal/model/mask.go b/services/equipment/internal/model/mask.go new file mode 100644 index 0000000..2abeb9e --- /dev/null +++ b/services/equipment/internal/model/mask.go @@ -0,0 +1,23 @@ +package model + +import ( + "lone-services/pkg/modelbase" + "lone-services/services/equipment/internal/dao" +) + +type MaskModel struct { + modelbase.Base +} + +func (m MaskModel) TableName() string { + return modelbase.Prefix() + "version" +} + +func (m MaskModel) Init() MaskModel { + m.Table = m.TableName() + return m +} + +func (m MaskModel) Create(data *dao.MaskCreate) error { + return m.Base.Create(data) +} diff --git a/services/equipment/internal/server/equipmentServer.go b/services/equipment/internal/server/equipmentServer.go index 17b7209..d813a5d 100644 --- a/services/equipment/internal/server/equipmentServer.go +++ b/services/equipment/internal/server/equipmentServer.go @@ -47,3 +47,84 @@ func (s *EquipmentServer) Status(ctx context.Context, in *equipment.StatusReques l := logic.NewStatusLogic(ctx, s.svcCtx) return l.Status(in) } + +func (s *EquipmentServer) MaskItems(ctx context.Context, in *equipment.MaskItemsRequest) (*equipment.Response, error) { + l := logic.NewMaskItemsLogic(ctx, s.svcCtx) + return l.MaskItems(in) +} + +func (s *EquipmentServer) BeansItems(ctx context.Context, in *equipment.BeansItemsRequest) (*equipment.Response, error) { + l := logic.NewBeansItemsLogic(ctx, s.svcCtx) + return l.BeansItems(in) +} + +func (s *EquipmentServer) BindExpiry(ctx context.Context, in *equipment.BindExpiryRequest) (*equipment.Response, error) { + l := logic.NewBindExpiryLogic(ctx, s.svcCtx) + return l.BindExpiry(in) +} + +// API +func (s *EquipmentServer) ApiMaskAdd(ctx context.Context, in *equipment.ApiMaskAddRequest) (*equipment.Response, error) { + l := logic.NewApiMaskAddLogic(ctx, s.svcCtx) + return l.ApiMaskAdd(in) +} + +func (s *EquipmentServer) ApiBindItems(ctx context.Context, in *equipment.EmptyRequest) (*equipment.Response, error) { + l := logic.NewApiBindItemsLogic(ctx, s.svcCtx) + return l.ApiBindItems(in) +} + +func (s *EquipmentServer) ApiUnBind(ctx context.Context, in *equipment.ApiUnBindRequest) (*equipment.Response, error) { + l := logic.NewApiUnBindLogic(ctx, s.svcCtx) + return l.ApiUnBind(in) +} + +func (s *EquipmentServer) ApiBindAdd(ctx context.Context, in *equipment.ApiBindAddRequest) (*equipment.Response, error) { + l := logic.NewApiBindAddLogic(ctx, s.svcCtx) + return l.ApiBindAdd(in) +} + +func (s *EquipmentServer) ApiBindExpiry(ctx context.Context, in *equipment.ApiBindExpiryRequest) (*equipment.Response, error) { + l := logic.NewApiBindExpiryLogic(ctx, s.svcCtx) + return l.ApiBindExpiry(in) +} + +func (s *EquipmentServer) ApiBindExpiryGet(ctx context.Context, in *equipment.ApiBindExpiryGetRequest) (*equipment.Response, error) { + l := logic.NewApiBindExpiryGetLogic(ctx, s.svcCtx) + return l.ApiBindExpiryGet(in) +} + +func (s *EquipmentServer) ApiBeansAdd(ctx context.Context, in *equipment.ApiBeansAddRequest) (*equipment.Response, error) { + l := logic.NewApiBeansAddLogic(ctx, s.svcCtx) + return l.ApiBeansAdd(in) +} + +func (s *EquipmentServer) ApiBeansLast(ctx context.Context, in *equipment.EmptyRequest) (*equipment.Response, error) { + l := logic.NewApiBeansLastLogic(ctx, s.svcCtx) + return l.ApiBeansLast(in) +} + +func (s *EquipmentServer) ApiBeansItems(ctx context.Context, in *equipment.ApiBeansItemsRequest) (*equipment.Response, error) { + l := logic.NewApiBeansItemsLogic(ctx, s.svcCtx) + return l.ApiBeansItems(in) +} + +func (s *EquipmentServer) ApiMaskUse(ctx context.Context, in *equipment.ApiMaskUseRequest) (*equipment.Response, error) { + l := logic.NewApiMaskUseLogic(ctx, s.svcCtx) + return l.ApiMaskUse(in) +} + +func (s *EquipmentServer) ApiMaskUsedItems(ctx context.Context, in *equipment.ApiMaskUsedItemsRequest) (*equipment.Response, error) { + l := logic.NewApiMaskUsedItemsLogic(ctx, s.svcCtx) + return l.ApiMaskUsedItems(in) +} + +func (s *EquipmentServer) ApiMaskStoreUse(ctx context.Context, in *equipment.ApiMaskUseRequest) (*equipment.Response, error) { + l := logic.NewApiMaskStoreUseLogic(ctx, s.svcCtx) + return l.ApiMaskStoreUse(in) +} + +func (s *EquipmentServer) ApiMaskStoreUseItems(ctx context.Context, in *equipment.ApiMaskUsedItemsRequest) (*equipment.Response, error) { + l := logic.NewApiMaskStoreUseItemsLogic(ctx, s.svcCtx) + return l.ApiMaskStoreUseItems(in) +} diff --git a/services/equipment/validator/beans.go b/services/equipment/validator/beans.go new file mode 100644 index 0000000..75a5e0e --- /dev/null +++ b/services/equipment/validator/beans.go @@ -0,0 +1,35 @@ +package validator + +import "lone-services/pkg/validate" + +type BeansItemsValidator struct { + Page int `form:"page" json:"page"` + Size int `form:"size" json:"size"` +} + +// GetMessage 提示消息 +func (p BeansItemsValidator) GetMessage() validate.ValidatorMessages { + return validate.ValidatorMessages{} +} + +type BeansImagesValidator struct { + Image string `form:"image" json:"image" validate:"required"` + Id int `form:"id" json:"id"` +} + +// GetMessage 提示消息 +func (p BeansImagesValidator) GetMessage() validate.ValidatorMessages { + return validate.ValidatorMessages{ + "Image.required": "图片不能为空", + } +} + +type BeansImagesItemsValidator struct { + Page int `form:"page" json:"page"` + Size int `form:"size" json:"size"` +} + +// GetMessage 提示消息 +func (p BeansImagesItemsValidator) GetMessage() validate.ValidatorMessages { + return validate.ValidatorMessages{} +} diff --git a/services/equipment/validator/bind.go b/services/equipment/validator/bind.go new file mode 100644 index 0000000..a81233c --- /dev/null +++ b/services/equipment/validator/bind.go @@ -0,0 +1,80 @@ +package validator + +import "lone-services/pkg/validate" + +type BindItemsValidator struct { + Page int `form:"page" json:"page"` + Size int `form:"size" json:"size"` + Status uint8 `form:"status" json:"status"` + NickName string `form:"nick_name" json:"nick_name"` + Code string `form:"code" json:"code"` + Time []string `form:"time" json:"time"` +} + +// GetMessage 提示消息 +func (p BindItemsValidator) GetMessage() validate.ValidatorMessages { + return validate.ValidatorMessages{} +} + +type BindSetExpiryValidator struct { + Id int `form:"id" json:"id" validate:"required"` + Expiry string `form:"expiry" json:"expiry"` + Reason string `form:"reason" json:"reason" validate:"required"` +} + +// GetMessage 提示消息 +func (p BindSetExpiryValidator) GetMessage() validate.ValidatorMessages { + return validate.ValidatorMessages{ + validate.FieldId: validate.FieldIdValue, + "Reason.required": "理由不能为空", + } +} + +type BindValidator struct { + HostNickname string `form:"host_nickname" json:"host_nickname" validate:"required"` + HostCode string `form:"host_code" json:"host_code" validate:"required"` +} + +// GetMessage 提示消息 +func (p BindValidator) GetMessage() validate.ValidatorMessages { + return validate.ValidatorMessages{ + "HostNickname.required": "缺少设备名称", + "HostCode.required": "缺少设备编码", + } +} + +type BindUnbindValidator struct { + HostCode string `form:"host_code" json:"host_code" validate:"required"` +} + +// GetMessage 提示消息 +func (p BindUnbindValidator) GetMessage() validate.ValidatorMessages { + return validate.ValidatorMessages{ + "HostCode.required": "缺少设备编码", + } +} + +type BindExpiryValidator struct { + HostCode string `form:"host_code" json:"host_code" binding:"required"` + Type uint8 `form:"type" json:"type" binding:"required,oneof=1 2"` +} + +// GetMessage 提示消息 +func (p BindExpiryValidator) GetMessage() validate.ValidatorMessages { + return validate.ValidatorMessages{ + "HostCode.required": "缺少设备编码", + "Type.required": "缺少设备类型", + "Type.oneof": "设备类型错误", + } +} + +type BindGetExpiryValidator struct { + HostCode string `form:"host_code" json:"host_code" binding:"required"` +} + +// GetMessage 提示消息 +func (p BindGetExpiryValidator) GetMessage() validate.ValidatorMessages { + return validate.ValidatorMessages{ + "HostCode.required": "缺少设备编码", + } +} diff --git a/services/equipment/validator/mask.go b/services/equipment/validator/mask.go new file mode 100644 index 0000000..a387a27 --- /dev/null +++ b/services/equipment/validator/mask.go @@ -0,0 +1,88 @@ +package validator + +import "lone-services/pkg/validate" + +type FacialItemsValidator struct { + Page int `form:"page" json:"page"` + Size int `form:"size" json:"size"` + FacialMaskId string `form:"facial_mask_id" json:"facial_mask_id"` + IsOnTrial int8 `form:"is_on_trial" json:"is_on_trial"` + Model int8 `form:"model" json:"model"` + WorkerGroupId int `form:"worker_group_id" json:"worker_group_id"` + Batch string `form:"batch" json:"batch"` + IsStore int8 `form:"is_store" json:"is_store"` + UseScenario int8 `form:"use_scenario" json:"use_scenario"` + Effect int8 `form:"effect" json:"effect"` + Time string `form:"time" json:"time"` + IsUse int8 `form:"is_use" json:"is_use"` +} + +// GetMessage 提示消息 +func (p FacialItemsValidator) GetMessage() validate.ValidatorMessages { + return validate.ValidatorMessages{} +} + +type MaskUseValidator struct { + FacialMaskId string `form:"facial_mask_id" json:"facial_mask_id" validate:"required"` + UseTime string `form:"use_time" json:"use_time" validate:"required"` + HostCode string `form:"host_code" json:"host_code" validate:"required"` + OpenId string `form:"openid" json:"openid"` + GearPosition string `form:"gear_position" json:"gear_position"` + Voltage string `form:"voltage" json:"voltage"` + ElectricCurrent string `form:"electric_current" json:"electric_current"` + Efficiency string `form:"efficiency" json:"efficiency"` + Resistance string `form:"resistance" json:"resistance"` + Score string `form:"score" json:"score"` + StoreId int `form:"store_id" json:"store_id"` +} + +// GetMessage 提示消息 +func (p MaskUseValidator) GetMessage() validate.ValidatorMessages { + return validate.ValidatorMessages{ + "FacialMaskId.required": "面膜ID不能为空", + "UseTime.required": "使用时间能为空", + "HostCode.required": "使用设备不能为空", + } +} + +type MaskUsedItemsValidator struct { + OpenId string `form:"openid" json:"openid"` + FacialMaskId string `form:"facial_mask_id" json:"facial_mask_id"` + UseTime string `form:"use_time" json:"use_time"` + HostCode string `form:"host_code" json:"host_code"` +} + +// GetMessage 提示消息 +func (p MaskUsedItemsValidator) GetMessage() validate.ValidatorMessages { + return validate.ValidatorMessages{} +} + +type MaskAddValidator struct { + OpenId string `form:"openid" json:"openid"` + FacialMaskId string `form:"facial_mask_id" json:"facial_mask_id" validate:"required"` + ProduceTime string `form:"produce_time" json:"produce_time" validate:"required"` + QualityGuaranteePeriod string `form:"quality_guarantee_period" json:"quality_guarantee_period" validate:"required"` + IsOnTrial string `form:"is_on_trial" json:"is_on_trial" validate:"required"` + Model string `form:"model" json:"model" validate:"required"` + Batch string `form:"batch" json:"batch" validate:"required"` + IsStore string `form:"is_store" json:"is_store" validate:"required"` + IsOnline string `form:"is_online" json:"is_online"` + Auto string `form:"auto" json:"auto"` + ModelId string `form:"model_id" json:"model_id"` + UseScenario string `form:"use_scenario" json:"use_scenario"` + Effect string `form:"effect" json:"effect"` + WorkerGroupId string `form:"worker_group_id" json:"worker_group_id"` +} + +// GetMessage 返回校验提示信息 +func (p MaskAddValidator) GetMessage() validate.ValidatorMessages { + return validate.ValidatorMessages{ + "FacialMaskId.required": "缺少ID", + "ProduceTime.required": "缺少生产日期", + "QualityGuaranteePeriod.required": "缺少保质期月份", + "IsOnTrial.required": "缺少是否试用", + "Model.required": "缺少面膜型号", + "Batch.required": "缺少批次", + "IsStore.required": "缺少渠道", + } +}