| | |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson2.JSONObject; |
|---|
| | | import com.dy.common.mw.protocol.Command; |
|---|
| | | import com.dy.common.util.Callback; |
|---|
| | | import com.dy.common.util.IDLongGenerator; |
|---|
| | | import com.dy.common.webUtil.BaseResponse; |
|---|
| | | import com.dy.common.webUtil.BaseResponseUtils; |
|---|
| | |
|---|
| | | * 发送命令后 |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | public BaseResponse<Object> after(String comCode) { |
|---|
| | | public BaseResponse<Object> after(String comCode, Callback callback) { |
|---|
| | | try{ |
|---|
| | | //等待通信中间件通知控制器执行命令上行数据（命令结果） |
|---|
| | | JSONObject resultData = feature.get(waitMwRtnResultTimeout, TimeUnit.SECONDS); |
|---|
| | | return BaseResponseUtils.buildSuccess(this.createRtnMsg(comCode, resultData)); |
|---|
| | | return BaseResponseUtils.buildSuccess(this.dealComResult(comCode, resultData, callback)); |
|---|
| | | }catch (Exception e){ |
|---|
| | | return BaseResponseUtils.buildFail("等待通信中间件通知命令结果超时"); |
|---|
| | | } |
|---|
| | |
|---|
| | | /** |
|---|
| | | * 生成命令返回信息 |
|---|
| | | */ |
|---|
| | | protected abstract String createRtnMsg(String code, JSONObject resultData); |
|---|
| | | protected abstract String dealComResult(String code, JSONObject resultData, Callback callback); |
|---|
| | | } |
|---|
