Parcourir la source

形态转换给批次主键赋值

pancy il y a 1 an
Parent
commit
4bfd4d72dd
1 fichiers modifiés avec 35 ajouts et 1 suppressions
  1. 35 1
      ic/ic/src/private/nc/bs/ic/impl/TransformAddImpl.java

+ 35 - 1
ic/ic/src/private/nc/bs/ic/impl/TransformAddImpl.java

@@ -115,9 +115,18 @@ public class TransformAddImpl extends BaseServlet implements IHttpServletAdaptor
 				transformbodyvo.setNassistnum(new UFDouble(bodyObject.getString("nassistnum")));
 //				transformbodyvo.setNcostprice(new UFDouble(bodyObject.getString("ncostprice")));
 //				transformbodyvo.setNcostmny(new UFDouble(bodyObject.getString("ncostmny")));
-				if(bodyObject.getString("vbatchcode")!=null){
+				if(bodyObject.opt("vbatchcode")!=null){
 					transformbodyvo.setVbatchcode(bodyObject.getString("vbatchcode"));
 				}
+				if(bodyObject.opt("vbdef5")!=null){
+					transformbodyvo.setVbdef5(bodyObject.getString("vbdef5"));
+				}
+				if(bodyObject.opt("vbdef6")!=null){
+					transformbodyvo.setVbdef6(bodyObject.getString("vbdef6"));
+				}
+				if(bodyObject.opt("vbatchcode")!=null){
+					transformbodyvo.setPk_batchcode(QryPkBatch(bodyObject.getString("vbatchcode"),transformbodyvo.getCmaterialoid()));
+				}
 				transformbodyvos[i] = transformbodyvo;
 				i++;
 			}
@@ -218,6 +227,29 @@ public class TransformAddImpl extends BaseServlet implements IHttpServletAdaptor
 		}
 	}
 	
+	
+	/*
+	 * 查询批次号档案主键
+	 */
+	private String QryPkBatch(String vbatchcode,String pk_material) throws Exception {
+		
+		String sql = "select pk_batchcode from scm_batchcode where dr=0 and vbatchcode = '"+vbatchcode+"' and cmaterialoid = '"+pk_material+"'";
+		
+		Object object;
+		try {
+			object = iuap.executeQuery(sql, new ColumnProcessor());
+			if (object==null) {
+				return "";
+			}
+			
+			return object.toString();
+		} catch (BusinessException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+			return e.getMessage();
+		}
+	}
+	
 	/*
 	 * 数据库查询
 	 */
@@ -240,6 +272,8 @@ public class TransformAddImpl extends BaseServlet implements IHttpServletAdaptor
 		}
 	}
 	
+	
+	
 	private String SqlexecuteQuery2(String out,String table,String key,String value) throws Exception {
 		
 		String sql = "select "+out+" from "+table+" where "+key+" = '"+value+"' and nvl(dr,0)=0 and enablestate = '2'";