TDGage.cs 3.86 KB
Newer Older
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
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO;
using System.Net;

using FObjBase;
using Misc;
using FLY.KSL.Server.Model;

namespace FLY.KSL.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 blowingServiceClient;
28
        FLY.Thick.Blowing.Client.BlowingDetectServiceClient bDetect;
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
        FLY.Thick.Blowing.Client.BulkDbServiceClient bulkDbServiceClient;
        /// <summary>
        /// 报警系统
        /// </summary>
        public FLY.OBJComponents.Server.WarningSystem warning;

        public HistoryDb historyDb;

        DbModel dbModel;
        
        #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 });

潘栩锋's avatar
潘栩锋 committed
71
            blowingServiceClient = new FLY.Thick.Blowing.Client.BlowingServiceClient(FLY.Thick.Blowing360.OBJ_INTERFACE.OBJ_INTERFACE_ID.RENZIJIA_ID, "blowing");
72

73
            bDetect = new FLY.Thick.Blowing.Client.BlowingDetectServiceClient(FLY.Thick.Blowing360.OBJ_INTERFACE.OBJ_INTERFACE_ID.BDETECT_ID, "blowing");
74

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

            #region 提取保存的数据

            //---------------------------------------------------------------------------------------------------------------
            //数据库
            dbModel = new DbModel();
潘栩锋's avatar
潘栩锋 committed
83 84
            dbModel.Init();
            dbModel.KeepDBSize(mSysParam.DBKeepMonth);
85
            historyDb = new HistoryDb();
潘栩锋's avatar
潘栩锋 committed
86
            historyDb.Init(dbModel);
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

            //---------------------------------------------------------------------------------------------------------------
            //Warning_Create
            warning = new FLY.OBJComponents.Server.WarningSystem();
            warning.Init(historyDb.ErrorBuffer);
            Misc.BindingOperations.SetBinding(warning, nameof(warning.IsRinging), () =>
            {
                //报警不动作
                if (warning.IsRinging)
                {

                }
                else
                {

                }
            });


            mfeedback = new FeedbackHeat();


            mfeedback.Init(
                blowingServiceClient,
                bDetect,
                bulkDbServiceClient,
                warning,
                historyDb
                );
            

            #endregion

        }



        #endregion

    }
}