Docs for m2-core, m2-components
  1. Injectables
  2. ReplicaReadService

File

projects/m2-core/src/lib/core/service/replication/replica-read.service.ts

Extends

ApiService

Index

Methods
Accessors

Constructor

constructor(http: HttpClient, logger: Logger, endpointService: EndpointConfigService, utilService: UtilService, clientConfigService: ClientConfigService, webSocketService: WebSocketService, authService: AuthService)
Parameters :
Name Type Optional
http HttpClient No
logger Logger No
endpointService EndpointConfigService No
utilService UtilService No
clientConfigService ClientConfigService No
webSocketService WebSocketService No
authService AuthService No

Methods

Public classesHaveExpiredMessages
classesHaveExpiredMessages(classIds?: number[])
Parameters :
Name Type Optional
classIds number[] Yes
Returns : Promise<NumberMap<boolean>>
Public editExportTableData
editExportTableData(request: EditExportedItemsPresentationRequest)

Exported items table presentation

Parameters :
Name Type Optional
request EditExportedItemsPresentationRequest No
Returns : Promise<void>
Public editImportTableData
editImportTableData(request: EditSourceRecordsPresentationRequest)

Начать инициализацию нового табличного представления входящих сообщений

Parameters :
Name Type Optional
request EditSourceRecordsPresentationRequest No
Returns : Promise<void>
Public expandExportFacet
expandExportFacet(tableId: number, columnId: string, facetId: string, formatFacets)
Parameters :
Name Type Optional Default value
tableId number No
columnId string No
facetId string No
formatFacets No false
Returns : Promise<Facet[]>
Public expandImportFacet
expandImportFacet(tableId: number, columnId: string, facetId: string, formatFacets)

Получить следующий уровень вложенности ранжированной фасеты таблицы экспортированных айтемов

Parameters :
Name Type Optional Default value Description
tableId number No
columnId string No

колока [ingestionStatusFormatted, stagingErrorTypeFormatted, stagingErrorReason]
facetId string No
formatFacets No false
Returns : Promise<Facet[]>
Public filterApplicabilityVisibleSystems
filterApplicabilityVisibleSystems(systemIds: number[])
Parameters :
Name Type Optional
systemIds number[] No
Returns : Promise<Set<number>>
Public Async findExternalSystems
findExternalSystems(names: string[], fullMatch: boolean)
Parameters :
Name Type Optional
names string[] No
fullMatch boolean No
Returns : Promise<StringMap<ExternalSystem[]>>
Public getActualSystemsAccess
getActualSystemsAccess(systemIds?: number[])

Получить рассчитанные права доступа вызывающего пользователя во все как-либо доступные системы. Для систем, в которых нет совсем никакого доступа, трансер не формируется

Parameters :
Name Type Optional Description
systemIds number[] Yes

Идентификаторы требуемых систем, если пусто, права рассчитываются для всех систем
Returns : Promise<NumberMap<DesirableSystemAccess>>
Public getAvailableIntegrationsQuantity
getAvailableIntegrationsQuantity()

Количество активных систем

Returns : Observable<number>
Public getClassesForElements
getClassesForElements(elementIds: number | number[], directions?: Set<ReplicaDirection>)

Получить список обменных классов, через которые можно отправлять айтем или айтемы указанной ноды, возможно не все, т.е. собираем ноды входящие в указанную

Parameters :
Name Type Optional Description
elementIds number | number[] No

дескриптор айтема (или список) или ноды
directions Set<ReplicaDirection> Yes
Returns : Promise<ExchangeClass[]>
Public getClassesForTable
getClassesForTable(tableId: number, directions?: Set<ReplicaDirection>)

Получить список классов, через которые можно отправлять айтемы, видимые сейчас в табличном представлении.

Parameters :
Name Type Optional Description
tableId number No

Табличное представление айтемов. Огр. таблицы, заявки и проч. не подходят
directions Set<ReplicaDirection> Yes
Returns : Promise<ExchangeClass[]>
Public getCompanyNames
getCompanyNames()
Returns : Promise<string[]>
Public getDesiredSystemAccess
getDesiredSystemAccess(systemId: number)

Получить назначенные права доступа всех субъектов прав во внешнюю систему

Parameters :
Name Type Optional
systemId number No
Returns : Promise<DesirableSystemAccess[]>
Public getExchangeClass
getExchangeClass(classId: string)
Parameters :
Name Type Optional
classId string No
Returns : Promise<ExchangeClass>
Public getExchangeClassById
getExchangeClassById(id: number, ignoreIfNotFound?: boolean)
Parameters :
Name Type Optional
id number No
ignoreIfNotFound boolean Yes
Returns : Observable<ExchangeClass>
Public getExchangeClasses
getExchangeClasses(directions?: Set<ReplicaDirection>)

Classes

