using System;
using System.Collections.Generic;
using System.Data;
using System.ServiceModel;
using Aitex.Core.RT.ConfigCenter;
using Aitex.Core.RT.DataCenter;
using Aitex.Core.RT.Event;
using Aitex.Core.RT.IOCore;
using Aitex.Core.RT.SCCore;
using Aitex.Core.UI.ControlDataContext;
using Aitex.Sorter.Common;
using Aitex.Sorter.RT.Module.DBRecorder;
using MECF.Framework.Common.CommonData;
using MECF.Framework.Common.ControlDataContext;
using MECF.Framework.Common.DBCore;
using MECF.Framework.Common.IOCore;
using MECF.Framework.Common.SubstrateTrackings;
using CyberX8_Core;
using VenusCommon;
using MECF.Framework.Common.SCCore;

namespace MECF.Framework.Common.DataCenter
{
    [ServiceBehavior(InstanceContextMode = InstanceContextMode.Single, ConcurrencyMode = ConcurrencyMode.Multiple)]
    public class QueryDataService : IQueryDataService
    {
        public Dictionary<string, object> PollData(IEnumerable<string> keys)
        {
            return DATA.PollData(keys);
        }

        public string GetConfigFileContent()
        {
            return SC.GetConfigFileContent();
        }

        public Dictionary<string, object> PollConfig(IEnumerable<string> keys)
        {
            return CONFIG.PollConfig(keys);
        }

        public object GetData(string key)
        {
            return DATA.Poll(key);
        }

        public object GetConfig(string key)
        {
            return CONFIG.Poll(key);
        }

        public List<NotifiableIoItem> GetDiList(string key)
        {
            var ret = IO.GetDiList(key);
            List<NotifiableIoItem> result = new List<NotifiableIoItem>();
            ret.ForEach(x=> result.Add(new NotifiableIoItem()
            {
                Address = x.Addr,
                Name = x.Name,
                Description = x.Description,
                Index = x.Index,
                BoolValue = x.Value,
                Provider = x.Provider,
                BlockOffset = x.BlockOffset,
                BlockIndex = x.Index,
            }));

            return result;
        }

        public List<NotifiableIoItem> GetDoList(string key)
        {
            var ret = IO.GetDoList(key);
            List<NotifiableIoItem> result = new List<NotifiableIoItem>();
            ret.ForEach(x => result.Add(new NotifiableIoItem()
            {
                Address = x.Addr,
                Name = x.Name,
                Description = x.Description,
                Index = x.Index,
                BoolValue = x.Value,
                Provider = x.Provider,
                BlockOffset = x.BlockOffset,
                BlockIndex = x.Index,
            }));

            return result;
        }

        public List<NotifiableIoItem> GetAiList(string key)
        {
            var ret = IO.GetAiList(key);
            List<NotifiableIoItem> result = new List<NotifiableIoItem>();
            ret.ForEach(x => result.Add(new NotifiableIoItem()
            {
                Address = x.Addr,
                Name = x.Name,
                Description = x.Description,
                Index = x.Index,
                ShortValue = x.Value,
                Provider = x.Provider,
                BlockOffset = x.BlockOffset,
                BlockIndex = x.Index,
            }));

            return result;
        }

        public List<NotifiableIoItem> GetAoList(string key)
        {
            var ret = IO.GetAoList(key);
            List<NotifiableIoItem> result = new List<NotifiableIoItem>();
            ret.ForEach(x => result.Add(new NotifiableIoItem()
            {
                Address = x.Addr,
                Name = x.Name,
                Description = x.Description,
                Index = x.Index,
                ShortValue = x.Value,
                Provider = x.Provider,
                BlockOffset = x.BlockOffset,
                BlockIndex = x.Index,
            }));

            return result;
        }


        public List<EventItem> QueryDBEvent(string sql)
        {
            return EV.QueryDBEvent(sql);
        }

