新火炬后端单体项目初始化代码
blame | 历史 | 补丁 | 提交 | 提交对比 | 显示空白
cuilei
2025-08-07 60025c612e4d068255d498ad69fb737ff27bf521 
 src/main/java/org/jeecg/modules/sap/service/impl/ProductionOrderSyncImpl.java


@@ -1,7 +1,14 @@


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




import com.sap.conn.jco.*;


import com.alibaba.fastjson.JSONObject;


import com.sap.conn.jco.JCoDestination;


import com.sap.conn.jco.JCoFunction;


import com.sap.conn.jco.JCoRepository;


import com.sap.conn.jco.JCoTable;


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.ProductionOrderDTO;


@@ -10,7 +17,9 @@


import org.springframework.stereotype.Service;




import java.util.ArrayList;


import java.util.HashMap;


import java.util.List;


import java.util.Map;




/**


 * 生成订单同步服务


@@ -18,26 +27,15 @@


@Service


@Slf4j


public class ProductionOrderSyncImpl implements ProductionOrderSync {


    //新火炬工厂编码


    private static final String factoryCode = "2301";


    //标准生产订单


    private static final String orderTypeCode1 = "Z001";


    //返工订单  暂时不用


    private static final String orderTypeCode2 = "Z002";


    //八分厂调度员


//    private static final String productionManager = "012";


    private static final String productionManager = "010";


    //生产订单状态 CRTD 新建，REL 下达，TECO 关闭  实际上，只有REL状态的工单才可以进行操作


    private static final String orderStatus = "REL";




    @Autowired


    private SapRfcConnectionManager connectionManager;






    @Override


    public void syncProductionOrder() {


    @ApiLog(apiName = "生产订单同步(ZPPF_033_1)", apiCategory = ApiLogCategoryEnum.SAP)


    public Map<String, Object> syncProductionOrder(String factoryCode, String orderTypeCode, String productionManager, String orderStatus, String createTimeLow, String createTimeHigh, String updateTimeLow, String updateTimeHigh) throws Exception {


        Map<String, Object> resultMap = new HashMap<>();


        JCoDestination destination = connectionManager.getDestination();


        try {


            JCoRepository repository = destination.getRepository();


            JCoFunction function = repository.getFunction(FunctionConst.ZPPF_033_1);


            if (function == null) {


@@ -46,31 +44,99 @@


            // 设置输入参数


            //订单号查询条件


//            JCoTable AUFNRTable = function.getTableParameterList().getTable("ZTAB_AUFNR");


        List<JSONObject> items = new ArrayList<>();


            //订单类型 标准生产订单


        if(StringUtils.isNotBlank(orderTypeCode)){


            JCoTable AUARTTable = function.getTableParameterList().getTable("ZTAB_AUART");


            String[] split = orderTypeCode.split(",");


            for(String code : split){


            AUARTTable.appendRow();


            AUARTTable.setValue("AUART", orderTypeCode1);


            //八分厂调度


                AUARTTable.setValue("AUART", code);


            }


            //组装请求参数


            JSONObject item = new JSONObject();


            item.put("AUART", orderTypeCode);


            items.add(item);


        }


        if(StringUtils.isNotBlank(productionManager)){


            JCoTable FEVORTable = function.getTableParameterList().getTable("ZTAB_FEVOR");


            String[] split = productionManager.split(",");


            for(String code : split){


            FEVORTable.appendRow();


            FEVORTable.setValue("FEVOR", productionManager);


                FEVORTable.setValue("FEVOR", code);


            }


            //组装请求参数


            JSONObject item = new JSONObject();


            item.put("FEVOR", productionManager);


            items.add(item);


        }


        if(StringUtils.isNotBlank(factoryCode)){


            //新火炬


            JCoTable WERKSTable = function.getTableParameterList().getTable("ZTAB_WERKS");


            String[] split = factoryCode.split(",");


            for(String code : split){


            WERKSTable.appendRow();


            WERKSTable.setValue("WERKS", factoryCode);


            //订单状态


                WERKSTable.setValue("WERKS", code);


            }


            //组装请求参数


            JSONObject item = new JSONObject();


            item.put("WERKS", factoryCode);


            items.add(item);


        }


        if(StringUtils.isNotBlank(orderStatus)) {


            //新火炬


            JCoTable TXT04Table = function.getTableParameterList().getTable("ZTAB_TXT04");


            String[] split = orderStatus.split(",");


            for(String code : split){


            TXT04Table.appendRow();


            TXT04Table.setValue("TXT04", orderStatus);


                TXT04Table.setValue("TXT04", code);


            }


            //组装请求参数


            JSONObject item = new JSONObject();


            item.put("TXT04", orderStatus);


            items.add(item);


        }


        if(StringUtils.isNotBlank(createTimeLow)){


            JCoTable UDATETable = function.getTableParameterList().getTable("ZTAB_UDATE");


            UDATETable.appendRow();


            UDATETable.setValue("LOW", createTimeLow);


            //组装请求参数


            JSONObject item = new JSONObject();


            item.put("ZTAB_UDATE_LOW", createTimeLow);


            items.add(item);


        }


        if(StringUtils.isNotBlank(createTimeHigh)){


            JCoTable UDATETable = function.getTableParameterList().getTable("ZTAB_UDATE");


            UDATETable.appendRow();


            UDATETable.setValue("HIGH", createTimeHigh);


            //组装请求参数


            JSONObject item = new JSONObject();


            item.put("ZTAB_UDATE_HIGH", createTimeHigh);


            items.add(item);


        }


        if(StringUtils.isNotBlank(updateTimeLow)){


            JCoTable LAEDATable = function.getTableParameterList().getTable("ZTAB_LAEDA");


            LAEDATable.appendRow();


            LAEDATable.setValue("LOW", updateTimeLow);


            //组装请求参数


            JSONObject item = new JSONObject();


            item.put("ZTAB_LAEDA_LOW", updateTimeLow);


            items.add(item);


        }


        if(StringUtils.isNotBlank(updateTimeHigh)){


            JCoTable LAEDATable = function.getTableParameterList().getTable("ZTAB_LAEDA");


            LAEDATable.appendRow();


            LAEDATable.setValue("HIGH", updateTimeLow);


            //组装请求参数


            JSONObject item = new JSONObject();


            item.put("ZTAB_LAEDA_HIGH", updateTimeLow);


            items.add(item);


        }


            // 执行调用


            function.execute(destination);


            //获取返回结果


            String zmess = function.getExportParameterList().getValue("ZMESS").toString();


            String ztype = function.getExportParameterList().getValue("ZTYPE").toString();//S 标识 成功


            if(!"S".equals(ztype)){


                log.error("获取订单信息失败，ZTYPE={}, ZMESS={}", ztype, zmess);


                return;


            }


            // 获取输出参数


            JCoTable outputTable = function.getTableParameterList().getTable("ZTAB_OUT");


            int numRows = outputTable.getNumRows();


@@ -108,8 +174,10 @@


                resultList.add(dto);


                log.info(dto.toString());


            }


        } catch (JCoException e) {


            log.error(e.getMessage(), e);


        }


        resultMap.put("zmess", zmess);


        resultMap.put("ztype", ztype);


        resultMap.put("importParameters", items);


        resultMap.put("result", resultList);


        return resultMap;


    }


}