yonyou
/
taikai2312
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

流程生产订单审批后推送高压IMS-sql去掉ts

This commit is contained in:
mzr 2025-09-28 10:21:33 +08:00
parent 93ef0d982a
commit 2b61df9528
1 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
mmpac/src/private/nc/bs/mmpac/pmo/pac0002/bp/rule/AfterApproveSyncImsRule.java
View File

@ -33,7 +33,19 @@ public class AfterApproveSyncImsRule implements IRule<PMOAggVO> {
// 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<PMOAggVO> {
*/
private void pushData(String headSql, SQLParameter headParams, List<Map<String, SQLParameter>> 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<String, SQLParameter> 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);
}