Commit e2e31b6d authored by 赵啸非's avatar 赵啸非

优化设备管理系统callback 下发消息效率

parent 76e68cc5
...@@ -186,7 +186,7 @@ public class DeviceApiController { ...@@ -186,7 +186,7 @@ public class DeviceApiController {
ProductEntity productEntity = productService.getCache(deviceEntity.getProductId().toString()); ProductEntity productEntity = productService.getCache(deviceEntity.getProductId().toString());
if (ObjectUtils.isEmpty(productEntity)) { if (ObjectUtils.isEmpty(productEntity)) {
throw new AppException(PRODUCT_IS_EMPTY, PRODUCT_IS_EMPTY_CONTENT); throw new AppException(PRODUCT_IS_EMPTY, PRODUCT_IS_EMPTY_CONTENT+"productId:"+deviceEntity.getProductId());
} }
if (ObjectUtils.isEmpty(productEntity.getPlatformId())) { if (ObjectUtils.isEmpty(productEntity.getPlatformId())) {
......
...@@ -59,6 +59,7 @@ public class DeviceDownMsgService implements IApplicationStartedService { ...@@ -59,6 +59,7 @@ public class DeviceDownMsgService implements IApplicationStartedService {
try { try {
DeviceMsgReq deviceMsgReq = cacheService.lpop(KEY_DEVICE_DOWN_MSG_QUEUE, DeviceMsgReq.class); DeviceMsgReq deviceMsgReq = cacheService.lpop(KEY_DEVICE_DOWN_MSG_QUEUE, DeviceMsgReq.class);
if (!ObjectUtils.isEmpty(deviceMsgReq)) { if (!ObjectUtils.isEmpty(deviceMsgReq)) {
log.info("下发消息:{}",deviceMsgReq.getDeviceCode());
//根据设备编码查询设备 //根据设备编码查询设备
DeviceEntity deviceEntity = null; DeviceEntity deviceEntity = null;
try { try {
......
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