feat：新增定时任务调度发布

api/cron/cron.validator.pb.go

@@ -0,0 +1,129 @@
+// Code generated by protoc-gen-gogo. DO NOT EDIT.
+// source: pb/cron.proto
+
+package cron
+
+import (
+	fmt "fmt"
+	math "math"
+	proto "github.com/golang/protobuf/proto"
+	github_com_mwitkow_go_proto_validators "github.com/mwitkow/go-proto-validators"
+)
+
+// Reference imports to suppress errors if they are not otherwise used.
+var _ = proto.Marshal
+var _ = fmt.Errorf
+var _ = math.Inf
+
+func (this *CommonIDRequest) Validate() error {
+	return nil
+}
+func (this *CommonResponse) Validate() error {
+	return nil
+}
+func (this *ScheduleTask) Validate() error {
+	if this.TaskDetail != nil {
+		if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(this.TaskDetail); err != nil {
+			return github_com_mwitkow_go_proto_validators.FieldError("TaskDetail", err)
+		}
+	}
+	for _, item := range this.ExecutionRecords {
+		if item != nil {
+			if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
+				return github_com_mwitkow_go_proto_validators.FieldError("ExecutionRecords", err)
+			}
+		}
+	}
+	return nil
+}
+func (this *ExecutionRecord) Validate() error {
+	for _, item := range this.ExecutionResults {
+		if item != nil {
+			if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
+				return github_com_mwitkow_go_proto_validators.FieldError("ExecutionResults", err)
+			}
+		}
+	}
+	return nil
+}
+func (this *ExecutionResult) Validate() error {
+	return nil
+}
+func (this *TaskDetail) Validate() error {
+	for _, item := range this.Artists {
+		if item != nil {
+			if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
+				return github_com_mwitkow_go_proto_validators.FieldError("Artists", err)
+			}
+		}
+	}
+	return nil
+}
+func (this *ArtistInfo) Validate() error {
+	return nil
+}
+func (this *CreateScheduleTaskRequest) Validate() error {
+	if this.TaskDetail != nil {
+		if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(this.TaskDetail); err != nil {
+			return github_com_mwitkow_go_proto_validators.FieldError("TaskDetail", err)
+		}
+	}
+	return nil
+}
+func (this *TaskDetailRequest) Validate() error {
+	for _, item := range this.Artists {
+		if item != nil {
+			if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
+				return github_com_mwitkow_go_proto_validators.FieldError("Artists", err)
+			}
+		}
+	}
+	return nil
+}
+func (this *CreateScheduleTaskResponse) Validate() error {
+	if this.Data != nil {
+		if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(this.Data); err != nil {
+			return github_com_mwitkow_go_proto_validators.FieldError("Data", err)
+		}
+	}
+	return nil
+}
+func (this *GetListScheduleTaskRequest) Validate() error {
+	return nil
+}
+func (this *GetListScheduleTaskResponse) Validate() error {
+	for _, item := range this.Data {
+		if item != nil {
+			if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
+				return github_com_mwitkow_go_proto_validators.FieldError("Data", err)
+			}
+		}
+	}
+	return nil
+}
+func (this *GetListExecutionRecordRequest) Validate() error {
+	return nil
+}
+func (this *GetListExecutionRecordResponse) Validate() error {
+	for _, item := range this.Data {
+		if item != nil {
+			if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
+				return github_com_mwitkow_go_proto_validators.FieldError("Data", err)
+			}
+		}
+	}
+	return nil
+}
+func (this *GetListExecutionResultRequest) Validate() error {
+	return nil
+}
+func (this *GetListExecutionResultResponse) Validate() error {
+	for _, item := range this.Data {
+		if item != nil {
+			if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
+				return github_com_mwitkow_go_proto_validators.FieldError("Data", err)
+			}
+		}
+	}
+	return nil
+}

api/cron/cron_triple.pb.go

