Merge branch 'dev' of https://gitea-net.fontree.cn/fiee/fonchain-fiee into dev

api/supplier/supplier.proto

@@ -0,0 +1,181 @@
+syntax = "proto3";
+package supplier;
+
+option go_package = "./;supplier";
+
+// FiEE供应商微服务
+service Supplier {
+  //供应商curd
+  rpc GetSupplier(GetSupplierRequest) returns (UpdateSupplierRequest) {}
+  rpc CreateSupplier(CreateSupplierRequest) returns (CreateSupplierResponse) {}
+  rpc UpdateSupplier(UpdateSupplierRequest) returns (CreateSupplierResponse) {}
+  rpc GetSupplierList(GetSupplierListRequest) returns (GetSupplierListResponse) {}
+  //组织字典
+  rpc CreateOrganizeDictionary(CreateOrganizeDictionaryRequest) returns (CreateOrganizeDictionaryResponse) {}
+  rpc GetOrganizeDictionaryList(GetOrganizeDictionaryListRequest) returns (GetOrganizeDictionaryListResponse) {}
+  //国家组织
+  rpc GetCountryRegionList(GetCountryRegionListRequest) returns (GetCountryRegionListResponse) {}
+  //导入
+  rpc CreateImportRecord(CreateImportRecordRequest) returns (CreateImportRecordResponse) {}
+  rpc GetImportRecordInfo(GetImportRecordRequest) returns (GetImportRecordResponse) {}
+}
+message GetImportRecordRequest{
+  string uuid = 1;
+}
+message GetImportRecordResponse{
+  uint64 successNum = 1;
+  uint64 failNum = 2;
+  string deriveUrl = 3;
+}
+message CreateImportRecordRequest{
+  repeated string supplierCodes = 1;
+  uint64 status = 2;
+  uint64 userId = 3;
+  string toLeadUrl = 4;
+  string deriveUrl = 5;
+  string uuid = 6;
+  uint64 successNum = 7;
+  uint64 failNum = 8;
+}
+message CreateImportRecordResponse{
+  uint64 id = 1;
+}
+message GetCountryRegionListResponse{
+  repeated CountryRegion data = 1;
+  uint64 page = 2;
+  uint64 pageSize = 3;
+  uint64 total = 4;
+}
+message CountryRegion{
+  uint64 id = 1;
+  string nameEN = 2;
+  string nameCN = 3;
+  string code = 4;
+}
+message GetCountryRegionListRequest{
+  uint64 page = 1;
+  uint64 pageSize = 2;
+  string nameEN = 3;
+  string nameCN = 4;
+  string code = 5;
+}
+message OrganizeDictionary{
+  uint64 id = 1;
+  string name = 2;
+}
+message GetOrganizeDictionaryListResponse{
+  repeated OrganizeDictionary data = 1;
+  uint64 page = 2;
+  uint64 pageSize = 3;
+  uint64 total = 4;
+}
+message CreateOrganizeDictionaryRequest{
+  string name = 1;
+}
+message CreateOrganizeDictionaryResponse{
+  uint64 id = 1;
+}
+message GetOrganizeDictionaryListRequest{
+  uint64 page = 1;
+  uint64 pageSize = 2;
+  string name = 3;
+}
+message GetSupplierListRequest{
+  uint64 page = 1;
+  uint64 pageSize = 2;
+  uint64 owningEntityId = 3;
+  string supplierUniqueCode = 4;
+  string legalName =5;
+  string localName = 6;
+}
+message GetSupplierListResponse{
+  uint64 total = 1;
+  repeated SupplierInfo data = 2;
+  uint64 page = 3;
+  uint64 pageSize = 4;
+}
+message SupplierInfo{
+  uint64 id = 1;
+  uint64 owningEntityId = 2;
+  string legalName = 3;
+  string localName = 4;
+  string abbreviationName = 5;
+  uint64 countryOrRegionId = 6;
+  string companyRegistrationNumber = 7;
+  string supplierType = 8;
+  string approvalStatus = 9;
+  string approvalDate = 10;
+  string lastReviewDate = 11;
+  string legalEntityType = 12;
+  string sanctionsCountryScreeningResult = 13;
+  string keyFinancial = 14;
+  string companyAddress = 15;
+  string primaryContact = 16;
+  string dataOwnerDepartment = 17;
+  string basicCompanyInformation = 18;
+  string linkAddress = 19;
+  string supplementaryText = 20;
+  repeated attachment attachments = 21;
+  uint64 status = 22;
+  string createdAt = 23;
+  string updatedAt = 24;
+  string supplierUniqueCode = 25;
+}
+message UpdateSupplierRequest{
+  uint64 id = 1;
+  uint64 owningEntityId = 2;
+  string legalName = 3;
+  string localName = 4;
+  string abbreviationName = 5;
+  uint64 countryOrRegionId = 6;
+  string companyRegistrationNumber = 7;
+  string supplierType = 8;
+  string approvalStatus = 9;
+  string approvalDate = 10;
+  string lastReviewDate = 11;
+  string legalEntityType = 12;
+  string sanctionsCountryScreeningResult = 13;
+  string keyFinancial = 14;
+  string companyAddress = 15;
+  string primaryContact = 16;
+  string dataOwnerDepartment = 17;
+  string basicCompanyInformation = 18;
+  string linkAddress = 19;
+  string supplementaryText = 20;
+  repeated attachment attachments = 21;
+  uint64 status = 22;
+}
+message CreateSupplierRequest{
+  uint64 owningEntityId = 1;
+  string legalName = 2;
+  string localName = 3;
+  string abbreviationName = 4;
+  uint64 countryOrRegionId = 5;
+  string companyRegistrationNumber = 6;
+  string supplierType = 7;
+  string approvalStatus = 8;
+  string approvalDate = 9;
+  string lastReviewDate = 10;
+  string legalEntityType = 11;
+  string sanctionsCountryScreeningResult = 12;
+  string keyFinancial = 13;
+  string companyAddress = 14;
+  string primaryContact = 15;
+  string dataOwnerDepartment = 16;
+  string basicCompanyInformation = 17;
+  string linkAddress = 18;
+  string supplementaryText = 19;
+  repeated attachment attachments = 20;
+  uint64 status = 21;
+}
+message attachment{
+  string url = 1;
+  string type = 2;
+  string name = 3;
+}
+message CreateSupplierResponse{
+  uint64 id = 1;
+}
+message GetSupplierRequest{
+  uint64 id = 1;
+}