Parameters :
Name Type Optional
directions Set<ReplicaDirection> Yes
Returns : Promise<ExchangeClass[]>
Public getExchangeClassesNodes
getExchangeClassesNodes(classIds: number[])
Parameters :
Name Type Optional
classIds number[] No
Returns : Promise<ClassificationNode[]>
Public getExchangeClassNodes
getExchangeClassNodes(classId: number)
Parameters :
Name Type Optional
classId number No
Returns : Promise<ClassificationNode[]>
Public getExchangeClassTopSystem
getExchangeClassTopSystem(classId?: number)
Parameters :
Name Type Optional
classId number Yes
Returns : Promise<ExternalSystem | null>
Public getExportFilterFacets
getExportFilterFacets(tableId: number, columnId: string, formatFacets, size?: number)

Получить дискретные фасеты и ранжированные первого уровня

Parameters :
Name Type Optional Default value Description
tableId number No
columnId string No

колока [dispatchStateFormatted, nodeName, processingInfo]
formatFacets No false
size number Yes
Returns : Promise<Facet[]>
Public getExportMessageById
getExportMessageById(exportedItemId: number)

Получить сообщение безусловно

Parameters :
Name Type Optional
exportedItemId number No
Returns : Promise<MqMessage>
Public getExportRestrictionById
getExportRestrictionById(id: number, ignoreIfNotFound?: boolean)
Parameters :
Name Type Optional
id number No
ignoreIfNotFound boolean Yes
Returns : Observable<ExportRestriction>
Public getExportRestrictionsByIds
getExportRestrictionsByIds(ids: number[], ignoreIfNotFound?: boolean)
Parameters :
Name Type Optional
ids number[] No
ignoreIfNotFound boolean Yes
Returns : Observable<ExportRestriction[]>
Public getExportRestrictionsBySystems
getExportRestrictionsBySystems(systemIds: number[])
Parameters :
Name Type Optional
systemIds number[] No
Returns : Observable<NumberMap<ExportRestriction[]>>
Public getExportTableRows
getExportTableRows(tableId: number, pageSize: number, start: number)
Parameters :
Name Type Optional
tableId number No
pageSize number No
start number No
Returns : Promise<ExportedItem[]>
Public getExternalCompatibilitySettings
getExternalCompatibilitySettings(classId: number)

#15595 External compatibility

Parameters :
Name Type Optional
classId number No
Returns : Observable<ExternalCompatibility[]>
Public getImportFilterFacets
getImportFilterFacets(tableId: number, columnId: string, formatFacets, size?: number)

Получить дискретные фасеты и ранжированные первого уровня таблицы входящих сообщений

Parameters :
Name Type Optional Default value Description
tableId number No
columnId string No

колока [ingestionStatusFormatted, stagingErrorTypeFormatted, stagingErrorReason]
formatFacets No false
size number Yes
Returns : Promise<Facet[]>
Public getImportTableRows
getImportTableRows(tableId: number, pageSize: number, start: number)
Parameters :
Name Type Optional
tableId number No
pageSize number No
start number No
Returns : Promise<SourceRecord[]>
Public getIngestionStatusFacets
getIngestionStatusFacets(tableId: number)
Parameters :
Name Type Optional
tableId number No
Returns : Promise<EntityLight[]>
Public getIntegrationDetails
getIntegrationDetails()
Returns : Promise<IntegrationDetailsRow[]>
Public getIntegrationFailuresQuantity
getIntegrationFailuresQuantity()

Количество систем, для которых есть ошибки интеграции

Returns : Observable<number>
Public getItemApplicableSystems
getItemApplicableSystems(itemId: number)
Parameters :
Name Type Optional
itemId number No
Returns : Promise<ItemApplicableSystem[]>
Public getItemExternalUsage
getItemExternalUsage(itemId: number)

Использование айтема во внешних системах

Parameters :
Name Type Optional
itemId number No
Returns : Promise<ItemExternalUsage[]>
Public getItemPosition
getItemPosition(tableId: number, itemId: number)
Parameters :
Name Type Optional
tableId number No
itemId number No
Returns : Promise<number>
Public getItemSystems
getItemSystems(itemId: number)
Parameters :
Name Type Optional
itemId number No
Returns : Observable<ExternalSystem[]>
Public getOnlineCompaniesQuantity
getOnlineCompaniesQuantity()

Количество активных прелприятий

Returns : Observable<number>
Public getRabbitMqLastActivity
getRabbitMqLastActivity()
Returns : Observable<string>
Public getRabbitMqMainConnectionState
getRabbitMqMainConnectionState()

Получить состояние основного соединения RabbitMq, в которое выполняется запись сообщений экспорта

Returns : Observable<RabbitMqState>
Public getSourceMessageById
getSourceMessageById(sourceRecordId: number)

Получить сообщение безусловно

