改写同事代码——血压操作集锦第一弹

前言

本文的选题来源于一周前我的一次崩溃，当时各种压力和工作把我整的不行了，让我在短时间内改另一个同事写的代码。本来以为是一次简单的叠叠乐，没想到随便看了眼之前的代码，发现历史需求没写完，而且逻辑还有错，当时直接蚌埠住了。我的IDEA比较新，平时看着报错我都会去手动改一下，有时候我看着同事的代码一片黄，总是忍不住要改。久而久之也烦了，不明白为什么这么明显的BUG还能放在上面，于是产生了来一期盘点的想法。排名不分先后，上榜各凭本事，客官们，上菜咯！

第一期

案例一

用不明白的三元表达式能不能别用了啊，求求啦。当时看到这个地方的时候，我一眼就觉得很怪，因为我觉得他写错了，但同时我又能了解开发者的意图，这种感觉就很奇妙，我觉得我融入这个BUG了。

错误示例，这里我单独写了个例子来证明他真的写错了，和我想得一样，就是执行顺序的问题。

正确示例，加括号，注意执行顺序，这样就对了嘛。

案例二

参数校验真的是非常常见的场景了，有用AOP的

还有方法里if判断的

有简单的法子，他是真不用啊，注解难道不是又快又简洁吗？这还是我开发文档里写了的，我麻了，真就不看文档呗。

案例三

log日志老是玩不对的，我也是见太多了，像这种占位符写不明白的，不是很理解。

莫名其妙的，我发现好多人喜欢这么写，不看API吗，这时候想起占位符了。

传世经典之异常不打印堆栈信息，我觉得这个倒是小问题，或许有别的想法呢，但是我推荐还是记录一下比较好。

案例四

意义不明的代码，要么删除要么打上注释，不要放在那里影响判断。这个问题在我去接手或者修改别人代码的时候最严重，依托答辩放在那里，没有引用也没有后续的使用，那到底是干啥的呢？我是真的猜不透啊，不敢动了。

案例五

严禁在方法内部自由输出错误码，同时也禁止在service层输出结果类，这样controller层将没有意义，切点在controller层的切面会失效。

异常需使用指定异常或者继承了指定异常的异常类抛出，这样才能抓到错误码，否则将被全局监听覆盖错误码和错误信息

同时也不建议在有框架保底的情况下在controller层写过多的代码，这种try catch能用全局异常监听能处理的就不要自己写，用好异常和错误码即可。

正常像这样简洁方便的写就好了，在service层处理的时候抛出自定义的异常即可。这个写法是两年前我做的一次优化，本以为不会出现类似问题了，结果最近的代码中又发现了，真是不改嗷。

案例六

经典自调用切面失效场景，这个其实注意一下就可以避免的，但是很多时候就是写着写着就忘了，非得报错才知道写错了。

最便捷的方法就是注入本体，再调用

案例七

在使用Redis等中间件相关的操作框架比如Redisson时，要特别注意不要让中间件宕机时影响程序的正常运行。最近Redis宕机了，猛然发现这个问题，想了下确实也不能怪框架，毕竟没有数据和报错确实是两码事，这个只能开发者自己控制。

@Autowiredprivate 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的基本校验，并且自带上传文件服务器以及传递PTMlong 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的业务模块 - 掘金 (juejin.cn)，这篇文章在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还没怎么找，慢慢攒素材留到二期吧。

小技巧

从我的开发百宝箱里淘点干货出来，主要是之前的文章没处放，正好趁这个话题把这些代码片放出来。

快速生成单表条件列表方法

应用于上图这种查询列表条件参数的接口，提供一个聚合性接口，根据type来区分是哪种类型的数据。还可以增加一个value参数接收前端用户输入的数据来做模糊查询，注意这里使用了Mybatis-Plus框架。

/** * 查询条件参数列表 * * @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转DateDate 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问题排查这个，正在研究中，摸不准方向，再沉淀沉淀。

链接：https://juejin.cn/post/7222676935147651132