SmartDoorLock/logoforcetestapp1/LogForceTestApp.Modules.MainModule/ViewModels/MainPageViewModel.cs

using HslCommunication.Core.IMessage;
using LogForceTestApp.Modules.MainModule.Models;
using LogoForceTestApp.Modules.MainModule.Enums;
using LogoForceTestApp.Modules.MainModule.Models;
using LogoForceTestApp.Modules.MainModule.Services;
using LogoForceTestApp.Services;
using LogoForceTestApp.Services.Interfaces;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using OxyPlot;
using OxyPlot.Axes;
using OxyPlot.Series;
using Prism.Commands;
using Prism.Events;
using Prism.Mvvm;
using Prism.Regions;
using Prism.Services.Dialogs;
using PropertyChanged;
using Repository;
using Repository.Entiies;
using Serilog;
using SkiaSharp.QrCode; //生成二维码
using SkiaSharp;
using StatementMachineService.Core;
using StatementMachineService.Events;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.Net.Http;
using System.Runtime.Serialization;
using System.Security.Cryptography;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Timers;
using System.Windows;
using Team.Utility;
using static AutoMapper.Internal.ExpressionFactory;
using System.Collections.ObjectModel;
using TouchSocket.Core;
using TouchSocket.Sockets;
using Result = LogoForceTestApp.Modules.MainModule.Models.Result;
using System.Windows.Media;
using SkiaSharp.Views.WPF;
using System.Windows.Media.Imaging;
using System.Windows.Media.Media3D;
using System.Drawing;
using ZXing.Common;
using ZXing;
using HandyControl.Controls;
using LogoForceTestApp.Core;

namespace LogoForceTestApp.Modules.MainModule.ViewModels
{
    public class MainPageViewModel : BindableBase
    {
        int _upLoadSlowTime;
        private bool _start;
        private List<DataPoint> _points = new();
        private readonly ConcurrentQueue<UpLoadTraceModel> _upLoadTraceModels = new();
        private readonly IHttpClientFactory _httpClientFactory;
        private readonly IScanService _scanService;
        private readonly IModbusTcpSlaverService _modbusTcpSlaverService;
        private readonly IStateService _stateService;
        private readonly IRepository _repository;
        private readonly IWritableOptions<AppSettings> _appSttings;
        private readonly IEventAggregator _eventAggregator;
        private readonly InovanceTcp inovanceTcp;
        private readonly ILogger _logger;
        private readonly IWarningUpdateService _warningUpdateService;
        private readonly IDialogService _dialogService;
        private readonly TcpService tcpService;
        private readonly Dictionary<int, string> SignalMapper;
        private bool _firstStart = true;
        private ResettableTimer _resettableTimer;

        public List<InformationNew> InforNew { get; set; }
        public PlotModel PlotModel { get; private set; }

        public bool ScanConnected { get; set; }
        public Param Param { get; set; }
        public string NewBarcode { get; set; }
        public string UsingBarcode { get; set; }
        public string ErrorCode { get; set; }

        [DoNotNotify]
        public string CSVPath { get; set; }
        [DoNotNotify]
        public string ImagePath { get; set; }
        public int OkDuration { get; set; } = 6000;
        public OeeConfig OeeConfig { get; set; }
        private bool _connected;

        public bool Connected
        {
            get
            {
                _connected = inovanceTcp.Connection("192.168.0.10", 502);
                return _connected;
            }
            set { _connected = value; }
        }

       
        public DelegateCommand QRCommand { get; set; }
        public DelegateCommand HouseCommand { get; set; }
        public DelegateCommand OutWorkCommand { get; set; }
        public DelegateCommand OrderCommand { get; set; }
        public string SelectedOrderName { get; set; }
        public ObservableCollection<string> OrderNames { get; set; }
        public string InQR { get; set; }
        public string LackHouse { get; set; }
        public string UsedHouse { get; set; }
        public string TotalHouse { get; set; }
        public int ActPer { get; set; }
        public int FallPer { get; set; }
        public int AbsPer { get; set; }
        #region Operator
        public string Operator1 { get; set; }
        public string Operator2 { get; set; }
        public string Operator3 { get; set; }
        public string Operator4 { get; set; }
        public string Operator5 { get; set; }
        public string Operator6 { get; set; }
        public string Operator7 { get; set; }
        public string Operator8 { get; set; }
        public string Operator9 { get; set; }
        public string Operator10 { get; set; }
        public string Operator11 { get; set; }
        public string Operator12 { get; set; }
        public string Operator13 { get; set; }
        public string Operator14 { get; set; }
        public string Operator15 { get; set; }
        public string Operator16 { get; set; }
        public string Operator17 { get; set; }
        public string Operator18 { get; set; }
        #endregion

        #region Material
        public string Material1 { get; set; }
        public string Material2 { get; set; }
        public string Material3 { get; set; }
        public string Material4 { get; set; }
        public string Material5 { get; set; }
        public string Material6 { get; set; }
        public string Material7 { get; set; }
        public string Material8 { get; set; }
        public string Material9 { get; set; }
        public string Material10 { get; set; }
        public string Material11 { get; set; }
        public string Material12 { get; set; }
        public string Material13 { get; set; }
        public string Material14 { get; set; }
        public string Material15 { get; set; }
        public string Material16 { get; set; }
        public string Material17 { get; set; }
        public string Material18 { get; set; }
        #endregion

        int[] q = new int[30];
        

