专题列表查询增加绑定流程回显

src/main/java/com/zzsn/event/entity/arrange/ClbModelArrange.java

+package com.zzsn.event.entity.arrange;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import org.jeecgframework.poi.excel.annotation.Excel;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Description: 流程编排
+ * @Author: jeecg-boot
+ * @Date:   2024-11-14
+ * @Version: V1.0
+ */
+@Data
+@TableName("clb_model_arrange")
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value="clb_model_arrange对象", description="流程编排")
+public class ClbModelArrange implements Serializable {
+    
+	/**主键id*/
+	@TableId(type = IdType.ASSIGN_ID)
+    @ApiModelProperty(value = "主键id")
+	private String id;
+	/**分组id*/
+	@Excel(name = "分组id", width = 15)
+    @ApiModelProperty(value = "分组id")
+	private String groupId;
+	/**流程名*/
+	@Excel(name = "流程名", width = 15)
+    @ApiModelProperty(value = "流程名")
+	private String name;
+	/**流程编码*/
+	@Excel(name = "流程编码", width = 15)
+    @ApiModelProperty(value = "流程编码")
+	private String code;
+	/**流程编码*/
+	@Excel(name = "流程编排信息", width = 15)
+    @ApiModelProperty(value = "流程编排信息")
+	private String conf;
+	/**状态*/
+	@Excel(name = "状态", width = 15)
+    @ApiModelProperty(value = "状态")
+	private Integer status;
+	/**0:正常 1:删除*/
+	@TableLogic
+	@Excel(name = "0:正常 1:删除", width = 15)
+    @ApiModelProperty(value = "0:正常 1:删除")
+	private Integer delFlag;
+	/**创建人*/
+	@Excel(name = "创建人", width = 15)
+    @ApiModelProperty(value = "创建人")
+	private String createBy;
+	/**创建日期*/
+	@Excel(name = "创建日期", width = 20, format = "yyyy-MM-dd HH:mm:ss")
+	@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
+    @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
+    @ApiModelProperty(value = "创建日期")
+	private Date createTime;
+	/**更新人*/
+	@Excel(name = "更新人", width = 15)
+    @ApiModelProperty(value = "更新人")
+	private String updateBy;
+	/**更新日期*/
+	@Excel(name = "更新日期", width = 20, format = "yyyy-MM-dd HH:mm:ss")
+	@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
+    @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
+    @ApiModelProperty(value = "更新日期")
+	private Date updateTime;
+	@TableField(exist = false)
+	private String subjectId;
+	/**流程编码*/
+	@Excel(name = "数据来源分类", width = 15)
+	@ApiModelProperty(value = "数据来源分类")
+	@TableField(exist = false)
+	private String type;
+}

src/main/java/com/zzsn/event/enums/SourceTypeEnum.java

