| | |
| | | import com.vincent.rsf.server.manager.enums.AsnExceStatus; |
| | | import com.vincent.rsf.server.manager.enums.PakinIOStatus; |
| | | import com.vincent.rsf.server.manager.service.*; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | import org.springframework.beans.BeanUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.scheduling.annotation.Scheduled; |
| | |
| | | |
| | | @Component |
| | | public class PakinSchedules { |
| | | |
| | | private static final Logger LOGGER = LoggerFactory.getLogger(PakinSchedules.class); |
| | | |
| | | @Autowired |
| | | private WaitPakinService waitPakinService; |
| | |
| | | pkinItems.forEach(asnCode -> { |
| | | List<WkOrderItem> orderItems = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderCode, asnCode)); |
| | | if (orderItems.isEmpty()) { |
| | | throw new CoolException("数据错误,原单据不存在或已丢失!!"); |
| | | // LOGGER.warn("pakinLog 跳过 ASN:原单据不存在或已丢失,asnCode={}", asnCode); |
| | | return; |
| | | } |
| | | Set<Long> orderIds = orderItems.stream().map(WkOrderItem::getOrderId).collect(Collectors.toSet()); |
| | | // 该订单下按明细汇总的已组托数量(所有组托档中 asnCode 对应的 anfme 按 asnItemId 汇总) |
| | |
| | | orderIds.forEach(orderId -> { |
| | | WkOrder wkOrder = asnOrderService.getById(orderId); |
| | | if (Objects.isNull(wkOrder)) { |
| | | throw new CoolException("数据错误,原单据不存在或已丢失!!"); |
| | | // throw new CoolException("数据错误,原单据不存在或已丢失!!"); |
| | | // LOGGER.warn("pakinLog 跳过订单:原单据不存在或已丢失,orderId={}", orderId); |
| | | return; |
| | | } |
| | | List<WkOrderItem> items = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderId, orderId)); |
| | | if (items.isEmpty()) { |