add egserver

egress-gateway-service-app/src/main/java/com/hrsk/cloud/eg/app/api/executor/ApiInvokeCmdExe.java

@@ -1,6 +1,5 @@
 package com.hrsk.cloud.eg.app.api.executor;
 
-import com.hrsk.cloud.eg.client.api.ApiService;
 import com.hrsk.cloud.eg.client.dto.cmd.ApiInvokeCmd;
 import com.hrsk.cloud.eg.domain.api.ApiGateway;
 import org.springframework.stereotype.Component;

egress-gateway-service-client/src/main/java/com/hrsk/cloud/eg/client/dto/plan/command/EgLoanApiConfigInfoCmd.java

@@ -29,7 +29,7 @@ public class EgLoanApiConfigInfoCmd implements Serializable {
     /**
      * 通道类型
      */
-    private String apiCode;
+    private String channelCode;
 
     /**
      * 请求配置 对应原始数据表中的 threeConfig
@@ -45,4 +45,9 @@ public class EgLoanApiConfigInfoCmd implements Serializable {
      * api 介入类型代码自定义 还是引导配置
      */
     private String integrationMode;
+
+    /**
+      * api集成方式
+     */
+    private String integrationSystem;
 }

egress-gateway-service-domain/pom.xml

@@ -65,18 +65,18 @@
             <groupId>com.caucho</groupId>
             <artifactId>hessian</artifactId>
         </dependency>
-        <dependency>
-            <groupId>org.springframework</groupId>
-            <artifactId>spring-expression</artifactId>
-        </dependency>
+<!--        <dependency>-->
+<!--            <groupId>org.springframework</groupId>-->
+<!--            <artifactId>spring-expression</artifactId>-->
+<!--        </dependency>-->
         <dependency>
             <groupId>com.alibaba.fastjson2</groupId>
             <artifactId>fastjson2</artifactId>
         </dependency>
-        <dependency>
-            <groupId>org.springframework</groupId>
-            <artifactId>spring-context</artifactId>
-        </dependency>
+<!--        <dependency>-->
+<!--            <groupId>org.springframework</groupId>-->
+<!--            <artifactId>spring-context</artifactId>-->
+<!--        </dependency>-->
         <dependency>
             <groupId>commons-codec</groupId>
             <artifactId>commons-codec</artifactId>

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/ApiChannel.java

@@ -1,7 +1,14 @@
 package com.hrsk.cloud.eg.domain.api;
 
+import com.alibaba.fastjson2.JSONObject;
 import com.google.common.base.Function;
 import com.hrsk.cloud.eg.client.dto.RedisSetDto;
+import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
+import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
+import com.hrsk.cloud.eg.client.dto.user.command.UserBaseInfoCmd;
+import com.hrsk.cloud.eg.client.vo.DataVo;
+import com.hrsk.cloud.eg.domain.api.channel.customized.LoanManagerService;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
 import com.hrsk.cloud.eg.domain.api.channel.guide.common.EgressApiEndpointIntegrationModeEnum;
 import com.hrsk.cloud.eg.domain.api.channel.guide.common.EgressApiErrorCodeEnum;
 import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequest;
@@ -9,6 +16,7 @@ import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiRequestConfig;
 import com.hrsk.cloud.eg.domain.api.channel.guide.http.HttpApiResponse;
 import com.hrsk.cloud.eg.domain.common.BeetlHelper;
 import com.hrsk.cloud.eg.domain.common.GsonUtils;
+import com.hrsk.pangu.domain.DomainFactory;
 import com.hrsk.pangu.tool.exception.BizException;
 import lombok.Data;
 import org.apache.commons.lang3.StringUtils;
@@ -21,6 +29,7 @@ import java.util.Map;
  * @create: 2024-11-10 16:28
  * @description: API通道
  **/