        public List<HistoryCarrierData> QueryDBCarrier(string sql)
        {
            return  CarrierDataRecorder.QueryDBCarrier(sql);
        }

        public List<HistoryProcessData> QueryDBProcess(string sql)
        {
            return  ProcessDataRecorder.QueryDBProcess(sql);
        }

        public List<HistoryWaferData> QueryDBWafer(string sql)
        {
            return  WaferDataRecorder.QueryDBWafer(sql);
        }

        public List<HistoryMoveData> QueryDBMovement(string sql)
        {
            return  WaferMoveHistoryRecorder.QueryDBMovement(sql);
        }

        public List<HistoryJobMoveData> QueryDBJobMovementByJobGuid(string jobGuid)
        {
	        return JobMoveHistoryRecorder.QueryJobMovement(jobGuid);
        }

        public List<HistoryJobMoveData> QueryDBJobMovementByJobGuidAndStationName(string jobGuid, string stationName)
        {
	        return JobMoveHistoryRecorder.QueryJobMovement(jobGuid,stationName);
        }

		public List<HistoryDataItem> GetHistoryData(IEnumerable<string> keys, string recipeRunGuid, string module)
        {
            return ProcessDataRecorder.GetHistoryData(keys, recipeRunGuid, module);
        }

        public List<HistoryDataItem> GetOneDayHistoryData(IEnumerable<string> keys, DateTime begin, string module)
		{
			return ProcessDataRecorder.GetOneDayHistoryData(keys, begin, module);
		}

        public List<HistoryDataItem> GetHistoryDataFromStartToEnd(IEnumerable<string> keys, DateTime begin, DateTime end, string module)
        {
	        return ProcessDataRecorder.GetHistoryDataFromStartToEnd(keys, begin, end,module);
        }

        public DataTable QueryData(string sql)
        {
            return DataQuery.Query(sql);
        }

        public List<LeakCheckResultItem> GetHistoryLeakCheck(string Module)
        {
            return LeakCheckResultManager.Instance.GetHistoryLeakCheck(Module);
        }

        public List<PMLeakCheckResult> GetPMLeakCheckResult(string moduleName)
        {
            return LeakCheckDataRecorder.GetAllLeakCheckData(moduleName);
        }
        public List<MFCVerificationData> GetMFCVerificationData(DateTime begin, DateTime end)
        {
            return MFCVerificationDataRecorder.GetMFCVerificationData(begin, end);
        }
        public List<MFCVerificationOnePointData> GetMFCVerificationOnePointData()
        {
            return MFCVerificationDataRecorder.GetMFCVerificationOnePointData();
        }
        public List<MFCVerificationTenPointsData> GetMFCVerificationTenPointsData()
        {
            return MFCVerificationDataRecorder.GetMFCVerificationTenPointsData();
        }
        public List<HistoryStepItem> GetHistorySteps(DateTime begin, DateTime end)
        {
            return ProcessDataRecorder.GetHistoryStepList(begin,end);
        }
        public List<OffsetItem> QueryOffsetDataByTime(string moduleName, DateTime from_time, DateTime to_time)
        {
            return OffsetDataRecorder.QueryOffsetDataByTime(moduleName, from_time, to_time);
        }
        public string GetTypedConfigContent(string type, string contentPath)
        {
            return TypedConfigManager.Instance.GetTypedConfigContent(type, contentPath);
        }
        public void SetTypedConfigContent(string type, string contentPath, string content)
        {
            TypedConfigManager.Instance.SetTypedConfigContent(type, contentPath, content);
        }
        public List<UserItem> QueryAllUsers()
        {
            return UserDataRecorder.GetUserItems();
        }
        public void InserUser(UserItem userItem)
        {
            UserDataRecorder.InserUser(userItem);
        }
        public void DeleteUser(string userName)
        {
            UserDataRecorder.DeleteUser(userName);
        }
        public void EditUser(UserItem userItem)
        {
            UserDataRecorder.EditUser(userItem);
        }
    }
}