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;

namespace TestTool.RemoteTriggerAPP
{
    /// <summary>
    /// MainWindow.xaml 的互動邏輯
    /// </summary>
    public partial class MainWindow : Window
    {
        string action = "";
        List<PublishVersion> publishes = new List<PublishVersion>();
        FTPClient UploadClient = new FTPClient(@"ftp://test.evsocket.phihong.com.cn", "testocpp", "testocpp");
        string chargingProfilePath = System.IO.Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "chargingProfile.json");
        int selectedPublish = -1;
        public MainWindow()
        {

            InitializeComponent();
            UploadClient.OnUploadProgress += UploadClient_OnUploadProgress;

        }


        private void UxSubmitBtn_Click(object sender, RoutedEventArgs e)
        {

            switch (action)
            {
                #region Core Profile
                case "ChangeAvailability_Inoperative":
                    {
                        SetChangeAvailability_Inoperative();
                    }
                    break;
                case "ChangeAvailability_Operative":
                    {
                        SetChangeAvailability_Operative();
                    }
                    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 "HardReset":
                    {
                        SetHardReset();
                    }
                    break;
                case "SoftReset":
                    {
                        SetSoftReset();
                    }
                    break;
                case "UnlockConnector":
                    {
                        SetUnlockConnector();
                    }

                    break;
                #endregion
                #region Local Authorization
                case "GetLocalListVersion":
                    {
                        GetLocalListVersion();
                    }
                    break;
                case "SendLocalAuthorizationList_Full":
                    {
                        SendLocalAuthorizationList(true);
                    }
                    break;
                case "SendLocalAuthorizationList_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 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 = 300
                };

                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 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("yyMMddHHmm")),

                    };

                    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 ? "ftp://evseocpp:evseocpp@test.evsocket.phihong.com.cn/" : "http://test.evsocket.phihong.com.cn:9003/api/file/"),
                    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 uuid = Guid.NewGuid().ToString();
                var request = new SendLocalListRequest()
                {
                    listVersion = Convert.ToInt32(DateTime.Now.ToUniversalTime().ToString("yyMMddHHmm")),
                    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
                    }
                });

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

                for (int i = 0; i < 23; 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 = byte.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 = byte.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 = byte.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 = byte.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)
        {
            using (var db = new MainDBContext())
            {
                db.MachineOperateRecord.Add(new MachineOperateRecord()
                {
                    CreatedOn = DateTime.Now.ToUniversalTime(),
                    ChargeBoxId = uxChargeBoxIdTb.Text,
                    SerialNo = uuid,
                    RequestContent = JsonConvert.SerializeObject(request, new JsonSerializerSettings() { NullValueHandling = NullValueHandling.Ignore, Formatting = Formatting.None }),
                    EVSE_Status = 0,
                    Status = 0,
                    RequestType = 1,
                    Action = request.Action.ToString()

                });

                db.ServerMessage.Add(new ServerMessage()
                {
                    ChargeBoxId = uxChargeBoxIdTb.Text,
                    CreatedBy = "TestTool",
                    CreatedOn = DateTime.Now.ToUniversalTime(),
                    OutAction = request.Action.ToString(),
                    OutRequest = 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;
            }

            FileInfo f = new FileInfo(uxUploadFileTb.Text);

            int size = (int)f.Length;
            string md5 = "";
            string filePreUrl = ConfigurationManager.AppSettings["FilePreUrl"];
            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();
            ufObj.FileName = md5 + ufObj.FileExtensionName;
            ufObj.FilePath = "~/UploadFiles/Fw/" + ufObj.FileName;
            ufObj.FileSize = size;
            ufObj.FileMD5 = md5;
            ufObj.CustomerId = new Guid("8456AED9-6DD9-4BF3-A94C-9F5DCB9506F7");
            ufObj.OriginName = System.IO.Path.GetFileName(uxUploadFileTb.Text);
            ufObj.FileUrl = new Uri(Properties.Settings.Default.FilePreUrl + ufObj.FilePath.Replace("~/", "")).ToString();
            ufObj.IsOnline = true;

            using (var db = new MainDBContext())
            {
                db.UploadFile.Add(ufObj);
                db.SaveChanges();
                var pvQry = db.PublishVersion.Where(x => x.CustomerMachineComponentId == 1).OrderByDescending(c => c.Version).FirstOrDefault();
                PublishVersion pv = new PublishVersion { CustomerMachineComponentId = 1, CreatedOn = DateTime.Now.ToUniversalTime(), Version = 1 };
                if (pvQry != null)
                {
                    pv.Version = pvQry.Version + 1;
                }
                pv.PublishVersionFiles.Add(new PublishVersionFile() { UploadFileId = ufObj.Id });
                db.PublishVersion.Add(pv);
                db.SaveChanges();
            }

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

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










        }

        private async Task UploadTask(string filePath, string fileName)
        {

            bool uploadResult = UploadClient.FtpUploadBroken(filePath, @"ftp://test.evsocket.phihong.com.cn/" + 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");


            }));




        }

        private void UploadClient_OnUploadProgress(double percent)
        {
            Dispatcher.BeginInvoke(new Action(() =>
            {
                uxMsgTb.Text = "Current Progress :" + (int)percent + " %";

            }));
        }

        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();
            ufObj.FileName = md5 + ufObj.FileExtensionName;
            ufObj.FilePath = "~/UploadFiles/Fw/" + ufObj.FileName;
            ufObj.FileSize = size;
            ufObj.FileMD5 = md5;
            ufObj.CustomerId = new Guid("8456AED9-6DD9-4BF3-A94C-9F5DCB9506F7");
            ufObj.OriginName = System.IO.Path.GetFileName(uxUploadFileTb.Text);
            ufObj.FileUrl = new Uri(Properties.Settings.Default.FTPFilePreUrl + ufObj.FileName).ToString();
            ufObj.IsOnline = true;


            using (var db = new MainDBContext())
            {
                db.UploadFile.Add(ufObj);
                db.SaveChanges();
                var pvQry = db.PublishVersion.Where(x => x.CustomerMachineComponentId == 1).OrderByDescending(c => c.Version).FirstOrDefault();
                PublishVersion pv = new PublishVersion { CustomerMachineComponentId = 1, CreatedOn = DateTime.Now.ToUniversalTime(), Version = 1 };
                if (pvQry != null)
                {
                    pv.Version = pvQry.Version + 1;
                }
                pv.PublishVersionFiles.Add(new PublishVersionFile() { UploadFileId = ufObj.Id });
                db.PublishVersion.Add(pv);
                db.SaveChanges();
            }



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

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


        }


        private void uxRefreshBtn_Click(object sender, RoutedEventArgs e)
        {
            using (var db = new MainDBContext())
            {
                publishes = db.PublishVersion
                   .Include(c => c.PublishVersionFiles)
                   .Include(c => c.PublishVersionFiles.Select(z => z.UploadFile))
                   .Include(c => c.CustomerMachineComponent)
                   .Include(c => c.CustomerMachineComponent.MachineComponent)
                   .Include(c => c.CustomerMachineComponent.MachineComponent.MachineModel)
                   .Include(c => c.CustomerMachineComponent.MachineComponent.MachinePart)
                   .Where(c => c.CustomerMachineComponent.CustomerId == new Guid("8456AED9-6DD9-4BF3-A94C-9F5DCB9506F7") && c.CustomerMachineComponent.Id == 1 && c.CustomerMachineComponent.Id == 1).OrderByDescending(c => c.Id).Take(20).ToList();

                StringBuilder sb = new StringBuilder();
                uxPublishCb.Items.Clear();
                foreach (var i in publishes)
                {
                    string prefix = i.PublishVersionFiles.FirstOrDefault().UploadFile.FileUrl.StartsWith("ftp") ? "FTP" : "HTTP";
                    sb.Clear();
                    sb.Append(string.Format("[{0}]", prefix));
                    sb.Append("_版本號:");
                    sb.Append(i.Version);
                    sb.Append("_上傳日期:");
                    sb.Append(i.PublishVersionFiles.First().UploadFile.CreatedOn.ToString());
                    sb.Append("_檔名:");
                    foreach (var f in i.PublishVersionFiles)
                    {
                        sb.Append(f.UploadFile.OriginName);
                        sb.Append("、");
                    }
                    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();
                MachineVersion obj = new MachineVersion()
                {
                    MachineId = machine.Id,
                    PublishVersionId = publishes[selectedPublish].Id,
                    CreatedOn = DateTime.Now.ToUniversalTime()
                };

                obj.MachineVersionFiles.Add(new MachineVersionFile()
                {
                    UploadFileId = publishes[selectedPublish].PublishVersionFiles.First().UploadFileId,
                    CreatedOn = DateTime.Now.ToUniversalTime()
                });
                db.MachineVersion.Add(obj);

                //將machine的軟體更新更新到這個值

                machine.FW_AssignedVersion = publishes[selectedPublish].Version;
                machine.FW_MachineVersion = obj;

                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;
                machine.FW_AssignedMachineVersionId = null;
                db.SaveChanges();
            }

            uxMsgTb.Text = "Clear Publish";

        }


    }
}