提交政策法规分页查询

kbqa-graph/src/main/java/com/supervision/controller/PolicyController.java

@@ -0,0 +1,36 @@
+package com.supervision.controller;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.supervision.model.KgPolicy;
+import com.supervision.service.KgPolicyService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@Api(tags = "政策法规")
+@RestController
+@RequestMapping("policy")
+@RequiredArgsConstructor
+public class PolicyController {
+
+    private final KgPolicyService kgPolicyService;
+
+
+    @GetMapping("queryPolicyPage")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "keyword", value = "模糊搜索", required = true, dataType = "String", paramType = "query"),
+            @ApiImplicitParam(name = "level", value = "政策层级(1国家级;2省级;3市级;4县级)", required = true, dataType = "String", paramType = "query"),
+            @ApiImplicitParam(name = "subject", value = "主题(1养老退休;2人事人才;3就业创业;4社会保障;5劳动关系)", required = true, dataType = "String", paramType = "query"),
+            @ApiImplicitParam(name = "type", value = "政策类型(1意见;2方案;3通知;4规章;5政策解读)", required = true, dataType = "String", paramType = "query"),
+            @ApiImplicitParam(name = "order", value = "排序方式 默认发文时间降序,1最多收藏降序;2最多浏览降序", required = true, dataType = "Integer", paramType = "query"),
+            @ApiImplicitParam(name = "pageSize", value = "pageSize", required = true, dataType = "Integer", paramType = "query"),
+            @ApiImplicitParam(name = "pageNum", value = "pageNum", required = true, dataType = "Integer", paramType = "query")
+    })
+    public IPage<KgPolicy> queryPolicyPage(String keyword, Integer level, Integer subject, Integer type, Integer order, Integer pageNum, Integer pageSize) {
+        return kgPolicyService.queryPolicyPage(keyword, level, subject, type, order, pageNum, pageSize);
+    }
+}

kbqa-model/src/main/java/com/supervision/mapper/KgPolicyMapper.java

@@ -1,16 +1,25 @@
 package com.supervision.mapper;
 
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.supervision.model.KgPolicy;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Param;
 
 /**
-* @author Administrator
-* @description 针对表【kg_policy(政策法规表)】的数据库操作Mapper
-* @createDate 2024-04-16 13:05:24
-* @Entity com.supervision.model.KgPolicy
-*/
+ * @author Administrator
+ * @description 针对表【kg_policy(政策法规表)】的数据库操作Mapper
+ * @createDate 2024-04-16 13:05:24
+ * @Entity com.supervision.model.KgPolicy
+ */
 public interface KgPolicyMapper extends BaseMapper<KgPolicy> {
 
+    IPage<KgPolicy> queryPolicyPage(@Param("keyword") String keyword,
+                                    @Param("level") Integer level,
+                                    @Param("subject") Integer subject,
+                                    @Param("type") Integer type,
+                                    @Param("page") Page<KgPolicy> page);
+
 }
 
 

kbqa-model/src/main/java/com/supervision/model/KgPolicy.java

