Merge remote-tracking branch 'origin/master'

# Conflicts:
#	zzlogs/application-webadmin/application-webadmin.log

application-webadmin/src/main/java/com/yice/webadmin/app/controller/ModelVersionController.java

@@ -174,8 +174,11 @@ public class ModelVersionController {
      */
     @PostMapping("/listModels")
     public ResponseResult<JSONArray> listModels() throws IOException {
-        String url = this.pythonConfig.getChatAddress() + "llm_model/list_models";
-        String result = proxyPythonService.predictPost(url, "");
+        JSONObject jsonObject = new JSONObject();
+        jsonObject.put("controller_address", pythonConfig.getControllerAddress());
+        jsonObject.put("placeholder", "string");
+        String url = this.pythonConfig.getChatAddress() + "llm_model/list_running_models";
+        String result = proxyPythonService.predictPost(url, jsonObject.toJSONString());
         JSONObject jo = JSON.parseObject(result);
         Integer code = jo.getIntValue("code");
         String msg = jo.getString("msg");

application-webadmin/src/main/java/com/yice/webadmin/app/dao/KnowledgeManageMapper.java

@@ -12,7 +12,7 @@ import java.util.List;
  * @author linking
  * @date 2023-04-13
  */
-public interface KnowledgeManageMapper extends BaseDaoMapper<KnowledgeManage> {
+    public interface KnowledgeManageMapper extends BaseDaoMapper<KnowledgeManage> {
 
     /**
      * 批量插入对象列表。
@@ -25,9 +25,21 @@ public interface KnowledgeManageMapper extends BaseDaoMapper<KnowledgeManage> {
      * 获取过滤后的对象列表。
      *
      * @param knowledgeManageFilter 主表过滤对象。
+     * @param orderBy 排序字符串，order by从句的参数。
      * @param orderBy               排序字符串，order by从句的参数。
      * @return 对象列表。
      */
     List<KnowledgeManage> getKnowledgeManageList(
             @Param("knowledgeManageFilter") KnowledgeManage knowledgeManageFilter, @Param("orderBy") String orderBy);
+
+    /**
+     * 获取过滤后的对象列表。
+     *
+     * @param knowledgeManageFilter 主表过滤对象。
+     * @param orderBy               排序字符串，order by从句的参数。
+     * @return 对象列表。
+     */
+    List<KnowledgeManage> loadKnowLedgeList(
+            @Param("knowledgeManageFilter") KnowledgeManage knowledgeManageFilter, @Param("orderBy") String orderBy);
+
 }

application-webadmin/src/main/java/com/yice/webadmin/app/dao/KnowledgeUserMapper.java

+package com.yice.webadmin.app.dao;
+
+import com.yice.common.core.base.dao.BaseDaoMapper;
+import com.yice.webadmin.app.model.KnowledgeUser;
+import com.yice.webadmin.upms.model.SysUser;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+/**
+ * 知识库管理数据操作访问接口。
+ *
+ * @author linking
+ * @date 2023-04-13
+ */
+public interface KnowledgeUserMapper extends BaseDaoMapper<KnowledgeUser> {
+
+    /**
+     * 批量插入对象列表。
+     *
+     * @param knowledgeUserList 新增对象列表。
+     */
+    void insertList(List<KnowledgeUser> knowledgeUserList);
+
+    /**
+     * 根据页面Id，获取关联的用户列表。
+     *
+     * @param knowledgeId   知识库ID。
+     * @param sysUserFilter 用户过滤条件对象。
+     * @param orderBy       order by从句的参数。
+     * @return 和角色Id关联的用户列表。
+     */
+    List<SysUser> getSysUserListByKnowledgeId(
+            @Param("knowledgeId") Long knowledgeId,
+            @Param("sysUserFilter") SysUser sysUserFilter,
+            @Param("orderBy") String orderBy);
+
+    /**
+     * 获取不属于指定知识库的用户列表。
+     *
+     * @param knowledgeId  知识库ID。
+     * @param sysUserFilter 用户过滤条件对象。
+     * @param orderBy order by从句的参数。
+     * @return 和RoleId没有建立关联关系的用户列表。
+     */
+    List<SysUser> getNotInSysUserListByKnowledgeId(
+            @Param("knowledgeId") Long knowledgeId,
+            @Param("sysUserFilter") SysUser sysUserFilter,
+            @Param("orderBy") String orderBy);
+
+}

application-webadmin/src/main/java/com/yice/webadmin/app/dao/mapper/KnowledgeManageMapper.xml

@@ -8,6 +8,7 @@
         <result column="update_user_id" jdbcType="BIGINT" property="updateUserId"/>
         <result column="update_time" jdbcType="TIMESTAMP" property="updateTime"/>
         <result column="knowledge_name" jdbcType="VARCHAR" property="knowledgeName"/>
+        <result column="knowledge_code" jdbcType="VARCHAR" property="knowledgeCode"/>
         <result column="knowledge_describe" jdbcType="VARCHAR" property="knowledgeDescribe"/>
     </resultMap>
 
@@ -19,6 +20,7 @@
         update_user_id,
         update_time,
         knowledge_name,
+        knowledge_code,
         knowledge_describe)
         VALUES
         <foreach collection="list" index="index" item="item" separator=",">
@@ -28,6 +30,7 @@
             #{item.updateUserId},
             #{item.updateTime},
             #{item.knowledgeName},
+            #{item.knowledgeCode},
             #{item.knowledgeDescribe})
         </foreach>
     </insert>
@@ -38,6 +41,18 @@
         <include refid="com.yice.webadmin.app.dao.KnowledgeManageMapper.inputFilterRef"/>
     </sql>
 
+    <select id="loadKnowLedgeList" resultMap="BaseResultMap" parameterType="com.yice.webadmin.app.model.KnowledgeManage">
+        SELECT DISTINCT lmp_knowledge_manage.*
+        FROM lmp_knowledge_manage
+        LEFT JOIN lmp_knowledge_user ON lmp_knowledge_user.knowledge_id = lmp_knowledge_manage.knowledge_id
+        <if test="knowledgeManageFilter.createUserId != null">
+            WHERE lmp_knowledge_user.user_id = #{knowledgeManageFilter.createUserId}
+        </if>
+        <if test="orderBy != null and orderBy != ''">
+            ORDER BY ${orderBy}
+        </if>
+    </select>
+
     <!-- 这里仅包含调用接口输入的主表过滤条件 -->
     <sql id="inputFilterRef">
         <if test="knowledgeManageFilter != null">

application-webadmin/src/main/java/com/yice/webadmin/app/dao/mapper/KnowledgeUserMapper.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.yice.webadmin.app.dao.KnowledgeUserMapper">
+    <resultMap id="BaseResultMap" type="com.yice.webadmin.upms.model.SysUser">
+        <id column="user_id" jdbcType="BIGINT" property="userId"/>
+        <result column="login_name" jdbcType="VARCHAR" property="loginName"/>
+        <result column="password" jdbcType="VARCHAR" property="password"/>
+        <result column="dept_id" jdbcType="BIGINT" property="deptId"/>
+        <result column="show_name" jdbcType="VARCHAR" property="showName"/>
+        <result column="user_type" jdbcType="INTEGER" property="userType"/>
+        <result column="head_image_url" jdbcType="VARCHAR" property="headImageUrl"/>
+        <result column="user_status" jdbcType="INTEGER" property="userStatus"/>
+        <result column="email" jdbcType="VARCHAR" property="email"/>
+        <result column="mobile" jdbcType="VARCHAR" property="mobile"/>
+        <result column="create_user_id" jdbcType="BIGINT" property="createUserId"/>
+        <result column="update_user_id" jdbcType="BIGINT" property="updateUserId"/>
+        <result column="create_time" jdbcType="TIMESTAMP" property="createTime"/>
+        <result column="update_time" jdbcType="TIMESTAMP" property="updateTime"/>
+        <result column="deleted_flag" jdbcType="INTEGER" property="deletedFlag"/>
+    </resultMap>
+
+    <insert id="insertList">
+        INSERT INTO lmp_knowledge_user(user_id,knowledge_id)
+        VALUES
+        <foreach collection="list" index="index" item="item" separator="," >
+            (#{item.userId},#{item.knowledgeId})
+        </foreach>
+    </insert>
+
+    <!-- 如果有逻辑删除字段过滤，请写到这里 -->
+    <sql id="filterRef">
+        <!-- 这里必须加上全包名，否则当filterRef被其他Mapper.xml包含引用的时候，就会调用Mapper.xml中的该SQL片段 -->
+        <include refid="com.yice.webadmin.upms.dao.SysUserMapper.inputFilterRef"/>
+        AND sys_user.deleted_flag = ${@com.yice.common.core.constant.GlobalDeletedFlag@NORMAL}
+    </sql>
+
+    <select id="getSysUserListByKnowledgeId" resultMap="BaseResultMap">
+        SELECT
+            sys_user.*
+        FROM
+            lmp_knowledge_user,
+            sys_user
+        <where>
+            AND lmp_knowledge_user.knowledge_id = #{knowledgeId}
+            AND lmp_knowledge_user.user_id = sys_user.user_id
+            <include refid="filterRef"/>
+        </where>
+        <if test="orderBy != null and orderBy != ''">
+            ORDER BY ${orderBy}
+        </if>
+    </select>
+
+    <select id="getNotInSysUserListByKnowledgeId" resultMap="BaseResultMap">
+        SELECT * FROM sys_user
+        <where>
+            NOT EXISTS (SELECT * FROM lmp_knowledge_user
+            WHERE lmp_knowledge_user.knowledge_id = #{knowledgeId} AND lmp_knowledge_user.user_id = sys_user.user_id)
+            <include refid="filterRef"/>
+        </where>
+        <if test="orderBy != null and orderBy != ''">
+            ORDER BY ${orderBy}
+        </if>
+    </select>
+</mapper>

application-webadmin/src/main/java/com/yice/webadmin/app/dto/KnowledgeManageDto.java

@@ -38,6 +38,12 @@ public class KnowledgeManageDto {
     @ApiModelProperty(value = "知识库描述")
     private String knowledgeDescribe;
 
+    /**
+     * 知识库编码。
+     */
+    @ApiModelProperty(value = "知识库编码")
+    private String knowledgeCode;
+
     /**
      * knowledge_name LIKE搜索字符串。
      */

application-webadmin/src/main/java/com/yice/webadmin/app/model/KnowledgeManage.java

@@ -38,6 +38,11 @@ public class KnowledgeManage extends BaseModel {
      */
     private String knowledgeName;
 
+    /**
+     * 知识库编码。
+     */
+    private String knowledgeCode;
+
     /**
      * 知识库描述。
      */

application-webadmin/src/main/java/com/yice/webadmin/app/model/KnowledgeUser.java

+package com.yice.webadmin.app.model;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * KnowledgeUser实体对象。
+ *
+ * @author linking
+ * @date 2022-04-05
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@TableName(value = "lmp_knowledge_user")
+public class KnowledgeUser {
+
+    /**
+     * 用户id。
+     */
+    private Long userId;
+
+    /**
+     * 知识库id。
+     */
+    private Long knowledgeId;
+
+}

application-webadmin/src/main/java/com/yice/webadmin/app/service/KnowledgeManageService.java

@@ -2,6 +2,8 @@ package com.yice.webadmin.app.service;
 
 import com.yice.common.core.base.service.IBaseService;
 import com.yice.webadmin.app.model.KnowledgeManage;
+import com.yice.webadmin.app.model.KnowledgeUser;
+import com.yice.webadmin.upms.model.SysUser;
 
 import java.util.List;
 
@@ -21,6 +23,51 @@ public interface KnowledgeManageService extends IBaseService<KnowledgeManage, Lo
      */
     KnowledgeManage saveNew(KnowledgeManage knowledgeManage);
 
+    /**
+     * 批量新增用户页面关联。
+     *
+     * @param knowledgeUserList 用户页面关系数据列表。
+     */
+    void addKnowledgeUserList(List<KnowledgeUser> knowledgeUserList);
+
+    /**
+     * 移除指定用户和指定知识库的关联关系。
+     *
+     * @param knowledgeId 知识库标识。
+     * @param userId 用户主键Id。
+     * @return 移除成功返回true，否则false。
+     */
+    boolean removeKnowledgeUser(Long knowledgeId, Long userId);
+
+    /**
+     * 获取指定角色的用户列表。
+     *
+     * @param knowledgeId 知识库标识。
+     * @param filter  用户过滤对象。
+     * @param orderBy 排序参数。
+     * @return 用户列表。
+     */
+    List<SysUser> getSysUserListByKnowledgeId(Long knowledgeId, SysUser filter, String orderBy);
+
+    /**
+     * 获取不属于指定知识库的用户列表。
+     *
+     * @param knowledgeId 知识库ID。
+     * @param filter  用户过滤对象。
+     * @param orderBy 排序参数。
+     * @return 用户列表。
+     */
+    List<SysUser> getNotInSysUserListByKnowledgeId(Long knowledgeId, SysUser filter, String orderBy);
+
+    /**
+     * 获取单表查询结果。由于没有关联数据查询，因此在仅仅获取单表数据的场景下，效率更高。
+     *
+     * @param filter  过滤对象。
+     * @param orderBy 排序参数。
+     * @return 查询结果集。
+     */
+    List<KnowledgeManage> loadKnowledgeUserList(KnowledgeManage filter, String orderBy);
+
     /**
      * 利用数据库的insertList语法，批量插入对象列表。
      *

application-webadmin/src/main/java/com/yice/webadmin/app/service/impl/KnowledgeManageServiceImpl.java

 package com.yice.webadmin.app.service.impl;
 
 import cn.hutool.core.collection.CollUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.github.pagehelper.Page;
 import com.yice.common.core.base.dao.BaseDaoMapper;
@@ -9,8 +10,11 @@ import com.yice.common.core.object.MyRelationParam;
 import com.yice.common.core.util.MyModelUtil;
 import com.yice.common.sequence.wrapper.IdGeneratorWrapper;
 import com.yice.webadmin.app.dao.KnowledgeManageMapper;
+import com.yice.webadmin.app.dao.KnowledgeUserMapper;
 import com.yice.webadmin.app.model.KnowledgeManage;
+import com.yice.webadmin.app.model.KnowledgeUser;
 import com.yice.webadmin.app.service.KnowledgeManageService;
+import com.yice.webadmin.upms.model.SysUser;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -32,7 +36,8 @@ public class KnowledgeManageServiceImpl extends BaseService<KnowledgeManage, Lon
     private KnowledgeManageMapper knowledgeManageMapper;
     @Autowired
     private IdGeneratorWrapper idGenerator;
-
+    @Autowired
+    private KnowledgeUserMapper knowledgeUserMapper;
 
     /**
      * 返回当前Service的主表Mapper对象。
@@ -71,6 +76,59 @@ public class KnowledgeManageServiceImpl extends BaseService<KnowledgeManage, Lon
         }
     }
 
+    /**
+     * 批量新增用户页面关联。
+     *
+     * @param knowledgeUserList 用户页面关系数据列表。
+     */
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public void addKnowledgeUserList(List<KnowledgeUser> knowledgeUserList) {
+        if(CollUtil.isNotEmpty(knowledgeUserList)){
+            knowledgeUserMapper.insertList(knowledgeUserList);
+        }
+    }
+
+    /**
+     * 获取指定角色的用户列表。
+     *
+     * @param knowledgeId  知识库标识。
+     * @param filter  用户过滤对象。
+     * @param orderBy 排序参数。
+     * @return 用户列表。
+     */
+    @Override
+    public List<SysUser> getSysUserListByKnowledgeId(Long knowledgeId, SysUser filter, String orderBy) {
+        return knowledgeUserMapper.getSysUserListByKnowledgeId(knowledgeId, filter, orderBy);
+    }
+
+    /**
+     * 获取不属于指定知识库的用户列表。
+     *
+     * @param knowledgeId 知识库ID。
+     * @param filter  用户过滤对象。
+     * @param orderBy 排序参数。
+     * @return 用户列表。
+     */
+    @Override
+    public List<SysUser> getNotInSysUserListByKnowledgeId(Long knowledgeId, SysUser filter, String orderBy) {
+        return knowledgeUserMapper.getNotInSysUserListByKnowledgeId(knowledgeId, filter, orderBy);
+    }
+
+    /**
+     * 移除指定用户和指定知识库的关联关系。
+     *
+     * @param knowledgeId 知识库标识。
+     * @param userId 用户主键Id。
+     * @return 移除成功返回true，否则false。
+     */
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public boolean removeKnowledgeUser(Long knowledgeId, Long userId) {
+        KnowledgeUser knowledgeUser  = new KnowledgeUser(userId, knowledgeId);
+        return knowledgeUserMapper.delete(new QueryWrapper<>(knowledgeUser)) == 1;
+    }
+
     /**
      * 更新数据对象。
      *
@@ -87,6 +145,21 @@ public class KnowledgeManageServiceImpl extends BaseService<KnowledgeManage, Lon
         return knowledgeManageMapper.update(knowledgeManage, uw) == 1;
     }
 
+    /**
+     * 获取单表查询结果。由于没有关联数据查询，因此在仅仅获取单表数据的场景下，效率更高。
+     *
+     * @param filter  过滤对象。
+     * @param orderBy 排序参数。
+     * @return 查询结果集。
+     */
+    @Override
+    public List<KnowledgeManage> loadKnowledgeUserList(KnowledgeManage filter, String orderBy) {
+        if (filter == null) {
+            filter = new KnowledgeManage();
+        }
+        return knowledgeManageMapper.loadKnowLedgeList(filter, orderBy);
+    }
+
     /**
      * 删除指定数据。
      *

application-webadmin/src/main/java/com/yice/webadmin/app/vo/KnowledgeManageVo.java

@@ -37,6 +37,12 @@ public class KnowledgeManageVo extends BaseVo {
     @ApiModelProperty(value = "知识库描述")
     private String knowledgeDescribe;
 
+    /**
+     * 知识库编码。
+     */
+    @ApiModelProperty(value = "知识库编码")
+    private String knowledgeCode;
+
     /**
      * 创建人名称。
      */

application-webadmin/src/main/java/com/yice/webadmin/upms/dao/SysUserMapper.java

@@ -23,6 +23,13 @@ public interface SysUserMapper extends BaseDaoMapper<SysUser> {
      */
     void insertList(List<SysUser> sysUserList);
 
+    /**
+     * 根据用户编号进行删除。
+     *
+     * @param userId 用户编号。
+     */
+    Integer deleteByUserId(@Param("userId") Long userId);
+
     /**
      * 获取过滤后的对象列表。
      *

application-webadmin/src/main/java/com/yice/webadmin/upms/dao/mapper/SysUserMapper.xml

@@ -386,4 +386,8 @@
         ORDER BY
         r.role_id, m.menu_id
     </select>
+
+    <delete id="deleteByUserId" parameterType="java.lang.Long">
+        DELETE FROM sys_user WHERE user_id = #{userId}
+    </delete>
 </mapper>

application-webadmin/src/main/java/com/yice/webadmin/upms/service/impl/SysUserServiceImpl.java

@@ -20,6 +20,8 @@ import com.yice.common.ext.base.BizWidgetDatasource;
 import com.yice.common.ext.constant.BizWidgetDatasourceType;
 import com.yice.common.ext.util.BizWidgetDatasourceExtHelper;
 import com.yice.common.sequence.wrapper.IdGeneratorWrapper;
+import com.yice.webadmin.app.dao.KnowledgeUserMapper;
+import com.yice.webadmin.app.model.KnowledgeUser;
 import com.yice.webadmin.upms.dao.SysDataPermUserMapper;
 import com.yice.webadmin.upms.dao.SysUserMapper;
 import com.yice.webadmin.upms.dao.SysUserPostMapper;
@@ -59,6 +61,8 @@ public class SysUserServiceImpl extends BaseService<SysUser, Long> implements Sy
     @Autowired
     private SysDataPermUserMapper sysDataPermUserMapper;
     @Autowired
+    private KnowledgeUserMapper knowledgeUserMapper;
+    @Autowired
     private SysDeptService sysDeptService;
     @Autowired
     private SysRoleService sysRoleService;
@@ -308,7 +312,7 @@ public class SysUserServiceImpl extends BaseService<SysUser, Long> implements Sy
     @Transactional(rollbackFor = Exception.class)
     @Override
     public boolean remove(Long userId) {
-        if (sysUserMapper.deleteById(userId) == 0) {
+        if (sysUserMapper.deleteByUserId(userId) == 0) {
             return false;
         }
         SysUserRole userRole = new SysUserRole();
@@ -320,6 +324,9 @@ public class SysUserServiceImpl extends BaseService<SysUser, Long> implements Sy
         SysDataPermUser dataPermUser = new SysDataPermUser();
         dataPermUser.setUserId(userId);
         sysDataPermUserMapper.delete(new QueryWrapper<>(dataPermUser));
+        KnowledgeUser knowledgeUser = new KnowledgeUser();
+        knowledgeUser.setUserId(userId);
+        knowledgeUserMapper.delete(new QueryWrapper<>(knowledgeUser));
         return true;
     }
 

application-webadmin/src/main/resources/application-dev.yml

@@ -78,9 +78,9 @@ python:
   #python websocket 服务地址
   pythonWebsocketUri: ws://192.168.0.36:7860/queue/join
   #输出控制地址
-  controllerAddress: http://0.0.0.0:20001
+  controllerAddress: http://192.168.0.36:20001
   #对话基础路径
-  chatAddress: http://192.168.0.36:8000/
+  chatAddress: http://192.168.0.36:7861/
 
 knowledge:
   #知识库通用接口地址
@@ -177,9 +177,9 @@ redis:
       # 连接池中最小空闲数量。
       minIdle: 5
 
-minio:
-  enabled: true
-  endpoint: http://192.168.0.145:9090
-  accessKey: minioadmin
-  secretKey: minioadmin
-  bucketName: application
+#minio:
+#  enabled: true
+#  endpoint: http://192.168.0.145:9090
+#  accessKey: minioadmin
+#  secretKey: minioadmin
+#  bucketName: application

pom.xml

@@ -166,7 +166,11 @@
             <artifactId>jaxb-api</artifactId>
             <version>2.3.0</version>
         </dependency>
-
+        <dependency>
+            <groupId>io.github.biezhi</groupId>
+            <artifactId>TinyPinyin</artifactId>
+            <version>2.0.3.RELEASE</version>
+        </dependency>
     </dependencies>
 
     <dependencyManagement>