using Newtonsoft.Json;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Drawing.Drawing2D;
using System.Drawing.Imaging;
using System.IO;
using System.Linq;
using System.Runtime.InteropServices;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using uPLibrary.Networking.M2Mqtt;
using uPLibrary.Networking.M2Mqtt.Messages;
using WindowsFormsApp1.Common;
using WindowsFormsApp1.Controllers;
using WindowsFormsApp1.Entity;
using WindowsFormsApp1.Helper;
using WindowsFormsApp1.Item;

namespace WindowsFormsApp1
{
    public partial class Form1 : Form
    {
        private Metafile metafile1;
        private Graphics.EnumerateMetafileProc metafileDelegate;
        private MqttClient client = null;

        public Form1()
        { 
            InitializeComponent();
            
        }


        string _UserNo { get { return MqttconfigHelp.UserName.Trim(); } }
        string _PW { get { return MqttconfigHelp.Password.Trim(); } }
        private bool MetafileCallback(EmfPlusRecordType recordType, int flags, int dataSize, IntPtr data, PlayRecordCallback callbackData)
        {
            byte[] dataArray = null;
            if (data != IntPtr.Zero)
            {

                dataArray = new byte[dataSize];
                Marshal.Copy(data, dataArray, 0, dataSize);
                //GdipComment
                metafile1.PlayRecord(recordType, flags, dataSize, dataArray);
                switch (recordType) //记录类型
                {

                    case EmfPlusRecordType.Object: //对象
                    case EmfPlusRecordType.DrawLines: //线
                    case EmfPlusRecordType.SetPageTransform: //设置页变换
                        break;
                }
            }
            Console.WriteLine(recordType.ToString());
            return true;
        }

        protected override void OnPaint(PaintEventArgs e)
        {
            //PointF destPoint = new PointF(e.ClipRectangle.X, e.ClipRectangle.Y);
           //e.Graphics.EnumerateMetafile(metafile1, destPoint, metafileDelegate);

        }
        protected override void OnClosed(EventArgs e)
        {
            base.OnClosed(e);
            //metafile1.Dispose();
        }
        string emf { get; set; }
        /// <summary>
        /// 导出为 Emf 或 Wmf 文件
        /// </summary>
        /// <param name="filePath">文件路径</param>
        /// <returns>是否成功</returns>
        private bool Export(string filePath)
        {
           
            filePath = @"D:\CompanyCode\DIXWeb\src\WindowsFormsApp1\imgs\imgup.jpg";
            //filePath = @"C:\Users\Administrator\Desktop\Debug\1.jpg";
            FileInfo fi = new FileInfo(filePath);
            emf = Path.GetDirectoryName(filePath) + "\\1.emf";
            fi.CopyTo(emf,true);
            try
            {
                Bitmap bmp = new Bitmap(2220, 2220);
                Graphics gs = Graphics.FromImage(bmp);
                Metafile mf = new Metafile(emf, gs.GetHdc());

                Graphics g = Graphics.FromImage(mf);
                //string sf = System.IO.Path.GetDirectoryName(filePath) + "1.wmf";
                //mf.Save(sf, ImageFormat.Wmf);
                Draw(g);
                g.Save();
                
                g.Dispose();
                mf.Dispose();

                return true;
            }
            catch(Exception er)
            {
                MessageBox.Show(er.Message);
                return false;
            }
        }
        /// <summary>
        /// 绘制图形
        /// </summary>
        /// <param name="g">用于绘图的Graphics对象</param>
        private void Draw(Graphics g)
        {
            HatchBrush hb = new HatchBrush(HatchStyle.LightUpwardDiagonal, Color.Black, Color.White);

            g.FillEllipse(Brushes.Gray, 10f, 10f, 200, 200);
            g.DrawEllipse(new Pen(Color.Black, 1f), 10f, 10f, 200, 200);

            g.FillEllipse(hb, 30f, 95f, 30, 30);
            g.DrawEllipse(new Pen(Color.Black, 1f), 30f, 95f, 30, 30);

            g.FillEllipse(hb, 160f, 95f, 30, 30);
            g.DrawEllipse(new Pen(Color.Black, 1f), 160f, 95f, 30, 30);

            g.FillEllipse(hb, 95f, 30f, 30, 30);
            g.DrawEllipse(new Pen(Color.Black, 1f), 95f, 30f, 30, 30);

            g.FillEllipse(hb, 95f, 160f, 30, 30);
            g.DrawEllipse(new Pen(Color.Black, 1f), 95f, 160f, 30, 30);

            g.FillEllipse(Brushes.Blue, 60f, 60f, 100, 100);
            g.DrawEllipse(new Pen(Color.Black, 1f), 60f, 60f, 100, 100);

            g.FillEllipse(Brushes.BlanchedAlmond, 95f, 95f, 30, 30);
            g.DrawEllipse(new Pen(Color.Black, 1f), 95f, 95f, 30, 30);

            g.DrawRectangle(new Pen(System.Drawing.Brushes.Blue, 0.1f), 6, 6, 208, 208);

            g.DrawLine(new Pen(Color.Black, 0.1f), 110f, 110f, 220f, 25f);
            g.DrawString("剖面图", new Font("宋体", 9f), Brushes.Green, 220f, 20f);
        }
        private void button1_Click(object sender, EventArgs e)
        {

           string MotifName=txtFilePath.Text.ToString();
            var db = SqlSugarConnection.SugarClient();
            List<Toprie_Motif> ToprieMotifList = db.SqlQueryable<Toprie_Motif>("select * from  Toprie_Motif").Where(m => m.IsVal == 0).ToList();

            if (ToprieMotifList.Where(m => m.MotifName == MotifName).ToList().Count() == 0)
            {
                if (!string.IsNullOrEmpty(MotifName))
                {
                    Toprie_Motif ToprieMotif = new Toprie_Motif();
                    ToprieMotif.Code = SnowFlakeSingle.Instance.NextId().ToString();
                    ToprieMotif.MotifName = MotifName;
                    ToprieMotif.Address = "";
                    ToprieMotif.Remark = "";
                    ToprieMotif.IsVal = 0;
                    ToprieMotif.CreateCode = "5105986045";
                    ToprieMotif.CreateTime = DateTime.Now;
                    InsertToprieMotif(ToprieMotif);
                    MessageBox.Show("新增成功", "提示");

                }else {
                    MessageBox.Show("请输入订阅主题", "提示");
                }
            }
            else{
                MessageBox.Show("当前主题已添加,无法重复添加", "提示");
            }
        }

