Wind与S的集成-低调大师

Wind与S的集成

2018-10-22 632

物料同步，我们首先要搞清楚，同步发生在何时何地。
打开组织的实用程序

打开工作流模板管理

找到图纸发布流程

下载到本地

点击运行，然后使用wcadmin账户登录系统

看到下面的流程图
在靠后的某个OR节点，执行发送物料的表达式（即java代码的方法）

我们仔细看看这部分表达式

代码的具体内容如下：

错误信息=ext.pwst.erp.ERPManager.sendMaterial((wt.fc.WTObject)primaryBusinessObject);
if(错误信息.equals("success")){
   result="通过";
}else{
   result="错误处理";
}

上述代码就是Windchill与SAP集成涉及到的核心方法的调用。
上述核心代码存放在Windchill服务器的什么位置呢？
我们使用xftp连接Windchill服务器进行查看，如下图所示

那么上述java文件的具体内容是怎样的呢？
我们进入自己的开发环境（Server2016）的eclipse中查看开发环境下，SAP集成代码的内容

package ext.pwst.erp;

import java.util.Vector;
import org.apache.log4j.Logger;
import com.ptc.core.meta.server.TypeIdentifierUtility;
import com.sap.mw.jco.JCO;
import ext.pwst.doc.util.IBAHelper;
import wt.change2.ChangeHelper2;
import wt.change2.WTChangeActivity2;
import wt.fc.QueryResult;
import wt.fc.WTObject;
import wt.maturity.MaturityHelper;
import wt.maturity.PromotionNotice;
import wt.method.RemoteAccess;
import wt.method.RemoteMethodServer;
import wt.part.WTPart;
import wt.util.WTException;
import wt.vc.VersionControlHelper;

public class ERPManager implements RemoteAccess {
    
    public static Logger log = Logger.getLogger(ERPManager.class);
    // 1. 
    public static String sendMaterial(WTObject obj){
        try{
            if(!RemoteMethodServer.ServerFlag){
                return (String)RemoteMethodServer.getDefault().invoke("sendMaterial", 
                        ERPManager.class.getName(), null, new Class[]{WTObject.class}, new Object[]{obj});
            }else{
                QueryResult qr = null;
                Vector<WTPart> vecPart = new Vector<WTPart>();
                if(obj instanceof PromotionNotice){
                    PromotionNotice pn = (PromotionNotice)obj;
                    qr = MaturityHelper.service.getPromotionTargets(pn);
                }else if(obj instanceof WTChangeActivity2){
                    WTChangeActivity2 eca = (WTChangeActivity2)obj;
                    qr = ChangeHelper2.service.getChangeablesAfter(eca);
                }
                if(qr != null){
                    while (qr.hasMoreElements()) {
                        WTObject o = (WTObject)qr.nextElement();
                        if(o instanceof WTPart){
                            WTPart part = (WTPart)o;
                            vecPart.add(part);
                        }
                    }
                }
                //调用2 sendMToSAP()
                String ret = sendMToSAP(vecPart);
                return ret;
            }
        }catch(Exception e){
            e.printStackTrace();
            return e.getMessage();
        }
    }
    
    
    /**
     * 2. 发送物料到ERP系统
     * @param part
     * @param mark
     * @return
     * @throws Exception
     */
    public static String sendMToSAP(Vector<WTPart> vecPart) throws Exception{
        boolean mark = false;
        StringBuffer buf = new StringBuffer();
        JCO.Client mConnection = SAPClientUtil.getConnectedClient();
        JCO.Function function = SAPClientUtil.createFunction("Z_PDM_MATERIAL", mConnection);//函数名
        JCO.Table input = function.getTableParameterList().getTable("IM_TAB");
        for(int i = 0; i < vecPart.size(); i++){
            WTPart part = vecPart.get(i);
            part = (WTPart)VersionControlHelper.service.getLatestIteration(part, false);
            input.appendRow();
            log.debug("[sendMToSAP]partnumber:" + part.getNumber());
            //调用3 setTableValue()
            setTableValue(input, part);
            mark = true;
        }
        if(mark){
            mConnection.execute(function);
            JCO.Table output = function.getTableParameterList().getTable("IT_RETURN");
            output.firstRow();
            do{
                String flag = (String)output.getValue("TYPE");
                String number = (String)output.getValue("MATNR");
                String message = (String)output.getValue("MESSAGE");
                log.debug("number:" + number + ";flag:" + flag + ";message:" + message);
                if(flag.equals("E")){
                    if(message.trim().length() > 0)
                        buf.append("物料编号为：" + number + " 的物料，传送erp失败。message:" + message + "\n");
                }
            }while(output.nextRow());
        }
        if(buf.toString().length() == 0){
            buf.append("success");
        }
        return buf.toString();
    }
    
