|
@@ -943,6 +943,7 @@ public class HandleDataController extends BaseController
|
|
|
|
|
|
int num = ( count / size ) + 1;
|
|
|
|
|
|
+ int index = 0;
|
|
|
for (int i = 0; i < num; i++) {
|
|
|
List<TXinyiIndustry> tXinyiIndustries = xinyiIndustryMapper.selectTXinyiIndustryListByPage(i * size, size);
|
|
|
if ( !CollectionUtils.isEmpty(tXinyiIndustries) ) {
|
|
@@ -983,6 +984,8 @@ public class HandleDataController extends BaseController
|
|
|
}
|
|
|
|
|
|
if (!CollectionUtils.isEmpty(tXinyiBigTableHourList)) {
|
|
|
+ index += tXinyiBigTableHourList.size();
|
|
|
+
|
|
|
SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH,false);
|
|
|
TXinyiBigTableHourMapper sqlSessionMapper = sqlSession.getMapper(TXinyiBigTableHourMapper.class);
|
|
|
tXinyiBigTableHourList.stream().forEach(item -> sqlSessionMapper.insertTXinyiBigTableHour(item));
|
|
@@ -992,6 +995,8 @@ public class HandleDataController extends BaseController
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ System.out.println( "index :::" + index );
|
|
|
+
|
|
|
long end = System.currentTimeMillis();
|
|
|
return "ok;耗时:" + (end - begin) /1000 + "秒。";
|
|
|
}
|