package com.iplatform.base.controller;
|
|
import com.iplatform.base.SystemController;
|
import com.iplatform.base.util.UserUtils;
|
import com.walker.cache.AbstractCacheProvider;
|
import com.walker.web.ResponseValue;
|
import com.walker.web.UserOnlineProvider;
|
import com.walker.web.UserPrincipal;
|
import com.walker.web.WebRuntimeException;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.util.ArrayList;
|
import java.util.Collection;
|
import java.util.List;
|
|
@RestController
|
@RequestMapping("/monitor/online")
|
public class OnlineUserController extends SystemController {
|
|
private static final int MAX_DATA_SIZE = 64;
|
|
private UserOnlineProvider userOnlineProvider;
|
|
@Autowired
|
public OnlineUserController(UserOnlineProvider userOnlineProvider){
|
this.userOnlineProvider = userOnlineProvider;
|
}
|
|
@RequestMapping("/list")
|
public ResponseValue list(){
|
AbstractCacheProvider cacheProvider = (AbstractCacheProvider)this.userOnlineProvider;
|
Collection<Object> list = cacheProvider.queryListLimit(MAX_DATA_SIZE);
|
List<UserPrincipal> data = new ArrayList<>();
|
if(list != null && list.size() > 0){
|
try {
|
for(Object up : list){
|
// logger.debug(up.toString());
|
data.add(UserUtils.toUserPrincipal(up.toString()));
|
}
|
} catch (Exception ex){
|
throw new WebRuntimeException("在线用户缓存对象转换错误:");
|
}
|
}
|
return this.acquireTablePage(data, data.size());
|
}
|
}
|
