|
@@ -57,8 +57,8 @@ public class CleanDataTask {
|
|
|
restClient6 = bbossESStarterEs5.getRestClient("es6");
|
|
|
}
|
|
|
|
|
|
- @Scheduled(cron = "*/30 * * * * ?")
|
|
|
- //@Scheduled(cron = "0 /2 * * * ? ")
|
|
|
+ //@Scheduled(cron = "*/30 * * * * ?")
|
|
|
+ @Scheduled(cron = "00 00 06 * * ?")
|
|
|
public void start() throws InterruptedException {
|
|
|
log.info("startJob CleanDataTask !!! ");
|
|
|
|
|
@@ -66,14 +66,13 @@ public class CleanDataTask {
|
|
|
String case_mongo = "sifa_remove_user";
|
|
|
int batchSize = 200;
|
|
|
|
|
|
-// String wenshu_index = "wenshu_detail2";
|
|
|
-// String judicial_case_index = "winhc_judicial_case_v2";
|
|
|
-// String judicial_case_detail_index = "winhc_judicial_case_detail_v2";
|
|
|
-
|
|
|
- String wenshu_index = "test_wenshu";
|
|
|
- String judicial_case_index = "test_case1";
|
|
|
- String judicial_case_detail_index = "test_case2";
|
|
|
+ String wenshu_index = "wenshu_detail2";
|
|
|
+ String judicial_case_index = "winhc_judicial_case_v2";
|
|
|
+ String judicial_case_detail_index = "winhc_judicial_case_detail_v2";
|
|
|
|
|
|
+// String wenshu_index = "test_wenshu";
|
|
|
+// String judicial_case_index = "test_case1";
|
|
|
+// String judicial_case_detail_index = "test_case2";
|
|
|
|
|
|
//先查询mongo再删除es文书
|
|
|
step1(wenshu_mongo, wenshu_index, batchSize);
|