| | |
|---|
| | | package com.dy.pipIrrRemote.monitor.mqttSd1.stir; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson2.JSON; |
|---|
| | | import com.alibaba.fastjson2.JSONObject; |
|---|
| | | import com.dy.common.aop.SsoAop; |
|---|
| | | import com.dy.common.mw.protocol.Command; |
|---|
| | | import com.dy.common.mw.protocol4Mqtt.MqttSubMsg; |
|---|
| | | import com.dy.common.mw.protocol4Mqtt.pSdV1.CodeSdV1; |
|---|
| | | import com.dy.common.mw.protocol4Mqtt.pSdV1.ProtocolConstantSdV1; |
|---|
| | | import com.dy.common.mw.protocol4Mqtt.pSdV1.upVos.ManureVo; |
|---|
| | |
|---|
| | | import org.springframework.web.bind.annotation.RequestMapping; |
|---|
| | | import org.springframework.web.bind.annotation.RestController; |
|---|
| | | |
|---|
| | | import java.lang.reflect.InvocationHandler; |
|---|
| | | import java.lang.reflect.Proxy; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @Author: liurunyu |
|---|
| | | * @Date: 2025/6/16 17:35 |
|---|
| | |
|---|
| | | @Slf4j |
|---|
| | | @Tag(name = "远程命令", description = "搅拌启停") |
|---|
| | | @RestController("mqttSd1StirCtrl") |
|---|
| | | @RequestMapping(path = "mqttSd1/stirCtrl") |
|---|
| | | @RequestMapping(path = "mqttSd1/stir") |
|---|
| | | @RequiredArgsConstructor |
|---|
| | | @Scope("prototype") //因为有对象类属性，所以采用原型模式，每次请求新建一个实例对象 |
|---|
| | | public class CdCtrl extends Com4MqttCtrl { |
|---|
| | |
|---|
| | | try { |
|---|
| | | //创建外部命令（发给MQTT->FBox） |
|---|
| | | Command com = sv.createMQTTCommand(ctrlPo.fboxId, "" + comId, Protocol, ProtocolVersion, ComCode); |
|---|
| | | com.rtuResultSendWebUrl = rtuResultSendWebUrl; |
|---|
| | | com.rtuResultSendWebUrl = mqttResultSendWebUrl; |
|---|
| | | com.param = comParam ; |
|---|
| | | //发送命令 |
|---|
| | | res = super.doSend(sv, com); |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | protected String dealComResult(String code, JSONObject resultData, Callback callback){ |
|---|
| | | protected String dealComResult(String code, MqttSubMsg subMsg, Callback callback){ |
|---|
| | | String msg; |
|---|
| | | if(resultData != null){ |
|---|
| | | log.info(resultData.toString()); |
|---|
| | | JSONObject codeData = resultData.getJSONObject("data") ; |
|---|
| | | if(codeData == null){ |
|---|
| | | msg = RtuSuccessMsg ; |
|---|
| | | }else { |
|---|
| | | String json = codeData.toJSONString(); |
|---|
| | | ManureVo cvo = JSON.parseObject(json, ManureVo.class) ; |
|---|
| | | if(cvo != null){ |
|---|
| | | msg = cvo.toString() ; |
|---|
| | | if(subMsg != null){ |
|---|
| | | if(subMsg.vo4Up != null && Proxy.isProxyClass(subMsg.vo4Up.getClass())){ |
|---|
| | | // 获取代理的 InvocationHandler |
|---|
| | | InvocationHandler handler = Proxy.getInvocationHandler(subMsg.vo4Up); |
|---|
| | | String json = JSON.toJSONString(handler) ; |
|---|
| | | ManureVo vo = JSON.parseObject(json, ManureVo.class); |
|---|
| | | msg = vo.toString() ; |
|---|
| | | }else{ |
|---|
| | | msg = RtuSuccessMsg ; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }else{ |
|---|
| | | msg = RtuSuccessMsg ; |
|---|
| | | } |
|---|
| | | return msg; |
|---|
| | | }} |
|---|
| | | } |
|---|
| | | } |
|---|
