|
|
@@ -48,11 +48,15 @@ public class TdCronJob implements JobHandler {
|
|
|
List<String> allTableNames = deviceMapper.getAllTableNames();
|
|
|
for (IotDeviceDO device : devices) {
|
|
|
String deviceCode = device.getDeviceCode();
|
|
|
+ if ("YF6660388".equals(deviceCode)) {
|
|
|
+ System.out.println("----------------"+deviceCode);
|
|
|
+ }
|
|
|
allDevice.stream().filter(e -> e.getSerialNumber().equals(deviceCode)).findFirst().ifPresent(e -> {
|
|
|
device.setYfDeviceId(e.getDeviceId());
|
|
|
// Integer i = deviceMapper.tableIfExist(e.getSerialNumber().toLowerCase());
|
|
|
if (allTableNames.contains("device_"+e.getSerialNumber().toLowerCase())) {//如果存在表
|
|
|
- Map<Object, Object> hashAll = redisTemplate.opsForHash().entries("TSLV:"+e.getProductId()+"_"+e.getSerialNumber());
|
|
|
+ String redisKey = "TSLV:"+e.getProductId()+"_"+e.getSerialNumber();
|
|
|
+ Map<Object, Object> hashAll = redisTemplate.opsForHash().entries(redisKey);
|
|
|
|
|
|
Map<String, String> result = new HashMap<>();
|
|
|
String timestamp = "";
|