+
 @Data
 public class ApiChannel {
     /**
@@ -91,9 +100,14 @@ public class ApiChannel {
             response = httpClientFunc.apply(new HttpApiRequest(httpApiRequestConfig).request(input));
             return BeetlHelper.render(httpApiResponseConfig,response);
         }else if(StringUtils.equals(integrationMode, EgressApiEndpointIntegrationModeEnum.CUSTOMIZE.getCode())){
-            //todo 代码模式
-
-            return null;
+            UserBaseInfoCmd userBaseInfoCmd = JSONObject.parseObject(input.get("user").toString(), UserBaseInfoCmd.class);
+            EgLoanApiConfigInfoCmd apiConfigInfoCmd = JSONObject.parseObject(input.get("api").toString(), EgLoanApiConfigInfoCmd.class);
+            PlanCmd planCmd = JSONObject.parseObject(input.get("plan").toString(), PlanCmd.class);
+            LoanManagerService loanManagerService = new LoanManagerService();
+            LoanDockingApi loanDockingApi = loanManagerService.apiRouter(planCmd, apiConfigInfoCmd);
+            DataVo dataVo = loanDockingApi.qualityCheck(userBaseInfoCmd, planCmd, apiConfigInfoCmd, httpClientFunc, redisGetFunction, redisSetFunction);
+            response.setData(dataVo);
+            return  JSONObject.toJSONString(response);
         }else{
             throw new BizException(EgressApiErrorCodeEnum.ILLEGAL_INTEGRATION_MODE.getCode(),EgressApiErrorCodeEnum.ILLEGAL_INTEGRATION_MODE.getMessage());
         }

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/BizHandlerContext.java

@@ -0,0 +1,49 @@
+package com.hrsk.cloud.eg.domain.api.channel.customized;
+
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import org.springframework.beans.BeansException;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.stereotype.Component;
+
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @description:  获取对应的助贷service 处理方法
+ * @param:
+ * @return:
+ * @author zhangyy
+ * @date: 2024/11/27 16:14
+ */
+@Component
+public class BizHandlerContext implements ApplicationContextAware {
+
+    private final Map<ServerCodeEnums, LoanDockingApi> bizHandlerMap = new HashMap<>();
+
+
+
+    public void putBizHandler(ServerCodeEnums type, LoanDockingApi handler) {
+        bizHandlerMap.put(type, handler);
+    }
+
+    public LoanDockingApi getBizHandler(ServerCodeEnums type) {
+        LoanDockingApi bizHandler = this.bizHandlerMap.get(type);
+        if (bizHandler == null) {
+            throw new RuntimeException("not.found.BizHandler");
+        }
+        return bizHandler;
+    }
+
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+        Map<String, LoanDockingApi> beansOfType = applicationContext.getBeansOfType(LoanDockingApi.class);
+        Collection<LoanDockingApi> services = beansOfType.values();
+        for (LoanDockingApi service : services) {
+             ServerCodeEnums type = service.getType();
+            bizHandlerMap.put(type, service);
+        }
+    }
+}

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/LoanManagerService.java

