1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558 |
- using Dapper;
- using EVCB_OCPP.Domain;
- using EVCB_OCPP.Packet.Features;
- using EVCB_OCPP.Packet.Messages;
- using EVCB_OCPP.Packet.Messages.Basic;
- using EVCB_OCPP.Packet.Messages.Core;
- using EVCB_OCPP.WSServer.Dto;
- using EVCB_OCPP.WSServer.Helper;
- using EVCB_OCPP.WSServer.Message;
- using EVCB_OCPP.WSServer.Service;
- using Microsoft.Extensions.Hosting;
- using Newtonsoft.Json;
- using OCPPServer.Protocol;
- using OCPPServer.SubProtocol;
- using SuperSocket.SocketBase;
- using SuperSocket.SocketBase.Config;
- using System.Data;
- using System.Diagnostics;
- using System.Security.Authentication;
- using System.Xml.Linq;
- using NLog;
- using Microsoft.Extensions.Configuration;
- using Microsoft.EntityFrameworkCore;
- using Microsoft.Extensions.DependencyInjection;
- using Microsoft.AspNetCore.Builder;
- using NLog.Extensions.Logging;
- using Microsoft.Data.SqlClient;
- using System.Collections.Concurrent;
- using EVCB_OCPP.WSServer.SuperSocket;
- using Microsoft.Extensions.Logging;
- using EVCB_OCPP.WSServer.Service.WsService;
- using System.Net.WebSockets;
- using EVCB_OCPP.Packet.Messages.Security;
- using Microsoft.AspNetCore.Http.HttpResults;
- using System;
- namespace EVCB_OCPP.WSServer
- {
- public class DestroyRequest : IRequest
- {
- public string Action { get; set; }
- public bool TransactionRelated()
- {
- return false;
- }
- public bool Validate()
- {
- return true;
- }
- }
- public class ProtalServer : IHostedService
- {
- //static private ILogger logger = NLog.LogManager.GetCurrentClassLogger();
- public ProtalServer(
- ILogger<ProtalServer> logger
- , IConfiguration configuration
- , IDbContextFactory<MainDBContext> maindbContextFactory
- , IMainDbService mainDbService
- , IDbContextFactory<ConnectionLogDBContext> connectionLogdbContextFactory
- , SqlConnectionFactory<WebDBConetext> webDbConnectionFactory
- , SqlConnectionFactory<MainDBContext> mainDbConnectionFactory
- , IHostEnvironment environment
- //, IOCPPWSServerFactory ocppWSServerFactory
- , IConnectionLogdbService connectionLogdbService
- , WebDbService webDbService
- , ServerMessageService serverMessageService
- , IServiceProvider serviceProvider
- , OcppWebsocketService websocketService
- , OuterHttpClient httpClient)
- {
- _ct = _cts.Token;
- this.logger = logger;
- this.configuration = configuration;
- this.maindbContextFactory = maindbContextFactory;
- this.mainDbService = mainDbService;
- this.webDbConnectionFactory = webDbConnectionFactory;
- //this.connectionLogdbContextFactory = connectionLogdbContextFactory;
- //this.ocppWSServerFactory = ocppWSServerFactory;
- this.connectionLogdbService = connectionLogdbService;
- this.webDbService = webDbService;
- this.messageService = serverMessageService;
- this.websocketService = websocketService;
- this.httpClient = httpClient;
- isInDocker = !string.IsNullOrEmpty(configuration["DOTNET_RUNNING_IN_CONTAINER"]);
- // = configuration.GetConnectionString("WebDBContext");
- this.profileHandler = serviceProvider.GetService<ProfileHandler>();// new ProfileHandler(configuration, serviceProvider);
- _loadingBalanceService = new LoadingBalanceService(mainDbConnectionFactory, webDbConnectionFactory);
- WarmUpLog();
- }
- #region private fields
- private OuterHttpClient httpClient;
- private DateTime lastcheckdt = DateTime.UtcNow.AddSeconds(-20);
- private ConcurrentDictionary<string, WsClientData> clientDic = new ConcurrentDictionary<string, WsClientData>();
- //private readonly Object _lockClientDic = new object();
- private readonly Object _lockConfirmPacketList = new object();
- private readonly ILogger<ProtalServer> logger;
- private readonly IConfiguration configuration;
- //private readonly IServiceProvider serviceProvider;
- private readonly IDbContextFactory<MainDBContext> maindbContextFactory;
- private readonly IMainDbService mainDbService;
- private readonly SqlConnectionFactory<WebDBConetext> webDbConnectionFactory;
- //private readonly IDbContextFactory<ConnectionLogDBContext> connectionLogdbContextFactory;
- //private readonly IOCPPWSServerFactory ocppWSServerFactory;
- private readonly IConnectionLogdbService connectionLogdbService;
- private readonly WebDbService webDbService;
- private readonly ServerMessageService messageService;
- private readonly OcppWebsocketService websocketService;
- private readonly ProfileHandler profileHandler;//= new ProfileHandler();
- //private readonly string webConnectionString;// = ConfigurationManager.ConnectionStrings["WebDBContext"].ConnectionString;
- private readonly bool isInDocker;
- private List<NeedConfirmMessage> needConfirmPacketList = new List<NeedConfirmMessage>();
- private DateTime checkUpdateDt = DateTime.UtcNow;
- private DateTime _CheckFeeDt = DateTime.UtcNow;
- private DateTime _CheckLBDt = DateTime.UtcNow;
- private DateTime _CheckDenyListDt = DateTime.UtcNow.AddDays(-1);
- private readonly LoadingBalanceService _loadingBalanceService;// = new LoadingBalanceService();
- private List<StationInfoDto> _StationInfo = new List<StationInfoDto>();
- private readonly List<string> needConfirmActions = new List<string>()
- {
- "GetConfiguration",
- "ChangeConfiguration",
- "RemoteStartTransaction",
- "RemoteStopTransaction",
- "ChangeAvailability",
- "ClearCache",
- "DataTransfer",
- "Reset",
- "UnlockConnector",
- "TriggerMessage",
- "GetDiagnostics",
- "UpdateFirmware",
- "GetLocalListVersion",
- "SendLocalList",
- "SetChargingProfile",
- "ClearChargingProfile",
- "GetCompositeSchedule",
- "ReserveNow",
- "CancelReservation",
- "ExtendedTriggerMessage"
- };
- private readonly List<Profile> profiles = new List<Profile>()
- {
- new CoreProfile(),
- new FirmwareManagementProfile(),
- new ReservationProfile(),
- new RemoteTriggerProfile(),
- new SmartChargingProfile(),
- new LocalAuthListManagementProfile(),
- new SecurityProfile(),
- };
- private CancellationTokenSource _cts = new CancellationTokenSource();
- private CancellationToken _ct;
- #endregion
- internal Dictionary<string, WsClientData> GetClientDic()
- {
- Dictionary<string, WsClientData> toReturn = null;
- toReturn = new Dictionary<string, WsClientData>(clientDic);
- return toReturn;
- }
- internal List<NeedConfirmMessage> GetResendMessage()
- {
- List<NeedConfirmMessage> sendMessages = new List<NeedConfirmMessage>();
- lock (_lockConfirmPacketList)
- {
- sendMessages = needConfirmPacketList.Where(x => x.SentTimes > 1 && x.CreatedBy == "Server").ToList();
- }
- return sendMessages;
- }
- internal IReadOnlyList<Profile> Profiles => profiles.AsReadOnly();
- internal LoadingBalanceService LoadingBalanceService => _loadingBalanceService;
- internal ProfileHandler ProfileHandler => profileHandler;
- public async Task StartAsync(CancellationToken cancellationToken)
- {
- GlobalConfig.DenyModelNames = await webDbService.GetDenyModelNames();
- Start();
- return;
- }
- public Task StopAsync(CancellationToken cancellationToken)
- {
- return Task.CompletedTask;
- }
- internal void UpdateClientDisplayPrice(string key,string price)
- {
- clientDic[key].DisplayPrice = price;
- }
- internal void SendMsg(WsClientData session, string msg, string messageType, string errorMsg = "")
- {
- Send(session,msg,messageType,errorMsg);
- }
- internal void Start()
- {
- Console.WriteLine("Starting Server...");
- if (!GlobalConfig.LoadAPPConfig(configuration))
- {
- Console.WriteLine("Please check App.Config setting .");
- return;
- }
- StartWsService();
- //OpenNetwork();
- //RunHttpConsoleService();
- return;
- if (!isInDocker)
- {
- Task consoleReadTask = new Task(RunConsoleInteractive);
- consoleReadTask.Start();
- //RunConsoleInteractive();
- return;
- }
- }
- private void StartWsService()
- {
- websocketService.NewSessionConnected += AppServer_NewSessionConnected;
- }
- private void StopWsService()
- {
- websocketService.NewSessionConnected -= AppServer_NewSessionConnected;
- }
- private async void AppServer_NewSessionConnected(object sender, WsClientData session)
- {
- logger.LogDebug(string.Format("{0} NewSessionConnected", session.Path));
- try
- {
- bool isNotSupported = session.SecWebSocketProtocol.Contains("ocpp1.6") ? false : session.SecWebSocketProtocol.Contains("ocpp2.0") ? false : true;
- if (isNotSupported)
- {
- //logger.LogDebug(string.Format("ChargeBoxId:{0} SecWebSocketProtocol:{1} NotSupported", session.ChargeBoxId, session.SecWebSocketProtocol));
- WriteMachineLog(session, string.Format("SecWebSocketProtocol:{0} NotSupported", session.SecWebSocketProtocol), "Connection", "");
- return;
- }
- TryRemoveDuplicatedSession(session);
- clientDic[session.ChargeBoxId] = session;
- session.SessionClosed += AppServer_SessionClosed;
- session.m_ReceiveData += ReceivedMessageTimeLimited;
- // logger.LogDebug("------------New " + (session == null ? "Oops" : session.ChargeBoxId));
- WriteMachineLog(session, "NewSessionConnected", "Connection", "");
- await mainDbService.UpdateMachineConnectionType(session.ChargeBoxId, session.UriScheme.Contains("wss") ? 2 : 1);
- }
- catch (Exception ex)
- {
- logger.LogError(string.Format("NewSessionConnected Ex: {0}", ex.ToString()));
- }
- }
- private void AppServer_SessionClosed(object sender, string closeReason)
- {
- if (sender is not WsClientData session)
- {
- return;
- }
- session.SessionClosed -= AppServer_SessionClosed;
- session.m_ReceiveData -= ReceivedMessageTimeLimited;
- WriteMachineLog(session, string.Format("CloseReason: {0}", closeReason), "Connection", "");
- RemoveClient(session);
- }
- private void TryRemoveDuplicatedSession(WsClientData session)
- {
- if (clientDic.ContainsKey(session.ChargeBoxId))
- {
- var oldSession = clientDic[session.ChargeBoxId];
- WriteMachineLog(oldSession, "Duplicate Logins", "Connection", "");
- RemoveClient(oldSession);
- }
- }
- private void RunConsoleInteractive()
- {
- while (true)
- {
- if (Console.In is null)
- {
- break;
- }
- var input = Console.ReadLine();
- switch (input.ToLower())
- {
- case "stop":
- Console.WriteLine("Command stop");
- Stop();
- break;
- case "gc":
- Console.WriteLine("Command GC");
- GC.Collect();
- break;
- case "lc":
- {
- Console.WriteLine("Command List Clients");
- Dictionary<string, WsClientData> _copyClientDic = null;
- _copyClientDic = new Dictionary<string, WsClientData>(clientDic);
- var list = _copyClientDic.Select(c => c.Value).ToList();
- int i = 1;
- foreach (var c in list)
- {
- Console.WriteLine(i + ":" + c.ChargeBoxId + " " + c.SessionID);
- i++;
- }
- }
- break;
- case "lcn":
- {
- Console.WriteLine("Command List Customer Name");
- Dictionary<string, WsClientData> _copyClientDic = null;
- _copyClientDic = new Dictionary<string, WsClientData>(clientDic);
- var lcn = clientDic.Select(c => c.Value.CustomerName).Distinct().ToList();
- int iLcn = 1;
- foreach (var c in lcn)
- {
- Console.WriteLine(iLcn + ":" + c + ":" + clientDic.Where(z => z.Value.CustomerName == c).Count().ToString());
- iLcn++;
- }
- }
- break;
- case "help":
- Console.WriteLine("Command help!!");
- Console.WriteLine("lcn : List Customer Name");
- Console.WriteLine("gc : GC Collect");
- Console.WriteLine("lc : List Clients");
- Console.WriteLine("cls : clear console");
- Console.WriteLine("silent : silent");
- Console.WriteLine("show : show log");
- // logger.Info("rcl : show Real Connection Limit");
- break;
- case "cls":
- Console.WriteLine("Command clear");
- Console.Clear();
- break;
- case "silent":
- Console.WriteLine("Command silent");
- //var xe = XElement.Load("NLog.config");
- //var xns = xe.GetDefaultNamespace();
- //var minlevelattr = xe.Descendants(xns + "rules").Elements(xns + "logger")
- // .Where(c => c.Attribute("writeTo").Value.Equals("console")).Attributes("minlevel").FirstOrDefault();
- //if (minlevelattr != null)
- //{
- // minlevelattr.Value = "Warn";
- //}
- //xe.Save("NLog.config");
- foreach (var rule in LogManager.Configuration.LoggingRules)
- {
- if (rule.RuleName != "ConsoleLog")
- {
- continue;
- }
- var isTargetRule = rule.Targets.Any(x => x.Name.ToLower() == "console");
- if (isTargetRule)
- {
- rule.SetLoggingLevels(NLog.LogLevel.Warn, NLog.LogLevel.Off);
- }
- }
- break;
- case "show":
- Console.WriteLine("Command show");
- //var xe1 = XElement.Load("NLog.config");
- //var xns1 = xe1.GetDefaultNamespace();
- //var minlevelattr1 = xe1.Descendants(xns1 + "rules").Elements(xns1 + "logger")
- // .Where(c => c.Attribute("writeTo").Value.Equals("console")).Attributes("minlevel").FirstOrDefault();
- //if (minlevelattr1 != null)
- //{
- // minlevelattr1.Value = "trace";
- //}
- //xe1.Save("NLog.config");
- foreach (var rule in LogManager.Configuration.LoggingRules)
- {
- if (rule.RuleName != "ConsoleLog")
- {
- continue;
- }
- var isTargetRule = rule.Targets.Any(x => x.Name.ToLower() == "console");
- if (isTargetRule)
- {
- rule.SetLoggingLevels(NLog.LogLevel.Trace, NLog.LogLevel.Off);
- }
- }
- break;
- case "rcl":
- break;
- default:
- break;
- }
- }
- }
- private void RunHttpConsoleService()
- {
- var appBuilder = WebApplication.CreateBuilder();
- appBuilder.Services.AddSingleton<IHostLifetime, DummyHostLifeTime>();
- var app = appBuilder.Build();
- var helpFunc = () => {
- return string.Join("\r\n", new[] {
- "Command help!!",
- "lcn : List Customer Name",
- "gc : GC Collect",
- "lc : List Clients",
- "silent : silent",
- "show : show log"
- });
- };
- app.MapGet("/", helpFunc);
- app.MapGet("/help", helpFunc);
- app.MapPost("/stop", () => {
- Stop();
- return "Command stop";
- });
- app.MapPost("/gc", () => {
- GC.Collect();
- return "Command GC";
- });
- app.MapPost("/lc", () => {
- List<string> toReturn = new List<string>() { "Command List Clients" };
- Dictionary<string, WsClientData> _copyClientDic = null;
- _copyClientDic = new Dictionary<string, WsClientData>(clientDic);
- var list = _copyClientDic.Select(c => c.Value).ToList();
- int i = 1;
- foreach (var c in list)
- {
- toReturn.Add(i + ":" + c.ChargeBoxId + " " + c.SessionID);
- i++;
- }
- return string.Join("\r\n", toReturn);
- });
- app.MapPost("/lcn", () => {
- List<string> toReturn = new List<string> { "Command List Customer Name" };
- Dictionary<string, WsClientData> _copyClientDic = null;
- _copyClientDic = new Dictionary<string, WsClientData>(clientDic);
- var lcn = clientDic.Select(c => c.Value.CustomerName).Distinct().ToList();
- int iLcn = 1;
- foreach (var c in lcn)
- {
- toReturn.Add(iLcn + ":" + c + ":" + clientDic.Where(z => z.Value.CustomerName == c).Count().ToString());
- iLcn++;
- }
- return string.Join("\r\n", toReturn);
- });
- app.MapPost("/silent", () => {
- foreach (var rule in LogManager.Configuration.LoggingRules)
- {
- if (rule.RuleName != "ConsoleLog")
- {
- continue;
- }
- var isTargetRule = rule.Targets.Any(x => x.Name.ToLower() == "console");
- if (isTargetRule)
- {
- rule.SetLoggingLevels(NLog.LogLevel.Warn, NLog.LogLevel.Off);
- }
- }
- return "Command silent";
- });
- app.MapPost("/show", () => {
- foreach (var rule in LogManager.Configuration.LoggingRules)
- {
- if (rule.RuleName != "ConsoleLog")
- {
- continue;
- }
- var isTargetRule = rule.Targets.Any(x => x.Name.ToLower() == "console");
- if (isTargetRule)
- {
- rule.SetLoggingLevels(NLog.LogLevel.Trace, NLog.LogLevel.Off);
- }
- }
- return "Command show";
- });
- app.MapGet("/threads", () => {
- ThreadPool.GetMaxThreads(out var maxWorkerThread,out var maxCompletionPortThreads);
- ThreadPool.GetAvailableThreads(out var avaliableWorkerThread, out var avaliableCompletionPortThreads);
- return $"WorkerThread:{avaliableWorkerThread}/{maxWorkerThread} CompletionPortThreads{avaliableCompletionPortThreads}/{maxCompletionPortThreads}";
- });
- app.MapPost("/threads", (int min, int max) => {
- ThreadPool.GetMaxThreads(out var maxWorkerThread, out var maxCompletionPortThreads);
- ThreadPool.GetAvailableThreads(out var avaliableWorkerThread, out var avaliableCompletionPortThreads);
- ThreadPool.SetMinThreads(min, 0);
- ThreadPool.SetMaxThreads(max, maxCompletionPortThreads);
- return $"WorkerThread:{avaliableWorkerThread}/{maxWorkerThread} CompletionPortThreads{avaliableCompletionPortThreads}/{maxCompletionPortThreads}";
- });
- app.Urls.Add("http://*:54088");
- _ = app.RunAsync();
- var builder = WebApplication.CreateBuilder();
- //builder.Configuration.AddJsonFile("./EVCB_OCPP.WSServer/appsettings.json");
- //var sec = builder.Configuration.GetSection("ReverseProxy");
- //Console.WriteLine($"Printing.............");
- //foreach (var pair in sec.AsEnumerable())
- //{
- // Console.WriteLine($"{pair.Key}:{pair.Value} \n");
- //}
- builder.Services.AddReverseProxy()
- .LoadFromConfig(builder.Configuration.GetSection("ReverseProxy"));
- builder.Services.AddSingleton<IHostLifetime, DummyHostLifeTime>();
- var yarpApp = builder.Build();
- yarpApp.Urls.Add("http://*:80");
- yarpApp.MapReverseProxy();
- _ = yarpApp.RunAsync();
- }
- internal void Stop()
- {
- _cts?.Cancel();
- }
- //private void OpenNetwork()
- //{
- // //載入OCPP Protocol
- // OCPPWSServer appServer = ocppWSServerFactory.Create(new List<OCPPSubProtocol>() { new OCPPSubProtocol(), new OCPPSubProtocol(" ocpp1.6"), new OCPPSubProtocol("ocpp2.0") });
- // //var appServer = new OCPPWSServer(new List<OCPPSubProtocol>() { new OCPPSubProtocol(), new OCPPSubProtocol(" ocpp1.6"), new OCPPSubProtocol("ocpp2.0") });
- // List<IListenerConfig> llistener = new List<IListenerConfig>();
- // if (GlobalConfig.GetWS_Port() != 0)
- // {
- // llistener.Add(new ListenerConfig { Ip = System.Net.IPAddress.Any.ToString(), Port = GlobalConfig.GetWS_Port(), Backlog = 100, Security = "None" });
- // }
- // foreach (var securityport in GlobalConfig.GetWSS_Ports())
- // {
- // llistener.Add(new ListenerConfig { Ip = System.Net.IPAddress.Any.ToString(), Port = securityport, Backlog = 100, Security = SslProtocols.Tls12.ToString() });
- // }
- // //var config = ConfigurationManager.GetSection("superSocket") as IConfigurationSource;\
- // //var certificate = configuration.GetSection("superSocket").GetSection("Servers:0").GetSection("Certificate").Get<CertificateConfig>();
- // var certificate = configuration.GetSection("SuperSocketServerCertificate").Get<CertificateConfig>();
- // ICertificateConfig Certificate = certificate;
- // IEnumerable<IListenerConfig> listeners = llistener;
- // //設定server config
- // var serverConfig = new ServerConfig
- // {
- // SendingQueueSize = 10,
- // //Port = Convert.ToInt32(2012),
- // //Ip = "172.17.40.13",
- // MaxRequestLength = 204800,
- // //Security = serverSecurity,
- // //Certificate = Certificate,
- // Listeners = listeners,
- // // LogAllSocketException = true,
- // KeepAliveTime = 10,
- // // LogBasicSessionActivity = true
- // //Security = "None"
- // };
- // //Setup with listening port
- // if (!appServer.Setup(serverConfig, logFactory: new NLogLoggerFactory()))
- // {
- // Console.WriteLine("Failed to setup!");
- // return;
- // }
- // appServer.NewSessionConnected += AppServer_NewSessionConnected;
- // appServer.SessionClosed += AppServer_SessionClosed;
- // //Try to start the appServer
- // if (!appServer.Start())
- // {
- // Console.WriteLine("Failed to start!");
- // //Console.ReadKey();
- // return;
- // }
- //}
- private void AppServer_SessionClosed(WsClientData session, CloseReason value)
- {
- WriteMachineLog(session, string.Format("CloseReason: {0}", value), "Connection", "");
- RemoveClient(session);
- }
- private async void AppServer_NewSessionConnected(WsClientData session)
- {
- logger.LogDebug(string.Format("{0} NewSessionConnected", session.Path));
- try
- {
- bool isNotSupported = session.SecWebSocketProtocol.Contains("ocpp1.6") ? false : session.SecWebSocketProtocol.Contains("ocpp2.0") ? false : true;
- if (isNotSupported)
- {
- //logger.LogDebug(string.Format("ChargeBoxId:{0} SecWebSocketProtocol:{1} NotSupported", session.ChargeBoxId, session.SecWebSocketProtocol));
- WriteMachineLog(session, string.Format("SecWebSocketProtocol:{0} NotSupported", session.SecWebSocketProtocol), "Connection", "");
- return;
- }
- //WsClientData _removeClient = null;
- //var addedClient = clientDic.GetOrAdd(session.ChargeBoxId, session);
- if (clientDic.ContainsKey(session.ChargeBoxId))
- {
- var oldSession = clientDic[session.ChargeBoxId];
- WriteMachineLog(oldSession, "Duplicate Logins", "Connection", "");
- //oldSession.Close(CloseReason.ServerShutdown);
- RemoveClient(oldSession);
- }
- clientDic[session.ChargeBoxId] = session;
- //clientDic.TryGetValue(session.ChargeBoxId, out _removeClient);
- //if (addedClient != session)
- //{
- // WriteMachineLog(addedClient, "Duplicate Logins", "Connection", "");
- // addedClient.Close(CloseReason.ServerShutdown);
- // RemoveClient(addedClient);
- //}
- //clientDic.add.Add(session.ChargeBoxId, session);
- session.m_ReceiveData += ReceivedMessageTimeLimited;
- // logger.LogDebug("------------New " + (session == null ? "Oops" : session.ChargeBoxId));
- WriteMachineLog(session, "NewSessionConnected", "Connection", "");
- using (var db = await maindbContextFactory.CreateDbContextAsync())
- {
- var machine = await db.Machine.Where(x => x.ChargeBoxId == session.ChargeBoxId).FirstOrDefaultAsync();
- if (machine != null)
- {
- machine.ConnectionType = session.UriScheme.Contains("wss") ? 2 : 1;
- await db.SaveChangesAsync();
- }
- }
- }
- catch (Exception ex)
- {
- logger.LogError(string.Format("NewSessionConnected Ex: {0}", ex.ToString()));
- }
- }
- async private void ReceivedMessageTimeLimited(object sender, string rawdata)
- {
- if (sender is not WsClientData session)
- {
- return;
- }
- CancellationTokenSource tokenSource = new();
- var task = ReceivedMessage(session, rawdata);
- var completedTask = await Task.WhenAny(task, Task.Delay(90_000, tokenSource.Token));
- if (completedTask != task)
- {
- logger.LogCritical("Process timeout: {0} ", rawdata);
- await task;
- return;
- }
- tokenSource.Cancel();
- return;
- }
- async private Task ReceivedMessage(WsClientData session, string rawdata)
- {
- try
- {
- BasicMessageHandler msgAnalyser = new BasicMessageHandler();
- MessageResult analysisResult = msgAnalyser.AnalysisReceiveData(session, rawdata);
- WriteMachineLog(session, rawdata,
- string.Format("{0} {1}", string.IsNullOrEmpty(analysisResult.Action) ? "unknown" : analysisResult.Action, analysisResult.Id == 2 ? "Request" : (analysisResult.Id == 3 ? "Confirmation" : "Error")), analysisResult.Exception == null ? "" : analysisResult.Exception.Message);
- if (session.ResetSecurityProfile)
- {
- logger.LogError(string.Format("[{0}] ChargeBoxId:{1} ResetSecurityProfile", DateTime.UtcNow, session.ChargeBoxId));
- RemoveClient(session);
- return;
- }
- if (!analysisResult.Success)
- {
- //解析RawData就發生錯誤
- if (!string.IsNullOrEmpty(analysisResult.CallErrorMsg))
- {
- Send(session, analysisResult.CallErrorMsg, string.Format("{0} {1}", analysisResult.Action, "Error"));
- }
- else
- {
- if (analysisResult.Message == null)
- {
- string replyMsg = BasicMessageHandler.GenerateCallError(analysisResult.UUID, OCPPErrorCodes.InternalError, OCPPErrorDescription.InternalError);
- string errorMsg = string.Empty;
- if (analysisResult.Exception != null)
- {
- errorMsg = analysisResult.Exception.ToString();
- }
- Send(session, replyMsg, string.Format("{0} {1}", "unknown", "Error"), "EVSE's sent essage has parsed Failed. ");
- }
- else
- {
- BaseMessage _baseMsg = analysisResult.Message as BaseMessage;
- string replyMsg = BasicMessageHandler.GenerateCallError(_baseMsg.Id, OCPPErrorCodes.InternalError, OCPPErrorDescription.InternalError);
- string errorMsg = string.Empty;
- if (analysisResult.Exception != null)
- {
- errorMsg = analysisResult.Exception.ToString();
- }
- Send(session, replyMsg, string.Format("{0} {1}", analysisResult.Action, "Error"), errorMsg);
- }
- }
- }
- else
- {
- switch (analysisResult.Id)
- {
- case BasicMessageHandler.TYPENUMBER_CALL:
- {
- if (!session.ISOCPP20)
- {
- Actions action = Convertor.GetAction(analysisResult.Action);
- try
- {
- await ProcessRequestMessage(analysisResult, session, action);
- }
- catch (Exception e)
- {
- logger.LogError($"Processing {action} exception!");
- throw;
- }
- }
- else
- {
- EVCB_OCPP20.Packet.Features.Actions action = Convertor.GetActionby20(analysisResult.Action);
- MessageResult result = new MessageResult() { Success = true };
- //ocpp20 處理
- switch (action)
- {
- case EVCB_OCPP20.Packet.Features.Actions.BootNotification:
- {
- EVCB_OCPP20.Packet.Messages.BootNotificationRequest _request = (EVCB_OCPP20.Packet.Messages.IRequest)analysisResult.Message as EVCB_OCPP20.Packet.Messages.BootNotificationRequest;
- var confirm = new EVCB_OCPP20.Packet.Messages.BootNotificationResponse() { CurrentTime = DateTime.UtcNow, Interval = 180, Status = EVCB_OCPP20.Packet.DataTypes.EnumTypes.RegistrationStatusEnumType.Pending };
- result.Message = confirm;
- result.Success = true;
- string response = BasicMessageHandler.GenerateConfirmationofOCPP20(analysisResult.UUID, (EVCB_OCPP20.Packet.Messages.IConfirmation)result.Message);
- Send(session, response, string.Format("{0} {1}", analysisResult.Action, "Response"), result.Exception == null ? string.Empty : result.Exception.ToString());
- var request = new EVCB_OCPP20.Packet.Messages.SetNetworkProfileRequest()
- {
- ConfigurationSlot = 1,
- ConnectionData = new EVCB_OCPP20.Packet.DataTypes.NetworkConnectionProfileType()
- {
- OcppVersion = EVCB_OCPP20.Packet.DataTypes.EnumTypes.OCPPVersionEnumType.OCPP20,
- OcppTransport = EVCB_OCPP20.Packet.DataTypes.EnumTypes.OCPPTransportEnumType.JSON,
- MessageTimeout = 30,
- OcppCsmsUrl = session.UriScheme == "ws" ? GlobalConfig.OCPP20_WSUrl : GlobalConfig.OCPP20_WSSUrl,
- OcppInterface = EVCB_OCPP20.Packet.DataTypes.EnumTypes.OCPPInterfaceEnumType.Wired0
- }
- };
- var uuid = session.queue20.store(request);
- string requestText = BasicMessageHandler.GenerateRequestofOCPP20(uuid, "SetNetworkProfile", request);
- Send(session, requestText, "SetNetworkProfile");
- }
- break;
- default:
- {
- logger.LogError(string.Format("We don't implement messagetype:{0} of raw data :{1} by {2}", analysisResult.Id, rawdata, session.ChargeBoxId));
- }
- break;
- }
- }
- }
- break;
- case BasicMessageHandler.TYPENUMBER_CALLRESULT:
- {
- if (!session.ISOCPP20)
- {
- Actions action = Convertor.GetAction(analysisResult.Action);
- ProcessConfirmationMessage(analysisResult, session, action);
- }
- else
- {
- EVCB_OCPP20.Packet.Features.Actions action = Convertor.GetActionby20(analysisResult.Action);
- MessageResult result = new MessageResult() { Success = true };
- //ocpp20 處理
- switch (action)
- {
- case EVCB_OCPP20.Packet.Features.Actions.SetNetworkProfile:
- {
- EVCB_OCPP20.Packet.Messages.SetNetworkProfileResponse response = (EVCB_OCPP20.Packet.Messages.IConfirmation)analysisResult.Message as EVCB_OCPP20.Packet.Messages.SetNetworkProfileResponse;
- if (response.Status == EVCB_OCPP20.Packet.DataTypes.EnumTypes.SetNetworkProfileStatusEnumType.Accepted)
- {
- var request = new EVCB_OCPP20.Packet.Messages.SetVariablesRequest()
- {
- SetVariableData = new List<EVCB_OCPP20.Packet.DataTypes.SetVariableDataType>()
- {
- new EVCB_OCPP20.Packet.DataTypes.SetVariableDataType()
- {
- Component=new EVCB_OCPP20.Packet.DataTypes.ComponentType()
- {
- Name="OCPPCommCtrlr",
- },
- AttributeType= EVCB_OCPP20.Packet.DataTypes.EnumTypes.AttributeEnumType.Actual,
- AttributeValue= JsonConvert.SerializeObject(new List<int>(){ 1 }),
- Variable=new EVCB_OCPP20.Packet.DataTypes.VariableType()
- {
- Name="NetworkConfigurationPriority",
- }
- }
- }
- };
- var uuid = session.queue20.store(request);
- string requestText = BasicMessageHandler.GenerateRequestofOCPP20(uuid, "SetVariables", request);
- Send(session, requestText, "SetVariables");
- }
- }
- break;
- case EVCB_OCPP20.Packet.Features.Actions.SetVariables:
- {
- EVCB_OCPP20.Packet.Messages.SetVariablesResponse response = (EVCB_OCPP20.Packet.Messages.IConfirmation)analysisResult.Message as EVCB_OCPP20.Packet.Messages.SetVariablesResponse;
- if (response.SetVariableResult[0].AttributeStatus == EVCB_OCPP20.Packet.DataTypes.EnumTypes.SetVariableStatusEnumType.RebootRequired)
- {
- var request = new EVCB_OCPP20.Packet.Messages.ResetRequest()
- {
- Type = EVCB_OCPP20.Packet.DataTypes.EnumTypes.ResetEnumType.OnIdle
- };
- var uuid = session.queue20.store(request);
- string requestText = BasicMessageHandler.GenerateRequestofOCPP20(uuid, "Reset", request);
- Send(session, requestText, "Reset");
- }
- }
- break;
- default:
- {
- logger.LogError(string.Format("We don't implement messagetype:{0} of raw data :{1} by {2}", analysisResult.Id, rawdata, session.ChargeBoxId));
- }
- break;
- }
- }
- }
- break;
- case BasicMessageHandler.TYPENUMBER_CALLERROR:
- {
- //只處理 丟出Request 收到Error的訊息
- if (analysisResult.Success && analysisResult.Message != null)
- {
- Actions action = Convertor.GetAction(analysisResult.Action);
- ProcessErrorMessage(analysisResult, session, action);
- }
- }
- break;
- default:
- {
- logger.LogError(string.Format("Can't analyze messagetype:{0} of raw data :{1} by {2}", analysisResult.Id, rawdata, session.ChargeBoxId));
- }
- break;
- }
- }
- await Task.Delay(10);
- }
- catch (Exception ex)
- {
- if (ex.InnerException != null)
- {
- logger.LogError(string.Format("{0} **Inner Exception :{1} ", session.ChargeBoxId + rawdata, ex.ToString()));
- }
- else
- {
- logger.LogError(string.Format("{0} **Exception :{1} ", session.ChargeBoxId, ex.ToString()));
- }
- }
- }
- private async Task ProcessRequestMessage(MessageResult analysisResult, WsClientData session, Actions action)
- {
- Stopwatch outter_stopwatch = Stopwatch.StartNew();
- //BasicMessageHandler msgAnalyser = new BasicMessageHandler();
- if (!session.IsCheckIn && action != Actions.BootNotification)
- {
- string response = BasicMessageHandler.GenerateCallError(analysisResult.UUID, OCPPErrorCodes.GenericError, OCPPErrorDescription.NotChecked);
- Send(session, response, string.Format("{0} {1}", analysisResult.Action, "Error"));
- }
- else
- {
- var profileName = profiles.Where(x => x.IsExisted(analysisResult.Action)).Select(x => x.Name).FirstOrDefault();
- switch (profileName)
- {
- case "Core":
- {
- var replyResult = await profileHandler.ExecuteCoreRequest(action, session, (IRequest)analysisResult.Message).ConfigureAwait(false);
- var sendTimer = Stopwatch.StartNew();
- if (replyResult.Success)
- {
- string response = BasicMessageHandler.GenerateConfirmation(analysisResult.UUID, (IConfirmation)replyResult.Message);
- Send(session, response, string.Format("{0} {1}", analysisResult.Action, "Confirmation"), replyResult.Exception == null ? string.Empty : replyResult.Exception.ToString());
- if (action == Actions.BootNotification && replyResult.Message is BootNotificationConfirmation)
- {
- if (((BootNotificationConfirmation)replyResult.Message).status == Packet.Messages.SubTypes.RegistrationStatus.Accepted)
- {
- session.IsCheckIn = true;
- if (session.IsSignedByCPO == false)
- {
- var _request = new ExtendedTriggerMessageRequest()
- {
- requestedMessage = Packet.Messages.SubTypes.MessageTriggerEnumType.SignChargePointCertificate
- };
- var uuid = session.queue.store(_request);
- string rawRequest = BasicMessageHandler.GenerateRequest(uuid, _request.Action, _request);
- SendMsg(session, rawRequest, string.Format("{0} {1}", _request.Action, "Request"), "");
- }
- await messageService.SendGetEVSEConfigureRequest(session.ChargeBoxId);
- if (session.CustomerId == new Guid("298918C0-6BB5-421A-88CC-4922F918E85E") || session.CustomerId == new Guid("9E6BFDCC-09FB-4DAB-A428-43FE507600A3"))
- {
- await messageService.SendChangeConfigurationRequest(
- session.ChargeBoxId, key: "TimeOffset", value: "+08:00");
- }
- await messageService.SendDataTransferRequest(
- session.ChargeBoxId,
- messageId: "ID_FirmwareVersion",
- vendorId: "Phihong Technology",
- data: string.Empty);
- }
- else
- {
- using (var db = await maindbContextFactory.CreateDbContextAsync())
- {
- var machine = await db.Machine.Where(x => x.ChargeBoxId == session.ChargeBoxId).FirstOrDefaultAsync();
- if (machine != null)
- {
- if (machine.ConnectorType.Contains("6") || machine.ConnectorType.Contains("7") || machine.ConnectorType.Contains("8") || machine.ConnectorType.Contains("9"))
- {
- session.IsAC = false;
- }
- machine.ConnectionType = session.UriScheme.Contains("wss") ? 2 : 1;
- await db.SaveChangesAsync();
- }
- }
- await SetDefaultFee(session);
- }
- }
- if (action == Actions.Authorize && replyResult.Message is AuthorizeConfirmation)
- {
- var authorizeRequest = (IRequest)analysisResult.Message as AuthorizeRequest;
- if (session.UserDisplayPrices.ContainsKey(authorizeRequest.idTag))
- {
- await messageService.SendDataTransferRequest(
- session.ChargeBoxId,
- messageId: "SetUserPrice",
- vendorId: "Phihong Technology",
- data: JsonConvert.SerializeObject(
- new
- {
- idToken = authorizeRequest.idTag,
- price = session.UserDisplayPrices[authorizeRequest.idTag]
- })
- );
- }
- }
- }
- else
- {
- if (action == Actions.StopTransaction && replyResult.CallErrorMsg == "Reject Response Message")
- {
- //do nothing
- logger.LogWarning(replyResult.Exception.ToString());
- }
- else
- {
- string response = BasicMessageHandler.GenerateCallError(analysisResult.UUID, OCPPErrorCodes.InternalError, OCPPErrorDescription.InternalError);
- string errorMsg = replyResult.Exception != null ? replyResult.Exception.ToString() : string.Empty;
- Send(session, response, string.Format("{0} {1}", analysisResult.Action, "Error"), errorMsg);
- }
- }
- sendTimer.Stop();
- if(sendTimer.ElapsedMilliseconds/1000 > 1)
- {
- logger.LogCritical("ProcessRequestMessage Send Cost {time} sec", sendTimer.ElapsedMilliseconds / 1000);
- }
- if (action == Actions.StartTransaction)
- {
- var stationId = await _loadingBalanceService.GetStationIdByMachineId(session.MachineId);
- var _powerDic = await _loadingBalanceService.GetSettingPower(stationId);
- if (_powerDic != null)
- {
- foreach (var kv in _powerDic)
- {
- try
- {
- if (kv.Value.HasValue)
- {
- profileHandler.SetChargingProfile(kv.Key, kv.Value.Value, Packet.Messages.SubTypes.ChargingRateUnitType.W);
- }
- }
- catch (Exception ex)
- {
- logger.LogError(string.Format("Set Profile Exception: {0}", ex.ToString()));
- }
- }
- }
- }
- if (action == Actions.StopTransaction)
- {
- var stationId = await _loadingBalanceService.GetStationIdByMachineId(session.MachineId);
- var _powerDic = await _loadingBalanceService.GetSettingPower(stationId);
- if (_powerDic != null)
- {
- foreach (var kv in _powerDic)
- {
- try
- {
- if (kv.Value.HasValue)
- {
- profileHandler.SetChargingProfile(kv.Key, kv.Value.Value, Packet.Messages.SubTypes.ChargingRateUnitType.W);
- }
- }
- catch (Exception ex)
- {
- logger.LogError(string.Format("Set Profile Exception: {0}", ex.ToString()));
- }
- }
- }
- }
- }
- break;
- case "FirmwareManagement":
- {
- var replyResult = await profileHandler.ExecuteFirmwareManagementRequest(action, session, (IRequest)analysisResult.Message);
- if (replyResult.Success)
- {
- string response = BasicMessageHandler.GenerateConfirmation(analysisResult.UUID, (IConfirmation)replyResult.Message);
- Send(session, response, string.Format("{0} {1}", analysisResult.Action, "Confirmation", replyResult.Exception == null ? string.Empty : replyResult.Exception.ToString()));
- }
- else
- {
- string response = BasicMessageHandler.GenerateCallError(analysisResult.UUID, OCPPErrorCodes.InternalError, OCPPErrorDescription.InternalError);
- string errorMsg = replyResult.Exception != null ? replyResult.Exception.ToString() : string.Empty;
- Send(session, response, string.Format("{0} {1}", analysisResult.Action, "Error"), errorMsg);
- }
- }
- break;
- case "Security":
- {
- var replyResult = await profileHandler.ExecuteSecurityRequest(action, session, (IRequest)analysisResult.Message);
- if (replyResult.Success)
- {
- string response = BasicMessageHandler.GenerateConfirmation(analysisResult.UUID, (IConfirmation)replyResult.Message);
- Send(session, response, string.Format("{0} {1}", analysisResult.Action, "Confirmation", replyResult.Exception == null ? string.Empty : replyResult.Exception.ToString()));
- }
- else
- {
- string response = BasicMessageHandler.GenerateCallError(analysisResult.UUID, OCPPErrorCodes.InternalError, OCPPErrorDescription.InternalError);
- string errorMsg = replyResult.Exception != null ? replyResult.Exception.ToString() : string.Empty;
- Send(session, response, string.Format("{0} {1}", analysisResult.Action, "Error"), errorMsg);
- }
- }
- break;
- default:
- {
- string replyMsg = BasicMessageHandler.GenerateCallError(analysisResult.UUID, OCPPErrorCodes.InternalError, OCPPErrorDescription.InternalError);
- string errorMsg = string.Format("Couldn't find action name: {0} of profile", action);
- Send(session, replyMsg, string.Format("{0} {1}", analysisResult.Action, "Error"), errorMsg);
- }
- break;
- }
- }
- outter_stopwatch.Stop();
- if (outter_stopwatch.ElapsedMilliseconds > 1000)
- {
- logger.LogCritical("ProcessRequestMessage {action} too long {time} sec", action.ToString(), outter_stopwatch.ElapsedMilliseconds / 1000);
- }
- }
- async private void ProcessConfirmationMessage(MessageResult analysisResult, WsClientData session, Actions action)
- {
- BasicMessageHandler msgAnalyser = new BasicMessageHandler();
- if (await ReConfirmMessage(analysisResult))
- {
- var profileName = profiles.Where(x => x.IsExisted(analysisResult.Action)).Select(x => x.Name).FirstOrDefault();
- MessageResult confirmResult = null;
- switch (profileName)
- {
- case "Core":
- {
- confirmResult = await profileHandler.ExecuteCoreConfirm(action, session, (IConfirmation)analysisResult.Message, analysisResult.RequestId);
- }
- break;
- case "FirmwareManagement":
- {
- confirmResult = await profileHandler.ExecuteFirmwareManagementConfirm(action, session, (IConfirmation)analysisResult.Message, analysisResult.RequestId);
- }
- break;
- case "RemoteTrigger":
- {
- confirmResult = await profileHandler.ExecuteRemoteTriggerConfirm(action, session, (IConfirmation)analysisResult.Message, analysisResult.RequestId);
- }
- break;
- case "Reservation":
- {
- confirmResult = await profileHandler.ExecuteReservationConfirm(action, session, (IConfirmation)analysisResult.Message, analysisResult.RequestId);
- }
- break;
- case "LocalAuthListManagement":
- {
- confirmResult = await profileHandler.ExecuteLocalAuthListManagementConfirm(action, session, (IConfirmation)analysisResult.Message, analysisResult.RequestId);
- }
- break;
- case "SmartCharging":
- {
- confirmResult = await profileHandler.ExecuteSmartChargingConfirm(action, session, (IConfirmation)analysisResult.Message, analysisResult.RequestId);
- }
- break;
- case "Security":
- {
- confirmResult = await profileHandler.ExecuteSecurityConfirm(action, session, (IConfirmation)analysisResult.Message, analysisResult.RequestId);
- }
- break;
- default:
- {
- string replyMsg = BasicMessageHandler.GenerateCallError(analysisResult.UUID, OCPPErrorCodes.InternalError, OCPPErrorDescription.InternalError);
- string errorMsg = string.Format("Couldn't find action name: {0} of profile", action);
- Send(session, replyMsg, string.Format("{0} {1}", analysisResult.Action, "Error"), errorMsg);
- }
- break;
- }
- if (confirmResult == null || !confirmResult.Success)
- {
- logger.LogError(string.Format("Action:{0} MessageId:{1} ExecuteConfirm Error:{2} ",
- analysisResult.Action, analysisResult.UUID, confirmResult.Exception.ToString()));
- }
- }
- else
- {
- string replyMsg = BasicMessageHandler.GenerateCallError(analysisResult.UUID, OCPPErrorCodes.InternalError, OCPPErrorDescription.InternalError);
- string errorMsg = string.Format("Action:{0} MessageId:{1} didn't exist in confirm message", analysisResult.Action, analysisResult.UUID);
- Send(session, replyMsg, string.Format("{0} {1}", analysisResult.Action, "Error"), errorMsg);
- }
- }
- private async void ProcessErrorMessage(MessageResult analysisResult, WsClientData session, Actions action)
- {
- BasicMessageHandler msgAnalyser = new BasicMessageHandler();
- if (await ReConfirmMessage(analysisResult))
- {
- var profileName = profiles.Where(x => x.IsExisted(analysisResult.Action)).Select(x => x.Name).FirstOrDefault();
- switch (profileName)
- {
- case "Core":
- {
- _ = profileHandler.ReceivedCoreError(action, analysisResult.ReceivedErrorCode, session, analysisResult.RequestId);
- }
- break;
- case "FirmwareManagement":
- {
- _ = profileHandler.ReceivedFirmwareManagementError(action, analysisResult.ReceivedErrorCode, session, analysisResult.RequestId);
- }
- break;
- case "RemoteTrigger":
- {
- _ = profileHandler.ReceivedRemoteTriggerError(action, analysisResult.ReceivedErrorCode, session, analysisResult.RequestId);
- }
- break;
- case "Reservation":
- {
- _ = profileHandler.ExecuteReservationError(action, analysisResult.ReceivedErrorCode, session, analysisResult.RequestId);
- }
- break;
- case "LocalAuthListManagement":
- {
- _ = profileHandler.ReceivedLocalAuthListManagementError(action, analysisResult.ReceivedErrorCode, session, analysisResult.RequestId);
- }
- break;
- case "SmartCharging":
- {
- _ = profileHandler.ReceivedSmartChargingError(action, analysisResult.ReceivedErrorCode, session, analysisResult.RequestId);
- }
- break;
- default:
- {
- string replyMsg = BasicMessageHandler.GenerateCallError(analysisResult.UUID, OCPPErrorCodes.InternalError, OCPPErrorDescription.InternalError);
- string errorMsg = string.Format("Couldn't find action name: {0} of profile", action);
- Send(session, replyMsg, string.Format("{0} {1}", analysisResult.Action, "Error"), errorMsg);
- }
- break;
- }
- }
- else
- {
- string replyMsg = BasicMessageHandler.GenerateCallError(analysisResult.UUID, OCPPErrorCodes.InternalError, OCPPErrorDescription.InternalError);
- string errorMsg = string.Format("Action:{0} MessageId:{1} didn't exist in confirm message", analysisResult.Action, analysisResult.UUID);
- Send(session, replyMsg, string.Format("{0} {1}", analysisResult.Action, "Error"), errorMsg);
- }
- }
- private void Send(WsClientData session, string msg, string messageType, string errorMsg = "")
- {
- try
- {
- if (session != null)
- {
- WriteMachineLog(session, msg, messageType, errorMsg, true);
- session.Send(msg);
- }
- }
- catch (Exception ex)
- {
- logger.LogError(string.Format("Send Ex:{0}", ex.ToString()));
- }
- }
- async private Task<string> SetDefaultFee(WsClientData client)
- {
- string displayPriceText = string.Empty;
- string charingPriceText = string.Empty;
- if (string.IsNullOrEmpty(client.ChargeBoxId)) return displayPriceText;
- try
- {
- using (SqlConnection conn = await webDbConnectionFactory.CreateAsync())
- {
- var parameters = new DynamicParameters();
- parameters.Add("@MachineId", client.MachineId, DbType.String, ParameterDirection.Input, 36);
- string displayPricestrSql = "";
- string strSql = "";
- if (client.IsAC)
- {
- displayPricestrSql = " SELECT [AC_BillingMethod] as BillingMethod,[AC_FeeName] as FeeName,[AC_Fee] as ChargingFeebyHour" +
- " ,[AC_ParkingFee] as ParkingFee, [Currency] FROM[StationMachine] left join[dbo].[Station]" +
- " on[StationMachine].StationId = Station.[Id] where StationMachine.MachineId=@MachineId and Station.IsBilling=1; ";
- strSql = " SELECT CAST( [StartTime] as varchar(5)) StartTime,CAST( [EndTime] as varchar(5)) EndTime,[Fee] FROM[StationMachine] left join [dbo].[StationFee]" +
- " on[StationMachine].StationId = StationFee.StationId where StationMachine.MachineId =@MachineId and StationFee.IsAC=1; ";
- }
- else
- {
- displayPricestrSql = " SELECT [DC_BillingMethod] as BillingMethod,[DC_FeeName] as FeeName,[DC_Fee] as ChargingFeebyHour" +
- " ,[DC_ParkingFee] as ParkingFee, [Currency] FROM[StationMachine] left join[dbo].[Station]" +
- " on[StationMachine].StationId = Station.[Id] where StationMachine.MachineId=@MachineId and Station.IsBilling=1; ";
- strSql = " SELECT CAST( [StartTime] as varchar(5)) StartTime,CAST( [EndTime] as varchar(5)) EndTime,[Fee] FROM[StationMachine] left join [dbo].[StationFee]" +
- " on[StationMachine].StationId = StationFee.StationId where StationMachine.MachineId =@MachineId and StationFee.IsAC=0; ";
- }
- //var result = await conn.QueryAsync<StationFee>(displayPricestrSql, parameters);
- var result = await conn.QueryFirstOrDefaultAsync<StationFee>(displayPricestrSql, parameters);
- if (result == default)
- {
- return string.Empty;
- }
- var stationPrice = result;//.First();
- if (stationPrice.BillingMethod == 1)
- {
- var chargingPriceResult = await conn.QueryAsync<ChargingPrice>(strSql, parameters);
- client.ChargingPrices = chargingPriceResult.ToList();
- if (string.IsNullOrEmpty(client.ChargingPrices[0].StartTime))
- {
- client.ChargingPrices = new List<ChargingPrice>();
- }
- }
- displayPriceText = stationPrice.FeeName;
- client.BillingMethod = stationPrice.BillingMethod;
- client.Currency = stationPrice.Currency;
- client.ChargingFeebyHour = stationPrice.ChargingFeebyHour;
- client.ParkingFee = stationPrice.ParkingFee;
- client.IsBilling = true;
- }
- }
- catch (Exception ex)
- {
- logger.LogError("SetDefaultFee", ex.ToString());
- }
- return displayPriceText;
- }
- internal void AddConfirmMessage(string chargePointSerialNumber, int table_id, string requestId, string action, string msg_id, string createdBy, string sendMessage)
- {
- NeedConfirmMessage _needConfirmMsg = new NeedConfirmMessage();
- _needConfirmMsg.Id = table_id;
- _needConfirmMsg.SentAction = action;
- _needConfirmMsg.SentOn = DateTime.UtcNow;
- _needConfirmMsg.SentTimes = 4;
- _needConfirmMsg.ChargePointSerialNumber = chargePointSerialNumber;
- _needConfirmMsg.RequestId = requestId;
- _needConfirmMsg.SentUniqueId = msg_id;
- _needConfirmMsg.CreatedBy = createdBy;
- _needConfirmMsg.SentMessage = sendMessage;
- if (needConfirmActions.Contains(action))
- {
- lock (_lockConfirmPacketList)
- {
- needConfirmPacketList.Add(_needConfirmMsg);
- }
- }
- }
- internal void RemoveConfirmMessage()
- {
- var before10Mins = DateTime.UtcNow.AddMinutes(-10);
- lock (_lockConfirmPacketList)
- {
- var removeList = needConfirmPacketList.Where(x => x.SentTimes == 0 || x.SentOn < before10Mins).ToList();
- foreach (var item in removeList)
- {
- needConfirmPacketList.Remove(item);
- }
- }
- }
- private async Task<bool> ReConfirmMessage(MessageResult analysisResult)
- {
- bool confirmed = false;
- if (needConfirmActions.Contains(analysisResult.Action))
- {
- NeedConfirmMessage foundRequest = null;
- lock (_lockConfirmPacketList)
- {
- foundRequest = needConfirmPacketList.Where(x => x.SentUniqueId == analysisResult.UUID).FirstOrDefault();
- }
- if (foundRequest != null && foundRequest.Id > 0)
- {
- foundRequest.SentTimes = 0;
- foundRequest.SentInterval = 0;
- analysisResult.RequestId = foundRequest.RequestId;
- using (var db = await maindbContextFactory.CreateDbContextAsync())
- {
- var sc = await db.ServerMessage.Where(x => x.Id == foundRequest.Id).FirstOrDefaultAsync();
- sc.InMessage = JsonConvert.SerializeObject(analysisResult.Message, Formatting.None);
- sc.ReceivedOn = DateTime.UtcNow;
- await db.SaveChangesAsync();
- // Console.WriteLine(string.Format("Now:{0} ServerMessage Id:{1} ", DateTime.UtcNow.ToString("yyyy/MM/dd HH:mm:ss"), foundRequest.Id));
- }
- confirmed = true;
- }
- else if (analysisResult.Action == Actions.TriggerMessage.ToString())
- {
- confirmed = true;
- }
- else
- {
- logger.LogError(string.Format("Received no record Action:{0} MessageId:{1} ", analysisResult.Action, analysisResult.UUID));
- }
- }
- return confirmed;
- }
- internal async void RemoveClient(WsClientData session)
- {
- if (session == null)
- {
- return;
- }
- if (!string.IsNullOrEmpty(session.MachineId))
- logger.LogTrace("RemoveClient[" + session.ChargeBoxId + "]");
- //if (session.Connected)
- //{
- // session.Close(CloseReason.ServerShutdown);
- //}
- RemoveClientDic(session);
- try
- {
- if (session.State == WebSocketState.Open)
- {
- await session.Close();
- }
- session.m_ReceiveData -= ReceivedMessageTimeLimited;
- // session.Close(CloseReason.ServerShutdown);
- }
- catch (Exception ex)
- {
- //logger.LogWarning("Close client socket error!!");
- logger.LogWarning(string.Format("Close client socket error!! {0} Msg:{1}", session.ChargeBoxId, ex.Message));
- }
- if (session != null)
- {
- session = null;
- }
- }
- private void RemoveClientDic(WsClientData session)
- {
- if (string.IsNullOrEmpty(session.ChargeBoxId))
- {
- return;
- }
- if (clientDic.ContainsKey(session.ChargeBoxId))
- {
- if (clientDic[session.ChargeBoxId].SessionID == session.SessionID)
- {
- logger.LogDebug(String.Format("ChargeBoxId:{0} Remove SessionId:{1} Removed SessionId:{2}", session.ChargeBoxId, session.SessionID, clientDic[session.ChargeBoxId].SessionID));
- clientDic.Remove(session.ChargeBoxId, out _);
- logger.LogTrace("RemoveClient ContainsKey " + session.ChargeBoxId);
- }
- }
- }
- private void WarmUpLog()
- {
- connectionLogdbService.WarmUpLog();
- }
- private void WriteMachineLog(WsClientData WsClientData, string data, string messageType, string errorMsg = "", bool isSent = false)
- {
- try
- {
- if (WsClientData == null || string.IsNullOrEmpty(data)) return;
- if (WsClientData.ChargeBoxId == null)
- {
- logger.LogCritical(WsClientData.Path.ToString() + "]********************session ChargeBoxId null sessionId=" + WsClientData.SessionID);
- }
- connectionLogdbService.WriteMachineLog(WsClientData, data, messageType, errorMsg, isSent);
- }
- catch (Exception ex)
- {
- //Console.WriteLine(ex.ToString());
- logger.LogError(ex,ex.Message);
- }
- }
- }
- }
|