Merge branch 'feature-butt-joint-2024-08-26' into pre_test

db/eg.sql

@@ -0,0 +1,72 @@
+DROP TABLE IF EXISTS eg_api_loan_extend;
+CREATE TABLE eg_api_loan_extend(
+                                   `id` bigint(64) NOT NULL   COMMENT 'id' ,
+                                   `create_uid` VARCHAR(64)    COMMENT '创建人id' ,
+                                   `create_username` VARCHAR(64)    COMMENT '创建人' ,
+                                   `gmt_create` DATETIME    COMMENT '创建时间' ,
+                                   `modify_uid` VARCHAR(32)    COMMENT '更新人' ,
+                                   `modify_username` VARCHAR(64)    COMMENT '修改人' ,
+                                   `gmt_modify` DATETIME    COMMENT '修改时间' ,
+                                   `status` VARCHAR(10)    COMMENT '有效（Y 有效 N 无效）' ,
+                                   `api_id` bigint(64)    COMMENT 'eg_api主键' ,
+                                   `share_range` VARCHAR(255)    COMMENT '共享范围' ,
+                                   `protocol` VARCHAR(255)    COMMENT '协议范围' ,
+                                   `share_purpose` VARCHAR(255)    COMMENT '共享目的' ,
+                                   `need_check` INT(4)    COMMENT '是否需要撞库0：不需要；1：需要' ,
+                                   `share_type` VARCHAR(255)    COMMENT '共享方式' ,
+                                   PRIMARY KEY (id)
+)  COMMENT = '接出助贷api的扩展表';
+
+DROP TABLE IF EXISTS eg_api_product_extend;
+CREATE TABLE eg_api_product_extend(
+                                      `id` bigint(64) NOT NULL   COMMENT 'id' ,
+                                      `create_uid` VARCHAR(64)    COMMENT '创建人id' ,
+                                      `create_username` VARCHAR(64)    COMMENT '创建人' ,
+                                      `gmt_create` DATETIME    COMMENT '创建时间' ,
+                                      `modify_uid` VARCHAR(32)    COMMENT '更新人' ,
+                                      `modify_username` VARCHAR(64)    COMMENT '修改人' ,
+                                      `gmt_modify` DATETIME    COMMENT '修改时间' ,
+                                      `status` VARCHAR(10)    COMMENT '有效（Y 有效 N 无效）' ,
+                                      `api_id` bigint(64)    COMMENT 'eg_api主键' ,
+                                      `share_range` VARCHAR(255)    COMMENT '共享范围' ,
+                                      `protocol` VARCHAR(255)    COMMENT '协议范围' ,
+                                      `share_purpose` VARCHAR(255)    COMMENT '共享目的' ,
+                                      `share_type` VARCHAR(255)    COMMENT '共享方式' ,
+                                      `need_check` INT(4)    COMMENT '是否需要撞库0：不需要；1：需要' ,
+                                      PRIMARY KEY (id)
+)  COMMENT = '接出产品api扩展表';
+
+CREATE TABLE `eg_api` (
+                          `id` bigint(64) NOT NULL COMMENT 'id',
+                          `create_uid` varchar(64) DEFAULT NULL COMMENT '创建人id',
+                          `create_username` varchar(64) DEFAULT NULL COMMENT '创建人',
+                          `gmt_create` datetime DEFAULT NULL COMMENT '创建时间',
+                          `modify_uid` varchar(32) DEFAULT NULL COMMENT '更新人',
+                          `modify_username` varchar(64) DEFAULT NULL COMMENT '修改人',
+                          `gmt_modify` datetime DEFAULT NULL COMMENT '修改时间',
+                          `status` varchar(10) DEFAULT NULL COMMENT '有效（Y 有效 N 无效）',
+                          `api_code` varchar(64) DEFAULT NULL COMMENT '业务编码',
+                          `api_name` varchar(64) DEFAULT NULL COMMENT '名称',
+                          `api_type` varchar(20) DEFAULT NULL COMMENT 'api类型',
+                          PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='api信息表';
+
+CREATE TABLE `eg_api_endpoint` (
+                                   `id` bigint(64) NOT NULL,
+                                   `create_uid` varchar(64) DEFAULT NULL COMMENT '乐观锁',
+                                   `create_username` varchar(64) DEFAULT NULL COMMENT '创建人',
+                                   `gmt_create` datetime DEFAULT NULL COMMENT '创建时间',
+                                   `modify_uid` varchar(64) DEFAULT NULL COMMENT '更新人',
+                                   `modify_username` varchar(64) DEFAULT NULL COMMENT '更新人',
+                                   `status` varchar(32) DEFAULT NULL COMMENT '有效（Y 有效 N 无效）',
+                                   `api_config` blob COMMENT '配置',
+                                   `api_code` varchar(32) DEFAULT NULL COMMENT 'code配置',
+                                   `desc` varchar(255) DEFAULT NULL COMMENT '描述',
+                                   `api_id` bigint(64) DEFAULT NULL COMMENT 'apiId',
+                                   `gmt_modify` datetime DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP,
+                                   `api_name` varchar(255) DEFAULT NULL COMMENT 'api名称',
+                                   `request_config` varchar(255) DEFAULT NULL COMMENT '请求配置',
+                                   `response_config` varchar(255) DEFAULT NULL COMMENT '响应设置',
+                                   `memo` varchar(255) DEFAULT NULL COMMENT '备注',
+                                   PRIMARY KEY (`id`) USING BTREE
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='api通道表';

db/新增eg_api_epoint字段.sql

@@ -0,0 +1,6 @@
+ALTER TABLE `loan_online`.`eg_api_endpoint`
+    ADD COLUMN `request_config` varchar(255) NULL COMMENT '请求配置' AFTER `api_name`,
+ADD COLUMN `response_config` varchar(255) NULL COMMENT '响应设置' AFTER `request_config`;
+
+ALTER TABLE `loan_online`.`eg_api_endpoint`
+    ADD COLUMN `endpoint_type` varchar(20) NULL COMMENT '对接类型';

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

@@ -0,0 +1,78 @@
+package com.hrsk.cloud.eg.app.api;
+
+import com.hrsk.cloud.eg.app.business.EgOperateBusinessService;
+import com.hrsk.cloud.eg.app.request.api.EgApiEndpointReq;
+import com.hrsk.cloud.eg.app.request.api.EgApiLoanExtendReq;
+import com.hrsk.cloud.eg.app.request.api.EgApiProductExtendReq;
+import com.hrsk.cloud.eg.app.request.api.EgApiReq;
+import com.hrsk.cloud.eg.vo.response.DefaultResponseVo;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+
+/**
+ * @author zhangyy
+ * @version 1.0
+ * @description: EgApiOperateServiceImpl
+ * @date 2024/9/23 11:25
+ */
+@RequestMapping
+@RestController("eg")
+public class EgApiOperateServiceImpl {
+
+    @Resource
+    private EgOperateBusinessService egOperateBusinessService;
+
+
+    /**
+     * @description: 创建助贷api扩展
+     * @author zhangyy
+     * @date 2024/9/23 13:40
+     * @version 1.0
+     */
+    @RequestMapping("saveLoanApiExtend")
+    public DefaultResponseVo saveLoanApiExtend(@RequestBody EgApiLoanExtendReq req) {
+        egOperateBusinessService.saveLoanApiExtend(req);
+        return DefaultResponseVo.success();
+    }
+
+    /**
+     * @description: 创建助贷api扩展
+     * @author zhangyy
+     * @date 2024/9/23 13:40
+     * @version 1.0
+     */
+    @RequestMapping("saveInterbankApiExtend")
+    public DefaultResponseVo saveInterbankApiExtend(@RequestBody EgApiProductExtendReq req) {
+        egOperateBusinessService.saveInterbankApiExtend(req);
+        return DefaultResponseVo.success();
+    }
+
+    /**
+     * @description: 保存信息api配置信息
+     * @author zhangyy
+     * @date 2024/9/23 13:46
+     * @version 1.0
+     */
+    @RequestMapping("saveApiConfig")
+    public DefaultResponseVo saveApiConfig(@RequestBody EgApiEndpointReq req){
+
+        Long id = egOperateBusinessService.saveApiConfig(req);
+        return DefaultResponseVo.success(id);
+    }
+
+    /**
+     * @description: 保存信息api
+     * @author zhangyy
+     * @date 2024/9/23 13:46
+     * @version 1.0
+     */
+    @RequestMapping("saveApiInfo")
+    public DefaultResponseVo saveApiInfo(@RequestBody EgApiReq req){
+        Long id = egOperateBusinessService.saveApiInfo(req);
+        return DefaultResponseVo.success(id);
+    }
+
+}

egress-gateway-service-app/src/main/java/com/hrsk/cloud/eg/app/business/EgOperateBusinessService.java

@@ -0,0 +1,105 @@
+package com.hrsk.cloud.eg.app.business;
+
+import com.alibaba.cola.exception.BizException;
+import com.hrsk.cloud.eg.app.request.api.EgApiEndpointReq;
+import com.hrsk.cloud.eg.app.request.api.EgApiLoanExtendReq;
+import com.hrsk.cloud.eg.app.request.api.EgApiProductExtendReq;
+import com.hrsk.cloud.eg.app.request.api.EgApiReq;
+import com.hrsk.cloud.eg.infrastructure.repository.database.entity.EgApiDo;
+import com.hrsk.cloud.eg.infrastructure.repository.database.entity.EgApiEndpointDo;
+import com.hrsk.cloud.eg.infrastructure.repository.database.entity.EgApiLoanExtendDo;
+import com.hrsk.cloud.eg.infrastructure.repository.database.entity.EgApiProductExtendDo;
+import com.hrsk.cloud.eg.infrastructure.service.EgApiEndpointService;
+import com.hrsk.cloud.eg.infrastructure.service.EgApiLoanExtendService;
+import com.hrsk.cloud.eg.infrastructure.service.EgApiProductExtendService;
+import com.hrsk.cloud.eg.infrastructure.service.EgApiService;
+import com.hrsk.cloud.eg.infrastructure.utils.BeanCopyUtils;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+import java.util.Objects;
+
+/**
+ * @author zhangyy
+ * @version 1.0
+ * @description: EgOperateBusinessService eg接出操作类
+ * @date 2024/9/23 13:49
+ */
+@Service
+public class EgOperateBusinessService {
+    @Resource
+    private EgApiService egApiService;
+
+    @Resource
+    private EgApiEndpointService egApiEndpointService;
+    @Resource
+    private EgApiProductExtendService egApiProductExtendService;
+
+    @Resource
+    private EgApiLoanExtendService egApiLoanExtendService;
+
+    /**
+     * @description:  保存接出api
+     * @author zhangyy
+     * @date 2024/9/23 14:08
+     * @version 1.0
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public Long saveApiInfo(EgApiReq req) {
+        EgApiDo copy = BeanCopyUtils.copy(req, EgApiDo.class);
+        egApiService.save(copy);
+        return copy.getId();
+
+    }
+
+    /**
+     * @description:  保存api的配置
+     * @author zhangyy
+     * @date 2024/9/23 14:18
+     * @version 1.0
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public Long saveApiConfig(EgApiEndpointReq req) {
+        EgApiEndpointDo copy = BeanCopyUtils.copy(req, EgApiEndpointDo.class);
+        EgApiDo apiDo = egApiService.getById(req.getApiId());
+        if (Objects.isNull(apiDo)) {
+           throw new BizException("主api信息为空");
+        }
+        copy.setApiName(apiDo.getApiName());
+        copy.setApiCode(apiDo.getApiCode());
+        egApiEndpointService.save(copy);
+        return copy.getId();
+    }
+
+    /** 
+     * @description: 保存api扩展信息
+     * @param:  
+     * @return:  
+     * @author zhangyy
+     * @date: 2024/9/23 14:26
+     */ 
+    @Transactional(rollbackFor = Exception.class)
+    public void saveLoanApiExtend(EgApiLoanExtendReq req) {
+        if (Objects.isNull(req)){
+            throw new BizException("信息不能为空");
+        }
+        EgApiLoanExtendDo copy = BeanCopyUtils.copy(req, EgApiLoanExtendDo.class);
+        egApiLoanExtendService.save(copy);
+    }
+    /**
+     * @description: 保存api扩展信息
+     * @param:
+     * @return:
+     * @author zhangyy
+     * @date: 2024/9/23 14:26
+     */
+    public void saveInterbankApiExtend(EgApiProductExtendReq req) {
+        if (Objects.isNull(req)){
+            throw new BizException("信息不能为空");
+        }
+        EgApiProductExtendDo copy = BeanCopyUtils.copy(req, EgApiProductExtendDo.class);
+        egApiProductExtendService.save(copy);
+    }
+
+}

egress-gateway-service-app/src/main/java/com/hrsk/cloud/eg/app/constant/EgApiTypeEnum.java

@@ -0,0 +1,45 @@
+package com.hrsk.cloud.eg.app.constant;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author zhangyy
+ * @version 1.0
+ * @description: EgApiTypeEnum
+ * @date 2024/9/23 13:58
+ */
+@Getter
+@AllArgsConstructor
+public enum EgApiTypeEnum {
+    LOAN_API("LOAN_API","助贷api"),
+    INTERBANK_API("INTERBANK_API","同业api"),
+    FAST_LOAN("FAST_LOAN","极速贷api")
+
+    ;
+    static Map<String, EgApiTypeEnum> map = new HashMap();
+
+    static {
+        for (EgApiTypeEnum value : EgApiTypeEnum.values()) {
+            map.put(value.code, value);
+        }
+    }
+
+    public static EgApiTypeEnum getByCode(String code) {
+        return map.get(code);
+    }
+    private String code;
+
+    private String msg;
+
+    public String getCode() {
+        return code;
+    }
+
+    public String getMsg() {
+        return msg;
+    }
+}

egress-gateway-service-app/src/main/java/com/hrsk/cloud/eg/app/request/api/EgApiEndpointReq.java

@@ -0,0 +1,53 @@
+package com.hrsk.cloud.eg.app.request.api;
+
+import com.hrsk.cloud.eg.infrastructure.repository.database.entity.BaseDo;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+
+/**
+ * @author: bianlanzhou
+ * @create: 2024-08-01 18:34
+ * @description: API通道数据对象
+ **/
+@Data
+public class EgApiEndpointReq extends BaseDo implements Serializable {
+    /**
+     * 数据API主键
+     */
+    @NotNull(message = "apiId不能为空")
+    private Long apiId;
+    /**
+     * 通道类型
+     */
+    private String apiCode;
+
+    /**
+     * api名称
+     */
+    private String apiName;
+    /**
+     * 通道配置
+     */
+    @NotBlank(message = "通道配置信息不能为空")
+    private byte[] apiConfig;
+
+    /**
+     * 请求配置
+     */
+    @NotBlank(message = "请求配置信息不能为空")
+    private String requestConfig;
+
+    /**
+     * 响应配置
+     */
+    @NotBlank(message = "响应配置信息不能为空")
+    private String responseConfig;
+
+    /**
+     * 备注
+     */
+    private String memo;
+}

egress-gateway-service-app/src/main/java/com/hrsk/cloud/eg/app/request/api/EgApiLoanExtendReq.java

@@ -0,0 +1,43 @@
+package com.hrsk.cloud.eg.app.request.api;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 接出助贷api的详细描述
+ * 
+ * @author zhangyy
+ * @email @gmail.com
+ * @date 2024-09-23 11:07:01
+ */
+@Data
+public class EgApiLoanExtendReq  implements Serializable {
+	private static final long serialVersionUID = 1L;
+
+	/**
+	 * eg_api主键
+	 */
+	private Long apiId;
+	/**
+	 * 共享范围
+	 */
+	private String shareRange;
+	/**
+	 * 协议范围
+	 */
+	private String protocol;
+	/**
+	 * 共享目的
+	 */
+	private String sharePurpose;
+	/**
+	 * 是否需要撞库0：不需要；1：需要
+	 */
+	private Integer needCheck;
+	/**
+	 * 共享方式
+	 */
+	private String shareType;
+
+}

egress-gateway-service-app/src/main/java/com/hrsk/cloud/eg/app/request/api/EgApiProductExtendReq.java

@@ -0,0 +1,46 @@
+package com.hrsk.cloud.eg.app.request.api;
+
+import lombok.Data;
+
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+
+/**
+ * 接出产品api扩展表
+ * 
+ * @author zhangyy
+ * @email
+ * @date 2024-09-23 11:07:01
+ */
+@Data
+public class EgApiProductExtendReq  implements Serializable {
+	private static final long serialVersionUID = 1L;
+
+
+	/**
+	 * eg_api主键
+	 */
+	@NotNull(message = "apiId信息不能为空")
+	private Long apiId;
+	/**
+	 * 共享范围
+	 */
+	private String shareRange;
+	/**
+	 * 协议范围
+	 */
+	private String protocol;
+	/**
+	 * 共享目的
+	 */
+	private String sharePurpose;
+	/**
+	 * 共享方式
+	 */
+	private String shareType;
+	/**
+	 * 是否需要撞库0：不需要；1：需要
+	 */
+	private Integer needCheck;
+
+}

egress-gateway-service-app/src/main/java/com/hrsk/cloud/eg/app/request/api/EgApiReq.java

@@ -0,0 +1,33 @@
+package com.hrsk.cloud.eg.app.request.api;
+
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import java.io.Serializable;
+
+/**
+ * @author: bianlanzhou
+ * @create: 2024-08-02 08:14
+ * @description: 接出网关API表
+ **/
+@Data
+public class EgApiReq implements Serializable  {
+    /**
+     * API名称
+     */
+    @NotBlank(message = "API名称不能为空")
+    private String apiName;
+
+    /**
+     * API类型
+     */
+    @NotBlank(message = "API类型不能为空")
+    private String apiType;
+
+    /**
+     * APICode
+     */
+    @NotBlank(message = "API编码不能为空")
+    private String apiCode;
+
+}

egress-gateway-service-infrastructure/src/main/java/com/hrsk/cloud/eg/infrastructure/repository/database/entity/EgApiEndpointDo.java

@@ -32,4 +32,19 @@ public class EgApiEndpointDo extends BaseDo implements Serializable {
      * 通道配置
      */
     private byte[] apiConfig;
+
+    /**
+     * 请求配置
+     */
+    private String requestConfig;
+
+    /**
+     * 响应配置
+     */
+    private String responseConfig;
+
+    /**
+     * 备注
+     */
+    private String memo;
 }

egress-gateway-service-infrastructure/src/main/java/com/hrsk/cloud/eg/infrastructure/repository/database/entity/EgApiLoanExtendDo.java

@@ -0,0 +1,47 @@
+package com.hrsk.cloud.eg.infrastructure.repository.database.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * 接出助贷api的详细描述
+ * 
+ * @author zhangyy
+ * @email @gmail.com
+ * @date 2024-09-23 11:07:01
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("eg_api_loan_extend")
+public class EgApiLoanExtendDo  extends  BaseDo implements Serializable {
+	private static final long serialVersionUID = 1L;
+
+	/**
+	 * eg_api主键
+	 */
+	private Long apiId;
+	/**
+	 * 共享范围
+	 */
+	private String shareRange;
+	/**
+	 * 协议范围
+	 */
+	private String protocol;
+	/**
+	 * 共享目的
+	 */
+	private String sharePurpose;
+	/**
+	 * 是否需要撞库0：不需要；1：需要
+	 */
+	private Integer needCheck;
+	/**
+	 * 共享方式
+	 */
+	private String shareType;
+
+}

egress-gateway-service-infrastructure/src/main/java/com/hrsk/cloud/eg/infrastructure/repository/database/entity/EgApiProductExtendDo.java

@@ -0,0 +1,49 @@
+package com.hrsk.cloud.eg.infrastructure.repository.database.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * 接出产品api扩展表
+ * 
+ * @author zhangyy
+ * @email
+ * @date 2024-09-23 11:07:01
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("eg_api_product_extend")
+public class EgApiProductExtendDo extends BaseDo implements Serializable {
+	private static final long serialVersionUID = 1L;
+
+
+	/**
+	 * eg_api主键
+	 */
+	private Long apiId;
+	/**
+	 * 共享范围
+	 */
+	private String shareRange;
+	/**
+	 * 协议范围
+	 */
+	private String protocol;
+	/**
+	 * 共享目的
+	 */
+	private String sharePurpose;
+	/**
+	 * 共享方式
+	 */
+	private String shareType;
+	/**
+	 * 是否需要撞库0：不需要；1：需要
+	 */
+	private Integer needCheck;
+
+}

egress-gateway-service-infrastructure/src/main/java/com/hrsk/cloud/eg/infrastructure/repository/database/mapper/EgApiLoanExtendMapper.java

@@ -0,0 +1,17 @@
+package com.hrsk.cloud.eg.infrastructure.repository.database.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.hrsk.cloud.eg.infrastructure.repository.database.entity.EgApiLoanExtendDo;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 接出助贷api的详细描述
+ * 
+ * @author chenshun
+ * @email sunlightcs@gmail.com
+ * @date 2024-09-23 11:07:01
+ */
+@Mapper
+public interface EgApiLoanExtendMapper extends BaseMapper<EgApiLoanExtendDo> {
+	
+}

egress-gateway-service-infrastructure/src/main/java/com/hrsk/cloud/eg/infrastructure/repository/database/mapper/EgApiProductExtendMapper.java

@@ -0,0 +1,17 @@
+package com.hrsk.cloud.eg.infrastructure.repository.database.mapper;
+
+import com.hrsk.cloud.eg.infrastructure.repository.database.entity.EgApiProductExtendDo;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 接出产品api扩展表
+ * 
+ * @author chenshun
+ * @email sunlightcs@gmail.com
+ * @date 2024-09-23 11:07:01
+ */
+@Mapper
+public interface EgApiProductExtendMapper extends BaseMapper<EgApiProductExtendDo> {
+	
+}

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

@@ -0,0 +1,17 @@
+package com.hrsk.cloud.eg.infrastructure.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.hrsk.cloud.eg.infrastructure.repository.database.entity.EgApiLoanExtendDo;
+
+
+/**
+ * 接出助贷api的详细描述
+ *
+ * @author zhangyy
+ * @email @gmail.com
+ * @date 2024-09-23 11:07:01
+ */
+public interface EgApiLoanExtendService extends IService<EgApiLoanExtendDo> {
+
+}
+

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

@@ -0,0 +1,17 @@
+package com.hrsk.cloud.eg.infrastructure.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.hrsk.cloud.eg.infrastructure.repository.database.entity.EgApiProductExtendDo;
+
+
+/**
+ * 接出产品api扩展表
+ *
+ * @author chenshun
+ * @email sunlightcs@gmail.com
+ * @date 2024-09-23 11:07:01
+ */
+public interface EgApiProductExtendService extends IService<EgApiProductExtendDo> {
+
+}
+

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

@@ -0,0 +1,13 @@
+package com.hrsk.cloud.eg.infrastructure.service.impl;
+
+import com.hrsk.cloud.eg.infrastructure.repository.database.entity.EgApiLoanExtendDo;
+import com.hrsk.cloud.eg.infrastructure.repository.database.mapper.EgApiLoanExtendMapper;
+import com.hrsk.cloud.eg.infrastructure.service.EgApiLoanExtendService;
+import org.springframework.stereotype.Service;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+
+
+@Service
+public class EgApiLoanExtendServiceImpl extends ServiceImpl<EgApiLoanExtendMapper, EgApiLoanExtendDo> implements EgApiLoanExtendService {
+
+}

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

@@ -0,0 +1,14 @@
+package com.hrsk.cloud.eg.infrastructure.service.impl;
+
+import com.hrsk.cloud.eg.infrastructure.repository.database.entity.EgApiProductExtendDo;
+import com.hrsk.cloud.eg.infrastructure.repository.database.mapper.EgApiProductExtendMapper;
+import com.hrsk.cloud.eg.infrastructure.service.EgApiProductExtendService;
+import org.springframework.stereotype.Service;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+
+
+@Service
+public class EgApiProductExtendServiceImpl extends ServiceImpl<EgApiProductExtendMapper, EgApiProductExtendDo> implements EgApiProductExtendService {
+
+
+}

egress-gateway-service-infrastructure/src/main/resources/mapper/EgApiEndpointMapper.xml

@@ -15,6 +15,9 @@
         <result column="api_code" property="apiCode"/>
         <result column="api_id" property="apiId"/>
         <result column="api_name" property="apiName"/>
+        <result column="request_config" property="requestConfig"/>
+        <result column="response_config" property="responseConfig"/>
+        <result column="memo" property="memo"/>
 
     </resultMap>
 

egress-gateway-service-infrastructure/src/main/resources/mapper/EgApiLoanExtendMapper.xml

@@ -0,0 +1,25 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.hrsk.cloud.eg.infrastructure.repository.database.mapper.EgApiLoanExtendMapper">
+
+	<!-- 可根据自己的需求，是否要使用 -->
+    <resultMap type="com.hrsk.cloud.eg.infrastructure.repository.database.entity.EgApiLoanExtendDo" id="egApiLoanExtendMap">
+        <result property="id" column="id"/>
+        <result property="createUid" column="create_uid"/>
+        <result property="createUsername" column="create_username"/>
+        <result property="gmtCreate" column="gmt_create"/>
+        <result property="modifyUid" column="modify_uid"/>
+        <result property="modifyUsername" column="modify_username"/>
+        <result property="gmtModify" column="gmt_modify"/>
+        <result property="status" column="status"/>
+        <result property="apiId" column="api_id"/>
+        <result property="shareRange" column="share_range"/>
+        <result property="protocol" column="protocol"/>
+        <result property="sharePurpose" column="share_purpose"/>
+        <result property="needCheck" column="need_check"/>
+        <result property="shareType" column="share_type"/>
+    </resultMap>
+
+
+</mapper>

egress-gateway-service-infrastructure/src/main/resources/mapper/EgApiProductExtendMapper.xml

@@ -0,0 +1,25 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.hrsk.cloud.eg.infrastructure.repository.database.mapper.EgApiProductExtendMapper">
+
+	<!-- 可根据自己的需求，是否要使用 -->
+    <resultMap type="com.hrsk.cloud.eg.infrastructure.repository.database.entity.EgApiProductExtendDo" id="egApiProductExtendMap">
+        <result property="id" column="id"/>
+        <result property="createUid" column="create_uid"/>
+        <result property="createUsername" column="create_username"/>
+        <result property="gmtCreate" column="gmt_create"/>
+        <result property="modifyUid" column="modify_uid"/>
+        <result property="modifyUsername" column="modify_username"/>
+        <result property="gmtModify" column="gmt_modify"/>
+        <result property="status" column="status"/>
+        <result property="apiId" column="api_id"/>
+        <result property="shareRange" column="share_range"/>
+        <result property="protocol" column="protocol"/>
+        <result property="sharePurpose" column="share_purpose"/>
+        <result property="shareType" column="share_type"/>
+        <result property="needCheck" column="need_check"/>
+    </resultMap>
+
+
+</mapper>

egress-gateway-service-infrastructure/src/main/resources/mapper/ProductBusinessApiInfoMapper.xml

@@ -6,6 +6,7 @@
     <resultMap id="BaseResultMap" type="com.hrsk.cloud.eg.infrastructure.repository.database.entity.ProductBusinessApiInfoDo">
         <id column="id" property="id"/>
         <result column="busi_id" property="busiId"/>
+        <result column="api_id" property="apiId"/>
         <result column="join_kind" property="joinKind"/>
         <result column="join_method" property="joinMethod"/>
         <result column="joint_type" property="jointType"/>

pom.xml

@@ -153,7 +153,6 @@
             </dependency>
         </dependencies>
     </dependencyManagement>
-
 <modules>  <module>start</module>
     <module>egress-gateway-service-app</module>
     <module>egress-gateway-service-adapter</module>
@@ -223,4 +222,18 @@
             </plugins>
         </pluginManagement>
     </build>
+
+    <!-- 本地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>

start/src/main/resources/logback-spring-dev.xml

@@ -2,7 +2,7 @@
 <configuration>
     <property name="PROJECT_NAME" value="eg-server"/>
     <!-- 日志存放路径 -->
-    <property name="LOG_HOME"  value="./start/log/"/>
+    <property name="LOG_HOME"  value="../start/log/"/>
     <!-- 日志输出格式 -->
     <property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n" />
     <!-- 控制台输出 -->

start/src/main/resources/logback-spring-pre.xml

@@ -2,7 +2,7 @@
 <configuration>
     <property name="PROJECT_NAME" value="eg-server"/>
     <!-- 日志存放路径 -->
-    <property name="LOG_HOME"  value="./start/log/"/>
+    <property name="LOG_HOME"  value="../start/log/"/>
     <!-- 日志输出格式 -->
     <property name="log.pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n" />
     <!-- 控制台输出 -->