From 43c5e331fa5325e382ecf94fe9e5a213864aeecd Mon Sep 17 00:00:00 2001
From: Jackwang <wt373747285@163.com>
Date: Tue, 25 Aug 2020 17:36:44 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=90=E5=A4=A7=E5=B1=8F=E5=B1=95=E7=A4=BA?=
 =?UTF-8?q?=E3=80=91-=E3=80=90=E6=B7=BB=E5=8A=A0=E6=9D=A1=E6=95=B0?=
 =?UTF-8?q?=E9=99=90=E5=88=B6=EF=BC=882000=EF=BC=89=E3=80=91-=EF=BC=88?=
 =?UTF-8?q?=E7=8E=8B=E7=AB=A5=EF=BC=89-2020/8/25?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/DataStatsScreencollServiceImpl.java  | 52 ++++++++++++++++---
 1 file changed, 44 insertions(+), 8 deletions(-)

diff --git a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/DataStatsScreencollServiceImpl.java b/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/DataStatsScreencollServiceImpl.java
index c0f0acab8..3965dd526 100644
--- a/esua-epdc/epdc-module/epdc-analysis/epdc-analysis-server/src/main/java/com/elink/esua/epdc/modules/screen/service/impl/DataStatsScreencollServiceImpl.java
+++ b/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;
+	}
 }