时间段收货地址实现

jiangchengyong
1 parent 84afa95a
Showing 5 changed files with 38 additions and 19 deletions
mobsite-getway-rpc/src/main/java/com/diligrp/mobsite/getway/rpc/impl/DeliveryTimeRPCImpl.java
mobsite-getway-rpc/src/main/java/com/diligrp/mobsite/getway/rpc/impl/FundTradeRPCImpl.java
mobsite-getway-rpc/src/main/java/com/diligrp/mobsite/getway/rpc/impl/PickInfoRPCImpl.java
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
@@ -40,12 +40,13 @@ public class DeliveryTimeRPCImpl implements DeliveryTimeRPC {
             output = myAppClient.getDeliveryTimeService().createShopDeliveryTime(deliveryTimeSaveInput);
             if(output.getCode().equals(200)){
                 return output.getData();
+            }else{
+                throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
             }
         } catch (Exception e) {
             logger.error("创建店铺送货时间段接口出错：msg={}",e);
             throw new ServiceException();
         }
-        return null;
     }
     /**
@@ -62,12 +63,13 @@ public class DeliveryTimeRPCImpl implements DeliveryTimeRPC {
             output = myAppClient.getDeliveryTimeService().deleteShopDeliveryTime(deliveryTimeId);
             if(output.getCode().equals(200)){
                 return output.getData();
+            }else{
+                throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
             }
         } catch (Exception e) {
             logger.error("删除店铺送货时间段接口出错：msg={}",e);
             throw new ServiceException();
         }
-        return null;
     }
     /**
@@ -84,11 +86,12 @@ public class DeliveryTimeRPCImpl implements DeliveryTimeRPC {
             output = myAppClient.getDeliveryTimeService().queryShopDeliveryTime(deliveryTimeListInput);
             if(output.getCode().equals(200)){
                 return output.getData();
+            }else{
+                throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
             }
         } catch (Exception e) {
             logger.error("查找店铺送货时间段接口出错：msg={}",e);
             throw new ServiceException();
         }
-        return null;
     }
 }
@@ -35,12 +35,13 @@ public class FundTradeRPCImpl implements FundTradeRPC {
             output = myAppClient.getFundTradeService().queryFundTrade(fundTradeListInput);
             if(output.getCode().equals(200)){
                 return output.getData();
+            }else{
+                throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
             }
         } catch (Exception e) {
             log.error("多条件查询储值卡资金交易明细接口出错：msg={}",e);
             throw new ServiceException();
         }
-        return null;
     }
     /**
@@ -56,11 +57,12 @@ public class FundTradeRPCImpl implements FundTradeRPC {
             output = myAppClient.getFundTradeService().fundTrade(fundTradeSaveInput);
             if(output.getCode().equals(200)){
                 return output.getData();
+            }else{
+                throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
             }
         } catch (Exception e) {
             log.error("储值卡交易接口出错：msg={}",e);
             throw new ServiceException();
         }
-        return null;
     }
 }
@@ -39,12 +39,13 @@ public class PickInfoRPCImpl implements PickInfoRPC{
             output = myAppClient.getPickingInfoService().addPickingInfo(pickingInfoSaveInput);
             if(output.getCode().equals(200)){
                 return output.getData();
+            }else{
+                throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
             }
         } catch (Exception e) {
             logger.error("新增收货人接口出错：msg={}",e);
             throw new ServiceException();
         }
-        return null;
     }
     /**
@@ -60,12 +61,13 @@ public class PickInfoRPCImpl implements PickInfoRPC{
             output = myAppClient.getPickingInfoService().modify(pickingInfoUpdateInput);
             if(output.getCode().equals(200)){
                 return output.getData();
+            }else{
+                throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
             }
         } catch (Exception e) {
             logger.error("修改收货人信息接口出错：msg={}",e);
             throw new ServiceException();
         }
-        return null;
     }
     /**
@@ -81,12 +83,13 @@ public class PickInfoRPCImpl implements PickInfoRPC{
             output = myAppClient.getPickingInfoService().queryPickingInfosByBuyerId(buyerId);
             if(output.getCode().equals(200)){
                 return output.getData();
+            }else{
+                throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
             }
         } catch (Exception e) {
             logger.error("按买家ID查询收货人接口出错：msg={}",e);
             throw new ServiceException();
         }
-        return null;
     }
     /**
@@ -103,12 +106,13 @@ public class PickInfoRPCImpl implements PickInfoRPC{
             output = myAppClient.getPickingInfoService().getDefaultPickingInfoByBuyerId(buyerId);
             if(output.getCode().equals(200)){
                 return output.getData();
+            }else{
+                throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
             }
         } catch (Exception e) {
             logger.error("根据买家id获取默认收货地址接口出错：msg={}",e);
             throw new ServiceException();
         }
-        return null;
     }
     /**
@@ -125,11 +129,12 @@ public class PickInfoRPCImpl implements PickInfoRPC{
             output = myAppClient.getPickingInfoService().delPickingInfoById(id);
             if(output.getCode().equals(200)){
                 return output.getData();
+            }else{
+                throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
             }
         } catch (Exception e) {
             logger.error("删除收货地址接口出错：msg={}",e);
             throw new ServiceException();
         }
-        return null;
     }
 }
@@ -38,12 +38,13 @@ public class ShopBuyerRPCImpl implements ShopBuyerRPC {
             output = myAppClient.getShopBuyerService().queryShopAllBuyerList(shopBuyerDetail);
             if(output.getCode().equals(200)){
                 return output.getData();
+            }else{
+                throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
             }
         } catch (Exception e) {
             log.error("查找店铺所有买家列表接口出错：msg={}",e);
             throw new ServiceException();
         }
-        return null;
     }
     /**
@@ -61,13 +62,14 @@ public class ShopBuyerRPCImpl implements ShopBuyerRPC {
             output = myAppClient.getShopBuyerService().bindAndActivate(buyerId,promoCode);
             if(output.getCode().equals(200)){
                 return output.getData();
+            }else{
+                throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
             }
         } catch (Exception e) {
             log.error("绑定并激活接口出错：msg={}",e);
             throw new ServiceException();
         }
-        return null;
     }
     /**
@@ -84,13 +86,14 @@ public class ShopBuyerRPCImpl implements ShopBuyerRPC {
             output = myAppClient.getShopBuyerService().getShopBuyerKeys(shopBuyerId);
             if(output.getCode().equals(200)){
                 return output.getData();
+            }else{
+                throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
             }
         } catch (Exception e) {
             log.error("获取店铺用户的相关主键信息接口出错：msg={}",e);
             throw new ServiceException();
         }
-        return null;
     }
     /**
@@ -108,12 +111,13 @@ public class ShopBuyerRPCImpl implements ShopBuyerRPC {
             output = myAppClient.getShopBuyerService().modifyShopRemarkName(shopBuyerId,remarkName);
             if(output.getCode().equals(200)){
                 return output.getData();
+            }else{
+                throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
             }
         } catch (Exception e) {
             log.error("修改店铺名称接口出错：msg={}",e);
             throw new ServiceException();
         }
-        return null;
     }
 }
@@ -44,12 +44,13 @@ public class ShopRPCImpl implements ShopRPC {
 			output = myAppClient.getShopInfoService().createShopInfo(shopSaveInput);
 			if(output.getCode().equals(200)){
 				return output.getData();
+			}else{
+				throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
 			}
 		}catch (Exception e){
 			logger.info("调用创建店铺接口出错：",e);
 			throw new ServiceException(ResultCode.NETWORK_FAILED);
 		}
-		return null;
 	}
 	/**
@@ -66,12 +67,13 @@ public class ShopRPCImpl implements ShopRPC {
 			output = myAppClient.getShopInfoService().getShopBySellerId(sellerId);
 			if(output.getCode().equals(200)){
 				return output.getData();
+			}else{
+				throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
 			}
 		}catch (Exception e){
 			logger.info("调用通过卖家id获取店铺信息接口出错：",e);
 			throw new ServiceException(ResultCode.NETWORK_FAILED);
 		}
-		return null;
 	}
 	/**
@@ -88,12 +90,13 @@ public class ShopRPCImpl implements ShopRPC {
 			output = myAppClient.getShopInfoService().getShopByShopId(shopId);
 			if(output.getCode().equals(200)){
 				return output.getData();
+			}else{
+				throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
 			}
 		}catch (Exception e){
 			logger.info("调用通过店铺id获取店铺信息接口出错：",e);
 			throw new ServiceException(ResultCode.NETWORK_FAILED);
 		}
-		return null;
 	}
 	/**
@@ -110,12 +113,13 @@ public class ShopRPCImpl implements ShopRPC {
 			output = myAppClient.getShopInfoService().getShopInfo(shopListInput);
 			if(output.getCode().equals(200)){
 				return output.getData();
+			}else{
+				throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
 			}
 		}catch (Exception e){
 			logger.info("调用多字段条件查询店铺信息接口出错：",e);
 			throw new ServiceException(ResultCode.NETWORK_FAILED);
 		}
-		return null;
 	}
 	/**
@@ -132,11 +136,12 @@ public class ShopRPCImpl implements ShopRPC {
 			output = myAppClient.getShopInfoService().modifyShopBasicInfo(shopUpdateInput);
 			if(output.getCode().equals(200)){
 				return output.getData();
+			}else{
+				throw new ServiceException(Integer.parseInt(output.getCode()),output.getResult());
 			}
 		}catch (Exception e){
 			logger.info("调用修改店铺基本信息接口出错：",e);
 			throw new ServiceException(ResultCode.NETWORK_FAILED);
 		}
-		return null;
 	}
 }