package org.jeecg.modules.sap.service.impl;

import com.sap.conn.jco.*;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.jeecg.config.sap.SapRfcConnectionManager;
import org.jeecg.modules.sap.service.SAPService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.Arrays;
import java.util.Collections;

@Service
@Slf4j
public class SAPServiceImpl implements SAPService {
    @Autowired
    private SapRfcConnectionManager connectionManager;

    @Override
    public String test()  {
        JCoDestination destination = connectionManager.getDestination();
        try {
            JCoRepository repository = destination.getRepository();
            JCoFunction function = repository.getFunction("ZPPF_022");

            if (function == null) {
                throw new RuntimeException("RFC 函数模块 ZPPF_022 未找到！");
            }

            // 设置输入参数
            JCoTable inputTable = function.getTableParameterList().getTable("ZTAB_WERKS");
            inputTable.appendRow();
            inputTable.setValue("WERKS", "2301"); //参数名需与 SAP 函数定义一致

            // 执行调用
            function.execute(destination);

            // 获取输出参数
            JCoTable outputTable = function.getTableParameterList().getTable("ZTAB_AUFNR");
            int numRows = outputTable.getNumRows();
            for (int i = 0; i < numRows; i++) {
                outputTable.setRow(i);
                log.info("Row {} : {}", i, outputTable.getString("AUFNR"));
            }

            return String.valueOf(numRows);
        } catch (JCoException e) {
            log.error(e.getMessage(), e);
        }
        return null;
    }
}