gongfuzhu преди 1 година
родител
ревизия
e5c893303c
променени са 1 файла, в които са добавени 3 реда и са изтрити 0 реда
  1. 3 0
      SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/stream/OrderStream.java

+ 3 - 0
SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/stream/OrderStream.java

@@ -52,6 +52,9 @@ public class OrderStream extends StreamConsumer<OrderStremModel> {
 
         for (GoodsResultModel goodsResultModel : listResultContent.getContent()) {
 
+            if (goodsResultModel.isDelivery()){
+                return;
+            }
             if (orderStremModel.getOrderType().equals(OrderType.HAVE_PAID)) {
                 ThreadLocal<GoodsResultModel> parameter = standarDeliveryJob.getParameter();
                 parameter.set(goodsResultModel);