自动周转异常SKU-仓库记录持久化到db

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

@@ -63,7 +63,8 @@ public class AutoTurnoverJob extends PointJob {
                 List<DcBaseStock> dcBaseStockList = null;//分页查SKU_仓库
                 try {
                     DcBaseStockMapper baseStockMapperFor = SessionUtil.getSession().getMapper(DcBaseStockMapper.class);
-                    dcBaseStockList = baseStockMapperFor.listOrderByFba(page * jobPointLog.getPageSize(), jobPointLog.getPageSize());
+                    //这里是根据id排序,方法名没改了
+                   dcBaseStockList = baseStockMapperFor.listOrderByFba(page * jobPointLog.getPageSize(), jobPointLog.getPageSize());
                 } catch (Exception e) {
                     e.printStackTrace();
                     throw new RuntimeException("Mybatis操作DB分页查询失败", e);

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

@@ -58,10 +58,10 @@ public class AutoTurnoverJobListener implements ElasticJobListener {
                         DcBaseStock dcBaseStock = dcBaseStockMapper.selectOneByExample(DcBaseStockExample.newAndCreateCriteria().andBailunSkuEqualTo(dcAutoException.getBailunSku()).andWarehouseCodeEqualTo(dcAutoException.getWarehouseCode()).example());
                         try {
                             autoTurnoverJob.autoTurnoverFromStock(queryTime, dcBaseStock);
+                            mapper.deleteByPrimaryKey(dcAutoException.getId());
                         } catch (Exception e) {
                             log.error("Mybatis操作自动周转异常数据再次计算失败SKU=" + dcAutoException.getBailunSku() + ",仓库编码=" + dcAutoException.getWarehouseCode());
                         }
-                        mapper.deleteByPrimaryKey(dcAutoException.getId());
                     }
                 }
                 pageIndex++;