| | |
|---|
| | | import com.dy.pipIrrGlobal.pojoSe.SeVirtualCard; |
|---|
| | | import jakarta.annotation.PostConstruct; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.beans.factory.annotation.Value; |
|---|
| | | import org.springframework.http.HttpEntity; |
|---|
| | | import org.springframework.http.HttpHeaders; |
|---|
| | | import org.springframework.http.HttpMethod; |
|---|
| | |
|---|
| | | */ |
|---|
| | | |
|---|
| | | public class ComSupport { |
|---|
| | | protected static String mwUrlSendCom = "http://127.0.0.1:8070/rtuMw/com/send" ; |
|---|
| | | @Value("${mw.comSendUrl}") |
|---|
| | | private String comSendUrl; |
|---|
| | | |
|---|
| | | protected static String controllerType = null; |
|---|
| | | protected static Integer projectNo = null; |
|---|
| | |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | protected BaseResponse sendCom2Mw(Command com){ |
|---|
| | | String url = UriComponentsBuilder.fromUriString(mwUrlSendCom) |
|---|
| | | String url = UriComponentsBuilder.fromUriString(comSendUrl) |
|---|
| | | .build() |
|---|
| | | .toUriString(); |
|---|
| | | HttpHeaders headers = new HttpHeaders(); |
|---|
| | |
|---|
| | | // 发送命令 |
|---|
| | | JSONObject response_SendCom= (JSONObject) JSON.toJSON(sendCom2Mw(com)); |
|---|
| | | if(response_SendCom != null && response_SendCom.getString("code").equals("0001")) { |
|---|
| | | // 请求成功 |
|---|
| | | // 请求成功, 处理回调 |
|---|
| | | BaseResponse response_CallBack = dealWithCallBack(comId); |
|---|
| | | |
|---|
| | | // 创建命令日志对象并添加到数据库中 |
|---|
| | | 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")) { |
|---|
