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

修改获取轮训redis

parent a009fd63
......@@ -36,10 +36,10 @@ public class AttendSummaryService implements IApplicationStartedService {
Thread sendThread = new Thread(new Runnable() {
@Override
public void run() {
int waitTime = 10;
int waitTime = 100;
while (!stopped) {
try {
AttendanceSummaryQuery query = cacheService.rpop(KEY_ATTENDANCE_STAT_CACHE, AttendanceSummaryQuery.class);
AttendanceSummaryQuery query = cacheService.brpop(KEY_ATTENDANCE_STAT_CACHE, 60,AttendanceSummaryQuery.class);
if(!ObjectUtils.isEmpty(query)){
if (StringUtils.isNotEmpty(query.getSummaryTimeStart()) && StringUtils.isNotEmpty(query.getSummaryTimeEnd())) {
List<String> dateList = getDatesBetween(query.getSummaryTimeStart(), query.getSummaryTimeEnd());
......
......@@ -39,7 +39,7 @@ public class StaffCheckSummaryService implements IApplicationStartedService {
Thread sendThread = new Thread(new Runnable() {
@Override
public void run() {
int waitTime = 10;
int waitTime = 100;
while (!stopped) {
try {
StaffCheckSummaryQuery query = cacheService.brpop(KEY_CHECK_SUMMARY_CACHE,60, StaffCheckSummaryQuery.class);
......
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