SpringBoot + MyBatis-Plus+DM8 +Elasic-job 通用代码框架

水深无声 2023-10-10 13:37 37阅读 0赞

**目录**

1、基础技术框架

2、完整pom.xml

3、初始化脚本

4、项目结构截图:

5、业务模块说明

6、通用模块说明

7、系统初始化配置

8、系统入口

9、配置参数和日志

10、Mapper 配置文件

11、定时任务实列化

12、程序效果截图：

--------------------

## 1、基础技术框架 ##

<table style="width:500px;"> 
 <tbody> 
  <tr> 
   <td>技术名称</td> 
   <td>版本</td> 
  </tr> 
  <tr> 
   <td>SpringBoot</td> 
   <td>2.1.9.RELEASE</td> 
  </tr> 
  <tr> 
   <td>MyBatis-plus</td> 
   <td>3.3.1</td> 
  </tr> 
  <tr> 
   <td>DM8</td> 
   <td>18</td> 
  </tr> 
  <tr> 
   <td>lombok</td> 
   <td>1.18.10</td> 
  </tr> 
  <tr> 
   <td>hutool-all</td> 
   <td>5.5.2</td> 
  </tr> 
  <tr> 
   <td>druid</td> 
   <td>1.2.3</td> 
  </tr> 
  <tr> 
   <td>swagger3</td> 
   <td>3.0.0</td> 
  </tr> 
  <tr> 
   <td>aop</td> 
   <td>1.9.4</td> 
  </tr> 
  <tr> 
   <td>fastjson</td> 
   <td>1.2.47</td> 
  </tr> 
  <tr> 
   <td>elastic-job</td> 
   <td>2.1.5</td> 
  </tr> 
 </tbody> 
</table>

## 2、完整pom.xml ##

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      <modelVersion>4.0.0</modelVersion>
      <groupId>com.building</groupId>
      <artifactId>digipower-building</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <packaging>jar</packaging>
      
      <parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>2.1.9.RELEASE</version>
    		<relativePath /> 
    	</parent>
     
    	<properties>
    		<java.version>1.8</java.version>
    		<maven-jar-plugin.version>3.1.1</maven-jar-plugin.version>
    	</properties>
     
    	<dependencies>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
     
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>
     
    		
    		<dependency>
    			<groupId>com.baomidou</groupId>
    			<artifactId>mybatis-plus-boot-starter</artifactId>
    			<version>3.3.1</version>
    		</dependency>
     
    		
    		<dependency>
    			<groupId>dm.jdbc</groupId>
      			<artifactId>DmJdbcDriver18</artifactId>
    		    <version>18</version>
    		</dependency>
    
     		
    		
    		<dependency>
    			<groupId>org.projectlombok</groupId>
    			<artifactId>lombok</artifactId>
    			<optional>true</optional>
    		</dependency>
    		
    		
    		<dependency>
    			<groupId>cn.hutool</groupId>
    			<artifactId>hutool-all</artifactId>
    			<version>5.5.2</version>
    		</dependency>
     
    		
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>druid-spring-boot-starter</artifactId>
    			<version>1.2.3</version>
    		</dependency>
    		
    		<dependency>
    			<groupId>io.springfox</groupId>
    			<artifactId>springfox-boot-starter</artifactId>
    			<version>3.0.0</version>
    			<exclusions>
    				<exclusion>
    					<groupId>org.springframework.plugin</groupId>
    					<artifactId>spring-plugin-core</artifactId>
    				</exclusion>
    				<exclusion>
    					<groupId>org.springframework.plugin</groupId>
    					<artifactId>spring-plugin-metadata</artifactId>
    				</exclusion>
    			</exclusions>
    		</dependency>
     
    		<dependency>
    			<groupId>org.springframework.plugin</groupId>
    			<artifactId>spring-plugin-core</artifactId>
    			<version>2.0.0.RELEASE</version>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.plugin</groupId>
    			<artifactId>spring-plugin-metadata</artifactId>
    			<version>2.0.0.RELEASE</version>
    		</dependency>
     
    		
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-aop</artifactId>
    		</dependency>
     
    		
    		<dependency>
    			<groupId>com.alibaba</groupId>
    			<artifactId>fastjson</artifactId>
    			<version>1.2.47</version>
    		</dependency>
    		
    		
    		 <dependency>
                <groupId>com.dangdang</groupId>
                <artifactId>elastic-job-lite-spring</artifactId>
                <version>2.1.5</version>
    		 </dependency> 
     
    	</dependencies>
     
     
    	<build>
    		<finalName>gcxt-building</finalName>
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    				<configuration>
    					<excludes>
    						<exclude>
    							<groupId>org.projectlombok</groupId>
    							<artifactId>lombok</artifactId>
    						</exclude>
    					</excludes>
    				</configuration>
    			</plugin>
    		</plugins>
    	</build>
    </project>

