本文正在参加「金石计划」
前语
本文的选题来源于一周前我的一次溃散,其时各种压力和工作把我整的不行了,让我在短时刻内改另一个搭档写的代码。本来以为是一次简略的叠叠乐,没想到随意看了眼之前的代码,发现前史需求没写完,并且逻辑还有错,其时直接蚌埠住了。我的IDEA比较新,平常看着报错我都会去手动改一下,有时分我看着搭档的代码一片黄,总是不由得要改。久而久之也烦了,不理解为什么这么显着的BUG还能放在上面,所以产生了来一期盘点的主意。排名不分先后,上榜各凭本事,客官们,上菜咯!
第一期
事例一
用不理解的三元表达式能不能别用了啊,求求啦。其时看到这个当地的时分,我一眼就觉得很怪,因为我觉得他写错了,但一起我又能了解开发者的目的,这种感觉就很奇妙,我觉得我融入这个BUG了。



事例二
参数校验真的是十分常见的场景了,有用AOP的



事例三
log日志老是玩不对的,我也是见太多了,像这种占位符写不理解的,不是很理解。

不可思议的,我发现好多人喜爱这么写,不看API吗,这时分想起占位符了。

传世经典之反常不打印堆栈信息,我觉得这个却是小问题,或许有别的主意呢,可是我引荐仍是记载一下比较好。


事例四
含义不明的代码,要么删去要么打上注释,不要放在那里影响判别。这个问题在我去接手或许修改他人代码的时分最严重,依托辩论放在那里,没有引用也没有后续的运用,那到底是干啥的呢?我是真的猜不透啊,不敢动了。

事例五
制止在办法内部自在输出过错码,一起也制止在service层输出结果类,这样controller层将没有含义,切点在controller层的切面会失效。




事例六
经典自调用切面失效场景,这个其实留意一下就能够防止的,可是许多时分便是写着写着就忘了,非得报错才知道写错了。


