From 1f30c75c35f7b9bb9497b1e131dd10d5e3d58ae0 Mon Sep 17 00:00:00 2001
From: Allenxy <13762749+chaosallen@user.noreply.gitee.com>
Date: Wed, 16 Oct 2024 14:19:27 +0800
Subject: [PATCH] =?UTF-8?q?feat():=E4=B8=8B=E5=8F=91=E9=92=A2=E5=8D=B7?=
 =?UTF-8?q?=E8=AE=BE=E5=AE=9A=E5=80=BC=E8=AF=B7=E6=B1=82=E5=88=B0=E6=A8=A1?=
 =?UTF-8?q?=E5=9E=8B=E7=A8=8B=E5=BA=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/ModSetupResultServiceImpl.java       | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)

diff --git a/business/src/main/java/com/fizz/business/service/impl/ModSetupResultServiceImpl.java b/business/src/main/java/com/fizz/business/service/impl/ModSetupResultServiceImpl.java
index 901a22c..c16148f 100644
--- a/business/src/main/java/com/fizz/business/service/impl/ModSetupResultServiceImpl.java
+++ b/business/src/main/java/com/fizz/business/service/impl/ModSetupResultServiceImpl.java
@@ -4,18 +4,29 @@ import cn.hutool.core.bean.BeanUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.StringUtils;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.fizz.business.constants.CommonConstants;
 import com.fizz.business.domain.ModSetupResult;
 import com.fizz.business.form.ModSetupResultForm;
 import com.fizz.business.mapper.ModSetupResultMapper;
 import com.fizz.business.service.ModSetupResultService;
 import com.fizz.business.vo.ModSetupResultVO;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.core.MessageProperties;
+import org.springframework.amqp.core.MessagePropertiesBuilder;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.stereotype.Service;
 
+import javax.annotation.Resource;
+import java.nio.charset.StandardCharsets;
 import java.util.List;
 
 @Service
 public class ModSetupResultServiceImpl extends ServiceImpl<ModSetupResultMapper, ModSetupResult> implements ModSetupResultService {
 
+    @Resource
+    RabbitTemplate rabbitTemplate;
+
+
     @Override
     public List<ModSetupResultVO> list(ModSetupResultForm form) {
 
@@ -57,6 +68,14 @@ public class ModSetupResultServiceImpl extends ServiceImpl<ModSetupResultMapper,
 
     @Override
     public String retrySetup(String coilid) {
+
+        //发送MQ
+        MessageProperties props = MessagePropertiesBuilder.newInstance()
+                .setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN)
+                .setMessageId("SETUP_CALL")
+                .build();
+        rabbitTemplate.send(CommonConstants.RabbitMQ.SEND_MODEL,new Message(coilid.getBytes(StandardCharsets.UTF_8),props));
+
         return null;
     }
 }
\ No newline at end of file