## 3、初始化脚本 ##

CREATE TABLE "SYSDBA"."SYS_BUILDING_INFO"
    (
    "SID" VARCHAR(50) NOT NULL,
    "DISTRICT" VARCHAR(50),
    "SUB_DISTRICT" VARCHAR(50),
    "BUSINESS_ID" VARCHAR(50),
    "BASIC_ID" VARCHAR(50),
    "TYPE" VARCHAR(50),
    "NAME" VARCHAR(50),
    "LOCATION" VARCHAR(500),
    "ATTRIBUTES" VARCHAR(500),
    CLUSTER PRIMARY KEY("SID")) STORAGE(ON "MAIN", CLUSTERBTR) ;
    
    COMMENT ON COLUMN "SYSDBA"."SYS_BUILDING_INFO"."ATTRIBUTES" IS '楼栋详情信息';
    COMMENT ON COLUMN "SYSDBA"."SYS_BUILDING_INFO"."BASIC_ID" IS '楼栋编码';
    COMMENT ON COLUMN "SYSDBA"."SYS_BUILDING_INFO"."BUSINESS_ID" IS '楼栋业务ID';
    COMMENT ON COLUMN "SYSDBA"."SYS_BUILDING_INFO"."DISTRICT" IS '行政区域';
    COMMENT ON COLUMN "SYSDBA"."SYS_BUILDING_INFO"."LOCATION" IS '楼栋地理位置';
    COMMENT ON COLUMN "SYSDBA"."SYS_BUILDING_INFO"."NAME" IS '楼栋名称';
    COMMENT ON COLUMN "SYSDBA"."SYS_BUILDING_INFO"."SID" IS '主键';
    COMMENT ON COLUMN "SYSDBA"."SYS_BUILDING_INFO"."SUB_DISTRICT" IS '区域街道';
    COMMENT ON COLUMN "SYSDBA"."SYS_BUILDING_INFO"."TYPE" IS '业务类型';

## 4、项目结构截图: ##

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5Zyo5aWL5paX55qE5aSn6YGT_size_9_color_FFFFFF_t_70_g_se_x_16][]

## 5、业务模块说明 ##

com.digipower.entity = 实体对象定义

com.digipower.mapper= 接口映射

com.digipower.service= 服务定义

com.digipower.service.impl= 服务实列化

com.digipower.controller=业务控制层

package com.digipower.entity;
    
    import java.io.Serializable;
    
    import com.baomidou.mybatisplus.annotation.TableName;
    import com.baomidou.mybatisplus.extension.activerecord.Model;
    
    import lombok.Builder;
    import lombok.Data;
    import lombok.EqualsAndHashCode;
    
    @Data
    @TableName("sys_building_info")
    @EqualsAndHashCode(callSuper = false)
    @Builder
    @SuppressWarnings("serial")
    public class BuildingInfo extends Model<BuildingInfo> implements Serializable{
    	private String sid;
    	
    	private String district;
    	
    	private String subDistrict;
    	
    	private String businessId;
    	
    	private String basicId;
    	
    	private String type;
    	
    	private String name;
    	
    	private String location;
    	
    	private String attributes;
    }

package com.digipower.mapper;
    
    import org.apache.ibatis.annotations.Mapper;
    
    import com.baomidou.mybatisplus.core.mapper.BaseMapper;
    import com.digipower.entity.BuildingInfo;
    
    @Mapper
    public interface BuildingInfoMapper extends BaseMapper<BuildingInfo> {
    
    }

