using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Runtime.InteropServices;
using System.Runtime.Serialization;
//using Newtonsoft.Json;
using System.Text.RegularExpressions;
using System.Threading;

namespace SampleCSharp
{
    public unsafe delegate int FT_RTCallBack(void* pUser, //函数调用时，调用者传入的参数指针
                       int iQueryID, //函数调用时，返回给调用者，用于指明本次请求的ID
                       char* pResultsBuff,//数据查询返回的结果，JSON格式
                       int iBuffLength, //结果缓存区的长度
                       int ErrorCode,//错误代码
                       int Reserved//预留
                       );
    class Program
    {
        /*
         * E:\\THSDataInterface_Windows\\bin\\x86\\:该目录是用户本地的数据接口安装目录且修复的位数是32位，如果是64位则目录为E:\\THSDataInterface_Windows\\bin\\x64\\
         * FTDataInterface.dll为接口文件，该文件是32位的，如果是64位，则文件名称为FTDataInterface_x64.dll
         */

        public const int REG_OPER_UPDATE = 0x01;
        public const int REG_OPER_ADD = 0x02;
        public const int REG_OPER_DEL = 0x03;


        //修改下面路径为本地数据接口安装包路径；如果是64位则目录为E:\\THSDataInterface_Windows\\bin\\x64\\，文件名称为FTDataInterface_x64.dll
        const string strPath = @"E:\\THSDataInterface_Windows\\bin\\x86\\";
        const string strDllFileName = "FTDataInterface.dll";        
        const string strDllFile = strPath + strDllFileName;

        static void Main(string[] args)
        {
            /*登录函数，填写账号、密码
             */
            string strUserName = "账号";
            string strPassWord = "密码";
            int nRet = THS_iFinDLogin(strUserName, strPassWord);
            string strOut = "Login result:" + nRet;
            Console.WriteLine(strOut);
            Thread.Sleep(3000);

            _event = new AutoResetEvent(false);
            ThreadStart threadStart = new ThreadStart(testSample);
            Thread thread = new Thread(threadStart);
            thread.Start();
            _event.WaitOne();

            //登出函数
            //nRet = THS_iFinDLogout();
            //strOut = "Logout result:" + nRet;
            //Console.WriteLine(strOut);

            Console.ReadLine();
        }

        private static AutoResetEvent _event;
        public static void testSample()
        {
            //高频序列函数
            //HighFrequenceSequenceSample();

            //实时行情函数
            //RealtimeQuotesSample();

            //历史行情函数
            //HistoryQuotesSample();

            //基础数据函数
            //BasicDataSample();

            //日期序列函数
            //DateSequenceSample();

            //数据池函数
            //DataPoolSample();
			
			//专题报表函数
            DataReport();

            //EDB数据请求函数
            //EDBQuerySample();

            //日内快照
            //Snapshot();

            //数据使用量统计函数
            //DataStatisticsSample();

            //错误信息查询函数
            //GetErrorInfoSample();

            //新日期查询函数
            //DateQuerySample();

            //新日期偏移函数
            //DateOffsetSample();

            //日期统计函数
            //DateCountSample();

            //Thread.Sleep(6000);
            //_event.Set();

        }

