EVCB_OCPP.OCPPServer.16J/EVCB_OCPP.WSServer/Jobs/ServerWeatherNotificationJob.cs

using EVCB_OCPP.Domain.Models.Database;
using EVCB_OCPP.WSServer.Dto;
using EVCB_OCPP.WSServer.Message;
using Newtonsoft.Json.Linq;
using Newtonsoft.Json;
using OCPPServer.Protocol;
using Quartz;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.Http;
using System.Text;
using System.Threading.Tasks;
using EVCB_OCPP.WSServer.Service;
using Microsoft.Extensions.Logging;
using EVCB_OCPP.Domain;
using Microsoft.EntityFrameworkCore;
using EVCB_OCPP.Packet.Features;
using EVCB_OCPP.Packet.Messages.Core;

namespace EVCB_OCPP.WSServer.Jobs
{
    [DisallowConcurrentExecution]
    public class ServerWeatherNotificationJob : IJob
    {
        public ServerWeatherNotificationJob(
            ProtalServer protalServer,
            IDbContextFactory<MainDBContext> maindbContextFactory,
            ILogger<ServerWeatherNotificationJob> logger)
        {
            this.protalServer = protalServer;
            this.maindbContextFactory = maindbContextFactory;
            this.logger = logger;
        }

        private readonly ProtalServer protalServer;
        private readonly IDbContextFactory<MainDBContext> maindbContextFactory;
        private readonly ILogger<ServerWeatherNotificationJob> logger;
        private OuterHttpClient httpClient = new OuterHttpClient();

        public async Task Execute(IJobExecutionContext context)
        {
            logger.LogDebug("{0} Started", nameof(ServerWeatherNotificationJob));
            // Console.WriteLine("in...............ServerWeatherNotificationTrigger");
            BasicMessageHandler msgAnalyser = new BasicMessageHandler();
            Dictionary<string, ClientData> _copyClientDic = protalServer.ClientDic;
            var _CheckWeatherDt = DateTime.UtcNow;

            var locations = _copyClientDic.Where(x => !string.IsNullOrEmpty(x.Value.StationLocation)).Distinct().Select(x => x.Value.StationLocation).ToList();

            // Console.WriteLine("in...............ServerWeatherNotificationTrigger");
            foreach (var location in locations)
            {
                try
                {   //query weather
                    var httpResult = await httpClient.GetWeather("https://api.weatherapi.com/v1/current.json?key=874346abc0874e69a9423510222201&q=" + location, null, null);

                    string temp = "17";
                    string weather_code = "1183";
                    if (httpResult.Status == System.Net.HttpStatusCode.OK)
                    {
                        try
                        {
                            var jsonResult = JsonConvert.DeserializeObject(httpResult.Response) as JObject;
                            temp = jsonResult["current"]["temp_c"].ToString();
                            weather_code = jsonResult["current"]["condition"]["code"].ToString();


                        }
                        catch (Exception ex)
                        {
                            ;
                        }

                    }

                    #region 台泥氣象Mapping
                    switch (weather_code)
                    {
                        case "1000":
                            weather_code = "1";
                            break;
                        case "1003":
                        case "1006":
                        case "1009":
                            weather_code = "2";
                            break;
                        case "1063":
                        case "1072":
                        case "1150":
                        case "1153":
                        case "1168":
                        case "1171":
                        case "1180":
                        case "1183":
                        case "1186":
                        case "1189":
                        case "1192":
                        case "1195":
                        case "1198":
                        case "1201":
                        case "1237":
                        case "1240":
                        case "1243":
                        case "1246":
                        case "1261":
                        case "1264":
                            weather_code = "3";
                            break;
                        case "1087":
                        case "1273":
                        case "1276":
                        case "1279":
                        case "1282":
                            weather_code = "4";
                            break;
                        case "1066":
                        case "1069":
                        case "1114":
                        case "1117":
                        case "1204":
                        case "1207":
                        case "1210":
                        case "1213":
                        case "1216":
                        case "1219":
                        case "1222":
                        case "1225":
                        case "1249":
                        case "1252":
                        case "1255":
                        case "1258":
                            weather_code = "5";
                            break;
                        case "1030":
                        case "1135":
                        case "1147":
                            weather_code = "2";
                            break;
                        default:
                            weather_code = "2";
                            break;
                    }
                    #endregion


                    if (protalServer.TCCStationDic.ContainsKey(location))
                    {
                        protalServer.TCCStationDic[location].Temperature = (int)double.Parse(temp);
                        protalServer.TCCStationDic[location].WeatherID = int.Parse(weather_code);
                    }
                    else
                    {
                        protalServer.TCCStationDic.Add(location, new TCCWeatherDto() { WeatherID = int.Parse(weather_code), Temperature = (int)double.Parse(temp) });
                    }

                }
                catch (Exception ex)
                {
                    logger.LogError("ServerWeatherNotificationTrigger ChargeBoxId:{0}  Ex:{1}", location, ex.ToString());
                }
            }

            var clients = _copyClientDic.Where(x => x.Value.CustomerId == new Guid("009E603C-79CD-4620-A2B8-D9349C0E8AD8")).
            Select(x => new { ChargeBoxId = x.Value.ChargeBoxId, StationLocation = x.Value.StationLocation }).ToList();

            using (var db = await maindbContextFactory.CreateDbContextAsync())
            {

                foreach (var client in clients)
                {
                    try
                    {
                        if (string.IsNullOrEmpty(client.StationLocation))
                        {
                            Console.WriteLine(client.StationLocation + " is empty");
                            continue;
                        }


                        if (protalServer.TCCStationDic.ContainsKey(client.StationLocation))
                        {
                            db.ServerMessage.Add(new ServerMessage()
                            {
                                ChargeBoxId = client.ChargeBoxId,
                                CreatedBy = "Server",
                                CreatedOn = DateTime.UtcNow,
                                OutAction = Actions.DataTransfer.ToString(),
                                OutRequest = JsonConvert.SerializeObject(
                                                   new DataTransferRequest()
                                                   {
                                                       messageId = "ID_Weather_Info",
                                                       vendorId = "Phihong Technology",
                                                       data = JsonConvert.SerializeObject(
                                                           new
                                                           {
                                                               weatherId = protalServer.TCCStationDic[client.StationLocation].WeatherID,
                                                               Temperature = protalServer.TCCStationDic[client.StationLocation].Temperature
                                                           })
                                                   },
                                                   new JsonSerializerSettings() { NullValueHandling = NullValueHandling.Ignore, Formatting = Formatting.None }),
                                SerialNo = Guid.NewGuid().ToString(),
                                InMessage = string.Empty

                            });

                            await db.SaveChangesAsync();
                        }
                    }
                    catch (Exception ex)
                    {
                        logger.LogError("ServerWeatherNotificationTrigger ChargeBoxId:{0}  Ex:{1}", client.ChargeBoxId, ex.ToString());
                    }
                }
            }
        }
    }
}