Преглед на файлове

修改私聊创建逻辑

udream-cxs преди 5 години
родител
ревизия
67841a6bb0

+ 2 - 2
lift-ud-service/pom.xml

@@ -18,10 +18,10 @@
             <groupId>cn.com.xwy</groupId>
             <artifactId>xwy-spring-boot</artifactId>
         </dependency>
-        <dependency>
+        <!--<dependency>
               <groupId>cn.com.xwy</groupId>
               <artifactId>xwy-cloud-dependencies</artifactId>
-        </dependency>
+        </dependency>-->
 
         <!-- swagger -->
         <dependency>

+ 2 - 2
lift-ud-service/src/main/java/cn/com/ty/lift/ud/chat/controller/query/ChatMsgQuery.java

@@ -41,13 +41,13 @@ public final class ChatMsgQuery extends BasePageQuery {
      * 来自
      */
     @ApiModelProperty("来自")
-    private Integer fromUser;
+    private Long fromUser;
 
     /**
      * 到达
      */
     @ApiModelProperty("到达")
-    private Integer toUser;
+    private Long toUser;
 
     /**
      * 信息 聊天信息

+ 4 - 3
lift-ud-service/src/main/java/cn/com/ty/lift/ud/chat/service/impl/ChatSessionServiceImpl.java

@@ -143,8 +143,9 @@ public class ChatSessionServiceImpl extends ServiceImpl<ChatSessionMapper, ChatS
 
         if (StringUtils.isBlank(sessionId)) {
             ChatSessionEntity record = new ChatSessionEntity();
+            //添加自己到房间
             sessionId = UUIDUtil.getUuidByTime9();
-            record.setUserId(request.getUserId());
+            record.setUserId(request.getCreateUserId());
             record.setCreateUserId(request.getCreateUserId());
             record.setSessionid(sessionId);
             record.setDataTable(3);
@@ -152,9 +153,9 @@ public class ChatSessionServiceImpl extends ServiceImpl<ChatSessionMapper, ChatS
             record.setStatuz(1);
             record.setCreateTime(LocalDateTime.now());
             sessionMapper.insertSelective(record);
-            
+            //添加对方用户到房间
             record = new ChatSessionEntity();
-            record.setUserId(request.getCreateUserId());
+            record.setUserId(request.getUserId());
             record.setSessionid(sessionId);
             record.setDataTable(3);
             record.setEntrance(1);