EVCB_OCPP.OCPPServer.16J/TestTool.RemoteTriggerAPP/MainWindow.xaml.cs

using EVCB_OCPP.Domain;
using EVCB_OCPP.Domain.Models.Database;
using EVCB_OCPP.Packet.Features;
using EVCB_OCPP.Packet.Messages;
using EVCB_OCPP.Packet.Messages.Core;
using Microsoft.Win32;
using Newtonsoft.Json;
using OCPPPackage.Profiles;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.IO;
using System.Linq;
using System.Net;
using System.Security.Cryptography;
using System.Text;
using System.Threading.Tasks;
using System.Windows;
using System.Windows.Controls;
using System.Windows.Data;
using System.Windows.Documents;
using System.Windows.Input;
using System.Windows.Media;
using System.Windows.Media.Imaging;
using System.Windows.Navigation;
using System.Windows.Shapes;
using System.Data.Entity;
using EVCB_OCPP.Packet.Messages.RemoteTrigger;
using EVCB_OCPP.Packet.Messages.SubTypes;
using EVCB_OCPP.Packet.Messages.LocalAuthListManagement;
using EVCB_OCPP.Packet.Messages.FirmwareManagement;
using EVCB_OCPP.Packet.Messages.Reservation;
using EVCB_OCPP.Packet.Messages.SmartCharging;
using System.Threading;
using System.Net.Http;
using Newtonsoft.Json.Converters;

namespace TestTool.RemoteTriggerAPP
{
    /// <summary>
    /// MainWindow.xaml 的互動邏輯
    /// </summary>
    public partial class MainWindow : Window
    {




        string action = "";
        List<UploadFile> publishes = new List<UploadFile>();