@@ -0,0 +1,107 @@
+package com.hrsk.cloud.eg.domain.api.channel.customized;
+
+import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
+import com.hrsk.cloud.eg.client.dto.plan.command.PlanCmd;
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.JoinMethodEnums;
+import com.hrsk.cloud.eg.domain.api.channel.customized.common.ServerCodeEnums;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.LoanDockingApi;
+import com.hrsk.cloud.eg.domain.api.channel.customized.threedocking.impl.*;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+
+/**
+ * @author zhangyy
+ * @version 1.0
+ * @description: LoanManagerService
+ * @date 2024/11/27 16:15
+ */
+@Slf4j
+@Service
+public class LoanManagerService {
+
+
+    @Resource
+    private QingyuCreditService qingyuCreditService;
+    @Resource
+    private QingyuV2CreditService qingyuV2CreditService;
+    @Resource
+    private  QingyuV3CreditService qingyuV3CreditService;
+    @Resource
+    private  JinDieV2CreditService jinDieV2CreditService;
+    @Resource
+    private  JinDieV3CreditService jinDieV3CreditService;
+    @Resource
+    private RxkCreditService rxkCreditService;
+    @Resource
+    private BizHandlerContext handlerContext;
+
+    @Resource
+    private  HuirongCrmCreditService huirongCrmCreditService;
+
+    @Resource
+    private OpenApiAesCreditService openApiAesCreditService;
+
+    @Resource
+    private XiangKeDaCreditService xiangKeDaCreditService;
+
+    @Resource
+    private XinluCreditService xinluCreditService;
+
+    @Resource
+    private OpenApiCreditService openApiCreditService;
+
+
+    public LoanDockingApi apiRouter(PlanCmd xdProduct,EgLoanApiConfigInfoCmd apiInfo) {
+        if (null == xdProduct.getApiId()) return null;
+
+        LoanDockingApi apiService = null;
+        JoinMethodEnums method = JoinMethodEnums.getByCode(apiInfo.getIntegrationSystem());
+        if (null == method) return null;
+        switch (method) {
+            case CRM_QY:
+                apiService = qingyuCreditService;
+                break;
+            case CRM_XL:
+                apiService = xinluCreditService;
+                break;
+            case OPEN_API:
+                apiService = openApiCreditService;
+                break;
+            case CRM_QY_V2:
+                apiService = qingyuV2CreditService;
+                break;
+            case CRM_XKD:
+                apiService = xiangKeDaCreditService;
+                break;
+            case CRM_RXK:
+                apiService = rxkCreditService;
+                break;
+            case HUIRONG_CRM:
+                apiService = huirongCrmCreditService;
+                break;
+            case CRM_EC:
+                break;
+            case CRM_JD:
+                apiService = jinDieV2CreditService;
+                break;
+            case CRM_JDV3:
+                apiService = jinDieV3CreditService;
+                break;
+            case BUSI_API:
+                apiService = handlerContext.getBizHandler(ServerCodeEnums.map.get(apiInfo.getIntegrationSystem()));
+                break;
+            case CRM_QY_V3:
+                apiService = qingyuV3CreditService;
+                break;
+            case OPEN_API_AES:
+                apiService = openApiAesCreditService;
+                break;
+            default:
+                log.error("不支持的对接方式:productId={}",xdProduct.getPlanId());
+        }
+        return apiService;
+    }
+
+}

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/api/channel/customized/threedocking/impl/AnHuiHengDaoCreditService.java

@@ -17,7 +17,6 @@ import com.hrsk.cloud.eg.domain.common.HessianUtils;
 import com.hrsk.cloud.eg.domain.common.Md5Util;
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Service;
 
 import java.time.Instant;
 import java.util.*;

egress-gateway-service-infrastructure/src/main/java/com/hrsk/cloud/eg/infrastructure/gatewayimpl/ApiGatewayImpl.java

@@ -10,6 +10,7 @@ import com.hrsk.cloud.eg.domain.common.GsonUtils;
 import com.hrsk.cloud.eg.infrastructure.client.http.HttpClient;
 import com.hrsk.cloud.eg.infrastructure.repository.database.dao.EgressApiChannelDao;
 import com.hrsk.cloud.eg.infrastructure.repository.database.entity.EgressApiChannelDo;
+import com.hrsk.cloud.eg.infrastructure.service.EgApiChannelService;
 import com.hrsk.cloud.eg.infrastructure.utils.RedisUtil;
 import com.hrsk.pangu.tool.exception.BizException;
 import lombok.extern.slf4j.Slf4j;