        static void HighFrequenceSequenceSample()
        {
            string strOut;
            //请求高频数据  传递5个字符串参数,返回数据
            /*高频序列函数格式为THS_HighFrequenceSequence('thsCodes','indicators','params','startTime','endTime')
             * thsCodes不可以为空，且支持多个输入，当有多个thsCodes则用英文半角逗号分隔，如thsCode1,thsCode2,thsCode3
             * indicators不可以为空，且支持多个输入，当有多个indicators则用英文半角分号分隔，如indicator1;indicator2;indicator3
             * params不可以为空，且支持多个输入，当使用默认的参数时可以使用'default'表示，当用户只对其中某个指标设定而其他参数保持默认时，只需要输入设定的参数即可，如'Interval:5'
             * startDate的日期输入格式为YYYY-MM-DD HH:MM:SS
             * endDate的日期输入格式为YYYY-MM-DD HH:MM:SS
             * 老版本：THS_HighFrequenceSequence('thsCode1,thsCode2,thsCode3','indicator1;indicator2;indicator3','param1,param2,param3','startTime','endTime')
             */
            strOut = THS_HighFrequenceSequence("301279.SZ,600000.SH", "open;high;low;close;avgPrice;volume;amount;change;changeRatio;turnoverRatio;sellVolume;buyVolume", "Fill:Original", "2021-12-31 09:15:00", "2021-12-31 15:15:00");
            Console.WriteLine(strOut);
        }

        static void Snapshot()
        {
            string strOut;
            //日内快照
            strOut = THS_Snapshot("300033.SZ", "open;high;low", "", "2022-06-13 09:15:00", "2022-06-13 15:15:00");
            Console.WriteLine(strOut);
        }

        static void RealtimeQuotesSample()
        {
            string strOut;
            //请求实时数据
            /*实时行情函数的格式为THS_RealtimeQuotes('thsCodes','indicators','params')
             * thsCodes不可以为空，且支持多个输入，当有多个thsCodes则用英文半角逗号分隔，如thsCode1,thsCode2,thsCode3
             * indicators不可以为空，且支持多个输入，当有多个indicators则用英文半角分号分隔，如indicator1;indicator2;indicator3
             * params不可以为空
             * 老版本：THS_RealtimeQuotes('thsCode1,thsCode2,thsCode3','indicator1;indicator2;indicator3','param1,param2,param3')
             * 第三个参数‘pricetype:1’为债券报价方式参数，超级命令生成其他证券类型的命令没有这个参数，但请不要填空，按照下面命令填写‘pricetype:1’
             */
            strOut = THS_RealtimeQuotes("300033.SZ,600000.SH", "open;high;low;latest;latestAmount;latestVolume", "pricetype:1");
            Console.WriteLine(strOut);
        }

        static void HistoryQuotesSample()
        {
            string strout;
            //请求历史行情
            /*
             *通过历史行情函数获取同花顺(300033.SZ)从2016-08-23到2016-11-23的开高低收数据
             *历史行情函数格式为THS_HistoryQuotes('thsCodes','indicators','params','startDate','endDate')
             *thsCodes不可以为空，且支持多个输入，当有多个thsCodes则用英文半角逗号分隔，如thsCode1,thsCode2,thsCode3
             *indicators不可以为空，且支持多个输入，当有多个indicators则用英文半角分号分隔，如indicator1;indicator2;indicator3
             *params不可以为空，且支持多个输入，当使用默认的参数时可以使用'default'表示，当用户只对其中某个指标设定而其他参数保持默认时，只需要输入设定的参数即可，如'period:W'
             *startDate的日期输入格式为YYYY-MM-DD
             *endDate的日期输入格式为YYYY-MM-DD
             *老版本：THS_HistoryQuotes('thsCode1,thsCode2,thsCode3','indicator1;indicator2;indicator3','param1,param2,param3','startDate','endDate')
             */
            strout = THS_HistoryQuotes("300033.SZ,600000.SH", "open,high,low,close", "fill:Blank", "2021-11-09", "2021-12-08");
            Console.WriteLine(strout);
        }

        static void BasicDataSample()
        {
            string strOut;
            //请求基础数据
            /*基础数据THS_BasicData('thsCodes','function','params');支持多证券单指标输入
             * thsCodes不可以为空，且支持多个输入，当有多个thsCodes则用英文半角逗号分隔，如thsCode1,thsCode2,thsCode3
             * function不可以为空，且当前只支持单个function，目前函数名称可以在【iFinD终端-工具-数据接口-指标函数查询工具】查看
             * params可以为空，也可以有多个，当有多个params时则用英文半角逗号分隔，如param1,param2,param3
             * THS_BasicData('thsCode1,thsCode2,thsCode3','function','param1,param2,param3')
             */
            strOut = THS_BasicData("300033.SZ,600000.SH", "ths_total_shares_stock;ths_float_ashare_stock", "2022-01-08;2022-01-08");
            Console.WriteLine(strOut);
        }

