Aucma.Scada/Aucma.Scada.Business/AssemblyPlanBusiness.cs

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

namespace Aucma.Scada.Business
{
    /// <summary>
    /// 组装计划业务逻辑
    /// </summary>
    public sealed class AssemblyPlanBusiness
    {
        #region 单例实现
        private static readonly Lazy<AssemblyPlanBusiness> lazy = new Lazy<AssemblyPlanBusiness>(() => new AssemblyPlanBusiness());
        public static AssemblyPlanBusiness Instance
        {
            get
            {
                return lazy.Value;
            }
        }
        #endregion

        #region 对象引用

        private LogHelper logHelper = LogHelper.Instance;

        private AppConfig appConfig = AppConfig.Instance;

        private RegisterServices registerServices = RegisterServices.Instance;
        #endregion

        #region 接口引用
        /// <summary>
        /// 生产计划
        /// </summary>
        private IProductPlanInfoService _productPlanInfoService;

        /// <summary>
        /// 执行计划
        /// </summary>
        private IExecutePlanInfoService _executePlanInfoService;

        /// <summary>
        /// BOM信息
        /// </summary>
        private IBaseBomInfoService _bomInfoService;

        /// <summary>
        /// 货道明细
        /// </summary>
        private IBaseSpaceDetailService _spaceDetailService;

        /// <summary>
        /// 货道信息
        /// </summary>
        private IBaseSpaceInfoService _spaceInfoService;

        private IRealTaskInfoService _realTaskInfoService;
        #endregion

        #region 委托事件
        /// <summary>
        /// 刷新执行计划
        /// </summary>
        /// <param name="taskInfos"></param>
        public delegate void RefreshExecutePlanInfo(List<ExecutePlanInfo> executePlanInfos);
        public event RefreshExecutePlanInfo RefreshExecutePlanInfoEvent;

        /// <summary>
        /// 下传执行计划
        /// </summary>
        /// <param name="planInfo"></param>
        public delegate Task NextPassExecutePlanInfo(ExecutePlanInfo planInfo);
        public event NextPassExecutePlanInfo NextPassExecutePlanInfoEvent;
        #endregion

        private AssemblyPlanBusiness()
        {
            _productPlanInfoService = registerServices.GetService<IProductPlanInfoService>();
            _executePlanInfoService = registerServices.GetService<IExecutePlanInfoService>();
            _bomInfoService = registerServices.GetService<IBaseBomInfoService>();
            _spaceDetailService = registerServices.GetService<IBaseSpaceDetailService>();
            _spaceInfoService = registerServices.GetService<IBaseSpaceInfoService>();
            _realTaskInfoService = registerServices.GetService<IRealTaskInfoService>();

        }


        /// <summary>
        /// 根据产线工位编号获取生产计划
        /// </summary>
        /// <param name="productLineCode"></param>
        /// <returns></returns>
        public List<ProductPlanInfo> GetProductPlanInfosByProductLineCode(string orderCode)
        {
            List<ProductPlanInfo> productPlanInfos = null;
            try
            {
                productPlanInfos = _productPlanInfoService.GetProductPlanInfosByProductLineCode(appConfig.stationCode);

                if (productPlanInfos.Count > 0)
                {
                    if (!string.IsNullOrEmpty(orderCode))
                    {
                        productPlanInfos = productPlanInfos.Where(x => x.orderCode.Contains(orderCode)).ToList();
                    }
                }
            }
            catch (Exception ex)
            {
                logHelper.Error("根据产线工位编号获取生产计划异常", ex);
            }
            return productPlanInfos;
        }

        /// <summary>
        /// 根据产线工位编号获取执行计划
        /// </summary>
        /// <returns></returns>
        public List<ExecutePlanInfo> GetEexecutePlanInfosByProductLineCode()
        {
            List<ExecutePlanInfo> planInfos = null;
            try
            {
                planInfos = _executePlanInfoService.GetExecutePlanInfosByProductLineCode(appConfig.stationCode).OrderBy(x => x.executeOrder).ToList();
                if (planInfos != null)
                {
                    //for(int i = 0; i < planInfos.Count; i++)
                    //{
                    //    planInfos[i].executeOrder = i + 1;
                    //}
                    //_executePlanInfoService.UpdateRangeExecutePlanInfo(planInfos);
                    planInfos = planInfos.Where(x => x.executeStatus != 3).ToList();
                    RefreshExecutePlanInfoEvent?.Invoke(planInfos);
                }
            }
            catch (Exception ex)
            {
                logHelper.Error("根据产线工位编号获取执行计划异常", ex);
            }
            return planInfos;
        }

