springcloud自动生成脚手架搭建（二）

客官°小女子只卖身不卖艺 2022-06-02 07:39 214阅读 0赞

完成之后的前台页面展示：

测试地址 ：dota2info.cn/index

![SouthEast][]

1.配置pom.xml

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
    
            </dependency>
            <dependency>
                <groupId>com.baomidou</groupId>
                <artifactId>mybatisplus-spring-boot-starter</artifactId>
                <version>1.0.4</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-thymeleaf</artifactId>
            </dependency>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>${mybatis.spring.boot.version}</version>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>${mysql.version}</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid</artifactId>
                <version>${druid.version}</version>
            </dependency>
            <dependency>
                <groupId>commons-lang</groupId>
                <artifactId>commons-lang</artifactId>
                <version>${commons.lang.version}</version>
            </dependency>
            <dependency>
                <groupId>commons-io</groupId>
                <artifactId>commons-io</artifactId>
                <version>${commons.io.version}</version>
            </dependency>
            <dependency>
                <groupId>commons-configuration</groupId>
                <artifactId>commons-configuration</artifactId>
                <version>${commons.configuration.version}</version>
            </dependency>
    
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>fastjson</artifactId>
                <version>${fastjson.version}</version>
            </dependency>
            <dependency>
                <artifactId>velocity</artifactId>
                <groupId>org.apache.velocity</groupId>
                <version>2.0</version>
            </dependency>
            <dependency>
                <groupId>com.baomidou</groupId>
                <artifactId>mybatis-plus</artifactId>
                <version>2.1.7</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-thymeleaf</artifactId>
            </dependency>
            <dependency>
                <groupId>net.sourceforge.nekohtml</groupId>
                <artifactId>nekohtml</artifactId>
                <version>1.9.22</version>
            </dependency>
            <dependency>
                <groupId>org.apache.velocity</groupId>
                <artifactId>velocity-engine-core</artifactId>
                <version>2.0</version>
            </dependency>
            <dependency>
                <groupId>com.gameley</groupId>
                <artifactId>gameley-common</artifactId>
                <version>1.0</version>
            </dependency>
            <dependency>
                <groupId>org.dom4j</groupId>
                <artifactId>dom4j</artifactId>
                <version>2.0.0</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-test</artifactId>
                <version>4.3.13.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-test</artifactId>
                <version>1.5.5.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-test</artifactId>
            </dependency>

数据库使用mysql,使用mybatis-plus作为连接数据库工具

2.配置application.yml