事例七
在运用Redis等中间件相关的操作结构比方Redisson时,要特别留意不要让中间件宕机时影响程序的正常运转。最近Redis宕机了,猛然发现这个问题,想了下确实也不能怪结构,究竟没有数据和报错确实是两码事,这个只能开发者自己操控。
@Autowired
private RedissonClient redissonClient;
//原始版别
public BigDecimal getIntervalQty(int itemId, Date startDate, Date endDate) {
String cacheKey = "dashboard:intervalQty:" + itemId + "-" + startDate + "-" + endDate;
RBucket<BigDecimal> bucket = redissonClient.getBucket(cacheKey);
BigDecimal cacheValue = bucket.get();
if (cacheValue != null) {
return cacheValue;
} else {
BigDecimal intervalQty = erpInfoMapper.getIntervalQty(itemId, startDate, endDate);
BigDecimal res = Optional.ofNullable(intervalQty).orElse(BigDecimal.valueOf(0)).setScale(2,
RoundingMode.HALF_UP);
bucket.set(res, 16, TimeUnit.HOURS);
return res;
}
}
//更新防止Redis报错版别
public String getProductLine(String itemNo) {
String cacheKey = "order:getProductLine:" + itemNo;
String cacheValue = null;
RBucket<String> bucket = redissonClient.getBucket(cacheKey);
try {
cacheValue = bucket.get();
} catch (Exception e) {
log.error("redis连接反常", e);
}
if (cacheValue != null) {
return cacheValue;
} else {
String res = ptmErpMapper.getProductLine(itemNo);
bucket.set(res, 16, TimeUnit.HOURS);
return res;
}
}
事例八
这是我写的事务组件的一个BUG,是一个上传文件导入时会报文件找不到的问题,正常我是让我们这么写Excel文件上传。
通用Controller层
@LimitMethod
@PostMapping("/import")
public RemoteResult<String> importAdd(@RequestParam("file") MultipartFile multipartFile)
1.第一步生成单号或许标识,userId之类的最好也取出来,做好传递的准备
identifier标识可运用LuaTool生成
String generateOrder = luaTool.generateOrder("SMB-PRODUCT-");
生成局部变量方便线程间数据传递
RequestContext.getCurrentContext()或许运用CurrentUserUtil东西类(sso-zero供给)
2.第二步调用commonImportExcel办法读取并传递文件到PTM2.0(这一步有必要放在外面,是对excel的根本校验,有过错及时推送前端,不能异步)
该办法包括对excel的根本校验,并且自带上传文件服务器以及传递PTM
long ptmFileId = excelTool.commonImportExcel(file, generateOrder);
3.敞开异步,运用readFile或许readMultipartFile解析文件,并进行事务处理
如果此部分需求事务,请另起一个事务类,运用@Transactional(rollbackFor = Exception.class)或许在当前代码区域手动敞开事务或许自注入再调用办法。
CompletableFuture.runAsync(() -> {
读取文件,readMultipartFile办法会调用Easy Excel解析读取excel,如果有读取过错会抛出过错,办法入参中有表头校验,挑选true会校验表头是否正确,不正确会抛反常
CustomizedExcelListener excelListener = new CustomizedExcelListener();
EasyExcel.read(finalInputStream, MaterialChipImportDTO.class, excelListener).sheet().doRead();
ExcelAnalyzeResDTO analyzeRes = excelListener.getExcelData();
List<MaterialChipImportDTO> judgeMaterialList = (List<MaterialChipImportDTO>) analyzeRes.getExcelDataList();
//事务处理,这儿MaterialChipImportDTO导入类需求冗余一个反常信息字段errMsg,事务处理的时分把过错信息塞进去
List<MaterialChipImportDTO> afterList = judgeChipImport(judgeMaterialList, beforeAllList, isAdd);
//判别errMsg字段是否有值,有值说明这一行有事务逻辑过错
MaterialChipImportDTO orElse = judgeMaterialList.stream()
.filter(ma -> StringUtils.isNotBlank(ma.getErrMsg())).findAny().orElse(null);
//可选,反常文件导出
if (orElse != null) {
String fileName = "过错提示文件-" + finalGenerateOrder;
excelTool.synchronizeExportExcel(judgeMaterialList, MaterialChipImportDTO.class, fileName, fileName,userId, userName);
throw new PtmException("文件校验有过错项,请下载过错提示文件");
} else {
//继续事务操作
}
}
})
4.handle处理部分,调用finishFileStatus办法回传PTM2.0状况,留意这儿的ptmFileId是指PTM文件列表的id
.handle((res, e) -> {
if (e != null) {
log.error("物料风险地图芯片导入异步处理数据失利,流程单号:{},反常信息:", generateOrder, e);
excelTool.finishFileStatus(ptmFileId, null, null, ExcelFieldConstant.TYPE_IMPORT,
ExcelFieldConstant.IMPORT_FAILED, e.getMessage());
} else {
excelTool.finishFileStatus(ptmFileId, null, null, ExcelFieldConstant.TYPE_IMPORT,ExcelFieldConstant.IMPORT_SUCCESS, null);
}
return null;
});
通过以上伪代码能够做到Excel上传校验解析以及与文件服务器和主站的数据交互,感兴趣的话能够看我之前这篇后端思想-如何规划一个操作和管理Excel的事务模块 – (),这篇文章在2023.04.16更新了一版。在给搭档运用的过程中会偶发文件找不到的问题,通过定位后发现是异步敞开后主线程处理完毕封闭MultipartFile的IO流,使得上传的临时文件删去的问题。解决方案很直接,将上传的multipartFile转换成一个本地临时文件flie,用这个临时文件在异步线程中解析,防止文件丢失,在运用完文件之后再主动删去
/**
* @param mFile 上传文件
* @param identifier PTM2.0文件列表查询参数:唯一标识
* @Author WangZY
* @Date 2021/12/14 14:25
* @Description 导入文件--文件下载链接10天有效期
* @return 文件列表ID
**/
public ExcelUploadResDTO commonImportExcel(MultipartFile mFile, String identifier) {
if (mFile.isEmpty()) {
throw new PtmException("上传excel文件不能为空");
} else {
String fileName = mFile.getOriginalFilename();
if (StringUtils.isEmpty(fileName)) {
throw new PtmException("excel称号不能为空");
} else {
if (!fileName.endsWith(".xls") && !fileName.endsWith(".xlsx")) {
throw new PtmException("excel格式不正确");
} else {
//拼装Token和文件服务器权限信息发送请求
String token = getToken(true, 10);
if (mFile.getSize() <= 0) {
throw new PtmException("上传文件为空");
} else {
// 先判别文件夹是否存在,防止不存在时报错
String fileDir = commonProperties.getFileDir();
File filePathExist = new File(fileDir);
if (!filePathExist.exists()) {
boolean mkdir = filePathExist.mkdirs();
if (!mkdir) {
return null;
}
}
//将multipartFile转换为临时文件file,防止异步时子线程找不到文件实例
File file = new File(fileDir + mFile.getOriginalFilename());
try (BufferedInputStream bis = new BufferedInputStream(mFile.getInputStream());
BufferedOutputStream bos =
new BufferedOutputStream(Files.newOutputStream(file.toPath()))) {
int bytesRead = 0;
byte[] buffer = new byte[8192];
while ((bytesRead = bis.read(buffer, 0, 8192)) != -1) {
bos.write(buffer, 0, bytesRead);
}
} catch (Exception e) {
log.error("multipartFileToFile失利", e);
}
String fileId = ExternalApi.uploadFileServer(token, file, splicingFileServerUrl("upload"));
//拼装文件信息,在PTM文件列表创建一条处理中的记载
long ptmFileId = createPtmFile(fileId, fileName, identifier, true);
return new ExcelUploadResDTO(ptmFileId, file);
}
}
}
}
}
/**
* @param file 文件
* @param clazz 类
* @Author WangZY
* @Date 2020/12/12 14:24
* @Description 读文件-文件运用后删去
**/
public List<?> readFile(File file, Class<?> clazz, boolean headCheck) {
ExcelListener excelListener = new ExcelListener();
EasyExcel.read(file, clazz, excelListener).sheet().doRead();
ExcelAnalyzeResDTO excelData = excelListener.getExcelData();
if (headCheck) {
checkHeadRight(clazz, excelData);
}
String dateError = excelData.getDateError();
log.info("完成文件解析,删去文件名={},临时文件结果={}", file.getName(), file.delete());
if (!StringUtils.isEmpty(dateError)) {
throw new PtmException(dateError);
} else {
return excelData.getExcelDataList();
}
}
这个Excel事务模块现在现已运用了两年时刻,前后更新了十余次吧,十分安稳的一个组件。今日翻到上这篇文章的时分,发现没有更新到最新一版,所以再从头润色了一版,加了许多细节。这篇数据的展现阅读比很夸大,可惜发早了,那会儿还不能主动引荐,不然铁定爆款了,究竟网上没有同类型的规划或许实战文章。个人认为这个组件规划仍是十分不错的,极大地减少了开发的代码量,并且即插即用,扩展性也很强。

