明细接口改造

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

@@ -2424,6 +2424,7 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
 				List<TForecastLibrary> pushList;
 				int k = 0;
 				for (int j = 0; j < i; j++) {
+					synchronized (this) {
 						if (j == i - 1) {
 							pushList = unPushInfo.subList(k, unPushInfo.size());
 						} else {
@@ -2438,6 +2439,7 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
 				}
 			}
 		}
+	}
 
 	private Map<String, TSettleDomainSelectVo> getSelectVoMap() {
 		R<TSettleDomainListVo> settleDomainR = archivesDaprUtil.selectAllSettleDomainSelectVos();
@@ -2465,6 +2467,7 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
 				List<TForecastLibrary> pushList;
 				int k = 0;
 				for (int j = 0; j < i; j++) {
+					synchronized (this) {
 						if (j == i - 1) {
 							pushList = unPushInfo.subList(k, unPushInfo.size());
 						} else {
@@ -2479,6 +2482,7 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
 				}
 			}
 		}
+	}
 
 	@Override
 	public void pushForecastInfo(List<TForecastLibrary> library, boolean synFlag,
@@ -2496,6 +2500,7 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
 				List<TForecastLibrary> pushList;
 				int k = 0;
 				for (int j = 0; j < i; j++) {
+					synchronized (this) {
 						if (j == i - 1) {
 							pushList = library.subList(k, library.size());
 						} else {
@@ -2504,7 +2509,8 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
 						k = k + 1000;
 						if (Common.isNotNull(pushList)) {
 							//推送数据封装并推送
-						initEkpPushSocialParam(pushList,synFlag, selectVoMap);
+							initEkpPushSocialParam(pushList, synFlag, selectVoMap);
+						}
 					}
 				}
 			}
@@ -2527,6 +2533,7 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
 				List<TForecastLibrary> pushList;
 				int k = 0;
 				for (int j = 0; j < i; j++) {
+					synchronized (this) {
 						if (j == i - 1) {
 							pushList = library.subList(k, library.size());
 						} else {
@@ -2535,7 +2542,8 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
 						k = k + 1000;
 						if (Common.isNotNull(pushList)) {
 							//推送数据封装并推送
-						initEkpPushFundParam(pushList,synFlag, selectVoMap);
+							initEkpPushFundParam(pushList, synFlag, selectVoMap);
+						}
 					}
 				}
 			}