feat: 创建 PlgMqMsg 表实体

Author: cadecode

framework/framework_base/src/main/java/com/github/cadecode/uniboot/framework/base/plugin/bean/po/PlgMqMsg.java

@@ -0,0 +1,59 @@
+package com.github.cadecode.uniboot.framework.base.plugin.bean.po;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.github.cadecode.uniboot.framework.base.plugin.enums.ConsumeStateEnum;
+import com.github.cadecode.uniboot.framework.base.plugin.enums.SendStateEnum;
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * MQ 消息实体
+ *
+ * @author Cade Li
+ * @since 2023/8/19
+ */
+@Data
+@TableName(autoResultMap = true)
+public class PlgMqMsg {
+
+    @TableId(type = IdType.ASSIGN_ID)
+    private String id;
+
+    private String bizType;
+
+    private String bizKey;
+
+    private String exchange;
+
+    private String routingKey;
+
+    private String message;
+
+    private SendStateEnum sendState;
+
+    private ConsumeStateEnum consumeState;
+
+    private Date nextRetryTime;
+
+    private String cause;
+
+    private Integer currRetryTimes;
+
+    private Integer maxRetryTimes;
+
+    private Long backoffInitInterval;
+
+    private Double backoffMultiplier;
+
+    private Long backoffMaxInterval;
+
+    @TableField(fill = FieldFill.INSERT)
+    private Date createTime;
+
+    @TableField(fill = FieldFill.UPDATE)
+    private Date updateTime;
+
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private String updateUser;
+}

framework/framework_base/src/main/java/com/github/cadecode/uniboot/framework/base/plugin/enums/ConsumeStateEnum.java

@@ -0,0 +1,35 @@
+package com.github.cadecode.uniboot.framework.base.plugin.enums;
+
+import com.baomidou.mybatisplus.annotation.EnumValue;
+import com.fasterxml.jackson.annotation.JsonValue;
+import lombok.Getter;
+
+/**
+ * 消费者消息确认状态枚举
+ *
+ * @author Cade Li
+ * @since 2023/8/19
+ */
+@Getter
+public enum ConsumeStateEnum {
+
+    /**
+     * 确认
+     */
+    ACK("ACK"),
+
+    /**
+     * 不确认
+     */
+    NACK("NACK"),
+
+    ;
+
+    @EnumValue
+    @JsonValue
+    private final String state;
+
+    ConsumeStateEnum(String state) {
+        this.state = state;
+    }
+}

framework/framework_base/src/main/java/com/github/cadecode/uniboot/framework/base/plugin/enums/SendStateEnum.java

@@ -0,0 +1,40 @@
+package com.github.cadecode.uniboot.framework.base.plugin.enums;
+
+import com.baomidou.mybatisplus.annotation.EnumValue;
+import com.fasterxml.jackson.annotation.JsonValue;
+import lombok.Getter;
+
+/**
+ * 生产者消息发送状态枚举
+ *
+ * @author Cade Li
+ * @since 2023/8/19
+ */
+@Getter
+public enum SendStateEnum {
+
+    /**
+     * 处理中
+     */
+    PREPARING("PREPARING"),
+
+    /**
+     * 完成
+     */
+    OVER("OVER"),
+
+    /**
+     * 失败
+     */
+    FAIL("FAIL"),
+
+    ;
+
+    @EnumValue
+    @JsonValue
+    private final String state;
+
+    SendStateEnum(String state) {
+        this.state = state;
+    }
+}

framework/framework_base/src/main/java/com/github/cadecode/uniboot/framework/base/plugin/mapper/PlgMqMsgMapper.java

@@ -0,0 +1,15 @@
+package com.github.cadecode.uniboot.framework.base.plugin.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.cadecode.uniboot.framework.base.plugin.bean.po.PlgMqMsg;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * PlgMqMsg Mapper
+ *
+ * @author Cade Li
+ * @since 2023/8/19
+ */
+@Mapper
+public interface PlgMqMsgMapper extends BaseMapper<PlgMqMsg> {
+}

framework/framework_base/src/main/java/com/github/cadecode/uniboot/framework/base/plugin/service/PlgMqMsgService.java

@@ -0,0 +1,13 @@
+package com.github.cadecode.uniboot.framework.base.plugin.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.github.cadecode.uniboot.framework.base.plugin.bean.po.PlgMqMsg;
+
+/**
+ * PlgMqMsg Service
+ *
+ * @author Cade Li
+ * @since 2023/5/26
+ */
+public interface PlgMqMsgService extends IService<PlgMqMsg> {
+}

framework/framework_base/src/main/java/com/github/cadecode/uniboot/framework/base/plugin/serviceimpl/PlgMqMsgServiceImpl.java

@@ -0,0 +1,17 @@
+package com.github.cadecode.uniboot.framework.base.plugin.serviceimpl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.cadecode.uniboot.framework.base.plugin.bean.po.PlgMqMsg;
+import com.github.cadecode.uniboot.framework.base.plugin.mapper.PlgMqMsgMapper;
+import com.github.cadecode.uniboot.framework.base.plugin.service.PlgMqMsgService;
+import org.springframework.stereotype.Service;
+
+/**
+ * PlgMqMsg Service 实现
+ *
+ * @author Cade Li
+ * @since 2023/5/26
+ */
+@Service
+public class PlgMqMsgServiceImpl extends ServiceImpl<PlgMqMsgMapper, PlgMqMsg> implements PlgMqMsgService {
+}