pipIrr-SV.git - Gitblit

New file
			@@ -0,0 +1,120 @@
			package com.dy.pipIrrMwTestWeb.p206V1;

			import com.dy.common.mw.protocol.Command;
			import com.dy.common.mw.protocol.CommandType;
			import com.dy.common.mw.protocol.p206V1.ProtocolConstantV206V1;
			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;
			import org.springframework.http.HttpMethod;
			import org.springframework.http.ResponseEntity;
			import org.springframework.web.client.RestTemplate;
			import org.springframework.web.util.UriComponentsBuilder;

			/**
			* @Author: liurunyu
			* @Date: 2024/6/29 6:47
			* @Description
			*/
			public class ComSupportP206V1 {
			protected static String mwUrlTest = "http://127.0.0.1:8070/rtuMw/com/test" ;
			protected static String mwUrlSendCom = "http://127.0.0.1:8070/rtuMw/com/send" ;
			protected static String mwUrlRtuLogFile = "http://127.0.0.1:8070/rtuMw/com/rtuLogFile" ;
			protected static String mwUrlRtuLogText = "http://127.0.0.1:8070/rtuMw/com/rtuLogText" ;
			protected static String rtuAddr = "532328059995" ;

			// protected static String mwUrlTest = "http://8.140.179.55:8071/rtuMw/com/test" ;
			// protected static String mwUrlSendCom = "http://8.140.179.55:8071/rtuMw/com/send" ;
			// protected static String rtuAddr = "620202000066" ;

			protected static String rtuResultSendWebUrl = "http://127.0.0.1:65535/test/comRes/receive" ;
			protected static String vsIcCardNo = "61181622830147822" ;//虚拟IC卡编号（用户虚拟卡序列号）


			@Autowired
			private RestTemplate restTemplate;


			protected Command commandLocal(String code, Object param, String comId){
			Command com = new Command() ;
			com.id = comId==null?Command.defaultId:(comId.trim().equals("")?Command.defaultId:comId) ;//实际应用中，替换成数据库记录id
			com.protocol = ProtocolConstantV206V1.protocolName ;
			com.code = code ;
			com.rtuAddr = rtuAddr ;
			com.type = CommandType.innerCommand ;
			com.rtuResultSendWebUrl = rtuResultSendWebUrl ;

			com.param = param ;

			return com ;
			}


			protected Command commandOuter(String code, Object param, String comId){
			Command com = new Command() ;
			com.id = comId==null?Command.defaultId:(comId.trim().equals("")?Command.defaultId:comId) ;//实际应用中，替换成数据库记录id
			com.protocol = ProtocolConstantV206V1.protocolName ;
			com.code = code ;
			com.rtuAddr = rtuAddr ;
			com.type = CommandType.outerCommand ;
			com.rtuResultSendWebUrl = rtuResultSendWebUrl ;

			com.param = param ;

			return com ;
			}


			/**
			* 连接通信中间件测试
			* @return
			*/
			protected BaseResponse sendTest(){
			String url = UriComponentsBuilder.fromUriString(mwUrlTest)
			.build()
			.toUriString();
			HttpHeaders headers = new HttpHeaders();
			HttpEntity<?> httpEntity = new HttpEntity<>(headers);
			ResponseEntity<BaseResponse> response = null;
			try {
			// 通过Get方式调用接口
			response = restTemplate.exchange(url, HttpMethod.GET, httpEntity, BaseResponse.class);
			} catch (Exception e) {
			e.printStackTrace();
			return BaseResponseUtils.buildError("后端系统出错，中间件调用异常");
			}
			if(response == null){
			return BaseResponseUtils.buildError("后端系统出错，中间件调用异常");
			}else{
			return response.getBody();
			}
			}

			/**
			* 发送命令
			* @return
			*/
			protected BaseResponse sendCom2Mw(Command com){
			String url = UriComponentsBuilder.fromUriString(mwUrlSendCom)
			.build()
			.toUriString();
			HttpHeaders headers = new HttpHeaders();
			HttpEntity<Command> httpEntity = new HttpEntity<>(com, headers);
			ResponseEntity<BaseResponse> response = null;
			try {
			// 通过Post方式调用接口
			response = restTemplate.exchange(url, HttpMethod.POST, httpEntity, BaseResponse.class);
			} catch (Exception e) {
			e.printStackTrace();
			return BaseResponseUtils.buildError("后端系统出错，中间件调用异常");
			}
			if(response == null){
			return BaseResponseUtils.buildError("后端系统出错，中间件调用异常");
			}else{
			return response.getBody();
			}
			}

			}