默认上传完成后启用b2cenable

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

@@ -1,5 +1,6 @@
 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.model.User;
 import com.uas.platform.b2c.common.account.service.EnterpriseService;
@@ -17,11 +18,9 @@ import com.uas.platform.b2c.prod.commodity.constant.ShortConstant;
 import com.uas.platform.b2c.prod.commodity.constant.UploadConstant;
 import com.uas.platform.b2c.prod.commodity.dao.GoodsDao;
 import com.uas.platform.b2c.prod.commodity.dao.ProductDao;
+import com.uas.platform.b2c.prod.commodity.dao.ProductPrivateDao;
 import com.uas.platform.b2c.prod.commodity.dao.ReleaseProductByBatchDao;
-import com.uas.platform.b2c.prod.commodity.model.Goods;
-import com.uas.platform.b2c.prod.commodity.model.GoodsQtyPrice;
-import com.uas.platform.b2c.prod.commodity.model.Product;
-import com.uas.platform.b2c.prod.commodity.model.ReleaseProductByBatch;
+import com.uas.platform.b2c.prod.commodity.model.*;
 import com.uas.platform.b2c.prod.commodity.service.GoodsService;
 import com.uas.platform.b2c.prod.commodity.service.ReleaseProductByBatchService;
 import com.uas.platform.b2c.prod.commodity.util.GoodsUtil;
@@ -102,6 +101,9 @@ public class ReleaseProductByBatchServiceImpl implements ReleaseProductByBatchSe
 	@Autowired
 	private RestTemplate restTemplate;
 
+	@Autowired
+	private ProductPrivateDao productPrivateDao;
+
 	@Override
 	public ReleaseProductByBatch save(ReleaseProductByBatch releaseProductByBatch) {
 		return releaseProductByBatch;
@@ -1039,7 +1041,18 @@ public class ReleaseProductByBatchServiceImpl implements ReleaseProductByBatchSe
 		if (!CollectionUtils.isEmpty(releaseProductByBatchList)) {
 			List<com.uas.ps.entity.Product> products = convertProduct(releaseProductByBatchList);
 			// TODO 什么接口
-			restTemplate.postForEntity("", products, String.class);
+			String result = restTemplate.postForEntity("/update", products, String.class).getBody();
+			List<Long> productIds = JSON.parseArray(result, Long.class);
+			// 默认为b2c Enable开启
+			List<ProductPrivate> productPrivates = new ArrayList<>();
+			for (Long prId : productIds) {
+				ProductPrivate productPrivate = productPrivateDao.findByPrId(prId);
+				if (null == productPrivate) {
+					productPrivate = new ProductPrivate();
+				}
+				productPrivate.setB2cEnabled(IntegerConstant.YES_SHORT);
+			}
+			productPrivateDao.save(productPrivates);
 		}
 
 		Enterprise enterprise = SystemSession.getUser().getEnterprise();