add api配置信息

egress-gateway-service-domain/src/main/java/com/hrsk/cloud/eg/domain/common/utils/SnowflakeIdWorker.java

@@ -0,0 +1,173 @@
+package com.hrsk.cloud.eg.domain.common.utils;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * <p>TODO</p>
+ *
+ * @author cheng.jin.peng
+ * @version V1.0.0
+ * @date 2023/5/11 11:17
+ */
+
+public class SnowflakeIdWorker {
+    private static final SnowflakeIdWorker singleBean = new SnowflakeIdWorker(2);
+    /**
+     * 开始时间截 (本次时间戳为：Thu Nov 04 2010 09:42:54 GMT+0800 (中国标准时间)----1288834974657L---1656543015264587776--19 )
+     */
+    private final long startTime = 1546300800L;
+
+    /** 机器id所占的位数 */
+    private final long workerIdBits = 3L;
+
+    /** 支持的最大机器id，结果是31 (这个移位算法可以很快的计算出几位二进制数所能表示的最大十进制数) */
+    private final long maxWorkerId = -1L ^ (-1L << workerIdBits);
+
+    /** 序列在id中占的位数 */
+    private final long sequenceBits = 5L;
+
+    /** 机器ID向左移12位 */
+    private final long workerIdShift = sequenceBits;
+
+    /** 时间截向左移22位(10+12) */
+    private final long timestampLeftShift = sequenceBits + workerIdBits;
+
+    /** 生成序列的掩码，这里为4095 (0b111111111111=0xfff=4095) */
+    private final long sequenceMask = -1L ^ (-1L << sequenceBits);
+
+    /** 工作机器ID(0~1024) */
+    private long workerId;
+
+    /** 毫秒内序列(0~4095) */
+    private long sequence = 0L;
+
+    /** 上次生成ID的时间截 */
+    private long lastTimestamp = -1L;
+
+    //==============================Constructors=====================================
+
+
+    private SnowflakeIdWorker(){
+    /**
+     * 构造函数
+     * @param workerId 工作ID (0~1024)
+     */
+
+    }
+    private SnowflakeIdWorker(long workerId) {
+        if (workerId > maxWorkerId || workerId < 0) {
+            throw new IllegalArgumentException(String.format("workerId can't be greater than %d or less than 0", maxWorkerId));
+        }
+        this.workerId = workerId;
+    }
+
+    // ==============================Methods==========================================
+    /**
+     * 获得下一个ID (该方法是线程安全的)
+     * @return SnowflakeId
+     */
+    public static long nextId() {
+        return singleBean.generateNextId();
+    }
+    public synchronized long generateNextId() {
+        long timestamp = timeGen();
+
+        //如果当前时间小于上一次ID生成的时间戳，说明系统时钟回退过这个时候应当抛出异常
+        if (timestamp < lastTimestamp) {
+            throw new RuntimeException(
+                    String.format("Clock moved backwards.  Refusing to generate id for %d milliseconds", lastTimestamp - timestamp));
+        }
+
+        //如果是同一时间生成的，则进行毫秒内序列
+        if (lastTimestamp == timestamp) {
+            sequence = (sequence + 1) & sequenceMask;
+            //毫秒内序列溢出
+            if (sequence == 0) {
+                //阻塞到下一个毫秒,获得新的时间戳
+                timestamp = tilNextMillis(lastTimestamp);
+            }
+        }
+        //时间戳改变，毫秒内序列重置
+        else {
+            sequence = 0L;
+        }
+
+        //上次生成ID的时间截
+        lastTimestamp = timestamp;
+
+        //移位并通过或运算拼到一起组成64位的ID
+        return ((timestamp - startTime) << timestampLeftShift)
+                | (workerId << workerIdShift)
+                | sequence;
+    }
+
+    /**
+     * 阻塞到下一个毫秒，直到获得新的时间戳
+     * @param lastTimestamp 上次生成ID的时间截
+     * @return 当前时间戳
+     */
+    protected long tilNextMillis(long lastTimestamp) {
+        long timestamp = timeGen();
+        while (timestamp <= lastTimestamp) {
+            timestamp = timeGen();
+        }
+        return timestamp;
+    }
+
+    /**
+     * 返回以毫秒为单位的当前时间
+     * @return 当前时间(毫秒)
+     */
+    protected long timeGen() {
+        return System.currentTimeMillis();
+    }
+
+    /**
+     * 测试
+     */
+    public static void main(String[] args) {
+        System.out.println("开始："+System.currentTimeMillis());
+
+
+
+//        for (int i = 0; i < 50; i++) {
+//            try {
+//                Thread.sleep(1000);
+//            } catch (InterruptedException e) {
+//                throw new RuntimeException(e);
+//            }
+//            long id = idWorker.nextId();
+//            System.out.println(id+"长度="+String.valueOf(id).length());
+//
+//        }
+        //SnowflakeIdWorker idWorker = new SnowflakeIdWorker(2);
+        for(int i=0; i<10; i++){
+            System.out.println(SnowflakeIdWorker.nextId());
+            try {
+                TimeUnit.MILLISECONDS.sleep(1000);
+            } catch (InterruptedException e) {
+                throw new RuntimeException(e);
+            }
+
+        }
+
+        /*System.out.println("结束："+System.currentTimeMillis());
+
+        Set<Long> set = new HashSet<>();
+
+        for (int i = 0; i < 100000;i++){
+            long id = idWorker.nextId();
+            try {
+                TimeUnit.MILLISECONDS.sleep(1000);
+            } catch (InterruptedException e) {
+                throw new RuntimeException(e);
+            }
+            System.out.println(id);
+            set.add(id);
+        }
+//        for (Long aLong : set) {
+//            System.out.println(aLong);
+//        }
+        System.out.println(set.size());*/
+    }
+}

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

