修改代码

cdp-tools/cdp-tool-netty-disruptor/src/main/java/com/baiye/service/SocketServerHandler.java

@@ -257,7 +257,7 @@ public class SocketServerHandler extends SimpleChannelInboundHandler<Object> {
         if (personalWeChatUserDTO != null) {
             WeChatSendTextDTO weChatSendTextDTO = new WeChatSendTextDTO();
             weChatSendTextDTO.setContent("");
-            weChatSendTextDTO.setTagetWxId(personalWeChatUserDTO.getWeChatId());
+            weChatSendTextDTO.setTargetWxId(personalWeChatUserDTO.getWeChatId());
             weChatSendTextDTO.setWechat(personalWeChatUserDTO.getEnterpriseId());
             weChatUserService.sendText(weChatSendTextDTO);
         }

cdp-tools/cdp-tool-wechat/cdp-wechat-core/src/main/java/com/baiye/dto/WeChatSendDTO.java

@@ -0,0 +1,22 @@
+package com.baiye.dto;
+
+import lombok.Data;
+
+/**
+ * @author Enzo
+ * @date : 2022/8/12
+ */
+@Data
+public class WeChatSendDTO {
+
+    /**
+     * 机器人id
+     */
+    private String wechat;
+    /**
+     * 接收方id
+     */
+    private String targetWxId;
+
+
+}

cdp-tools/cdp-tool-wechat/cdp-wechat-core/src/main/java/com/baiye/dto/WeChatSendGifDTO.java

@@ -2,20 +2,17 @@ package com.baiye.dto;
 
 import lombok.Data;
 
+import java.io.Serializable;
+
 /**
  * @author wjt
  * @date 2022/07/18
  */
 @Data
-public class WeChatSendGifDTO {
-    /**
-     * 机器人id
-     */
-    private String wechat;
-    /**
-     * 接收方id
-     */
-    private String targetWxId;
+public class WeChatSendGifDTO extends WeChatSendDTO implements Serializable {
+
+    private static final long serialVersionUID = -5600057882417345174L;
+
     /**
      * cdn地址,回调中msgContent部分
      */

cdp-tools/cdp-tool-wechat/cdp-wechat-core/src/main/java/com/baiye/dto/WeChatSendPicDTO.java

@@ -2,23 +2,21 @@ package com.baiye.dto;
 
 import lombok.Data;
 
+import java.io.Serializable;
+
 /**
  * 发送图片
  * @author wjt
  * @date 2022/07/18
  */
 @Data
-public class WeChatSendPicDTO {
-    /**
-     * 机器人微信
-     */
-    private String wechat;
+public class WeChatSendPicDTO extends WeChatSendDTO implements Serializable {
+
+    private static final long serialVersionUID = 9020956822916854049L;
+
     /**
      * url地址
      */
     private String parhUrl;
-    /**
-     * 接收方微信id,,群聊的话需要最后加@chatroom
-     */
-    private String tagetWxId;
+
 }

cdp-tools/cdp-tool-wechat/cdp-wechat-core/src/main/java/com/baiye/dto/WeChatSendTextDTO.java

@@ -1,7 +1,8 @@
 package com.baiye.dto;
 
 import lombok.Data;
-import lombok.NonNull;
+
+import java.io.Serializable;
 
 /**
  * 发送文本信息
@@ -10,11 +11,9 @@ import lombok.NonNull;
  * @date 2022/07/18
  */
 @Data
-public class WeChatSendTextDTO {
-    /**
-     * 机器人微信ID
-     */
-    private String wechat;
+public class WeChatSendTextDTO extends WeChatSendDTO implements Serializable {
+
+    private static final long serialVersionUID = 7892016635249900606L;
 
     /**
      * 消息内容(需要encoder转码)
@@ -22,10 +21,7 @@ public class WeChatSendTextDTO {
 
     private String content;
 
-    /**
-     * 接收方微信id,群聊的话需要最后加@chatroom
-     */
-    private String tagetWxId;
+
     /**
      * 需要@的群成员微信id , 分隔
      */

cdp-tools/cdp-tool-wechat/cdp-wechat-core/src/main/java/com/baiye/dto/WebsocketMessageRequestDTO.java

@@ -2,27 +2,25 @@ package com.baiye.dto;
 
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
+import org.apache.poi.ss.formula.functions.T;
+
+import java.io.Serializable;
 
 /**
  * @author Enzo
  * @date : 2022/8/12
  */
 @Data
-public class WebsocketMessageRequestDTO {
+public class WebsocketMessageRequestDTO implements Serializable {
+
+    private static final long serialVersionUID = 357140662095940272L;
 
-    @ApiModelProperty(value = "用户微信id")
-    private String userWechatId;
+    private String cmd;
 
-    @ApiModelProperty(value = "微信用户id")
-    private Long userId;
+    private String weChatId;
 
-    @ApiModelProperty(value = "企业微信")
-    private String enterpriseId;
+    private WeChatSendDTO data;
 
-    @ApiModelProperty(value = "消息主要内容")
-    private String content;
 
-    @ApiModelProperty(value = "消息类型")
-    private Integer messageType;
 
 }

cdp-tools/cdp-tool-wechat/cdp-wechat-server/src/main/java/com/baiye/service/impl/MessageRecordServiceImpl.java

@@ -149,7 +149,7 @@ public class MessageRecordServiceImpl extends
     public Boolean saveMessageByUserId(WebsocketMessageRequestDTO websocketMessageRequestDTO) {
         Long messageRecordId = IdUtil.getSnowflake(workerId, datacenterId).nextId();
 
-        MessageRecord build = MessageRecord.builder().id(messageRecordId).msgFlag(Boolean.TRUE).
+        /*MessageRecord build = MessageRecord.builder().id(messageRecordId).msgFlag(Boolean.TRUE).
                 wechatId(websocketMessageRequestDTO.getEnterpriseId()).
                 userWechatId(websocketMessageRequestDTO.getUserWechatId()).
                 msg(websocketMessageRequestDTO.getContent()).
@@ -157,6 +157,7 @@ public class MessageRecordServiceImpl extends
                 status(DefaultNumberConstants.ONE_NUMBER).
                 msgType(websocketMessageRequestDTO.getMessageType()).
                 isRead(DefaultNumberConstants.ONE_NUMBER).build();
-        return this.save(build);
+        return this.save(build);*/
+        return Boolean.TRUE;
     }
 }