aboutsummaryrefslogtreecommitdiffstats
path: root/Software/Visual_Studio/MachineStudio/Modules/Tango.MachineStudio.Technician/TechItems/ControllerItem.cs
blob: 67266ee66265a8de959e6a0a501b5212b08264cd (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Media;
using System.Xml.Serialization;
using Tango.BL.Entities;
using Tango.SharedUI.Helpers;

namespace Tango.MachineStudio.Technician.TechItems
{
    /// <summary>
    /// Represents a single component value controller and monitor.
    /// </summary>
    /// <seealso cref="TechItem" />
    [TechItem(10)]
    public class ControllerItem : TechItem
    {
        /// <summary>
        /// Occurs when the controller value has changed.
        /// </summary>
        public event EventHandler<double> ValueChanged;

        private TechController _techController;
        /// <summary>
        /// Gets or sets the DB controller item.
        /// </summary>
        [XmlIgnore]
        public TechController TechController
        {
            get { return _techController; }
            set { _techController = value; RaisePropertyChangedAuto(); TechName = _techController != null ? _techController.Description : null; ItemGuid = value != null ? value.Guid : null; }
        }

        private double _value;
        /// <summary>
        /// Gets or sets the component value.
        /// </summary>
        [XmlIgnore]
        public double Value
        {
            get { return _value; }
            set
            {
                _value = value; RaisePropertyChangedAuto();
                ValueChanged?.Invoke(this, _value);
            }
        }

        private int _updateInterval;
        /// <summary>
        /// Gets or sets the update interval.
        /// </summary>
        public int UpdateInterval
        {
            get { return _updateInterval; }
            set { _updateInterval = value; RaisePropertyChangedAuto(); }
        }

        /// <summary>
        /// Gets or sets the last update time.
        /// </summary>
        [XmlIgnore]
        public DateTime LastUpdateTime { get; set; }


        private double _effectiveValue;
        /// <summary>
        /// Gets or sets the effective value received from the embedded device.
        /// </summary>
        [XmlIgnore]
        public double EffectiveValue
        {
            get { return _effectiveValue; }
            set
            {
                LastUpdateTime = DateTime.Now;

                if (_effectiveValue != value)
                {
                    _effectiveValue = value;
                    RaisePropertyChangedAuto();
                }
            }
        }

        /// <summary>
        /// Initializes a new instance of the <see cref="ControllerItem"/> class.
        /// </summary>
        public ControllerItem() : base()
        {
            Name = "Value Controller";
            Description = "Single component value controller";
            Image = ResourceHelper.GetImageFromResources("Images/controller.png");
            Color = Colors.DodgerBlue;
            LastUpdateTime = DateTime.Now;
            UpdateInterval = 10;
        }

        /// <summary>
        /// Initializes a new instance of the <see cref="ControllerItem"/> class.
        /// </summary>
        /// <param name="techController">The db tech controller.</param>
        public ControllerItem(TechController techController) : this()
        {
            TechController = techController;
        }

        /// <summary>
        /// Clones this instance.
        /// </summary>
        /// <returns></returns>
        public override TechItem Clone()
        {
            ControllerItem cloned = base.Clone() as ControllerItem;
            cloned.TechController = TechController;
            return cloned;
        }
    }
}
n class="w"> CmdCommand command = new CmdCommand("sqllocaldb", "start \"MSSQLLocalDB\""); var result = command.Run().Result; command = new CmdCommand("sqllocaldb", "info \"MSSQLLocalDB\""); result = command.Run().Result; String pattern = "np:.+"; Regex reg = new Regex(pattern); var match = reg.Match(result.StandardOutput); String address = match.ToString(); if (address.Contains("np:")) { localDataSource.Address = address; address = address.Trim().Replace("\r", ""); } else { throw new ArgumentException("Could not parse LocalDB address string."); } LogManager.Log($"Trying to connect via LocalDB:\n{localDataSource.ToJsonString()}"); dbManager = DbManager.FromDataSource(localDataSource); } catch (Exception x) { LogManager.Log(x, "Could not find any database service for this operation."); throw x; } } OnProgress("Downloading latest PPC version..."); LogManager.Log("Connecting to machine service..."); MachineStudioWebClient client = TangoIOC.Default.GetInstance<MachineStudioWebClient>(); LogManager.Log("Requesting latest PPC version from machine service..."); var response = client.DownloadLatestPPCVersion(new DownloadLatestPPCVersionRequest() { SerialNumber = serialNumber }).Result; LogManager.Log($"Machine service response:\n{response.ToJsonString()}"); var remoteDataSource = response.DataSource; using (AutoFileDownloader downloader = new AutoFileDownloader(response.BlobAddress, response.CdnAddress, tempZipFile)) { downloader.Progress += (x, e) => { OnProgress($"Downloading latest PPC version '{response.Version}'...", false, e.Current, e.Total); }; downloader.ResolveMode().GetAwaiter().GetResult(); LogManager.Log($"Downloading latest PPC version from: '{downloader.Address}'"); downloader.Download().Wait(); } LogManager.Log("Extracting PPC version package..."); OnProgress("Extracting PPC package..."); using (ZipFile zip = new ZipFile(tempZipFile)) { int currentEntry = 0; zip.ExtractProgress += (x, args) => { if (args.EventType == ZipProgressEventType.Extracting_AfterExtractEntry) { OnProgress("Extracting PPC package...", false, currentEntry++, zip.Entries.Count); } }; zip.ExtractAll(tempPackageFolder); } OnProgress("Extracting version information..."); LogManager.Log("Extracting publish information..."); PublishInfo publishInfo = PublishInfo.FromJson(File.ReadAllText(Path.Combine(tempPackageFolder, "version.json"))); LogManager.Log($"Publish Information:\n{publishInfo}"); LogManager.Log("Modifying publish information to custom tup file..."); publishInfo.IsMachineTupPackage = true; publishInfo.MachineSerialNumber = serialNumber; publishInfo.MachineDeploymentSlot = SettingsManager.Default.GetOrCreate<MachineStudioSettings>().DeploymentSlot; OnProgress("Creating temporary database..."); LogManager.Log($"Creating temporary db backup directory '{tempBackupFolder}'"); Directory.CreateDirectory(tempBackupFolder); LogManager.Log($"Creating new database: '{tempDbName}'"); //Create temp db dbManager.Create(tempDbName, Path.Combine(tempBackupFolder, tempDbName + ".mdf")); OnProgress("Generating database snapshot..."); LogManager.Log("Starting database synchronization..."); Thread.Sleep(2000); localDataSource.Catalog = tempDbName; ExaminerSequenceConfigurationRunner runner = new ExaminerSequenceConfigurationRunner( Path.Combine(tempPackageFolder, "Provision Scripts", "config.xml"), Path.Combine(tempPackageFolder, "Provision Scripts"), remoteDataSource, localDataSource, serialNumber); runner.ScriptExecuting += (x, item) => { LogManager.Log($"Executing script '{item.FileName}'..."); OnProgress($"{item.Name}..."); }; runner.Log += (x, log) => { LogManager.Log(log); }; runner.Run().GetAwaiter().GetResult(); OnProgress("Generating database snapshot..."); if (File.Exists(tempBackupFile)) { LogManager.Log($"Deleting file '{tempBackupFile}'"); File.Delete(tempBackupFile); } LogManager.Log($"Generating backup for '{tempDbName}' to '{tempBackupFile}'..."); dbManager.Backup(tempDbName, tempBackupFile); OnProgress("Injecting database snapshot to PPC package..."); using (ZipFile zip = new ZipFile(tempZipFile)) { LogManager.Log($"Injecting file '{tempBackupFile}' to original package at '{tempZipFile}'..."); zip.AddFile(tempBackupFile, "/"); LogManager.Log($"Injecting modified publish information..."); zip.UpdateEntry("version.json", publishInfo.ToJson()); zip.Save(); } LogManager.Log($"Copying '{tempZipFile}' to '{filePath}'..."); File.Copy(tempZipFile, filePath, true); OnProgress("Completed", false, 100, 100); LogManager.Log("TUP file generation completed successfully."); } catch (Exception ex) { LogManager.Log(ex, "TUP file generation failed."); OnProgress("Failed", false, 0, 100); throw ex; } finally { LogManager.Log($"Removing '{tempZipFile}'."); tempZipFile.Delete(); LogManager.Log($"Removing '{tempPackageFolder}'."); tempPackageFolder.Delete(); try { LogManager.Log($"Removing database '{tempDbName}'."); dbManager.SetOffline(tempDbName); dbManager.SetOnline(tempDbName); dbManager.Delete(tempDbName); dbManager.Dispose(); } catch (Exception ex) { LogManager.Log(ex, $"Error removing temp database '{tempDbName}'."); } try { LogManager.Log($"Removing '{tempBackupFolder}'."); Directory.Delete(tempBackupFolder, true); } catch (Exception ex) { LogManager.Log(ex, $"Error removing folder '{tempBackupFolder}'."); } } }); } public async Task<String> GetLatestPPCVersion(String serialNumber) { MachineStudioWebClient client = TangoIOC.Default.GetInstance<MachineStudioWebClient>(); var response = await client.DownloadLatestPPCVersion(new DownloadLatestPPCVersionRequest() { SerialNumber = serialNumber }); return response.Version; } private void OnProgress(String message, bool isIntermediate = true, double progress = 0, double total = 100) { Progress?.Invoke(this, new TupFileBuilderProgressEventArgs() { Message = message, IsIntermediate = isIntermediate, Progress = progress, Total = total, }); } } }