        static void DateSequenceSample()
        {
            string strOut;
            //请求日期序列
            /*日期系列函数格式为THS_DateSequence('thsCodes','indicators','params','startDate','endDate')
             * thsCodes不可以为空，且支持多个输入，当有多个thsCodes则用英文半角逗号分隔，如thsCode1,thsCode2,thsCode3
             * indicators不可以为空，且支持多个输入，当有多个indicators则用英文半角分号分隔，如indicator1;indicator2;indicator3
             * params不可以为空，且支持多个输入，当使用默认的参数时可以使用'default'表示，当用户只对其中某个指标设定而其他参数保持默认时，只需要输入设定的参数即可，如'Interval:M'
             * startDate的日期输入格式为YYYY-MM-DD
             * endDate的日期输入格式为YYYY-MM-DD
             * 老版本：THS_DateSequence('thsCode1,thsCode2,thsCode3','indicator1;indicator2;indicator3','param1,param2,param3','startDate','endDate')
             */
            strOut = THS_DateSerial("000001.SH", "ths_pe_index;ths_pb_index;ths_ps_index", "100,100;100,100;100,100", "Fill:Blank,block:history", "2021-03-23", "2021-04-23");
            Console.WriteLine(strOut);
        }

        static void DataPoolSample()
        {
            string strOut;
            //请求数据池
            /*
             * 数据池函数格式为THS_DataPool('modelName','inputParams','outputParams')
             * modelName不可以为空，且一次只能输入一个
             * inputParams用英文半角分号隔开，如inputParam1;inputParam2;inputParam3
             * outputParams用英文半角冒号赋值，用英文半角逗号分隔，Y表示该字段输出，N表示该字段不输出，如果不写则默认为Y,如outputParam1:Y,outputParam2:Y,outputParam3:N
             * THS_DataPool('modelName','inputParam1;inputParam2;inputParam3','outputParam1,outputParam2,outputParams3')
             * 【001005010】是板块ID，目前板块ID可以在【iFinD终端-工具-数据接口-板块ID查询工具】查看
             */
            strOut = THS_DataPool("block", "最新;001005010", "date:Y,thscode:Y,security_name:Y,security_name_in_time:Y");
            Console.WriteLine(strOut);

        }
		
		 static void DataReport()
        {
            string strOut;
            strOut = THS_DR("p00001", "sclx=沪深两市", "p00001_f001:Y,p00001_f002:Y,p00001_f005:Y,p00001_f007:Y");
            Console.WriteLine(strOut);

        }

        static void EDBQuerySample()
        {
            string strout;
            //请求EDB宏观经济数据
            /*EDB数据请求函数格式为THS_EDBQuery('indicatorIDs','startDate','endDate')
             * indicatorIDs不可以为空，支持多个ID输入。指标ID可以在【iFinD终端-工具-数据接口】中的指标ID查询工具查看
             * startDate的日期输入格式为YYYY-MM-DD
             * endDate的日期输入格式为YYYY-MM-DD
             */
            strout = THS_EDBQuery("M001620247", "2020-01-01", "2020-12-31");
            Console.WriteLine(strout);
        }

        static void DataStatisticsSample()
        {
            string strout;
            //用户数据使用量查询函数
            /*
             * 数据使用量查询函数，用于用户查询自身账号的数据使用量，其中行情数据是15000万条/周，基础数据是500万条/周，EDB数据是500条/周；
             * 通过高频序列函数、历史行情函数和实时行情函数获取的数据统称为行情数据；
             * 通过基础数据函数、日期序列函数和数据池函数获取的数据统称为基础数据；
             * 通过EDB数据请求函数获取的数据统称为EDB数据。
             */
            strout = THS_DataStatistics();
            Console.WriteLine(strout);
        }

