瀏覽代碼

add offline queue3

xiewj 4 月之前
父節點
當前提交
4a65c8b962
共有 1 個文件被更改,包括 1 次插入2 次删除
  1. 1 2
      720yun_fd_consumer/src/main/java/com/gis/listener/container/WorkOfflineListener.java

+ 1 - 2
720yun_fd_consumer/src/main/java/com/gis/listener/container/WorkOfflineListener.java

@@ -97,7 +97,6 @@ public class WorkOfflineListener implements ChannelAwareMessageListener {
         try {
             if (redisUtil.hasKey(key)) {
                 log.error("场景WorkOffline正在已处理,id:{},deliveryTag:{},消息体:{}", messageId, deliveryTag, msg);
-                channel.basicAck(deliveryTag, false);
                 return;
             }
             //value存入进度
@@ -139,7 +138,7 @@ public class WorkOfflineListener implements ChannelAwareMessageListener {
                 List<WorkNavigationEntity> workNavigationEntities = workNavigationService.selectByWorkId(workEntity.getId());
 
                 int totalItems = workNavigationEntities.size();
-                int progressIncrement = (totalItems > 0) ? (70 - 20) / totalItems : 0; // 进度从20增加到70%
+                int progressIncrement = (totalItems > 0) ? 50 / totalItems : 0; // 进度从20增加到70%
                 int currentProgress = 20;
 
                 for (WorkNavigationEntity workNavigationEntity : workNavigationEntities) {