package com.shlanbao.tzsc.data.webservice.server.impl;
|
|
import java.util.concurrent.ExecutorService;
|
import java.util.concurrent.Executors;
|
|
import javax.jws.WebService;
|
|
import org.dom4j.Document;
|
import org.dom4j.DocumentHelper;
|
|
import com.shlanbao.tzsc.base.interceptor.PMSXmlDataInterceptor;
|
import com.shlanbao.tzsc.utils.tools.DateUtil;
|
|
/**
|
* [功能说明]：MES webService interface
|
* @author wanchanghuang
|
* @createTime 2019年4月29日16:46:58
|
*/
|
@WebService
|
public class IPMSWebServiceImpl implements IPMSWebService {
|
// 线程池
|
private static ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
|
|
/**
|
* [说明]：将字符串转换成Document
|
* @author wanchanghuang
|
* @date 2019年4月29日16:42:14
|
*/
|
public Document stringXmlToDoc(String xml) {
|
try {
|
// 1. 清除左右字符串空格
|
xml = xml.trim();
|
// 2 字符串判空
|
if ("".equals(xml)) {
|
System.err.println("ERR:XML数据为空！！！！");
|
return null;
|
}
|
// 3 将字符串转换成document
|
return DocumentHelper.parseText(xml);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return null;
|
}
|
|
/**
|
* [说明]：系统握手信号接口 -同步
|
*
|
* @author wanchanghuang
|
* @date 2019年4月29日16:42:14
|
*/
|
@Override
|
public String MESSendHandshakeSignal(String strXml) {
|
return PMSXmlDataInterceptor.getInstance().MESSendHandshakeSignal(strXml);
|
}
|
|
/**
|
* [功能说明]：工单BOM接口 -同步
|
*
|
* @author wanchanghuang
|
* @createTime 2019年4月29日16:46:58
|
*/
|
@Override
|
public String MESSendWorkOrderBom(String strXml) {
|
try {
|
return PMSXmlDataInterceptor.getInstance().MESSendWorkOrderBom(stringXmlToDoc(strXml),strXml);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return "<?xml version=\"1.0\" encoding=\"UTF-8\"?><dataset><data><Result>2</Result><ReceiveTime>"+DateUtil.getNowDateTime("yyyy-MM-dd HH:mm:ss")+"</ReceiveTime><Reason>ERR：BOM接口异常,XML不是标准的XML格式！！！</Reason></data></dataset>";
|
}
|
/**
|
* [功能说明]：成品主数据接口-异步
|
* @author wanchanghuang
|
* @createTime 2019年5月7日08:14:25
|
* */
|
@Override
|
public void MESSendFinProductData(String strXml) {
|
PMSXmlDataInterceptor.getInstance().MESSendFinProductData(stringXmlToDoc(strXml),strXml);
|
|
}
|
/**
|
* [功能说明]：烟丝 / 滤棒半成品接口-异步
|
* @author wanchanghuang
|
* @createTime 2019年5月7日08:14:25
|
* */
|
@Override
|
public void MESSendSemiFinProductData(String strXml) {
|
PMSXmlDataInterceptor.getInstance().MESSendSemiFinProductData(stringXmlToDoc(strXml),strXml);
|
}
|
/**
|
* [功能说明]：卷包 / 成型 物料主数据 -异步
|
* @author wanchanghuang
|
* @createTime 2019年5月7日08:14:25
|
* */
|
@Override
|
public void MESSendPartData(String strXml) {
|
PMSXmlDataInterceptor.getInstance().MESSendPartData(stringXmlToDoc(strXml),strXml);
|
}
|
/**
|
* [功能说明]：卷包/成型工单下发 -同步
|
* @author wanchanghuang
|
* @createTime 2019年5月7日08:14:25
|
* */
|
@Override
|
public String MESSendWorkOrder(String strXml) {
|
try {
|
return PMSXmlDataInterceptor.getInstance().MESSendWorkOrder(stringXmlToDoc(strXml),strXml);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return "<?xml version=\"1.0\" encoding=\"UTF-8\"?><dataset><data><Result>2</Result><ReceiveTime>"+DateUtil.getNowDateTime("yyyy-MM-dd HH:mm:ss")+"</ReceiveTime><Reason>ERR：工单接口异常,XML不是标准的XML格式！！！</Reason></data></dataset>";
|
}
|
|
/**
|
* [功能说明]：工单撤销接口-同步
|
* @author wanchanghuang
|
* @createTime 2019年5月7日08:14:25
|
* */
|
@Override
|
public String MESSendOrderCancelRequest(String strXml) {
|
try {
|
return PMSXmlDataInterceptor.getInstance().MESSendOrderCancelRequest(stringXmlToDoc(strXml),strXml);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return "<?xml version=\"1.0\" encoding=\"UTF-8\"?><dataset><data><Result>ERR：工单撤销请求接口异常,XML不是标准的XML格式！！！</Result></data></dataset>";
|
}
|
/**
|
* [功能说明]：物料锁定-同步
|
* @author wanchanghuang
|
* @createTime 2019年5月7日08:14:25
|
* */
|
@Override
|
public String MESSendMaterialLock(String strXml) {
|
try {
|
return PMSXmlDataInterceptor.getInstance().MESSendMaterialLock(stringXmlToDoc(strXml),strXml);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return "<?xml version=\"1.0\" encoding=\"UTF-8\"?><dataset><data><Result>ERR：解析异常，请查看XML数据样式是否正确！！！</Result><Message>/Message></data></dataset>";
|
}
|
|
/**
|
* [功能说明]：卷接机台物料告警接口 -异步
|
* @author wanchanghuang
|
* @createTime 2019年5月15日13:00:07
|
* */
|
@Override
|
public void MESSendEquipmentAlarm(String strXml) {
|
try {
|
PMSXmlDataInterceptor.getInstance().MESSendEquipmentAlarm(stringXmlToDoc(strXml),strXml);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
|
|
|
/**
|
* @Title: MESSendRCapacityUnitToDAS
|
* @Description: 额定产能单位标识代码下发接口
|
* @author baoshiwei
|
* @date 2019年5月6日
|
* @param xml
|
* @return
|
*/
|
@Override
|
public String MESSendRCapacityUnitToDAS(String xml) {
|
mesDataReceive("MESSendRCapacityUnitToDAS", xml);
|
return null;
|
}
|
|
/**
|
* @Title: MESSendRSpeedUnitToDAS
|
* @Description: 额定车速单位标识代码下发接口
|
* @author baoshiwei
|
* @date 2019年5月6日
|
* @param xml
|
* @return
|
*/
|
|
@Override
|
public String MESSendRSpeedUnitToDAS(String xml) {
|
mesDataReceive("MESSendRSpeedUnitToDAS", xml);
|
return null;
|
}
|
|
/**
|
* @title: MESSendEquipmentToDAS
|
* @Description: 设备主数据下发接口
|
* @author baoshiwei
|
* @date 2019年5月6日
|
* @param strXml
|
* @return
|
*/
|
@Override
|
public String MESSendEquipmentToDAS(String strXml) {
|
mesDataReceive("MESSendEquipmentToDAS", strXml);
|
return null;
|
}
|
|
|
/**
|
* @Title: MESSendEquipmentWorkOrderToDAS
|
* @Description: 设备保养工单下发接口
|
* @author baoshiwei
|
* @date 2019年5月7日
|
* @param strXml
|
* @return
|
*/
|
@Override
|
public String MESSendEquipmentWorkOrderToDAS(String strXml) {
|
mesDataReceive("MESSendEquipmentWorkOrderToDAS", strXml);
|
return null;
|
}
|
|
/**
|
* @Title: DASSSendEquipmentRepairOrder
|
* @Description: 维修工单下发接口
|
* @author baoshiwei
|
* @date 2019年5月8日
|
* @param strXml
|
* @return
|
*/
|
@Override
|
public String DASSSendEquipmentRepairOrder(String strXml) {
|
mesDataReceive("EquipmentRepairOrder",strXml);
|
return null;
|
}
|
|
/**
|
* @Title: MESSendUnitToDAS
|
* @Description: 计量单位下发接口
|
* @author baoshiwei
|
* @date 2019年5月14日
|
* @param xml
|
* @return
|
*/
|
@Override
|
public String MESSendUnitToDAS(String xml) {
|
mesDataReceive("MESSendUnitToDAS",xml);
|
return null;
|
}
|
|
/**
|
* @Title: MESSendFaultDefinition
|
* @Description: 卷包成型缺陷定义下发接口
|
* @author baoshiwei
|
* @date 2019年5月14日
|
* @param xml
|
* @return
|
*/
|
@Override
|
public String MESSendFaultDefinition(String xml) {
|
mesDataReceive("MESSendFaultDefinition",xml);
|
return null;
|
}
|
|
/**
|
* @Title: MESSendOrderCancelConfirmToDAS
|
* @Description: 工单撤销请求确认接口
|
* @author baoshiwei
|
* @date 2019年5月14日
|
* @param strXml
|
* @return
|
*/
|
@Override
|
public String MESSendOrderCancelConfirmToDAS(String strXml) {
|
mesDataReceive("MESSendOrderCancelConfirmToDAS",strXml);
|
return null;
|
}
|
|
/**
|
* @Title: MESSendParameterSetToDAS
|
* @Description: 工艺标准下发接口 -- 同步
|
* @author baoshiwei
|
* @date 2019年5月14日
|
* @param strXml
|
* @return
|
*/
|
@Override
|
public String MESSendParameterSetToDAS(String strXml) {
|
try {
|
|
return PMSXmlDataInterceptor.getInstance().alalyMESSendParameterSetToDAS("MESSendParameterSetToDAS",strXml,stringXmlToDoc(strXml));
|
} catch (Exception e) {
|
return "<?xml version=\"1.0\" encoding=\"UTF-8\"?><dataset><data><Result>2</Result><Reason>xml解析失败</Reason><ReceiveTime>"+DateUtil.datetoStr(new java.util.Date(), "yyyy-MM-dd HH:mm:ss")+"</ReceiveTime></data></dataset>";
|
}
|
}
|
|
/**
|
* @Title: MESSendShiftsToDAS
|
* @Description: 排班计划下发接口
|
* @author baoshiwei
|
* @date 2019年5月14日
|
* @param strXml
|
* @return
|
*/
|
@Override
|
public String MESSendShiftsToDAS(String strXml) {
|
mesDataReceive("MESSendShiftsToDAS",strXml);
|
return null;
|
}
|
|
/**
|
* @Title: MESSendTestResultToDAS
|
* @Description: 卷包批次检验结果判定
|
* @author baoshiwei
|
* @date 2019年5月14日
|
* @param strXml
|
* @return
|
*/
|
@Override
|
public String MESSendTestResultToDAS(String strXml) {
|
mesDataReceive("MESSendTestResultToDAS",strXml);
|
return null;
|
}
|
|
/**
|
* @Title: MESSendWorkorderIOToDAS
|
* @Description: 工单出入库记录下发接口
|
* @author baoshiwei
|
* @date 2019年5月16日
|
* @param strXml
|
* @return
|
*/
|
@Override
|
public String MESSendWorkorderIOToDAS(String strXml) {
|
mesDataReceive("MESSendWorkorderIOToDAS",strXml);
|
return null;
|
}
|
|
/**
|
* @Title: MESSendProdInventoryToDAS
|
* @Description: 成品入库记录下发接口
|
* @author baoshiwei
|
* @date 2019年5月16日
|
* @param strXml
|
* @return
|
*/
|
@Override
|
public String MESSendProdInventoryToDAS(String strXml) {
|
mesDataReceive("MESSendProdInventoryToDAS",strXml);
|
return null;
|
}
|
|
@Override
|
public String MESSendSparePartsToDAS(String xml) {
|
mesDataReceive("MESSendSparePartsToDAS",xml);
|
return null;
|
}
|
|
|
/**
|
* @Title: mesDataReceive
|
* @Description: webservcie调用的方法，且传递 type，str参数
|
* @author baoshiwei
|
* @date 2019年5月6日
|
* @param type
|
* @param str
|
*/
|
private String mesDataReceive(String type, String str) {
|
str = str.trim();// 去除字符串两边空格
|
Document doc = null;
|
// XML空判断
|
if ("".equals(str)) {
|
return "ERROR:数据异常..." + type + str;
|
}
|
// 将xml字符串转换成document
|
try {
|
doc = DocumentHelper.parseText(str);
|
} catch (Exception e) {
|
PMSXmlDataInterceptor.getInstance().addLog(false, "MES下发转换错误", 2, str,"XML字符串转换Document对象异常！请检查XML数据格式是否规范");
|
System.out.println("ERROR:XML字符串转换Document对象异常..." + str);
|
e.printStackTrace();
|
}
|
// 线程处理
|
final Document fdoc = doc;
|
final String ftype = type;
|
final String fstr = str;
|
cachedThreadPool.execute(new Runnable() {
|
public void run() {
|
|
if ("MESSendEquipmentToDAS".equals(ftype)) {
|
// 设备主数据
|
PMSXmlDataInterceptor.getInstance().alalyMESSendEquipmentToDAS(ftype, fstr, fdoc);
|
} else if("MESSendRCapacityUnitToDAS".equals(ftype)) {
|
// 额定产能
|
PMSXmlDataInterceptor.getInstance().alalyMESSendRCapacityUnitToDAS(ftype, fstr, fdoc);
|
} else if("MESSendRSpeedUnitToDAS".equals(ftype)) {
|
// 额定车速
|
PMSXmlDataInterceptor.getInstance().alalyMESSendRSpeedUnitToDAS(ftype, fstr, fdoc);
|
}else if("MESSendEquipmentWorkOrderToDAS".equals(ftype)){
|
// 设备保养工单
|
PMSXmlDataInterceptor.getInstance().addMesSendEquipmentWorkOrder(ftype,fstr, fdoc);
|
}else if("EquipmentRepairOrder".equals(ftype)){
|
// 维修呼叫工单
|
PMSXmlDataInterceptor.getInstance().addMesSendEquipmentRepairOrder(ftype,fstr, fdoc);
|
}else if("MESSendUnitToDAS".equals(ftype)){
|
// 单位基础数据下发
|
PMSXmlDataInterceptor.getInstance().addMesSendUnit(ftype,fstr, fdoc);
|
}else if("MESSendFaultDefinition".equals(ftype)){
|
// 卷包成型外观缺陷基础数据
|
PMSXmlDataInterceptor.getInstance().alalyMESSendFaultDefinition(ftype,fstr,fdoc);
|
}else if("MESSendOrderCancelConfirmToDAS".equals(ftype)){
|
// MES工单撤销结果 是否确认撤销
|
PMSXmlDataInterceptor.getInstance().alalyMESSendOrderCancelConfirmToDAS(ftype,fstr,fdoc);
|
}else if("MESSendShiftsToDAS".equals(ftype)){
|
// 排班计划
|
PMSXmlDataInterceptor.getInstance().alalyMESSendShiftsToDAS(ftype,fstr,fdoc);
|
}else if("MESSendTestResultToDAS".equals(ftype)){
|
// 卷包批次检验结果判定
|
PMSXmlDataInterceptor.getInstance().alalyMESSendTestResultToDAS(ftype,fstr,fdoc);
|
}else if("MESSendWorkorderIOToDAS".equals(ftype)){
|
// 工单出入库
|
PMSXmlDataInterceptor.getInstance().alalyMESSendWorkorderIOToDAS(ftype,fstr,fdoc);
|
}else if("MESSendProdInventoryToDAS".equals(ftype)){
|
// 成品入库记录
|
PMSXmlDataInterceptor.getInstance().alalyMESSendProdInventoryToDAS(ftype,fstr,fdoc);
|
|
} else if("MESSendSparePartsToDAS".equals(ftype)){
|
// 备件出库记录
|
PMSXmlDataInterceptor.getInstance().alalyMESSendSparePartsToDAS(ftype,fstr,fdoc);
|
}
|
}
|
});
|
return "";
|
|
}
|
|
|
|
|
|
|
|
|
}
|
