自定义专题配置编辑/校验bug处理、信息源绑定逻辑修改

src/main/java/com/zzsn/event/controller/SubjectManageController.java

@@ -95,7 +95,7 @@ public class SubjectManageController {
     private KafkaTemplate<String, String> kafkaTemplate;
     @Autowired
     private PythonUtil pythonUtil;
-    @Autowired
+    @Autowired(required = false)
     private RemoteModelService remoteModelService;
 
 
@@ -735,7 +735,7 @@ public class SubjectManageController {
     public Result<?> subjectBindDirectSourcePageList(@RequestParam String subjectId,
                                                      @RequestParam(defaultValue = "1") Integer pageNo,
                                                      @RequestParam(defaultValue = "10") Integer pageSize) {
-        IPage<Map<String, Object>> page = infoSourceService.subjectBindDirectSourcePageList(subjectId, pageNo, pageSize);
+        IPage<SubjectBindDirectSourceVO> page = infoSourceService.subjectBindDirectSourcePageList(subjectId, pageNo, pageSize);
         return Result.OK(page);
     }
 
@@ -752,24 +752,7 @@ public class SubjectManageController {
     public Result<?> directSourcePageList(@RequestParam(required = false) String searchWord,
                                           @RequestParam(defaultValue = "1") Integer pageNo,
                                           @RequestParam(defaultValue = "10") Integer pageSize) {
-        IPage<String> page = infoSourceService.directSourcePageList(searchWord, pageNo, pageSize);
-        return Result.OK(page);
-    }
-
-    /**
-     * 信息源下栏目分页列表(专题绑定定向信息源时使用-研究中心)
-     *
-     * @param webSiteName 信息源名称
-     * @param pageNo      当前页
-     * @param pageSize    返回条数
-     * @author lkg
-     * @date 2025/1/4
-     */
-    @GetMapping("/directInfoSourceColumnPageList")
-    public Result<?> directSourceColumnPageList(String webSiteName,
-                                                @RequestParam(defaultValue = "1") Integer pageNo,
-                                                @RequestParam(defaultValue = "10") Integer pageSize) {
-        IPage<InfoSource> page = infoSourceService.directSourceColumnPageList(webSiteName, pageNo, pageSize);
+        IPage<SubjectBindDirectSourceVO> page = infoSourceService.directSourcePageList(searchWord, pageNo, pageSize);
         return Result.OK(page);
     }
 
@@ -782,18 +765,39 @@ public class SubjectManageController {
      */
     @PostMapping("/bindDirectInfoSource")
     public Result<?> bindDirectInfoSource(@RequestBody SubjectSourceVO subjectSourceVO) {
-        List<InfoSource> infoSources = infoSourceService.directSourceColumnList(subjectSourceVO.getWebSiteName());
+        List<String> sourceIdList = subjectSourceVO.getSourceIdList();
+        if (CollectionUtils.isEmpty(sourceIdList)) {
+            LambdaQueryWrapper<InfoSource> queryWrapper = Wrappers.lambdaQuery();
+            queryWrapper.select(InfoSource::getId,InfoSource::getSiteName,InfoSource::getSiteUri)
+                    .in(InfoSource::getWebSiteName, subjectSourceVO.getWebSiteNameList())
+                    .groupBy(InfoSource::getId);
+            List<InfoSource> infoSources = infoSourceService.list(queryWrapper);
             if (CollectionUtils.isNotEmpty(infoSources)) {
+                sourceIdList = infoSources.stream().map(InfoSource::getId).collect(Collectors.toList());
+            }
+        }
+        if (CollectionUtils.isNotEmpty(sourceIdList)) {
+            LambdaQueryWrapper<SubjectInfoSourceMap> queryWrapper = Wrappers.lambdaQuery();
+            queryWrapper.eq(SubjectInfoSourceMap::getSubjectId, subjectSourceVO.getSubjectId())
+                    .in(SubjectInfoSourceMap::getSourceId, sourceIdList)
+                    .eq(SubjectInfoSourceMap::getType, 1);
+            List<SubjectInfoSourceMap> list = subjectInfoSourceMapService.list(queryWrapper);
+            if (CollectionUtils.isNotEmpty(list)) {
+                List<String> existSourceIdList = list.stream().map(SubjectInfoSourceMap::getSourceId).collect(Collectors.toList());
+                sourceIdList.removeAll(existSourceIdList);
+            }
+            if (CollectionUtils.isNotEmpty(sourceIdList)) {
                 List<SubjectInfoSourceMap> dataList = new ArrayList<>();
-            for (InfoSource source : infoSources) {
+                for (String sourceId : sourceIdList) {
                     SubjectInfoSourceMap subjectInfoSourceMap = new SubjectInfoSourceMap();
                     subjectInfoSourceMap.setSubjectId(subjectSourceVO.getSubjectId());
-                subjectInfoSourceMap.setSourceId(source.getId());
+                    subjectInfoSourceMap.setSourceId(sourceId);
                     subjectInfoSourceMap.setType(1);
                     dataList.add(subjectInfoSourceMap);
                 }
                 subjectInfoSourceMapService.saveBatch(dataList);
             }
+        }
         return Result.OK();
     }
 
@@ -848,17 +852,29 @@ public class SubjectManageController {
      * @date 2025/1/9
      */
     @PostMapping("/removeDirectInfoSource")
-    public Result<?> removeDirectInfoSource(@RequestBody List<JSONObject> params){
-        for (JSONObject param : params) {
-            String subjectId = param.get("subjectId").toString();
-            String webSiteName = param.get("webSiteName").toString();
-            String status = param.get("status").toString();
-            if ("1".equals(status)) {
-                List<InfoSource> infoSources = infoSourceService.directSourceColumnList(webSiteName);
-                List<String> sourceIds = infoSources.stream().map(InfoSource::getId).collect(Collectors.toList());
-                subjectInfoSourceMapService.remove(new LambdaQueryWrapper<SubjectInfoSourceMap>().eq(SubjectInfoSourceMap::getSubjectId, subjectId).in(SubjectInfoSourceMap::getSourceId, sourceIds));
-            } else if ("0".equals(status)) {
-                subjectInfoSourceMiddleMapService.remove(new LambdaQueryWrapper<SubjectInfoSourceMiddleMap>().eq(SubjectInfoSourceMiddleMap::getSubjectId, subjectId).eq(SubjectInfoSourceMiddleMap::getInfoSourceName, webSiteName));
+    public Result<?> removeDirectInfoSource(@RequestBody List<SubjectBindDirectSourceVO> params){
+        for (SubjectBindDirectSourceVO param : params) {
+            String subjectId = param.getSubjectId();
+            String webSiteName = param.getWebSiteName();
+            Integer status = param.getStatus();
+            if (status == 1) {
+                List<String> sourceIdList;
+                List<InfoSource> children = param.getChildren();
+                if (CollectionUtils.isNotEmpty(children)) {
+                    sourceIdList = children.stream().map(InfoSource::getId).collect(Collectors.toList());
+                } else {
+                    List<String> webSiteNameList = new ArrayList<>();
+                    webSiteNameList.add(webSiteName);
+                    List<InfoSource> infoSources = infoSourceService.subjectBindSourceColumnList(subjectId,webSiteNameList);
+                    sourceIdList = infoSources.stream().map(InfoSource::getId).collect(Collectors.toList());
+                }
+                subjectInfoSourceMapService.remove(new LambdaQueryWrapper<SubjectInfoSourceMap>()
+                        .eq(SubjectInfoSourceMap::getSubjectId, subjectId)
+                        .in(SubjectInfoSourceMap::getSourceId, sourceIdList));
+            } else if (status == 0) {
+                subjectInfoSourceMiddleMapService.remove(new LambdaQueryWrapper<SubjectInfoSourceMiddleMap>()
+                        .eq(SubjectInfoSourceMiddleMap::getSubjectId, subjectId)
+                        .eq(SubjectInfoSourceMiddleMap::getInfoSourceName, webSiteName));
             }
         }
         return Result.OK();

src/main/java/com/zzsn/event/entity/Subject.java

@@ -104,7 +104,6 @@ public class Subject implements Serializable {
     /**是否是平台创建的专题（0否--外部创建 1是--平台创建 ）*/
     private String isPlatform;
     /**第一次启用时间*/
-    @TableField(updateStrategy = FieldStrategy.IGNORED)
     @JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
     @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
     private Date firstOpenTime;

src/main/java/com/zzsn/event/es/EsService.java

@@ -78,7 +78,8 @@ public class EsService {
     private LabelEntityService labelEntityService;
     @Autowired
     private ISubjectKeywordsMapService subjectKeywordsMapService;
-
+    @Autowired
+    private CommonService commonService;
 
     /**
      * 获取专题下的资讯
@@ -1787,12 +1788,38 @@ public class EsService {
         if (StringUtils.isNotBlank(crawler)) {
             boolQuery.must(QueryBuilders.termQuery("source.keyword", crawler));
         }
+        //关联标签id集合
         List<String> labelIds = searchCondition.getLabelIds();
         if (CollectionUtils.isNotEmpty(labelIds)) {
             Set<String> relationIdSet = new HashSet<>(labelIds);
             TermsQueryBuilder relationIdQuery = QueryBuilders.termsQuery("labels.relationId", relationIdSet);
             boolQuery.must(QueryBuilders.nestedQuery("labels", relationIdQuery, ScoreMode.None));
         }
+        //正面标签
+        String tendencyLabelId = searchCondition.getTendencyLabelId();
+        if (StringUtils.isNotBlank(tendencyLabelId)) {
+            TermQueryBuilder relationIdQuery = QueryBuilders.termQuery("labels.relationId", tendencyLabelId);
+            boolQuery.must(QueryBuilders.nestedQuery("labels", relationIdQuery, ScoreMode.None));
+        }
+        //地域标签
+        List<String> areaLabelIds = searchCondition.getAreaLabelIds();
+        if (CollectionUtils.isNotEmpty(areaLabelIds)) {
+            Set<String> relationIdSet = new HashSet<>(areaLabelIds);
+            TermsQueryBuilder relationIdQuery = QueryBuilders.termsQuery("labels.relationId", relationIdSet);
+            boolQuery.must(QueryBuilders.nestedQuery("labels", relationIdQuery, ScoreMode.None));
+        }
+        //企业标签
+        List<String> enterpriseLabelTypeIds = searchCondition.getEnterpriseLabelTypeIds();
+        List<String> socialCreditCodeList = searchCondition.getSocialCreditCodeList();
+        if (CollectionUtils.isNotEmpty(socialCreditCodeList) || CollectionUtils.isNotEmpty(enterpriseLabelTypeIds)) {
+            if (CollectionUtils.isEmpty(socialCreditCodeList)) {
+                socialCreditCodeList = commonService.codesByLabels(enterpriseLabelTypeIds);
+            }
+            Set<String> codeSet = new HashSet<>(socialCreditCodeList);
+            TermsQueryBuilder relationIdQuery = QueryBuilders.termsQuery("labels.relationId", codeSet);
+            boolQuery.must(QueryBuilders.nestedQuery("labels", relationIdQuery, ScoreMode.None));
+        }
+        //信息源标签
         List<Label> labelList = searchCondition.getLabelList();
         if (CollectionUtils.isNotEmpty(labelList)) {
             List<String> collect = labelList.stream().map(label -> label.getLabelMark() + "-" + label.getRelationId()).collect(Collectors.toList());

src/main/java/com/zzsn/event/mapper/InfoSourceMapper.java

@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.zzsn.event.vo.InfoSourceCondition;
 import com.zzsn.event.vo.InfoSourceVo;
 import com.zzsn.event.entity.InfoSource;
+import com.zzsn.event.vo.SubjectBindDirectSourceVO;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
@@ -38,7 +39,7 @@ public interface InfoSourceMapper extends BaseMapper<InfoSource> {
      * @author lkg
      * @date 2024/5/7
      */
-    List<InfoSourceVo> queryInfoSource(@Param("sourceIdList") List<String> sourceIdList,@Param("subjectIds") List<String> subjectIds);
+    List<InfoSourceVo> queryInfoSource(@Param("sourceIdList") List<String> sourceIdList, @Param("subjectIds") List<String> subjectIds);
 
     /**
      * 专题绑定的信息源集合
@@ -68,7 +69,7 @@ public interface InfoSourceMapper extends BaseMapper<InfoSource> {
      * @author lkg
      * @date 2025/2/6
      */
-    List<InfoSourceVo> bindGroupSourceIdList(@Param("subjectIds") List<String> subjectIds, @Param("sourceIds")List<String> sourceIds);
+    List<InfoSourceVo> bindGroupSourceIdList(@Param("subjectIds") List<String> subjectIds, @Param("sourceIds") List<String> sourceIds);
 
     /**
      * 专题直接屏蔽的信息源列表(不包括专题屏蔽的信息源组下的信息源)
@@ -88,7 +89,7 @@ public interface InfoSourceMapper extends BaseMapper<InfoSource> {
      * @author lkg
      * @date 2025/1/6
      */
-    Page<Map<String, Object>> subjectBindDirectInfoSourceList(@Param("subjectId") String subjectId, Page<Map<String, Object>> page);
+    Page<SubjectBindDirectSourceVO> subjectBindDirectInfoSourceList(@Param("subjectId") String subjectId, Page<Map<String, Object>> page);
 
 
     /**
@@ -99,35 +100,18 @@ public interface InfoSourceMapper extends BaseMapper<InfoSource> {
      * @author lkg
      * @date 2025/1/4
      */
-    Page<String> infoSourcePageList(@Param("searchWord") String searchWord, Page<String> page);
+    Page<SubjectBindDirectSourceVO> infoSourcePageList(@Param("searchWord") String searchWord, Page<String> page);
 
     /**
-     * 信息源下栏目分页列表(专题绑定定向信息源时使用-研究中心)
+     * 信息源下专题绑定的栏目列表(专题绑定定向信息源时使用-研究中心)
      *
-     * @param webSiteName 信息源名称
-     * @param page        分页参数
-     * @author lkg
-     * @date 2025/1/4
-     */
-    Page<InfoSource> directSourceColumnList(@Param("webSiteName") String webSiteName, Page<InfoSource> page);
-
-    /**
-     * 信息源下栏目列表(专题绑定定向信息源时使用-研究中心)
-     *
-     * @param webSiteName 信息源名称
+     * @param subjectId    专题id
+     * @param webSiteNames 信息源名称
      * @author lkg
      * @date 2025/1/4
      */
-    List<InfoSource> directSourceColumnList(@Param("webSiteName") String webSiteName);
+    List<InfoSource> subjectBindSourceColumnList(@Param("subjectId") String subjectId, @Param("webSiteNames") List<String> webSiteNames);
 
-    /**
-     * 信息源下栏目id列表(校验专题配置时使用-研究中心)
-     *
-     * @param webSiteNames 信息源名称集合
-     * @author lkg
-     * @date 2025/1/4
-     */
-    Set<String> directSourceColumnSet(@Param("webSiteNames") List<String> webSiteNames);
 
     IPage<InfoSourceVo> bindSourceIdPageList(Page<InfoSourceVo> page, @Param("infoSourceVo") InfoSourceCondition infoSourceCondition, @Param("subjectIds") List<String> subjectIds);
 }

src/main/java/com/zzsn/event/mapper/xml/InfoSourceMapper.xml

@@ -334,7 +334,7 @@
     </select>
 
 
-    <select id="subjectBindDirectInfoSourceList" resultType="Map">
+    <select id="subjectBindDirectInfoSourceList" resultType="com.zzsn.event.vo.SubjectBindDirectSourceVO">
         select a.*
         from (
                  select iso.web_site_name as webSiteName, 1 as `status`
@@ -351,31 +351,26 @@
         order by a.status desc, a.webSiteName asc
     </select>
 
-    <select id="infoSourcePageList" resultType="String">
+    <select id="infoSourcePageList" resultType="com.zzsn.event.vo.SubjectBindDirectSourceVO">
         select iso.web_site_name
         from info_source iso where 1=1
         <if test="searchWord!=null and searchWord != ''">
-            and (
-            iso.web_site_name like CONCAT('%',#{searchWord},'%')
-            )
+            and iso.web_site_name like CONCAT('%',#{searchWord},'%')
         </if>
         group by iso.web_site_name
     </select>
 
-    <select id="directSourceColumnList" resultType="com.zzsn.event.entity.InfoSource">
-        select iso.id, iso.site_name, iso.site_uri
+    <select id="subjectBindSourceColumnList" resultType="com.zzsn.event.entity.InfoSource">
+        select iso.id, iso.web_site_name,iso.site_name, iso.site_uri
         from info_source iso
-        where iso.web_site_name = #{webSiteName}
-    </select>
-
-    <select id="directSourceColumnSet" resultType="String">
-        select iso.id from info_source iso
-        where 1=1
+        inner join subject_info_source_map sm on iso.id = sm.source_id and sm.type = 1
+        where sm.subject_id = #{subjectId}
         <if test="webSiteNames != null and webSiteNames.size() > 0">
             and iso.web_site_name in
             <foreach collection="webSiteNames" item="item" open="(" close=")" separator=",">
                 #{item}
             </foreach>
         </if>
+        group by iso.id
     </select>
 </mapper>

src/main/java/com/zzsn/event/service/IInfoSourceService.java

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.extension.service.IService;
 import com.zzsn.event.vo.InfoSourceCondition;
 import com.zzsn.event.vo.InfoSourceVo;
 import com.zzsn.event.entity.InfoSource;
+import com.zzsn.event.vo.SubjectBindDirectSourceVO;
 
 import java.util.List;
 import java.util.Map;
@@ -64,7 +65,7 @@ public interface IInfoSourceService extends IService<InfoSource> {
      * @author lkg
      * @date 2025/1/4
      */
-    IPage<Map<String, Object>> subjectBindDirectSourcePageList(String subjectId, Integer pageNo, Integer pageSize);
+    IPage<SubjectBindDirectSourceVO> subjectBindDirectSourcePageList(String subjectId, Integer pageNo, Integer pageSize);
 
     /**
      * 信息源分页列表(专题绑定定向信息源时使用-研究中心)
@@ -75,37 +76,19 @@ public interface IInfoSourceService extends IService<InfoSource> {
      * @author lkg
      * @date 2025/1/4
      */
-    IPage<String> directSourcePageList(String searchWord, Integer pageNo, Integer pageSize);
+    IPage<SubjectBindDirectSourceVO> directSourcePageList(String searchWord, Integer pageNo, Integer pageSize);
 
-    /**
-     * 信息源下栏目分页列表(专题绑定定向信息源时使用-研究中心)
-     *
-     * @param webSiteName 信息源名称
-     * @param pageNo      当前页
-     * @param pageSize    返回条数
-     * @author lkg
-     * @date 2025/1/4
-     */
-    IPage<InfoSource> directSourceColumnPageList(String webSiteName, Integer pageNo, Integer pageSize);
 
-    /**
-     * 信息源下栏目列表(专题绑定定向信息源时使用-研究中心)
-     *
-     * @param webSiteName 信息源名称
-     * @author lkg
-     * @date 2025/1/4
-     */
-    List<InfoSource> directSourceColumnList(String webSiteName);
 
+    IPage<InfoSourceVo> bindInfoSourcePageList(InfoSourceCondition infoSourceCondition, List<String> subjectIdList, Integer pageNo, Integer pageSize);
 
     /**
-     * 信息源下栏目id列表(校验专题配置时使用-研究中心)
+     * 信息源下专题绑定的栏目列表(专题绑定定向信息源时使用-研究中心)
      *
+     * @param subjectId 专题id
      * @param webSiteNames 信息源名称集合
      * @author lkg
-     * @date 2025/1/4
+     * @date 2025/2/12
      */
-    Set<String> directSourceColumnSet(List<String> webSiteNames);
-
-    IPage<InfoSourceVo> bindInfoSourcePageList(InfoSourceCondition infoSourceCondition, List<String> subjectIdList, Integer pageNo, Integer pageSize);
+    List<InfoSource> subjectBindSourceColumnList(String subjectId,List<String> webSiteNames);
 }

src/main/java/com/zzsn/event/service/impl/InfoSourceServiceImpl.java

@@ -4,7 +4,9 @@ import cn.hutool.core.date.DateField;
 import cn.hutool.core.date.DateTime;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ObjectUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.zzsn.event.entity.InfoSource;
@@ -14,6 +16,7 @@ import com.zzsn.event.service.IInfoSourceService;
 import com.zzsn.event.vo.InfoSourceCondition;
 import com.zzsn.event.vo.InfoSourceVo;
 import com.zzsn.event.vo.NumVO;
+import com.zzsn.event.vo.SubjectBindDirectSourceVO;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -124,31 +127,43 @@ public class InfoSourceServiceImpl extends ServiceImpl<InfoSourceMapper, InfoSou
     }
 
     @Override
-    public IPage<Map<String, Object>> subjectBindDirectSourcePageList(String subjectId, Integer pageNo, Integer pageSize) {
+    public IPage<SubjectBindDirectSourceVO> subjectBindDirectSourcePageList(String subjectId, Integer pageNo, Integer pageSize) {
         Page<Map<String, Object>> page = new Page<>(pageNo, pageSize);
-        return baseMapper.subjectBindDirectInfoSourceList(subjectId, page);
+        Page<SubjectBindDirectSourceVO> pageList = baseMapper.subjectBindDirectInfoSourceList(subjectId, page);
+        List<SubjectBindDirectSourceVO> records = pageList.getRecords();
+        if (CollectionUtils.isNotEmpty(records)) {
+            List<String> webSiteNames = records.stream().map(SubjectBindDirectSourceVO::getWebSiteName).collect(Collectors.toList());
+            List<InfoSource> bindSourceColumnList = this.subjectBindSourceColumnList(subjectId, webSiteNames);
+            Map<String, List<InfoSource>> webSiteNameMap = bindSourceColumnList.stream().collect(Collectors.groupingBy(InfoSource::getWebSiteName));
+            for (SubjectBindDirectSourceVO subjectBindDirectSourceVO : records) {
+                Integer status = subjectBindDirectSourceVO.getStatus();
+                if (status == 1) {
+                    List<InfoSource> infoSources = webSiteNameMap.get(subjectBindDirectSourceVO.getWebSiteName());
+                    subjectBindDirectSourceVO.setChildren(infoSources);
                 }
-
-    @Override
-    public IPage<String> directSourcePageList(String searchWord, Integer pageNo, Integer pageSize) {
-        Page<String> page = new Page<>(pageNo, pageSize);
-        return baseMapper.infoSourcePageList(searchWord, page);
             }
-
-    @Override
-    public IPage<InfoSource> directSourceColumnPageList(String webSiteName, Integer pageNo, Integer pageSize) {
-        Page<InfoSource> page = new Page<>(pageNo, pageSize);
-        return baseMapper.directSourceColumnList(webSiteName, page);
         }
-
-    @Override
-    public List<InfoSource> directSourceColumnList(String webSiteName) {
-        return baseMapper.directSourceColumnList(webSiteName);
+        return pageList;
     }
 
     @Override
-    public Set<String> directSourceColumnSet(List<String> webSiteNames) {
-        return baseMapper.directSourceColumnSet(webSiteNames);
+    public IPage<SubjectBindDirectSourceVO> directSourcePageList(String searchWord, Integer pageNo, Integer pageSize) {
+        Page<String> page = new Page<>(pageNo, pageSize);
+        Page<SubjectBindDirectSourceVO> pageList = baseMapper.infoSourcePageList(searchWord, page);
+        List<SubjectBindDirectSourceVO> records = pageList.getRecords();
+        if (CollectionUtils.isNotEmpty(records)) {
+            List<String> webSiteNames = records.stream().map(SubjectBindDirectSourceVO::getWebSiteName).collect(Collectors.toList());
+            LambdaQueryWrapper<InfoSource> queryWrapper = Wrappers.lambdaQuery();
+            queryWrapper.select(InfoSource::getId,InfoSource::getWebSiteName,InfoSource::getSiteName,InfoSource::getSiteUri)
+                    .in(InfoSource::getWebSiteName, webSiteNames);
+            List<InfoSource> children = this.list(queryWrapper);
+            Map<String, List<InfoSource>> webSiteNameMap = children.stream().collect(Collectors.groupingBy(InfoSource::getWebSiteName));
+            for (SubjectBindDirectSourceVO subjectBindDirectSourceVO : records) {
+                List<InfoSource> infoSources = webSiteNameMap.get(subjectBindDirectSourceVO.getWebSiteName());
+                subjectBindDirectSourceVO.setChildren(infoSources);
+            }
+        }
+        return pageList;
     }
 
     @Override
@@ -215,4 +230,9 @@ public class InfoSourceServiceImpl extends ServiceImpl<InfoSourceMapper, InfoSou
         }
         return pageList;
     }
+
+    @Override
+    public List<InfoSource> subjectBindSourceColumnList(String subjectId, List<String> webSiteNames) {
+        return baseMapper.subjectBindSourceColumnList(subjectId, webSiteNames);
+    }
 }

src/main/java/com/zzsn/event/service/impl/InformationServiceImpl.java

@@ -117,13 +117,6 @@ public class InformationServiceImpl implements InformationService {
                 subjectIdList = subjectTypeMapService.selectEventByTypeIds(typeIds);
             }
         }
-        List<String> relationIds = searchCondition.getLabelIds();
-        List<String> labelTypeIds = searchCondition.getLabelTypeIds();
-        if (CollectionUtils.isNotEmpty(labelTypeIds)) {
-            List<String> socialCreditCodeList = commonService.codesByLabels(labelTypeIds);
-            relationIds.addAll(socialCreditCodeList);
-        }
-        searchCondition.setLabelIds(relationIds);
         try {
             IPage<SpecialInformation> specialInformationIPage = esService.pageListByCondition(searchCondition,subjectIdList);
             long total = specialInformationIPage.getTotal();

src/main/java/com/zzsn/event/service/impl/SubjectSimpleServiceImpl.java

@@ -63,8 +63,6 @@ public class SubjectSimpleServiceImpl implements SubjectSimpleService {
     private ISubjectModelMapService subjectModelMapService;
     @Autowired
     private ScoreModelService scoreModelService;
-    @Autowired
-    private IInfoSourceService infoSourceService;
 
     @Autowired
     private EsService esService;
@@ -157,9 +155,11 @@ public class SubjectSimpleServiceImpl implements SubjectSimpleService {
             if (judgeKeyword) {
                 return false;
             }
-            //判断信息源配置是否变化
-            boolean judgeInfoSource = judgeInfoSource(subjectId, subjectParamsCheckVO.getSubjectSourceTagVO(), subjectParamsCheckVO.getInfoSourceWebSiteNames(), subjectParamsCheckVO.getInfoSourceIds());
-            return !judgeInfoSource;
+            //判断信息源标签配置是否变化
+            boolean judgeInfoSourceLabel = judgeInfoSourceLabel(subjectId, subjectParamsCheckVO.getSubjectSourceTagVO());
+            //判断定向信息源是否发生变化(前端传参)
+            boolean directSourceChange = subjectParamsCheckVO.isDirectSourceChange();
+            return !judgeInfoSourceLabel && !directSourceChange;
         }
     }
 
@@ -205,19 +205,17 @@ public class SubjectSimpleServiceImpl implements SubjectSimpleService {
      *
      * @param subjectId              专题id
      * @param subjectSourceTagVO     信息源标签信息(编辑时前端传参)
-     * @param infoSourceWebSiteNames 定向信息源名称集合(编辑时前端传参)
-     * @param infoSourceIds          推荐信息源id集合(编辑时前端传参)
      * @author lkg
      * @date 2025/2/5
      */
-    private boolean judgeInfoSource(String subjectId, SubjectSourceTagVO subjectSourceTagVO, List<String> infoSourceWebSiteNames, List<String> infoSourceIds) {
+    private boolean judgeInfoSourceLabel(String subjectId, SubjectSourceTagVO subjectSourceTagVO) {
         boolean flag = false;
         LambdaQueryWrapper<SubjectInfoSourceMap> queryWrapper = Wrappers.lambdaQuery();
         queryWrapper.eq(SubjectInfoSourceMap::getSubjectId, subjectId);
         List<SubjectInfoSourceMap> mapList = subjectInfoSourceMapService.list(queryWrapper);
-        //判断是否已存在信息源配置
+        //判断绑定的信息源标签是否发生变化
         if (CollectionUtils.isEmpty(mapList)) {
-            if (subjectSourceTagVO != null || CollectionUtils.isNotEmpty(infoSourceWebSiteNames) || CollectionUtils.isNotEmpty(infoSourceIds)) {
+            if (subjectSourceTagVO != null) {
                 flag = true;
             }
         } else {
@@ -238,17 +236,6 @@ public class SubjectSimpleServiceImpl implements SubjectSimpleService {
                 } else {
                     flag = true;
                 }
-            } else {
-                //判断 信息源绑定是否变化
-                Set<String> sourceIdSet = mapList.stream().filter(e -> e.getType() == 1).map(SubjectInfoSourceMap::getSourceId).collect(Collectors.toSet());
-                Set<String> sourceColumnSet = new HashSet<>();
-                if (CollectionUtils.isNotEmpty(infoSourceWebSiteNames)) {
-                    sourceColumnSet = infoSourceService.directSourceColumnSet(infoSourceWebSiteNames);
-                }
-                sourceColumnSet.addAll(infoSourceIds);
-                if (!sourceIdSet.equals(sourceColumnSet)) {
-                    flag = true;
-                }
             }
         }
         return flag;
@@ -454,14 +441,15 @@ public class SubjectSimpleServiceImpl implements SubjectSimpleService {
         LambdaQueryWrapper<SubjectKeywordsMap> queryWrapper = Wrappers.lambdaQuery();
         queryWrapper.eq(SubjectKeywordsMap::getSubjectId, subjectId);
         List<SubjectKeywordsMap> bindList = subjectKeywordsMapService.list(queryWrapper);
-        List<String> bindIdList = bindList.stream().map(SubjectKeywordsMap::getKeywordsId).collect(Collectors.toList());
+        List<SubjectKeywordsMap> filterList = bindList.stream().filter(s -> s.getBindingType().equals("2")).collect(Collectors.toList());
+        //前端传过来的编辑的关键词信息
         List<SearchWordVO> updateList = keywords.stream().filter(searchWordVO -> searchWordVO.getId() != null).collect(Collectors.toList());
         List<String> updateIdList = updateList.stream().map(SearchWordVO::getId).collect(Collectors.toList());
+        //比较后，获得要删除的关键词组id集合
         List<String> removeIdList = new ArrayList<>();
-        for (SearchWordVO searchWordVO : updateList) {
-            String id = searchWordVO.getId();
-            if (!bindIdList.contains(id)) {
-                removeIdList.add(id);
+        for (SubjectKeywordsMap subjectKeywordsMap : filterList) {
+            if (!updateIdList.contains(subjectKeywordsMap.getKeywordsId())) {
+                removeIdList.add(subjectKeywordsMap.getKeywordsId());
             }
         }
         //编辑后保留下来的关键词
@@ -473,7 +461,7 @@ public class SubjectSimpleServiceImpl implements SubjectSimpleService {
                 addMapIdList.add(searchWordVO);
             }
         }
-        handlerSubjectKeywordMap(subjectId, addMapIdList, removeIdList);
+        handlerSubjectKeywordMap(subjectId, addMapIdList,bindList, retainList, removeIdList);
         //专题下关键词之间的关系
         modifySubjectKeywordsGroupRelation(subjectId, retainList);
     }
@@ -511,8 +499,6 @@ public class SubjectSimpleServiceImpl implements SubjectSimpleService {
         subjectKeywordsGroupRelation.setRelationType(relationType);
         List<String> keywordsGroupIds = new ArrayList<>();
         List<JSONObject> paramsStr = new ArrayList<>();
-        String expression;
-        if ("3".equals(relationType)) {
         StringBuilder expressionStr = new StringBuilder();
         for (int i = 0; i < relationList.size(); i++) {
             SearchWordVO searchWordVO = relationList.get(i);
@@ -544,26 +530,7 @@ public class SubjectSimpleServiceImpl implements SubjectSimpleService {
                 paramsStr.add(params);
             }
         }
-            expression = expressionStr.toString();
-        } else {
-            StringBuilder expressionStr = new StringBuilder();
-            for (SearchWordVO searchWordVO : relationList) {
-                String id = searchWordVO.getId();
-                String wordName = searchWordVO.getWordName();
-                keywordsGroupIds.add(id);
-                expressionStr.append("&").append(id);
-                JSONObject relationParam = new JSONObject();
-                relationParam.put("title", "and");
-                relationParam.put("value", "&");
-                paramsStr.add(relationParam);
-                JSONObject params = new JSONObject();
-                params.put("title", wordName);
-                params.put("value", id);
-                paramsStr.add(params);
-            }
-            expression = expressionStr.substring(1);
-            paramsStr = paramsStr.subList(1, paramsStr.size());
-        }
+        String expression = expressionStr.toString();
         subjectKeywordsGroupRelation.setKeywordsGroupIds(String.join(",", keywordsGroupIds));
         subjectKeywordsGroupRelation.setExpressionStr(expression);
         subjectKeywordsGroupRelation.setParamsStr(JSON.toJSONString(paramsStr));
@@ -571,7 +538,7 @@ public class SubjectSimpleServiceImpl implements SubjectSimpleService {
     }
 
     //处理专题-关键词绑定关系
-    private void handlerSubjectKeywordMap(String subjectId, List<SearchWordVO> addMapIdList, List<String> removeIdList) {
+    private void handlerSubjectKeywordMap(String subjectId, List<SearchWordVO> addMapIdList,List<SubjectKeywordsMap> bindList, List<SearchWordVO> retainList, List<String> removeIdList) {
         if (CollectionUtils.isNotEmpty(addMapIdList)) {
             List<SubjectKeywordsMap> subjectKeywordsMapList = new ArrayList<>();
             for (SearchWordVO wordVO : addMapIdList) {
@@ -596,8 +563,21 @@ public class SubjectSimpleServiceImpl implements SubjectSimpleService {
                     e.setBindingType("1");
                     e.setId(null);
                 });
-                subjectKeywordsMapService.saveBatch(subjectKeywordsMapList);
+                subjectKeywordsMapService.saveBatch(collect);
+            }
+        }
+        //更新关键词的作用范围
+        if (CollectionUtils.isNotEmpty(retainList)) {
+            List<SubjectKeywordsMap> subjectKeywordsMapList = new ArrayList<>();
+            for (SearchWordVO wordVO : retainList) {
+                for (SubjectKeywordsMap subjectKeywordsMap : bindList) {
+                    if (wordVO.getId().equals(subjectKeywordsMap.getKeywordsId())) {
+                        subjectKeywordsMap.setType(String.valueOf(wordVO.getSearchScope()));
+                        subjectKeywordsMapList.add(subjectKeywordsMap);
+                    }
+                }
             }
+            subjectKeywordsMapService.updateBatchById(subjectKeywordsMapList);
         }
         if (CollectionUtils.isNotEmpty(removeIdList)) {
             LambdaQueryWrapper<SubjectKeywordsMap> queryWrapper = Wrappers.lambdaQuery();
@@ -638,7 +618,7 @@ public class SubjectSimpleServiceImpl implements SubjectSimpleService {
         if (CollectionUtils.isNotEmpty(removeIdList)) {
             keywordWordsService.removeByIds(removeIdList);
             LambdaQueryWrapper<KeywordsTypeMap> queryWrapper = Wrappers.lambdaQuery();
-            queryWrapper.eq(KeywordsTypeMap::getKeywordsId, removeIdList);
+            queryWrapper.in(KeywordsTypeMap::getKeywordsId, removeIdList);
             keywordsTypeMapService.remove(queryWrapper);
         }
         return realKeyWordList;

src/main/java/com/zzsn/event/util/PythonUtil.java

@@ -120,7 +120,7 @@ public class PythonUtil {
             if (isHandleSuccess.equals("true")) {
                 log.info("专题-{}，清空数据，调用python接口清空去重服务历史数据请求发送成功",subjectId);
             } else {
-                log.info("python清空去重服务历史数据接口异常");
+                log.info("python清空去重服务历史数据接口异常：{}",jsonObject.getString("logs"));
             }
         } catch (Exception e) {
             e.printStackTrace();

src/main/java/com/zzsn/event/vo/InfoDataSearchCondition.java

@@ -61,11 +61,19 @@ public class InfoDataSearchCondition {
     private String isSubject = "1";
     //爬虫类型
     private String crawler;
+    /**----企业类标签筛选----**/
     //企业类标签id集合
-    private List<String> labelTypeIds;
+    private List<String> enterpriseLabelTypeIds;
+    //企业信用代码集合
+    private List<String> socialCreditCodeList;
+    /**----企业类标签id集合----**/
     //关联标签值id集合
     private List<String> labelIds;
-    //关联标签集合
+    //正负面标签
+    private String tendencyLabelId;
+    //地域标签id集合
+    private List<String> areaLabelIds;
+    //关联信息源标签集合
     private List<Label> labelList;
     //信息源id
     private String sourceId;

src/main/java/com/zzsn/event/vo/SubjectBindDirectSourceVO.java

+package com.zzsn.event.vo;
+
+import com.zzsn.event.entity.InfoSource;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * 专题绑定信息源
+ *
+ * @author lkg
+ * @date 2025/2/12
+ */
+@Data
+public class SubjectBindDirectSourceVO {
+    /**专题id*/
+    private String subjectId;
+    /**信息源名称*/
+    private String webSiteName;
+    /**状态(1-已配置；0-待配置)*/
+    private Integer status;
+    /**信息源栏目集合*/
+    private List<InfoSource> children;
+}

src/main/java/com/zzsn/event/vo/SubjectParamsCheckVO.java

@@ -19,9 +19,6 @@ public class SubjectParamsCheckVO {
     /**信息源标签*/
     private SubjectSourceTagVO subjectSourceTagVO;
 
-    /**信息源名称列表*/
-    private List<String> infoSourceWebSiteNames;
-
-    /**信息源id列表-推荐信息源*/
-    private List<String> infoSourceIds;
+    /**定向信息源是否发生变化*/
+    private boolean directSourceChange;
 }

src/main/java/com/zzsn/event/vo/SubjectSourceVO.java

@@ -2,6 +2,8 @@ package com.zzsn.event.vo;
 
 import lombok.Data;
 
+import java.util.List;
+
 /**
  *
  *
@@ -14,6 +16,10 @@ public class SubjectSourceVO {
     private String sourceId;
     private Integer count;
 
-    //绑定定向信息源时使用(研究中心)
+    /**---绑定定向信息源时使用(研究中心)---**/
+    private List<String> webSiteNameList;
+    private List<String> sourceIdList;
+
     private String webSiteName;
+    /**---绑定定向信息源时使用(研究中心)---**/
 }

src/main/resources/application-dev.yml

@@ -134,11 +134,25 @@ scoreRule:
 translate:
   url: http://114.116.116.241:8018/translate/getTranslateInfoWithTag
 python:
-  #python打分接口
+  #python打分接口-弃用
   scoreModelUrl: http://114.116.36.231:8080/score
-  #python开始执行接口
+  #python开始执行接口--弃用
   subjectProcessorUrl: http://114.116.36.231:8085/subject/subject_processor
   #判重
-  judgeDuplicateUrl: http://114.116.36.231:8080/subject/judg_duplicate
+  judgeDuplicateUrl: http://1.95.13.40:8080/subject/judg_duplicate
   #抽取关键词
   keyWordsExtractUrl: http://1.95.91.200:7006/get_phrase/
+  #清空去重服务历史数据
+  clearDuplicateHistoryUrl: http://1.95.13.40:8080/subject/delete_history_data
+jeecg:
+  shiro:
+    excludeUrls:
+kafka:
+  topic:
+    subject:
+      run: subjectModelTest
+clb:
+  subject:
+    default:
+      processing:
+        advanceMonth: 6
\ No newline at end of file

src/main/resources/application-pro.yml

@@ -131,3 +131,26 @@ scoreRule:
   beforeYearScore: 1
 translate:
   url: http://114.116.116.241:8018/translate/getTranslateInfoWithTag
+python:
+  #python打分接口-弃用
+  scoreModelUrl: http://114.116.36.231:8080/score
+  #python开始执行接口--弃用
+  subjectProcessorUrl: http://114.116.36.231:8085/subject/subject_processor
+  #判重
+  judgeDuplicateUrl: http://1.95.13.40:8080/subject/judg_duplicate
+  #抽取关键词
+  keyWordsExtractUrl: http://1.95.91.200:7006/get_phrase/
+  #清空去重服务历史数据
+  clearDuplicateHistoryUrl: http://1.95.13.40:8080/subject/delete_history_data
+jeecg:
+  shiro:
+    excludeUrls:
+kafka:
+  topic:
+    subject:
+      run: subjectModelTest
+clb:
+  subject:
+    default:
+      processing:
+        advanceMonth: 6
\ No newline at end of file