MTP2.0_CSharp/Muchinfo.MTPClient/Fx4.0/Main/05.Services/Muchinfo.TASClient.Service/CommonQueryService.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Muchinfo.MTPClient.Adapter.Abstract;
using Muchinfo.MTPClient.Data;
using Muchinfo.MTPClient.Data.Enums;
using Muchinfo.MTPClient.Data.Model.Account;
using Muchinfo.MTPClient.Data.Model.Report;
using Muchinfo.MTPClient.Infrastructure.LinkProxy;
using Muchinfo.MTPClient.Infrastructure.Utilities;
using Muchinfo.MTPClient.IService;
using Muchinfo.MTPClient.Resources;
using Muchinfo.MTPClient.Service.Utilities;
using Muchinfo.MTPClient.Data.Model;
using Muchinfo.MTPClient.Infrastructure.Cache;

namespace Muchinfo.MTPClient.Service
{
    /// <summary>
    /// 通用查询服务
    /// </summary>
    public class CommonQueryService : ICommonQueryService
    {
        #region Public Methods

        /// <summary>
        /// 查询市场运行状态
        /// </summary>
        /// <param name="marketId">The market identifier.</param>
        /// <param name="successAction">The success action.</param>
        /// <param name="errorAction">The error action.</param>
        public void QueryMarketRun(int marketId, Action<List<MarketRunModelNew>> successAction, Action<ErrorEntity> errorAction)
        {
            var statement = QueryStatement.ClientSearchMarketRun;
            var queryParams = new List<QueryCommonParam>()
            {
                new QueryCommonParam() { ParamKey = "marketId", ParamValue = marketId.ToString()},  
            };

            QueryCommonHelper.QueryCommon(statement, queryParams, successAction, errorAction, "查询市场运行状态");
        }

        /// <summary>
        /// 查询结算单-资金账户信息
        /// </summary>
        /// <param name="cycleType">Type of the cycle.</param>
        /// <param name="cycleTime">The cycle time.</param>
        /// <param name="successAction">The success action.</param>
        /// <param name="errorAction">The error action.</param>
        /// <exception cref="System.NotImplementedException"></exception>
        public void QueryTaAccount(ReckonReportQueryType cycleType, string cycleTime, Action<List<ReckonAccountModel>> successAction, Action<ErrorEntity> errorAction)
        {
            var statement = QueryStatement.ClientDayRetortTaaccount;
            var queryParams = new List<QueryCommonParam>()
            {
                new QueryCommonParam() { ParamKey = "accountId", ParamValue = UserManager.CurrentTradeAccount.FundsAccountId.ToString()},  
                new QueryCommonParam() { ParamKey = "cycleTime", ParamValue = cycleTime },  
            };
            if (cycleType != ReckonReportQueryType.DayReckon)
            {
                //周期报表
                statement = QueryStatement.ClientRetortTaaccount;
                queryParams.Add(new QueryCommonParam() { ParamKey = "cycleType", ParamValue = ((int)cycleType).ToString() });
            }

            QueryCommonHelper.QueryCommon(statement, queryParams, successAction, errorAction, "查询结算单-账号资金信息");
        }

        /// <summary>
        /// 查询结算单-资金账户币种信息
        /// </summary>
        /// <param name="cycleType">Type of the cycle.</param>
        /// <param name="cycleTime">The cycle time.</param>
        /// <param name="successAction">The success action.</param>
        /// <param name="errorAction">The error action.</param>
        public void QueryTaAccountCur(ReckonReportQueryType cycleType, string cycleTime, Action<List<ReckonReportModel>> successAction, Action<ErrorEntity> errorAction)
        {
            var statement = QueryStatement.ClientReportDayTaAccountCur;
            var queryParams = new List<QueryCommonParam>()
            {
                new QueryCommonParam() { ParamKey = "accountId", ParamValue = UserManager.CurrentTradeAccount.FundsAccountId.ToString()},  
                new QueryCommonParam() { ParamKey = "cycleTime", ParamValue = cycleTime },  
            };
            if (cycleType != ReckonReportQueryType.DayReckon)
            {
                //周期报表
                statement = QueryStatement.ClientReportTaAccountCur;
                queryParams.Add(new QueryCommonParam() { ParamKey = "cycleType", ParamValue = ((int)cycleType).ToString() });
            }

            QueryCommonHelper.QueryCommon(statement, queryParams, successAction, errorAction, "查询结算单-资金账户币种信息");
        }

        /// <summary>
        /// 查询账户止盈止损单
        /// </summary>
        /// <param name="accountId">The account identifier.</param>
        /// <param name="successAction">The success action.</param>
        /// <param name="errorAction">The error action.</param>
        /// <exception cref="System.NotImplementedException"></exception>
        public void QuerySPSLOrder(ulong accountId, Action<List<SPSLOrderModel>> successAction, Action<ErrorEntity> errorAction)
        {
            var queryParams = new List<QueryCommonParam>()
            {
                new QueryCommonParam() { ParamKey = "accountid", ParamValue = accountId.ToString()},  
            };

            QueryCommonHelper.QueryCommon(QueryStatement.ClientQuerySpslOrderdetail, queryParams, successAction, errorAction, "查询账户止盈止损单");
        }

        /// <summary>
        /// 查询资管内部委托单
        /// </summary>
        /// <param name="queryParams">The query parameters.</param>
        /// <param name="successAction">The success action.</param>
        /// <param name="errorAction">The error action.</param>
        public void QueryInnerHisOrderDetails(List<QueryCommonParam> queryParams, Action<List<Data.Model.Account.OrderDetail>> successAction, Action<ErrorEntity> errorAction)
        {
            QueryCommonHelper.QueryCommon(QueryStatement.ClientInforHisInnerOrderDetail, queryParams, successAction, errorAction, "查询资管内部委托单");
        }

        /// <summary>
        /// 查询资管内部成交单
        /// </summary>
        /// <param name="queryParams">The query parameters.</param>
        /// <param name="successAction">The success action.</param>
        /// <param name="errorAction">The error action.</param>
        public void QueryInnerHisTradeDetails(List<QueryCommonParam> queryParams, Action<List<CompleteOrder>> successAction, Action<ErrorEntity> errorAction)
        {
            QueryCommonHelper.QueryCommon(QueryStatement.ClientInforHisInnerTradeDetail, queryParams, successAction, errorAction, "查询资管内部成交单");
        }

        /// <summary>
        /// 查询资管内部平仓明细
        /// </summary>
        /// <param name="queryParams">The query parameters.</param>
        /// <param name="successAction">The success action.</param>
        /// <param name="errorAction">The error action.</param>
        /// <exception cref="System.NotImplementedException"></exception>
        public void QueryInnerHisCloseDetails(List<QueryCommonParam> queryParams, Action<List<Data.Model.Account.CloseDetail>> successAction, Action<ErrorEntity> errorAction)
        {
            QueryCommonHelper.QueryCommon(QueryStatement.ClientInforHisInnerCloseDetail, queryParams, successAction, errorAction, "查询资管内部平仓明细");
        }

        /// <summary>
        /// 查询资管内部持仓单
        /// </summary>
        /// <param name="queryParams">The query parameters.</param>
        /// <param name="successAction">The success action.</param>
        /// <param name="errorAction">The error action.</param>
        public void QueryInnerHisHoldDetails(List<QueryCommonParam> queryParams, Action<List<HoldDetail>> successAction, Action<ErrorEntity> errorAction)
        {
            QueryCommonHelper.QueryCommon(QueryStatement.ClientInforHisInnerHolderDetail, queryParams, successAction, errorAction, "查询资管内部持仓单");
        }

        /// <summary>
        /// 查询账户持仓汇总
        /// </summary>
        /// <param name="cycleType">Type of the cycle.</param>
        /// <param name="cycleTime">The cycle time.</param>
        /// <param name="successAction">The success action.</param>
        /// <param name="errorAction">The error action.</param>
        /// <exception cref="System.NotImplementedException"></exception>
        public void QueryTradePostion(ReckonReportQueryType cycleType, string cycleTime, Action<List<TradePosition>> successAction, Action<ErrorEntity> errorAction)
        {
            var statement = QueryStatement.ClientDayRetortTradePosition;
            var queryParams = new List<QueryCommonParam>()
            {
                new QueryCommonParam() { ParamKey = "accountId", ParamValue = UserManager.CurrentTradeAccount.FundsAccountId.ToString()},  
                new QueryCommonParam() { ParamKey = "cycleTime", ParamValue = cycleTime },  
            };
            if (cycleType != ReckonReportQueryType.DayReckon)
            {
                //周期报表
                statement = QueryStatement.ClientRetortTradePosition;
                queryParams.Add(new QueryCommonParam() { ParamKey = "cycleType", ParamValue = ((int)cycleType).ToString() });
            }

            QueryCommonHelper.QueryCommon(statement, queryParams, successAction, errorAction, "查询账户持仓汇总");
        }

