HIA24016N管子线DEMO开发
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
schangxiang@126.com
2025-05-10 4209c8ff313ce8bac44bc9fe0b2260111a3fb388 
 PipeLineLems/server/src/CMS.Plugin.PipeLineLems.Application/Implements/MesAppService.cs


@@ -1,164 +1,164 @@


//using CMS.Plugin.FormulaManagement.Abstractions;


//using CMS.Plugin.OrderManagement.Abstractions;


//using CMS.Plugin.OrderManagement.Abstractions.Enums;


//using CMS.Plugin.OrderManagement.Abstractions.Models;


//using CMS.Plugin.PipeLineLems.Application.Contracts.Dtos.WorkPlan;


//using CMS.Plugin.PipeLineLems.Application.Contracts.Services;


//using CMS.Plugin.PipeLineLems.Domain.WorkPlan;


//using CMS.Plugin.ProductManagement.Abstractions;


//using Microsoft.Extensions.DependencyInjection;


//using Volo.Abp;


using CMS.Plugin.FormulaManagement.Abstractions;


using CMS.Plugin.OrderManagement.Abstractions;


using CMS.Plugin.OrderManagement.Abstractions.Enums;


using CMS.Plugin.OrderManagement.Abstractions.Models;


using CMS.Plugin.PipeLineLems.Application.Contracts.Dtos.WorkPlan;


using CMS.Plugin.PipeLineLems.Application.Contracts.Services;


using CMS.Plugin.PipeLineLems.Domain.WorkPlan;


using CMS.Plugin.ProductManagement.Abstractions;


using Microsoft.Extensions.DependencyInjection;


using Volo.Abp;




//namespace CMS.Plugin.PipeLineLems.Application.Implements;


namespace CMS.Plugin.PipeLineLems.Application.Implements;




//public class MesAppService : CMSPluginAppService, IMesAppService


//{


//    private readonly IServiceProvider _serviceProvider;


//    private readonly IWorkPlanAppService _workPlanAppService;


public class MesAppService : CMSPluginAppService


{


    private readonly IServiceProvider _serviceProvider;


    private readonly IWorkPlanAppService _workPlanAppService;




//    //private readonly IEventBus _eventBus;


    //private readonly IEventBus _eventBus;




//    public MesAppService(IServiceProvider serviceProvider


//        , IWorkPlanAppService workPlanAppService


//        //, IEventBus eventBus


//        )


//    {


//        _serviceProvider = serviceProvider;


//        // _eventBus = eventBus;


//        _workPlanAppService = workPlanAppService;


//    }


    public MesAppService(IServiceProvider serviceProvider


        , IWorkPlanAppService workPlanAppService


        //, IEventBus eventBus


        )


    {


        _serviceProvider = serviceProvider;


        // _eventBus = eventBus;


        _workPlanAppService = workPlanAppService;


    }




//    public async Task<MesOrderResponse> CreateAsync(List<WorkPlanInput> input)


//    {


//        if (input == null)


//        {


//            throw new UserFriendlyException("输入参数不能为空");


//        }


    public async Task<MesOrderResponse> CreateAsync(List<WorkPlanInput> input)


