表阀一体机协议，根据王江海测试问题，进行修改完善

liurunyu

2 天以前 71b9ac1d2459239d2c5340b384f1536b156fc003

 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/monitor/p202404V201/cd5C/CdCtrl.java

@@ -1,10 +1,13 @@
package com.dy.pipIrrRemote.monitor.p202404V201.cd5C;

import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.dy.common.aop.SsoAop;
import com.dy.common.mw.protocol.Command;
import com.dy.common.mw.protocol.p206V202404.upVos.DataCd55Vo;
import com.dy.common.mw.protocol.p206V202404.upVos.DataCd5CVo;
import com.dy.common.util.Callback;
import com.dy.common.webUtil.BaseResponse;
import com.dy.common.webUtil.BaseResponseUtils;
import com.dy.pipIrrRemote.common.dto.DtoBase;
@@ -31,7 +34,7 @@
 */
@Slf4j
@Tag(name = "远程命令", description = "查询设备终端的日记录")
@RestController("cd5CCtrl")
@RestController("p202404V201Cd5CCtrl")
@RequestMapping(path = "p202404V201/cd5C")
@RequiredArgsConstructor
@Scope("prototype") //因为有对象类属性，所以采用原型模式，每次请求新建一个实例对象
@@ -75,7 +78,7 @@
                        res = super.doSend(sv, com);
                        if (res == null) {
                            //发送命令后
                            res = super.after(ComCode);
                            res = super.after(ComCode, null);
                        }
                    } catch (Exception e) {
                        res = BaseResponseUtils.buildFail("服务端构造并向通信中间件发送请求时异常" + (e.getMessage() == null ? "" : e.getMessage()));
@@ -95,19 +98,29 @@
    }

    @Override
    protected String createRtnMsg(String code, JSONObject resultData){
    protected String dealComResult(String code, JSONObject resultData, Callback callback){
        String msg;
        if(resultData != null){
            JSONObject codeData = resultData.getJSONObject("data") ;
            JSONArray codeDataArray = null ;
            if(codeData == null){
                codeDataArray = resultData.getJSONArray("data") ;
            }
            if(codeData == null && codeDataArray == null){
                msg = RtuSuccessMsg ;
            }else {
                String json = codeData.toJSONString();
                String json = null ;
                if(codeData != null){
                    json = codeData.toJSONString() ;
                }else if(codeDataArray != null){
                    json = codeDataArray.toJSONString() ;
                }
                List<DataCd5CVo> list = JSON.parseArray(json, DataCd5CVo.class) ;
                if(list != null && list.size() > 0){
                    msg = "" ;
                    msg = "\n" ;
                    for(DataCd5CVo cvo : list){
                        msg += cvo.toStr(false) + "\n";
                        msg += cvo.toStr(false) ;
                        msg += "\n" ;
                    }
                }else{
                    msg = RtuSuccessMsg ;
@@ -118,4 +131,5 @@
        }
        return msg;
    }

}