高压IMS-生产报告调整

This commit is contained in:
mzr 2025-10-15 09:20:55 +08:00
parent 442874e2f1
commit bff4a4265f
1 changed files with 6 additions and 2 deletions

View File

@ -66,12 +66,14 @@ public class ProductReportGyImsPlugin implements IBackgroundWorkPlugin {
IWrMaintainService wrService = NCLocator.getInstance().lookup(IWrMaintainService.class);
// ÊÖ¯¿ªÆôÊÂÎñ
TransactionFactory.getTMProxy().begin(3, 0);
// IMS:C-创建;U-修改 BIP:2-BIP单据接收完成
String selSql = "select * from BIPReportMainTab where status != '2'";
List<Map<String, Object>> mainList = (List<Map<String, Object>>) getImsDao().executeQuery(selSql, new MapListProcessor());
Set<String> pkWrSet = new HashSet<>();
for (Map<String, Object> mainMap : mainList) {
// IMS生产报告的主键
String pkWr = mainMap.get("pk_wr").toString();
// 同步标识 IMS:C-创建;U-修改 BIP:2-BIP单据接收完成
String status = mainMap.get("status").toString();
String pkWrSql = "select * from BIPReportDetailTab where pk_wr = '" + pkWr + "'";
List<Map<String, Object>> detailList = (List<Map<String, Object>>) getImsDao().executeQuery(pkWrSql, new MapListProcessor());
Map<String, Map<String, Object>> detailIdMap = new HashMap<>();
@ -134,7 +136,9 @@ public class ProductReportGyImsPlugin implements IBackgroundWorkPlugin {
}
AggWrVO[] resultvos = null;
try {
resultvos = wrService.insert(vos);
if ("C".equals(status)) {
resultvos = wrService.insert(vos);
}
} catch (BusinessException e) {
Logger.error("ProductReportGyImsPlugin Error: ", e);
NCCForUAPLogger.debug("ProductReportGyImsPlugin Error: " + e.getMessage());