百步立体仓库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
xxyy
2025-02-15 abff6261e5e74ff16a844f4739f84d49b6133000 
 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,27 +101,30 @@


                        }




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


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


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


                        {


                            //throw new Exception(conveyorLine.DeviceName + "缓存中未找到Token缓存");


                            continue;


                        }


                        var userTokenIds = tokenInfos?.Select(x => x.Token_ID).ToList();


                        var userIds = tokenInfos?.Select(x => x.UserId).ToList();




                        object obj = new


                        {


                            station.stationChildCode,


                            commandAfter = command,


                        };


                        _noticeService.StackerData(userIds?.FirstOrDefault(), userTokenIds, new { conveyorLine.DeviceName, data = obj });


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


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


                        //{


                        //    //throw new Exception(conveyorLine.DeviceName + "缓存中未找到Token缓存");


                        //    continue;


                        //}


                        //var userTokenIds = tokenInfos?.Select(x => x.Token_ID).ToList();


                        //var userIds = tokenInfos?.Select(x => x.UserId).ToList();




                        //object obj = new


                        //{


                        //    station.stationChildCode,


                        //    commandAfter = command,


                        //};


                        //_noticeService.StackerData(userIds?.FirstOrDefault(), userTokenIds, new { conveyorLine.DeviceName, data = obj });




                        #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)


@@ -193,7 +186,7 @@


        public void RequestOutbound(CommonConveyorLine_BZ conveyorLine, ConveyorLineTaskCommand_After command, Dt_StationManager station)


        {


            //查询对应产线的在途数据


            dt_needBarcode needBarcode = _needBarcodeRepository.QueryFirst(x => x.productLine == station.productLine);


            dt_needBarcode needBarcode = _needBarcodeRepository.QueryFirst(x => x.productLine == station.productLine && x.toArea == station.stationChildCode);




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




@@ -260,7 +253,7 @@


                }


                else


                {


                    //写入对应产线目标地址


                    //写入对应产线的目标地址


                    if (station.productLine == "ZJ-7")


                    {


                        conveyorLine.SetValue(ConveyorLineDBName_After.ConveyorLineTargetAddress, "", station.stationChildCode);


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


        }


    }


}




#endregion