admin/wisdomisite-java
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

打印

Browse Source
This commit is contained in:
guoshengxiong 2025-08-13 17:41:38 +08:00
parent e0b1e446e6
commit cfd227d1ef
1 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/main/java/com/zhgd/xmgl/modules/environment/service/impl/DustNoiseDataServiceImpl.java
View File

@ -264,16 +264,17 @@ public class DustNoiseDataServiceImpl extends ServiceImpl<DustNoiseDataMapper, D
*/ */
private void rzckStartHj212() throws InterruptedException { private void rzckStartHj212() throws InterruptedException {
RSServer rsServer = RSServer.Initiate(rengzhicekongHj212Port);// 初始化 RSServer rsServer = RSServer.Initiate(rengzhicekongHj212Port);// 初始化
String rzck = "仁智测控";
rsServer.addDataListener(new IDataListener() {// 添加监听 rsServer.addDataListener(new IDataListener() {// 添加监听
@Override @Override
public void receiveTimmingAck(TimmingAck data) {// 校时指令应答处理 public void receiveTimmingAck(TimmingAck data) {// 校时指令应答处理
log.info("校时应答->设备编号:" + data.getDeviceId() log.info(rzck + "校时应答->设备编号:" + data.getDeviceId()
+ "\t执行结果：" + data.getStatus()); + "\t执行结果：" + data.getStatus());
} }
@Override @Override
public void receiveTelecontrolAck(TelecontrolAck data) {// 遥控指令应答处理 public void receiveTelecontrolAck(TelecontrolAck data) {// 遥控指令应答处理
log.info("遥控应答->设备编号:" + data.getDeviceId() log.info(rzck + "遥控应答->设备编号:" + data.getDeviceId()
+ "\t继电器编号:" + data.getRelayId() + "\t执行结果:" + "\t继电器编号:" + data.getRelayId() + "\t执行结果:"
+ data.getStatus()); + data.getStatus());
} }
@ -285,7 +286,7 @@ public class DustNoiseDataServiceImpl extends ServiceImpl<DustNoiseDataMapper, D
SimpleDateFormat sdf = new SimpleDateFormat( SimpleDateFormat sdf = new SimpleDateFormat(
"yy-MM-dd HH:mm:ss"); "yy-MM-dd HH:mm:ss");
String str = sdf.format(nd.getRecordTime()); String str = sdf.format(nd.getRecordTime());
log.info("存储数据->设备地址:" + data.getDeviceId() log.info(rzck + "存储数据->设备地址:" + data.getDeviceId()
+ "\t节点:" + nd.getNodeId() + "\t温度:" + nd.getTem() + "\t节点:" + nd.getNodeId() + "\t温度:" + nd.getTem()
+ "\t湿度:" + nd.getHum() + "\t存储时间:" + str); + "\t湿度:" + nd.getHum() + "\t存储时间:" + str);
} }
@ -307,7 +308,7 @@ public class DustNoiseDataServiceImpl extends ServiceImpl<DustNoiseDataMapper, D
+ "\t纬度:" + data.getLat() + "\t坐标类型:" + "\t纬度:" + data.getLat() + "\t坐标类型:"
+ data.getCoordinateType() + "\t继电器状态:" + data.getCoordinateType() + "\t继电器状态:"
+ data.getRelayStatus(); + data.getRelayStatus();
log.info(printData); log.info(rzck + printData);
/* /*
{ {
"deviceId": "", "deviceId": "",
@ -402,7 +403,7 @@ public class DustNoiseDataServiceImpl extends ServiceImpl<DustNoiseDataMapper, D
@Override @Override
public void receiveLoginData(LoginData data) {// 登录数据接收处理 public void receiveLoginData(LoginData data) {// 登录数据接收处理
log.info("登录->设备地址:" + data.getDeviceId()); log.info(rzck + "登录->设备地址:" + data.getDeviceId());
} }
@ -415,7 +416,7 @@ public class DustNoiseDataServiceImpl extends ServiceImpl<DustNoiseDataMapper, D
{ {
str += paramId + ","; str += paramId + ",";
} }
log.info(str); log.info(rzck + str);
} }
@ -433,7 +434,7 @@ public class DustNoiseDataServiceImpl extends ServiceImpl<DustNoiseDataMapper, D
.getValue() : pararm.getValueDescription() .getValue() : pararm.getValueDescription()
.get(pararm.getValue())) + "\r\n"; .get(pararm.getValue())) + "\r\n";
} }
log.info(str); log.info(rzck + str);
} }
@ -442,7 +443,7 @@ public class DustNoiseDataServiceImpl extends ServiceImpl<DustNoiseDataMapper, D
String str = "下载设备参数->设备编号：" + data.getDeviceId() + "\t参数数量：" String str = "下载设备参数->设备编号：" + data.getDeviceId() + "\t参数数量："
+ data.getCount() + "\t" + data.getCount() + "\t"
+ (data.isSuccess() ? "下载成功" : "下载失败"); + (data.isSuccess() ? "下载成功" : "下载失败");
log.info(str); log.info(rzck + str);
} }
@ -450,13 +451,13 @@ public class DustNoiseDataServiceImpl extends ServiceImpl<DustNoiseDataMapper, D
public void receiveTransDataAck(TransDataAck data) { public void receiveTransDataAck(TransDataAck data) {
String str = "数据透传->设备编号：" + data.getDeviceId() + "\t响应结果：" String str = "数据透传->设备编号：" + data.getDeviceId() + "\t响应结果："
+ data.getData() + "\r\n字节数：" + data.getTransDataLen(); + data.getData() + "\r\n字节数：" + data.getTransDataLen();
log.info(str); log.info(rzck + str);
} }
@Override @Override
public void receiveHeartbeatData(HeartbeatData heartbeatData) { public void receiveHeartbeatData(HeartbeatData heartbeatData) {
log.info(rzck + "receiveHeartbeatData");
} }
}); });
rsServer.start(); rsServer.start();