feat(ys):验收服务初始化

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-api/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">
+    <parent>
+        <artifactId>amos-boot-module-ys</artifactId>
+        <groupId>com.amosframework.boot</groupId>
+        <version>1.0.1</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <artifactId>amos-boot-module-ys-api</artifactId>
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.data</groupId>
+            <artifactId>spring-data-elasticsearch</artifactId>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.amosframework.boot</groupId>
+            <artifactId>amos-boot-module-ymt-api</artifactId>
+            <version>${amos-boot-biz.version}</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.amosframework.boot</groupId>
+            <artifactId>amos-boot-module-common-api</artifactId>
+            <version>${amos-boot-biz.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>net.javacrumbs.shedlock</groupId>
+            <artifactId>shedlock-spring</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>net.javacrumbs.shedlock</groupId>
+            <artifactId>shedlock-provider-redis-spring</artifactId>
+        </dependency>
+        <dependency>
+            <artifactId>amos-component-rule</artifactId>
+            <groupId>com.yeejoin</groupId>
+        </dependency>
+    </dependencies>
+
+</project>
\ No newline at end of file

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-api/src/main/java/com/yeejoin/amos/boot/module/ys/api/common/BaseEntity.java

+package com.yeejoin.amos.boot.module.ys.api.common;
+
+import com.baomidou.mybatisplus.annotation.FieldFill;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @description: 公共实体
+ * @author: duanwei
+ **/
+@Data
+public class BaseEntity implements Serializable {
+    private static final long serialVersionUID = -5464322936854328207L;
+    @TableId(type = IdType.ID_WORKER)
+    private Long id;
+    /**
+     * 创建时间
+     */
+    @TableField(value = "create_date", fill = FieldFill.INSERT)
+    private Date createDate;
+    
+    /**
+     * 更新时间
+     */
+    @TableField(value = "update_time", fill = FieldFill.UPDATE)
+    private Date updateTime;
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-api/src/main/java/com/yeejoin/amos/boot/module/ys/api/common/BaseException.java

+package com.yeejoin.amos.boot.module.ys.api.common;
+
+import com.yeejoin.amos.boot.module.ys.api.enums.BaseExceptionEnum;
+
+/**
+ * @Author cpp
+ * @Description基础异常类
+ * @Date 2023/4/23
+ */
+
+public class BaseException extends RuntimeException {
+    private static final long serialVersionUID = 194906846739586857L;
+    /**
+     * 错误码
+     */
+    private int code;
+    /**
+     * 错误内容
+     */
+    private String msg;
+
+    public BaseException(String msg) {
+        super(msg);
+    }
+
+    public BaseException(int code, String msg) {
+        super(msg);
+        this.code = code;
+        this.msg = msg;
+    }
+
+    public BaseException(BaseExceptionEnum baseExceptionEnum) {
+        super(baseExceptionEnum.getMsg());
+        this.msg = baseExceptionEnum.getMsg();
+        this.code = baseExceptionEnum.getCode();
+    }
+
+    public int getCode() {
+        return code;
+    }
+
+    public void setCode(int code) {
+        this.code = code;
+    }
+
+    public String getMsg() {
+        return msg;
+    }
+
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+}
+

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-api/src/main/java/com/yeejoin/amos/boot/module/ys/api/common/BizCommonConstant.java

+package com.yeejoin.amos.boot.module.ys.api.common;
+
+/**
+ * @Description: 通用常量类
+ * @Author: DELL
+ * @Date: 2021/5/26
+ */
+public interface BizCommonConstant {
+
+	/**
+	 * 所有平台企业数据redisKey
+	 */
+	String COMPANY_TREE_REDIS_KEY = "REGULATOR_UNIT_TREE";
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-api/src/main/java/com/yeejoin/amos/boot/module/ys/api/common/BizCustomDateSerializer.java

+package com.yeejoin.amos.boot.module.ys.api.common;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.JsonSerializer;
+import com.fasterxml.jackson.databind.SerializerProvider;
+import org.apache.commons.lang3.StringUtils;
+import org.typroject.tyboot.core.foundation.utils.DateTimeUtil;
+
+import java.io.IOException;
+import java.lang.reflect.Field;
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+/**
+ * @author yangyang
+ * @version v1.0
+ * @JsonComponent 会覆盖JsonFormat, 这里解析字段提升JsonFormat优先级
+ * <p>
+ * ProjectName: amos-boot-biz
+ * PackageName: com.yeejoin.amos.boot.module.ys.biz.config
+ * @date 2023/12/18 17:35
+ */
+public class BizCustomDateSerializer extends JsonSerializer<Date> {
+
+    private List<String> customFields = Arrays.asList("createDate", "acceptDate", "expiryDate", "applicationDate", "noticeDate", "installStartDate", "handleDate", "auditPassDate", "applyDate");
+
+    public BizCustomDateSerializer() {
+    }
+
+    @Override
+    public void serialize(Date value, JsonGenerator jgen, SerializerProvider provider) throws IOException, JsonProcessingException {
+        try {
+            Class<?> clazz = jgen.getCurrentValue().getClass();
+            if (Objects.equals(clazz, HashMap.class)) {
+                // 分页参数
+                if (customFields.contains(jgen.getOutputContext().getCurrentName())) {
+                    SimpleDateFormat formatter = new SimpleDateFormat(DateTimeUtil.ISO_DATE);
+                    jgen.writeString(formatter.format(value));
+                    return;
+                }
+            } else {
+                Field field = clazz.getDeclaredField(jgen.getOutputContext().getCurrentName());
+                if (Objects.equals(field.getType(), Date.class)) {
+                    if (field.isAnnotationPresent(JsonFormat.class)) {
+                        String pattern = field.getAnnotation(JsonFormat.class).pattern();
+                        if (StringUtils.isNotBlank(pattern)) {
+                            SimpleDateFormat formatter = new SimpleDateFormat(pattern);
+                            jgen.writeString(formatter.format(value));
+                            return;
+                        }
+                    }
+                }
+            }
+            jgen.writeString(defaultFormattedDate(value));
+        } catch (Exception e) {
+            jgen.writeString(defaultFormattedDate(value));
+        }
+    }
+
+    private String defaultFormattedDate(Date value) {
+        SimpleDateFormat formatter = new SimpleDateFormat(DateTimeUtil.ISO_DATE_HOUR24_MIN_SEC);
+        String formattedDate = formatter.format(value);
+        return formattedDate;
+    }
+
+}
\ No newline at end of file

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-api/src/main/java/com/yeejoin/amos/boot/module/ys/api/common/CommonException.java

+package com.yeejoin.amos.boot.module.ys.api.common;
+
+
+import com.yeejoin.amos.boot.module.ys.api.enums.CommonErrorEnum;
+
+/**
+ * @description: 共同异常类
+ * @author: duanwei
+ * @create: 2019-08-28 20:07
+ **/
+public class CommonException extends BaseException {
+    private static final long serialVersionUID = 194906846739586857L;
+    /**
+     * 错误码
+     */
+    private int code;
+    /**
+     * 错误内容
+     */
+    private String msg;
+
+    public CommonException(int code, String msg) {
+        super(msg);
+        this.code = code;
+        this.msg = msg;
+    }
+
+    public CommonException(CommonErrorEnum menuExceptionEnum) {
+        super(menuExceptionEnum.getMsg());
+        this.msg = menuExceptionEnum.getMsg();
+        this.code = menuExceptionEnum.getCode();
+    }
+
+    @Override
+    public int getCode() {
+        return code;
+    }
+
+    @Override
+    public void setCode(int code) {
+        this.code = code;
+    }
+
+    @Override
+    public String getMsg() {
+        return msg;
+    }
+
+    @Override
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+}
+

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-api/src/main/java/com/yeejoin/amos/boot/module/ys/api/common/ExtendedIOUtils.java

+package com.yeejoin.amos.boot.module.ys.api.common;
+
+import org.springframework.util.Assert;
+
+import java.io.Closeable;
+import java.io.Flushable;
+import java.io.IOException;
+
+/**
+ * IO流拓展工具类，补充IOUtils新版本中废弃的closeQuietly
+ *
+ * @author King
+ * @since 2018/12/27 17:56
+ */
+public class ExtendedIOUtils {
+    public static void flush(Flushable... resources) throws IOException {
+        Assert.noNullElements(resources, "resources invalid");
+        int length = resources.length;
+        for (int i = 0; i < length; ++i) {
+            Flushable resource = resources[i];
+            if (resource != null) {
+                resource.flush();
+            }
+        }
+    }
+
+    public static void closeQuietly(Closeable... resources) {
+        int length = resources.length;
+        for (int i = 0; i < length; ++i) {
+            Closeable resource = resources[i];
+            if (resource != null) {
+                try {
+                    resource.close();
+                } catch (IOException e) {
+                    //ignore exception
+                }
+            }
+        }
+    }
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-api/src/main/java/com/yeejoin/amos/boot/module/ys/api/common/GlobalCache.java

+package com.yeejoin.amos.boot.module.ys.api.common;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @Description: 全局单机缓存
+ * @Author: duanwei
+ * @Date: 2020/6/30
+ */
+public class GlobalCache {
+    /**
+     * 全局请求头
+     */
+    public static Map<String, String> header = new HashMap<>();
+    /**
+     * 依赖参数容器
+     */
+    public static Map<String, String> paramMap = new HashMap<>(1000);
+
+
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-api/src/main/java/com/yeejoin/amos/boot/module/ys/api/common/MobileLoginParam.java

+package com.yeejoin.amos.boot.module.ys.api.common;
+
+import lombok.Data;
+
+/**
+ * @Author cpp
+ * @Description
+ * @Date 2023/4/23
+ */
+@Data
+public class MobileLoginParam {
+
+    /**
+     * 注册类型：1-微信授权快捷登录；2-手机验证登录
+     */
+    private int registerType;
+
+    /**
+     * 是否需要需要短信验证： true-验证； false-不验证
+     */
+    private Boolean isNeedVerify;
+
+    /**
+     * 注册类型为1时使用：微信用户数据字段1,根据1、2进行数据解密，计算出手机号
+     */
+    private String encryptedData;
+
+    /**
+     * 注册类型为1时使用：微信用户数据字段2,根据1、2进行数据解密，计算出手机号
+     */
+    private String iv;
+
+    /**
+     *注册类型为1时使用：微信用户数据字段3,根据1、2、3进行数据解密，计算出手机号
+     */
+    private String code;
+
+    /**
+     * 账号或手机号
+     */
+    private String phoneNo;
+
+    /**
+     *  密码
+     */
+    private String verifyCode;
+}
\ No newline at end of file

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-api/src/main/java/com/yeejoin/amos/boot/module/ys/api/common/StringUtil.java

+package com.yeejoin.amos.boot.module.ys.api.common;
+
+import java.math.BigDecimal;
+import java.util.Collection;
+import java.util.Map;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+/**
+ * 字符串工具类
+ *
+ * @author as-youjun
+ */
+public class StringUtil {
+    private static Pattern NOT_ZERO_AT_THE_END = Pattern.compile("[1-9](\\d*[1-9])?");
+    private static Pattern numericPattern = Pattern.compile("-?[0-9]+\\.?[0-9]*");
+    private static Pattern NUMBER_PATTERN = Pattern.compile("-?[0-9]+(\\.[0-9]+)?");
+
+    /**
+     * 判断对象是否为空
+     *
+     * @param str
+     * @return
+     */
+    public static boolean isNotEmpty(Object str) {
+        boolean flag = true;
+        if (str != null && !"".equals(str)) {
+            if (str.toString().length() > 0) {
+                flag = true;
+            }
+        } else {
+            flag = false;
+        }
+        return flag;
+    }
+
+    /***************************************************************************
+     * repeat - 通过源字符串重复生成N次组成新的字符串。
+     *
+     * @param src
+     *            - 源字符串 例如: 空格(" "), 星号("*"), "浙江" 等等...
+     * @param num
+     *            - 重复生成次数
+     * @return 返回已生成的重复字符串
+     * @version 1.0 (2006.10.10) Wilson Lin
+     **************************************************************************/
+    public static String repeat(String src, int num) {
+        StringBuffer s = new StringBuffer();
+        for (int i = 0; i < num; i++) {
+            s.append(src);
+        }
+        return s.toString();
+    }
+
+    /**
+     * 判断是否数字表示
+     *
+     * @param str 源字符串
+     * @return 是否数字的标志
+     */
+    public static boolean isNumeric(String str) {
+        // 该正则表达式可以匹配所有的数字 包括负数
+        String bigStr;
+        try {
+            bigStr = new BigDecimal(str).toString();
+        } catch (Exception e) {
+            return false;//异常 说明包含非数字。
+        }
+        Matcher isNum = NUMBER_PATTERN.matcher(bigStr); // matcher是全匹配
+        if (!isNum.matches()) {
+            return false;
+        }
+        return true;
+    }
+
+    public static int toInt(String s) {
+        if (s != null && !"".equals(s.trim())) {
+            try {
+                return Integer.parseInt(s);
+            } catch (Exception e) {
+                return 0;
+            }
+        }
+        return 0;
+    }
+
+
+    public static boolean isEmpty(Collection collection) {
+        return collection == null || collection.isEmpty();
+    }
+
+    public static boolean isNotEmpty(Collection collection) {
+        return collection != null && collection.size() > 0;
+    }
+
+
+    public static boolean isEmpty(Map map) {
+        return map == null || map.isEmpty();
+    }
+
+
+    /**
+     * 截取前后都不是0的数字字符串
+     * <p>
+     * 12010102 => 12010102 12010100 => 120101 ab1201100b => 12011
+     *
+     * @param str
+     * @return
+     */
+    public static String delEndZero(String str) {
+        Matcher mat = NOT_ZERO_AT_THE_END.matcher(str);
+        boolean rs = mat.find();
+        if (rs) {
+            return mat.group(0);
+        }
+        return null;
+    }
+
+    /**
+     * <pre>
+     * 移除字符串后面的0
+     * </pre>
+     *
+     * @param s
+     * @return
+     */
+    public static String removeSufixZero(String s) {
+        if (s == null) {
+            return "";
+        }
+        while (s.endsWith("0")) {
+            if ("0".equals(s)) {
+                s = "";
+                break;
+            }
+            s = s.substring(0, s.length() - 1);
+        }
+        return s;
+    }
+
+    public static String transforCode(String code) {
+        if (code.endsWith("0000000")) {
+            code = code.substring(0, 1);
+        } else if (code.endsWith("000000")) {
+            code = code.substring(0, 2);
+        } else if (code.endsWith("0000")) {
+            code = code.substring(0, 4);
+        } else if (code.endsWith("00")) {
+            code = code.substring(0, 6);
+        }
+        return code;
+    }
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-api/src/main/java/com/yeejoin/amos/boot/module/ys/api/dto/ByteArrayMultipartFile.java

+package com.yeejoin.amos.boot.module.ys.api.dto;
+
+import lombok.Getter;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.*;
+import java.nio.file.Files;
+
+@Getter
+public class ByteArrayMultipartFile implements MultipartFile {
+
+    private byte[] bytes;
+    private String name;
+    private String originalFilename;
+    private String contentType;
+
+
+    public ByteArrayMultipartFile() {
+    }
+
+    public ByteArrayMultipartFile(String name, String originalFilename, String contentType, byte[] bytes) {
+        super();
+        this.name = name;
+        this.originalFilename = originalFilename;
+        this.contentType = contentType;
+        this.bytes = bytes;
+    }
+
+    @Override
+    public boolean isEmpty() {
+        return bytes.length == 0;
+    }
+
+    @Override
+    public long getSize() {
+        return bytes.length;
+    }
+
+    @Override
+    public InputStream getInputStream() {
+        return new ByteArrayInputStream(bytes);
+    }
+
+    @Override
+    public void transferTo(File destination) throws IOException {
+        try (OutputStream outputStream = Files.newOutputStream(destination.toPath())) {
+            outputStream.write(bytes);
+        }
+    }
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-api/src/main/java/com/yeejoin/amos/boot/module/ys/api/enums/BaseExceptionEnum.java

+package com.yeejoin.amos.boot.module.ys.api.enums;
+
+/**
+        * @description: 基础枚举类
+
+        **/
+public enum BaseExceptionEnum {
+    /**
+     * 请求成功
+     */
+    SUCCESS(0, "请求成功"),
+    /**
+     * 系统繁忙
+     */
+    SYSTEM_BUSY(100, "系统繁忙"),
+    /**
+     * 请求超时
+     */
+    REQUEST_TIME_OUT(300, "请求超时"),
+    /**
+     * 参数错误
+     */
+    PARAMETER_ERROR(400, "参数错误"),
+    /**
+     * 网络异常
+     */
+    NETWORK_ERROR(404, "网络异常"),
+    /**
+     * 数据不存在
+     */
+    DATA_NOT_EXISTS(600, "数据不存在"),
+    /**
+     * 无权访问
+     */
+    ACCESSDENIED_ERROR(501, "无权访问"),
+    /**
+     * 请求已经过期
+     */
+    REQUEST_EXPIRATION(406, "请求已经过期"),
+    /**
+     * 请求失败
+     */
+    REQUEST_ERROR(407, "请求失败"),
+    /**
+     * 未知错误
+     */
+    FAILURE(999, "未知错误");
+    private Integer code;
+    private String msg;
+
+    BaseExceptionEnum(Integer code, String msg) {
+        this.code = code;
+        this.msg = msg;
+    }
+
+    public Integer getCode() {
+        return code;
+    }
+
+    public void setCode(Integer code) {
+        this.code = code;
+    }
+
+    public String getMsg() {
+        return msg;
+    }
+
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+}
+

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-api/src/main/java/com/yeejoin/amos/boot/module/ys/api/enums/CommonErrorEnum.java

+package com.yeejoin.amos.boot.module.ys.api.enums;
+
+/**
+ * 通用错误码，code编码：10000000-10000999
+ *
+ * @author King
+ * @since 2018/12/14 10:30
+ */
+public enum CommonErrorEnum {
+    /**
+     * 服务器核心数据丢失
+     */
+    SERVER_KEY_DATA_MISSING(10000000, "服务器核心数据丢失"),
+    /**
+     * 服务器数据查询错误
+     */
+    SERVER_DATA_QUERY_ERROR(10000001, "服务器数据查询错误"),
+    /**
+     * 主键查询主键无效
+     */
+    QUERY_PRIMARY_INVALID(10000002, "主键查询主键无效"),
+    /**
+     * 主键查询主键无效
+     */
+    QUERY_ONE_PARAM_INVALID(10000003, "唯一性查询参数无效"),
+    /**
+     * 序列化异常
+     */
+    SERIALIZATION_EXCEPTION(10000004, "序列化异常"),
+    /**
+     * 反序列化异常
+     */
+    DESERIALIZATION_EXCEPTION(10000005, "反序列化异常"),
+    /**
+     * 入参无效
+     */
+    PARAM_INVALID(10000006, "入参无效"),
+    /**
+     * 核心字段无效
+     */
+    CRUCIAL_FIELD_INVALID(10000007, "核心字段无效"),
+    /**
+     * 解压缩异常
+     */
+    DECOMPRESS_EXCEPTION(10000008, "解压缩异常"),
+    /**
+     * 缓存查询key值无效
+     */
+    CACHE_QUERY_KEY_INVALID(10000009, "缓存查询key值无效"),
+    /**
+     * 缓存失效
+     */
+    CACHE_LOSE_EFFICACY(10000010, "缓存失效"),
+    /**
+     * 未知错误
+     */
+    UNKNOWN(10000999, "未知错误");
+    private Integer code;
+    private String msg;
+
+    CommonErrorEnum(Integer code, String msg) {
+        this.code = code;
+        this.msg = msg;
+    }
+
+    public Integer getCode() {
+        return code;
+    }
+
+    public void setCode(Integer code) {
+        this.code = code;
+    }
+
+    public String getMsg() {
+        return msg;
+    }
+
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-api/src/main/java/com/yeejoin/amos/boot/module/ys/api/enums/CompanyTypeEnum.java

+package com.yeejoin.amos.boot.module.ys.api.enums;
+
+import lombok.Getter;
+import org.apache.commons.compress.utils.Lists;
+import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
+
+import java.util.HashSet;
+import java.util.List;
+import java.util.Set;
+
+/**
+ * 业务类型枚举
+ *
+ * @author Administrator
+ */
+@Getter
+public enum CompanyTypeEnum {
+
+    /**
+     * 单位类型枚举
+     */
+    SUPERVISION("supervision","supervision", "监管机构"),
+
+    USE("company","use", "使用单位"),
+
+    DESIGN("company","design", "设计单位"),
+
+    MANUFACTURE("company","manufacture", "制造单位"),
+
+    FILLING("company","filling", "充装单位"),
+
+    INDIVIDUAL("company","individual", "个人主体"),
+
+    CONSTRUCTION("company","construction", "安装改造维修单位"),
+
+    INSPECTION("company","inspection", "检验检测机构");
+
+    private final String level;
+    private final String code;
+    private final String name;
+
+    CompanyTypeEnum(String level, String code, String name) {
+        this.level = level;
+        this.code = code;
+        this.name = name;
+    }
+
+    public static String getNameByType(String code) {
+        String name = null;
+        for (CompanyTypeEnum enumOne : CompanyTypeEnum.values()) {
+            if (enumOne.getCode().equals(code)) {
+                name = enumOne.getName();
+                break;
+            }
+        }
+        return name;
+    }
+
+    public static String decideCompanyLevel(String str) {
+        List<CompanyTypeEnum> typeList = getCompanyTypeEnums(str);
+        if (typeList == null) return null;
+        String result;
+        Set<String> set = new HashSet<>();
+        for (CompanyTypeEnum one : typeList) {
+            set.add(one.getLevel());
+        }
+        result = String.join(",", set);
+        return result;
+    }
+
+    private static List<CompanyTypeEnum> getCompanyTypeEnums(String str) {
+        if (ValidationUtil.isEmpty(str)) {
+            return null;
+        }
+        List<CompanyTypeEnum> typeList = Lists.newArrayList();
+        for (CompanyTypeEnum enumOne : CompanyTypeEnum.values()) {
+            if (str.contains(enumOne.getName())) {
+                typeList.add(enumOne);
+            }
+        }
+        if (ValidationUtil.isEmpty(typeList)) {
+            return null;
+        }
+        return typeList;
+    }
+
+    public static String decideCompanyCode(String str) {
+        List<CompanyTypeEnum> typeList = getCompanyTypeEnums(str);
+        if (typeList == null) return null;
+        String result;
+        Set<String> set = new HashSet<>();
+        for (CompanyTypeEnum one : typeList) {
+            set.add(one.getCode());
+        }
+        result = String.join(",", set);
+        return result;
+    }
+
+    public static String decideCompanyType(String str) {
+        List<CompanyTypeEnum> typeList = getCompanyTypeEnums(str);
+        if (typeList == null) return null;
+        String result;
+        Set<String> set = new HashSet<>();
+        for (CompanyTypeEnum one : typeList) {
+            set.add(one.getName());
+        }
+        result = String.join(",", set);
+        return result;
+    }
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-api/src/main/java/com/yeejoin/amos/boot/module/ys/api/vo/ResponeVo.java

+package com.yeejoin.amos.boot.module.ys.api.vo;
+
+import lombok.Data;
+import org.apache.http.client.methods.CloseableHttpResponse;
+
+import java.io.InputStream;
+
+/**
+ * @description: http封装响应对象
+ * @author: duanwei
+ * @create: 2019-08-08 13:30
+ **/
+@Data
+public class ResponeVo {
+    int code;
+    CloseableHttpResponse response;
+    String content;
+    byte[] inStream;
+    InputStream inputStream;
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/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">
+    <parent>
+        <artifactId>amos-boot-module-ys</artifactId>
+        <groupId>com.amosframework.boot</groupId>
+        <version>1.0.1</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>amos-boot-module-ys-biz</artifactId>
+    <dependencies>
+        <dependency>
+            <groupId>com.amosframework.boot</groupId>
+            <artifactId>amos-boot-module-ys-api</artifactId>
+            <version>${amos-boot-biz.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.amosframework.boot</groupId>
+            <artifactId>amos-boot-module-common-biz</artifactId>
+            <version>${amos-boot-biz.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpmime</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.aspose</groupId>
+            <artifactId>aspose-words</artifactId>
+            <version>19.5jdk</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>io.github.openfeign</groupId>
+            <artifactId>feign-httpclient</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.esotericsoftware.kryo</groupId>
+            <artifactId>kryo</artifactId>
+            <version>2.24.0</version>
+        </dependency>
+        <dependency>
+            <groupId>de.javakaffee</groupId>
+            <artifactId>kryo-serializers</artifactId>
+            <version>0.45</version>
+        </dependency>
+        <dependency>
+            <groupId>com.esotericsoftware</groupId>
+            <artifactId>kryo</artifactId>
+            <version>4.0.2</version>
+        </dependency>
+        <dependency>
+            <groupId>cn.com.vastdata</groupId>
+            <artifactId>vastbase-jdbc</artifactId>
+            <version>2.7p</version>
+        </dependency>
+        <dependency>
+            <groupId>io.seata</groupId>
+            <artifactId>seata-spring-boot-starter</artifactId>
+            <version>1.8.0</version>
+        </dependency>
+    </dependencies>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <version>2.7.8</version>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>
\ No newline at end of file

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/AmosYsApplication.java

+package com.yeejoin.amos;
+
+import com.yeejoin.amos.boot.biz.common.utils.oConvertUtils;
+import net.javacrumbs.shedlock.spring.annotation.EnableSchedulerLock;
+import org.mybatis.spring.annotation.MapperScan;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.boot.web.servlet.ServletComponentScan;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+import org.springframework.context.ConfigurableApplicationContext;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.FilterType;
+import org.springframework.core.env.Environment;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
+import springfox.documentation.swagger2.annotations.EnableSwagger2WebMvc;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+
+/**
+ * <pre>
+ * 特种设备服务启动类
+ * </pre>
+ *
+ * @author DELL
+ */
+@EnableTransactionManagement
+@EnableConfigurationProperties
+@ServletComponentScan
+@EnableDiscoveryClient
+@EnableFeignClients
+@EnableAsync
+@EnableSwagger2WebMvc
+@EnableEurekaClient
+@EnableSchedulerLock(defaultLockAtMostFor = "10m")
+@MapperScan({"org.typroject.tyboot.demo.face.orm.dao*", "org.typroject.tyboot.face.*.orm.dao*",
+        "org.typroject.tyboot.core.auth.face.orm.dao*", "org.typroject.tyboot.component.*.face.orm.dao*",
+        "com.yeejoin.amos.boot.module.**.api.mapper", "com.yeejoin.amos.boot.biz.common.dao.mapper"})
+@ComponentScan(basePackages = {"org.typroject", "com.yeejoin.amos"}, excludeFilters = {
+        @ComponentScan.Filter(type = FilterType.ASSIGNABLE_TYPE, classes = {org.typroject.tyboot.core.restful.exception.GlobalExceptionHandler.class})})
+@SpringBootApplication(exclude = {org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration.class})
+public class AmosYsApplication {
+    private static final Logger logger = LoggerFactory.getLogger(AmosYsApplication.class);
+
+
+    public static void main(String[] args) throws UnknownHostException {
+        ConfigurableApplicationContext context = SpringApplication.run(AmosYsApplication.class, args);
+        Environment env = context.getEnvironment();
+        String ip = InetAddress.getLocalHost().getHostAddress();
+        String port = env.getProperty("server.port");
+        String path = oConvertUtils.getString(env.getProperty("server.servlet.context-path"));
+        logger.info("\n----------------------------------------------------------\n\t"
+                + "Application Amos-Ys is running! Access URLs:\n\t" + "Swagger文档: \thttp://" + ip + ":" + port
+                + path + "/doc.html\n" + "----------------------------------------------------------\n");
+    }
+
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/config/DataSourceConfiguration.java

+package com.yeejoin.amos.boot.module.ys.biz.config;
+
+import com.baomidou.mybatisplus.autoconfigure.MybatisPlusProperties;
+import com.baomidou.mybatisplus.core.config.GlobalConfig;
+import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor;
+import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
+import com.yeejoin.amos.boot.biz.config.MetaHandler;
+import com.yeejoin.amos.boot.biz.config.MybatisSqlInjector;
+import com.zaxxer.hikari.HikariDataSource;
+import io.seata.rm.datasource.DataSourceProxy;
+import org.apache.ibatis.plugin.Interceptor;
+import org.apache.ibatis.session.SqlSessionFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
+import org.springframework.core.io.support.ResourcePatternResolver;
+
+import javax.sql.DataSource;
+
+/**
+ * 数据源代理
+ *
+ * @author LiuLin
+ */
+@Configuration
+public class DataSourceConfiguration {
+
+
+    @Bean("dataSource")
+    public DataSourceProxy dataSourceProxy(HikariDataSourceProperties hikariDataSourceProperties, DataSourceProperties dataSourceProperties) {
+        HikariDataSource dataSource = dataSourceProperties.initializeDataSourceBuilder().type(HikariDataSource.class).build();
+        dataSource.setMaximumPoolSize(hikariDataSourceProperties.getMaximumPoolSize());
+        dataSource.setMinimumIdle(hikariDataSourceProperties.getMinimumIdle());
+        dataSource.setMaxLifetime(hikariDataSourceProperties.getMaxLifetime());
+        dataSource.setPoolName(hikariDataSourceProperties.getPoolName());
+        dataSource.setConnectionTestQuery(hikariDataSourceProperties.getConnectionTestQuery());
+        dataSource.setIdleTimeout(hikariDataSourceProperties.getIdleTimeout());
+        dataSource.setConnectionTimeout(hikariDataSourceProperties.getConnectionTimeout());
+        dataSource.setIdleTimeout(hikariDataSourceProperties.getIdleTimeout());
+        dataSource.setConnectionInitSql(hikariDataSourceProperties.getConnectionInitSql());
+        return new DataSourceProxy(dataSource);
+    }
+
+    @Bean(name = "sqlSessionFactory")
+    @Autowired
+    public SqlSessionFactory sqlSessionFactoryBean(DataSource dataSourceProxy, PaginationInterceptor paginationInterceptor, MetaHandler metaHandler, MybatisPlusProperties mybatisPlusProperties) throws Exception {
+        MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();
+        bean.setDataSource(dataSourceProxy);
+        ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
+        bean.setMapperLocations(resolver.getResources("classpath*:mapper/*.xml"));
+        bean.setConfigurationProperties(mybatisPlusProperties.getConfigurationProperties());
+        GlobalConfig globalConfig = new GlobalConfig();
+        globalConfig.setSqlInjector(new MybatisSqlInjector());
+        globalConfig.setMetaObjectHandler(metaHandler);
+        bean.setGlobalConfig(globalConfig);
+        Interceptor[] plugins = {paginationInterceptor};
+        bean.setPlugins(plugins);
+        return bean.getObject();
+    }
+
+    @Bean
+    public MetaHandler metaHandler() {
+        return new MetaHandler();
+    }
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/config/ElasticSearchClientConfig.java

+package com.yeejoin.amos.boot.module.ys.biz.config;
+
+import org.apache.http.HttpHost;
+import org.apache.http.auth.AuthScope;
+import org.apache.http.auth.UsernamePasswordCredentials;
+import org.apache.http.client.CredentialsProvider;
+import org.apache.http.impl.client.BasicCredentialsProvider;
+import org.elasticsearch.client.RestClient;
+import org.elasticsearch.client.RestClientBuilder;
+import org.elasticsearch.client.RestHighLevelClient;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.Arrays;
+
+@Configuration
+public class ElasticSearchClientConfig {
+
+    @Value("${spring.elasticsearch.rest.uris}")
+    private String uris;
+    @Value("${elasticsearch.username}")
+    private String username;
+
+    @Value("${elasticsearch.password}")
+    private String password;
+
+    @Bean(destroyMethod = "close")
+    public RestHighLevelClient restHighLevelClient() {
+        final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
+        credentialsProvider.setCredentials(AuthScope.ANY,
+                new UsernamePasswordCredentials(username, password));
+
+        try {
+            HttpHost[] httpHosts = Arrays.stream(uris.split(",")).map(HttpHost::create).toArray(HttpHost[]::new);
+            RestClientBuilder builder = RestClient.builder(httpHosts);
+            builder.setHttpClientConfigCallback(httpClientBuilder -> {
+                httpClientBuilder.disableAuthCaching();
+                return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
+            });
+            // 该方法接收一个RequestConfig.Builder对象，对该对象进行修改后然后返回。
+            builder.setRequestConfigCallback(requestConfigBuilder -> {
+                // 连接超时（默认为1秒）
+                return requestConfigBuilder.setConnectTimeout(5000 * 1000)
+                        // 套接字超时（默认为30秒）//更改客户端的超时限制默认30秒现在改为100*1000分钟
+                        .setSocketTimeout(6000 * 1000);
+            });
+
+            return new RestHighLevelClient(builder);
+        } catch (Exception e) {
+            throw new IllegalStateException("Invalid ES nodes " + "property '" + uris + "'", e);
+        }
+    }
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/config/GlobalExceptionHandler.java

+package com.yeejoin.amos.boot.module.jg.biz.config;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.http.HttpStatus;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+import org.typroject.tyboot.core.foundation.context.RequestContext;
+import org.typroject.tyboot.core.restful.utils.ResponseModel;
+import javax.servlet.http.HttpServletRequest;
+
+@RestControllerAdvice
+public class GlobalExceptionHandler {
+
+    private final Logger log = LoggerFactory.getLogger(GlobalExceptionHandler.class);
+
+    public GlobalExceptionHandler() {
+        log.info("GlobalExceptionHandler initialized.");
+    }
+
+    @ExceptionHandler(Exception.class)
+    public ResponseModel<Object> handleException(Exception exception, HttpServletRequest request) {
+        log.error("Exception occurred:", exception);
+
+        ResponseModel<Object> response = new ResponseModel<>();
+        response.setStatus(HttpStatus.INTERNAL_SERVER_ERROR.value());
+        response.setDevMessage("FAILED");
+        response.setMessage(exception.getMessage());
+        response.setTraceId(RequestContext.getTraceId());
+        response.setPath(request != null ? request.getServletPath() : null);
+
+        if (exception.getMessage() != null && (exception.getMessage().contains("账号已经在其他设备登录") || exception.getMessage().contains("请重新登录"))) {
+            response.setStatus(HttpStatus.FORBIDDEN.value());
+        }
+        return response;
+    }
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/config/HikariDataSourceProperties.java

+package com.yeejoin.amos.boot.module.ys.biz.config;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author shg
+ */
+@Component
+@ConfigurationProperties(prefix = "spring.datasource.hikari")
+@Data
+public class HikariDataSourceProperties {
+
+
+    private int maximumPoolSize;
+
+    private int minimumIdle;
+
+    private boolean autoCommit;
+
+    private long idleTimeout;
+
+    private String poolName;
+
+    private long maxLifetime;
+
+    private long connectionTimeout;
+
+    private String connectionTestQuery;
+
+    private long validationTimeout;
+
+    private String connectionInitSql;
+
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/config/LocalBadRequest.java

+package com.yeejoin.amos.boot.module.ys.biz.config;
+
+import org.typroject.tyboot.core.foundation.exception.BaseException;
+
+public class LocalBadRequest extends BaseException {
+
+    public LocalBadRequest(String message)
+    {
+        super(message, com.yeejoin.amos.component.robot.BadRequest.class.getSimpleName(),message);
+        this.httpStatus = 500;
+    }
+
+}
\ No newline at end of file

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/config/MybatisPlusConfigs.java

+package com.yeejoin.amos.boot.module.ys.biz.config;
+
+import com.baomidou.mybatisplus.annotation.DbType;
+import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor;
+import com.yeejoin.amos.boot.module.ys.biz.utils.SqlInjectorUtils;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration(value="MybatisPlusConfig")
+public class MybatisPlusConfigs {
+
+	@Bean
+	public  PaginationInterceptor paginationInterceptor()
+	{
+		PaginationInterceptor paginationInterceptor = new PaginationInterceptor();
+		paginationInterceptor.setLimit(50000);
+		paginationInterceptor.setDialectType(DbType.POSTGRE_SQL.getDb());
+		return paginationInterceptor;
+	}
+
+	@Bean
+	public SqlInjectorUtils sqlInjectorUtils() {
+		return new SqlInjectorUtils();
+	}
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/config/RedissonManager.java

+package com.yeejoin.amos.boot.module.ys.biz.config;
+
+import lombok.extern.slf4j.Slf4j;
+import org.redisson.Redisson;
+import org.redisson.api.RedissonClient;
+import org.redisson.config.Config;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+
+@Configuration
+@Slf4j
+public class RedissonManager {
+
+    /**
+     * 集群环境使用-节点信息
+     */
+    @Value("${spring.redis.cluster.nodes:default}")
+    private String clusterNodes;
+
+
+    /**
+     * 公共-密码
+     */
+    @Value("${spring.redis.password}")
+    private String password;
+
+    /**
+     * 单机环境使用
+     */
+    @Value("${spring.redis.host:default}")
+    private String host;
+
+
+    /**
+     * 单机环境使用
+     */
+    @Value("${spring.redis.port:default}")
+    private String port;
+
+    /**
+     * 单机环境使用
+     */
+    @Value("${spring.redis.database:0}")
+    private int database;
+
+    @Bean
+    @ConditionalOnProperty(name = "spring.redis.mode", havingValue = "cluster")
+    public RedissonClient redissonClient() {
+        // 集群环境使用
+        Config config = new Config();
+        config.useClusterServers()
+                .addNodeAddress(clusterNodes.split(","))
+                .setPassword(password);
+        return Redisson.create(config);
+    }
+
+    @Bean
+    @ConditionalOnProperty(name = "spring.redis.mode", havingValue = "singleton", matchIfMissing = true)
+    public RedissonClient redissonSingletonClient() {
+        // 单机环境使用
+        Config config = new Config();
+        config.useSingleServer().setAddress(host + ":" + port).setPassword(password).setDatabase(database);
+        return Redisson.create(config);
+    }
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/config/ShedLockConfig.java

+package com.yeejoin.amos.boot.module.ys.biz.config;
+
+import net.javacrumbs.shedlock.core.LockProvider;
+import net.javacrumbs.shedlock.provider.redis.spring.RedisLockProvider;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+
+/**
+ * @author Administrator
+ */
+@Configuration
+public class ShedLockConfig {
+
+    @Bean
+    public LockProvider lockProvider(RedisConnectionFactory connectionFactory) {
+        return new RedisLockProvider(connectionFactory);
+    }
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/config/XidFeignConfiguration.java

+package com.yeejoin.amos.boot.module.ys.biz.config;
+
+import feign.RequestInterceptor;
+import feign.RequestTemplate;
+import feign.codec.Encoder;
+import feign.form.spring.SpringFormEncoder;
+import io.seata.core.context.RootContext;
+import org.springframework.beans.factory.ObjectFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.http.HttpMessageConverters;
+import org.springframework.cloud.openfeign.support.SpringEncoder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.util.StringUtils;
+import org.springframework.web.context.request.RequestContextListener;
+
+@Configuration
+public class XidFeignConfiguration implements RequestInterceptor {
+    @Autowired
+    private ObjectFactory<HttpMessageConverters> messageConverters;
+
+    @Bean
+    public Encoder feignFormEncoder() {
+        return new SpringFormEncoder(new SpringEncoder(messageConverters));
+    }
+    /**
+     * 创建Feign请求拦截器，在发送请求前设置认证的token,各个微服务将token设置到环境变量中来达到通用
+     * @return
+     */
+    @Bean
+    public RequestContextListener requestInterceptor() {
+        return new RequestContextListener();
+    }
+
+    @Override
+    public void apply(RequestTemplate template) {
+        String xid = RootContext.getXID();
+        if(StringUtils.hasText(xid)){
+            template.header(RootContext.KEY_XID, xid);
+        }
+    }
+}
\ No newline at end of file

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/dao/ESElavtorRepository.java

+package com.yeejoin.amos.boot.module.ys.biz.dao;
+
+import com.yeejoin.amos.boot.module.ymt.api.entity.EsElevator;
+import org.springframework.data.repository.PagingAndSortingRepository;
+import org.springframework.stereotype.Repository;
+
+/**
+ * @author fengwang
+ * @date 2021-09-26.
+ */
+@Repository
+public interface ESElavtorRepository extends PagingAndSortingRepository<EsElevator, Long> {
+
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/feign/PrivilegeFeginService.java

+package com.yeejoin.amos.boot.module.ys.biz.feign;
+
+
+import com.yeejoin.amos.boot.biz.common.feign.FeignConfiguration;
+import com.yeejoin.amos.component.feign.config.InnerInvokException;
+import com.yeejoin.amos.component.feign.model.FeignClientResult;
+import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
+import com.yeejoin.amos.feign.privilege.model.VerifyCodeAuthModel;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.*;
+import org.typroject.tyboot.core.restful.utils.ResponseModel;
+
+@FeignClient(value = "AMOS-API-PRIVILEGE", configuration = {FeignConfiguration.class})
+public interface PrivilegeFeginService {
+
+    @RequestMapping(value = "/privilege/v1/agencyuser/me", method = RequestMethod.GET)
+    ResponseModel<AgencyUserModel> getMe();
+
+    //获取单位树
+    @RequestMapping(value = "/privilege/v1/company/tree", method = RequestMethod.GET)
+    FeignClientResult tree(@RequestHeader("token") String token, @RequestHeader("appKey") String appKey, @RequestHeader("product") String product);
+
+    @RequestMapping(value = {"/privilege/v1/company/tree/cache"}, method = {RequestMethod.GET})
+    FeignClientResult queryAgencyTreeForCache(@RequestHeader("token") String token, @RequestHeader("appKey") String appKey, @RequestHeader("product") String product) throws InnerInvokException;
+
+
+    //获取省级行政区划
+    @RequestMapping(value = "systemctl/v1/region/level", method = RequestMethod.GET)
+    FeignClientResult getProvince(@RequestParam String level);
+
+    //获取行政区划树
+    @RequestMapping(value = "systemctl/v1/region/tree", method = RequestMethod.GET)
+    FeignClientResult getTree();
+
+    /**
+     * 手机号验证码登录
+     */
+    @RequestMapping(value = "/privilege/v1/auth/mobile/verifycode", method = RequestMethod.POST)
+    FeignClientResult mobileVerifyCode(@RequestBody VerifyCodeAuthModel model) throws InnerInvokException;
+
+
+
+    @RequestMapping(value = "/privilege/v1/agencyuser/list/company/{companyId}", method = RequestMethod.GET)
+    FeignClientResult getCompanyUser(@PathVariable(value = "companyId")Long companyId);
+
+
+
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/feign/TaskV2FeignService.java

+package com.yeejoin.amos.boot.module.ys.biz.feign;
+
+import com.yeejoin.amos.boot.module.ys.biz.config.XidFeignConfiguration;
+import com.yeejoin.amos.component.feign.config.InnerInvokException;
+import com.yeejoin.amos.component.feign.model.FeignClientResult;
+import com.yeejoin.amos.feign.systemctl.model.TaskV2Model;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+
+import java.util.List;
+
+/**
+ * @author LiuLin
+ * @apiNote 待办Feign调用
+ * @date 2024-05-16
+ */
+@FeignClient(name = "AMOS-API-PRIVILEGE", path = "/systemctl/v2/task", configuration = {XidFeignConfiguration.class})
+public interface TaskV2FeignService {
+
+    /**
+     * 批量新增任务
+     *
+     * @param modelList 新增待办
+     * @return TaskV2Model
+     * @throws InnerInvokException e
+     */
+    @RequestMapping(value = "/batch/add", method = RequestMethod.POST)
+    FeignClientResult<List<TaskV2Model>> batchAdd(@RequestBody List<TaskV2Model> modelList) throws InnerInvokException;
+
+    /**
+     * 更新任务
+     *
+     * @param model       待办信息
+     * @param sequenceNbr 主键
+     * @return TaskV2Model
+     * @throws InnerInvokException e
+     */
+    @RequestMapping(value = "/{sequenceNbr}", method = RequestMethod.PUT)
+    FeignClientResult<TaskV2Model> update(@RequestBody TaskV2Model model, @PathVariable("sequenceNbr") Long sequenceNbr) throws InnerInvokException;
+
+    /**
+     * 创建任务
+     *
+     * @param model 待办
+     * @return
+     * @throws InnerInvokException
+     */
+    @RequestMapping(value = "", method = RequestMethod.POST)
+    FeignClientResult<TaskV2Model> create(@RequestBody TaskV2Model model) throws InnerInvokException;
+
+    /**
+     * 批量删除任务
+     *
+     * @param ids 主键
+     * @return Long
+     * @throws InnerInvokException e
+     */
+    @RequestMapping(value = "/{ids}", method = RequestMethod.DELETE)
+    FeignClientResult<List<Long>> delete(@PathVariable("ids") String ids) throws InnerInvokException;
+
+    /**
+     * 查询指定任务
+     *
+     * @param relationId 关联Id
+     * @return List<TaskV2Model>
+     * @throws InnerInvokException
+     */
+    @RequestMapping(value = "/queryByRelationId/{relationId}", method = RequestMethod.GET)
+    FeignClientResult<List<TaskV2Model>> selectListByRelationId(@PathVariable("relationId") String relationId) throws InnerInvokException;
+
+    /**
+     * 批量修改任务
+     */
+    @RequestMapping(value = "/batch/update", method = RequestMethod.PUT)
+    FeignClientResult<List<TaskV2Model>> batchUpdate(@RequestBody List<TaskV2Model> modelList) throws InnerInvokException;
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/feign/TzsServiceFeignClient.java

+package com.yeejoin.amos.boot.module.ys.biz.feign;
+
+
+import com.yeejoin.amos.boot.biz.common.feign.FeignConfiguration;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.typroject.tyboot.core.restful.utils.ResponseModel;
+
+import java.util.List;
+import java.util.Map;
+
+@FeignClient(name = "TZS-YMT", path = "/ymt", configuration =
+        {FeignConfiguration.class})
+public interface TzsServiceFeignClient {
+
+
+    /**
+     * 创建监管码及96333
+     *
+     * @param map 请求体
+     * @return
+     */
+    @RequestMapping(value = "/equipment-category/createSupervisorCode", method = RequestMethod.POST)
+    ResponseModel<Map<String, Object>> createCode(@RequestBody Map<String, Object> map);
+
+    /**
+     * 创建监管码及96333
+     *
+     * @param paramMap 请求体
+     * @return
+     */
+    @RequestMapping(value = "/equipment-category/commonUpdateEsData", method = RequestMethod.POST)
+    ResponseModel<Map<String, Object>> commonUpdateEsDataByIds(@RequestBody Map<String, Map<String, Object>> paramMap);
+
+
+    /**
+     * 申请单编号生成
+     * @param type 参考ApplicationFormTypeEnum中的枚举
+     * @param batchSize batchSize
+     * @return List
+     */
+    @RequestMapping(value = "/generate-code/applicationFormCode", method = RequestMethod.POST)
+    ResponseModel<List<String>> applicationFormCode(@RequestParam("type") String type,
+                                                    @RequestParam("batchSize") int batchSize);
+
+    /**
+     * 生成设备注册编码
+     * @param key 16位
+     * @return 生成设备注册编码(20位)
+     */
+    @RequestMapping(value = "/generate-code/deviceRegistrationCode", method = RequestMethod.POST)
+    ResponseModel<String> deviceRegistrationCode(@RequestParam("key") String key);
+
+    /**
+     * 使用登记证生成
+     * @param key 起11陕C
+     * @return 生成使用登记证编号(13位，起11陕C00001(23))
+     */
+    @RequestMapping(value = "/generate-code/useRegistrationCode", method = RequestMethod.POST)
+    ResponseModel<String> useRegistrationCode(@RequestParam("key") String key);
+
+
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/feign/WorkFlowFeignService.java

+package com.yeejoin.amos.boot.module.ys.biz.feign;
+
+import com.alibaba.fastjson.JSONObject;
+import com.yeejoin.amos.boot.module.ys.biz.config.XidFeignConfiguration;
+import com.yeejoin.amos.component.feign.model.FeignClientResult;
+import com.yeejoin.amos.feign.workflow.model.*;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+import java.util.Map;
+
+@FeignClient(name = "AMOS-API-WORKFLOW", path = "workflow", configuration = {XidFeignConfiguration.class})
+public interface WorkFlowFeignService {
+
+    /***
+     * 根据task_id 获取节点信息
+     *
+     * */
+    @RequestMapping(value = "/history/task/nodeInfo", method = RequestMethod.GET)
+    FeignClientResult<JSONObject> getNodeInfo(@RequestParam(value = "taskId") String taskId);
+
+
+    /***
+     *
+     * 查询当前流程对应的可执行任务，无权限级别
+     * */
+
+    @RequestMapping(value = "/task/getTaskNoAuth/{processInstanceId}", method = RequestMethod.GET)
+    JSONObject getTaskNoAuth(@PathVariable(value = "processInstanceId") String processInstanceId);
+
+    /***
+     *
+     * 获取流程审批日志
+     * */
+    @RequestMapping(value = "/task/flowLogger/{procInsId}", method = RequestMethod.GET)
+    FeignClientResult<Map<String, Object>> getFlowLogger(@PathVariable(value = "procInsId") String procInsId);
+
+
+    @RequestMapping(value = "/history/task/nodeInfo", method = RequestMethod.GET)
+    FeignClientResult<JSONObject> getNodeInfotoken(
+            @RequestHeader(name = "appKey", required = true) String appKey,
+            @RequestHeader(name = "product", required = true) String product,
+            @RequestHeader(name = "token", required = true) String token,
+            @RequestParam(value = "taskId") String taskId);
+
+
+    /***
+     *
+     * 查询当前流程对应的可执行任务，无权限级别
+     * */
+
+    @RequestMapping(value = "/task/getTaskNoAuth/{processInstanceId}", method = RequestMethod.GET)
+    JSONObject getTaskNoAuthtoken(
+            @RequestHeader(name = "appKey", required = true) String appKey,
+            @RequestHeader(name = "product", required = true) String product,
+            @RequestHeader(name = "token", required = true) String token,
+            @PathVariable(value = "processInstanceId") String processInstanceId);
+
+
+    @RequestMapping(value = "/v2/task/rollBack/{processInstanceId}", method = RequestMethod.POST)
+    JSONObject rollBack(@PathVariable(value = "processInstanceId") String processInstanceId);
+
+    /**
+     * 工作流启动接口
+     *
+     * @param params 业务参数
+     * @return ProcessTaskDTO
+     * @throws Exception e
+     */
+    @RequestMapping(value = "/v2/task/start/batch", method = RequestMethod.POST)
+    FeignClientResult<List<ProcessTaskDTO>> startForBatch(@RequestBody ActWorkflowBatchDTO params) throws Exception;
+
+    /**
+     * 工作流驳回任务接口
+     *
+     * @param taskId 任务Id
+     * @param data   业务参数
+     * @return ProcessTaskDTO
+     * @throws Exception e
+     */
+    @RequestMapping(value = "/v2/task/reject/{taskId}", method = RequestMethod.POST)
+    FeignClientResult<ProcessTaskDTO> reject(@PathVariable("taskId") String taskId, @RequestBody TaskResultDTO data) throws Exception;
+
+    /**
+     * 工作流完成任务接口
+     *
+     * @param taskId 任务Id
+     * @param data   业务参数
+     * @return ProcessTaskDTO
+     * @throws Exception e
+     */
+    @RequestMapping(value = "/v2/task/complete/standard/{taskId}", method = RequestMethod.POST)
+    FeignClientResult<ProcessTaskDTO> completeByTaskFroStandard(@PathVariable("taskId") String taskId, @RequestBody TaskResultDTO data) throws Exception;
+
+    /**
+     * 工作流撤回
+     *
+     * @param processInstanceId processInstanceId
+     * @return ProcessTaskDTO
+     */
+    @PostMapping(value = "/v2/task/rollBack/standard/{processInstanceId}")
+    FeignClientResult<ProcessTaskDTO> rollBackTask(@PathVariable("processInstanceId") String processInstanceId);
+
+    /**
+     * 转办任务
+     *
+     * @param flowTaskVo flowTaskVo
+     * @return ProcessTaskDTO
+     */
+    @PostMapping(value = "/v2/task/assign")
+    FeignClientResult<ProcessTaskDTO> assign(@RequestBody FlowTaskVo flowTaskVo);
+
+    /**
+     * 终止流程
+     *
+     * @param processInstanceId processInstanceId
+     * @return ProcessInstanceDTO
+     * @throws Exception e
+     */
+    @DeleteMapping(value = "/v2/task/stopProcess/{processInstanceId}")
+    FeignClientResult<ProcessInstanceDTO> stopProcess(@PathVariable("processInstanceId") String processInstanceId, @RequestParam(required = false, value = "stopReason") String stopReason) throws Exception;
+
+    /**
+     * 处理审批错误历史数据
+     *
+     * @param processInstanceId processInstanceId
+     * @return ProcessTaskDTO
+     */
+    @RequestMapping(value = "/v2/task/error/history/data/{processInstanceId}", method = RequestMethod.GET)
+    FeignClientResult<ProcessTaskDTO> handleErrorForm(@PathVariable("processInstanceId") String processInstanceId,
+                                                      @RequestParam(value = "receiveCompanyCode") String receiveCompanyCode);
+
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/service/impl/StartPlatformTokenService.java

+package com.yeejoin.amos.boot.module.ys.biz.service.impl;
+
+import com.yeejoin.amos.boot.module.ys.biz.utils.RedisUtil;
+import com.yeejoin.amos.component.robot.AmosRequestContext;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.typroject.tyboot.core.foundation.context.RequestContext;
+
+@Service
+public class StartPlatformTokenService {
+
+    @Autowired
+    RedisUtil redisUtil;
+
+    @Autowired
+    AmosRequestContext amosRequestContext;
+
+
+    public void getToken() {
+        RequestContext.setProduct(amosRequestContext.getProduct());
+        RequestContext.setAppKey(amosRequestContext.getAppKey());
+        RequestContext.setToken(amosRequestContext.getToken());
+    }
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/utils/FileExporter.java

+package com.yeejoin.amos.boot.module.ys.biz.utils;
+
+import org.typroject.tyboot.core.restful.exception.instance.BadRequest;
+
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.net.URLEncoder;
+
+public class FileExporter {
+
+    public static void exportFile(FileType fileType, String fileName, byte[] data, HttpServletResponse response) {
+        try {
+            response.reset();
+            response.setCharacterEncoding("utf-8");
+            response.setContentType(fileType.getContentType());
+            fileName = fileName.replaceAll("\\..*", "");
+            fileName = URLEncoder.encode(fileName + fileType.getFileSufix(), "UTF-8");
+            response.setHeader("Content-Disposition", "attachment; filename=" + fileName + "");
+            response.getOutputStream().write(data);
+            response.getOutputStream().flush();
+        } catch (Exception e) {
+            throw new BadRequest("导出文档出错");
+        } finally {
+            try {
+                response.getOutputStream().close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+    /**
+     * 文件类型
+     */
+    public enum FileType {
+        // word文档
+        docx(".docx", "application/msword"),
+        // pdf文档
+        pdf(".pdf", "application/pdf");
+
+        private String fileSufix;
+        private String contentType;
+
+        private FileType(String fileSufix, String contentType) {
+            this.fileSufix = fileSufix;
+            this.contentType = contentType;
+        }
+
+        public String getFileSufix() {
+            return fileSufix;
+        }
+
+        public String getContentType() {
+            return contentType;
+        }
+
+        public static FileType getInstance(String fileSufix) {
+            FileType knowledgeRoleName = null;
+            for (FileType fileType : FileType.values()) {
+                if (fileType.getFileSufix().equals(fileSufix)) {
+                    knowledgeRoleName = fileType;
+                }
+            }
+            return knowledgeRoleName;
+        }
+    }
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/utils/JsonUtils.java

+package com.yeejoin.amos.boot.module.ys.biz.utils;
+
+import com.alibaba.fastjson.JSONObject;
+import org.apache.commons.io.IOUtils;
+import org.springframework.core.io.Resource;
+
+import java.io.IOException;
+import java.nio.charset.StandardCharsets;
+import java.util.List;
+import java.util.Map;
+
+import static com.alibaba.fastjson.JSON.parseArray;
+
+
+public class JsonUtils {
+    //将json文件转化为Map<list<Map<>>>
+    public static Map getResourceJson(Resource resource) {
+        String json = null;
+        try {
+            json = IOUtils.toString(resource.getInputStream(), String.valueOf(StandardCharsets.UTF_8));
+        } catch (IOException e) {
+            throw new RuntimeException(resource + "json文件转化失败");
+        }
+        return JSONObject.parseObject(json, Map.class);
+    }
+
+    //将json文件转化为List<Map>
+    public static  List<Map> getResourceList(Resource resource) {
+        String json = null;
+        try {
+            json = IOUtils.toString(resource.getInputStream(), String.valueOf(StandardCharsets.UTF_8));
+        } catch (IOException e) {
+            throw new RuntimeException(resource + "json文件转化失败");
+        }
+        List<Map> list = parseArray(json, Map.class);
+        return list;
+    }
+
+
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/utils/PdfUtils.java

+package com.yeejoin.amos.boot.module.ys.biz.utils;
+
+import com.itextpdf.text.Image;
+import com.itextpdf.text.Rectangle;
+import com.itextpdf.text.*;
+import com.itextpdf.text.pdf.*;
+import lombok.SneakyThrows;
+
+import javax.imageio.ImageIO;
+import java.awt.Font;
+import java.awt.*;
+import java.awt.image.BufferedImage;
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+
+/**
+ * @author Administrator
+ */
+
+public class PdfUtils {
+
+    @SneakyThrows
+    public static File addImageToPdf(String inputPdfPath, int width, int height, String imagePath) {
+        PdfReader reader = null;
+        PdfStamper stamper = null;
+        File outputPdfFile = null;
+        try {
+            reader = new PdfReader(inputPdfPath);
+            outputPdfFile = File.createTempFile("output", ".pdf");
+            stamper = new PdfStamper(reader, new FileOutputStream(outputPdfFile));
+            Image img = Image.getInstance(imagePath);
+            img.scaleToFit(width, height);
+            PdfContentByte content = stamper.getOverContent(1);
+            img.setAbsolutePosition(reader.getPageSize(1).getWidth() - width, reader.getPageSize(1).getHeight() - height);
+            content.addImage(img);
+        } catch (IOException | DocumentException e) {
+            e.printStackTrace();
+        } finally {
+            if (stamper != null) {
+                try {
+                    stamper.close();
+                } catch (DocumentException | IOException e) {
+                    e.printStackTrace();
+                }
+            }
+            if (reader != null) {
+                reader.close();
+            }
+        }
+        return outputPdfFile;
+    }
+
+
+    public static void generatorImageWithText(File imageFile, int width, int height, String text, Color color) {
+        BufferedImage image = new BufferedImage(width, height, BufferedImage.TYPE_INT_ARGB);
+        Graphics2D g2d = image.createGraphics();
+        // 设置背景为透明
+        image = g2d.getDeviceConfiguration().createCompatibleImage(width, height, Transparency.TRANSLUCENT);
+        g2d.dispose();
+        g2d = image.createGraphics();
+
+        // 设置抗锯齿
+        g2d.setRenderingHint(RenderingHints.KEY_ANTIALIASING, RenderingHints.VALUE_ANTIALIAS_ON);
+
+        // 写入字符串
+        Font font = new Font("Microsoft YaHei", Font.BOLD, 20);
+        g2d.setFont(font);
+        FontMetrics fm = g2d.getFontMetrics();
+        int textWidth = fm.stringWidth(text);
+        int textHeight = fm.getHeight();
+
+        int x = (width - textWidth) / 2;
+        int y = (height - textHeight) / 2 + fm.getAscent();
+
+        g2d.setColor(color);
+        g2d.drawString(text, x, y);
+        g2d.dispose();
+        try {
+            ImageIO.write(image, "PNG", imageFile);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+
+    @SneakyThrows
+    public static File addFullPageWatermark(String src, String watermarkText) {
+        PdfReader reader = null;
+        PdfStamper stamper = null;
+        File outputPdfFile = null;
+        try {
+            outputPdfFile = File.createTempFile("output", ".pdf");
+            reader = new PdfReader(src);
+            stamper = new PdfStamper(reader, new FileOutputStream(outputPdfFile));
+            PdfGState gs = new PdfGState();
+            // 设置透明度为0.1
+            gs.setFillOpacity(0.5f);
+            int n = reader.getNumberOfPages();
+            // 创建一个BaseFont实例，用于水印文本
+            BaseFont bf = BaseFont.createFont("STSong-Light", "UniGB-UCS2-H", BaseFont.EMBEDDED);
+            // 设置水印文本大小
+            float fontSize = 40;
+            // 设置水印文本的间距、根据字体大小调整行间距
+            float lineSpacing = fontSize + 2;
+            // 设置水印文本的起始位置
+            float x = 0;
+            // 遍历PDF的每一页
+            for (int i = 1; i <= n; i++) {
+                PdfContentByte over = stamper.getOverContent(i);
+                // 获取页面尺寸
+                Rectangle pageSize = reader.getPageSizeWithRotation(i);
+                float pageWidth = pageSize.getWidth();
+                float pageHeight = pageSize.getHeight();
+
+                // 从页面底部开始
+                float y = pageHeight;
+                // 计算文本宽度
+                float textWidth = bf.getWidthPoint(watermarkText, fontSize);
+                // 添加水印文本到页面
+                while (y > 0) {
+                    // 文本从页面左侧开始
+                    x = 60;
+                    while (x < pageWidth) {
+                        over.beginText();
+                        over.setFontAndSize(bf, fontSize);
+                        //水印颜色
+                        over.setColorFill(BaseColor.LIGHT_GRAY);
+                        over.setGState(gs);
+                        // 设置文本渲染模式为填充，使文本不可选择
+                        over.setTextRenderingMode(PdfContentByte.TEXT_RENDER_MODE_FILL);
+                        over.setTextMatrix(x, y);
+                        over.showTextAligned(Element.ALIGN_CENTER, watermarkText, x, y, 45);
+                        over.endText();
+                        // 更新x坐标以跳过当前行的文本宽度
+                        x += textWidth + lineSpacing;
+                    }
+                    // 当一行文本添加完毕后，减少y坐标以开始新的一行
+                    y -= (lineSpacing + 50);
+                }
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            if (stamper != null) {
+                stamper.close();
+            }
+            if (reader != null) {
+                reader.close();
+            }
+        }
+        return outputPdfFile;
+    }
+
+
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/java/com/yeejoin/amos/boot/module/ys/biz/utils/SqlInjectorUtils.java

+package com.yeejoin.amos.boot.module.ys.biz.utils;
+
+import com.baomidou.mybatisplus.core.injector.AbstractMethod;
+import com.baomidou.mybatisplus.core.injector.DefaultSqlInjector;
+import com.baomidou.mybatisplus.extension.injector.methods.additional.InsertBatchSomeColumn;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * @author DELL
+ */
+@Component
+public class SqlInjectorUtils extends DefaultSqlInjector {
+
+    @Override
+    public List<AbstractMethod> getMethodList(Class<?> mapperClass) {
+        List<AbstractMethod> methodList = super.getMethodList(mapperClass);
+        // 添加批量插入方法
+        methodList.add(new InsertBatchSomeColumn());
+        return methodList;
+    }
+}

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/resources/application-cluster.properties

+
+
+spring.datasource.url=jdbc:vastbase://${POSTGRESQL_IP_port}/${POSTGRESQL_NAME}?currentSchema=${TZS_IDX_BIZ_DATABASE}&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&autoReconnect=true&useSSL=false&noAccessToProcedureBodies=true&allowMultiQueries=true
+spring.datasource.username=${POSTGRESQL_USER}
+spring.datasource.password=${POSTGRESQL_PASSWORD}
+
+
+
+
+#注册中心地址
+eureka.client.service-url.defaultZone =http://admin:a1234560@192.168.249.13:10001/eureka/,http://admin:a1234560@192.168.249.139:10001/eureka/
+eureka.instance.prefer-ip-address=true
+eureka.instance.ip-address = 192.168.249.139
+management.endpoint.health.show-details=always
+management.endpoints.web.exposure.include=*
+eureka.instance.health-check-url=http://elevator:${server.port}${server.servlet.context-path}/actuator/health
+eureka.instance.metadata-map.management.context-path=${server.servlet.context-path}/actuator
+eureka.instance.status-page-url=http://elevator:${server.port}${server.servlet.context-path}/actuator/info
+eureka.instance.metadata-map.management.api-docs=http://elevator:${server.port}${server.servlet.context-path}/doc.html
+
+
+## ES properties:
+spring.elasticsearch.rest.uris=${ELASTICSEARCH_REST_URIS}
+elasticsearch.username=${ELASTICSEARCH_USERNAME}
+elasticsearch.password= ${ELASTICSEARCH_PASSWORD}
+
+## unit(h)
+alertcall.es.synchrony.time=48
+
+
+#redis properties:
+spring.redis.cluster.nodes=${REDIS_CLUSTER_NODES}
+spring.redis.password=${REDIS_PASSWORD}
+spring.redis.cluster.max-redirects=3
+spring.redis.timeout=10000
+spring.redis.lettuce.cluster.refresh.adaptive=true
+spring.redis.lettuce.cluster.refresh.period=2000
+
+spring.redis.mode=cluster
+
+#springboot指标显示器不使用默认的，使用自定义的MyRedisHealthIndicator
+management.health.redis.enabled=false
+
+
+##emqx
+emqx.clean-session=true
+emqx.client-id=${spring.application.name}-${random.int[1024,65536]}
+emqx.broker=${EMQX_BROKER}
+emqx.client-user-name=${EMQX_USER}
+emqx.client-password=${EMQX_PASSWORD}
+
+tzs.cti.appkey=0a1b1cf1-a55b-447a-d275-02931f13b2fa
+tzs.cti.secretkey=cae7c0f8-a7b8-9876-d69b-3eba8262898a
+tzs.cti.url=http://192.168.249.178:8000
+
+
+##wechatToken
+tzs.wechat.token=yeejoin_2021
+##wechatTicketUrl
+tzs.wechat.ticketurl=https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token=
+
+#tzs.wechat.tempId.kr=rjW8x9rRitIpa21Jekyx2nzBzpJy7tycssCXSN4YhWw
+tzs.wechat.tempId.kr=bxchKYhYW7aHbGKM2pVyR_yY2-bG4sRMNU3ZRQbMKYM
+tzs.wechat.url.kr=tzs.yeeamos.com/persondetail.html
+#tzs.wechat.tempId.wx=ofBIZS8Bup9s0zKbrGa8BfhVhS18H_hyC_OYXuBN6hI
+tzs.wechat.tempId.wx=rags-expfNSBB-h2WenuBI2c6pCEndH4uwTtOqlHqDM
+tzs.wechat.url.wx=tzs.yeeamos.com/repairPersondetail.html
+#tzs.wechat.tempId.ts=Kr7lcV8g4g_lgyW_RpwnNgw_HDxxRuVx759EoFWrIfU
+tzs.wechat.tempId.ts=VWqgY-lXFt4dg2EL4pLjfDCBAU49Z0mRxVaQhAMMW8Q
+tzs.wechat.url.ts=tzs.yeeamos.com/taskComplaintDetail.html
+
+mqtt.topic.task.newtask=tzs-task-newtask
+
+mqtt.topic.task.personinfo=tzs-task-personinfo
+
+mqtt.topic.elevator.push=/tzs/tcb_elevator
+
+mqtt.topic.alertInfo.push=/tzs/tcb_alertInfo
+
+mqtt.topic.alertReport.push=/tzs/tcb_alertReport
+
+mqtt.topic.alertHeart.push=/tzs/tcb_alertHeart
+
+mqtt.topic.alertMatrix.push=/tzs/tcb_alertMatrix
+
+mqtt.topic.cti.push=/cti/record
+
+cti.user.name=tzs_cti
+
+cti.user.pwd=a1234567
+
+flc.sms.tempCode=SMS_TZS_0001
+
+
+
+## 预警通知模板id
+tzs.wechat.tempId.warning=-pHsHLIjW8j-_AemoZycf6Dmu6iYc-YWWaJ0cAPGeUY
+##督查整改通知
+tzs.wechat.tempId.supervise=P5XGbszS2Pc6kynvGjzPpZ--ikAwDZo6O7WdJ2EUxtE
+
+## 公众号测试用户id（平台userId）
+tzs.wechat.test.userId=3413513
+
+
+fileserver.domain=https://rpm.yeeamos.com:8888/
+org.filter.group.seq=1564150103147573249
+
+duty.seats.role.ids=1585956200472674305,1585956257590706177
+
+## 规则配置 properties:
+rule.definition.load=false
+##rule.definition.model-package=com.yeejoin.amos.boot.module.jcs.api.dto
+rule.definition.default-agency=tzs
+rule.definition.local-ip=192.168.249.139
+
+tzs.auth.user.photo=/public/common/userPic.png
+
+
+minio.url.path=${MINIO_FILESERVER_DOMAIN}/
+
+
+#### 管理员变更机器人账号
+tzs.admin.name=tzs_robot
+tzs.admin.pwd=a1234567
+
+##小程序appid
+tzs.WxApp.appId=wx48a1b1915b10d14b
+tzs.WxApp.secret=ac4f4a9d3c97676badb70c19a2f37b16
+tzs.WxApp.grant-type=authorization_code
+
+
+
+#气瓶充装信息定时同步至es
+tzs.cylinder.fill.cron=0 0 12 * * ?
+#气瓶基本信息定时同步至es
+tzs.cylinder.info.cron=0 0 1 * * ?
+
+outSystem.user.password=a1234560
+amos.system.user.app-key=AMOS_STUDIO
+amos.system.user.product=STUDIO_APP_WEB
+
+
+##生成监管码前缀域名
+regulatory_code_prefix=https://nav.sspai.top/tzs?code=

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/resources/application-dev.properties

+#DB properties:
+spring.datasource.url=jdbc:postgresql://172.16.10.243:5432/tzs_amos_tzs_biz_init?currentSchema=amos_tzs_biz&allowMultiQueries=true
+spring.datasource.username=admin
+spring.datasource.password=Yeejoin@2023
+eureka.client.service-url.defaultZone=http://172.16.10.243:10001/eureka/
+eureka.instance.prefer-ip-address=true
+management.endpoint.health.show-details=always
+management.endpoints.web.exposure.include=*
+eureka.instance.health-check-url=http://172.16.3.68:${server.port}${server.servlet.context-path}/actuator/health
+eureka.instance.metadata-map.management.context-path=${server.servlet.context-path}/actuator
+eureka.instance.status-page-url=http://172.16.3.68:${server.port}${server.servlet.context-path}/actuator/info
+eureka.instance.metadata-map.management.api-docs=http://172.16.3.68:${server.port}${server.servlet.context-path}/doc.html
+eureka.instance.ip-address=172.16.3.68
+## ES properties:
+elasticsearch.username=elastic
+elasticsearch.password=a123456
+spring.elasticsearch.rest.uris=http://172.16.10.243:9200
+## unit(h)
+alertcall.es.synchrony.time=48
+#redis properties:
+spring.redis.database=1
+spring.redis.host=172.16.10.243
+spring.redis.port=6379
+spring.redis.password=yeejoin@2020
+spring.redis.lettuce.pool.max-active=200
+spring.redis.lettuce.pool.max-wait=-1
+spring.redis.lettuce.pool.max-idle=10
+spring.redis.lettuce.pool.min-idle=0
+
+## emqx properties:
+emqx.clean-session=true
+emqx.client-id=${spring.application.name}-${random.int[1024,65536]}
+emqx.broker=tcp://172.16.10.243:2883
+emqx.client-user-name=super
+emqx.client-password=123456
+emqx.keepAliveInterval=1000
+tzs.cti.appkey=4e805006-3fef-ae43-3915-a153731007c4
+tzs.cti.secretkey=7bd29115-99ee-4f7d-1fb1-7c4719d5f43a
+tzs.cti.url=http://36.41.172.83:8000
+##wechatToken
+tzs.wechat.token=yeejoin_2021
+##wechatTicketUrl
+tzs.wechat.ticketurl=https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token=
+#tzs.wechat.tempId.kr=rjW8x9rRitIpa21Jekyx2nzBzpJy7tycssCXSN4YhWw
+tzs.wechat.tempId.kr=bxchKYhYW7aHbGKM2pVyR_yY2-bG4sRMNU3ZRQbMKYM
+tzs.wechat.url.kr=tzs.yeeamos.com/persondetail.html
+#tzs.wechat.tempId.wx=ofBIZS8Bup9s0zKbrGa8BfhVhS18H_hyC_OYXuBN6hI
+tzs.wechat.tempId.wx=rags-expfNSBB-h2WenuBI2c6pCEndH4uwTtOqlHqDM
+tzs.wechat.url.wx=tzs.yeeamos.com/repairPersondetail.html
+#tzs.wechat.tempId.ts=Kr7lcV8g4g_lgyW_RpwnNgw_HDxxRuVx759EoFWrIfU
+tzs.wechat.tempId.ts=VWqgY-lXFt4dg2EL4pLjfDCBAU49Z0mRxVaQhAMMW8Q
+tzs.wechat.url.ts=tzs.yeeamos.com/taskComplaintDetail.html
+mqtt.topic.task.newtask=tzs-task-newtask
+mqtt.topic.task.personinfo=tzs-task-personinfo
+mqtt.topic.elevator.push=/tzs/tcb_elevator
+mqtt.topic.alertInfo.push=/tzs/tcb_alertInfo
+mqtt.topic.alertReport.push=/tzs/tcb_alertReport
+mqtt.topic.alertHeart.push=/tzs/tcb_alertHeart
+mqtt.topic.alertMatrix.push=/tzs/tcb_alertMatrix
+mqtt.topic.cti.push=/cti/record
+cti.user.name=tzs_cti
+cti.user.pwd=a1234567
+flc.sms.tempCode=SMS_TZS_0001
+## ??????id
+tzs.wechat.tempId.warning=-pHsHLIjW8j-_AemoZycf6Dmu6iYc-YWWaJ0cAPGeUY
+##??????
+tzs.wechat.tempId.supervise=P5XGbszS2Pc6kynvGjzPpZ--ikAwDZo6O7WdJ2EUxtE
+## ???????id???userId?
+tzs.wechat.test.userId=3413513
+##new properties
+org.filter.group.seq=1564150103147573249
+fileserver.domain=http://172.16.10.243:19000/
+log.level=INFO
+duty.seats.role.ids=1585956200472674305,1585956257590706177
+## ???? properties:
+rule.definition.load=false
+##rule.definition.model-package=com.yeejoin.amos.boot.module.jcs.api.dto
+rule.definition.default-agency=tzs
+rule.definition.local-ip=172.16.10.243
+# minio ??
+minio.endpoint=http://172.16.10.243:9000
+minio.accessKey=root
+minio.secretKey=Yeejoin@2020
+## \u7279\u79CD\u8BBE\u5907\u57DF\u540D
+tzs.domain=http://sxtzsb.sxsei.com
+
+outSystem.user.password=a1234560
+amos.system.user.app-key=AMOS_STUDIO
+amos.system.user.product=STUDIO_APP_WEB
+
+#Seata Config
+seata.tx-service-group= tzs-seata
+seata.service.grouplist.tzs-seata=172.16.10.243:8091
\ No newline at end of file

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/resources/application.properties

+spring.application.name=TZS-YS
+server.servlet.context-path=/ys
+server.port=11008
+spring.profiles.active=dev
+
+spring.feign.client.config.default.clockSkew=0m
+spring.jackson.time-zone=GMT+8
+spring.jackson.date-format=yyyy-MM-dd HH:mm:ss
+logging.config=classpath:logback-${spring.profiles.active}.xml
+mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
+
+logging.level.net.javacrumbs.shedlock=DEBUG
+##liquibase
+spring.liquibase.change-log = classpath:/db/changelog/changelog-master.xml
+spring.liquibase.enabled= false
+
+feign.client.config.default.connect-timeout=30000
+feign.client.config.default.read-timeout=30000
+
+## eureka properties:
+eureka.client.registry-fetch-interval-seconds=5
+eureka.instance.prefer-ip-address=true
+management.endpoint.health.show-details=always
+management.endpoints.web.exposure.include=*
+eureka.instance.health-check-url-path=/actuator/health
+eureka.instance.lease-expiration-duration-in-seconds=10
+eureka.instance.lease-renewal-interval-in-seconds=5
+eureka.instance.metadata-map.management.context-path=${server.servlet.context-path}/actuator
+eureka.instance.status-page-url-path=/actuator/info
+eureka.instance.metadata-map.management.api-docs=http://localhost:${server.port}${server.servlet.context-path}/doc.html
+#DB properties:
+spring.datasource.driver-class-name=org.postgresql.Driver
+spring.datasource.type=com.zaxxer.hikari.HikariDataSource
+spring.datasource.hikari.minimum-idle=10
+spring.datasource.hikari.maximum-pool-size=25
+spring.datasource.hikari.auto-commit=true
+spring.datasource.hikari.idle-timeout=30000
+spring.datasource.hikari.pool-name=DatebookHikariCP
+spring.datasource.hikari.max-lifetime=120000
+spring.datasource.hikari.connection-timeout=30000
+spring.datasource.hikari.connection-test-query=SELECT 1
+spring.datasource.schema=amos_tzs_biz
+
+spring.main.allow-bean-definition-overriding=true
+iot.fegin.name=AMOS-API-IOT
+
+equip.fegin.name=AMOS-EQUIPMANAGE
+
+supervision.feign.name = AMOS-SUPERVISION-API
+
+security.systemctl.name=AMOS-API-SYSTEMCTL
+
+jcs.company.topic.add=jcs/company/topic/add
+jcs.company.topic.delete=jcs/company/topic/delete
+## \uFFFD\u8C78\uFFFD\uFFFD\uFFFD\uFFFD\uFFFD\uFFFD\uFFFD\uD94E\uDE33\uFFFD\uFFFD\uFFFD\uFFFD\u0161\uFFFD\uFFFD\u3CA5\uFFFD\uFFFD\uFFFD\uFFFD\uFFFD\u58E9
+control.fegin.name=JCS-API-CONTROL
+## redis\uFFFD\uFFFD\u02B1\u02B1\uFFFD\uFFFD
+redis.cache.failure.time=10800
+failure.work.flow.processDefinitionKey=malfunction_repair
+video.fegin.name=video
+latentDanger.feign.name=AMOS-LATENT-DANGER
+Knowledgebase.fegin.name=AMOS-API-KNOWLEDGEBASE
+
+
+## \uFFFD\u8C78\uFFFD\uFFFD\u05AA\uFFFD\uFFFD\uFFFD\uFFFDv1
+inform.work.flow.processDefinitionKey=equipment_inform_process_v1
+
+## \uFFFD\uFFFD\uFFFD\uFFFD\uFFFD\uFFFD\u052E\uFFFD\uFFFD\uFFFD\u03F2\uFFFDID
+fire-rescue=1432549862557130753
+
+
+tzs.cti.appkey=4e805006-3fef-ae43-3915-a153731007c4
+tzs.cti.secretkey=7bd29115-99ee-4f7d-1fb1-7c4719d5f43a
+
+
+tzs.wechat.url=https://api.weixin.qq.com
+tzs.wechat.appid=wx79aca5bb1cb4af92
+tzs.wechat.secret=f3a12323ba731d282c3d4698c27c3e97
+
+##wechatToken
+tzs.wechat.token=yeejoin_2021
+##wechatTicketUrl
+tzs.wechat.ticketurl=https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token=
+
+#tzs.wechat.tempId.kr=rjW8x9rRitIpa21Jekyx2nzBzpJy7tycssCXSN4YhWw
+tzs.wechat.tempId.kr=bxchKYhYW7aHbGKM2pVyR_yY2-bG4sRMNU3ZRQbMKYM
+tzs.wechat.url.kr=tzs.yeeamos.com/persondetail.html
+#tzs.wechat.tempId.wx=ofBIZS8Bup9s0zKbrGa8BfhVhS18H_hyC_OYXuBN6hI
+tzs.wechat.tempId.wx=rags-expfNSBB-h2WenuBI2c6pCEndH4uwTtOqlHqDM
+tzs.wechat.url.wx=tzs.yeeamos.com/repairPersondetail.html
+#tzs.wechat.tempId.ts=Kr7lcV8g4g_lgyW_RpwnNgw_HDxxRuVx759EoFWrIfU
+tzs.wechat.tempId.ts=VWqgY-lXFt4dg2EL4pLjfDCBAU49Z0mRxVaQhAMMW8Q
+tzs.wechat.url.ts=tzs.yeeamos.com/taskComplaintDetail.html
+
+mqtt.topic.task.newtask=tzs-task-newtask
+
+mqtt.topic.task.personinfo=tzs-task-personinfo
+
+mqtt.topic.elevator.push=/tzs/tcb_elevator
+
+mqtt.topic.alertInfo.push=/tzs/tcb_alertInfo
+
+mqtt.topic.alertReport.push=/tzs/tcb_alertReport
+
+mqtt.topic.alertHeart.push=/tzs/tcb_alertHeart
+
+mqtt.topic.alertMatrix.push=/tzs/tcb_alertMatrix
+
+mqtt.topic.cti.push=/cti/record
+
+mqtt.topic.cyl.warning.push=/tzs/cyl_cyl_warning
+
+cti.user.name=tzs_cti
+
+cti.user.pwd=a1234567
+
+flc.sms.tempCode=SMS_TZS_0001
+### \u7BA1\u7406\u5458\u53D8\u66F4\u673A\u5668\u4EBA\u8D26\u53F7
+#tzs.admin.name=tzs_admin
+
+## \u0524\uFFFD\uFFFD\u0368\u05AA\u0123\uFFFD\uFFFDid
+tzs.wechat.tempId.warning=-pHsHLIjW8j-_AemoZycf6Dmu6iYc-YWWaJ0cAPGeUY
+##\uFFFD\uFFFD\uFFFD\uFFFD\uFFFD\uFFFD\uFFFD\uFFFD\u0368\u05AA
+tzs.wechat.tempId.supervise=P5XGbszS2Pc6kynvGjzPpZ--ikAwDZo6O7WdJ2EUxtE
+
+## \uFFFD\uFFFD\uFFFD\u06BA\u0172\uFFFD\uFFFD\uFFFD\uFFFD\u00FB\uFFFDid\uFFFD\uFFFD\u01BD\u0328userId\uFFFD\uFFFD
+tzs.wechat.test.userId=3393279
+
+
+amos.secret.key=qazknife4j.production=false
+
+knife4j.production=false
+knife4j.enable=true
+knife4j.basic.enable=true
+knife4j.basic.username=admin
+knife4j.basic.password=a1234560
+
+spring.security.user.name=admin
+spring.security.user.password=a1234560
+spring.security.user.roles=SBA_ADMIN
+
+## \u540E\u53F0\u6267\u884C\u673A\u5668\u4EBA\u8D26\u53F7\u914D\u7F6E
+amos.system.user.user-name=jyjg04
+amos.system.user.password=a1234560
+amos.system.user.app-key=AMOS_STUDIO
+amos.system.user.product=AMOS_STUDIO_WEB
+
+## ??????????????topic
+amos.operation.log=$share/${spring.application.name}//amos/operation/log
+amos.agency.code=tzs
+
+## ?????orgCode
+regulator.unit.code=50
+
+# \u82E5tzs\u548Cugp\u4E00\u8D77\uFF0C\u5219true
+is.ugp=false
+
+#\u5DE5\u4F5C\u53F0\u7528\u6237\u7EDF\u4E00\u663E\u793A\u5934\u50CF
+tzs.auth.user.photo=/public/common/userPic.png
+
+tzs.WxApp.appId=wx48a1b1915b10d14b
+tzs.WxApp.secret=ac4f4a9d3c97676badb70c19a2f37b16
+tzs.WxApp.grant-type=authorization_code
+
+amos.wechat.robot.user=we_robot
+amos.wechat.robot.password=a1234567
+
+feign.okhttp.enabled= true
\ No newline at end of file

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/resources/file.conf

+transport {
+  # tcp udt unix-domain-socket
+  type = "TCP"
+  #NIO NATIVE
+  server = "NIO"
+  #enable heartbeat
+  heartbeat = true
+  # the client batch send request enable
+  enableClientBatchSendRequest = true
+  #thread factory for netty
+  threadFactory {
+    bossThreadPrefix = "NettyBoss"
+    workerThreadPrefix = "NettyServerNIOWorker"
+    serverExecutorThread-prefix = "NettyServerBizHandler"
+    shareBossWorker = false
+    clientSelectorThreadPrefix = "NettyClientSelector"
+    clientSelectorThreadSize = 1
+    clientWorkerThreadPrefix = "NettyClientWorkerThread"
+    # netty boss thread size,will not be used for UDT
+    bossThreadSize = 1
+    #auto default pin or 8
+    workerThreadSize = "8"
+  }
+  shutdown {
+    # when destroy server, wait seconds
+    wait = 3
+  }
+  serialization = "seata"
+  compressor = "none"
+}
+service {
+  #transaction service group mapping
+  vgroupMapping.tzs-seata = "tzs-seata"
+  #only support when registry.type=file, please don't set multiple addresses
+  default.grouplist = "172.16.10.243:8091"
+  #degrade, current not support
+  enableDegrade = false
+  #disable seata
+  disableGlobalTransaction = false
+}
+
+client {
+  rm {
+    asyncCommitBufferLimit = 10000
+    lock {
+      retryInterval = 10
+      retryTimes = 30
+      retryPolicyBranchRollbackOnConflict = true
+    }
+    reportRetryCount = 5
+    tableMetaCheckEnable = false
+    reportSuccessEnable = false
+  }
+  tm {
+    commitRetryCount = 5
+    rollbackRetryCount = 5
+    default-global-transaction-timeout = 600  # 600秒
+  }
+  undo {
+    dataValidation = true
+    logSerialization = "protostuff"
+    logTable = "undo_log"
+  }
+  log {
+    exceptionRate = 100
+  }
+}
\ No newline at end of file

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/resources/logback-cluster.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<configuration debug="false">
+    <!--定义日志文件的存储地址 勿在 LogBack 的配置中使用相对路径-->
+    <property name="LOG_HOME" value="log" />
+    <!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符-->
+    <property name="LOG_PATTERN" value="%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %-50.50logger{50} - %msg [%file:%line] %n" />
+    <!-- 按照每天生成日志文件 -->
+    <appender name="FILE"  class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
+            <!--日志文件输出的文件名-->
+            <FileNamePattern>${LOG_HOME}/Tcm.log.%d{yyyy-MM-dd}.%i.log</FileNamePattern>
+            <!--日志文件保留天数-->
+            <MaxHistory>30</MaxHistory>
+            <!--日志文件大小-->
+            <MaxFileSize>30mb</MaxFileSize>
+        </rollingPolicy>
+        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
+            <pattern>${LOG_PATTERN}</pattern>
+        </encoder>
+    </appender>
+    <!-- 控制台输出 -->
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
+            <pattern>${LOG_PATTERN}</pattern>
+        </encoder>
+    </appender>
+<!--    &lt;!&ndash; ELK管理 &ndash;&gt;-->
+<!--    <appender name="ELK" class="net.logstash.logback.appender.LogstashTcpSocketAppender">-->
+<!--        <destination>172.16.10.210:4560</destination>-->
+<!--        <encoder charset="UTF-8" class="net.logstash.logback.encoder.LogstashEncoder"/>-->
+<!--    </appender>-->
+    <!--    show parameters for hibernate sql 专为 Hibernate 定制
+    <logger name="org.hibernate.type.descriptor.sql.BasicBinder"  level="TRACE" />
+    <logger name="org.hibernate.type.descriptor.sql.BasicExtractor"  level="DEBUG" />
+    <logger name="org.hibernate.SQL" level="DEBUG" />
+    <logger name="org.hibernate.engine.QueryParameters" level="DEBUG" />
+    <logger name="org.hibernate.engine.query.HQLQueryPlan" level="DEBUG" />
+    -->
+    <!--myibatis log configure-->
+    <logger name="com.apache.ibatis" level="debug"/>
+    <logger name="org.mybatis" level="debug" />
+    <logger name="java.sql.Connection" level="debug"/>
+    <logger name="java.sql.Statement" level="debug"/>
+    <logger name="java.sql.PreparedStatement" level="debug"/>
+    <logger name="org.springframework" level="debug"/>
+
+    <logger name="com.baomidou.mybatisplus" level="debug"/>
+    <logger name="org.apache.activemq" level="debug"/>
+    <logger name="org.typroject" level="debug"/>
+    <logger name="com.yeejoin" level="debug"/>
+
+    <!-- 日志输出级别 -->
+    <root level="error">
+        <!-- <appender-ref ref="FILE" /> -->
+        <appender-ref ref="STDOUT" />
+<!--        <appender-ref ref="ELK" />-->
+    </root>
+</configuration>
\ No newline at end of file

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/resources/logback-dev.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<configuration debug="false">
+    <!--定义日志文件的存储地址 勿在 LogBack 的配置中使用相对路径-->
+    <property name="LOG_HOME" value="log" />
+    <!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符-->
+    <property name="LOG_PATTERN" value="%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %-50.50logger{50} - %msg [%file:%line] %n" />
+    <!-- 按照每天生成日志文件 -->
+    <appender name="FILE"  class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
+            <!--日志文件输出的文件名-->
+            <FileNamePattern>${LOG_HOME}/ys.log.%d{yyyy-MM-dd}.%i.log</FileNamePattern>
+            <!--日志文件保留天数-->
+            <MaxHistory>30</MaxHistory>
+            <!--日志文件大小-->
+            <MaxFileSize>30mb</MaxFileSize>
+        </rollingPolicy>
+        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
+            <pattern>${LOG_PATTERN}</pattern>
+        </encoder>
+    </appender>
+    <!-- 控制台输出 -->
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
+            <pattern>${LOG_PATTERN}</pattern>
+        </encoder>
+    </appender>
+<!--    &lt;!&ndash; ELK管理 &ndash;&gt;-->
+<!--    <appender name="ELK" class="net.logstash.logback.appender.LogstashTcpSocketAppender">-->
+<!--        <destination>172.16.10.210:4560</destination>-->
+<!--        <encoder charset="UTF-8" class="net.logstash.logback.encoder.LogstashEncoder"/>-->
+<!--    </appender>-->
+    <!--    show parameters for hibernate sql 专为 Hibernate 定制
+    <logger name="org.hibernate.type.descriptor.sql.BasicBinder"  level="TRACE" />
+    <logger name="org.hibernate.type.descriptor.sql.BasicExtractor"  level="DEBUG" />
+    <logger name="org.hibernate.SQL" level="DEBUG" />
+    <logger name="org.hibernate.engine.QueryParameters" level="DEBUG" />
+    <logger name="org.hibernate.engine.query.HQLQueryPlan" level="DEBUG" />
+    -->
+    <!--myibatis log configure-->
+    <logger name="com.apache.ibatis" level="INFO"/>
+    <logger name="org.mybatis" level="INFO" />
+    <logger name="java.sql.Connection" level="INFO"/>
+    <logger name="java.sql.Statement" level="INFO"/>
+    <logger name="java.sql.PreparedStatement" level="INFO"/>
+    <logger name="org.springframework" level="INFO"/>
+
+    <logger name="com.baomidou.mybatisplus" level="INFO"/>
+    <logger name="org.apache.activemq" level="INFO"/>
+    <logger name="org.typroject" level="INFO"/>
+    <logger name="com.yeejoin" level="INFO"/>
+
+    <!-- 日志输出级别 -->
+    <root level="INFO">
+        <!-- <appender-ref ref="FILE" /> -->
+        <appender-ref ref="STDOUT" />
+<!--        <appender-ref ref="ELK" />-->
+    </root>
+</configuration>
\ No newline at end of file

amos-boot-system-tzs/amos-boot-module-ys/amos-boot-module-ys-biz/src/main/resources/registry.conf

+registry {
+  # file 、nacos 、eureka、redis、zk、consul、etcd3、sofa
+  type = "eureka"
+
+  nacos {
+    serverAddr = "localhost"
+    namespace = ""
+    cluster = "default"
+  }
+  eureka {
+    serviceUrl = "http://172.16.10.243:10001/eureka"
+    application = "default"
+    weight = "1"
+  }
+  redis {
+    serverAddr = "localhost:6379"
+    db = "0"
+    password = ""
+    cluster = "default"
+    timeout = "0"
+  }
+  zk {
+    cluster = "default"
+    serverAddr = "127.0.0.1:2181"
+    session.timeout = 6000
+    connect.timeout = 2000
+    username = ""
+    password = ""
+  }
+  consul {
+    cluster = "default"
+    serverAddr = "127.0.0.1:8500"
+  }
+  etcd3 {
+    cluster = "default"
+    serverAddr = "http://localhost:2379"
+  }
+  sofa {
+    serverAddr = "127.0.0.1:9603"
+    application = "default"
+    region = "DEFAULT_ZONE"
+    datacenter = "DefaultDataCenter"
+    cluster = "default"
+    group = "SEATA_GROUP"
+    addressWaitTime = "3000"
+  }
+  file {
+    name = "file.conf"
+  }
+}
+
+config {
+  # file、nacos 、apollo、zk、consul、etcd3、springCloudConfig
+  type = "file"
+
+  nacos {
+    serverAddr = "localhost"
+    namespace = ""
+    group = "SEATA_GROUP"
+  }
+  consul {
+    serverAddr = "127.0.0.1:8500"
+  }
+  apollo {
+    app.id = "seata-server"
+    apollo.meta = "http://192.168.1.204:8801"
+    namespace = "application"
+  }
+  zk {
+    serverAddr = "127.0.0.1:2181"
+    session.timeout = 6000
+    connect.timeout = 2000
+    username = ""
+    password = ""
+  }
+  etcd3 {
+    serverAddr = "http://localhost:2379"
+  }
+  file {
+    name = "file.conf"
+  }
+}

amos-boot-system-tzs/amos-boot-module-ys/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">
+    <parent>
+        <artifactId>amos-boot-system-tzs</artifactId>
+        <groupId>com.amosframework.boot</groupId>
+        <version>1.0.1</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <artifactId>amos-boot-module-ys</artifactId>
+    <description>验收模块</description>
+    <packaging>pom</packaging>
+    <version>1.0.1</version>
+    <modules>
+        <module>amos-boot-module-ys-api</module>
+        <module>amos-boot-module-ys-biz</module>
+    </modules>
+
+</project>
\ No newline at end of file

amos-boot-system-tzs/pom.xml

@@ -20,6 +20,7 @@
         <module>amos-boot-module-app</module>
         <module>amos-boot-module-tzspatrol</module>
         <module>amos-boot-module-statistics</module>
+        <module>amos-boot-module-ys</module>
     </modules>
     <properties>
         <amos.version.tzs>1.10.8-TZS</amos.version.tzs>