        #endregion


        /// <summary>
        /// 查询账户汇率模板
        /// </summary>
        /// <param name="taAccountIdList">The ta account identifier list.</param>
        /// <param name="successAction">The success action.</param>
        /// <param name="errorAction">The error action.</param>
        public void QueryTradeRateTmpConfig(string taAccountIdList, Action<List<TradeRateTmpConfig>> successAction, Action<ErrorEntity> errorAction)
        {
            var statement = QueryStatement.ClientInforTradeRateTmpConfig;
            var queryParams = new List<QueryCommonParam>()
            {
                new QueryCommonParam() { ParamKey = "taAccountIdList", ParamValue = taAccountIdList},  
            };

            QueryCommonHelper.QueryCommon(statement, queryParams, new Action<List<TradeRateTmpConfig>>((configs) =>
            {
                UserManager.TradeRateTmpConfigs = configs;
                if (successAction != null ) successAction(configs);
            }), errorAction, "查询账户汇率模板");
        }

        /// <summary>
        /// 查询外部汇率模版配置表
        /// </summary>
        /// <param name="taAccountIdList">The ta account identifier list.</param>
        /// <param name="tradeDate">交易日</param>
        /// <param name="successAction">The success action.</param>
        /// <param name="errorAction">The error action.</param>
        public void QueryExtenalTradeRateTmpConfig(string taAccountIdList, string tradeDate, Action<List<TradeRateTmpConfig>> successAction, Action<ErrorEntity> errorAction)
        {
            var statement = QueryStatement.ClientExtenalExchangeRate;
            var queryParams = new List<QueryCommonParam>()
            {
                new QueryCommonParam() { ParamKey = "taAccountIdList", ParamValue = taAccountIdList},
                new QueryCommonParam() { ParamKey = "tradeDate", ParamValue = tradeDate},
            };

            QueryCommonHelper.QueryCommon(statement, queryParams, new Action<List<TradeRateTmpConfig>>((configs) =>
            {
                UserManager.ExtenalTradeRateTmpConfigs = configs;
                if (successAction != null) successAction(configs);
            }), errorAction, "查询外部汇率模版配置表");
        }

        /// <summary>
        /// 查询资金账户汇率
        /// </summary>
        /// <param name="taAccountIdList">The ta account identifier list.</param>
        /// <param name="successAction">The success action.</param>
        /// <param name="errorAction">The error action.</param>
        public void QueryTaAccountExchangeRate(string taAccountIdList, Action<List<TradeRateTmpConfig>> successAction, Action<ErrorEntity> errorAction)
        {
            var statement = QueryStatement.TaAccountExchangeRate;
            var queryParams = new List<QueryCommonParam>()
            {
                new QueryCommonParam() { ParamKey = "taAccountIdList", ParamValue = taAccountIdList},  
            };

            QueryCommonHelper.QueryCommon(statement, queryParams, new Action<List<TradeRateTmpConfig>>((configs) =>
            {
                UserManager.TaAccountExchangeRateConfigs = configs;
                if (successAction != null) successAction(configs);
            }), errorAction, "查询资金账户汇率");
        }

        /// <summary>
        /// 获取行情交易日
        /// </summary>
        /// <param name="successAction"></param>
        /// <param name="errorAction"></param>
        public void QuoteSourceGroupMarketDate(Action<List<QuoteSourceGroupMarketData>> successAction, Action<ErrorEntity> errorAction)
        {
            var statement = QueryStatement.QuoteSourceGroupMarketDate;
            var queryParams = new List<QueryCommonParam>()
            {
                
            };

            QueryCommonHelper.QueryCommon(statement, queryParams, new Action<List<QuoteSourceGroupMarketData>>((configs) =>
            {
                CacheManager.QuoteSourceGroupMarketDatas = configs;
                if (successAction != null) successAction(configs);
            }), errorAction, "获取行情交易日失败");
        }
    }
}