package com.ruoyi.device.controller;
|
|
|
import com.ruoyi.common.core.domain.Result;
|
import com.ruoyi.device.pojo.NA7672LRequestBean;
|
import com.ruoyi.device.pojo.NA7672LValueVO;
|
import com.ruoyi.device.utils.NA7672LTCPClientUtils;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.io.IOException;
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.regex.Matcher;
|
import java.util.regex.Pattern;
|
|
/**
|
* demo 表
|
*
|
* @author pig
|
* @date 2023-07-31 14:07:58
|
*/
|
@RestController
|
@RequiredArgsConstructor
|
@RequestMapping("tcpClient")
|
@Api(value = "tcp", tags = "读取网分仪数据")
|
public class NA7672LTCPController {
|
|
@ApiOperation(value = "获取网分仪所有值", notes = "获取网分仪所有值")
|
@PostMapping("/getTCPValuesNew")
|
public Result<?> getTCPValuesNew(@RequestBody NA7672LRequestBean requestBean) throws IOException, InterruptedException {
|
// List<NA7672LValueVO> valueList = new ArrayList<>();
|
// //设置默认配置，可在yml里进行配置
|
// String serverIp = requestBean.getServerIp();
|
// int serverPort = requestBean.getServerPort();
|
// NA7672LTCPClientUtils tcpClient = new NA7672LTCPClientUtils(serverIp, serverPort);
|
// //设置全部通道（界面save/recall-调式2，需要本地有state02文件）
|
// tcpClient.initMemory(requestBean.getMemoryDir());
|
// String valueUnit = this.getMemoryDirName(requestBean.getMemoryDir());
|
// //延迟两秒再取值
|
// try {
|
// Thread.sleep(2000);
|
// } catch (InterruptedException e) {
|
// e.printStackTrace();
|
// }
|
// List<NA7672LValueVO> rs = new ArrayList<>();
|
// if (valueUnit.equals("state01")) {
|
// rs = tcpClient.getState01AllValue(requestBean);
|
// } else if (valueUnit.equals("state02")) {
|
// rs = tcpClient.getState02AllValue(requestBean);
|
// } else if (valueUnit.equals("state03")) {
|
// rs = tcpClient.getState03AllValue(requestBean);
|
// } else if (valueUnit.equals("state04")) {
|
// rs = tcpClient.getState04AllValue(requestBean);
|
// } else if (valueUnit.equals("state05")) {
|
// rs = tcpClient.getState05AllValue(requestBean);
|
// } else if (valueUnit.equals("state06")) {
|
// rs = tcpClient.getState06AllValue(requestBean);
|
// } else if (valueUnit.equals("state07")) {
|
// rs = tcpClient.getState07AllValue(requestBean);
|
// } else if (valueUnit.equals("state08")) {
|
// rs = tcpClient.getState08AllValue(requestBean);
|
// } else if (valueUnit.equals("autorec")) {
|
// rs = tcpClient.getStateAutoRecAllValue(requestBean);
|
// } else {
|
//
|
// }
|
// System.out.println(rs);
|
// return Result.success(rs);
|
List<NA7672LValueVO> rs = new ArrayList<>();
|
// 示例数据添加
|
rs.add(new NA7672LValueVO(3, 1, 1, 1, "swr_155m", null, null, new BigDecimal("299892.062500"), null, null, null, 1));
|
rs.add(new NA7672LValueVO(3, 1, 2, 1, "swr_30m", null, null, new BigDecimal("314821.968750"), null, null, null, 1));
|
rs.add(new NA7672LValueVO(3, 3, 1, 1, "swr_701m", null, null, new BigDecimal("332.007080078"), null, null, null, 1));
|
rs.add(new NA7672LValueVO(3, 3, 2, 1, "swr_700m", null, null, new BigDecimal("354.251983643"), null, null, null, 1));
|
rs.add(new NA7672LValueVO(3, 4, 1, 1, "swr_1713m", null, null, new BigDecimal("47.4854316711"), null, null, null, 1));
|
rs.add(new NA7672LValueVO(3, 4, 2, 1, "swr_1700m", null, null, new BigDecimal("45.4008331299"), null, null, null, 1));
|
rs.add(new NA7672LValueVO(4, 5, 1, 1, "swr_1902m", null, null, new BigDecimal("37.0886840820"), null, null, null, 1));
|
rs.add(new NA7672LValueVO(3, 5, 2, 1, "swr_1913m", null, null, new BigDecimal("36.3293724060"), null, null, null, 1));
|
rs.add(new NA7672LValueVO(3, 6, 1, 1, "swr_2345m", null, null, new BigDecimal("24.7591514587"), null, null, null, 1));
|
rs.add(new NA7672LValueVO(3, 6, 2, 1, "swr_2324m", null, null, new BigDecimal("22.8147945404"), null, null, null, 1));
|
rs.add(new NA7672LValueVO(3, 7, 1, 1, "swr_3301m", null, null, new BigDecimal("12.0206012726"), null, null, null, 1));
|
rs.add(new NA7672LValueVO(3, 7, 2, 1, "swr_3324m", null, null, new BigDecimal("10.9548406601"), null, null, null, 1));
|
rs.add(new NA7672LValueVO(3, 8, 1, 1, "swr_4800m", null, null, new BigDecimal("5.30891036987"), null, null, null, 1));
|
rs.add(new NA7672LValueVO(3, 8, 2, 1, "swr_4806m", null, null, new BigDecimal("5.10930156708"), null, null, null, 1));
|
rs.add(new NA7672LValueVO(2, 2, 1, -1, "impedance_mean", null, null, new BigDecimal("-8.24090110890"), null, null, null, 1));
|
|
return Result.success(rs);
|
}
|
|
/*依照约定把前端传递的查询转化为后端接口查询*/
|
private String decayLabelOrg2Label(String labelOrg) {
|
String label = "decay_0m";
|
Pattern pattern = Pattern.compile("(\\d*)M");
|
Matcher matcher = pattern.matcher(labelOrg);
|
String valueUnit = null;
|
if (matcher.find()) {
|
valueUnit = matcher.group();
|
}
|
if (valueUnit != null) {
|
label = "decay_" + valueUnit.substring(0, valueUnit.length() - 1) + "m";
|
}
|
return label;
|
}
|
|
/*使用memory_dir的路径解析出类别*/
|
private String getMemoryDirName(String pathName) {
|
String[] splitString = pathName.split("/");
|
String filename_1 = splitString[splitString.length - 1];
|
String[] filename_2 = filename_1.split("\\.");
|
String filename_3 = filename_2[0];
|
return filename_3;
|
|
/*Pattern pattern = Pattern.compile("state(\\d*)");
|
Matcher matcher = pattern.matcher(pathName);
|
String valueUnit = null;
|
if (matcher.find()) {
|
valueUnit = matcher.group();
|
}
|
return valueUnit;*/
|
}
|
|
|
}
|