        /// <summary>
        /// 判断库存
        /// </summary>
        /// <param name="planInfo">生产计划</param>
        /// <param name="transmitAmount">下达数量</param>
        /// <param name="materialType">BOM类型</param>
        /// <param name="storeCode"></param>
        /// <returns></returns>
        public bool JudgmentStock(ProductPlanInfo planInfo, int transmitAmount, string materialType, string storeCode)
        {
            bool result = false;
            try
            {
                BaseBomInfo baseBomInfo = null;
                if (appConfig.shellStoreCode == storeCode)
                {
                    baseBomInfo = _bomInfoService.GetBomInfoByMaterialCode(planInfo.materialCode);
                }
                else
                {
                    baseBomInfo = _bomInfoService.GetChildenBomInfoByMaterialCode(planInfo.materialCode, materialType);

                }

                if (baseBomInfo != null)
                {
                    materialType = baseBomInfo.materialCode;

                   // var planInfos = _executePlanInfoService.GetExecutePlanInfosByProductLineCode(appConfig.stationCode);
                    var spaceInfo = _spaceInfoService.GetBaseSpaceInfosByMaterialType(storeCode, materialType);
                    if (spaceInfo != null)
                    {
                        int sumStock = spaceInfo.Sum(x => x.spaceStock);

                     //   if (planInfos != null)
                     //   {
                          //  int sumPlanAmount = planInfos.Sum(x => x.planAmount - x.completeAmount);

                            if (sumStock >= transmitAmount)
                            {
                                result = true;
                            }
                    //    }
                    }

                }
            }
            catch (Exception ex)
            {
                logHelper.Error("计划下达判断库存异常", ex);
            }
            return result;
        }

        /// <summary>
        /// 根据生产计划下达执行计划
        /// </summary>
        /// <param name="productPlanCode"></param>
        /// <param name="transmitAmount"></param>
        public bool PlanTransmitByProductPlan(string productPlanCode, int transmitAmount)
        {
            bool result = false;
            try
            {
                var productPlanInfo = _productPlanInfoService.GetProductPlanByPlanCode(productPlanCode);
                if (productPlanInfo != null)
                {
                    ExecutePlanInfo executePlanInfo = new ExecutePlanInfo();
                    executePlanInfo.executePlanCode = System.Guid.NewGuid().ToString("N");
                    executePlanInfo.productPlanCode = productPlanInfo.planCode;
                    executePlanInfo.productLineCode = productPlanInfo.productLineCode;
                    executePlanInfo.orderCode = productPlanInfo.orderCode;
                    executePlanInfo.materialCode = productPlanInfo.materialCode;
                    executePlanInfo.materialName = productPlanInfo.materialName;
                    executePlanInfo.executeOrder = _executePlanInfoService.GetExecuteOrderByProductLineCode(appConfig.stationCode);
                    executePlanInfo.executeStatus = 1;
                    executePlanInfo.planAmount = transmitAmount;
                    executePlanInfo.createdTime = DateTime.Now;
                    result = _executePlanInfoService.InsertExecutePlanInfo(executePlanInfo);

                    if (result)
                    {
                        GetEexecutePlanInfosByProductLineCode();
                    }
                }
            }
            catch (Exception ex)
            {
                logHelper.Error("根据生产计划下达执行计划异常", ex);
            }
            return result;
        }