        private void button2_Click(object sender, EventArgs e)
        {

        }
         

        /// <summary>
        /// 发布消息成功后调用的事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void client_MqttMsgPublished(object sender, MqttMsgPublishedEventArgs e)
        {
            MessageBox.Show("发布消息成功。", "信息");
        }

        /// <summary>
        /// 订阅主题成功后调用的事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void client_MqttMsgSubscribed(object sender, MqttMsgSubscribedEventArgs e)
        {
           
           
        }

        /// <summary>
        /// 取消订阅主题成功后调用的事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void client_MqttMsgUnsubscribed(object sender, MqttMsgUnsubscribedEventArgs e)
        {
            MessageBox.Show("取消订阅主题成功。", "信息");
        }

        /// <summary>
        /// 当接收到订阅主题的消息时调用的事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void client_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e)
        {
            SnowFlakeSingle.WorkId =1;


            try {
                this.Invoke(new Action(() =>
                {
                    txt_SubscribeMessage.Text += DateTime.Now.ToString("yyyy/MM/dd-HH:mm:ss") + "  Received topic: " + e.Topic + ", message: " + Encoding.UTF8.GetString(e.Message) + "\n";
                    string Topic = e.Topic;
                    string Message = Encoding.UTF8.GetString(e.Message);
                    bool DupFlag = e.DupFlag;
                    byte QosLevel = e.QosLevel;
                    bool Retain = e.Retain;

                    lbMsg.Items.Insert(0, Encoding.UTF8.GetString(e.Message));
                    lbMsg.Items.Insert(0, "订阅主题："+ Topic+ "*********************************************   --" + DateTime.Now.ToString("yyyy/MM/dd-HH:mm:ss"));

                    if (Message!= "getParam"){

                        ToreieItem ToreieItem = JsonConvert.DeserializeObject<ToreieItem>(Encoding.UTF8.GetString(e.Message));

                        List<Toprie> ToprieList = new List<Toprie>();

                        if (ToreieItem.sensorDatas != null && ToreieItem.sensorDatas.Count() > 0)
                        {

                            foreach (var item in ToreieItem.sensorDatas)
                            {

                                Toprie obj = new Toprie();
                                obj.Code = SnowFlakeSingle.Instance.NextId().ToString();
                                obj.motif = Topic;
                                obj.times = ToreieItem.times;
                                obj.flag = item.flag;
                                obj.CreateCode = "5105986045";
                                obj.CreateTime = DateTime.Now;

                                switch (item.flag)
                                {
                                    case FlagHelp.flag1:
                                    case FlagHelp.flag2:
                                    case FlagHelp.flag3:
                                    case FlagHelp.flag4:
                                    case FlagHelp.flag5:
                                    case FlagHelp.flag7:
                                        obj.val = item.value;
                                        break;
                                    case FlagHelp.flag6:
                                        obj.switcher = item.switcher;
                                        break;

                                    case FlagHelp.flag8:
                                        obj.lat = item.lat;
                                        obj.lng = item.lng;
                                        break;
                                    case FlagHelp.flagICCID:
                                        obj.str = item.str;
                                        break;
                                    default:
                                        continue;
                                }
                                ToprieList.Add(obj);

                            }
                        }

                        InsertListToprieList(ToprieList);
                        
                    }

                }));

            }
            catch (Exception ex) {

                string str = ex.ToString();

            }
        }

