Commit 6c18fb85 authored by 赵啸非's avatar 赵啸非

修改获取轮训redis

parent 1e127744
...@@ -42,7 +42,7 @@ public class StaffCheckSummaryService implements IApplicationStartedService { ...@@ -42,7 +42,7 @@ public class StaffCheckSummaryService implements IApplicationStartedService {
int waitTime = 10; int waitTime = 10;
while (!stopped) { while (!stopped) {
try { try {
StaffCheckSummaryQuery query = cacheService.rpop(KEY_CHECK_SUMMARY_CACHE, StaffCheckSummaryQuery.class); StaffCheckSummaryQuery query = cacheService.brpop(KEY_CHECK_SUMMARY_CACHE,60, StaffCheckSummaryQuery.class);
if(!ObjectUtils.isEmpty(query)){ if(!ObjectUtils.isEmpty(query)){
if(query.getCheckType() == CheckTypeEnum.考勤绩效.getValue()){ if(query.getCheckType() == CheckTypeEnum.考勤绩效.getValue()){
checkAttendRecordService.summaryCheck(query); checkAttendRecordService.summaryCheck(query);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment