元谋二期后端软件系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
liurunyu
2025-08-19 e33bca52d26faa836a4db7436e85eb3a0a08adff 
 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/web/comResult/CommandResultDeal.java


@@ -5,6 +5,7 @@


import com.dy.common.mw.protocol.Data;


import com.dy.common.mw.protocol4Mqtt.MqttSubMsg;


import com.dy.rtuMw.server.ServerProperties;


import lombok.extern.slf4j.Slf4j;


import org.apache.logging.log4j.LogManager;


import org.apache.logging.log4j.Logger;


import org.springframework.beans.factory.annotation.Autowired;


@@ -22,6 +23,7 @@


 * @LastEditTime 2023/12/21 20:28


 * @Description 通信中间件对外进行web调用，把命令结果发送出去


 */


@Slf4j


@Component()


public class CommandResultDeal {




@@ -48,7 +50,7 @@


            restTemplate.getMessageConverters().set(1,new StringHttpMessageConverter(StandardCharsets.UTF_8));


            HttpHeaders headers = new HttpHeaders();


            headers.setContentType(MediaType.parseMediaType("application/json;charset=UTF-8"));


            headers.set(Constant.UserTokenKeyInHeader, ServerProperties.orgTag);


            headers.set(Constant.TokenKeyInHeader, ServerProperties.orgTag);


            HttpEntity<?> httpEntity = new HttpEntity<>(data, headers);


            ResponseEntity<WebResponseVo> response = null;


            try {


@@ -78,7 +80,7 @@


            restTemplate.getMessageConverters().set(1,new StringHttpMessageConverter(StandardCharsets.UTF_8));


            HttpHeaders headers = new HttpHeaders();


            headers.setContentType(MediaType.parseMediaType("application/json;charset=UTF-8"));


            headers.set(Constant.UserTokenKeyInHeader, ServerProperties.orgTag);


            headers.set(Constant.TokenKeyInHeader, ServerProperties.orgTag);


            HttpEntity<?> httpEntity = new HttpEntity<>(subMsg, headers);


            ResponseEntity<WebResponseVo> response = null;


            try {