        public MainPageViewModel(IHttpClientFactory httpClientFactory, IScanService scanService,
            IModbusTcpSlaverService modbusTcpSlaverService, IStateService stateService, IRepository repository,
                IWritableOptions<AppSettings> appSttings, IEventAggregator eventAggregator, InovanceTcp inovanceTcp,
                ILogger logger, IWarningUpdateService warningUpdateService, IDialogService dialogService, TcpService tcpService)
        {

            _httpClientFactory = httpClientFactory;
            _scanService = scanService;
            _modbusTcpSlaverService = modbusTcpSlaverService;
            _stateService = stateService;
            _repository = repository;
            _appSttings = appSttings;
            CSVPath = _appSttings.Value.CSVPath;
            ImagePath = _appSttings.Value.ImageSavePath;
            _eventAggregator = eventAggregator;
            this.inovanceTcp = inovanceTcp;
            _eventAggregator.GetEvent<WaringUpdateLog>().Subscribe(WaringUpdateLogChanged);
            _logger = logger;
            _warningUpdateService = warningUpdateService;
            _dialogService = dialogService;
            this.tcpService = tcpService;
            InforNew = new List<InformationNew>();
            HouseCommand = new DelegateCommand(UploadHouse);
            OutWorkCommand = new DelegateCommand(UploadOutWork);
            OrderCommand = new DelegateCommand(OrderEnter);
            
        #region tcpService

        tcpService.Connecting = (client, e) =>
            {
                #region ip
                /*
                e.Id = $"{client.IP}:{client.Port}";
                if (client.IP == "192.168.10.1")//1号机 
                {
                    e.Id = "Num1";
                }
                if (client.IP == "192.168.10.2")//2号机
                {
                    e.Id = "Num2";
                }
                if (client.IP == "192.168.10.3")//3号机
                {
                    e.Id = "Num3";
                }
                if (client.IP == "192.168.10.4")//4号机
                {
                    e.Id = "Num4";
                }
                if (client.IP == "192.168.10.5")//5号机
                {
                    e.Id = "Num5";
                }
                if (client.IP == "192.168.10.6")//6号机 
                {
                    e.Id = "Num6";
                }
                if (client.IP == "192.168.10.7")//7号机
                {
                    e.Id = "Num7";
                }
                if (client.IP == "192.168.10.8")//8号机
                {
                    e.Id = "Num8";
                }
                if (client.IP == "192.168.10.9")//9号机
                {
                    e.Id = "Num9";
                }
                if (client.IP == "192.168.10.10")//10号机
                {
                    e.Id = "Num10";
                }
                if (client.IP == "192.168.10.11")//11号机 
                {
                    e.Id = "Num11";
                }
                if (client.IP == "192.168.10.12")//12号机
                {
                    e.Id = "Num12";
                }
                if (client.IP == "192.168.10.13")//13号机
                {
                    e.Id = "Num13";
                }
                if (client.IP == "192.168.10.14")//14号机
                {
                    e.Id = "Num14";
                }
                
                if (client.IP == "192.168.10.15")//检测机1
                {
                    e.Id = "Test1";
                }
                if (client.IP == "192.168.10.16")//检测机2
                {
                    e.Id = "Test2";
                }
                if (client.IP == "192.168.10.17")//检测机3
                {
                    e.Id = "Test3";
                }
                if (client.IP == "192.168.10.18")//检测机4
                {
                    e.Id = "Test4";
                }*/
                #endregion
                return EasyTask.CompletedTask;
            };//有客户端正在连接
            tcpService.Connected = (client, e) =>
            {
                WriteLog("有客户端成功连接");
                return EasyTask.CompletedTask;
            };//有客户端成功连接

            tcpService.Disconnecting = (client, e) =>
            {
                return EasyTask.CompletedTask;
            };//有客户端正在断开连接，只有当主动断开时才有效。
            tcpService.Disconnected = (client, e) =>
            {
                WriteLog("有客户端断开连接");
                return EasyTask.CompletedTask;
            };//有客户端断开连接

            tcpService.Received = (client, e) =>
            {
                //从客户端收到信息
                var mes = Encoding.UTF8.GetString(e.ByteBlock.Buffer, 0, e.ByteBlock.Len);//注意：数据长度是byteBlock.Len
                //WriteLog($"已从{client.Id}接收到信息：{mes}");
                //client.Send(mes);
                //WriteLog("发送" + mes);
                try
                {
                    #region 1-7

                    if (client.IP == "192.168.10.1")//1号机
                    {
                        if (mes.Split(":")[0] == "WU")
                        {
                            Material1 = mes.Split(":")[1];
                            client.Send($"WU:物料上传成功");
                            WriteLog("1#物料上传成功");
                        }
                        if (mes.Split(":")[0] == "New")
                        {
                            var newOper = new Account()
                            {
                                Id = Guid.NewGuid(),
                                AccountID = mes.Split(":")[1],
                                ChangePassword = mes.Split(":")[2],
                            };
                            _repository.Add(newOper);
                            client.Send($"NewSuc:注册成功");
                            WriteLog("1#注册成功");
                        }
                        if (mes.Split(":")[0] == "Login")
                        {
                            string accountID = mes.Split(":")[1];
                            string changePassword = mes.Split(":")[2];
                            var login = _repository.GetFirstDefault<Account>(c => c.AccountID == accountID && c.ChangePassword == changePassword);//数据库查
                            if (login != null)
                            {
                                Operator1 = accountID;
                                client.Send($"LoginSuc:登录成功");
                                WriteLog("1#登录成功");
                            }
                        }
                        if (mes == "切换完成")
                        {
                            inovanceTcp.WriteDate("D1501.0", true);
                            Thread.Sleep(1000);
                            WriteLog("1#切换完成");
                        }
                        inovanceTcp.WriteDate("D1501.0", false);
                    }
                    if (client.IP == "192.168.10.2")//2号机
                    {
                        if (mes.Split(":")[0] == "WU")
                        {
                            Material2 = mes.Split(":")[1];
                            client.Send($"WU:物料上传成功");
                            WriteLog("2#物料上传成功");
                        }
                        if (mes.Split(":")[0] == "New")
                        {
                            var newOper = new Account()
                            {
                                Id = Guid.NewGuid(),
                                AccountID = mes.Split(":")[1],
                                ChangePassword = mes.Split(":")[2],
                            };
                            _repository.Add(newOper);
                            client.Send($"NewSuc:注册成功");
                            WriteLog("2#注册成功");
                        }
                        if (mes.Split(":")[0] == "Login")
                        {
                            string accountID = mes.Split(":")[1];
                            string changePassword = mes.Split(":")[2];
                            var login = _repository.GetFirstDefault<Account>(c => c.AccountID == accountID && c.ChangePassword == changePassword);//数据库查
                            if (login != null)
                            {
                                Operator2 = accountID;
                                client.Send($"LoginSuc:登录成功");
                                WriteLog("2#登录成功");
                            }
                        }
                        if (mes == "切换完成")
                        {
                            inovanceTcp.WriteDate("D1501.1", true);
                            Thread.Sleep(1000);
                            WriteLog("2#切换完成");
                        }
                        inovanceTcp.WriteDate("D1501.1", false);
                    }
                    if (client.IP == "192.168.10.3")//3号机
                    {
                        if (mes.Split(":")[0] == "WU")
                        {
                            Material3 = mes.Split(":")[1];
                            client.Send($"WU:物料上传成功");
                            WriteLog("3#物料上传成功");
                        }
                        if (mes.Split(":")[0] == "New")
                        {
                            var newOper = new Account()
                            {
                                Id = Guid.NewGuid(),
                                AccountID = mes.Split(":")[1],
                                ChangePassword = mes.Split(":")[2],
                            };
                            _repository.Add(newOper);
                            client.Send($"NewSuc:注册成功");
                            WriteLog("3#注册成功");
                        }
                        if (mes.Split(":")[0] == "Login")
                        {
                            string accountID = mes.Split(":")[1];
                            string changePassword = mes.Split(":")[2];
                            var login = _repository.GetFirstDefault<Account>(c => c.AccountID == accountID && c.ChangePassword == changePassword);//数据库查
                            if (login != null)
                            {
                                Operator3 = accountID;
                                client.Send($"LoginSuc:登录成功");
                                WriteLog("3#登录成功");
                            }
                        }
                        if (mes == "切换完成")
                        {
                            inovanceTcp.WriteDate("D1501.2", true);
                            Thread.Sleep(1000);
                            WriteLog("3#切换完成");
                        }
                        inovanceTcp.WriteDate("D1501.2", false);
                    }
                    if (client.IP == "192.168.10.4")//4号机
                    {
                        if (mes.Split(":")[0] == "WU")
                        {
                            Material4 = mes.Split(":")[1];
                            client.Send($"WU:物料上传成功");
                            WriteLog("4#物料上传成功");
                        }
                        if (mes.Split(":")[0] == "New")
                        {
                            var newOper = new Account()
                            {
                                Id = Guid.NewGuid(),
                                AccountID = mes.Split(":")[1],
                                ChangePassword = mes.Split(":")[2],
                            };
                            _repository.Add(newOper);
                            client.Send($"NewSuc:注册成功");
                            WriteLog("4#注册成功");
                        }
                        if (mes.Split(":")[0] == "Login")
                        {
                            string accountID = mes.Split(":")[1];
                            string changePassword = mes.Split(":")[2];
                            var login = _repository.GetFirstDefault<Account>(c => c.AccountID == accountID && c.ChangePassword == changePassword);//数据库查
                            if (login != null)
                            {
                                Operator4 = accountID;
                                client.Send($"LoginSuc:登录成功");
                                WriteLog("4#登录成功");
                            }
                        }
                        if (mes == "切换完成")
                        {
                            inovanceTcp.WriteDate("D1501.3", true);
                            Thread.Sleep(1000);
                            WriteLog("4#切换完成");
                        }
                        inovanceTcp.WriteDate("D1501.3", false);
                    }
                    if (client.IP == "192.168.10.5")//5号机
                    {
                        if (mes.Split(":")[0] == "WU")
                        {
                            Material5 = mes.Split(":")[1];
                            client.Send($"WU:物料上传成功");
                            WriteLog("5#物料上传成功");
                        }
                        if (mes.Split(":")[0] == "New")
                        {
                            var newOper = new Account()
                            {
                                Id = Guid.NewGuid(),
                                AccountID = mes.Split(":")[1],
                                ChangePassword = mes.Split(":")[2],
                            };
                            _repository.Add(newOper);
                            client.Send($"NewSuc:注册成功");
                            WriteLog("5#注册成功");
                        }
                        if (mes.Split(":")[0] == "Login")
                        {
                            string accountID = mes.Split(":")[1];
                            string changePassword = mes.Split(":")[2];
                            var login = _repository.GetFirstDefault<Account>(c => c.AccountID == accountID && c.ChangePassword == changePassword);//数据库查
                            if (login != null)
                            {
                                Operator5 = accountID;
                                client.Send($"LoginSuc:登录成功");
                                WriteLog("5#登录成功");
                            }
                        }
                        if (mes == "切换完成")
                        {
                            inovanceTcp.WriteDate("D1501.4", true);
                            Thread.Sleep(1000);
                            WriteLog("5#切换完成");
                        }
                        inovanceTcp.WriteDate("D1501.4", false);
                    }
                    if (client.IP == "192.168.10.6")//6号机
                    {
                        if (mes.Split(":")[0] == "WU")
                        {
                            Material6 = mes.Split(":")[1];
                            client.Send($"WU:物料上传成功");
                            WriteLog("6#物料上传成功");
                        }
                        if (mes.Split(":")[0] == "New")
                        {
                            var newOper = new Account()
                            {
                                Id = Guid.NewGuid(),
                                AccountID = mes.Split(":")[1],
                                ChangePassword = mes.Split(":")[2],
                            };
                            _repository.Add(newOper);
                            client.Send($"NewSuc:注册成功");
                            WriteLog("6#注册成功");
                        }
                        if (mes.Split(":")[0] == "Login")
                        {
                            string accountID = mes.Split(":")[1];
                            string changePassword = mes.Split(":")[2];
                            var login = _repository.GetFirstDefault<Account>(c => c.AccountID == accountID && c.ChangePassword == changePassword);//数据库查
                            if (login != null)
                            {
                                Operator6 = accountID;
                                client.Send($"LoginSuc:登录成功");
                                WriteLog("6#登录成功");
                            }
                        }
                        if (mes == "切换完成")
                        {
                            inovanceTcp.WriteDate("D1501.5", true);
                            Thread.Sleep(1000);
                            WriteLog("6#切换完成");
                        }
                        inovanceTcp.WriteDate("D1501.5", false);
                    }
                    if (client.IP == "192.168.10.7")//7号机
                    {
                        if (mes.Split(":")[0] == "WU")
                        {
                            Material7 = mes.Split(":")[1];
                            client.Send($"WU:物料上传成功");
                            WriteLog("7#物料上传成功");
                        }
                        if (mes.Split(":")[0] == "New")
                        {
                            var newOper = new Account()
                            {
                                Id = Guid.NewGuid(),
                                AccountID = mes.Split(":")[1],
                                ChangePassword = mes.Split(":")[2],
                            };
                            _repository.Add(newOper);
                            client.Send($"NewSuc:注册成功");
                            WriteLog("7#注册成功");
                        }
                        if (mes.Split(":")[0] == "Login")
                        {
                            string accountID = mes.Split(":")[1];
                            string changePassword = mes.Split(":")[2];
                            var login = _repository.GetFirstDefault<Account>(c => c.AccountID == accountID && c.ChangePassword == changePassword);//数据库查
                            if (login != null)
                            {
                                Operator7 = accountID;
                                client.Send($"LoginSuc:登录成功");
                                WriteLog("7#登录成功");
                            }
                        }
                        if (mes == "切换完成")
                        {
                            inovanceTcp.WriteDate("D1501.6", true);
                            Thread.Sleep(1000);
                            WriteLog("7#切换完成");
                        }
                        inovanceTcp.WriteDate("D1501.6", false);
                    }
                    #endregion
                    #region 7-14

                    if (client.IP == "192.168.10.8")//8号机
                    {
                        if (mes.Split(":")[0] == "WU")
                        {
                            Material8 = mes.Split(":")[1];
                            client.Send($"WU:物料上传成功");
                            WriteLog("8#物料上传成功");
                        }
                        if (mes.Split(":")[0] == "New")
                        {
                            var newOper = new Account()
                            {
                                Id = Guid.NewGuid(),
                                AccountID = mes.Split(":")[1],
                                ChangePassword = mes.Split(":")[2],
                            };
                            _repository.Add(newOper);
                            client.Send($"NewSuc:注册成功");
                            WriteLog("8#注册成功");
                        }
                        if (mes.Split(":")[0] == "Login")
                        {
                            string accountID = mes.Split(":")[1];
                            string changePassword = mes.Split(":")[2];
                            var login = _repository.GetFirstDefault<Account>(c => c.AccountID == accountID && c.ChangePassword == changePassword);//数据库查
                            if (login != null)
                            {
                                Operator8 = accountID;
                                client.Send($"LoginSuc:登录成功");
                                WriteLog("8#登录成功");
                            }
                        }
                        if (mes == "切换完成")
                        {
                            inovanceTcp.WriteDate("D1501.7", true);
                            Thread.Sleep(1000);
                            WriteLog("8#切换完成");
                        }
                        inovanceTcp.WriteDate("D1501.7", false);
                    }
                    if (client.IP == "192.168.10.9")//9号机
                    {
                        if (mes.Split(":")[0] == "WU")
                        {
                            Material9 = mes.Split(":")[1];
                            client.Send($"WU:物料上传成功");
                            WriteLog("9#物料上传成功");
                        }
                        if (mes.Split(":")[0] == "New")
                        {
                            var newOper = new Account()
                            {
                                Id = Guid.NewGuid(),
                                AccountID = mes.Split(":")[1],
                                ChangePassword = mes.Split(":")[2],
                            };
                            _repository.Add(newOper);
                            client.Send($"NewSuc:注册成功");
                            WriteLog("9#注册成功");
                        }
                        if (mes.Split(":")[0] == "Login")
                        {
                            string accountID = mes.Split(":")[1];
                            string changePassword = mes.Split(":")[2];
                            var login = _repository.GetFirstDefault<Account>(c => c.AccountID == accountID && c.ChangePassword == changePassword);//数据库查
                            if (login != null)
                            {
                                Operator9 = accountID;
                                client.Send($"LoginSuc:登录成功");
                                WriteLog("9#登录成功");
                            }
                        }
                        if (mes == "切换完成")
                        {
                            inovanceTcp.WriteDate("D1501.8", true);
                            Thread.Sleep(1000);
                            WriteLog("9#切换完成");
                        }
                        inovanceTcp.WriteDate("D1501.8", false);
                    }
                    if (client.IP == "192.168.10.10")//10号机
                    {
                        if (mes.Split(":")[0] == "WU")
                        {
                            Material10 = mes.Split(":")[1];
                            client.Send($"WU:物料上传成功");
                            WriteLog("10#物料上传成功");
                        }
                        if (mes.Split(":")[0] == "New")
                        {
                            var newOper = new Account()
                            {
                                Id = Guid.NewGuid(),
                                AccountID = mes.Split(":")[1],
                                ChangePassword = mes.Split(":")[2],
                            };
                            _repository.Add(newOper);
                            client.Send($"NewSuc:注册成功");
                            WriteLog("10#注册成功");
                        }
                        if (mes.Split(":")[0] == "Login")
                        {
                            string accountID = mes.Split(":")[1];
                            string changePassword = mes.Split(":")[2];
                            var login = _repository.GetFirstDefault<Account>(c => c.AccountID == accountID && c.ChangePassword == changePassword);//数据库查
                            if (login != null)
                            {
                                Operator10 = accountID;
                                client.Send($"LoginSuc:登录成功");
                                WriteLog("10#登录成功");
                            }
                        }
                        if (mes == "切换完成")
                        {
                            inovanceTcp.WriteDate("D1501.9", true);
                            Thread.Sleep(1000);
                            WriteLog("10#切换完成");
                        }
                        inovanceTcp.WriteDate("D1501.9", false);
                    }
                    if (client.IP == "192.168.10.11")//11号机
                    {
                        if (mes.Split(":")[0] == "WU")
                        {
                            Material11 = mes.Split(":")[1];
                            client.Send($"WU:物料上传成功");
                            WriteLog("11#物料上传成功");
                        }
                        if (mes.Split(":")[0] == "New")
                        {
                            var newOper = new Account()
                            {
                                Id = Guid.NewGuid(),
                                AccountID = mes.Split(":")[1],
                                ChangePassword = mes.Split(":")[2],
                            };
                            _repository.Add(newOper);
                            client.Send($"NewSuc:注册成功");
                            WriteLog("11#注册成功");
                        }
                        if (mes.Split(":")[0] == "Login")
                        {
                            string accountID = mes.Split(":")[1];
                            string changePassword = mes.Split(":")[2];
                            var login = _repository.GetFirstDefault<Account>(c => c.AccountID == accountID && c.ChangePassword == changePassword);//数据库查
                            if (login != null)
                            {
                                Operator11 = accountID;
                                client.Send($"LoginSuc:登录成功");
                                WriteLog("11#登录成功");
                            }
                        }
                        if (mes == "切换完成")
                        {
                            inovanceTcp.WriteDate("D1501.10", true);
                            Thread.Sleep(1000);
                            WriteLog("11#切换完成");
                        }
                        inovanceTcp.WriteDate("D1501.10", false);
                    }
                    if (client.IP == "192.168.10.12")//12号机
                    {
                        if (mes.Split(":")[0] == "WU")
                        {
                            Material12 = mes.Split(":")[1];
                            client.Send($"WU:物料上传成功");
                            WriteLog("12#物料上传成功");
                        }
                        if (mes.Split(":")[0] == "New")
                        {
                            var newOper = new Account()
                            {
                                Id = Guid.NewGuid(),
                                AccountID = mes.Split(":")[1],
                                ChangePassword = mes.Split(":")[2],
                            };
                            _repository.Add(newOper);
                            client.Send($"NewSuc:注册成功");
                            WriteLog("12#注册成功");
                        }
                        if (mes.Split(":")[0] == "Login")
                        {
                            string accountID = mes.Split(":")[1];
                            string changePassword = mes.Split(":")[2];
                            var login = _repository.GetFirstDefault<Account>(c => c.AccountID == accountID && c.ChangePassword == changePassword);//数据库查
                            if (login != null)
                            {
                                Operator12 = accountID;
                                client.Send($"LoginSuc:登录成功");
                                WriteLog("12#登录成功");
                            }
                        }
                        if (mes == "切换完成")
                        {
                            inovanceTcp.WriteDate("D1501.11", true);
                            Thread.Sleep(1000);
                            WriteLog("12#切换完成");
                        }
                        inovanceTcp.WriteDate("D1501.11", false);
                    }
                    if (client.IP == "192.168.10.13")//13号机
                    {
                        if (mes.Split(":")[0] == "WU")
                        {
                            Material13 = mes.Split(":")[1];
                            client.Send($"WU:物料上传成功");
                            WriteLog("13#物料上传成功");
                        }
                        if (mes.Split(":")[0] == "New")
                        {
                            var newOper = new Account()
                            {
                                Id = Guid.NewGuid(),
                                AccountID = mes.Split(":")[1],
                                ChangePassword = mes.Split(":")[2],
                            };
                            _repository.Add(newOper);
                            client.Send($"NewSuc:注册成功");
                            WriteLog("13#注册成功");
                        }
                        if (mes.Split(":")[0] == "Login")
                        {
                            string accountID = mes.Split(":")[1];
                            string changePassword = mes.Split(":")[2];
                            var login = _repository.GetFirstDefault<Account>(c => c.AccountID == accountID && c.ChangePassword == changePassword);//数据库查
                            if (login != null)
                            {
                                Operator13 = accountID;
                                client.Send($"LoginSuc:登录成功");
                                WriteLog("13#登录成功");
                            }
                        }
                        if (mes == "切换完成")
                        {
                            inovanceTcp.WriteDate("D1501.12", true);
                            Thread.Sleep(1000);
                            WriteLog("13#切换完成");
                        }
                        inovanceTcp.WriteDate("D1501.12", false);
                    }
                    if (client.IP == "192.168.10.14")//14号机
                    {
                        if (mes.Split(":")[0] == "WU")
                        {
                            Material14 = mes.Split(":")[1];
                            client.Send($"WU:物料上传成功");
                            WriteLog("14#物料上传成功");
                        }
                        if (mes.Split(":")[0] == "New")
                        {
                            var newOper = new Account()
                            {
                                Id = Guid.NewGuid(),
                                AccountID = mes.Split(":")[1],
                                ChangePassword = mes.Split(":")[2],
                            };
                            _repository.Add(newOper);
                            client.Send($"NewSuc:注册成功");
                            WriteLog("14#注册成功");
                        }
                        if (mes.Split(":")[0] == "Login")
                        {
                            string accountID = mes.Split(":")[1];
                            string changePassword = mes.Split(":")[2];
                            var login = _repository.GetFirstDefault<Account>(c => c.AccountID == accountID && c.ChangePassword == changePassword);//数据库查
                            if (login != null)
                            {
                                Operator14 = accountID;
                                client.Send($"LoginSuc:登录成功");
                                WriteLog("14#登录成功");
                            }
                        }
                        if (mes == "切换完成")
                        {
                            inovanceTcp.WriteDate("D1501.13", true);
                            Thread.Sleep(1000);
                            WriteLog("14#切换完成");
                        }
                        inovanceTcp.WriteDate("D1501.13", false);
                    }
                    #endregion
                    #region test

                    if (client.IP == "192.168.10.15")//检测1
                    {
                        if (mes.Split(":")[0] == "Test")
                        {
                            for (int i = 0; i < 30; i++)
                            {
                                if (mes.Split(":")[i+1] == "1")
                                {
                                    q[i] = 1;
                                }
                                else
                                {
                                    q[i] = 0;
                                }
                            }
                            string str = DateTime.Now.ToString("yyyy/MM/dd");
                            var list = repository.GetFirstDefault<Quality>(c => c.DateQuality==str);//查一个值
                            if (list != null)
                            {
                                list.Q1 = list.Q1 + q[0];
                                list.Q2 = list.Q2 + q[1];
                                list.Q3 = list.Q3 + q[2];
                                list.Q4 = list.Q4 + q[3];
                                list.Q5 = list.Q5 + q[4];
                                list.Q6 = list.Q6 + q[5];
                                list.Q7 = list.Q7 + q[6];
                                list.Q8 = list.Q8 + q[7];
                                list.Q9 = list.Q9 + q[8];
                                list.Q10 = list.Q10 + q[9];
                                list.Q11 = list.Q11 + q[10];
                                list.Q12 = list.Q12 + q[11];
                                list.Q13 = list.Q13 + q[12];
                                list.Q14 = list.Q14 + q[13];
                                list.Q15 = list.Q15 + q[14];
                                list.Q16 = list.Q16 + q[15];
                                list.Q17 = list.Q17 + q[16];
                                list.Q18 = list.Q18 + q[17];
                                list.Q19 = list.Q19 + q[18];
                                list.Q20 = list.Q20 + q[19];
                                list.Q21 = list.Q21 + q[20];
                                list.Q22 = list.Q22 + q[21];
                                list.Q23 = list.Q23 + q[22];
                                list.Q24 = list.Q24 + q[23];
                                list.Q25 = list.Q25 + q[24];
                                list.Q26 = list.Q26 + q[25];
                                list.Q27 = list.Q27 + q[26];
                                list.Q28 = list.Q28 + q[27];
                                list.Q29 = list.Q29 + q[28];
                                list.Q30 = list.Q30 + q[29];
                                _repository.Update(list);
                                client.Send("Te:上传成功");
                                WriteLog("检测1#上传成功");
                            }
                            else
                            {
                                var item = new Quality()
                                {
                                    Id = Guid.NewGuid(),
                                    DateQuality = str,
                                    Q1 = q[0],Q2 = q[1],Q3 = q[2], Q4 = q[3],Q5 = q[4],
                                    Q6 = q[5], Q7 = q[6], Q8 = q[7],Q9 = q[8],Q10 = q[9],
                                    Q11 = q[10], Q12 = q[11],Q13 = q[12], Q14 = q[13],Q15 = q[14],
                                    Q16 = q[15],Q17 = q[16],Q18 = q[17],Q19 = q[18],Q20 = q[19],
                                    Q21 = q[20],Q22 = q[21],Q23 = q[22], Q24 = q[23], Q25 = q[24],
                                    Q26 = q[25], Q27 = q[26],Q28 = q[27],Q29 = q[28],Q30 = q[29],
                                };
                                _repository.Add(item);
                                client.Send("Te:上传成功");
                                WriteLog("检测1#上传成功");
                            }
                        }
                        if (mes == "切换完成")
                        {
                            inovanceTcp.WriteDate("D1501.14", true);
                            Thread.Sleep(1000);
                            WriteLog("检测1#切换完成");
                        }
                        inovanceTcp.WriteDate("D1501.14", false);
                        if (mes.Split(":")[0] == "New")
                        {
                            var newOper = new Account()
                            {
                                Id = Guid.NewGuid(),
                                AccountID = mes.Split(":")[1],
                                ChangePassword = mes.Split(":")[2],
                            };
                            _repository.Add(newOper);
                            client.Send($"NewSuc:注册成功");
                            WriteLog("检测1#注册成功");
                        }
                        if (mes.Split(":")[0] == "Login")
                        {
                            string accountID = mes.Split(":")[1];
                            string changePassword = mes.Split(":")[2];
                            var login = _repository.GetFirstDefault<Account>(c => c.AccountID == accountID && c.ChangePassword == changePassword);//数据库查
                            if (login != null)
                            {
                                Operator15 = accountID;
                                client.Send($"LoginSuc:登录成功");
                                WriteLog("检测1#登录成功");
                            }
                        }
                    }
                    if (client.IP == "192.168.10.16")//检测2
                    {
                        if (mes.Split(":")[0] == "Test")
                        {
                            for (int i = 0; i < 30; i++)
                            {
                                if (mes.Split(":")[i + 1] == "1")
                                {
                                    q[i] = 1;
                                }
                                else
                                {
                                    q[i] = 0;
                                }
                            }
                            string str = DateTime.Now.ToString("yyyy/MM/dd");
                            var list = repository.GetFirstDefault<Quality>(c => c.DateQuality == str);//查一个值
                            if (list != null)
                            {
                                list.Q1 = list.Q1 + q[0];
                                list.Q2 = list.Q2 + q[1];
                                list.Q3 = list.Q3 + q[2];
                                list.Q4 = list.Q4 + q[3];
                                list.Q5 = list.Q5 + q[4];
                                list.Q6 = list.Q6 + q[5];
                                list.Q7 = list.Q7 + q[6];
                                list.Q8 = list.Q8 + q[7];
                                list.Q9 = list.Q9 + q[8];
                                list.Q10 = list.Q10 + q[9];
                                list.Q11 = list.Q11 + q[10];
                                list.Q12 = list.Q12 + q[11];
                                list.Q13 = list.Q13 + q[12];
                                list.Q14 = list.Q14 + q[13];
                                list.Q15 = list.Q15 + q[14];
                                list.Q16 = list.Q16 + q[15];
                                list.Q17 = list.Q17 + q[16];
                                list.Q18 = list.Q18 + q[17];
                                list.Q19 = list.Q19 + q[18];
                                list.Q20 = list.Q20 + q[19];
                                list.Q21 = list.Q21 + q[20];
                                list.Q22 = list.Q22 + q[21];
                                list.Q23 = list.Q23 + q[22];
                                list.Q24 = list.Q24 + q[23];
                                list.Q25 = list.Q25 + q[24];
                                list.Q26 = list.Q26 + q[25];
                                list.Q27 = list.Q27 + q[26];
                                list.Q28 = list.Q28 + q[27];
                                list.Q29 = list.Q29 + q[28];
                                list.Q30 = list.Q30 + q[29];
                                _repository.Update(list);
                                client.Send("Te:上传成功");
                                WriteLog("检测2#上传成功");
                            }
                            else
                            {
                                var item = new Quality()
                                {
                                    Id = Guid.NewGuid(),
                                    DateQuality = str,
                                    Q1 = q[0],
                                    Q2 = q[1],
                                    Q3 = q[2],
                                    Q4 = q[3],
                                    Q5 = q[4],
                                    Q6 = q[5],
                                    Q7 = q[6],
                                    Q8 = q[7],
                                    Q9 = q[8],
                                    Q10 = q[9],
                                    Q11 = q[10],
                                    Q12 = q[11],
                                    Q13 = q[12],
                                    Q14 = q[13],
                                    Q15 = q[14],
                                    Q16 = q[15],
                                    Q17 = q[16],
                                    Q18 = q[17],
                                    Q19 = q[18],
                                    Q20 = q[19],
                                    Q21 = q[20],
                                    Q22 = q[21],
                                    Q23 = q[22],
                                    Q24 = q[23],
                                    Q25 = q[24],
                                    Q26 = q[25],
                                    Q27 = q[26],
                                    Q28 = q[27],
                                    Q29 = q[28],
                                    Q30 = q[29],
                                };
                                _repository.Add(item);
                                client.Send("Te:上传成功");
                                WriteLog("检测2#上传成功");
                            }
                        }
                        if (mes == "切换完成")
                        {
                            inovanceTcp.WriteDate("D1501.15", true);
                            Thread.Sleep(1000);
                            WriteLog("检测2#切换完成");
                        }
                        inovanceTcp.WriteDate("D1501.15", false);
                        if (mes.Split(":")[0] == "New")
                        {
                            var newOper = new Account()
                            {
                                Id = Guid.NewGuid(),
                                AccountID = mes.Split(":")[1],
                                ChangePassword = mes.Split(":")[2],
                            };
                            _repository.Add(newOper);
                            client.Send($"NewSuc:注册成功");
                            WriteLog("检测2#注册成功");
                        }
                        if (mes.Split(":")[0] == "Login")
                        {
                            string accountID = mes.Split(":")[1];
                            string changePassword = mes.Split(":")[2];
                            var login = _repository.GetFirstDefault<Account>(c => c.AccountID == accountID && c.ChangePassword == changePassword);//数据库查
                            if (login != null)
                            {
                                Operator16 = accountID;
                                client.Send($"LoginSuc:登录成功");
                                WriteLog("检测2#登录成功");
                            }
                        }
                    }
                    if (client.IP == "192.168.10.17")//检测3
                    {
                        if (mes.Split(":")[0] == "Test")
                        {
                            for (int i = 0; i < 30; i++)
                            {
                                if (mes.Split(":")[i + 1] == "1")
                                {
                                    q[i] = 1;
                                }
                                else
                                {
                                    q[i] = 0;
                                }
                            }
                            string str = DateTime.Now.ToString("yyyy/MM/dd");
                            var list = repository.GetFirstDefault<Quality>(c => c.DateQuality == str);//查一个值
                            if (list != null)
                            {
                                list.Q1 = list.Q1 + q[0];
                                list.Q2 = list.Q2 + q[1];
                                list.Q3 = list.Q3 + q[2];
                                list.Q4 = list.Q4 + q[3];
                                list.Q5 = list.Q5 + q[4];
                                list.Q6 = list.Q6 + q[5];
                                list.Q7 = list.Q7 + q[6];
                                list.Q8 = list.Q8 + q[7];
                                list.Q9 = list.Q9 + q[8];
                                list.Q10 = list.Q10 + q[9];
                                list.Q11 = list.Q11 + q[10];
                                list.Q12 = list.Q12 + q[11];
                                list.Q13 = list.Q13 + q[12];
                                list.Q14 = list.Q14 + q[13];
                                list.Q15 = list.Q15 + q[14];
                                list.Q16 = list.Q16 + q[15];
                                list.Q17 = list.Q17 + q[16];
                                list.Q18 = list.Q18 + q[17];
                                list.Q19 = list.Q19 + q[18];
                                list.Q20 = list.Q20 + q[19];
                                list.Q21 = list.Q21 + q[20];
                                list.Q22 = list.Q22 + q[21];
                                list.Q23 = list.Q23 + q[22];
                                list.Q24 = list.Q24 + q[23];
                                list.Q25 = list.Q25 + q[24];
                                list.Q26 = list.Q26 + q[25];
                                list.Q27 = list.Q27 + q[26];
                                list.Q28 = list.Q28 + q[27];
                                list.Q29 = list.Q29 + q[28];
                                list.Q30 = list.Q30 + q[29];
                                _repository.Update(list);
                                client.Send("Te:上传成功");
                                WriteLog("检测3#上传成功");
                            }
                            else
                            {
                                var item = new Quality()
                                {
                                    Id = Guid.NewGuid(),
                                    DateQuality = str,
                                    Q1 = q[0],
                                    Q2 = q[1],
                                    Q3 = q[2],
                                    Q4 = q[3],
                                    Q5 = q[4],
                                    Q6 = q[5],
                                    Q7 = q[6],
                                    Q8 = q[7],
                                    Q9 = q[8],
                                    Q10 = q[9],
                                    Q11 = q[10],
                                    Q12 = q[11],
                                    Q13 = q[12],
                                    Q14 = q[13],
                                    Q15 = q[14],
                                    Q16 = q[15],
                                    Q17 = q[16],
                                    Q18 = q[17],
                                    Q19 = q[18],
                                    Q20 = q[19],
                                    Q21 = q[20],
                                    Q22 = q[21],
                                    Q23 = q[22],
                                    Q24 = q[23],
                                    Q25 = q[24],
                                    Q26 = q[25],
                                    Q27 = q[26],
                                    Q28 = q[27],
                                    Q29 = q[28],
                                    Q30 = q[29],
                                };
                                _repository.Add(item);
                                client.Send("Te:上传成功");
                                WriteLog("检测3#上传成功");
                            }
                        }
                        if (mes == "切换完成")
                        {
                            inovanceTcp.WriteDate("D1502.0", true);
                            Thread.Sleep(1000);
                            WriteLog("检测3#切换完成");
                        }
                        inovanceTcp.WriteDate("D1502.0", false);
                        if (mes.Split(":")[0] == "New")
                        {
                            var newOper = new Account()
                            {
                                Id = Guid.NewGuid(),
                                AccountID = mes.Split(":")[1],
                                ChangePassword = mes.Split(":")[2],
                            };
                            _repository.Add(newOper);
                            client.Send($"NewSuc:注册成功");
                            WriteLog("检测3#注册成功");
                        }
                        if (mes.Split(":")[0] == "Login")
                        {
                            string accountID = mes.Split(":")[1];
                            string changePassword = mes.Split(":")[2];
                            var login = _repository.GetFirstDefault<Account>(c => c.AccountID == accountID && c.ChangePassword == changePassword);//数据库查
                            if (login != null)
                            {
                                Operator17 = accountID;
                                client.Send($"LoginSuc:登录成功");
                                WriteLog("检测3#登录成功");
                            }
                        }
                    }
                    if (client.IP == "192.168.10.18")//检测4
                    {
                        if (mes.Split(":")[0] == "Test")
                        {
                            for (int i = 0; i < 30; i++)
                            {
                                if (mes.Split(":")[i + 1] == "1")
                                {
                                    q[i] = 1;
                                }
                                else
                                {
                                    q[i] = 0;
                                }
                            }
                            string str = DateTime.Now.ToString("yyyy/MM/dd");
                            var list = repository.GetFirstDefault<Quality>(c => c.DateQuality == str);//查一个值
                            if (list != null)
                            {
                                list.Q1 = list.Q1 + q[0];
                                list.Q2 = list.Q2 + q[1];
                                list.Q3 = list.Q3 + q[2];
                                list.Q4 = list.Q4 + q[3];
                                list.Q5 = list.Q5 + q[4];
                                list.Q6 = list.Q6 + q[5];
                                list.Q7 = list.Q7 + q[6];
                                list.Q8 = list.Q8 + q[7];
                                list.Q9 = list.Q9 + q[8];
                                list.Q10 = list.Q10 + q[9];
                                list.Q11 = list.Q11 + q[10];
                                list.Q12 = list.Q12 + q[11];
                                list.Q13 = list.Q13 + q[12];
                                list.Q14 = list.Q14 + q[13];
                                list.Q15 = list.Q15 + q[14];
                                list.Q16 = list.Q16 + q[15];
                                list.Q17 = list.Q17 + q[16];
                                list.Q18 = list.Q18 + q[17];
                                list.Q19 = list.Q19 + q[18];
                                list.Q20 = list.Q20 + q[19];
                                list.Q21 = list.Q21 + q[20];
                                list.Q22 = list.Q22 + q[21];
                                list.Q23 = list.Q23 + q[22];
                                list.Q24 = list.Q24 + q[23];
                                list.Q25 = list.Q25 + q[24];
                                list.Q26 = list.Q26 + q[25];
                                list.Q27 = list.Q27 + q[26];
                                list.Q28 = list.Q28 + q[27];
                                list.Q29 = list.Q29 + q[28];
                                list.Q30 = list.Q30 + q[29];
                                _repository.Update(list);
                                client.Send("Te:上传成功");
                                WriteLog("检测4#上传成功");
                            }
                            else
                            {
                                var item = new Quality()
                                {
                                    Id = Guid.NewGuid(),
                                    DateQuality = str,
                                    Q1 = q[0],
                                    Q2 = q[1],
                                    Q3 = q[2],
                                    Q4 = q[3],
                                    Q5 = q[4],
                                    Q6 = q[5],
                                    Q7 = q[6],
                                    Q8 = q[7],
                                    Q9 = q[8],
                                    Q10 = q[9],
                                    Q11 = q[10],
                                    Q12 = q[11],
                                    Q13 = q[12],
                                    Q14 = q[13],
                                    Q15 = q[14],
                                    Q16 = q[15],
                                    Q17 = q[16],
                                    Q18 = q[17],
                                    Q19 = q[18],
                                    Q20 = q[19],
                                    Q21 = q[20],
                                    Q22 = q[21],
                                    Q23 = q[22],
                                    Q24 = q[23],
                                    Q25 = q[24],
                                    Q26 = q[25],
                                    Q27 = q[26],
                                    Q28 = q[27],
                                    Q29 = q[28],
                                    Q30 = q[29],
                                };
                                _repository.Add(item);
                                client.Send("Te:上传成功");
                                WriteLog("检测4#上传成功");
                            }
                        }
                        if (mes == "切换完成")
                        {
                            inovanceTcp.WriteDate("D1502.1", true);
                            Thread.Sleep(1000);
                            WriteLog("检测4#切换完成");
                        }
                        inovanceTcp.WriteDate("D1502.1", false);
                        if (mes.Split(":")[0] == "New")
                        {
                            var newOper = new Account()
                            {
                                Id = Guid.NewGuid(),
                                AccountID = mes.Split(":")[1],
                                ChangePassword = mes.Split(":")[2],
                            };
                            _repository.Add(newOper);
                            client.Send($"NewSuc:注册成功");
                            WriteLog("检测4#注册成功");
                        }
                        if (mes.Split(":")[0] == "Login")
                        {
                            string accountID = mes.Split(":")[1];
                            string changePassword = mes.Split(":")[2];
                            var login = _repository.GetFirstDefault<Account>(c => c.AccountID == accountID && c.ChangePassword == changePassword);//数据库查
                            if (login != null)
                            {
                                Operator18 = accountID;
                                client.Send($"LoginSuc:登录成功");
                                WriteLog("检测4#登录成功");
                            }
                        }
                    }

                    #endregion
                }
                catch (Exception ex)
                {
                    WriteLog($"报错:{ex.Message}");
                }
                return EasyTask.CompletedTask;
            };
            #endregion

            SignalMapper = new Dictionary<int, string>
            {
                {1, "D1025.0" },
                {2, "D1025.1" },
                {3, "D1025.2" },
                {4, "D1025.3" },
                {5, "D1025.4" },
                {6, "D1025.5" },
                {7, "D1025.8" },
                {8, "D1025.9" },
                {9, "D1025.10" },
                {10, "D1025.11" },
                {11, "D1025.14" },
                {12, "D1025.15" },
                {13, "D1026.0" },
                {14, "D1026.1" },
            };

            _stateService.CreateMachine(1, RecordOneMessage1, null);
            _stateService.CreateMachine(2, RecordOneMessage2, null);
            _stateService.CreateMachine(3, RecordOneMessage3, null);
            _stateService.CreateMachine(4, RecordOneMessage4, null);
            _stateService.CreateMachine(5, RecordOneMessage5, null);
            _stateService.CreateMachine(6, RecordOneMessage6, null);
            _stateService.CreateMachine(7, RecordOneMessage7, null);
            _stateService.CreateMachine(8, RecordOneMessage8, null);
            _stateService.CreateMachine(9, RecordOneMessage9, null);
            _stateService.CreateMachine(10, RecordOneMessage10, null);
            _stateService.CreateMachine(11, RecordOneMessage11, null);
            _stateService.CreateMachine(12, RecordOneMessage12, null);
            _stateService.CreateMachine(13, RecordOneMessage13, null);
            _stateService.CreateMachine(14, RecordOneMessage14, null);

            Task.Factory.StartNew(Timer_Elapsed, TaskCreationOptions.LongRunning);
            Task.Factory.StartNew(Timer_Elapsed2, TaskCreationOptions.LongRunning);

            QRCommand = new DelegateCommand(QRcode);

            //_eventAggregator.GetEvent<FileChangedEvent>().Subscribe(ReadConfig);
            
        }

