Aucma.Scada/Aucma.Scada.Business/OutStoreTaskHandle.cs

using Aucma.Scada.Model.domain;
using HighWayIot.Config;
using HighWayIot.Log4net;
using HighWayIot.Plc;
using HighWayIot.Repository.service;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;

namespace Aucma.Scada.Business
{
    /// <summary>
    /// 出库任务处理
    /// </summary>
    internal sealed class OutStoreTaskHandle
    {
        #region 单例实现
        private static readonly Lazy<OutStoreTaskHandle> lazy = new Lazy<OutStoreTaskHandle>(() => new OutStoreTaskHandle());
        public static OutStoreTaskHandle Instance
        {
            get
            {
                return lazy.Value;
            }
        }
        #endregion

        #region 对象引用

        private LogHelper logHelper = LogHelper.Instance;

        private AppConfig appConfig = AppConfig.Instance;

        private PlcConfig plcConfig = PlcConfig.Instance;

        private PlcPool _pool = PlcPool.Instance;

        private PlcSpaceConfig spaceConfig = PlcSpaceConfig.Instance;
        private RegisterServices registerServices = RegisterServices.Instance;
        private ICodeBindingRecordServices _codeBindingRecordServices;
        #endregion

        #region 私有变量
        /// <summary>
        /// 字典存放PLC连接
        /// </summary>
        private Dictionary<string, IPlc> _plcDictionary = new Dictionary<string, IPlc>();

        /// <summary>
        /// 箱壳任务编号,PLC反馈后进行赋值
        /// </summary>
        private string shellTaskCode = string.Empty;

        /// <summary>
        /// 内胆任务编号,PLC反馈后进行赋值
        /// </summary>
        private string linerTaskCode = string.Empty;

        /// <summary>
        /// 已下传的任务信息
        /// </summary>
        private List<RealTaskInfo> shellTaskInfos = new List<RealTaskInfo>();
        private List<RealTaskInfo> linerTaskInfos = new List<RealTaskInfo>();
        #endregion

        #region 委托事件
        /// <summary>
        /// 出库完成
        /// </summary>
        /// <param name="storeCode"></param>
        /// <param name="taskCode"></param>
        public delegate void OutStoreFinsih(string storeCode, string taskCode);
        public event OutStoreFinsih OutStoreFinsihEvent;

        /// <summary>
        /// PLC应答
        /// </summary>
        /// <param name="storeCode"></param>
        /// <param name="taskCode"></param>
        public delegate void OutStoreAnswer(string storeCode, string taskCode);
        public event OutStoreAnswer OutStoreAnswerEvent;
        #endregion


        private OutStoreTaskHandle()
        {
            _codeBindingRecordServices = registerServices.GetService<ICodeBindingRecordServices>();
            _plcDictionary = _pool.GetAll();

            RealReadShellFinish();

            RealReadLinerFinish();

            RealBindMaterialCode();
        }

        #region 箱壳出库任务下发处理
        /// <summary>
        /// 箱壳出库任务下发
        /// </summary>
        /// <param name="taskInfo"></param>
        public bool SendShellTask_OutStore(RealTaskInfo taskInfo)
        {
            bool result = false;
            try
            {
                IPlc _plc = _plcDictionary[appConfig.shellStoreCode];

                if (_plc != null)
                {
                    if (_plc.IsConnected)
                    {
                        //写入货道号
                        _plc.writeStringByAddress(plcConfig.out_shell_spaceCode, taskInfo.spaceCode);
                        //写入出库数量
                        _plc.writeInt32ByAddress(plcConfig.out_shell_amount, taskInfo.planAmount);
                        //写入应答字
                        _plc.writeInt32ByAddress(plcConfig.out_shell_answer, 1);
                        //写入任务号
                        _plc.writeStringByAddress(plcConfig.out_shell_task, taskInfo.taskCode);

                        //写入完成后读取应答字进行复位
                        ReadShellAnswer_OutStore(taskInfo);

                        result = true;
                    }
                    else
                    {
                        logHelper.Info($"仓库{taskInfo.storeCode}；PLC未连接");
                    }
                }
                else
                {
                    logHelper.Info($"PLC信息为空，通过{taskInfo.storeCode}未获取到该仓库对应的PLC信息");
                }
            }
            catch (Exception ex)
            {
                logHelper.Error("箱壳出库任务下发异常", ex);
            }

            return result;
        }

