修改商品库接

alexyang
1 parent 68c948f9
Showing 3 changed files with 32 additions and 8 deletions
mobsite-getway-rpc/src/main/java/com/diligrp/mobsite/getway/rpc/GoodsRPC.java
mobsite-getway-rpc/src/main/java/com/diligrp/mobsite/getway/rpc/impl/GoodsRPCImpl.java
mobsite-getway-service/src/main/java/com/diligrp/mobsite/getway/service/seller/impl/SellerGoodsServiceImpl.java
@@ -16,6 +16,7 @@ import com.diligrp.titan.sdk.domain.Product;
 import com.diligrp.titan.sdk.input.CategoryInput;
 import com.diligrp.titan.sdk.input.PopProductView;
 import com.diligrp.titan.sdk.input.ProductSearchInput;
+import com.diligrp.titan.sdk.input.UpdateProductInput;
 import com.diligrp.titan.sdk.output.PageOutput;
  
 import java.util.HashMap;
@@ -131,4 +132,5 @@ public interface GoodsRPC {
 	List<Category> listCategory(int parentId,int shopId);
  
 	List<Product> searchProduct(ProductSearchInput input);
+	Object updateProduct(UpdateProductInput updateProductInput);
 }
@@ -22,6 +22,7 @@ import com.diligrp.titan.sdk.domain.Product;
 import com.diligrp.titan.sdk.input.CategoryInput;
 import com.diligrp.titan.sdk.input.PopProductView;
 import com.diligrp.titan.sdk.input.ProductSearchInput;
+import com.diligrp.titan.sdk.input.UpdateProductInput;
 import com.diligrp.titan.sdk.output.BaseOutput;
 import com.diligrp.titan.sdk.output.PageOutput;
 import com.diligrp.website.util.redis.RedisUtil;
@@ -269,21 +270,22 @@ public class GoodsRPCImpl implements GoodsRPC {
         return output.getData();
     }
  
-    public PageOutput<List<Product>>  getProductRecommend(ProductSearchInput input, Long userId) {
+    public PageOutput<List<Product>> getProductRecommend(ProductSearchInput input, Long userId) {
         PageOutput<List<Product>> output = null;
         try {
             output = titanClient.getProductService().searchListPopProducts(input);
-        }catch (Exception e){
-            logger.info("获取店铺热门推荐商品接口出错：",e);
+        } catch (Exception e) {
+            logger.info("获取店铺热门推荐商品接口出错：", e);
             throw new ServiceException(ResultCode.NETWORK_FAILED);
         }
-        if (output.getCode()!=200) {
+        if (output.getCode() != 200) {
             logger.error("获取店铺热门推荐商品失败[userId={},code={},result={}]",
-                    new Object[]{ userId,output.getCode(),output.getResult()});
-            throw new ServiceException(ResultCode.BUSINESS_FAILED,output.getResult());
+                    new Object[]{userId, output.getCode(), output.getResult()});
+            throw new ServiceException(ResultCode.BUSINESS_FAILED, output.getResult());
         }
         return output;
     }
+
     @Override
     public List<Category> listCategory(int parentId, int shopId) {
         try {
@@ -312,5 +314,20 @@ public class GoodsRPCImpl implements GoodsRPC {
         }
     }
  
+    @Override
+    public Object updateProduct(UpdateProductInput updateProductInput) {
+        BaseOutput<Object> output;
+        try {
+            output = titanClient.getProductService().updatePop(updateProductInput);
+        } catch (Exception e) {
+            logger.error("调用修改商品接口失败");
+            throw new ServiceException();
  
+        }
+        if (output.getCode() != 200) {
+            logger.error("调用修改分类接口失败");
+            throw new ServiceException(ResultCode.BUSINESS_FAILED, output.getResult());
+        }
+        return output.getData();
+    }
 }
@@ -18,6 +18,7 @@ import com.diligrp.titan.sdk.domain.Sku;
 import com.diligrp.titan.sdk.input.CategoryInput;
 import com.diligrp.titan.sdk.input.PopProductView;
 import com.diligrp.titan.sdk.input.ProductSearchInput;
+import com.diligrp.titan.sdk.input.UpdateProductInput;
 import com.diligrp.website.util.security.Validator;
 import com.yqyw.filter.client.KeyWordsClient;
 import org.apache.log4j.Logger;
@@ -228,14 +229,18 @@ public class SellerGoodsServiceImpl implements SellerGoodsService {
  
     private List<com.diligrp.titan.sdk.domain.Attribute> buildSaleAttr(List<Attribute> saleAtt) {
  
-        List<com.diligrp.titan.sdk.domain.Attribute> attrs = null;
+        String jsonString = JSONArray.toJSONString(saleAtt);
  
-        return attrs;
+        return JSONArray.parseArray(jsonString, com.diligrp.titan.sdk.domain.Attribute.class);
  
     }
  
     @Override
     public UpdateGoodsResp updateGoods(UpdateGoodsReq req) {
+        UpdateProductInput input = new UpdateProductInput();
+
+        input.setDesc(req.getGoods().getDesc());
+        goodsRPC.updateProduct(input);
         return null;
     }