pipIrr-SV.git - Gitblit

			@@ -7,19 +7,22 @@
			import com.dy.common.mw.protocol.Data;
			import com.dy.common.webUtil.BaseResponse;
			import com.dy.common.webUtil.BaseResponseUtils;
			import com.dy.pipIrrGlobal.command.dto.Param;
			import com.dy.pipIrrGlobal.command.enums.LastOperateENUM;
			import com.dy.pipIrrGlobal.command.result.CommandResultCode;
			import com.dy.pipIrrGlobal.daoBa.BaSettingsMapper;
			import com.dy.pipIrrGlobal.daoPr.PrControllerMapper;
			import com.dy.pipIrrGlobal.daoRm.RmCommandHistoryMapper;
			import com.dy.pipIrrGlobal.daoSe.SeVirtualCardMapper;
			import com.dy.pipIrrGlobal.pojoPr.PrController;
			import com.dy.pipIrrGlobal.pojoRm.RmCommandHistory;
			import com.dy.pipIrrGlobal.pojoSe.SeVirtualCard;
			import jakarta.annotation.PostConstruct;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.context.annotation.DependsOn;
			import org.springframework.http.HttpEntity;
			import org.springframework.http.HttpHeaders;
			import org.springframework.http.HttpMethod;
			import org.springframework.http.ResponseEntity;
			import org.springframework.stereotype.Component;
			import org.springframework.web.client.RestTemplate;
			import org.springframework.web.util.UriComponentsBuilder;

			@@ -41,8 +44,6 @@
			* @Description 命令支撑类
			*/

			@Component
			@DependsOn({"baSettingsMapper", "prControllerMapper"})
			public class ComSupport {
			protected static String mwUrlSendCom = "http://127.0.0.1:8070/rtuMw/com/send" ;

			@@ -59,8 +60,16 @@

			@Autowired
			private BaSettingsMapper baSettingsMapper;

			@Autowired
			private PrControllerMapper prControllerMapper;

			@Autowired
			private RmCommandHistoryMapper rmCommandHistoryMapper;

			@Autowired
			private SeVirtualCardMapper seVirtualCardMapper;

			public static ComSupport comSupport;

			/**
			@@ -176,7 +185,7 @@
			try {
			CompletableFuture<Data> feature = (CompletableFuture<Data>) features.get(comId);
			System.out.println("receive result ID:" + comId);
			Data resultData = feature.get(30, TimeUnit.SECONDS);
			Data resultData = feature.get(180, TimeUnit.SECONDS);
			features.remove(comId);
			Long commandId = Long.parseLong(resultData.getCommandId());
			if(commandId.equals(comId)) {
			@@ -191,7 +200,7 @@
			e.printStackTrace();
			return BaseResponseUtils.buildFail(CommandResultCode.GET_RESULT_ERROR.getMessage());
			} catch (TimeoutException e) {
			return BaseResponseUtils.buildFail(CommandResultCode.GET_RESULT_IN_ONE_MINUTE.getMessage());
			return BaseResponseUtils.buildSuccess(CommandResultCode.GET_RESULT_IN_ONE_MINUTE.getMessage());
			}
			}

			@@ -214,4 +223,99 @@
			}
			return response.getBody();
			}

			/**
			* 构造命令、发送命令并处理请求结果及执行结果
			* @param po
			* @return
			*/
			protected BaseResponse<Boolean> dealWithCommandResult(Param po) {
			Long comId = po.getComId();
			Byte comType = po.getComType();
			String commandCode = po.getCommandCode();
			String commandName = po.getCommandName();
			Long intakeId = po.getIntakeId();
			String rtuAddr = po.getRtuAddr();
			String protocol = po.getProtocol();
			Long vcId = po.getVcId();
			Object param = po.getParam();
			String rtuResultSendWebUrl = po.getRtuResultSendWebUrl();
			Long operator = po.getOperator();

			// 构造命令
			Command com = command(comId, commandCode, rtuAddr, protocol, rtuResultSendWebUrl, param);

			// 发送命令
			JSONObject response_SendCom= (JSONObject) JSON.toJSON(sendCom2Mw(com));
			if(response_SendCom != null && response_SendCom.getString("code").equals("0001")) {
			// 请求成功

			// 创建命令日志对象并添加到数据库中
			RmCommandHistory rmCommandHistory = getComHistory(comId, commandCode, commandName, intakeId, rtuAddr, protocol, param, operator);
			rmCommandHistoryMapper.insert(rmCommandHistory);

			// 处理回调
			BaseResponse response_CallBack = dealWithCallBack(comId);

			// 回调异常
			if(!response_CallBack.getCode().equals("0001")) {
			// 命令日志执行结果改为失败
			rmCommandHistory = new RmCommandHistory();
			rmCommandHistory.setId(comId);
			rmCommandHistory.setResult((byte)0);
			rmCommandHistoryMapper.updateByPrimaryKeySelective(rmCommandHistory);
			return BaseResponseUtils.buildErrorMsg(response_CallBack.getContent().toString());
			}

			// 回调超时
			if (response_CallBack.getContent().toString().equals(CommandResultCode.GET_RESULT_IN_ONE_MINUTE.getMessage())) {
			/**
			* 回调超时，暂时认为执行失败
			* 命令置为失败
			* 虚拟卡依旧保持使用中的状态
			*/

			rmCommandHistory = new RmCommandHistory();
			rmCommandHistory.setId(comId);
			rmCommandHistory.setResult((byte) 0);
			rmCommandHistoryMapper.updateByPrimaryKeySelective(rmCommandHistory);
			return BaseResponseUtils.buildErrorMsg(CommandResultCode.GET_RESULT_IN_ONE_MINUTE.getMessage());
			}

			// 回调成功，再判断执行是否成功
			JSONObject job_content = (JSONObject)JSON.toJSON(response_CallBack.getContent());
			System.out.println(job_content);
			JSONObject job_subData = (JSONObject) job_content.getJSONObject("subData").getJSONObject("subData");
			System.out.println(job_subData);
			Boolean dealResult = job_subData.getBoolean("success");
			if(!dealResult) {
			return BaseResponseUtils.buildErrorMsg(response_CallBack.getContent().toString());
			}

			/**
			* 执行成功，返回回调内容
			* 如果是开关阀：更改虚拟卡状态：是否使用中、最后操作、最后操作时间
			*/
			if(comType != null) {
			SeVirtualCard virtualCard = new SeVirtualCard();
			virtualCard.setId(vcId);
			if(comType == 1) {
			virtualCard.setInUse((byte) 1);
			}else {
			virtualCard.setInUse((byte) 0);
			}
			virtualCard.setLastOperate(LastOperateENUM.OPEN_VALVE.getCode());
			virtualCard.setLastOperateTime(new Date());
			seVirtualCardMapper.updateByPrimaryKeySelective(virtualCard);
			}

			// 回调返回的内容
			Data myData = (Data)response_CallBack.getContent();
			return BaseResponseUtils.buildSuccess(myData) ;
			} else {
			// 请求失败
			JSONObject job_param = response_SendCom.getJSONObject("content").getJSONObject("param");
			return BaseResponseUtils.buildErrorMsg(job_param.getString("message"));
			}
			}
			}