明细接口改造

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/service/impl/TForecastLibraryServiceImpl.java

@@ -2491,7 +2491,23 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
 			} else {
 				selectVoMap = this.getSelectVoMap();
 			}
-			initEkpPushSocialParam(library,synFlag, selectVoMap);
+			int i = (int) Math.ceil((double) library.size() / CommonConstants.ONE_THOUSAND_INT);
+			if (!library.isEmpty()) {
+				List<TForecastLibrary> pushList;
+				int k = 0;
+				for (int j = 0; j < i; j++) {
+					if (j == i - 1) {
+						pushList = library.subList(k, library.size());
+					} else {
+						pushList = library.subList(k, k + 1000);
+					}
+					k = k + 1000;
+					if (Common.isNotNull(pushList)) {
+						//推送数据封装并推送
+						initEkpPushSocialParam(pushList,synFlag, selectVoMap);
+					}
+				}
+			}
 		}
 	}
 
@@ -2506,7 +2522,23 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
 				selectVoMap = this.getSelectVoMap();
 			}
 			//推送数据封装并推送
-			initEkpPushFundParam(library,synFlag, selectVoMap);
+			int i = (int) Math.ceil((double) library.size() / CommonConstants.ONE_THOUSAND_INT);
+			if (!library.isEmpty()) {
+				List<TForecastLibrary> pushList;
+				int k = 0;
+				for (int j = 0; j < i; j++) {
+					if (j == i - 1) {
+						pushList = library.subList(k, library.size());
+					} else {
+						pushList = library.subList(k, k + 1000);
+					}
+					k = k + 1000;
+					if (Common.isNotNull(pushList)) {
+						//推送数据封装并推送
+						initEkpPushFundParam(pushList,synFlag, selectVoMap);
+					}
+				}
+			}
 		}
 	}