@@ -84,74 +84,4 @@ public class KgPolicy implements Serializable {
     @TableField(exist = false)
     private static final long serialVersionUID = 1L;
 
-    @Override
-    public boolean equals(Object that) {
-        if (this == that) {
-            return true;
-        }
-        if (that == null) {
-            return false;
-        }
-        if (getClass() != that.getClass()) {
-            return false;
-        }
-        KgPolicy other = (KgPolicy) that;
-        return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
-            && (this.getTitle() == null ? other.getTitle() == null : this.getTitle().equals(other.getTitle()))
-            && (this.getContent() == null ? other.getContent() == null : this.getContent().equals(other.getContent()))
-            && (this.getStatus() == null ? other.getStatus() == null : this.getStatus().equals(other.getStatus()))
-            && (this.getDocNumber() == null ? other.getDocNumber() == null : this.getDocNumber().equals(other.getDocNumber()))
-            && (this.getLevel() == null ? other.getLevel() == null : this.getLevel().equals(other.getLevel()))
-            && (this.getSubject() == null ? other.getSubject() == null : this.getSubject().equals(other.getSubject()))
-            && (this.getType() == null ? other.getType() == null : this.getType().equals(other.getType()))
-            && (this.getReadCount() == null ? other.getReadCount() == null : this.getReadCount().equals(other.getReadCount()))
-            && (this.getMarkCount() == null ? other.getMarkCount() == null : this.getMarkCount().equals(other.getMarkCount()))
-            && (this.getPublishTime() == null ? other.getPublishTime() == null : this.getPublishTime().equals(other.getPublishTime()))
-            && (this.getWriteTime() == null ? other.getWriteTime() == null : this.getWriteTime().equals(other.getWriteTime()))
-            && (this.getPublishDept() == null ? other.getPublishDept() == null : this.getPublishDept().equals(other.getPublishDept()));
-    }
-
-    @Override
-    public int hashCode() {
-        final int prime = 31;
-        int result = 1;
-        result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
-        result = prime * result + ((getTitle() == null) ? 0 : getTitle().hashCode());
-        result = prime * result + ((getContent() == null) ? 0 : getContent().hashCode());
-        result = prime * result + ((getStatus() == null) ? 0 : getStatus().hashCode());
-        result = prime * result + ((getDocNumber() == null) ? 0 : getDocNumber().hashCode());
-        result = prime * result + ((getLevel() == null) ? 0 : getLevel().hashCode());
-        result = prime * result + ((getSubject() == null) ? 0 : getSubject().hashCode());
-        result = prime * result + ((getType() == null) ? 0 : getType().hashCode());
-        result = prime * result + ((getReadCount() == null) ? 0 : getReadCount().hashCode());
-        result = prime * result + ((getMarkCount() == null) ? 0 : getMarkCount().hashCode());
-        result = prime * result + ((getPublishTime() == null) ? 0 : getPublishTime().hashCode());
-        result = prime * result + ((getWriteTime() == null) ? 0 : getWriteTime().hashCode());
-        result = prime * result + ((getPublishDept() == null) ? 0 : getPublishDept().hashCode());
-        return result;
-    }
-
-    @Override
-    public String toString() {
-        StringBuilder sb = new StringBuilder();
-        sb.append(getClass().getSimpleName());
-        sb.append(" [");
-        sb.append("Hash = ").append(hashCode());
-        sb.append(", id=").append(id);
-        sb.append(", title=").append(title);
-        sb.append(", content=").append(content);
-        sb.append(", status=").append(status);
-        sb.append(", docNumber=").append(docNumber);
-        sb.append(", level=").append(level);
-        sb.append(", subject=").append(subject);
-        sb.append(", type=").append(type);
-        sb.append(", readCount=").append(readCount);
-        sb.append(", markCount=").append(markCount);
-        sb.append(", publishTime=").append(publishTime);
-        sb.append(", writeTime=").append(writeTime);
-        sb.append(", publishDept=").append(publishDept);
-        sb.append(", serialVersionUID=").append(serialVersionUID);
-        sb.append("]");
-        return sb.toString();
-    }
 }

kbqa-model/src/main/java/com/supervision/service/KgPolicyService.java

@@ -1,5 +1,6 @@
 package com.supervision.service;
 
+import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.supervision.model.KgPolicy;
 import com.baomidou.mybatisplus.extension.service.IService;
 
@@ -10,4 +11,6 @@ import com.baomidou.mybatisplus.extension.service.IService;
 */
 public interface KgPolicyService extends IService<KgPolicy> {
 
+    IPage<KgPolicy> queryPolicyPage(String keyword, Integer level, Integer subject, Integer type,  Integer order,Integer pageNum, Integer pageSize);
+
 }

kbqa-model/src/main/java/com/supervision/service/impl/KgPolicyServiceImpl.java

@@ -1,5 +1,9 @@
 package com.supervision.service.impl;
 
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.metadata.OrderItem;
+import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.supervision.model.KgPolicy;
 import com.supervision.service.KgPolicyService;
@@ -7,14 +11,34 @@ import com.supervision.mapper.KgPolicyMapper;
 import org.springframework.stereotype.Service;
 
 /**
-* @author Administrator
-* @description 针对表【kg_policy(政策法规表)】的数据库操作Service实现
-* @createDate 2024-04-16 13:05:24
-*/
+ * @author Administrator
+ * @description 针对表【kg_policy(政策法规表)】的数据库操作Service实现
+ * @createDate 2024-04-16 13:05:24
+ */
 @Service
 public class KgPolicyServiceImpl extends ServiceImpl<KgPolicyMapper, KgPolicy>
