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
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO;
using System.Net;
using FObjBase;
using Misc;
using FLY.FeedbackRenZiJia.Server.Model;
namespace FLY.FeedbackRenZiJia.Server
{
public class TDGage
{
#region 参数--------------------------------------------------------------------
#region 初始化------------------------------------------------------------------
public string mParamDirectory;//参数目录 m_path;//数据文件的 根目录默认是 Gage1
public string mName;//名字 如:gage0
#endregion
#region 本地数据----------------------------------------------------------------
public SysParam mSysParam;
public FeedbackHeat mfeedback;
#endregion
#region 服务器数据--------------------------------------------------------------
FLY.Thick.Blowing.Client.BlowingServiceClient mRenZiJia;
FLY.Thick.Blowing.Client.BlowingDetectServiceClient mBDetect;
FLY.Thick.Blowing.Client.BulkDbServiceClient bulkDbServiceClient;
/// <summary>
/// 报警系统
/// </summary>
public FLY.OBJComponents.Server.WarningSystem mWarning;
public HistoryDb mHistoryDb;
DbModel mDbModel;
#endregion
#endregion
public TDGage(string nam)
{
mName = nam;
mParamDirectory = mName;// @"D:\" + m_name;
if (!System.IO.Directory.Exists(mParamDirectory))
{
System.IO.Directory.CreateDirectory(mParamDirectory);
}
System.Environment.CurrentDirectory = mParamDirectory;
Init1();
}
#region Init登陆服务器初始化----------------------------------------------------
/// <summary>
/// 第1步, 加载本地数据
/// </summary>
public void Init1()
{
mSysParam = new SysParam();
#region 与服务器同步的数据
FObjServiceClientManager.Instance.ConnAddrs.Add(new ConnAddr() { ConnName = "blowing", Addr = mSysParam.BlowingAddr });
mRenZiJia = new FLY.Thick.Blowing.Client.BlowingServiceClient(FLY.Thick.Blowing.OBJ_INTERFACE.OBJ_INTERFACE_ID.RENZIJIA_ID, "blowing");
mBDetect = new FLY.Thick.Blowing.Client.BlowingDetectServiceClient(FLY.Thick.Blowing.OBJ_INTERFACE.OBJ_INTERFACE_ID.BDETECT_ID, "blowing");
bulkDbServiceClient = new FLY.Thick.Blowing.Client.BulkDbServiceClient(FLY.Thick.Blowing.OBJ_INTERFACE.OBJ_INTERFACE_ID.BULKDB_ID, "blowing");
#endregion
#region 提取保存的数据
//---------------------------------------------------------------------------------------------------------------
//数据库
mDbModel = new DbModel();
mDbModel.Init();
mHistoryDb = new HistoryDb();
mHistoryDb.Init(mDbModel);
mHistoryDb.KeepDBSize(mSysParam.DBKeepMonth);
//PollModule.Current.Poll_Config(PollModule.POLL_CONFIG.ADD, () =>
//{
// //避免1个月都不关程序，每天检查一次
// mHistoryDb.KeepDBSize(mSysParam.DBKeepMonth);
//}, TimeSpan.FromDays(1));
//---------------------------------------------------------------------------------------------------------------
//Warning_Create
mWarning = new FLY.OBJComponents.Server.WarningSystem();
mWarning.Init(mHistoryDb.ErrorBuffer);
Misc.BindingOperations.SetBinding(mWarning, "IsRinging", () =>
{
//报警不动作
if (mWarning.IsRinging)
{
}
else
{
}
});
mfeedback = new FeedbackHeat();
mfeedback.Init(
mRenZiJia,
mBDetect,
bulkDbServiceClient,
mWarning,
mHistoryDb
);
#endregion
}
#endregion
}
}