        /// <summary>
        /// 当连接断开时调用的事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void client_ConnectionClosed(object sender, EventArgs e)
        {
            MessageBox.Show("连接已断开。", "信息");
        }

        /// <summary>
        /// 连接
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btn_Connect_Click(object sender, EventArgs e)
        {
            try
            {
                string brokerAddress = MqttconfigHelp.BrokerAddress;
                int brokerPort = MqttconfigHelp.BrokerPort;
                client = new MqttClient(brokerAddress, brokerPort, false, null, null, MqttSslProtocols.None, null);  //实例化mqtt客户端

                string clientId =   Guid.NewGuid().ToString("N");  //生成32位全球唯一标识符
                client.Connect(clientId,"","");  //建立客户端连接

                client.MqttMsgPublished += client_MqttMsgPublished;  //发布消息成功后调用
                client.MqttMsgSubscribed += client_MqttMsgSubscribed;  //订阅主题成功后调用
                client.MqttMsgUnsubscribed += client_MqttMsgUnsubscribed;  //取消订阅主题成功后调用
                client.MqttMsgPublishReceived += client_MqttMsgPublishReceived;  //当接收到订阅主题的消息时调用
                client.ConnectionClosed += client_ConnectionClosed;  //连接断开后调用
                MessageBox.Show("连接成功。", "信息");// 
            }
            catch (Exception ex)
            {
                MessageBox.Show("连接失败!\n\r" + ex.Message.ToString(), "警告");
            }
        }

        /// <summary>
        /// 断开连接
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btn_DisConnect_Click(object sender, EventArgs e)
        {
            client.Disconnect();
        }

        /// <summary>
        /// 发布消息
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btn_Publish_Click(object sender, EventArgs e)
        {
            //string publishTopic = txt_PublishTopic.Text.ToString();  //发布的主题
            //string publishMessage = txt_PublishMessage.Text.ToString();  //发布的消息
            //client.Publish(publishTopic, Encoding.UTF8.GetBytes(publishMessage));  //发布消息
        }

