From 08e0444055c21e753ca71f150bab142d19dfbb15 Mon Sep 17 00:00:00 2001
From: lindj <67092759@qq.com>
Date: Wed, 17 Jan 2024 13:37:49 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8Doutput=E8=AE=A1=E6=95=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 ConsoleApp2/HostedServices/OutputService.cs | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/ConsoleApp2/HostedServices/OutputService.cs b/ConsoleApp2/HostedServices/OutputService.cs
index b4598e3..a6f2ccd 100644
--- a/ConsoleApp2/HostedServices/OutputService.cs
+++ b/ConsoleApp2/HostedServices/OutputService.cs
@@ -40,7 +40,6 @@ public class OutputService : IOutputService
     public async Task ExecuteAsync(CancellationToken cancellationToken)
     {
         _logger.LogInformation("***** Mysql output service started *****");
-        var count = 0;
         _taskManager.CreateTasks(async () =>
         {
             var records = new List<DataRecord>();
@@ -48,12 +47,10 @@ public class OutputService : IOutputService
             {
                 if (!_consumerQueue.TryDequeue(out var record)) continue;
                 records.Add(record);
-                count++;
                 //_logger.LogInformation(@"*****OutputCount: {count} *****",count);
                 if (records.Count >= _outputOptions.Value.FlushCount)
                 {
                     await FlushAsync(records);
-                    _context.AddOutput(count);
                     records.Clear();
                 }
                 if (_context.GetExceptions().Count>0)