Selaa lähdekoodia

更新临时表的状态改为java代码层做

yujia 7 vuotta sitten
vanhempi
commit
119bc2a829

+ 4 - 1
src/main/java/com/uas/platform/b2c/prod/commodity/service/impl/ReleaseProductByBatchServiceImpl.java

@@ -1715,7 +1715,7 @@ public class ReleaseProductByBatchServiceImpl implements ReleaseProductByBatchSe
 		}
 		Enterprise enterprise = SystemSession.getUser().getEnterprise();
         final Object[] obj = new Object[]{enterprise.getUu(), enterprise.getEnName(), batch};
-        String sql = "/*#mycat:db_type=master*/ set @enuu = %s; set @enName = '%s'; set @batch = '%s'; call RELEASE_TO_GOODS_V4(@enuu, @enName, @batch, @out); select @out; commit;";
+        String sql = "/*#mycat:db_type=master*/ set @enuu = %s; set @enName = '%s'; set @batch = '%s'; call RELEASE_TO_GOODS_V5(@enuu, @enName, @batch, @out); select @out; commit;";
         final String updateSql = String.format(sql, obj);
         String num = jdbcTemplate.execute(new StatementCallback<String>() {
 
@@ -1730,6 +1730,9 @@ public class ReleaseProductByBatchServiceImpl implements ReleaseProductByBatchSe
                 return "0";
             }
         });
+		String updateReleaseSql = "/*#mycat:db_type=master*/ update trade$releasebybatch set rel_releasecode = 101,rel_releasestatus = '已发布' where (rel_releasecode = 112 OR rel_releasecode = 113) and rel_batchid = '%s';";
+		final String updateRelease = String.format(updateReleaseSql, new Object[]{batch});
+		jdbcTemplate.execute(updateRelease);
 		ArrayList<Long> list = new ArrayList<>();
 		list.addAll((Set<Long>)map.get("prIds"));
 		afterPublishToGoodsDo(list, (Set<Long>)map.get("reIds"), batch);