        /// <summary>
        /// 订阅消息
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btn_Subscribe_Click(object sender, EventArgs e)
        {
           
            try {
                
                client = new MqttClient(MqttconfigHelp.BrokerAddress,MqttconfigHelp.BrokerPort, false, null, null, MqttSslProtocols.None, null);  //实例化mqtt客户端

                string clientId = Guid.NewGuid().ToString("N");  //生成32位全球唯一标识符
                client.Connect(clientId, MqttconfigHelp.UserName, MqttconfigHelp.Password);  //建立客户端连接

                client.MqttMsgPublished += client_MqttMsgPublished;  //发布消息成功后调用
                client.MqttMsgSubscribed += client_MqttMsgSubscribed;  //订阅主题成功后调用
                client.MqttMsgUnsubscribed += client_MqttMsgUnsubscribed;  //取消订阅主题成功后调用
                client.MqttMsgPublishReceived += client_MqttMsgPublishReceived;  //当接收到订阅主题的消息时调用
                client.ConnectionClosed += client_ConnectionClosed;//连接断开后调用

                string[] subscribeTopic = Toprie_MotifList().Split(',');  //可以同时订阅多个主题的消息，各主题之间用逗号分隔
                byte[] qosLevels = new byte[] { MqttMsgBase.QOS_LEVEL_AT_LEAST_ONCE };

                foreach (var item in subscribeTopic){
                    string[] MotifNameList ={ item };
                    client.Subscribe(MotifNameList, qosLevels);
                }
                //this.Opacity = 0;
                MessageBox.Show("订阅主题成功。", "信息");
            }
            catch (Exception ex){
                MessageBox.Show(ex.Message.ToString(),"异常");
            }
           
        }

        /// <summary>
        /// 取消订阅消息
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void btn_UnSubscribe_Click(object sender, EventArgs e)
        {
            string[] unSubscribeTopic =null;
            client.Unsubscribe(unSubscribeTopic);
        }

        /// <summary>
        /// 窗口关闭事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void Window_Closed(object sender, EventArgs e)
        {
            Environment.Exit(0);  //强制退出，即使有其他的线程没有结束，因为M2Mqtt调用事件都是在单独的线程中进行的
        }

        private void txtFilePath_TextChanged(object sender, EventArgs e)
        {


        }

        private void Form1_Load(object sender, EventArgs e)
        {
            //this.Opacity = 0;
            ////窗体最小化显示
            //this.WindowState = FormWindowState.Minimized;
            ////不显示在任务栏中
            //this.ShowInTaskbar = false;

        }


        /// <summary>
        /// 
        /// </summary>
        public void InsertToprie(Toprie Toprie)
        {
            try
            {
                var db = SqlSugarConnection.SugarClient();
                int RowIndex = db.Insertable(Toprie).ExecuteReturnIdentity();
            }
            catch (Exception ex)
            {

            }
        }


        /// <summary>
        /// 批量添加数据
        /// </summary>
        public void InsertListToprieList(List<Toprie> ToprieList)
        {

            try
            {

                var db = SqlSugarConnection.SugarClient();
                int RowIndex = db.Insertable(ToprieList).ExecuteReturnIdentity();
            }
            catch (Exception ex)
            {

            }
        }

        /// <summary>
        /// 获取所有订阅主题
        /// </summary>
        public string Toprie_MotifList(){

            try {

                #region 初始化

                string str = "";

                #endregion
                
                #region 获取订阅主题
                var db = SqlSugarConnection.SugarClient();
                List<Toprie_Motif> ToprieMotifList = db.SqlQueryable<Toprie_Motif>("select * from  Toprie_Motif").Where(m => m.IsVal == 0).ToList();

                #endregion

                #region 

                for (int i=0; ToprieMotifList !=null && i < ToprieMotifList.Count();i++){

                    if (i == ToprieMotifList.Count() - 1)
                    {
                        str += ToprieMotifList[i].MotifName;
                    }
                    else {
                        str += ToprieMotifList[i].MotifName + ",";
                    }
                }


                #endregion

                return str;


            }
            catch (Exception ex){

                return "";
                
            }
        }



        /// <summary>
        /// 添加订阅主题
        /// </summary>
        public void InsertToprieMotif(Toprie_Motif ToprieMotif)
        {
            try
            {
                var db = SqlSugarConnection.SugarClient();
                int RowIndex = db.Insertable(ToprieMotif).ExecuteReturnIdentity();
            }
            catch (Exception ex)
            {

            }
        }

        private void txt_SubscribeMessage_TextChanged(object sender, EventArgs e)
        {

        }

        private void txt_BrokerAddress_TextChanged(object sender, EventArgs e)
        {

        }
    }
}