增加交易类型

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<Map<String, Object>> mainList = GyImsDbUtil.query(selSql);
         for (Map<String, Object> 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;
+    }
     /**
      * 填充生产报告的质量信息
      */