package com.digipower.service;
    
    import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
    import com.baomidou.mybatisplus.extension.service.IService;
    import com.digipower.entity.BuildingInfo;
    
    public interface BuildingInfoService extends IService<BuildingInfo>  {
    	/**
    	 * 查询列表数据
    	 * 
    	 * @param building  楼栋信息 
    	 * @param current 当前页
    	 * @param size    每页显示条数
    	 * @return
    	 */
    	public Page<BuildingInfo> listData(BuildingInfo building, long current, long size);
    
    }

package com.digipower.service.impl;
    
    import org.springframework.stereotype.Service;
    
    import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
    import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
    import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
    import com.digipower.entity.BuildingInfo;
    import com.digipower.mapper.BuildingInfoMapper;
    import com.digipower.service.BuildingInfoService;
    
    import cn.hutool.core.util.StrUtil;
    
    @Service
    public class BuildingInfoServiceImpl extends ServiceImpl<BuildingInfoMapper, BuildingInfo> implements BuildingInfoService {
    
    	@Override
    	public Page<BuildingInfo> listData(BuildingInfo building, long current, long size) {
    		// TODO Auto-generated method stub
    		QueryWrapper<BuildingInfo> queryWrapper = new QueryWrapper<>();
    		if (null != building.getSid()) {
    			queryWrapper.eq("sid", building.getSid());
    		}
    		//district
    		if (StrUtil.isNotBlank(building.getDistrict())) {
    			queryWrapper.eq("district", building.getDistrict());
    		}
    		// 
    		if (StrUtil.isNotBlank(building.getSubDistrict())) {
    			queryWrapper.eq("sub_district", building.getSubDistrict());
    		}
    		if (StrUtil.isNotBlank(building.getName())) {
    			queryWrapper.like("name", building.getName());
    		}
    		return baseMapper.selectPage(new Page<>(current, size), queryWrapper);
    	}
    
    }

package com.digipower.controller;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestParam;
    import org.springframework.web.bind.annotation.ResponseBody;
    
    import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
    import com.digipower.common.Response;
    import com.digipower.entity.BuildingInfo;
    import com.digipower.service.BuildingInfoService;
    
    @Controller
    @RequestMapping(value = "building")
    public class BuildingInfoController {
    	@Autowired
    	private BuildingInfoService buildingInfoService;
    	
    	@RequestMapping(value = "listData")
    	@ResponseBody
    	public Response<Page<BuildingInfo>> listData(BuildingInfo auth, @RequestParam(name = "page") long current,
    			@RequestParam(name = "limit") long size) {
    		Page<BuildingInfo> page = buildingInfoService.listData(auth, current, size);
    		return Response.success(page);
    	}
    
    }

## 6、通用模块说明 ##

com.digipower.common= 响应封装和UUID生成工具

com.digipower.common.elastic.job= 定时任务框架封装