    {


        if (input == null)


        {


            throw new UserFriendlyException("输入参数不能为空");


        }




//        if (input.Count == 0)


//        {


//            throw new UserFriendlyException("输入参数Data不能为空");


//        }


        if (input.Count == 0)


        {


            throw new UserFriendlyException("输入参数Data不能为空");


        }




//        var orderManager = _serviceProvider.GetRequiredService<IOrderManager>();


//        var productProvider = _serviceProvider.GetRequiredService<IProductProvider>();


//        var formulaProvider = _serviceProvider.GetRequiredService<IFormulaProvider>();


//        List<OrderModel> orderModels = new List<OrderModel>();


//        //按照任务编号分组


//        var groupTask = input.GroupBy(x => x.TaskCode);


//        foreach (var gTask in groupTask)


//        {


//            var taskCode = gTask.Key;


//            var order = await orderManager.GetByCodeAsync(taskCode);


//            if (order != null)


//            {


//                throw new UserFriendlyException($"任务编号[{taskCode}]已存在");


//            }


        var orderManager = _serviceProvider.GetRequiredService<IOrderManager>();


        var productProvider = _serviceProvider.GetRequiredService<IProductProvider>();


        var formulaProvider = _serviceProvider.GetRequiredService<IFormulaProvider>();


        List<OrderModel> orderModels = new List<OrderModel>();


        //按照任务编号分组


        var groupTask = input.GroupBy(x => x.TaskCode);


        foreach (var gTask in groupTask)


        {


            var taskCode = gTask.Key;


            var order = await orderManager.GetByCodeAsync(taskCode);


            if (order != null)


            {


                throw new UserFriendlyException($"任务编号[{taskCode}]已存在");


            }






//            //var product = await productProvider.FindByNameAsync(orderItem.PipeSectionName);


//            //if (product == null)


//            //{


//            //    throw new UserFriendlyException($"产品名称[{orderItem.PipeSectionName}]不存在");


//            //}


            //var product = await productProvider.FindByNameAsync(orderItem.PipeSectionName);


            //if (product == null)


            //{


            //    throw new UserFriendlyException($"产品名称[{orderItem.PipeSectionName}]不存在");


            //}




//            //var formula = await formulaProvider.GetFormulaAsync(product.Id);


//            //if (formula == null)


//            //{


//            //    throw new UserFriendlyException($"产品型号[{orderItem.MaterialCode}]无关联配方");


//            //}


//            //首先要创建 打码切割的工单 


//            var productForCut = await productProvider.FindByNameAsync("切割原料管");


//            if (productForCut == null)


//            {


//                throw new UserFriendlyException($"产品名称[切割原料管]不存在");


//            }


//            var formulaForCut = await formulaProvider.GetFormulaAsync(productForCut.Id);


//            if (formulaForCut == null)


//            {


//                throw new UserFriendlyException($"产品名称[切割原料管]无关联配方");


//            }


//            //分组数据


//            var group = gTask.ToList().GroupBy(x => x.DataIdentifier);


//            foreach (var item in group)


//            {


//                OrderModel orderModelForCut = new OrderModel()


//                {


//                    Id = Guid.NewGuid(),


//                    Code = "Cut_" + taskCode,


//                    Source = "APS推送",


//                    PlanStartTime = gTask.ToList().First().PlannedStartTime,


//                    PlanFinishTime = gTask.ToList().First().PlannedEndTime,


//                    PlanQty = (ulong)item.ToList().Count,


//                    Status = OrderStatus.NotActive,


//                    Product = new AssociationProductModel() { Id = productForCut.Id, Name = productForCut.Name, Model = productForCut.Model, ShortNumber = productForCut.ShortNumber },


//                    Formula = new AssociationFormulaModel() { Id = formulaForCut.Id, Code = formulaForCut.Code, Name = formulaForCut.Name }


//                };


//                orderModelForCut.ExtraProperties["OuterDiameter"] = gTask.ToList().First().OuterDiameter;//外径


//                orderModelForCut.ExtraProperties["Material"] = gTask.ToList().First().Material;//材质


//                orderModelForCut.ExtraProperties["Length"] = gTask.ToList().First().Length;//长度


            //var formula = await formulaProvider.GetFormulaAsync(product.Id);


            //if (formula == null)


            //{


            //    throw new UserFriendlyException($"产品型号[{orderItem.MaterialCode}]无关联配方");


            //}


            //首先要创建 打码切割的工单 


            var productForCut = await productProvider.FindByNameAsync("切割原料管");


            if (productForCut == null)


            {


                throw new UserFriendlyException($"产品名称[切割原料管]不存在");


            }


            var formulaForCut = await formulaProvider.GetFormulaAsync(productForCut.Id);


            if (formulaForCut == null)


            {


                throw new UserFriendlyException($"产品名称[切割原料管]无关联配方");


            }


            //分组数据


            var group = gTask.ToList().GroupBy(x => x.DataIdentifier);


            foreach (var item in group)


            {


                OrderModel orderModelForCut = new OrderModel()


                {


                    Id = Guid.NewGuid(),


                    Code = "Cut_" + taskCode,


                    Source = "APS推送",


                    PlanStartTime = gTask.ToList().First().PlannedStartTime,


                    PlanFinishTime = gTask.ToList().First().PlannedEndTime,


                    PlanQty = (ulong)item.ToList().Count,


                    Status = OrderStatus.NotActive,


                    Product = new AssociationProductModel() { Id = productForCut.Id, Name = productForCut.Name, Model = productForCut.Model, ShortNumber = productForCut.ShortNumber },


                    Formula = new AssociationFormulaModel() { Id = formulaForCut.Id, Code = formulaForCut.Code, Name = formulaForCut.Name }


                };


                orderModelForCut.ExtraProperties["OuterDiameter"] = gTask.ToList().First().OuterDiameter;//外径


                orderModelForCut.ExtraProperties["Material"] = gTask.ToList().First().Material;//材质


                orderModelForCut.ExtraProperties["Length"] = gTask.ToList().First().Length;//长度




//                var orderForCut = await orderManager.GetByCodeAsync(orderModelForCut.Code);


//                if (orderForCut != null)


//                {


//                    //throw new UserFriendlyException($"工单[{orderModelForCut.Code}]已存在");


//                    //不再抛异常，直接跳过


//                    break;


//                }


                var orderForCut = await orderManager.GetByCodeAsync(orderModelForCut.Code);


                if (orderForCut != null)


                {


                    //throw new UserFriendlyException($"工单[{orderModelForCut.Code}]已存在");


                    //不再抛异常，直接跳过


                    break;


                }




//                var orderModelResultForCut = await orderManager.CreateAsync(orderModelForCut);


//                if (orderModelResultForCut == null)


//                {


//                    throw new UserFriendlyException($"工单[{orderModelForCut.Code}]创建失败");


//                }


//                orderModels.Add(orderModelResultForCut);


                var orderModelResultForCut = await orderManager.CreateAsync(orderModelForCut);


                if (orderModelResultForCut == null)


                {


                    throw new UserFriendlyException($"工单[{orderModelForCut.Code}]创建失败");


                }


                orderModels.Add(orderModelResultForCut);






//                //OrderModel orderModel = new OrderModel();


//                //orderModel.Id = Guid.NewGuid();


//                //orderModel.Code = orderItem.TaskCode;


//                //orderModel.Source = "APS推送";


//                //orderModel.Product = new AssociationProductModel() { Id = product.Id, Name = product.Name, Model = product.Model, ShortNumber = product.ShortNumber };


//                ////orderModel.Formula = new AssociationFormulaModel() { Id = formula.Id, Code = formula.Code, Name = formula.Name };


//                //orderModel.PlanStartTime = orderItem.PlannedStartTime;


//                //orderModel.PlanFinishTime = orderItem.PlannedEndTime;


//                //orderModel.PlanQty = (ulong?)orderItem.OrderQty;


//                //orderModel.Status = OrderStatus.NotActive;


//                //orderModel.ExtraProperties["Source"] = "ddd";


//                //var source = orderModel.ExtraProperties["Source"];


//                //var orderModelResult = await orderManager.CreateAsync(orderModel);


//                //if (orderModelResult == null)


//                //{


//                //    throw new UserFriendlyException($"工单[{orderItem.TaskCode}]创建失败");


//                //}


//                //orderModels.Add(orderModelResult);


//            }


                //OrderModel orderModel = new OrderModel();


                //orderModel.Id = Guid.NewGuid();


                //orderModel.Code = orderItem.TaskCode;


                //orderModel.Source = "APS推送";


                //orderModel.Product = new AssociationProductModel() { Id = product.Id, Name = product.Name, Model = product.Model, ShortNumber = product.ShortNumber };


                ////orderModel.Formula = new AssociationFormulaModel() { Id = formula.Id, Code = formula.Code, Name = formula.Name };


                //orderModel.PlanStartTime = orderItem.PlannedStartTime;


                //orderModel.PlanFinishTime = orderItem.PlannedEndTime;


                //orderModel.PlanQty = (ulong?)orderItem.OrderQty;


                //orderModel.Status = OrderStatus.NotActive;


                //orderModel.ExtraProperties["Source"] = "ddd";


                //var source = orderModel.ExtraProperties["Source"];


                //var orderModelResult = await orderManager.CreateAsync(orderModel);


                //if (orderModelResult == null)


                //{


                //    throw new UserFriendlyException($"工单[{orderItem.TaskCode}]创建失败");


                //}


                //orderModels.Add(orderModelResult);


            }




//        }


        }






//        //保存到表中


//        foreach (var item in input)


//        {


//            var insertObj = ObjectMapper.Map<WorkPlanInput, WorkPlanCreateDto>(item);


//            insertObj.OrgMaterialCode = "1111";


//            insertObj.Sort = 1;


//            await _workPlanAppService.CreateAsync(insertObj);


//        }


        //保存到表中


        foreach (var item in input)


        {


            var insertObj = ObjectMapper.Map<WorkPlanInput, WorkPlanCreateDto>(item);


            //insertObj.OrgMaterialCode = "1111";


            insertObj.Sort = 1;


            await _workPlanAppService.CreateAsync(insertObj);


        }






//        // 发布事件


//        //await _eventBus.PublishAsync(new EntityChangedEto("MESCREATE", input, null, EntityChangeType.Add, true));


        // 发布事件


        //await _eventBus.PublishAsync(new EntityChangedEto("MESCREATE", input, null, EntityChangeType.Add, true));




//        var response = new MesOrderResponse


//        {


//            Code = "000000",


//            Data = orderModels,


//            Fail = false,


//            Mesg = "处理成功",


//            Success = true,


//            Time = DateTime.UtcNow


//        };


//        return response;


//    }


//}


        var response = new MesOrderResponse


        {


            Code = "000000",


            Data = orderModels,


            Fail = false,


            Mesg = "处理成功",


            Success = true,


            Time = DateTime.UtcNow


        };


        return response;


    }


}