    // 3. 
    public static void setTableValue(JCO.Table input, WTPart part) throws WTException{
        String factory = "";
        String pinpai = "";
        double penqimianji = 0;
        double zhongliang = 0;
        String bianma = "";
        String miaoshu = "";
        String zhongyaodu = "";
        String chanpinxinghao = "";
        String type = TypeIdentifierUtility.getTypeIdentifier(part).getTypename();
        if(type.contains("PWSTXTB.xtbparts")){
            factory = "2000";
            miaoshu = part.getName();
            bianma = part.getNumber();
            penqimianji = IBAHelper.getIBAFloatValue(part, "com.tsmi.pengqimianji");
            zhongliang = IBAHelper.getIBAFloatValue(part, "com.tsmi.zhongliang");
            pinpai = IBAHelper.getIBAStringValue(part, "com.tsmi.pinpai"); 
            pinpai = pinpai == null ? "":pinpai;
            String xinghao = IBAHelper.getIBAStringValue(part, "com.tsmi.xinghao");
            //如果物料型号属性存在且型号编码不超过18位，则型号作为物料号传给erp，否则传编号
            if(xinghao != null && xinghao.length() > 0){
                if(xinghao.length() > 18){
                    bianma = part.getNumber();
                    miaoshu = part.getName() + " " + xinghao;
                }else{
                    bianma = xinghao;
                    miaoshu = part.getName() + " " + part.getNumber();
                }
            }
        }else{
            //技术部部件  重要度，产品型号
            factory = "1000";
            //重要度    01 安全 ；02 重要；03一般
        }
        String unit = part.getDefaultUnit().toString().toUpperCase();
        //调用4 toERPUnit()
        unit = toERPUnit(unit);
        log.debug("[setTableValue]bianma:" + bianma + " miaoshu:" + miaoshu + " unit:" + unit 
                 + " zhongliang:" + zhongliang + " penqimianji:" + penqimianji
                + " zhongyaodu:" + zhongyaodu + " chanpinxinghao:" + chanpinxinghao + " factory:" + factory + " pinpai:" + pinpai);
        input.setValue(bianma, "MATNR");   //物料编码
        input.setValue(miaoshu, "MAKTX");     //物料描述
        input.setValue(unit, "MEINS");         //单位
        input.setValue("Z001", "MTART");     //物料类型
        input.setValue(zhongliang, "NTGEW");     //重量
        input.setValue(penqimianji, "VOLUM");     //涂装面积
        input.setValue(zhongyaodu, "TEMPB");     //重要度
        input.setValue(chanpinxinghao, "WRKST");     //产品型号
        input.setValue("1000", "PRCTR");     //利润中心
        input.setValue(pinpai, "ZEINR");     //品牌
        input.setValue("X", "XMCNG");        //是否允许负库存
        input.setValue(factory, "WERKS");     //工厂
    }
    
    //4.
    public static String toERPUnit(String unit){
        if(unit.equals("EA")){
            return "EA";
        }else if(unit.equals("KG")){
            return "KG";
        }else if(unit.equals("M")){
            return "M";
        }else if(unit.equals("L")){
            return "L";
        }else if(unit.equals("SQ_M")){
            return "M2";
        }else if(unit.equals("MIN")){
            return "MIN";
        }else if(unit.equals("CU_M")){
            return "M3";
        }else if(unit.equals("KM")){
            return "KM";
        }else if(unit.equals("MM")){
            return "MM";
        }else if(unit.equals("CAN")){
            return "CAN";
        }else if(unit.equals("DEG")){
            return "DEG";
        }else if(unit.equals("BLANK")){
            return "EA";
        }else if(unit.equals("PC")){
            return "PC";
        }else{
            return "";
        }
    }
}

package ext.pwst.erp;

import java.util.HashMap;
import java.util.Map;

import com.sap.mw.jco.IFunctionTemplate;
import com.sap.mw.jco.JCO;

import ext.pwst.conf.ConfigUtil;

public class SAPClientUtil {
    public static JCO.Client getConnectedClient(){
        
        String clientV = ConfigUtil.getProperty("SAP_CLIENT");
        String user = ConfigUtil.getProperty("SAP_USRE");
        String pwd = ConfigUtil.getProperty("SAP_PASSWORD");
        String lang = ConfigUtil.getProperty("SAP_LANG");
        String ipAddress = ConfigUtil.getProperty("SAP_IPADDRESS");
        String sync = ConfigUtil.getProperty("SAP_SYSNR");
        
        JCO.Client client = JCO.createClient(clientV, user, pwd, lang, ipAddress, sync);
        client.connect();
        
        return client;
    }

