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

Compare commits

base: yonyou:900748953c28d71733279ffdb4112dfe524242e2
Branches Tags
yonyou:main
yonyou:dev
...
compare: yonyou:6e78a0b7433ccb334c08de72a9643f0225f66ab7
Branches Tags
yonyou:main
yonyou:dev

2 Commits
900748953c ... 6e78a0b743

Author SHA1 Message Date
mzr 6e78a0b743 Merge remote-tracking branch 'origin/main' 2025-09-28 10:21:47 +08:00
mzr 2b61df9528 流程生产订单审批后推送高压IMS-sql去掉ts 2025-09-28 10:21:33 +08:00
1 changed files with 15 additions and 3 deletions
Show Stats 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Êý¾ÝÔ´ // BIPÊý¾ÝÔ´
public static final BaseDAO baseDAO = new BaseDAO(); public static final BaseDAO baseDAO = new BaseDAO();
// IMSÊý¾ÝÔ´ // 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 @Override
public void process(PMOAggVO[] pmoAggVOS) { 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 { private void pushData(String headSql, SQLParameter headParams, List<Map<String, SQLParameter>> bodyParameterList) throws BusinessException {
logger.error("gyIms-PMO-headSql = " + headSql); logger.error("gyIms-PMO-headSql = " + headSql);
int i = imsDao.executeUpdate(headSql, headParams); int i = getImsDao().executeUpdate(headSql, headParams);
if (i != 1) { if (i != 1) {
NCCForUAPLogger.error("gyIms-PMO-headSql = " + headSql); NCCForUAPLogger.error("gyIms-PMO-headSql = " + headSql);
} }
for (Map<String, SQLParameter> map : bodyParameterList) { for (Map<String, SQLParameter> map : bodyParameterList) {
String bodySql = map.keySet().iterator().next(); 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) { if (j != 1) {
NCCForUAPLogger.error("gyIms-PMO-bodySql = " + bodySql); NCCForUAPLogger.error("gyIms-PMO-bodySql = " + bodySql);
} }