api/supplier/supplier.validator.pb.go

@@ -0,0 +1,119 @@
+// Code generated by protoc-gen-gogo. DO NOT EDIT.
+// source: api/supplier/supplier.proto
+
+package supplier
+
+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 *GetImportRecordRequest) Validate() error {
+	return nil
+}
+func (this *GetImportRecordResponse) Validate() error {
+	return nil
+}
+func (this *CreateImportRecordRequest) Validate() error {
+	return nil
+}
+func (this *CreateImportRecordResponse) Validate() error {
+	return nil
+}
+func (this *GetCountryRegionListResponse) 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 *CountryRegion) Validate() error {
+	return nil
+}
+func (this *GetCountryRegionListRequest) Validate() error {
+	return nil
+}
+func (this *OrganizeDictionary) Validate() error {
+	return nil
+}
+func (this *GetOrganizeDictionaryListResponse) 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 *CreateOrganizeDictionaryRequest) Validate() error {
+	return nil
+}
+func (this *CreateOrganizeDictionaryResponse) Validate() error {
+	return nil
+}
+func (this *GetOrganizeDictionaryListRequest) Validate() error {
+	return nil
+}
+func (this *GetSupplierListRequest) Validate() error {
+	return nil
+}
+func (this *GetSupplierListResponse) 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 *SupplierInfo) Validate() error {
+	for _, item := range this.Attachments {
+		if item != nil {
+			if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
+				return github_com_mwitkow_go_proto_validators.FieldError("Attachments", err)
+			}
+		}
+	}
+	return nil
+}
+func (this *UpdateSupplierRequest) Validate() error {
+	for _, item := range this.Attachments {
+		if item != nil {
+			if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
+				return github_com_mwitkow_go_proto_validators.FieldError("Attachments", err)
+			}
+		}
+	}
+	return nil
+}
+func (this *CreateSupplierRequest) Validate() error {
+	for _, item := range this.Attachments {
+		if item != nil {
+			if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil {
+				return github_com_mwitkow_go_proto_validators.FieldError("Attachments", err)
+			}
+		}
+	}
+	return nil
+}
+func (this *Attachment) Validate() error {
+	return nil
+}
+func (this *CreateSupplierResponse) Validate() error {
+	return nil
+}
+func (this *GetSupplierRequest) Validate() error {
+	return nil
+}

