DEMOMySql/MicroServices/Business/Business.Application/ResourceExamineManagement/ResourceExamineAppService.cs

using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Dynamic.Core;
using System.Threading.Tasks;
using Volo.Abp.Application.Dtos;
using Volo.Abp.Domain.Repositories;
using Business.Models;
using Microsoft.AspNetCore.Authorization;
using Business.Permissions;
using XCZ;
using Business.ResourceExamineManagement.Dto;
using Bussiness.Model.MES.IC;
using AutoMapper.Internal.Mappers;
using Bussiness.Model.Tech;
using Bussiness.Model.Production;
using Business.Core.MongoDBHelper;
using Business.Core.Utilities;
using Hangfire.Storage.Monitoring;
using Business.BookManagement.Dto;
using Volo.Abp.ObjectMapping;
using Volo.Abp.Application.Services;
using ZstdSharp.Unsafe;

namespace Business.ResourceExamineManagement
{
    /// <summary>
    /// 资源检查
    /// </summary>
    //[Authorize(BusinessPermissions.ResourceExamine.Default)]
    public class ResourceExamineAppService : ApplicationService, IResourceExamineAppService
    {
        #region 服务
        /// <summary>
        /// 工艺路径
        /// </summary>
        private readonly IMongoDB<mes_technique> _mes_technique;

        /// <summary>
        /// 工艺关联工序
        /// </summary>
        private readonly IMongoDB<mes_tech_process> _mes_tech_process;

        /// <summary>
        /// 工作日历
        /// </summary>
        private readonly IMongoDB<mes_work_calendar> _mes_work_calendar;

        /// <summary>
        /// 工作日历明细
        /// </summary>
        private readonly IMongoDB<mes_work_calendar_list> _mes_work_calendar_list;

        /// <summary>
        /// 工艺工序关联工位
        /// </summary>
        private readonly IMongoDB<mes_tech_proc_workshop> _mes_tech_proc_workshop;

        /// <summary>
        /// 排程占用记录
        /// </summary>
        private readonly IMongoDB<mes_schedule_occupy> _mes_schedule_occupy;

        /// <summary>
        /// 物料详情
        /// </summary>
        private readonly IMongoDB<ic_item> _ic_item;

        /// <summary>
        /// 物料BOM
        /// </summary>
        private readonly IMongoDB<ic_bom> _ic_bom;

        /// <summary>
        /// 物料BOM明细
        /// </summary>
        private readonly IMongoDB<ic_bom_child> _ic_bom_child;
        #endregion

        /// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="icitem"></param>
        /// <param name="icbom"></param>
        public ResourceExamineAppService(
            IMongoDB<mes_technique> mes_technique,
            IMongoDB<ic_item> ic_item,
            IMongoDB<ic_bom> ic_bom,
            IMongoDB<ic_bom_child> ic_bom_child
            )
        {
            _mes_technique = mes_technique;
            _ic_item = ic_item;
            _ic_bom = ic_bom;
            _ic_bom_child = ic_bom_child;
        }

        /// <summary>
        /// 资源检查
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        /// <exception cref="NotImplementedException"></exception>
        public async Task<PschedDto> ReceiveResult(SeorderentryDto input)
        {
            ////多条插入
            //List<mes_technique> infos = new List<mes_technique>();
            //mes_technique info;
            //for (int i = 0; i < 3; i++)
            //{
            //    info = new mes_technique();
            //    info.GenerateNewId();
            //    info.tech_name = "多条"+i;
            //    info.level = i;
            //    infos.Add(info);
            //}
            //await _mes_technique.InsertMany(infos);

            ////获取数据
            //var info1 = await _mes_technique.GetOneByID((long)1732029975067480064);

            ////更新数据
            //info1.tech_name = "更新777";
            //await _mes_technique.UpdateOne(info1, info1.Id);

            throw new NotImplementedException();

        }



        /// <summary>
        /// 产能计算
        /// </summary>
        /// <param name="BomId">Bom主键</param>
        /// <param name="Quantity">需要数量</param>
        public async Task ProductiveExamine(long? BomId, int Quantity)
        {

        }
        /// <summary>
        /// 检查在制工单
        /// </summary>
        /// <param name="bomNumber">Bom编码</param>
        /// <param name="Quantity">需要数量</param>
        /// <returns></returns>
        public async Task CheckMorder(string bomNumber, int Quantity)
        {
            if (string.IsNullOrEmpty(bomNumber) || Quantity < 0)
            {
                //TODO：入参异常；
                //throw new NotImplementedException();
            }
            //查询生产工单类型为计划工单并且工单类型为备库工单 并且BOM编码一致数据
            // 订单状态为 初始或下达工单
            // List =>数量满足Quantity && 生成工单结束日期最早
        }

        public async Task BomPretreatmentAsync(long? orderid, long? BomId, int Quantity)
        {
            if (orderid == null)
            {
                //throw new bu
            }
            if (BomId == null)
            {
                //throw new bu
            }

            //var query = (await _ic_bom.GetQueryableAsync()).WhereIf(true, a => a.bom_id == BomId).ToList();
            //var help = new SnowFlake();
            //var id = help.NextId();
            var level = 0;
            var bomlist = _ic_bom.GetAll();
            var bomchildlist = _ic_bom_child.GetAll();
            var icitemlist = _ic_item.GetAll();
            //GetBomListAsync();
        }


        public void GetBomList(List<ic_bom> bomlist, List<ic_bom_child> bomchildlist, List<ic_item> icitemlist, long bomId, List<BomChildExamineDto> returnlist, long? parent_id, int le)
        {
            int level = le++;//初始化定义level层级
            var help = new SnowFlake();

            var bom = bomlist.WhereIf(true, s => s.bom_id == bomId).FirstOrDefault();
            if (bom == null)
            {

            }
            var dto = new BomChildExamineDto();
            dto.level = level;
            dto.bom_id = bomId;
            dto.id = help.NextId();
            dto.parent_id = parent_id;
            dto.item_id = bom.icitem_id;
            dto.item_name = bom.item_name;
            dto.item_code = bom.item_number;
            //var bdto = ObjectMapper.Map<ic_bom,BomChildExamineDto>(bom);
            returnlist.Add(dto);
            var childlist = bomchildlist.WhereIf(true, a => a.bom_id == bom.bom_id).ToList();
            foreach (var c in childlist)
            {
                var icitem = icitemlist.WhereIf(true, a => a.icitem_id == c.icitem_id).FirstOrDefault();
                //如果此明细查的到BOM信息，则代表此child是一个子BOM。
                if (c.is_bom == 1)
                {
                    var childBom = bomlist.WhereIf(true, a => a.icitem_id == c.icitem_id).FirstOrDefault();
                    if (childBom != null)
                    {
                        GetBomList(bomlist, bomchildlist, icitemlist, childBom.bom_id, returnlist, dto.id, level);
                    }
                }
                else
                {
                    if (icitem != null)
                    {
                        var childDto = new BomChildExamineDto();
                        childDto.level = level++;
                        childDto.bom_id = bomId;
                        childDto.id = help.NextId();
                        childDto.parent_id = parent_id;
                        childDto.item_id = icitem.icitem_id;
                        childDto.item_name = icitem.name;
                        childDto.item_code = icitem.number;
                        returnlist.Add(childDto);
                    }
                }
            }

        }
    }
}