# Tomcat
    server:
        tomcat:
            max-threads: 10
            min-spare-threads: 10
        port: 7777
    
    # mysql
    spring:
        datasource:
            type: com.alibaba.druid.pool.DruidDataSource
            driverClassName: com.mysql.jdbc.Driver
            url: jdbc:mysql://localhost:3306/ag_admin?useUnicode=true&characterEncoding=UTF-8&useSSL=false
            username: root
            password: 123456
        jackson:
            time-zone: GMT+8
            date-format: yyyy-MM-dd HH:mm:ss
        thymeleaf:
            mode: LEGACYHTML5
            cache: false
    
    # Mybatis配置
    mybatis:
        mapperLocations: classpath:mapper/*.xml
    #mybatis
    mybatis-plus:
      mapper-locations: classpath:mapper/*.xml
      #实体扫描，多个package用逗号或者分号分隔
      typeAliasesPackage: com.gameley.generator.entity
      global-config:
        #主键类型  0:"数据库ID自增", 1:"用户输入ID",2:"全局唯一ID (数字类型唯一ID)", 3:"全局唯一ID UUID";
        id-type: 0
        #字段策略 0:"忽略判断",1:"非 NULL 判断"),2:"非空判断"
        field-strategy: 2
        #驼峰下划线转换
        db-column-underline: true
        #刷新mapper 调试神器
        refresh-mapper: true
        #数据库大写下划线转换
        #capital-mode: true
        #序列接口实现类配置
        #key-generator: cn.jeefast.xxx
        #逻辑删除配置
        logic-delete-value: 0
        logic-not-delete-value: 1
        #自定义填充策略接口实现
        #meta-object-handler: cn.jeefast.xxx
        #自定义SQL注入器
        #sql-injector: cn.jeefast.xxx
      configuration:
        map-underscore-to-camel-case: true
        cache-enabled: false

3.编写主要的生成工具类：

package com.gameley.generator.utils;
    
    import com.baomidou.mybatisplus.plugins.Page;
    import com.gameley.generator.entity.ColumnEntity;
    import com.gameley.generator.entity.TableEntity;
    import org.apache.commons.configuration.Configuration;
    import org.apache.commons.configuration.ConfigurationException;
    import org.apache.commons.configuration.PropertiesConfiguration;
    import org.apache.commons.io.IOUtils;
    import org.apache.commons.lang.StringUtils;
    import org.apache.commons.lang.WordUtils;
    import org.apache.velocity.Template;
    import org.apache.velocity.VelocityContext;
    import org.apache.velocity.app.Velocity;
    
    import java.io.File;
    import java.io.IOException;
    import java.io.StringWriter;
    import java.util.*;
    import java.util.zip.ZipEntry;
    import java.util.zip.ZipOutputStream;
    
    /**
     * 代码生成器   工具类
     *
     * @author chenshun
     * @email sunlightcs@gmail.com
     * @date 2016年12月19日 下午11:40:24
     */
    public class GeneratorUtils {
    
        public static List<String> getTemplates() {
            List<String> templates = new ArrayList<String>();
            templates.add("template/index.vue.vm");
            templates.add("template/mapper.xml.vm");
            templates.add("template/entity.java.vm");
            templates.add("template/mapper.java.vm");
            templates.add("template/controller.java.vm");
            templates.add("template/service.java.vm");
            templates.add("template/serviceImpl.java.vm");
            return templates;
        }
    
        /**
         * 生成代码
         */
        public static void generatorCode(Map<String, String> table,
                                         List<Map<String, String>> columns, ZipOutputStream zip) {
            //配置信息
            Configuration config = getConfig();
    
            //表信息
            TableEntity tableEntity = new TableEntity();
            tableEntity.setTableName(table.get("tableName"));
            tableEntity.setComments(table.get("tableComment"));
            //表名转换成Java类名
            String className = tableToJava(tableEntity.getTableName(), config.getString("tablePrefix"));
            tableEntity.setClassName(className);
            tableEntity.setClassname(StringUtils.uncapitalize(className));
    
            //列信息
            List<ColumnEntity> columsList = new ArrayList<>();
            for (Map<String, String> column : columns) {
                ColumnEntity columnEntity = new ColumnEntity();
                columnEntity.setColumnName(column.get("columnName"));
                columnEntity.setDataType(column.get("dataType"));
                columnEntity.setComments(column.get("columnComment"));
                columnEntity.setExtra(column.get("extra"));
    
                //列名转换成Java属性名
                String attrName = columnToJava(columnEntity.getColumnName());
                columnEntity.setAttrName(attrName);
                columnEntity.setAttrname(StringUtils.uncapitalize(attrName));
    
                //列的数据类型，转换成Java类型
                String attrType = config.getString(columnEntity.getDataType(), "unknowType");
                columnEntity.setAttrType(attrType);
    
                //是否主键
                if ("PRI".equalsIgnoreCase(column.get("columnKey")) && tableEntity.getPk() == null) {
                    tableEntity.setPk(columnEntity);
                }
    
                columsList.add(columnEntity);
            }
            tableEntity.setColumns(columsList);
    
            //没主键，则第一个字段为主键
            if (tableEntity.getPk() == null) {
                tableEntity.setPk(tableEntity.getColumns().get(0));
            }
    
            //设置velocity资源加载器
            Properties prop = new Properties();
            prop.put("file.resource.loader.class", "org.apache.velocity.runtime.resource.loader.ClasspathResourceLoader");
            Velocity.init(prop);
    
            //封装模板数据
            Map<String, Object> map = new HashMap<>();
            map.put("tableName", tableEntity.getTableName());
            map.put("comments", tableEntity.getComments());
            map.put("pk", tableEntity.getPk());
            map.put("className", tableEntity.getClassName());
            map.put("classname", tableEntity.getClassname());
            map.put("pathName", tableEntity.getClassname().toLowerCase());
            map.put("columns", tableEntity.getColumns());
            map.put("package", config.getString("package"));
            map.put("author", config.getString("author"));
            map.put("email", config.getString("email"));
            map.put("datetime", DateUtils.format(new Date(), DateUtils.DATE_TIME_PATTERN));
            map.put("moduleName", config.getString("mainModule"));
            map.put("secondModuleName", toLowerCaseFirstOne(className));
            map.put("enableCache",false);  //不开启二级缓存
            map.put("baseResultMap",true);
    
            VelocityContext context = new VelocityContext(map);
    
            //获取模板列表
            List<String> templates = getTemplates();
            for (String template : templates) {
                //渲染模板
                StringWriter sw = new StringWriter();
                Template tpl = Velocity.getTemplate(template, "UTF-8");
                tpl.merge(context, sw);
    
                try {
                    //添加到zip
                    zip.putNextEntry(new ZipEntry(getFileName(template, tableEntity.getClassName(), config.getString("package"), config.getString("mainModule"))));
                    IOUtils.write(sw.toString(), zip, "UTF-8");
                    IOUtils.closeQuietly(sw);
                    zip.closeEntry();
                } catch (IOException e) {
                    throw new RuntimeException("渲染模板失败，表名：" + tableEntity.getTableName(), e);
                }
            }
        }
    
    
        /**
         * 列名转换成Java属性名
         */
        public static String columnToJava(String columnName) {
            return WordUtils.capitalizeFully(columnName, new char[]{'_'}).replace("_", "");
        }
    
        /**
         * 表名转换成Java类名
         */
        public static String tableToJava(String tableName, String tablePrefix) {
            if (StringUtils.isNotBlank(tablePrefix)) {
                tableName = tableName.replace(tablePrefix, "");
            }
            return columnToJava(tableName);
        }
    
        /**
         * 获取配置信息
         */
        public static Configuration getConfig() {
            try {
                return new PropertiesConfiguration("generator.properties");
            } catch (ConfigurationException e) {
                throw new RuntimeException("获取配置文件失败，", e);
            }
        }
    
        /**
         * 获取文件名
         */
        public static String getFileName(String template, String className, String packageName, String moduleName) {
            String packagePath = "main" + File.separator + "java" + File.separator;
            String frontPath = "ui" + File.separator;
            if (StringUtils.isNotBlank(packageName)) {
                packagePath += packageName.replace(".", File.separator) + File.separator;
            }
    
            if (template.contains("index.vue.vm")) {
                return frontPath + "views" + File.separator + moduleName + File.separator + toLowerCaseFirstOne(className) + File.separator + "index.vue";
            }
    
            if (template.contains("service.java.vm")) {
                return packagePath + "service" + File.separator + className + "Service.java";
            }
            if (template.contains("mapper.java.vm")) {
                return packagePath + "dao" + File.separator + className + "Dao.java";
            }
            if (template.contains("entity.java.vm")) {
                return packagePath + "entity" + File.separator + className + ".java";
            }
            if (template.contains("controller.java.vm")) {
                return packagePath + "controller" + File.separator + className + "Controller.java";
            }
            if (template.contains("serviceImpl.java.vm")) {
                return packagePath + "service" + File.separator +"impl"+File.separator+ className + "ServiceImpl.java";
            }
            if (template.contains("mapper.xml.vm")) {
                return "main" + File.separator + "resources" + File.separator + "mapper" + File.separator + className + "Mapper.xml";
            }
    
            return null;
        }
    
        //首字母转小写
        public static String toLowerCaseFirstOne(String s) {
            if (Character.isLowerCase(s.charAt(0))) {
                return s;
            } else {
                return (new StringBuilder()).append(Character.toLowerCase(s.charAt(0))).append(s.substring(1)).toString();
            }
        }
    
    }

