DataLoaderService
extends AirlayService
in package
Class AirlayService
Table of Contents
- $ : AirlayConfig
- $collection : DataLoadersCollection
- $rabbitmq : AMQPStreamConnection
- $user : UserEntity
- $collection : mixed
- __construct() : mixed
- dynamicHandle() : void
- getCollection() : mixed
- processingClientHandle() : void
- staticHandle() : ObjectId
- findFeature() : FeatureEntity|null
- fireUpdateRelationsEvent() : void
- saveTracksData() : FeatureEntity
- setOfflineStatus() : FeatureEntity
- setOnlineStatus() : FeatureEntity
Properties
$
public
AirlayConfig
$
config
$collection
public
DataLoadersCollection
$collection
$rabbitmq
public
AMQPStreamConnection
$rabbitmq
$user
public
UserEntity
$user
$collection
protected
mixed
$collection
Methods
__construct()
public
__construct(mixed $collection) : mixed
Parameters
- $collection : mixed
Return values
mixed —dynamicHandle()
public
dynamicHandle(string $body, DatasetEntity $dataSet, array<string|int, mixed> $customer) : void
Parameters
- $body : string
- $dataSet : DatasetEntity
- $customer : array<string|int, mixed>
Return values
void —getCollection()
public
getCollection() : mixed
Return values
mixed —processingClientHandle()
public
processingClientHandle(string $body, DatasetEntity $dataSet) : void
Parameters
- $body : string
- $dataSet : DatasetEntity
Return values
void —staticHandle()
public
staticHandle(string $body, string $format, DatasetEntity $dataSet, array<string|int, mixed> $customer[, string $updatePropertiesStrategy = 'replace' ]) : ObjectId
Parameters
- $body : string
- $format : string
- $dataSet : DatasetEntity
- $customer : array<string|int, mixed>
- $updatePropertiesStrategy : string = 'replace'
Return values
ObjectId —findFeature()
private
findFeature(FeaturesCollection $collection, FeatureEntity $importFeature, string|null $uniqueField) : FeatureEntity|null
Parameters
- $collection : FeaturesCollection
- $importFeature : FeatureEntity
- $uniqueField : string|null
Return values
FeatureEntity|null —fireUpdateRelationsEvent()
private
fireUpdateRelationsEvent(array<string|int, mixed> $operations, ObjectId $dataSetId) : void
Parameters
- $operations : array<string|int, mixed>
- $dataSetId : ObjectId
Return values
void —saveTracksData()
private
saveTracksData(FeatureEntity $feature, array<string|int, mixed> $track) : FeatureEntity
Parameters
- $feature : FeatureEntity
- $track : array<string|int, mixed>
Return values
FeatureEntity —setOfflineStatus()
private
setOfflineStatus(FeatureEntity $feature) : FeatureEntity
Parameters
- $feature : FeatureEntity
Return values
FeatureEntity —setOnlineStatus()
private
setOnlineStatus(FeatureEntity $feature, array<string|int, mixed> $data) : FeatureEntity
Parameters
- $feature : FeatureEntity
- $data : array<string|int, mixed>