CommandService创建指令
外部厂商 / 第三方平台 / 设备
IP白名单识别
ProtocolDispatcher.dispatch
同步完成受理校验并返回受理结果
AppIdPartnerResolver
Adapter转换为厂商受理响应
ProtocolRequest.from
ProtocolResponse
等待后续notification_xxx_result
内部业务服务异步消费
ProtocolAuthenticator.authenticate
具体厂商Adapter
ProtocolRouteRepository.findCandidateRoutes
返回已受理 / 失败
立即返回外部厂商
BodyPartnerResolver
查询Redis / MySQL / TDengine / MongoDB
下发设备 / 调厂商平台 / 写指令状态
PartnerResolver识别厂商
TokenPartnerResolver
SYNC_ACCEPT_ASYNC_RESULT
Adapter返回接收成功
ProtocolGatewayController
process_mode处理模式
Adapter转换为厂商响应
SYNC 同步处理
ASYNC 异步处理
ResolvedRoute
ProtocolAdapterRegistry.getAdapter
转换统一事件并投递MQ
同步调用内部业务服务
Kafka / RocketMQ
ProtocolRouteResolver.resolve
DeviceStatusService / StationService / PolicyService / OrderService
返回内部统一结果
