| | |
| | | } |
| | | |
| | | #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(); |
| | | //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 }); |
| | | //object obj = new |
| | | //{ |
| | | // station.stationChildCode, |
| | | // commandAfter = command, |
| | | //}; |
| | | //_noticeService.StackerData(userIds?.FirstOrDefault(), userTokenIds, new { conveyorLine.DeviceName, data = obj }); |
| | | |
| | | #endregion 调用事件总线通知前端 |
| | | } |