处理批量导入，加入个人产品库，找物料不存在的问题。

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

@@ -1867,10 +1867,7 @@ public class ReleaseProductByBatchServiceImpl implements ReleaseProductByBatchSe
 		if (isPcb) {
 			savePcbInfo(idSet, map);
 		}
-		logger.info("测试数据", idSet.toString());
-		//添加个人关系
-		String res  = restTemplate.postForEntity(productServiceIp + "/product/assign/batch?userUU=" + SystemSession.getUser().getUserUU(), idSet, String.class).getBody();
-		Integer num = releaseToGoods(releaseProductByBatchList, ignoreImport, idSet);
+        Integer num = releaseToGoods(releaseProductByBatchList, ignoreImport, idSet);
 		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);
@@ -2177,7 +2174,8 @@ public class ReleaseProductByBatchServiceImpl implements ReleaseProductByBatchSe
         if (CollectionUtils.isEmpty(productIds) || StringUtils.isEmpty(batchid)) {
 			return ;
 		}
-		final Runnable afterPublishToGoodsRunnable = new Runnable() {
+        final Long userUU = SystemSession.getUser().getUserUU();
+        final Runnable afterPublishToGoodsRunnable = new Runnable() {
 			@Override
 			public void run() {
 
@@ -2193,6 +2191,8 @@ public class ReleaseProductByBatchServiceImpl implements ReleaseProductByBatchSe
 //				}
 				//创建物料的私有信息
 				productPrivateService.newProductPrivateIfNotExist(productIds);
+				//添加个人关系
+                restTemplate.postForEntity(productServiceIp + "/product/assign/batch?userUU=" + userUU, productIds, String.class).getBody();
 
 //				if ((reIds != null) && (reIds.size() != 0)) {
 //					List<ReleaseProductByBatch> productByBatches = releaseProductByBatchDao.findAll(reIds);