|
...
|
...
|
@@ -17,7 +17,6 @@ import org.slf4j.LoggerFactory; |
|
|
|
import org.springframework.scheduling.annotation.Scheduled;
|
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
|
import com.yoho.activity.common.enums.UserTypeEnum;
|
|
|
|
import com.yoho.activity.common.utils.MapUtil;
|
|
|
|
import com.yoho.activity.common.utils.MapUtil.FunctionExPlus;
|
|
...
|
...
|
@@ -101,7 +100,6 @@ public class AddVirtualUserTimer { |
|
|
|
waitAddUserMap.put(activity.getId(), waitList);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
System.out.println("result= " + JSON.toJSONString(waitAddUserMap));
|
|
|
|
}
|
|
|
|
|
|
|
|
@Scheduled(fixedDelay = 60 * 1000)
|
|
...
|
...
|
@@ -151,7 +149,7 @@ public class AddVirtualUserTimer { |
|
|
|
}
|
|
|
|
waitList = waitAddUserMap.get(activity.getId());
|
|
|
|
if (waitList == null || waitList.size() == 0) {
|
|
|
|
log.info("wait queue user is empty");
|
|
|
|
log.info("wait queue user is empty with activityId is {}, activityName is {}", activity.getId(), activity.getActivityName());
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
if (first.get(activity.getId()) == null) {
|
...
|
...
|
|