        static void GetErrorInfoSample()
        {
            string strout;
            //错误代码信息查询
            /*错误信息查询函数，对于函数执行后的errorcode进行查询，了解错误信息
             * value的值不可以为空，并且value的值必须是枚举出的错误值
             */
            strout = THS_GetErrorInfo(-1);
            Console.WriteLine(strout);
        }

        static void DateQuerySample()
        {
            string strout;
            //方便用户在其自定义的时间区间内查询交易所的交易日历
            /*
             * 交易日期/日历日期查询函数
             * 日期查询函数的格式是THS_DateQuery('exchange','dateType:value,period:value,dateFormat:value','startDate','endDate')
             * exchange不可以为空
             * dateType，period，dateFormat的值也不可以为空
             * startDate的日期输入格式为YYYY-MM-DD
             * endDate的日期输入格式为YYYY-MM-DD
             */
            strout = THS_Date_Query("212001", "mode:1,dateType:0,period:D,dateFormat:0", "2022-05-19", "2022-05-19");
            Console.WriteLine(strout);
        }

        static void DateOffsetSample()
        {
            string strout;
            //根据用户指定一个日期和偏移量查询到相应的交易日期
            /*
             * 根据指定日期和偏移量找到相应的日期
             * 日期偏移函数的格式是THS_DateQuery('exchange','dateType:value,period:value,dateFormat:value','date')
             * exchange不可以为空
             * dateType，period，dateFormat的值也不可以为空
             * date的日期输入格式为YYYY-MM-DD
             */
            strout = THS_Date_Offset("212001", "dateType:0,period:D,offset:0,dateFormat:0,output:singledate", "2022-05-19");
            Console.WriteLine(strout);
        }

