店铺资金相关接口 update

jiangchengyong
1 parent 2765bc38
Showing 2 changed files with 66 additions and 8 deletions
mobsite-getway-rpc/src/main/java/com/diligrp/mobsite/getway/rpc/impl/ShopBuyerRPCImpl.java
mobsite-getway-rpc/src/main/java/com/diligrp/mobsite/getway/rpc/impl/ShopRPCImpl.java
@@ -10,13 +10,14 @@ import com.b2c.myapp.sdk.MyAppClient;
 import com.diligrp.mobsite.getway.domain.except.ServiceException;
 import com.diligrp.mobsite.getway.rpc.ShopBuyerRPC;
 import org.apache.log4j.Logger;
+import org.springframework.stereotype.Service;
 import javax.annotation.Resource;
-import java.util.List;
 /**
  * Created by jiangchengyong on 2017/1/10.
  */
+@Service
 public class ShopBuyerRPCImpl implements ShopBuyerRPC {
     private final static Logger log = Logger.getLogger(ShopBuyerRPCImpl.class);
     @Resource
@@ -4,6 +4,10 @@ import com.b2c.myapp.common.api.shop.input.ShopListInput;
 import com.b2c.myapp.common.api.shop.input.ShopSaveInput;
 import com.b2c.myapp.common.api.shop.input.ShopUpdateInput;
 import com.b2c.myapp.common.api.shop.output.ShopOutput;
+import com.b2c.myapp.common.utils.BaseOutput;
+import com.b2c.myapp.sdk.MyAppClient;
+import com.diligrp.mobsite.getway.domain.common.ResultCode;
+import com.diligrp.mobsite.getway.domain.except.ServiceException;
 import com.diligrp.mobsite.getway.domain.protocol.ProductCategory;
 import com.diligrp.mobsite.getway.domain.protocol.ShopIntroduction;
 import com.diligrp.mobsite.getway.domain.protocol.shop.model.ShopInfo;
@@ -12,6 +16,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
+import javax.annotation.Resource;
 import java.util.List;
 /**
@@ -19,23 +24,35 @@ import java.util.List;
  * <B>Copyright</B> Copyright (c) 2015 www.diligrp.com All rights reserved. <br />
  * 本软件源代码版权归地利集团,未经许可不得任意复制与传播.<br />
  * <B>Company</B> 地利集团
- * @createTime 2015年6月10日 下午1:40:41
- * @author zhangshirui
+ * @createTime 2017年1月10日 下午1:40:41
+ * @author jiangchengyong
  */
 @Service
 public class ShopRPCImpl implements ShopRPC {
 	private Logger logger = LoggerFactory.getLogger(ShopRPCImpl.class);
+	@Resource
+	private MyAppClient myAppClient;
 	/**
 	 * @param shopSaveInput 店铺基本信息
 	 * @return Integer
 	 * @comment 创建店铺
-	 * @author kelan
+	 * @author jiangchengyong
 	 * @time 2016/11/29 19:03
 	 */
 	@Override
 	public Integer createShopInfo(ShopSaveInput shopSaveInput) {
+		BaseOutput<Integer> output = null;
+		try{
+			output = myAppClient.getShopInfoService().createShopInfo(shopSaveInput);
+			if(output.getCode().equals(200)){
+				return output.getData();
+			}
+		}catch (Exception e){
+			logger.info("调用创建店铺接口出错：",e);
+			throw new ServiceException(ResultCode.NETWORK_FAILED);
+		}
 		return null;
 	}
@@ -43,11 +60,21 @@ public class ShopRPCImpl implements ShopRPC {
 	 * @param sellerId 卖家id
 	 * @return ShopOutput
 	 * @comment 通过卖家id获取店铺信息
-	 * @author kelan
+	 * @author jiangchengyong
 	 * @time 2016/11/29 18:54
 	 */
 	@Override
 	public ShopOutput getShopBySellerId(Long sellerId) {
+		BaseOutput<ShopOutput> output = null;
+		try{
+			output = myAppClient.getShopInfoService().getShopBySellerId(sellerId);
+			if(output.getCode().equals(200)){
+				return output.getData();
+			}
+		}catch (Exception e){
+			logger.info("调用通过卖家id获取店铺信息接口出错：",e);
+			throw new ServiceException(ResultCode.NETWORK_FAILED);
+		}
 		return null;
 	}
@@ -55,11 +82,21 @@ public class ShopRPCImpl implements ShopRPC {
 	 * @param shopId 店铺id
 	 * @return ShopOutput
 	 * @comment 通过店铺id获取店铺信息
-	 * @author kelan
+	 * @author jiangchengyong
 	 * @time 2016/12/2 10:15
 	 */
 	@Override
 	public ShopOutput getShopByShopId(Long shopId) {
+		BaseOutput<ShopOutput> output = null;
+		try{
+			output = myAppClient.getShopInfoService().getShopByShopId(shopId);
+			if(output.getCode().equals(200)){
+				return output.getData();
+			}
+		}catch (Exception e){
+			logger.info("调用通过店铺id获取店铺信息接口出错：",e);
+			throw new ServiceException(ResultCode.NETWORK_FAILED);
+		}
 		return null;
 	}
@@ -67,11 +104,21 @@ public class ShopRPCImpl implements ShopRPC {
 	 * @param shopListInput 多字段条件查询
 	 * @return ShopOutput
 	 * @comment 多字段条件查询店铺信息
-	 * @author kelan
+	 * @author jiangchengyong
 	 * @time 2016/11/30 10:00
 	 */
 	@Override
 	public ShopOutput getShopInfo(ShopListInput shopListInput) {
+		BaseOutput<ShopOutput> output = null;
+		try{
+			output = myAppClient.getShopInfoService().getShopInfo(shopListInput);
+			if(output.getCode().equals(200)){
+				return output.getData();
+			}
+		}catch (Exception e){
+			logger.info("调用多字段条件查询店铺信息接口出错：",e);
+			throw new ServiceException(ResultCode.NETWORK_FAILED);
+		}
 		return null;
 	}
@@ -79,11 +126,21 @@ public class ShopRPCImpl implements ShopRPC {
 	 * @param shopUpdateInput
 	 * @return Integer
 	 * @comment 修改店铺基本信息
-	 * @author kelan
+	 * @author jiangchengyong
 	 * @time 2016/11/30 15:43
 	 */
 	@Override
 	public Boolean modifyShopBasicInfo(ShopUpdateInput shopUpdateInput) {
+		BaseOutput<Boolean> output = null;
+		try{
+			output = myAppClient.getShopInfoService().modifyShopBasicInfo(shopUpdateInput);
+			if(output.getCode().equals(200)){
+				return output.getData();
+			}
+		}catch (Exception e){
+			logger.info("调用修改店铺基本信息接口出错：",e);
+			throw new ServiceException(ResultCode.NETWORK_FAILED);
+		}
 		return null;
 	}
 }