完成收货直接入库的逻辑

nflg-wms-admin/src/main/java/com/nflg/wms/admin/controller/NormalPGIController.java

@@ -213,11 +213,39 @@ public class NormalPGIController extends BaseController {
 
         List<SrmMaterialReceiptScanCodes> srmMaterialReceiptScanCodes = new ArrayList<>();
         List<QCMaterialSyncDTO> qcMaterialSyncDTOS = new ArrayList<>();
+        List<InventoryDTO> inventories = new ArrayList<>();
+        List<ZWM3A17DTO> zwm3A17DTOS = new ArrayList<>();
+        List<WmsQrCodeMaster> qrCodes = new ArrayList<>();
 
         for (SrmMaterialReceiptQO item : request) {
 
             if (item.getReceiptNum().equals(BigDecimal.ZERO))
                 continue;
+// 处理二维码
+            for (PDAScanCodeQO code : item.getScanCodes()) {
+                WmsQrCodeMaster qrCodeMaster = qrCodeMasterService.lambdaQuery()
+                        .eq(WmsQrCodeMaster::getBarcodeCode, code.getCodeId())
+                        .one();
+                VUtil.trueThrowBusinessError(Objects.isNull(qrCodeMaster)).throwMessage("无效码【" + code.getCodeId() + "】");
+                if (qrCodeMaster.getPackagingType().equals(1)) {
+                    code.setCodeNum(BigDecimal.ZERO);
+                    List<WmsQrCodeMaster> childCode= qrCodeMasterService.lambdaQuery()
+                            .eq(WmsQrCodeMaster::getParentBarcodeId, qrCodeMaster.getId())
+                            .list();
+                    VUtil.trueThrowBusinessError(CollectionUtil.isEmpty(childCode)).throwMessage("箱码【" + code.getCodeId() + "】为空箱");
+                    for (WmsQrCodeMaster child : childCode)
+                    {
+                        item.getScanCodes().add(new PDAScanCodeQO()
+                                .setBatchNumber(child.getBatchNo())
+                                .setSerialNumbers(child.getSerialNo())
+                                .setCodeId(child.getBarcodeCode())
+                                .setCodeNum(child.getQuantity())
+                                .setCodeContent(child.getPackagingType().toString())
+                        );
+                    }
+                }
+            }
+
 
             SAPSyncParamsDTO materialInfoInOrder = sapSyncParamsDTOS.stream()
                     .filter(sapSyncParamsDTO ->
@@ -238,44 +266,173 @@ public class NormalPGIController extends BaseController {
             // 如果是质检单
             if (isQuality) {
                 setQcMaterialSyncDto(qcMaterialSyncDTOS, item, order, codes, materialInfoInOrder, wmsQcReceiveItems, wmsQcReceive.getId(), orderItemId);
+                for (PDAScanCodeQO code : item.getScanCodes()) {
+                    // 处理条码
+                    WmsQrCodeMaster qrCodeMaster = wmsQrCodeMasterService.lambdaQuery()
+                            .eq(WmsQrCodeMaster::getBarcodeCode, code.getCodeId())
+                            .one();
+                    VUtil.trueThrowBusinessError(Objects.isNull(qrCodeMaster)).throwMessage("无效码【" + code.getCodeId() + "】");
+                    qrCodeMaster.setLastScanTime(LocalDateTime.now());
+                    qrCodeMaster.setLastScanBy(UserUtil.getUserId());
+                    qrCodeMaster.setLastScanByname(UserUtil.getUserName());
+                    qrCodeMaster.setProcessStage(BarCodeProcessStage.Checking.getState());
+                    qrCodeMaster.setReceiptItemId(orderItemId);
+                    qrCodes.add(qrCodeMaster);
+                }
+            } else {
+                //判断是否存在没有启用储位管理的仓库
+                WmsWarehouse warehouse = wmsWarehouseService.lambdaQuery().eq(WmsWarehouse::getNo, item.getReceivedWarehouse()).one();
+                if (!warehouse.getIsDisableLocation()) {
+                    //设置收货明细项
+                    setPoReceiveByIn(item, wmsPoReceiptItems, wmsPoReceipt.getId(), materialInfoInOrder, orderItemId);
+                    //设置SAP过账接口
+                    ZWM3A17DTO zwm3A17DTO = zwm3A17DTOS.stream()
+                            .filter(zwm3A17DTO1 -> zwm3A17DTO1.getEbeln().equals(item.getPoNum()))
+                            .findFirst()
+                            .orElse(null);
+                    if (Objects.isNull(zwm3A17DTO)) {
+                        zwm3A17DTO = new ZWM3A17DTO()
+                                .setEbeln(item.getPoNum())
+                                .setUsnam(UserUtil.getUserName())
+                                .setReceiveId(orderItemId)
+                                .setItem1(new ArrayList<>())
+                                .setItem2(new ArrayList<>());
+                        zwm3A17DTOS.add(zwm3A17DTO);
+                    }
+                    List<ZWM3A17Item1DTO> item1 = zwm3A17DTO.getItem1();
+                    List<ZWM3A17Item2DTO> item2 = zwm3A17DTO.getItem2();
+                    for (PDAScanCodeQO code : item.getScanCodes()) {
+                        // 处理条码
+                        WmsQrCodeMaster qrCodeMaster = wmsQrCodeMasterService.lambdaQuery()
+                                .eq(WmsQrCodeMaster::getBarcodeCode, code.getCodeId())
+                                .one();
+                        VUtil.trueThrowBusinessError(Objects.isNull(qrCodeMaster)).throwMessage("无效码【" + code.getCodeId() + "】");
+                        qrCodeMaster.setLastScanTime(LocalDateTime.now());
+                        qrCodeMaster.setLastScanBy(UserUtil.getUserId());
+                        qrCodeMaster.setLastScanByname(UserUtil.getUserName());
+                        qrCodeMaster.setProcessStage(BarCodeProcessStage.InBound.getState());
+                        qrCodeMaster.setReceiptItemId(orderItemId);
+                        qrCodes.add(qrCodeMaster);
+                        if (qrCodeMaster.getPackagingType().equals(1)) {
+                            continue;
+                        }
+                        // 库存
+                        InventoryDTO inventoryDTO = inventories.stream()
+                                .filter(inventoriesDTO -> inventoriesDTO.getMaterialNo().equals(item.getItemCode())
+                                        && inventoriesDTO.getBatchNo().equals(code.getBatchNumber())
+                                        && inventoriesDTO.getSerialNo().equals(code.getSerialNumbers())
+                                        && inventoriesDTO.getFactoryNo().equals(wmsPoReceipt.getFactoryCode())
+                                        && inventoriesDTO.getWarehouseNo().equals(item.getReceivedWarehouse())
+                                ).findFirst().orElse(null);
+                        if (Objects.isNull(inventoryDTO)) {
+                            inventoryDTO = new InventoryDTO()
+                                    .setMaterialNo(item.getItemCode())
+                                    .setFactoryNo(wmsPoReceipt.getFactoryCode())
+                                    .setWarehouseNo(item.getReceivedWarehouse())
+                                    .setBatchNo(code.getBatchNumber())
+                                    .setSerialNo(code.getSerialNumbers())
+                                    .setNum(code.getCodeNum());
+                            inventories.add(inventoryDTO);
+                        } else {
+                            inventoryDTO.setNum(inventoryDTO.getNum().add(code.getCodeNum()));
+                        }
+                        ZWM3A17Item1DTO ietm1Dto = item1.stream()
+                                .filter(dto1 ->
+                                        dto1.getEBELP().equals(item.getPoLineNumber())
+                                                && dto1.getMATNR().equals(item.getItemCode())
+                                                && dto1.getMeins().equals(item.getUomCode())
+                                                && dto1.getCHARG().equals(code.getBatchNumber())
+                                                && dto1.getWERKS().equals(wmsPoReceipt.getFactoryCode())
+                                                && dto1.getLGORT().equals(item.getReceivedWarehouse())
+                                ).findFirst().orElse(null);
+                        if (Objects.isNull(ietm1Dto)) {
+                            item1.add(new ZWM3A17Item1DTO()
+                                    .setEBELP(item.getPoLineNumber())
+                                    .setMATNR(item.getItemCode())
+                                    .setERFMG(code.getCodeNum())
+                                    .setMEINS(item.getUomCode())
+                                    .setCHARG(code.getBatchNumber())
+                                    .setWERKS(wmsPoReceipt.getFactoryCode())
+                                    .setLGORT(item.getReceivedWarehouse())
+                                    .setKZKRI("")
+                            );
+                        } else {
+                            ietm1Dto.setERFMG(ietm1Dto.getERFMG().add(code.getCodeNum()));
+                        }
+
+                        item2.add(new ZWM3A17Item2DTO()
+                                .setEBELP(item.getPoLineNumber())
+                                .setFLAG("")
+                                .setSERNR(code.getSerialNumbers()));
+                    }
+                    //...................
                 } else {
                     setPoReceive(item, wmsPoReceiptItems, wmsPoReceipt.getId(), materialInfoInOrder, orderItemId);
+                    for (PDAScanCodeQO code : item.getScanCodes()) {
+                        // 处理条码
+                        WmsQrCodeMaster qrCodeMaster = wmsQrCodeMasterService.lambdaQuery()
+                                .eq(WmsQrCodeMaster::getBarcodeCode, code.getCodeId())
+                                .one();
+                        VUtil.trueThrowBusinessError(Objects.isNull(qrCodeMaster)).throwMessage("无效码【" + code.getCodeId() + "】");
+                        qrCodeMaster.setLastScanTime(LocalDateTime.now());
+                        qrCodeMaster.setLastScanBy(UserUtil.getUserId());
+                        qrCodeMaster.setLastScanByname(UserUtil.getUserName());
+                        qrCodeMaster.setStorageLocation(materialInfoInOrder.getWarehouseNo());
+                        qrCodeMaster.setProcessStage(BarCodeProcessStage.Received.getState());
+                        qrCodeMaster.setReceiptItemId(orderItemId);
+                        qrCodes.add(qrCodeMaster);
+                    }
+                }
             }
         }
         // 盘点条码是否重复
-        Map<String, Long> duplicateCodes = srmMaterialReceiptScanCodes.stream()
-                .collect(Collectors.groupingBy(
-                        SrmMaterialReceiptScanCodes::getCodeId,
-                        Collectors.counting()
-                ))
-                .entrySet()
-                .stream()
-                .filter(entry -> entry.getValue() > 1)
-                .collect(Collectors.toMap(
-                        Map.Entry::getKey,
-                        Map.Entry::getValue
-                ));
-
-        VUtil.trueThrowBusinessError(CollectionUtil.isNotEmpty(duplicateCodes)).throwMessage("存在重复条码");
-        qrCodeMasterService.saveBatch(
-                srmMaterialReceiptScanCodes
-                        .stream()
-                        .map(it -> new WmsQrCodeMaster()
-                                .setBarcodeCode(KeyUtil.next())
-                                .setProcessStage(BarCodeProcessStage.Received.getState())
-                                .setBarcodeType(BarCodeType.Disassemble.getState())
-                                .setMaterialCode(it.getCodeId())
-                                .setMaterialDescription("")
-                                .setPackagingType((short) 0)
-                                .setQuantity(it.getCodeNum())
-                                .setReceiptItemId(it.getReceiveItemId())
-                                .setCreateUserId(UserUtil.getUserId())
-                                .setCreateUserName(UserUtil.getUserName())
-                                .setCreateTime(LocalDateTime.now())
-                        )
-                        .toList()
-        );
+//        Map<String, Long> duplicateCodes = srmMaterialReceiptScanCodes.stream()
+//                .collect(Collectors.groupingBy(
+//                        SrmMaterialReceiptScanCodes::getCodeId,
+//                        Collectors.counting()
+//                ))
+//                .entrySet()
+//                .stream()
+//                .filter(entry -> entry.getValue() > 1)
+//                .collect(Collectors.toMap(
+//                        Map.Entry::getKey,
+//                        Map.Entry::getValue
+//                ));
+//
+//        VUtil.trueThrowBusinessError(CollectionUtil.isNotEmpty(duplicateCodes)).throwMessage("存在重复条码");
+//        qrCodeMasterService.saveBatch(
+//                srmMaterialReceiptScanCodes
+//                        .stream()
+//                        .map(it -> new WmsQrCodeMaster()
+//                                .setBarcodeCode(KeyUtil.next())
+//                                .setProcessStage(BarCodeProcessStage.Received.getState())
+//                                .setBarcodeType(BarCodeType.Disassemble.getState())
+//                                .setMaterialCode(it.getCodeId())
+//                                .setMaterialDescription("")
+//                                .setPackagingType((short) 0)
+//                                .setQuantity(it.getCodeNum())
+//                                .setReceiptItemId(it.getReceiveItemId())
+//                                .setCreateUserId(UserUtil.getUserId())
+//                                .setCreateUserName(UserUtil.getUserName())
+//                                .setCreateTime(LocalDateTime.now())
+//                        )
+//                        .toList()
+//        );
          normalPGIControllerService.takeDelivery(wmsPoReceipt, wmsQcReceive, wmsPoReceiptItems, wmsQcReceiveItems, srmMaterialReceiptScanCodes, qcMaterialSyncDTOS, order.getId());
+        List<GoodReceiptDTO> dtos = new ArrayList<>();
+        GoodReceiptDTO dto = new GoodReceiptDTO()
+                .setWmsPoReceipt(wmsPoReceipt)
+                .setWmsQcReceive(wmsQcReceive)
+                .setWmsPoReceiptItems(wmsPoReceiptItems)
+                .setWmsQcReceiveItems(wmsQcReceiveItems)
+                .setSrmMaterialReceiptScanCodes(srmMaterialReceiptScanCodes)
+                .setOrderId(order.getId())
+                .setInventories(inventories)
+                .setZwm3A17DTOS(zwm3A17DTOS)
+                .setQrCodes(qrCodes)
+                .setQcMaterialSyncDTOS(qcMaterialSyncDTOS);
+        dtos.add(dto);
+        normalPGIControllerService.takeDeliveryByPackage(dtos, null);
         return ApiResult.success();
     }
 
@@ -1693,6 +1850,30 @@ public class NormalPGIController extends BaseController {
             for (SrmMaterialReceiptQO item : items) {
                 // 盘点是否有条码
                 VUtil.trueThrowBusinessError(CollectionUtil.isEmpty(item.getScanCodes())).throwMessage("[" + item.getItemCode() + "]没有码信息");
+                //对项目进行处理
+                for (PDAScanCodeQO code : item.getScanCodes()) {
+                    WmsQrCodeMaster qrCodeMaster = qrCodeMasterService.lambdaQuery()
+                            .eq(WmsQrCodeMaster::getBarcodeCode, code.getCodeId())
+                            .one();
+                    VUtil.trueThrowBusinessError(Objects.isNull(qrCodeMaster)).throwMessage("无效码【" + code.getCodeId() + "】");
+                    if (qrCodeMaster.getPackagingType().equals(1)) {
+                        code.setCodeNum(BigDecimal.ZERO);
+                        List<WmsQrCodeMaster> childCode= qrCodeMasterService.lambdaQuery()
+                                .eq(WmsQrCodeMaster::getParentBarcodeId, qrCodeMaster.getId())
+                                .list();
+                        VUtil.trueThrowBusinessError(CollectionUtil.isEmpty(childCode)).throwMessage("箱码【" + code.getCodeId() + "】为空箱");
+                        for (WmsQrCodeMaster child : childCode)
+                        {
+                            item.getScanCodes().add(new PDAScanCodeQO()
+                                    .setBatchNumber(child.getBatchNo())
+                                    .setSerialNumbers(child.getSerialNo())
+                                    .setCodeId(child.getBarcodeCode())
+                                    .setCodeNum(child.getQuantity())
+                                    .setCodeContent(child.getPackagingType().toString())
+                            );
+                        }
+                    }
+                }
             }
             receipt.setReceiptQOS(items);
             receipts.add(receipt);

nflg-wms-srm-receive/lib/sapjcomanifest.mf

@@ -0,0 +1,9 @@
+Manifest-Version: 1.0
+
+keyname: SAP JCO
+keyvendor: sap.com
+keylocation: SAP SE
+
+sapjco release: 3.1
+sapjco patch level: 12
+sapjco os: darwinarm64

nflg-wms-srm-receive/pom.xml

@@ -38,6 +38,13 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-actuator</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.sap.conn.jco</groupId>
+            <artifactId>sapjco3</artifactId>
+            <version>3.1.12</version>
+            <scope>system</scope>
+            <systemPath>${project.basedir}/lib/sapjco3.jar</systemPath>
+        </dependency>
         <dependency>
             <groupId>com.jcraft</groupId>
             <artifactId>jsch</artifactId>
@@ -55,6 +62,32 @@
                     <skip>true</skip>
                 </configuration>
             </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-resources-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <id>copy-external-libs</id>
+                        <phase>process-resources</phase>
+                        <goals>
+                            <goal>copy-resources</goal>
+                        </goals>
+                        <configuration>
+                            <!-- 指定源目录（项目根目录下的lib） -->
+                            <resources>
+                                <resource>
+                                    <directory>${project.basedir}/lib</directory>
+                                    <filtering>false</filtering>
+                                </resource>
+                            </resources>
+                            <!-- 指定目标目录（与依赖库相同的目录） -->
+                            <outputDirectory>${project.build.directory}/lib</outputDirectory>
+                            <!-- 自动创建目标目录 -->
+                            <overwrite>true</overwrite>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-dependency-plugin</artifactId>

nflg-wms-srm-receive/src/main/java/com/nflg/wms/srm/receive/config/SAPConfig.java

@@ -0,0 +1,119 @@
+package com.nflg.wms.srm.receive.config;
+
+import com.sap.conn.jco.JCoDestination;
+import com.sap.conn.jco.JCoDestinationManager;
+import com.sap.conn.jco.JCoException;
+import com.sap.conn.jco.JCoRepository;
+import com.sap.conn.jco.ext.DestinationDataEventListener;
+import com.sap.conn.jco.ext.DestinationDataProvider;
+import com.sap.conn.jco.ext.Environment;
+import jakarta.annotation.PostConstruct;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Properties;
+
+@Slf4j
+@Configuration
+public class SAPConfig {
+
+    public static final String ABAP_AS_POOLED = "ABAP_AS_WITH_POOL";
+    private final String sapHost;
+    private final String sapSysnr;
+    private final String sapClient;
+    private final String sapUsername;
+    private final String sapPassword;
+    private final String sapLang;
+    private final String sapPool;
+    private String sapPeak;
+
+    public SAPConfig(
+            @Value("${custom.sap.host}") String sapHost,
+            @Value("${custom.sap.sysnr}") String sapSysnr,
+            @Value("${custom.sap.client}") String sapClient,
+            @Value("${custom.sap.username}") String sapUsername,
+            @Value("${custom.sap.password}") String sapPassword,
+            @Value("${custom.sap.lang}") String sapLang,
+            @Value("${custom.sap.pool}") String sapPool,
+            @Value("${custom.sap.peak}") String sapPeak
+    ) {
+        this.sapHost = sapHost;
+        this.sapSysnr = sapSysnr;
+        this.sapClient = sapClient;
+        this.sapUsername = sapUsername;
+        this.sapPassword = sapPassword;
+        this.sapLang = sapLang;
+        this.sapPool = sapPool;
+        this.sapPeak = sapPeak;
+    }
+
+    @PostConstruct
+    public void initDestination() {
+        try {
+            // 验证连接池配置有效性
+            validatePoolConfig();
+            // 直接注册到JCo内存环境（避免文件IO）
+            Environment.registerDestinationDataProvider(new SimpleDestinationDataProvider(ABAP_AS_POOLED, buildConnectionProperties()));
+        } catch (Exception e) {
+            log.error("SAP JCo目的地初始化失败", e);
+            throw new IllegalStateException("SAP JCo配置初始化失败", e);
+        }
+    }
+
+    private Properties buildConnectionProperties() {
+        Properties props = new Properties();
+        props.setProperty(DestinationDataProvider.JCO_ASHOST, sapHost);
+        props.setProperty(DestinationDataProvider.JCO_SYSNR, sapSysnr);
+        props.setProperty(DestinationDataProvider.JCO_CLIENT, sapClient);
+        props.setProperty(DestinationDataProvider.JCO_USER, sapUsername);
+        props.setProperty(DestinationDataProvider.JCO_PASSWD, sapPassword);
+        props.setProperty(DestinationDataProvider.JCO_LANG, sapLang);
+        props.setProperty(DestinationDataProvider.JCO_PEAK_LIMIT, sapPeak);
+        props.setProperty(DestinationDataProvider.JCO_POOL_CAPACITY, sapPool);
+        return props;
+    }
+    // 连接池配置验证
+    private void validatePoolConfig() {
+        try {
+            int peak = Integer.parseInt(sapPeak);
+            int pool = Integer.parseInt(sapPool);
+            if (peak < pool) {
+                log.warn("JCO_PEAK_LIMIT({}) 不应小于 JCO_POOL_CAPACITY({})，已自动修正", peak, pool);
+                sapPeak = sapPool;
+            }
+        } catch (NumberFormatException e) {
+            throw new IllegalArgumentException("SAP连接池配置必须是数字");
+        }
+    }
+
+    @Bean(destroyMethod = "")
+    public JCoDestination jcoDestination() throws JCoException {
+        return JCoDestinationManager.getDestination(ABAP_AS_POOLED);
+    }
+
+    @Bean
+    public JCoRepository getJCoRepository() throws JCoException {
+        return jcoDestination().getRepository();
+    }
+
+    private static class SimpleDestinationDataProvider implements DestinationDataProvider {
+        private final Map<String, Properties> destinations = new HashMap<>();
+        public SimpleDestinationDataProvider(String destName, Properties props) {
+            destinations.put(destName, props);
+        }
+        @Override
+        public Properties getDestinationProperties(String destinationName) {
+            return destinations.get(destinationName);
+        }
+        @Override
+        public void setDestinationDataEventListener(DestinationDataEventListener listener) {}
+        @Override
+        public boolean supportsEvents() {
+            return false;
+        }
+    }
+}

nflg-wms-srm-receive/src/main/java/com/nflg/wms/srm/receive/pojo/dto/SAPMaterialInfoInOrderDTO.java

@@ -0,0 +1,120 @@
+package com.nflg.wms.srm.receive.pojo.dto;
+
+import cn.hutool.core.util.StrUtil;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.nflg.wms.common.util.BomUtil;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.math.BigDecimal;
+
+@Data
+@Accessors(chain = true)
+public class SAPMaterialInfoInOrderDTO {
+
+    /**
+     * 未收货数量
+     */
+    @JsonProperty("WSHSL")
+    private BigDecimal transportNum;
+
+    /**
+     * 仓库编号
+     */
+    @JsonProperty("LGORT")
+    private String warehouseNo;
+
+    /**
+     * 采购凭证号
+     */
+    private String ebeln;
+
+    /**
+     * 采购凭证行项目
+     */
+    private String ebelp;
+
+    public String getEbelp() {
+        return StrUtil.removeAllPrefix(ebelp, "0");
+    }
+
+    /**
+     * 物料号
+     */
+    private String matnr;
+
+    /**
+     * 物料描述
+     */
+    private String maktx;
+
+    /**
+     * 标志：关键部件(是否质检)
+     */
+    private String kzkri;
+
+    /**
+     * 采购订单数量
+     */
+    private BigDecimal menge;
+
+    /**
+     * 收货数量
+     */
+
+    private BigDecimal wemng;
+
+    /**
+     * 单位
+     */
+    private String meins;
+
+    public String getMeins() {
+        return BomUtil.changeMeins(meins);
+    }
+
+    /**
+     * 物料组
+     */
+    private String matkl;
+
+    /**
+     * 物料描述描述
+     */
+    private String wgbez;
+
+    /**
+     * 工厂
+     */
+    private String werks;
+
+    /**
+     * 标识：基于收获的发票验证
+     */
+    private String webre;
+
+    /**
+     * 打印参数
+     */
+    private String lbprt;
+
+    /**
+     * 特性值
+     */
+    private String atwrt;
+
+    /**
+     * 采购组
+     */
+    private String ekgrp;
+
+    /**
+     * 订单类型
+     */
+    private String bsart;
+
+    /**
+     * 供应商账号
+     */
+    private String lifnr;
+}

nflg-wms-srm-receive/src/main/java/com/nflg/wms/srm/receive/pojo/dto/ZWM3A17DTO.java

@@ -0,0 +1,26 @@
+package com.nflg.wms.srm.receive.pojo.dto;
+
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Data
+@Accessors(chain = true)
+public class ZWM3A17DTO {
+
+    /**
+     * 采购凭证号
+     */
+    private String ebeln;
+
+    /**
+     * 用户名
+     */
+    private String usnam;
+
+    private List<ZWM3A17Item1DTO> item1 = new ArrayList<>();
+
+    private List<ZWM3A17Item2DTO> item2 = new ArrayList<>();
+}

nflg-wms-srm-receive/src/main/java/com/nflg/wms/srm/receive/pojo/dto/ZWM3A17Item1DTO.java

@@ -0,0 +1,56 @@
+package com.nflg.wms.srm.receive.pojo.dto;
+
+import com.nflg.wms.common.util.BomUtil;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.math.BigDecimal;
+
+@Data
+@Accessors(chain = true)
+public class ZWM3A17Item1DTO {
+
+    /**
+     * 采购凭证的项目编号
+     */
+    private String EBELP;
+
+    /**
+     * 物料号
+     */
+    private String MATNR;
+
+    /**
+     * 以输入单位计的数量
+     */
+    private BigDecimal ERFMG;
+
+    /**
+     * 基本计量单位
+     */
+    private String MEINS;
+
+    public String getMeins() {
+        return BomUtil.changeMeins(MEINS);
+    }
+
+    /**
+     * 批号
+     */
+    private String CHARG;
+
+    /**
+     * 工厂
+     */
+    private String WERKS;
+
+    /**
+     * 库存地点
+     */
+    private String LGORT;
+
+    /**
+     * 标志：关键部件
+     */
+    private String KZKRI;
+}

nflg-wms-srm-receive/src/main/java/com/nflg/wms/srm/receive/pojo/dto/ZWM3A17Item2DTO.java

@@ -0,0 +1,24 @@
+package com.nflg.wms.srm.receive.pojo.dto;
+
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class ZWM3A17Item2DTO {
+
+    /**
+     * 采购凭证的项目编号
+     */
+    private String EBELP;
+
+    /**
+     * 序列号
+     */
+    private String SERNR;
+
+    /**
+     * 标志，X表示合格品，空表示不合格品
+     */
+    private String FLAG;
+}

nflg-wms-srm-receive/src/main/java/com/nflg/wms/srm/receive/pojo/dto/ZWM3A18DTO.java

@@ -0,0 +1,35 @@
+package com.nflg.wms.srm.receive.pojo.dto;
+
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.util.List;
+
+@Data
+@Accessors(chain = true)
+public class ZWM3A18DTO {
+
+    /**
+     * 采购凭证号
+     */
+    private String ebeln;
+
+    /**
+     * 用户名
+     */
+    private String usnam;
+
+    /**
+     * 物料凭证编号
+     */
+    private String mblnr;
+
+    /**
+     * 物料凭证年度
+     */
+    private String mjahr;
+
+    private List<ZWM3A18Item1DTO> item1;
+
+    private List<ZWM3A17Item2DTO> item2;
+}

nflg-wms-srm-receive/src/main/java/com/nflg/wms/srm/receive/pojo/dto/ZWM3A18Item1DTO.java

@@ -0,0 +1,66 @@
+package com.nflg.wms.srm.receive.pojo.dto;
+
+import com.nflg.wms.common.util.BomUtil;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.math.BigDecimal;
+
+@Data
+@Accessors(chain = true)
+public class ZWM3A18Item1DTO {
+
+    /**
+     * 报检数量
+     */
+    private BigDecimal erfmg;
+
+    /**
+     * 质检合格数量
+     */
+    private BigDecimal erfmg1;
+
+    /**
+     * 质检不合格数量
+     */
+    private BigDecimal erfmg2;
+
+    /**
+     * 采购凭证的项目编号
+     */
+    private String ebelp;
+
+    /**
+     * 物料号
+     */
+    private String matnr;
+
+    /**
+     * 单位
+     */
+    private String meins;
+
+    public String getMeins() {
+        return BomUtil.changeMeins(meins);
+    }
+
+    /**
+     * 批号
+     */
+    private String charg;
+
+    /**
+     * 库存地点
+     */
+    private String lgort;
+
+    /**
+     * 项目文本
+     */
+    private String sgtxt;
+
+    /**
+     * 工厂
+     */
+    private String werks;
+}

nflg-wms-srm-receive/src/main/java/com/nflg/wms/srm/receive/util/JCoUtil.java

@@ -0,0 +1,103 @@
+package com.nflg.wms.srm.receive.util;
+
+import cn.hutool.core.collection.CollectionUtil;
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.MapperFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.json.JsonMapper;
+import com.nflg.wms.common.util.BeanUtil;
+import com.sap.conn.jco.*;
+
+import java.util.*;
+import java.util.stream.Collectors;
+
+public class JCoUtil {
+
+    private static final ObjectMapper MAPPER = JsonMapper.builder()
+            .enable(MapperFeature.ACCEPT_CASE_INSENSITIVE_PROPERTIES)
+            .disable(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES)
+            .build();
+
+    /**
+     * 将 JCoTable 转换为 Java Bean 列表
+     * @param table JCoTable 对象
+     * @param clazz 目标实体类
+     * @param <T>   泛型
+     * @return List<T> 列表
+     */
+    public static <T> List<T> toBeanList(JCoTable table, Class<T> clazz) {
+        List<Map<String, Object>> mapList = toMapList(table);
+        List<T> resultList = new ArrayList<>(mapList.size());
+        for (Map<String, Object> map : mapList) {
+            resultList.add(MAPPER.convertValue(map, clazz));
+        }
+        return resultList;
+    }
+
+    public static List<Map<String, Object>> toMapList(JCoTable table) {
+        if (CollectionUtil.isEmpty(table) || table.isEmpty()) {
+            return Collections.emptyList();
+        }
+        List<Map<String, Object>> mapList = new ArrayList<>();
+        JCoRecordMetaData meta = table.getRecordMetaData();
+        table.firstRow();
+        do {
+            Map<String, Object> rowMap = new HashMap<>();
+            for (int i = 0; i < meta.getFieldCount(); i++) {
+                rowMap.put(meta.getName(i), table.getField(i).getValue());
+            }
+            mapList.add(rowMap);
+        } while (table.nextRow());
+        return mapList;
+    }
+
+    public static <T> List<Map<String, Object>> toMapList(List<T> datas) {
+        return datas.stream().map(BeanUtil::toMap)
+                .map(list -> list.entrySet().stream()
+                        .collect(Collectors.toMap(entry -> entry.getKey().toUpperCase(),
+                                Map.Entry::getValue)))
+                .toList();
+    }
+
+    public static <T> List<Map<String, Object>> toMapList(T data) {
+        return Collections.singletonList(BeanUtil.toMap(data));
+    }
+
+    /**
+     * 将 JCoStructure 转换为 Java Bean
+     * @param structure JCoStructure 对象
+     * @param clazz     目标实体类
+     * @param <T>       泛型
+     * @return T 实体对象
+     */
+    public static <T> T toBean(JCoStructure structure, Class<T> clazz) {
+        if (Objects.isNull(structure)) {
+            return null;
+        }
+        JCoRecordMetaData meta = structure.getRecordMetaData();
+        Map<String, Object> rowMap = new HashMap<>();
+        for (int i = 0; i < meta.getFieldCount(); i++) {
+            rowMap.put(meta.getName(i), structure.getField(i).getValue());
+        }
+        return MAPPER.convertValue(rowMap, clazz);
+    }
+
+    /**
+     * 将 JCoParameterList 转换为 Java Bean
+     * @param parameters JCoParameterList 对象
+     * @param clazz      目标实体类
+     * @param <T>        泛型
+     * @return T 实体对象
+     */
+    public static <T> T toBean(JCoParameterList parameters, Class<T> clazz) {
+        if (Objects.isNull(parameters)) {
+            return null;
+        }
+        JCoListMetaData meta = parameters.getListMetaData();
+        Map<String, Object> rowMap = new HashMap<>();
+        for (int i = 0; i < meta.getFieldCount(); i++) {
+            rowMap.put(meta.getName(i), parameters.getField(i).getValue());
+        }
+        return MAPPER.convertValue(rowMap, clazz);
+    }
+}

nflg-wms-srm-receive/src/test/java/com/nflg/wms/srm/receive/SapMetaPrintTest.java

@@ -0,0 +1,410 @@
+package com.nflg.wms.srm.receive;
+
+import cn.hutool.core.util.StrUtil;
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
+import com.sap.conn.jco.*;
+import com.sap.conn.jco.ext.DestinationDataEventListener;
+import com.sap.conn.jco.ext.DestinationDataProvider;
+import com.sap.conn.jco.ext.Environment;
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.Test;
+
+import java.util.*;
+
+public class SapMetaPrintTest {
+
+    @Test
+    public void ZWM3A22() throws JCoException {
+        printMeta("ZWM3A22");
+    }
+
+    @Test
+    public void ZWM3A23() throws JCoException {
+        printMeta("ZWM3A23");
+    }
+
+    @Test
+    public void ZIM_004() throws JCoException {
+        printMeta("ZIM_004");
+    }
+
+    @Test
+    public void ZWM3A02() throws JCoException {
+        printMeta("ZWM3A02");
+    }
+
+    @Test
+    public void ZRFC_MM_SMXT() throws JCoException {
+        printMeta("ZRFC_MM_SMXT");
+    }
+
+    @Test
+    public void ZWM3A17() throws JCoException {
+        printMeta("ZWM3A17");
+    }
+
+    @Test
+    public void ZWM3A18() throws JCoException {
+        printMeta("ZWM3A18");
+    }
+
+    @Test
+    public void ZWM00_MB007() throws JCoException {
+        printMeta("ZWM00_MB007");
+    }
+
+    @Test
+    public void ZWM00_MB107() throws JCoException {
+        printMeta("ZWM00_MB107");
+    }
+
+    @Test
+    public void ZIM_001_QUERY() throws JCoException {
+        printMeta("ZIM_001_QUERY");
+    }
+
+    @Test
+    public void ZWM3A05() throws JCoException {
+        printMeta("ZWM3A05");
+    }
+
+    @Test
+    public void ZIM_001() throws JCoException {
+        printMeta("ZIM_001");
+    }
+
+    @Test
+    public void ZWM3A06() throws JCoException {
+        printMeta("ZWM3A06");
+    }
+
+    @Test
+    public void ZWM00_MB017() throws JCoException {
+        printMeta("ZWM00_MB017");
+    }
+
+    @Test
+    public void ZWM00_MB112() throws JCoException {
+        printMeta("ZWM00_MB112");
+    }
+
+    @Test
+    public void ZWM00_MB026() throws JCoException {
+        printMeta("ZWM00_MB026");
+    }
+
+    @Test
+    public void ZWM00_MB115() throws JCoException {
+        printMeta("ZWM00_MB115");
+    }
+
+    @Test
+    public void ZWM3A03() throws JCoException {
+        printMeta("ZWM3A03");
+    }
+
+    @Test
+    public void ZWM3A04() throws JCoException {
+        printMeta("ZWM3A04");
+    }
+
+    @Test
+    public void ZWM3A07() throws JCoException {
+        printMeta("ZWM3A07");
+    }
+
+    @Test
+    public void ZWM3A10() throws JCoException {
+        printMeta("ZWM3A10");
+    }
+
+    @Test
+    public void ZWM3A08() throws JCoException {
+        printMeta("ZWM3A08");
+    }
+
+    @Test
+    public void ZWM3A09() throws JCoException {
+        printMeta("ZWM3A09");
+    }
+
+    @Test
+    public void ZWM3A11() throws JCoException {
+        printMeta("ZWM3A11");
+    }
+
+    @Test
+    public void ZWM3A12() throws JCoException {
+        printMeta("ZWM3A12");
+    }
+
+    @Test
+    public void ZWM3A13() throws JCoException {
+        printMeta("ZWM3A13");
+    }
+
+    @Test
+    public void ZWM3A14() throws JCoException {
+        printMeta("ZWM3A14");
+    }
+
+    @Test
+    public void ZWM3A15() throws JCoException {
+        printMeta("ZWM3A15");
+    }
+
+    @Test
+    public void ZWM3A16() throws JCoException {
+        printMeta("ZWM3A16");
+    }
+
+    @Test
+    public void ZWM00_MB113() throws JCoException {
+        printMeta("ZWM00_MB113");
+    }
+
+    @Test
+    public void ZWM00_MB116() throws JCoException {
+        printMeta("ZWM00_MB116");
+    }
+
+    @Test
+    public void ZWM3A21() throws JCoException {
+        printMeta("ZWM3A21");
+    }
+
+
+    @Test
+    public void ZWM3A19() throws JCoException {
+        printMeta("ZWM3A19");
+    }
+
+
+    @Test
+    public void ZWM3A20() throws JCoException {
+        printMeta("ZWM3A20");
+    }
+
+    @Test
+    public void ZWM3A24() throws JCoException {
+        printMeta("ZWM3A24");
+    }
+
+    @Test
+    public void ZWM3A25() throws JCoException {
+        printMeta("ZWM3A25");
+    }
+
+
+    public void printMeta(String functionName) throws JCoException {
+        functionName = functionName.toUpperCase();
+        JCoFunction function = repository.getFunction(functionName);
+        if (Objects.isNull(function)) {
+            print("方法" + functionName + "不存在");
+        } else {
+            printMeta(function);
+        }
+    }
+
+    private void printMeta(JCoFunction function) {
+        print("SAP {} 方法参数信息", function.getName());
+        printParameterField("Import", function.getImportParameterList());
+        printParameterField("Changing", function.getChangingParameterList());
+        printParameterField("Export", function.getExportParameterList());
+        printParameterField("Table", function.getTableParameterList());
+    }
+
+    private void printParameterField(String name, JCoParameterList parameterList) {
+        print("▶ " + name);
+        if (Objects.nonNull(parameterList)) {
+            JCoParameterFieldIterator iterator = parameterList.getParameterFieldIterator();
+            if (Objects.nonNull(iterator)) {
+                List<JCoParameterField> fields = new ArrayList<>();
+                List<String[]> data = new ArrayList<>();
+                JSONObject jo = new JSONObject();
+                while (iterator.hasNextField()) {
+                    JCoParameterField field = iterator.nextParameterField();
+                    data.add(new String[]{field.getName(), field.getTypeAsString(), field.getDescription()});
+                    if (field.isTable() || field.isStructure()) {
+                        fields.add(field);
+                    }
+                    jo.putOnce(field.getName(), field.getDescription());
+                }
+                printTable(data);
+                printJson(jo);
+                fields.forEach(this::print);
+            }
+        }
+    }
+
+    private void print(JCoParameterField field) {
+        print("★★ {}({}) 参数", field.getName(), field.getDescription());
+        if (field.isTable()) {
+            print(field.getTable().getRecordFieldIterator());
+        } else if (field.isStructure()) {
+            print(field.getStructure().getRecordFieldIterator());
+        }
+    }
+
+    private void print(JCoRecordFieldIterator iterator) {
+        List<String[]> data = new ArrayList<>();
+        JSONObject jo = new JSONObject();
+        while (iterator.hasNextField()) {
+            JCoRecordField field = iterator.nextRecordField();
+            data.add(new String[]{field.getName(), field.getTypeAsString(), field.getDescription()});
+            jo.putOnce(field.getName(), field.getDescription());
+        }
+        printTable(data);
+        printJson(jo);
+    }
+
+    private void printJson(JSONObject jo) {
+        print("JSON形式:");
+        print(JSONUtil.toJsonPrettyStr(jo).toLowerCase());
+    }
+
+    private void printTable(List<String[]> datas) {
+        print("表格形式:");
+        SimpleTable table = new SimpleTable();
+        table.addHeader("序号", "名称", "类型", "描述");
+        for (int i = 0; i < datas.size(); i++) {
+            table.addRow(String.valueOf(i + 1), datas.get(i)[0], datas.get(i)[1], datas.get(i)[2]);
+        }
+        table.print();
+    }
+
+    private void print(String content) {
+        System.out.println(content);
+    }
+
+    private void print(String template, Object... args) {
+        System.out.println(StrUtil.format(template, args));
+    }
+
+    // 简单实现示例
+    private static class SimpleTable {
+        private final List<String[]> rows = new ArrayList<>();
+        private final List<String> headers = new ArrayList<>();
+
+        public void addHeader(String... headers) {
+            this.headers.addAll(Arrays.asList(headers));
+        }
+
+        public void addRow(String... values) {
+            rows.add(values);
+        }
+
+        public void print() {
+            // 计算每列最大宽度
+            int[] maxWidths = new int[headers.size()];
+            for (int i = 0; i < headers.size(); i++) {
+                maxWidths[i] = getWeightedLength(headers.get(i));
+            }
+
+            for (String[] row : rows) {
+                for (int i = 0; i < row.length && i < maxWidths.length; i++) {
+                    maxWidths[i] = Math.max(maxWidths[i], getWeightedLength(row[i]));
+                }
+            }
+
+            // 打印表格
+            printLine(maxWidths);
+            printRow(headers.toArray(new String[0]), maxWidths);
+            printLine(maxWidths);
+
+            for (String[] row : rows) {
+                printRow(row, maxWidths);
+            }
+            printLine(maxWidths);
+        }
+
+        private void printLine(int[] widths) {
+            System.out.print("+");
+            for (int width : widths) {
+                for (int i = 0; i < width + 2; i++) {
+                    System.out.print("-");
+                }
+                System.out.print("+");
+            }
+            System.out.println();
+        }
+
+        private void printRow(String[] row, int[] widths) {
+            System.out.print("|");
+            for (int i = 0; i < widths.length; i++) {
+                String value = i < row.length ? row[i] : "";
+                System.out.printf(" %-" + (widths[i] - getChineseNum(value) / 2) + "s |", value);
+            }
+            System.out.println();
+        }
+
+        private static final String CHINESE_REGEX = "[\\u4e00-\\u9fff]";
+
+        public static int getWeightedLength(String str) {
+            if (str == null || str.isEmpty()) {
+                return 0;
+            }
+            return str.chars()
+                    .map(c -> String.valueOf((char) c).matches(CHINESE_REGEX) ? 2 : 1)
+                    .sum();
+        }
+
+        public static int getChineseNum(String str) {
+            if (str == null || str.isEmpty()) {
+                return 0;
+            }
+            return str.chars()
+                    .map(c -> String.valueOf((char) c).matches(CHINESE_REGEX) ? 1 : 0)
+                    .sum();
+        }
+    }
+
+    private static JCoRepository repository;
+
+    @BeforeAll
+    static void initOnce() throws JCoException {
+        Environment.registerDestinationDataProvider(new SimpleDestinationDataProvider(ABAP_AS_POOLED, buildConnectionProperties()));
+        repository = JCoDestinationManager.getDestination(ABAP_AS_POOLED).getRepository();
+    }
+
+    private static final String ABAP_AS_POOLED = "ABAP_AS_WITH_POOL";
+
+    private static Properties buildConnectionProperties() {
+        Properties props = new Properties();
+        props.setProperty(DestinationDataProvider.JCO_ASHOST, "192.168.0.24");
+        props.setProperty(DestinationDataProvider.JCO_SYSNR, "03");
+        props.setProperty(DestinationDataProvider.JCO_CLIENT, "800");
+        props.setProperty(DestinationDataProvider.JCO_USER, "mdm_back");
+        props.setProperty(DestinationDataProvider.JCO_PASSWD, "sap-mdm");
+        props.setProperty(DestinationDataProvider.JCO_LANG, "ZH");
+        props.setProperty(DestinationDataProvider.JCO_PEAK_LIMIT, "10");
+        props.setProperty(DestinationDataProvider.JCO_POOL_CAPACITY, "20");
+        return props;
+    }
+
+    private static class SimpleDestinationDataProvider implements DestinationDataProvider {
+        private final Map<String, Properties> destinations = new HashMap<>();
+
+        public SimpleDestinationDataProvider(String destName, Properties props) {
+            destinations.put(destName, props);
+        }
+
+        @Override
+        public Properties getDestinationProperties(String destinationName) {
+            return destinations.get(destinationName);
+        }
+
+        @Override
+        public void setDestinationDataEventListener(DestinationDataEventListener listener) {
+        }
+
+        @Override
+        public boolean supportsEvents() {
+            return false;
+        }
+    }
+}
+
+
+