chuangte/smart-switch-java
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

监控有问题，回滚了

Browse Source
This commit is contained in:
磷叶 2024-12-31 09:00:53 +08:00
parent 1dfa2e2316
commit 92fe7a34c7
2 changed files with 42 additions and 100 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

81
smart-switch-service/src/main/java/com/ruoyi/ss/device/service/impl/DeviceServiceImpl.java
View File

@ -1314,48 +1314,51 @@ public class DeviceServiceImpl implements DeviceService
/** /**
* 监控设备信息，并对设备进行校准 * 监控设备信息，并对设备进行校准
* FIXME 存在问题：数据量大时，处理较慢，会造成数据不一致，导致频繁关闭设备
* 应该考虑实时获取设备数据，采用同步方式进行校准
* 或者考虑有针对性的对设备进行校准
*/ */
@Override @Override
public void monitor(List<Long> deviceIds) { public void monitor(List<Long> deviceIds) {
DeviceQuery query = new DeviceQuery(); // DeviceQuery query = new DeviceQuery();
query.setDeviceIds(deviceIds); // query.setDeviceIds(deviceIds);
List<DeviceVO> deviceList = this.selectSmDeviceList(query); // List<DeviceVO> deviceList = this.selectSmDeviceList(query);
if (CollectionUtils.isEmptyElement(deviceList)) { // if (CollectionUtils.isEmptyElement(deviceList)) {
return; // return;
} // }
this.pullDeviceInfoList(deviceList, IotConstants.ONLINE_TYPE_GET); // this.pullDeviceInfoList(deviceList, IotConstants.ONLINE_TYPE_GET);
//
for (DeviceVO device : deviceList) { // for (DeviceVO device : deviceList) {
try { // try {
scheduledExecutorService.schedule(() -> { // scheduledExecutorService.schedule(() -> {
// 若物联网设备的时长或者电量小于当前设备数据库的值，则执行一次同步（开启） // // 若物联网设备的时长或者电量小于当前设备数据库的值，则执行一次同步（开启）
// 一般情况下，物联网设备的值会大于或等于当前数据库的值 // // 一般情况下，物联网设备的值会大于或等于当前数据库的值
long deviceSeconds = device.getRemainTime() == null ? 0 : device.getRemainTime().longValue(); // long deviceSeconds = device.getRemainTime() == null ? 0 : device.getRemainTime().longValue();
if (device.getSurplusSecondsDb() > deviceSeconds) { // if (device.getSurplusSecondsDb() > deviceSeconds) {
this.syncTime(device.getDeviceId(), LocalDateTime.now(), "设备监控-同步时长"); // this.syncTime(device.getDeviceId(), LocalDateTime.now(), "设备监控-同步时长");
} // }
if (device.getSurplusEleDb().compareTo(device.getSurplusEle()) > 0) { // if (device.getSurplusEleDb().compareTo(device.getSurplusEle()) > 0) {
this.syncEle(device.getDeviceId(), "设备监控-同步电量"); // this.syncEle(device.getDeviceId(), "设备监控-同步电量");
} // }
//
// 若当前设备数据库的时长并且电量<=0，且在这之后用户没有发open命令，则执行一次同步（关闭） // // 若当前设备数据库的时长并且电量<=0，且在这之后用户没有发open命令，则执行一次同步（关闭）
boolean hasOpen = DeviceUserOperaType.OPEN.getType().equals(device.getUserOperaType()); // 是否开启过 // boolean hasOpen = DeviceUserOperaType.OPEN.getType().equals(device.getUserOperaType()); // 是否开启过
LocalDateTime lastOperaTime = device.getUserOperaTime(); // 上次开启的时间 // LocalDateTime lastOperaTime = device.getUserOperaTime(); // 上次开启的时间
BigDecimal lastOperaEle = device.getUserOperaEle(); // 上次开启的总用电量 // BigDecimal lastOperaEle = device.getUserOperaEle(); // 上次开启的总用电量
//
boolean hasOpenAfterExpireTime = hasOpen && lastOperaTime != null && lastOperaTime.isAfter(device.getExpireTime()); // 是否在时间结束后开启 // boolean hasOpenAfterExpireTime = hasOpen && lastOperaTime != null && lastOperaTime.isAfter(device.getExpireTime()); // 是否在时间结束后开启
boolean hasTime = device.getSurplusSecondsDb() > 0; // 剩余时间 // boolean hasTime = device.getSurplusSecondsDb() > 0; // 剩余时间
boolean hasOpenAfterExpireEle = hasOpen && lastOperaEle != null && lastOperaEle.compareTo(device.getExpireEle()) > 0; // 是否在结束电量后开启 // boolean hasOpenAfterExpireEle = hasOpen && lastOperaEle != null && lastOperaEle.compareTo(device.getExpireEle()) > 0; // 是否在结束电量后开启
boolean hasEle = device.getSurplusEleDb().compareTo(BigDecimal.ZERO) > 0; // 剩余电量 // boolean hasEle = device.getSurplusEleDb().compareTo(BigDecimal.ZERO) > 0; // 剩余电量
if (!hasTime && !hasEle && !hasOpenAfterExpireTime && !hasOpenAfterExpireEle) { // if (!hasTime && !hasEle && !hasOpenAfterExpireTime && !hasOpenAfterExpireEle) {
this.switchDevice(device, DevicePowerStatus.OFF, "设备监控-发现异常未关闭设备"); // this.switchDevice(device, DevicePowerStatus.OFF, "设备监控-发现异常未关闭设备");
} // }
},0, TimeUnit.SECONDS); // },0, TimeUnit.SECONDS);
//
} catch (Exception e) { // } catch (Exception e) {
log.error("监控设备{}出错：{}", device.getDeviceNo(), e.getMessage()); // log.error("监控设备{}出错：{}", device.getDeviceNo(), e.getMessage());
} // }
} // }
} }
/** /**

61
smart-switch-web/src/main/resources/application-druid-test.yml
View File

@ -1,61 +0,0 @@
# 数据源配置
spring:
datasource:
type: com.alibaba.druid.pool.DruidDataSource
driverClassName: com.mysql.cj.jdbc.Driver
druid:
# 主库数据源
master:
url: jdbc:mysql://106.75.233.135:3306/smart-switch-test?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
username: root
password: 9671e015b05b3f11
# 从库数据源
slave:
# 从数据源开关/默认关闭
enabled: false
url:
username:
password:
# 初始连接数
initialSize: 5
# 最小连接池数量
minIdle: 10
# 最大连接池数量
maxActive: 20
# 配置获取连接等待超时的时间
maxWait: 60000
# 配置连接超时时间
connectTimeout: 30000
# 配置网络超时时间
socketTimeout: 60000
# 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
timeBetweenEvictionRunsMillis: 60000
# 配置一个连接在池中最小生存的时间，单位是毫秒
minEvictableIdleTimeMillis: 300000
# 配置一个连接在池中最大生存的时间，单位是毫秒
maxEvictableIdleTimeMillis: 900000
# 配置检测连接是否有效
validationQuery: SELECT 1 FROM DUAL
testWhileIdle: true
testOnBorrow: false
testOnReturn: false
webStatFilter:
enabled: true
statViewServlet:
enabled: true
# 设置白名单，不填则允许所有访问
allow:
url-pattern: /druid/*
# 控制台管理用户名和密码
login-username: ruoyi
login-password: 123456
filter:
stat:
enabled: true
# 慢SQL记录
log-slow-sql: true
slow-sql-millis: 1000
merge-sql: true
wall:
config:
multi-statement-allow: true