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

高压IMS-取消审批同步

This commit is contained in:
mzr 2025-09-29 14:39:23 +08:00
parent 8380c2a43c
commit 691c9367e3
1 changed files with 16 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -25,7 +25,7 @@ import java.util.*;
* @date 2025/9/27 * @date 2025/9/27
*/ */
public class AfterApproveSyncImsRule implements IRule<PMOAggVO> { public class AfterApproveSyncImsRule implements IRule<PMOAggVO> {
private String auditFlag;
private static final String LOG_INFO_NAME = "gymeslog"; private static final String LOG_INFO_NAME = "gymeslog";
private static final Log logger = Log.getInstance(LOG_INFO_NAME); private static final Log logger = Log.getInstance(LOG_INFO_NAME);
private Map<String, String> configParams; private Map<String, String> configParams;
@ -34,6 +34,10 @@ public class AfterApproveSyncImsRule implements IRule<PMOAggVO> {
// IMS数据源 // IMS数据源
public BaseDAO imsDao; public BaseDAO imsDao;
public AfterApproveSyncImsRule(String auditFlag) {
this.auditFlag = auditFlag;
}
/** /**
* 获取IMS数据源 * 获取IMS数据源
*/ */
@ -106,9 +110,8 @@ public class AfterApproveSyncImsRule implements IRule<PMOAggVO> {
String pkOrg = pmoHeadVO.getPk_org(); String pkOrg = pmoHeadVO.getPk_org();
String orgCode = MyHelper.transferField(OrgVO.getDefaultTableName(), OrgVO.CODE, OrgVO.PK_ORG, pkOrg); String orgCode = MyHelper.transferField(OrgVO.getDefaultTableName(), OrgVO.CODE, OrgVO.PK_ORG, pkOrg);
if (checkIfOrg(orgCode, configParams)) { if (checkIfOrg(orgCode, configParams)) {
// continue; continue;
} }
// 获取主键值 // 获取主键值
String headPrimaryKeyValue = (String) pmoHeadVO.getAttributeValue("cpmohid"); String headPrimaryKeyValue = (String) pmoHeadVO.getAttributeValue("cpmohid");
@ -226,8 +229,12 @@ public class AfterApproveSyncImsRule implements IRule<PMOAggVO> {
headParams.addParam(value); headParams.addParam(value);
} }
} }
// status C=创建U=修改2=处理完成 // status 同步状态：BIP:C-创建;U-修改D-删除 IMS:2-MES单据接收完成
headParams.addParam("U"); // 更新状态为U(修改) if ("N".equals(auditFlag)) {
headParams.addParam("D");
} else {
headParams.addParam("U"); // 更新状态为U(修改)
}
// 添加主键作为WHERE条件 // 添加主键作为WHERE条件
headParams.addParam(pmoHeadVO.getAttributeValue("cpmohid")); headParams.addParam(pmoHeadVO.getAttributeValue("cpmohid"));
} else { } else {
@ -239,12 +246,14 @@ public class AfterApproveSyncImsRule implements IRule<PMOAggVO> {
Object value = pmoHeadVO.getAttributeValue(column); Object value = pmoHeadVO.getAttributeValue(column);
if (headNumFields.contains(column)) { if (headNumFields.contains(column)) {
value = skipNullForNumber(value); value = skipNullForNumber(value);
} else if (headTransferFields.contains(column)) {
value = transferHeadFields(column, value);
} else { } else {
value = skipNull(value); value = skipNull(value);
} }
headParams.addParam(value); headParams.addParam(value);
} }
// status C=创建U=修改2=处理完成 // status 同步状态：BIP:C-创建;U-修改D-删除 IMS:2-MES单据接收完成
headParams.addParam("C"); // 默认状态为C(新增) headParams.addParam("C"); // 默认状态为C(新增)
} }
@ -410,7 +419,7 @@ public class AfterApproveSyncImsRule implements IRule<PMOAggVO> {
String sql = " select code from bd_measdoc where nvl(dr,0) = 0 and pk_measdoc = '[value]' "; String sql = " select code from bd_measdoc where nvl(dr,0) = 0 and pk_measdoc = '[value]' ";
sql = sql.replace("[value]", value.toString()); sql = sql.replace("[value]", value.toString());
result = (String) baseDAO.executeQuery(sql, new ColumnProcessor()); result = (String) baseDAO.executeQuery(sql, new ColumnProcessor());
} else if ("cdeptid".equals(column)) { } else if ("cdeptid".equals(column)) {
String sql = " select code from org_dept where nvl(dr,0) = 0 and pk_dept = '[value]' "; String sql = " select code from org_dept where nvl(dr,0) = 0 and pk_dept = '[value]' ";
sql = sql.replace("[value]", value.toString()); sql = sql.replace("[value]", value.toString());
result = (String) baseDAO.executeQuery(sql, new ColumnProcessor()); result = (String) baseDAO.executeQuery(sql, new ColumnProcessor());