| | |
| | | import com.java110.core.event.cmd.ServiceCmdEventPublishing; |
| | | import com.java110.core.factory.DataFlowFactory; |
| | | import com.java110.core.smo.ISaveTransactionLogSMO; |
| | | import com.java110.core.trace.Java110TraceLog; |
| | | import com.java110.entity.center.DataFlowLinksCost; |
| | | import com.java110.service.smo.ICmdServiceSMO; |
| | | import com.java110.utils.cache.MappingCache; |
| | |
| | | import com.java110.utils.kafka.KafkaFactory; |
| | | import com.java110.utils.log.LoggerEngine; |
| | | import com.java110.utils.util.DateUtil; |
| | | import com.java110.vo.ResultVo; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | import com.java110.core.log.LoggerFactory; |
| | | |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.http.HttpStatus; |
| | | import org.springframework.http.ResponseEntity; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | |
| | | * @throws SMOException |
| | | */ |
| | | @Override |
| | | @Java110TraceLog |
| | | public ResponseEntity<String> cmd(String reqJson, Map<String, String> headers) throws Exception { |
| | | |
| | | ICmdDataFlowContext cmdDataFlowContext = null; |
| | |
| | | Date startDate = DateUtil.getCurrentDate(); |
| | | |
| | | ResponseEntity<String> responseEntity = null; |
| | | |
| | | String resJson = ""; |
| | | |
| | | |
| | | //1.0 创建数据流 appId serviceCode |
| | | cmdDataFlowContext = DataFlowFactory.newInstance(CmdDataFlow.class).builder(reqJson, headers); |
| | |
| | | Date endDate = DateUtil.getCurrentDate(); |
| | | |
| | | if (responseEntity == null) { |
| | | //resJson = encrypt(responseJson.toJSONString(),headers); |
| | | responseEntity = new ResponseEntity<String>(resJson, HttpStatus.OK); |
| | | responseEntity = ResultVo.success(); |
| | | } |
| | | return responseEntity; |
| | | } |