删除通过存储过程返回值的代码

src/main/java/com/uas/platform/b2c/prod/commodity/dao/ReleaseProductByBatchDao.java

@@ -80,7 +80,7 @@ public interface ReleaseProductByBatchDao
      * @param batchid     the batchid 批次号
      */
     @Procedure(procedureName = "PRODUCT_RELEASE_VALID_V4")
-	String callValidProcedure(Long publisherUu, String batchid);
+	void callValidProcedure(Long publisherUu, String batchid);
 
 
 	/**

src/main/java/com/uas/platform/b2c/prod/commodity/service/impl/ReleaseProductByBatchServiceImpl.java

@@ -271,7 +271,53 @@ public class ReleaseProductByBatchServiceImpl implements ReleaseProductByBatchSe
 		if (isPcb) {
 			strCount = releaseProductByBatchDao.callValidProcedurePcb(enUU, batch);
 		} else {
-			strCount = releaseProductByBatchDao.callValidProcedure(enUU, batch);
+			// final Object[] obj = new Object[]{enUU, batch};
+//			final Object[] obj = new Object[]{enUU, batch};
+//			String sql = "/*#mycat:db_type=master*/ set @enuu = %s; set @batch = '%s'; call PRODUCT_RELEASE_VALID_V4(@enuu, @batch, @rest); select @rest";
+
+//			String sql = "/*#mycat:db_type=master*/ set @enuu = %s; set @enName = '%s'; set @batch = '%s'; call RELEASE_TO_GOODS_V3(@enuu, @enName, @batch, @out); select @out";
+//			final String updateSql = String.format(sql, obj);
+//			String num = jdbcTemplate.execute(new StatementCallback<String>() {
+//
+//				@Override
+//				public String doInStatement(Statement stmt) throws SQLException, DataAccessException {
+//					stmt.executeQuery(updateSql);
+//					ResultSet rs = stmt.getResultSet();
+//					if (null != rs) {
+//						rs.next();
+//						return rs.getString(1);
+//					}
+//					return "0-0-0";
+//				}
+//			});
+//			final Long uu = enUU;
+//			final String ba = batch;
+//			jdbcTemplate.execute(
+//					new CallableStatementCreator() {
+//						@Override
+//						public CallableStatement createCallableStatement(Connection con) throws SQLException {
+//							String storedProc = "{call PRODUCT_RELEASE_VALID_V4(?, ?)}";// 调用的sql
+//							CallableStatement cs = con.prepareCall(storedProc);
+//							cs.setLong(1, uu);// 设置输入参数的值
+//							cs.setString(2, ba);// 设置输入参数的值
+//							cs.registerOutParameter(3, Types.VARCHAR);// 注册输出参数的类型
+//							return cs;
+//						}
+//					}, new CallableStatementCallback() {
+//						@Override
+//						public Object doInCallableStatement(CallableStatement cs) throws SQLException, DataAccessException {
+//							boolean exist = cs.execute();
+//							ResultSet resultSet = cs.getResultSet();
+//							if (exist) {
+//								while (resultSet.next()) {
+////                            System.out.println(resultSet.getString(1));
+//									return resultSet.getString(1);
+//								}
+//							}
+//							return "";
+//						}
+//					});
+			releaseProductByBatchDao.callValidProcedure(enUU, batch);
 			l4 = System.currentTimeMillis();
 			System.err.println("l4--------------l3" + (l4 - l3));
 		}