package com.vci.server.omd.lifecycle.service;
|
|
import java.sql.Clob;
|
import java.sql.Connection;
|
import java.sql.PreparedStatement;
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.sql.Timestamp;
|
import java.util.ArrayList;
|
import java.util.Calendar;
|
import java.util.Iterator;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Set;
|
import java.util.Map.Entry;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.dom4j.Document;
|
import org.dom4j.DocumentException;
|
import org.dom4j.Element;
|
import org.dom4j.io.SAXReader;
|
|
import com.vci.common.log.ServerWithLog4j;
|
import com.vci.common.utility.ObjectUtility;
|
import com.vci.corba.common.VCIError;
|
import com.vci.corba.omd.lcm.Bound;
|
import com.vci.corba.omd.lcm.LifeCycle;
|
import com.vci.corba.omd.lcm.TransationHistoryRecord;
|
import com.vci.corba.omd.lcm.TransitionVO;
|
import com.vci.omd.constants.OmdConstants;
|
import com.vci.server.base.persistence.dao.HibernateSessionFactory;
|
import com.vci.server.omd.lifecycle.delegate.LifeCycleServerDelegate;
|
import com.vci.server.omd.common.LifeCycleHelper;
|
import com.vci.server.omd.lifecycle.LifeCycleServerUtil;
|
import com.vci.server.omd.lifecycle.LifeCycleServiceImpl;
|
|
public class LifeCycleService {
|
private static LifeCycleService instance;
|
|
private LifeCycleService() {
|
|
}
|
|
public static LifeCycleService getInstance() {
|
if (instance == null) {
|
instance = new LifeCycleService();
|
}
|
|
return instance;
|
}
|
|
public boolean addLifeCyle(LifeCycle lc) throws Exception {
|
boolean flag = false;
|
String insertSql = "insert into pllifecycle values(?,?,?,?,?,?,?,?,?,xmltype(?))";
|
Connection connection = HibernateSessionFactory.getSessionConnection();
|
PreparedStatement pst = connection.prepareStatement(insertSql);
|
|
String id = lc.id;
|
if (StringUtils.isBlank(id)) {
|
id = ObjectUtility.getNewObjectID36();
|
lc.id = id;
|
}
|
pst.setString(1, id);
|
pst.setString(2, lc.name);
|
pst.setString(3, lc.tag);
|
pst.setString(4, lc.description);
|
long time = Calendar.getInstance().getTimeInMillis();
|
Timestamp ts = new Timestamp(time);
|
pst.setTimestamp(5, ts);
|
pst.setString(6, lc.creator);
|
pst.setTimestamp(7, ts);
|
pst.setString(8, lc.modifier);
|
pst.setTimestamp(9, ts);
|
String xmlText = LifeCycleHelper.getInstance().getXmlText(lc);
|
// CLOB content =
|
// LifeCycleServerDelegate.getInstance().getXmlTypeContent(xmlText, connection);
|
// pst.setObject(10, content);
|
pst.setString(10, xmlText);
|
pst.executeUpdate();
|
ServerWithLog4j.logger.debug(insertSql);
|
pst.close();
|
flag = true;
|
return flag;
|
}
|
|
public boolean modifyLifeCyle(LifeCycle lc) throws Exception {
|
boolean flag = false;
|
String sql = "update pllifecycle t set t.name=?, t.label=?, t.description=?, t.ts=?, t.creator=?, t.createtime=?, t.modifier=?, t.modifytime=?, t.content=xmltype(?) where t.oid=? and t.ts = ?";
|
Connection conn = HibernateSessionFactory.getSessionConnection();
|
PreparedStatement pst = conn.prepareStatement(sql);
|
pst.setString(1, lc.name);
|
pst.setString(2, lc.tag);
|
pst.setString(3, lc.description);
|
long time = Calendar.getInstance().getTimeInMillis();
|
Timestamp ts = new Timestamp(time);
|
pst.setTimestamp(4, ts);
|
pst.setString(5, lc.creator);
|
pst.setTimestamp(6, new Timestamp(lc.createTime));
|
pst.setString(7, lc.modifier);
|
pst.setTimestamp(8, ts);
|
String xmlText = LifeCycleHelper.getInstance().getXmlText(lc);
|
// CLOB content =
|
// LifeCycleServerDelegate.getInstance().getXmlTypeContent(xmlText, conn);
|
// pst.setObject(9, content);
|
pst.setString(9, xmlText);
|
pst.setString(10, lc.oid);
|
pst.setTimestamp(11, Timestamp.valueOf(lc.ts));
|
pst.executeUpdate();
|
ServerWithLog4j.logger.debug(sql);
|
pst.close();
|
flag = true;
|
return flag;
|
}
|
|
public boolean deleteLifeCyle(LifeCycle lc) throws Exception {
|
boolean flag = false;
|
String sql = "delete from pllifecycle where oid = ? and ts = ?";
|
Connection connection = HibernateSessionFactory.getSessionConnection();
|
PreparedStatement pst = connection.prepareStatement(sql);
|
pst.setString(1, lc.oid);
|
String ts = lc.ts;
|
pst.setTimestamp(2, Timestamp.valueOf(ts));
|
pst.executeUpdate();
|
ServerWithLog4j.logger.debug(sql);
|
pst.close();
|
flag = true;
|
return flag;
|
}
|
|
/**
|
* 删除生命周期
|
*
|
* @throws Exception
|
*/
|
|
public boolean deleteLifeCyles(LifeCycle[] lcs) throws Exception {
|
boolean flag = false;
|
for (LifeCycle lc : lcs) {
|
deleteLifeCyle(lc);
|
}
|
flag = true;
|
return flag;
|
}
|
|
public LifeCycle[] getLifeCyles() throws Exception {
|
String sql = "";
|
|
switch (HibernateSessionFactory.getDbType()) {
|
case DM8:
|
sql = "select oid, name, label, description, ts, creator, createtime, modifier, modifytime, content from pllifecycle t";
|
break;
|
case ORACL:
|
default:
|
sql = "select oid, name, label, description, ts, creator, createtime, modifier, modifytime, t.content.getclobval() content from pllifecycle t";
|
break;
|
}
|
|
Connection connection = HibernateSessionFactory.getSessionConnection();
|
PreparedStatement pst = connection.prepareStatement(sql);
|
ResultSet rs = pst.executeQuery();
|
ServerWithLog4j.logger.debug(sql);
|
List<LifeCycle> lcs = new ArrayList<LifeCycle>();
|
while (rs.next()) {
|
LifeCycle lc = resultSetToLifeCycle(rs);
|
lcs.add(lc);
|
}
|
rs.close();
|
pst.close();
|
return lcs.toArray(new LifeCycle[0]);
|
}
|
|
/*
|
* public String getLifeCycleEventPath() throws VCIError { return
|
* LifeCycleServerDelegate.getInstance().getLifeCycleEventPath(); }
|
*/
|
public String getLifeCycleEventPath() throws VCIError {
|
String classPath = LifeCycleServiceImpl.class.getResource("").getPath();
|
String subPath;
|
String filePath;
|
if (classPath.contains("file:")) {
|
subPath = classPath.substring(classPath.indexOf("file:") + 6,
|
classPath.indexOf("plm-lifeCycle-server.jar"));
|
filePath = subPath + "properties/lce.properties";
|
} else {
|
subPath = classPath.substring(1, classPath.indexOf("LifeCycle"));
|
filePath = subPath + "LifeCycle/properties/lce.properties";
|
}
|
return handlerOS(filePath);
|
}
|
|
/**
|
* 处理不同OS的路径格式不同问题
|
*
|
* @param filePath
|
* @return
|
*/
|
public String handlerOS(String filePath) {
|
String osName = System.getProperty("os.name");
|
// unix, linux
|
if (!osName.startsWith("Win")) {
|
filePath = "/" + filePath.replace("\\", "/");
|
}
|
return filePath;
|
}
|
|
/*
|
* public String getLifeCycleEventViewPath() throws VCIError { return
|
* LifeCycleServerDelegate.getInstance().getLifeCycleEventViewPath(); }
|
*/
|
public String getLifeCycleEventViewPath() throws VCIError {
|
String classPath = LifeCycleServiceImpl.class.getResource("").getPath();
|
String subPath;
|
String filePath;
|
if (classPath.contains("file:")) {
|
subPath = classPath.substring(classPath.indexOf("file:") + 6,
|
classPath.indexOf("plm-lifeCycle-server.jar"));
|
filePath = subPath + "properties/lce_view.properties";
|
} else {
|
subPath = classPath.substring(1, classPath.indexOf("LifeCycle"));
|
filePath = subPath + "LifeCycle/properties/lce_view.properties";
|
}
|
return handlerOS(filePath);
|
}
|
|
/*
|
* public String getLifeCycleEventViewSavePath() throws VCIError { return
|
* LifeCycleServerDelegate.getInstance().getLifeCycleEventViewSavePath(); }
|
*/
|
public String getLifeCycleEventViewSavePath() throws VCIError {
|
String classPath = LifeCycleServiceImpl.class.getResource("").getPath();
|
String subPath;
|
String filePath;
|
if (classPath.contains("file:")) {
|
subPath = classPath.substring(classPath.indexOf("file:") + 6,
|
classPath.indexOf("plm-lifeCycle-server.jar"));
|
filePath = subPath + "properties/lce_view_save.properties";
|
} else {
|
subPath = classPath.substring(1, classPath.indexOf("LifeCycle"));
|
filePath = subPath + "LifeCycle/properties/lce_view_save.properties";
|
}
|
return handlerOS(filePath);
|
}
|
|
/*
|
* public String get_lifecycle_event_path() throws VCIError { try{ return
|
* LifeCycleServerDelegate.getInstance().get_lifecycle_event_path();
|
* }catch(Throwable e){ e.printStackTrace(); throw
|
* getLocalVciError("P0010LIFECYCLE-00009", e); } }
|
*/
|
/**
|
* 根据jar包中文件路径获取
|
*
|
* @return
|
* @throws VCIError
|
*/
|
public String get_lifecycle_event_path() throws VCIError {
|
String classPath = LifeCycleServerDelegate.class.getResource("").getPath();
|
String subPath;
|
String filePath = "";
|
// String curProjectPath = System.getProperty("user.dir");
|
// ProjectEnum pe = getFileNameByPrjPath(curProjectPath);
|
|
if (classPath.contains("file:")) {
|
subPath = classPath.substring(classPath.indexOf("file:") + 6,
|
classPath.indexOf("plm-lifeCycle-server.jar"));
|
filePath = subPath + "properties/lce_events.properties";
|
} else {
|
subPath = classPath.substring(1, classPath.indexOf("LifeCycle"));
|
filePath = subPath + "LifeCycle/properties/lce_events.properties";
|
// if (pe != null) {
|
// subPath = classPath.substring(1, classPath.indexOf(pe.prjName));
|
// filePath = subPath + pe.prjName + "/src/properties/" +
|
// pe.fileName;
|
// }
|
}
|
return handlerOS(filePath);
|
}
|
|
// 跃迁记录
|
public boolean recordTransitionHistory(TransationHistoryRecord transationHistoryRecord) throws Throwable {
|
try {
|
return false;
|
} catch (Throwable e) {
|
throw e;
|
}
|
}
|
|
/**
|
* 获取事件key
|
*
|
* @throws Throwable
|
*/
|
|
public String[] getLCEventKeys() throws Throwable {
|
// add by caill start 2016.3.10 获取LifeCycleServerUtil.java中的所有key.
|
Map<String, String> allLifyCycleFileName = LifeCycleServerUtil.getInstance().getAllLifeEventConf();
|
String[] str = new String[allLifyCycleFileName.size()];
|
Set<Entry<String, String>> entrySet = allLifyCycleFileName.entrySet();
|
Iterator<Entry<String, String>> it = entrySet.iterator();
|
int sign = 0;
|
while (it.hasNext()) {
|
Entry<String, String> element = it.next();
|
String key = element.getKey().trim();
|
str[sign] = key;
|
ServerWithLog4j.logger.debug(element.getKey());
|
sign++;
|
}
|
// add by caill end
|
|
return str;
|
}
|
|
/**
|
* 获取事件value
|
*
|
* @throws Throwable
|
*/
|
|
public String getLCEventValueByKey(String key) throws Throwable {
|
try {
|
String value = "";
|
// add by caill start 2016.3.10根据propertity文件中的key获取value
|
Map<String, String> allLifyCycleFileName = LifeCycleServerUtil.getInstance().getAllLifeEventConf();
|
value = allLifyCycleFileName.get(key);
|
// add by caill end
|
return value;
|
} catch (Throwable e) {
|
throw e;
|
}
|
}
|
|
public LifeCycle getLifeCycle(String name) throws Exception {
|
String sql = "";
|
switch (HibernateSessionFactory.getDbType()) {
|
case DM8:
|
sql = "select oid, name, label, description, ts, creator, createtime, modifier, modifytime, content from pllifecycle t where t.name =?";
|
break;
|
case ORACL:
|
default:
|
sql = "select oid, name, label, description, ts, creator, createtime, modifier, modifytime, t.content.getclobval() content from pllifecycle t where t.name =?";
|
break;
|
}
|
Connection connection = HibernateSessionFactory.getSessionConnection();
|
PreparedStatement pst = connection.prepareStatement(sql);
|
pst.setString(1, name);
|
ResultSet rs = pst.executeQuery();
|
ServerWithLog4j.logger.debug(sql);
|
LifeCycle lc = null;
|
while (rs.next()) {
|
lc = resultSetToLifeCycle(rs);
|
}
|
rs.close();
|
pst.close();
|
if (lc == null) {
|
lc = new LifeCycle();
|
lc.bounds = new Bound[0];
|
lc.routes = new TransitionVO[0];
|
}
|
return lc;
|
}
|
|
public boolean xml2DB(String userName) throws VCIError {
|
// List<LifeCyle> news = Xml2DBDelegate.getInstance().getNews(userName);
|
// if (news == null) {
|
// return true;
|
// }
|
// for (LifeCyle o : news) {
|
// try {
|
// addLifeCyle(o);
|
// } catch (Throwable e) {
|
// e.printStackTrace();
|
// ServerWithLog4j.logger.warn(o.name + "迁移失败, 生命周期的迁移中止!");
|
// return false;
|
// }
|
// }
|
return true;
|
}
|
|
// 根据id查询状态
|
public LifeCycle getLifeCycleByOid(String oid) throws Exception {
|
String sql = "select oid, name, label, description, ts, creator, createtime, modifier, modifytime, t.content.getclobval() content from pllifecycle t where t.oid =?";
|
Connection connection = HibernateSessionFactory.getSessionConnection();
|
PreparedStatement pst = connection.prepareStatement(sql);
|
pst.setString(1, oid);
|
ResultSet rs = pst.executeQuery();
|
ServerWithLog4j.logger.debug(sql);
|
LifeCycle lc = null;
|
while (rs.next()) {
|
lc = resultSetToLifeCycle(rs);
|
}
|
rs.close();
|
pst.close();
|
/*
|
* if(lc == null){ lc = new LifeCyle(); lc.bounds = new Bound[0]; lc.routes =
|
* new TransitionVO[0]; }
|
*/
|
return lc;
|
}
|
|
/**
|
* 将一条数据库中的记录转化成btmitem
|
* @param rs
|
* @return
|
* @throws SQLException
|
*/
|
private LifeCycle resultSetToLifeCycle(ResultSet rs) throws SQLException, DocumentException{
|
LifeCycle lc = new LifeCycle();
|
String value = rs.getString("oid");
|
lc.oid = (value == null ? "" : value);
|
value = rs.getString("name");
|
lc.name = (value == null ? "" : value);
|
value = rs.getString("label");
|
lc.tag = (value == null ? "" : value);
|
value = rs.getString("description");
|
lc.description = (value == null ? "" : value);
|
lc.ts = OmdConstants.tsDF.format(rs.getTimestamp("ts"));
|
value = rs.getString("creator");
|
lc.creator = (value == null ? "" : value);
|
lc.createTime = rs.getTimestamp("createTime").getTime();
|
value = rs.getString("modifier");
|
lc.modifier = (value == null ? "" : value);
|
lc.modifyTime = rs.getTimestamp("modifyTime").getTime();
|
//CLOB clob = (CLOB) rs.getClob("content");
|
Clob clob = rs.getClob("content");
|
Element lcDetails = getLCDetails(clob);
|
LifeCycleHelper.getInstance().setLCValueFormDoc(lc, lcDetails);
|
return lc;
|
}
|
|
/**
|
* 将查询的clob对象转换成xml的element, 便于解析
|
* @param clob
|
* @return
|
* @throws SQLException
|
* @throws IOException
|
* @throws DocumentException
|
*/
|
//public Element getLCDetails(CLOB clob) throws DocumentException, SQLException{
|
private Element getLCDetails(Clob clob) throws DocumentException, SQLException{
|
SAXReader saxReader = new SAXReader();
|
//Document document = saxReader.read(clob.characterStreamValue());
|
Document document = saxReader.read(clob.getCharacterStream());
|
Element root = document.getRootElement();
|
return root;
|
}
|
}
|
