#region

using System;
using System.Collections.Generic;
using System.Data;
using System.ServiceModel;
using CSFrameworkV5.Common;
using CSFrameworkV5.Core;
using CSFrameworkV5.Interfaces;
using CSFrameworkV5.Interfaces.InterfaceModels;
using CSFrameworkV5.WCFContract;

///*************************************************************************/
///*
///* 文件名    ：WinService_CommonData.cs 
///*
///* 程序说明  : 公共数据桥接类定义
///* 原创作者  ：www.csframework.com 
///* 
///* Copyright 2006-2021 C/S框架网 www.csframework.com
///*
///**************************************************************************/

#endregion

namespace CSFrameworkV5.WebRef.CommonService
{
    /// <summary>
    ///     公共方法的Windows Service策略层
    /// </summary>
    public class WCF_CommonData : WCF_Base<ICommonService>, IBridge_CommonData
    {
        public List<DbTableModel> GetDbTableFields(string DBName,
            string TableName)
        {
            return Excute(client =>
            {
                var loginTicket =
                    WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
                return client.GetDbTableFields(loginTicket, DBName, TableName);
            });
        }

        public List<DbTableModel> GetDbTables()
        {
            return Excute(client =>
            {
                var loginTicket =
                    WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
                return client.GetDbTables(loginTicket);
            });
        }

        public int GetUpgraderPackages(string currentVersionID)
        {
            return Excute(client =>
            {
                var loginTicket =
                    WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
                return client.GetUpgraderPackages(loginTicket,
                    currentVersionID);
            });
        }

        /// <summary>
        ///     测试客户端访问WCF接口
        /// </summary>
        private void TestCommonService()
        {
            var uri = "net.tcp://localhost:8585/CommonService";

            //创建透明代理
            var svc =
                WCFInvokeContext.CreateWCFService<ICommonService>(uri,
                    BindingType.NetTcpBinding);
            try
            {
                (svc as ICommunicationObject).Open(); //打开WCF通道

                //模拟用户登陆信息
                byte[] loginTicket = { 22, 141, 34, 123, 55, 2, 23, 73, 22 };

                //调用WCF接口
                var bs = svc.GetAttachedFiles(loginTicket, "PO201805130002");

                //将byte数组转换为DataSet
                var ds = ZipTools.DecompressionDataSet(bs);
            }
            finally
            {
                (svc as ICommunicationObject).Close(); //关闭通道
            }
        }

        #region IBridge_CommonDAL Members

        public bool ApprovalBusiness(QueryApproval P)
        {
            return Excute(client =>
            {
                var loginTicket = WebServiceSecurity.GetLoginTicket();
                return client.ApprovalBusiness(loginTicket, P);
            });
        }

        public DataTable GetEmptyTable(string DBID, string tableName)
        {
            return Excute(client =>
            {
                var loginTicket = WebServiceSecurity.GetLoginTicket();
                return client.GetEmptyTable(loginTicket, DBID, tableName);
            });
        }

        public string TestConnection()
        {
            return Excute(client =>
            {
                var validationTicket = WebServiceSecurity.GetLoginTicket();
                return client.TestConnection(validationTicket);
            });
        }

        public DataTable GetSystemDataSet()
        {
            return Excute(client =>
            {
                var validationTicket = WebServiceSecurity.GetLoginTicket();
                var receivedData = client.GetSystemDataSet(validationTicket);
                return ZipTools.DecompressionDataSet(receivedData).Tables[0];
            });
        }

        public DataTable GetSystemDataSet(string user, string password)
        {
            return Excute(client =>
            {
                var loginTicket = WebServiceSecurity.GetLoginTicket();
                var bs = client.GetSystemDataSetEx(loginTicket, user, password);
                return ZipTools.DecompressionDataSet(bs).Tables[0];
            });
        }

        public DataTable GetTableFieldsDef(string tableName,
            bool onlyDisplayField)
        {
            return Excute(client =>
            {
                var loginTicket =
                    WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
                var receivedData = client.GetTableFieldsDef(loginTicket,
                    tableName, onlyDisplayField);
                return ZipTools.DecompressionDataSet(receivedData).Tables[0];
            });
        }

        public DataTable GetTableFields(string tableName)
        {
            return Excute(client =>
            {
                var loginTicket =
                    WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
                var receivedData =
                    client.GetTableFields(loginTicket, tableName);
                return ZipTools.DecompressionDataSet(receivedData).Tables[0];
            });
        }

