add5

720yun_fd_consumer/gis_consumer/src/main/java/com/gis/entity/DoSliceDTO.java

@@ -0,0 +1,11 @@
+package com.gis.entity;
+import lombok.Data;
+
+/**
+ * @author Xiewj
+ * @date 2024/4/7
+ */
+@Data
+public class DoSliceDTO {
+    private Long id;
+}

720yun_fd_consumer/gis_consumer/src/main/java/com/gis/listener/DoSliceListener.java

@@ -1,6 +1,7 @@
 package com.gis.listener;
 
 import com.alibaba.fastjson.JSONObject;
+import com.gis.entity.DoSliceDTO;
 import com.gis.service.FodderService;
 import com.rabbitmq.client.Channel;
 import lombok.extern.slf4j.Slf4j;
@@ -51,8 +52,8 @@ public class DoSliceListener {
             String msg = new String(message.getBody(), StandardCharsets.UTF_8);
             String messageId = message.getMessageProperties().getMessageId();
             log.info("场景doSliceQueue开始,id:{},deliveryTag:{},消息体:{}", messageId,deliveryTag,msg);
-            Map<String,Object> map = JSONObject.parseObject(msg, Map.class);
-            fodderService.doSlice((Long) map.get("id"), traceId);
+            DoSliceDTO dto = JSONObject.parseObject(msg, DoSliceDTO.class);
+            fodderService.doSlice(dto.getId(), traceId);
             channel.basicAck(deliveryTag, false);
         }catch (Exception e){
             e.printStackTrace();