Compare commits

...

2 Commits

Author SHA1 Message Date
lijunjie df5dbbbcad 安装 3 years ago
lijunjie dbf0b85f26 输入串口 3 years ago
  1. 14
      java安装说明.docx
  2. 9
      src/main/java/com/ccsens/pelma_analyse/service/impl/PelmaDataAcceptImpl.java
  3. 119
      src/main/java/com/ccsens/pelma_analyse/service/impl/SerialServiceImpl.java
  4. 2
      src/main/java/com/ccsens/pelma_analyse/util/netty/SocketServer.java
  5. 3
      src/main/resources/application.yml

14
java安装说明.docx

@ -0,0 +1,14 @@
1.目录不要有中文 、空格,打开项目目录,在该目录打开cmd,查看是否安装java环境,有环境的可以直接跳到第4步
2.要是查看不到java版本号,就需要安装java环境,要是有java版本号,直接看第4步
3.配置环境变量
https://www.runoob.com/java/java-environment-setup.html
4.修改成自己需要的tcp端口,打开application.yml,记事本就可以打开
5.项目目录打开cmd
输入java -jar pelma_analyse-0.0.1-SNAPSHOT.jar
已经正常启动

9
src/main/java/com/ccsens/pelma_analyse/service/impl/PelmaDataAcceptImpl.java

@ -27,7 +27,12 @@ public class PelmaDataAcceptImpl implements PelmaDataAccept {
String pelma_url = GetServiceUrlAnalyseUtil.getUrl(); String pelma_url = GetServiceUrlAnalyseUtil.getUrl();
String url = pelma_url + "/storePelma"; String url = pelma_url + "/storePelma";
String res = restTemplate.postForObject(url, map, String.class); try {
System.out.println(res); String res = restTemplate.postForObject(url, map, String.class);
System.out.println(res);
} catch (Exception exception){
System.out.println(exception.getMessage());
}
} }
} }

119
src/main/java/com/ccsens/pelma_analyse/service/impl/SerialServiceImpl.java

@ -8,7 +8,9 @@ import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate; import org.springframework.web.client.RestTemplate;
import purejavacomm.SerialPort; import purejavacomm.SerialPort;
import java.io.BufferedReader;
import java.io.IOException; import java.io.IOException;
import java.io.InputStreamReader;
import java.text.DecimalFormat; import java.text.DecimalFormat;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
@ -34,40 +36,107 @@ public class SerialServiceImpl implements SerialService {
*/ */
@Override @Override
public void connect() { public void connect() {
SerialPort openSerial = null; String inputCom = "";
try { InputStreamReader in = new InputStreamReader(System.in);
String serial_com = ""; BufferedReader bufferedReader = new BufferedReader(in);
for (int i = com_num; i <= com_num_limit; i++) { while (true){
serial_com = "com" + i; System.out.print("请输入串口(例:10):");
try {
inputCom = bufferedReader.readLine();//获得数据
SerialPort openSerial = null;
try { try {
openSerial = SerialTool.openPort(serial_com, 115200, 8, 1, 0); String serial_com = "";
} catch (Exception e){ serial_com = "com" + inputCom;
continue; try {
} openSerial = SerialTool.openPort(serial_com, 115200, 8, 1, 0);
} catch (Exception e){
System.out.println("打开串口失败");
continue;
}
if (openSerial instanceof SerialPort){ if (!(openSerial instanceof SerialPort)){
break; System.out.println("打开串口失败");
continue;
}
if (openSerial == null){
System.out.println("打开串口失败");
continue;
}
System.out.println("打开串口" + serial_com);
//lora初始化话
initLora(openSerial);
//上报数据
sendData(openSerial);
//测试足底
// sendPelmaData(openSerial);
} catch (Exception e) {
System.out.println(e.getMessage());
} }
System.out.println('a'); } catch (IOException e) {
}
if (openSerial == null){ e.printStackTrace();
System.out.println("打开串口失败"); continue;
return; //System.out.println(e.toString());
} }
System.out.println("打开串口" + serial_com);
//lora初始化话
// initLora(openSerial);
//上报数据
// sendData(openSerial);
//测试足底
// sendPelmaData(openSerial);
} catch (Exception e) {
System.out.println(e.getMessage());
} }
} }
// /**
// * 连接串口
// */
// @Override
// public void connect() {
// String inputCom = "";
// InputStreamReader in = new InputStreamReader(System.in);
// BufferedReader bufferedReader = new BufferedReader(in);
// System.out.print("请输入串口(例:10):");
// try {
// inputCom = bufferedReader.readLine();//获得数据
// } catch (IOException e) {
// e.printStackTrace();
// //System.out.println(e.toString());
// }
//
// SerialPort openSerial = null;
// try {
// String serial_com = "";
// for (int i = com_num; i <= com_num_limit; i++) {
// serial_com = "com" + i;
// try {
// openSerial = SerialTool.openPort(serial_com, 115200, 8, 1, 0);
// } catch (Exception e){
// continue;
// }
//
// if (openSerial instanceof SerialPort){
// break;
// }
// System.out.println('a');
// }
// if (openSerial == null){
// System.out.println("打开串口失败");
// return;
// }
//
// System.out.println("打开串口" + serial_com);
//
// //lora初始化话
// initLora(openSerial);
// //上报数据
// sendData(openSerial);
// //测试足底
//// sendPelmaData(openSerial);
// } catch (Exception e) {
// System.out.println(e.getMessage());
// }
// }
/** /**
* lora初始化话 * lora初始化话
* @param openSerial * @param openSerial

2
src/main/java/com/ccsens/pelma_analyse/util/netty/SocketServer.java

@ -39,7 +39,7 @@ public class SocketServer {
public void start() { public void start() {
this.init(); this.init();
this.serverBootstrap.bind(this.port); this.serverBootstrap.bind(this.port);
log.info("Netty started on port: {} (TCP) with boss thread {}", this.port, this.bossThread); log.info("网线端口: {} (TCP) with boss thread {}", this.port, this.bossThread);
} }
/** /**

3
src/main/resources/application.yml

@ -4,7 +4,10 @@ spring:
server: server:
port: 8080 port: 8080
#网页地址
service_url_analyse: "http://127.0.0.1:8000" service_url_analyse: "http://127.0.0.1:8000"
#足底 网线端口
netty: netty:
port: 8081 port: 8081
bossThread: 1 bossThread: 1

Loading…
Cancel
Save