angelo
/
java-zk-app
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

## 定时任务判断调用是否成功判断方式修改；

This commit is contained in:
cabbage 2025-10-22 17:12:36 +08:00
parent e5568ca043
commit 2326c9d9d9
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
bd-business/bd-business-member/src/main/java/com/hzs/member/statis/service/impl/CuBonusVertexStatisServiceImpl.java
View File

@ -53,6 +53,11 @@ public class CuBonusVertexStatisServiceImpl extends ServiceImpl<CuBonusVertexSta
return dates; return dates;
} }
@Override
public Boolean delStatis(String startDate, String endDate, List<Integer> pkVertexList) {
return baseMapper.delStatis(startDate, endDate, pkVertexList);
}
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void anewStatisHistoryBonus(String startDate, String endDate) { public void anewStatisHistoryBonus(String startDate, String endDate) {
@ -126,11 +131,6 @@ public class CuBonusVertexStatisServiceImpl extends ServiceImpl<CuBonusVertexSta
} }
} }
@Override
public Boolean delStatis(String startDate, String endDate, List<Integer> pkVertexList) {
return baseMapper.delStatis(startDate, endDate, pkVertexList);
}
@Override @Override
public List<CuBonusVertexStatisVO> queryCuBonusStatis(CuBonusVertexStatisVO cuBonusVertexStatisVO) { public List<CuBonusVertexStatisVO> queryCuBonusStatis(CuBonusVertexStatisVO cuBonusVertexStatisVO) {
return baseMapper.queryCuBonusStatis(cuBonusVertexStatisVO); return baseMapper.queryCuBonusStatis(cuBonusVertexStatisVO);

6
bd-third/src/main/java/com/hzs/third/job/MemberJob.java
View File

@ -73,7 +73,7 @@ public class MemberJob {
date = DateUtils.beforeDate(1, ChronoUnit.DAYS, date); date = DateUtils.beforeDate(1, ChronoUnit.DAYS, date);
String payTimeStr = (DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, date)); String payTimeStr = (DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, date));
R<Boolean> statis = iCuBonusVertexStatisServiceApi.anewStatisHistoryBonus(payTimeStr, payTimeStr); R<Boolean> statis = iCuBonusVertexStatisServiceApi.anewStatisHistoryBonus(payTimeStr, payTimeStr);
if (!statis.getData()) { if (!statis.isSuccess()) {
log.info("{}-定时统计奖金拨统计失败", DateUtils.currentDate()); log.info("{}-定时统计奖金拨统计失败", DateUtils.currentDate());
} }
} }
@ -91,10 +91,10 @@ public class MemberJob {
String startDateStr = (DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, endDate)); String startDateStr = (DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, endDate));
//删除前6天的数据 //删除前6天的数据
R<Boolean> delstatis = iCuBonusVertexStatisServiceApi.delStatis(startDateStr, endDateStr); R<Boolean> delstatis = iCuBonusVertexStatisServiceApi.delStatis(startDateStr, endDateStr);
if (delstatis.getData()) { if (delstatis.isSuccess()) {
//重算前6天的数据 //重算前6天的数据
R<Boolean> statis = iCuBonusVertexStatisServiceApi.anewStatisHistoryBonus(startDateStr, endDateStr); R<Boolean> statis = iCuBonusVertexStatisServiceApi.anewStatisHistoryBonus(startDateStr, endDateStr);
if (!statis.getData()) { if (!statis.isSuccess()) {
log.info("{}-重算7天定时统计顶点奖金拨统计失败", DateUtils.currentDate()); log.info("{}-重算7天定时统计顶点奖金拨统计失败", DateUtils.currentDate());
} }
} }