package com.digipower.common;
    
    import java.io.PrintWriter;
    
    import javax.servlet.ServletResponse;
    
    import cn.hutool.json.JSONUtil;
    import lombok.AllArgsConstructor;
    import lombok.Getter;
    import lombok.NoArgsConstructor;
    import lombok.Setter;
    
    @Getter
    @Setter
    @AllArgsConstructor
    @NoArgsConstructor
    public class Response<T> {
    	/**
    	 * 响应码
    	 */
    	private int code;
    
    	/**
    	 * 响应消息体
    	 */
    	private String msg;
    
    	/**
    	 * 响应数据
    	 */
    	private T data;
    
    	/**
    	 * 失败响应
    	 * 
    	 * @param code 响应码
    	 * @param msg  响应消息体
    	 * @param data 响应数据
    	 * @return
    	 */
    	public static <T> Response<T> error(int code, String msg, T data) {
    		return new Response<T>(code, msg, data);
    	}
    
    	/**
    	 * 失败响应
    	 * 
    	 * @param msg 响应消息体
    	 * @return
    	 */
    	public static <T> Response<T> error(String msg) {
    		return new Response<T>(500, msg, null);
    	}
    
    	/**
    	 * 成功响应
    	 * 
    	 * @param data 响应数据
    	 * @return
    	 */
    	public static <T> Response<T> success(T data) {
    		return new Response<T>(200, null, data);
    	}
    
    	/**
    	 * 成功响应
    	 * 
    	 * @param msg 响应消息体
    	 * @return
    	 */
    	public static <T> Response<T> success(String msg) {
    		return new Response<T>(200, msg, null);
    	}
    
    	/**
    	 * 成功响应
    	 * 
    	 * @param msg  响应消息体
    	 * @param data 响应数据
    	 * @return
    	 */
    	public static <T> Response<T> success(String msg, T data) {
    		return new Response<T>(200, msg, data);
    	}
    
    	/**
    	 * Response输出Json格式
    	 * 
    	 * @param response
    	 * @param data     返回数据
    	 */
    	public static void responseJson(ServletResponse response, Object data) {
    		PrintWriter out = null;
    		try {
    			response.setCharacterEncoding("UTF-8");
    			response.setContentType("application/json");
    			out = response.getWriter();
    			out.println(JSONUtil.toJsonStr(data));
    			out.flush();
    		} catch (Exception e) {
    		} finally {
    			if (out != null) {
    				out.close();
    			}
    		}
    	}
    }

package com.digipower.common;
    
    import java.util.UUID;
    
    /**
     * UUID 工具类
     * @author zzg
     *
     */
    public class UUIDUtils {
    	 public static String getUUID(){
             return UUID.randomUUID().toString().replace("-", "");
        }
    }

package com.digipower.common.elastic.job;
    
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    import com.baomidou.mybatisplus.core.toolkit.StringUtils;
    import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperConfiguration;
    import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperRegistryCenter;
     
    @Configuration
    public class ElasticRegCenterConfig {
     
    	// zookeeper地址信息
    	@Value("${zookeeper.serverLists}")
    	private String serverList;
    	// 命名空间
    	@Value("${zookeeper.namespace}")
    	private String namespace;
    	
    	@Value("${zookeeper.digest}")
    	private String digest;
     
    	@Bean(initMethod = "init")
    	public ZookeeperRegistryCenter regCenter() {
    		ZookeeperConfiguration zookeeperConfiguration = new ZookeeperConfiguration(serverList, namespace);
    		if(StringUtils.isNotEmpty(digest)){
    			zookeeperConfiguration.setDigest(digest);
    		}
    		
    		return new ZookeeperRegistryCenter(zookeeperConfiguration);
    	}
    
    }

package com.digipower.common.elastic.job;
    
    import javax.annotation.PostConstruct;
    import org.apache.commons.lang3.StringUtils;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.annotation.Configuration;
    import com.dangdang.ddframe.job.api.simple.SimpleJob;
    import com.dangdang.ddframe.job.config.JobCoreConfiguration;
    import com.dangdang.ddframe.job.config.simple.SimpleJobConfiguration;
    import com.dangdang.ddframe.job.lite.config.LiteJobConfiguration;
    import com.dangdang.ddframe.job.lite.spring.api.SpringJobScheduler;
    import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperRegistryCenter;
    
    /**
     * 分布式任务实例化
     * @author zzg
     *
     */
    @Configuration
    public class ElasticSchedulerInit {
    	// 日志记录
    	public static final Logger log = LoggerFactory.getLogger(ElasticSchedulerInit.class);
     
    	@Autowired
    	private ZookeeperRegistryCenter regCenter;
     
    	@Autowired
    	private ApplicationContext applicationContext;
     
    	@PostConstruct
    	public void startSimpleJob() {
    		applicationContext.getBeansWithAnnotation(ElasticSchedulerParam.class).forEach((className, obj) -> {
    			ElasticSchedulerParam config = obj.getClass().getAnnotation(ElasticSchedulerParam.class);
    			String cron = StringUtils.defaultIfBlank(config.cron(), config.value());
    			int shardingTotalCount = config.shardingTotalCount();
    			String shardingItemParameters = config.shardingItemParameters();
    			MyElasticJobListener elasticJobListener = new MyElasticJobListener();
    			SimpleJob simpleJob = (SimpleJob) obj;
    			new SpringJobScheduler(simpleJob, regCenter,
    					getLiteJobConfiguration(simpleJob.getClass(), cron, shardingTotalCount, shardingItemParameters),
    					elasticJobListener).init();
    		});
    	}
     
    	// 私有方法
    	private LiteJobConfiguration getLiteJobConfiguration(final Class<? extends SimpleJob> jobClass, final String cron,
    			final int shardingTotalCount, final String shardingItemParameters) {
    		return LiteJobConfiguration
    				.newBuilder(
    						new SimpleJobConfiguration(
    								JobCoreConfiguration.newBuilder(jobClass.getName(), cron, shardingTotalCount)
    										.shardingItemParameters(shardingItemParameters).build(),
    								jobClass.getCanonicalName()))
    				.overwrite(true).build();
    	}
     
    }