        /// <summary>
        /// 读取箱壳出库应答
        /// </summary>
        private void ReadShellAnswer_OutStore(RealTaskInfo taskInfo)
        {
            bool isFlag = true;
            IPlc _plc = _plcDictionary[appConfig.shellStoreCode];
            try
            {
                Task.Run(() =>
                {
                    if (_plc != null)
                    {
                        if (_plc.IsConnected)
                        {
                            do
                            {
                                //读取PLC应答字为2时，上位机清空写入的出库内容
                                if (_plc.readInt32ByAddress(plcConfig.out_shell_answer) == 2)
                                {
                                    //写入货道号
                                    _plc.writeStringByAddress(plcConfig.out_shell_spaceCode, string.Empty);
                                    //写入出库数量
                                    _plc.writeInt32ByAddress(plcConfig.out_shell_amount, 0);
                                    //写入应答字
                                    _plc.writeInt32ByAddress(plcConfig.out_shell_answer, 0);
                                    //写入任务号
                                    _plc.writeStringByAddress(plcConfig.out_shell_task, string.Empty);
                                    isFlag = false;

                                    //ReadShellFinish_OutStore(taskInfo.taskCode);

                                    OutStoreAnswerEvent?.Invoke(appConfig.shellStoreCode, taskInfo.taskCode);

                                    shellTaskInfos.Add(taskInfo);
                                }

                                Thread.Sleep(1000);
                            } while (isFlag);
                        }
                        else
                        {
                            logHelper.Info($"仓库{appConfig.shellStoreCode}；PLC未连接");
                        }
                    }
                    else
                    {
                        logHelper.Info($"PLC信息为空，通过{appConfig.shellStoreCode}未获取到该仓库对应的PLC信息");
                    }
                });
            }
            catch (Exception ex)
            {
                logHelper.Error("读取箱壳出库应答字异常", ex);
            }
        }

        /// <summary>
        /// 读取箱壳出库完成
        /// </summary>
        private void ReadShellFinish_OutStore(RealTaskInfo taskInfo)
        {
            lock (string.Empty)
            {
                bool isFlag = true;
                IPlc _plc = _plcDictionary[appConfig.shellStoreCode];
                shellTaskCode = taskInfo.taskCode;
                try
                {
                    if (_plc != null)
                    {
                        if (_plc.IsConnected)
                        {
                            do
                            {
                                //读取PLC出库任务完成
                                if (_plc.readInt32ByAddress(plcConfig.out_shell_finish) == 1)
                                {
                                    _plc.writeInt32ByAddress(plcConfig.out_shell_finish, 0);

                                    //string taskCode = _plc.readStringByAddress(plcConfig.out_shell_task, 10);

                                    OutStoreFinsihEvent?.Invoke(appConfig.shellStoreCode, taskInfo.taskCode);

                                    isFlag = false;

                                    //shellTaskInfos.Remove(taskInfo);
                                }

                                Thread.Sleep(1000);
                            } while (isFlag);
                        }
                        else
                        {
                            logHelper.Info($"仓库{appConfig.shellStoreCode}；PLC未连接");
                        }
                    }
                    else
                    {
                        logHelper.Info($"PLC信息为空，通过{appConfig.shellStoreCode}未获取到该仓库对应的PLC信息");
                    }
                }
                catch (Exception ex)
                {
                    logHelper.Error("读取箱壳出库出库完成异常", ex);
                }
            }
        }
        #endregion