@@ -0,0 +1,18 @@
+package com.hrsk.cloud.eg.infrastructure.repository.database.entity;
+
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * @author: bianlanzhou
+ * @create: 2024-08-02 08:14
+ * @description: 接出网关API表
+ **/
+@EqualsAndHashCode(callSuper = true)
+@Data
+public class EgApiDo extends BaseDo{
+    /**
+     * API名称
+     */
+    private String apiName;
+}

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

@@ -0,0 +1,28 @@
+package com.hrsk.cloud.eg.infrastructure.repository.database.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * @author: bianlanzhou
+ * @create: 2024-08-01 18:34
+ * @description: API通道数据对象
+ **/
+@EqualsAndHashCode(callSuper = true)
+@Data
+@TableName("eg_api_endpoint")
+public class EgApiEndpointDo extends BaseDo {
+    /**
+     * 数据API主键
+     */
+    private Long apiId;
+    /**
+     * 通道类型
+     */
+    private String endpointType;
+    /**
+     * 通道配置
+     */
+    private byte[] endpointConfig;
+}

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

@@ -0,0 +1,12 @@
+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.EgApiEndpointDo;
+
+/**
+ * @author: bianlanzhou
+ * @create: 2024-08-01 18:31
+ * @description: 接出网关API通道Mapper
+ **/
+public interface EgApiEndpointMapper extends BaseMapper<EgApiEndpointDo>{
+}

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

@@ -0,0 +1,12 @@
+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.EgApiDo;
+
+/**
+ * @author: bianlanzhou
+ * @create: 2024-08-02 08:14
+ * @description: 接出网关API数据映射
+ **/
+public interface EgApiMapper extends BaseMapper<EgApiDo> {
+}

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

@@ -0,0 +1,16 @@
+<?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.EgApiEndpointMapper">
+    <sql id="allCol" >
+        id,
+        `status`,
+        create_userid,
+        create_username,
+        modify_userid,
+        modify_username,
+        gmt_create,
+        gmt_modify
+    </sql>
+
+</mapper>

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

@@ -0,0 +1,16 @@
+<?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.EgApiMapper">
+    <sql id="allCol" >
+        id,
+        `status`,
+        create_userid,
+        create_username,
+        modify_userid,
+        modify_username,
+        gmt_create,
+        gmt_modify
+    </sql>
+
+</mapper>