//package com.product.kt.test.service;
|
//
|
//import java.util.List;
|
//import java.util.concurrent.Future;
|
//
|
//import org.slf4j.Logger;
|
//import org.slf4j.LoggerFactory;
|
//import org.springframework.beans.factory.annotation.Autowired;
|
//import org.springframework.scheduling.annotation.Async;
|
//import org.springframework.scheduling.annotation.AsyncResult;
|
//import org.springframework.stereotype.Component;
|
//
|
//import com.product.core.entity.FieldSetEntity;
|
//
|
//
|
//@Component
|
//public class SyncToolsHandler {
|
//
|
// private static final Logger LOG = LoggerFactory.getLogger(SyncToolsHandler.class);
|
//
|
// @Autowired
|
// WriteToolService writeToolService;
|
//
|
// /**
|
// * 异步执行
|
// *
|
// * @param readToolList
|
// * @param pageIndex
|
// * @return
|
// */
|
//// @Async("ToolTask")
|
// public Future<String> syncTools(List<FieldSetEntity> readToolList, int pageIndex, String tableName, String timeField) {
|
//
|
// System.out.println("thread name " + Thread.currentThread().getName());
|
//
|
// LOG.info(String.format("此批数据的段数为:%s 此段数据的数据条数为:%s", pageIndex, readToolList.size()));
|
//
|
// //声明future对象
|
// Future<String> result = new AsyncResult<String>("");
|
//
|
// //循环遍历
|
// if (null != readToolList && readToolList.size() > 0) {
|
// try {
|
// int listSize = readToolList.size();
|
// int listStart = 0, listEnd = 0;
|
// int ropeNum = listSize / 2000;
|
//
|
// for (int i = 0; i < ropeNum; i++) {
|
// //数据入库操作
|
// listStart = i * 2000;
|
// listEnd = i * 2000 + 2000;
|
// writeToolService.writeData(readToolList.subList(listStart, listEnd), tableName, timeField);
|
// }
|
// writeToolService.writeData(readToolList.subList(listEnd, listSize), tableName, timeField);
|
//
|
// } catch (Exception e) {
|
// //记录出现异常的时间，线程name
|
// result = new AsyncResult<String>("fail,time=" + System.currentTimeMillis() + ",thread id=" + Thread.currentThread().getName() + ",pageIndex=" + pageIndex);
|
// }
|
// }
|
// return result;
|
// }
|
//}
|