        #region 内胆出库任务处理
        /// <summary>
        /// 内胆出库任务下发
        /// </summary>
        /// <param name="taskInfo"></param>
        public bool SendLinerTask_OutStore(RealTaskInfo taskInfo)
        {
            bool result = false;
            try
            {
                IPlc _plc = _plcDictionary[appConfig.linerStoreCode];

                if (_plc != null)
                {
                    if (_plc.IsConnected)
                    {
                        //写入货道号
                        _plc.writeStringByAddress(plcConfig.out_liner_spaceCode, taskInfo.spaceCode);
                        //写入出库数量
                        _plc.writeInt32ByAddress(plcConfig.out_liner_amount, taskInfo.planAmount);
                        //写入应答字
                        _plc.writeInt32ByAddress(plcConfig.out_liner_answer, 1);
                        //写入任务号
                        _plc.writeStringByAddress(plcConfig.out_liner_task, taskInfo.taskCode);

                        //写入完成后读取应答字进行复位
                        ReadLinerAnswer_OutStore(taskInfo);

                        result = true;
                    }
                    else
                    {
                        logHelper.Info($"仓库{taskInfo.storeCode}；PLC未连接");
                    }
                }
                else
                {
                    logHelper.Info($"PLC信息为空，通过{taskInfo.storeCode}未获取到该仓库对应的PLC信息");
                }
            }
            catch (Exception ex)
            {
                logHelper.Error("内胆出库任务下发异常", ex);
            }
            return result;
        }

        /// <summary>
        /// 读取内胆出库应答
        /// </summary>
        private void ReadLinerAnswer_OutStore(RealTaskInfo taskInfo)
        {
            bool isFlag = true;
            IPlc _plc = _plcDictionary[appConfig.linerStoreCode];
            try
            {
                Task.Run(() =>
                {

                    if (_plc != null)
                    {
                        if (_plc.IsConnected)
                        {
                            do
                            {
                                //读取PLC应答字为2时，上位机清空写入的出库内容
                                if (_plc.readInt32ByAddress(plcConfig.out_liner_answer) == 2)
                                {
                                    //写入货道号
                                    _plc.writeStringByAddress(plcConfig.out_liner_spaceCode, string.Empty);
                                    //写入出库数量
                                    _plc.writeInt32ByAddress(plcConfig.out_liner_amount, 0);
                                    //写入应答字
                                    _plc.writeInt32ByAddress(plcConfig.out_liner_answer, 0);
                                    //写入任务号
                                    _plc.writeStringByAddress(plcConfig.out_liner_task, string.Empty);
                                    isFlag = false;

                                    //ReadLinerFinish_OutStore(taskCode);
                                    OutStoreAnswerEvent?.Invoke(appConfig.linerStoreCode, taskInfo.taskCode);

                                    linerTaskInfos.Add(taskInfo);
                                }

                                Thread.Sleep(1000);
                            } while (isFlag);
                        }
                        else
                        {
                            logHelper.Info($"仓库{appConfig.linerStoreCode}；PLC未连接");
                        }
                    }
                    else
                    {
                        logHelper.Info($"PLC信息为空，通过{appConfig.linerStoreCode}未获取到该仓库对应的PLC信息");
                    }
                });
            }
            catch (Exception ex)
            {
                logHelper.Error("读取内胆出库应答字异常", ex);
            }
        }

        /// <summary>
        /// 读取内胆出库完成
        /// </summary>
        private void ReadLinerFinish_OutStore(RealTaskInfo taskInfo)
        {
            lock (string.Empty)
            {
                try
                {
                    bool isFlag = true;
                    IPlc _plc = _plcDictionary[appConfig.linerStoreCode];
                    if (_plc != null)
                    {
                        if (_plc.IsConnected)
                        {
                            do
                            {
                                //读取PLC出库任务完成
                                if (_plc.readInt32ByAddress(plcConfig.out_liner_finish) == 1)
                                {
                                    _plc.writeInt32ByAddress(plcConfig.out_liner_finish, 0);

                                    //string taskCode = _plc.readStringByAddress(plcConfig.out_liner_task, 10);

                                    OutStoreFinsihEvent?.Invoke(appConfig.linerStoreCode, taskInfo.taskCode);

                                    isFlag = false;

                                    //linerTaskInfos.Remove(taskInfo);
                                }

                                Thread.Sleep(1000);
                            } while (isFlag);
                        }
                        else
                        {
                            logHelper.Info($"仓库{appConfig.linerStoreCode}；PLC未连接");
                        }
                    }
                    else
                    {
                        logHelper.Info($"PLC信息为空，通过{appConfig.linerStoreCode}未获取到该仓库对应的PLC信息");
                    }
                }
                catch (Exception ex)
                {
                    logHelper.Error("读取内胆出库完成异常", ex);
                }
            }
        }
        #endregion