        static void DateCountSample()
        {
            string strout;
            //方便用户统一在其自定义的时间区间内查询交易日期的总数
            /*
             * 统计指定时间区间和日期类型中的日期数量
             * 日期查询函数的格式是THS_DateCount('exchange','dateType:value,period:value,dateFormat:value','startDate','endDate')
             * exchange不可以为空
             * dateType，period，dateFormat的值也不可以为空
             * startDate的日期输入格式为YYYY-MM-DD
             * endDate的日期输入格式为YYYY-MM-DD
             */
            strout = THS_DateCount("SSE", "dateType:trade,period:D,dateFormat:0", "2016-07-21", "2017-08-21");
            Console.WriteLine(strout);
        }


/********************************************************************************************************************************************************************/

        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)]
        public static extern int FT_ifinDLogin(string strUserName, string strPassWord, int nType);

        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)]
        public static extern int FT_ifinDLogout();

        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)] 
        unsafe public static extern IntPtr FTQueryTHS_SynDateCountC(string ExchangeCode, //交易所
                                                     string Param, //参数
                                                     string startDate, //函数需要的参数
                                                     string endDate,
                                                     out  char* pret
                                                     );


        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)] 
        unsafe public static extern IntPtr FTQueryTHS_SynDateOffsetC(string ExchangeCode, //交易所
                                                     string Param, //参数
                                                     string endDate,
                                                     out  char* pret
                                                     );


        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)]
        unsafe public static extern IntPtr FTQueryTHS_SynDate_OffsetC(string ExchangeCode, //交易所
                                                     string Param, //参数
                                                     string endDate,
                                                     out  char* pret
                                                     );


        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)] 
        unsafe public static extern IntPtr FTQueryTHS_SynDateQueryC(string ExchangeCode, //交易所
                                                     string Param, //参数
                                                     string startDate, //函数需要的参数
                                                     string endDate,
                                                     out  char* pret
                                                     );



        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)]
        unsafe public static extern IntPtr FTQueryTHS_SynDate_QueryC(string ExchangeCode, //交易所
                                                     string Param, //参数
                                                     string startDate, //函数需要的参数
                                                     string endDate,
                                                     out  char* pret
                                                     );



        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)]
        unsafe public static extern int FTQueryTHS_SynDataPoolC(string DataPoolName, //数据池
                                                     string jsonIndicator, //
                                                     string jsonParam, //函数需要的参数
                                                     out  char* pret
                                                     );



        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)]
		unsafe public static extern int FTQueryTHS_SynDRC(string DataReportID, //专题报表ID
                                                    string jsonIndicator, //报表参数
                                                    string jsonParam, //报表列名称
                                                    out  char* pret
                                                    );



        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)]
        unsafe public static extern int FTQueryTHS_SynDateSeriesC(string THSCodes, //同花顺代码
                                                     string jsonIndicator, //指标及指标需要的参数
                                                     string jsonParam, //函数需要的参数
                                                     string begintime,
                                                     string endtime,
                                                     out  char* pret
                                                     );

		[DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)] 
        unsafe public static extern int FTQueryTHS_SynDateSerialC(string THSCodes, //同花顺代码
                                                     string jsonIndicator, //指标
                                                     string jsonParam, //函数需要的参数
													 string globalParam,
                                                     string begintime,
                                                     string endtime,
                                                     out  char* pret
                                                     );


        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)] 
        unsafe public static extern int FTQueryTHS_SynBasicDataC(string THSCodes, //同花顺代码
                                                     string jsonIndicator, //指标
                                                     string jsonParam, //函数需要的参数
                                                     out  char* pret
                                                     );



        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)] 
        unsafe public static extern int FTQueryTHS_SynHisQuoteC(string THSCodes, //同花顺代码
                                                     string jsonIndicator, //指标及指标需要的参数
                                                     string jsonParam, //函数需要的参数
                                                     string begintime,
                                                     string endtime,
                                                     out  char* pret
                                                     );

        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)] 
        unsafe public static extern int FTQueryTHS_SynRTByJsonC(string THSCodes, //同花顺代码
                                                     string jsonIndicator, //指标及指标需要的参数
                                                     string jsonParam, //函数需要的参数
                                                     out  char* pret
                                                     );

        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)]
        unsafe public static extern int FTQueryTHS_SynHFQByJsonC(string THSCodes,
                                                      string jsonIndicator,
                                                      string jsonParam,
                                                      string begintime,
                                                      string endtime,
                                                      out  char* pret);

        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)]
        unsafe public static extern int FTQueryTHS_SynEDBQueryC(string jsonIndicator,                                                    
                                                      string begintime,
                                                      string endtime,
                                                      out  char* pret);

        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)]
        unsafe public static extern int FTQueryTHS_SynSnapshotQueryC(string THSCodes,
                                                      string jsonIndicator,
                                                      string jsonParam,
                                                      string begintime,
                                                      string endtime,
                                                      out  char* pret);

        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)]
        unsafe public static extern int FTQueryTHS_SynGetErrorInfoC(int errorcode,
                                                      out  char* pret);

        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)]
        unsafe public static extern IntPtr FTQuery_SynDataStasticsC(out int errorcode, void* reserve1, void* reserve2, void* reserve3);



        [DllImport(strDllFile, CallingConvention = CallingConvention.StdCall, CharSet = CharSet.Unicode)]
        unsafe public static extern void DeleteBuffer(char* pret);