其余部分及生成模板详见：https://gitee.com/lwydyby/springcloud-adplatform

\----  2018-01-10------

增加springcloud-bus，以实现自动配置

1.在两个工程的pom.xml中引入

<dependency>
       <groupId>org.springframework.cloud</groupId>
       <artifactId>spring-cloud-starter-bus-amqp</artifactId>
    </dependency>
    
    <dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>

2.在config的配置中加入

rabbitmq:
            host: rabbitmq   # 登录 Rabbitmq 后台管理页面地址为：http://localhost:15672
            port: 5672
            username: guest   # 默认账户
            password: guest   # 默认密码

3.在generator增加config配置类 （这里只做了对数据库的动态配置）

package com.gameley.generator.config;
    
    import java.sql.SQLException;
    
    import javax.sql.DataSource;
    
    
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.cloud.context.config.annotation.RefreshScope;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.Primary;
    
    import com.alibaba.druid.pool.DruidDataSource;
    
    import lombok.extern.slf4j.Slf4j;
    
    /**
     *
     * 配置数据库
     * @author wwmxd
     * @version 1.2.0
     */
    @Slf4j
    @Configuration
    @RefreshScope
    public class DruidConfiguration {
        @Value("${spring.datasource.url}")
        private String dbUrl;
        @Value("${spring.datasource.username}")
        private String username;
        @Value("${spring.datasource.password}")
        private String password;
      
    
    
        @Bean     //声明其为Bean实例
        @Primary  //在同样的DataSource中，首先使用被标注的DataSource
        @RefreshScope
        public DataSource dataSource(){
            DruidDataSource datasource = new DruidDataSource();
            datasource.setUrl(dbUrl);
            datasource.setUsername(username);
            datasource.setPassword(password);
            return datasource;
        }
    }

4.配置github或者码云上的项目管理，增加WebHooks，来主动推送更新

增加的url,例如：

http://\{ip\}:8888/bus/refresh

如需设置密码，则在config中增加配置

encrypt:
      key: 123456

[SouthEast]: /images/20220602/b0a2785ba8f54f1e89f47a48bee104f0.png