+package com.zzsn.event.enums;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public enum SourceTypeEnum {
+    BASE_DATE_TO_SUBJECT_ORI("baseDateToSubjectOri" ,"定向信息源","定向信息源"),
+    BASE_DATE_TO_SUBJECT("baseDateToSubject", "通用信息源","通用信息源"),
+    BASE_DATE_TO_SUBJECT_IGNORE_KW("baseDateToSubjectIgnoreKw", "通用信息源（免过关键词信息源）","通用信息源（免过关键词信息源）"),
+    BASE_DATE_TO_SUBJECT_VIDEO("baseDateToSubjectVideo", "视频数据","专题绑定的所有信息源的视频数据"),
+    SUBJECT_TO_SUBJECT("subjectToSubject", "专题库","专题到专题来源"),
+    ENTERPRISE_TO_SUBJECT_TYPE_OTHER("enterpriseToSubjectTypeOther", "企业库-其他","企业库源研报、公告、动态数据来源"),
+    ENTERPRISE_TO_SUBJECT_TYPE_YEAR("enterpriseToSubjectTypeYear", "企业库-年报","企业库年报来源"),
+    POLICY_TO_SUBJECT("policyToSubject", "政策库","政策法规来源"),
+    YJZX_PLATFORM_TO_SUBJECT("yjzxPlatFormToSubject", "平台数据","平台数据来源"),
+    KEYWORDS_TO_SUBJECT("keyWordsToSubject", "采集词","配置的采集词组来源");
+
+    private final String value;
+    private final String description;
+    private final String valueName;
+
+    SourceTypeEnum(String value, String valueName, String description) {
+        this.value = value;
+        this.description = description;
+        this.valueName = valueName;
+    }
+
+    public String getValue() {
+        return value;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public String getValueName() {
+        return valueName;
+    }
+
+    public static String getDescriptionByValue(String value) {
+        for (SourceTypeEnum enumValue : values()) {
+            if (enumValue.getValue().equals(value)) {
+                return enumValue.getDescription();
+            }
+        }
+        return null;
+    }
+
+    public static String getValueNameByValue(String value) {
+        for (SourceTypeEnum enumValue : values()) {
+            if (enumValue.getValue().equals(value)) {
+                return enumValue.getValueName();
+            }
+        }
+        return null;
+    }
+
+    public static List<String> getAllValues() {
+        List<String> values = new ArrayList<>();
+        for (SourceTypeEnum enumValue : values()) {
+            values.add(enumValue.getValue());
+        }
+        return values;
+    }
+    public static List<String> getbaseDateSourceType() {
+        List<String> values = new ArrayList<>();
+        values.add(SourceTypeEnum.BASE_DATE_TO_SUBJECT.getValue());
+        values.add(SourceTypeEnum.BASE_DATE_TO_SUBJECT_ORI.getValue());
+        values.add(SourceTypeEnum.BASE_DATE_TO_SUBJECT_IGNORE_KW.getValue());
+        values.add(SourceTypeEnum.BASE_DATE_TO_SUBJECT_VIDEO.getValue());
+        values.add(SourceTypeEnum.KEYWORDS_TO_SUBJECT.getValue());
+        return values;
+    }
+    public static List<String> getEnterpriseSourceType() {
+        List<String> values = new ArrayList<>();
+        values.add(SourceTypeEnum.ENTERPRISE_TO_SUBJECT_TYPE_OTHER.getValue());
+        values.add(SourceTypeEnum.ENTERPRISE_TO_SUBJECT_TYPE_OTHER.getValue());
+        return values;
+    }
+}

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

+package com.zzsn.event.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.zzsn.event.entity.arrange.ClbModelArrange;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+/**
+ * @Description: 流程编排
+ * @Author: jeecg-boot
+ * @Date:   2024-11-14
+ * @Version: V1.0
+ */
+@Mapper
+public interface ClbModelArrangeMapper extends BaseMapper<ClbModelArrange> {
+
+    List<ClbModelArrange> listBySubjectIds(@Param("idList") List<String> idList);
+}

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

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.zzsn.event.mapper.ClbModelArrangeMapper">
+
+    <select id="listBySubjectIds" resultType="com.zzsn.event.entity.arrange.ClbModelArrange">
+        SELECT ag.id,ag.group_id,ag.name,ag.code,ag.status,ag.create_by,mp.subject_id,mp.type FROM clb_model_arrange_subject_map mp
+        INNER JOIN clb_model_arrange ag on mp.arrange_id = ag.id and ag.del_flag = 0 and mp.del_flag = 0
+        WHERE mp.subject_id in
+        <if test="idList!=null and idList.size()>0">
+            <foreach collection="idList" item="item" open="(" close=")" separator=",">
+                #{item}
+            </foreach>
+        </if>
+    </select>
+</mapper>
\ No newline at end of file

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

+package com.zzsn.event.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.zzsn.event.entity.arrange.ClbModelArrange;
+
+import java.util.List;
+
+/**
+ * @Description: 流程编排
+ * @Author: jeecg-boot
+ * @Date:   2024-11-14
+ * @Version: V1.0
+ */
+public interface IClbModelArrangeService extends IService<ClbModelArrange> {
+
+    List<ClbModelArrange> listBySubjectIds(List<String> idList);
+}

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

+package com.zzsn.event.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.zzsn.event.entity.arrange.ClbModelArrange;
+import com.zzsn.event.mapper.ClbModelArrangeMapper;
+import com.zzsn.event.service.IClbModelArrangeService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @Description: 流程编排
+ * @Author: jeecg-boot
+ * @Date:   2024-11-14
+ * @Version: V1.0
+ */
+@Service
+public class ClbModelArrangeServiceImpl extends ServiceImpl<ClbModelArrangeMapper, ClbModelArrange> implements IClbModelArrangeService {
+
+    @Override
+    public List<ClbModelArrange> listBySubjectIds(List<String> idList) {
+        return baseMapper.listBySubjectIds(idList);
+    }
+
+}

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

@@ -16,8 +16,10 @@ import com.zzsn.clb.common.model.task.dto.titr.KeyWordsDTO;
 import com.zzsn.event.constant.Constants;
 import com.zzsn.event.constant.Result;
 import com.zzsn.event.entity.*;
+import com.zzsn.event.entity.arrange.ClbModelArrange;
 import com.zzsn.event.enums.BindTypeEnum;
 import com.zzsn.event.enums.CodePrefixEnum;
+import com.zzsn.event.enums.SourceTypeEnum;
 import com.zzsn.event.mapper.SubjectMapper;
 import com.zzsn.event.service.*;
 import com.zzsn.event.util.CodeGenerateUtil;
@@ -88,7 +90,8 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl
     private IAlgorithmModelService modelService;
     @Autowired
     private ClbModelArrangeSubjectMapService clbModelArrangeSubjectMapService;
-
+    @Autowired
+    private IClbModelArrangeService clbModelArrangeService;
 
     @Value("${python.subjectProcessorUrl}")
     private String subjectProcessorUrl;
@@ -129,6 +132,16 @@ public class SubjectServiceImpl extends ServiceImpl<SubjectMapper, Subject> impl
                 subjectPage1.setInfoSourceNum(infoSourceNum);
                 subjectPage1.setKeyWordsNum(keyWordsNum);
             }
+
+            //查询绑定的流程
+            List<ClbModelArrange> clbModelArranges = clbModelArrangeService.listBySubjectIds(idList);
+            if (CollectionUtil.isNotEmpty(clbModelArranges)){
+                clbModelArranges.forEach(e -> e.setType(SourceTypeEnum.getValueNameByValue(e.getType())));
+                Map<String, List<ClbModelArrange>> collect = clbModelArranges.stream().collect(Collectors.groupingBy(ClbModelArrange::getSubjectId));
+                records.forEach(e -> {
+                    e.setClbModelArranges(collect.get(e.getId()));
+                });
+            }
         }
         return pageList;
     }

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

 package com.zzsn.event.vo;
 
 import com.fasterxml.jackson.annotation.JsonFormat;
+import com.zzsn.event.entity.arrange.ClbModelArrange;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
@@ -158,4 +159,6 @@ public class SubjectPage {
     /**预估状态*/
     private String estimateStatus;
 
+    private List<ClbModelArrange> clbModelArranges;
+
 }