DEMOMySql/MicroServices/Business/Business.Application/SaleForecastManagement/MonthlyCapacityLoadAppService.cs

using Abp.Application.Services;
using Business.Core.Utilities;
using Business.Dto;
using Business.EntityFrameworkCore;
using Business.EntityFrameworkCore.SqlRepositories;
using Business.Model.MES.IC;
using Business.Model.Production;
using Business.Model.SRM;
using Business.MongoModel.MES.IC;
using Business.MongoModel.Production;
using Business.MongoModel.SRM;
using Business.ResourceExamineManagement;
using Business.SaleForecast;
using Microsoft.CodeAnalysis.CSharp.Syntax;
using Microsoft.EntityFrameworkCore.Migrations;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Volo.Abp.DependencyInjection;
using Volo.Abp.Domain.Repositories;
using Volo.Abp.MultiTenancy;
using Volo.Abp.Uow;

namespace Business.SaleForecastManagement
{
    /// <summary>
    /// 产能分析
    /// </summary>
    public class MonthlyCapacityLoadAppService : ApplicationService, IMonthlyCapacityLoadAppService, ITransientDependency
    {
        #region 服务
        /// <summary>
        /// 物料
        /// </summary>
        private IRepository<ic_item, long> _ic_item;

        /// <summary>
        /// 整体需求计划明细
        /// </summary>
        private ISqlRepository<OverallDemandPlanDtl> _overallDemandPlanDtl;

        /// <summary>
        /// 生产线明细
        /// </summary>
        private ISqlRepository<ProdLineDetail> _prodLineDetail;

        /// <summary>
        /// 工作日历数据
        /// </summary>
        private ISqlRepository<ShopCalendarWorkCtr> _shopCalendarWorkCtr;

        /// <summary>
        /// 产线休息时间记录表
        /// </summary>
        private ISqlRepository<QualityLineWorkDetail> _qualityLineWorkDetail;

        /// <summary>
        /// 节假日记录表
        /// </summary>
        private ISqlRepository<HolidayMaster> _holidayMaster;

        /// <summary>
        /// 月度产能共识主表
        /// </summary>
        private ISqlRepository<MonthlyProdCapacityMain> _monthlyProdCapacityMain;

        /// <summary>
        /// 月度产能共识明细表
        /// </summary>
        private ISqlRepository<MonthlyProdCapacityDtl> _monthlyProdCapacityDtl;

        /// <summary>
        /// 标准物料规格型号设置表
        /// </summary>
        private ISqlRepository<StandardItemModelSet> _standardItemModelSet;

        /// <summary>
        /// 工作单元
        /// </summary>
        private readonly IUnitOfWorkManager _unitOfWorkManager;

        /// <summary>
        /// 日志
        /// </summary>
        private readonly ICurrentTenant _currentTenant;

        /// <summary>
        /// 雪花算法
        /// </summary>
        SnowFlake help = new SnowFlake();
        #endregion

        #region 构造函数
        /// <summary>
        /// 构造函数
        /// </summary>
        public MonthlyCapacityLoadAppService(
            IRepository<ic_item, long> ic_item,
            ISqlRepository<OverallDemandPlanDtl> overallDemandPlanDtl,
            ISqlRepository<ProdLineDetail> prodLineDetail,
            ISqlRepository<ShopCalendarWorkCtr> shopCalendarWorkCtr,
            ISqlRepository<QualityLineWorkDetail> qualityLineWorkDetail,
            ISqlRepository<HolidayMaster> holidayMaster,
            ISqlRepository<MonthlyProdCapacityMain> monthlyProdCapacityMain,
            ISqlRepository<MonthlyProdCapacityDtl> monthlyProdCapacityDtl,
            IUnitOfWorkManager unitOfWorkManager,
            ICurrentTenant currentTenant,
            ISqlRepository<StandardItemModelSet> standardItemModelSet
            ) 
        { 
            _ic_item= ic_item;
            _overallDemandPlanDtl= overallDemandPlanDtl;
            _prodLineDetail= prodLineDetail;
            _shopCalendarWorkCtr= shopCalendarWorkCtr;
            _qualityLineWorkDetail= qualityLineWorkDetail;
            _holidayMaster= holidayMaster;
            _monthlyProdCapacityMain= monthlyProdCapacityMain;
            _monthlyProdCapacityDtl= monthlyProdCapacityDtl;
            _unitOfWorkManager= unitOfWorkManager;
            _currentTenant= currentTenant;
            _standardItemModelSet= standardItemModelSet;
        }
        #endregion

