收入推送优化，防止大批量数据 异常

yifu-common/yifu-common-core/src/main/java/com/yifu/cloud/plus/v1/yifu/common/core/constant/CommonConstants.java

@@ -156,6 +156,10 @@ public interface CommonConstants {
 	 * number 5000
 	 */
 	int FIVES_INT = 5000;
+	/**
+	 * number 5000
+	 */
+	int TEN_THOUSAND_INT = 10000;
 
 	/**
 	 * number 1

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

@@ -2513,13 +2513,25 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 	@Override
 	public void createPaymentSocialInfo() {
 		//获取所有未推送的社保实缴明细数据
-		List<TPaymentInfo> unPushInfo = baseMapper.selectList(Wrappers.<TPaymentInfo>query().lambda()
+		long count = baseMapper.selectCount(Wrappers.<TPaymentInfo>query().lambda()
 				.eq(TPaymentInfo::getPushStatus, CommonConstants.ONE_STRING)
 				.eq(TPaymentInfo::getLockStatus, CommonConstants.ONE_STRING)
 				.isNotNull(TPaymentInfo::getSocialId));
-		if (Common.isNotNull(unPushInfo)) {
-			//推送数据封装并推送
-			initEkpPushSocialParam(unPushInfo);
+		if (count > 0){
+			List<TPaymentInfo> unPushs;
+			int i = (int)Math.ceil((double)count/CommonConstants.TEN_THOUSAND_INT);
+			for (int j=0;j<i;j++){
+				unPushs = baseMapper.selectList(Wrappers.<TPaymentInfo>query().lambda()
+						.eq(TPaymentInfo::getPushStatus, CommonConstants.ONE_STRING)
+						.eq(TPaymentInfo::getLockStatus, CommonConstants.ONE_STRING)
+						.isNotNull(TPaymentInfo::getSocialId).last(" limit 0,10000"));
+				synchronized (this){
+					if (Common.isNotNull(unPushs)) {
+						//推送数据封装并推送
+						initEkpPushSocialParam(unPushs);
+					}
+				}
+			}
 		}
 	}