【大屏展示】-【添加条数限制（2000）】-（王童）-2020/8/25

esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/DataStatsScreencollServiceImpl.java

@@ -11,6 +11,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
 
+import java.util.ArrayList;
 import java.util.List;
 
 /**
@@ -44,10 +45,14 @@ public class DataStatsScreencollServiceImpl extends BaseServiceImpl<DataStatsScr
 				re.getImgDataList().get(x).setSort(x+1);
 			}
 		}
-		// 将list转换为json格式
-		String json = JSONObject.toJSONString(list);
-		String body = EpmetUtils.httpPost("/data/stats/screencoll/eventdata", json);
-		log.info(body);
+
+		List<List<EventdataResultDTO>> formList = fixedGrouping(list,2000);
+		for(int i = 0 ; i < formList.size() ; i++){
+			// 将list转换为json格式
+			String json = JSONObject.toJSONString(formList.get(i));
+			String body = EpmetUtils.httpPost("/data/stats/screencoll/eventdata", json);
+			log.info(body);
+		}
 		return null;
 	}
 
@@ -84,10 +89,13 @@ public class DataStatsScreencollServiceImpl extends BaseServiceImpl<DataStatsScr
 	@Override
 	public Result meetdata() {
 		List<MeetdataResultDTO> list = baseDao.meetdata();
-		// 将list转换为json格式
-		String json = JSONObject.toJSONString(list);
-		String body = EpmetUtils.httpPost("/data/stats/screencoll/meetdata", json);
-		log.info(body);
+		List<List<MeetdataResultDTO>> formList = fixedGrouping(list,2000);
+		for(int i = 0 ; i < formList.size() ; i++){
+			// 将list转换为json格式
+			String json = JSONObject.toJSONString(formList.get(i));
+			String body = EpmetUtils.httpPost("/data/stats/screencoll/meetdata", json);
+			log.info(body);
+		}
 		return null;
 	}
 
@@ -120,4 +128,32 @@ public class DataStatsScreencollServiceImpl extends BaseServiceImpl<DataStatsScr
 		log.info(body);
 		return null;
 	}
+
+	/**
+	 * 将一组数据固定分组，每组n个元素
+	 *
+	 * @param source 要分组的数据源
+	 * @param n      每组n个元素
+	 * @param <T>
+	 * @return
+	 */
+	public static <T> List<List<T>> fixedGrouping(List<T> source, int n) {
+
+		if (null == source || source.size() == 0 || n <= 0)
+			return null;
+		List<List<T>> result = new ArrayList<List<T>>();
+		int remainder = source.size() % n;
+		int size = (source.size() / n);
+		for (int i = 0; i < size; i++) {
+			List<T> subset = null;
+			subset = source.subList(i * n, (i + 1) * n);
+			result.add(subset);
+		}
+		if (remainder > 0) {
+			List<T> subset = null;
+			subset = source.subList(size * n, size * n + remainder);
+			result.add(subset);
+		}
+		return result;
+	}
 }