From 0a17fa9f5333e18de15a988133283f41b41fc89a Mon Sep 17 00:00:00 2001
From: pikachu <1321288662@qq.com>
Date: Tue, 10 Aug 2021 19:21:11 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E4=BC=9A=E5=91=98=E6=80=BB?=
 =?UTF-8?q?=E8=8E=B7=E5=BE=97=E7=A7=AF=E5=88=86api?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../member/PointsHistoryBuyerController.java  |  8 +++++
 .../service/MemberPointsHistoryService.java   | 12 +++++--
 .../MemberPointsHistoryServiceImpl.java       | 32 +++++++++++++++++++
 3 files changed, 49 insertions(+), 3 deletions(-)

diff --git a/buyer-api/src/main/java/cn/lili/controller/member/PointsHistoryBuyerController.java b/buyer-api/src/main/java/cn/lili/controller/member/PointsHistoryBuyerController.java
index 8bc163f1..3f3a6d60 100644
--- a/buyer-api/src/main/java/cn/lili/controller/member/PointsHistoryBuyerController.java
+++ b/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());
+    }
+
 }
diff --git a/framework/src/main/java/cn/lili/modules/member/service/MemberPointsHistoryService.java b/framework/src/main/java/cn/lili/modules/member/service/MemberPointsHistoryService.java
index ce523a6f..41edf1a5 100644
--- a/framework/src/main/java/cn/lili/modules/member/service/MemberPointsHistoryService.java
+++ b/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();
 
 }
\ No newline at end of file
diff --git a/framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberPointsHistoryServiceImpl.java b/framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberPointsHistoryServiceImpl.java
index 1920c783..e92ccf85 100644
--- a/framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberPointsHistoryServiceImpl.java
+++ b/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";
+    }
 }
\ No newline at end of file