package com.yeshi.fanli.job.money;
|
|
import com.xxl.job.core.biz.model.ReturnT;
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
import com.yeshi.fanli.service.inter.money.UserMoneyDebtService;
|
import com.yeshi.fanli.util.StringUtil;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.util.List;
|
|
@Component
|
public class UserMoneyJob {
|
|
@Resource
|
private UserMoneyDebtService userMoneyDebtService;
|
|
/**
|
* 还账
|
*
|
* @param param 用户ID
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("usermoney-repayDebt")
|
public ReturnT<String> repayDebt(String param) throws Exception {
|
if (!StringUtil.isNullOrEmpty(param)) {
|
userMoneyDebtService.repayDebt(Long.parseLong(param));
|
} else {
|
long count = userMoneyDebtService.countNeedRepayDebtUser();
|
int page = (int) (count % 100 == 0 ? count / 100 : count / 100 + 1);
|
for (int i = 0; i < page; i++) {
|
List<Long> uids = userMoneyDebtService.listNeedRepayDebtUser(i + 1, 100);
|
for (long uid : uids) {
|
userMoneyDebtService.repayDebt(uid);
|
}
|
}
|
}
|
return ReturnT.SUCCESS;
|
}
|
}
|
