Initial commit

.gitignore

+*.iml
+node_modules/
+.idea/
+*.class
+target/
\ No newline at end of file

common-lib/.gitignore

+*.iml
+node_modules/
+.idea/
+*.class
+target/
\ No newline at end of file

common-lib/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.mortals.xhx</groupId>
+    <artifactId>common-lib</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <packaging>jar</packaging>
+
+    <name>common-lib</name>
+    <description>公共依赖库</description>
+
+    <parent>
+        <groupId>com.mortals.xhx</groupId>
+        <artifactId>log-platform</artifactId>
+        <version>1.0.0-SNAPSHOT</version>
+    </parent>
+
+    <properties>
+        <rabbitmq.version>4.8.0</rabbitmq.version>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.mortals.framework</groupId>
+            <artifactId>mortals-framework-springcloud</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.google.code.gson</groupId>
+            <artifactId>gson</artifactId>
+            <version>2.9.0</version>
+        </dependency>
+
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-all</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka-clients</artifactId>
+            <version>2.6.0</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.rabbitmq</groupId>
+            <artifactId>amqp-client</artifactId>
+            <version>${rabbitmq.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-pool2</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-configuration-processor</artifactId>
+            <optional>true</optional>
+        </dependency>
+
+        <dependency>
+            <groupId>cn.hutool</groupId>
+            <artifactId>hutool-all</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.google.zxing</groupId>
+            <artifactId>javase</artifactId>
+        </dependency>
+
+
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.google.code.gson</groupId>
+            <artifactId>gson</artifactId>
+        </dependency>
+
+    </dependencies>
+
+
+</project>
\ No newline at end of file

common-lib/src/main/java/com/mortals/xhx/common/BrokerConfig.java

+package com.mortals.xhx.common;
+
+/**
+ * @author: zxfei
+ * @date: 2021/11/22 11:17
+ * @description:
+ **/
+public class BrokerConfig {
+}

common-lib/src/main/java/com/mortals/xhx/common/code/ApproveStateEnum.java

+package com.mortals.xhx.common.code;
+
+import com.mortals.framework.ap.SysConstains;
+import com.mortals.framework.common.IBaseEnum;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+ * 审核状态
+ * @author 
+ *
+ */
+public enum ApproveStateEnum implements IBaseEnum {
+
+    UN_AUDIT(1, "未审核", SysConstains.STYLE_DEFAULT),
+    AUDITING(2, "审核中", SysConstains.STYLE_PRIMARY),
+	AUDIT_FIN(3, "审核完成", SysConstains.STYLE_PRIMARY);
+
+    private int value;
+    private String desc;
+    private String style;
+
+    ApproveStateEnum(int value, String desc, String style) {
+        this.value = value;
+        this.desc = desc;
+        this.style = style;
+    }
+
+    @Override
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+    public String getStyle()
+	{
+		return style;
+	}
+
+	public static ApproveStateEnum getByValue(int value) {
+        for (ApproveStateEnum examStatus : ApproveStateEnum.values()) {
+            if (examStatus.getValue() == value) {
+                return examStatus;
+            }
+        }
+        return null;
+    }
+	/**
+	 * 获取Map集合
+	 * @param eItem 不包含项
+	 * @return
+	 */
+	public static Map<String,String> getEnumMap(int... eItem) {
+		Map<String,String> resultMap= new LinkedHashMap<String,String>();
+		for (ApproveStateEnum item : ApproveStateEnum.values()) {
+			try{
+				boolean hasE = false;
+				for (int e : eItem){
+					if(item.getValue()==e){
+						hasE = true;
+						break;
+					}
+				}
+				if(!hasE){
+					resultMap.put(item.getValue()+"", item.getDesc());
+				}
+			}catch(Exception ex){
+			}
+		}
+		return resultMap;
+	}
+}

common-lib/src/main/java/com/mortals/xhx/common/code/AreaLevelEnum.java

+package com.mortals.xhx.common.code;
+
+import com.mortals.framework.ap.SysConstains;
+import com.mortals.framework.common.IBaseEnum;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+ * 区域级别
+ *
+ * @author yiqimin
+ * @create 2018/09/26
+ */
+public enum AreaLevelEnum implements IBaseEnum {
+
+    PROVINCE(1, "省", SysConstains.STYLE_DEFAULT),
+    CITY(2, "市", SysConstains.STYLE_DEFAULT),
+    AREA(3, "区/县", SysConstains.STYLE_DEFAULT),
+    TOWN(4, "镇", SysConstains.STYLE_DEFAULT);
+
+    private int value;
+    private String desc;
+    private String style;
+
+    AreaLevelEnum(int value, String desc, String style) {
+        this.value = value;
+        this.desc = desc;
+        this.style = style;
+    }
+
+    @Override
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+    public String getStyle()
+    {
+        return style;
+    }
+
+    public static AreaLevelEnum getByValue(int value) {
+        for (AreaLevelEnum e : AreaLevelEnum.values()) {
+            if (e.getValue() == value) {
+                return e;
+            }
+        }
+        return null;
+    }
+
+    public static Map<String,String> getEnumMap(int... eItem) {
+        Map<String,String> resultMap= new LinkedHashMap<String,String>();
+        for (AreaLevelEnum item : AreaLevelEnum.values()) {
+            try{
+                boolean hasE = false;
+                for (int e : eItem){
+                    if(item.getValue()==e){
+                        hasE = true;
+                        break;
+                    }
+                }
+                if(!hasE){
+                    resultMap.put(item.getValue()+"", item.getDesc());
+                }
+            }catch(Exception ex){
+            }
+        }
+        return resultMap;
+    }
+    
+}

common-lib/src/main/java/com/mortals/xhx/common/code/AuthType.java

+package com.mortals.xhx.common.code;
+
+import com.mortals.framework.ap.SysConstains;
+import com.mortals.framework.common.IBaseEnum;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+ * 资源类型
+ * @author 
+ *
+ */
+public enum AuthType implements IBaseEnum {
+	UNLIMITED(0, "无限制", SysConstains.STYLE_DEFAULT),
+    UNLOGIN(1, "无需登录查看", SysConstains.STYLE_DEFAULT),
+    LOGIN(2, "需要登录查看", SysConstains.STYLE_DEFAULT),
+    AUTH(3, "需要角色权限查看", SysConstains.STYLE_PRIMARY);
+	//0：无限制，1：无需登录查看，2：需要登录查看，3：需要角色权限查看，默认3
+    private int value;
+    private String desc;
+    private String style;
+
+    AuthType(int value, String desc, String style) {
+        this.value = value;
+        this.desc = desc;
+        this.style = style;
+    }
+
+    @Override
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+    public String getStyle()
+	{
+		return style;
+	}
+
+	public static AuthType getByValue(int value) {
+        for (AuthType examStatus : AuthType.values()) {
+            if (examStatus.getValue() == value) {
+                return examStatus;
+            }
+        }
+        return null;
+    }
+	/**
+	 * 获取Map集合
+	 * @param eItem 不包含项
+	 * @return
+	 */
+	public static Map<String,String> getEnumMap(int... eItem) {
+		Map<String,String> resultMap= new LinkedHashMap<String,String>();
+		for (AuthType item : AuthType.values()) {
+			try{
+				boolean hasE = false;
+				for (int e : eItem){
+					if(item.getValue()==e){
+						hasE = true;
+						break;
+					}
+				}
+				if(!hasE){
+					resultMap.put(item.getValue()+"", item.getDesc());
+				}
+			}catch(Exception ex){
+			}
+		}
+		return resultMap;
+	}
+}

common-lib/src/main/java/com/mortals/xhx/common/code/CommentTypeEnum.java

+package com.mortals.xhx.common.code;
+
+import java.io.Serializable;
+
+/**
+ * 审批模式
+ *
+ * @author: zxfei
+ * @date: 2021/8/26 9:58
+ */
+public enum CommentTypeEnum implements Serializable {
+    SP("审批"),
+    QS("签收"),
+    FQS("反签收"),
+    BH("驳回"),
+    CH("撤回"),
+    ZC("暂存"),
+    XTZX("系统执行"),
+    TJ("提交"),
+    CXTJ("重新提交"),
+    SPJS("审批结束"),
+    LCZZ("流程终止"),
+    WP("委派"),
+    ZH("知会"),
+    ZY("转阅"),
+    YY("已阅"),
+    ZB("转办"),
+    SQ("授权"),
+    SPBJQ("审批并加签"),
+    HJQ("后加签"),
+    QJQ("前加签"),
+    CFTG("重复跳过"),
+    XT("协同"),
+    PS("评审");
+    private String name;//名称
+
+    /**
+     * 通过type获取Msg
+     *
+     * @param type
+     * @return
+     * @Description:
+     */
+    public static String getEnumMsgByType(String type) {
+        for (CommentTypeEnum e : CommentTypeEnum.values()) {
+            if (e.toString().equals(type)) {
+                return e.name;
+            }
+        }
+        return "";
+    }
+
+    CommentTypeEnum(String name) {
+        this.name = name;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+}

common-lib/src/main/java/com/mortals/xhx/common/code/CompareTypeEnum.java

+package com.mortals.xhx.common.code;
+
+import com.mortals.framework.common.IBaseEnum;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+public enum CompareTypeEnum implements IBaseEnum {
+	DAY(1, "按日"),
+	MONTH(2, "按月");
+
+	private int value;
+	private String desc;
+	
+	CompareTypeEnum(int value, String desc) {
+		this.value = value;
+		this.desc = desc;
+	}
+	
+	@Override
+	public int getValue() {
+		return this.value;
+	}
+
+	@Override
+	public String getDesc() {
+		return this.desc;
+	}
+	
+	public static Map<String,String> getEnumMap() {
+        Map<String, String> resultMap= new LinkedHashMap<String, String>();
+        for (CompareTypeEnum item : CompareTypeEnum.values()) {
+        	resultMap.put(item.getValue() + "", item.getDesc());
+        }
+        return resultMap;
+    }
+}

common-lib/src/main/java/com/mortals/xhx/common/code/DataSatus.java

+package com.mortals.xhx.common.code;
+
+import com.mortals.framework.ap.SysConstains;
+import com.mortals.framework.common.IBaseEnum;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+ * 资源类型
+ * @author 
+ *
+ */
+public enum DataSatus implements IBaseEnum {
+	DISENABLE(0, "禁用", SysConstains.STYLE_DEFAULT),
+	ENABLE(1, "启用", SysConstains.STYLE_DEFAULT),
+	CLOSE(2, "注销", SysConstains.STYLE_DEFAULT),
+	DELETE(3, "已删除", SysConstains.STYLE_DEFAULT),
+	OVERDUE(4, "过期", SysConstains.STYLE_DEFAULT),
+	USEOUT(5, "用完", SysConstains.STYLE_DEFAULT);
+    private int value;
+    private String desc;
+    private String style;
+
+    DataSatus(int value, String desc, String style) {
+        this.value = value;
+        this.desc = desc;
+        this.style = style;
+    }
+
+    @Override
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+    public String getStyle()
+	{
+		return style;
+	}
+
+	public static DataSatus getByValue(int value) {
+        for (DataSatus examStatus : DataSatus.values()) {
+            if (examStatus.getValue() == value) {
+                return examStatus;
+            }
+        }
+        return null;
+    }
+	/**
+	 * 获取Map集合
+	 * @param eItem 不包含项
+	 * @return
+	 */
+	public static Map<String,String> getEnumMap(int... eItem) {
+		Map<String,String> resultMap= new LinkedHashMap<String,String>();
+		for (DataSatus item : DataSatus.values()) {
+			try{
+				boolean hasE = false;
+				for (int e : eItem){
+					if(item.getValue()==e){
+						hasE = true;
+						break;
+					}
+				}
+				if(!hasE){
+					resultMap.put(item.getValue()+"", item.getDesc());
+				}
+			}catch(Exception ex){
+			}
+		}
+		return resultMap;
+	}
+}

common-lib/src/main/java/com/mortals/xhx/common/code/DataSatusEnum.java

+package com.mortals.xhx.common.code;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+ * 资源类型
+ * @author 
+ *
+ */
+public enum DataSatusEnum {
+	DISENABLE(0, "禁用"),
+	ENABLE(1, "启用"),
+	CLOSE(2, "注销"),
+	DELETE(3, "已删除"),
+	OVERDUE(4, "过期"),
+	USEOUT(5, "用完");
+    private int value;
+    private String desc;
+    
+
+    DataSatusEnum(int value, String desc) {
+        this.value = value;
+        this.desc = desc;
+        
+    }
+
+    
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+	public static DataSatusEnum getByValue(int value) {
+        for (DataSatusEnum examStatus : DataSatusEnum.values()) {
+            if (examStatus.getValue() == value) {
+                return examStatus;
+            }
+        }
+        return null;
+    }
+	/**
+	 * 获取Map集合
+	 * @param eItem 不包含项
+	 * @return
+	 */
+	public static Map<String,String> getEnumMap(int... eItem) {
+		Map<String,String> resultMap= new LinkedHashMap<String,String>();
+		for (DataSatusEnum item : DataSatusEnum.values()) {
+			try{
+				boolean hasE = false;
+				for (int e : eItem){
+					if(item.getValue()==e){
+						hasE = true;
+						break;
+					}
+				}
+				if(!hasE){
+					resultMap.put(item.getValue()+"", item.getDesc());
+				}
+			}catch(Exception ex){
+			}
+		}
+		return resultMap;
+	}
+}

common-lib/src/main/java/com/mortals/xhx/common/code/FlowStateType.java

+package com.mortals.xhx.common.code;
+
+import com.mortals.framework.ap.SysConstains;
+import com.mortals.framework.common.IBaseEnum;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+ * 流程状态
+ * @author 
+ *
+ */
+public enum FlowStateType implements IBaseEnum {
+	 /** 激活 */
+    active(1, "激活", SysConstains.STYLE_DEFAULT),
+    /** 挂起 */
+    suspend(2, "挂起", SysConstains.STYLE_PRIMARY);
+
+    private int value;
+    private String desc;
+    private String style;
+
+    FlowStateType(int value, String desc, String style) {
+        this.value = value;
+        this.desc = desc;
+        this.style = style;
+    }
+
+    @Override
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+    public String getStyle()
+	{
+		return style;
+	}
+
+	public static FlowStateType getByValue(int value) {
+        for (FlowStateType examStatus : FlowStateType.values()) {
+            if (examStatus.getValue() == value) {
+                return examStatus;
+            }
+        }
+        return null;
+    }
+	/**
+	 * 获取Map集合
+	 * @param eItem 不包含项
+	 * @return
+	 */
+	public static Map<String,String> getEnumMap(int... eItem) {
+		Map<String,String> resultMap= new LinkedHashMap<String,String>();
+		for (FlowStateType item : FlowStateType.values()) {
+			try{
+				boolean hasE = false;
+				for (int e : eItem){
+					if(item.getValue()==e){
+						hasE = true;
+						break;
+					}
+				}
+				if(!hasE){
+					resultMap.put(item.getValue()+"", item.getDesc());
+				}
+			}catch(Exception ex){
+			}
+		}
+		return resultMap;
+	}
+}

common-lib/src/main/java/com/mortals/xhx/common/code/FlowStatusNotifyType.java

+package com.mortals.xhx.common.code;
+
+import com.mortals.framework.ap.SysConstains;
+import com.mortals.framework.common.IBaseEnum;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+ * 流程通知状态
+ * @author 
+ *
+ */
+public enum FlowStatusNotifyType implements IBaseEnum {
+
+    FLOW_START(0, "流程启动", SysConstains.STYLE_DEFAULT),
+
+    FLOW_END(1, "流程结束", SysConstains.STYLE_PRIMARY),
+
+	TASK_CREATE(2, "任务创建", SysConstains.STYLE_PRIMARY),
+
+	TASK_COMPLETE(3, "任务结束", SysConstains.STYLE_PRIMARY);
+
+    private int value;
+    private String desc;
+    private String style;
+
+    FlowStatusNotifyType(int value, String desc, String style) {
+        this.value = value;
+        this.desc = desc;
+        this.style = style;
+    }
+
+    @Override
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+    public String getStyle()
+	{
+		return style;
+	}
+
+	public static FlowStatusNotifyType getByValue(int value) {
+        for (FlowStatusNotifyType examStatus : FlowStatusNotifyType.values()) {
+            if (examStatus.getValue() == value) {
+                return examStatus;
+            }
+        }
+        return null;
+    }
+	/**
+	 * 获取Map集合
+	 * @param eItem 不包含项
+	 * @return
+	 */
+	public static Map<String,String> getEnumMap(int... eItem) {
+		Map<String,String> resultMap= new LinkedHashMap<String,String>();
+		for (FlowStatusNotifyType item : FlowStatusNotifyType.values()) {
+			try{
+				boolean hasE = false;
+				for (int e : eItem){
+					if(item.getValue()==e){
+						hasE = true;
+						break;
+					}
+				}
+				if(!hasE){
+					resultMap.put(item.getValue()+"", item.getDesc());
+				}
+			}catch(Exception ex){
+			}
+		}
+		return resultMap;
+	}
+}

common-lib/src/main/java/com/mortals/xhx/common/code/MenuAuthType.java

+package com.mortals.xhx.common.code;
+
+import com.mortals.framework.ap.SysConstains;
+import com.mortals.framework.common.IBaseEnum;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+public enum MenuAuthType implements IBaseEnum{
+	 /** 无限制 */
+    UNLIMIT(0, "无限制", SysConstains.STYLE_DEFAULT),
+    /** 无需登录查看 */
+    WITHOUTLOGIN(1, "无需登录查看", SysConstains.STYLE_DEFAULT),
+    /** 需要登录查看 */
+    WITHLOGIN(2, "需要登录查看", SysConstains.STYLE_DEFAULT),
+    /** 需要角色权限查看 */
+    WITHAUTHORITY(3, "需要角色权限查看", SysConstains.STYLE_DEFAULT);
+    
+    private int value;
+    private String desc;
+    private String style;
+
+    MenuAuthType(int value, String desc, String style) {
+        this.value = value;
+        this.desc = desc;
+        this.style = style;
+    }
+
+    @Override
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+    public String getStyle()
+	{
+		return style;
+	}
+
+	public static MenuAuthType getByValue(int value) {
+        for (MenuAuthType menuAuthType : MenuAuthType.values()) {
+            if (menuAuthType.getValue() == value) {
+                return menuAuthType;
+            }
+        }
+        return null;
+    }
+	/**
+	 * 获取Map集合
+	 * @param eItem 不包含项
+	 * @return
+	 */
+	public static Map<String,String> getEnumMap(int... eItem) {
+		Map<String,String> resultMap= new LinkedHashMap<String,String>();
+		for (MenuAuthType item : MenuAuthType.values()) {
+			try{
+				boolean hasE = false;
+				for (int e : eItem){
+					if(item.getValue()==e){
+						hasE = true;
+						break;
+					}
+				}
+				if(!hasE){
+					resultMap.put(item.getValue()+"", item.getDesc());
+				}
+			}catch(Exception ex){
+			}
+		}
+		return resultMap;
+	}
+}

common-lib/src/main/java/com/mortals/xhx/common/code/MenuComm.java

+package com.mortals.xhx.common.code;
+
+import com.mortals.framework.ap.SysConstains;
+import com.mortals.framework.common.IBaseEnum;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+public enum MenuComm {
+    /** 非常用 */
+    UNCOMMON(0, "非常用"),
+    /** 常用 */
+    COMMON(1, "常用");
+    
+    private int value;
+    private String desc;
+    private String style;
+
+    MenuComm(int value, String desc) {
+        this.value = value;
+        this.desc = desc;
+    }
+
+
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+
+	public static MenuComm getByValue(int value) {
+        for (MenuComm menuComm : MenuComm.values()) {
+            if (menuComm.getValue() == value) {
+                return menuComm;
+            }
+        }
+        return null;
+    }
+	/**
+	 * 获取Map集合
+	 * @param eItem 不包含项
+	 * @return
+	 */
+	public static Map<String,String> getEnumMap(int... eItem) {
+		Map<String,String> resultMap= new LinkedHashMap<String,String>();
+		for (MenuComm item : MenuComm.values()) {
+			try{
+				boolean hasE = false;
+				for (int e : eItem){
+					if(item.getValue()==e){
+						hasE = true;
+						break;
+					}
+				}
+				if(!hasE){
+					resultMap.put(item.getValue()+"", item.getDesc());
+				}
+			}catch(Exception ex){
+			}
+		}
+		return resultMap;
+	}
+}

common-lib/src/main/java/com/mortals/xhx/common/code/MenuLinkType.java

+package com.mortals.xhx.common.code;
+
+import com.mortals.framework.ap.SysConstains;
+import com.mortals.framework.common.IBaseEnum;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+public enum MenuLinkType implements IBaseEnum{
+    /** 普通 */
+    NORMAL(0, "普通", SysConstains.STYLE_DEFAULT),
+    /** 弹出 */
+    POP(1, "弹出", SysConstains.STYLE_DEFAULT),
+    /** 脚本（JavaScript） */
+    SCRIPT(2, "脚本", SysConstains.STYLE_DEFAULT);
+    
+    private int value;
+    private String desc;
+    private String style;
+
+    MenuLinkType(int value, String desc, String style) {
+        this.value = value;
+        this.desc = desc;
+        this.style = style;
+    }
+
+    @Override
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+    public String getStyle()
+	{
+		return style;
+	}
+
+	public static MenuLinkType getByValue(int value) {
+        for (MenuLinkType menuLinkType : MenuLinkType.values()) {
+            if (menuLinkType.getValue() == value) {
+                return menuLinkType;
+            }
+        }
+        return null;
+    }
+	/**
+	 * 获取Map集合
+	 * @param eItem 不包含项
+	 * @return
+	 */
+	public static Map<String,String> getEnumMap(int... eItem) {
+		Map<String,String> resultMap= new LinkedHashMap<String,String>();
+		for (MenuLinkType item : MenuLinkType.values()) {
+			try{
+				boolean hasE = false;
+				for (int e : eItem){
+					if(item.getValue()==e){
+						hasE = true;
+						break;
+					}
+				}
+				if(!hasE){
+					resultMap.put(item.getValue()+"", item.getDesc());
+				}
+			}catch(Exception ex){
+			}
+		}
+		return resultMap;
+	}
+}

common-lib/src/main/java/com/mortals/xhx/common/code/MenuType.java

+package com.mortals.xhx.common.code;
+
+import com.mortals.framework.ap.SysConstains;
+import com.mortals.framework.common.IBaseEnum;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+public enum MenuType implements IBaseEnum{
+    /** 主菜单 */
+    MAIN(0, "主菜单", SysConstains.STYLE_DEFAULT),
+    /** 非主菜单 */
+    UNMAIN(1, "非主菜单", SysConstains.STYLE_DEFAULT);
+    
+    private int value;
+    private String desc;
+    private String style;
+
+    MenuType(int value, String desc, String style) {
+        this.value = value;
+        this.desc = desc;
+        this.style = style;
+    }
+
+    @Override
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+    public String getStyle()
+	{
+		return style;
+	}
+
+	public static MenuType getByValue(int value) {
+        for (MenuType menuType : MenuType.values()) {
+            if (menuType.getValue() == value) {
+                return menuType;
+            }
+        }
+        return null;
+    }
+	/**
+	 * 获取Map集合
+	 * @param eItem 不包含项
+	 * @return
+	 */
+	public static Map<String,String> getEnumMap(int... eItem) {
+		Map<String,String> resultMap= new LinkedHashMap<String,String>();
+		for (MenuType item : MenuType.values()) {
+			try{
+				boolean hasE = false;
+				for (int e : eItem){
+					if(item.getValue()==e){
+						hasE = true;
+						break;
+					}
+				}
+				if(!hasE){
+					resultMap.put(item.getValue()+"", item.getDesc());
+				}
+			}catch(Exception ex){
+			}
+		}
+		return resultMap;
+	}
+}

common-lib/src/main/java/com/mortals/xhx/common/code/MessageProtocolEnum.java

+package com.mortals.xhx.common.code;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+ *
+ *
+ * @author zxfei
+ */
+public enum MessageProtocolEnum {
+    JSON("json", "未激活");
+    private String value;
+    private String desc;
+
+    MessageProtocolEnum(String value, String desc) {
+        this.value = value;
+        this.desc = desc;
+    }
+
+    public String getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return this.desc;
+    }
+
+    public static MessageProtocolEnum getByValue(String value) {
+        for (MessageProtocolEnum activeEnum : MessageProtocolEnum.values()) {
+            if (value.equals(activeEnum.getValue())) {
+                return activeEnum;
+            }
+        }
+        return null;
+    }
+
+    /**
+     * 获取Map集合
+     *
+     * @param eItem 不包含项
+     * @return
+     */
+    public static Map<String, String> getEnumMap(String... eItem) {
+        Map<String, String> resultMap = new LinkedHashMap<>();
+        for (MessageProtocolEnum item : MessageProtocolEnum.values()) {
+            try {
+                boolean hasE = false;
+                for (String e : eItem) {
+                    if (item.getValue() == e) {
+                        hasE = true;
+                        break;
+                    }
+                }
+                if (!hasE) {
+                    resultMap.put(item.getValue(), item.getDesc());
+                }
+            } catch (Exception ex) {
+
+            }
+        }
+        return resultMap;
+    }
+}
\ No newline at end of file

common-lib/src/main/java/com/mortals/xhx/common/code/ModStatusEnum.java

+package com.mortals.xhx.common.code;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+ * 参数修改状态
+ * @author 
+ *
+ */
+public enum ModStatusEnum {
+	 /** 页面隐藏 */
+    HIDDEN(0, "隐藏"),
+    /** 页面可查看 */
+    VIEW(1, "查看"),
+    /** 页面可修改 */
+    EDIT(2, "修改"),
+    /** 页面可删除 */
+    DELETE(3, "删除"),
+    /** 页面可修改删除 */
+    EDITANDDELETE(4, "修改删除");
+
+    private int value;
+    private String desc;
+    
+
+    ModStatusEnum(int value, String desc) {
+        this.value = value;
+        this.desc = desc;
+        
+    }
+
+    
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+	public static ModStatusEnum getByValue(int value) {
+        for (ModStatusEnum modStatus : ModStatusEnum.values()) {
+            if (modStatus.getValue() == value) {
+                return modStatus;
+            }
+        }
+        return null;
+    }
+	/**
+	 * 获取Map集合
+	 * @param eItem 不包含项
+	 * @return
+	 */
+	public static Map<String,String> getEnumMap(int... eItem) {
+		Map<String,String> resultMap= new LinkedHashMap<String,String>();
+		for (ModStatusEnum item : ModStatusEnum.values()) {
+			try{
+				boolean hasE = false;
+				for (int e : eItem){
+					if(item.getValue()==e){
+						hasE = true;
+						break;
+					}
+				}
+				if(!hasE){
+					resultMap.put(item.getValue()+"", item.getDesc());
+				}
+			}catch(Exception ex){
+			}
+		}
+		return resultMap;
+	}
+}

common-lib/src/main/java/com/mortals/xhx/common/code/OperTypeEnum.java

+package com.mortals.xhx.common.code;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * Created by chendilin on 2018/3/7.
+ */
+public enum OperTypeEnum {
+
+    SAVE(0,"添加"),
+    UPDATE(1,"更新"),
+    DELETE(2,"删除"),
+    OTHER(-1,"其它");
+
+    private int value;
+    private String msg;
+
+    private OperTypeEnum(int value,String msg) {
+        this.value = value;
+        this.msg = msg;
+    }
+
+    public int getValue() {
+        return this.value;
+    }
+
+    public static Map<String,String> getEnumMap(){
+        Map<String,String> resultMap = new HashMap<>();
+        OperTypeEnum[] operTypeEnum =  OperTypeEnum.values();
+        for (OperTypeEnum typeEnum : operTypeEnum) {
+            resultMap.put(String.valueOf(typeEnum.value),typeEnum.msg);
+        }
+        return resultMap;
+    }
+}

common-lib/src/main/java/com/mortals/xhx/common/code/ProcessStatusEnum.java

+package com.mortals.xhx.common.code;
+
+import java.io.Serializable;
+
+/**
+ * 流程的状态
+ *
+ * @author: zxfei
+ * @date: 2021/8/26 9:58
+ */
+public enum ProcessStatusEnum implements Serializable {
+
+    SPZ("审批中"),
+    BH("驳回"),
+    CH("撤回"),
+    JQ("加签"),
+    ZC("暂存"),
+    ZB("转办"),
+    BJ("办结"),
+    ZZ("终止");
+
+    private String msg;
+    private String type;
+
+    ProcessStatusEnum(String msg) {
+        this.msg = msg;
+    }
+
+    /**
+     * 通过type获取Msg
+     *
+     * @param type
+     * @return
+     * @Description:
+     */
+    public static String getEnumMsgByType(String type) {
+        for (ProcessStatusEnum e : ProcessStatusEnum.values()) {
+            if (e.toString().equals(type)) {
+                return e.msg;
+            }
+        }
+        return "";
+    }
+
+    public String getMsg() {
+        return msg;
+    }
+
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+}
+
+	
\ No newline at end of file

common-lib/src/main/java/com/mortals/xhx/common/code/ResultCodeEnum.java

+package com.mortals.xhx.common.code;
+
+/**
+ * 业务统一返回码
+ * @author linlc
+ *
+ */
+public enum ResultCodeEnum {
+	
+	CODE_001(156001,"参数类型错误"),
+	CODE_002(156002,"部分参数为空"),
+	CODE_003(156003,"参数长度超过限制"),
+	CODE_004(156004,"日期格式错误"),
+	CODE_005(156005,"时间区间不合法"),
+	CODE_006(156006,"远端服务不可用"),
+	CODE_007(156007,"无效的签名"),
+	CODE_008(156008,"不合法的 AppID ，请开发者检查 AppID 的正确性，避免异常字符，注意大小写"),
+	CODE_009(156009,"请求来源地址不合法"),
+	CODE_010(156010,"没有相应的用户"),
+	CODE_011(156011,"不合法的文件类型"),
+	CODE_012(156012,"不合法的文件大小"),
+	CODE_013(156013,"上传文件缺失"),
+	CODE_014(156014,"不支持的图片格式"),
+	CODE_015(156015,"无效的url"),
+	CODE_016(156016,"设备编号不合法"),
+	CODE_017(356017,"设备编号不存在"),
+	CODE_018(356018,"设备当前在线状态为“离线”，无法使用！"),
+	CODE_019(356019,"设备当前投放状态为“待重投”，无法使用！"),
+	CODE_020(356020,"设备当前投放状态为“已报废”，无法使用！"),
+	CODE_021(356021,"设备当前投放状态为“初始化”，无法使用！"),
+	CODE_022(356022,"此设备当前启用状态为“禁用”，无法使用！"),
+	CODE_023(356023,"API 调用太频繁，请稍候再试"),
+	CODE_024(256024,"用户未授权该 api"),
+	CODE_025(156025,"解析 JSON/XML 内容错误"),
+	CODE_FAILUER(-1,"失败");
+
+    private int value;
+    private String desc;
+
+    ResultCodeEnum(int value, String desc) {
+    	this.value = value;
+        this.desc = desc;
+    }
+
+    public int getValue() {
+    	return value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+
+
+}

common-lib/src/main/java/com/mortals/xhx/common/code/RoleType.java

+package com.mortals.xhx.common.code;
+
+import com.mortals.framework.ap.SysConstains;
+import com.mortals.framework.common.IBaseEnum;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+ * 角色类型
+ * @author 
+ *
+ */
+public enum RoleType implements IBaseEnum {
+	 /** 系统内置角色 */
+    BUILT_IN(0, "系统内置角色", SysConstains.STYLE_DEFAULT),
+    /** 默认系统角色 */
+    SYSTEM_DEFAULT(1, "默认系统角色", SysConstains.STYLE_INFO),
+    /** 企业用户角色 */
+    CUSTOMER_DEFAULT(2, "企业用户角色", SysConstains.STYLE_PRIMARY),
+    /** 普通角色 */
+    NORMAL(4, "普通角色 ", SysConstains.STYLE_SUCCESS),;
+
+    
+
+	//0：系统内置角色（不可删除），1：默认系统角色，2：默认新闻用户角色，3：默认资讯用户角色，4：普通角色，默认4
+	
+    private int value;
+    private String desc;
+    private String style;
+
+    RoleType(int value, String desc, String style) {
+        this.value = value;
+        this.desc = desc;
+        this.style = style;
+    }
+
+    @Override
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+    public String getStyle()
+	{
+		return style;
+	}
+
+	public static RoleType getByValue(int value) {
+        for (RoleType examStatus : RoleType.values()) {
+            if (examStatus.getValue() == value) {
+                return examStatus;
+            }
+        }
+        return null;
+    }
+	/**
+	 * 获取Map集合
+	 * @param eItem 不包含项
+	 * @return
+	 */
+	public static Map<String,String> getEnumMap(int... eItem) {
+		Map<String,String> resultMap= new LinkedHashMap<String,String>();
+		for (RoleType item : RoleType.values()) {
+			try{
+				boolean hasE = false;
+				for (int e : eItem){
+					if(item.getValue()==e){
+						hasE = true;
+						break;
+					}
+				}
+				if(!hasE){
+					resultMap.put(item.getValue()+"", item.getDesc());
+				}
+			}catch(Exception ex){
+			}
+		}
+		return resultMap;
+	}
+}

common-lib/src/main/java/com/mortals/xhx/common/code/SourceType.java

+package com.mortals.xhx.common.code;
+
+import com.mortals.framework.ap.SysConstains;
+import com.mortals.framework.common.IBaseEnum;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+ * 资源类型
+ * @author 
+ *
+ */
+public enum SourceType implements IBaseEnum {
+	 /** 系统资源 */
+    SYSTEM(0, "系统资源", SysConstains.STYLE_DEFAULT),
+    /** 开放资源 */
+    OPEN(1, "开放资源", SysConstains.STYLE_PRIMARY);
+
+    private int value;
+    private String desc;
+    private String style;
+
+    SourceType(int value, String desc, String style) {
+        this.value = value;
+        this.desc = desc;
+        this.style = style;
+    }
+
+    @Override
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+    public String getStyle()
+	{
+		return style;
+	}
+
+	public static SourceType getByValue(int value) {
+        for (SourceType examStatus : SourceType.values()) {
+            if (examStatus.getValue() == value) {
+                return examStatus;
+            }
+        }
+        return null;
+    }
+	/**
+	 * 获取Map集合
+	 * @param eItem 不包含项
+	 * @return
+	 */
+	public static Map<String,String> getEnumMap(int... eItem) {
+		Map<String,String> resultMap= new LinkedHashMap<String,String>();
+		for (SourceType item : SourceType.values()) {
+			try{
+				boolean hasE = false;
+				for (int e : eItem){
+					if(item.getValue()==e){
+						hasE = true;
+						break;
+					}
+				}
+				if(!hasE){
+					resultMap.put(item.getValue()+"", item.getDesc());
+				}
+			}catch(Exception ex){
+			}
+		}
+		return resultMap;
+	}
+}

common-lib/src/main/java/com/mortals/xhx/common/code/StartVariableEnum.java

+package com.mortals.xhx.common.code;
+
+import java.io.Serializable;
+
+/**
+ * 启动参数
+ *
+ * @author: zxfei
+ * @date: 2021/8/26 9:59
+ */
+public enum StartVariableEnum implements Serializable {
+
+    USER("user", "人员信息"),
+    UDEPT("udept", "人员部门变量"),
+    UCOMPANY("ucompany", "人员公司变量"),
+    COMPANY_ROLE("company", "公司角色层级审批领导"),
+    MATRIX_COMPANY_ROLE("mcompany", "矩阵公司角色"),
+    MATRIX_DEPT_ROLE("mdept", "矩阵部门角色"),
+    FORM("form", "表单"),
+    LCDB("lcdb", "流程底表"),
+    LINE("line", "汇报线");
+    private String code;
+    private String msg;
+
+    StartVariableEnum(String code, String msg) {
+        this.msg = msg;
+        this.code = code;
+    }
+
+
+    /**
+     * 通过code获取Msg
+     *
+     * @param code
+     * @return
+     * @Description:
+     */
+    public static String getEnumMsgByCode(String code) {
+        for (StartVariableEnum e : StartVariableEnum.values()) {
+            if (e.getCode().equals(code)) {
+                return e.msg;
+            }
+        }
+        return "";
+    }
+
+    public String getMsg() {
+        return msg;
+    }
+
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    public void setCode(String code) {
+        this.code = code;
+    }
+}

common-lib/src/main/java/com/mortals/xhx/common/code/TaskExcuteStatusEnum.java

+package com.mortals.xhx.common.code;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+ * @author 
+ * @create 2018/01/12
+ */
+public enum TaskExcuteStatusEnum {
+
+    WAIT_RUN(0, "待执行"),
+    RUNNING(1, "执行中"),
+    SUCCESS_RUN(2, "执行成功"),
+    FAIL_RUN(3, "执行失败"),
+    CANCEL(4, "取消");
+
+    private int value;
+    private String desc;
+
+    TaskExcuteStatusEnum(int value, String desc) {
+        this.value = value;
+        this.desc = desc;
+    }
+
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return this.desc;
+    }
+
+    public static TaskExcuteStatusEnum getByValue(int value) {
+        for (TaskExcuteStatusEnum taskExcuteStatusEnum : TaskExcuteStatusEnum.values()) {
+            if (taskExcuteStatusEnum.getValue() == value) {
+                return taskExcuteStatusEnum;
+            }
+        }
+        return null;
+    }
+    /**
+     * 获取Map集合
+     * @param eItem 不包含项
+     * @return
+     */
+    public static Map<String,String> getEnumMap(int... eItem) {
+        Map<String,String> resultMap= new LinkedHashMap<String,String>();
+        for (TaskExcuteStatusEnum item : TaskExcuteStatusEnum.values()) {
+            try{
+                boolean hasE = false;
+                for (int e : eItem){
+                    if(item.getValue()==e){
+                        hasE = true;
+                        break;
+                    }
+                }
+                if(!hasE){
+                    resultMap.put(item.getValue()+"", item.getDesc());
+                }
+            }catch(Exception ex){
+            }
+        }
+        return resultMap;
+    }
+
+
+}

common-lib/src/main/java/com/mortals/xhx/common/code/TaskExcuteStrategyEnum.java

+package com.mortals.xhx.common.code;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+public enum TaskExcuteStrategyEnum{
+    /** 按日 */
+    DAY(1, "按日"),
+    /** 按周 */
+    WEEK(2, "按周"),
+    /** 按月 */
+    MONTH(3, "按月"),
+    /** 按间隔时间 */
+    INTERVAL(4, "按间隔时间");
+    
+    private int value;
+    private String desc;
+    
+
+    TaskExcuteStrategyEnum(int value, String desc) {
+        this.value = value;
+        this.desc = desc;
+        
+    }
+
+    
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+	public static TaskExcuteStrategyEnum getByValue(int value) {
+        for (TaskExcuteStrategyEnum taskExcuteStrategy : TaskExcuteStrategyEnum.values()) {
+            if (taskExcuteStrategy.getValue() == value) {
+                return taskExcuteStrategy;
+            }
+        }
+        return null;
+    }
+	/**
+	 * 获取Map集合
+	 * @param eItem 不包含项
+	 * @return
+	 */
+	public static Map<String,String> getEnumMap(int... eItem) {
+		Map<String,String> resultMap= new LinkedHashMap<String,String>();
+		for (TaskExcuteStrategyEnum item : TaskExcuteStrategyEnum.values()) {
+			try{
+				boolean hasE = false;
+				for (int e : eItem){
+					if(item.getValue()==e){
+						hasE = true;
+						break;
+					}
+				}
+				if(!hasE){
+					resultMap.put(item.getValue()+"", item.getDesc());
+				}
+			}catch(Exception ex){
+			}
+		}
+		return resultMap;
+	}
+}

common-lib/src/main/java/com/mortals/xhx/common/code/TaskInterimExcuteStatusEnum.java

+package com.mortals.xhx.common.code;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+public enum TaskInterimExcuteStatusEnum{
+    /** 未启用 */
+    UNUSE(0, "未启用"),
+    /** 立即执行并保留 */
+    IMMEDIATE_EXECUTION(1, "立即执行并保留"),
+    /** 立即执行并删除 */
+    IMMEDIATE_EXECUTION_BEFORE_DELETE(2, "立即执行并删除");
+    
+    private int value;
+    private String desc;
+    
+
+    TaskInterimExcuteStatusEnum(int value, String desc) {
+        this.value = value;
+        this.desc = desc;
+        
+    }
+
+    
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+	public static TaskInterimExcuteStatusEnum getByValue(int value) {
+        for (TaskInterimExcuteStatusEnum taskInterimExcuteStatus : TaskInterimExcuteStatusEnum.values()) {
+            if (taskInterimExcuteStatus.getValue() == value) {
+                return taskInterimExcuteStatus;
+            }
+        }
+        return null;
+    }
+	/**
+	 * 获取Map集合
+	 * @param eItem 不包含项
+	 * @return
+	 */
+	public static Map<String,String> getEnumMap(int... eItem) {
+		Map<String,String> resultMap= new LinkedHashMap<String,String>();
+		for (TaskInterimExcuteStatusEnum item : TaskInterimExcuteStatusEnum.values()) {
+			try{
+				boolean hasE = false;
+				for (int e : eItem){
+					if(item.getValue()==e){
+						hasE = true;
+						break;
+					}
+				}
+				if(!hasE){
+					resultMap.put(item.getValue()+"", item.getDesc());
+				}
+			}catch(Exception ex){
+			}
+		}
+		return resultMap;
+	}
+}

common-lib/src/main/java/com/mortals/xhx/common/code/UploadFileType.java

+package com.mortals.xhx.common.code;
+
+import com.mortals.framework.common.IBaseEnum;
+
+/**
+ * 上传文件类型枚举
+ *
+ * @author pengziyuan
+ */
+public enum UploadFileType implements IBaseEnum {
+
+    /** 表格 */
+    EXCEL(1, "表格", 1024 * 1023 * 100),
+    /** 图片 */
+    IMG(2, "图片", 1024 * 1024 * 10),
+    /** 压缩文件 */
+    ZIP(3, "压缩文件", 1024 * 1024 * 100),
+    /** PDF */
+    PDF(4, "PDF", 1024 * 1024 * 100),
+    /** 其他 */
+    OTHER(99, "其他", 1024 * 1024 * 100);
+
+    private int value;
+    private String desc;
+    private int maxSize;
+
+    UploadFileType(int value, String desc, int maxSize) {
+        this.value = value;
+        this.desc = desc;
+        this.maxSize = maxSize;
+    }
+
+    @Override
+    public int getValue() {
+        return this.value;
+    }
+
+    @Override
+    public String getDesc() {
+        return desc;
+    }
+
+    public int getMaxSize() {
+        return maxSize;
+    }
+
+    public static UploadFileType getFileType(String extension) {
+        if ("xls".equalsIgnoreCase(extension) || "xlsx".equalsIgnoreCase(extension)) {
+            return EXCEL;
+        }
+        if ("jpg".equalsIgnoreCase(extension) || "jpeg".equalsIgnoreCase(extension) || "png".equalsIgnoreCase(extension)
+                || "gif".equalsIgnoreCase(extension)) {
+            return IMG;
+        }
+        if ("zip".equalsIgnoreCase(extension)) {
+            return ZIP;
+        }
+        if ("pdf".equalsIgnoreCase(extension)) {
+            return PDF;
+        }
+        return OTHER;
+    }
+
+}
+
+

common-lib/src/main/java/com/mortals/xhx/common/code/ValidCodeType.java

+package com.mortals.xhx.common.code;
+
+import com.mortals.framework.ap.SysConstains;
+import com.mortals.framework.common.IBaseEnum;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+public enum ValidCodeType implements IBaseEnum{
+    IMAGE(0, "图片校验", SysConstains.STYLE_DEFAULT),
+    MOBILE(1, "手机校验", SysConstains.STYLE_DEFAULT),
+    EMAIL(2, "邮箱校验", SysConstains.STYLE_DEFAULT);
+    
+    private int value;
+    private String desc;
+    private String style;
+
+    ValidCodeType(int value, String desc, String style) {
+        this.value = value;
+        this.desc = desc;
+        this.style = style;
+    }
+
+    @Override
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+    public String getStyle()
+	{
+		return style;
+	}
+
+	public static ValidCodeType getByValue(int value) {
+        for (ValidCodeType validCodeType : ValidCodeType.values()) {
+            if (validCodeType.getValue() == value) {
+                return validCodeType;
+            }
+        }
+        return null;
+    }
+	/**
+	 * 获取Map集合
+	 * @param eItem 不包含项
+	 * @return
+	 */
+	public static Map<String,String> getEnumMap(int... eItem) {
+		Map<String,String> resultMap= new LinkedHashMap<String,String>();
+		for (ValidCodeType item : ValidCodeType.values()) {
+			try{
+				boolean hasE = false;
+				for (int e : eItem){
+					if(item.getValue()==e){
+						hasE = true;
+						break;
+					}
+				}
+				if(!hasE){
+					resultMap.put(item.getValue()+"", item.getDesc());
+				}
+			}catch(Exception ex){
+			}
+		}
+		return resultMap;
+	}
+}

common-lib/src/main/java/com/mortals/xhx/common/code/YesNoEnum.java

+package com.mortals.xhx.common.code;
+
+import com.mortals.framework.common.IBaseEnum;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+public enum YesNoEnum implements IBaseEnum{
+	
+	NO(0, "否"),
+    YES(1, "是");
+    
+    private int value;
+    private String desc;
+
+    YesNoEnum(int value, String desc) {
+        this.value = value;
+        this.desc = desc;
+    }
+
+    @Override
+    public int getValue() {
+        return this.value;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+	public static YesNoEnum getByValue(int value) {
+        for (YesNoEnum YesNoEnum : YesNoEnum.values()) {
+            if (YesNoEnum.getValue() == value) {
+                return YesNoEnum;
+            }
+        }
+        return null;
+    }
+
+
+	/**
+	 * 获取Map集合
+	 * @param eItem 不包含项
+	 * @return
+	 */
+	public static Map<String,String> getEnumMap(int... eItem) {
+		Map<String,String> resultMap= new LinkedHashMap<String,String>();
+		for (YesNoEnum item : YesNoEnum.values()) {
+			try{
+				boolean hasE = false;
+				for (int e : eItem){
+					if(item.getValue()==e){
+						hasE = true;
+						break;
+					}
+				}
+				if(!hasE){
+					resultMap.put(item.getValue()+"", item.getDesc());
+				}
+			}catch(Exception ex){
+			}
+		}
+		return resultMap;
+	}
+
+}

common-lib/src/main/java/com/mortals/xhx/common/keys/BusizParams.java

+package com.mortals.xhx.common.keys;
+
+import java.math.BigDecimal;
+
+/**
+ * 业务参数类，这个类全部为field参数，可以直接从外部设置和获取
+ *
+ * @author karlhoo
+ */
+public final class BusizParams {
+    public static int WORK_ID;
+
+    /**
+     * 无限常量：-1
+     */
+    public static int NO_LIMIT = -1;
+
+    /**
+     * 一天的分钟数
+     */
+    public static long DAY_MINUTES = 24 * 60;
+
+    /**
+     * 现金类押金支付金额默认折扣
+     */
+    public static BigDecimal DEFAULT_CASH_DEPOSIT_DISCOUNT = new BigDecimal("1.0");
+    /**
+     * 押金默认计费上限费用
+     */
+    public static Long DEFAULT_BILL_LIMIT_FEE = 20000L;
+    /**
+     * 现金押金默认计费上限费用
+     */
+    public static Long DEFAULT_CASH_BILL_LIMIT_FEE = 8000L;
+    /**
+     * 用户冻结的默认延时
+     */
+    public static Integer DEFAULT_CUSTOMER_FREEZE_DELAY = 121;
+    /**
+     * 用户冻结的默认时长
+     */
+    public static Integer DEFAULT_CUSTOMER_FREEZE_LENGHT = 1440;
+
+
+    /**
+     * 系统参数：按摩椅下发命令间隔时间（单位：秒，默认值：10秒）
+     */
+    public static String SYS_PARAM_CHAIR_ISCMDRSP_INTERVAL = "chair_iscmdrsp_interval";
+    /**
+     * 系统参数：闪充待支付超时时间（单位：秒，默认值：600秒）
+     */
+    public static String SYS_PARAM_WIRE_WAITLOAN_TIMEOUT = "wire_waitloan_timeout";
+
+
+    /**
+     * 系统参数：filetoken过期时间（单位：天，默认值：1天）
+     */
+    public static String SYS_PARAM_PRINT_FILETOKEN_TIMEOUT = "print_filetoken_timeout";
+
+
+    /**
+     * 系统参数：打印机保存文件过期时间（单位：月，默认值：3）
+     */
+    public static String SYS_PARAM_PRINT_FILE_TIMEOUT = "print_orderfile_timeout";
+
+    /**
+     * 系统参数：打印机保存文件存储使用方式（0：本地存储，1：fastdfs存储）
+     */
+    public static String SYS_PARAM_PRINT_FILE_STORE_MODE = "print_file_store_mode";
+
+
+    /**
+     * 系统参数：word文件转换方式
+     */
+    public static String SYS_PARAM_PRINT_WORD_CONVERT_METHOD = "print_word_convert_method";
+
+    /**
+     * 系统参数：文件访问域
+     */
+    public static String SYS_PARAM_FILE_DOMAIN = "file_domain";
+
+
+    /**
+     * 流程参数
+     */
+    public static String SYS_PARAM_FLOW_KEY = "oneThingKey";
+
+}

common-lib/src/main/java/com/mortals/xhx/common/keys/CacheLoggers.java

+package com.mortals.xhx.common.keys;
+
+/**
+ * 关键操作失败时，用来缓存数据的logger名称
+ *
+ * @author karlhoo
+ */
+public interface CacheLoggers {
+
+}

common-lib/src/main/java/com/mortals/xhx/common/keys/RedisCacheKeys.java

+package com.mortals.xhx.common.keys;
+
+
+/**
+ * redis缓存参数key
+ *
+ * @author karlhoo
+ */
+public final class RedisCacheKeys {
+    /**
+     * @return 文件访问的地址
+     */
+    public static String getFileUrlKey() {
+        return "params:file:upload";
+    }
+
+    public static String getCoopsDistributedLockKey() {
+        return "coops:distributed:lock";
+    }
+    
+}

common-lib/src/main/java/com/mortals/xhx/common/keys/ResponseConstants.java

+package com.mortals.xhx.common.keys;
+
+/**
+ * 服务调用响应常量
+ *
+ * @author karlhoo
+ */
+public interface ResponseConstants {
+    /**
+     * 请求结果Code主键
+     */
+    String KEY_RESULT_CODE = "code";
+    /**
+     * 请求结果Message主键
+     */
+    String KEY_RESULT_MSG = "msg";
+    /**
+     * 请求结果Code值-成功
+     */
+    int RESULT_VALUE_SUCCESS = 1;
+    /**
+     * 请求结果Code值-失败
+     */
+    int RESULT_VALUE_FAILURE = -1;
+}
\ No newline at end of file

common-lib/src/main/java/com/mortals/xhx/common/model/DefaultTbQueueMsgHeaders.java

+package com.mortals.xhx.common.model;
+
+import cn.hutool.crypto.SecureUtil;
+import cn.hutool.crypto.asymmetric.SignAlgorithm;
+import com.mortals.framework.util.DateUtils;
+import com.mortals.xhx.common.code.MessageProtocolEnum;
+import com.mortals.xhx.queue.TbQueueMsgHeaders;
+import lombok.Setter;
+
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * 默认消息头
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 11:14
+ */
+public class DefaultTbQueueMsgHeaders implements TbQueueMsgHeaders {
+
+    @Setter
+    protected  Map<String, String> data = new HashMap<>();
+
+    public DefaultTbQueueMsgHeaders() {
+        data.put(MessageHeader.TIMESTAMP, String.valueOf(new Date().getTime()));
+       // data.put(MessageHeader.MESSAGESIGN, new String(SecureUtil.sign(SignAlgorithm.SHA256withRSA).sign(data.get(MessageHeader.TIMESTAMP).getBytes())));
+        // TODO: 2022/4/15
+        data.put(MessageHeader.MESSAGESIGN, "abcd1234");
+        data.put(MessageHeader.MESSAGEPROTOCOL, MessageProtocolEnum.JSON.getValue());
+      //  data.put(MessageHeader.TOPIC, "");
+       // data.put(MessageHeader.QOS, "0");
+
+    }
+
+    @Override
+    public void put(String key, String value) {
+        data.put(key, value);
+    }
+
+    @Override
+    public String get(String key) {
+        return data.get(key);
+    }
+
+    @Override
+    public Map<String, String> getData() {
+        return data;
+    }
+}

common-lib/src/main/java/com/mortals/xhx/common/model/MessageHeader.java

+package com.mortals.xhx.common.model;
+
+
+/**
+ * 消息头
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 11:15
+ */
+public class MessageHeader {
+    /**
+     * 客户id
+     */
+    public static final String CLIENTID = "clientId";
+    /**
+     * 协议
+     */
+    public static final String MESSAGEPROTOCOL = "protocol";
+    /**
+     * 时间戳
+     */
+    public static final String TIMESTAMP = "timestamp";
+    /**
+     * 消息签名
+     */
+    public static final String MESSAGESIGN = "sign";
+    /**
+     * 消息类型
+     */
+    public static final String MESSAGETYPE = "messageType";
+    public static final String DEVICECODE = "deviceCode";
+    /**
+     * topic
+     */
+    public static final String TOPIC = "topic";
+    /**
+     * 消息等级
+     */
+    public static final String QOS = "qos";
+
+    public static final String RETAIN = "retain";
+
+    public static final String WILL = "will";
+
+    public static final String DUP = "dup";
+
+}

common-lib/src/main/java/com/mortals/xhx/common/pdu/RespData.java

+package com.mortals.xhx.common.pdu;
+
+import com.mortals.framework.model.PageInfo;
+import lombok.Data;
+
+/**
+ * @author: zxfei
+ * @date: 2022/7/13 14:17
+ * @description:
+ **/
+@Data
+public class RespData<T> {
+
+    private T data;
+    private T entity;
+    private PageInfo pageInfo;
+
+
+    public static void main(String[] args) {
+
+        String resp="";
+
+        //JSON.parseObject()
+
+    }
+}

common-lib/src/main/java/com/mortals/xhx/feign/IFeign.java

+package com.mortals.xhx.feign;
+
+public interface IFeign {
+}

common-lib/src/main/java/com/mortals/xhx/feign/user/IUserFeign.java

+package com.mortals.xhx.feign.user;
+
+import com.mortals.xhx.common.pdu.RespData;
+import com.mortals.xhx.common.pdu.user.UserPdu;
+import com.alibaba.fastjson.JSON;
+import com.mortals.framework.common.Rest;
+import com.mortals.xhx.feign.IFeign;
+import feign.hystrix.FallbackFactory;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.stereotype.Component;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * 用户信息业务 Feign接口
+ * @author zxfei
+ * @date 2022-07-06
+ */
+@FeignClient(name = "portal-manager", path = "/zwfw", fallbackFactory = UserFeignFallbackFactory.class)
+public interface IUserFeign extends IFeign {
+
+
+    /**
+     * 查看用户信息业务列表
+     *
+     * @param userPdu
+     * @return
+     */
+    @PostMapping(value = "/user/list")
+    Rest<RespData<List<UserPdu>>> list(@RequestBody UserPdu userPdu);
+
+
+    /**
+     * 查看用户信息业务
+     *
+     * @param id
+     * @return
+     */
+    @GetMapping(value = "/user/info")
+    Rest<UserPdu> info(@RequestParam(value = "id") Long id);
+
+    /**
+     * 删除用户信息业务
+     *
+     * @param ids
+     * @return
+     */
+    @GetMapping(value = "/user/delete")
+    Rest<Void> delete(Long[] ids,@RequestHeader("Authorization") String authorization);
+
+
+    /**
+     * 用户信息业务保存更新
+     *
+     * @param userPdu
+     * @return
+     */
+    @PostMapping(value = "/user/save")
+    Rest<RespData<UserPdu>> save(@RequestBody UserPdu userPdu,@RequestHeader("Authorization") String authorization);
+
+
+    @PostMapping(value = "/login/login")
+    String portalLogin(@RequestBody UserPdu userPdu);
+
+    /**
+     * 查询用户列表
+     *
+     * @param userPdu
+     * @return
+     */
+    @PostMapping("/api/user/findAllUser")
+    String findAllUser(@RequestBody UserPdu userPdu);
+
+
+    /**
+     * 获取token
+     *
+     * @param
+     * @return
+     */
+    @PostMapping(value = "/user/token")
+    Rest<String> getToken(@RequestParam(value = "userKey") String userKey);
+
+
+}
+
+
+@Slf4j
+@Component
+class UserFeignFallbackFactory implements FallbackFactory<IUserFeign> {
+    @Override
+    public IUserFeign create(Throwable t) {
+        return new IUserFeign() {
+            @Override
+            public Rest<RespData<List<UserPdu>>>  list(UserPdu userPdu) {
+               return Rest.fail("暂时无法获取用户信息业务列表，请稍后再试!");
+            }
+
+            @Override
+            public Rest<UserPdu>  info(Long id) {
+               return Rest.fail("暂时无法获取用户信息业务详细，请稍后再试!");
+            }
+
+            @Override
+            public Rest<Void> delete(Long[] ids, String authorization) {
+                return Rest.fail("暂时无法删除用户信息业务，请稍后再试!");
+            }
+
+            @Override
+            public Rest<RespData<UserPdu>> save(UserPdu userPdu, String authorization) {
+                return Rest.fail("暂时无法保存用户信息业务，请稍后再试!");
+            }
+
+            @Override
+            public String portalLogin(UserPdu userPdu) {
+                return JSON.toJSONString(Rest.fail("登录失败!"));
+            }
+
+            @Override
+            public String findAllUser(UserPdu userPdu) {
+                return null;
+            }
+
+            @Override
+            public Rest<String> getToken(String userKey) {
+                return Rest.fail("token获取失败");
+            }
+        };
+    }
+}
+
+
+
+
+
+
+
+

common-lib/src/main/java/com/mortals/xhx/queue/ConsumerService.java

+package com.mortals.xhx.queue;
+
+import com.alibaba.fastjson.JSONObject;
+import lombok.Getter;
+import lombok.extern.apachecommons.CommonsLog;
+import org.slf4j.Logger;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+/**
+ * 服务端消费消息服务
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 11:31
+ */
+@CommonsLog
+public class ConsumerService {
+    private long pollDuration;
+    protected volatile ExecutorService consumersExecutor;
+    @Getter
+    private TbQueueConsumer<TbQueueMsg> mainConsumer;
+    private String currentIp;
+
+    protected volatile boolean stopped = false;
+
+    public void init(TbQueueConsumer<TbQueueMsg> mainConsumer) {
+        this.consumersExecutor = Executors.newCachedThreadPool();
+        this.mainConsumer = mainConsumer;
+        launchMainConsumers();
+        this.mainConsumer.subscribe();
+
+    }
+
+    public ConsumerService(long pollDuration, String currentIp) {
+        this.pollDuration = pollDuration;
+        this.currentIp = currentIp;
+    }
+
+    /**
+     * 消费服务主线程
+     */
+    protected void launchMainConsumers() {
+        consumersExecutor.submit(() -> {
+            while (!stopped) {
+                try {
+                    //todo
+                    List<TbQueueMsg> poll = mainConsumer.poll(pollDuration);
+                    List<TbQueueMsg> msgs = poll;
+                    if (msgs.isEmpty()) {
+                        continue;
+                    }
+
+                    for (TbQueueMsg item : msgs) {
+                        //todo
+//                        }
+                    }
+                } catch (Exception e) {
+                    log.error("Exception", e);
+                }
+            }
+            log.info("Queue Consumer stopped.");
+        });
+    }
+
+
+    public void destroy() {
+        if (!stopped) {
+            stopMainConsumers();
+        }
+        stopped = true;
+        if (consumersExecutor != null) {
+            consumersExecutor.shutdownNow();
+        }
+
+    }
+
+    protected void stopMainConsumers() {
+        if (mainConsumer != null) {
+            mainConsumer.unsubscribe();
+        }
+    }
+}

common-lib/src/main/java/com/mortals/xhx/queue/DefaultTbCoreConsumerService.java

+
+package com.mortals.xhx.queue;
+
+import com.mortals.xhx.queue.processing.AbstractConsumerService;
+import com.mortals.xhx.queue.provider.TbCoreQueueFactory;
+import lombok.Getter;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.ApplicationEvent;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.PreDestroy;
+import java.util.List;
+import java.util.concurrent.LinkedBlockingQueue;
+
+@Service
+@Slf4j
+public class DefaultTbCoreConsumerService extends AbstractConsumerService<TbQueueMsg> implements TbCoreConsumerService {
+
+    @Value("${queue.core.poll-interval}")
+    private long pollDuration;//队列拉取时间间隔，单位毫秒
+    @Value("${queue.core.pack-processing-timeout}")
+    private long packProcessingTimeout;
+
+    @Getter
+    private LinkedBlockingQueue<TbQueueMsg> comsureQueue = new LinkedBlockingQueue<>();
+
+    @Getter
+    private TbQueueConsumer<TbQueueMsg> mainConsumer;
+    @Getter
+    private List<TbQueueConsumer<TbQueueMsg>> consumerList;
+
+    /**
+     * 根据配置文件动态加载kafka,rabbmitMq等工厂类
+     * @param tbCoreQueueFactory
+     */
+    public DefaultTbCoreConsumerService(TbCoreQueueFactory tbCoreQueueFactory) {
+        //通过工厂类创建通道
+        this.mainConsumer = tbCoreQueueFactory.createMsgConsumer();
+    }
+
+    @PostConstruct
+    public void init() {
+        log.info("初始化消费服务线程");
+        super.init("core-consumer");
+    }
+
+    @PreDestroy
+    public void destroy() {
+        super.destroy();
+    }
+
+
+    @Override
+    public void onApplicationEvent(ApplicationEvent applicationEvent) {
+    }
+
+    @Override
+    protected void launchMainConsumers() {
+        log.info("启动消费线程！");
+        consumersExecutor.submit(() -> {
+            while (!stopped) {
+                try {
+                    List<TbQueueMsg> msgs = mainConsumer.poll(pollDuration);
+                    if (msgs.isEmpty()) {
+                        continue;
+                    }
+                    for (TbQueueMsg item : msgs) {
+                        comsureQueue.offer(item);
+                    }
+
+                    mainConsumer.commit();
+                } catch (Exception e) {
+                    if (!stopped) {
+                        // log.warn("Failed to obtain messages from queue.", e);
+                        try {
+                            Thread.sleep(pollDuration);
+                        } catch (InterruptedException e2) {
+                            // log.trace("Failed to wait until the server has capacity to handle new requests", e2);
+                        }
+                    }
+                }
+            }
+            log.info(" Core Consumer stopped.");
+        });
+    }
+
+    @Override
+    protected void stopMainConsumers() {
+        if (mainConsumer != null) {
+            mainConsumer.unsubscribe();
+        }
+
+    }
+
+    @Override
+    protected void launchConsumersList() {
+        log.info("启动消费线程组！");
+        consumerList.stream().forEach(consumer -> {
+            log.info("channel number:{}"+consumer.getChannelNumber());
+            consumersExecutor.submit(() -> {
+                while (!stopped) {
+                    try {
+                        List<TbQueueMsg> msgs = consumer.poll(pollDuration);
+                        if (msgs.isEmpty()) {
+                            continue;
+                        }
+                        for (TbQueueMsg item : msgs) {
+                            comsureQueue.offer(item);
+                        }
+
+                        consumer.commit();
+                    } catch (Exception e) {
+                        if (!stopped) {
+                            try {
+                                Thread.sleep(pollDuration);
+                            } catch (InterruptedException e2) {
+                                log.trace("Failed to wait until the server has capacity to handle new requests", e2);
+                            }
+                        }
+                    }
+                }
+            });
+        });
+    }
+
+}

common-lib/src/main/java/com/mortals/xhx/queue/DefaultTbQueueMsg.java

+package com.mortals.xhx.queue;
+
+import cn.hutool.core.util.IdUtil;
+import com.alibaba.fastjson.JSON;
+import com.mortals.framework.util.DateUtils;
+import com.mortals.xhx.common.model.DefaultTbQueueMsgHeaders;
+import com.mortals.xhx.common.model.MessageHeader;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.json.JSONObject;
+
+import java.util.HashMap;
+import java.util.UUID;
+
+/**
+ * 默认消息
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 10:59
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class DefaultTbQueueMsg implements TbQueueMsg {
+    /**
+     * key 唯一标识
+     */
+    private  String key;
+    /**
+     * 数据载体
+     */
+    private  String data;
+
+
+    /**
+     * 消息头信息
+     */
+    private  TbQueueMsgHeaders headers;
+
+    public DefaultTbQueueMsg(TbQueueMsg msg) {
+        this.key = msg.getKey();
+        this.data = msg.getData();
+        TbQueueMsgHeaders headers = new DefaultTbQueueMsgHeaders();
+
+        msg.getHeaders().getData().entrySet().stream().forEach(item->
+            headers.put(item.getKey(),item.getValue()));
+
+        this.headers = headers;
+    }
+
+    public static void main(String[] args) {
+
+        TbQueueMsgHeaders header = new DefaultTbQueueMsgHeaders();
+        header.put(MessageHeader.MESSAGETYPE, "UPGREAD");
+        // header.put(MessageHeader.CLIENTID, "abcd1234");
+      //  header.put(MessageHeader.TIMESTAMP, DateUtils.getCurrStrDateTime());
+        //header.put(MessageHeader.MESSAGESIGN,"ssdafasdfasdfasfd");
+        TbQueueMsg queueMsg = new DefaultTbQueueMsg(IdUtil.fastUUID(), "eyJmbG93bnVtIjoiQzEwMTEifQ==" , header);
+
+        String ret = JSON.toJSONString(queueMsg);
+        System.out.println("pro:"+ret);
+//
+//        DefaultTbQueueMsg qu = JSON.parseObject(ret, DefaultTbQueueMsg.class);
+
+    }
+
+}

common-lib/src/main/java/com/mortals/xhx/queue/MessageQueueFactory.java

+package com.mortals.xhx.queue;
+
+
+import com.mortals.xhx.common.BrokerConfig;
+
+/**
+ * 消息队列工厂类，初始化MQ类型（kafka,rabbitMQ，memory）
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 10:57
+ */
+public interface MessageQueueFactory {
+
+
+    /**
+     * 创建消息生产者
+     * @return
+     */
+    TbQueueProducer<TbQueueMsg> createMsgProducer(BrokerConfig brokerConfig);
+
+    /**
+     * 创建消息消费者
+     * @return
+     */
+    TbQueueConsumer<TbQueueMsg> createMsgConsumer(BrokerConfig brokerConfig);
+}

common-lib/src/main/java/com/mortals/xhx/queue/TbCoreConsumerService.java

+package com.mortals.xhx.queue;
+
+import org.springframework.context.ApplicationListener;
+
+public interface TbCoreConsumerService extends ApplicationListener {
+
+}

common-lib/src/main/java/com/mortals/xhx/queue/TbQueueCallback.java

+package com.mortals.xhx.queue;
+
+/**
+ * 队列回调消息
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 10:57
+ */
+public interface TbQueueCallback {
+
+    void onSuccess(TbQueueMsgMetadata metadata);
+
+    void onFailure(Throwable t);
+}

common-lib/src/main/java/com/mortals/xhx/queue/TbQueueConsumer.java

+package com.mortals.xhx.queue;
+
+import java.util.List;
+import java.util.Set;
+
+/**
+ * 队列消息消费者接口
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 10:57
+ */
+public interface TbQueueConsumer<T extends TbQueueMsg> {
+    /**
+     * 获取当topic
+     * @return
+     */
+    String getTopic();
+
+    /**
+     * 订阅
+     */
+    void subscribe();
+
+    /**
+     * 订阅（分区）
+     * @param partitions
+     */
+    void subscribe(Set<TopicPartitionInfo> partitions);
+
+    /**
+     * 取消订阅
+     */
+    void unsubscribe();
+
+    /**
+     * 取消订阅消息
+     * @param partitions
+     */
+    void unsubscribe(Set<TopicPartitionInfo> partitions);
+
+    /**
+     * 拉取消息间隔
+     * @param durationInMillis
+     * @return
+     */
+    List<T> poll(long durationInMillis);
+
+    /**
+     * 提交
+     */
+    void commit();
+
+    /**
+     * 通道
+     * @return
+     */
+    String getChannelNumber();
+
+}

common-lib/src/main/java/com/mortals/xhx/queue/TbQueueCoreSettings.java

+package com.mortals.xhx.queue;
+
+import lombok.Data;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+@Data
+@Component
+public class TbQueueCoreSettings {
+
+    @Value("${queue.core.topic}")
+    private String topic;
+
+
+    @Value("${queue.core.partitions}")
+    private int partitions;
+}

common-lib/src/main/java/com/mortals/xhx/queue/TbQueueMsg.java

+package com.mortals.xhx.queue;
+
+import java.util.UUID;
+
+/**
+ * 队列消息体
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 10:56
+ */
+public interface TbQueueMsg {
+
+     String getKey();
+
+    TbQueueMsgHeaders getHeaders();
+
+    String getData();
+}

common-lib/src/main/java/com/mortals/xhx/queue/TbQueueMsgDecoder.java

+package com.mortals.xhx.queue;
+
+
+public interface TbQueueMsgDecoder<T extends TbQueueMsg> {
+
+    T decode(TbQueueMsg msg);
+}

common-lib/src/main/java/com/mortals/xhx/queue/TbQueueMsgHeaders.java

+package com.mortals.xhx.queue;
+
+import java.util.Map;
+
+/**
+ * 消息头信息
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 10:56
+ */
+public interface TbQueueMsgHeaders {
+
+   void put(String key, String value);
+
+    String get(String key);
+
+    Map<String, String> getData();
+    
+    void  setData(Map<String, String> data);
+}

common-lib/src/main/java/com/mortals/xhx/queue/TbQueueMsgMetadata.java

+package com.mortals.xhx.queue;
+
+/**
+ * 队列消息元数据
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 10:56
+ */
+public interface TbQueueMsgMetadata {
+    String getMessageId();
+}

common-lib/src/main/java/com/mortals/xhx/queue/TbQueueProducer.java

+package com.mortals.xhx.queue;
+
+/**
+ * 队列消息生产者
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 10:55
+ */
+public interface TbQueueProducer<T extends TbQueueMsg> {
+
+    void init();
+
+    String getDefaultTopic();
+
+    //发送消息
+    void send(TopicPartitionInfo tpi, T msg, TbQueueCallback callback);
+
+    void stop();
+
+    void queueDeclare(TopicPartitionInfo tpi, TbQueueCallback callback);
+
+    void queueDel(String queue, TbQueueCallback callback);
+
+}

common-lib/src/main/java/com/mortals/xhx/queue/TopicPartitionInfo.java

+package com.mortals.xhx.queue;
+
+import lombok.Builder;
+import lombok.Data;
+
+import java.util.Objects;
+import java.util.Optional;
+
+@Data
+public class TopicPartitionInfo {
+    /**
+     * topic名称
+     */
+    private String topic;
+    /**
+     * 分区，kafka存在
+     */
+    private Integer partition;
+    /**
+     * 交换机名称，rabbmitmq存在
+     */
+    private String exchangeName;
+    /**
+     * 带分区的topic
+     */
+    private String fullTopicName;
+
+
+    @Builder
+    public TopicPartitionInfo(String topic, Integer partition, String exchangeName) {
+        this.topic = topic;
+        this.partition = partition;
+        this.exchangeName = exchangeName;
+        String tmp = topic;
+        if (partition != null) {
+            tmp += "." + partition;
+        }
+        this.fullTopicName = tmp;
+    }
+
+    public TopicPartitionInfo newByTopic(String topic) {
+        return new TopicPartitionInfo(topic, this.partition, "");
+    }
+
+    public String getTopic() {
+        return topic;
+    }
+
+
+    public Optional<Integer> getPartition() {
+        return Optional.ofNullable(partition);
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+        TopicPartitionInfo that = (TopicPartitionInfo) o;
+        return topic.equals(that.topic) &&
+                Objects.equals(partition, that.partition) &&
+                fullTopicName.equals(that.fullTopicName);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(fullTopicName);
+    }
+}

common-lib/src/main/java/com/mortals/xhx/queue/kafka/AbstractTbQueueConsumerTemplate.java

+package com.mortals.xhx.queue.kafka;
+
+
+import com.alibaba.fastjson.JSON;
+import com.mortals.xhx.queue.TbQueueConsumer;
+import com.mortals.xhx.queue.TbQueueMsg;
+import com.mortals.xhx.queue.TopicPartitionInfo;
+import lombok.Getter;
+import lombok.extern.slf4j.Slf4j;
+
+import java.io.IOException;
+import java.util.*;
+import java.util.concurrent.ConcurrentLinkedQueue;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.locks.ReentrantLock;
+import java.util.stream.Collectors;
+
+import static java.util.Collections.emptyList;
+
+/**
+ * 抽象队列消费者模板
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 11:12
+ */
+@Slf4j
+public abstract class AbstractTbQueueConsumerTemplate<R, T extends TbQueueMsg> implements TbQueueConsumer<T> {
+
+    private volatile boolean subscribed;
+    protected volatile boolean stopped = false;
+    protected volatile Set<TopicPartitionInfo> partitions;
+    protected final ReentrantLock consumerLock = new ReentrantLock();
+    final Queue<Set<TopicPartitionInfo>> subscribeQueue = new ConcurrentLinkedQueue<>();
+
+    @Getter
+    private final String topic;
+
+    public AbstractTbQueueConsumerTemplate(String topic) {
+        this.topic = topic;
+    }
+
+    @Override
+    public void subscribe() {
+        if (stopped) {
+            log.error("consumer 线程已停止 topic {}", topic);
+            return;
+        }
+        subscribeQueue.add(Collections.singleton(new TopicPartitionInfo(topic, null,"")));
+    }
+
+    @Override
+    public void subscribe(Set<TopicPartitionInfo> partitions) {
+       // log.info("订阅的topics {} ", JSON.toJSONString(partitions));
+        if (stopped) {
+            log.error("订阅服务已停止，topic {}", topic);
+            return;
+        }
+        subscribeQueue.add(partitions);
+    }
+
+    @Override
+    public List<T> poll(long durationInMillis) {
+        List<R> records;
+        long startNanos = System.nanoTime();
+        if (stopped) {
+            return errorAndReturnEmpty();
+        }
+        if (!subscribed && partitions == null && subscribeQueue.isEmpty()) {
+            return sleepAndReturnEmpty(startNanos, durationInMillis);
+        }
+
+        if (consumerLock.isLocked()) {
+            log.error("poll. consumerLock is locked. will wait with no timeout. it looks like a race conditions or deadlock", new RuntimeException("stacktrace"));
+        }
+        consumerLock.lock();
+        try {
+            //更新订阅的主题
+            while (!subscribeQueue.isEmpty()) {
+                subscribed = false;
+                partitions = subscribeQueue.poll();
+            }
+            //新增新的订阅信息
+            if (!subscribed) {
+                List<String> topicNames = partitions.stream().map(TopicPartitionInfo::getFullTopicName).collect(Collectors.toList());
+                //新加订阅项
+                doSubscribe(topicNames);
+                subscribed = true;
+            }
+            records = partitions.isEmpty() ? emptyList() : doPoll(durationInMillis);
+        } finally {
+            consumerLock.unlock();
+        }
+
+        if (records.isEmpty()) {
+            return sleepAndReturnEmpty(startNanos, durationInMillis);
+        }
+
+        return decodeRecords(records);
+    }
+
+    List<T> decodeRecords(List<R> records) {
+        List<T> result =records.stream().map(record->decode(record)).collect(Collectors.toList());
+        return result;
+    }
+
+    List<T> errorAndReturnEmpty() {
+        log.error("poll invoked but consumer stopped for topic:" + topic, new RuntimeException("stacktrace"));
+        return emptyList();
+    }
+
+    List<T> sleepAndReturnEmpty(final long startNanos, final long durationInMillis) {
+        long durationNanos = TimeUnit.MILLISECONDS.toNanos(durationInMillis);
+        long spentNanos = System.nanoTime() - startNanos;
+        if (spentNanos < durationNanos) {
+            try {
+                Thread.sleep(Math.max(TimeUnit.NANOSECONDS.toMillis(durationNanos - spentNanos), 1));
+            } catch (InterruptedException e) {
+                if (!stopped) {
+                    log.error("Failed to wait", e);
+                }
+            }
+        }
+        return emptyList();
+    }
+
+    @Override
+    public void commit() {
+        if (consumerLock.isLocked()) {
+            log.error("commit. consumerLock is locked. will wait with no timeout. it looks like a race conditions or deadlock", new RuntimeException("stacktrace"));
+        }
+        consumerLock.lock();
+        try {
+            doCommit();
+        } finally {
+            consumerLock.unlock();
+        }
+    }
+
+    @Override
+    public void unsubscribe() {
+        log.info("unsubscribe topic and stop consumer {}", getTopic());
+        stopped = true;
+        consumerLock.lock();
+        try {
+            doUnsubscribe();
+        } finally {
+            consumerLock.unlock();
+        }
+    }
+
+    abstract protected List<R> doPoll(long durationInMillis);
+
+    abstract protected T decode(R record);
+
+    abstract protected void doSubscribe(List<String> topicNames);
+
+    abstract protected void doCommit();
+
+    abstract protected void doUnsubscribe();
+
+
+}

common-lib/src/main/java/com/mortals/xhx/queue/kafka/KafkaTbQueueMsg.java

+package com.mortals.xhx.queue.kafka;
+
+import com.mortals.xhx.common.model.DefaultTbQueueMsgHeaders;
+import com.mortals.xhx.queue.TbQueueMsg;
+import com.mortals.xhx.queue.TbQueueMsgHeaders;
+import org.apache.kafka.clients.consumer.ConsumerRecord;
+
+import java.util.UUID;
+
+public class KafkaTbQueueMsg implements TbQueueMsg {
+    private final String key;
+    private final TbQueueMsgHeaders headers;
+    private final byte[] data;
+
+    public KafkaTbQueueMsg(ConsumerRecord<String, byte[]> record) {
+        this.key = record.key();
+        TbQueueMsgHeaders headers = new DefaultTbQueueMsgHeaders();
+        record.headers().forEach(header -> {
+            headers.put(header.key(), new String(header.value()));
+        });
+        this.headers = headers;
+        this.data = record.value();
+    }
+
+    @Override
+    public String getKey() {
+        return key;
+    }
+
+    @Override
+    public TbQueueMsgHeaders getHeaders() {
+        return headers;
+    }
+
+    @Override
+    public String getData() {
+        return data.toString();
+    }
+}

common-lib/src/main/java/com/mortals/xhx/queue/kafka/KafkaTbQueueMsgMetadata.java

+package com.mortals.xhx.queue.kafka;
+
+import com.mortals.xhx.queue.TbQueueMsgMetadata;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import org.apache.kafka.clients.producer.RecordMetadata;
+
+/**
+ * 队列元数据
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 14:40
+ */
+@Data
+@AllArgsConstructor
+public class KafkaTbQueueMsgMetadata implements TbQueueMsgMetadata {
+    private RecordMetadata metadata;
+
+    private String messageId;
+}

common-lib/src/main/java/com/mortals/xhx/queue/kafka/TbKafkaConsumerTemplate.java

+package com.mortals.xhx.queue.kafka;
+
+import com.mortals.xhx.queue.TbQueueMsg;
+import com.mortals.xhx.queue.TopicPartitionInfo;
+import lombok.Builder;
+import lombok.extern.apachecommons.CommonsLog;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.kafka.clients.consumer.ConsumerConfig;
+import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.apache.kafka.clients.consumer.ConsumerRecords;
+import org.apache.kafka.clients.consumer.KafkaConsumer;
+import org.slf4j.Logger;
+
+import java.io.IOException;
+import java.time.Duration;
+import java.util.*;
+
+/**
+ * kafka consumer 消费者模板
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 11:21
+ */
+@Slf4j
+public class TbKafkaConsumerTemplate<T extends TbQueueMsg> extends AbstractTbQueueConsumerTemplate<ConsumerRecord<String, byte[]>, T> {
+    private final KafkaConsumer<String, byte[]> consumer;
+
+    private final String groupId;
+
+    private final TbKafkaDecoder<T> decoder;
+
+    @Builder
+    private TbKafkaConsumerTemplate(TbKafkaSettings settings, String clientId, TbKafkaDecoder<T> decoder, String groupId, String topic) {
+        //默认topic
+        super(topic);
+        Properties props = settings.toConsumerProps();
+        //多个输入源的时候 需要配置
+        //props.put(ConsumerConfig.CLIENT_ID_CONFIG, clientId);
+        if (groupId != null) {
+            props.put(ConsumerConfig.GROUP_ID_CONFIG, groupId);
+        }
+
+        this.groupId = groupId;
+        this.consumer = new KafkaConsumer<>(props);
+        this.decoder = decoder;
+    }
+
+    @Override
+    protected void doSubscribe(List<String> topicNames) {
+        if (!topicNames.isEmpty()) {
+            //  topicNames.forEach(admin::createTopicIfNotExists);
+            log.info("subscribe topics {}", topicNames);
+            consumer.subscribe(topicNames);
+        } else {
+            log.info("unsubscribe due to empty topic list");
+            consumer.unsubscribe();
+        }
+    }
+
+    @Override
+    protected List<ConsumerRecord<String, byte[]>> doPoll(long durationInMillis) {
+        ConsumerRecords<String, byte[]> records = consumer.poll(Duration.ofMillis(durationInMillis));
+
+        records.forEach(record -> {
+            System.out.printf("topic = %s ,partition = %d,offset = %d, key = %s, value = %s%n", record.topic(), record.partition(),
+                    record.offset(), record.key(), record.value());
+        });
+        if (records.isEmpty()) {
+            return Collections.emptyList();
+        } else {
+            List<ConsumerRecord<String, byte[]>> recordList = new ArrayList<>(256);
+            records.forEach(recordList::add);
+            return recordList;
+        }
+    }
+
+    @Override
+    public T decode(ConsumerRecord<String, byte[]> record)  {
+        return decoder.decode(new KafkaTbQueueMsg(record));
+    }
+
+    @Override
+    protected void doCommit() {
+        //同步提交，线程会阻塞，直到当前批次offset提交成功
+        consumer.commitAsync();
+    }
+
+    @Override
+    protected void doUnsubscribe() {
+        log.info("unsubscribe topic and close consumer for topic {}", getTopic());
+        if (consumer != null) {
+            //consumer.unsubscribe();
+            consumer.close();
+        }
+    }
+
+    public static void main(String[] args) {
+        // TbKafkaConsumerTemplate.builder().
+    }
+
+    @Override
+    public void unsubscribe(Set<TopicPartitionInfo> partitions) {
+
+    }
+
+    @Override
+    public String getChannelNumber() {
+        return "1231";
+    }
+}

common-lib/src/main/java/com/mortals/xhx/queue/kafka/TbKafkaDecoder.java

+package com.mortals.xhx.queue.kafka;
+
+
+import com.mortals.xhx.queue.TbQueueMsg;
+
+import java.io.IOException;
+
+/**
+ * 队列消息编码
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 11:22
+ */
+public interface TbKafkaDecoder<T extends TbQueueMsg> {
+
+    T decode(TbQueueMsg msg);
+
+}

common-lib/src/main/java/com/mortals/xhx/queue/kafka/TbKafkaProducerTemplate.java

+package com.mortals.xhx.queue.kafka;
+
+import com.mortals.xhx.queue.TbQueueCallback;
+import com.mortals.xhx.queue.TbQueueMsg;
+import com.mortals.xhx.queue.TbQueueProducer;
+import com.mortals.xhx.queue.TopicPartitionInfo;
+import lombok.Builder;
+import lombok.Data;
+import lombok.Getter;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.kafka.clients.producer.KafkaProducer;
+import org.apache.kafka.clients.producer.ProducerRecord;
+import org.apache.kafka.common.header.Header;
+import org.apache.kafka.common.header.internals.RecordHeader;
+
+import java.util.Properties;
+import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.stream.Collectors;
+
+/**
+ * kafka 生产者模板
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 11:23
+ */
+@Data
+@Slf4j
+public class TbKafkaProducerTemplate<T extends TbQueueMsg> implements TbQueueProducer<T> {
+
+    /**
+     * 生产者
+     */
+    private KafkaProducer<String, byte[]> producer;
+    /**
+     * kafka 配置信息
+     */
+    private TbKafkaSettings settings;
+
+    private String defaultTopic;
+    /**
+     * topic组
+     */
+    private Set<TopicPartitionInfo> topics;
+
+    @Builder
+    private TbKafkaProducerTemplate(TbKafkaSettings settings, String defaultTopic) {
+        this.settings = settings;
+        //初始化生产者参数
+        this.producer = new KafkaProducer<>(settings.toProducerProps());
+        this.defaultTopic = defaultTopic;
+        topics = ConcurrentHashMap.newKeySet();
+    }
+
+    @Override
+    public void init() {
+    }
+
+    @Override
+    public void send(TopicPartitionInfo tpi, T msg, TbQueueCallback callback) {
+        String key = msg.getKey().toString();
+        byte[] data = msg.getData().getBytes();
+        ProducerRecord<String, byte[]> record;
+        if (tpi.getTopic() == null) {
+            tpi.setTopic(this.defaultTopic);
+        }
+        Iterable<Header> headers = msg.getHeaders().getData().entrySet().stream().map(e -> new RecordHeader(e.getKey(), e.getValue().getBytes())).collect(Collectors.toList());
+        record = new ProducerRecord<>(tpi.getTopic(), null, key, data, headers);
+        producer.send(record, (metadata, exception) -> {
+            if (exception == null) {
+                if (callback != null) {
+                    callback.onSuccess(new KafkaTbQueueMsgMetadata(metadata,key));
+                }
+            } else {
+                if (callback != null) {
+                    callback.onFailure(exception);
+                } else {
+                    log.warn("Producer template failure: {}", exception.getMessage(), exception);
+                }
+            }
+        });
+
+    }
+
+
+    @Override
+    public void stop() {
+        if (producer != null) {
+            producer.close();
+        }
+    }
+
+    @Override
+    public void queueDeclare(TopicPartitionInfo tpi, TbQueueCallback callback) {
+        // TODO: 2022/4/29 创建kafka队列
+    }
+
+    @Override
+    public void queueDel(String queue, TbQueueCallback callback) {
+        // TODO: 2022/5/20 删除队列
+    }
+
+
+}

common-lib/src/main/java/com/mortals/xhx/queue/kafka/TbKafkaProperty.java

+package com.mortals.xhx.queue.kafka;
+
+import lombok.Data;
+
+/**
+ * 其它配置类
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 13:31
+ */
+@Data
+public class TbKafkaProperty {
+
+    private String key;
+    private String value;
+}

common-lib/src/main/java/com/mortals/xhx/queue/kafka/TbKafkaSettings.java

+package com.mortals.xhx.queue.kafka;
+
+import lombok.Getter;
+import lombok.Setter;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.kafka.clients.CommonClientConfigs;
+import org.apache.kafka.clients.admin.AdminClientConfig;
+import org.apache.kafka.clients.consumer.ConsumerConfig;
+import org.apache.kafka.clients.producer.ProducerConfig;
+import org.apache.kafka.common.serialization.ByteArrayDeserializer;
+import org.apache.kafka.common.serialization.ByteArraySerializer;
+import org.apache.kafka.common.serialization.StringDeserializer;
+import org.apache.kafka.common.serialization.StringSerializer;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.Properties;
+
+/**
+ * kafka 配置类
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 13:30
+ */
+@Slf4j
+@ConditionalOnProperty(prefix = "queue", value = "type", havingValue = "kafka")
+@ConfigurationProperties(prefix = "queue.kafka")
+@Component
+public class TbKafkaSettings {
+
+    @Value("${queue.kafka.bootstrap.servers}")
+    private String servers;
+
+    @Value("${queue.kafka.acks}")
+    private String acks;
+
+    @Value("${queue.kafka.retries}")
+    private int retries;
+
+    @Value("${queue.kafka.batch.size}")
+    private int batchSize;
+
+    @Value("${queue.kafka.linger.ms}")
+    private long lingerMs;
+
+    @Value("${queue.kafka.buffer.memory}")
+    private long bufferMemory;
+
+    @Value("${queue.kafka.replication_factor}")
+    @Getter
+    private short replicationFactor;
+
+    @Value("${queue.kafka.max_poll_records:8192}")
+    private int maxPollRecords;
+
+    @Value("${queue.kafka.max_poll_interval_ms:300000}")
+    private int maxPollIntervalMs;
+
+    @Value("${queue.kafka.max_partition_fetch_bytes:16777216}")
+    private int maxPartitionFetchBytes;
+
+    @Value("${queue.kafka.fetch_max_bytes:134217728}")
+    private int fetchMaxBytes;
+
+    @Setter
+    private List<TbKafkaProperty> other;
+
+    /**
+     * 管理端参数配置
+     * @return
+     */
+    public Properties toAdminProps() {
+        Properties props = toProps();
+        props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, servers);
+        props.put(AdminClientConfig.RETRIES_CONFIG, retries);
+
+        return props;
+    }
+
+    /**
+     * 消费者参数
+     *
+     * @return
+     */
+    public Properties toConsumerProps() {
+        Properties props = toProps();
+        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, servers);
+        props.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, maxPollRecords);
+        props.put(ConsumerConfig.MAX_PARTITION_FETCH_BYTES_CONFIG, maxPartitionFetchBytes);
+        props.put(ConsumerConfig.FETCH_MAX_BYTES_CONFIG, fetchMaxBytes);
+        props.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, maxPollIntervalMs);
+
+        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
+        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, ByteArrayDeserializer.class);
+        return props;
+    }
+
+    /**
+     * 生产者参数
+     *
+     * @return
+     */
+    public Properties toProducerProps() {
+        Properties props = toProps();
+        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, servers);
+        props.put(ProducerConfig.RETRIES_CONFIG, retries);
+        props.put(ProducerConfig.ACKS_CONFIG, acks);
+        props.put(ProducerConfig.BATCH_SIZE_CONFIG, batchSize);
+        props.put(ProducerConfig.LINGER_MS_CONFIG, lingerMs);
+        props.put(ProducerConfig.BUFFER_MEMORY_CONFIG, bufferMemory);
+        props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
+        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, ByteArraySerializer.class);
+        return props;
+    }
+
+    private Properties toProps() {
+        Properties props = new Properties();
+        //添加其它参数
+        if (other != null) {
+            other.forEach(kv -> props.put(kv.getKey(), kv.getValue()));
+        }
+        return props;
+    }
+
+}

