# 更新

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

@@ -63,10 +63,14 @@ public class QueueConsumerJob implements SimpleJob {
                         .example());
                 try {
                     autoTurnoverJob.autoTurnoverFromStock(DateTimeFormatter.ofPattern(CommonConstant.DATE_FORMAT).format(LocalDate.now()), dcBaseStock);
+
                     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.autoTurnoverFromStock(DateTimeFormatter.ofPattern(CommonConstant.DATE_FORMAT).format(LocalDate.now()), dcBaseStock);
+                    AutoTurnoverJob.shardingContextThreadLocal.remove();
 
                     dcBaseQueueMapper.deleteByPrimaryKey(dcBaseQueue.getId());
                 } catch (Exception e) {

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

@@ -256,14 +256,14 @@ public class AutoTurnoverTest {
 
     //{"bailun_sku":"N-GNS631-7ML","warehouse_code":"BLGZ03"}
 
-
+    //{"bailun_sku":"N-GNS006-7ML","warehouse_code":"BLGZ03"}
     @Transactional
     @Test
     public void testXX2() {
         DcBaseStock dcBaseStock = SessionUtil.getSession().getMapper(DcBaseStockMapper.class)
                 .selectOneByExample(DcBaseStockExample.newAndCreateCriteria()
-                        .andBailunSkuEqualTo("228427301")
-                        .andWarehouseCodeEqualTo("BLFBW01")
+                        .andBailunSkuEqualTo("N-GNS006-7ML")
+                        .andWarehouseCodeEqualTo("BLGZ03")
                         .example());
         try {
             AutoTurnoverJob autoTurnoverJob = new AutoTurnoverJob();

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

+package com.bailuntec.job;
+
+import com.bailuntec.domain.constant.CommonConstant;
+import com.bailuntec.domain.constant.Constant;
+import com.bailuntec.domain.entity.DcBaseStock;
+import com.bailuntec.domain.example.DcBaseStockExample;
+import com.bailuntec.mapper.DcBaseStockMapper;
+import com.bailuntec.utils.SessionUtil;
+import com.dangdang.ddframe.job.api.ShardingContext;
+import com.dangdang.ddframe.job.executor.ShardingContexts;
+import org.junit.jupiter.api.Test;
+
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+import java.util.HashMap;
+
+/**
+ * <p>
+ *
+ * </p>
+ *
+ * @author robbendev
+ * @since 2021/2/25 10:02 上午
+ */
+
+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);
+        QueueConsumerJob.BaseQueueMessage baseQueueMessage = new QueueConsumerJob.BaseQueueMessage();
+        baseQueueMessage.setBailunSku("228427301");
+        baseQueueMessage.setWarehouseCode("BLFBW01");
+
+        DcBaseStockMapper dcBaseStockMapper = SessionUtil.getSession().getMapper(DcBaseStockMapper.class);
+        AutoTurnoverJob autoTurnoverJob = new AutoTurnoverJob();
+
+        DcBaseStock dcBaseStock = dcBaseStockMapper.selectOneByExample(DcBaseStockExample.newAndCreateCriteria()
+                .andBailunSkuEqualTo(baseQueueMessage.getBailunSku())
+                .andWarehouseCodeEqualTo(baseQueueMessage.getWarehouseCode())
+                .example());
+
+//        autoTurnoverJob.autoTurnoverFromStock(DateTimeFormatter.ofPattern(CommonConstant.DATE_FORMAT).format(LocalDate.now()), dcBaseStock);
+//        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.autoTurnoverFromStock(DateTimeFormatter.ofPattern(CommonConstant.DATE_FORMAT).format(LocalDate.now()), dcBaseStock);
+        AutoTurnoverJob.shardingContextThreadLocal.remove();
+
+
+    }
+
+}