diff --git a/bd-business/bd-business-member/src/main/java/com/hzs/member/account/provider/IMemberJobServiceProvider.java b/bd-business/bd-business-member/src/main/java/com/hzs/member/account/provider/IMemberJobServiceProvider.java index ad0ff2d4..9d6ed75e 100644 --- a/bd-business/bd-business-member/src/main/java/com/hzs/member/account/provider/IMemberJobServiceProvider.java +++ b/bd-business/bd-business-member/src/main/java/com/hzs/member/account/provider/IMemberJobServiceProvider.java @@ -6,6 +6,7 @@ import com.hzs.member.account.IMemberJobServiceApi; import com.hzs.member.account.service.ICuMemberAccountDetailService; import com.hzs.member.account.service.ICuMemberRechargeService; import com.hzs.member.account.service.ICuMemberWithdrawService; +import com.hzs.member.base.mapper.DeleteGarbageDataMapper; import lombok.extern.slf4j.Slf4j; import org.apache.dubbo.config.annotation.DubboService; import org.springframework.beans.factory.annotation.Autowired; @@ -35,6 +36,10 @@ public class IMemberJobServiceProvider implements IMemberJobServiceApi { @Autowired private ICuMemberRechargeService memberRechargeService; + @Autowired + private DeleteGarbageDataMapper deleteGarbageDataMapper; + + @Override public R insertAccountDetail() { try { @@ -64,4 +69,12 @@ public class IMemberJobServiceProvider implements IMemberJobServiceApi { return R.ok(memberRechargeService.selectRechargeTotalAmount(startDate, endDate)); } + @Override + public R autoDeleteGarbageData() { + deleteGarbageDataMapper.deleteMemberAwards(30); + deleteGarbageDataMapper.deleteMemberLevel(30); + deleteGarbageDataMapper.deleteMemberGrade(30); + return R.ok(); + } + } diff --git a/bd-business/bd-business-member/src/main/java/com/hzs/member/base/mapper/DeleteGarbageDataMapper.java b/bd-business/bd-business-member/src/main/java/com/hzs/member/base/mapper/DeleteGarbageDataMapper.java new file mode 100644 index 00000000..6fdb3525 --- /dev/null +++ b/bd-business/bd-business-member/src/main/java/com/hzs/member/base/mapper/DeleteGarbageDataMapper.java @@ -0,0 +1,22 @@ +package com.hzs.member.base.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.hzs.common.domain.member.base.CuMemberAgent; +import org.apache.ibatis.annotations.Param; + +import java.util.Date; + +/** + *
+ * 会员信息-代理商信息 Mapper 接口 + *
+ * + * @author hzs + * @since 2022-08-31 + */ +public interface DeleteGarbageDataMapper extends BaseMapper { + + void deleteMemberAwards(@Param("days") Integer days); + void deleteMemberLevel(@Param("days") Integer days); + void deleteMemberGrade(@Param("days") Integer days); +} diff --git a/bd-business/bd-business-member/src/main/resources/mapper/member/base/DeleteGarbageDataMapper.xml b/bd-business/bd-business-member/src/main/resources/mapper/member/base/DeleteGarbageDataMapper.xml new file mode 100644 index 00000000..9a8b57eb --- /dev/null +++ b/bd-business/bd-business-member/src/main/resources/mapper/member/base/DeleteGarbageDataMapper.xml @@ -0,0 +1,23 @@ + + +