@@ -35,6 +36,9 @@ public class ApiGatewayImpl implements ApiGateway {
     @Resource
     private EgressApiChannelDao egressApiChannelDao;
 
+    @Resource
+    private EgApiChannelService egApiChannelService;
+
     @Resource
     private RedisUtil redisUtil;
 

egress-gateway-service-infrastructure/src/main/java/com/hrsk/cloud/eg/infrastructure/service/EgApiChannelService.java

@@ -1,6 +1,7 @@
 package com.hrsk.cloud.eg.infrastructure.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
 import com.hrsk.cloud.eg.infrastructure.repository.database.entity.EgressApiChannelDo;
 
 /**
@@ -20,4 +21,14 @@ public interface EgApiChannelService extends IService<EgressApiChannelDo> {
      */
     EgressApiChannelDo findByApiId(Integer apiId);
 
+
+    /**
+     * @description: 查询对应api配置信息通过 apiId和通道类型
+     * @param:
+     * @return:
+     * @author zhangyy
+     * @date: 2024/11/27 17:29
+     */
+
+     EgLoanApiConfigInfoCmd findEgressConfigCmdByApiIdAndChannel(Integer apiId, String channelId);
 }

egress-gateway-service-infrastructure/src/main/java/com/hrsk/cloud/eg/infrastructure/service/impl/EgApiChannelServiceImpl.java

@@ -2,11 +2,19 @@ package com.hrsk.cloud.eg.infrastructure.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.hrsk.cloud.eg.client.dto.plan.command.EgLoanApiConfigInfoCmd;
+import com.hrsk.cloud.eg.domain.common.HessianUtils;
+import com.hrsk.cloud.eg.infrastructure.repository.database.dao.EgApiLoanExtendDao;
 import com.hrsk.cloud.eg.infrastructure.repository.database.dao.EgressApiChannelDao;
+import com.hrsk.cloud.eg.infrastructure.repository.database.entity.EgApiLoanExtendDo;
 import com.hrsk.cloud.eg.infrastructure.repository.database.entity.EgressApiChannelDo;
 import com.hrsk.cloud.eg.infrastructure.service.EgApiChannelService;
+import com.hrsk.cloud.eg.infrastructure.service.EgApiLoanExtendService;
 import org.springframework.stereotype.Service;
 