package com.digipower.common.elastic.job;
    
    import java.lang.annotation.Documented;
    import java.lang.annotation.ElementType;
    import java.lang.annotation.Inherited;
    import java.lang.annotation.Retention;
    import java.lang.annotation.RetentionPolicy;
    import java.lang.annotation.Target;
     
    import org.springframework.core.annotation.AliasFor;
     
    /**
     * 分布式定时任务注解
     * 
     * @author zzg
     *
     */
     
    @Target({ ElementType.TYPE })
    @Retention(RetentionPolicy.RUNTIME)
    @Inherited
    @Documented
    public @interface ElasticSchedulerParam {
    	@AliasFor("value")
    	String cron() default "";
     
    	@AliasFor("cron")
    	String value() default "";
     
    	int shardingTotalCount() default 1;
     
    	String shardingItemParameters() default "0=0";
    }

package com.digipower.common.elastic.job;
    
    import java.text.SimpleDateFormat;
    import java.util.Date;
     
    import org.apache.commons.lang3.StringUtils;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
     
    import com.dangdang.ddframe.job.executor.ShardingContexts;
    import com.dangdang.ddframe.job.lite.api.listener.ElasticJobListener;
     
    /**
     * 自定义ElasticJob 定时器
     * @author zzg
     *
     */
    public class MyElasticJobListener implements ElasticJobListener {
    	private static final Logger logger = LoggerFactory.getLogger(MyElasticJobListener.class);
     
    	/**
    	 * 长日期格式
    	 */
    	public static String TIME_FORMAT = "yyyy-MM-dd HH:mm:ss";
    	private long beginTime = 0;
     
    	@Override
    	public void beforeJobExecuted(ShardingContexts shardingContexts) {
    		beginTime = System.currentTimeMillis();
     
    		logger.info("===>{} JOB BEGIN TIME: {} <===", shardingContexts.getJobName(), beginTime);
    	}
     
    	@Override
    	public void afterJobExecuted(ShardingContexts shardingContexts) {
    		long endTime = System.currentTimeMillis();
    		logger.info("===>{} JOB END TIME: {},TOTAL CAST: {} <===", shardingContexts.getJobName(), endTime,
    				endTime - beginTime);
    	}
     
    	/**
    	 * 将长整型数字转换为日期格式的字符串
    	 *
    	 * @param time
    	 * @param format
    	 * @return
    	 */
    	public static String convert2String(long time, String format) {
    		if (time > 0l) {
    			if (StringUtils.isBlank(format))
    				format = TIME_FORMAT;
     
    			SimpleDateFormat sf = new SimpleDateFormat(format);
    			Date date = new Date(time);
     
    			return sf.format(date);
    		}
    		return "";
    	}
     
    }

## 7、系统初始化配置 ##

com.digipower.config = 系统配置化

package com.digipower.config;
    
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.transaction.annotation.EnableTransactionManagement;
    
    import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor;
    
    @Configuration
    @EnableTransactionManagement(proxyTargetClass = true)
    public class MybatisPlusConfig {
    	/**
    	 * 注入分页插件
    	 */
    	@Bean
    	public PaginationInterceptor paginationInterceptor() {
    		return new PaginationInterceptor();
    	}
    }

## 8、系统入口 ##

