FilesExpand file tree

 master

/

DtuClient.cs

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

91 lines (76 loc) · 2.44 KB

 master

/

DtuClient.cs

Copy path

Top

File metadata and controls

• Code
• Blame

91 lines (76 loc) · 2.44 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

using System;

using CommLib.ShareFun;

using System.Timers;

namespace MonitorServer

{

public class DtuClient

{

/// <summary>

/// 配置文件

/// </summary>

private readonly Config cfg;

/// <summary>

/// 本对象客户端

/// </summary>

public ClientObject transClinet;

/// <summary>

/// 登陆事件--只读

/// </summary>

public DateTime LoginTime;

/// <summary>

/// 最后传输数据时间

/// </summary>

public DateTime LastUpdateTime;

/// <summary>

/// DTU发来的ID号码

/// </summary>

public string DtuId;

/// <summary>

/// 电话号码

/// </summary>

public string PhoneNum;

public DtuClient(ClientObject co)

{

cfg = new Config();

//初始化对象

transClinet = co;

//然后把接受数据回调发上来。。

transClinet.SetReceiveCallBack(MessageReceived);

//初始化对象

LoginTime = DateTime.Now;

LastUpdateTime = DateTime.Now;

//开个计时器，判断是否超时

Timer tmTimeOutTick = new Timer(1000);

tmTimeOutTick.Elapsed += TmTimeOutTick_Elapsed;

tmTimeOutTick.AutoReset = true;

tmTimeOutTick.Start();

}

//判断是否超时

private void TmTimeOutTick_Elapsed(object sender, ElapsedEventArgs e)

{

if ((DateTime.Now - LastUpdateTime).TotalSeconds > cfg.HeartBeatTimeOutSecond)

{

//超时了。直接关掉。。

transClinet.Shutdown();

}

}

//正在处理接受事件。。

private bool isReceiving = false;

//是否第一次进入，第一次进来的时候有注册包，要收这个数据。。

private bool isFirstEnter = true;

/// <summary>

/// 数据已经收到

/// </summary>

/// <param name="co"></param>

private void MessageReceived(ClientObject co)

{

//正在处理，就不重复进入了。。

if (isReceiving) return;

isReceiving = true;

#region 开始处理收到的数据

//todo 数据处理，首次注册信息，接收心跳，其他数据。。

#endregion

isReceiving = false;

}

}

}