内配订单推PLM调整

mmpac/src/private/nc/bs/mmpac/pmo/pac0002/bp/rule/AfterApproveSyncPLMRule.java

@@ -1,10 +1,8 @@
 package nc.bs.mmpac.pmo.pac0002.bp.rule;
 
-import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.google.gson.Gson;
-import nc.bs.dao.BaseDAO;
 import nc.bs.dao.DAOException;
 import nc.bs.framework.common.InvocationInfoProxy;
 import nc.bs.logging.Log;
@@ -12,8 +10,6 @@ import nc.bs.trade.business.HYPubBO;
 import nc.bs.trade.business.HYSuperDMO;
 import nc.bs.uapbd.util.MyHelper;
 import nc.impl.pubapp.pattern.rule.IRule;
-import nc.jdbc.framework.processor.MapProcessor;
-import nc.uif.pub.exception.UifException;
 import nc.vo.bd.defdoc.DefdocVO;
 import nc.vo.cmp.util.StringUtils;
 import nc.vo.mmpac.pmo.pac0002.entity.PMOAggVO;
@@ -42,6 +38,8 @@ import java.util.Map;
 
 /**
  * BIP 系统将生产订单类型为“内配订单 ”的生产订单按照物料编码+项目号向PLM 传递设计任务， PLM 方接收后根据项目号，与成套产品设计任务挂载到相同位置。
+ *
+ * @author lihao
  */
 public class AfterApproveSyncPLMRule implements IRule<PMOAggVO> {
 
@@ -58,6 +56,7 @@ public class AfterApproveSyncPLMRule implements IRule<PMOAggVO> {
 
 
     private Map<String, String> configParams;
+
     @Override
     public void process(PMOAggVO[] pmoAggVOS) {
         if (ArrayUtil.isEmpty(pmoAggVOS)) {
@@ -72,10 +71,10 @@ public class AfterApproveSyncPLMRule implements IRule<PMOAggVO> {
                 return;
             }
 
-            // 推送到锐制系统
+            // 推送到思普PLM系统
             pushToRZMOM(filteredOrders);
         } catch (Exception e) {
-            logDl.error("同步生产订单到RZ系统失败: " + e.getMessage());
+            logDl.error("同步生产订单到SPPLM系统失败: " + e.getMessage());
             ExceptionUtils.wrappException(e);
         }
     }
@@ -99,7 +98,7 @@ public class AfterApproveSyncPLMRule implements IRule<PMOAggVO> {
                 if (itemVO != null) {
 //                   NO	产品品号	 cmaterialvid	物料编码
 //                   NAME	产品名称	name	物料名称
-//                   ASUSER34	项目名称	project_name	项目名称
+//                   ASUSER34	项目名称	projectName	项目名称
 //                   ASUSER28	生产计划号	vsrccode	来源单据号	销售订单号
 //                   AB012	数量	nastnum	数量
 //                   GSDM	公司代码
@@ -111,17 +110,16 @@ public class AfterApproveSyncPLMRule implements IRule<PMOAggVO> {
                     Object no = hybo.findColValue("bd_material", "code", "pk_material = '" + itemVO.getCmaterialvid() + "' ");
 
                     Object name = hybo.findColValue("bd_material", "name", "pk_material = '" + itemVO.getCmaterialvid() + "' ");
-                   Object pk_project = hybo.findColValue("bd_project", "project_name", " pk_project = '" + itemVO.getCprojectid() + "' ");
+                    Object projectName = hybo.findColValue("bd_project", "projectName", " pk_project = '" + itemVO.getCprojectid() + "' ");
-
                     Object GSDM = hybo.findColValue("org_factory", "code", " pk_factory = '" + parentVO.getPk_org() + "' ");
 
                     request.put("no", no);
 
                     request.put("name", name);
 
-                   request.put("ASUSER34", pk_project);
+                    request.put("ASUSER34", projectName);
 
-                   request.put("ASUSER28", itemVO.getVsrccode());
+                    request.put("ASUSER28", itemVO.getVfirstcode());
                     request.put("AB012", itemVO.getNastnum());
 
                     request.put("GSDM", GSDM);
@@ -148,12 +146,12 @@ public class AfterApproveSyncPLMRule implements IRule<PMOAggVO> {
             plmBaseUrl = configParams.get("plmBaseUrl");
             plmUser = configParams.get("plmUser");
             token = getToken();
-            logDl.info("请求参数 ："+jsonArrayStr);
+            logDl.error("AfterApproveSyncPLMRule-param = " + jsonArrayStr);
             String responseString = this.doPost(plmBaseUrl + pmourl, jsonArrayStr);
-            logDl.info("返回结果 ："+responseString);
+            logDl.error("AfterApproveSyncPLMRule-res = " + responseString);
             Gson gson = new Gson();
             Map result = gson.fromJson(responseString, Map.class);
-            if (!result.get("success").toString().equals("true")) {
+            if (!"true".equals(result.get("success").toString())) {
                 throw new BusinessException(result.get("msg").toString());
             }
 
@@ -183,6 +181,7 @@ public class AfterApproveSyncPLMRule implements IRule<PMOAggVO> {
 
         return filteredOrders;
     }
+
     public Map<String, String> getConfigParams(String code) {
         Map<String, String> map = new HashMap<>();
         String strWhere = " pk_defdoclist in (select pk_defdoclist from bd_defdoclist where code='[code]' and dr=0 ) and dr=0";
@@ -200,6 +199,7 @@ public class AfterApproveSyncPLMRule implements IRule<PMOAggVO> {
         }
         return map;
     }
+
     private String doPost(String requestUrl, String param) throws IOException {
         PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
         cm.setMaxTotal(500);
@@ -221,8 +221,6 @@ public class AfterApproveSyncPLMRule implements IRule<PMOAggVO> {
     }
 
 
-
-
     /**
      * 获取token
      */
@@ -239,6 +237,7 @@ public class AfterApproveSyncPLMRule implements IRule<PMOAggVO> {
         }
         return token;
     }
+
     private String doGet(String requestUrl, Map<String, String> paramMap) throws IOException {
         PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
         cm.setMaxTotal(5000);
@@ -267,4 +266,5 @@ public class AfterApproveSyncPLMRule implements IRule<PMOAggVO> {
         get.releaseConnection();
         return responseString;
     }
+
 }