5 Commits

Author SHA1 Message Date
杨黄林
32d3de7550 Merge remote-tracking branch 'gitea/master'
# Conflicts:
#	README.md
2022-11-30 15:24:14 +08:00
杨黄林
bb2ddfc34a 新增 格式化时,可以传入年、月、日 2022-11-30 14:48:18 +08:00
3615ed9eec 更新 'README.md' 2022-07-09 09:55:55 +08:00
53ac87f0e8 更新 'README.md' 2022-07-09 09:42:22 +08:00
6dc6498e6c generate方法增加无序号参数withOutSeq;基础配置中可以配置年、月不足2位时是否补零 2022-07-09 09:35:59 +08:00
9 changed files with 392 additions and 259 deletions

176
README.md
View File

@@ -4,11 +4,13 @@
用于生成全局自增序号,跳过的序号可以回收使用。 用于生成全局自增序号,跳过的序号可以回收使用。
***本生成器内部使用transactionTemplate进行事务管理如果你项目中给使用此生成器的方法或类加了`@Transactional`注解则需将新建一个Service来专门负责调用此生成器的方法同时要给新建的类增加`@Transactional`注解,并设置`propagation = Propagation.NOT_SUPPORTED`***
--- ---
使用方法: 使用方法:
+ 在项目中放置jar包的地方把seq-1.7.2.jar、seq-1.7.2-sources.jar、seq-1.7.2-pom.xml复制过去 + 在项目中放置jar包的地方把seq-1.9.2.jar、seq-1.9.2-sources.jar、seq-1.9.2-pom.xml复制过去
+ 在pom.xml中增加以下内容然后执行maven命令mvn clean + 在pom.xml中增加以下内容然后执行maven命令mvn clean
```xml ```xml
@@ -18,7 +20,7 @@
<dependency> <dependency>
<groupId>com.yanghuanglin</groupId> <groupId>com.yanghuanglin</groupId>
<artifactId>seq</artifactId> <artifactId>seq</artifactId>
<version>1.7.2</version> <version>1.9.2</version>
<exclusions> <exclusions>
<!-- 如若你项目中有引用spring-jdbc则需要排除seq的jdbc依赖 --> <!-- 如若你项目中有引用spring-jdbc则需要排除seq的jdbc依赖 -->
<exclusion> <exclusion>
@@ -50,13 +52,13 @@
</goals> </goals>
<configuration> <configuration>
<!-- ${project.basedir}表示当前项目的根目录 --> <!-- ${project.basedir}表示当前项目的根目录 -->
<file>${project.basedir}/lib/seq-1.7.2.jar</file> <file>${project.basedir}/lib/seq-1.9.2.jar</file>
<pomFile>${project.basedir}/lib/seq-1.7.2-pom.xml</pomFile> <pomFile>${project.basedir}/lib/seq-1.9.2-pom.xml</pomFile>
<sources>${project.basedir}/lib/seq-1.7.2-sources.jar</sources> <sources>${project.basedir}/lib/seq-1.9.2-sources.jar</sources>
<repositoryLayout>default</repositoryLayout> <repositoryLayout>default</repositoryLayout>
<groupId>com.yanghuanglin</groupId> <groupId>com.yanghuanglin</groupId>
<artifactId>seq</artifactId> <artifactId>seq</artifactId>
<version>1.7.2</version> <version>1.9.2</version>
<packaging>jar</packaging> <packaging>jar</packaging>
<generatePom>true</generatePom> <generatePom>true</generatePom>
</configuration> </configuration>
@@ -68,78 +70,7 @@
</project> </project>
``` ```
+ springboot中配置方式一(优先):直接注入已有jdbcTemplate和transactionTemplate + springboot中配置方式注入已有的dataSource或自行构建dataSource通过dataSource自动生成jdbcTemplate和transactionTemplate
```java
package com.yanghuanglin.springseq.baseConfig;
import com.yanghuanglin.seq.baseConfig.GeneratorConfig;
import com.yanghuanglin.seq.baseConfig.TableConfig;
import com.yanghuanglin.seq.generator.Generator;
import com.yanghuanglin.seq.generator.impl.SequencesGenerator;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.transaction.support.TransactionTemplate;
import javax.annotation.Resource;
/**
* 基于已有的jdbcTemplate和transactionTemplate一般如果引用了spring的数据库操作如jpa、mybatis都可以直接注入
*/
@Configuration
public class SeqGeneratorConfig {
/**
* 注入已有的数据库操作模板
*/
@Resource
private JdbcTemplate jdbcTemplate;
/**
* 注入已有的事务操作模板
*/
@Resource
private TransactionTemplate transactionTemplate;
/**
* 序号表配置类
*/
@Bean
public TableConfig tableConfig() {
TableConfig tableConfig = new TableConfig();
//自定义表名、字段名
tableConfig.setTable("sequences");
tableConfig.setKeyColumn("SEQUENCE_KEY");
tableConfig.setTypeColumn("SEQUENCE_TYPE");
tableConfig.setSeqColumn("NEXT_ID");
tableConfig.setCreateTimeColumn("CREATE_TIME");
return tableConfig;
}
/**
* 序号生成器配置类
* @param tableConfig 序号表配置类
*/
@Bean
public GeneratorConfig generatorConfig(TableConfig tableConfig) {
GeneratorConfig generatorConfig = new GeneratorConfig();
generatorConfig.setJdbcTemplate(jdbcTemplate);
generatorConfig.setTransactionTemplate(transactionTemplate);
generatorConfig.setTableConfig(tableConfig);
return generatorConfig;
}
/**
* 注册序号生成器类
* @param generatorConfig 序号生成器配置类
*/
@Bean
public Generator generator(GeneratorConfig generatorConfig) {
return new SequencesGenerator(generatorConfig);
}
}
```
+ springboot中配置方式二注入已有的dataSource或自行构建dataSource通过dataSource自动生成jdbcTemplate和transactionTemplate
```java ```java
package com.yanghuanglin.springseq.baseConfig; package com.yanghuanglin.springseq.baseConfig;
@@ -160,7 +91,7 @@ import javax.sql.DataSource;
@Configuration @Configuration
public class SeqGeneratorConfig { public class SeqGeneratorConfig {
/** /**
* 注入已有的数据源,果没有,也可以自行构建 * 注入已有的数据源,果没有,也可以自行构建
*/ */
@Resource @Resource
private DataSource dataSource; private DataSource dataSource;
@@ -276,18 +207,14 @@ GeneratorConfig配置项通过set方法设置
| 配置项 | 类型 | 默认值 | 说明 | | 配置项 | 类型 | 默认值 | 说明 |
|---------------------|------------------------------------------------------------------|------------------|------------------| |---------------------|------------------------------------------------------------------|------------------|------------------|
| dataSource | javax.sql.DataSource | null | 数据源 | | dataSource | javax.sql.DataSource | null | 数据源 |
| jdbcTemplate | org.springframework.jdbc.core.JdbcTemplate | null | 数据库操作模板 | | monthZeroFilling | Boolean | true | 月份不足2位时自动补零 |
| transactionTemplate | org.springframework.jdbc.core.JdbcTemplate | null | 事务操作模板 | | dayZeroFilling | Boolean | true | 当前日期不足2位时自动补零 |
| transactionManager | org.springframework.jdbc.datasource.DataSourceTransactionManager | null | 事务管理器 |
| autoCreate | Boolean | true | 开启自动建表 | | autoCreate | Boolean | true | 开启自动建表 |
| step | Integer | 1 | 序号增加时的步长 | | step | Integer | 1 | 序号增加时的步长 |
| type | String | DEFAULT | 默认序号类型 | | type | String | DEFAULT | 默认序号类型 |
| minLength | Integer | 1 | 默认序号格式化后长度,不足的补零 | | minLength | Integer | 1 | 默认序号格式化后长度,不足的补零 |
| tableConfig | com.yanghuanglin.seq.baseConfig.TableConfig | TableConfig的默认配置 | 表配置 | | tableConfig | com.yanghuanglin.seq.baseConfig.TableConfig | TableConfig的默认配置 | 表配置 |
以上配置中jdbcTemplate和transactionTemplate优先级最高如果jdbcTemplate、transactionTemplate、dataSource、transactionManager同时配置则dataSource和transactionManager无效
可进行这几种组合dataSource+autoCreate+step+minLength+tableConfigjdbcTemplate+transactionTemplate+autoCreate+step+minLength+tableConfigjdbcTemplate+transactionManager+autoCreate+step+minLength+tableConfig
--- ---
Generator方法如下 Generator方法如下
@@ -304,6 +231,14 @@ import com.yanghuanglin.seq.po.SequencesUnused;
import java.util.Date; import java.util.Date;
public interface Generator { public interface Generator {
/**
* 判断格式定义中是否有序号
*
* @param pattern 格式
* @return 是否包含序号
*/
boolean containSeq(String pattern);
/** /**
* 根据传入的key和type生成可用的序号对象。 * 根据传入的key和type生成可用的序号对象。
* <p/> * <p/>
@@ -312,9 +247,15 @@ public interface Generator {
* 如果根据key和默认的{@link GeneratorConfig#getType()}在{@link Sequences}中找到了记录,且在{@link SequencesUnused}也找到了记录,说明该组合生成的序号有部分未使用,返回的是{@link SequencesUnused}中找到的seq最小的序号对象。同时会将{@link SequencesUnused}中找到的seq最小的记录删除然后写入到{@link SequencesUnlock}中。 * 如果根据key和默认的{@link GeneratorConfig#getType()}在{@link Sequences}中找到了记录,且在{@link SequencesUnused}也找到了记录,说明该组合生成的序号有部分未使用,返回的是{@link SequencesUnused}中找到的seq最小的序号对象。同时会将{@link SequencesUnused}中找到的seq最小的记录删除然后写入到{@link SequencesUnlock}中。
* <p/> * <p/>
* *
* @param key 数据字典中的编码 * @param key 数据字典中的编码
* @param withOutSeq 序号对象不包含序号,其值通过{@link #containSeq(String)}来判断
* @return 可用的序号对象 * @return 可用的序号对象
*/ */
Sequences generate(String key, Boolean withOutSeq);
/**
* 同 {@link #generate(String, Boolean)}第二个参数默认为false
*/
Sequences generate(String key); Sequences generate(String key);
/** /**
@@ -325,26 +266,38 @@ public interface Generator {
* 如果根据key和type在{@link Sequences}中找到了记录,且在{@link SequencesUnused}也找到了记录,说明该组合生成的序号有部分未使用,返回的是{@link SequencesUnused}中找到的seq最小的序号对象。同时会将{@link SequencesUnused}中找到的seq最小的记录删除然后写入到{@link SequencesUnlock}中。 * 如果根据key和type在{@link Sequences}中找到了记录,且在{@link SequencesUnused}也找到了记录,说明该组合生成的序号有部分未使用,返回的是{@link SequencesUnused}中找到的seq最小的序号对象。同时会将{@link SequencesUnused}中找到的seq最小的记录删除然后写入到{@link SequencesUnlock}中。
* <p/> * <p/>
* *
* @param key 数据字典中的编码 * @param key 数据字典中的编码
* @param type 序号类型 * @param type 序号类型
* @param withOutSeq 序号对象不包含序号,其值通过{@link #containSeq(String)}来判断
* @return 可用的序号对象 * @return 可用的序号对象
*/ */
Sequences generate(String key, String type, Boolean withOutSeq);
/**
* 同{@link #generate(String, String, Boolean)}第三个参数默认为false
*/
Sequences generate(String key, String type); Sequences generate(String key, String type);
/** /**
* 返回根据{@link #generate(String, String)}得到的序号对象,补零后的序号字符串 * 返回根据{@link #generate(String, String, Boolean)}得到的序号对象,补零后的序号字符串
* <p/> * <p/>
* 如生成的为3而minLength为5则返回的是00003 * 如生成的为3而minLength为5则返回的是00003
* *
* @param key 数据字典中的编码 * @param key 数据字典中的编码
* @param type 序号类型 * @param type 序号类型
* @param minLength 序号数字最小长度 * @param minLength 序号数字最小长度
* @param withOutSeq 序号对象不包含序号,其值通过{@link #containSeq(String)}来判断
* @return 补零后的字符串 * @return 补零后的字符串
*/ */
String generate(String key, String type, Integer minLength, Boolean withOutSeq);
/**
* 同{@link #generate(String, String, Integer, Boolean)}第四个参数默认为false
*/
String generate(String key, String type, Integer minLength); String generate(String key, String type, Integer minLength);
/** /**
* 将{@link #generate(String, String)}得到的序号对象格式化为补零后的序号字符串,其最小长度通过{@link BaseConfig#getMinLength()}设定。实际上只会用到{@link Sequences#getSeq()}属性 * 将{@link #generate(String, String, Boolean)}得到的序号对象格式化为补零后的序号字符串,其最小长度通过{@link BaseConfig#getMinLength()}设定。实际上只会用到{@link Sequences#getSeq()}属性
* <p/> * <p/>
* pattern支持{@link FormatPlaceholder#YEAR}(当前年份)、{@link FormatPlaceholder#MONTH}}(当前月份)、{@link FormatPlaceholder#DAY}}(当前日期)、{@link FormatPlaceholder#SEQ}}(生成的字符串序号)几个枚举值通过{@link FormatPlaceholder#getPlaceholder()}得到的字符串 * pattern支持{@link FormatPlaceholder#YEAR}(当前年份)、{@link FormatPlaceholder#MONTH}}(当前月份)、{@link FormatPlaceholder#DAY}}(当前日期)、{@link FormatPlaceholder#SEQ}}(生成的字符串序号)几个枚举值通过{@link FormatPlaceholder#getPlaceholder()}得到的字符串
* *
@@ -355,7 +308,7 @@ public interface Generator {
String format(Sequences sequences, String pattern); String format(Sequences sequences, String pattern);
/** /**
* 将{@link #generate(String, String)}得到的序号对象格式化为补零后的序号字符串。实际上只会用到{@link Sequences#getSeq()}属性 * 将{@link #generate(String, String, Boolean)}得到的序号对象格式化为补零后的序号字符串。实际上只会用到{@link Sequences#getSeq()}属性
* <p/> * <p/>
* pattern支持{@link FormatPlaceholder#YEAR}(当前年份)、{@link FormatPlaceholder#MONTH}}(当前月份)、{@link FormatPlaceholder#DAY}}(当前日期)、{@link FormatPlaceholder#SEQ}}(生成的字符串序号)几个枚举值通过{@link FormatPlaceholder#getPlaceholder()}得到的字符串 * pattern支持{@link FormatPlaceholder#YEAR}(当前年份)、{@link FormatPlaceholder#MONTH}}(当前月份)、{@link FormatPlaceholder#DAY}}(当前日期)、{@link FormatPlaceholder#SEQ}}(生成的字符串序号)几个枚举值通过{@link FormatPlaceholder#getPlaceholder()}得到的字符串
* *
@@ -430,6 +383,26 @@ public interface Generator {
*/ */
String format(Long seq, String start, Integer minLength, String pattern); String format(Long seq, String start, Integer minLength, String pattern);
/**
* 将生成的序号对象格式化为指定格式
* <p/>
* pattern支持{@link FormatPlaceholder#YEAR}(当前年份)、{@link FormatPlaceholder#MONTH}}(当前月份)、{@link FormatPlaceholder#DAY}}(当前日期)、{@link FormatPlaceholder#SEQ}}(生成的字符串序号)几个枚举值通过{@link FormatPlaceholder#getPlaceholder()}得到的字符串
* <p/>
* seq为1,start为6minLength为4pattern为#year##month##day##seq#则会格式化为2022013060001。此序号含义如下
* <p/>
* 序号格式:[年][月][日][固定6开头][序号1最小位数为4位不足4位则补零]
*
* @param seq 需要格式化的序号
* @param start 序号格式化后以什么字符串开头
* @param minLength 序号最小长度,不足的会补零
* @param pattern 序号格式
* @param year 格式化时使用的年
* @param month 格式化时使用的月
* @param day 格式化时使用的日
* @return 格式化后的序号字符串
*/
String format(Long seq, String start, Integer minLength, String pattern, Integer year, Integer month, Integer day);
/** /**
* 将已格式化的序号解析为序号对象 * 将已格式化的序号解析为序号对象
* <p/> * <p/>
@@ -452,7 +425,7 @@ public interface Generator {
/** /**
* 锁定指定序号,在序号生成后,调用该序号的逻辑完成后需要执行此方法 * 锁定指定序号,在序号生成后,调用该序号的逻辑完成后需要执行此方法
* <p/> * <p/>
* 如办理案件时,先调用{@link #generate(String, String)}或者{@link #generate(String, String, Integer)}生成了序号,之后对案件进行了入库,如果入库完毕,则将该序号锁定,说明这个序号已被使用 * 如办理案件时,先调用{@link #generate(String, String, Boolean)}或者{@link #generate(String, String, Integer, Boolean)}生成了序号,之后对案件进行了入库,如果入库完毕,则将该序号锁定,说明这个序号已被使用
* <p/> * <p/>
* 注意,此处的锁定非数据库中锁定,而是{@link SequencesUnused}和{@link SequencesUnlock}中均不存在key、type、seq相同的记录视为锁定。因此此处实际是把这两个表中的记录均删除了 * 注意,此处的锁定非数据库中锁定,而是{@link SequencesUnused}和{@link SequencesUnlock}中均不存在key、type、seq相同的记录视为锁定。因此此处实际是把这两个表中的记录均删除了
* *
@@ -477,7 +450,7 @@ public interface Generator {
* <p/> * <p/>
* {@link SequencesUnlock}中未通过{@link #lock(Sequences)}方法锁定的序号会一直存在,调用此方法会将里面的所有序号都移动到{@link SequencesUnused}中,下次生成序号时优先从{@link SequencesUnused}获取。 * {@link SequencesUnlock}中未通过{@link #lock(Sequences)}方法锁定的序号会一直存在,调用此方法会将里面的所有序号都移动到{@link SequencesUnused}中,下次生成序号时优先从{@link SequencesUnused}获取。
*/ */
void release(); boolean release();
/** /**
* 释放指定时间段内未使用的序号 * 释放指定时间段内未使用的序号
@@ -487,7 +460,7 @@ public interface Generator {
* @param begin 开始时间 * @param begin 开始时间
* @param end 结束时间 * @param end 结束时间
*/ */
void release(Date begin, Date end); boolean release(Date begin, Date end);
/** /**
* 释放从开始时间开始,到现在时间之间未使用的序号。结束时间为方法执行时的时间 * 释放从开始时间开始,到现在时间之间未使用的序号。结束时间为方法执行时的时间
@@ -508,7 +481,7 @@ public interface Generator {
* *
* @param sequences 需要释放的序号。一般是一个通过{@link Sequences#setKey(String)}、{@link Sequences#setType(String)}、{@link Sequences#setSeq(Long)}三方法一起手动构建或通过{@link Sequences#Sequences(String, String, Long)}构造方法构建的实例对象 * @param sequences 需要释放的序号。一般是一个通过{@link Sequences#setKey(String)}、{@link Sequences#setType(String)}、{@link Sequences#setSeq(Long)}三方法一起手动构建或通过{@link Sequences#Sequences(String, String, Long)}构造方法构建的实例对象
*/ */
void release(Sequences sequences); boolean release(Sequences sequences);
/** /**
* 忽略{@link Sequences#getSeq()}来释放指定序号。一般用于业务对象删除后,对应序号需要回收使用时。 * 忽略{@link Sequences#getSeq()}来释放指定序号。一般用于业务对象删除后,对应序号需要回收使用时。
@@ -518,17 +491,17 @@ public interface Generator {
* @param sequences 需要释放的序号。一般是一个通过{@link Sequences#setKey(String)}、{@link Sequences#setType(String)}、{@link Sequences#setSeq(Long)}三方法一起手动构建或通过{@link Sequences#Sequences(String, String, Long)}构造方法构建的实例对象 * @param sequences 需要释放的序号。一般是一个通过{@link Sequences#setKey(String)}、{@link Sequences#setType(String)}、{@link Sequences#setSeq(Long)}三方法一起手动构建或通过{@link Sequences#Sequences(String, String, Long)}构造方法构建的实例对象
* @param ignoreSeq 是否忽略序号 * @param ignoreSeq 是否忽略序号
*/ */
void release(Sequences sequences, boolean ignoreSeq); boolean release(Sequences sequences, boolean ignoreSeq);
/** /**
* 清空所有闲置序号和未锁定序号 * 清空所有闲置序号和未锁定序号
*/ */
void clear(); boolean clear();
/** /**
* 清空指定时间段内闲置序号和未锁定序号 * 清空指定时间段内闲置序号和未锁定序号
*/ */
void clear(Date begin, Date end); boolean clear(Date begin, Date end);
/** /**
* 清空从开始时间到限制时间之间闲置序号和未锁定序号,结束时间为方法执行时的时间 * 清空从开始时间到限制时间之间闲置序号和未锁定序号,结束时间为方法执行时的时间
@@ -545,5 +518,4 @@ public interface Generator {
void clearBefore(Date end); void clearBefore(Date end);
} }
``` ```

View File

@@ -4,7 +4,7 @@
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<groupId>com.yanghuanglin</groupId> <groupId>com.yanghuanglin</groupId>
<artifactId>seq</artifactId> <artifactId>seq</artifactId>
<version>1.7.2</version> <version>1.9.2</version>
<name>seq</name> <name>seq</name>
<description>seq</description> <description>seq</description>
<properties> <properties>

View File

@@ -28,6 +28,8 @@ public class BaseConfig {
private Integer step; private Integer step;
private String type; private String type;
private Integer minLength; private Integer minLength;
private Boolean monthZeroFilling;
private Boolean dayZeroFilling;
private BaseConfig() { private BaseConfig() {
} }
@@ -48,10 +50,10 @@ public class BaseConfig {
synchronized (BaseConfig.class) { synchronized (BaseConfig.class) {
if (instance == null) { if (instance == null) {
instance = new BaseConfig(); instance = new BaseConfig();
instance.init(generatorConfig);
} }
} }
} }
instance.init(generatorConfig);
return instance; return instance;
} }
@@ -125,46 +127,47 @@ public class BaseConfig {
return minLength; return minLength;
} }
public Boolean getMonthZeroFilling() {
if (monthZeroFilling == null)
throw new NullPointerException("请先初始化BaseConfig");
return monthZeroFilling;
}
public void setMonthZeroFilling(Boolean monthZeroFilling) {
this.monthZeroFilling = monthZeroFilling;
}
public Boolean getDayZeroFilling() {
if (dayZeroFilling == null)
throw new NullPointerException("请先初始化BaseConfig");
return dayZeroFilling;
}
public void setDayZeroFilling(Boolean dayZeroFilling) {
this.dayZeroFilling = dayZeroFilling;
}
public void setMinLength(Integer minLength) { public void setMinLength(Integer minLength) {
this.minLength = minLength; this.minLength = minLength;
} }
private void init(GeneratorConfig generatorConfig) { private void init(GeneratorConfig generatorConfig) {
//数据库操作模板 //数据
JdbcTemplate jdbcTemplate = generatorConfig.getJdbcTemplate(); DataSource dataSource = generatorConfig.getDataSource();
if (dataSource == null)
if (jdbcTemplate == null) { //若数据库操作模板为空,也没有配置数据源,则抛出异常
//数据源 throw new NullPointerException("数据源不能为空");
DataSource dataSource = generatorConfig.getDataSource(); //否则以数据源创建数据库操作模板
if (dataSource == null) JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
//若数据库操作模板为空,也没有配置数据源,则抛出异常 DataSourceTransactionManager transactionManager = new DataSourceTransactionManager(dataSource);
throw new NullPointerException("数据源不能为空"); this.transactionTemplate = new TransactionTemplate(transactionManager);
//否则以数据源创建数据库操作模板
jdbcTemplate = new JdbcTemplate(dataSource);
}
if (generatorConfig.getTransactionTemplate() == null) {
//若没有配置事务操作模板,则从配置中取事务管理器
DataSourceTransactionManager transactionManager = generatorConfig.getTransactionManager();
if (transactionManager == null) {
//若未配置事务管理器,则通过数据源新建
DataSource dataSource = jdbcTemplate.getDataSource();
if (dataSource == null)
throw new NullPointerException("数据源不能为空");
transactionManager = new DataSourceTransactionManager(dataSource);
}
//通过事务管理器创建事务操作模板
transactionTemplate = new TransactionTemplate(transactionManager);
} else {
//获取事务操作模板
transactionTemplate = generatorConfig.getTransactionTemplate();
}
this.sequencesDao = new SequencesDaoImpl(jdbcTemplate, generatorConfig.getTableConfig()); this.sequencesDao = new SequencesDaoImpl(jdbcTemplate, generatorConfig.getTableConfig());
this.sequencesUnusedDao = new SequencesUnusedDaoImpl(jdbcTemplate, generatorConfig.getTableConfig()); this.sequencesUnusedDao = new SequencesUnusedDaoImpl(jdbcTemplate, generatorConfig.getTableConfig());
this.sequencesUnlockDao = new SequencesUnlockDaoImpl(jdbcTemplate, generatorConfig.getTableConfig()); this.sequencesUnlockDao = new SequencesUnlockDaoImpl(jdbcTemplate, generatorConfig.getTableConfig());
this.step = generatorConfig.getStep(); this.step = generatorConfig.getStep();
this.type = generatorConfig.getType(); this.type = generatorConfig.getType();
this.minLength = generatorConfig.getMinLength(); this.minLength = generatorConfig.getMinLength();
this.monthZeroFilling = generatorConfig.getMonthZeroFilling();
this.dayZeroFilling = generatorConfig.getDayZeroFilling();
} }
} }

View File

@@ -1,9 +1,5 @@
package com.yanghuanglin.seq.config; package com.yanghuanglin.seq.config;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.support.TransactionTemplate;
import javax.sql.DataSource; import javax.sql.DataSource;
/** /**
@@ -18,21 +14,6 @@ public class GeneratorConfig {
*/ */
private DataSource dataSource; private DataSource dataSource;
/**
* 数据库操作模板
*/
private JdbcTemplate jdbcTemplate;
/**
* 事务处理模板
*/
private TransactionTemplate transactionTemplate;
/**
* 事务管理器
*/
private DataSourceTransactionManager transactionManager;
/** /**
* 自动创建表 * 自动创建表
*/ */
@@ -51,7 +32,17 @@ public class GeneratorConfig {
/** /**
* 默认序号类型 * 默认序号类型
*/ */
private String type="DEFAULT"; private String type = "DEFAULT";
/**
* 月份是否补零。为false时1月显示为1为true时1月显示为01
*/
private Boolean monthZeroFilling = true;
/**
* 日期是否补零。为false时1日显示为1为true时1日显示为01
*/
private Boolean dayZeroFilling = true;
/** /**
* 表和字段配置 * 表和字段配置
@@ -73,30 +64,6 @@ public class GeneratorConfig {
this.dataSource = dataSource; this.dataSource = dataSource;
} }
public JdbcTemplate getJdbcTemplate() {
return jdbcTemplate;
}
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
this.jdbcTemplate = jdbcTemplate;
}
public TransactionTemplate getTransactionTemplate() {
return transactionTemplate;
}
public void setTransactionTemplate(TransactionTemplate transactionTemplate) {
this.transactionTemplate = transactionTemplate;
}
public DataSourceTransactionManager getTransactionManager() {
return transactionManager;
}
public void setTransactionManager(DataSourceTransactionManager transactionManager) {
this.transactionManager = transactionManager;
}
public Boolean getAutoCreate() { public Boolean getAutoCreate() {
return autoCreate; return autoCreate;
} }
@@ -131,6 +98,22 @@ public class GeneratorConfig {
this.step = step; this.step = step;
} }
public Boolean getMonthZeroFilling() {
return monthZeroFilling;
}
public void setMonthZeroFilling(Boolean monthZeroFilling) {
this.monthZeroFilling = monthZeroFilling;
}
public Boolean getDayZeroFilling() {
return dayZeroFilling;
}
public void setDayZeroFilling(Boolean dayZeroFilling) {
this.dayZeroFilling = dayZeroFilling;
}
public TableConfig getTableConfig() { public TableConfig getTableConfig() {
return tableConfig; return tableConfig;
} }

View File

@@ -13,7 +13,7 @@ public class TableConfig {
private String table = "sequences"; private String table = "sequences";
/** /**
* 序号英文名称,和序号类型组成唯一组件 * 序号英文名称,和序号类型组成唯一主键
*/ */
private String keyColumn = "key"; private String keyColumn = "key";

View File

@@ -10,6 +10,14 @@ import com.yanghuanglin.seq.po.SequencesUnused;
import java.util.Date; import java.util.Date;
public interface Generator { public interface Generator {
/**
* 判断格式定义中是否有序号
*
* @param pattern 格式
* @return 是否包含序号
*/
boolean containSeq(String pattern);
/** /**
* 根据传入的key和type生成可用的序号对象。 * 根据传入的key和type生成可用的序号对象。
* <p/> * <p/>
@@ -18,9 +26,15 @@ public interface Generator {
* 如果根据key和默认的{@link GeneratorConfig#getType()}在{@link Sequences}中找到了记录,且在{@link SequencesUnused}也找到了记录,说明该组合生成的序号有部分未使用,返回的是{@link SequencesUnused}中找到的seq最小的序号对象。同时会将{@link SequencesUnused}中找到的seq最小的记录删除然后写入到{@link SequencesUnlock}中。 * 如果根据key和默认的{@link GeneratorConfig#getType()}在{@link Sequences}中找到了记录,且在{@link SequencesUnused}也找到了记录,说明该组合生成的序号有部分未使用,返回的是{@link SequencesUnused}中找到的seq最小的序号对象。同时会将{@link SequencesUnused}中找到的seq最小的记录删除然后写入到{@link SequencesUnlock}中。
* <p/> * <p/>
* *
* @param key 数据字典中的编码 * @param key 数据字典中的编码
* @param withOutSeq 序号对象不包含序号,其值通过{@link #containSeq(String)}来判断
* @return 可用的序号对象 * @return 可用的序号对象
*/ */
Sequences generate(String key, Boolean withOutSeq);
/**
* 同 {@link #generate(String, Boolean)}第二个参数默认为false
*/
Sequences generate(String key); Sequences generate(String key);
/** /**
@@ -31,26 +45,38 @@ public interface Generator {
* 如果根据key和type在{@link Sequences}中找到了记录,且在{@link SequencesUnused}也找到了记录,说明该组合生成的序号有部分未使用,返回的是{@link SequencesUnused}中找到的seq最小的序号对象。同时会将{@link SequencesUnused}中找到的seq最小的记录删除然后写入到{@link SequencesUnlock}中。 * 如果根据key和type在{@link Sequences}中找到了记录,且在{@link SequencesUnused}也找到了记录,说明该组合生成的序号有部分未使用,返回的是{@link SequencesUnused}中找到的seq最小的序号对象。同时会将{@link SequencesUnused}中找到的seq最小的记录删除然后写入到{@link SequencesUnlock}中。
* <p/> * <p/>
* *
* @param key 数据字典中的编码 * @param key 数据字典中的编码
* @param type 序号类型 * @param type 序号类型
* @param withOutSeq 序号对象不包含序号,其值通过{@link #containSeq(String)}来判断
* @return 可用的序号对象 * @return 可用的序号对象
*/ */
Sequences generate(String key, String type, Boolean withOutSeq);
/**
* 同{@link #generate(String, String, Boolean)}第三个参数默认为false
*/
Sequences generate(String key, String type); Sequences generate(String key, String type);
/** /**
* 返回根据{@link #generate(String, String)}得到的序号对象,补零后的序号字符串 * 返回根据{@link #generate(String, String, Boolean)}得到的序号对象,补零后的序号字符串
* <p/> * <p/>
* 如生成的为3而minLength为5则返回的是00003 * 如生成的为3而minLength为5则返回的是00003
* *
* @param key 数据字典中的编码 * @param key 数据字典中的编码
* @param type 序号类型 * @param type 序号类型
* @param minLength 序号数字最小长度 * @param minLength 序号数字最小长度
* @param withOutSeq 序号对象不包含序号,其值通过{@link #containSeq(String)}来判断
* @return 补零后的字符串 * @return 补零后的字符串
*/ */
String generate(String key, String type, Integer minLength, Boolean withOutSeq);
/**
* 同{@link #generate(String, String, Integer, Boolean)}第四个参数默认为false
*/
String generate(String key, String type, Integer minLength); String generate(String key, String type, Integer minLength);
/** /**
* 将{@link #generate(String, String)}得到的序号对象格式化为补零后的序号字符串,其最小长度通过{@link BaseConfig#getMinLength()}设定。实际上只会用到{@link Sequences#getSeq()}属性 * 将{@link #generate(String, String, Boolean)}得到的序号对象格式化为补零后的序号字符串,其最小长度通过{@link BaseConfig#getMinLength()}设定。实际上只会用到{@link Sequences#getSeq()}属性
* <p/> * <p/>
* pattern支持{@link FormatPlaceholder#YEAR}(当前年份)、{@link FormatPlaceholder#MONTH}}(当前月份)、{@link FormatPlaceholder#DAY}}(当前日期)、{@link FormatPlaceholder#SEQ}}(生成的字符串序号)几个枚举值通过{@link FormatPlaceholder#getPlaceholder()}得到的字符串 * pattern支持{@link FormatPlaceholder#YEAR}(当前年份)、{@link FormatPlaceholder#MONTH}}(当前月份)、{@link FormatPlaceholder#DAY}}(当前日期)、{@link FormatPlaceholder#SEQ}}(生成的字符串序号)几个枚举值通过{@link FormatPlaceholder#getPlaceholder()}得到的字符串
* *
@@ -61,7 +87,7 @@ public interface Generator {
String format(Sequences sequences, String pattern); String format(Sequences sequences, String pattern);
/** /**
* 将{@link #generate(String, String)}得到的序号对象格式化为补零后的序号字符串。实际上只会用到{@link Sequences#getSeq()}属性 * 将{@link #generate(String, String, Boolean)}得到的序号对象格式化为补零后的序号字符串。实际上只会用到{@link Sequences#getSeq()}属性
* <p/> * <p/>
* pattern支持{@link FormatPlaceholder#YEAR}(当前年份)、{@link FormatPlaceholder#MONTH}}(当前月份)、{@link FormatPlaceholder#DAY}}(当前日期)、{@link FormatPlaceholder#SEQ}}(生成的字符串序号)几个枚举值通过{@link FormatPlaceholder#getPlaceholder()}得到的字符串 * pattern支持{@link FormatPlaceholder#YEAR}(当前年份)、{@link FormatPlaceholder#MONTH}}(当前月份)、{@link FormatPlaceholder#DAY}}(当前日期)、{@link FormatPlaceholder#SEQ}}(生成的字符串序号)几个枚举值通过{@link FormatPlaceholder#getPlaceholder()}得到的字符串
* *
@@ -136,6 +162,26 @@ public interface Generator {
*/ */
String format(Long seq, String start, Integer minLength, String pattern); String format(Long seq, String start, Integer minLength, String pattern);
/**
* 将生成的序号对象格式化为指定格式
* <p/>
* pattern支持{@link FormatPlaceholder#YEAR}(当前年份)、{@link FormatPlaceholder#MONTH}}(当前月份)、{@link FormatPlaceholder#DAY}}(当前日期)、{@link FormatPlaceholder#SEQ}}(生成的字符串序号)几个枚举值通过{@link FormatPlaceholder#getPlaceholder()}得到的字符串
* <p/>
* seq为1,start为6minLength为4pattern为#year##month##day##seq#则会格式化为2022013060001。此序号含义如下
* <p/>
* 序号格式:[年][月][日][固定6开头][序号1最小位数为4位不足4位则补零]
*
* @param seq 需要格式化的序号
* @param start 序号格式化后以什么字符串开头
* @param minLength 序号最小长度,不足的会补零
* @param pattern 序号格式
* @param year 格式化时使用的年
* @param month 格式化时使用的月
* @param day 格式化时使用的日
* @return 格式化后的序号字符串
*/
String format(Long seq, String start, Integer minLength, String pattern, Integer year, Integer month, Integer day);
/** /**
* 将已格式化的序号解析为序号对象 * 将已格式化的序号解析为序号对象
* <p/> * <p/>
@@ -158,7 +204,7 @@ public interface Generator {
/** /**
* 锁定指定序号,在序号生成后,调用该序号的逻辑完成后需要执行此方法 * 锁定指定序号,在序号生成后,调用该序号的逻辑完成后需要执行此方法
* <p/> * <p/>
* 如办理案件时,先调用{@link #generate(String, String)}或者{@link #generate(String, String, Integer)}生成了序号,之后对案件进行了入库,如果入库完毕,则将该序号锁定,说明这个序号已被使用 * 如办理案件时,先调用{@link #generate(String, String, Boolean)}或者{@link #generate(String, String, Integer, Boolean)}生成了序号,之后对案件进行了入库,如果入库完毕,则将该序号锁定,说明这个序号已被使用
* <p/> * <p/>
* 注意,此处的锁定非数据库中锁定,而是{@link SequencesUnused}和{@link SequencesUnlock}中均不存在key、type、seq相同的记录视为锁定。因此此处实际是把这两个表中的记录均删除了 * 注意,此处的锁定非数据库中锁定,而是{@link SequencesUnused}和{@link SequencesUnlock}中均不存在key、type、seq相同的记录视为锁定。因此此处实际是把这两个表中的记录均删除了
* *
@@ -183,7 +229,7 @@ public interface Generator {
* <p/> * <p/>
* {@link SequencesUnlock}中未通过{@link #lock(Sequences)}方法锁定的序号会一直存在,调用此方法会将里面的所有序号都移动到{@link SequencesUnused}中,下次生成序号时优先从{@link SequencesUnused}获取。 * {@link SequencesUnlock}中未通过{@link #lock(Sequences)}方法锁定的序号会一直存在,调用此方法会将里面的所有序号都移动到{@link SequencesUnused}中,下次生成序号时优先从{@link SequencesUnused}获取。
*/ */
void release(); boolean release();
/** /**
* 释放指定时间段内未使用的序号 * 释放指定时间段内未使用的序号
@@ -193,7 +239,7 @@ public interface Generator {
* @param begin 开始时间 * @param begin 开始时间
* @param end 结束时间 * @param end 结束时间
*/ */
void release(Date begin, Date end); boolean release(Date begin, Date end);
/** /**
* 释放从开始时间开始,到现在时间之间未使用的序号。结束时间为方法执行时的时间 * 释放从开始时间开始,到现在时间之间未使用的序号。结束时间为方法执行时的时间
@@ -214,7 +260,7 @@ public interface Generator {
* *
* @param sequences 需要释放的序号。一般是一个通过{@link Sequences#setKey(String)}、{@link Sequences#setType(String)}、{@link Sequences#setSeq(Long)}三方法一起手动构建或通过{@link Sequences#Sequences(String, String, Long)}构造方法构建的实例对象 * @param sequences 需要释放的序号。一般是一个通过{@link Sequences#setKey(String)}、{@link Sequences#setType(String)}、{@link Sequences#setSeq(Long)}三方法一起手动构建或通过{@link Sequences#Sequences(String, String, Long)}构造方法构建的实例对象
*/ */
void release(Sequences sequences); boolean release(Sequences sequences);
/** /**
* 忽略{@link Sequences#getSeq()}来释放指定序号。一般用于业务对象删除后,对应序号需要回收使用时。 * 忽略{@link Sequences#getSeq()}来释放指定序号。一般用于业务对象删除后,对应序号需要回收使用时。
@@ -224,17 +270,17 @@ public interface Generator {
* @param sequences 需要释放的序号。一般是一个通过{@link Sequences#setKey(String)}、{@link Sequences#setType(String)}、{@link Sequences#setSeq(Long)}三方法一起手动构建或通过{@link Sequences#Sequences(String, String, Long)}构造方法构建的实例对象 * @param sequences 需要释放的序号。一般是一个通过{@link Sequences#setKey(String)}、{@link Sequences#setType(String)}、{@link Sequences#setSeq(Long)}三方法一起手动构建或通过{@link Sequences#Sequences(String, String, Long)}构造方法构建的实例对象
* @param ignoreSeq 是否忽略序号 * @param ignoreSeq 是否忽略序号
*/ */
void release(Sequences sequences, boolean ignoreSeq); boolean release(Sequences sequences, boolean ignoreSeq);
/** /**
* 清空所有闲置序号和未锁定序号 * 清空所有闲置序号和未锁定序号
*/ */
void clear(); boolean clear();
/** /**
* 清空指定时间段内闲置序号和未锁定序号 * 清空指定时间段内闲置序号和未锁定序号
*/ */
void clear(Date begin, Date end); boolean clear(Date begin, Date end);
/** /**
* 清空从开始时间到限制时间之间闲置序号和未锁定序号,结束时间为方法执行时的时间 * 清空从开始时间到限制时间之间闲置序号和未锁定序号,结束时间为方法执行时的时间

View File

@@ -30,6 +30,8 @@ public class SequencesGenerator implements Generator {
private final Integer step; private final Integer step;
private final String type; private final String type;
private final Integer minLength; private final Integer minLength;
private final Boolean monthZeroFilling;
private final Boolean dayZeroFilling;
public SequencesGenerator(GeneratorConfig generatorConfig) { public SequencesGenerator(GeneratorConfig generatorConfig) {
BaseConfig baseConfig = BaseConfig.getInstance(generatorConfig); BaseConfig baseConfig = BaseConfig.getInstance(generatorConfig);
@@ -41,6 +43,8 @@ public class SequencesGenerator implements Generator {
this.step = baseConfig.getStep(); this.step = baseConfig.getStep();
this.type = baseConfig.getType(); this.type = baseConfig.getType();
this.minLength = baseConfig.getMinLength(); this.minLength = baseConfig.getMinLength();
this.monthZeroFilling = baseConfig.getMonthZeroFilling();
this.dayZeroFilling = baseConfig.getDayZeroFilling();
createTable(generatorConfig.getAutoCreate()); createTable(generatorConfig.getAutoCreate());
} }
@@ -60,47 +64,65 @@ public class SequencesGenerator implements Generator {
@Override @Override
public synchronized Sequences generate(String key) { public boolean containSeq(String pattern) {
return generate(key, type); return StringUtils.hasLength(pattern) && pattern.contains(SEQ.getPlaceholder());
} }
@Override @Override
public synchronized Sequences generate(String key, String type) { public synchronized Sequences generate(String key, Boolean withOutSeq) {
return generate(key, type, withOutSeq);
}
@Override
public Sequences generate(String key) {
return generate(key, false);
}
@Override
public synchronized Sequences generate(String key, String type, Boolean withOutSeq) {
return transactionTemplate.execute(status -> { return transactionTemplate.execute(status -> {
try { try {
//根据传入的key和type新生成查询条件对象 //根据传入的key和type新生成查询条件对象
Sequences condition = new Sequences(key, type); Sequences condition = new Sequences(key, type);
//找到正在使用的最大序号 if (!withOutSeq) {
Sequences sequences = sequencesDao.find(condition); //不是不包含序号的序号对象(有可能格式中只配置了#year##month##day#,序号就不用自增,也不用入库,直接返回即可)
if (sequences == null) { //找到正在使用的最大序号
//不存在说明还没生成将新生成的入库此时序号为默认的0 Sequences sequences = sequencesDao.find(condition);
sequences = condition; boolean result = true;
sequencesDao.save(sequences); if (sequences == null) {
} //不存在说明还没生成将新生成的入库此时序号为默认的0
sequences = condition;
result = sequencesDao.save(sequences);
}
//根据传入的key和type查找空闲编号最小的一个 //根据传入的key和type查找空闲编号最小的一个
SequencesUnused conditionIdle = new SequencesUnused(condition); SequencesUnused conditionIdle = new SequencesUnused(condition);
SequencesUnused sequencesUnused = sequencesUnusedDao.findMinSeq(conditionIdle); SequencesUnused sequencesUnused = sequencesUnusedDao.findMinSeq(conditionIdle);
if (sequencesUnused == null) { if (sequencesUnused == null) {
//空闲编号不存在,说明是未生成过,序号需要增加后直接使用,同时将新生成的写入到使用中表 //空闲编号不存在,说明是未生成过,序号需要增加后直接使用,同时将新生成的写入到使用中表
sequences.increase(step); sequences.increase(step);
SequencesUnlock sequencesUnlock = new SequencesUnlock(sequences); SequencesUnlock sequencesUnlock = new SequencesUnlock(sequences);
sequencesUnlock.setCreateTime(new Date()); sequencesUnlock.setCreateTime(new Date());
sequencesDao.update(sequences); result = result && sequencesDao.update(sequences) &&
sequencesUnlockDao.save(sequencesUnlock); sequencesUnlockDao.save(sequencesUnlock);
} else {
//空闲编号存在,说明已经生成过,序号不需要增加,直接使用。同时将该空闲编号移动到使用中表
sequences = new Sequences(sequencesUnused);
SequencesUnlock sequencesUnlock = new SequencesUnlock(sequencesUnused);
sequencesUnlock.setCreateTime(new Date());
result = result && sequencesUnlockDao.save(sequencesUnlock) &&
sequencesUnusedDao.delete(sequencesUnused);
}
sequences.setWithOutSeq(false);
return result ? sequences : null;
} else { } else {
//空闲编号存在,说明已经生成过,序号不需要增加,直接使用。同时将该空闲编号移动到使用中表 condition.setWithOutSeq(true);
sequences = new Sequences(sequencesUnused); return condition;
SequencesUnlock sequencesUnlock = new SequencesUnlock(sequencesUnused);
sequencesUnlock.setCreateTime(new Date());
sequencesUnlockDao.save(sequencesUnlock);
sequencesUnusedDao.delete(sequencesUnused);
} }
return sequences;
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
status.setRollbackOnly(); status.setRollbackOnly();
@@ -110,13 +132,23 @@ public class SequencesGenerator implements Generator {
} }
@Override @Override
public synchronized String generate(String key, String type, Integer minLength) { public Sequences generate(String key, String type) {
Sequences sequences = generate(key, type); return generate(key, type, false);
}
@Override
public synchronized String generate(String key, String type, Integer minLength, Boolean withOutSeq) {
Sequences sequences = generate(key, type, withOutSeq);
if (sequences == null) if (sequences == null)
return null; return null;
return sequences.format(minLength); return sequences.format(minLength);
} }
@Override
public String generate(String key, String type, Integer minLength) {
return generate(key, type, minLength, false);
}
@Override @Override
public String format(Sequences sequences, String pattern) { public String format(Sequences sequences, String pattern) {
return format(sequences, minLength, pattern); return format(sequences, minLength, pattern);
@@ -144,13 +176,24 @@ public class SequencesGenerator implements Generator {
@Override @Override
public String format(Long seq, String start, Integer minLength, String pattern) { public String format(Long seq, String start, Integer minLength, String pattern) {
return format(seq, start, minLength, pattern, null, null, null);
}
@Override
public String format(Long seq, String start, Integer minLength, String pattern, Integer year, Integer month, Integer day) {
if (start == null) if (start == null)
start = ""; start = "";
String seqString = start + new Sequences(seq).format(minLength); String seqString = start + new Sequences(seq).format(minLength);
Calendar calendar = Calendar.getInstance(); Calendar calendar = Calendar.getInstance();
pattern = pattern.replaceAll(YEAR.getPlaceholder(), String.valueOf(calendar.get(Calendar.YEAR))); if (year == null)
pattern = pattern.replaceAll(MONTH.getPlaceholder(), String.format("%02d", calendar.get(Calendar.MONTH) + 1)); year = calendar.get(Calendar.YEAR);
pattern = pattern.replaceAll(DAY.getPlaceholder(), String.valueOf(calendar.get(Calendar.DAY_OF_MONTH))); if (month == null)
month = calendar.get(Calendar.MONTH) + 1;
if (day == null)
day = calendar.get(Calendar.DAY_OF_MONTH);
pattern = pattern.replaceAll(YEAR.getPlaceholder(), String.valueOf(year));
pattern = pattern.replaceAll(MONTH.getPlaceholder(), monthZeroFilling ? String.format("%02d", month) : String.valueOf(month));
pattern = pattern.replaceAll(DAY.getPlaceholder(), dayZeroFilling ? String.format("%02d", day) : String.valueOf(day));
pattern = pattern.replaceAll(SEQ.getPlaceholder(), seqString); pattern = pattern.replaceAll(SEQ.getPlaceholder(), seqString);
return pattern; return pattern;
} }
@@ -228,6 +271,7 @@ public class SequencesGenerator implements Generator {
sequences.setMonth(StringUtils.hasLength(month) ? Integer.valueOf(month) : null); sequences.setMonth(StringUtils.hasLength(month) ? Integer.valueOf(month) : null);
sequences.setDay(StringUtils.hasLength(day) ? Integer.valueOf(day) : null); sequences.setDay(StringUtils.hasLength(day) ? Integer.valueOf(day) : null);
sequences.setSeq(StringUtils.hasLength(seq) ? Long.parseLong(seq) : 0L); sequences.setSeq(StringUtils.hasLength(seq) ? Long.parseLong(seq) : 0L);
sequences.setWithOutSeq(!StringUtils.hasLength(seq));
sequences.setType(type); sequences.setType(type);
return sequences; return sequences;
@@ -235,27 +279,43 @@ public class SequencesGenerator implements Generator {
@Override @Override
public synchronized boolean lock(Sequences sequences) { public synchronized boolean lock(Sequences sequences) {
if (sequences == null) if (sequences == null || sequences.getWithOutSeq())
return true; return true;
SequencesUnlock condition = new SequencesUnlock(sequences); SequencesUnlock condition = new SequencesUnlock(sequences);
//将使用中表的对应数据删除,空闲表中数据在生成时会删除,因此这里不需要处理该表 //将使用中表的对应数据删除,空闲表中数据在生成时会删除,因此这里不需要处理该表
return sequencesUnlockDao.delete(condition); return Boolean.TRUE.equals(transactionTemplate.execute(status -> {
try {
return sequencesUnlockDao.delete(condition);
} catch (Exception e) {
e.printStackTrace();
status.setRollbackOnly();
return false;
}
}));
} }
@Override @Override
public synchronized boolean lock(Sequences sequences, boolean ignoreSeq) { public synchronized boolean lock(Sequences sequences, boolean ignoreSeq) {
if (!ignoreSeq) if (!ignoreSeq)
return lock(sequences); return lock(sequences);
if (sequences == null) if (sequences == null || sequences.getWithOutSeq())
return true; return true;
SequencesUnlock condition = new SequencesUnlock(sequences); SequencesUnlock condition = new SequencesUnlock(sequences);
condition.setSeq(null); condition.setSeq(null);
//将使用中表的对应数据删除,空闲表中数据在生成时会删除,因此这里不需要处理该表 //将使用中表的对应数据删除,空闲表中数据在生成时会删除,因此这里不需要处理该表
return sequencesUnlockDao.delete(condition); return Boolean.TRUE.equals(transactionTemplate.execute(status -> {
try {
return sequencesUnlockDao.delete(condition);
} catch (Exception e) {
e.printStackTrace();
status.setRollbackOnly();
return false;
}
}));
} }
@Override @Override
public synchronized void release() { public synchronized boolean release() {
//列出所有使用中表存在的序号 //列出所有使用中表存在的序号
List<SequencesUnlock> sequencesUnlockList = sequencesUnlockDao.listAll(); List<SequencesUnlock> sequencesUnlockList = sequencesUnlockDao.listAll();
@@ -265,13 +325,23 @@ public class SequencesGenerator implements Generator {
} }
//将使用中表的序号放到空闲表中 //将使用中表的序号放到空闲表中
sequencesUnusedDao.saveBatch(sequencesUnusedList);
//删除所有使用中表的数据 //删除所有使用中表的数据
sequencesUnlockDao.deleteAll(); return Boolean.TRUE.equals(transactionTemplate.execute(status -> {
try {
//将使用中表的序号放到空闲表中
//删除所有使用中表的数据
return sequencesUnusedDao.saveBatch(sequencesUnusedList) &&
sequencesUnlockDao.deleteAll();
} catch (Exception e) {
e.printStackTrace();
status.setRollbackOnly();
return false;
}
}));
} }
@Override @Override
public synchronized void release(Date begin, Date end) { public synchronized boolean release(Date begin, Date end) {
//列出指定时间段内使用中表存在的序号 //列出指定时间段内使用中表存在的序号
List<SequencesUnlock> sequencesUnlockList = sequencesUnlockDao.listByDate(begin, end); List<SequencesUnlock> sequencesUnlockList = sequencesUnlockDao.listByDate(begin, end);
@@ -281,9 +351,19 @@ public class SequencesGenerator implements Generator {
} }
//将指定时间段内使用中表的序号放到空闲表中 //将指定时间段内使用中表的序号放到空闲表中
sequencesUnusedDao.saveBatch(sequencesUnusedList);
//删除指定时间段内使用中表的数据 //删除指定时间段内使用中表的数据
sequencesUnlockDao.deleteByDate(begin, end); return Boolean.TRUE.equals(transactionTemplate.execute(status -> {
try {
//将指定时间段内使用中表的序号放到空闲表中
//删除指定时间段内使用中表的数据
return sequencesUnusedDao.saveBatch(sequencesUnusedList) &&
sequencesUnlockDao.deleteByDate(begin, end);
} catch (Exception e) {
e.printStackTrace();
status.setRollbackOnly();
return false;
}
}));
} }
@Override @Override
@@ -297,37 +377,68 @@ public class SequencesGenerator implements Generator {
} }
@Override @Override
public synchronized void release(Sequences sequences) { public synchronized boolean release(Sequences sequences) {
if (sequences == null) if (sequences == null)
return; return true;
sequencesUnlockDao.delete(new SequencesUnlock(sequences)); return Boolean.TRUE.equals(transactionTemplate.execute(status -> {
sequencesUnusedDao.save(new SequencesUnused(sequences, new Date())); try {
return sequencesUnlockDao.delete(new SequencesUnlock(sequences))
&& sequencesUnusedDao.save(new SequencesUnused(sequences, new Date()));
} catch (Exception e) {
e.printStackTrace();
status.setRollbackOnly();
return false;
}
}));
} }
@Override @Override
public synchronized void release(Sequences sequences, boolean ignoreSeq) { public synchronized boolean release(Sequences sequences, boolean ignoreSeq) {
if (!ignoreSeq) { if (!ignoreSeq) {
release(sequences); return release(sequences);
return;
} }
if (sequences == null) if (sequences == null)
return; return true;
SequencesUnlock sequencesUnlock = new SequencesUnlock(sequences); return Boolean.TRUE.equals(transactionTemplate.execute(status -> {
sequencesUnlock.setSeq(null); try {
sequencesUnlockDao.delete(sequencesUnlock); SequencesUnlock sequencesUnlock = new SequencesUnlock(sequences);
//由于忽略了序号因此不需要将未使用序号放到SequencesUnused里面 sequencesUnlock.setSeq(null);
//由于忽略了序号因此不需要将未使用序号放到SequencesUnused里面
return sequencesUnlockDao.delete(sequencesUnlock);
} catch (Exception e) {
e.printStackTrace();
status.setRollbackOnly();
return false;
}
}));
} }
@Override @Override
public synchronized void clear() { public synchronized boolean clear() {
sequencesUnlockDao.deleteAll(); return Boolean.TRUE.equals(transactionTemplate.execute(status -> {
sequencesUnusedDao.deleteAll(); try {
return sequencesUnlockDao.deleteAll() &&
sequencesUnusedDao.deleteAll();
} catch (Exception e) {
e.printStackTrace();
status.setRollbackOnly();
return false;
}
}));
} }
@Override @Override
public synchronized void clear(Date begin, Date end) { public synchronized boolean clear(Date begin, Date end) {
sequencesUnlockDao.deleteByDate(begin, end); return Boolean.TRUE.equals(transactionTemplate.execute(status -> {
sequencesUnusedDao.deleteByDate(begin, end); try {
return sequencesUnlockDao.deleteByDate(begin, end) &&
sequencesUnusedDao.deleteByDate(begin, end);
} catch (Exception e) {
e.printStackTrace();
status.setRollbackOnly();
return false;
}
}));
} }
@Override @Override

View File

@@ -42,6 +42,11 @@ public class Sequences {
*/ */
private transient Integer day; private transient Integer day;
/**
* 临时字段,表示序号对象不包含序号
*/
private transient Boolean withOutSeq;
public Sequences() { public Sequences() {
} }
@@ -114,6 +119,14 @@ public class Sequences {
this.day = day; this.day = day;
} }
public Boolean getWithOutSeq() {
return withOutSeq;
}
public void setWithOutSeq(Boolean withOutSeq) {
this.withOutSeq = withOutSeq;
}
/** /**
* 将序号增加指定步长 * 将序号增加指定步长
* *
@@ -156,6 +169,7 @@ public class Sequences {
", year=" + year + ", year=" + year +
", month=" + month + ", month=" + month +
", day=" + day + ", day=" + day +
", withOutSeq=" + withOutSeq +
'}'; '}';
} }
} }

View File

@@ -1,10 +1,14 @@
import com.mysql.cj.jdbc.MysqlDataSource; import com.mysql.cj.jdbc.MysqlDataSource;
import com.yanghuanglin.seq.config.BaseConfig;
import com.yanghuanglin.seq.config.GeneratorConfig; import com.yanghuanglin.seq.config.GeneratorConfig;
import com.yanghuanglin.seq.config.TableConfig; import com.yanghuanglin.seq.config.TableConfig;
import com.yanghuanglin.seq.generator.Generator; import com.yanghuanglin.seq.generator.Generator;
import com.yanghuanglin.seq.generator.impl.SequencesGenerator; import com.yanghuanglin.seq.generator.impl.SequencesGenerator;
import com.yanghuanglin.seq.po.Sequences; import com.yanghuanglin.seq.po.Sequences;
import org.junit.Test; import org.junit.Test;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.support.TransactionTemplate;
import java.util.HashSet; import java.util.HashSet;
import java.util.Set; import java.util.Set;
@@ -26,12 +30,15 @@ public class SeqTest {
dataSource.setPassword("root"); dataSource.setPassword("root");
GeneratorConfig generatorConfig = new GeneratorConfig(dataSource); GeneratorConfig generatorConfig = new GeneratorConfig(dataSource);
TableConfig tableConfig = new TableConfig(); TableConfig tableConfig = new TableConfig();
tableConfig.setTable("sequences"); tableConfig.setTable("sequences");
tableConfig.setKeyColumn("SEQUENCE_KEY"); tableConfig.setKeyColumn("SEQUENCE_KEY");
tableConfig.setTypeColumn("SEQUENCE_TYPE"); tableConfig.setTypeColumn("SEQUENCE_TYPE");
tableConfig.setSeqColumn("CURRENT"); tableConfig.setSeqColumn("CURRENT");
generatorConfig.setTableConfig(tableConfig); generatorConfig.setTableConfig(tableConfig);
generatorConfig.setDayZeroFilling(false);
generatorConfig.setMonthZeroFilling(false);
generator = new SequencesGenerator(generatorConfig); generator = new SequencesGenerator(generatorConfig);
} }
@@ -44,12 +51,9 @@ public class SeqTest {
Set<String> set = new HashSet<>(); Set<String> set = new HashSet<>();
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10, 10, 1, TimeUnit.MINUTES, new ArrayBlockingQueue<>(100)); ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10, 10, 1, TimeUnit.MINUTES, new ArrayBlockingQueue<>(100));
for (int i = 0; i < 5; i++) { for (int i = 0; i < 5; i++) {
int finalI = i;
threadPoolExecutor.execute(() -> { threadPoolExecutor.execute(() -> {
Sequences sequences = generator.generate("SNT", "MISSION"); Sequences sequences = generator.generate("SNT", "MISSION");
String formattedSeq = generator.format(sequences.getSeq(), "处〔#year#10801#seq#"); String formattedSeq = generator.format(sequences.getSeq(), "处〔#year#10801#seq#");
// if (finalI % 2 == 0)
// System.out.println(3 / 0);
generator.lock(sequences); generator.lock(sequences);
set.add(formattedSeq); set.add(formattedSeq);
System.out.println(formattedSeq); System.out.println(formattedSeq);