[CMLR-020] 补齐 Anchors/SystemMessage/Chat DTO

src/main/java/vvpkassistant/Anchors/model/DTO/AnchorDeleteRequestDTO.java

@@ -0,0 +1,8 @@
+package vvpkassistant.Anchors.model.DTO;
+
+import lombok.Data;
+
+@Data
+public class AnchorDeleteRequestDTO {
+    private Integer id;
+}

src/main/java/vvpkassistant/Anchors/model/DTO/AnchorListRequestDTO.java

@@ -0,0 +1,8 @@
+package vvpkassistant.Anchors.model.DTO;
+
+import lombok.Data;
+
+@Data
+public class AnchorListRequestDTO {
+    private Integer id;
+}

src/main/java/vvpkassistant/SystemMessage/model/DTO/SystemMessageListRequestDTO.java

@@ -0,0 +1,9 @@
+package vvpkassistant.SystemMessage.model.DTO;
+
+import lombok.Data;
+
+@Data
+public class SystemMessageListRequestDTO {
+    private Integer page;
+    private Integer size;
+}

src/main/java/vvpkassistant/chat/model/DTO/ChatReceiveImMessageDTO.java

@@ -0,0 +1,25 @@
+package vvpkassistant.chat.model.DTO;
+
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import lombok.Data;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Data
+public class ChatReceiveImMessageDTO {
+    private String eventType;
+    private Map<String, Object> payload;
+    private final Map<String, Object> additionalFields = new HashMap<>();
+
+    @JsonAnySetter
+    public void putAdditionalField(String key, Object value) {
+        additionalFields.put(key, value);
+    }
+
+    @JsonAnyGetter
+    public Map<String, Object> getAdditionalFields() {
+        return additionalFields;
+    }
+}

src/main/java/vvpkassistant/controller/AnchorsController.java

@@ -4,13 +4,14 @@ import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
+import vvpkassistant.Anchors.model.DTO.AnchorDeleteRequestDTO;
+import vvpkassistant.Anchors.model.DTO.AnchorListRequestDTO;
 import vvpkassistant.Anchors.model.AnchorModel;
 import vvpkassistant.Anchors.service.AnchorsService;
 import vvpkassistant.Data.ResponseData;
 import vvpkassistant.common.ErrorCode;
 
 import javax.annotation.Resource;
-import java.util.Map;
 
 @RestController
 @RequestMapping("anchor")
@@ -28,15 +29,15 @@ public class AnchorsController {
 
     // 查询我的主播列表
     @PostMapping("list")
-    public ResponseData<Object> myAnchorList(@RequestBody Map<String,Integer> map) {
-        Integer userId = map.get("id");
+    public ResponseData<Object> myAnchorList(@RequestBody AnchorListRequestDTO request) {
+        Integer userId = request.getId();
         return ResponseData.success(anchorsService.selectMyAnchor(userId));
     }
 
     // 删除我的主播
     @PostMapping("deleteMyAnchor")
-    public ResponseData<Object> deleteMyAnchor(@RequestBody Map<String,Integer> map) {
-        Integer id = map.get("id");
+    public ResponseData<Object> deleteMyAnchor(@RequestBody AnchorDeleteRequestDTO request) {
+        Integer id = request.getId();
         return anchorsService.deleteMyAnchor(id) == 1 ? ResponseData.success(""):ResponseData.error(ErrorCode.DELETE_FAILED );
     }
 

src/main/java/vvpkassistant/controller/ChatController.java

@@ -5,6 +5,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 import vvpkassistant.Data.ResponseData;
 import vvpkassistant.chat.mapper.ChatDao;
+import vvpkassistant.chat.model.DTO.ChatReceiveImMessageDTO;
 import vvpkassistant.chat.model.ChatModel;
 import vvpkassistant.common.ErrorCode;
 
@@ -34,7 +35,7 @@ public class ChatController {
 
     //接收im消息
     @PostMapping("receiveImMessage")
-    public Map<String,Object> receiveImMessage(@RequestBody Map<String,Object> data) {
+    public Map<String,Object> receiveImMessage(@RequestBody ChatReceiveImMessageDTO data) {
         System.out.println(data);
         Map<String,Object> result = new HashMap<>();
         result.put("code",200);

src/main/java/vvpkassistant/controller/SystemMessageController.java

@@ -7,11 +7,11 @@ import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 import vvpkassistant.Data.ResponseData;
 import vvpkassistant.SystemMessage.mapper.SystemMessageDao;
+import vvpkassistant.SystemMessage.model.DTO.SystemMessageListRequestDTO;
 import vvpkassistant.SystemMessage.model.SystemMessage;
 import vvpkassistant.Tools.VVTools;
 
 import java.util.List;
-import java.util.Map;
 
 @RestController
 @RequestMapping("systemMessage")
@@ -22,9 +22,9 @@ public class SystemMessageController {
 
     //  获取列表
     @PostMapping("list")
-    public ResponseData<Object> messageList(@RequestBody Map<String,Integer> map) {
-        Integer page = map.get("page");
-        Integer size = map.get("size");
+    public ResponseData<Object> messageList(@RequestBody SystemMessageListRequestDTO request) {
+        Integer page = request.getPage();
+        Integer size = request.getSize();
         List<SystemMessage> systemMessages = messageDao.messageList(page * size, size);
         return ResponseData.success(systemMessages);
     }