修复会员总获得积分api

buyer-api/src/main/java/cn/lili/controller/member/PointsHistoryBuyerController.java

@@ -15,6 +15,7 @@ import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
@@ -46,4 +47,11 @@ public class PointsHistoryBuyerController {
     public ResultMessage<MemberPointsHistoryVO> getMemberPointsHistoryVO() {
         return ResultUtil.data(memberPointsHistoryService.getMemberPointsHistoryVO(UserContext.getCurrentUser().getId()));
     }
+
+    @ApiOperation(value = "修复会员总获得积分数据")
+    @PostMapping(value = "/repairPointData")
+    public ResultMessage<String> repairPointData() {
+        return ResultUtil.data(memberPointsHistoryService.repairPointData());
+    }
+
 }

framework/src/main/java/cn/lili/modules/member/service/MemberPointsHistoryService.java

@@ -24,11 +24,17 @@ public interface MemberPointsHistoryService extends IService<MemberPointsHistory
 
     /**
      * 会员积分历史
-     * @param page 分页
+     *
-     * @param memberId 会员ID
+     * @param page       分页
+     * @param memberId   会员ID
      * @param memberName 会员名称
      * @return 积分历史分页
      */
-    IPage<MemberPointsHistory>  MemberPointsHistoryList(PageVO page, String memberId, String memberName);
+    IPage<MemberPointsHistory> MemberPointsHistoryList(PageVO page, String memberId, String memberName);
+
+    /**
+     * 修复会员总积分数据
+     */
+    String repairPointData();
 
 }

framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberPointsHistoryServiceImpl.java

@@ -3,6 +3,7 @@ package cn.lili.modules.member.serviceimpl;
 
 import cn.lili.modules.member.entity.dos.Member;
 import cn.lili.modules.member.entity.enums.PointTypeEnum;
+import cn.lili.modules.member.mapper.MemberMapper;
 import cn.lili.modules.member.service.MemberService;
 import cn.lili.mybatis.util.PageUtil;
 import cn.lili.common.utils.StringUtils;
@@ -12,11 +13,15 @@ import cn.lili.modules.member.entity.vo.MemberPointsHistoryVO;
 import cn.lili.modules.member.mapper.MemberPointsHistoryMapper;
 import cn.lili.modules.member.service.MemberPointsHistoryService;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.ArrayList;
+import java.util.List;
+
 /**
  * 会员积分历史业务层实现
  *
@@ -30,6 +35,12 @@ public class MemberPointsHistoryServiceImpl extends ServiceImpl<MemberPointsHist
     @Autowired
     private MemberService memberService;
 
+    @Autowired
+    private MemberMapper memberMapper;
+
+    @Autowired
+    private MemberPointsHistoryMapper memberPointsHistoryMapper;
+
     @Override
     public MemberPointsHistoryVO getMemberPointsHistoryVO(String memberId) {
         //获取会员积分历史
@@ -55,4 +66,25 @@ public class MemberPointsHistoryServiceImpl extends ServiceImpl<MemberPointsHist
         }
         return this.page(PageUtil.initPage(page), lambdaQueryWrapper);
     }
+
+
+    @Override
+    public String repairPointData() {
+        List<Member> memberList = memberMapper.selectList(new QueryWrapper<Member>());
+        for (Member member : memberList) {
+            QueryWrapper<MemberPointsHistory> queryWrapper = new QueryWrapper<>();
+            queryWrapper.eq("member_id", member.getId());
+            queryWrapper.eq("point_type", PointTypeEnum.INCREASE.name());
+            List<MemberPointsHistory> memberPointsHistorys = memberPointsHistoryMapper.selectList(queryWrapper);
+            Long point = 0L;
+            if (memberPointsHistorys.size() > 0) {
+                for (MemberPointsHistory memberPointsHistory : memberPointsHistorys) {
+                    point += memberPointsHistory.getVariablePoint();
+                }
+            }
+            member.setTotalPoint(point);
+            memberMapper.updateById(member);
+        }
+        return "SUCCESS";
+    }
 }