# 更新

data-common/src/main/java/com/bailuntec/mapper/DcBaseQueueMapper.xml

@@ -570,6 +570,7 @@
         select *
         from dc_base_queue
         where consume_date is null
+          and queue_type = 1
           and id % #{shardingContext.shardingTotalCount} = #{shardingContext.shardingItem}
         limit 1000
     </select>