全域VOC由异步入库改为同步入库，解决超过线程数据后无法入库

13693261870

2023-06-16 a17d95b52d4d2feb4b0af44b24884db8d8a8b067

 src/main/java/com/yssh/service/VocValsService.java

@@ -2,6 +2,7 @@

import com.google.common.collect.Lists;
import com.yssh.dao.VocValsMapper;
import com.yssh.entity.VocCoords;
import com.yssh.entity.VocVals;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -30,6 +31,11 @@
    }

    @Override
    public List<VocCoords> selectCoords(Integer x, Integer y) {
        return vocValsMapper.selectCoords(x, y);
    }

    @Override
    public int insert(VocVals vv) {
        return vocValsMapper.insert(vv);
    }
@@ -49,6 +55,15 @@
        return vocValsMapper.deleteByTime(time);
    }

    public void insertVocSync(List<VocVals> list) {
        List<List<VocVals>> subLists = Lists.partition(list, 100);
        for (List<VocVals> sub : subLists) {
            vocValsMapper.inserts(sub);
        }

        logger.info("------ VOC.csv，" + list.size() + " 条数据已入库 ------");
    }

    @Async("threadPoolTaskExecutor")
    public void insertVocVals(List<VocVals> list) throws InterruptedException {
        List<List<VocVals>> lists = Lists.partition(list, IAsyncService.BATCH_INSERT_500);