财务回调调整

gic-platform-finance-service/src/main/java/com/gic/finance/service/outer/impl/CashWithdrawalApiServiceImpl.java

@@ -11,6 +11,7 @@ import com.gic.api.base.commons.ServiceResponse;
 import com.gic.commons.util.EntityUtil;
 import com.gic.commons.util.PageHelperUtils;
 import com.gic.enterprise.error.ErrorCode;
+import com.gic.enterprise.utils.AsyncCallbackUtils;
 import com.gic.enterprise.utils.CreateRandomUtils;
 import com.gic.enterprise.utils.valid.ValidParamsUtils;
 import com.gic.finance.constant.WithdrawalApplyTypeEnum;
@@ -23,7 +24,6 @@ import com.gic.finance.qo.CashWithdrawalQueryListQO;
 import com.gic.finance.service.CashWithdrawalApiService;
 import com.gic.finance.service.CashWithdrawalService;
 import com.gic.finance.service.PayAccountService;
-import com.gic.finance.util.AsynCallbackUtils;
 
 @Service("cashWithdrawalApiService")
 public class CashWithdrawalApiServiceImpl implements CashWithdrawalApiService{
@@ -105,7 +105,7 @@ public class CashWithdrawalApiServiceImpl implements CashWithdrawalApiService{
         cashWithdrawalService.update(record);
 
         //回调
-        AsynCallbackUtils.callBack(record, "com.gic.open.api.service.market.PayCallbackApiService", "callbackWithdraw");
+        AsyncCallbackUtils.callBack(record, "com.gic.open.api.service.market.PayCallbackApiService", "callbackWithdraw");
         return ServiceResponse.success();
     }
 
@@ -135,7 +135,7 @@ public class CashWithdrawalApiServiceImpl implements CashWithdrawalApiService{
         cashWithdrawalService.update(record);
 
         //回调
-        AsynCallbackUtils.callBack(record, "com.gic.open.api.service.market.PayCallbackApiService", "callbackWithdraw");
+        AsyncCallbackUtils.callBack(record, "com.gic.open.api.service.market.PayCallbackApiService", "callbackWithdraw");
         return ServiceResponse.success();
     }
 

gic-platform-finance-service/src/main/java/com/gic/finance/service/outer/impl/InvoiceManageApiServiceImpl.java

@@ -13,6 +13,7 @@ import com.gic.api.base.commons.ServiceResponse;
 import com.gic.commons.util.EntityUtil;
 import com.gic.commons.util.PageHelperUtils;
 import com.gic.enterprise.error.ErrorCode;
+import com.gic.enterprise.utils.AsyncCallbackUtils;
 import com.gic.enterprise.utils.CreateRandomUtils;
 import com.gic.enterprise.utils.valid.ValidParamsUtils;
 import com.gic.finance.constant.InvoiceInitiateTypeConstants;
@@ -26,7 +27,6 @@ import com.gic.finance.qo.InvoiceManageListQueryQO;
 import com.gic.finance.service.InvoiceAccountService;
 import com.gic.finance.service.InvoiceManageApiService;
 import com.gic.finance.service.InvoiceManageService;
-import com.gic.finance.util.AsynCallbackUtils;
 
 @Service("invoiceManageApiService")
 public class InvoiceManageApiServiceImpl implements InvoiceManageApiService {
@@ -116,7 +116,7 @@ public class InvoiceManageApiServiceImpl implements InvoiceManageApiService {
         //回调
         if (tabInvoiceManage.getInitiateType().intValue() == InvoiceInitiateTypeConstants.APP) {
             InvoiceCallbackDTO callbackDTO = EntityUtil.changeEntityNew(InvoiceCallbackDTO.class, tabInvoiceManage);
-            AsynCallbackUtils.callBack(callbackDTO, "com.gic.open.api.service.market.InvoiceCallbackApiService",
+            AsyncCallbackUtils.callBack(callbackDTO, "com.gic.open.api.service.market.InvoiceCallbackApiService",
                     "invoiceCallback");
         }
         return ServiceResponse.success();
@@ -144,7 +144,7 @@ public class InvoiceManageApiServiceImpl implements InvoiceManageApiService {
             tabInvoiceManage.setInvoiceStatus(InvoiceStatusEnum.REJECT.getCode());
             tabInvoiceManage.setRejectReason(rejectReason);
             InvoiceCallbackDTO callbackDTO = EntityUtil.changeEntityNew(InvoiceCallbackDTO.class, tabInvoiceManage);
-            AsynCallbackUtils.callBack(callbackDTO, "com.gic.open.api.service.market.InvoiceCallbackApiService",
+            AsyncCallbackUtils.callBack(callbackDTO, "com.gic.open.api.service.market.InvoiceCallbackApiService",
                     "invoiceCallback");
         }
         return ServiceResponse.success();

gic-platform-finance-service/src/main/java/com/gic/finance/service/outer/impl/TransferAccountsApprovalApiServiceImpl.java

@@ -4,9 +4,6 @@ import java.util.Date;
 import java.util.List;
 
 import org.apache.commons.lang.StringUtils;
-import org.apache.dubbo.config.ReferenceConfig;
-import org.apache.dubbo.config.RegistryConfig;
-import org.apache.dubbo.rpc.service.GenericService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -18,6 +15,7 @@ import com.gic.api.base.commons.ServiceResponse;
 import com.gic.commons.util.EntityUtil;
 import com.gic.commons.util.PageHelperUtils;
 import com.gic.enterprise.error.ErrorCode;
+import com.gic.enterprise.utils.AsyncCallbackUtils;
 import com.gic.enterprise.utils.CreateRandomUtils;
 import com.gic.finance.constant.OrderTypeEnum;
 import com.gic.finance.constant.TransferAccountApprovalStatusEnum;
@@ -252,16 +250,8 @@ public class TransferAccountsApprovalApiServiceImpl implements TransferAccountsA
             method = "payCallbackTransfer";
         }
 
-        RegistryConfig registry = new RegistryConfig();
-        registry.setAddress("zookeeper://10.105.220.75:2199");
-        registry.setCheck(false);
-        ReferenceConfig<GenericService> reference = new ReferenceConfig<>();
-        reference.setInterface(interfaceUrl);
-        reference.setRegistry(registry);
-        reference.setGeneric(true);
-        GenericService genericService = reference.get();
-
-        genericService.$invoke(method, new String[]{String.class.getName()}, new String[]{JSONObject.toJSONString(tab)});
+        //回调
+        AsyncCallbackUtils.callBack(tab, interfaceUrl, method);
     }
 
     private void operationUserInfo(TransferAccountsApprovalDTO dto, OperationUserInfoDTO userInfoDTO) {

gic-platform-finance-service/src/main/java/com/gic/finance/util/AsynCallbackUtils.java

-package com.gic.finance.util;
-
-import org.apache.dubbo.config.ReferenceConfig;
-import org.apache.dubbo.config.RegistryConfig;
-import org.apache.dubbo.rpc.service.GenericService;
-
-import com.alibaba.fastjson.JSONObject;
-import org.apache.logging.log4j.LogManager;
-import org.apache.logging.log4j.Logger;
-
-/**
- * 回调方法工具
- * @ClassName: AsynCallbackUtils

- * @Description: 

- * @author guojuxing

- * @date 2019/9/12 1:52 PM

- */
-public class AsynCallbackUtils {
-    private static Logger logger = LogManager.getLogger(AsynCallbackUtils.class);
-
-    /**
-     * 回调
-     * @Title: callBack

-     * @Description: 
-    
 * @author guojuxing 
-     * @param obj 需要传递的参数对象
-     * @param interfaceUrl 接口路径 例如com.gic.open.api.service.market.PayCallbackApiService
-     * @param method
 方法名称 payCallbackTransfer
-     * @return  void

-    
 */
-    public static void callBack(Object obj, String interfaceUrl, String method) {
-        logger.info("转账审批回调：{}，接口路径：{}，接口方法名称:{}" ,JSONObject.toJSONString(obj), interfaceUrl, method);
-        RegistryConfig registry = new RegistryConfig();
-        //todo 上线修改zookeeper地址
-        registry.setAddress("zookeeper://10.105.220.75:2199");
-        registry.setCheck(false);
-        ReferenceConfig<GenericService> reference = new ReferenceConfig<>();
-        reference.setInterface(interfaceUrl);
-        reference.setRegistry(registry);
-        reference.setGeneric(true);
-        GenericService genericService = reference.get();
-
-        genericService.$invoke(method, new String[]{String.class.getName()}, new String[]{JSONObject.toJSONString(obj)});
-    }
-}