Local message retry optimization

[zhenlei520]

Local messages need to increase the last execution time to avoid repeated execution of messages

public async Task<IEnumerable<IntegrationEventLog>> RetrieveEventLogsFailedToPublishAsync(int retryBatchSize = 200, int maxRetryTimes = 10)
{
    var result = await _eventLogContext.EventLogs
        .Where(e => (e.State == IntegrationEventStates.PublishedFailed || e.State == IntegrationEventStates.InProgress) &&
            e.TimesSent <= maxRetryTimes)
        .OrderBy(o => o.CreationTime)
        .Take(retryBatchSize)
        .ToListAsync();

    if (result.Any())
    {
        _eventTypes ??= _serviceProvider.GetRequiredService<IIntegrationEventBus>().GetAllEventTypes()
            .Where(type => typeof(IIntegrationEvent).IsAssignableFrom(type));

        return result.OrderBy(o => o.CreationTime)
            .Select(e => e.DeserializeJsonContent(_eventTypes.First(t => t.Name == e.EventTypeShortName)));
    }

    return result;
}