feat():下发钢卷设定值请求到模型程序

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;
     }
 }