Commit e6aefe2e authored by 赵啸非's avatar 赵啸非

修改获取轮训redis

parent ad507cc7
......@@ -42,7 +42,7 @@ public class StaffCheckSummaryService implements IApplicationStartedService {
int waitTime = 1000;
while (!stopped) {
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(query.getCheckType() == CheckTypeEnum.考勤绩效.getValue()){
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