Updata:跟新pb文件与路由；补充缺失接口

api/members/members.validator.pb.go

@@ -0,0 +1,101 @@
+// Code generated by protoc-gen-gogo. DO NOT EDIT.
+// source: api/members/members.proto
+
+package members
+
+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 *AddMemberReq) Validate() error {
+	return nil
+}
+func (this *AddMemberResp) Validate() error {
+	return nil
+}
+func (this *EditMemberReq) Validate() error {
+	return nil
+}
+func (this *EditMemberResp) Validate() error {
+	return nil
+}
+func (this *DeleteMemberReq) Validate() error {
+	return nil
+}
+func (this *DeleteMemberResp) Validate() error {
+	return nil
+}
+func (this *Filtrate) Validate() error {
+	return nil
+}
+func (this *GetMemberListReq) Validate() error {
+	if this.Filterate != nil {
+		if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(this.Filterate); err != nil {
+			return github_com_mwitkow_go_proto_validators.FieldError("Filterate", err)
+		}
+	}
+	return nil
+}
+func (this *GetMemberListResp) 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 *Member) Validate() error {
+	if this.Management != nil {
+		if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(this.Management); err != nil {
+			return github_com_mwitkow_go_proto_validators.FieldError("Management", err)
+		}
+	}
+	if this.BoardOfDirectors != nil {
+		if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(this.BoardOfDirectors); err != nil {
+			return github_com_mwitkow_go_proto_validators.FieldError("BoardOfDirectors", err)
+		}
+	}
+	if this.CommitteeAppointments != nil {
+		if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(this.CommitteeAppointments); err != nil {
+			return github_com_mwitkow_go_proto_validators.FieldError("CommitteeAppointments", err)
+		}
+	}
+	return nil
+}
+func (this *Management) Validate() error {
+	return nil
+}
+func (this *EditManagementReq) Validate() error {
+	return nil
+}
+func (this *EditManagementResp) Validate() error {
+	return nil
+}
+func (this *BoardOfDirectors) Validate() error {
+	return nil
+}
+func (this *EditBoardOfDirectorsReq) Validate() error {
+	return nil
+}
+func (this *EditBoardOfDirectorsResp) Validate() error {
+	return nil
+}
+func (this *CommitteeAppointments) Validate() error {
+	return nil
+}
+func (this *EditCommitteeAppointmentsReq) Validate() error {
+	return nil
+}
+func (this *EditCommitteeAppointmentsResp) Validate() error {
+	return nil
+}

api/members/members_triple.pb.go

