diff --git a/bonus-modules/bonus-material/src/main/java/com/bonus/material/purchase/service/impl/PurchaseBindServiceImpl.java b/bonus-modules/bonus-material/src/main/java/com/bonus/material/purchase/service/impl/PurchaseBindServiceImpl.java index a15f7c7f..1375f574 100644 --- a/bonus-modules/bonus-material/src/main/java/com/bonus/material/purchase/service/impl/PurchaseBindServiceImpl.java +++ b/bonus-modules/bonus-material/src/main/java/com/bonus/material/purchase/service/impl/PurchaseBindServiceImpl.java @@ -233,23 +233,32 @@ public class PurchaseBindServiceImpl implements IPurchaseBindService { Collectors.mapping(PurchaseVo::getStatus, Collectors.toList()) )); result += groupedByIdStatus.entrySet().stream() - .mapToInt(entry -> { - Integer taskId = entry.getKey(); - List statusList = entry.getValue(); - if (statusList.contains(MaterialConstants.EIGHT_CONSTANT) || statusList.contains(MaterialConstants.THREE_CONSTANT)) { - return tmTaskMapper.updateStatusById(MaterialConstants.TEN_CONSTANT, taskId.toString()); - } else if (!statusList.contains(MaterialConstants.EIGHT_CONSTANT) && !statusList.contains(MaterialConstants.THREE_CONSTANT) - && statusList.contains(MaterialConstants.FOUR_CONSTANT)) { - return tmTaskMapper.updateStatusById(MaterialConstants.FIVE_CONSTANT, taskId.toString()); - } - return 0; - }).sum(); + .mapToInt(entry -> updateTaskStatus(entry.getKey(), entry.getValue())) + .sum(); if (result > 0) { return AjaxResult.success("绑定成功"); } return AjaxResult.error(HttpCodeEnum.FAIL.getCode(), HttpCodeEnum.FAIL.getMsg()); } + /** + * 提取状态更新逻辑到一个方法 + * @param taskId + * @param statusList + * @return + */ + private int updateTaskStatus(Integer taskId, List statusList) { + if (statusList.contains(MaterialConstants.EIGHT_CONSTANT) || + statusList.contains(MaterialConstants.THREE_CONSTANT)) { + return tmTaskMapper.updateStatusById(MaterialConstants.TEN_CONSTANT, taskId.toString()); + } else if (!statusList.contains(MaterialConstants.EIGHT_CONSTANT) && + !statusList.contains(MaterialConstants.THREE_CONSTANT) && + statusList.contains(MaterialConstants.FOUR_CONSTANT)) { + return tmTaskMapper.updateStatusById(MaterialConstants.FIVE_CONSTANT, taskId.toString()); + } + return 0; + } + /** * 下载二维码 * @param response diff --git a/bonus-modules/bonus-material/src/main/resources/mapper/material/task/TmTaskMapper.xml b/bonus-modules/bonus-material/src/main/resources/mapper/material/task/TmTaskMapper.xml index b5fccb36..26cb94d7 100644 --- a/bonus-modules/bonus-material/src/main/resources/mapper/material/task/TmTaskMapper.xml +++ b/bonus-modules/bonus-material/src/main/resources/mapper/material/task/TmTaskMapper.xml @@ -86,7 +86,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" - update tm_task set status = #{updatedStatus} where task_id = #{id} + update tm_task set task_status = #{updatedStatus} where task_id = #{id}