Parameters :
Name Type Optional
sourceRecordId number No
Returns : Promise<SourceMessage>
Public getSourceRecordsByIds
getSourceRecordsByIds(ids: number[])
Parameters :
Name Type Optional
ids number[] No
Returns : Promise<SourceRecord[]>
Public getStateFacets
getStateFacets(tableId: number)
Parameters :
Name Type Optional
tableId number No
Returns : Promise<EntityLight[]>
Public getSystemById
getSystemById(id: number, ignoreIfNotFound?: boolean)
Parameters :
Name Type Optional
id number No
ignoreIfNotFound boolean Yes
Returns : Promise<ExternalSystem>
Public getSystemImages
getSystemImages(systemIds: number[])
Parameters :
Name Type Optional
systemIds number[] No
Returns : Promise<Map<number, BlobData>>
Public getSystemRegexpReplacements
getSystemRegexpReplacements(systemId: number)
Parameters :
Name Type Optional
systemId number No
Returns : Observable<ExternalRegexpReplacement[]>
Public getSystemReplicaLevel
getSystemReplicaLevel(systemId?: number)

Returns access level as number

Parameters :
Name Type Optional
systemId number Yes
Returns : Promise<ReplicaAccessLevel>
Public getSystems
getSystems(forceRefresh?: boolean)

Common

Parameters :
Name Type Optional
forceRefresh boolean Yes
Returns : Promise<ExternalSystem[]>
Public getSystemsByIds
getSystemsByIds(ids: number[], ignoreIfNotFound?: boolean)
Parameters :
Name Type Optional
ids number[] No
ignoreIfNotFound boolean Yes
Returns : Promise<ExternalSystem[]>
Public getSystemsForElement
getSystemsForElement(elementId: number)

Получить список систем, в которые можно отправлять айтем или айтемы указанной ноды, возможно не все, т.е. собираем ноды входящие в указанную

Parameters :
Name Type Optional
elementId number No
Returns : Promise<ExternalSystem[]>
Public getSystemsForTable
getSystemsForTable(tableId: number)

Получить список систем, в которые можно отправлять айтемы, видимые сейчас в табличном представлении.

Parameters :
Name Type Optional Description
tableId number No

Табличное представление айтемов. Огр. таблицы, заявки и проч. не подходят
Returns : Promise<ExternalSystem[]>
Public getSystemsMap
getSystemsMap(ids: number[], ignoreIfNotFound?: boolean)
Parameters :
Name Type Optional
ids number[] No
ignoreIfNotFound boolean Yes
Returns : Promise<Map<number, ExternalSystem>>
Public getSystemsReplicaLevels
getSystemsReplicaLevels(systemIds: number[])

Returns map: systemId - access level as number

Parameters :
Name Type Optional
systemIds number[] No
Returns : Promise<NumberMap<ReplicaAccessLevel>>
Public getSystemsToClassesMapping
getSystemsToClassesMapping(systemOrClassid: number, fromSystem: boolean)

Datatable

Parameters :
Name Type Optional
systemOrClassid number No
fromSystem boolean No
Returns : Promise<ExportRestrictionInfo[]>
Public getSystemsWithKeysForClassifiableElements
getSystemsWithKeysForClassifiableElements(elementIds: number[])

Получить список систем, для которых есть переходные ключи позиций указанных элементов классификации, то есть нод или айтемов #21023

Parameters :
Name Type Optional
elementIds number[] No
Returns : Observable<ExternalSystem[]>
Public getSystemsWithKeysForTable
getSystemsWithKeysForTable(tableId: number)

Получить список систем, для которых есть переходные ключи позиций указанной таблицы айтемов #21023

Parameters :
Name Type Optional
tableId number No
Returns : Observable<ExternalSystem[]>
Public getTableRowCount
getTableRowCount(tableId: number)
Parameters :
Name Type Optional
tableId number No
Returns : Promise<number>
Public getTransitionalKeysByItems
getTransitionalKeysByItems(itemIds: number[])

Получить переходные ключи для айтемов

Parameters :
Name Type Optional
itemIds number[] No
Returns : Promise<TransitionalKey[]>
Public getTransitionalKeysByValue
getTransitionalKeysByValue(systemId: number, keyValue: string[])

Получить переходные ключи в системе по значению

Parameters :
Name Type Optional
systemId number No
keyValue string[] No
Returns : Promise<TransitionalKey[]>
Public isFullBuilderClass
isFullBuilderClass(classId: string)
Parameters :
Name Type Optional
classId string No
Returns : Promise<boolean>
Public setUsageAccessLevel
setUsageAccessLevel(usages: ItemExternalUsage[])
Parameters :
Name Type Optional
usages ItemExternalUsage[] No
Returns : Promise<void>
Public systemsHaveExpiredMessages
systemsHaveExpiredMessages()
Returns : Promise<number[]>
Public validateHaveExpiredMessages
validateHaveExpiredMessages(systemsOrClasses: T[], type: ModelEntityType)
Type parameters :
  • T

Validation

Parameters :
Name Type Optional
systemsOrClasses T[] No
type ModelEntityType No
Returns : Promise<T[]>

Accessors

mqAddress
getmqAddress()

results matching ""

    No results matching ""