|
@@ -2,6 +2,7 @@ package com.jjt.out.service.impl;
|
|
|
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
|
|
+import com.github.pagehelper.PageHelper;
|
|
|
import com.jjt.common.domain.FileDesc;
|
|
|
import com.jjt.common.domain.IndexDO;
|
|
|
import com.jjt.common.enums.SyncType;
|
|
@@ -193,11 +194,13 @@ public class OutEsServiceImpl extends OutBaseService implements IOutEsService {
|
|
|
*/
|
|
|
@Override
|
|
|
public void clean() {
|
|
|
- //如果是增量,需要获取时间戳
|
|
|
+ //先获取上次备份的时间戳
|
|
|
OutProcessInfo pi = new OutProcessInfo();
|
|
|
pi.setProcessType(SyncType.es.toString());
|
|
|
+ PageHelper.startPage(1, 10, "create_time desc").setReasonable(true);
|
|
|
List<OutProcessInfo> list = processInfoService.selectOutProcessInfoList(pi);
|
|
|
String time = list.get(0).getProcessKey();
|
|
|
+
|
|
|
String params = sysConfigService.selectConfigByKey("out.es.connect");
|
|
|
JSONObject jsonObject = JSONObject.parseObject(params);
|
|
|
String index = jsonObject.getString("index");
|