using com.igetui.api.openservice;
using com.igetui.api.openservice.igetui;
using com.igetui.api.openservice.igetui.template;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Data;

namespace MesMessage
{
    public static class GeTuiService
    {
        // 个推接口地址（使用 HTTPS）
        private static readonly string HOST = "https://api.getui.com/apiex.htm";
        private static readonly string APPID = "X3I10VqaROAH8C7ElIc1L5";
        private static readonly string APPKEY = "V425beWn5K65BcOYKTcXx8";
        private static readonly string MASTERSECRET = "LOXAgRbXS98NxHKUXmlJQ";
        static DBHelper oCN = new DBHelper();
        static DataSet ds = new DataSet();

        // 注意：不再声明静态 IGtPush 字段，避免类型初始化异常

        /// <summary>
        /// 单条消息推送（工作联系单）
        /// </summary>
        public static void PubishSingle(int HInterID)
        {


            try
            {
                JObject NameMsgKVP = new JObject();
                ds = oCN.RunProcReturn($@"
                    select * from h_v_OA_WorkLinkBillAllList where hmainid = {HInterID}
                    select * from Gy_UserClientIdRelation
                ", "h_v_OA_WorkLinkBillAllList");
                NotificationTemplate template = null;
                ConcurrentDictionary<string, List<string>> userClientIDDictionary = new ConcurrentDictionary<string, List<string>>();
                // 将用户设备关联表 收集为 Map
                if (ds.Tables[1].Rows.Count > 0)
                {
                    foreach (DataRow row in ds.Tables[1].Rows)
                    {
                        if (userClientIDDictionary.ContainsKey(row["HUserName"].ToString()))
                        {
                            userClientIDDictionary[row["HUserName"].ToString()].Add(row["HClientID"].ToString());
                        }
                        else
                        {
                            userClientIDDictionary.TryAdd(row["HUserName"].ToString(), new List<string>() { row["HClientID"].ToString() });
                        }
                    }
                }
                if (ds.Tables[0].Rows.Count > 0)
                {
                    string title = ds.Tables[0].Rows[0]["主题"].ToString();
                    string content = ds.Tables[0].Rows[0]["内容"].ToString();
                    template = GetNotificationTemplate(title, content, "/pages/ZLGL/OA_WorkLink/OA_WorkLinkBillQuery", "0"); // 跳转到工作联系单查询页面

                    bool pushSuccess = false;
                    // 广播
                    if (ds.Tables[0].Rows[0]["发送类型"].ToString() == "公共")
                    {
                        string rule = GetSystemRule();
                        if (rule == "华舟")
                        {
                            // 推送给接收人 和 抄送人
                            foreach (DataRow row in ds.Tables[0].Rows)
                            {
                                List<string> clientIDList = new List<string>();
                                if (userClientIDDictionary.ContainsKey(row["接收人"].ToString()))
                                {
                                    clientIDList = userClientIDDictionary[row["接收人"].ToString()];
                                }
                                else if (userClientIDDictionary.ContainsKey(row["抄送接收人"].ToString()))
                                {
                                    clientIDList = userClientIDDictionary[row["抄送接收人"].ToString()];
                                }


                                foreach (string clientID in clientIDList)
                                {
                                    pushSuccess = PushMessageToSingle(template, clientID);

                                }
                            }
                        }
                        else
                        {
                            // 遍历 全推送
                            foreach (DataRow row in ds.Tables[1].Rows)
                            {
                                pushSuccess = PushMessageToSingle(template, row["HClientID"].ToString());
                            }
                        }
                    }
                    else // 单独推送
                    {
                        // 推送给接收人 和 抄送人
                        foreach (DataRow row in ds.Tables[0].Rows)
                        {
                            List<string> clientIDList = new List<string>();
                            if (userClientIDDictionary.ContainsKey(row["接收人"].ToString()))
                            {
                                clientIDList = userClientIDDictionary[row["接收人"].ToString()];
                            }
                            else if (userClientIDDictionary.ContainsKey(row["抄送接收人"].ToString()))

                            {
                                clientIDList = userClientIDDictionary[row["抄送接收人"].ToString()];
                            }


                            foreach (string clientID in clientIDList)
                            {
                                pushSuccess = PushMessageToSingle(template, clientID);

                            }
                        }
                    }

                    if (!pushSuccess)
                    {
                        // 个推 推送不成功(内网环境) 使用webSocket进行推送
                        // TODO: 使用 rabbitMQ 实现消息队列
                        // WebSocketServer.PushOne(HInterID);
                    }
                }
            }
            catch (Exception ex)
            {
                DBHelper.CustomWriteLog(ex.ToString(), DateTime.Now.ToString("yyyy-MM-dd"));
                return;
            }
        }

        /// <summary>
        /// 单推消息（通知模板）
        /// </summary>
        private static bool PushMessageToSingle(NotificationTemplate template, string clientId)
        {
            try
            {
                // 每次调用创建新实例，避免共享状态
                IGtPush push = new IGtPush(HOST, APPKEY, MASTERSECRET);

                SingleMessage message = new SingleMessage
                {
                    IsOffline = true,
                    OfflineExpireTime = 1000 * 3600 * 12, // 12小时
                    Data = template
                };

                Target target = new Target
                {
                    appId = APPID,
                    clientId = clientId
                };

                string pushResult = push.pushMessageToSingle(message, target);
                DBHelper.CustomWriteLog($"个推推送结果: {pushResult}", DateTime.Now.ToString("yyyy-MM-dd"));
                return true;
            }
            catch (RequestException ex)
            {
                // 可尝试重发（使用原请求ID）
                DBHelper.CustomWriteLog($"推送异常，请求ID: {ex.RequestId}, 错误: {ex}", DateTime.Now.ToString("yyyy-MM-dd"));
                return false;
            }
            catch (Exception ex)
            {
                DBHelper.CustomWriteLog($"推送异常: {ex}", DateTime.Now.ToString("yyyy-MM-dd"));
                return false;
            }
        }

        /// <summary>
        /// 创建通知模板（携带透传数据）
        /// </summary>
        public static NotificationTemplate GetNotificationTemplate(string title, string content, string pagePath, string itemId)
        {
            var template = new NotificationTemplate
            {
                AppId = APPID,
                AppKey = APPKEY,
                Title = title,
                Text = content,
                Logo = "icon",                 // 应用内图标名称（根据实际修改）
                LogoURL = "",                   // 网络图标，可留空
                IsRing = true,
                IsVibrate = true,
                IsClearable = true,
                TransmissionType = 1             // 1=点击通知触发客户端透传回调
            };

            // 透传内容：JSON 格式
            var customData = new Dictionary<string, string>
            {
                { "pagePath", pagePath },
                { "itemId", itemId }
            };
            template.TransmissionContent = JsonConvert.SerializeObject(customData);

            return template;
        }

        /// <summary>
        /// 获取系统参数 OA_AndengFlowRule_XT 的值
        /// </summary>
        private static string GetSystemRule()
        {
            string sql = "select HValue from xt_SystemParameter where HKey='WMS_CampanyName'";
            DataSet ds = oCN.RunProcReturn(sql, "xt_SystemParameter");
            if (ds != null && ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
                return ds.Tables[0].Rows[0]["HValue"].ToString();
            return null;
        }

    }
}