|
|
@@ -2,13 +2,13 @@ package com.uas.platform.b2c.prod.commodity.service.impl;
|
|
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
import com.uas.platform.b2c.common.account.model.Enterprise;
|
|
|
-import com.uas.platform.b2c.common.account.service.EnterpriseService;
|
|
|
import com.uas.platform.b2c.common.base.dao.CommonDao;
|
|
|
import com.uas.platform.b2c.core.config.SysConf;
|
|
|
import com.uas.platform.b2c.core.constant.IntegerConstant;
|
|
|
import com.uas.platform.b2c.core.constant.ReleaseStatus;
|
|
|
import com.uas.platform.b2c.core.constant.Status;
|
|
|
import com.uas.platform.b2c.core.support.SystemSession;
|
|
|
+import com.uas.platform.b2c.core.support.log.UsageBufferedLogger;
|
|
|
import com.uas.platform.b2c.core.utils.NumberUtil;
|
|
|
import com.uas.platform.b2c.core.utils.RegexConstant;
|
|
|
import com.uas.platform.b2c.core.utils.StringUtilB2C;
|
|
|
@@ -31,6 +31,7 @@ import com.uas.platform.b2c.prod.store.service.StoreInService;
|
|
|
import com.uas.platform.b2c.trade.order.StringConstant.Currency;
|
|
|
import com.uas.platform.b2c.trade.support.ResultMap;
|
|
|
import com.uas.platform.core.exception.IllegalOperatorException;
|
|
|
+import com.uas.platform.core.logging.BufferedLoggerManager;
|
|
|
import com.uas.platform.core.model.PageInfo;
|
|
|
import com.uas.platform.core.persistence.criteria.CriterionExpression;
|
|
|
import com.uas.platform.core.persistence.criteria.PredicateUtils;
|
|
|
@@ -92,9 +93,6 @@ public class ReleaseProductByBatchServiceImpl implements ReleaseProductByBatchSe
|
|
|
@Autowired
|
|
|
private SysConf SysConf;
|
|
|
|
|
|
- @Autowired
|
|
|
- private EnterpriseService enterpriseService;
|
|
|
-
|
|
|
@Autowired
|
|
|
private JdbcTemplate jdbcTemplate;
|
|
|
|
|
|
@@ -136,6 +134,8 @@ public class ReleaseProductByBatchServiceImpl implements ReleaseProductByBatchSe
|
|
|
@Value("#{sys.productServiceIp}")
|
|
|
private String productServiceIp;
|
|
|
|
|
|
+ private static final UsageBufferedLogger logger = BufferedLoggerManager.getLogger(UsageBufferedLogger.class);
|
|
|
+
|
|
|
@Override
|
|
|
public ReleaseProductByBatch save(ReleaseProductByBatch releaseProductByBatch) {
|
|
|
return releaseProductByBatch;
|
|
|
@@ -272,50 +272,24 @@ public class ReleaseProductByBatchServiceImpl implements ReleaseProductByBatchSe
|
|
|
} else {
|
|
|
// 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 "";
|
|
|
-// }
|
|
|
-// });
|
|
|
+ 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, @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();
|
|
|
+ logger.log("test", "这是测试--------------" + rs);
|
|
|
+ if (null != rs) {
|
|
|
+ rs.next();
|
|
|
+ logger.log("test", "这是测试--------------" + rs.getString(1));
|
|
|
+ return rs.getString(1);
|
|
|
+ }
|
|
|
+ return "0";
|
|
|
+ }
|
|
|
+ });
|
|
|
String result = releaseProductByBatchDao.callValidProcedure(enUU, batch);
|
|
|
l4 = System.currentTimeMillis();
|
|
|
System.err.println("l4--------------l3 testyuj" + (l4 - l3));
|
|
|
@@ -1788,7 +1762,7 @@ public class ReleaseProductByBatchServiceImpl implements ReleaseProductByBatchSe
|
|
|
|
|
|
@Override
|
|
|
public String doInStatement(Statement stmt) throws SQLException, DataAccessException {
|
|
|
- stmt.executeQuery(updateSql);
|
|
|
+ stmt.executeUpdate(updateSql);
|
|
|
ResultSet rs = stmt.getResultSet();
|
|
|
if (null != rs) {
|
|
|
rs.next();
|