        private void OrderEnter()
        {
            try
            {
                if (string.IsNullOrWhiteSpace(SelectedOrderName))
                {
                    
                }
                else
                {
                    Quest(SelectedOrderName);
                    WriteLog("切换订单成功");
                }
            }
            catch (Exception)
            {

            }
        }
        
        public void ReadOrder()
        {
            var customRepo = new CustomRepository();
            try
            {
                DateTime max = DateTime.Today.AddDays(1);
                DateTime min = DateTime.Today.AddDays(-1);
                //var list = customRepo.GetAllQuery<ICMO>(c => c.FDate == DateTime.Today);
                var list = customRepo.GetAllQuery<ICMO>(c => c.FDate < max && c.FDate > min);
                if (list != null)
                {
                    OrderNames = new ObservableCollection<string>();
                    for (int i = 0; i < list.Count; i++)
                    {
                        OrderNames.Add(list[i].FBillNo);
                    }
                }
            }
            catch (Exception ex)
            {
                
            }
        }
        private void UploadOutWork()
        {
            string str = DateTime.Now.ToString("yyyy/MM/dd");
            var list = _repository.GetFirstDefault<OutofWork>(c => c.DateOutWork == str);
            if (list != null)
            {
                list.DateOutWork = str;
                list.Actual = ActPer;
                list.FallIll = FallPer;
                list.Absenteeism = AbsPer;
                _repository.Update(list);
                WriteLog("出勤信息上传成功");
            }
            else
            {
                var outwork = new OutofWork()
                {
                    Id = Guid.NewGuid(),
                    DateOutWork = DateTime.Now.ToString("yyyy/MM/dd"),
                    Actual = ActPer,
                    FallIll = FallPer,
                    Absenteeism = AbsPer,
                };
                _repository.Add(outwork);
                WriteLog("出勤信息上传成功");
            }
        }

