TDGage.cs 4.11 KB
Newer Older
潘栩锋's avatar
潘栩锋 committed
1 2 3 4 5 6 7 8 9
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO;
using System.Net;

using FObjBase;
using Misc;
10
using FLY.FeedbackRenZiJia.Server.Model;
潘栩锋's avatar
潘栩锋 committed
11 12 13

namespace FLY.FeedbackRenZiJia.Server
{
14
    public class TDGage
潘栩锋's avatar
潘栩锋 committed
15 16 17 18 19 20 21
    {
        #region 参数--------------------------------------------------------------------
        #region 初始化------------------------------------------------------------------
        public string mParamDirectory;//参数目录 m_path;//数据文件的 根目录默认是 Gage1
        public string mName;//名字 如:gage0
        #endregion
        #region 本地数据----------------------------------------------------------------
22
        public SysParam mSysParam;
潘栩锋's avatar
潘栩锋 committed
23 24 25
        public FeedbackHeat mfeedback;
        #endregion
        #region 服务器数据--------------------------------------------------------------
26 27 28 29
        
        FLY.Thick.Blowing.Client.BlowingServiceClient mRenZiJia;
        FLY.Thick.Blowing.Client.BlowingDetectServiceClient mBDetect;
        FLY.Thick.Blowing.Client.BulkDbServiceClient bulkDbServiceClient;
潘栩锋's avatar
潘栩锋 committed
30
        /// <summary>
31
        /// 报警系统
潘栩锋's avatar
潘栩锋 committed
32
        /// </summary>
33
        public FLY.OBJComponents.Server.WarningSystem mWarning;
潘栩锋's avatar
潘栩锋 committed
34

35
        public HistoryDb mHistoryDb;
潘栩锋's avatar
潘栩锋 committed
36

潘栩锋's avatar
潘栩锋 committed
37
        DbModel mDbModel;
38
        
潘栩锋's avatar
潘栩锋 committed
39 40 41 42 43 44 45 46 47 48 49 50 51 52 53
        #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;

54

潘栩锋's avatar
潘栩锋 committed
55 56 57 58 59 60 61 62 63 64 65
            Init1();

        }


        #region Init登陆服务器初始化----------------------------------------------------
        /// <summary>
        /// 第1步, 加载本地数据
        /// </summary>
        public void Init1()
        {
66
            mSysParam = new SysParam();
潘栩锋's avatar
潘栩锋 committed
67 68

            #region 与服务器同步的数据
69 70 71
            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");
潘栩锋's avatar
潘栩锋 committed
72

73
            mBDetect = new FLY.Thick.Blowing.Client.BlowingDetectServiceClient(FLY.Thick.Blowing.OBJ_INTERFACE.OBJ_INTERFACE_ID.BDETECT_ID, "blowing");
潘栩锋's avatar
潘栩锋 committed
74

75
            bulkDbServiceClient = new FLY.Thick.Blowing.Client.BulkDbServiceClient(FLY.Thick.Blowing.OBJ_INTERFACE.OBJ_INTERFACE_ID.BULKDB_ID, "blowing");
潘栩锋's avatar
潘栩锋 committed
76 77 78 79
            #endregion

            #region 提取保存的数据

80 81 82 83
            //---------------------------------------------------------------------------------------------------------------
            //数据库
            mDbModel = new DbModel();
            mDbModel.Init();
84
            mDbModel.KeepDBSize(mSysParam.DBKeepMonth);
85 86
            mHistoryDb = new HistoryDb();
            mHistoryDb.Init(mDbModel);
潘栩锋's avatar
潘栩锋 committed
87 88 89 90 91
            //PollModule.Current.Poll_Config(PollModule.POLL_CONFIG.ADD, () =>
            //{
            //    //避免1个月都不关程序,每天检查一次
            //    mHistoryDb.KeepDBSize(mSysParam.DBKeepMonth);
            //}, TimeSpan.FromDays(1));
92 93 94

            //---------------------------------------------------------------------------------------------------------------
            //Warning_Create
95 96
            mWarning = new FLY.OBJComponents.Server.WarningSystem();
            mWarning.Init(mHistoryDb.ErrorBuffer);
97 98 99 100 101 102 103 104 105 106 107 108 109
            Misc.BindingOperations.SetBinding(mWarning, "IsRinging", () =>
            {
                //报警不动作
                if (mWarning.IsRinging)
                {

                }
                else
                {

                }
            });

潘栩锋's avatar
潘栩锋 committed
110

潘栩锋's avatar
潘栩锋 committed
111
            mfeedback = new FeedbackHeat();
潘栩锋's avatar
潘栩锋 committed
112 113 114


            mfeedback.Init(
潘栩锋's avatar
潘栩锋 committed
115
                mRenZiJia,
116
                mBDetect,
117
                bulkDbServiceClient,
118 119
                mWarning,
                mHistoryDb
潘栩锋's avatar
潘栩锋 committed
120 121
                );
            
潘栩锋's avatar
潘栩锋 committed
122

潘栩锋's avatar
潘栩锋 committed
123 124 125 126 127 128 129 130 131 132
            #endregion

        }



        #endregion

    }
}