屏蔽流号定尺的消息推送

zgztBus/jeecg-module-sbm/src/main/java/org/jeecg/modules/billet/billetHotsend/controller/BilletHotsendBaseController.java

@@ -515,7 +515,7 @@ public class BilletHotsendBaseController extends JeecgController<BilletHotsend,
     }
 
 
-    @ApiOperation(value = "推送流号定尺", notes = "推送流号定尺")
+    @ApiOperation(value = "接收前端传递的流号定尺", notes = "接收前端传递的流号定尺")
     @PostMapping(value = "/pushStrandNoSize")
     public Result<?> pushStrandNoSize(@RequestBody StrandNoSizeDTO dto) {
         billetHotsendBaseService.pushStrandNoSize(dto);

zgztBus/jeecg-module-sbm/src/main/java/org/jeecg/modules/billet/billetHotsend/service/impl/BilletHotsendBaseServiceImpl.java

@@ -799,27 +799,27 @@ public class BilletHotsendBaseServiceImpl extends ServiceImpl<BilletHotsendBaseM
 		redisTemplate.opsForValue().set(redisKey, jsonValue);
 
 
-		// 变更的定尺集合
-		for (StrandNoSizeDTO.StrandNoSize strandNoSize : dto.getStrandNoSizeList()) {
-				sendStrandNoSizeToMqtt(strandNoSize);
-		}
+//		// 变更的定尺集合
+//		for (StrandNoSizeDTO.StrandNoSize strandNoSize : dto.getStrandNoSizeList()) {
+//				sendStrandNoSizeToMqtt(strandNoSize);
+//		}
 	}
 
-	public void sendStrandNoSizeToMqtt(StrandNoSizeDTO.StrandNoSize strandNoSize) {
-
-		try {
-			Map<String, Object> mapSendInfo = new HashMap<>();
-			mapSendInfo.put("strandNo", strandNoSize.getStrandNo());
-			mapSendInfo.put("length", strandNoSize.getLength());
-
-			// 执行MQTT推送，设置合理的超时时间
-			MqttClientUtil mqttClientUtilBe = new MqttClientUtil();
-			mqttClientUtilBe.pushCData(configMqttMapper, mapSendInfo, TopicType.SYN_BILLET_PUSHSTRANDNOLENGTH.getTopicValue());
-			log.info("B端传递流号定尺参数，发送MQTT成功: {}", mapSendInfo);
-		} catch (Exception e) {
-			log.error("B端传递流号定尺参数，发送MQTT异常!", e);
-		}
-	}
+//	public void sendStrandNoSizeToMqtt(StrandNoSizeDTO.StrandNoSize strandNoSize) {
+//
+//		try {
+//			Map<String, Object> mapSendInfo = new HashMap<>();
+//			mapSendInfo.put("strandNo", strandNoSize.getStrandNo());
+//			mapSendInfo.put("length", strandNoSize.getLength());
+//
+//			// 执行MQTT推送，设置合理的超时时间
+//			MqttClientUtil mqttClientUtilBe = new MqttClientUtil();
+//			mqttClientUtilBe.pushCData(configMqttMapper, mapSendInfo, TopicType.SYN_BILLET_PUSHSTRANDNOLENGTH.getTopicValue());
+//			log.info("B端传递流号定尺参数，发送MQTT成功: {}", mapSendInfo);
+//		} catch (Exception e) {
+//			log.error("B端传递流号定尺参数，发送MQTT异常!", e);
+//		}
+//	}
 
 	public void sendFurnaceChangeToMqtt(FurnaceChangeData data) {
 		try {