add offline queue5

720yun_fd_consumer/src/main/java/com/gis/listener/container/WorkOfflineListener.java

@@ -104,11 +104,12 @@ public class WorkOfflineListener implements ChannelAwareMessageListener {
         WorkOfflineDTO param = JSONObject.parseObject(msg, WorkOfflineDTO.class);
         String key = RedisConstant.WORK_OFFLINE + param.getWorkId();
         String progressKey = RedisConstant.WORK_OFFLINE_PROGRESS + param.getWorkId();
+        if (redisUtil.hasKey(key)) {
+            log.error("场景WorkOffline正在已处理,id:{},deliveryTag:{},消息体:{}", messageId, deliveryTag, msg);
+            channel.basicAck(deliveryTag, false);
+            return;
+        }
         try {
-            if (redisUtil.hasKey(key)) {
-                log.error("场景WorkOffline正在已处理,id:{},deliveryTag:{},消息体:{}", messageId, deliveryTag, msg);
-                return;
-            }
             //value存入进度
             redisUtil.set(key, DateUtil.now(), 5, TimeUnit.HOURS);