using System;

using Nest;

using System.Collections.Generic;

using System.Linq;

​

public class Program

{

    public static void Main()

        {

            var node = new Uri("https://pageviewtrack.monotype.com");

            var settings = new ConnectionSettings(node);

            var client = new ElasticClient(settings);

            settings.DefaultIndex("custfontid*");

​

            int page = 0;

            int pageSize = 10000;

​

            var scanResults = SearchService.SearchByDate(client, DateTime.UtcNow.AddDays(-1).Date, DateTime.UtcNow.Date, page, pageSize);

​

            var searchResponse = new ISearchResponse<PVR>

            {

                Total = (int)scanResults.Total,

                Page = page,

                Results = scanResults.Documents,

                ElapsedMilliseconds = (int)scanResults.Took,

                TotalPages = (int)Math.Ceiling(scanResults.Total / (double)pageSize)

            };

​

            Console.WriteLine($"Total result: {searchResponse.Total} \n Total pages: {searchResponse.TotalPages}");

            Console.WriteLine($"Page:  {searchResponse.Page} \n Results:  {searchResponse.Results.Count()}");

            Console.WriteLine($"ElapsedMilliseconds:  {searchResponse.ElapsedMilliseconds}");

​

            //var pvrList = SearchService.fetchDataAsync(client, scanResults.ScrollId);

​

            // Console.WriteLine($"Total Scan Elapsed in MilliSeconds: {totalScanTime} \n Total Scan Results: {pageViewTrackingList.Count()}");

            foreach (var response in searchResponse.Results)

            {

                Console.WriteLine($"CustomerId : {response.CustomerId} FontId : {response.FontId}  raw_time: {response.ReportingTime} \t referrer: {response.Refdomain} ");

            }

​

            //Console.ReadKey();

        }

    }

​

    [ElasticsearchType]

    public class PVR

    {

​

        [Text(Name = "customerId")]

        public string CustomerId { get; set; }

​

        [Text(Name = "raw_time")]

        public DateTime? RawTime { get; set; }

​

        [Number(NumberType.Long)]

        public long PageViewCount { get; set; }

​

        [Text(Name = "refdomain")]

        public string Refdomain { get; set; }

​

        [Text(Name = "apiType")]

        public string ApiType { get; set; }

​

        [Text(Name = "fontId")]

        public string FontId { get; set; }

​

        [Text(Name = "url_type")]

        public string UrlType { get; set; }

​

        [Text(Name = "filename")]

        public string FileName { get; set; }

​

        [Text(Name = "reporting_time")]

        public DateTime? ReportingTime { get; set; }

    }

    public class ISearchResponse<T>

    {

        public int Total { get; set; }

        public int Page { get; set; }

        public IEnumerable<T> Results { get; set; }

        public int ElapsedMilliseconds { get; set; }

        public int TotalPages { get; set; }

    }

​

    public class SearchService

    {

        public static List<PVR> pageViewTrackingList = new List<PVR>();

        public static Nest.ISearchResponse<PVR> SearchByDate(ElasticClient client, DateTime maxDate, DateTime minDate, int page, int pageSize)

        {

            try

            {

                var result = client.Search<PVR>(s => s

                        .AllTypes()

                        .From(page)

                        .Size(pageSize)

                        .MatchAll()

                        .Sort(so => so

                            .Ascending("reporting_time"))

                        .Query(q => q

                            .Bool(b => b

                                .Must(mu => mu

                                    .Match(m => m

                                        .Field(f => f.UrlType)

                                        .Query("MtPayGo")

                                    )

                                    ||

                                    mu.Match(m => m

                                               .Field(f => f.UrlType)

                                               .Query("MtDigitalAd")

                                           )

                                )

                                //.Must(mu => mu

                                //            .Match(m => m

                                //                .Field(f => f.ApiType)

                                //                .Query("css")

                                //            )

                                //            ||

                                //            mu.Match(m => m

                                //                        .Field(f => f.ApiType)

                                //                        .Query("da")

                                //                    )

                                //        )

                                //.Should(bs=>bs

                                //    .Term(t=>t.Field(p=>p.FontId)))

                                .Filter(fi => fi

                                     .DateRange(r => r

                                        .Field(f => f.ReportingTime)

                                        .GreaterThanOrEquals(maxDate)

                                        .LessThan(minDate)

                                    )

                                )

                            )

                        )

                        .Scroll("5m")

                    );

                return result;

            }

            catch (Exception ex)

            {

                throw ex;

            }

        }

}