|  |  |  | 
|---|
|  |  |  | import com.dy.common.mw.protocol.p206V202404.ProtocolConstantV206V202404; | 
|---|
|  |  |  | import com.dy.common.mw.protocol.p206V202404.downVos.ComCdXyVo; | 
|---|
|  |  |  | import com.dy.common.webUtil.BaseResponse; | 
|---|
|  |  |  | import com.dy.common.webUtil.BaseResponseUtils; | 
|---|
|  |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
|---|
|  |  |  | import org.springframework.http.HttpEntity; | 
|---|
|  |  |  | import org.springframework.http.HttpHeaders; | 
|---|
|  |  |  | 
|---|
|  |  |  | //protected static final String mwIp = "romq9311819.vicp.fun" ; //http://romq9311819.vicp.fun:16583 | 
|---|
|  |  |  | //protected static final String mwPort = "16583" ; | 
|---|
|  |  |  | protected static final String mwIp = "127.0.0.1" ; | 
|---|
|  |  |  | protected static final String mwPort = "8071" ; | 
|---|
|  |  |  | protected static final String mwPort = "65533" ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | protected static String mwUrlTest = "http://" + mwIp + ":" + mwPort + "/rtuMw/com/test" ; | 
|---|
|  |  |  | protected static String mwUrlSendCom = "http://" + mwIp + ":" + mwPort + "/rtuMw/com/send" ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | protected static String rtuAddr = "41162810400100001" ; | 
|---|
|  |  |  | protected static String rtuAddr = "37142501020100229" ; | 
|---|
|  |  |  | protected static String rtuResultSendWebUrl = "http://127.0.0.1:65535/test/comRes/receive" ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | protected static String controllerType = "57" ;//控制器类型 | 
|---|
|  |  |  | 
|---|
|  |  |  | response = restTemplate.exchange(url, HttpMethod.GET, httpEntity, BaseResponse.class); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | e.printStackTrace(); | 
|---|
|  |  |  | return BaseResponseUtils.buildError("后端系统出错,中间件调用异常"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return response.getBody(); | 
|---|
|  |  |  | if(response == null){ | 
|---|
|  |  |  | return BaseResponseUtils.buildError("后端系统出错,中间件调用异常"); | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | return response.getBody(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | response = restTemplate.exchange(url, HttpMethod.POST, httpEntity, BaseResponse.class); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | e.printStackTrace(); | 
|---|
|  |  |  | return BaseResponseUtils.buildError("后端系统出错,中间件调用异常"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return response.getBody(); | 
|---|
|  |  |  | if(response == null){ | 
|---|
|  |  |  | return BaseResponseUtils.buildError("后端系统出错,中间件调用异常"); | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | return response.getBody(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|