    public static JCO.Function createFunction(String name, JCO.Client client) throws Exception {
        JCO.Repository repository = new JCO.Repository("ARAsoft", client);
        try {
            IFunctionTemplate ft = repository.getFunctionTemplate(name.toUpperCase());
            if (ft == null)
                return null;
            return ft.getFunction();
        } catch (Exception ex) {
            throw new Exception("Problem retrieving JCO.Function object.");
        }
    }
    
    public static JCO.Table callRFC(String funcName, String paramName, String paramValue, String returnTab) throws Exception{
        Map<String, String> params = new HashMap<String, String>();
        params.put(paramName, paramValue);
        
        return callRFC(funcName, params, returnTab);
    }
    
    public static JCO.Table callRFC(String funcName, String paramName, String paramValue, String returnTab, JCO.Client client) throws Exception{
        Map<String, String> params = new HashMap<String, String>();
        params.put(paramName, paramValue);
        
        return callRFC(funcName, params, returnTab, client);
    }
    
    public static JCO.Table callRFC(String funcName, Map<String, String> params, String returnTab) throws Exception{
        return callRFC(funcName, params).getTableParameterList().getTable(returnTab);
    }
    
    public static JCO.Table callRFC(String funcName, Map<String, String> params, String returnTab, JCO.Client client) throws Exception{
        return callRFC(funcName, params, client).getTableParameterList().getTable(returnTab);
    }
    
    public static JCO.Function callRFC(String funcName, Map<String, String> params) throws Exception{
        JCO.Client client = null;
        try{
            client = SAPClientUtil.getConnectedClient();
            return callRFC(funcName, params, client);
        }catch(Exception e){
            throw e;
        }finally{
            if(client != null){
                client.disconnect();
                client = null;
            }
        }
    }
    
    public static JCO.Function callRFC(String funcName, Map<String, String> params, JCO.Client client) throws Exception{
        client = SAPClientUtil.getConnectedClient();
        JCO.Function function = createFunction(funcName, client);
        JCO.ParameterList input = function.getImportParameterList();
        if(params != null){
            for(String key : params.keySet())
                input.setValue(params.get(key), key);
        }
        
        client.execute(function);
        return function;
    }
}

微信关注我们

原文链接：https://yq.aliyun.com/articles/656390

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

一位程序猿面试蚂蚁金服后端的经验总结！

前言今天本是一个阳光明媚，鸟语花香的日子。于是我决定在逛街中感受春日的阳光~结果晚上七点的时候，蚂蚁金服后端大佬来了电话，要进行一轮的技术面试。我一脸黑人问号？？？现在的面试都流行突袭吗？于是我的第一次面试之旅，就此壮烈的展开。自我介绍首先呢，大佬让我用两分钟自我介绍。我本以为自己能滔滔不绝，将对方视作相亲对象般全方位介绍自己。结果不到半分钟，我就介绍完了==。五秒钟的沉默后，大佬嗯了一声。感觉自己的脸上堆满了尴尬而不失礼貌的微笑。最近的项目经历这时大佬问我最近从事了什么项目，研究生阶段都进行了什么样的工作。那必须吹一吹！从JAVA的起源到Spring的发展再到jenkin的使用顺便提一嘴dva+antd，结果半分钟一到，又说不下去了== 大佬很有耐心的听我说了一堆语无伦次的话，开始进入正题。 Spring 大佬：我看你用过这个Spring啊，你来聊聊为什么我们要使用Spring呢？我：（因为大家都说好啊）首先呢，spring是一个庞大的框架，它封装了很多成熟的功能能够让我们无需重复造轮子。其次呢，它使用IOC进行依赖管理，我们就不用自己初始化实例啦。大佬：（我就...

2018-10-23

478

NumPy（Numerical Python）是 Python 中的一个线性代数库。对每一个数据科学或机器学习 Python 包而言，这都是一个非常重要的库，SciPy（Scientific Python）、Mat-plotlib（plotting library）、Scikit-learn 等都在一定程度上依赖 NumPy。对数组执行数学运算和逻辑运算时，NumPy 是非常有用的。在用 Python 对 n 维数组和矩阵进行运算时，NumPy 提供了大量有用特征。这篇教程介绍了数据科学初学者需要了解的 NumPy 基础知识，包括如何创建 NumPy 数组、如何使用 NumPy 中的广播机制、如何获取值以及如何操作数组。更重要的是，大家可以通过本文了解到 NumPy 在 Python 列表中的优势：更简洁、更快速地读写项、更方便、更高效。本教程将使用 Jupyter notebook 作为编辑器。让我们开始吧！安装 NumPy 如果你已经装有 Anaconda，那么你可以使用以下命令通过终端或命令提示符安装 NumPy： conda install numpy 如果你没有 A...

2018-10-23

533

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。