feat:资源扣减

rpc/internal/server/resourceserver.go

@@ -22,16 +22,19 @@ func NewResourceServer(svcCtx *svc.ServiceContext) *ResourceServer {
 	}
 }
 
+// 开通或者取消用户/企业权益
 func (s *ResourceServer) PowerHandle(ctx context.Context, in *pb.PowerReq) (*pb.Resp, error) {
 	l := logic.NewPowerHandleLogic(ctx, s.svcCtx)
 	return l.PowerHandle(in)
 }
 
+// 检查用户/企业权益
 func (s *ResourceServer) CheckPower(ctx context.Context, in *pb.CheckPowerReq) (*pb.Resp, error) {
 	l := logic.NewCheckPowerLogic(ctx, s.svcCtx)
 	return l.CheckPower(in)
 }
 
+// 资源扣减
 func (s *ResourceServer) Deduction(ctx context.Context, in *pb.DeductionReq) (*pb.Resp, error) {
 	l := logic.NewDeductionLogic(ctx, s.svcCtx)
 	return l.Deduction(in)

rpc/pb/resource_grpc.pb.go

@@ -22,8 +22,11 @@ const _ = grpc.SupportPackageIsVersion7
 //
 // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
 type ResourceClient interface {
+	//开通或者取消用户/企业权益
 	PowerHandle(ctx context.Context, in *PowerReq, opts ...grpc.CallOption) (*Resp, error)
+	//检查用户/企业权益
 	CheckPower(ctx context.Context, in *CheckPowerReq, opts ...grpc.CallOption) (*Resp, error)
+	//资源扣减
 	Deduction(ctx context.Context, in *DeductionReq, opts ...grpc.CallOption) (*Resp, error)
 }
 
@@ -66,8 +69,11 @@ func (c *resourceClient) Deduction(ctx context.Context, in *DeductionReq, opts .
 // All implementations must embed UnimplementedResourceServer
 // for forward compatibility
 type ResourceServer interface {
+	//开通或者取消用户/企业权益
 	PowerHandle(context.Context, *PowerReq) (*Resp, error)
+	//检查用户/企业权益
 	CheckPower(context.Context, *CheckPowerReq) (*Resp, error)
+	//资源扣减
 	Deduction(context.Context, *DeductionReq) (*Resp, error)
 	mustEmbedUnimplementedResourceServer()
 }

rpc/resource.proto

@@ -35,7 +35,10 @@ message Resp {
 }
 
 service Resource {
+  //开通或者取消用户/企业权益
   rpc PowerHandle(PowerReq) returns(Resp);
+  //检查用户/企业权益
   rpc CheckPower(CheckPowerReq) returns(Resp);
+  //资源扣减
   rpc Deduction(DeductionReq) returns(Resp);
 }

rpc/resource/resource.go

@@ -19,8 +19,11 @@ type (
 	Resp          = pb.Resp
 
 	Resource interface {
+		// 开通或者取消用户/企业权益
 		PowerHandle(ctx context.Context, in *PowerReq, opts ...grpc.CallOption) (*Resp, error)
+		// 检查用户/企业权益
 		CheckPower(ctx context.Context, in *CheckPowerReq, opts ...grpc.CallOption) (*Resp, error)
+		// 资源扣减
 		Deduction(ctx context.Context, in *DeductionReq, opts ...grpc.CallOption) (*Resp, error)
 	}
 
@@ -35,16 +38,19 @@ func NewResource(cli zrpc.Client) Resource {
 	}
 }
 
+// 开通或者取消用户/企业权益
 func (m *defaultResource) PowerHandle(ctx context.Context, in *PowerReq, opts ...grpc.CallOption) (*Resp, error) {
 	client := pb.NewResourceClient(m.cli.Conn())
 	return client.PowerHandle(ctx, in, opts...)
 }
 
+// 检查用户/企业权益
 func (m *defaultResource) CheckPower(ctx context.Context, in *CheckPowerReq, opts ...grpc.CallOption) (*Resp, error) {
 	client := pb.NewResourceClient(m.cli.Conn())
 	return client.CheckPower(ctx, in, opts...)
 }
 
+// 资源扣减
 func (m *defaultResource) Deduction(ctx context.Context, in *DeductionReq, opts ...grpc.CallOption) (*Resp, error) {
 	client := pb.NewResourceClient(m.cli.Conn())
 	return client.Deduction(ctx, in, opts...)