        private void UploadHouse()
        {
            string str = DateTime.Now.ToString("yyyy/MM/dd");
            var list = _repository.GetFirstDefault<House>(c => c.DateH == str);
            if (list != null)
            {
                list.DateH = str;
                list.LackH = LackHouse;
                list.UsedH = UsedHouse;
                list.TotalH = TotalHouse;
                _repository.Update(list);
                WriteLog("线边仓数据上传成功");
            }
            else
            {
                var houses = new House()
                {
                    Id = Guid.NewGuid(),
                    DateH = DateTime.Now.ToString("yyyy/MM/dd"),
                    LackH = LackHouse,
                    UsedH = UsedHouse,
                    TotalH = TotalHouse,
                };
                _repository.Add(houses);
                WriteLog("线边仓数据上传成功");
            }
        }

        //void SwitchProduct()
        //{
        //    SendToClient("Num1");
        //}
        //public void SendToClient(string id)
        //{
        //    //tcpService.SocketClients.GetIds() 向所有id发送
        //    //foreach (var item in tcpService.SocketClients.GetIds())
        //    //{
        //    //    if (string.IsNullOrWhiteSpace(SelectedConfigName))
        //    //    {
        //    //        tcpService.Send(item, "None");
        //    //        WriteLog("发送：None");
        //    //        return;
        //    //    }
        //    //    tcpService.Send(item, SelectedConfigName);
        //    //    WriteLog("发送：" + SelectedConfigName);
        //    //}
        //    if (string.IsNullOrWhiteSpace(SelectedConfigName))
        //    {
        //        tcpService.Send(id, "None");
        //        WriteLog("发送：None");
        //        return;
        //    }
        //    tcpService.Send(id, SelectedConfigName);
        //    WriteLog("发送：" + SelectedConfigName);

        //}
        public void SendPro(string id, string name)
        {
            try
            {
                var ids = tcpService.SocketClients.GetIds();
                foreach (var item in tcpService.SocketClients.GetClients())
                {
                    if (item.IP == id)
                    {
                        item.Send("Type:" + name + ":" + id);
                        WriteLog("发送：" + name);
                        break;
                    }

                }
                //tcpService.Send(id, "Type:" + name + ":" + id);
                //WriteLog("发送：" + name);
            }
            catch (Exception)
            {

            }
        }

