java110
2023-06-07 e050a2ab2fa176ebd0d2461681a41df34838c028
java110-service/src/main/java/com/java110/service/smo/impl/CmdServiceSMOImpl.java
@@ -53,7 +53,7 @@
    /**
     * 服务调度
     * cmd 服务调度
     *
     * @param reqJson 请求报文json
     * @param headers
@@ -70,11 +70,11 @@
        ResponseEntity<String> responseEntity = null;
        //1.0 创建数据流 appId serviceCode
        //todo 1.0 创建数据流 appId serviceCode
        cmdDataFlowContext = DataFlowFactory.newInstance(CmdDataFlow.class).builder(reqJson, headers);
        //6.0 调用下游系统
        //todo 2.0 调用下游系统
        invokeBusinessSystem(cmdDataFlowContext);
        responseEntity = cmdDataFlowContext.getResponseEntity();
@@ -89,12 +89,13 @@
    /**
     * 6.0 调用下游系统
     * 2.0 调用下游系统
     *
     * @param cmdDataFlowContext
     * @throws BusinessException
     */
    private void invokeBusinessSystem(ICmdDataFlowContext cmdDataFlowContext) throws Exception {
        //todo 发布 cmd 事件
        ServiceCmdEventPublishing.multicastEvent(cmdDataFlowContext);
    }