common-lib/src/main/java/com/mortals/xhx/queue/processing/AbstractConsumerService.java

+package com.mortals.xhx.queue.processing;
+
+import com.mortals.xhx.queue.TbQueueMsg;
+import com.mortals.xhx.utils.IotThreadFactory;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.context.event.ApplicationReadyEvent;
+import org.springframework.context.event.EventListener;
+import org.springframework.core.annotation.Order;
+
+import javax.annotation.PreDestroy;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+/**
+ * 消费服务抽象类
+ *
+ * @author: zxfei
+ * @date: 2022/4/28 9:43
+ */
+@Slf4j
+public abstract class AbstractConsumerService<N extends TbQueueMsg> {
+
+    /**
+     * 启动消费主线程服务
+     */
+    protected abstract void launchMainConsumers();
+    /**
+     * 停止消费主线程服务
+     */
+    protected abstract void stopMainConsumers();
+    /**
+     * 启动一组消费线程
+     */
+    protected abstract void launchConsumersList();
+
+    /**
+     * 消息线程池
+     */
+    protected volatile ExecutorService consumersExecutor;
+    /**
+     * 变量
+     */
+    protected volatile boolean stopped = false;
+
+    public void init(String mainConsumerThreadName) {
+        this.consumersExecutor = Executors.newCachedThreadPool(IotThreadFactory.forName(mainConsumerThreadName));
+        launchMainConsumers();
+    }
+
+
+
+    @PreDestroy
+    public void destroy() {
+        stopped = true;
+        stopMainConsumers();
+        if (consumersExecutor != null) {
+            consumersExecutor.shutdownNow();
+        }
+
+    }
+}

common-lib/src/main/java/com/mortals/xhx/queue/rabbitmq/RabbitQueueMsgMetadata.java

+package com.mortals.xhx.queue.rabbitmq;
+
+import com.mortals.xhx.queue.TbQueueMsgMetadata;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import org.apache.kafka.clients.producer.RecordMetadata;
+
+/**
+ * 队列元数据
+ *
+ * @author: zxfei
+ * @date: 2021/11/22 14:40
+ */
+@Data
+@AllArgsConstructor
+public class RabbitQueueMsgMetadata implements TbQueueMsgMetadata {
+    private String messageId;
+}