package com.digipower;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    /**
     * 
     * @ClassName:  BuildingApplication   
     * @Description: 程序启动入口   
     */
    @SpringBootApplication
    public class BuildingApplication {
    
    	public static void main(String[] args) {
    		// TODO Auto-generated method stub
    		SpringApplication.run(BuildingApplication.class, args);
    	}
    
    }

## 9、配置参数和日志 ##

application.properties

# \u6307\u5B9A\u670D\u52A1\u7AEF\u53E3
    server.port=5088
    # \u6307\u5B9A\u65E5\u5FD7\u6587\u4EF6\u914D\u7F6E
    logging.config=classpath:logback.xml
    
    # DM setting
    spring.datasource.url=jdbc:dm://127.0.0.1:5256/SYSDBA
    spring.datasource.username=SYSDBA
    spring.datasource.password=SYSDBA
    spring.datasource.driver-class-name=dm.jdbc.driver.DmDriver
    # druid \u6570\u636E\u5E93\u8FDE\u63A5\u6C60\u914D\u7F6E
    # \u4E0B\u9762\u4E3A\u8FDE\u63A5\u6C60\u7684\u8865\u5145\u8BBE\u7F6E\uFF0C\u5E94\u7528\u5230\u4E0A\u9762\u6240\u6709\u6570\u636E\u6E90\u4E2D
    # \u521D\u59CB\u5316\u5927\u5C0F\uFF0C\u6700\u5C0F\uFF0C\u6700\u5927
    spring.datasource.druid.initialSize=10
    spring.datasource.druid.minIdle=10
    spring.datasource.druid.maxActive=200
    # \u914D\u7F6E\u83B7\u53D6\u8FDE\u63A5\u7B49\u5F85\u8D85\u65F6\u7684\u65F6\u95F4
    spring.datasource.druid.maxWait=6000
    # \u914D\u7F6E\u95F4\u9694\u591A\u4E45\u624D\u8FDB\u884C\u4E00\u6B21\u68C0\u6D4B\uFF0C\u68C0\u6D4B\u9700\u8981\u5173\u95ED\u7684\u7A7A\u95F2\u8FDE\u63A5\uFF0C\u5355\u4F4D\u662F\u6BEB\u79D2
    spring.datasource.druid.timeBetweenEvictionRunsMillis=60000
    # \u914D\u7F6E\u4E00\u4E2A\u8FDE\u63A5\u5728\u6C60\u4E2D\u6700\u5C0F\u751F\u5B58\u7684\u65F6\u95F4\uFF0C\u5355\u4F4D\u662F\u6BEB\u79D2
    spring.datasource.druid.minEvictableIdleTimeMillis=100000
    spring.datasource.druid.validationQuery=SELECT 1 FROM DUAL
    spring.datasource.druid.testWhileIdle=true
    spring.datasource.druid.testOnBorrow=false
    spring.datasource.druid.testOnReturn=false
    # \u6253\u5F00PSCache\uFF0C\u5E76\u4E14\u6307\u5B9A\u6BCF\u4E2A\u8FDE\u63A5\u4E0APSCache\u7684\u5927\u5C0F
    spring.datasource.druid.poolPreparedStatements=true
    spring.datasource.druid.maxPoolPreparedStatementPerConnectionSize=20
    # \u914D\u7F6E\u76D1\u63A7\u7EDF\u8BA1\u62E6\u622A\u7684filters\uFF0C\u53BB\u6389\u540E\u76D1\u63A7\u754C\u9762sql\u65E0\u6CD5\u7EDF\u8BA1\uFF0C'wall'\u7528\u4E8E\u9632\u706B\u5899
    spring.datasource.druid.filters=stat,slf4j
    # \u901A\u8FC7connectProperties\u5C5E\u6027\u6765\u6253\u5F00mergeSql\u529F\u80FD\uFF1B\u6162SQL\u8BB0\u5F55
    spring.datasource.druid.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
    
    # \u914D\u7F6EMyBatis-plus
    mybatis-plus.mapper-locations=classpath:mapper/*.xml
    mybatis-plus.global-config.db-config.id-type=AUTO
    
     
    # elastic-job\u5B9A\u65F6\u4EFB\u52A1\u914D\u7F6E\u53C2\u6570
    zookeeper.serverLists=127.0.0.1:2181
    zookeeper.namespace=building_elasticjob 
    zookeeper.digest=
    
    # setting
    building.url=http://127.0.0.1/gw/BUILDING/shenzhenS/LOU
    building.key=KZZfAHBau2Xme6irarMoD1ohume1E7DoGzQdGeJCE1GgnPIOmvz2U94Cf9vqM72jnjKgoyHmppBgwwLi6wZED0a/RtzEZ7grD04kOLFcLAE=

logback.xml

<?xml version="1.0" encoding="UTF-8"?> 
      
      
      
      
      
      
      
    <configuration scan="true" scanPeriod="60 seconds" debug="false">  
          
        <property name="log_dir" value="/logs/building" />  
          
        <property name="maxHistory" value="30"/>  
      
      
          
        <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">  
              
            <encoder>  
                <pattern>%d{yyyy-MM-dd HH:mm:ss} [%thread] %-5level %logger -%msg%n</pattern>  
            </encoder>  
        </appender>  
          
          
          
          
        <appender name="ERROR" class="ch.qos.logback.core.rolling.RollingFileAppender">  
              
            <filter class="ch.qos.logback.classic.filter.LevelFilter">  
                <level>ERROR</level>  
                <onMatch>ACCEPT</onMatch>  
                <onMismatch>DENY</onMismatch>  
            </filter>  
              
            <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">  
                  
                <fileNamePattern>${log_dir}/%d{yyyy-MM-dd}/error.log</fileNamePattern>  
                  
                <maxHistory>${maxHistory}</maxHistory>  
            </rollingPolicy>  
                      
            <encoder>  
                <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger - %msg%n</pattern>  
            </encoder>  
        </appender>  
          
          
          
        <appender name="WARN" class="ch.qos.logback.core.rolling.RollingFileAppender">  
              
            <filter class="ch.qos.logback.classic.filter.LevelFilter">  
                <level>WARN</level>  
                <onMatch>ACCEPT</onMatch>  
                <onMismatch>DENY</onMismatch>  
            </filter>  
            <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">  
                <fileNamePattern>${log_dir}/%d{yyyy-MM-dd}/warn.log  
                </fileNamePattern>  
                <maxHistory>${maxHistory}</maxHistory>  
            </rollingPolicy>  
            <encoder>  
                <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger - %msg%n</pattern>  
            </encoder>  
        </appender>  
          
          
          
        <appender name="INFO" class="ch.qos.logback.core.rolling.RollingFileAppender">  
              
            <filter class="ch.qos.logback.classic.filter.LevelFilter">  
                <level>INFO</level>  
                <onMatch>ACCEPT</onMatch>  
                <onMismatch>DENY</onMismatch>  
            </filter>  
            <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">  
                <fileNamePattern>${log_dir}/%d{yyyy-MM-dd}/info.log  
                </fileNamePattern>  
                <maxHistory>${maxHistory}</maxHistory>  
            </rollingPolicy>  
            <encoder>  
                <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger - %msg%n</pattern>  
            </encoder>  
        </appender>  
          
          
          
        <appender name="DEBUG" class="ch.qos.logback.core.rolling.RollingFileAppender">  
            <filter class="ch.qos.logback.classic.filter.LevelFilter">  
                <level>DEBUG</level>  
                <onMatch>ACCEPT</onMatch>  
                <onMismatch>DENY</onMismatch>  
            </filter>  
            <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">  
                <fileNamePattern>${log_dir}/%d{yyyy-MM-dd}/debug.log  
                </fileNamePattern>  
                <maxHistory>${maxHistory}</maxHistory>  
            </rollingPolicy>  
            <encoder>  
                <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger - %msg%n</pattern>  
            </encoder>  
        </appender>  
        
        <logger name="org.springframework.web"/>
        <logger name="com.digipower" />
    		
          
          
        <root level="INFO">  
              
            <appender-ref ref="STDOUT" />  
              
            <appender-ref ref="ERROR" />  
            <appender-ref ref="INFO" />  
            <appender-ref ref="WARN" />  
            <appender-ref ref="DEBUG" />  
        </root>  
    </configuration>

## 10、Mapper 配置文件 ##

BuildingInfoMapper.xml

<?xml version="1.0" encoding="UTF-8"?>
    <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    <mapper namespace="com.digipower.mapper.BuildingInfoMapper">
      
    </mapper>

## 11、定时任务实列化 ##

com.digipower.job = 定时任务实列化对象

package com.digipower.job;
    
    import java.util.ArrayList;
    import java.util.Date;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.stereotype.Component;
    
    import com.dangdang.ddframe.job.api.ShardingContext;
    import com.dangdang.ddframe.job.api.simple.SimpleJob;
    import com.digipower.common.UUIDUtils;
    import com.digipower.common.elastic.job.ElasticSchedulerParam;
    import com.digipower.entity.BuildingInfo;
    import com.digipower.service.BuildingInfoService;
    
    import cn.hutool.core.collection.CollectionUtil;
    import cn.hutool.core.util.StrUtil;
    import cn.hutool.http.HttpUtil;
    import cn.hutool.json.JSONArray;
    import cn.hutool.json.JSONObject;
    
    @ElasticSchedulerParam(cron = "* */2 * * * ?", shardingTotalCount = 1, shardingItemParameters = "0=Core")
    @Component
    public class BuildingJobDemo implements SimpleJob {
    	private static final Logger log = LoggerFactory.getLogger(BuildingJobDemo.class);
    
    	@Value("${building.url}")
    	private String url;
    	@Value("${building.key}")
    	private String key;
    
    	@Autowired
    	private BuildingInfoService buildingInfoService;
    
    	@Override
    	public void execute(ShardingContext shardingContext) {
    		// TODO Auto-generated method stub
    		int num = buildingInfoService.count();
    		System.out.println("楼栋数据总数:" + num);
    		// 存在记录不执行插入操作
    		
    			// hutool 发起网络请求
    			Map<String, Object> map = new HashMap<>();// 存放参数
    			map.put("pageNum", 1);
    			map.put("pageSize", 500);
    			map.put("district", "龙岗区");
    			map.put("subDistrict", "坂田街道");
    			map.put("operation", "list");
    
    			HashMap<String, String> headers = new HashMap<>();// 存放请求头，可以存放多个请求头
    			headers.put("Content-Type", "application/json");
    			headers.put("szvsud-license-key", key);
    			
    			// 发送POST请求并接收响应数据
    			String result = HttpUtil.createPost(url).addHeaders(headers).form(map).execute().body();
    			
    			if (StrUtil.isNotEmpty(result)) {
    				analyzeJSON(result);
    			}
    		
    
    	}
    
    	public void analyzeJSON(String str) {
    		List<BuildingInfo> list = new ArrayList<BuildingInfo>();
    		System.out.println("后台响应:" + str);
    		JSONObject json = new JSONObject(str);
    		boolean success = json.getBool("success");
    		System.out.println("楼栋数据请求是否成功:" + success);
    		if (success) {
    			JSONArray array = json.getJSONArray("dataList");
    			for (int i = 0; i < array.size(); i++) {
    				JSONObject jsonObject = array.getJSONObject(i);
    				BuildingInfo obj = BuildingInfo.builder().attributes(jsonObject.getJSONObject("attributes").toString())
    						.basicId(jsonObject.getStr("basicId")).businessId(jsonObject.getStr("id")).district("龙岗区")
    						.location(jsonObject.getJSONObject("location").toString()).name(jsonObject.getStr("name"))
    						.sid(UUIDUtils.getUUID()).subDistrict("坂田街道").type(jsonObject.getStr("type")).build();
    				list.add(obj);
    			}
    		}
    
    		if (CollectionUtil.isNotEmpty(list)) {
    			buildingInfoService.saveBatch(list);
    		}
    
    	}
    
    }

## 12、程序效果截图： ##

[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5Zyo5aWL5paX55qE5aSn6YGT_size_9_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/c805bde16b494c2a9e0093f57368f578.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5Zyo5aWL5paX55qE5aSn6YGT,size_9,color_FFFFFF,t_70,g_se,x_16