        string chargingProfilePath = System.IO.Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "SetChargingProfile.json");
        string dataTransferPath = System.IO.Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "DataTransfer.json");
        int selectedPublish = -1;
        bool isDestroyMode = false;
        public MainWindow()
        {

            InitializeComponent();
            Loaded += MainWindow_Loaded;


        }

        private void MainWindow_Loaded(object sender, RoutedEventArgs e)
        {
            uxChargeBoxIdTb.Text = Properties.Settings.Default.ChargeBoxId;
        }

        private void UxSubmitBtn_Click(object sender, RoutedEventArgs e)
        {
            if (isDestroyMode)
            {
                try
                {
                    string actualAction = action.Split(new char[] { '_', '(' })[0];
                    var uuid = Guid.NewGuid().ToString();
                    WritetoDB(uuid, null, actualAction, GetDestroyVersionData(actualAction));
                    uxMsgTb.Text = string.Format("Send Actions: {0} UUID:{1}", actualAction, uuid);

                }
                catch (Exception ex)
                {
                    MessageBox.Show(ex.ToString());
                }

            }
            else
            {
                switch (action)
                {

                    #region Core Profile
                    case "ChangeAvailability_Inoperative":
                        {
                            SetChangeAvailability_Inoperative();
                        }
                        break;
                    case "ChangeAvailability_Operative":
                        {
                            SetChangeAvailability_Operative();
                        }
                        break;
                    case "DataTransfer":
                        {
                            var request = VerifyDataTransfer(dataTransferPath);
                            SetDataTransfer(request);
                        }
                        break;
                    case "GetConfiguration":
                        {
                            if (uxConfigKeyTb.Text == "")
                            {
                                SetGetConfiguration_ALL();
                            }
                            else
                            {
                                SetGetConfiguration();
                            }

                        }
                        break;
                    case "ChangeConfiguration":
                        {
                            SetChangeConfiguration();

                        }
                        break;
                    case "ClearCache":
                        {
                            SetClearCache();
                        }
                        break;
                    case "RemoteStartTransaction":
                        {
                            SetRemoteStartTransaction();
                        }
                        break;
                    case "RemoteStartTransaction_ChargingProfile":
                        {
                            var chargingProfile = VerifyChargingProfile(chargingProfilePath);
                            if (chargingProfile != null)
                            {
                                SetRemoteStartTransaction(chargingProfile);
                            }
                            else
                            {
                                uxMsgTb.Text = "Please check chargingProfile.json exist in " + AppDomain.CurrentDomain.BaseDirectory;
                            }

                        }
                        break;
                    case "RemoteStopTransaction":
                        {
                            SetRemoteStopTransaction();
                        }
                        break;
                    case "Reset_HardReset":
                        {
                            SetHardReset();
                        }
                        break;
                    case "Reset_SoftReset":
                        {
                            SetSoftReset();
                        }
                        break;
                    case "UnlockConnector":
                        {
                            SetUnlockConnector();
                        }

                        break;
                    #endregion
                    #region Local Authorization
                    case "GetLocalListVersion":
                        {
                            GetLocalListVersion();
                        }
                        break;
                    case "SendLocalList_Full":
                        {
                            SendLocalAuthorizationList(true);
                        }
                        break;
                    case "SendLocalList_Diff":
                        {
                            SendLocalAuthorizationList(false);
                        }
                        break;
                    #endregion
                    case "GetDiagnostics_FTP":
                        {
                            GetDiagnostics(true);
                        }
                        break;
                    case "GetDiagnostics_HTTP":
                        {
                            GetDiagnostics(false);
                        }
                        break;
                    case "ReserveNow":
                        {
                            ReserveNow();
                        }
                        break;
                    case "CancelReservation":
                        {
                            CancelReservation();
                        }
                        break;
                    case "ClearChargingProfile":
                        {
                            ClearChargingProfile();
                        }
                        break;
                    case "GetCompositeSchedule":
                        {
                            GetCompositeSchedule();
                        }
                        break;
                    case "SetChargingProfile":
                        {
                            var chargingProfile = VerifyChargingProfile(chargingProfilePath);
                            if (chargingProfile != null)
                            {
                                SetChargingProfile(chargingProfile);
                            }
                            else
                            {
                                uxMsgTb.Text = "Please check chargingProfile.json exist in " + AppDomain.CurrentDomain.BaseDirectory;
                            }

                            //SetChargingProfile(new SetChargingProfileRequest()
                            //{
                            //    connectorId = 0,
                            //    csChargingProfiles = new csChargingProfiles()
                            //    {
                            //        chargingProfileId = 1,
                            //        chargingProfileKind = ChargingProfileKindType.Recurring,
                            //        chargingProfilePurpose = ChargingProfilePurposeType.ChargePointMaxProfile,
                            //        chargingSchedule = new ChargingSchedule()
                            //        {
                            //            chargingRateUnit = ChargingRateUnitType.W,
                            //            chargingSchedulePeriod = new List<ChargingSchedulePeriod>()
                            //                            {
                            //                                new ChargingSchedulePeriod(){  startPeriod=0, limit=int.Parse(uxConfigValueTb.Text)}
                            //                            },


                            //        },
                            //        recurrencyKind = RecurrencyKindType.Daily,
                            //        stackLevel = 1,

                            //    }
                            //});

                        }
                        break;

                    #region Trigger Profile
                    case "TriggerMessage_BootNotification":
                    case "TriggerMessage_DiagnosticsStatusNotification":
                    case "TriggerMessage_FirmwareStatusNotification":
                    case "TriggerMessage_Heartbeat":
                    case "TriggerMessage_MeterValues":
                    case "TriggerMessage_StatusNotification":
                        {
                            SetRemoteTrigger(action);
                        }
                        break;
                    #endregion
                    default:
                        break;

                }
            }

        }

        private void SetDataTransfer(DataTransferRequest request)
        {
            try
            {
                var uuid = Guid.NewGuid().ToString();

                WritetoDB(uuid, request);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }

        private DataTransferRequest VerifyDataTransfer(string path)
        {
            DataTransferRequest request = null;

            if (!File.Exists(path)) return request;

            try
            {
                request = JsonConvert.DeserializeObject<DataTransferRequest>(File.ReadAllText(path));
            }
            catch
            {

            }
            return request;
        }

        private SetChargingProfileRequest VerifyChargingProfile(string path)
        {
            SetChargingProfileRequest request = null;

            if (!File.Exists(path)) return request;

            try
            {
                request = JsonConvert.DeserializeObject<SetChargingProfileRequest>(File.ReadAllText(path));
            }
            catch
            {

            }
            return request;
        }


        private void SetChargingProfile(SetChargingProfileRequest csProfile)
        {
            try
            {

                var uuid = Guid.NewGuid().ToString();

                WritetoDB(uuid, csProfile);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }

        private void GetCompositeSchedule()
        {
            try
            {

                var uuid = Guid.NewGuid().ToString();
                var request = new GetCompositeScheduleRequest()
                {
                    connectorId = Convert.ToInt32(uxConnectorIdTb.Text),
                    duration = 10000
                };

                WritetoDB(uuid, request);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }

        private void ClearChargingProfile()
        {
            try
            {

                var uuid = Guid.NewGuid().ToString();
                var request = new ClearChargingProfileRequest()
                {
                    connectorId = Convert.ToInt32(uxConnectorIdTb.Text),

                };

                WritetoDB(uuid, request);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }

        private void CancelReservation()
        {

            try
            {

                var uuid = Guid.NewGuid().ToString();
                var request = new CancelReservationRequest()
                {
                    reservationId = Convert.ToInt32(uxReservationTb.Text),
                };

                WritetoDB(uuid, request);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }

        private void SetWrongAction()
        {
            bool isError = false;
            DateTime expiryTime = DateTime.Now;
            try
            {
                try
                {
                    expiryTime = Convert.ToDateTime(uxExpiryTimeTb.Text);
                    //if (expiryTime < DateTime.Now.AddSeconds(60))
                    //{
                    //    isError = true;
                    //    uxMsgTb.Text = string.Format("ExpiryTime is too close or too early to the current time (60 seconds).");
                    //}

                }
                catch (Exception ex)
                {
                    if (ex is FormatException)
                    {
                        isError = true;
                        uxMsgTb.Text = string.Format("ExpiryTime's Format is wrong Example:{0}", DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
                    }
                }
                if (!isError)
                {
                    var uuid = Guid.NewGuid().ToString();
                    var request = new ReserveNowRequest()
                    {
                        connectorId = Convert.ToInt32(uxConnectorIdTb.Text),
                        expiryDate = expiryTime.ToUniversalTime(),
                        idTag = uxIdTagTb.Text,
                        parentIdTag = "PTAG",
                        reservationId = Convert.ToInt32(expiryTime.ToUniversalTime().ToString("yyMMddHHmm")),

                    };

                    WritetoDB(uuid, request);
                    uxMsgTb.Text = string.Format("UUID:{0}", uuid);
                }

            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }

        private void ReserveNow()
        {
            bool isError = false;
            DateTime expiryTime = DateTime.Now;
            try
            {
                try
                {
                    expiryTime = Convert.ToDateTime(uxExpiryTimeTb.Text);
                    //if (expiryTime < DateTime.Now.AddSeconds(60))
                    //{
                    //    isError = true;
                    //    uxMsgTb.Text = string.Format("ExpiryTime is too close or too early to the current time (60 seconds).");
                    //}

                }
                catch (Exception ex)
                {
                    if (ex is FormatException)
                    {
                        isError = true;
                        uxMsgTb.Text = string.Format("ExpiryTime's Format is wrong Example:{0}", DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"));
                    }
                }
                if (!isError)
                {
                    var uuid = Guid.NewGuid().ToString();
                    var request = new ReserveNowRequest()
                    {
                        connectorId = Convert.ToInt32(uxConnectorIdTb.Text),
                        expiryDate = expiryTime.ToUniversalTime(),
                        idTag = uxIdTagTb.Text,
                        parentIdTag = "PTAG",
                        reservationId = Convert.ToInt32(expiryTime.ToUniversalTime().ToString("MMddHHmm")),

                    };

                    WritetoDB(uuid, request);
                    uxMsgTb.Text = string.Format("UUID:{0}", uuid);
                }

            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }

        private void GetDiagnostics(bool ftp)
        {
            try
            {

                var uuid = Guid.NewGuid().ToString();
                var request = new GetDiagnosticsRequest()
                {

                    location = new Uri(ftp ? Properties.Settings.Default.FTPGetDiagnosticsPreUrl : Properties.Settings.Default.GetDiagnosticsPreUrl),
                    retries = 1,
                    retryInterval = 30,
                    startTime = DateTime.Now.AddHours(-1).ToUniversalTime(),
                    stopTime = DateTime.Now.ToUniversalTime()


                };

                WritetoDB(uuid, request);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }

        #region Local Authorization

        private void GetLocalListVersion()
        {
            try
            {

                var uuid = Guid.NewGuid().ToString();
                var request = new GetLocalListVersionRequest()
                {

                };

                WritetoDB(uuid, request);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }

        private void SendLocalAuthorizationList(bool isFull)
        {
            try
            {
                var size = Convert.ToInt32(uxLocalListSizeTb.Text);
                var uuid = Guid.NewGuid().ToString();
                var request = new SendLocalListRequest()
                {
                    listVersion = Convert.ToInt32(DateTimeOffset.Now.AddDays(-50).ToUnixTimeSeconds()),
                    updateType = isFull ? UpdateType.Full : UpdateType.Differential,
                    localAuthorizationList = new List<AuthorizationData>()
                    //localAuthorizationList = new List<AuthorizationData>()
                    //{
                    //     new AuthorizationData()
                    //     {

                    //          idTagInfo=new IdTagInfo(){  expiryDate=DateTime.Now.ToUniversalTime().AddDays(3), status=  AuthorizationStatus.Accepted},
                    //           idTag="F5902677"
                    //     }, new AuthorizationData()
                    //     {
                    //          idTagInfo=new IdTagInfo(){  expiryDate=DateTime.Now.ToUniversalTime().AddDays(3), status=  AuthorizationStatus.Expired},
                    //           idTag="772690F5"
                    //     }
                    //}

                };

                //request.localAuthorizationList.Add(new AuthorizationData()
                //{
                //    idTag = "F5902677",
                //    idTagInfo = new IdTagInfo()
                //    {
                //        parentIdTag = "0000000000000000001",
                //        expiryDate = DateTime.UtcNow.AddMonths(1),
                //        status = AuthorizationStatus.ConcurrentTx
                //    }
                //});


                for (int i = 0; i < size; i++)
                {
                    request.localAuthorizationList.Add(new AuthorizationData()
                    {
                        idTag = DateTime.Now.ToString("yyyyMMddHHmmss" + i.ToString("00000")),
                        idTagInfo = new IdTagInfo()
                        {
                            parentIdTag = "0000000000000000001",
                            expiryDate = DateTime.UtcNow.AddMonths(1),
                            status = AuthorizationStatus.Accepted
                        }

                    });

                }


                WritetoDB(uuid, request);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }
        #endregion


        private void SetRemoteTrigger(string action)
        {
            try
            {
                string type = action.Split('_').Last();
                var uuid = Guid.NewGuid().ToString();
                var request = new TriggerMessageRequest()
                {
                    requestedMessage = (MessageTrigger)Enum.Parse(typeof(MessageTrigger), type, false)
                };

                WritetoDB(uuid, request);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }

        private void SetGetConfiguration()
        {
            try
            {
                string uuid = Guid.NewGuid().ToString();
                var request = new GetConfigurationRequest()
                {
                    key = uxConfigKeyTb.Text.Split('/').ToList()
                };

                WritetoDB(uuid, request);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }

        private void UxCmdCb_SelectionChanged(object sender, SelectionChangedEventArgs e)
        {

            var item = uxCmdCb.SelectedValue as ComboBoxItem;
            action = item.Content as string;

        }


        private void SetRemoteStartTransaction(SetChargingProfileRequest csProfile = null)
        {
            try
            {
                var uuid = Guid.NewGuid().ToString();
                var request = new RemoteStartTransactionRequest()
                {
                    connectorId = int.Parse(uxConnectorIdTb.Text),
                    idTag = uxIdTagTb.Text

                };
                if (csProfile != null)
                {
                    request.chargingProfile = csProfile.csChargingProfiles;
                }

                WritetoDB(uuid, request);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }

        private void SetUnlockConnector()
        {
            try
            {
                var uuid = Guid.NewGuid().ToString();
                var request = new UnlockConnectorRequest()
                {
                    connectorId = int.Parse(uxConnectorIdTb.Text),

                };

                WritetoDB(uuid, request);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }

        private void SetChangeAvailability_Inoperative()
        {
            try
            {
                var uuid = Guid.NewGuid().ToString();
                var request = new ChangeAvailabilityRequest()
                {
                    connectorId = int.Parse(uxConnectorIdTb.Text),
                    type = EVCB_OCPP.Packet.Messages.SubTypes.AvailabilityType.Inoperative
                };

                WritetoDB(uuid, request);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }

        private void SetChangeAvailability_Operative()
        {
            try
            {
                var uuid = Guid.NewGuid().ToString();
                var request = new ChangeAvailabilityRequest()
                {
                    connectorId = int.Parse(uxConnectorIdTb.Text),
                    type = EVCB_OCPP.Packet.Messages.SubTypes.AvailabilityType.Operative
                };

                WritetoDB(uuid, request);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }




        private void SetChangeConfiguration()
        {
            try
            {
                var uuid = Guid.NewGuid().ToString();
                var request = new ChangeConfigurationRequest()
                {
                    key = uxConfigKeyTb.Text,
                    value = uxConfigValueTb.Text,

                };

                WritetoDB(uuid, request);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }

        private void SetClearCache()
        {
            try
            {
                var uuid = Guid.NewGuid().ToString();
                var request = new ClearCacheRequest()
                {

                };

                WritetoDB(uuid, request);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }



        private void SetGetConfiguration_ALL()
        {
            try
            {
                var uuid = Guid.NewGuid().ToString();
                var request = new GetConfigurationRequest()
                {
                    key = new List<string>() { }
                };

                WritetoDB(uuid, request);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }



        private void SetHardReset()
        {
            try
            {
                var uuid = Guid.NewGuid().ToString();
                var request = new ResetRequest()
                {
                    type = EVCB_OCPP.Packet.Messages.SubTypes.ResetType.Hard
                };

                WritetoDB(uuid, request);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }

        private void SetSoftReset()
        {
            try
            {
                var uuid = Guid.NewGuid().ToString();
                var request = new ResetRequest()
                {
                    type = EVCB_OCPP.Packet.Messages.SubTypes.ResetType.Soft
                };

                WritetoDB(uuid, request);
                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }

        private void SetRemoteStopTransaction()
        {
            try
            {
                var uuid = Guid.NewGuid().ToString();
                var request = new RemoteStopTransactionRequest()
                {
                    transactionId = int.Parse(uxTransactionIdTb.Text)
                };

                WritetoDB(uuid, request);

                uxMsgTb.Text = string.Format("UUID:{0}", uuid);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }



        private void WritetoDB(string uuid, IRequest request, string action = "", string destroyData = "")
        {
            using (var db = new MainDBContext())
            {
                db.MachineOperateRecord.Add(new MachineOperateRecord()
                {
                    CreatedOn = DateTime.Now.ToUniversalTime(),
                    ChargeBoxId = uxChargeBoxIdTb.Text,
                    SerialNo = uuid,
                    RequestContent = !string.IsNullOrEmpty(destroyData) ? destroyData : JsonConvert.SerializeObject(request, new JsonSerializerSettings() { NullValueHandling = NullValueHandling.Ignore, Formatting = Formatting.None }),
                    EVSE_Status = 0,
                    Status = 0,
                    RequestType = 1,
                    Action = !string.IsNullOrEmpty(destroyData) ? action : request.Action.ToString()

                });

                db.ServerMessage.Add(new ServerMessage()
                {
                    ChargeBoxId = uxChargeBoxIdTb.Text,
                    CreatedBy = !string.IsNullOrEmpty(destroyData) ? "Destroyer" : "TestTool",
                    CreatedOn = DateTime.Now.ToUniversalTime(),
                    OutAction = !string.IsNullOrEmpty(destroyData) ? action : request.Action.ToString(),
                    OutRequest = !string.IsNullOrEmpty(destroyData) ? destroyData : JsonConvert.SerializeObject(request, new JsonSerializerSettings() { NullValueHandling = NullValueHandling.Ignore, Formatting = Formatting.None }),
                    SerialNo = uuid,
                    InMessage = string.Empty

                });

                db.SaveChanges();
            }
        }

        private void uxFileSubmitBtn_Click(object sender, RoutedEventArgs e)
        {
            OpenFileDialog openFileDialog = new OpenFileDialog();
            openFileDialog.Title = "Select file";
            var result = openFileDialog.ShowDialog();
            if (result == true)
            {
                uxUploadFileTb.Text = openFileDialog.FileName;
            }
        }



        private void uxUploadBtn_Click(object sender, RoutedEventArgs e)
        {
            if (string.IsNullOrEmpty(uxUploadFileTb.Text))
            {
                uxMsgTb.Text = "Please select upload file!";
                return;
            }
            string filePath = uxUploadFileTb.Text;



            Task.Run(async () =>
            {

                await UploadTask(filePath, false);
            });
        }

        private async Task UploadTask(string filepath, bool isFTP)
        {
            try
            {
                await Dispatcher.BeginInvoke(new Action(() =>
                {
                    uxMsgTb.Text = "Uploading........";

                }));

                FileInfo f = new FileInfo(filepath);
                int size = (int)f.Length;
                string fileMD5 = "";  //get file md5
                using (var md5 = MD5.Create())
                {
                    using (var stream = File.OpenRead(filepath))
                    {
                        fileMD5 = BitConverter.ToString(md5.ComputeHash(stream)).Replace("-", String.Empty).ToLower();
                    }
                }
                string filePreUrl = isFTP ? Properties.Settings.Default.FTPUpdateFWPreUrl : Properties.Settings.Default.UpdateFWPreUrl;

                UploadFile ufObj = new UploadFile();
                ufObj.CreatedOn = DateTime.Now.ToUniversalTime();
                ufObj.FileExtensionName = System.IO.Path.GetExtension(filepath);
                ufObj.Id = Guid.NewGuid().ToString();
                ufObj.FileName = fileMD5 + System.IO.Path.GetExtension(filepath);
                ufObj.FilePath = isFTP ? "~/" + ufObj.FileName : "~/UploadFiles/FW/" + ufObj.FileName;
                ufObj.FileSize = size;
                ufObj.FileMD5 = fileMD5;
                ufObj.OriginName = System.IO.Path.GetFileName(filepath);
                ufObj.FileUrl = new Uri(filePreUrl + ufObj.FilePath.Replace("~/", "")).ToString();
                ufObj.VendorId = "TestTool";
                ufObj.ModelName = "TestTool";
                ufObj.ModuleId = 0;

                using (var db = new MainDBContext())
                {
                    db.UploadFile.Add(ufObj);
                    await db.SaveChangesAsync();

                }

                FluentFTPClient ftpClient = new FluentFTPClient("ocpp.phihong.com.tw", 5002, "testocpp", "testocpp", "/");
                //Properties.Settings.Default.UpdateFWPreUrl
                bool uploadResult = await ftpClient.UploadFileAsync(filepath, ufObj.FileName);

                await Dispatcher.BeginInvoke(new Action(() =>
                {
                    if (uploadResult)
                    {
                        uxMsgTb.Text = "Current Progress :100 %";
                        Thread.CurrentThread.Join(100);
                    }
                    uxMsgTb.Text = "Upload File Result :" + (uploadResult ? "Success" : "Fail");


                }));

            }
            catch (Exception ex)
            {

            }

        }



        private void uxFTPUploadBtn_Click(object sender, RoutedEventArgs e)
        {
            if (string.IsNullOrEmpty(uxUploadFileTb.Text))
            {
                uxMsgTb.Text = "Please select upload file!";
                return;
            }

            FileInfo f = new FileInfo(uxUploadFileTb.Text);

            int size = (int)f.Length;
            string md5 = "";

            using (WebClient client = new WebClient())
            {
                client.UseDefaultCredentials = false;
                client.Headers.Add("Content-Type", "application/octet-stream");
                using (Stream fileStream = File.OpenRead(uxUploadFileTb.Text))
                {
                    var _md5 = MD5.Create();
                    var hash = _md5.ComputeHash(fileStream);
                    md5 = BitConverter.ToString(hash).Replace("-", String.Empty).ToLowerInvariant();

                }
            }

            UploadFile ufObj = new UploadFile();
            ufObj.CreatedOn = DateTime.Now.ToUniversalTime();
            ufObj.FileExtensionName = System.IO.Path.GetExtension(uxUploadFileTb.Text);
            ufObj.Id = Guid.NewGuid().ToString();
            ufObj.FileName = md5 + ufObj.FileExtensionName;
            ufObj.FilePath = "~/UploadFiles/Fw/" + ufObj.FileName;
            ufObj.FileSize = size;
            ufObj.FileMD5 = md5;
            ufObj.OriginName = System.IO.Path.GetFileName(uxUploadFileTb.Text);
            ufObj.FileUrl = new Uri(Properties.Settings.Default.FTPUpdateFWPreUrl + ufObj.FileName).ToString();
            ufObj.VendorId = "TestTool";
            ufObj.ModelName = "TestTool";
            ufObj.ModuleId = 0;

            using (var db = new MainDBContext())
            {
                db.UploadFile.Add(ufObj);
                db.SaveChanges();

            }



            string filePath = uxUploadFileTb.Text;
            uxMsgTb.Text = "Uploading........";

            Task.Run(async () =>
            {
                await UploadTask(filePath, true);
            });


        }


        private void uxRefreshBtn_Click(object sender, RoutedEventArgs e)
        {
            using (var db = new MainDBContext())
            {
                publishes = db.UploadFile.OrderByDescending(c => c.CreatedOn).Take(20).ToList();

                StringBuilder sb = new StringBuilder();
                uxPublishCb.Items.Clear();
                foreach (var i in publishes)
                {
                    string prefix = i.FileUrl.StartsWith("ftp") ? "FTP" : "HTTP";
                    sb.Clear();
                    sb.Append(string.Format("[{0}]", prefix));
                    sb.Append("_上傳日期:");
                    sb.Append(i.CreatedOn.ToString());
                    sb.Append("_檔名:");
                    sb.Append(i.OriginName);

                    uxPublishCb.Items.Add(sb.ToString());
                    uxPublishCb.SelectedIndex = 0;
                }
            }

        }

        private void uxPublishBtn_Click(object sender, RoutedEventArgs e)
        {
            if (selectedPublish < 0)
            {
                uxMsgTb.Text = "Please choose publish version!";
                return;
            }
            using (var db = new MainDBContext())
            {

                var machine = db.Machine.Where(x => x.ChargeBoxId == uxChargeBoxIdTb.Text).FirstOrDefault();
                MachineVersionFile obj = new MachineVersionFile()
                {
                    ChargeBoxId = uxChargeBoxIdTb.Text,
                    UploadFileId = publishes[selectedPublish].Id,
                    CreatedOn = DateTime.Now.ToUniversalTime()
                };

                db.MachineVersionFile.Add(obj);

                //將machine的軟體更新更新到這個值
                db.SaveChanges();

                machine.FW_AssignedVersion = obj.Id;

                db.SaveChanges();


            }
            uxMsgTb.Text = "Publish Complete";


        }

        private void uxPublishCb_SelectionChanged(object sender, SelectionChangedEventArgs e)
        {
            selectedPublish = uxPublishCb.SelectedIndex;

        }

        private void uxClearPublishBtn_Click(object sender, RoutedEventArgs e)
        {
            using (var db = new MainDBContext())
            {

                var machine = db.Machine.Where(x => x.ChargeBoxId == uxChargeBoxIdTb.Text).FirstOrDefault();
                machine.FW_AssignedVersion = null;
                db.SaveChanges();
            }

            uxMsgTb.Text = "Clear Publish";

        }

        private void uxChargeBoxIdTb_LostFocus(object sender, RoutedEventArgs e)
        {
            Properties.Settings.Default.ChargeBoxId = uxChargeBoxIdTb.Text;
            Properties.Settings.Default.Save();

        }


        private string GetDestroyVersionData(string action)
        {
            string result = "";
            try
            {
                string path = System.IO.Path.Combine(AppDomain.CurrentDomain.BaseDirectory, action + ".json");
                var request = JsonConvert.DeserializeObject(File.ReadAllText(path));
                result = JsonConvert.SerializeObject(request);
            }
            catch (Exception ex)
            {
                uxMsgTb.Text += "解析檔案發生問題 " + ex.ToString();
            }

            return result;
        }

        private void uxDestroyCb_Checked(object sender, RoutedEventArgs e)
        {
            isDestroyMode = true;
            uxConnectorIdTb.IsEnabled = false;
            uxReservationTb.IsEnabled = false;
            uxIdTagTb.IsEnabled = false;
            uxParentIdTagTb.IsEnabled = false;
            uxTransactionIdTb.IsEnabled = false;
            uxLocalListSizeTb.IsEnabled = false;
            uxConfigKeyTb.IsEnabled = false;
            uxConfigValueTb.IsEnabled = false;
            uxExpiryTimeTb.IsEnabled = false;
        }

        private void uxDestroyCb_Unchecked(object sender, RoutedEventArgs e)
        {
            isDestroyMode = false;
            uxConnectorIdTb.IsEnabled = true;
            uxReservationTb.IsEnabled = true;
            uxIdTagTb.IsEnabled = true;
            uxParentIdTagTb.IsEnabled = true;
            uxTransactionIdTb.IsEnabled = true;
            uxLocalListSizeTb.IsEnabled = true;
            uxConfigKeyTb.IsEnabled = true;
            uxConfigValueTb.IsEnabled = true;
            uxExpiryTimeTb.IsEnabled = true;
        }
    }
}