Jelajahi Sumber

Add CarNum info while reporting stop stransaction info

Robert 1 tahun lalu
induk
melakukan
808811c8de

+ 1 - 0
EVCB_OCPP.TaskScheduler/App.config

@@ -12,6 +12,7 @@
   <connectionStrings>
     <add name="OnlineLogDBContext" connectionString="Server=tcp:zerova-evbackend.database.windows.net,1433;initial catalog=StandardOCPP_OnlineRecord;;persist security info=True;user id=ev_user;password=Thw2DEa2hZPdg;MultipleActiveResultSets=True;App=EntityFramework" providerName="System.Data.SqlClient" />
     <add name="MainDBContext" connectionString="Server=tcp:zerova-evbackend.database.windows.net,1433;initial catalog=StandardOCPP_Main;;persist security info=True;user id=ev_user;password=Thw2DEa2hZPdg;MultipleActiveResultSets=True;App=EntityFramework" providerName="System.Data.SqlClient" />
+    <add name="WebDBContext" connectionString="data source=172.1.2.187;initial catalog=StandardOCPP_Web;;persist security info=True;user id=sa;password=Ph0930118811;MultipleActiveResultSets=True;App=EntityFramework; Max Pool Size=500" providerName="System.Data.SqlClient" />
   </connectionStrings>
   
   <runtime>  

+ 1 - 1
EVCB_OCPP.TaskScheduler/Properties/AssemblyInfo.cs

@@ -34,4 +34,4 @@ using System.Runtime.InteropServices;
 // [assembly: AssemblyVersion("0.1.0.0")]
 [assembly: AssemblyVersion("0.1.0.0")]
 [assembly: AssemblyFileVersion("0.1.0.0")]
-[assembly: AssemblyInformationalVersion("7b5c47a")]
+[assembly: AssemblyInformationalVersion("befd1a7")]

+ 20 - 3
EVCB_OCPP.TaskScheduler/Services/CommonCustomerService.cs

@@ -1,7 +1,10 @@
-using EVCB_OCPP.TaskScheduler.Models;
+using Dapper;
+using EVCB_OCPP.TaskScheduler.Models;
 using Newtonsoft.Json;
 using System;
 using System.Collections.Generic;
+using System.Configuration;
+using System.Data.SqlClient;
 using System.Diagnostics;
 using System.Linq;
 using System.Text;
@@ -24,6 +27,8 @@ namespace EVCB_OCPP.TaskScheduler.Services
         private OuterHttpClient httpClient = new OuterHttpClient();
         private int ChargeRecordCallCounter = 0;
 
+        private string _WebConnectionString = ConfigurationManager.ConnectionStrings["WebDBContext"].ToString();
+
         public CommonCustomerService() { }
 
         public CommonCustomerService(Guid customerId)
@@ -234,6 +239,7 @@ namespace EVCB_OCPP.TaskScheduler.Services
                             }
                             else
                             {
+                                string CarNum = await GetCustomerFromIdTag(r.StartIdTag);
                                 var request = new
                                 {
                                     ChargeBoxId = r.ChargeBoxId,
@@ -248,8 +254,8 @@ namespace EVCB_OCPP.TaskScheduler.Services
                                     ReservationId=r.ReservationId,
                                     Receipt = r.Receipt,
                                     TotalCost = r.Cost,
-                                    Fee = r.Fee
-
+                                    Fee = r.Fee,
+                                    CarNum = CarNum
                                 };
 
 
@@ -429,5 +435,16 @@ namespace EVCB_OCPP.TaskScheduler.Services
 
 
         }
+        private async Task<string> GetCustomerFromIdTag(string startIdTag)
+        {
+            string toReturn;
+            string sqlstatement = "SELECT [CarNum] FROM VehicleCustomer where IdTag = '" + startIdTag + "'";
+            using (var dbConn = new SqlConnection(_WebConnectionString))
+            {
+                dbConn.Open();
+                toReturn = await dbConn.ExecuteScalarAsync<string>(sqlstatement);
+            }
+            return toReturn;
+        }
     }
 }