        /// <summary>
        /// 执行计划上移
        /// </summary>
        /// <param name="executePlanCode"></param>
        public void ExecutePlanInfo_MoveUp(List<ExecutePlanInfo> executePlanInfos, string executePlanCode)
        {
            List<ExecutePlanInfo> executePlans = new List<ExecutePlanInfo>();
            if (executePlanInfos != null)
            {
                ExecutePlanInfo planInfo = executePlanInfos.Where(x => x.executePlanCode == executePlanCode).First();
                int executeOrder = planInfo.executeOrder;
                int planIndex = executePlanInfos.IndexOf(planInfo);
                if (planIndex != -1 && planIndex != 0)
                {
                    var lastPlanInfo = executePlanInfos[planIndex - 1];
                    planInfo.executeOrder = lastPlanInfo.executeOrder;
                    lastPlanInfo.executeOrder = executeOrder;
                    executePlans.Add(planInfo);
                    executePlans.Add(lastPlanInfo);
                    var result = _executePlanInfoService.UpdateRangeExecutePlanInfo(executePlans);
                    if (result)
                    {
                        GetEexecutePlanInfosByProductLineCode();
                    }
                }
            }
        }

        /// <summary>
        /// 执行计划下移
        /// </summary>
        /// <param name="executePlanCode"></param>
        public void ExecutePlanInfo_MoveDown(List<ExecutePlanInfo> executePlanInfos, string executePlanCode)
        {
            List<ExecutePlanInfo> executePlans = new List<ExecutePlanInfo>();
            if (executePlanInfos != null)
            {
                ExecutePlanInfo planInfo = executePlanInfos.Where(x => x.executePlanCode == executePlanCode).First();
                int executeOrder = planInfo.executeOrder;
                int planIndex = executePlanInfos.IndexOf(planInfo);
                if (planIndex != executePlanInfos.Count - 1)
                {
                    var lastPlanInfo = executePlanInfos[planIndex + 1];
                    planInfo.executeOrder = lastPlanInfo.executeOrder;
                    lastPlanInfo.executeOrder = executeOrder;
                    executePlans.Add(planInfo);
                    executePlans.Add(lastPlanInfo);
                    var result = _executePlanInfoService.UpdateRangeExecutePlanInfo(executePlans);
                    if (result)
                    {
                        GetEexecutePlanInfosByProductLineCode();
                    }
                }
            }
        }

        /// <summary>
        /// 根据执行计划编号删除执行计划
        /// </summary>
        /// <param name="planCode"></param>
        /// <returns></returns>
        public bool ExecutePlanInfo_Delete(string planCode)
        {
            bool result = _executePlanInfoService.DeleteExecutePlanInfoByPlanCode(planCode);
            if (result)
            {
                GetEexecutePlanInfosByProductLineCode();
            }
            return result;
        }

        /// <summary>
        /// 下传计划
        /// </summary>
        /// <param name="planCode"></param>
        public ExecutePlanInfo ExecutePlanInfo_NextPass(string planCode, string nowPlanCode)
        {
            ExecutePlanInfo planInfo = null;
            try
            {
                List<ExecutePlanInfo> planInfos = new List<ExecutePlanInfo>();
                if (!string.IsNullOrEmpty(nowPlanCode))
                {
                    ExecutePlanInfo nowPlanInfo = _executePlanInfoService.GetExecutePlanInfoByPlanCode(nowPlanCode);
                    if (nowPlanInfo != null)
                    {
                        nowPlanInfo.executeStatus = 1;
                        planInfos.Add(nowPlanInfo);
                    }
                }

                //获取执行计划
                planInfo = _executePlanInfoService.GetExecutePlanInfoByPlanCode(planCode);
                if (planInfo != null)
                {
                    //传给出库
                    NextPassExecutePlanInfoEvent?.Invoke(planInfo);

                    planInfo.executeStatus = 2;
                    planInfo.beginTime = DateTime.Now;
                    planInfos.Add(planInfo);
                }
                else
                {
                    logHelper.Info($"执行计划下传失败,执行计划编号：{planCode}未获取到执行计划");
                    return planInfo;
                }

                if (planInfos.Count > 0)
                {
                    var result = _executePlanInfoService.UpdateRangeExecutePlanInfo(planInfos);
                    if (result)
                    {
                        GetEexecutePlanInfosByProductLineCode();
                    }
                }

            }
            catch (Exception ex)
            {
                logHelper.Error("计划下传异常", ex);
            }
            return planInfo;
        }

        /// <summary>
        /// 获取小时产量
        /// </summary>
        /// <returns></returns>
        public List<dynamic> GetHourAmount()
        {
            return _executePlanInfoService.GetStationHourAmount(appConfig.stationCode);
        }

