using Lskj.Push.Common;
using Lskj.Push.Util;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading.Tasks;

namespace Lskj.Push.Report
{
    class ReportClient:BaseHttpClient
    {
        private  const String REPORT_HOST_NAME = "https://report.jpush.cn";
        private  const String REPORT_RECEIVE_PATH = "/v2/received";
        private const String REPORT_RECEIVE_PATH_V3 = "/v3/received";
        private const String REPORT_USER_PATH = "/v3/users";

        private String appKey;
        private String masterSecret;
        public ReportClient(String appKey, String masterSecret) 
        {
            this.appKey = appKey;
            this.masterSecret = masterSecret;        
        }
        public ReceivedResult getReceiveds(String msg_ids) 
        {
            checkMsgids(msg_ids);
            return getReceiveds_common(msg_ids, REPORT_RECEIVE_PATH);
        }
        public ReceivedResult getReceiveds_v3(String msg_ids)
        {
            checkMsgids(msg_ids);
            return getReceiveds_common(msg_ids, REPORT_RECEIVE_PATH_V3);
        }
        public  UsersResult    getUsers(TimeUnit timeUnit, String start, int duration)
        {
            String url = REPORT_HOST_NAME + REPORT_USER_PATH
                    + "?time_unit=" + timeUnit.ToString()
                    + "&start=" + start + "&duration=" + duration;
            String auth = Base64.getBase64Encode(this.appKey + ":" + this.masterSecret);
            ResponseWrapper response = this.sendGet(url, auth, null);

            return UsersResult.fromResponse(response);
        }
        public MessagesResult getReportMessages(params String[] msgIds)
        {
            return getReportMessages(StringUtil.arrayToString(msgIds));
        }
        public String checkMsgids(String msgIds)
        {

            if (string.IsNullOrEmpty(msgIds)) {
                throw new ArgumentException("msgIds param is required.");
            }
            Regex reg = new Regex(@"[^0-9, ]");
            if(reg.IsMatch(msgIds))
            {
                  throw new ArgumentException("msgIds param format is incorrect. "
                        + "It should be msg_id (number) which response from JPush Push API. "
                        + "If there are many, use ',' as interval. ");
            }
            msgIds = msgIds.Trim();
            if (msgIds.EndsWith(",")) {
                msgIds = msgIds.Substring(0, msgIds.Length - 1);
            }
            String[] splits = msgIds.Split(',');
            List<string> list = new List<string>();
            try {
                foreach (String s in splits) {
                    string trim = s.Trim();
                    if (!string.IsNullOrEmpty(trim))
                    {
                        int.Parse(trim);
                        list.Add(trim);
                    }
                }
                return StringUtil.arrayToString(list.ToArray());
            } catch (Exception) {
                throw new Exception("Every msg_id should be valid Integer number which splits by ','");
            }
            
        }

        private ReceivedResult getReceiveds_common(String msg_ids, string path)
        {
            String url = REPORT_HOST_NAME + path + "?msg_ids=" + msg_ids;
            String auth = Base64.getBase64Encode(this.appKey + ":" + this.masterSecret);
            ResponseWrapper rsp = this.sendGet(url, auth, null);
            ReceivedResult result = new ReceivedResult();
            List<ReceivedResult.Received> list = new List<ReceivedResult.Received>();

            Console.WriteLine("recieve content==" + rsp.responseContent);
            if (rsp.responseCode == System.Net.HttpStatusCode.OK)
            {
                list = (List<ReceivedResult.Received>)JsonTool.JsonToObject(rsp.responseContent, list);
                String content = rsp.responseContent;
            }
            result.ResponseResult = rsp;
            result.ReceivedList = list;
            return result;
        }
        private MessagesResult getReportMessages(String msgIds)
        {
            String checkMsgId = checkMsgids(msgIds);
            String url = REPORT_HOST_NAME + REPORT_RECEIVE_PATH + "?msg_ids=" + checkMsgId;
            String auth = Base64.getBase64Encode(this.appKey + ":" + this.masterSecret);
            ResponseWrapper response = this.sendGet(url, auth, null);

            return MessagesResult.fromResponse(response);

        }

   
       
    }
}