## 余额汇总定时任务调整开放;

This commit is contained in:
cabbage 2025-05-20 15:32:33 +08:00
parent 961340890f
commit 9fe54c65b5
3 changed files with 33 additions and 35 deletions

View File

@ -17,13 +17,6 @@ public interface IMemberJobServiceApi {
*/ */
R<?> insertAccountDetail(); R<?> insertAccountDetail();
/**
* 自动提现
*
* @return
*/
R<?> automaticWithdrawal();
/** /**
* 每月月初定时删除上上个月的数据 * 每月月初定时删除上上个月的数据
* *
@ -31,6 +24,13 @@ public interface IMemberJobServiceApi {
*/ */
R<?> deleteAccountDetailByMonth(); R<?> deleteAccountDetailByMonth();
/**
* 自动提现
*
* @return
*/
R<?> automaticWithdrawal();
/** /**
* 查询充值金额总和 * 查询充值金额总和
* *

View File

@ -37,17 +37,6 @@ public class IMemberJobServiceProvider implements IMemberJobServiceApi {
return R.ok(); return R.ok();
} }
@Override
public R<?> automaticWithdrawal() {
try {
iCuMemberWithdrawService.autoWithdraw();
} catch (Exception e) {
log.info("自动提现报错:", e);
return R.fail(e.getMessage());
}
return R.ok();
}
@Override @Override
public R<?> deleteAccountDetailByMonth() { public R<?> deleteAccountDetailByMonth() {
try { try {
@ -59,6 +48,18 @@ public class IMemberJobServiceProvider implements IMemberJobServiceApi {
return R.ok(); return R.ok();
} }
@Override
public R<?> automaticWithdrawal() {
try {
iCuMemberWithdrawService.autoWithdraw();
} catch (Exception e) {
log.info("自动提现报错:", e);
return R.fail(e.getMessage());
}
return R.ok();
}
@Override @Override
public R<CuMemberRecharge> selectRechargeTotalAmount(Date startDate, Date endDate) { public R<CuMemberRecharge> selectRechargeTotalAmount(Date startDate, Date endDate) {
return R.ok(iCuMemberRechargeService.selectRechargeTotalAmount(startDate, endDate)); return R.ok(iCuMemberRechargeService.selectRechargeTotalAmount(startDate, endDate));

View File

@ -22,17 +22,24 @@ import java.util.List;
public class CuMemberJob { public class CuMemberJob {
@DubboReference @DubboReference
IMemberJobServiceApi memberJobServiceApi; IMemberJobServiceApi iMemberJobServiceApi;
@DubboReference @DubboReference
IMemberServiceApi memberServiceApi; IMemberServiceApi iMemberServiceApi;
/** /**
* 定时插入账户详情数据 * 定时插入账户详情数据
*/ */
@XxlJob("insertAccountDetail") @XxlJob("insertAccountDetail")
public void insertAccountDetail() { public void insertAccountDetail() {
memberJobServiceApi.insertAccountDetail(); iMemberJobServiceApi.insertAccountDetail();
}
/**
* 每月月初定时删除上上个月的数据
*/
@XxlJob("deleteAccountDetailByMonth")
public void deleteAccountDetailByMonth() {
iMemberJobServiceApi.deleteAccountDetailByMonth();
} }
/** /**
@ -40,22 +47,12 @@ public class CuMemberJob {
*/ */
@XxlJob("automaticWithdrawal") @XxlJob("automaticWithdrawal")
public void automaticWithdrawal() { public void automaticWithdrawal() {
memberJobServiceApi.automaticWithdrawal(); iMemberJobServiceApi.automaticWithdrawal();
}
/**
* 每月月初定时删除上上个月的数据
*
* @return Integer
*/
@XxlJob("deleteAccountDetailByMonth")
public void deleteAccountDetailByMonth() {
memberJobServiceApi.deleteAccountDetailByMonth();
} }
@XxlJob("sendPlaceErrorMsg") @XxlJob("sendPlaceErrorMsg")
public void sendPlaceErrorMsg() { public void sendPlaceErrorMsg() {
List<CuMemberExt> cuMemberList = memberServiceApi.queryPlaceErrorCode().getData(); List<CuMemberExt> cuMemberList = iMemberServiceApi.queryPlaceErrorCode().getData();
if (CollectionUtil.isNotEmpty(cuMemberList)) { if (CollectionUtil.isNotEmpty(cuMemberList)) {
StringBuilder sb = new StringBuilder(); StringBuilder sb = new StringBuilder();
for (CuMemberExt cuMemberExt : cuMemberList) { for (CuMemberExt cuMemberExt : cuMemberList) {
@ -72,7 +69,7 @@ public class CuMemberJob {
*/ */
@XxlJob("updateMemberWhiteExpireDate") @XxlJob("updateMemberWhiteExpireDate")
public void updateMemberExpireDate() { public void updateMemberExpireDate() {
R<?> result = memberServiceApi.updateMemberExpireDate(); R<?> result = iMemberServiceApi.updateMemberExpireDate();
if (!result.isSuccess()) { if (!result.isSuccess()) {
log.error("提前四个月自动服务协议有效期续期一年,{}", result.getMsg()); log.error("提前四个月自动服务协议有效期续期一年,{}", result.getMsg());
} }