新购绑定

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 -> {
+                .mapToInt(entry -> updateTaskStatus(entry.getKey(), entry.getValue()))
-                    Integer taskId = entry.getKey();
+                .sum();
-                    List<Integer> 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();
         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<Integer> 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

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>
 
     <update id="updateStatusById">
-        update tm_task set status = #{updatedStatus} where task_id = #{id}
+        update tm_task set task_status = #{updatedStatus} where task_id = #{id}
     </update>
 
     <delete id="deleteTmTaskByTaskId" parameterType="Long">