定时任务-礼物-mq-补偿前double check

accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/gift/GiftMessageService.java

@@ -48,6 +48,12 @@ public class GiftMessageService extends BaseService {
             logger.warn("handleGiftMessage giftMessage had handle, mess: " + giftMessage);
             return;
         }
+
+        if (!jedisService.hexists(RedisKey.mq_gift_status.getKey(), giftMessage.getMessId())){
+            logger.warn("handleGiftMessage giftMessage had handle, mess: " + giftMessage);
+            return;
+        }
+
         logger.info("【处理礼物mq】 giftMessage: {}", giftMessage);
 
         long totalGoldNum = giftMessage.getGoldNum();

accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/GiftMessageConsumer.java

@@ -27,11 +27,6 @@ public class GiftMessageConsumer extends AbstractMessageListener<GiftMessage> {
     @Override
     public void onMessage(GiftMessage giftMessage) {
         log.info("onMessage giftMessage: {}", giftMessage.toString());
-        // 判断该消息是否已经消费过
-        String messStatus = jedisService.hget(RedisKey.mq_gift_status.getKey(), giftMessage.getMessId());
-        if (BlankUtil.isBlank(messStatus)) {
-            return;
-        }
         giftMessageService.handleGiftMessage(giftMessage);
     }