11

啊鑫

2025-05-07 dff0470bf77f3fa525a9d1f1f761dd9609072205

11

 src/main/java/com/gs/xiaomi/service/XM104Service.java

@@ -22,6 +22,11 @@
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.function.Function;
import java.util.function.Predicate;
import java.util.stream.Collectors;

@Service
@Transactional(rollbackFor = Exception.class)
@@ -75,7 +80,9 @@
            //获取所有的ASN号
            List<EtHeader> etHeaders = deliveryNo.getEtHeaders();

            etHeaders.forEach(etHeader -> {
            List<EtHeader> collect = etHeaders.stream().filter(distinctByKey(EtHeader::getZzasn)).collect(Collectors.toList());

            collect.forEach(etHeader -> {

                log.info("1.获取到送货单号: {}", etHeader.getZzasn());

@@ -114,6 +121,11 @@
        BizDocumentResult bizDocumentResult = soapApiService.callAndParse(DataAcquisitionConfiguration.XM104_URL, request);

        return bizDocumentResult;
    }

    private <T> Predicate<T> distinctByKey(Function<? super T, ?> keyExtractor) {
        Map<Object, Boolean> seen = new ConcurrentHashMap<>();
        return t -> seen.putIfAbsent(keyExtractor.apply(t), Boolean.TRUE) == null;
    }

    private void setDeliveryMain(BizDocumentResult result) {
@@ -196,7 +208,7 @@

            }

            deliveryMainService.callPdaReceiptBtn("送货单签收[BTNOK[PL017[" + etHeader.getZzasn(), "");
            //deliveryMainService.callPdaReceiptBtn("送货单签收[BTNOK[PL017[" + etHeader.getZzasn(), "");
        });
    }