        #region 工位
        public void RecordOneMessage1(object sender, StateEventArgs e)//1
        {
            var spt = inovanceTcp.ReadInt("D1003");
            var d1 = inovanceTcp.ReadInt("D1030");
            var d2 = inovanceTcp.ReadInt("D1031");
            var d3 = inovanceTcp.ReadInt("D1032");
            var pno = d1.ToString() + d2.ToString() + d3.ToString();
            var productNew = new InformationNew
            {
                OperatorCode = Operator1,
                ProCode = Material1,
                SpendTime = spt/10,
                CreateTime = DateTime.Now,
                ProType = proName,
                ProNo=pno,
            };
            var product = new Information()
            {
                CreateTime = productNew.CreateTime,
                Id = Guid.NewGuid(),
                OperatorCode = productNew.OperatorCode,
                ProCode = productNew.ProCode,
                SpendTime = productNew.SpendTime,
                ProType = productNew.ProType,
                ProNo=productNew.ProNo
            };

            InforNew.Add(productNew);
            _repository.Add(product);
            inovanceTcp.WriteDate("D1025.0", false);
        }
        public void RecordOneMessage2(object sender, StateEventArgs e)//2
        {
            var spt = inovanceTcp.ReadInt("D1004");
            var d1 = inovanceTcp.ReadInt("D1033");
            var d2 = inovanceTcp.ReadInt("D1034");
            var d3 = inovanceTcp.ReadInt("D1035");
            var pno = d1.ToString() + d2.ToString() + d3.ToString();
            var productNew = new InformationNew
            {
                OperatorCode = Operator2,
                ProCode = Material2,
                SpendTime = spt/10,
                CreateTime = DateTime.Now,
                ProType = proName,
                ProNo = pno,
            };
            var product = new Information()
            {
                CreateTime = productNew.CreateTime,
                Id = Guid.NewGuid(),
                OperatorCode = productNew.OperatorCode,
                ProCode = productNew.ProCode,
                SpendTime = productNew.SpendTime,
                ProType = productNew.ProType,
                ProNo = productNew.ProNo
            };

            _repository.Add(product);
            InforNew.Add(productNew);
            inovanceTcp.WriteDate("D1025.1", false);
        }
        public void RecordOneMessage3(object sender, StateEventArgs e)//3
        {
            var spt = inovanceTcp.ReadInt("D1005");
            var d1 = inovanceTcp.ReadInt("D1036");
            var d2 = inovanceTcp.ReadInt("D1037");
            var d3 = inovanceTcp.ReadInt("D1038");
            var pno = d1.ToString() + d2.ToString() + d3.ToString();
            var productNew = new InformationNew
            {
                OperatorCode = Operator3,
                ProCode = Material3,
                SpendTime = spt/10,
                CreateTime = DateTime.Now,
                ProType = proName,
                ProNo = pno,
            };
            var product = new Information()
            {
                CreateTime = productNew.CreateTime,
                Id = Guid.NewGuid(),
                OperatorCode = productNew.OperatorCode,
                ProCode = productNew.ProCode,
                SpendTime = productNew.SpendTime,
                ProType = productNew.ProType,
                ProNo=productNew.ProNo
            };

            _repository.Add(product);
            InforNew.Add(productNew);
            inovanceTcp.WriteDate("D1025.2", false);
        }
        public void RecordOneMessage4(object sender, StateEventArgs e)//4
        {
            var spt = inovanceTcp.ReadInt("D1006");
            var d1 = inovanceTcp.ReadInt("D1039");
            var d2 = inovanceTcp.ReadInt("D1040");
            var d3 = inovanceTcp.ReadInt("D1041");
            var pno = d1.ToString() + d2.ToString() + d3.ToString();
            var productNew = new InformationNew
            {
                OperatorCode = Operator4,
                ProCode = Material4,
                SpendTime = spt/10,
                CreateTime = DateTime.Now,
                ProType = proName,
                ProNo = pno,
            };
            var product = new Information()
            {
                CreateTime = productNew.CreateTime,
                Id = Guid.NewGuid(),
                OperatorCode = productNew.OperatorCode,
                ProCode = productNew.ProCode,
                SpendTime = productNew.SpendTime,
                ProType = productNew.ProType,
                ProNo = productNew.ProNo
            };

            _repository.Add(product);
            InforNew.Add(productNew);
            inovanceTcp.WriteDate("D1025.3", false);
        }
        public void RecordOneMessage5(object sender, StateEventArgs e)//5
        {
            var spt = inovanceTcp.ReadInt("D1007");
            var d1 = inovanceTcp.ReadInt("D1042");
            var d2 = inovanceTcp.ReadInt("D1043");
            var d3 = inovanceTcp.ReadInt("D1044");
            var pno = d1.ToString() + d2.ToString() + d3.ToString();
            var productNew = new InformationNew
            {
                OperatorCode = Operator5,
                ProCode = Material5,
                SpendTime = spt/10,
                CreateTime = DateTime.Now,
                ProType = proName,
                ProNo = pno,
            };
            var product = new Information()
            {
                CreateTime = productNew.CreateTime,
                Id = Guid.NewGuid(),
                OperatorCode = productNew.OperatorCode,
                ProCode = productNew.ProCode,
                SpendTime = productNew.SpendTime,
                ProType = productNew.ProType,
                ProNo = productNew.ProNo
            };

            _repository.Add(product);
            InforNew.Add(productNew);
            inovanceTcp.WriteDate("D1025.4", false);
        }
        public void RecordOneMessage6(object sender, StateEventArgs e)//6
        {
            var spt = inovanceTcp.ReadInt("D1008");
            var d1 = inovanceTcp.ReadInt("D1045");
            var d2 = inovanceTcp.ReadInt("D1046");
            var d3 = inovanceTcp.ReadInt("D1047");
            var pno = d1.ToString() + d2.ToString() + d3.ToString();
            var productNew = new InformationNew
            {
                OperatorCode = Operator6,
                ProCode = Material6,
                SpendTime = spt/10,
                CreateTime = DateTime.Now,
                ProType = proName,
                ProNo = pno,
            };
            var product = new Information()
            {
                CreateTime = productNew.CreateTime,
                Id = Guid.NewGuid(),
                OperatorCode = productNew.OperatorCode,
                ProCode = productNew.ProCode,
                SpendTime = productNew.SpendTime,
                ProType = productNew.ProType,
                ProNo=productNew.ProNo
            };

            _repository.Add(product);
            InforNew.Add(productNew);
            inovanceTcp.WriteDate("D1025.5", false);
        }
        public void RecordOneMessage7(object sender, StateEventArgs e)//7
        {
            var spt = inovanceTcp.ReadInt("D1011");
            var d1 = inovanceTcp.ReadInt("D1048");
            var d2 = inovanceTcp.ReadInt("D1049");
            var d3 = inovanceTcp.ReadInt("D1050");
            var pno = d1.ToString() + d2.ToString() + d3.ToString();
            var productNew = new InformationNew
            {
                OperatorCode = Operator9,
                ProCode = Material9,
                SpendTime = spt / 10,
                CreateTime = DateTime.Now,
                ProType = proName,
                ProNo = pno,
            };
            var product = new Information()
            {
                CreateTime = productNew.CreateTime,
                Id = Guid.NewGuid(),
                OperatorCode = productNew.OperatorCode,
                ProCode = productNew.ProCode,
                SpendTime = productNew.SpendTime,
                ProType = productNew.ProType,
                ProNo = productNew.ProNo,
            };

            _repository.Add(product);
            InforNew.Add(productNew);
            inovanceTcp.WriteDate("D1025.8", false);
        }
        public void RecordOneMessage8(object sender, StateEventArgs e)//8
        {
            var spt = inovanceTcp.ReadInt("D1012");
            var d1 = inovanceTcp.ReadInt("D1051");
            var d2 = inovanceTcp.ReadInt("D1052");
            var d3 = inovanceTcp.ReadInt("D1053");
            var pno = d1.ToString() + d2.ToString() + d3.ToString();
            var productNew = new InformationNew
            {
                OperatorCode = Operator10,
                ProCode = Material10,
                SpendTime = spt/10,
                CreateTime = DateTime.Now,
                ProType = proName,
                ProNo = pno,
            };
            var product = new Information()
            {
                CreateTime = productNew.CreateTime,
                Id = Guid.NewGuid(),
                OperatorCode = productNew.OperatorCode,
                ProCode = productNew.ProCode,
                SpendTime = productNew.SpendTime,
                ProType = productNew.ProType,
                ProNo= productNew.ProNo,
            };

            _repository.Add(product);
            InforNew.Add(productNew);
            inovanceTcp.WriteDate("D1025.9", false);
        }
        public void RecordOneMessage9(object sender, StateEventArgs e)//9
        {
            var spt = inovanceTcp.ReadInt("D1013");
            var d1 = inovanceTcp.ReadInt("D1054");
            var d2 = inovanceTcp.ReadInt("D1055");
            var d3 = inovanceTcp.ReadInt("D1056");
            var pno = d1.ToString() + d2.ToString() + d3.ToString();
            var productNew = new InformationNew
            {
                OperatorCode = Operator11,
                ProCode = Material11,
                SpendTime = spt/10,
                CreateTime = DateTime.Now,
                ProType = proName,
                ProNo = pno,
            };
            var product = new Information()
            {
                CreateTime = productNew.CreateTime,
                Id = Guid.NewGuid(),
                OperatorCode = productNew.OperatorCode,
                ProCode = productNew.ProCode,
                SpendTime = productNew.SpendTime,
                ProType = productNew.ProType,
                ProNo= productNew.ProNo,
            };

            _repository.Add(product);
            InforNew.Add(productNew);
            inovanceTcp.WriteDate("D1025.10", false);
        }
        public void RecordOneMessage10(object sender, StateEventArgs e)//10
        {
            var spt = inovanceTcp.ReadInt("D1014");
            var d1 = inovanceTcp.ReadInt("D1057");
            var d2 = inovanceTcp.ReadInt("D1058");
            var d3 = inovanceTcp.ReadInt("D1059");
            var pno = d1.ToString() + d2.ToString() + d3.ToString();
            var productNew = new InformationNew
            {
                OperatorCode = Operator12,
                ProCode = Material12,
                SpendTime = spt/10,
                CreateTime = DateTime.Now,
                ProType = proName,
                ProNo = pno,
            };
            var product = new Information()
            {
                CreateTime = productNew.CreateTime,
                Id = Guid.NewGuid(),
                OperatorCode = productNew.OperatorCode,
                ProCode = productNew.ProCode,
                SpendTime = productNew.SpendTime,
                ProType = productNew.ProType,
                ProNo= productNew.ProNo,
            };

            _repository.Add(product);
            InforNew.Add(productNew);
            inovanceTcp.WriteDate("D1025.11", false);
        }
        public void RecordOneMessage11(object sender, StateEventArgs e)//11
        {
            var spt = inovanceTcp.ReadInt("D1017");
            var d1 = inovanceTcp.ReadInt("D1060");
            var d2 = inovanceTcp.ReadInt("D1061");
            var d3 = inovanceTcp.ReadInt("D1062");
            var pno = d1.ToString() + d2.ToString() + d3.ToString();
            var productNew = new InformationNew
            {
                OperatorCode = Operator15,
                ProCode = Material15,
                SpendTime = spt/10,
                CreateTime = DateTime.Now,
                ProType = proName,
                ProNo = pno,
            };
            var product = new Information()
            {
                CreateTime = productNew.CreateTime,
                Id = Guid.NewGuid(),
                OperatorCode = productNew.OperatorCode,
                ProCode = productNew.ProCode,
                SpendTime = productNew.SpendTime,
                ProType = productNew.ProType,
                ProNo= productNew.ProNo,
            };

            _repository.Add(product);
            InforNew.Add(productNew);
            inovanceTcp.WriteDate("D1025.14", false);
        }
        public void RecordOneMessage12(object sender, StateEventArgs e)//12
        {
            var spt = inovanceTcp.ReadInt("D1018");
            var d1 = inovanceTcp.ReadInt("D1063");
            var d2 = inovanceTcp.ReadInt("D1064");
            var d3 = inovanceTcp.ReadInt("D1065");
            var pno = d1.ToString() + d2.ToString() + d3.ToString();
            var productNew = new InformationNew
            {
                OperatorCode = Operator16,
                ProCode = Material16,
                SpendTime = spt/10,
                CreateTime = DateTime.Now,
                ProType = proName,
                ProNo = pno,
            };
            var product = new Information()
            {
                CreateTime = productNew.CreateTime,
                Id = Guid.NewGuid(),
                OperatorCode = productNew.OperatorCode,
                ProCode = productNew.ProCode,
                SpendTime = productNew.SpendTime,
                ProType = productNew.ProType,
                ProNo = productNew.ProNo,
            };

            _repository.Add(product);
            InforNew.Add(productNew);
            inovanceTcp.WriteDate("D1025.15", false);
        }
        public void RecordOneMessage13(object sender, StateEventArgs e)//13
        {
            var spt = inovanceTcp.ReadInt("D1019");
            var d1 = inovanceTcp.ReadInt("D1066");
            var d2 = inovanceTcp.ReadInt("D1067");
            var d3 = inovanceTcp.ReadInt("D1068");
            var pno = d1.ToString() + d2.ToString() + d3.ToString();
            var productNew = new InformationNew
            {
                OperatorCode = Operator17,
                ProCode = Material17,
                SpendTime = spt/10,
                CreateTime = DateTime.Now,
                ProType = proName,
                ProNo = pno,
            };
            var product = new Information()
            {
                CreateTime = productNew.CreateTime,
                Id = Guid.NewGuid(),
                OperatorCode = productNew.OperatorCode,
                ProCode = productNew.ProCode,
                SpendTime = productNew.SpendTime,
                ProType = productNew.ProType,
                ProNo = productNew.ProNo,
            };

            _repository.Add(product);
            InforNew.Add(productNew);
            inovanceTcp.WriteDate("D1026.0", false);
        }
        public void RecordOneMessage14(object sender, StateEventArgs e)//14
        {
            var spt = inovanceTcp.ReadInt("D1020");
            var d1 = inovanceTcp.ReadInt("D1069");
            var d2 = inovanceTcp.ReadInt("D1070");
            var d3 = inovanceTcp.ReadInt("D1071");
            var pno = d1.ToString() + d2.ToString() + d3.ToString();
            var productNew = new InformationNew
            {
                OperatorCode = Operator18,
                ProCode = Material18,
                SpendTime = spt/10,
                CreateTime = DateTime.Now,
                ProType = proName,
                ProNo = pno,
            };
            var product = new Information()
            {
                CreateTime = productNew.CreateTime,
                Id = Guid.NewGuid(),
                OperatorCode = productNew.OperatorCode,
                ProCode = productNew.ProCode,
                SpendTime = productNew.SpendTime,
                ProType = productNew.ProType,
                ProNo = productNew.ProNo,
            };

            _repository.Add(product);
            InforNew.Add(productNew);
            inovanceTcp.WriteDate("D1026.1", false);
        }
        #endregion
        public void Quest(string str)
        {
            _eventAggregator.GetEvent<QuestEvent>().Publish(str);
        }

