فهرست منبع

增加分享人员时,发送聊天消息

wukai 1 سال پیش
والد
کامیت
0bc6678222

+ 109 - 0
doc-admin/src/main/resources/application-t1.yml

@@ -0,0 +1,109 @@
+# 开发环境配置
+server:
+  # 服务器的HTTP端口,默认为8080
+  port: 8080
+# 项目相关配置
+ruoyi:
+  # 文件路径 示例( Windows配置D:/ruoyi/uploadPath,Linux配置 /home/ruoyi/uploadPath)
+  profile: D:/ruoyi/uploadPath
+# Spring配置
+spring:
+  #es配置
+  elasticsearch:
+    rest:
+      uris: http://192.168.1.28:19200
+  #mongodb配置
+  data:
+    mongodb:
+      host: 192.168.1.28
+      port: 27017
+      database: document
+
+  # redis 配置
+  redis:
+    # 地址
+    host: 192.168.1.28
+    # 端口,默认为6379
+    port: 6379
+    # 数据库索引
+    database: 0
+    # 密码
+    password: redis123
+    # 连接超时时间
+    timeout: 10s
+    lettuce:
+      pool:
+        # 连接池中的最小空闲连接
+        min-idle: 0
+        # 连接池中的最大空闲连接
+        max-idle: 8
+        # 连接池的最大数据库连接数
+        max-active: 8
+        # #连接池最大阻塞等待时间(使用负值表示没有限制)
+        max-wait: -1ms
+  #数据源配置
+  datasource:
+    type: com.alibaba.druid.pool.DruidDataSource
+    driverClassName: com.mysql.cj.jdbc.Driver
+    druid:
+      # 主库数据源
+      master:
+        url: jdbc:mysql://192.168.1.28:3306/doc?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+        username: root
+        password: 123456
+      # 从库数据源
+      slave:
+        # 从数据源开关/默认关闭
+        enabled: false
+        url:
+        username:
+        password:
+      # 初始连接数
+      initialSize: 5
+      # 最小连接池数量
+      minIdle: 10
+      # 最大连接池数量
+      maxActive: 20
+      # 配置获取连接等待超时的时间
+      maxWait: 60000
+      # 配置连接超时时间
+      connectTimeout: 30000
+      # 配置网络超时时间
+      socketTimeout: 60000
+      # 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒
+      timeBetweenEvictionRunsMillis: 60000
+      # 配置一个连接在池中最小生存的时间,单位是毫秒
+      minEvictableIdleTimeMillis: 300000
+      # 配置一个连接在池中最大生存的时间,单位是毫秒
+      maxEvictableIdleTimeMillis: 900000
+      # 配置检测连接是否有效
+      validationQuery: SELECT 1 FROM DUAL
+      testWhileIdle: true
+      testOnBorrow: false
+      testOnReturn: false
+      webStatFilter:
+        enabled: true
+      statViewServlet:
+        enabled: true
+        # 设置白名单,不填则允许所有访问
+        allow:
+        url-pattern: /druid/*
+        # 控制台管理用户名和密码
+        login-username: admin
+        login-password: admin
+      filter:
+        stat:
+          enabled: true
+          # 慢SQL记录
+          log-slow-sql: true
+          slow-sql-millis: 1000
+          merge-sql: true
+        wall:
+          config:
+            multi-statement-allow: true
+
+# 日志配置
+logging:
+  level:
+    com.doc: debug
+    org.springframework: warn

+ 3 - 2
doc-biz/src/main/java/com/doc/biz/controller/DocInfoController.java

@@ -5,6 +5,7 @@ import com.doc.biz.service.*;
 import com.doc.biz.vo.DocInfoVO;
 import com.doc.biz.vo.DocumentVO;
 import com.doc.chat.domain.ChatMsg;
+import com.doc.chat.service.IChatMsgService;
 import com.doc.common.annotation.Log;
 import com.doc.common.config.EsConfig;
 import com.doc.common.core.controller.BaseController;
@@ -53,7 +54,7 @@ public class DocInfoController extends BaseController {
     @Resource
     private IDocShareService shareService;
     @Resource
-    private ISysConfigService configService;
+    private IChatMsgService msgService;
     @Resource
     private IDocDirService dirService;
 
@@ -165,7 +166,6 @@ public class DocInfoController extends BaseController {
     public AjaxResult share(@ApiParam(value = "文件ID", required = true) @PathVariable(name = "docId") Long docId, @ApiParam(value = "分享人员", required = true) @RequestBody List<DocShare> shares) {
         shareService.deleteDocShareByDocId(docId);
 
-        String content = configService.selectConfigByKey("msg.share.content");
         shares.forEach(s -> {
             s.setDocId(docId);
             ChatMsg msg = new ChatMsg();
@@ -173,6 +173,7 @@ public class DocInfoController extends BaseController {
             msg.setToId(s.getUserId());
             msg.setContent(docId + "");
             msg.setFromId(SecurityUtils.getUserId());
+            msgService.send(msg);
             shareService.insertDocShare(s);
         });