# 更新

data-show/show-auto-turnover/src/main/java/com/bailuntec/job/QueueConsumerJob.java

@@ -51,6 +51,7 @@ public class QueueConsumerJob implements SimpleJob {
             List<DcBaseQueue> dcBaseQueueList = dcBaseQueueMapper.poll(shardingContext);
 
             dcBaseQueueList.parallelStream().forEach(dcBaseQueue -> {
+                AutoTurnoverJob.shardingContextThreadLocal.set(shardingContext);
                 BaseQueueMessage baseQueueMessage = JSON.parseObject(dcBaseQueue.getMessage(), BaseQueueMessage.class);
 
                 DcBaseStock dcBaseStock = dcBaseStockMapper.selectOneByExample(DcBaseStockExample.newAndCreateCriteria()

data-show/show-auto-turnover/src/test/java/AutoTurnoverTest.java

@@ -261,8 +261,8 @@ public class AutoTurnoverTest {
     public void testXX2() {
         DcBaseStock dcBaseStock = SessionUtil.getSession().getMapper(DcBaseStockMapper.class)
                 .selectOneByExample(DcBaseStockExample.newAndCreateCriteria()
-                        .andBailunSkuEqualTo("950786236")
-                        .andWarehouseCodeEqualTo("GB4PXBL")
+                        .andBailunSkuEqualTo("3395609119")
+                        .andWarehouseCodeEqualTo("GZBLWH")
                         .example());
         try {
             AutoTurnoverJob autoTurnoverJob = new AutoTurnoverJob();