滴滴出行平台业务架构演进

//配置文件，管理流程环节，以及提供给不同品类注册各自transport{  "name": "ConfirmOrder,  "transports": {    "default": "\\DuKang\\Transport\\ConfirmOrderaseTransport",    "express": "\\DuKang\\Express\\Transport\\ConfirmOrderExpressTransport",    "luxury": "\\DuKang\\Luxury\\Transport\\ConfirmOrderLuxuryTransport",    "taxi": "\\DuKang\\Taxi\\Transport\\ConfirmOrderTaxiTransport",},  "steps": [    {      "step_id": "fetchInfoStep",      "description": "获取基本信息"    },    {      "step_id": "confirmTravelStep",      "description": "确认行程信息"    },    {      "step_id": "confirmBillStep",      "description": "确认计价信息"    },    {      "step_id": "checkStep",      "description": "成单检查"    },    {      "step_id": "fillOrderDetailStep",      "description": "订单维度填充"    },    {      "step_id": "sendOrderCommandStep",      "description": "订单处理操作"    },    {      "step_id": "sendDriverCommandStep",      "description": "司机处理操作"    },    {      "step_id": "sendSchedulingCommandStep",      "description": "调度处理操作"    },    {      "step_id": "buildResponseStep",      "description": "构建响应"    },    {      "step_id": "asyncOperationStep",      "description": "异步操作"    },    {      "step_id": "writeLogStep",      "description": "日志处理"    }  ]}
// dukang框架核心执行过程try {    // 加载并解析接口配置，包括BizConfig、StepConfig    $oBizConf = BizConfig::load($sConfigStr);
    // 获取输入源数据，包括Request和基础数据获取    $oInputSource = new ConfirmOrdernputSource();
    // 构造StepRuntime    $oStepRuntime = new ConfirmOrdertepRuntime($oInputSource);
    // 将接口配置对象、StepRuntime放入流程调度器    $oFlowScheduler = new FlowScheduler($oBizConf, $oStepRuntime);
    // 初始化传输器路由因子    $oTransportSelectFactor = new ConfirmOrderTransportSelectFactor($oInputSource);        if($oFlowScheduler->selectTransport($oTransportSelectFactor))    {        // 执行流程调度        $oFlowScheduler->run();    }    // 异常处理原则：接口外层只处理DuKangException和Exception，Step或者Ability处理异常则先处理逻辑再抛异常} catch (DuKangException $e) {    $aResp = [        'errno'  => $e->getCode(),        'errmsg' => $e->getMessage(),    ];    echo json_encode($aResp);} catch (\Exception $e) {    $aResp = [        'errno'  => $e->getCode(),        'errmsg' => $e->getMessage(),    ];    echo json_encode($aResp);}

// 模块根目录├── Dukang // 新引入的内容，区隔老代码，未来将替代hermes│   ├── Ability // 能力目录│   │   ├── Common // 公用能力│   │   │   ├── DispatchOrder│   │   │   │   └── DispatchOrderComponent.php│   │   │   └── VirtualPhone│   │   │       └── VirtualPhoneComponent.php│   │   └── Express // 品类特有能力扩展│   │       └── DispatchOrder│   │           └── DispatchOrderComponent.php│   ├── Config // 接口配置│   │   └── ConfirmOrder.json│   ├── InputSource // 接口输入│   │   └── ConfirmOrderInputSource.php│   ├── StepRuntime // 全局数据总线│   │   └── ConfirmOrderStepRuntime.php│   ├── Model   // 公用model│   │   ├── Dao│   │   ├── Driver│   │   │   └── DriverModel.php│   │   └── Order│   │       └── OrderModel.php│   ├── Service  // 公用service│   │   └── Driver│   │       └── DriverService.php│   ├── TransportFactor // Transport因子│   │   └── ConfirmOrderTransportFactor.php│   └── Transport // 流程串接│       ├── Base│       │   └── ConfirmOrderBaseTransport.php│       └── Taxi│           └── ConfirmOrderTaxiTransport.php└── vendor    └── dukang        └── framework            ├── idl  // 数据字典（Dimensions，标准dto）            └── src  // 框架代码