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


@@ -13,6 +13,7 @@


using CMS.Plugin.PipeLineLems.Domain.CallMaterialOrder;


using CMS.Plugin.PipeLineLems.Domain.CallMaterialOrderRecord;


using CMS.Plugin.PipeLineLems.Domain.WorkPlan;


using CMS.Plugin.PipeLineLems.Domain.WorkTask;


using CMS.Plugin.ProcessManagement.Abstractions;


using CMS.Plugin.ProductManagement.Abstractions;


using CMS.Plugin.TraceManagement.Abstractions;


@@ -563,6 +564,7 @@




        var callMaterialOrderRepository = _serviceProvider.GetRequiredService<ICallMaterialOrderRepository>();


        var workPlanRepository = _serviceProvider.GetRequiredService<IWorkPlanRepository>();


        var workTaskRepository = _serviceProvider.GetRequiredService<IWorkTaskRepository>();


        var callMaterialOrderRecordRepository = _serviceProvider.GetRequiredService<ICallMaterialOrderRecordRepository>();


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




@@ -633,6 +635,15 @@


        }


        await workPlanRepository.UpdateManyAsync(workPlanList);




        //更新作业任务表


        var workTaskList = await workTaskRepository.GetListByFilterAsync(x => x.DataIdentifier == callMaterialOrder.DataIdentifier);


        foreach (var item in workTaskList)


        {


            item.CallMaterialStatus = Domain.Shared.Enums.CallMaterialStatusEnum.叫料完成;


            item.LastModifierName = "SuperAdmin";


        }


        await workTaskRepository.UpdateManyAsync(workTaskList);




        //新增叫料记录表


        var callMaterialOrderRecord = new CallMaterialOrderRecord()


        {


@@ -691,12 +702,17 @@


        VariableService _variableService = _serviceProvider.GetRequiredService<VariableService>();


        var callMaterialOrderRepository = _serviceProvider.GetRequiredService<ICallMaterialOrderRepository>();


        var workPlanRepository = _serviceProvider.GetRequiredService<IWorkPlanRepository>();


        var workTaskRepository = _serviceProvider.GetRequiredService<IWorkTaskRepository>();


        var callMaterialOrderRecordRepository = _serviceProvider.GetRequiredService<ICallMaterialOrderRecordRepository>();


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


        var callMaterialOrderAppService = _serviceProvider.GetRequiredService<ICallMaterialOrderAppService>();




        // 查找数据




        var workTask = await workTaskRepository.GetSingleByFilterAsync(x => x.TaskCode == input.TaskCode);


        if (workTask == null)


        {


            throw new UserFriendlyException($"找不到作业计划");


        }


        var workPlan = await workPlanRepository.GetSingleByFilterAsync(x => x.TaskCode == input.TaskCode);


        if (workPlan == null)


        {


@@ -740,6 +756,7 @@


            //    workPlan.WorkPlanStatus = Domain.Shared.Enums.WorkPlanStatusEnum.已完成;


            //}


            workPlan.WorkPlanStatus = Domain.Shared.Enums.WorkPlanStatusEnum.生产中;


            workTask.WorkPlanStatus = Domain.Shared.Enums.WorkPlanStatusEnum.生产中;




            await workPlanRepository.UpdateAsync(workPlan);




@@ -822,10 +839,17 @@


        var traceProvider = _serviceProvider.GetRequiredService<ITraceProvider>();


        var materialProvider = _serviceProvider.GetRequiredService<IMaterialProvider>();


        var workPlanAppService = _serviceProvider.GetRequiredService<IWorkPlanAppService>();


        var workTaskAppService = _serviceProvider.GetRequiredService<IWorkTaskAppService>();


        var workPlanRepository = _serviceProvider.GetRequiredService<IWorkPlanRepository>();


        var workTaskRepository = _serviceProvider.GetRequiredService<IWorkTaskRepository>();


        var callMaterialOrderAppService = _serviceProvider.GetRequiredService<ICallMaterialOrderAppService>();




        string processName = "";


        var firstWorkTask = await workTaskAppService.GetSingleByFilterAsync(x => x.PipeSpecCode == input.PipeSpecCode && x.ProcessName == input.ProcessName);


        if (firstWorkTask == null)


        {


            throw new UserFriendlyException($"找不到作业计划");


        }


        //物料参数列表


        var firstWorkPlan = await workPlanAppService.GetSingleByFilterAsync(x => x.PipeSpecCode == input.PipeSpecCode && x.ProcessName == input.ProcessName);


        if (firstWorkPlan == null)


@@ -883,7 +907,8 @@


        {


            #region 数据处理






            firstWorkTask.WorkPlanStatus = Domain.Shared.Enums.WorkPlanStatusEnum.已完成;


            await workTaskRepository.UpdateAsync(firstWorkTask);




            firstWorkPlan.WorkPlanStatus = Domain.Shared.Enums.WorkPlanStatusEnum.已完成;


            await workPlanRepository.UpdateAsync(firstWorkPlan);