        public void Alarm(Dictionary<string, string> plcsignal)
        {
            _eventAggregator.GetEvent<AlarmEvent>().Publish(plcsignal);//跨viewmodel发信息,Publish(发送的消息)
        }

        bool mybool = false;
        bool one = true;
        string proName;
        private void Timer_Elapsed()
        {
            while (true)
            {
                if (!Connected)
                {
                    if (one)
                    {
                        WriteLog("plc连接异常", LogType.Error);
                        one = false;
                    }
                    continue;
                }

                try
                {
                    if (one)
                    {
                        WriteLog("plc连接成功", LogType.Info);
                        one = false;
                    }

                    if (!mybool)
                    {
                        inovanceTcp.WriteDate("D1500", 0);
                        mybool = true;
                    }
                    else
                    {
                        inovanceTcp.WriteDate("D1500", 1);
                        mybool = false;
                    }

                    foreach (var item in SignalMapper)
                    {
                        //if (e.StartingAddress+e.Points.Length < item.Value)
                        //{
                        //    continue;
                        //}
                        //var data = e.Points[item.Value];

                        //var value = inovanceTcp.Read(item.Value, 1);
                        
                        var value=inovanceTcp.ReadBool(item.Value);
                        _stateService.ExecuteState(item.Key, value ? (ushort)1 : (ushort)0);
                    }
                }
                catch (ObjectDisposedException ex)
                {
                    _logger.Information(ex.ToString());
                }
                finally
                {
                    Thread.Sleep(1000);
                }
            }
        }
        int a=0;
        private void Timer_Elapsed2()
        {
            while (true)
            {
                if (!Connected)
                {
                    continue;
                }
                try
                {
                    ReadOrder();
                    //切换产品
                    int type = inovanceTcp.ReadInt("D1000");
                    if (a !=type)
                    {
                        Change();
                    }
                    a = type;
                    #region 报警
                    var dictionary = new Dictionary<string, string>();
                    
                    for (int i = 0; i < 31; i++)
                    {
                        var adrress = "D" + (1100 + i).ToString();
                        int ad = inovanceTcp.ReadInt(adrress);
                        if (ad != 0)
                        {
                            dictionary.Add(adrress, "报警");
                        }
                        else
                        {
                            dictionary.Add(adrress, "正常");
                        }
                    }
                    for (int i = 0; i < 25; i++)
                    {
                        var adrress = "D" + (1141.15 + i).ToString();
                        if (inovanceTcp.ReadBool(adrress))
                        {
                            dictionary.Add(adrress, "缺料");
                        }
                        else
                        {
                            dictionary.Add(adrress, "正常");
                        }
                    }
                    for (int i = 0; i < 7; i++)
                    {
                        var adrress = "D" + (1166 + (double)i / 10).ToString("0.0");
                        if (inovanceTcp.ReadBool(adrress))
                        {
                            dictionary.Add(adrress, "缺料");
                        }
                        else
                        {
                            dictionary.Add(adrress, "正常");
                        }
                    }

                    Alarm(dictionary);
                    #endregion
                }
                catch (ObjectDisposedException ex)
                {
                    _logger.Information(ex.ToString());
                }
                finally
                {
                    Thread.Sleep(1000);
                }
            }
        }
        public void Change()
        {
            int type = inovanceTcp.ReadInt("D1000");
            switch (type)
            {
                case 0:
                    break;
                case 1:
                    proName = "P60";
                    break;
                case 2:
                    proName = "P70";
                    break;
                case 3:
                    proName = "P80";
                    break;
                case 4:
                    proName = "P90";
                    break;
            }
            if (inovanceTcp.ReadBool("D1001.0"))
            {
                SendPro("192.168.10.1", proName);
            }
            if (inovanceTcp.ReadBool("D1001.1"))
            {
                SendPro("192.168.10.2", proName);
            }
            if (inovanceTcp.ReadBool("D1001.2"))
            {
                SendPro("192.168.10.3", proName);
            }
            if (inovanceTcp.ReadBool("D1001.3"))
            {
                SendPro("192.168.10.4", proName);
            }
            if (inovanceTcp.ReadBool("D1001.4"))
            {
                SendPro("192.168.10.5", proName);
            }
            if (inovanceTcp.ReadBool("D1001.5"))
            {
                SendPro("192.168.10.6", proName);
            }
            if (inovanceTcp.ReadBool("D1001.6"))
            {
                SendPro("192.168.10.7", proName);
            }
            if (inovanceTcp.ReadBool("D1001.7"))
            {
                SendPro("192.168.10.8", proName);
            }
            if (inovanceTcp.ReadBool("D1001.8"))
            {
                SendPro("192.168.10.9", proName);
            }
            if (inovanceTcp.ReadBool("D1001.9"))
            {
                SendPro("192.168.10.10", proName);
            }
            if (inovanceTcp.ReadBool("D1001.10"))
            {
                SendPro("192.168.10.11", proName);
            }
            if (inovanceTcp.ReadBool("D1001.11"))
            {
                SendPro("192.168.10.12", proName);
            }
            if (inovanceTcp.ReadBool("D1001.12"))
            {
                SendPro("192.168.10.13", proName);
            }
            if (inovanceTcp.ReadBool("D1001.13"))
            {
                SendPro("192.168.10.14", proName);
            }
            if (inovanceTcp.ReadBool("D1001.14"))
            {
                SendPro("192.168.10.15", proName);
            }
            if (inovanceTcp.ReadBool("D1001.15"))
            {
                SendPro("192.168.10.16", proName);
            }
            if (inovanceTcp.ReadBool("D1002.0"))
            {
                SendPro("192.168.10.17", proName);
            }
            if (inovanceTcp.ReadBool("D1002.1"))
            {
                SendPro("192.168.10.18", proName);
            }

        }

        public string SelectedConfigName { get; set; }
        public ObservableCollection<string> ConfigNames { get; set; }
        public WriteableBitmap QrImage { get; set; }

        public void ReadConfig()
        {
            ConfigNames = new ObservableCollection<string>();
            if (!Directory.Exists(@"d:\作业指导书\"))
            {
                return;
            }
            var files = Directory.GetFiles(@"d:\作业指导书\");
            foreach (var item in files)
            {
                var file = new FileInfo(item);
                if (file.Extension == ".json")
                {
                    ConfigNames.Add(file.Name.Replace(file.Extension, ""));
                }
            }
        }

        #region old

        private void StopCheck(object sender, StateEventArgs e)
        {
            var modbus = _modbusTcpSlaverService.GetModbusSlaveByIp();
            //var points = modbus.DataStore.HoldingRegisters.ReadPoints(200, 1);

            Application.Current.Dispatcher.Invoke(new Action(() =>
            {
                var (errorCode, error) = _warningUpdateService.GetErrorCode(1);
                //Dialog.Show(new OeeDialogPage(), "");
                // var DialogResult = await Dialog.Show<OeeDialogPage>()
                //.Initialize<OeeDialogPageViewModel>(vm => vm.Message = "DialogResult")
                //.GetResultAsync<string>();
                var param = new DialogParameters
                {
                    { "OP_Id", Param.OPID },
                    {"ExceptionCode", errorCode}
                };
                modbus.DataStore.CoilInputs.WritePoints(12, new bool[] { true });
                _dialogService.ShowDialog("OeeDialogPage", param, async r =>
                {
                    //dialog.Parameters.Add("OP_Id", OP_Id);
                    //dialog.Parameters.Add("ExceptionCode", ExceptionCode);
                    //dialog.Parameters.Add("ExceptionContent", ExceptionContent);
                    //dialog.Parameters.Add("Duration", Duration);
                    //dialog.Parameters.Add("ExceptionTime", ExceptionTime.ToString("yyyy-mm-dd HH:mm:ss"));
                    //dialog.Parameters.Add("Mode", "手动调试模式");
                    //dialog.Parameters.Add("Reason", ExceptionReason);
                    var param = r.Parameters;
                    var opid = param.GetValue<string>("OP_Id");
                    var exceptionCodeMessage = param.GetValue<string>("ExceptionCode");
                    var exceptionCode = exceptionCodeMessage.Split('-')[0];
                    var exceptionContent = param.GetValue<string>("ExceptionContent");
                    var duration = param.GetValue<int>("Duration");
                    var exceptionTime = param.GetValue<string>("ExceptionTime");
                    var mode = param.GetValue<string>("Mode");
                    var reason = param.GetValue<string>("Reason");
                    var oeeLogger = new OeeLogger
                    {
                        site = OeeConfig.Site,
                        floor = OeeConfig.Floor,
                        product = OeeConfig.Product,
                        line = OeeConfig.Line,
                        vendor = "Team",
                        process = OeeConfig.Process,
                        terminalId = OeeConfig.TerminalId,
                        machineId = OeeConfig.MachineId,
                        status = mode,
                        op_id = opid,
                        startTime = exceptionTime,
                        ipaddr = OeeConfig.Ipaddr,
                        macaddr = OeeConfig.Macaddr,
                        warningCodeList = new Warningcodelist[2]
                    };
                    oeeLogger.warningCodeList[0] = new Warningcodelist
                    {
                        warningCode = "400002",
                        remark = exceptionContent
                    };
                    oeeLogger.warningCodeList[1] = new Warningcodelist
                    {
                        warningCode = exceptionCode,
                        remark = reason
                    };
                    await UploadOeeAsync(oeeLogger);

                    modbus.DataStore.CoilInputs.WritePoints(12, new bool[] { false });

                });
            }));
        }
        private async void ResettableTimer_Elapsed(object sender, ElapsedEventArgs e)
        {
            OeeLogger oeeLogger = new()
            {
                site = OeeConfig.Site,
                floor = OeeConfig.Floor,
                product = OeeConfig.Product,
                line = OeeConfig.Line,
                vendor = "Team",
                process = OeeConfig.Process,
                terminalId = OeeConfig.TerminalId,
                machineId = OeeConfig.MachineId,
                status = "Waiting for parts",
                op_id = Param.OPID,
                startTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
                ipaddr = OeeConfig.Ipaddr,
                macaddr = OeeConfig.Macaddr,
                warningCodeList = new Warningcodelist[1]
            };
            oeeLogger.warningCodeList[0] = new Warningcodelist
            {
                warningCode = "100002",
                remark = "待料"
            };
            await UploadOeeAsync(oeeLogger);

        }
        private void WaringUpdateLogChanged(Tuple<LogType, string> tuple)
        {
            Debug.WriteLine(tuple.Item2);
            HandyControl.Controls.MessageBox.Show("test");
        }
        private void OeeConfigChanged(OeeConfig config)
        {
            OeeConfig ??= new OeeConfig();
            OeeConfig.Ip = config.Ip;
            OeeConfig.Port = config.Port;
            OeeConfig.WaitPartDuration = config.WaitPartDuration;
            OeeConfig.StopDuration = config.StopDuration;
            OeeConfig.Site = config.Site;
            OeeConfig.Floor = config.Floor;
            OeeConfig.Product = config.Product;
            OeeConfig.Line = config.Line;
            OeeConfig.Process = config.Process;
            OeeConfig.Vendor = config.Vendor;
            OeeConfig.TerminalId = config.TerminalId;
            OeeConfig.MachineId = config.MachineId;
            OeeConfig.Op_id = config.Op_id;
            OeeConfig.Ipaddr = config.Ipaddr;
            OeeConfig.Macaddr = config.Macaddr;
            OeeConfig.OeePath = config.OeePath;
            OeeConfig.UnUse = config.UnUse;
        }
        private async Task UploadOeeAsync(OeeLogger oeeLogger)
        {
            if (OeeConfig == null)
            {
                WriteLog("oee配置文件不存在请重新配置", LogType.Error);
                return;
            }
            using var client = _httpClientFactory.CreateClient();
            //var url = _appSttings.Value.OeeUrl;
            var loggingURI = $"http://{OeeConfig.Ip}:{OeeConfig.Port}/device/upload/logging/v1";

            try
            {
                var json = JsonConvert.SerializeObject(oeeLogger, Formatting.Indented);
                WriteToLocal(json);
                if (!OeeConfig.UnUse)
                {
                    client.BaseAddress = new Uri(loggingURI);
                    var content = new StringContent(json, Encoding.UTF8, "application/json");
                    var response = await client.PostAsync(loggingURI, content);
                    WriteLog("oee上传成功");
                    var s = await response.Content.ReadAsStringAsync();
                    WriteLog($"状态码:{response.StatusCode}:" + s, LogType.Info);
                }
                else
                {
                    WriteLog("oee上传屏蔽，未上传");
                }

            }
            catch (Exception e)
            {
                WriteLog($"oee上传失败,{e.Message}", LogType.Error);
            }
        }
        private void WriteToLocal(string json)
        {
            var name = DateTime.Now.ToString("yyyy-mm-dd-HH-mm-ss") + "_oee" + ".json";
            var path = Path.Combine(OeeConfig.OeePath, name);
            if (!Directory.Exists(OeeConfig.OeePath))
            {
                WriteLog("oee路径不存在", LogType.Error);
                return;
            }
            using var stream = new StreamWriter(path);
            stream.Write(json);
        }
        private void ClearQueue(object sender, StateEventArgs e)
        {
            var length = _upLoadTraceModels.Count;
            for (int i = 0; i < length; i++)
            {
                _upLoadTraceModels.TryDequeue(out _);
            }
        }
        private void InitTraceData()
        {
            var filePath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "param.json");
            if (File.Exists(filePath))
            {
                using var stream = new StreamReader(filePath);
                var json = stream.ReadToEnd();
                Param = JsonConvert.DeserializeObject<Param>(json);
            }
            else
            {
                Param = new Param
                {
                    station_id = "LkYC_BO7_2F_01_002_TRACE",
                    line_id = "B07-2F-01",
                    station_vendor = "Team",
                    test = "Logo 30N Non-Destructive Test",
                    OPID = "C10088888",
                    DownLimit = "30",
                    UpperLimit = "60"
                };
            }
        }
        private void ScanMethodComplete(object sender, StateEventArgs e)
        {
            //var modbus = _modbusTcpSlaverService.GetModbusSlaveByIp();
            //modbus.DataStore.CoilInputs.WritePoints(9, new bool[] { false });
            //WriteLog("复位扫码OK信号");
        }
        private void SaveDataCompleted(object sender, StateEventArgs e)
        {
            var modbus = _modbusTcpSlaverService.GetModbusSlaveByIp();
            modbus.DataStore.CoilInputs.WritePoints(10, new bool[] { false });
            modbus.DataStore.CoilInputs.WritePoints(11, new bool[] { false });
        }
        private void SaveImage(string barcode, string result)
        {
            var filePath = string.Empty;
            var fileName = barcode + "-" + Guid.NewGuid().ToString("N") + $"-{result}" + ".png";
            string directory = ImagePath;


            Application.Current.Dispatcher.Invoke(new Action(() =>
            {
                try
                {
                    var finalPath = Path.Combine(directory, result);
                    if (!Directory.Exists(finalPath))
                    {

                        Directory.CreateDirectory(finalPath);
                    }
                    filePath = Path.Combine(finalPath, fileName);

                    (PlotModel.PlotView as OxyPlot.Wpf.PlotView)?.SaveBitmap(filePath);
                }
                catch (Exception e)
                {
                    WriteLog($"保存图片出现异常:{e.Message}");
                }

            }));

        }
        public float ReadFloat(ushort startId)
        {
            var modbus = _modbusTcpSlaverService.GetModbusSlaveByIp();
            var data = modbus.DataStore
               .HoldingRegisters.ReadPoints((ushort)(32 + startId), 2);
            var bytes1 = BitConverter.GetBytes(data[0]);
            var bytes2 = BitConverter.GetBytes(data[1]);
            var bytes = new List<byte>();
            bytes.AddRange(bytes1);
            bytes.AddRange(bytes2);
            var value = BitConverter.ToSingle(bytes.ToArray(), 0);
            return value;
        }

        private async void ScanMethod(object sender, StateEventArgs e)
        {
            ErrorCode = string.Empty;
            var modbus = _modbusTcpSlaverService.GetModbusSlaveByIp();
            if (!ScanConnected)
            {
                WriteLog($"扫码枪未连接，无法执行扫码动作");
                ErrorCode = "扫码枪未连接，无法执行扫码动作";
                modbus.DataStore.CoilInputs.WritePoints(9, new bool[] { false });
                return;
            }

            for (int i = 0; i < 3; i++)
            {
                try
                {
                    WriteLog($"开始第{i + 1}次扫码");
                    NewBarcode = await _scanService.ReadAsync("start");
                    WriteLog($"第{i + 1}次扫码结果:{NewBarcode}");
                    if (NewBarcode != string.Empty && (NewBarcode.ToUpper()) != "NOREAD")
                    {
                        break;
                    }
                }
                catch (Exception ex)
                {
                    modbus.DataStore.CoilInputs.WritePoints(9, new bool[] { false });
                    WriteLog($"扫码出现异常:{ex.Message}", LogType.Error, ex);
                    ErrorCode = "扫码出现异常";
                }
            }


            if (NewBarcode != string.Empty && NewBarcode.ToUpper() != "NOREAD")
            {
                // modbus.DataStore.CoilInputs.WritePoints(9, new bool[] { true });
                WriteLog($"扫码成功,SN:{NewBarcode}");
                if (!_appSttings.Value.TraceDisable)
                {
                    var result = await GetTraceAsync(NewBarcode);
                    if (result)
                    {
                        modbus.DataStore.CoilInputs.WritePoints(9, new bool[] { true });
                        WriteLog($"获取trace成功,SN:{NewBarcode}");
                        if (OkDuration <= 1000)
                        {
                            OkDuration = 4000;
                        }
                        await Task.Delay(OkDuration);
                        modbus.DataStore.CoilInputs.WritePoints(9, new bool[] { false });
                    }
                    else
                    {
                        modbus.DataStore.CoilInputs.WritePoints(9, new bool[] { false });
                        WriteLog($"trace卡关无法继续 ");
                        ErrorCode = "trace卡关校验失败";
                    }
                }
                else
                {
                    modbus.DataStore.CoilInputs.WritePoints(9, new bool[] { true });
                    WriteLog($"卡关屏蔽中,直接放行:SN:{NewBarcode}");
                }

            }
            else
            {
                ErrorCode = $"扫码没有读取正确的二维码";
                modbus.DataStore.CoilInputs.WritePoints(9, new bool[] { false });
                WriteLog($"扫码失败:{NewBarcode}", LogType.Error);
            }
        }
        private async Task Test()
        {
            var updateModel = new UpLoadTraceModel()
            {
                serials = new Serials { part_id = UsingBarcode },
                data = new Data
                {
                    insight = new Insight
                    {
                        test_attributes = new Test_Attributes()
                        {
                            test_result = "pass",
                            uut_start = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
                        },
                        test_station_attributes = new Test_Station_Attributes()
                        {
                            line_id = Param.line_id,
                            software_name = "ForceTest",
                            software_version = "1.0.12",
                            station_id = Param.station_id
                        },
                        uut_attributes = new Uut_Attributes()
                        {
                            station_vendor = Param.station_vendor
                        },
                        results = new Result[1]
                        {
                            new() {
                                test=Param.test,
                                units="N"
                            }
                        }
                    }
                }
            };
            var dateName = DateTime.Now.ToString("yyyy_MM_dd_HH_mm_ss");
            var fileName = dateName + "-" + updateModel.serials.part_id + ".csv";
            var filePath = Path.Combine(CSVPath, fileName);
            var exsit = File.Exists(filePath);
            using var streamWriter = new StreamWriter(filePath, false, Encoding.UTF8);
            if (!exsit)
            {
                var header = "SERIAL_NUMBER,MEASURE_DATE,MEASURE_TIME,STATION,OP_NAME,AIM_VENDOR,AIM_NAME,AIM_UNIQUE," +
                    "INSPECTION_PROGRAM_NAME,PROJECT,PART,PROCESS,BUILDS,SHIFT_D_N,CAVITY,RESULT,BIN_MP,COLOR,TEMPERATURE," +
                    "HUMIDITY,PRODUCT_TEMP,COLOR_BANKING,KB_LAYOUT,DATA_BIN," +
                    "DATA1,DATA2,DATA3,DATA4,DATA5,DATA6,DATA7,DATA8,DATA9,DATA10,DATA11,DATA12,DATA13," +
                    "DATA14,DATA15,DATA16,DATA17,DATA18,DATA19,DATA20,DATA21,DATA22,DATA23,DATA24,DATA25,DATA26," +
                    "DATA27,DATA28,DATA29,DATA30,DATA31,DATA32,DATA33,DATA34,DATA35,DATA36,DATA37,DATA38,DATA39," +
                    "DATA40,DATA41,DATA42,DATA43,DATA44,DATA45,DATA46,DATA47,DATA48,DATA49,DATA50,DATA51,DATA52," +
                    "DATA53,DATA54,DATA55,DATA56,DATA57,DATA58,DATA59,DATA60,DATA61,DATA62,DATA63,DATA64,DATA65," +
                    "DATA66,DATA67,DATA68,DATA69,DATA70,DATA71,DATA72,DATA73,DATA74,DATA75," +
                    "DATA76,DATA77,DATA78,DATA79,DATA80,DATA81,DATA82,DATA83,DATA84,DATA85,DATA86,DATA87,DATA88," +
                    "DATA89,DATA90,DATA91,DATA92,DATA93,DATA94,DATA95,DATA96,DATA97,DATA98,DATA99,DATA100";
                await streamWriter.WriteLineAsync(header);
                await streamWriter.FlushAsync();
            }
            var value = $"SPC_G1/{updateModel.data.insight.results[0].value}/H{Param.UpperLimit}/L{Param.DownLimit}";
            var data = $"{updateModel.serials.part_id},{DateTime.Now:yyyy/MM/dd}" + $",{DateTime.Now:HH:mm:ss}" +
               $",logo-test,{Param.OPID},{updateModel.data.insight.uut_attributes.station_vendor}," +
               $"{_appSttings.Value.AimName},{_appSttings.Value.AIM_UNIQUE},{_appSttings.Value.INSPECTION_PROGRAM_NAME}," +
               $"{_appSttings.Value.Project},{_appSttings.Value.Part},{_appSttings.Value.Process},{_appSttings.Value.Builds},,," +
               $"{updateModel.data.insight.test_attributes.test_result},,color,,,,,,,{value}";
            var list = new List<string>();
            for (int i = 0; i < 99; i++)
            {
                data += ",";
            }
            data += "test";
            await streamWriter.WriteLineAsync(data);

            await streamWriter.FlushAsync();
            streamWriter.Close();
            WriteLog("保存csv完成");
        }
        private async Task<bool> GetTraceAsync(string barcode)
        {
            using var client = _httpClientFactory.CreateClient();
            try
            {
                var content = await client.GetStringAsync($"http://localhost:8765/v2/process_control?serial={barcode}&serial_type=part_id");
                var data = JsonConvert.DeserializeObject<Rootobject>(content);
                try
                {
                    if (string.IsNullOrWhiteSpace(barcode))
                    {
                        barcode = Guid.NewGuid().ToString("N");
                    }
                    var fileName = "request_" + barcode + ".json";
                    var path = Path.Combine("logs", fileName);
                    using var stream = new StreamWriter(path);
                    await stream.WriteLineAsync(content);
                    _logger.Information(content);
                }
                catch (Exception)
                {
                }

                if (!data.pass)
                {
                    foreach (var item in data.processes)
                    {
                        if (!item.pass)
                        {
                            WriteLog($"{item.id}：{item.name}卡关fail!", LogType.Error);
                        }

                    }
                }
                return data.pass;
            }
            catch (HttpRequestException e)
            {

                WriteLog($"请求超时失败:{e.Message}", LogType.Error, e);
                return false;
            }

        }

        private async void SaveData(object sender, StateEventArgs e)
        {
            var modbus = _modbusTcpSlaverService.GetModbusSlaveByIp();
            _upLoadTraceModels.TryDequeue(out var _updateModel);
            if (_updateModel == null)
            {
                WriteLog("_updateModel not init");
                modbus.DataStore.CoilInputs.WritePoints(10, new bool[] { false });
                modbus.DataStore.CoilInputs.WritePoints(11, new bool[] { true });
                return;
            }
            var productTestForce = ReadFloat(74);//test
            WriteLog($"读取当前压检值:{productTestForce}");
            modbus.DataStore.CoilInputs.WritePoints(10, new bool[] { false });
            modbus.DataStore.CoilInputs.WritePoints(11, new bool[] { false });
            var plcResult = modbus.DataStore.HoldingRegisters.ReadPoints(32, 1);
            var juge = plcResult[0] == 1 ? "pass" : "fail";
            _updateModel.data.insight.test_attributes.uut_stop = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
            _updateModel.data.insight.test_attributes.test_result = juge;
            _updateModel.data.insight.results[0].value = productTestForce.ToString("F2");
            _updateModel.data.insight.results[0].result = juge;
            var runResult = plcResult[0] == 1 ? RunResultState.OK : RunResultState.NG;
            _eventAggregator.GetEvent<ResultEvent>().Publish(runResult);
            WriteLog("开始保存图片");
            SaveImage(_updateModel.serials.part_id, juge);
            WriteLog("保存图片完成");
            await _repository.AddAsync(new TestResult
            {
                Id = Guid.NewGuid(),
                Barcode = _updateModel.serials.part_id,
                Datetime = DateTime.Now,
                Result = productTestForce
            });
            WriteLog("开始保存csv");
            try
            {
                var dateName = DateTime.Now.ToString("yyyy_MM_dd_HH_mm_ss");
                var fileName = dateName + "-" + _updateModel.serials.part_id + ".csv";
                var filePath = Path.Combine(CSVPath, fileName);
                var exsit = File.Exists(filePath);
                using var streamWriter = new StreamWriter(filePath, false, Encoding.UTF8);
                if (!exsit)
                {
                    var header = "SERIAL_NUMBER,MEASURE_DATE,MEASURE_TIME,STATION,OP_NAME,AIM_VENDOR,AIM_NAME,AIM_UNIQUE," +
                        "INSPECTION_PROGRAM_NAME,PROJECT,PART,PROCESS,BUILDS,SHIFT_D_N,CAVITY,RESULT,BIN_MP,COLOR,TEMPERATURE," +
                        "HUMIDITY,PRODUCT_TEMP,COLOR_BANKING,KB_LAYOUT,DATA_BIN," +
                        "DATA1,DATA2,DATA3,DATA4,DATA5,DATA6,DATA7,DATA8,DATA9,DATA10,DATA11,DATA12,DATA13," +
                        "DATA14,DATA15,DATA16,DATA17,DATA18,DATA19,DATA20,DATA21,DATA22,DATA23,DATA24,DATA25,DATA26," +
                        "DATA27,DATA28,DATA29,DATA30,DATA31,DATA32,DATA33,DATA34,DATA35,DATA36,DATA37,DATA38,DATA39," +
                        "DATA40,DATA41,DATA42,DATA43,DATA44,DATA45,DATA46,DATA47,DATA48,DATA49,DATA50,DATA51,DATA52," +
                        "DATA53,DATA54,DATA55,DATA56,DATA57,DATA58,DATA59,DATA60,DATA61,DATA62,DATA63,DATA64,DATA65," +
                        "DATA66,DATA67,DATA68,DATA69,DATA70,DATA71,DATA72,DATA73,DATA74,DATA75," +
                        "DATA76,DATA77,DATA78,DATA79,DATA80,DATA81,DATA82,DATA83,DATA84,DATA85,DATA86,DATA87,DATA88," +
                        "DATA89,DATA90,DATA91,DATA92,DATA93,DATA94,DATA95,DATA96,DATA97,DATA98,DATA99,DATA100";
                    await streamWriter.WriteLineAsync(header);
                    await streamWriter.FlushAsync();
                }
                var value = $"SPC_G1/{_updateModel.data.insight.results[0].value}/H{Param.UpperLimit}/L{Param.DownLimit}";
                var data = $"{_updateModel.serials.part_id},{DateTime.Now:yyyy/MM/dd}" + $",{DateTime.Now:HH:mm:ss}" +
                   $",logo-test,{Param.OPID},{_updateModel.data.insight.uut_attributes.station_vendor}," +
                   $"{_appSttings.Value.AimName},{_appSttings.Value.AIM_UNIQUE},{_appSttings.Value.INSPECTION_PROGRAM_NAME}," +
                   $"{_appSttings.Value.Project},{_appSttings.Value.Part},{_appSttings.Value.Process},{_appSttings.Value.Builds},,," +
                   $"{_updateModel.data.insight.test_attributes.test_result},,color,,,,,,,{value}";
                var list = new List<string>();
                for (int i = 0; i < 99; i++)
                {
                    data += ",";
                }
                await streamWriter.WriteLineAsync(data);
                await streamWriter.FlushAsync();
                streamWriter.Close();
                WriteLog("保存csv完成");
            }
            catch (Exception ex)
            {
                WriteLog($"保存csv失败:{ex}");
            }
            WriteLog("开始上传数据");

            if (!_appSttings.Value.UnUseUpload)
            {
                var json = JsonConvert.SerializeObject(_updateModel, Formatting.Indented);
                try
                {

                    var barcode = _updateModel.serials.part_id;
                    if (string.IsNullOrWhiteSpace(barcode))
                    {
                        barcode = Guid.NewGuid().ToString("N");
                    }

                    var fileName = "upload_" + barcode + ".json";
                    var path = Path.Combine("logs", fileName);
                    using var stream = new StreamWriter(path);
                    await stream.WriteLineAsync(json);
                }
                catch (Exception)
                {
                }

                _logger.Information("正在上传数据:" + json);
                var stopWatch = new System.Diagnostics.Stopwatch();
                stopWatch.Start();
                var ret = await UploadAsync(json);

                if (stopWatch.ElapsedMilliseconds > 2000)
                {
                    _upLoadSlowTime++;
                    WriteLog($"连续{_upLoadSlowTime}上传trace数据大于2s", LogType.Warning);
                    if (_upLoadSlowTime >= 5)
                    {
                        ErrorCode = "连续5次上传数据缓慢,请检查网络连接";
                    }
                }
                else
                {
                    _upLoadSlowTime = 0;
                }
                if (ret)
                {
                    modbus.DataStore.CoilInputs.WritePoints(10, new bool[] { true });
                    modbus.DataStore.CoilInputs.WritePoints(11, new bool[] { false });
                }
                else
                {
                    modbus.DataStore.CoilInputs.WritePoints(10, new bool[] { false });
                    modbus.DataStore.CoilInputs.WritePoints(11, new bool[] { true });
                }

            }
            else
            {
                modbus.DataStore.CoilInputs.WritePoints(10, new bool[] { true });
                modbus.DataStore.CoilInputs.WritePoints(11, new bool[] { false });
            }

            OeeLogger oeeLogger = new()
            {
                site = OeeConfig.Site,
                floor = OeeConfig.Floor,
                product = OeeConfig.Product,
                line = OeeConfig.Line,
                vendor = "Team",
                process = OeeConfig.Process,
                terminalId = OeeConfig.TerminalId,
                machineId = OeeConfig.MachineId,
                status = "running",
                op_id = Param.OPID,
                startTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
                ipaddr = OeeConfig.Ipaddr,
                macaddr = OeeConfig.Macaddr,
                warningCodeList = new Warningcodelist[1]
            };
            oeeLogger.warningCodeList[0] = new Warningcodelist
            {
                warningCode = "100001",
                remark = "压力检测完成"
            };
            await UploadOeeAsync(oeeLogger);

            WriteLog("上传数据完成");
        }

        //UpLoadTraceModel _updateModel;

        private async Task<bool> UploadAsync(string data)
        {
            using var client = _httpClientFactory.CreateClient();
            var stringContent = new StringContent(data);
            stringContent.Headers.ContentType = new
                System.Net.Http.Headers.MediaTypeHeaderValue("application/json");
            var statisticsLog = new StatisticsLog
            {
                Id = Guid.NewGuid(),
                Timestamp = DateTime.Now,
                RequstType = RequstType.Post
            };
            try
            {
                var responseMessage = await client.PostAsync("http://localhost:8765/v2/logs", stringContent);
                if (responseMessage.StatusCode == System.Net.HttpStatusCode.OK)
                {
                    WriteLog($"上传数据成功");
                    statisticsLog.TraceState = TraceState.PostOK;
                    var s = await responseMessage.Content.ReadAsStringAsync();
                    WriteLog($"response:{s}");
                    statisticsLog.RequestCode = (int)responseMessage.StatusCode;
                    return true;
                }
                else
                {
                    statisticsLog.TraceState = TraceState.PostNG;
                    WriteLog($"上传失败:状态码{responseMessage.StatusCode}," +
                        $"请求uri:{responseMessage.RequestMessage.RequestUri}");
                    statisticsLog.RequestCode = (int)responseMessage.StatusCode;
                    var s = await responseMessage.Content.ReadAsStringAsync();
                    WriteLog($"response:{s}");
                    return false;
                }
            }
            catch (HttpRequestException e)
            {
                statisticsLog.TraceState = TraceState.PostNG;
                statisticsLog.RequestCode = 600;
                WriteLog($"上传失败:{e.Message}");
                return false;
            }
            finally
            {
                await _repository.AddAsync(statisticsLog);
            }

        }
        private async void StartReadForceMethod(object sender, StateEventArgs e)
        {
            WriteLog("开始读取压力传感器数值");
            UsingBarcode = NewBarcode;
            _resettableTimer.Stop();
            var updateModel = new UpLoadTraceModel()
            {
                serials = new Serials { part_id = UsingBarcode },
                data = new Data
                {
                    insight = new Insight
                    {
                        test_attributes = new Test_Attributes()
                        {
                            test_result = "pass",
                            uut_start = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
                        },
                        test_station_attributes = new Test_Station_Attributes()
                        {
                            line_id = Param.line_id,
                            software_name = "ForceTest",
                            software_version = "1.0.12",
                            station_id = Param.station_id
                        },
                        uut_attributes = new Uut_Attributes()
                        {
                            station_vendor = Param.station_vendor
                        },
                        results = new Result[1]
                        {
                            new() {
                                test=Param.test,
                                units="N"
                            }
                        }
                    }
                }
            };
            _upLoadTraceModels.Enqueue(updateModel);
            var modbusSlave = _modbusTcpSlaverService.GetModbusSlaveByIp();
            _start = true;
            //Clear();
            int i = 1;
            var sw = new System.Diagnostics.Stopwatch();
            sw.Start();
            var points = new List<DataPoint>();
            while (true)
            {
                var data = modbusSlave.DataStore.HoldingRegisters.ReadPoints(32 + 68, 2);//读取节拍
                var bytes1 = BitConverter.GetBytes(data[0]);
                var bytes2 = BitConverter.GetBytes(data[1]);
                var bytes = new List<byte>();
                bytes.AddRange(bytes1);
                bytes.AddRange(bytes2);
                var force = BitConverter.ToSingle(bytes.ToArray(), 0);
                var dataPoint = new DataPoint((++i) * 0.005, force);
                points.Add(dataPoint);
                lock (PlotModel.SyncRoot)
                {
                    //Update(dataPoint);
                }

                this.PlotModel.InvalidatePlot(true);

                if (!_start)
                {
                    break;
                }
                await Task.Delay(5);
                if (sw.ElapsedMilliseconds > 10000)
                {
                    break;
                }
            }
            _resettableTimer.Reset();
        }

        private void StopReadForceMethod(object sender, StateEventArgs e)
        {
            WriteLog("停止读取压力传感器数值");
            _start = false;

        }

        private void ModbusTcpSlaverService_CoilDiscretesHandler(object sender, LogoForceTestApp.Services.Interfaces.Events.StorageEventArgs<bool> e)
        {

        }

        //private void SetupModel()
        //{

        //    PlotModel = new PlotModel();
        //    PlotModel.Axes.Add(new LinearAxis { Position = OxyPlot.Axes.AxisPosition.Left, Minimum = 0, Maximum = 80 });


        //    PlotModel.Series.Add(new OxyPlot.Series.LineSeries { LineStyle = LineStyle.Solid });

        //    RaisePropertyChanged(nameof(PlotModel));
        //}

        //private void Clear()
        //{
        //    var s = (OxyPlot.Series.LineSeries)PlotModel.Series[0];
        //    s.Points.Clear();
        //}
        //private void Update(DataPoint dataPoint)
        //{
        //    var s = (OxyPlot.Series.LineSeries)PlotModel.Series[0];
        //    s.Points.Add(dataPoint);
        //}

        #endregion

        #region log
        private void WriteLog(string message, LogType logType = LogType.Info, Exception exception = null)
        {
            if (exception != null)
            {
                _logger.Error("{@Message}", exception.ToString());
            }
            else
            {
                _logger.Information("{@Message}", message);
            }

            string singleLine = message.Trim();
            string item = $"【{DateTime.Now:F}】 {singleLine}";
            _eventAggregator.GetEvent<LogEvent>().Publish(new Tuple<LogType, string>(logType, item));
        }
        #endregion

        #region 生成二维码

        public void QRcode()
        {
            //GenerateQRCode(InQR);
            //GenerateBarCode(InQR, 400, 150).Save("BarCode.png", System.Drawing.Imaging.ImageFormat.Png);
            
        }
        /// <summary>
        /// 生成二维码图片
        /// </summary>
        public void GenerateQRCode(string qrCodeContent)
        {
            if (qrCodeContent != null)
            {
                using (var generator = new QRCodeGenerator())
                {
                    // 创建二维码（并设置纠错能力最高级）
                    var createQrCode = generator.CreateQrCode(qrCodeContent, ECCLevel.H);

                    var skImageInfo = new SKImageInfo(300, 300);

                    // 创建SkiaSharp画布
                    using (var surface = SKSurface.Create(skImageInfo))
                    {
                        var canvas = surface.Canvas;

                        // 渲染二维码到画布
                        canvas.Render(createQrCode, skImageInfo.Width, skImageInfo.Height);

                        using var image = surface.Snapshot();// 获取画布快照
                        using var data = image.Encode(SKEncodedImageFormat.Png, 100);// 编码画布快照为PNG格式的数据
                        using (var stream = File.OpenWrite(@"MyQRCode.png"))
                        {
                            data.SaveTo(stream);// 将数据保存到文件流中，生成二维码图片
                        }
                        QrImage = image.ToWriteableBitmap();
                    }
                    WriteLog("二维码生成成功");
                }
            }
        }
        /// <summary>
        /// 生成一维条形码
        /// </summary>
        /// <param name="text">内容</param>
        /// <param name="width">宽度</param>
        /// <param name="height">高度</param>
        /// <returns></returns>
        public Bitmap GenerateBarCode(string text, int width, int height)
        {
            BarcodeWriter writer = new BarcodeWriter();
            //使用ITF 格式，不能被现在常用的支付宝、微信扫出来
            //如果想生成可识别的可以使用 CODE_128 格式
            writer.Format = BarcodeFormat.CODE_128;
            EncodingOptions options = new EncodingOptions()
            {
                Width = width,
                Height = height,
                //GS1Format = false,
                //PureBarcode = true,
                Margin = 20
            };
            writer.Options = options;

            BitMatrix bm = writer.Encode(text);
            //Bitmap b = writer.Write(bm);
            Bitmap b = writer.Write(text);
            WriteLog("一维码生成成功");
            return b;
        }
        #endregion
    }
}