Skip to content

D
device-new-platform
Commit 578418f9 authored by 赵啸非's avatar 赵啸非
Browse files
Options

添加开启与关闭消费队列

parent 0a9d2536
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 3 deletions
device-manager/src/main/java/com/mortals/xhx/module/device/web/DeviceController.java
View file @ 578418f9
...@@ -206,14 +206,14 @@ public class DeviceController extends BaseCRUDJsonBodyMappingController<DeviceSe ...@@ -206,14 +206,14 @@ public class DeviceController extends BaseCRUDJsonBodyMappingController<DeviceSe
public String stopOrStartComsumeQueue(@RequestBody DeviceEntity deviceEntity) { public String stopOrStartComsumeQueue(@RequestBody DeviceEntity deviceEntity) {
JSONObject jsonObject = new JSONObject(); JSONObject jsonObject = new JSONObject();
Map<String, Object> model = new HashMap<>(); Map<String, Object> model = new HashMap<>();
String busiDesc = this.getModuleDesc() + "设备启用停用"; String busiDesc = this.getModuleDesc() + "设备消费队列启用停用";
try { try {
this.service.deviceEnabled(deviceEntity.getId(), deviceEntity.getEnabled(), getContext()); this.service.stopOrStartComsumeQueue(deviceEntity.getId(), deviceEntity.getEnabled(), getContext());
recordSysLog(request, busiDesc + " 【成功】"); recordSysLog(request, busiDesc + " 【成功】");
jsonObject.put(KEY_RESULT_DATA, model); jsonObject.put(KEY_RESULT_DATA, model);
jsonObject.put(KEY_RESULT_CODE, VALUE_RESULT_SUCCESS); jsonObject.put(KEY_RESULT_CODE, VALUE_RESULT_SUCCESS);
} catch (Exception e) { } catch (Exception e) {
log.error("设备启用停用消息", e); log.error("设备消费队列启用停用", e);
jsonObject.put(KEY_RESULT_CODE, VALUE_RESULT_FAILURE); jsonObject.put(KEY_RESULT_CODE, VALUE_RESULT_FAILURE);
jsonObject.put(KEY_RESULT_MSG, super.convertException(e)); jsonObject.put(KEY_RESULT_MSG, super.convertException(e));
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment