服务调用日志

mall-service/src/main/java/com/txz/mall/dubbo/client/CifAccountDubboServiceClient.java

@@ -1,17 +1,20 @@
 package com.txz.mall.dubbo.client;
 
+import com.alibaba.fastjson.JSONObject;
 import com.txz.cif.dto.Result;
 import com.txz.cif.param.*;
 import com.txz.cif.service.AccountDubboService;
+import com.txz.mall.core.ServiceException;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.dubbo.config.annotation.Reference;
 import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
 
 @Slf4j
 @Component
 public class CifAccountDubboServiceClient {
 
-    @Reference(timeout = 120000)
+    @Reference(timeout = 120000 )
     private AccountDubboService accountDubboService;
 
     /**
@@ -21,7 +24,20 @@ public class CifAccountDubboServiceClient {
      * @return
      */
     public Result getWalletAccount(Long userId) {
-        return accountDubboService.getWalletAccount(userId);
+        Result walletAccount = null;
+
+        try{
+            log.info("accountDubboService.getWalletAccount:"+userId);
+            walletAccount = accountDubboService.getWalletAccount(userId);
+        }catch (Exception e){
+            log.error("accountDubboService.getWalletAccount:"+e.getMessage());
+            throw new ServiceException("cif service unavailable accountDubboService.getWalletAccount unavailable");
+        }
+        if(!ObjectUtils.isEmpty(walletAccount)){
+            log.info("accountDubboService.getWalletAccount result:"+JSONObject.toJSONString(walletAccount));
+        }
+
+        return walletAccount;
     }
 
     /**
@@ -31,7 +47,22 @@ public class CifAccountDubboServiceClient {
      * @return
      */
     public Result recharge(RechargeParam param) {
-        return accountDubboService.recharge(param);
+
+        Result recharge = null;
+
+        try{
+            log.info("accountDubboService.recharge:"+JSONObject.toJSONString(param));
+             recharge = accountDubboService.recharge(param);
+        }catch (Exception e){
+            log.error("accountDubboService.recharge:"+e.getMessage());
+            throw new ServiceException("cif service unavailable accountDubboService.recharge unavailable");
+        }
+        if(!ObjectUtils.isEmpty(recharge)){
+            log.info("accountDubboService.recharge:"+JSONObject.toJSONString(recharge));
+        }
+
+
+        return recharge;
     }
 
     /**
@@ -41,7 +72,21 @@ public class CifAccountDubboServiceClient {
      * @return
      */
     public Result withdraw(WithdrawParam param) {
-        return accountDubboService.withdraw(param);
+
+        Result result = null;
+        try{
+            log.info("accountDubboService.withdraw:"+JSONObject.toJSONString(param));
+            result = accountDubboService.withdraw(param);
+        }catch (Exception e){
+            log.error("accountDubboService.withdraw:"+e.getMessage());
+            throw new ServiceException("cif service unavailable accountDubboService.withdraw unavailable");
+        }
+        if(!ObjectUtils.isEmpty(result)){
+            log.info("accountDubboService.withdraw result:"+JSONObject.toJSONString(result));
+        }
+
+
+        return result;
     }
 
     /**
@@ -51,7 +96,20 @@ public class CifAccountDubboServiceClient {
      * @return
      */
     public Result openGroup(OpenParam param) {
-        return accountDubboService.openGroup(param);
+
+        Result result = null;
+        try{
+            log.info("accountDubboService.openGroup:"+JSONObject.toJSONString(param));
+            result = accountDubboService.openGroup(param);
+        }catch (Exception e){
+            log.error("accountDubboService.openGroup:"+e.getMessage());
+            throw new ServiceException("cif service unavailable accountDubboService.openGroup unavailable");
+        }
+        if(!ObjectUtils.isEmpty(result)){
+            log.info("accountDubboService.openGroup result:"+JSONObject.toJSONString(result));
+        }
+
+        return result;
     }
 
     /**
@@ -61,7 +119,24 @@ public class CifAccountDubboServiceClient {
      * @return
      */
     public Result joinGroup(JoinParam param) {
-        return accountDubboService.joinGroup(param);
+
+        Result resul = null;
+
+        try{
+
+            log.info("accountDubboService.joinGroup:"+JSONObject.toJSONString(param));
+            resul = accountDubboService.joinGroup(param);
+        }catch (Exception e){
+            log.error("accountDubboService.joinGroup:"+e.getMessage());
+            throw new ServiceException("cif  service unavailable accountDubboService.joinGroup unavailable");
+        }
+
+        if(!ObjectUtils.isEmpty(resul)){
+            log.info("accountDubboService.joinGroup:"+JSONObject.toJSONString(resul));
+        }
+
+
+        return resul;
     }
 
     /**
@@ -71,14 +146,41 @@ public class CifAccountDubboServiceClient {
      * @return
      */
     public Result cancelGroup(CancelParam param) {
-        return accountDubboService.cancelGroup(param);
+
+        Result result = null;
+        try{
+            log.info("accountDubboService.cancelGroup:"+JSONObject.toJSONString(param));
+             result = accountDubboService.cancelGroup(param);
+        }catch (Exception e){
+            log.error("accountDubboService.cancelGroup:"+e.getMessage());
+            throw new ServiceException("cif service unavailable accountDubboService.cancelGroup unavailable");
+        }
+        if(!ObjectUtils.isEmpty(result)){
+            log.info("accountDubboService.cancelGroup result:"+JSONObject.toJSONString(result));
+        }
+
+        return result;
     }
 
     /**
      * 成团
      */
     public Result accomplishGroup(AccomplishParam param) {
-        return accountDubboService.accomplishGroup(param);
+
+
+        Result result = null;
+        try{
+            log.info("accountDubboService.accomplishGroup:"+JSONObject.toJSONString(param));
+            result = accountDubboService.accomplishGroup(param);
+        }catch (Exception e){
+            log.error("accountDubboService.accomplishGroup:"+e.getMessage());
+            throw new ServiceException("cif service unavailable accountDubboService.accomplishGroup unavailable");
+        }
+        if(!ObjectUtils.isEmpty(result)){
+            log.info("accountDubboService.accomplishGroup result:"+JSONObject.toJSONString(result));
+        }
+
+        return  result;
     }
 
     /**
@@ -88,7 +190,20 @@ public class CifAccountDubboServiceClient {
      * @return
      */
     public Result addRedEnvelope(SignRedEnvelopeParam param) {
-        return accountDubboService.addRedEnvelope(param);
+
+        Result result = null;
+        try{
+            log.info("accountDubboService.addRedEnvelope:"+JSONObject.toJSONString(param));
+             result = accountDubboService.addRedEnvelope(param);
+        }catch (Exception e){
+            log.error("accountDubboService.addRedEnvelope:"+e.getMessage());
+            throw new ServiceException("cif service unavailable accountDubboService.addRedEnvelope unavailable");
+        }
+        if(!ObjectUtils.isEmpty(result)){
+            log.info(" accountDubboService.addRedEnvelope result:"+JSONObject.toJSONString(result));
+        }
+
+        return result;
     }
 
 }

mall-service/src/main/java/com/txz/mall/dubbo/client/CifRedEnvelopeDubboServiceClient.java

@@ -1,12 +1,15 @@
 package com.txz.mall.dubbo.client;
 
+import com.alibaba.fastjson.JSONObject;
 import com.txz.cif.dto.EarningsDTO;
 import com.txz.cif.dto.OrderParam;
 import com.txz.cif.service.AccountDubboService;
 import com.txz.cif.service.RedEnvelopeDubboService;
+import com.txz.mall.core.ServiceException;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.dubbo.config.annotation.Reference;
 import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
 
 import java.util.List;
 
@@ -19,7 +22,21 @@ public class CifRedEnvelopeDubboServiceClient {
 
 
    public List<EarningsDTO> getEarningsByOrders(List<OrderParam> params){
-       return redEnvelopeDubboService.getEarningsByOrders(params);
+
+       List<EarningsDTO> earningsByOrders = null;
+       try{
+           log.info("redEnvelopeDubboService.getEarningsByOrders:"+JSONObject.toJSONString(params));
+           earningsByOrders  = redEnvelopeDubboService.getEarningsByOrders(params);
+       }catch (Exception e){
+           log.error("redEnvelopeDubboService.getEarningsByOrders :"+e.getMessage());
+           throw new ServiceException("cif service unavailable redEnvelopeDubboService.getEarningsByOrders unavailable");
+       }
+       if(!ObjectUtils.isEmpty(earningsByOrders)){
+           log.info("redEnvelopeDubboService.getEarningsByOrders result:"+ JSONObject.toJSONString(earningsByOrders));
+       }
+
+
+       return earningsByOrders;
    }
 
 

mall-service/src/main/java/com/txz/mall/service/impl/StoreOrderServiceImpl.java

@@ -1831,7 +1831,7 @@ public class StoreOrderServiceImpl extends AbstractService<StoreOrder> implement
         log.info("accountDubboServiceClient.getWalletAccount");
         // 检验余额够不够
         Result result = accountDubboServiceClient.getWalletAccount(storeOrder.getUid());
-        log.info("accountDubboServiceClient.getWalletAccount result" + result);
+        log.info("accountDubboServiceClient.getWalletAccount result" + JSONObject.toJSONString(result));
         if (result.getCode().equals(ResultCode.SUCCESS.getCode())) {
             AccountDTO accountDTO = JSONObject.parseObject(JSONObject.toJSONString(result.getData()), AccountDTO.class);
             if (accountDTO.getBalance().compareTo(storeOrder.getPayPrice()) < 0) {
@@ -1856,7 +1856,7 @@ public class StoreOrderServiceImpl extends AbstractService<StoreOrder> implement
             log.info("accountDubboServiceClient.openGroup openParam" + openParam);
             //
             Result result1 = accountDubboServiceClient.openGroup(openParam);
-            log.info("accountDubboServiceClient.openGroup result1" + result1);
+            log.info("accountDubboServiceClient.openGroup result1:" + result1);
             if (!result1.getCode().equals("200")) {
                 throw new ServiceException(I18nUtil.get("payment.failed") + result1.getMessage());
             }