百步立体仓库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
xxyy
2025-02-28 c2461f320a6b36390d8dd26d4ce11a62baa0e215 
 Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/ConveyorLineJob_BZ/CommonConveyorLine_BZJob.cs


@@ -1,4 +1,5 @@


#region MyRegion




#region << 版 本 注 释 >>




/*----------------------------------------------------------------


@@ -20,37 +21,24 @@




using AutoMapper;


using HslCommunication;


using Microsoft.AspNetCore.Server.HttpSys;


using Newtonsoft.Json;


using Quartz;


using SqlSugar;


using System.Diagnostics.CodeAnalysis;


using System.Net;


using System.Reflection;


using System.Threading.Tasks;


using WIDESEAWCS_BasicInfoRepository;


using WIDESEAWCS_BasicInfoService;


using WIDESEAWCS_Common;


using WIDESEAWCS_Common.TaskEnum;


using WIDESEAWCS_Core;


using WIDESEAWCS_Core.Caches;


using WIDESEAWCS_Core.Helper;


using WIDESEAWCS_Core.HttpContextUser;


using WIDESEAWCS_DTO.MOM;


using WIDESEAWCS_DTO.TaskInfo;


using WIDESEAWCS_IProcessRepository;


using WIDESEAWCS_ISystemRepository;


using WIDESEAWCS_ISystemServices;


using WIDESEAWCS_ITaskInfoRepository;


using WIDESEAWCS_ITaskInfoService;


using WIDESEAWCS_Model.Models;


using WIDESEAWCS_QuartzJob;


using WIDESEAWCS_QuartzJob.DeviceBase;


using WIDESEAWCS_QuartzJob.DTO;


using WIDESEAWCS_QuartzJob.Service;


using WIDESEAWCS_SignalR;


using WIDESEAWCS_Tasks.ConveyorLineJob;


using static Microsoft.EntityFrameworkCore.DbLoggerCategory.Database;


using ICacheService = WIDESEAWCS_Core.Caches.ICacheService;




namespace WIDESEAWCS_Tasks


@@ -95,6 +83,7 @@


                if (conveyorLine != null)


                {


                    #region 站台方式




                    List<Dt_StationManager> stationManagers = _stationManagerService.GetAllStationByDeviceCode(conveyorLine.DeviceCode);




                    foreach (var station in stationManagers)


@@ -112,6 +101,7 @@


                        }




                        #region 调用事件总线通知前端




                        //var tokenInfos = _cacheService.Get<List<UserInfo>>("Cache_UserToken");


                        //if (tokenInfos == null || !tokenInfos.Any())


                        //{


@@ -130,9 +120,11 @@




                        #endregion 调用事件总线通知前端


                    }


                    #endregion




                    #endregion 站台方式




                    #region 路由方式




                    //List<string> childDeviceCodes = _routerService.QueryAllPositions(conveyorLine.DeviceCode);


                    //foreach (string childDeviceCode in childDeviceCodes)


                    //{


@@ -168,7 +160,8 @@


                    //        }


                    //    }


                    //}


                    #endregion




                    #endregion 路由方式


                }


            }


            catch (Exception ex)


@@ -198,7 +191,7 @@


            needBarcode.inLineNum = _taskRepository.QueryData(x => x.TargetAddress == station.stationChildCode).Count();




            //若在途数量小于目标位置的缓存数量 则寻找对应常温库存中常温3工序的可出库数据 并建立出库任务


            if (needBarcode.inLineNum <= needBarcode.cacheNum)


            if (needBarcode.inLineNum < needBarcode.cacheNum)


            {


                if (_taskService.RequestOutTaskToBZAsync(station).Result.Status)


                {


@@ -226,7 +219,7 @@


                conveyorLine.SetValue(ConveyorLineDBName_After.ConveyorLineTargetAddress, task.NextAddress, station.stationChildCode);


                _taskRepository.DeleteData(task);




                if (needBarcode.inLineNum-- <= 0) needBarcode.inLineNum = 0;


                if (--needBarcode.inLineNum <= 0) needBarcode.inLineNum = 0;


                _needBarcodeRepository.UpdateData(needBarcode);


            }


            else  //如无任务 则判定为从NG口上料 调取MOM接口  判断返回参数 无异常则送入包装，有异常则退回NG口


@@ -274,4 +267,5 @@


        }


    }


}




#endregion