AUCMA_SCADA/Aucma.Core.CodeBinding/ViewModels/IndexPageViewModel.cs

using CommunityToolkit.Mvvm.ComponentModel;
using System;
using System.Collections.ObjectModel;
using log4net;
using Aucma.Core.CodeBinding.Common;
using LiveCharts;
using Admin.Core.Model;
using Admin.Core.Service;
using LiveCharts.Wpf;
using Admin.Core.IService;
using Microsoft.Extensions.DependencyInjection;
using System.Threading.Tasks;
using System.Windows.Controls;
using System.Collections;
using Aucma.Core.CodeBinding.Models;
using System.Reflection.Emit;
using NPOI.SS.Formula.Functions;
using System.Threading;
using System.Windows.Threading;
using static Admin.Core.Service.CodeBindingRecordServices;
using System.Windows.Data;
using System.Windows;
using System.Linq;
using Aucma.Core.Scanner;
using System.Collections.Generic;
using NPOI.HSSF.Record;
using Aucma.Core.PLc;
/*
* 首页信息
*/
namespace Aucma.Core.CodeBinding.ViewModels
{
    public partial class IndexPageViewModel : ObservableObject
    {
        private static readonly log4net.ILog log = LogManager.GetLogger(typeof(IndexPageViewModel));
        private readonly ICodeBindingRecordServices? _codeBindingRecordServices;

        public IndexPageViewModel()
        {
            _codeBindingRecordServices = App.ServiceProvider.GetService<ICodeBindingRecordServices>();
            MvCodeHelper.ReceiveCode1Event += receiveCode1;
            MvCodeHelper.ReceiveCode2Event += receiveCode2;



            //  var list = _codeBindingRecordServices.FirstAsync().Result;
            LoadData();
            // 程序运行 5 秒后添加新数据项
            add();

        }

        #region 加载DataGrid数据
        private async void LoadData()
        {
            List<CodeBindingRecord> records = null;
            records = await _codeBindingRecordServices.QueryAsync(x => x.BoxCode != null, "RECORD_TIME1 desc");
            if (records != null)
            {
                foreach (CodeBindingRecord record in records)
                {
                    Application.Current.Dispatcher.Invoke(() =>
                    {
                        ListItems.Add(new ReaderInfo() { No = record.ObjId, BoxCode = record.BoxCode, ProductCode = record.ProductCode, BindingResult = record.BindingResult, RecordTime = record.RecordTime1.ToString() });
                    });

                }
            }

        }
        // 测试方法
        private async void add()
        {
         //   await Task.Delay(3000);
           
           
            //  SendPlcPass();
            //ListItems.Add(new ReaderInfo() { No = 4, BoxCode = "44444444", ProductCode = "8659452123", BindingResult = "成功", RecordTime = System.DateTime.Now.ToString() });
            //ListItems.Add(new ReaderInfo() { No = 5, BoxCode = "42423444", ProductCode = "8659452123", BindingResult = "成功", RecordTime = System.DateTime.Now.ToString() });
            //ListItems.Add(new ReaderInfo() { No = 6, BoxCode = "42423444", ProductCode = "8659452123", BindingResult = "成功", RecordTime = System.DateTime.Now.ToString() });
            //ListItems.Add(new ReaderInfo() { No = 7, BoxCode = "42423444", ProductCode = "8659452123", BindingResult = "成功", RecordTime = System.DateTime.Now.ToString() });
            //ListItems.Add(new ReaderInfo() { No = 8, BoxCode = "42423444", ProductCode = "8659452123", BindingResult = "成功", RecordTime = System.DateTime.Now.ToString() }); ListItems.Add(new ReaderInfo() { No = 1, BoxCode = "42423444", ProductCode = "8659452123", BindingResult = "成功", RecordTime = System.DateTime.Now.ToString() });
            //ListItems.Add(new ReaderInfo() { No = 9, BoxCode = "42423444", ProductCode = "8659452123", BindingResult = "成功", RecordTime = System.DateTime.Now.ToString() });
            //ListItems.Add(new ReaderInfo() { No = 10, BoxCode = "42423444", ProductCode = "8659452123", BindingResult = "成功", RecordTime = System.DateTime.Now.ToString() });
           // string str = Guid.NewGuid().ToString().Substring(0, 10);
           // receiveCode1(str);
           // await Task.Delay(7000);
           //receiveCode1(Guid.NewGuid().ToString().Substring(0, 10));

        }

