package com.jcdm.main.webservice.service; import cn.hutool.json.JSONObject; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; import com.google.gson.Gson; import com.google.gson.JsonObject; import com.jcdm.main.da.collectionParamConf.service.IDaCollectionParamConfService; import com.jcdm.main.da.opcuaconfig.init.BeanUtils; import com.jcdm.main.om.productionOrde.domain.OmProductionOrdeInfo; import com.jcdm.main.om.productionOrde.service.IOmProductionOrdeInfoService; import com.jcdm.main.om.workReport.service.IOmWorkReportService; import com.jcdm.main.webservice.domain.Item; import com.jcdm.main.webservice.domain.ItemList; import org.apache.commons.httpclient.HttpClient; import org.apache.commons.httpclient.UsernamePasswordCredentials; import org.apache.commons.httpclient.auth.AuthScope; import org.apache.commons.httpclient.methods.PostMethod; import org.apache.commons.httpclient.methods.RequestEntity; import org.apache.commons.httpclient.methods.StringRequestEntity; import org.apache.commons.io.IOUtils; import com.jcdm.main.om.productionOrde.*; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.RestController; import javax.swing.border.Border; import java.io.IOException; import java.io.InputStream; import java.io.UnsupportedEncodingException; import java.util.List; public class ReceivingServices { @Autowired // private static IOmProductionOrdeInfoService omProductionOrdeInfoService; private static IOmProductionOrdeInfoService omProductionOrdeInfoService = BeanUtils.getBean(IOmProductionOrdeInfoService.class); public static final String ProductionPlanInformationUrl = "http://podqapp.cfmoto.com.cn:50200/XISOAPAdapter/MessageServlet?senderParty=&senderService=BC_MES&receiverParty=&receiverService=&interface=SI_ZPP_CF_MES_005_SYN_OUT&interfaceNamespace=http://cfmoto.com/xi/MES"; public static void main(String[] args) throws Exception { // getInterfaceInformationXml(ProductionPlanInformationUrl,getProductionPlanInformationXml("A0055577")); // test1(); // String serviceUrl = "http://podqapp.cfmoto.com.cn:50200/XISOAPAdapter/MessageServlet?senderParty=&senderService=BC_MES&receiverParty=&receiverService=&interface=SI_ZPP_CF_MES_005_SYN_OUT&interfaceNamespace=http://cfmoto.com/xi/MES"; // String serviceUrl = "http://podqapp.cfmoto.com.cn:50200/XISOAPAdapter/MessageServlet?senderParty=&senderService=BC_MES&receiverParty=&receiverService=&interface=SI_ZPP_CF_BC_001_SYN_OUT&interfaceNamespace=http://cfmoto.com/xi/MES"; //// String content = "\n" + //// " \n" + //// " \n" + //// " \n" + //// " \n" + //// " 1000\n" + //// " \n" + //// " A0055577\n" + //// " \n" + //// " \n" + //// ""; // String content = "\n" + // " \n" + // " \n" + // " \n" + // " 000010569212\n" + // " 0010\n" + // " 1\n" + // " 0 \n" + // " 1 \n" + // " \n" + // " \n" + // ""; // // HttpClient发送SOAP请求 // int timeout = 10000; // HttpClient client = new HttpClient(); // //如果需要用户名密码验证;不需要验证登录则不需要以下4行 // String username = "POMESUSER"; // String password = "12345tgb"; // UsernamePasswordCredentials creds = new UsernamePasswordCredentials(username, password); // client.getState().setCredentials(AuthScope.ANY, creds); // // PostMethod postMethod = new PostMethod(serviceUrl); // // 设置连接超时 // client.getHttpConnectionManager().getParams().setConnectionTimeout(timeout); // // 设置读取时间超时 // client.getHttpConnectionManager().getParams().setSoTimeout(timeout); // // 然后把Soap请求数据添加到PostMethod中 // RequestEntity requestEntity = new StringRequestEntity(content, "text/xml", "UTF-8"); // // // 设置请求头部,否则可能会报 “no SOAPAction header” 的错误 // postMethod.setRequestHeader("SOAPAction", ""); // // 设置请求体 // postMethod.setRequestEntity(requestEntity); // int status = client.executeMethod(postMethod); // // if (status == 200) {// 成功 // InputStream is = postMethod.getResponseBodyAsStream(); // // 获取请求结果字符串 // String result = IOUtils.toString(is); //// String jsonStr = xmlToJSON2(result); //// Gson gson = new Gson(); //// // 将json字符串转换成对象 //// ItemList itemList = gson.fromJson(jsonStr, ItemList.class); // System.out.println("返回结果:" + result); // } else { // System.out.println("错误代码:" + status + ":" + postMethod.getResponseBodyAsString()); // } } public static void insertWebserviceData(String str) { String result = getInterfaceInformationXml(ProductionPlanInformationUrl, getProductionPlanInformationXml(str)); String jsonStr = xmlToJSON2(result); Gson gson = new Gson(); // 将json字符串转换成对象 ItemList itemList = gson.fromJson(jsonStr, ItemList.class); for (Item item : itemList.getItem()) { OmProductionOrdeInfo ordeInfo = new OmProductionOrdeInfo(); ordeInfo.setProductCode(item.getPLNBEZ()); ordeInfo.setProductName(item.getMAKTX()); ordeInfo.setLineCode(item.getFEVOR()); ordeInfo.setWorkOrderNo(item.getAUFNR()); ordeInfo.setPlanQty((long) Double.parseDouble(item.getPSMNG())); ordeInfo.setProductionNotice(item.getZSCTZD()); ordeInfo.setTypeZ(item.getFERTH()); ordeInfo.setCreateUser(item.getZUSER()); ordeInfo.setCreateTime(item.getZDATE()); omProductionOrdeInfoService.insertOmProductionOrdeInfo(ordeInfo); } } public static String getInterfaceInformationXml(String url,String xml){ int timeout = 10000; HttpClient client = new HttpClient(); //如果需要用户名密码验证;不需要验证登录则不需要以下4行 String username = "POMESUSER"; String password = "12345tgb"; UsernamePasswordCredentials creds = new UsernamePasswordCredentials(username, password); client.getState().setCredentials(AuthScope.ANY, creds); PostMethod postMethod = new PostMethod(url); // 设置连接超时 client.getHttpConnectionManager().getParams().setConnectionTimeout(timeout); // 设置读取时间超时 client.getHttpConnectionManager().getParams().setSoTimeout(timeout); // 然后把Soap请求数据添加到PostMethod中 RequestEntity requestEntity = null; try { requestEntity = new StringRequestEntity(xml, "text/xml", "UTF-8"); } catch (UnsupportedEncodingException e) { throw new RuntimeException(e); } // 设置请求头部,否则可能会报 “no SOAPAction header” 的错误 postMethod.setRequestHeader("SOAPAction", ""); // 设置请求体 postMethod.setRequestEntity(requestEntity); int status = 0; try { status = client.executeMethod(postMethod); } catch (IOException e) { throw new RuntimeException(e); } if (status == 200) {// 成功 InputStream is = null; try { is = postMethod.getResponseBodyAsStream(); } catch (IOException e) { throw new RuntimeException(e); } // 获取请求结果字符串 String result = null; try { result = IOUtils.toString(is); return result; } catch (IOException e) { throw new RuntimeException(e); } } return "接口调用错误"; } public static String getProductionPlanInformationXml(String str){ String content = "\n" + " \n" + " \n" + " \n" + " \n" + " 1000\n" + " \n" + " "+str+"\n" + " \n" + " \n" + ""; return content; } /** * 方式--贰 * 使用hutool工具包中的工具转化 * @param xmlStr * @return */ public static String xmlToJSON2(String xmlStr){ JSONObject jsonObject1 = cn.hutool.json.XML.toJSONObject(xmlStr, true); Gson gson = new Gson(); JsonObject jsonObject2 = gson.fromJson(jsonObject1.toString(), JsonObject.class); JsonObject etData = jsonObject2 .getAsJsonObject("SOAP:Envelope") .getAsJsonObject("SOAP:Body") .getAsJsonObject("n0:ZPP_CF_MES_005.Response") .getAsJsonObject("ET_DATA"); return etData.toString(); } /** * 方式--贰 * 使用hutool工具包中的工具转化 * @param xmlStr * @return */ public static String xmlToJSON3(String xmlStr){ String status = ""; if(xmlStr.contains("EV_STATUS")){ JSONObject jsonObject1 = cn.hutool.json.XML.toJSONObject(xmlStr, true); ObjectMapper objectMapper = new ObjectMapper(); JsonNode rootNode = null; try { rootNode = objectMapper.readTree(String.valueOf(jsonObject1)); } catch (JsonProcessingException e) { throw new RuntimeException(e); } String evStatus = rootNode .path("SOAP:Envelope") .path("SOAP:Body") .path("n0:ZPP_BC_001.Response") .path("EV_STATUS") .asText(); status = evStatus; } return status; } }