# 更新

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

@@ -45,33 +45,35 @@ public class QueueConsumerJob implements SimpleJob {
 
         SqlSession sqlSession = SessionUtil.getFactory().openSession(true);
         try {
-            AutoTurnoverJob autoTurnoverJob = new AutoTurnoverJob();
-            DcBaseQueueMapper dcBaseQueueMapper = sqlSession.getMapper(DcBaseQueueMapper.class);
-            DcBaseStockMapper dcBaseStockMapper = sqlSession.getMapper(DcBaseStockMapper.class);
+            if (shardingContext.getShardingItem() == 0) {
+                AutoTurnoverJob autoTurnoverJob = new AutoTurnoverJob();
+                DcBaseQueueMapper dcBaseQueueMapper = sqlSession.getMapper(DcBaseQueueMapper.class);
+                DcBaseStockMapper dcBaseStockMapper = sqlSession.getMapper(DcBaseStockMapper.class);
 
-            List<DcBaseQueue> dcBaseQueueList = dcBaseQueueMapper.selectByExample(DcBaseQueueExample.newAndCreateCriteria()
-                    .andConsumeDateIsNull()
-                    .example()
-                    .limit(1000));
+                List<DcBaseQueue> dcBaseQueueList = dcBaseQueueMapper.selectByExample(DcBaseQueueExample.newAndCreateCriteria()
+                        .andConsumeDateIsNull()
+                        .example()
+                        .limit(1000));
 
-            dcBaseQueueList.forEach(dcBaseQueue -> {
-                BaseQueueMessage baseQueueMessage = JSON.parseObject(dcBaseQueue.getMessage(), BaseQueueMessage.class);
+                dcBaseQueueList.forEach(dcBaseQueue -> {
+                    BaseQueueMessage baseQueueMessage = JSON.parseObject(dcBaseQueue.getMessage(), BaseQueueMessage.class);
 
-                DcBaseStock dcBaseStock = dcBaseStockMapper.selectOneByExample(DcBaseStockExample.newAndCreateCriteria()
-                        .andBailunSkuEqualTo(baseQueueMessage.getBailunSku())
-                        .andWarehouseCodeEqualTo(baseQueueMessage.getWarehouseCode())
-                        .example());
-                try {
-                    autoTurnoverJob.autoTurnoverFromStock(DateTimeFormatter.ofPattern(CommonConstant.DATE_FORMAT).format(LocalDate.now()), dcBaseStock);
-                    dcBaseQueueMapper.deleteByPrimaryKey(dcBaseQueue.getId());
-                } catch (Exception e) {
-                    dcBaseQueue.setErrorMessage(e.getMessage());
-                    dcBaseQueue.setErrorStackTrace(e.getStackTrace().toString());
-                } finally {
-                    log.info("消费一条数据 message:{}", dcBaseQueue.getMessage());
-                }
+                    DcBaseStock dcBaseStock = dcBaseStockMapper.selectOneByExample(DcBaseStockExample.newAndCreateCriteria()
+                            .andBailunSkuEqualTo(baseQueueMessage.getBailunSku())
+                            .andWarehouseCodeEqualTo(baseQueueMessage.getWarehouseCode())
+                            .example());
+                    try {
+                        autoTurnoverJob.autoTurnoverFromStock(DateTimeFormatter.ofPattern(CommonConstant.DATE_FORMAT).format(LocalDate.now()), dcBaseStock);
+                        dcBaseQueueMapper.deleteByPrimaryKey(dcBaseQueue.getId());
+                    } catch (Exception e) {
+                        dcBaseQueue.setErrorMessage(e.getMessage());
+                        dcBaseQueue.setErrorStackTrace(e.getStackTrace().toString());
+                    } finally {
+                        log.info("消费一条数据 message:{}", dcBaseQueue.getMessage());
+                    }
 
-            });
+                });
+            }
         } finally {
             sqlSession.close();
         }