diff --git a/uapbd/src/private/nc/bs/uapbd/task/ims/ProductReportGyImsPlugin.java b/uapbd/src/private/nc/bs/uapbd/task/ims/ProductReportGyImsPlugin.java index bdda63cc..671126cc 100644 --- a/uapbd/src/private/nc/bs/uapbd/task/ims/ProductReportGyImsPlugin.java +++ b/uapbd/src/private/nc/bs/uapbd/task/ims/ProductReportGyImsPlugin.java @@ -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> mainList = (List>) getImsDao().executeQuery(selSql, new MapListProcessor()); Set pkWrSet = new HashSet<>(); for (Map 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> detailList = (List>) getImsDao().executeQuery(pkWrSql, new MapListProcessor()); Map> 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());