package kr.wisestone.owl.search;
|
|
import kr.wisestone.owl.constant.ElasticSearchConstants;
|
import kr.wisestone.owl.util.ElasticSearchUtil;
|
import kr.wisestone.owl.vo.UserVo;
|
import org.elasticsearch.action.ActionListener;
|
import org.elasticsearch.action.index.IndexRequest;
|
import org.elasticsearch.action.index.IndexResponse;
|
import org.elasticsearch.action.support.WriteRequest;
|
import org.elasticsearch.client.RequestOptions;
|
import org.elasticsearch.client.RestHighLevelClient;
|
import org.elasticsearch.common.xcontent.XContentType;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import javax.servlet.http.HttpServletRequest;
|
|
@Component
|
public class ElasticSearch {
|
private static final Logger log = LoggerFactory.getLogger(ElasticSearch.class);
|
|
@Autowired
|
private RestHighLevelClient restHighLevelClient;
|
|
/*// 사용자 시스템 사용 기록을 저장한다.
|
public void updateUserActiveHistory(HttpServletRequest httpServletRequest, UserVo userVo) {
|
IndexRequest request = new IndexRequest(ElasticSearchConstants.USER_SESSION_HISTORY_INDEX);
|
|
request.source(ElasticSearchUtil.makeUserActiveHistoryDocument(httpServletRequest, userVo), XContentType.JSON);
|
request.timeout("5s");
|
request.setRefreshPolicy(WriteRequest.RefreshPolicy.WAIT_UNTIL);
|
|
try {
|
this.restHighLevelClient.indexAsync(request, RequestOptions.DEFAULT, new ActionListener<IndexResponse>() {
|
@Override
|
public void onResponse(IndexResponse indexResponse) {
|
log.debug("사용자 시스템 사용 기록 인덱스 업데이트 성공");
|
}
|
|
@Override
|
public void onFailure(Exception ex) {
|
log.error("사용자 시스템 사용 기록 인덱스 업데이트 오류 : " + ex.getMessage());
|
}
|
});
|
} catch (Exception ex) {
|
log.error("사용자 시스템 사용 기록 인덱스 업데이트 오류 : " + ex.getMessage());
|
}
|
}*/
|
}
|
