using Confluent.Kafka;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Xml.Linq;
using WIDESEA_Comm.LogInfo;
using WIDESEA_Comm.MES_Info;
using WIDESEA_Core.EFDbContext;
using WIDESEA_WMS.IRepositories;
using WIDESEA_WMS.Repositories;

namespace WIDESEA_WMS.Common
{
    public class ToMes
    {
        public static void InfoToMes()
        {
            try
            {
                VOLContext context = new VOLContext();
                Idt_info_to_mesRepository mesRepository = new dt_info_to_mesRepository(context);
                var infos = mesRepository.Find(x => !x.State).OrderBy(x => x.Createtime).ToList();
                foreach (var info in infos)
                {
                    try
                    {
                        var mesData = Request.RequestData(info.Info, MESAPIAddress.IPAddress_MES + info.ActionName);
                        if (mesData.Contains("连接尝试失败")) throw new Exception(mesData);
                        if (mesData.Contains("向一个无法连接的网络尝试了一个套接字操作")) throw new Exception(mesData);
                        var requestMes = JsonConvert.DeserializeObject<MES_Response>(mesData);

                        if (requestMes.code == "200" && requestMes.Type == "success")
                        {
                            info.State = true;
                            info.Successtime = DateTime.Now;
                            info.Message = requestMes.message;
                        }
                        else
                            throw new Exception(requestMes.message);
                    }
                    catch (Exception ex)
                    {
                        info.Message = ex.Message;
                    }
                    mesRepository.Update(info, x => new { x.State, x.Successtime, x.Message }, true);
                }
            }
            catch (Exception ex)
            {
                throw;
            }
            
        }
    }
}