# 更新

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

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

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

@@ -62,7 +62,9 @@ public class QueueConsumerJob implements SimpleJob {
                         .andWarehouseCodeEqualTo(baseQueueMessage.getWarehouseCode())
                         .example());
                 try {
+                    AutoTurnoverJob.shardingContextThreadLocal.set(new ShardingContext(new ShardingContexts("x", null, 1, "NORMAL", 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.OCEAN_HEAD, new HashMap<>(16)), 0));
                     autoTurnoverJob.autoTurnoverFromStock(DateTimeFormatter.ofPattern(CommonConstant.DATE_FORMAT).format(LocalDate.now()), dcBaseStock);

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

@@ -262,14 +262,16 @@ public class AutoTurnoverTest {
     public void testXX2() {
         DcBaseStock dcBaseStock = SessionUtil.getSession().getMapper(DcBaseStockMapper.class)
                 .selectOneByExample(DcBaseStockExample.newAndCreateCriteria()
-                        .andBailunSkuEqualTo("N-GNS006-7ML")
-                        .andWarehouseCodeEqualTo("BLGZ03")
+                        .andBailunSkuEqualTo("LM-EO-007")
+                        .andWarehouseCodeEqualTo("MMDUSFBA")
                         .example());
         try {
             AutoTurnoverJob autoTurnoverJob = new AutoTurnoverJob();
             long time = System.currentTimeMillis();
             log.info(Long.toString(time));
-            AutoTurnoverJob.shardingContextThreadLocal.set(new ShardingContext(new ShardingContexts("x", null, 8, Constant.AIR_HEAD, new HashMap<>()), 0));
+//            AutoTurnoverJob.shardingContextThreadLocal.set(new ShardingContext(new ShardingContexts("x", null, 8, Constant.AIR_HEAD, new HashMap<>()), 0));
+
+            AutoTurnoverJob.shardingContextThreadLocal.set(new ShardingContext(new ShardingContexts("x", null, 1, "NORMAL", new HashMap<>(16)), 0));
             autoTurnoverJob.autoTurnoverFromStock(DateTimeFormatter.ofPattern(CommonConstant.DATE_FORMAT).format(LocalDate.now()), dcBaseStock);
             log.info(String.valueOf((System.currentTimeMillis() - time)));