# 更新

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

@@ -43,8 +43,7 @@ public class QueueConsumerJob implements SimpleJob {
     @Override
     public void execute(ShardingContext shardingContext) {
 
-        SqlSession sqlSession = SessionUtil.getFactory().openSession(true);
-        try {
+        try (SqlSession sqlSession = SessionUtil.getFactory().openSession(true)) {
             if (shardingContext.getShardingItem() == 0) {
                 AutoTurnoverJob autoTurnoverJob = new AutoTurnoverJob();
                 DcBaseQueueMapper dcBaseQueueMapper = sqlSession.getMapper(DcBaseQueueMapper.class);
@@ -66,16 +65,19 @@ public class QueueConsumerJob implements SimpleJob {
                         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());
+                        try {
+                            dcBaseQueue.setErrorMessage(e.getMessage());
+                            dcBaseQueue.setErrorStackTrace(e.getStackTrace().toString());
+                            dcBaseQueueMapper.updateByPrimaryKey(dcBaseQueue);
+                        } catch (Exception ex) {
+                            log.error(ex.getMessage());
+                        }
                     } finally {
                         log.info("消费一条数据 message:{}", dcBaseQueue.getMessage());
                     }
 
                 });
             }
-        } finally {
-            sqlSession.close();
         }
     }
 }

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

@@ -258,8 +258,8 @@ public class AutoTurnoverTest {
     public void testXX2() {
         DcBaseStock dcBaseStock = SessionUtil.getSession().getMapper(DcBaseStockMapper.class)
                 .selectOneByExample(DcBaseStockExample.newAndCreateCriteria()
-                        .andBailunSkuEqualTo("217632401")
-                        .andWarehouseCodeEqualTo("MMDUSFBA")
+                        .andBailunSkuEqualTo("BLGP-E1549")
+                        .andWarehouseCodeEqualTo("BIAT74")
                         .example());
         try {
             AutoTurnoverJob autoTurnoverJob = new AutoTurnoverJob();