///////////////////////////////////////////////////////////////////////////////////////////////////////////////////
//封装的函数命令  直接按照以下封装接口调用即可

        static int THS_iFinDLogin(string UserAcount, string Password)
        {
            int nRet = FT_ifinDLogin(UserAcount, Password, 0);
            return nRet;
        }

        static int THS_iFinDLogout()
        {
            int nRet = FT_ifinDLogout();
            return nRet;
        }

        unsafe static string THS_HighFrequenceSequence(string THSCodes,
                                                      string jsonIndicator,
                                                      string jsonParam,
                                                      string begintime,
                                                      string endtime)//高频序列新版接口
        {
            string strOut;
            char* Pret;
            FTQueryTHS_SynHFQByJsonC(THSCodes, jsonIndicator, jsonParam, begintime, endtime, out  Pret);
            IntPtr data = new IntPtr(Pret);
            strOut = Marshal.PtrToStringUni(data);
            DeleteBuffer(Pret);
            return strOut;
        }

        unsafe static string THS_Snapshot(string THSCodes,
                                                      string jsonIndicator,
                                                      string jsonParam,
                                                      string begintime,
                                                      string endtime)//日内快照
        {
            string strOut;
            char* Pret;
            FTQueryTHS_SynSnapshotQueryC(THSCodes, jsonIndicator, jsonParam, begintime, endtime, out  Pret);
            IntPtr data = new IntPtr(Pret);
            strOut = Marshal.PtrToStringUni(data);
            DeleteBuffer(Pret);
            return strOut;
        }

        unsafe static string THS_RealtimeQuotes(string THSCodes, //同花顺代码
                                                     string jsonIndicator, //指标及指标需要的参数
                                                     string jsonParam //函数需要的参数
                                                       )//实时行情新版接口
        {
            string strOut;
            char* Pret;
            FTQueryTHS_SynRTByJsonC(THSCodes, jsonIndicator, jsonParam, out  Pret);
            IntPtr data = new IntPtr(Pret);
            strOut = Marshal.PtrToStringUni(data);
            DeleteBuffer(Pret);
            return strOut;
        }

        unsafe static string THS_HistoryQuotes(string THSCodes, //同花顺代码
                                                     string jsonIndicator, //指标及指标需要的参数
                                                     string jsonParam, //函数需要的参数
                                                     string begintime,
                                                     string endtime
                                                     )//历史行情新版接口
        {
            string strOut;
            char* Pret;
            FTQueryTHS_SynHisQuoteC(THSCodes, jsonIndicator, jsonParam, begintime, endtime, out  Pret);
            IntPtr data = new IntPtr(Pret);
            strOut = Marshal.PtrToStringUni(data);
            DeleteBuffer(Pret);
            return strOut;
        }

        unsafe static string THS_BasicData(string THSCodes, //同花顺代码
                                                     string jsonIndicator, //指标
                                                     string jsonParam //函数需要的参数
                                                     )//基础数据新版接口
        {
            string strOut;
            char* Pret;
            FTQueryTHS_SynBasicDataC(THSCodes, jsonIndicator, jsonParam, out  Pret);
            IntPtr data = new IntPtr(Pret);
            strOut = Marshal.PtrToStringUni(data);
            DeleteBuffer(Pret);
            return strOut;
        }

        // unsafe static string THS_DS(string THSCodes, //同花顺代码
                                                     // string jsonIndicator, //指标及指标需要的参数
                                                     // string jsonParam, //函数需要的参数
                                                     // string begintime,
                                                     // string endtime)//日期序列新版接口
        // {
            // string strOut;
            // char* Pret;
            // FTQueryTHS_SynDateSeriesC(THSCodes, jsonIndicator, jsonParam, begintime, endtime, out  Pret);
            // IntPtr data = new IntPtr(Pret);
            // strOut = Marshal.PtrToStringUni(data);
            // DeleteBuffer(Pret);
            // return strOut;
        // }

        unsafe static string THS_DateSerial(string THSCodes, //同花顺代码
                                                     string jsonIndicator, //指标
                                                     string jsonParam, //函数需要的参数
													 string globalParam,
                                                     string begintime,
                                                     string endtime)//日期序列新版接口
        {
            string strOut;
            char* Pret;
            FTQueryTHS_SynDateSerialC(THSCodes, jsonIndicator, jsonParam, globalParam, begintime, endtime, out  Pret);
            IntPtr data = new IntPtr(Pret);
            strOut = Marshal.PtrToStringUni(data);
            DeleteBuffer(Pret);
            return strOut;
        }

        unsafe static string THS_DataPool(string DataPoolName, //数据池
                                                     string jsonIndicator, //
                                                     string jsonParam //函数需要的参数
                                                     )//数据池新版接口
        {
            string strOut;
            char* Pret;
            FTQueryTHS_SynDataPoolC(DataPoolName, jsonIndicator, jsonParam, out  Pret);
            IntPtr data = new IntPtr(Pret);
            strOut = Marshal.PtrToStringUni(data);
            DeleteBuffer(Pret);
            return strOut;
        }
		
		unsafe static string THS_DR(string DataReportID, //专题报表ID
                                             string jsonIndicator, //报表参数
                                             string jsonParam //报表列
                                             )//专题报表接口
        {
            string strOut;
            char* Pret;
            FTQueryTHS_SynDRC(DataReportID, jsonIndicator, jsonParam, out  Pret);
            IntPtr data = new IntPtr(Pret);
            strOut = Marshal.PtrToStringUni(data);
            DeleteBuffer(Pret);
            return strOut;
        }

        unsafe static string THS_Date_Query(string ExchangeCode, //交易所
                                                     string Param, //参数
                                                     string startDate, //函数需要的参数
                                                     string endDate)//日期查询新版接口
        {
            string strOut;
            char* Pret;
            FTQueryTHS_SynDate_QueryC(ExchangeCode, Param, startDate, endDate, out  Pret);
            IntPtr data = new IntPtr(Pret);
            strOut = Marshal.PtrToStringUni(data);
            DeleteBuffer(Pret);
            return strOut;
        }

        unsafe static string THS_Date_Offset(string ExchangeCode, //交易所
                                                     string Param, //参数
                                                     string endDate)//日期便宜新版接口
        {
            string strOut;
            char* Pret;
            FTQueryTHS_SynDate_OffsetC(ExchangeCode, Param, endDate, out  Pret);
            IntPtr data = new IntPtr(Pret);
            strOut = Marshal.PtrToStringUni(data);
            DeleteBuffer(Pret);
            return strOut;
        }

        unsafe static string THS_DateCount(string ExchangeCode, //交易所
                                                     string Param, //参数
                                                     string startDate, //函数需要的参数
                                                     string endDate)//日期数量新版接口
        {
            string strOut;
            char* Pret;
            FTQueryTHS_SynDateCountC(ExchangeCode, Param, startDate, endDate,  out  Pret);
            IntPtr data = new IntPtr(Pret);
            strOut = Marshal.PtrToStringUni(data);
            DeleteBuffer(Pret);
            return strOut;
        }

        unsafe static string THS_EDBQuery(string jsonIndicator,
                                                      string begintime,
                                                      string endtime
                                                      )
        {
            string strOut;
            char* Pret;
            FTQueryTHS_SynEDBQueryC(jsonIndicator, begintime, endtime, out  Pret);
            IntPtr data = new IntPtr(Pret);
            strOut = Marshal.PtrToStringUni(data);
            DeleteBuffer(Pret);
            return strOut;
        }

        unsafe static string THS_DataStatistics()
        {
            string strOut;
            int code;
            strOut = Marshal.PtrToStringUni(FTQuery_SynDataStasticsC(out code, null, null, null));
            return strOut;
        }

        unsafe static string THS_GetErrorInfo(int code)
        {
            string strOut;
            char* Pret;
            FTQueryTHS_SynGetErrorInfoC(code, out  Pret);
            IntPtr data = new IntPtr(Pret);
            strOut = Marshal.PtrToStringUni(data);
            DeleteBuffer(Pret);
            return strOut;
        }
/**********************************************************************************************************************************************/

    }
}