@@ -0,0 +1,425 @@
+// Code generated by protoc-gen-go-triple. DO NOT EDIT.
+// versions:
+// - protoc-gen-go-triple v1.0.5
+// - protoc             v5.26.0
+// source: api/members/members.proto
+
+package members
+
+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
+
+// MembersClient is the client API for Members 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 MembersClient interface {
+	// ==================================成员管理======================================
+	AddMember(ctx context.Context, in *AddMemberReq, opts ...grpc_go.CallOption) (*AddMemberResp, common.ErrorWithAttachment)
+	EditMember(ctx context.Context, in *EditMemberReq, opts ...grpc_go.CallOption) (*EditMemberResp, common.ErrorWithAttachment)
+	DeleteMember(ctx context.Context, in *DeleteMemberReq, opts ...grpc_go.CallOption) (*DeleteMemberResp, common.ErrorWithAttachment)
+	GetMemberList(ctx context.Context, in *GetMemberListReq, opts ...grpc_go.CallOption) (*GetMemberListResp, common.ErrorWithAttachment)
+	// ===================================成员信息管理=======================================
+	EditManagement(ctx context.Context, in *EditManagementReq, opts ...grpc_go.CallOption) (*EditManagementResp, common.ErrorWithAttachment)
+	// ===================================董事会信息管理=======================================
+	EditBoardOfDirectors(ctx context.Context, in *EditBoardOfDirectorsReq, opts ...grpc_go.CallOption) (*EditBoardOfDirectorsResp, common.ErrorWithAttachment)
+	// ==================================委员会任命管理======================================
+	EditCommitteeAppointments(ctx context.Context, in *EditCommitteeAppointmentsReq, opts ...grpc_go.CallOption) (*EditCommitteeAppointmentsResp, common.ErrorWithAttachment)
+}
+
+type membersClient struct {
+	cc *triple.TripleConn
+}
+
+type MembersClientImpl struct {
+	AddMember                 func(ctx context.Context, in *AddMemberReq) (*AddMemberResp, error)
+	EditMember                func(ctx context.Context, in *EditMemberReq) (*EditMemberResp, error)
+	DeleteMember              func(ctx context.Context, in *DeleteMemberReq) (*DeleteMemberResp, error)
+	GetMemberList             func(ctx context.Context, in *GetMemberListReq) (*GetMemberListResp, error)
+	EditManagement            func(ctx context.Context, in *EditManagementReq) (*EditManagementResp, error)
+	EditBoardOfDirectors      func(ctx context.Context, in *EditBoardOfDirectorsReq) (*EditBoardOfDirectorsResp, error)
+	EditCommitteeAppointments func(ctx context.Context, in *EditCommitteeAppointmentsReq) (*EditCommitteeAppointmentsResp, error)
+}
+
+func (c *MembersClientImpl) GetDubboStub(cc *triple.TripleConn) MembersClient {
+	return NewMembersClient(cc)
+}
+
+func (c *MembersClientImpl) XXX_InterfaceName() string {
+	return "members.Members"
+}
+
+func NewMembersClient(cc *triple.TripleConn) MembersClient {
+	return &membersClient{cc}
+}
+
+func (c *membersClient) AddMember(ctx context.Context, in *AddMemberReq, opts ...grpc_go.CallOption) (*AddMemberResp, common.ErrorWithAttachment) {
+	out := new(AddMemberResp)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/AddMember", in, out)
+}
+
+func (c *membersClient) EditMember(ctx context.Context, in *EditMemberReq, opts ...grpc_go.CallOption) (*EditMemberResp, common.ErrorWithAttachment) {
+	out := new(EditMemberResp)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/EditMember", in, out)
+}
+
+func (c *membersClient) DeleteMember(ctx context.Context, in *DeleteMemberReq, opts ...grpc_go.CallOption) (*DeleteMemberResp, common.ErrorWithAttachment) {
+	out := new(DeleteMemberResp)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/DeleteMember", in, out)
+}
+
+func (c *membersClient) GetMemberList(ctx context.Context, in *GetMemberListReq, opts ...grpc_go.CallOption) (*GetMemberListResp, common.ErrorWithAttachment) {
+	out := new(GetMemberListResp)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetMemberList", in, out)
+}
+
+func (c *membersClient) EditManagement(ctx context.Context, in *EditManagementReq, opts ...grpc_go.CallOption) (*EditManagementResp, common.ErrorWithAttachment) {
+	out := new(EditManagementResp)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/EditManagement", in, out)
+}
+
+func (c *membersClient) EditBoardOfDirectors(ctx context.Context, in *EditBoardOfDirectorsReq, opts ...grpc_go.CallOption) (*EditBoardOfDirectorsResp, common.ErrorWithAttachment) {
+	out := new(EditBoardOfDirectorsResp)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/EditBoardOfDirectors", in, out)
+}
+
+func (c *membersClient) EditCommitteeAppointments(ctx context.Context, in *EditCommitteeAppointmentsReq, opts ...grpc_go.CallOption) (*EditCommitteeAppointmentsResp, common.ErrorWithAttachment) {
+	out := new(EditCommitteeAppointmentsResp)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/EditCommitteeAppointments", in, out)
+}
+
+// MembersServer is the server API for Members service.
+// All implementations must embed UnimplementedMembersServer
+// for forward compatibility
+type MembersServer interface {
+	// ==================================成员管理======================================
+	AddMember(context.Context, *AddMemberReq) (*AddMemberResp, error)
+	EditMember(context.Context, *EditMemberReq) (*EditMemberResp, error)
+	DeleteMember(context.Context, *DeleteMemberReq) (*DeleteMemberResp, error)
+	GetMemberList(context.Context, *GetMemberListReq) (*GetMemberListResp, error)
+	// ===================================成员信息管理=======================================
+	EditManagement(context.Context, *EditManagementReq) (*EditManagementResp, error)
+	// ===================================董事会信息管理=======================================
+	EditBoardOfDirectors(context.Context, *EditBoardOfDirectorsReq) (*EditBoardOfDirectorsResp, error)
+	// ==================================委员会任命管理======================================
+	EditCommitteeAppointments(context.Context, *EditCommitteeAppointmentsReq) (*EditCommitteeAppointmentsResp, error)
+	mustEmbedUnimplementedMembersServer()
+}
+
+// UnimplementedMembersServer must be embedded to have forward compatible implementations.
+type UnimplementedMembersServer struct {
+	proxyImpl protocol.Invoker
+}
+
+func (UnimplementedMembersServer) AddMember(context.Context, *AddMemberReq) (*AddMemberResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method AddMember not implemented")
+}
+func (UnimplementedMembersServer) EditMember(context.Context, *EditMemberReq) (*EditMemberResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method EditMember not implemented")
+}
+func (UnimplementedMembersServer) DeleteMember(context.Context, *DeleteMemberReq) (*DeleteMemberResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method DeleteMember not implemented")
+}
+func (UnimplementedMembersServer) GetMemberList(context.Context, *GetMemberListReq) (*GetMemberListResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetMemberList not implemented")
+}
+func (UnimplementedMembersServer) EditManagement(context.Context, *EditManagementReq) (*EditManagementResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method EditManagement not implemented")
+}
+func (UnimplementedMembersServer) EditBoardOfDirectors(context.Context, *EditBoardOfDirectorsReq) (*EditBoardOfDirectorsResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method EditBoardOfDirectors not implemented")
+}
+func (UnimplementedMembersServer) EditCommitteeAppointments(context.Context, *EditCommitteeAppointmentsReq) (*EditCommitteeAppointmentsResp, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method EditCommitteeAppointments not implemented")
+}
+func (s *UnimplementedMembersServer) XXX_SetProxyImpl(impl protocol.Invoker) {
+	s.proxyImpl = impl
+}
+
+func (s *UnimplementedMembersServer) XXX_GetProxyImpl() protocol.Invoker {
+	return s.proxyImpl
+}
+
+func (s *UnimplementedMembersServer) XXX_ServiceDesc() *grpc_go.ServiceDesc {
+	return &Members_ServiceDesc
+}
+func (s *UnimplementedMembersServer) XXX_InterfaceName() string {
+	return "members.Members"
+}
+
+func (UnimplementedMembersServer) mustEmbedUnimplementedMembersServer() {}
+
+// UnsafeMembersServer may be embedded to opt out of forward compatibility for this service.
+// Use of this interface is not recommended, as added methods to MembersServer will
+// result in compilation errors.
+type UnsafeMembersServer interface {
+	mustEmbedUnimplementedMembersServer()
+}
+
+func RegisterMembersServer(s grpc_go.ServiceRegistrar, srv MembersServer) {
+	s.RegisterService(&Members_ServiceDesc, srv)
+}
+
+func _Members_AddMember_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(AddMemberReq)
+	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("AddMember", 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 _Members_EditMember_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(EditMemberReq)
+	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("EditMember", 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 _Members_DeleteMember_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(DeleteMemberReq)
+	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("DeleteMember", 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 _Members_GetMemberList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetMemberListReq)
+	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("GetMemberList", 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 _Members_EditManagement_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(EditManagementReq)
+	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("EditManagement", 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 _Members_EditBoardOfDirectors_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(EditBoardOfDirectorsReq)
+	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("EditBoardOfDirectors", 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 _Members_EditCommitteeAppointments_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(EditCommitteeAppointmentsReq)
+	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("EditCommitteeAppointments", 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)
+}
+
+// Members_ServiceDesc is the grpc_go.ServiceDesc for Members service.
+// It's only intended for direct use with grpc_go.RegisterService,
+// and not to be introspected or modified (even as a copy)
+var Members_ServiceDesc = grpc_go.ServiceDesc{
+	ServiceName: "members.Members",
+	HandlerType: (*MembersServer)(nil),
+	Methods: []grpc_go.MethodDesc{
+		{
+			MethodName: "AddMember",
+			Handler:    _Members_AddMember_Handler,
+		},
+		{
+			MethodName: "EditMember",
+			Handler:    _Members_EditMember_Handler,
+		},
+		{
+			MethodName: "DeleteMember",
+			Handler:    _Members_DeleteMember_Handler,
+		},
+		{
+			MethodName: "GetMemberList",
+			Handler:    _Members_GetMemberList_Handler,
+		},
+		{
+			MethodName: "EditManagement",
+			Handler:    _Members_EditManagement_Handler,
+		},
+		{
+			MethodName: "EditBoardOfDirectors",
+			Handler:    _Members_EditBoardOfDirectors_Handler,
+		},
+		{
+			MethodName: "EditCommitteeAppointments",
+			Handler:    _Members_EditCommitteeAppointments_Handler,
+		},
+	},
+	Streams:  []grpc_go.StreamDesc{},
+	Metadata: "api/members/members.proto",
+}

pkg/router/router.go

@@ -12,6 +12,7 @@ import (
 	"fonchain-fiee/pkg/service/governance"
 	imports "fonchain-fiee/pkg/service/import"
 	"fonchain-fiee/pkg/service/lang"
+	"fonchain-fiee/pkg/service/members"
 	"fonchain-fiee/pkg/service/pressreleases"
 	"fonchain-fiee/pkg/service/qr"
 	"fonchain-fiee/pkg/service/redirect"
@@ -212,6 +213,22 @@ func NewRouter() *gin.Engine {
 		emailAlertsRoute.POST("/submit", emailAlert.EmailAlertSubmit)
 		emailAlertsRouteLogin.POST("/list", emailAlert.GetEmailInformationList)
 	}
+	{
+		// 成员管理
+		membersRoute := v1.Group("/members")
+		membersRouteLogin := membersRoute.Group("", middleware.CheckWebLogin(service.AccountProvider))
+
+		membersRouteLogin.POST("/add", members.AddMember)
+		membersRouteLogin.POST("/list", members.GetMemberList)
+		membersRouteLogin.POST("/edit", members.EditMember)
+		membersRouteLogin.POST("/delete", members.DeleteMember)
+		// 成员信息管理
+		membersRouteLogin.POST("/management/edit", members.EditManagement)
+		// 董事会信息管理
+		membersRouteLogin.POST("/boardofdirectors/edit", members.EditBoardOfDirectors)
+		// 委员会任命管理
+		membersRouteLogin.POST("/committeeappointments/edit", members.EditCommitteeAppointments)
+	}
 	{
 		importRoute := v1.Group("/import")
 		importRoute.Use(middleware.CheckWebLogin(service.AccountProvider))

pkg/service/init.go

@@ -9,6 +9,7 @@ import (
 	"fonchain-fiee/api/emailAlerts"
 	"fonchain-fiee/api/files"
 	"fonchain-fiee/api/governance"
+	"fonchain-fiee/api/members"
 	"fonchain-fiee/api/order"
 	"fonchain-fiee/api/payment"
 	"fonchain-fiee/api/pressreleases"
@@ -35,6 +36,7 @@ var PressReleasesProvider = new(pressreleases.PressReleasesClientImpl)
 var SecFilingProvider = new(secFilings.SecFilingsClientImpl)
 var ReportsProvider = new(reports.ReportsClientImpl)
 var EmailAlertsProvider = new(emailAlerts.EmailAlertsClientImpl)
+var MembersProvider = new(members.MembersClientImpl)
 
 func init() {
 	config.SetConsumerService(BundleProvider)
@@ -49,6 +51,7 @@ func init() {
 	config.SetConsumerService(SecFilingProvider)
 	config.SetConsumerService(ReportsProvider)
 	config.SetConsumerService(EmailAlertsProvider)
+	config.SetConsumerService(MembersProvider)
 
 	if err := config.Load(); err != nil {
 		panic(err)

pkg/service/members/members.go

@@ -0,0 +1,122 @@
+package members
+
+import (
+	"fonchain-fiee/api/members"
+	"fonchain-fiee/pkg/model/login"
+	"fonchain-fiee/pkg/service"
+
+	"github.com/gin-gonic/gin"
+)
+
+func AddMember(ctx *gin.Context) {
+	var req members.AddMemberReq
+	if err := ctx.ShouldBindJSON(&req); err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	user := login.GetUserInfoFromC(ctx)
+	req.Operator = user.Name
+	req.OperatorId = int32(user.ID)
+	resp, err := service.MembersProvider.AddMember(ctx, &req)
+	if err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	service.Success(ctx, resp)
+}
+
+func GetMemberList(ctx *gin.Context) {
+	var req members.GetMemberListReq
+	if err := ctx.ShouldBindJSON(&req); err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	resp, err := service.MembersProvider.GetMemberList(ctx, &req)
+	if err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	service.Success(ctx, resp)
+}
+
+func EditMember(ctx *gin.Context) {
+	var req members.EditMemberReq
+	if err := ctx.ShouldBindJSON(&req); err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	user := login.GetUserInfoFromC(ctx)
+	req.Operator = user.Name
+	req.OperatorId = int32(user.ID)
+	resp, err := service.MembersProvider.EditMember(ctx, &req)
+	if err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	service.Success(ctx, resp)
+}
+
+func DeleteMember(ctx *gin.Context) {
+	var req members.DeleteMemberReq
+	if err := ctx.ShouldBindJSON(&req); err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	resp, err := service.MembersProvider.DeleteMember(ctx, &req)
+	if err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	service.Success(ctx, resp)
+}
+
+func EditManagement(ctx *gin.Context) {
+	var req members.EditManagementReq
+	if err := ctx.ShouldBindJSON(&req); err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	user := login.GetUserInfoFromC(ctx)
+	req.Operator = user.Name
+	req.OperatorId = int32(user.ID)
+	resp, err := service.MembersProvider.EditManagement(ctx, &req)
+	if err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	service.Success(ctx, resp)
+}
+
+func EditBoardOfDirectors(ctx *gin.Context) {
+	var req members.EditBoardOfDirectorsReq
+	if err := ctx.ShouldBindJSON(&req); err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	user := login.GetUserInfoFromC(ctx)
+	req.Operator = user.Name
+	req.OperatorId = int32(user.ID)
+	resp, err := service.MembersProvider.EditBoardOfDirectors(ctx, &req)
+	if err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	service.Success(ctx, resp)
+}
+
+func EditCommitteeAppointments(ctx *gin.Context) {
+	var req members.EditCommitteeAppointmentsReq
+	if err := ctx.ShouldBindJSON(&req); err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	user := login.GetUserInfoFromC(ctx)
+	req.Operator = user.Name
+	req.OperatorId = int32(user.ID)
+	resp, err := service.MembersProvider.EditCommitteeAppointments(ctx, &req)
+	if err != nil {
+		service.Error(ctx, err)
+		return
+	}
+	service.Success(ctx, resp)
+}