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
|
using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Tango.Core;
using Tango.Core.IO;
using Tango.Settings;
using Tango.SQLExaminer;
namespace Tango.PPC.Common.MachineSetup
{
public class MachineSetupManager : ExtendedObject, IMachineSetupManager
{
public event EventHandler<string> ProgressLog;
public event EventHandler<MachineSetupSteps> ProgressStep;
private MachineSetupSteps _currentStep;
public MachineSetupSteps CurrentStep
{
get { return _currentStep; }
set
{
_currentStep = value;
RaisePropertyChangedAuto();
ProgressStep?.Invoke(this, _currentStep);
}
}
public Task Setup(string serialNumber, string hostAddress)
{
return Task.Factory.StartNew(() =>
{
CurrentStep = MachineSetupSteps.SynchronizingSchema;
String db_name = "Tango";
String localAddress = SettingsManager.Default.GetOrCreate<CoreSettings>().DataBaseSource;
var tempFolder = TemporaryManager.Default.CreateFolder("Machine Setup");
String report_file = tempFolder.CreateImaginaryFile(".xml");
String config_file = tempFolder.CreateImaginaryFile(".xml");
DbManager db = new DbManager(new SqlConnection(String.Format("Server={0};Integrated security=SSPI", localAddress)));
if (!db.Exists("Tango"))
{
throw new InvalidProgramException("Database tango does not exists.");
}
//Create schema configuration
ExaminerConfigurationBuilder builder = new ExaminerConfigurationBuilder(ExaminerConfigurationType.Schema);
builder.
SetSourceServer(hostAddress, db_name).
SetTargetServer(localAddress, db_name).
Synchronize();
//Synchronize Source schema with Target schema
var process = new ExaminerProcess(builder.Build(), ExaminerProcessType.Schema);
process.Progress += (x, msg) =>
{
ProgressLog?.Invoke(this, msg);
};
var result = process.Execute().Result;
//Synchronization was successful
if (result.ExitCode != ExaminerProcessExitCode.Success)
{
throw new InvalidProgramException("Error while trying to synchronize database schema.");
}
CurrentStep = MachineSetupSteps.SynchronizingData;
//Create override data configuration
builder = new ExaminerConfigurationBuilder(ExaminerConfigurationType.OverrideData);
builder.
SetSourceServer(hostAddress, db_name).
SetTargetServer(localAddress, db_name).
Synchronize();
process = new ExaminerProcess(builder.Build(), ExaminerProcessType.Data);
process.Progress += (x, msg) =>
{
ProgressLog?.Invoke(this, msg);
};
result = process.Execute().Result;
//Synchronization was successful
if (result.ExitCode != ExaminerProcessExitCode.Success)
{
throw new InvalidProgramException("Error while trying to synchronize data.");
}
CurrentStep = MachineSetupSteps.SynchronizingMachineConfiguration;
//Provision Target
builder = new ExaminerConfigurationBuilder(ExaminerConfigurationType.ProvisionMachine);
builder.
SetSourceServer(hostAddress, db_name).
SetTargetServer(localAddress, db_name).
SetMachineSerialNumber(serialNumber).
Synchronize();
process = new ExaminerProcess(builder.Build(), ExaminerProcessType.Data);
process.Progress += (x, msg) =>
{
ProgressLog?.Invoke(this, msg);
};
result = process.Execute().Result;
//Synchronization was successful
if (result.ExitCode != ExaminerProcessExitCode.Success)
{
throw new InvalidProgramException("Error while trying to synchronize database schema.");
}
});
}
}
}
|
