Discuz!NT聚合功能页面程序架构的方法

1 AggregationFacade.cs
2
3 private static AggregationData __baseAggregationData;
4
5 private static ForumAggregationData __forumAggregationData;
6
7 private static SpaceAggregationData __spaceAggregationData;
8
9 private static AlbumAggregationData __albumAggregationData;
10
11 private static PhotoAggregationData __photoAggregationData;
12
13 static AggregationFacade()
14 {
15 __baseAggregationData = new AggregationData();
16
17 __forumAggregationData = new ForumAggregationData();
18
19 __spaceAggregationData = new SpaceAggregationData();
20
21 __albumAggregationData = new AlbumAggregationData();
22
23 __photoAggregationData = new PhotoAggregationData();
24
25 //加载要通知的聚合数据对象,Attach函数将在下面内容中介绍
26 AggregationDataSubject.Attach(__baseAggregationData);
27
28 AggregationDataSubject.Attach(__forumAggregationData);
29
30 AggregationDataSubject.Attach(__spaceAggregationData);
31
32 AggregationDataSubject.Attach(__albumAggregationData);
33
34 AggregationDataSubject.Attach(__photoAggregationData);
35 }

1 public static ForumAggregationData ForumAggregation
2 {
3 get
4 {
5 return __forumAggregationData;
6 }
7 }

1 #region 采用Observer模式清空当前进程中的聚合数据
2
3 private static ArrayList __aggregationDataArrayList = new ArrayList();
4
5
6 //调用在AggregationFacade类的静态构造函数中
7 public static void Attach(AggregationData __aggregationData)
8 {
9 __aggregationDataArrayList.Add(__aggregationData);
10 }
11
12 public static void Detach(AggregationData __aggregationData)
13 {
14 __aggregationDataArrayList.Remove(__aggregationData);
15 }
16
17 public static void NotifyClearDataBind()
18 {
19 foreach (AggregationData __aggregationData in __aggregationDataArrayList)
20 {
21 __aggregationData.ClearDataBind();
22 }
23 }
24
25 #endregion

1 //设置定时器时间为15秒
2 private static System.Timers.Timer aggregationConfigTimer = new System.Timers.Timer(15000);
3
4 //AggregationDataSubject类的静态构造函数
5 static AggregationDataSubject()
6 {
7
8 //初始化定时器
9 aggregationConfigTimer.AutoReset = true;
10 aggregationConfigTimer.Enabled = true;
11 aggregationConfigTimer.Elapsed += new System.Timers.ElapsedEventHandler(Timer_Elapsed);
12 aggregationConfigTimer.Start();
13 }
14
15 private static void Timer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
16 {
17 if (IsFileHadRewrite())
18 {
19 //重设文件修改时间，以便下次文件更新时进行逻辑判断
20 ReSetFileChangeTime();
21
22 //重新从数据文件中读取数据
23 AggregationData.ReadAggregationConfig();
24
25 //调用上面的相关函数
26 NotifyClearDataBind();
27 }
28 }

1 private DataTable topNComment;
2 public DataTable GetSpaceTopCommentsFromFile()
3 {
4 //注意此处的判断
5 if (topNComment != null)
6 {
7 return topNComment;
8 }
9
10 //从文件中取
11 topNComment = aggregationDS.Tables["topncommentspace"];
12
13
14 return topNComment;
15 }