code-image-backup-public/lilishop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

删除积分修复数据

Browse Source
This commit is contained in:
pikachu
2021-08-10 19:25:30 +08:00
parent 0a17fa9f53
commit 7b7bab44c7
3 changed files with 0 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -32,9 +32,4 @@ public interface MemberPointsHistoryService extends IService<MemberPointsHistory
*/
IPage<MemberPointsHistory> MemberPointsHistoryList(PageVO page, String memberId, String memberName);
/**
* 修复会员总积分数据
*/
String repairPointData();
}

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

@@ -35,12 +35,6 @@ public class MemberPointsHistoryServiceImpl extends ServiceImpl<MemberPointsHist
@Autowired
private MemberService memberService;
@Autowired
private MemberMapper memberMapper;
@Autowired
private MemberPointsHistoryMapper memberPointsHistoryMapper;
@Override
public MemberPointsHistoryVO getMemberPointsHistoryVO(String memberId) {
//获取会员积分历史
@@ -67,24 +61,4 @@ 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";
}
}