using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;
using System.Data;
using System.Drawing;
using System.Net.Http;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using UAS_MES_NEW.CustomControl.RichText;
using UAS_MES_NEW.DataOperate;
using UAS_MES_NEW.Entity;

namespace UAS_MES_NEW.Make
{
    public partial class Make_BodyTest : Form
    {
        public Make_BodyTest()
        {
            InitializeComponent();
        }

        string url = "http://192.168.41.200:9527/";
        string key = "c6b0ac61-bb5a-411f-9213-3ed05da979f8";

        DataHelper dh;
        DataTable dt;
        int InsertNum = 0;

        private void Make_Humiture_Load(object sender, EventArgs e)
        {
            IpPortUrlVal.Text = url;
            ketVal.Text = key;

            workTimeVal1.Value = DateTime.Today.AddHours(08).AddMinutes(00).AddSeconds(0);
            workTimeVal2.Value = DateTime.Today.AddHours(12).AddMinutes(30).AddSeconds(0);

            workTimeVal3.Value = DateTime.Today.AddHours(12).AddMinutes(00).AddSeconds(0);
            workTimeVal4.Value = DateTime.Today.AddHours(17).AddMinutes(30).AddSeconds(0);

            workTimeLab1.Visible = false;
            workTimeLab2.Visible = false;
            workTimeLab3.Visible = false;
            workTimeLab4.Visible = false;

            workTimeVal1.Visible = false;
            workTimeVal2.Visible = false;
            workTimeVal3.Visible = false;
            workTimeVal4.Visible = false;
            dh = SystemInf.dh;
        }

        private void onStart_Click(object sender, EventArgs e)
        {
            if (string.IsNullOrEmpty(IpPortUrlVal.Text))
            {
                ShowMsg(Msg1, 0, "请输出请求地址");
                IpPortUrlVal.Focus();
                IpPortUrlVal.SelectAll();
                return;
            }

            if (onStart.Text == "获取中")
            {
                IpPortUrlVal.Enabled = true;
                ketVal.Enabled = true;
                workTimeVal1.Enabled = true;
                workTimeVal2.Enabled = true;
                workTimeVal3.Enabled = true;
                workTimeVal4.Enabled = true;
                onStart.Text = "开启获取";
                timer1.Stop();
            }
            else
            {
                IpPortUrlVal.Enabled = false;
                ketVal.Enabled = false;
                workTimeVal1.Enabled = false;
                workTimeVal2.Enabled = false;
                workTimeVal3.Enabled = false;
                workTimeVal4.Enabled = false;
                onStart.Text = "获取中";
                ShowMsg(Msg1, 2, $"执行间隔:{timer1.Interval / 60000}分钟");
                timer1.Start();
                //timer1_Tick(null, null);
            }
        }
        private async void timer1_Tick(object sender, EventArgs e)
        {
            try
            {
                string apiUrl = IpPortUrlVal.Text.Trim() + "api/AcsDataApi/GetData";
                DateTime startTime = DateTime.Now.Date;
                DateTime endTime = DateTime.Now.Date.AddDays(1).AddSeconds(-1);

                var dataObject = new
                {
                    Key = ketVal.Text.Trim(),
                    Type = "Event",
                    STime = startTime.ToString("yyyy-MM-dd HH:mm:ss"),
                    ETime = endTime.ToString("yyyy-MM-dd HH:mm:ss"),
                    IsAllType = "0"
                };
                string result = await HttpHelper.PostAsync(apiUrl, dataObject);
                JObject root = JObject.Parse(result);
                JArray dataArr = (JArray)root["Data"];


                if (root["Code"].ToString() == "1")
                {
                    ShowMsg(Msg1, 1, $"获取人体测试仪设备成功,已获取到{dataArr.Count}条记录");
                }
                InsertNum = 0;
                foreach (JToken item in dataArr)
                {
                    string DeptName = item["DeptName"].ToString();
                    string EmployeeCode = item["EmployeeCode"].ToString();
                    string EmployeeName = item["EmployeeName"].ToString();
                    string EventName = item["EventName"].ToString();
                    string ControlName = item["ControlName"].ToString();

                    string EventID = item["EventID"].ToString();
                    string EventTime = item["EventTime"].ToString();
                    DateTime.TryParse(EventTime, out DateTime dtHour);
                    string timeType = dtHour.Hour < 11 ? "上午" : "下午";


                    dt = (DataTable)dh.ExecuteSql($"select * from bodytest where BT_EVENTID = '{EventID}'", "select");
                    if (dt.Rows.Count == 0)
                    {
                        string sql = $@"INSERT INTO BODYTEST (BT_ID,BT_DEPTNAME,BT_EMPNO,BT_EMP,BT_TYPE,BT_TIMETYPE,
                            BT_HAND,BT_DHAND,BT_LEFTSHOES,BT_RIGHTSHOES,BT_CONTROLNAME,BT_EVENTID,BT_INDATE) VALUES 
                            (BODYTEST_SEQ.NEXTVAL,'{DeptName}','{EmployeeCode}','{EmployeeName}','{EventName}','{timeType}',
                            '','','','','{ControlName}','{EventID}',to_date('{EventTime}', 'YYYY-MM-DD HH24:MI:SS'))";

                        dh.ExecuteSql(sql, "insert");
                        InsertNum += 1;
                    }
                }

                ShowMsg(Msg1, 1, $"人体测试信息已记录{InsertNum}条记录");
            }
            catch (Exception ex)
            {
                ShowMsg(Msg1, 0, $"获取数据时发生错误: {ex.Message}");
            }
        }


        private void claerBtn_Click(object sender, EventArgs e)
        {
            Msg1.Clear();
        }

        private void ShowMsg(RichTextAutoBottom msgBox, int type, string msg)
        {
            msg = msg.Replace("\r", "").Replace("\n", "");
            string msgTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
            string showMsg = $"{msgTime}: {msg}\n";

            if (type == 0)
            {
                msgBox.AppendText(showMsg, Color.Red);
                msgBox.SelectionStart = msgBox.Text.Length;
                msgBox.ScrollToCaret();
            }
            else if (type == 1)
            {
                msgBox.AppendText(showMsg, Color.Green);
                msgBox.SelectionStart = msgBox.Text.Length;
                msgBox.ScrollToCaret();
            }
            else if (type == 2)
            {
                msgBox.AppendText(showMsg, Color.YellowGreen);
                msgBox.SelectionStart = msgBox.Text.Length;
                msgBox.ScrollToCaret();
            }
        }
        public static class HttpHelper
        {
            public static async Task<string> PostAsync<T>(string url, T data)
            {
                var client = new HttpClient();
                string json = JsonConvert.SerializeObject(data);
                var content = new StringContent(json, Encoding.UTF8, "application/json");
                var response = await client.PostAsync(url, content);
                response.EnsureSuccessStatusCode();
                return await response.Content.ReadAsStringAsync();
            }
        }

    }
}