@@ -0,0 +1,417 @@
+// Code generated by protoc-gen-go-triple. DO NOT EDIT.
+// versions:
+// - protoc-gen-go-triple v1.0.5
+// - protoc             v6.32.0
+// source: pb/cron.proto
+
+package cron
+
+import (
+	context "context"
+	protocol "dubbo.apache.org/dubbo-go/v3/protocol"
+	dubbo3 "dubbo.apache.org/dubbo-go/v3/protocol/dubbo3"
+	invocation "dubbo.apache.org/dubbo-go/v3/protocol/invocation"
+	grpc_go "github.com/dubbogo/grpc-go"
+	codes "github.com/dubbogo/grpc-go/codes"
+	metadata "github.com/dubbogo/grpc-go/metadata"
+	status "github.com/dubbogo/grpc-go/status"
+	common "github.com/dubbogo/triple/pkg/common"
+	constant "github.com/dubbogo/triple/pkg/common/constant"
+	triple "github.com/dubbogo/triple/pkg/triple"
+)
+
+// This is a compile-time assertion to ensure that this generated file
+// is compatible with the grpc package it is being compiled against.
+const _ = grpc_go.SupportPackageIsVersion7
+
+// CronClient is the client API for Cron service.
+//
+// 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 CronClient interface {
+	CreateScheduleTask(ctx context.Context, in *CreateScheduleTaskRequest, opts ...grpc_go.CallOption) (*CreateScheduleTaskResponse, common.ErrorWithAttachment)
+	GetListScheduleTask(ctx context.Context, in *GetListScheduleTaskRequest, opts ...grpc_go.CallOption) (*GetListScheduleTaskResponse, common.ErrorWithAttachment)
+	GetListExecutionRecord(ctx context.Context, in *GetListExecutionRecordRequest, opts ...grpc_go.CallOption) (*GetListExecutionRecordResponse, common.ErrorWithAttachment)
+	GetListExecutionResult(ctx context.Context, in *GetListExecutionResultRequest, opts ...grpc_go.CallOption) (*GetListExecutionResultResponse, common.ErrorWithAttachment)
+	PauseScheduleTask(ctx context.Context, in *CommonIDRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment)
+	StartScheduleTask(ctx context.Context, in *CommonIDRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment)
+	DeleteScheduleTask(ctx context.Context, in *CommonIDRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment)
+}
+
+type cronClient struct {
+	cc *triple.TripleConn
+}
+
+type CronClientImpl struct {
+	CreateScheduleTask     func(ctx context.Context, in *CreateScheduleTaskRequest) (*CreateScheduleTaskResponse, error)
+	GetListScheduleTask    func(ctx context.Context, in *GetListScheduleTaskRequest) (*GetListScheduleTaskResponse, error)
+	GetListExecutionRecord func(ctx context.Context, in *GetListExecutionRecordRequest) (*GetListExecutionRecordResponse, error)
+	GetListExecutionResult func(ctx context.Context, in *GetListExecutionResultRequest) (*GetListExecutionResultResponse, error)
+	PauseScheduleTask      func(ctx context.Context, in *CommonIDRequest) (*CommonResponse, error)
+	StartScheduleTask      func(ctx context.Context, in *CommonIDRequest) (*CommonResponse, error)
+	DeleteScheduleTask     func(ctx context.Context, in *CommonIDRequest) (*CommonResponse, error)
+}
+
+func (c *CronClientImpl) GetDubboStub(cc *triple.TripleConn) CronClient {
+	return NewCronClient(cc)
+}
+
+func (c *CronClientImpl) XXX_InterfaceName() string {
+	return "cron.Cron"
+}
+
+func NewCronClient(cc *triple.TripleConn) CronClient {
+	return &cronClient{cc}
+}
+
+func (c *cronClient) CreateScheduleTask(ctx context.Context, in *CreateScheduleTaskRequest, opts ...grpc_go.CallOption) (*CreateScheduleTaskResponse, common.ErrorWithAttachment) {
+	out := new(CreateScheduleTaskResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/CreateScheduleTask", in, out)
+}
+
+func (c *cronClient) GetListScheduleTask(ctx context.Context, in *GetListScheduleTaskRequest, opts ...grpc_go.CallOption) (*GetListScheduleTaskResponse, common.ErrorWithAttachment) {
+	out := new(GetListScheduleTaskResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetListScheduleTask", in, out)
+}
+
+func (c *cronClient) GetListExecutionRecord(ctx context.Context, in *GetListExecutionRecordRequest, opts ...grpc_go.CallOption) (*GetListExecutionRecordResponse, common.ErrorWithAttachment) {
+	out := new(GetListExecutionRecordResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetListExecutionRecord", in, out)
+}
+
+func (c *cronClient) GetListExecutionResult(ctx context.Context, in *GetListExecutionResultRequest, opts ...grpc_go.CallOption) (*GetListExecutionResultResponse, common.ErrorWithAttachment) {
+	out := new(GetListExecutionResultResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetListExecutionResult", in, out)
+}
+
+func (c *cronClient) PauseScheduleTask(ctx context.Context, in *CommonIDRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment) {
+	out := new(CommonResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/PauseScheduleTask", in, out)
+}
+
+func (c *cronClient) StartScheduleTask(ctx context.Context, in *CommonIDRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment) {
+	out := new(CommonResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/StartScheduleTask", in, out)
+}
+
+func (c *cronClient) DeleteScheduleTask(ctx context.Context, in *CommonIDRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment) {
+	out := new(CommonResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/DeleteScheduleTask", in, out)
+}
+
+// CronServer is the server API for Cron service.
+// All implementations must embed UnimplementedCronServer
+// for forward compatibility
+type CronServer interface {
+	CreateScheduleTask(context.Context, *CreateScheduleTaskRequest) (*CreateScheduleTaskResponse, error)
+	GetListScheduleTask(context.Context, *GetListScheduleTaskRequest) (*GetListScheduleTaskResponse, error)
+	GetListExecutionRecord(context.Context, *GetListExecutionRecordRequest) (*GetListExecutionRecordResponse, error)
+	GetListExecutionResult(context.Context, *GetListExecutionResultRequest) (*GetListExecutionResultResponse, error)
+	PauseScheduleTask(context.Context, *CommonIDRequest) (*CommonResponse, error)
+	StartScheduleTask(context.Context, *CommonIDRequest) (*CommonResponse, error)
+	DeleteScheduleTask(context.Context, *CommonIDRequest) (*CommonResponse, error)
+	mustEmbedUnimplementedCronServer()
+}
+
+// UnimplementedCronServer must be embedded to have forward compatible implementations.
+type UnimplementedCronServer struct {
+	proxyImpl protocol.Invoker
+}
+
+func (UnimplementedCronServer) CreateScheduleTask(context.Context, *CreateScheduleTaskRequest) (*CreateScheduleTaskResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method CreateScheduleTask not implemented")
+}
+func (UnimplementedCronServer) GetListScheduleTask(context.Context, *GetListScheduleTaskRequest) (*GetListScheduleTaskResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetListScheduleTask not implemented")
+}
+func (UnimplementedCronServer) GetListExecutionRecord(context.Context, *GetListExecutionRecordRequest) (*GetListExecutionRecordResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetListExecutionRecord not implemented")
+}
+func (UnimplementedCronServer) GetListExecutionResult(context.Context, *GetListExecutionResultRequest) (*GetListExecutionResultResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetListExecutionResult not implemented")
+}
+func (UnimplementedCronServer) PauseScheduleTask(context.Context, *CommonIDRequest) (*CommonResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method PauseScheduleTask not implemented")
+}
+func (UnimplementedCronServer) StartScheduleTask(context.Context, *CommonIDRequest) (*CommonResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method StartScheduleTask not implemented")
+}
+func (UnimplementedCronServer) DeleteScheduleTask(context.Context, *CommonIDRequest) (*CommonResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method DeleteScheduleTask not implemented")
+}
+func (s *UnimplementedCronServer) XXX_SetProxyImpl(impl protocol.Invoker) {
+	s.proxyImpl = impl
+}
+
+func (s *UnimplementedCronServer) XXX_GetProxyImpl() protocol.Invoker {
+	return s.proxyImpl
+}
+
+func (s *UnimplementedCronServer) XXX_ServiceDesc() *grpc_go.ServiceDesc {
+	return &Cron_ServiceDesc
+}
+func (s *UnimplementedCronServer) XXX_InterfaceName() string {
+	return "cron.Cron"
+}
+
+func (UnimplementedCronServer) mustEmbedUnimplementedCronServer() {}
+
+// UnsafeCronServer may be embedded to opt out of forward compatibility for this service.
+// Use of this interface is not recommended, as added methods to CronServer will
+// result in compilation errors.
+type UnsafeCronServer interface {
+	mustEmbedUnimplementedCronServer()
+}
+
+func RegisterCronServer(s grpc_go.ServiceRegistrar, srv CronServer) {
+	s.RegisterService(&Cron_ServiceDesc, srv)
+}
+
+func _Cron_CreateScheduleTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(CreateScheduleTaskRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	base := srv.(dubbo3.Dubbo3GrpcService)
+	args := []interface{}{}
+	args = append(args, in)
+	md, _ := metadata.FromIncomingContext(ctx)
+	invAttachment := make(map[string]interface{}, len(md))
+	for k, v := range md {
+		invAttachment[k] = v
+	}
+	invo := invocation.NewRPCInvocation("CreateScheduleTask", args, invAttachment)
+	if interceptor == nil {
+		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
+		return result, result.Error()
+	}
+	info := &grpc_go.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string),
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
+		return result, result.Error()
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Cron_GetListScheduleTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetListScheduleTaskRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	base := srv.(dubbo3.Dubbo3GrpcService)
+	args := []interface{}{}
+	args = append(args, in)
+	md, _ := metadata.FromIncomingContext(ctx)
+	invAttachment := make(map[string]interface{}, len(md))
+	for k, v := range md {
+		invAttachment[k] = v
+	}
+	invo := invocation.NewRPCInvocation("GetListScheduleTask", args, invAttachment)
+	if interceptor == nil {
+		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
+		return result, result.Error()
+	}
+	info := &grpc_go.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string),
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
+		return result, result.Error()
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Cron_GetListExecutionRecord_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetListExecutionRecordRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	base := srv.(dubbo3.Dubbo3GrpcService)
+	args := []interface{}{}
+	args = append(args, in)
+	md, _ := metadata.FromIncomingContext(ctx)
+	invAttachment := make(map[string]interface{}, len(md))
+	for k, v := range md {
+		invAttachment[k] = v
+	}
+	invo := invocation.NewRPCInvocation("GetListExecutionRecord", args, invAttachment)
+	if interceptor == nil {
+		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
+		return result, result.Error()
+	}
+	info := &grpc_go.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string),
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
+		return result, result.Error()
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Cron_GetListExecutionResult_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetListExecutionResultRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	base := srv.(dubbo3.Dubbo3GrpcService)
+	args := []interface{}{}
+	args = append(args, in)
+	md, _ := metadata.FromIncomingContext(ctx)
+	invAttachment := make(map[string]interface{}, len(md))
+	for k, v := range md {
+		invAttachment[k] = v
+	}
+	invo := invocation.NewRPCInvocation("GetListExecutionResult", args, invAttachment)
+	if interceptor == nil {
+		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
+		return result, result.Error()
+	}
+	info := &grpc_go.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string),
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
+		return result, result.Error()
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Cron_PauseScheduleTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(CommonIDRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	base := srv.(dubbo3.Dubbo3GrpcService)
+	args := []interface{}{}
+	args = append(args, in)
+	md, _ := metadata.FromIncomingContext(ctx)
+	invAttachment := make(map[string]interface{}, len(md))
+	for k, v := range md {
+		invAttachment[k] = v
+	}
+	invo := invocation.NewRPCInvocation("PauseScheduleTask", args, invAttachment)
+	if interceptor == nil {
+		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
+		return result, result.Error()
+	}
+	info := &grpc_go.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string),
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
+		return result, result.Error()
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Cron_StartScheduleTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(CommonIDRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	base := srv.(dubbo3.Dubbo3GrpcService)
+	args := []interface{}{}
+	args = append(args, in)
+	md, _ := metadata.FromIncomingContext(ctx)
+	invAttachment := make(map[string]interface{}, len(md))
+	for k, v := range md {
+		invAttachment[k] = v
+	}
+	invo := invocation.NewRPCInvocation("StartScheduleTask", args, invAttachment)
+	if interceptor == nil {
+		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
+		return result, result.Error()
+	}
+	info := &grpc_go.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string),
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
+		return result, result.Error()
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Cron_DeleteScheduleTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(CommonIDRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	base := srv.(dubbo3.Dubbo3GrpcService)
+	args := []interface{}{}
+	args = append(args, in)
+	md, _ := metadata.FromIncomingContext(ctx)
+	invAttachment := make(map[string]interface{}, len(md))
+	for k, v := range md {
+		invAttachment[k] = v
+	}
+	invo := invocation.NewRPCInvocation("DeleteScheduleTask", args, invAttachment)
+	if interceptor == nil {
+		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
+		return result, result.Error()
+	}
+	info := &grpc_go.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string),
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
+		return result, result.Error()
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+// Cron_ServiceDesc is the grpc_go.ServiceDesc for Cron service.
+// It's only intended for direct use with grpc_go.RegisterService,
+// and not to be introspected or modified (even as a copy)
+var Cron_ServiceDesc = grpc_go.ServiceDesc{
+	ServiceName: "cron.Cron",
+	HandlerType: (*CronServer)(nil),
+	Methods: []grpc_go.MethodDesc{
+		{
+			MethodName: "CreateScheduleTask",
+			Handler:    _Cron_CreateScheduleTask_Handler,
+		},
+		{
+			MethodName: "GetListScheduleTask",
+			Handler:    _Cron_GetListScheduleTask_Handler,
+		},
+		{
+			MethodName: "GetListExecutionRecord",
+			Handler:    _Cron_GetListExecutionRecord_Handler,
+		},
+		{
+			MethodName: "GetListExecutionResult",
+			Handler:    _Cron_GetListExecutionResult_Handler,
+		},
+		{
+			MethodName: "PauseScheduleTask",
+			Handler:    _Cron_PauseScheduleTask_Handler,
+		},
+		{
+			MethodName: "StartScheduleTask",
+			Handler:    _Cron_StartScheduleTask_Handler,
+		},
+		{
+			MethodName: "DeleteScheduleTask",
+			Handler:    _Cron_DeleteScheduleTask_Handler,
+		},
+	},
+	Streams:  []grpc_go.StreamDesc{},
+	Metadata: "pb/cron.proto",
+}

conf/dubbogo.yaml

@@ -2,10 +2,27 @@ dubbo:
   registries:
     demoZK:
       protocol: zookeeper
-      timeout: 5s
+      timeout: 3s
+      #      address: 121.229.45.214:9004
       address: 127.0.0.1:2181
+  #      address: 127.0.0.1:2181
+  #      address: 114.218.158.24:2181
   consumer:
+    filter: tracing
+    request-timeout: 300s
     references:
+      OrderClientImpl:
+        protocol: tri
+        retries: 0
+        interface: com.fontree.microservices.common.order # must be compatible with grpc or dubbo-java
+        #        filter: cshutdown,sign,fonDomainFilter,fonValidateFilter
+        params:
+          .accessKeyId: "SYD8-order-04"
+          .secretAccessKey: "Al-order-FDF112"
+      BundleClientImpl:
+        protocol: tri
+        retries: 0
+        interface: com.fontree.microservices.fiee.bundle # must be compatible with grpc or dubbo-java
       AccountClientImpl:
         protocol: tri
         retries: 0
@@ -14,19 +31,65 @@ dubbo:
         params:
           .accessKeyId: "Accountksl"
           .secretAccessKey: "BSDY-FDF1-Fontree_account"
-
       AccountFieeClientImpl:
         protocol: tri
-        retries: 0
+        retries: 3
         interface: com.fontree.microservices.common.micro.account.fiee
-#        filter: cshutdown,sign,fonDomainFilter,fonValidateFilter
-#        params:
-#          .accessKeyId: "Accountksl"
-#          .secretAccessKey: "BSDY-FDF1-Fontree_account"
-      BundleClientImpl:
+      #        filter: echo,metrics,token,accesslog,sign,tps,generic_service,execute,pshutdown,auth,fonValidateFilter
+      PaymentCentClientImpl:
         protocol: tri
         retries: 0
-        interface: com.fontree.microservices.fiee.bundle # must be compatible with grpc or dubbo-java
+        interface: com.fontree.microservices.common.payment.cent # must be compatible with grpc or dubbo-java
       CastClientImpl:
         protocol: tri
         interface: com.fontree.microservices.fiee.multicast
+      SecFilingsClientImpl:
+        protocol: tri
+        retries: 0
+        interface: com.fontree.microservices.fiee.SecFiling
+      AyrshareClientImpl:
+        protocol: tri
+        interface: com.fontree.microservices.fiee.ayrshare
+      FieeCronClientImpl:
+        protocol: tri
+        interface: com.fontree.microservices.fiee.cron
+  logger:
+    zap-config:
+      level: error # 日志级别
+      development: false
+      disableCaller: false
+      disableStacktrace: false
+      encoding: "json"
+      # zap encoder 配置
+      encoderConfig:
+        messageKey: "message"
+        levelKey: "level"
+        timeKey: "time"
+        nameKey: "logger"
+        callerKey: "caller"
+        stacktraceKey: "stacktrace"
+        lineEnding: ""
+        levelEncoder: "capitalColor"
+        timeEncoder: "iso8601"
+        durationEncoder: "seconds"
+        callerEncoder: "short"
+        nameEncoder: ""
+        EncodeTime: zapcore.TimeEncoderOfLayout("2006-01-02 15:04:05.000"),
+        EncodeDuration: zapcore.SecondsDurationEncoder,
+      outputPaths:
+        - "stderr"
+      errorOutputPaths:
+        - "stderr"
+    lumberjack-config:
+      # 写日志的文件名称
+      filename: "runtime/logs/fiee.log"
+      # 每个日志文件长度的最大大小，单位是 MiB。默认 100MiB
+      maxSize: 5
+      # 日志保留的最大天数(只保留最近多少天的日志)
+      maxAge: 30
+      # 只保留最近多少个日志文件，用于控制程序总日志的大小
+      maxBackups: 30
+      # 是否使用本地时间，默认使用 UTC 时间
+      localTime: true
+      # 是否压缩日志文件，压缩方法 gzip
+      compress: false

docs/dev/dubbogo.yaml

@@ -50,6 +50,9 @@ dubbo:
       AyrshareClientImpl:
         protocol: tri
         interface: com.fontree.microservices.fiee.ayrshare
+      FieeCronClientImpl:
+        protocol: tri
+        interface: com.fontree.microservices.fiee.cron
   logger:
     zap-config:
       level: error # 日志级别

docs/prod/dubbogo.yaml

@@ -52,6 +52,9 @@ dubbo:
       AyrshareClientImpl:
         protocol: tri
         interface: com.fontree.microservices.fiee.ayrshare
+      FieeCronClientImpl:
+        protocol: tri
+        interface: com.fontree.microservices.fiee.cron
   logger:
     zap-config:
       level: error # 日志级别

docs/test/dubbogo.yaml

@@ -50,6 +50,9 @@ dubbo:
       AyrshareClientImpl:
         protocol: tri
         interface: com.fontree.microservices.fiee.ayrshare
+      FieeCronClientImpl:
+        protocol: tri
+        interface: com.fontree.microservices.fiee.cron
   logger:
     zap-config:
       level: error # 日志级别

pkg/router/cron.go

@@ -0,0 +1,23 @@
+package router
+
+import (
+	cronService "fonchain-fiee/pkg/service/cron"
+
+	"github.com/gin-gonic/gin"
+)
+
+func cronRouter(r *gin.RouterGroup) {
+	auth := r.Group("")
+	//auth.Use(middleware.CheckWebLogin(service.AccountProvider))
+	cron := auth.Group("cron")
+	{
+		cron.POST("createScheduleTask", cronService.CreateScheduleTask)
+		cron.POST("pauseScheduleTask", cronService.PauseScheduleTask)
+		cron.POST("startScheduleTask", cronService.StartScheduleTask)
+		cron.POST("deleteScheduleTask", cronService.DeleteScheduleTask)
+		cron.GET("getListScheduleTask", cronService.GetListScheduleTask)
+		cron.GET("getListExecutionResult", cronService.GetListExecutionResult)
+		cron.GET("getListExecutionRecord", cronService.GetListExecutionRecord)
+
+	}
+}

pkg/router/router.go

@@ -55,6 +55,7 @@ func NewRouter() *gin.Engine {
 	MediaRouter(privateGroup)
 	SecFilingRouter(privateGroup)
 	app.MediaAppRouter(privateGroup)
+	cronRouter(privateGroup)
 	{
 		v1.POST("version", version.Version) //版本号公共
 	}

pkg/service/cron/cron.go

@@ -0,0 +1,135 @@
+package cron
+
+import (
+	"context"
+	"errors"
+	"fonchain-fiee/api/cron"
+	"fonchain-fiee/pkg/service"
+
+	"github.com/gin-gonic/gin"
+	"github.com/gin-gonic/gin/binding"
+)
+
+func CreateScheduleTask(c *gin.Context) {
+	var req cron.CreateScheduleTaskRequest
+	if err := c.ShouldBindBodyWith(&req, binding.JSON); err != nil {
+		service.Error(c, errors.New("参数错误"))
+		return
+	}
+	res, err := service.CronProvider.CreateScheduleTask(context.Background(), &req)
+	if err != nil {
+		service.Error(c, errors.New("网络超时,请重试"))
+		return
+	}
+	if res.Code != 200 {
+		service.Error(c, errors.New(res.Message))
+		return
+	}
+	service.Success(c, res)
+}
+
+func GetListScheduleTask(c *gin.Context) {
+	var req cron.GetListScheduleTaskRequest
+	if err := c.ShouldBindJSON(&req); err != nil {
+		service.Error(c, errors.New("参数错误"))
+		return
+	}
+	res, err := service.CronProvider.GetListScheduleTask(context.Background(), &req)
+	if err != nil {
+		service.Error(c, errors.New("网络超时,请重试"))
+		return
+	}
+	if res.Code != 200 {
+		service.Error(c, errors.New(res.Message))
+		return
+	}
+	service.Success(c, res)
+}
+
+func GetListExecutionRecord(c *gin.Context) {
+	var req cron.GetListExecutionRecordRequest
+	if err := c.ShouldBindJSON(&req); err != nil {
+		service.Error(c, errors.New("参数错误"))
+		return
+	}
+	res, err := service.CronProvider.GetListExecutionRecord(context.Background(), &req)
+	if err != nil {
+		service.Error(c, errors.New("网络超时,请重试"))
+		return
+	}
+	if res.Code != 200 {
+		service.Error(c, errors.New(res.Message))
+		return
+	}
+	service.Success(c, res)
+}
+func GetListExecutionResult(c *gin.Context) {
+	var req cron.GetListExecutionResultRequest
+	if err := c.ShouldBindJSON(&req); err != nil {
+		service.Error(c, errors.New("参数错误"))
+		return
+	}
+	res, err := service.CronProvider.GetListExecutionResult(context.Background(), &req)
+	if err != nil {
+		service.Error(c, errors.New("网络超时,请重试"))
+		return
+	}
+	if res.Code != 200 {
+		service.Error(c, errors.New(res.Message))
+		return
+	}
+	service.Success(c, res)
+}
+func StartScheduleTask(c *gin.Context) {
+	var req cron.CommonIDRequest
+	if err := c.ShouldBindJSON(&req); err != nil {
+		service.Error(c, errors.New("参数错误"))
+		return
+	}
+	res, err := service.CronProvider.StartScheduleTask(context.Background(), &req)
+	if err != nil {
+		service.Error(c, errors.New("网络超时,请重试"))
+		return
+	}
+	if res.Code != 200 {
+		service.Error(c, errors.New(res.Message))
+		return
+	}
+	service.Success(c, res)
+}
+
+func PauseScheduleTask(c *gin.Context) {
+	var req cron.CommonIDRequest
+	if err := c.ShouldBindJSON(&req); err != nil {
+		service.Error(c, errors.New("参数错误"))
+		return
+	}
+	res, err := service.CronProvider.PauseScheduleTask(context.Background(), &req)
+	if err != nil {
+		service.Error(c, errors.New("网络超时,请重试"))
+		return
+	}
+	if res.Code != 200 {
+		service.Error(c, errors.New(res.Message))
+		return
+	}
+	service.Success(c, res)
+}
+
+func DeleteScheduleTask(c *gin.Context) {
+	var req cron.CommonIDRequest
+	if err := c.ShouldBindJSON(&req); err != nil {
+		service.Error(c, errors.New("参数错误"))
+		return
+	}
+	res, err := service.CronProvider.DeleteScheduleTask(context.Background(), &req)
+	if err != nil {
+		service.Error(c, errors.New("网络超时,请重试"))
+		return
+	}
+	if res.Code != 200 {
+		service.Error(c, errors.New(res.Message))
+		return
+	}
+	service.Success(c, res)
+}

pkg/service/init.go

@@ -7,6 +7,7 @@ import (
 	"fonchain-fiee/api/aryshare"
 	"fonchain-fiee/api/bundle"
 	"fonchain-fiee/api/cast"
+	"fonchain-fiee/api/cron"
 	"fonchain-fiee/api/files"
 	"fonchain-fiee/api/governance"
 	"fonchain-fiee/api/order"
@@ -33,6 +34,7 @@ var GovernanceProvider = new(governance.GovernanceClientImpl)
 var PressReleasesProvider = new(pressreleases.PressReleasesClientImpl)
 var SecFilingProvider = new(secFilings.SecFilingsClientImpl)
 var AyrshareProvider = new(aryshare.AyrshareClientImpl)
+var CronProvider = new(cron.CronClientImpl)
 
 func init() {
 	config.SetConsumerService(BundleProvider)
@@ -46,6 +48,7 @@ func init() {
 	config.SetConsumerService(PressReleasesProvider)
 	config.SetConsumerService(SecFilingProvider)
 	config.SetConsumerService(AyrshareProvider)
+	config.SetConsumerService(CronProvider)
 
 	if err := config.Load(); err != nil {
 		panic(err)