代码修改

business/es-service/src/main/java/com/yihu/jw/es/service/DataService.java

@@ -20,6 +20,7 @@ import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;
/**
 * Created by yeshijie on 2024/8/15.
@@ -44,7 +45,9 @@ public class DataService {
            int num = delData(quotaDate, quotaCode, timeLevel);
            while (num==50000&&i<10){
                i++;
                TimeUnit.MILLISECONDS.sleep(100);
                num = delData(quotaDate, quotaCode, timeLevel);
                logger.info("============================="+i);
            }
        } catch (Exception e) {
@@ -81,14 +84,14 @@ public class DataService {
                bulkRequest.add(new DeleteRequest(esIndex)
                        .id(obj.getId()));
            }
            logger.info("delete size:"+result.size());
            num = result.size();
            logger.info("delete size:"+num);
            if (saveModels!=null&&saveModels.size()!=0){
                BulkResponse bulkResponse = restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);
                logger.info(bulkResponse.buildFailureMessage());
                logger.info("delete data count:" + saveModels.size());
                logger.info("delete flag:" + !bulkResponse.hasFailures());
            }
            num = result.size();
        } catch (Exception e) {
            logger.info("delete error:"+e.getMessage());
        }

svr/svr-statistics-hlw/src/main/java/com/yihu/jw/statistics/job/business/MysqlToEsQuotaJob.java

@@ -46,6 +46,7 @@ import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.concurrent.TimeUnit;
/**
 * Created by chenweida on 2017/7/10.
@@ -199,6 +200,7 @@ public class MysqlToEsQuotaJob implements Job {
            int num = delData(quotaDate, quotaCode, timeLevel);
            while (num==50000&&i<10){
                i++;
                TimeUnit.MILLISECONDS.sleep(100);
                num = delData(quotaDate, quotaCode, timeLevel);
            }
@@ -232,14 +234,15 @@ public class MysqlToEsQuotaJob implements Job {
                bulkRequest.add(new DeleteRequest(esIndex)
                        .id(obj.getId()));
            }
            logger.info("delete size:"+result.size());
            num = result.size();
            logger.info("delete size:"+num);
            if (saveModels!=null&&saveModels.size()!=0){
                BulkResponse bulkResponse = restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);
                logger.info(bulkResponse.buildFailureMessage());
                logger.info("delete data count:" + saveModels.size());
                logger.info("delete flag:" + !bulkResponse.hasFailures());
            }
            num = result.size();
        } catch (Exception e) {
            logger.info("delete error:"+e.getMessage());
        }