        #endregion

        #region 参数定义
        /// <summary>
        /// 条码1
        /// </summary>
        private string code1 = string.Empty;
        public string Code1
        {
            get { return code1; }
            set
            {
                code1 = value;
                OnPropertyChanged(nameof(Code1));
            }
        }

        /// <summary>
        /// 条码1扫描时间
        /// </summary>
        private string code1Time = string.Empty;
        public string Code1Time
        {
            get { return code1Time; }

            set
            {
                code1Time = value;
                OnPropertyChanged(nameof(Code1Time));
            }
        }
        /// <summary>
        /// 条码2
        /// </summary>
        private string code2 = string.Empty;
        public string Code2
        {
            get { return code2; }
            set
            {
                code2 = value;
                OnPropertyChanged(nameof(Code2));
            }
        }
        /// <summary>
        /// 条码2扫描时间
        /// </summary>
        private string code2Time = string.Empty;
        public string Code2Time
        {
            get { return code2Time; }
            set
            {
                code2Time = value;
                OnPropertyChanged(nameof(Code2Time));
            }
        }
        /// <summary>
        /// 绑定提示信息
        /// </summary>
        private string bindingInfo = string.Empty;
        public string BindingInfo
        {
            get { return bindingInfo; }
            set
            {
                bindingInfo = value;
                OnPropertyChanged(nameof(BindingInfo));
            }
        }
        #endregion

        #region 初始化datagrid
        private ObservableCollection<ReaderInfo> listItems = new ObservableCollection<ReaderInfo>() { };
        public ObservableCollection<ReaderInfo> ListItems
        {
            get { return listItems; }
            set
            {
                listItems = value;
                OnPropertyChanged();//属性通知
            }
        }
        #endregion

        /// <summary>
        ///  code1扫码信息刷新
        /// </summary>
        /// <param name="materialType"></param>
        private void RefreshCode1(string code1, string time)
        {
            Code1 = code1;
            Code1Time = time;
        }

        /// <summary>
        ///  code2扫码信息及表格记录刷新
        /// </summary>
        /// <param name="materialType"></param>
        private void RefreshCode2(CodeBindingRecord record)
        {
            Code2 = record.ProductCode;
            Code2Time = record.RecordTime2.ToString();
            if ("成功".Equals(record.BindingResult))
            {
                BindingInfo = "条码【" + record.BoxCode + "】与SN码【" + record.ProductCode + "】绑定成功";
            }
            else
            {
                BindingInfo = "条码【" + record.BoxCode + "】与SN码【" + record.ProductCode + "】绑定失败";
            }

            Application.Current.Dispatcher.Invoke(() =>
            {
                ReaderInfo readerToUpdate = (ReaderInfo)ListItems.Select(item => item.No == 2);
                ListItems.Add(new ReaderInfo() { No = record.ObjId, BoxCode = record.BoxCode, ProductCode = record.ProductCode, BindingResult = record.BindingResult, RecordTime = record.RecordTime2.ToString() });
            });

        }

