add6

720yun_fd_manage/gis_domain/src/main/java/com/gis/domain/dto/DoSliceDTO.java

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

720yun_fd_manage/gis_service/src/main/java/com/gis/service/impl/FodderServiceImpl.java

@@ -229,9 +229,9 @@ public class FodderServiceImpl extends IBaseServiceImpl<FodderEntity, Long> impl
             if (type.equals("pano")) {
                 log.info("准备发送消息： " + entity.getId());
                 //发消息到mq
-                Map<String,Object> map=new HashMap<>();
-                map.put("id", entity.getId());
-                rabbitMqProducer.sendByWorkQueue(doSliceQueue,map);
+                DoSliceDTO doSliceDTO = new DoSliceDTO();
+                doSliceDTO.setId(entity.getId());
+                rabbitMqProducer.sendByWorkQueue(doSliceQueue,doSliceDTO);
                 log.info("发送消息到队列完成： " + entity.getId());
             }
             long end = System.currentTimeMillis();
@@ -732,9 +732,9 @@ public class FodderServiceImpl extends IBaseServiceImpl<FodderEntity, Long> impl
         List<FodderEntity> fodderEntities = getBaseMapper().selectByCondition(condition);
         log.info("重新入队数量{}",fodderEntities.size());
         for (FodderEntity fodderEntity : fodderEntities) {
-            Map<String,Object> map=new HashMap<>();
-            map.put("id",  fodderEntity.getId());
-            rabbitMqProducer.sendByWorkQueue(doSliceQueue,map);
+            DoSliceDTO doSliceDTO = new DoSliceDTO();
+            doSliceDTO.setId(fodderEntity.getId());
+            rabbitMqProducer.sendByWorkQueue(doSliceQueue,doSliceDTO);
         }
     }
 }

720yun_fd_manage/gis_web/src/main/java/com/gis/web/controller/TestController.java

@@ -4,6 +4,7 @@ import cn.hutool.core.io.FileUtil;
 import com.gis.common.constant.ConfigConstant;
 import com.gis.common.mq.RabbitMqProducerUtil;
 import com.gis.common.util.Result;
+import com.gis.domain.dto.DoSliceDTO;
 import com.gis.domain.dto.TestShDto;
 import com.gis.domain.entity.WorkEntity;
 import com.gis.oss.util.AliYunOssUtil;
@@ -171,10 +172,11 @@ public class TestController extends BaseController {
     @ApiOperation(value = "rabbitMQ发送", position = 1)
     public Result testSendMq(){
         //发消息到mq
-        Map<String,Object> map=new HashMap<>();
-        map.put("id",  1);
-        rabbitMqProducer.sendByWorkQueue(doSliceQueue,map);
-        return Result.success(map);
+        DoSliceDTO doSliceDTO = new DoSliceDTO();
+        doSliceDTO.setId(1L);
+        Map<String, Object> map = new HashMap<>();
+        rabbitMqProducer.sendByWorkQueue(doSliceQueue,doSliceDTO);
+        return Result.success(doSliceDTO);
     }