fix: 创建返回antomid

api/payment/payment.proto

@@ -14,12 +14,14 @@ service PaymentCent{
   rpc CreateRefund(CreateRefundRequest) returns (CreateRefundResponse); // 发起退款，暂定公共
 
   rpc StripeGermanyWebhook(GetCheckoutWebhookRequest) returns(GetCheckoutWebhookResponse){};// stripe支付回调, 德国账号
+  rpc StripeJapanWebhook(GetCheckoutWebhookRequest) returns(GetCheckoutWebhookResponse){};// stripe支付回调, 日本账号
 
   rpc AliCommonWebhook(NotifyPayRequest) returns (NotifyPayResponse){}; // 支付宝支付回调，通用
 
   rpc WechatFengLianWebhook(NotifyPayRequest) returns (NotifyPayResponse){}; // 微信支付回调，丰链
   rpc AntomWebhook(AntomNotifyPayRequest) returns (AntomNotifyPayResponse){}; // Antom支付回调
   rpc QueryAntomPayByCheckoutSessionId(AntomPayQueryRequest) returns (AntomPayQueryResponse){}; // 根据checkoutSessionIds查询支付情况
+  rpc ExpireStripePayByCheckoutSessionId(ExpireRequest) returns (CommonResponse){}; // 根据checkoutSessionId
 
 
 
@@ -127,6 +129,7 @@ message CreatePayResponse {
   string partnerId = 11 [json_name = "partnerId"];
 
   string checkoutSessionId = 12 [json_name = "checkoutSessionId"];
+  string antomId = 13 [json_name = "antomId"];
 }
 
 message CreateRefundRequest {
@@ -633,6 +636,7 @@ message WechatPayOkRequest {
 message CommonResponse {
   bool Success = 1 [json_name = "success"];
   uint32 ID = 2 ;
+  string Message = 3 ;
 }
 
 message PayQueryRequest {
@@ -711,6 +715,7 @@ message OrderDetail {
   string  productName = 19;
   string  productImg = 20;
   string  productDescription = 21;
+  string antomId = 22;
 }
 
 message BusinessInfo {
@@ -741,3 +746,8 @@ message ChannelIncome {
   int64 totalRefundAmount = 6; // 总退款费
   int64 netIncome = 7; // 净收入
 }
+
+message ExpireRequest {
+  string checkoutSessionId = 1;
+  string payee = 2; //
+}

api/payment/payment.validator.pb.go

@@ -299,3 +299,6 @@ func (this *Overview) Validate() error {
 func (this *ChannelIncome) Validate() error {
 	return nil
 }
+func (this *ExpireRequest) Validate() error {
+	return nil
+}

api/payment/payment_triple.pb.go

@@ -35,10 +35,12 @@ type PaymentCentClient interface {
 	QueryExportPay(ctx context.Context, in *ExportPayRequest, opts ...grpc_go.CallOption) (*ExportPayResponse, common.ErrorWithAttachment)
 	CreateRefund(ctx context.Context, in *CreateRefundRequest, opts ...grpc_go.CallOption) (*CreateRefundResponse, common.ErrorWithAttachment)
 	StripeGermanyWebhook(ctx context.Context, in *GetCheckoutWebhookRequest, opts ...grpc_go.CallOption) (*GetCheckoutWebhookResponse, common.ErrorWithAttachment)
+	StripeJapanWebhook(ctx context.Context, in *GetCheckoutWebhookRequest, opts ...grpc_go.CallOption) (*GetCheckoutWebhookResponse, common.ErrorWithAttachment)
 	AliCommonWebhook(ctx context.Context, in *NotifyPayRequest, opts ...grpc_go.CallOption) (*NotifyPayResponse, common.ErrorWithAttachment)
 	WechatFengLianWebhook(ctx context.Context, in *NotifyPayRequest, opts ...grpc_go.CallOption) (*NotifyPayResponse, common.ErrorWithAttachment)
 	AntomWebhook(ctx context.Context, in *AntomNotifyPayRequest, opts ...grpc_go.CallOption) (*AntomNotifyPayResponse, common.ErrorWithAttachment)
 	QueryAntomPayByCheckoutSessionId(ctx context.Context, in *AntomPayQueryRequest, opts ...grpc_go.CallOption) (*AntomPayQueryResponse, common.ErrorWithAttachment)
+	ExpireStripePayByCheckoutSessionId(ctx context.Context, in *ExpireRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment)
 	// stripe支付
 	CreateStripeCheckoutSession(ctx context.Context, in *CreateStripeCheckoutSessionRequest, opts ...grpc_go.CallOption) (*CreateStripeCheckoutSessionResponse, common.ErrorWithAttachment)
 	// 支付宝支付
@@ -70,37 +72,39 @@ type paymentCentClient struct {
 }
 
 type PaymentCentClientImpl struct {
-	CreatePay                        func(ctx context.Context, in *CreatePayRequest) (*CreatePayResponse, error)
+	CreatePay                          func(ctx context.Context, in *CreatePayRequest) (*CreatePayResponse, error)
-	NotifyPay                        func(ctx context.Context, in *NotifyPayRequest) (*NotifyPayResponse, error)
+	NotifyPay                          func(ctx context.Context, in *NotifyPayRequest) (*NotifyPayResponse, error)
-	QueryPayByOutTradeNo             func(ctx context.Context, in *PayQueryRequest) (*PayQueryResponse, error)
+	QueryPayByOutTradeNo               func(ctx context.Context, in *PayQueryRequest) (*PayQueryResponse, error)
-	QueryExportPay                   func(ctx context.Context, in *ExportPayRequest) (*ExportPayResponse, error)
+	QueryExportPay                     func(ctx context.Context, in *ExportPayRequest) (*ExportPayResponse, error)
-	CreateRefund                     func(ctx context.Context, in *CreateRefundRequest) (*CreateRefundResponse, error)
+	CreateRefund                       func(ctx context.Context, in *CreateRefundRequest) (*CreateRefundResponse, error)
-	StripeGermanyWebhook             func(ctx context.Context, in *GetCheckoutWebhookRequest) (*GetCheckoutWebhookResponse, error)
+	StripeGermanyWebhook               func(ctx context.Context, in *GetCheckoutWebhookRequest) (*GetCheckoutWebhookResponse, error)
-	AliCommonWebhook                 func(ctx context.Context, in *NotifyPayRequest) (*NotifyPayResponse, error)
+	StripeJapanWebhook                 func(ctx context.Context, in *GetCheckoutWebhookRequest) (*GetCheckoutWebhookResponse, error)
-	WechatFengLianWebhook            func(ctx context.Context, in *NotifyPayRequest) (*NotifyPayResponse, error)
+	AliCommonWebhook                   func(ctx context.Context, in *NotifyPayRequest) (*NotifyPayResponse, error)
-	AntomWebhook                     func(ctx context.Context, in *AntomNotifyPayRequest) (*AntomNotifyPayResponse, error)
+	WechatFengLianWebhook              func(ctx context.Context, in *NotifyPayRequest) (*NotifyPayResponse, error)
-	QueryAntomPayByCheckoutSessionId func(ctx context.Context, in *AntomPayQueryRequest) (*AntomPayQueryResponse, error)
+	AntomWebhook                       func(ctx context.Context, in *AntomNotifyPayRequest) (*AntomNotifyPayResponse, error)
-	CreateStripeCheckoutSession      func(ctx context.Context, in *CreateStripeCheckoutSessionRequest) (*CreateStripeCheckoutSessionResponse, error)
+	QueryAntomPayByCheckoutSessionId   func(ctx context.Context, in *AntomPayQueryRequest) (*AntomPayQueryResponse, error)
-	AliWapPay                        func(ctx context.Context, in *AliWapPayRequest) (*AliWapPayResponse, error)
+	ExpireStripePayByCheckoutSessionId func(ctx context.Context, in *ExpireRequest) (*CommonResponse, error)
-	AliAppPay                        func(ctx context.Context, in *AliAppPayRequest) (*AliAppPayResponse, error)
+	CreateStripeCheckoutSession        func(ctx context.Context, in *CreateStripeCheckoutSessionRequest) (*CreateStripeCheckoutSessionResponse, error)
-	AliNativePay                     func(ctx context.Context, in *AliNativePayRequest) (*AliNativePayResponse, error)
+	AliWapPay                          func(ctx context.Context, in *AliWapPayRequest) (*AliWapPayResponse, error)
-	AliPcWabPay                      func(ctx context.Context, in *AliPcWabPayRequest) (*AliPcWabPayResponse, error)
+	AliAppPay                          func(ctx context.Context, in *AliAppPayRequest) (*AliAppPayResponse, error)
-	AliReFund                        func(ctx context.Context, in *AliReFundRequest) (*AliReFundResponse, error)
+	AliNativePay                       func(ctx context.Context, in *AliNativePayRequest) (*AliNativePayResponse, error)
-	AliNotify                        func(ctx context.Context, in *AliNotifyRequest) (*AliNotifyResponse, error)
+	AliPcWabPay                        func(ctx context.Context, in *AliPcWabPayRequest) (*AliPcWabPayResponse, error)
-	AliQueryByOutTradeNo             func(ctx context.Context, in *AliQueryByOutTradeNoRequest) (*AliQueryByOutTradeNoResponse, error)
+	AliReFund                          func(ctx context.Context, in *AliReFundRequest) (*AliReFundResponse, error)
-	AliRefundQueryByOutTradeNo       func(ctx context.Context, in *AliRefundQueryByOutTradeNoRequest) (*AliRefundQueryByOutTradeNoResponse, error)
+	AliNotify                          func(ctx context.Context, in *AliNotifyRequest) (*AliNotifyResponse, error)
-	WechatJsApiPay                   func(ctx context.Context, in *WechatJsApiPayRequest) (*WechatJsApiPayResponse, error)
+	AliQueryByOutTradeNo               func(ctx context.Context, in *AliQueryByOutTradeNoRequest) (*AliQueryByOutTradeNoResponse, error)
-	WechatJsApiQueryByOutTradeNo     func(ctx context.Context, in *WechatJsApiQueryByOutTradeNoRequest) (*WechatJsApiQueryByOutTradeNoResponse, error)
+	AliRefundQueryByOutTradeNo         func(ctx context.Context, in *AliRefundQueryByOutTradeNoRequest) (*AliRefundQueryByOutTradeNoResponse, error)
-	GetPayByOutTradeNo               func(ctx context.Context, in *GetPayByOutTradeNoRequest) (*GetPayByOutTradeNoResponse, error)
+	WechatJsApiPay                     func(ctx context.Context, in *WechatJsApiPayRequest) (*WechatJsApiPayResponse, error)
-	WechatJsApiRefunds               func(ctx context.Context, in *WechatJsApiRefundsRequest) (*WechatJsApiRefundsResponse, error)
+	WechatJsApiQueryByOutTradeNo       func(ctx context.Context, in *WechatJsApiQueryByOutTradeNoRequest) (*WechatJsApiQueryByOutTradeNoResponse, error)
-	SetPayOk                         func(ctx context.Context, in *WechatPayOkRequest) (*CommonResponse, error)
+	GetPayByOutTradeNo                 func(ctx context.Context, in *GetPayByOutTradeNoRequest) (*GetPayByOutTradeNoResponse, error)
-	WechatAppPay                     func(ctx context.Context, in *WechatAppPayRequest) (*WechatAppPayResponse, error)
+	WechatJsApiRefunds                 func(ctx context.Context, in *WechatJsApiRefundsRequest) (*WechatJsApiRefundsResponse, error)
-	WechatAppQueryByOutTradeNo       func(ctx context.Context, in *WechatAppQueryByOutTradeNoRequest) (*WechatAppQueryByOutTradeNoResponse, error)
+	SetPayOk                           func(ctx context.Context, in *WechatPayOkRequest) (*CommonResponse, error)
-	WechatNativePay                  func(ctx context.Context, in *WechatNativePayRequest) (*WechatNativePayResponse, error)
+	WechatAppPay                       func(ctx context.Context, in *WechatAppPayRequest) (*WechatAppPayResponse, error)
-	WechatNativeQueryByOutTradeNo    func(ctx context.Context, in *WechatNativeQueryByOutTradeNoRequest) (*WechatNativeQueryByOutTradeNoResponse, error)
+	WechatAppQueryByOutTradeNo         func(ctx context.Context, in *WechatAppQueryByOutTradeNoRequest) (*WechatAppQueryByOutTradeNoResponse, error)
-	WechatRefundQueryByOutRefundNo   func(ctx context.Context, in *WechatRefundQueryByOutRefundNoRequest) (*WechatRefundQueryByOutRefundNoResponse, error)
+	WechatNativePay                    func(ctx context.Context, in *WechatNativePayRequest) (*WechatNativePayResponse, error)
-	WechatH5Pay                      func(ctx context.Context, in *WechatH5PayRequest) (*WechatH5PayResponse, error)
+	WechatNativeQueryByOutTradeNo      func(ctx context.Context, in *WechatNativeQueryByOutTradeNoRequest) (*WechatNativeQueryByOutTradeNoResponse, error)
-	WechatH5QueryByOutTradeNo        func(ctx context.Context, in *WechatH5QueryByOutTradeNoRequest) (*WechatH5QueryByOutTradeNoResponse, error)
+	WechatRefundQueryByOutRefundNo     func(ctx context.Context, in *WechatRefundQueryByOutRefundNoRequest) (*WechatRefundQueryByOutRefundNoResponse, error)
+	WechatH5Pay                        func(ctx context.Context, in *WechatH5PayRequest) (*WechatH5PayResponse, error)
+	WechatH5QueryByOutTradeNo          func(ctx context.Context, in *WechatH5QueryByOutTradeNoRequest) (*WechatH5QueryByOutTradeNoResponse, error)
 }
 
 func (c *PaymentCentClientImpl) GetDubboStub(cc *triple.TripleConn) PaymentCentClient {
@@ -151,6 +155,12 @@ func (c *paymentCentClient) StripeGermanyWebhook(ctx context.Context, in *GetChe
 	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/StripeGermanyWebhook", in, out)
 }
 
+func (c *paymentCentClient) StripeJapanWebhook(ctx context.Context, in *GetCheckoutWebhookRequest, opts ...grpc_go.CallOption) (*GetCheckoutWebhookResponse, common.ErrorWithAttachment) {
+	out := new(GetCheckoutWebhookResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/StripeJapanWebhook", in, out)
+}
+
 func (c *paymentCentClient) AliCommonWebhook(ctx context.Context, in *NotifyPayRequest, opts ...grpc_go.CallOption) (*NotifyPayResponse, common.ErrorWithAttachment) {
 	out := new(NotifyPayResponse)
 	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
@@ -175,6 +185,12 @@ func (c *paymentCentClient) QueryAntomPayByCheckoutSessionId(ctx context.Context
 	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/QueryAntomPayByCheckoutSessionId", in, out)
 }
 
+func (c *paymentCentClient) ExpireStripePayByCheckoutSessionId(ctx context.Context, in *ExpireRequest, opts ...grpc_go.CallOption) (*CommonResponse, common.ErrorWithAttachment) {
+	out := new(CommonResponse)
+	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
+	return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/ExpireStripePayByCheckoutSessionId", in, out)
+}
+
 func (c *paymentCentClient) CreateStripeCheckoutSession(ctx context.Context, in *CreateStripeCheckoutSessionRequest, opts ...grpc_go.CallOption) (*CreateStripeCheckoutSessionResponse, common.ErrorWithAttachment) {
 	out := new(CreateStripeCheckoutSessionResponse)
 	interfaceKey := ctx.Value(constant.InterfaceKey).(string)
@@ -312,10 +328,12 @@ type PaymentCentServer interface {
 	QueryExportPay(context.Context, *ExportPayRequest) (*ExportPayResponse, error)
 	CreateRefund(context.Context, *CreateRefundRequest) (*CreateRefundResponse, error)
 	StripeGermanyWebhook(context.Context, *GetCheckoutWebhookRequest) (*GetCheckoutWebhookResponse, error)
+	StripeJapanWebhook(context.Context, *GetCheckoutWebhookRequest) (*GetCheckoutWebhookResponse, error)
 	AliCommonWebhook(context.Context, *NotifyPayRequest) (*NotifyPayResponse, error)
 	WechatFengLianWebhook(context.Context, *NotifyPayRequest) (*NotifyPayResponse, error)
 	AntomWebhook(context.Context, *AntomNotifyPayRequest) (*AntomNotifyPayResponse, error)
 	QueryAntomPayByCheckoutSessionId(context.Context, *AntomPayQueryRequest) (*AntomPayQueryResponse, error)
+	ExpireStripePayByCheckoutSessionId(context.Context, *ExpireRequest) (*CommonResponse, error)
 	// stripe支付
 	CreateStripeCheckoutSession(context.Context, *CreateStripeCheckoutSessionRequest) (*CreateStripeCheckoutSessionResponse, error)
 	// 支付宝支付
@@ -366,6 +384,9 @@ func (UnimplementedPaymentCentServer) CreateRefund(context.Context, *CreateRefun
 func (UnimplementedPaymentCentServer) StripeGermanyWebhook(context.Context, *GetCheckoutWebhookRequest) (*GetCheckoutWebhookResponse, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method StripeGermanyWebhook not implemented")
 }
+func (UnimplementedPaymentCentServer) StripeJapanWebhook(context.Context, *GetCheckoutWebhookRequest) (*GetCheckoutWebhookResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method StripeJapanWebhook not implemented")
+}
 func (UnimplementedPaymentCentServer) AliCommonWebhook(context.Context, *NotifyPayRequest) (*NotifyPayResponse, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method AliCommonWebhook not implemented")
 }
@@ -378,6 +399,9 @@ func (UnimplementedPaymentCentServer) AntomWebhook(context.Context, *AntomNotify
 func (UnimplementedPaymentCentServer) QueryAntomPayByCheckoutSessionId(context.Context, *AntomPayQueryRequest) (*AntomPayQueryResponse, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method QueryAntomPayByCheckoutSessionId not implemented")
 }
+func (UnimplementedPaymentCentServer) ExpireStripePayByCheckoutSessionId(context.Context, *ExpireRequest) (*CommonResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method ExpireStripePayByCheckoutSessionId not implemented")
+}
 func (UnimplementedPaymentCentServer) CreateStripeCheckoutSession(context.Context, *CreateStripeCheckoutSessionRequest) (*CreateStripeCheckoutSessionResponse, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method CreateStripeCheckoutSession not implemented")
 }
@@ -643,6 +667,35 @@ func _PaymentCent_StripeGermanyWebhook_Handler(srv interface{}, ctx context.Cont
 	return interceptor(ctx, in, info, handler)
 }
 
+func _PaymentCent_StripeJapanWebhook_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(GetCheckoutWebhookRequest)
+	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("StripeJapanWebhook", 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 _PaymentCent_AliCommonWebhook_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
 	in := new(NotifyPayRequest)
 	if err := dec(in); err != nil {
@@ -759,6 +812,35 @@ func _PaymentCent_QueryAntomPayByCheckoutSessionId_Handler(srv interface{}, ctx
 	return interceptor(ctx, in, info, handler)
 }
 
+func _PaymentCent_ExpireStripePayByCheckoutSessionId_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
+	in := new(ExpireRequest)
+	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("ExpireStripePayByCheckoutSessionId", 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 _PaymentCent_CreateStripeCheckoutSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
 	in := new(CreateStripeCheckoutSessionRequest)
 	if err := dec(in); err != nil {
@@ -1399,6 +1481,10 @@ var PaymentCent_ServiceDesc = grpc_go.ServiceDesc{
 			MethodName: "StripeGermanyWebhook",
 			Handler:    _PaymentCent_StripeGermanyWebhook_Handler,
 		},
+		{
+			MethodName: "StripeJapanWebhook",
+			Handler:    _PaymentCent_StripeJapanWebhook_Handler,
+		},
 		{
 			MethodName: "AliCommonWebhook",
 			Handler:    _PaymentCent_AliCommonWebhook_Handler,
@@ -1415,6 +1501,10 @@ var PaymentCent_ServiceDesc = grpc_go.ServiceDesc{
 			MethodName: "QueryAntomPayByCheckoutSessionId",
 			Handler:    _PaymentCent_QueryAntomPayByCheckoutSessionId_Handler,
 		},
+		{
+			MethodName: "ExpireStripePayByCheckoutSessionId",
+			Handler:    _PaymentCent_ExpireStripePayByCheckoutSessionId_Handler,
+		},
 		{
 			MethodName: "CreateStripeCheckoutSession",
 			Handler:    _PaymentCent_CreateStripeCheckoutSession_Handler,