+import javax.annotation.Resource;
+import java.util.Objects;
+
 /**
  * @author zhangyy
  * @version 1.0
@@ -16,6 +24,10 @@ import org.springframework.stereotype.Service;
 @Service
 public class EgApiChannelServiceImpl extends ServiceImpl<EgressApiChannelDao, EgressApiChannelDo> implements EgApiChannelService {
 
+    @Resource
+    private EgApiLoanExtendDao egApiLoanExtendDao;
+
+
     @Override
     public EgressApiChannelDo findByApiId(Integer apiId) {
 
@@ -29,4 +41,34 @@ public class EgApiChannelServiceImpl extends ServiceImpl<EgressApiChannelDao, Eg
         }
         return egApiEndpointDo;
     }
+
+    @Override
+    public EgLoanApiConfigInfoCmd findEgressConfigCmdByApiIdAndChannel(Integer apiId, String channelCode) {
+        EgLoanApiConfigInfoCmd cmd=new EgLoanApiConfigInfoCmd();
+        LambdaQueryWrapper<EgressApiChannelDo> queryWrapper=new LambdaQueryWrapper<>();
+        queryWrapper.eq(EgressApiChannelDo::getApiId, apiId);
+        queryWrapper.eq(EgressApiChannelDo::getChannelCode,channelCode);
+        queryWrapper.orderByDesc(EgressApiChannelDo::getId);
+        queryWrapper.last("limit 1");
+        EgressApiChannelDo egressApiChannelDo = baseMapper.selectOne(queryWrapper);
+        if (Objects.isNull(egressApiChannelDo)) {
+            return new EgLoanApiConfigInfoCmd();
+        }
+       LambdaQueryWrapper<EgApiLoanExtendDo> loanExtend=new LambdaQueryWrapper<>();
+        queryWrapper.eq(EgressApiChannelDo::getApiId, egressApiChannelDo.getApiId());
+        queryWrapper.orderByDesc(EgressApiChannelDo::getId);
+        queryWrapper.last("limit 1");
+        EgApiLoanExtendDo egApiLoanExtendDo = egApiLoanExtendDao.selectOne(loanExtend);
+        if (Objects.isNull(egApiLoanExtendDo)) {
+            return new EgLoanApiConfigInfoCmd();
+        }
+        cmd.setApiId(egressApiChannelDo.getApiId());
+        cmd.setChannelCode(egressApiChannelDo.getChannelCode());
+        cmd.setRequestConfig(HessianUtils.serialize(egressApiChannelDo.getRequestConfig()));
+        cmd.setIntegrationMode(egressApiChannelDo.getIntegrationMode());
+        cmd.setIntegrationSystem(egApiLoanExtendDo.getIntegrationSystem());
+        cmd.setNeedCheck(egApiLoanExtendDo.getCheckInto());
+        return cmd;
+
+    }
 }

egress-gateway-service-infrastructure/src/main/java/com/hrsk/cloud/eg/infrastructure/service/impl/EgApiServiceImpl.java

@@ -9,7 +9,6 @@ import com.hrsk.cloud.eg.infrastructure.repository.database.dao.EgressApiDao;
 import com.hrsk.cloud.eg.infrastructure.repository.database.entity.*;
 import com.hrsk.cloud.eg.infrastructure.repository.database.dao.EgApiLoanExtendDao;
 import com.hrsk.cloud.eg.infrastructure.service.EgApiService;
-import com.hrsk.cloud.eg.infrastructure.utils.HessianUtils;
 import com.hrsk.cloud.eg.infrastructure.utils.RedisUtil;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;

egress-gateway-service-infrastructure/src/main/java/com/hrsk/cloud/eg/infrastructure/utils/HessianUtils.java

@@ -1,63 +0,0 @@
-package com.hrsk.cloud.eg.infrastructure.utils;
-
-import com.caucho.hessian.io.Hessian2Input;
-import com.caucho.hessian.io.Hessian2Output;
-import lombok.extern.slf4j.Slf4j;
-
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.io.IOException;
-
-/**
- * @author: bianlanzhou
- * @create: 2024-08-02 08:43
- * @description: hessian工具类
- **/
-@Slf4j
-public class HessianUtils {
-    public static byte[] serialize(Object object){
-        Hessian2Output ho = null;
-        try{
-            ByteArrayOutputStream bos = new ByteArrayOutputStream();
-            ho = new Hessian2Output(bos);
-            ho.writeObject(object);
-            ho.flush();
-            return bos.toByteArray();
-        } catch (IOException e) {
-            log.error("序列化对象异常!",e);
-            //throw new SysException("序列化对象异常!",e);
-            throw new RuntimeException("序列化对象异常!",e);
-        }finally {
-            if(ho !=null){
-                try {
-                    ho.close();
-                } catch (IOException e) {
-                    log.error("序列化流关闭失败!",e);
-                }
-            }
-        }
-    }
-
-    /** Hessian反序列化 */
-    public static Object deserialize(byte[] bytes){
-        Hessian2Input hi = null;
-        try{
-            ByteArrayInputStream is = new ByteArrayInputStream(bytes);
-            hi = new Hessian2Input(is);
-            return hi.readObject();
-        }catch (Exception e){
-            log.error("反序列化对象异常!",e);
-            //throw new SysException("反序列化对象异常!",e);
-            throw new RuntimeException("反序列化对象异常!",e);
-        }finally {
-            if(hi !=null){
-                try {
-                    hi.close();
-                } catch (IOException e) {
-                    log.error("序列化流关闭失败!",e);
-                }
-            }
-        }
-    }
-
-}

pom.xml

@@ -174,4 +174,17 @@
         <module>egress-gateway-service-infrastructure</module>
         <module>egress-gateway-service-domain</module>
     </modules>
+    <!-- 本地nexus私有库-->
+    <distributionManagement>
+        <snapshotRepository>
+            <id>rdc-snapshots</id>
+            <name>snapshots</name>
+            <url>http://192.168.1.169:8000/repository/maven-snapshots/</url>
+        </snapshotRepository>
+        <repository>
+            <id>rdc-releases</id>
+            <name>release</name>
+            <url>http://192.168.1.169:8000/repository/maven-releases/</url>
+        </repository>
+    </distributionManagement>
 </project>