fix 新增客户关系去除过滤

netflix-service/src/main/java/com/cyksj/service/corp/impl/CorpEventActionServiceImpl.java

@@ -21,7 +21,6 @@ import com.cyksj.config.corp.WeChatCorpFactory;
 import com.cyksj.mapper.GroupsRelationExpiryRecordMapper;
 import com.cyksj.mapper.OrderDonMapper;
 import com.cyksj.mapper.UserMapper;
-import com.cyksj.mapper.channel.ChannelPopularizeMapper;
 import com.cyksj.mapper.corp.*;
 import com.cyksj.mapper.manage.coupon.CouponMapper;
 import com.cyksj.mapper.market.task.UserBindDetailMapper;
@@ -42,8 +41,6 @@ import com.cyksj.service.mange.coupon.CouponCommonService;
 import com.cyksj.service.market.MarketFrontService;
 import com.cyksj.service.oceanengine.OceanengineService;
 import com.cyksj.service.order.OrderDonPostService;
-import com.cyksj.service.order.post.AbstractPostDataService;
-import com.cyksj.service.order.post.PostDataFactory;
 import com.cyksj.service.relation.GroupRelationFrontService;
 import com.cyksj.service.sys.SysConfigService;
 import com.ejlchina.searcher.BeanSearcher;
@@ -56,7 +53,6 @@ import org.apache.commons.lang3.StringUtils;
 import org.springframework.dao.DuplicateKeyException;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
-import org.springframework.util.Assert;
 
 import java.net.http.HttpRequest;
 import java.net.http.HttpResponse;
@@ -179,13 +175,13 @@ public class CorpEventActionServiceImpl implements CorpEventActionService {
 			}
 
 
-			Set<String> relationFollowUserIds = relationMapper.selectList(Wrappers.lambdaQuery(CorpUserFollowRelation.class)
-					.select(CorpUserFollowRelation::getFollowId)
-					.eq(CorpUserFollowRelation::getWxCorpId, wxCorpApp.getCorpId())
-					.eq(CorpUserFollowRelation::getCorpUserId, corpUserInfo.getExternalUserId())).stream().map(CorpUserFollowRelation::getFollowId).collect(Collectors.toSet());
+//			Set<String> relationFollowUserIds = relationMapper.selectList(Wrappers.lambdaQuery(CorpUserFollowRelation.class)
+//					.select(CorpUserFollowRelation::getFollowId)
+//					.eq(CorpUserFollowRelation::getWxCorpId, wxCorpApp.getCorpId())
+//					.eq(CorpUserFollowRelation::getCorpUserId, corpUserInfo.getExternalUserId())).stream().map(CorpUserFollowRelation::getFollowId).collect(Collectors.toSet());
 
 			followedUsers.stream()
-					.filter((followedUser) -> !relationFollowUserIds.contains(followedUser.getUserId()))
+//					.filter((followedUser) -> !relationFollowUserIds.contains(followedUser.getUserId()))
 					.forEach(followedUser -> updateUserFollowRelation(followedUser, corpUserInfo.getExternalUserId(), wxCorpApp.getId()));
 		});