微醺码头
第一期总结
大概翻找了我比较熟悉的五六个项目的代码,发现居然不好找了,我其时的感觉是震动的。早知道不改了,我怎么那会儿就没想到记载留证呢(拍桌子!)。不过也是功德吧,我的个人感觉是结构越狠,犯错机会就会越少,本期因为时刻问题,我只取了一些清楚明了的问题,平常合作开发时查到的比较深的BUG还没怎么找,慢慢攒资料留到二期吧。
小技巧
从我的开发百宝箱里淘点干货出来,主要是之前的文章没处放,正好趁这个话题把这些代码片放出来。
快速生成单表条件列表办法

/**
* 查询条件参数列表
*
* @param type 支撑五种类型 item物料 supplier供应商 brand品牌
* @return 返回参数调集中,获取其间某个字段即可
*/
@GetMapping(value = "/listCondition")
public RemoteResult<List<String>> listCondition(@RequestParam("type") String type) {
List<String> list = specialMaterialService.listCondition(type);
return RemoteResult.successResult(list);
}
//List<String>版别
public List<String> listCondition(String type) {
List<String> strList = new ArrayList<>();
QueryWrapper<SpecialMaterial> jobQw = new QueryWrapper<>();
switch (type) {
case "item":
jobQw.select("distinct material_number")
.and(e -> e.isNotNull("material_number").ne("material_number", ""));
jobQw.eq("delete_status", 0);
strList = list(jobQw).stream().map(SpecialMaterial::getMaterialNumber)
.distinct().collect(Collectors.toList());
break;
case "supplier":
jobQw.select("distinct manufacturer_name")
.and(e -> e.isNotNull("manufacturer_name").ne("manufacturer_name", ""));
jobQw.eq("delete_status", 0);
strList = list(jobQw).stream().map(SpecialMaterial::getManufacturerName)
.distinct().collect(Collectors.toList());
break;
default:
throw new PtmException("条件类型不能为空");
}
return strList;
}
//含糊查询版别
public List<CommunicationJob> listCondition(String type, String value) {
QueryWrapper<CommunicationJob> jobQw = new QueryWrapper<>();
switch (type) {
case "organizationCode":
jobQw.select("distinct organization_code").like("organization_code", value)
.and(e -> e.isNotNull("organization_code").ne("organization_code", ""));
break;
case "type":
jobQw.select("distinct type").like("type", value)
.and(e -> e.isNotNull("type").ne("type", ""));
break;
case "workshop":
jobQw.select("distinct workshop").like("workshop", value)
.and(e -> e.isNotNull("workshop").ne("workshop", ""));
break;
default:
throw new OrderDeliveryException("条件类型不能为空");
}
jobQw.eq("is_delete", 0).last("limit 20");
return list(jobQw);
}
JDK8时刻转换
//将java.util.Date 转换为java8 的java.time.LocalDateTime,默许时区为东8区
public static LocalDateTime dateConvertToLocalDateTime(Date date) {
return date.toInstant().atOffset(ZoneOffset.of("+8")).toLocalDateTime();
}
//将java8 的 java.time.LocalDateTime 转换为 java.util.Date,默许时区为东8区
public static Date localDateTimeConvertToDate(LocalDateTime localDateTime) {
return Date.from(localDateTime.toInstant(ZoneOffset.of("+8")));
}
//获取当前月第一天和最终一天
LocalDate firstDay = LocalDate.now().with(TemporalAdjusters.firstDayOfMonth());
LocalDate lastDay = LocalDate.now().with(TemporalAdjusters.lastDayOfMonth());
//LocalDate转Date
Date date = Date.from(firstDay.atTime(LocalTime.MIDNIGHT).atZone(ZoneId.systemDefault()).toInstant());
LocalDate startDate = new Date().toInstant().atOffset(ZoneOffset.of("+8")).toLocalDate();
十分规Stream流操作
//对两个字段降序排序,取某个字段分组
Map<String, List<String>> stockAgeMap = stockAgeConversionList.parallelStream()
.sorted(Comparator.comparing(ErpStockAgeDTO::getTissueAge, Comparator.reverseOrder())
.thenComparing(ErpStockAgeDTO::getSubLibraryAge, Comparator.reverseOrder()))
.collect(Collectors.groupingBy(ErpStockAgeDTO::getMaterialNumber,
Collectors.mapping(ErpStockAgeDTO::getWarehouseCode, Collectors.toList())));
//以几个属性为key做map,当重复时挑选第一个
Map<String, MaterialErpDTO> mrpMap = mrpBaseList.parallelStream().collect(Collectors.
toMap(val -> val.getInvOrgId() + val.getItemId() + val.getVendorId(), Function.identity(),(key1, key2) -> key1));
//获取对象调集中重复数据
Map<String, Long> longMap = signInfoList.stream().collect(
Collectors.groupingBy(SignInfo::getSn,Collectors.counting()));
String duplicateKey = longMap.keySet().stream().filter(
key -> longMap.get(key) > 1).collect(Collectors.joining(","));
写在最终
最近有几篇资料还没有成文,八股、技术场景规划方案、GC问题排查、项目难点,一摆放仍是挺多的。可是都在难产中,特别是GC问题排查这个,正在研讨中,摸禁绝方向,再沉积沉积。下一篇是一周年写文总结,再回忆一把,算是献给自己的礼物,嘻嘻,祝我们日子愉快,身体安康!