| | |
|---|
| | | public <T extends BaseResponseInnerFrame<T>> WrapResponseCommonFrame<T> sendRRPC(String deviceName, IRequestFrame iRequestFrame, Class<T> clz){ |
|---|
| | | CommonFrame commonFrame = sendRRPC(deviceName, iRequestFrame); |
|---|
| | | if (commonFrame == null) { |
|---|
| | | throw new BusinessException("rrpc请求失败"); |
|---|
| | | return null; |
|---|
| | | } |
|---|
| | | WrapResponseCommonFrame<T> responseCommonFrame = new WrapResponseCommonFrame<>(); |
|---|
| | | BeanUtils.copyProperties(commonFrame, responseCommonFrame); |
|---|
| | |
|---|
| | | result = result.replace("\\", ""); |
|---|
| | | Map map = JSON.parseObject(result, Map.class); |
|---|
| | | result = (String) map.get("msg"); |
|---|
| | | CommonFrame connectFrame = FrameUtils.transformMessageToFrame(result); |
|---|
| | | return connectFrame; |
|---|
| | | return FrameUtils.transformMessageToFrame(result); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | request.setIdentifier("rrpc"); |
|---|
| | | request.setArgs(JSON.toJSONString(param)); |
|---|
| | | |
|---|
| | | //todo |
|---|
| | | // 获得服务调用响应 |
|---|
| | | InvokeThingServiceResponse response = null; |
|---|
| | | try { |
|---|