-    implements KgPolicyService{
+        implements KgPolicyService {
 
+    @Override
+    public IPage<KgPolicy> queryPolicyPage(String keyword, Integer level, Integer subject, Integer type, Integer order, Integer pageNum, Integer pageSize) {
+        // 排序方式 默认发文时间降序,1最多收藏降序;2最多浏览降序
+        Page<KgPolicy> page = new Page<>(pageNum, pageSize);
+        if (ObjectUtils.isNull(order)) {
+            // 默认发文时间排序
+            page.addOrder(OrderItem.desc("publish_time"));
+        } else {
+            if (1 == order) {
+                // 收藏降序
+                page.addOrder(OrderItem.desc("mark_count"));
+            }
+            if (2 == order) {
+                // 浏览降序
+                page.addOrder(OrderItem.desc("read_count"));
+            }
+        }
+
+        return this.baseMapper.queryPolicyPage(keyword, level, subject, type, page);
+    }
 }
 
 

kbqa-model/src/main/resources/mapper/KgPolicyMapper.xml

@@ -5,26 +5,44 @@
 <mapper namespace="com.supervision.mapper.KgPolicyMapper">
 
     <resultMap id="BaseResultMap" type="com.supervision.model.KgPolicy">
-            <id property="id" column="id" jdbcType="VARCHAR"/>
-            <result property="title" column="title" jdbcType="VARCHAR"/>
-            <result property="content" column="content" jdbcType="VARCHAR"/>
-            <result property="status" column="status" jdbcType="INTEGER"/>
-            <result property="docNumber" column="doc_number" jdbcType="VARCHAR"/>
-            <result property="level" column="level" jdbcType="INTEGER"/>
-            <result property="subject" column="subject" jdbcType="INTEGER"/>
-            <result property="type" column="type" jdbcType="INTEGER"/>
-            <result property="readCount" column="read_count" jdbcType="INTEGER"/>
-            <result property="markCount" column="mark_count" jdbcType="INTEGER"/>
-            <result property="publishTime" column="publish_time" jdbcType="TIMESTAMP"/>
-            <result property="writeTime" column="write_time" jdbcType="TIMESTAMP"/>
-            <result property="publishDept" column="publish_dept" jdbcType="VARCHAR"/>
+        <id property="id" column="id" jdbcType="VARCHAR"/>
+        <result property="title" column="title" jdbcType="VARCHAR"/>
+        <result property="content" column="content" jdbcType="VARCHAR"/>
+        <result property="status" column="status" jdbcType="INTEGER"/>
+        <result property="docNumber" column="doc_number" jdbcType="VARCHAR"/>
+        <result property="level" column="level" jdbcType="INTEGER"/>
+        <result property="subject" column="subject" jdbcType="INTEGER"/>
+        <result property="type" column="type" jdbcType="INTEGER"/>
+        <result property="readCount" column="read_count" jdbcType="INTEGER"/>
+        <result property="markCount" column="mark_count" jdbcType="INTEGER"/>
+        <result property="publishTime" column="publish_time" jdbcType="TIMESTAMP"/>
+        <result property="writeTime" column="write_time" jdbcType="TIMESTAMP"/>
+        <result property="publishDept" column="publish_dept" jdbcType="VARCHAR"/>
     </resultMap>
 
     <sql id="Base_Column_List">
-        id,title,content,
+        id
+        ,title,content,
         status,doc_number,level,
         subject,type,read_count,
         mark_count,publish_time,write_time,
         publish_dept
     </sql>
+    <select id="queryPolicyPage" resultType="com.supervision.model.KgPolicy">
+        select *
+        from kg_policy
+        where 1= 1
+        <if test="keyword != null and keyword != ''">
+            and (title like concat('%', #{keyword}, '%') or content like concat('%', #{keyword}, '%'))
+        </if>
+        <if test="level != null">
+            and level = #{level}
+        </if>
+        <if test="subject != null">
+            and subject = #{subject}
+        </if>
+        <if test="type != null">
+            and type = #{type}
+        </if>
+    </select>
 </mapper>