只查询企业微信数据

src/main/java/cn/quantgroup/xyqb/repository/IWeChatInfoRelationRepository.java

@@ -19,6 +19,6 @@ public interface IWeChatInfoRelationRepository extends JpaRepository<WechatInfoR
     @Query(value = "update wechat_info_relation as wir set wir.is_follow_wechat = 1 where wir.open_id IN (?1)", nativeQuery = true)
     void updateIsFollowWechatInOpenIdList(List<String> openIdList);
 
-    List<WechatInfoRelation> findByUnionIdInAndTaskPeriod(List<String> unionIdList, String period);
+    List<WechatInfoRelation> findByUnionIdInAndTaskPeriodAndType(List<String> unionIdList, String period, Integer type);
 
 }

src/main/java/cn/quantgroup/xyqb/service/wechat/impl/WechatFollowServiceImpl.java

@@ -183,7 +183,7 @@ public class WechatFollowServiceImpl implements IWechatFollowService {
 
     @Override
     public Object findByUnionIdsToUserIds(List<String> unionIds, String period) {
-        return weChatInfoRelationRepository.findByUnionIdInAndTaskPeriod(unionIds, period);
+        return weChatInfoRelationRepository.findByUnionIdInAndTaskPeriodAndType(unionIds, period, ENTERPRISE_WECHAT);
     }
 
     private JsonResult executeEnterpriseFollowStatus(String s, String period) {