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 4ac3b91a..03894cc8 100644 --- a/uapbd/src/private/nc/bs/uapbd/task/ims/ProductReportGyImsPlugin.java +++ b/uapbd/src/private/nc/bs/uapbd/task/ims/ProductReportGyImsPlugin.java @@ -1,6 +1,7 @@ package nc.bs.uapbd.task.ims; import nc.bs.dao.BaseDAO; +import nc.bs.framework.common.InvocationInfoProxy; import nc.bs.framework.common.NCLocator; import nc.bs.logging.Log; import nc.bs.pub.pa.PreAlertObject; @@ -56,6 +57,7 @@ public class ProductReportGyImsPlugin implements IBackgroundWorkPlugin { IPMOQueryService pmoQueryService = NCLocator.getInstance().lookup(IPMOQueryService.class); IWrMaintainService wrService = NCLocator.getInstance().lookup(IWrMaintainService.class); String selSql = "select * from BIPReportMainTab where status = 'C'"; + // String selSql = "select * from BIPReportMainTab WHERE vbillcode='YK260129000291'\n"; List> mainList = GyImsDbUtil.query(selSql); for (Map mainMap : mainList) { // IMS生产报告的主键 @@ -118,6 +120,11 @@ public class ProductReportGyImsPlugin implements IBackgroundWorkPlugin { UFDate taudittime1 = new UFDate(taudittimeStr); hvo.setTaudittime(taudittime1); } + String ctrantypeid = getValueByCondtion("bd_billtype", " pk_billtypeid ", " istransaction = 'Y' and nvl ( islock, 'N' ) = 'N' and parentbilltype = '55A4' and pk_group = '" + + InvocationInfoProxy.getInstance().getGroupId() + "' and pk_billtypecode = '" + mainMap.get("vtrantypeid") + "' "); + hvo.setVtrantypeid(ctrantypeid); + // hvo.setVtrantypeid("1001A11000000ZW5C3YG"); + hvo.setVtrantypecode(mainMap.get("vtrantypeid") + ""); for (WrItemVO bvo : bvos) { bvo.setFbproducttype(1);// 产品类型 1.主产品 bvo.setTbstarttime(new UFDateTime(dmakedateStr + " 00:00:00"));// 开始时间 @@ -180,7 +187,16 @@ public class ProductReportGyImsPlugin implements IBackgroundWorkPlugin { logger.error("---end----高压IMS-生产报告-任务结束运行--"); return null; } - + private String getValueByCondtion(String tablename, String fieldname, String contion) throws BusinessException { + BaseDAO dao = new BaseDAO(); + String result = ""; + StringBuffer sb = new StringBuffer(); + sb.append(" SELECT " + fieldname + " FROM " + tablename + " "); + sb.append(" WHERE nvl(" + tablename + " .dr,0)= 0 "); + sb.append(" and " + contion + " "); + result = (String) dao.executeQuery(sb.toString(), new ColumnProcessor()); + return result; + } /** * 填充生产报告的质量信息 */