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.core.io.ClassPathResource;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.io.BufferedReader;
|
import java.io.IOException;
|
import java.io.InputStreamReader;
|
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 {
|
|
}
|
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;*/
|
}
|
|
|
}
|