        #region 出库完成
        /// <summary>
        /// 实时读取箱壳出库完成
        /// </summary>
        private void RealReadShellFinish()
        {
            Task.Run(() =>
            {
                while (true)
                {
                    var info = shellTaskInfos.Where(x => x.taskStatus != 3).ToList();
                    for (int i = 0; i < info.Count; i++)
                    {
                        var item = info[i];
                        ReadShellFinish_OutStore(item);
                        Console.WriteLine($"箱壳任务：{item.taskCode}；物料：{item.materialCode}；出库完成");
                        item.taskStatus = 3;
                    }

                    Thread.Sleep(1000);
                };
            });
        }

        /// <summary>
        /// 实时读取内胆出库完成
        /// </summary>
        private void RealReadLinerFinish()
        {
            Task.Run(() =>
            {
                while (true)
                {
                    var info = linerTaskInfos.Where(x => x.taskStatus != 3).ToList();
                    for (int i = 0; i < info.Count; i++)
                    {
                        var item = info[i];
                        ReadLinerFinish_OutStore(item);
                        Console.WriteLine($"内胆任务：{item.taskCode}；物料：{item.materialCode}；出库完成");
                        item.taskStatus = 3;
                    }

                    Thread.Sleep(1000);
                };
            });
        }

        /// <summary>
        /// 实时绑定箱壳内胆
        /// </summary>
        private void RealBindMaterialCode()
        {
            Task.Run(() =>
            {
                while (true)
                {
                    var shellTasks = shellTaskInfos.Where(x => x.taskStatus == 3).ToList();

                    var linerTasks = linerTaskInfos.Where(x => x.taskStatus == 3).ToList();

                    RealTaskInfo shellTask = null;
                    RealTaskInfo linerTask = null;

                    if (shellTasks.Count > 0)
                    {
                        shellTask = shellTasks.First();
                    }

                    if (linerTasks.Count > 0)
                    {
                        linerTask = linerTasks.First();
                    }

                    if (shellTask != null && linerTask != null)
                    {
                        logHelper.Info($"绑定条码:箱壳：{shellTask.materialCode}；内胆：{linerTask.materialCode}");
                        // 条码绑定表，绑定箱壳和内胆码 shellTask.materialCode,linerTask.materialCode           
                       _codeBindingRecordServices.BindingCode(shellTask.materialCode, linerTask.materialCode);

                        shellTaskInfos.Remove(shellTask);
                        linerTaskInfos.Remove(linerTask);
                    }

                    Thread.Sleep(1000);
                }
            });

        }
        #endregion


        /// <summary>
        /// 通过PLC获取货道信息
        /// </summary>
        /// <param name="spaceInfo"></param>
        /// <returns></returns>
        public BaseSpaceInfo ReadSpaceInfoByPlc(BaseSpaceInfo spaceInfo)
        {
            var spaceAddress = spaceConfig.GetSpaceAddress(spaceInfo.storeCode, spaceInfo.spaceCode);
            IPlc _plc = _plcDictionary[spaceInfo.storeCode];

            if (_plc != null)
            {
                if (_plc.IsConnected)
                {
                    spaceInfo.spaceStock = _plc.readInt32ByAddress(spaceAddress.onStore);
                    spaceInfo.onRouteAmount = _plc.readInt32ByAddress(spaceAddress.onRoute);
                    spaceInfo.spaceStatus = _plc.readInt32ByAddress(spaceAddress.spaceStatus);
                }
            }

            return spaceInfo;
        }

        /// <summary>
        /// 测试方法，联调时不用
        /// </summary>
        /// <param name="storeCode"></param>
        /// <param name="spaceCode"></param>
        /// <param name="flag"></param>
        public void WritePlc(string storeCode, string spaceCode)
        {
            var spaceAddress = spaceConfig.GetSpaceAddress(storeCode, spaceCode);
            IPlc _plc = _plcDictionary[storeCode];

            if (_plc != null)
            {
                if (_plc.IsConnected)
                {
                    var spaceStock = _plc.readInt32ByAddress(spaceAddress.onStore);
                    //var onRouteAmount = _plc.readInt32ByAddress(spaceAddress.onRoute);

                    _plc.writeInt32ByAddress(spaceAddress.onStore, spaceStock - 1);

                }
            }
        }
    }
}