diff --git a/mmpac/src/private/nc/bs/mmpac/pmo/pac0002/bp/rule/AfterApproveSyncImsRule.java b/mmpac/src/private/nc/bs/mmpac/pmo/pac0002/bp/rule/AfterApproveSyncImsRule.java index 90124146..4c884b42 100644 --- a/mmpac/src/private/nc/bs/mmpac/pmo/pac0002/bp/rule/AfterApproveSyncImsRule.java +++ b/mmpac/src/private/nc/bs/mmpac/pmo/pac0002/bp/rule/AfterApproveSyncImsRule.java @@ -33,7 +33,19 @@ public class AfterApproveSyncImsRule implements IRule { // BIP数据源 public static final BaseDAO baseDAO = new BaseDAO(); // IMS数据源 - public static final BaseDAO imsDao = new BaseDAO("gyims"); + public BaseDAO imsDao; + + /** + * 获取IMS数据源 + */ + public BaseDAO getImsDao() { + if (imsDao == null) { + imsDao = new BaseDAO("gyims"); + // 禁用时间戳ts + imsDao.setAddTimeStamp(false); + } + return imsDao; + } @Override public void process(PMOAggVO[] pmoAggVOS) { @@ -331,13 +343,13 @@ public class AfterApproveSyncImsRule implements IRule { */ private void pushData(String headSql, SQLParameter headParams, List> bodyParameterList) throws BusinessException { logger.error("gyIms-PMO-headSql = " + headSql); - int i = imsDao.executeUpdate(headSql, headParams); + int i = getImsDao().executeUpdate(headSql, headParams); if (i != 1) { NCCForUAPLogger.error("gyIms-PMO-headSql = " + headSql); } for (Map map : bodyParameterList) { String bodySql = map.keySet().iterator().next(); - int j = imsDao.executeUpdate(bodySql, map.get(bodySql)); + int j = getImsDao().executeUpdate(bodySql, map.get(bodySql)); if (j != 1) { NCCForUAPLogger.error("gyIms-PMO-bodySql = " + bodySql); }