资金管理 update

jiangchengyong
1 parent bf4a0fab
Showing 1 changed file with 33 additions and 2 deletions
mobsite-getway-rpc/src/main/java/com/diligrp/mobsite/getway/rpc/impl/FundTradeRPCImpl.java
@@ -3,22 +3,43 @@ package com.diligrp.mobsite.getway.rpc.impl;
 import com.b2c.myapp.common.api.fundTrade.input.FundTradeListInput;
 import com.b2c.myapp.common.api.fundTrade.input.FundTradeSaveInput;
 import com.b2c.myapp.common.api.fundTrade.output.FundTradeOutput;
+import com.b2c.myapp.common.utils.BaseOutput;
 import com.b2c.myapp.common.utils.base.Page;
+import com.b2c.myapp.sdk.MyAppClient;
+import com.diligrp.mobsite.getway.domain.except.ServiceException;
 import com.diligrp.mobsite.getway.rpc.FundTradeRPC;
+import org.apache.log4j.Logger;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
 /**
  * Created by jiangchengyong on 2017/1/19.
  */
+@Component
 public class FundTradeRPCImpl implements FundTradeRPC {
+    private final static Logger log = Logger.getLogger(FundTradeRPCImpl.class);
+    @Resource
+    private MyAppClient myAppClient;
     /**
-     * @param FundTradeListInput
+     * @param fundTradeListInput
      * @return BaseOutput<Page<FundTradeOutput>>
      * @comment 多条件查询储值卡资金交易明细
      * @author kelan
      * @time 2016/12/8 10:36
      */
     @Override
-    public Page<FundTradeOutput> queryFundTrade(FundTradeListInput FundTradeListInput) {
+    public Page<FundTradeOutput> queryFundTrade(FundTradeListInput fundTradeListInput) {
+        BaseOutput<Page<FundTradeOutput>> output = null;
+        try {
+            output = myAppClient.getFundTradeService().queryFundTrade(fundTradeListInput);
+            if(output.getCode().equals(200)){
+                return output.getData();
+            }
+        } catch (Exception e) {
+            log.error("多条件查询储值卡资金交易明细接口出错：msg={}",e);
+            throw new ServiceException();
+        }
         return null;
     }
@@ -30,6 +51,16 @@ public class FundTradeRPCImpl implements FundTradeRPC {
      */
     @Override
     public Boolean fundTrade(FundTradeSaveInput fundTradeSaveInput) {
+        BaseOutput<Boolean> output = null;
+        try {
+            output = myAppClient.getFundTradeService().fundTrade(fundTradeSaveInput);
+            if(output.getCode().equals(200)){
+                return output.getData();
+            }
+        } catch (Exception e) {
+            log.error("储值卡交易接口出错：msg={}",e);
+            throw new ServiceException();
+        }
         return null;
     }
 }