Solar/Swarm
2
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

🐛 Trying to fix afdian webhook

Browse Source
This commit is contained in:
LittleSheep 2025-06-23 01:58:12 +08:00
parent feb612afcd
commit a97bf15362
1 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
DysonNetwork.Sphere/Wallet/PaymentHandlers/AfdianPaymentHandler.cs
View File

@ -203,8 +203,13 @@ public class AfdianPaymentHandler(
/// <param name="request">The HTTP request containing webhook data</param> /// <param name="request">The HTTP request containing webhook data</param>
/// <param name="processOrderAction">An action to process the received order</param> /// <param name="processOrderAction">An action to process the received order</param>
/// <returns>A WebhookResponse object to be returned to Afdian</returns> /// <returns>A WebhookResponse object to be returned to Afdian</returns>
public async Task<WebhookResponse> HandleWebhook(HttpRequest request, Func<WebhookOrderData, Task>? processOrderAction) public async Task<WebhookResponse> HandleWebhook(
HttpRequest request,
Func<WebhookOrderData, Task>? processOrderAction
)
{ {
_logger.LogInformation("Received webhook request from afdian...");
try try
{ {
// Read the request body // Read the request body
@ -235,7 +240,7 @@ public class AfdianPaymentHandler(
if (webhook.Data.Type != "order") if (webhook.Data.Type != "order")
{ {
_logger.LogWarning($"Unsupported webhook type: {webhook.Data.Type}"); _logger.LogWarning($"Unsupported webhook type: {webhook.Data.Type}");
return new WebhookResponse { ErrorCode = 200, ErrorMessage = "Unsupported type, but acknowledged" }; return WebhookResponse.Success;
} }
// Process the order // Process the order
@ -246,7 +251,8 @@ public class AfdianPaymentHandler(
if (processOrderAction != null) if (processOrderAction != null)
await processOrderAction(webhook.Data); await processOrderAction(webhook.Data);
else else
_logger.LogInformation($"Order received but no processing action provided: {webhook.Data.Order.TradeNumber}"); _logger.LogInformation(
$"Order received but no processing action provided: {webhook.Data.Order.TradeNumber}");
} }
catch (Exception ex) catch (Exception ex)
{ {
@ -256,12 +262,12 @@ public class AfdianPaymentHandler(
} }
// Return success response to Afdian // Return success response to Afdian
return new WebhookResponse { ErrorCode = 200, ErrorMessage = "" }; return WebhookResponse.Success;
} }
catch (Exception ex) catch (Exception ex)
{ {
_logger.LogError(ex, "Error handling webhook"); _logger.LogError(ex, "Error handling webhook");
return new WebhookResponse { ErrorCode = 500, ErrorMessage = "Internal server error" }; return WebhookResponse.Success;
} }
} }
@ -401,6 +407,12 @@ public class WebhookResponse
[JsonProperty("ec")] public int ErrorCode { get; set; } = 200; [JsonProperty("ec")] public int ErrorCode { get; set; } = 200;
[JsonProperty("em")] public string ErrorMessage { get; set; } = ""; [JsonProperty("em")] public string ErrorMessage { get; set; } = "";
public static WebhookResponse Success => new()
{
ErrorCode = 200,
ErrorMessage = string.Empty
};
} }
/// <summary> /// <summary>