|
@@ -1,5 +1,6 @@
|
|
|
package com.fdkankan.openApi.mq.listener;
|
|
|
|
|
|
+import cn.hutool.core.util.StrUtil;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import com.fdkankan.openApi.mq.dto.CallApiDTO;
|
|
|
import com.fdkankan.openApi.service.system.IUserAuthService;
|
|
@@ -52,11 +53,13 @@ public class CallApiListener {
|
|
|
try {
|
|
|
log.info("callApi开始,id:{},deliveryTag:{},消息体:{}", messageId, deliveryTag, msg);
|
|
|
CallApiDTO param = JSONObject.parseObject(msg, CallApiDTO.class);
|
|
|
-
|
|
|
- int i = userAuthService.updateCallCounts(param.getAppKey());
|
|
|
- log.info("修改数据量为{}", i);
|
|
|
+ if (StrUtil.isNotEmpty(param.getAppKey())){
|
|
|
+ int i = userAuthService.updateCallCounts(param.getAppKey());
|
|
|
+ log.info("修改数据量为{}", i);
|
|
|
+ }
|
|
|
channel.basicAck(deliveryTag, false);
|
|
|
|
|
|
+
|
|
|
} catch (DeadlockLoserDataAccessException e) {
|
|
|
log.info("修改死锁重新入队");
|
|
|
channel.basicReject(deliveryTag, true);
|