## 余额汇总定时任务调整开放;
This commit is contained in:
parent
1227a8cf7f
commit
841058b359
|
@ -17,13 +17,6 @@ public interface IMemberJobServiceApi {
|
|||
*/
|
||||
R<?> insertAccountDetail();
|
||||
|
||||
/**
|
||||
* 自动提现
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
R<?> automaticWithdrawal();
|
||||
|
||||
/**
|
||||
* 每月月初定时删除上上个月的数据
|
||||
*
|
||||
|
@ -31,6 +24,13 @@ public interface IMemberJobServiceApi {
|
|||
*/
|
||||
R<?> deleteAccountDetailByMonth();
|
||||
|
||||
/**
|
||||
* 自动提现
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
R<?> automaticWithdrawal();
|
||||
|
||||
/**
|
||||
* 查询充值金额总和
|
||||
*
|
||||
|
|
|
@ -37,17 +37,6 @@ public class IMemberJobServiceProvider implements IMemberJobServiceApi {
|
|||
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
|
||||
public R<?> deleteAccountDetailByMonth() {
|
||||
try {
|
||||
|
@ -59,6 +48,18 @@ public class IMemberJobServiceProvider implements IMemberJobServiceApi {
|
|||
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
|
||||
public R<CuMemberRecharge> selectRechargeTotalAmount(Date startDate, Date endDate) {
|
||||
return R.ok(iCuMemberRechargeService.selectRechargeTotalAmount(startDate, endDate));
|
||||
|
|
|
@ -22,17 +22,24 @@ import java.util.List;
|
|||
public class CuMemberJob {
|
||||
|
||||
@DubboReference
|
||||
IMemberJobServiceApi memberJobServiceApi;
|
||||
|
||||
IMemberJobServiceApi iMemberJobServiceApi;
|
||||
@DubboReference
|
||||
IMemberServiceApi memberServiceApi;
|
||||
IMemberServiceApi iMemberServiceApi;
|
||||
|
||||
/**
|
||||
* 定时插入账户详情数据
|
||||
*/
|
||||
@XxlJob("insertAccountDetail")
|
||||
public void insertAccountDetail() {
|
||||
memberJobServiceApi.insertAccountDetail();
|
||||
iMemberJobServiceApi.insertAccountDetail();
|
||||
}
|
||||
|
||||
/**
|
||||
* 每月月初定时删除上上个月的数据
|
||||
*/
|
||||
@XxlJob("deleteAccountDetailByMonth")
|
||||
public void deleteAccountDetailByMonth() {
|
||||
iMemberJobServiceApi.deleteAccountDetailByMonth();
|
||||
}
|
||||
|
||||
/**
|
||||
|
@ -40,22 +47,12 @@ public class CuMemberJob {
|
|||
*/
|
||||
@XxlJob("automaticWithdrawal")
|
||||
public void automaticWithdrawal() {
|
||||
memberJobServiceApi.automaticWithdrawal();
|
||||
}
|
||||
|
||||
/**
|
||||
* 每月月初定时删除上上个月的数据
|
||||
*
|
||||
* @return Integer
|
||||
*/
|
||||
@XxlJob("deleteAccountDetailByMonth")
|
||||
public void deleteAccountDetailByMonth() {
|
||||
memberJobServiceApi.deleteAccountDetailByMonth();
|
||||
iMemberJobServiceApi.automaticWithdrawal();
|
||||
}
|
||||
|
||||
@XxlJob("sendPlaceErrorMsg")
|
||||
public void sendPlaceErrorMsg() {
|
||||
List<CuMemberExt> cuMemberList = memberServiceApi.queryPlaceErrorCode().getData();
|
||||
List<CuMemberExt> cuMemberList = iMemberServiceApi.queryPlaceErrorCode().getData();
|
||||
if (CollectionUtil.isNotEmpty(cuMemberList)) {
|
||||
StringBuilder sb = new StringBuilder();
|
||||
for (CuMemberExt cuMemberExt : cuMemberList) {
|
||||
|
@ -72,7 +69,7 @@ public class CuMemberJob {
|
|||
*/
|
||||
@XxlJob("updateMemberWhiteExpireDate")
|
||||
public void updateMemberExpireDate() {
|
||||
R<?> result = memberServiceApi.updateMemberExpireDate();
|
||||
R<?> result = iMemberServiceApi.updateMemberExpireDate();
|
||||
if (!result.isSuccess()) {
|
||||
log.error("提前四个月自动服务协议有效期续期一年,{}", result.getMsg());
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue