From 9f9bdc17eddca673e04ad35cc46f64854e725acb Mon Sep 17 00:00:00 2001
From: sangelxiu1 <15781802@163.com>
Date: Fri, 27 Jun 2025 11:27:30 +0800
Subject: [PATCH] =?UTF-8?q?##=20Feat=20-=20=E6=B8=85=E7=90=86=E6=95=B0?=
=?UTF-8?q?=E6=8D=AEJob=20(del=5Fflag=20=3D=201=20&=2030=E5=A4=A9=20awards?=
=?UTF-8?q?/level/grade)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../provider/IMemberJobServiceProvider.java | 13 +++++++++++
.../base/mapper/DeleteGarbageDataMapper.java | 22 ++++++++++++++++++
.../member/base/DeleteGarbageDataMapper.xml | 23 +++++++++++++++++++
.../java/com/hzs/third/job/CuMemberJob.java | 5 ++++
.../job/controller/JobTestController.java | 10 ++++++++
5 files changed, 73 insertions(+)
create mode 100644 bd-business/bd-business-member/src/main/java/com/hzs/member/base/mapper/DeleteGarbageDataMapper.java
create mode 100644 bd-business/bd-business-member/src/main/resources/mapper/member/base/DeleteGarbageDataMapper.xml
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 @@
+
+
+
+
+
+ delete from CU_MEMBER_AWARDS
+ where
+ CREATION_TIME (SYSDATE - #{days})
+ and DEL_FLAG = 1
+
+
+ delete from CU_MEMBER_AWARDS
+ where
+ CREATION_TIME (SYSDATE - #{days})
+ and DEL_FLAG = 1
+
+
+ delete from CU_MEMBER_AWARDS
+ where
+ CREATION_TIME (SYSDATE - #{days})
+ and DEL_FLAG = 1
+
+
diff --git a/bd-third/src/main/java/com/hzs/third/job/CuMemberJob.java b/bd-third/src/main/java/com/hzs/third/job/CuMemberJob.java
index bcac0ee7..ac5e366d 100644
--- a/bd-third/src/main/java/com/hzs/third/job/CuMemberJob.java
+++ b/bd-third/src/main/java/com/hzs/third/job/CuMemberJob.java
@@ -34,4 +34,9 @@ public class CuMemberJob {
iMemberJobServiceApi.automaticWithdrawal();
}
+ @XxlJob("autoDeleteGarbageData")
+ public void autoDeleteGarbageData(){
+ iMemberJobServiceApi.autoDeleteGarbageData();
+ }
+
}
diff --git a/bd-third/src/main/java/com/hzs/third/job/controller/JobTestController.java b/bd-third/src/main/java/com/hzs/third/job/controller/JobTestController.java
index bb2795b0..72160a75 100644
--- a/bd-third/src/main/java/com/hzs/third/job/controller/JobTestController.java
+++ b/bd-third/src/main/java/com/hzs/third/job/controller/JobTestController.java
@@ -6,6 +6,7 @@ import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.hzs.common.core.domain.R;
import com.hzs.common.core.web.domain.AjaxResult;
+import com.hzs.member.account.IMemberJobServiceApi;
import com.hzs.system.base.IAreaServiceApi;
import com.hzs.system.base.dto.AreaDTO;
import com.hzs.third.job.OrderJob;
@@ -29,6 +30,9 @@ public class JobTestController {
@DubboReference
IAreaServiceApi iAreaServiceApi;
+ @DubboReference
+ IMemberJobServiceApi iMemberJobServiceApi;
+
/**
* 测试行政区划更新
*
@@ -124,4 +128,10 @@ public class JobTestController {
return AjaxResult.error("处理失败：" + resultR.getMsg());
}
+
+ @GetMapping("/autoDeleteGarbageData")
+ public AjaxResult autoDeleteGarbageData() {
+ iMemberJobServiceApi.autoDeleteGarbageData();
+ return AjaxResult.success();
+ }
}