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

import com.alibaba.fastjson.JSONObject;
import com.sap.conn.jco.*;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.jeecg.common.aspect.annotation.ApiLog;
import org.jeecg.common.constant.ApiLogCategoryEnum;
import org.jeecg.config.sap.SapRfcConnectionManager;
import org.jeecg.modules.sap.FunctionConst;
import org.jeecg.modules.sap.dto.OrderBomDTO;
import org.jeecg.modules.sap.service.OrderBomSync;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Service
@Slf4j
public class OrderBomSyncImpl implements OrderBomSync {
    @Autowired
    private SapRfcConnectionManager connectionManager;

    @Override
    @ApiLog(apiName = "订单BOM同步(ZPPF_033_3)", apiCategory = ApiLogCategoryEnum.SAP)
    public Map<String, Object> syncOrderBom(String factoryCode, String orderCode) throws Exception {
        Map<String, Object> resultMap = new HashMap<>();
        JCoDestination destination = connectionManager.getDestination();
        JCoRepository repository = destination.getRepository();
        JCoFunction function = repository.getFunction(FunctionConst.ZPPF_033_3);
        if (function == null) {
            throw new RuntimeException("RFC 函数 ZPPF_033_3 未找到！");
        }
        // 设置输入参数
        List<JSONObject> items = new ArrayList<>();
        if(StringUtils.isNotBlank(factoryCode)){
            //新火炬
            JCoParameterList importParameterList = function.getImportParameterList();
            importParameterList.setValue("WERKS", factoryCode);
            //组装请求参数
            JSONObject item = new JSONObject();
            item.put("WERKS", factoryCode);
            items.add(item);
        }
        if(StringUtils.isNotBlank(orderCode)) {
            //新火炬
            JCoTable AUFNRTable = function.getTableParameterList().getTable("ZTAB_AUFNR");
            String[] split = orderCode.split(",");
            for(String code : split){
                AUFNRTable.appendRow();
                AUFNRTable.setValue("AUFNR", code);
            }
            //组装请求参数
            JSONObject item = new JSONObject();
            item.put("AUFNR", orderCode);
            items.add(item);
        }
        // 执行调用
        function.execute(destination);
        //获取返回结果
        String zmess = function.getExportParameterList().getValue("ZMESS").toString();
        String ztype = function.getExportParameterList().getValue("ZTYPE").toString();//S 标识 成功
        // 获取输出参数
        JCoTable outputTable = function.getTableParameterList().getTable("ZTAB_OUT");
        int numRows = outputTable.getNumRows();
        List<OrderBomDTO> resultList = new ArrayList<>();
        OrderBomDTO dto;
        for (int i = 0; i < numRows; i++) {
            outputTable.setRow(i);
            dto = new OrderBomDTO();
            dto.setAUFNR(outputTable.getString("AUFNR"));
            dto.setMATNR(outputTable.getString("MATNR"));
            dto.setWERKS(outputTable.getString("WERKS"));
            dto.setMAKTX(outputTable.getString("MAKTX"));
            dto.setBDMNG(outputTable.getString("BDMNG"));
            dto.setMEINS(outputTable.getString("MEINS"));

            //添加结果集
            resultList.add(dto);
            log.info(dto.toString());
        }
        resultMap.put("zmess", zmess);
        resultMap.put("ztype", ztype);
        resultMap.put("importParameters", items);
        resultMap.put("result", resultList);
        return resultMap;
    }
}