api/supplier/supplier_triple.pb.go

@@ -0,0 +1,515 @@
+// Code generated by protoc-gen-go-triple. DO NOT EDIT.
+// versions:
+// - protoc-gen-go-triple v1.0.5
+// - protoc             v6.32.0
+// source: api/supplier/supplier.proto
+
+package supplier
+
+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
+
+// SupplierClient is the client API for Supplier 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 SupplierClient interface {
+	// 供应商curd
+	GetSupplier(ctx context.Context, in *GetSupplierRequest, opts ...grpc_go.CallOption) (*UpdateSupplierRequest, common.ErrorWithAttachment)
+	CreateSupplier(ctx context.Context, in *CreateSupplierRequest, opts ...grpc_go.CallOption) (*CreateSupplierResponse, common.ErrorWithAttachment)
+	UpdateSupplier(ctx context.Context, in *UpdateSupplierRequest, opts ...grpc_go.CallOption) (*CreateSupplierResponse, common.ErrorWithAttachment)
+	GetSupplierList(ctx context.Context, in *GetSupplierListRequest, opts ...grpc_go.CallOption) (*GetSupplierListResponse, common.ErrorWithAttachment)
+	// 组织字典
+	CreateOrganizeDictionary(ctx context.Context, in *CreateOrganizeDictionaryRequest, opts ...grpc_go.CallOption) (*CreateOrganizeDictionaryResponse, common.ErrorWithAttachment)
+	GetOrganizeDictionaryList(ctx context.Context, in *GetOrganizeDictionaryListRequest, opts ...grpc_go.CallOption) (*GetOrganizeDictionaryListResponse, common.ErrorWithAttachment)
+	// 国家组织
+	GetCountryRegionList(ctx context.Context, in *GetCountryRegionListRequest, opts ...grpc_go.CallOption) (*GetCountryRegionListResponse, common.ErrorWithAttachment)
+	// 导入
+	CreateImportRecord(ctx context.Context, in *CreateImportRecordRequest, opts ...grpc_go.CallOption) (*CreateImportRecordResponse, common.ErrorWithAttachment)
+	GetImportRecordInfo(ctx context.Context, in *GetImportRecordRequest, opts ...grpc_go.CallOption) (*GetImportRecordResponse, common.ErrorWithAttachment)
+}
+
+type supplierClient struct {
+	cc *triple.TripleConn
+}
+
+type SupplierClientImpl struct {
+	GetSupplier               func(ctx context.Context, in *GetSupplierRequest) (*UpdateSupplierRequest, error)
+	CreateSupplier            func(ctx context.Context, in *CreateSupplierRequest) (*CreateSupplierResponse, error)
+	UpdateSupplier            func(ctx context.Context, in *UpdateSupplierRequest) (*CreateSupplierResponse, error)
+	GetSupplierList           func(ctx context.Context, in *GetSupplierListRequest) (*GetSupplierListResponse, error)
+	CreateOrganizeDictionary  func(ctx context.Context, in *CreateOrganizeDictionaryRequest) (*CreateOrganizeDictionaryResponse, error)
+	GetOrganizeDictionaryList func(ctx context.Context, in *GetOrganizeDictionaryListRequest) (*GetOrganizeDictionaryListResponse, error)
+	GetCountryRegionList      func(ctx context.Context, in *GetCountryRegionListRequest) (*GetCountryRegionListResponse, error)
+	CreateImportRecord        func(ctx context.Context, in *CreateImportRecordRequest) (*CreateImportRecordResponse, error)
+	GetImportRecordInfo       func(ctx context.Context, in *GetImportRecordRequest) (*GetImportRecordResponse, error)
+}
+
+func (c *SupplierClientImpl) GetDubboStub(cc *triple.TripleConn) SupplierClient {
+	return NewSupplierClient(cc)
+}
+
+func (c *SupplierClientImpl) XXX_InterfaceName() string {
+	return "supplier.Supplier"
+}
+
+func NewSupplierClient(cc *triple.TripleConn) SupplierClient {
+	return &supplierClient{cc}
+}
+
+func (c *supplierClient) GetSupplier(ctx context.Context, in *GetSupplierRequest, opts ...grpc_go.CallOption) (*UpdateSupplierRequest, common.ErrorWithAttachment) {
+	out := new(UpdateSupplierRequest)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetSupplier", in, out)
+}
+
+func (c *supplierClient) CreateSupplier(ctx context.Context, in *CreateSupplierRequest, opts ...grpc_go.CallOption) (*CreateSupplierResponse, common.ErrorWithAttachment) {
+	out := new(CreateSupplierResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/CreateSupplier", in, out)
+}
+
+func (c *supplierClient) UpdateSupplier(ctx context.Context, in *UpdateSupplierRequest, opts ...grpc_go.CallOption) (*CreateSupplierResponse, common.ErrorWithAttachment) {
+	out := new(CreateSupplierResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/UpdateSupplier", in, out)
+}
+
+func (c *supplierClient) GetSupplierList(ctx context.Context, in *GetSupplierListRequest, opts ...grpc_go.CallOption) (*GetSupplierListResponse, common.ErrorWithAttachment) {
+	out := new(GetSupplierListResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetSupplierList", in, out)
+}
+
+func (c *supplierClient) CreateOrganizeDictionary(ctx context.Context, in *CreateOrganizeDictionaryRequest, opts ...grpc_go.CallOption) (*CreateOrganizeDictionaryResponse, common.ErrorWithAttachment) {
+	out := new(CreateOrganizeDictionaryResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/CreateOrganizeDictionary", in, out)
+}
+
+func (c *supplierClient) GetOrganizeDictionaryList(ctx context.Context, in *GetOrganizeDictionaryListRequest, opts ...grpc_go.CallOption) (*GetOrganizeDictionaryListResponse, common.ErrorWithAttachment) {
+	out := new(GetOrganizeDictionaryListResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetOrganizeDictionaryList", in, out)
+}
+
+func (c *supplierClient) GetCountryRegionList(ctx context.Context, in *GetCountryRegionListRequest, opts ...grpc_go.CallOption) (*GetCountryRegionListResponse, common.ErrorWithAttachment) {
+	out := new(GetCountryRegionListResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetCountryRegionList", in, out)
+}
+
+func (c *supplierClient) CreateImportRecord(ctx context.Context, in *CreateImportRecordRequest, opts ...grpc_go.CallOption) (*CreateImportRecordResponse, common.ErrorWithAttachment) {
+	out := new(CreateImportRecordResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/CreateImportRecord", in, out)
+}
+
+func (c *supplierClient) GetImportRecordInfo(ctx context.Context, in *GetImportRecordRequest, opts ...grpc_go.CallOption) (*GetImportRecordResponse, common.ErrorWithAttachment) {
+	out := new(GetImportRecordResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetImportRecordInfo", in, out)
+}
+
+// SupplierServer is the server API for Supplier service.
+// All implementations must embed UnimplementedSupplierServer
+// for forward compatibility
+type SupplierServer interface {
+	// 供应商curd
+	GetSupplier(context.Context, *GetSupplierRequest) (*UpdateSupplierRequest, error)
+	CreateSupplier(context.Context, *CreateSupplierRequest) (*CreateSupplierResponse, error)
+	UpdateSupplier(context.Context, *UpdateSupplierRequest) (*CreateSupplierResponse, error)
+	GetSupplierList(context.Context, *GetSupplierListRequest) (*GetSupplierListResponse, error)
+	// 组织字典
+	CreateOrganizeDictionary(context.Context, *CreateOrganizeDictionaryRequest) (*CreateOrganizeDictionaryResponse, error)
+	GetOrganizeDictionaryList(context.Context, *GetOrganizeDictionaryListRequest) (*GetOrganizeDictionaryListResponse, error)
+	// 国家组织
+	GetCountryRegionList(context.Context, *GetCountryRegionListRequest) (*GetCountryRegionListResponse, error)
+	// 导入
+	CreateImportRecord(context.Context, *CreateImportRecordRequest) (*CreateImportRecordResponse, error)
+	GetImportRecordInfo(context.Context, *GetImportRecordRequest) (*GetImportRecordResponse, error)
+	mustEmbedUnimplementedSupplierServer()
+}
+
+// UnimplementedSupplierServer must be embedded to have forward compatible implementations.
+type UnimplementedSupplierServer struct {
+	proxyImpl protocol.Invoker
+}
+
+func (UnimplementedSupplierServer) GetSupplier(context.Context, *GetSupplierRequest) (*UpdateSupplierRequest, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetSupplier not implemented")
+}
+func (UnimplementedSupplierServer) CreateSupplier(context.Context, *CreateSupplierRequest) (*CreateSupplierResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method CreateSupplier not implemented")
+}
+func (UnimplementedSupplierServer) UpdateSupplier(context.Context, *UpdateSupplierRequest) (*CreateSupplierResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method UpdateSupplier not implemented")
+}
+func (UnimplementedSupplierServer) GetSupplierList(context.Context, *GetSupplierListRequest) (*GetSupplierListResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetSupplierList not implemented")
+}
+func (UnimplementedSupplierServer) CreateOrganizeDictionary(context.Context, *CreateOrganizeDictionaryRequest) (*CreateOrganizeDictionaryResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method CreateOrganizeDictionary not implemented")
+}
+func (UnimplementedSupplierServer) GetOrganizeDictionaryList(context.Context, *GetOrganizeDictionaryListRequest) (*GetOrganizeDictionaryListResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetOrganizeDictionaryList not implemented")
+}
+func (UnimplementedSupplierServer) GetCountryRegionList(context.Context, *GetCountryRegionListRequest) (*GetCountryRegionListResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetCountryRegionList not implemented")
+}
+func (UnimplementedSupplierServer) CreateImportRecord(context.Context, *CreateImportRecordRequest) (*CreateImportRecordResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method CreateImportRecord not implemented")
+}
+func (UnimplementedSupplierServer) GetImportRecordInfo(context.Context, *GetImportRecordRequest) (*GetImportRecordResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetImportRecordInfo not implemented")
+}
+func (s *UnimplementedSupplierServer) XXX_SetProxyImpl(impl protocol.Invoker) {
+	s.proxyImpl = impl
+}
+
+func (s *UnimplementedSupplierServer) XXX_GetProxyImpl() protocol.Invoker {
+	return s.proxyImpl
+}
+
+func (s *UnimplementedSupplierServer) XXX_ServiceDesc() *grpc_go.ServiceDesc {
+	return &Supplier_ServiceDesc
+}
+func (s *UnimplementedSupplierServer) XXX_InterfaceName() string {
+	return "supplier.Supplier"
+}
+
+func (UnimplementedSupplierServer) mustEmbedUnimplementedSupplierServer() {}
+
+// UnsafeSupplierServer may be embedded to opt out of forward compatibility for this service.
+// Use of this interface is not recommended, as added methods to SupplierServer will
+// result in compilation errors.
+type UnsafeSupplierServer interface {
+	mustEmbedUnimplementedSupplierServer()
+}
+
+func RegisterSupplierServer(s grpc_go.ServiceRegistrar, srv SupplierServer) {
+	s.RegisterService(&Supplier_ServiceDesc, srv)
+}
+
+func _Supplier_GetSupplier_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetSupplierRequest)
+	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("GetSupplier", 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 _Supplier_CreateSupplier_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(CreateSupplierRequest)
+	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("CreateSupplier", 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 _Supplier_UpdateSupplier_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(UpdateSupplierRequest)
+	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("UpdateSupplier", 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 _Supplier_GetSupplierList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetSupplierListRequest)
+	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("GetSupplierList", 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 _Supplier_CreateOrganizeDictionary_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(CreateOrganizeDictionaryRequest)
+	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("CreateOrganizeDictionary", 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 _Supplier_GetOrganizeDictionaryList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetOrganizeDictionaryListRequest)
+	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("GetOrganizeDictionaryList", 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 _Supplier_GetCountryRegionList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetCountryRegionListRequest)
+	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("GetCountryRegionList", 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 _Supplier_CreateImportRecord_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(CreateImportRecordRequest)
+	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("CreateImportRecord", 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 _Supplier_GetImportRecordInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetImportRecordRequest)
+	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("GetImportRecordInfo", 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)
+}
+
+// Supplier_ServiceDesc is the grpc_go.ServiceDesc for Supplier service.
+// It's only intended for direct use with grpc_go.RegisterService,
+// and not to be introspected or modified (even as a copy)
+var Supplier_ServiceDesc = grpc_go.ServiceDesc{
+	ServiceName: "supplier.Supplier",
+	HandlerType: (*SupplierServer)(nil),
+	Methods: []grpc_go.MethodDesc{
+		{
+			MethodName: "GetSupplier",
+			Handler:    _Supplier_GetSupplier_Handler,
+		},
+		{
+			MethodName: "CreateSupplier",
+			Handler:    _Supplier_CreateSupplier_Handler,
+		},
+		{
+			MethodName: "UpdateSupplier",
+			Handler:    _Supplier_UpdateSupplier_Handler,
+		},
+		{
+			MethodName: "GetSupplierList",
+			Handler:    _Supplier_GetSupplierList_Handler,
+		},
+		{
+			MethodName: "CreateOrganizeDictionary",
+			Handler:    _Supplier_CreateOrganizeDictionary_Handler,
+		},
+		{
+			MethodName: "GetOrganizeDictionaryList",
+			Handler:    _Supplier_GetOrganizeDictionaryList_Handler,
+		},
+		{
+			MethodName: "GetCountryRegionList",
+			Handler:    _Supplier_GetCountryRegionList_Handler,
+		},
+		{
+			MethodName: "CreateImportRecord",
+			Handler:    _Supplier_CreateImportRecord_Handler,
+		},
+		{
+			MethodName: "GetImportRecordInfo",
+			Handler:    _Supplier_GetImportRecordInfo_Handler,
+		},
+	},
+	Streams:  []grpc_go.StreamDesc{},
+	Metadata: "api/supplier/supplier.proto",
+}

conf/dubbogo.yaml

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

docs/dev/dubbogo.yaml

@@ -61,6 +61,9 @@ dubbo:
         methods:
           - name: SecurityScan
             timeout: 120000
+      SupplierClientImpl:
+        protocol: tri
+        interface: com.fontree.microservices.common.supplier
   logger:
     zap-config:
       level: error # 日志级别

docs/prod/dubbogo.yaml

@@ -63,6 +63,9 @@ dubbo:
         methods:
           - name: SecurityScan
             timeout: 120000
+      SupplierClientImpl:
+        protocol: tri
+        interface: com.fontree.microservices.common.supplier
   logger:
     zap-config:
       level: error # 日志级别

docs/test/dubbogo.yaml

@@ -61,7 +61,9 @@ dubbo:
       FieeCronClientImpl:
         protocol: tri
         interface: com.fontree.microservices.fiee.cron
-        timeout: 120000
+      SupplierClientImpl:
+        protocol: tri
+        interface: com.fontree.microservices.common.supplier
   logger:
     zap-config:
       level: error # 日志级别

pkg/router/router.go

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

pkg/router/supplier.go

@@ -0,0 +1,32 @@
+package router
+
+import (
+	"fonchain-fiee/pkg/service/supplier"
+
+	"github.com/gin-gonic/gin"
+)
+
+func SupplierRouter(r *gin.RouterGroup) {
+
+	supplierRoute := r.Group("supplier/web")
+
+	//supplierRoute.Use(middleware.CheckWebLogin(service.AccountProvider))
+	{
+		supplierRoute.POST("info", supplier.GetSupplier)
+		supplierRoute.POST("create", supplier.CreateSupplier)
+		supplierRoute.POST("update", supplier.UpdateSupplier)
+		supplierRoute.POST("list", supplier.GetSupplierList)
+	}
+	{
+		supplierRoute.POST("dictionary/create", supplier.CreateOrganizeDictionary)
+		supplierRoute.POST("dictionary/list", supplier.GetOrganizeDictionaryList)
+	}
+	{
+		supplierRoute.POST("country-region/list", supplier.GetCountryRegionList)
+	}
+	{
+		supplierRoute.POST("import/record", supplier.CreateImportRecord)
+		supplierRoute.POST("import/info", supplier.GetImportRecordInfo)
+	}
+
+}

pkg/service/init.go

@@ -17,6 +17,7 @@ import (
 	"fonchain-fiee/api/pressreleases"
 	"fonchain-fiee/api/reports"
 	"fonchain-fiee/api/secFilings"
+	"fonchain-fiee/api/supplier"
 	pkConfig "fonchain-fiee/pkg/config"
 	"os"
 
@@ -41,6 +42,7 @@ var CronProvider = new(cron.CronClientImpl)
 var ReportsProvider = new(reports.ReportsClientImpl)
 var EmailAlertsProvider = new(emailAlerts.EmailAlertsClientImpl)
 var MembersProvider = new(members.MembersClientImpl)
+var SupplierProvider = new(supplier.SupplierClientImpl)
 
 func init() {
 	config.SetConsumerService(BundleProvider)
@@ -58,6 +60,7 @@ func init() {
 	config.SetConsumerService(MembersProvider)
 	config.SetConsumerService(AyrshareProvider)
 	config.SetConsumerService(CronProvider)
+	config.SetConsumerService(SupplierProvider)
 
 	if err := config.Load(); err != nil {
 		panic(err)

pkg/service/supplier/supplier.go

@@ -0,0 +1,157 @@
+package supplier
+
+import (
+	"errors"
+	"fonchain-fiee/api/supplier"
+	"fonchain-fiee/pkg/service"
+
+	"github.com/gin-gonic/gin"
+	"github.com/gin-gonic/gin/binding"
+)
+
+func GetSupplier(c *gin.Context) {
+	req := &supplier.GetSupplierRequest{}
+	if err := c.ShouldBindBodyWith(&req, binding.JSON); err != nil {
+		service.Error(c, err)
+		return
+	}
+	res, err := service.SupplierProvider.GetSupplier(c, req)
+	if err != nil {
+		service.Error(c, err)
+		return
+	}
+
+	service.Success(c, res)
+	return
+}
+func CreateSupplier(c *gin.Context) {
+	req := &supplier.CreateSupplierRequest{}
+	if err := c.ShouldBindBodyWith(&req, binding.JSON); err != nil {
+		service.Error(c, err)
+		return
+	}
+	res, err := service.SupplierProvider.CreateSupplier(c, req)
+	if err != nil {
+		service.Error(c, err)
+		return
+	}
+	service.Success(c, res)
+	return
+}
+
+func UpdateSupplier(c *gin.Context) {
+	req := &supplier.UpdateSupplierRequest{}
+	if err := c.ShouldBindBodyWith(&req, binding.JSON); err != nil {
+		service.Error(c, err)
+		return
+	}
+	info, err := service.SupplierProvider.GetSupplier(c, &supplier.GetSupplierRequest{Id: req.Id})
+	if err != nil {
+		service.Error(c, err)
+		return
+	}
+	if info.Status == 3 {
+		service.Error(c, errors.New("审核中不可修改")) //todo 修改:审核中并且存在审核人 不可修改
+		return
+	}
+	if req.Status != 1 && req.Status != 2 {
+		service.Error(c, errors.New("审批状态错误")) //todo 只允许前端暂存或提交审核申请
+	}
+	res, err := service.SupplierProvider.UpdateSupplier(c, req)
+	if err != nil {
+		service.Error(c, err)
+		return
+	}
+	service.Success(c, res)
+	return
+}
+
+func GetSupplierList(c *gin.Context) {
+	req := &supplier.GetSupplierListRequest{}
+	if err := c.ShouldBindBodyWith(&req, binding.JSON); err != nil {
+		service.Error(c, err)
+		return
+	}
+	res, err := service.SupplierProvider.GetSupplierList(c, req)
+	if err != nil {
+		service.Error(c, err)
+		return
+	}
+	service.Success(c, res)
+	return
+}
+
+func CreateOrganizeDictionary(c *gin.Context) {
+	req := &supplier.CreateOrganizeDictionaryRequest{}
+	if err := c.ShouldBindBodyWith(&req, binding.JSON); err != nil {
+		service.Error(c, err)
+		return
+	}
+	res, err := service.SupplierProvider.CreateOrganizeDictionary(c, req)
+	if err != nil {
+		service.Error(c, err)
+		return
+	}
+	service.Success(c, res)
+	return
+}
+
+func GetOrganizeDictionaryList(c *gin.Context) {
+	req := &supplier.GetOrganizeDictionaryListRequest{}
+	if err := c.ShouldBindBodyWith(&req, binding.JSON); err != nil {
+		service.Error(c, err)
+		return
+	}
+	res, err := service.SupplierProvider.GetOrganizeDictionaryList(c, req)
+	if err != nil {
+		service.Error(c, err)
+		return
+	}
+	service.Success(c, res)
+	return
+}
+
+func GetCountryRegionList(c *gin.Context) {
+	req := &supplier.GetCountryRegionListRequest{}
+	if err := c.ShouldBindBodyWith(&req, binding.JSON); err != nil {
+		service.Error(c, err)
+		return
+	}
+	res, err := service.SupplierProvider.GetCountryRegionList(c, req)
+	if err != nil {
+		service.Error(c, err)
+		return
+	}
+	service.Success(c, res)
+	return
+}
+
+func CreateImportRecord(c *gin.Context) {
+	req := &supplier.CreateImportRecordRequest{}
+	if err := c.ShouldBindBodyWith(&req, binding.JSON); err != nil {
+		service.Error(c, err)
+		return
+	}
+	res, err := service.SupplierProvider.CreateImportRecord(c, req)
+	if err != nil {
+		service.Error(c, err)
+		return
+	}
+	service.Success(c, res)
+	return
+}
+
+func GetImportRecordInfo(c *gin.Context) {
+	req := &supplier.GetImportRecordRequest{}
+	if err := c.ShouldBindBodyWith(&req, binding.JSON); err != nil {
+		service.Error(c, err)
+		return
+	}
+	res, err := service.SupplierProvider.GetImportRecordInfo(c, req)
+	if err != nil {
+		service.Error(c, err)
+		return
+	}
+	service.Success(c, res)
+	return
+}