        /// <summary>
        /// 获取物料型号统计
        /// </summary>
        /// <returns></returns>
        public List<dynamic> GetMaterialStats()
        {
            return _executePlanInfoService.GetStationMaterialStats(appConfig.stationCode);
        }

        public bool autoFlag = false;

        /// <summary>
        /// 自动下发执行计划
        /// </summary>
        public void AutomaticDownpass()
        { 
            //获取当前创建的执行计划
            while (autoFlag)
            {
                try
                {                  
                    var planInfos = _executePlanInfoService.GetExecutePlanInfosByProductLineCode(appConfig.stationCode);
                    if (planInfos != null)
                    {
                        planInfos = planInfos.Where(x => x.executeStatus == 1).ToList();
                        if(planInfos.Count > 0)
                        {
                            planInfos = planInfos.OrderBy(x => x.createdTime).ToList();
                        }
                        foreach (var planInfo in planInfos)
                        {
                            ExecutePlanInfo_NextPass(planInfo.executePlanCode, "");
                            Task.Delay(2000).Wait();
                            bool isFlase = true;
                            do
                            {

                                if (!autoFlag)
                                {
                                    isFlase = autoFlag;
                                    break;
                                }

                                var taksInfos = _realTaskInfoService.GetTaskInfosByStoreCode(new string[] { appConfig.shellStoreCode, appConfig.linerStoreCode }, 2);
                                                               
                                    if (taksInfos==null|| taksInfos.Count == 0)
                                    {
                                        var prodPlanInfo = _productPlanInfoService.GetProductPlanByPlanCode(planInfo.productPlanCode);
                                        if (prodPlanInfo != null)
                                        {
                                            if (prodPlanInfo.planAmount > prodPlanInfo.completeAmount)
                                            {
                                                if ((prodPlanInfo.planAmount - prodPlanInfo.completeAmount) >= planInfo.planAmount)
                                                {
                                                    //创建新计划
                                                    PlanTransmitByProductPlan(planInfo.productPlanCode, planInfo.planAmount);
                                                    // 删除老计划
                                                    _executePlanInfoService.DeleteExecutePlanInfoByPlanCode(planInfo.executePlanCode);
                                                }
                                                else
                                                {
                                                    //创建新计划
                                                    PlanTransmitByProductPlan(planInfo.productPlanCode, prodPlanInfo.planAmount - prodPlanInfo.completeAmount);
                                                    // 删除老计划
                                                    _executePlanInfoService.DeleteExecutePlanInfoByPlanCode(planInfo.executePlanCode);
                                                }
                                               
                                            }
                                            else
                                            {
                                                var prodPlanInfos = _productPlanInfoService.GetProductPlanInfosByProductLineCode(appConfig.stationCode);
                                                if (prodPlanInfos != null)
                                                {
                                                    prodPlanInfos = prodPlanInfos.Where(x => x.materialCode == planInfo.materialCode && x.planAmount > x.completeAmount).ToList();

                                                    prodPlanInfo = prodPlanInfos.First();
                                                    if ((prodPlanInfo.planAmount - prodPlanInfo.completeAmount) >= planInfo.planAmount)
                                                    {
                                                        //创建新计划
                                                        PlanTransmitByProductPlan(planInfo.productPlanCode, planInfo.planAmount);
                                                        // 删除老计划
                                                        _executePlanInfoService.DeleteExecutePlanInfoByPlanCode(planInfo.executePlanCode);
                                                    }
                                                    else
                                                    {
                                                        //创建新计划
                                                        PlanTransmitByProductPlan(planInfo.productPlanCode, prodPlanInfo.planAmount - prodPlanInfo.completeAmount);
                                                        // 删除老计划
                                                        _executePlanInfoService.DeleteExecutePlanInfoByPlanCode(planInfo.executePlanCode);
                                                    }
                                                }
                                            }
                                        }

                                        isFlase = false;
                                    }

                                Task.Delay(2000).Wait();
                            } while (isFlase);
                        }
                    }
                    Task.Delay(5000).Wait();
                }
                catch (Exception ex)
                {
                    Console.WriteLine($"组装计划自动执行异常:{ex.Message}");
                }
            }
        }
    }
}