Files
jsowell-charger-web/jsowell-pile/src/main/java/com/jsowell/pile/service/PileSnGenerateService.java

94 lines
2.4 KiB
Java
Raw Normal View History

2024-09-03 09:36:27 +08:00
package com.jsowell.pile.service;
2023-03-04 16:29:55 +08:00
import com.google.common.collect.Lists;
import com.jsowell.common.constant.CacheConstants;
import com.jsowell.common.core.redis.RedisCache;
2023-08-26 09:46:46 +08:00
import com.jsowell.common.util.StringUtils;
import com.jsowell.pile.domain.PileBasicInfo;
2023-03-04 16:29:55 +08:00
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.time.LocalDate;
import java.util.List;
/**
* 生成sn号Util
*/
@Component
2024-09-03 09:36:27 +08:00
public class PileSnGenerateService {
2023-03-04 16:29:55 +08:00
2024-09-03 09:36:27 +08:00
private static Logger logger = LoggerFactory.getLogger(PileSnGenerateService.class);
2023-03-04 16:29:55 +08:00
@Autowired
2023-08-26 09:46:46 +08:00
private RedisCache redisCache;
@Autowired
2024-01-06 15:20:28 +08:00
private PileBasicInfoService pileBasicInfoService;
2023-03-04 16:29:55 +08:00
private String prefix = "88";
/**
* 获取递增的序列号
* 充电桩编号定义为14位: 固定位88 + 年份23 + 10位自增数字不足补0
* @param prefix 生成序列号的前缀
* @return
*/
2023-08-26 15:47:10 +08:00
public String getPileSn(String prefix) {
2023-03-04 16:29:55 +08:00
//序列号前缀加特定标识,如系统模块名之类的 防止重复
String key = CacheConstants.PILE_SN_GENERATE_KEY + prefix;
String increResult = null;
try {
2023-08-26 15:47:10 +08:00
// 取缓存
Integer pileNum = redisCache.getCacheObject(key);
if (pileNum == null) {
2023-08-26 09:46:46 +08:00
// 缓存中没有,从数据库中取
PileBasicInfo pileInfo = pileBasicInfoService.getMaxNumPileInfo();
String pileSn = pileInfo.getSn();
// 将前四位截取并将后面转为long
2023-08-26 15:47:10 +08:00
Long pileSnNum = Long.parseLong(StringUtils.substring(pileSn, 4, pileSn.length()));
// String pileSnNum = StringUtils.substring(pileSn, 4, pileSn.length());
2023-08-26 09:46:46 +08:00
// 再将该值存入数据库
2023-08-26 15:47:10 +08:00
redisCache.setCacheObject(key, pileSnNum.intValue());
2023-08-26 09:46:46 +08:00
}
2023-03-04 16:29:55 +08:00
Long increNum = redisCache.increment(key, 1);
// 年份
int year = LocalDate.now().getYear() - 2000;
//不足补位
increResult = prefix + year + String.format("%1$010d", increNum);
} catch (Exception e) {
logger.error("获取序列号失败", e);
}
return increResult;
}
/**
* 生成sn号
*
* @return
*/
public List<String> generateSN() {
return generateSN(1);
}
/**
* 批量生成sn号
*
* @param size
* @return
*/
public List<String> generateSN(int size) {
List<String> resultList = Lists.newArrayList();
if (size <= 0) {
return resultList;
}
for (int i = 0; i < size; i++) {
resultList.add(getPileSn(prefix));
}
return resultList;
}
}