Browse Source

add connection log HourIndex

Robert 1 year ago
parent
commit
fc42b9a563
2 changed files with 17 additions and 4 deletions
  1. 16 3
      EVCB_OCPP.WSServer/Service/ConnectionLogdbService.cs
  2. 1 1
      version.txt

+ 16 - 3
EVCB_OCPP.WSServer/Service/ConnectionLogdbService.cs

@@ -222,6 +222,11 @@ public class ConnectionLogdbService : IConnectionLogdbService
         times.Add(watch.ElapsedMilliseconds);
         var tableName = GetTableName(workTime);
 
+        string withHourIndexCommand = $"""
+        INSERT INTO {tableName} (CreatedOn, ChargeBoxId, MessageType, Data, Msg, IsSent, EVSEEndPoint, Session, HourIndex)
+        VALUES (@CreatedOn, @ChargeBoxId, @MessageType, @Data, @Msg, @IsSent, @EVSEEndPoint, @Session, @HourIndex);
+        """;
+
         string command = $"""
         INSERT INTO {tableName} (CreatedOn, ChargeBoxId, MessageType, Data, Msg, IsSent, EVSEEndPoint, Session)
         VALUES (@CreatedOn, @ChargeBoxId, @MessageType, @Data, @Msg, @IsSent, @EVSEEndPoint, @Session);
@@ -238,10 +243,18 @@ public class ConnectionLogdbService : IConnectionLogdbService
             parameters.Add("IsSent", log.isSent, DbType.Boolean);
             parameters.Add("EVSEEndPoint", log.clientData.Endpoint == null ? "123" : log.clientData.Endpoint.ToString(), DbType.String, size: 25);
             parameters.Add("Session", log.clientData.SessionID == null ? "123" : log.clientData.SessionID, DbType.String, size: 36);
+            parameters.Add("HourIndex", workTime.Hour, DbType.Int32);
+
+            try
+            {
+                await sqlConnection.ExecuteAsync(withHourIndexCommand, parameters);
+            }
+            catch
+            {
+                logger.LogInformation("Connection Log insert with HourIndex failed, insert without HourIndex");
+                await sqlConnection.ExecuteAsync(command, parameters);
+            }
 
-            await sqlConnection.ExecuteAsync(command, parameters
-                //, trans
-                );
             bundleHandlerData.AddCompletedData(log);
         }
 

+ 1 - 1
version.txt

@@ -1 +1 @@
-Docker_v1.1.12
+Docker_v1.1.13