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

修改获取轮训redis

parent b2206f6a
......@@ -39,10 +39,10 @@ public class StaffCheckSummaryService implements IApplicationStartedService {
Thread sendThread = new Thread(new Runnable() {
@Override
public void run() {
int waitTime = 100;
int waitTime = 1000;
while (!stopped) {
try {
StaffCheckSummaryQuery query = cacheService.brpop(KEY_CHECK_SUMMARY_CACHE,60, StaffCheckSummaryQuery.class);
StaffCheckSummaryQuery query = cacheService.rpop(KEY_CHECK_SUMMARY_CACHE, 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