        /// <summary>
        /// 条码绑定,条码1处理
        /// </summary>
        /// <param name="materialType"></param>
        private async void receiveCode1(string code1)
        {
            log.Info("进入条码1处理函数receiveCode1,code1:" + code1);
            DateTime time = System.DateTime.Now;
            string strTime = time.ToString();
            // 1.刷新界面条码信息
            RefreshCode1(code1, strTime);
            // 2.创建任务更新数据库条码1
            CodeBindingRecord codeRecord = new CodeBindingRecord();
            codeRecord.BoxCode = code1;
            codeRecord.BoxName = "去别的数据库查询";
            codeRecord.RecordTime1 = time;
            int a = await _codeBindingRecordServices.AddAsync(codeRecord);
            //// 页面刷新ListItems
            //await Application.Current.Dispatcher.InvokeAsync(() =>
            //{
            //    // 在 UI 线程上操作列表
            //    ListItems.Insert(0, new ReaderInfo() { No = codeRecord.ObjId, BoxCode = codeRecord.BoxCode,  RecordTime = codeRecord.RecordTime1.ToString() });
            //});

            log.Info("条码1记录更新");
        }

        /// <summary>
        /// 条码绑定,条码2处理
        /// </summary>
        /// <param name="materialType"></param>
        private async void receiveCode2(string code2)
        {
            log.Info("进入条码2处理函数receiveCode1,code2:" + code2);
            // 1.数据库匹配条码1并绑定

            // 查询条码2为null的最新记录
            List<CodeBindingRecord> list = await _codeBindingRecordServices.QueryByTime();
            CodeBindingRecord record = list.FirstOrDefault();
            record.ProductCode = code2;
            record.RecordTime2 = System.DateTime.Now;
            record.BindingResult = "成功";
            await _codeBindingRecordServices.UpdateAsync(record);
            // 2.刷新界面信息
            RefreshCode2(record);

            // 产品入库
            // 3.下发plc放行信号
            SendPlcPass();

        }

        #region plc交互
        /// <summary>
        /// 下发plc放行信号
        /// </summary>
        /// <param name="materialType"></param>
        private bool SendPlcPass()
        {
            bool result = false;
            try
            {
                var obj = PlcHelper.melsecList.FirstOrDefault(d => d.EquipName.Equals("条码绑定Plc"));
                if (obj != null)
                {
                    if (obj.plc.IsConnected)
                    {
                        // 往plc写入放行信号
                        obj.plc.WriteInt32("D100", 1);
                        // 等待plc反馈信号
                        waitPlcSignal();
                        result = true;
                    }
                    else
                    {
                        log.Info("条码绑定plc连接失败，请检查plc连接");
                    }
                }
                else
                {
                    log.Info("获取plc连接对象信息为空");
                }
            }
            catch (Exception ex)
            {
                log.Error("下发plc放行信号方法SendPlcPass()出现异常,ex:" + ex);
            }
            return result;
        }
        /// <summary>
        /// 读取plc放行反馈
        /// </summary>
        /// <param name="materialType"></param>
        private void waitPlcSignal()
        {
            try
            {
                lock (string.Empty)
                {
                    bool isFlag = true;
                    var obj = PlcHelper.melsecList.FirstOrDefault(d => d.EquipName.Equals("条码绑定Plc"));
                    Task.Run(() =>
                    {
                        if (obj != null)
                        {
                            if (obj.plc.IsConnected)
                            {
                                do
                                {
                                    // 往plc写入放行信号
                                    if (obj.plc.ReadInt32("D100") == 2)
                                    {
                                        Console.WriteLine("收到plc放行成功");
                                        obj.plc.WriteInt32("D100", 0);
                                        isFlag = false;
                                    }

                                    Thread.Sleep(1000);
                                } while (isFlag);
                            }
                            else
                            {
                                log.Info("条码绑定plc连接失败，请检查plc连接");
                            }
                        }
                        else
                        {
                            log.Info("获取plc连接对象信息为空");
                        }
                    });

                }
            }
            catch (Exception ex)
            {
                log.Error("读取plc放行反馈方法waitPlcSignal()出现异常,ex:" + ex);
            }
        }

        #endregion

    }
}