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> 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 list = baseDao.meetdata(); - // 将list转换为json格式 - String json = JSONObject.toJSONString(list); - String body = EpmetUtils.httpPost("/data/stats/screencoll/meetdata", json); - log.info(body); + List> 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 + * @return + */ + public static List> fixedGrouping(List source, int n) { + + if (null == source || source.size() == 0 || n <= 0) + return null; + List> result = new ArrayList>(); + int remainder = source.size() % n; + int size = (source.size() / n); + for (int i = 0; i < size; i++) { + List subset = null; + subset = source.subList(i * n, (i + 1) * n); + result.add(subset); + } + if (remainder > 0) { + List subset = null; + subset = source.subList(size * n, size * n + remainder); + result.add(subset); + } + return result; + } }