        public DataTable GetBusinessTables()
        {
            return Excute(client =>
            {
                var loginTicket =
                    WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
                var receivedData = client.GetBusinessTables(loginTicket);
                return ZipTools.DecompressionDataSet(receivedData).Tables[0];
            });
        }

        public DataTable GetModules()
        {
            return Excute(client =>
            {
                var loginTicket =
                    WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
                var receivedData = client.GetModules(loginTicket);
                return ZipTools.DecompressionDataSet(receivedData).Tables[0];
            });
        }

        public string GetDataSN(string dataCode, bool asHeader)
        {
            return Excute(client =>
            {
                var loginTicket =
                    WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
                return client.GetDataSN(loginTicket, dataCode, asHeader);
            });
        }

        public string GetDocNo(string DocNoName)
        {
            return Excute(client =>
            {
                var loginTicket =
                    WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
                return client.GetDocNo(loginTicket, DocNoName);
            });
        }

        public DataSet SearchOutstandingByPage(string invoiceNo,
            string customer,
            DateTime dateFrom, DateTime dateTo, DateTime dateEnd,
            string outstandingType, int pageNo, int pageSize)
        {
            return Excute(client =>
            {
                var loginTicket =
                    WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
                var bs = client.SearchOutstanding_ByPage(loginTicket, invoiceNo,
                    customer, dateFrom, dateTo, dateEnd,
                    outstandingType, pageNo, pageSize);
                return ZipTools.DecompressionDataSet(bs);
            });
        }

        public DataTable SearchOutstanding(string invoiceNo, string customer,
            DateTime dateFrom, DateTime dateTo, DateTime dateEnd,
            string outstandingType)
        {
            return Excute(client =>
            {
                var loginTicket =
                    WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
                var bs = client.SearchOutstanding(loginTicket, invoiceNo,
                    customer, dateFrom, dateTo, dateEnd,
                    outstandingType);
                return ZipTools.DecompressionDataSet(bs).Tables[0];
            });
        }

        public DateTime GetServerTime()
        {
            return Excute(client =>
            {
                //byte[] loginTicket = WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
                var loginTicket = WebServiceSecurity.GetLoginTicket();
                return client.GetServerTime(loginTicket);
            });
        }

        public bool UploadUpgrader(string upgraderName, byte[] body,
            string version,
            DateTime uploadTime, string user)
        {
            return Excute(client =>
            {
                var loginTicket =
                    WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
                return client.UploadUpgrader(loginTicket, upgraderName, body,
                    version, uploadTime, user);
            });
        }

        public string GetUpgraderVersion(string upgraderName)
        {
            return Excute(client =>
            {
                var loginTicket =
                    WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
                return client.GetUpgraderVersion(loginTicket, upgraderName);
            });
        }

        public byte[] GetUpgrader(string upgraderName, string serverVer)
        {
            return Excute(client =>
            {
                var loginTicket =
                    WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
                return client.GetUpgrader(loginTicket, upgraderName, serverVer);
            });
        }

        public DataTable GetSystemSettingsEx(string ParamName, string ParamType)
        {
            return Excute(client =>
            {
                var loginTicket =
                    WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
                var receivedData =
                    client.GetSystemSettingsEx(loginTicket, ParamName,
                        ParamType);
                return ZipTools.DecompressionDataSet(receivedData).Tables[0];
            });
        }

        public DataTable GetSystemSettingsByUser(string DataSetID,
            string UserID)
        {
            return Excute(client =>
            {
                var loginTicket =
                    WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
                var receivedData =
                    client.GetSystemSettingsByUser(loginTicket, DataSetID,
                        UserID);
                return ZipTools.DecompressionDataSet(receivedData).Tables[0];
            });
        }

        public DataTable GetSystemSettings4Program(string DataSetID,
            string UserID)
        {
            return Excute(client =>
            {
                var loginTicket = WebServiceSecurity.GetLoginTicket();
                var receivedData =
                    client.GetSystemSettings4Program(loginTicket, DataSetID,
                        UserID);
                return ZipTools.DecompressionDataSet(receivedData).Tables[0];
            });
        }

        public void PostUserSettings(Loginer currentUser, string paramKey,
            string paramValue)
        {
            Excute(client =>
            {
                var loginTicket =
                    WebServiceSecurity.EncryptLoginer(Loginer.CurrentUser);
                client.PostUserSettings(loginTicket, paramKey, paramValue);
            });
        }

        public DataTable GetUpgraderVersionData()
        {
            throw new NotImplementedException();
        }

        public DataTable GetReports(string ReportsName)
        {
            throw new NotImplementedException();
        }

        #endregion
    }
}