blob: cd63bfa4a6aa0fbbfbe6f35407c85a021b0fc94e (
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
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
|
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Tango.BL;
using Tango.BL.Entities;
using Tango.Core;
using Tango.Integration.Operation;
using Tango.Integration.ExternalBridge;
using Tango.PMR.Connection;
using Tango.Transport.Adapters;
using Tango.Settings;
using Tango.Logging;
namespace Tango.PPC.Common.Connection
{
/// <summary>
/// Represents the default <see cref="IMachineProvider"/>.
/// </summary>
/// <seealso cref="Tango.Core.ExtendedObject" />
/// <seealso cref="Tango.PPC.Common.Connection.IMachineProvider" />
public class DefaultMachineProvider : ExtendedObject, IMachineProvider
{
private bool _isInitialized;
/// <summary>
/// Occurs when current <see cref="IMachineOperator" /> has changed.
/// </summary>
public event EventHandler<MachineOperatorChangedEventArgs> MachineOperatorChanged;
private Machine _machine;
/// <summary>
/// Gets the database machine entity associated with the current machine.
/// </summary>
public Machine Machine
{
get
{
return _machine;
}
private set
{
_machine = value;
RaisePropertyChangedAuto();
}
}
private IMachineOperator _machineOperator;
/// <summary>
/// Gets the machine operator.
/// </summary>
public IMachineOperator MachineOperator
{
get
{
return _machineOperator;
}
private set
{
var oldOperator = _machineOperator;
_machineOperator = value;
OnMachineOperatorChanged(oldOperator, _machineOperator);
RaisePropertyChangedAuto();
}
}
/// <summary>
/// Called when the machine operator has been changed
/// </summary>
/// <param name="oldOperator">The old operator.</param>
/// <param name="newOperator">The new operator.</param>
protected virtual void OnMachineOperatorChanged(IMachineOperator oldOperator, IMachineOperator newOperator)
{
MachineOperatorChanged?.Invoke(this, new MachineOperatorChangedEventArgs(oldOperator, newOperator));
}
/// <summary>
/// Initializes a new instance of the <see cref="DefaultMachineProvider"/> class.
/// </summary>
public DefaultMachineProvider()
{
MachineOperator = new MachineOperator();
}
/// <summary>
/// Initializes this machine provider start machine port scanning and connection.
/// </summary>
public void Init()
{
if (!_isInitialized)
{
LogManager.Log("Initializing machine operator...");
_isInitialized = true;
LogManager.Log("Retrieving first machine database entry...");
Machine = ObservablesEntitiesAdapter.Instance.Machines.FirstOrDefault();
if (Machine != null)
{
LogManager.Log("First machine entry found. Machine serial number is: " + Machine.SerialNumber + ".");
ConnectToMachine();
}
else
{
LogManager.Log("No machine entry found on database. Could not connect to the embedded device!", LogCategory.Error);
}
}
}
/// <summary>
/// Tries to connect to the machine by scanning all available serial ports.
/// The timeout for a scan cycle is specified on <see cref="PPCSettings.MachineScanningTimeoutSeconds"/>.
/// </summary>
private async void ConnectToMachine()
{
try
{
LogManager.Log("Starting machine connection procedure...");
TimeSpan timeout = TimeSpan.FromSeconds(SettingsManager.Default.GetOrCreate<PPCSettings>().MachineScanningTimeoutSeconds);
LogManager.Log("Scanning for machine on available serial ports...");
Transport.Discovery.UsbCommunicationScanner<ConnectRequest, ConnectResponse> scanner = new Transport.Discovery.UsbCommunicationScanner<ConnectRequest, ConnectResponse>(UsbSerialBaudRates.BR_9600);
var response = await scanner.Scan(new ConnectRequest() { Password = "1234" }, timeout);
LogManager.Log("Machine discovered on port: " + response.Adapter.Address);
LogManager.Log("Device Information:");
LogManager.Log(response.Response.DeviceInformation.ToJsonString());
LogManager.Log("Disconnecting machine operator...");
await MachineOperator.Disconnect();
MachineOperator.Adapter = response.Adapter;
MachineOperator.JobHandlingMode = JobHandlerModes.SettingUp;
LogManager.Log("Connecting machine operator...");
await MachineOperator.Connect();
}
catch (Exception ex)
{
LogManager.Log(ex, "Error while trying to scan and connect to the machine.");
}
}
}
}
|
