Mettre en place le socle de distribution multi-canaux Enterprise.

Cette couche permet de connecter les propriétés aux différents canaux de vente :

OTA

Site Web

Application Mobile

Partenaires

Marketplaces

Channel Managers

afin de centraliser la gestion :

Inventaire

Tarification

Disponibilités

Synchronisation

Distribution

À l'issue de cette étape :

✓ Channel

✓ ChannelConnection

✓ ChannelMapping

✓ DistributionRule

✓ ChannelInventory

✓ ChannelPricing

✓ Distribution Core Platform

Properties

↓

Distribution Core

├── Channels
├── Connections
├── Mapping
├── Inventory
├── Pricing
└── Rules Engine

↓

OTA / Marketplace

↓

Reservations

model Channel {
 
  id                    String
                        @id
                        @default(uuid())
 
  code                  String
                        @unique
 
  name                  String
 
  category              ChannelCategory
 
  provider              String
 
  active                Boolean
                        @default(true)
 
  supportsInventory     Boolean
                        @default(true)
 
  supportsPricing       Boolean
                        @default(true)
 
  supportsReservations  Boolean
                        @default(true)
 
  createdAt             DateTime
                        @default(now())
 
  updatedAt             DateTime
                        @updatedAt
 
  connections           ChannelConnection[]
 
  @@index([category])
 
  @@index([active])
}

model ChannelConnection {
 
  id                    String
                        @id
                        @default(uuid())
 
  tenantId              String
 
  channelId             String
 
  portfolioId           String?
 
  connectionName        String
 
  externalAccountId     String?
 
  status                ChannelConnectionStatus
 
  credentials           Json?
 
  lastSyncAt            DateTime?
 
  createdAt             DateTime
                        @default(now())
 
  updatedAt             DateTime
                        @updatedAt
 
  channel               Channel
                        @relation(
                          fields:[channelId],
                          references:[id]
                        )
 
  @@index([tenantId])
 
  @@index([channelId])
 
  @@index([status])
}

model ChannelMapping {
 
  id                    String
                        @id
                        @default(uuid())
 
  tenantId              String
 
  propertyId            String
 
  channelConnectionId   String
 
  externalPropertyId    String
 
  externalListingId     String?
 
  active                Boolean
                        @default(true)
 
  createdAt             DateTime
                        @default(now())
 
  updatedAt             DateTime
                        @updatedAt
 
  @@index([tenantId])
 
  @@index([propertyId])
 
  @@index([channelConnectionId])
}

model DistributionRule {
 
  id                    String
                        @id
                        @default(uuid())
 
  tenantId              String
 
  propertyId            String?
 
  portfolioId           String?
 
  name                  String
 
  priority              Int
                        @default(100)
 
  enabled               Boolean
                        @default(true)
 
  conditions            Json
 
  actions               Json
 
  createdAt             DateTime
                        @default(now())
 
  updatedAt             DateTime
                        @updatedAt
 
  @@index([tenantId])
 
  @@index([enabled])
 
  @@index([priority])
}

model ChannelInventory {
 
  id                    String
                        @id
                        @default(uuid())
 
  propertyId            String
 
  channelMappingId      String
 
  inventoryDate         DateTime
 
  availableUnits        Int
 
  blockedUnits          Int
                        @default(0)
 
  syncedAt              DateTime?
 
  createdAt             DateTime
                        @default(now())
 
  @@unique([
    channelMappingId,
    inventoryDate
  ])
 
  @@index([propertyId])
 
  @@index([inventoryDate])
}

model ChannelPricing {
 
  id                    String
                        @id
                        @default(uuid())
 
  propertyId            String
 
  channelMappingId      String
 
  pricingDate           DateTime
 
  basePrice             Decimal
                        @db.Decimal(12,2)
 
  adjustedPrice         Decimal?
                        @db.Decimal(12,2)
 
  currency              String
 
  syncedAt              DateTime?
 
  createdAt             DateTime
                        @default(now())
 
  @@unique([
    channelMappingId,
    pricingDate
  ])
 
  @@index([propertyId])
 
  @@index([pricingDate])
}

enum ChannelCategory {
 
  OTA
 
  DIRECT
 
  MARKETPLACE
 
  WHOLESALER
 
  CORPORATE
 
  CHANNEL_MANAGER
}
 
enum ChannelConnectionStatus {
 
  PENDING
 
  CONNECTED
 
  ERROR
 
  DISCONNECTED
}

npx prisma migrate dev \
--name distribution_core

src/modules/distribution

├── channels
├── connections
├── mappings
├── inventory
├── pricing
├── rules
└── distribution.module.ts

ChannelService

ChannelConnectionService

ChannelMappingService

DistributionRuleService

ChannelInventoryService

ChannelPricingService

channel.service.ts

Airbnb

Booking.com

Expedia

Abritel

Direct Website

Mobile App

getChannels()
 
createChannel()
 
activateChannel()
 
deactivateChannel()

channel-connection.service.ts

connectChannel()
 
disconnectChannel()
 
refreshConnection()
 
validateCredentials()

API Keys

OAuth Tokens

Secrets

dans le coffre-fort sécurisé existant.

channel-mapping.service.ts

mapProperty()
 
unmapProperty()
 
validateMapping()
 
syncExternalListing()

Associer :

Property

↓

External Listing

sur chaque canal.

distribution-rule.service.ts

Inventory Rules

Pricing Rules

Channel Restrictions

Priority Rules

Si Occupancy > 90%

↓

+15% prix

Si Channel = OTA

↓

Min Stay = 2 nuits

channel-inventory.service.ts

syncInventory()
 
pushAvailability()
 
pullAvailability()
 
resolveInventoryConflict()

Temps réel

Batch

Webhook

channel-pricing.service.ts

syncPricing()
 
pushRates()
 
pullRates()
 
applyChannelMarkup()

Prix base

Prix OTA

Prix Corporate

Prix Promotion

GET    /distribution/channels
 
POST   /distribution/channels/connect
 
GET    /distribution/mappings
 
POST   /distribution/mappings
 
GET    /distribution/inventory
 
GET    /distribution/pricing
 
POST   /distribution/rules

{
  "channel":"Booking.com",
  "status":"CONNECTED",
  "mappedProperties":124
}

Portfolio

Property Group

Property

comme niveau de distribution.

distribution.read

distribution.connect

distribution.mapping

distribution.inventory

distribution.pricing

distribution.admin

CHANNEL_CONNECTED

CHANNEL_DISCONNECTED

PROPERTY_MAPPED

INVENTORY_SYNCED

PRICING_SYNCED

DISTRIBUTION_RULE_CREATED

Toutes les 5 minutes

Inventory Sync

Pricing Sync

Connection Health Check

Compatible avec :

OTA APIs

Webhook Sync

Channel Intelligence

Rate Optimization

Le Sprint 7-A.1 est terminé lorsque :

✓ Channel créé

✓ ChannelConnection créé

✓ ChannelMapping créé

✓ DistributionRule créé

✓ ChannelInventory créé

✓ ChannelPricing créé

✓ Distribution Core opérationnel

Channel

ChannelConnection

ChannelMapping

DistributionRule

ChannelInventory

ChannelPricing

ChannelService

ChannelConnectionService

ChannelMappingService

DistributionRuleService

ChannelInventoryService

ChannelPricingService

Distribution Core Platform

OTA Integrations & Synchronisation Temps Réel

Objectif :

Implémenter :

Airbnb API

Booking.com API

Expedia API

Webhook Engine

Rate Sync

Availability Sync

afin de connecter la plateforme aux principaux canaux de distribution.