# 更新

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

@@ -79,8 +79,8 @@ public class Application {
 
     private static LiteJobConfiguration createQueueConsumer() {
         JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(
-                "queueConsumer2",
-                "0/1 * * * * ? ",
+                "queueConsumer3",
+                "0/10 * * * * ? ",
                 8)
                 .build();
         SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, QueueConsumerJob.class.getCanonicalName());

data-show/show-auto-turnover/src/test/java/com/bailuntec/job/QueueConsumerJobTest.java

@@ -27,11 +27,11 @@ public class QueueConsumerJobTest {
 
     @Test
     public void test() {
-        ShardingContext shardingContext = new ShardingContext(new ShardingContexts("x", null, 1, Constant.AIR_HEAD, new HashMap<>()), 0);
-        AutoTurnoverJob.shardingContextThreadLocal.set(shardingContext);
+//        ShardingContext shardingContext = new ShardingContext(new ShardingContexts("x", null, 1, Constant.AIR_HEAD, new HashMap<>()), 0);
+//        AutoTurnoverJob.shardingContextThreadLocal.set(shardingContext);
         QueueConsumerJob.BaseQueueMessage baseQueueMessage = new QueueConsumerJob.BaseQueueMessage();
-        baseQueueMessage.setBailunSku("228427301");
-        baseQueueMessage.setWarehouseCode("BLFBW01");
+        baseQueueMessage.setBailunSku("LM-EO-007");
+        baseQueueMessage.setWarehouseCode("MMDUSFBA");
 
         DcBaseStockMapper dcBaseStockMapper = SessionUtil.getSession().getMapper(DcBaseStockMapper.class);
         AutoTurnoverJob autoTurnoverJob = new AutoTurnoverJob();
@@ -45,7 +45,7 @@ public class QueueConsumerJobTest {
 //        AutoTurnoverJob.shardingContextThreadLocal.set(new ShardingContext(new ShardingContexts("x", null, 1, Constant.OCEAN_HEAD, new HashMap<>(16)), 0));
 //        autoTurnoverJob.autoTurnoverFromStock(DateTimeFormatter.ofPattern(CommonConstant.DATE_FORMAT).format(LocalDate.now()), dcBaseStock);
 //        AutoTurnoverJob.shardingContextThreadLocal.remove();
-        AutoTurnoverJob.shardingContextThreadLocal.set(new ShardingContext(new ShardingContexts("x", null, 1, Constant.AIR_HEAD, new HashMap<>(16)), 0));
+        AutoTurnoverJob.shardingContextThreadLocal.set(new ShardingContext(new ShardingContexts("x", null, 1, Constant.OCEAN_HEAD, new HashMap<>(16)), 0));
         autoTurnoverJob.autoTurnoverFromStock(DateTimeFormatter.ofPattern(CommonConstant.DATE_FORMAT).format(LocalDate.now()), dcBaseStock);
         AutoTurnoverJob.shardingContextThreadLocal.remove();