        /// <summary>
        /// 产能分析
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        /// <exception cref="NotImplementedException"></exception>
        public async Task<string> CapacityAnalysis(InputDto input)
        {
            //1、获取数据
            //1.1 根据年、月、版本号获取整体需求计划明细
            List<OverallDemandPlanDtl> planDtls = _overallDemandPlanDtl.Select(p=>p.Year == input.year && p.Month == input.month && p.Version == input.version && p.tenant_id == input.tenant_id && p.factory_id == input.factory_id).OrderBy(p=>p.ProdLine).ThenBy(p=>p.ProdRange).ThenBy(p=>p.Model).ThenBy(p=>p.PlanDate).ToList();
            //1.2 根据规格型号获取物料数据
            List<string> models = planDtls.Select(p => p.Model).Distinct().ToList();
            List<StandardItemModelSet> standards = _standardItemModelSet.Select(p=> models.Contains(p.Model) && p.tenant_id == input.tenant_id && p.factory_id == input.factory_id);
            //1.3 根据物料编码获取产线数据
            List<ProdLineDetail> lines = _prodLineDetail.Select(p => standards.Select(m => m.ItemNumber).Contains(p.Part) && p.Domain == input.factory_id.ToString() && p.IsActive);
            //1.4 根据产线获取工作日历数据和产线休息配置数据
            List<ShopCalendarWorkCtr> calendars = _shopCalendarWorkCtr.Select(p=> lines.Select(m=>m.Line).Contains(p.ProdLine) && p.Domain == input.factory_id.ToString() && p.IsActive);
            List<QualityLineWorkDetail> lineWorks = _qualityLineWorkDetail.Select(p => lines.Select(m => m.Line).Contains(p.ProdLine) && p.Domain == input.factory_id.ToString() && p.IsActive);
            //1.5 获取当前年和下一年的节假日配置数据
            List<HolidayMaster> holidays = _holidayMaster.Select(p => (p.Dated.Value.Year == input.year || p.Dated.Value.Year == (input.year + 1)) && p.Domain == input.factory_id.ToString() && p.IsActive);

            //月度产能共识主表
            List<MonthlyProdCapacityMain> capacityMains = new List<MonthlyProdCapacityMain>();
            //月度产能共识明细表
            List<MonthlyProdCapacityDtl> capacityDtls = new List<MonthlyProdCapacityDtl>();
            foreach (var item in planDtls)
            {
                //获取当前产品的生产线
                var std = standards.FirstOrDefault(p => p.Model == item.Model);
                if (std == null)
                {
                    new NLogHelper("MonthlyCapacityLoadAppService").WriteLog("CapacityAnalysis", "规格型号【" + item.Model + "】没有维护标准物料数据", _currentTenant.Id.ToString());
                    return "NO|规格型号【" + item.Model + "】没有维护标准物料数据，请维护后再发布！";
                }
                var curLines = lines.Where(p=>p.Part == std.ItemNumber).OrderBy(p => p.Line).ToList();
                //过滤产线
                var distLines = curLines.Select(p => p.Line).Distinct().ToList();
                if (distLines.Count() == 0)
                {
                    new NLogHelper("MonthlyCapacityLoadAppService").WriteLog("CapacityAnalysis", "物料【" + std.ItemNumber + "】没有维护产线数据", _currentTenant.Id.ToString());
                    return "NO|物料【" + std.ItemNumber + "】没有维护产线数据，请维护后再发布！";
                }
                foreach (var dl in distLines)
                {
                    //添加月度产能共识主表数据
                    MonthlyProdCapacityMain main = new MonthlyProdCapacityMain();
                    main.Id = help.NextId();
                    main.Version = input.version;//整体需求计划版本号
                    main.Year = Convert.ToInt16(item.PlanDate.Substring(0, 4));
                    main.Month = Convert.ToInt16(item.PlanDate.Substring(4, 2));
                    main.ProdRange = item.ProdRange;
                    main.Model = item.Model;
                    main.ProdQty = item.Qty;
                    main.ProdLine = dl;
                    main.Qty = item.Qty;
                    main.tenant_id = item.tenant_id;
                    main.factory_id = item.factory_id;
                    main.Version = item.Version;
                    main.CreateTime = DateTime.Now;
                    capacityMains.Add(main);

                    //添加月度产能共识产能效率数据
                    MonthlyProdCapacityDtl dtl = new MonthlyProdCapacityDtl();
                    dtl.MainId = main.Id;
                    dtl.Version = input.version;
                    dtl.Year = main.Year;
                    dtl.Month = main.Month;
                    dtl.ProdLine = dl;
                    //计算每天工作时间
                    var curCal = calendars.FirstOrDefault(p => p.ProdLine == dl);
                    if (curCal == null) {
                        continue;
                    }
                    dtl.DailyWorks = curCal.ShiftsHours1;
                    dtl.FlightQty = 1;
                    //计算当月工作天数
                    var curHoildays = holidays.Where(p => p.Dated.Value.Year == main.Year && p.Dated.Value.Month == main.Month).ToList();
                    //当月天数
                    int days = DateTime.DaysInMonth(main.Year.Value, main.Month.Value);
                    //当月周末天数
                    int weekDays = CalcWeekDays(days,Convert.ToDateTime(main.Year.ToString()+"-"+main.Month.ToString()+"-01"));
                    dtl.YearWorks= days-weekDays-curHoildays.Where(p=>p.Ufld1 == "休假").Count() + curHoildays.Where(p=>p.Ufld1 == "调班").Count();
                    dtl.AvailableTimes= dtl.DailyWorks * dtl.FlightQty * dtl.YearWorks;
                    //计算产线耗时
                    var line = curLines.Where(p => p.Line == dl).OrderByDescending(p=>p.Op).First();
                    dtl.NeedWorks= line.Rate == 0? 0:( Math.Ceiling(main.Qty.GetValueOrDefault() / line.Rate));
                    dtl.ProdRate= 100;
                    dtl.Rate= dtl.AvailableTimes == 0? 0: Math.Floor(dtl.NeedWorks.GetValueOrDefault()/ dtl.AvailableTimes.GetValueOrDefault() * 100);
                    dtl.IsOverTime = dtl.NeedWorks > dtl.YearWorks ? "是" : "否";
                    dtl.OverTimes = dtl.IsOverTime == "是" ? (dtl.NeedWorks - dtl.YearWorks) : 0;
                    dtl.tenant_id = main.tenant_id;
                    dtl.factory_id = main.factory_id;
                    capacityDtls.Add(dtl);
                }
            }
            //保存数据
            using (var unitOfWork = _unitOfWorkManager.Begin(false, true))
            {
                try
                {
                    //先删除数据
                    _monthlyProdCapacityMain.Delete(p =>p.tenant_id == input.tenant_id && p.factory_id == input.factory_id && p.Version.Contains(input.version.Substring(0, 7)));
                    _monthlyProdCapacityDtl.Delete(p => p.tenant_id == input.tenant_id && p.factory_id == input.factory_id && p.Version.Contains(input.version.Substring(0, 7)));

                    //插入数据
                    _monthlyProdCapacityMain.Insert(capacityMains);
                    _monthlyProdCapacityDtl.Insert(capacityDtls);
                    await unitOfWork.CompleteAsync();
                }
                catch (Exception e)
                {
                    unitOfWork.Dispose();
                    new NLogHelper("MonthlyCapacityLoadAppService").WriteLog("CapacityAnalysis", "生成【"+input.year+"年"+input.month+"月】月度产能共识失败：" + e.Message, _currentTenant.Id.ToString());
                    return "NO|" + e.Message;
                };
            }
            return "OK|发布成功！";
        }

        /// <summary>
        /// 计算当月有多少个周末
        /// </summary>
        /// <param name="days"></param>
        /// <param name="startDay"></param>
        /// <returns></returns>
        private int CalcWeekDays(int days, DateTime startDay)
        {
            int sumDays = 0;
            for (int i = 0; i < days; i++)
            {
                int weekDays = (int)startDay.AddDays(i).DayOfWeek;
                if (weekDays == 0 || weekDays == 6)
                {
                    sumDays++;
                }
            }
            return sumDays;
        }
    }
}