|
@@ -7,6 +7,8 @@ import com.bz.zoneiot.core.utils.DateUtil;
|
|
|
import com.bz.zoneiot.core.utils.util.RedisUtils;
|
|
|
import com.bz.zoneiot.water.api.dto.DeviceDataDto;
|
|
|
import com.bz.zoneiot.water.api.dto.TimeValueDto;
|
|
|
+import com.bz.zoneiot.water.api.enums.DeviceStatusEnum;
|
|
|
+import com.bz.zoneiot.water.api.vo.DeviceVo;
|
|
|
import com.bz.zoneiot.water.core.dao.DeviceMapper;
|
|
|
import com.bz.zoneiot.water.core.dao.MonitorDataMapper;
|
|
|
import com.bz.zoneiot.water.core.entity.MonitorDataEntity;
|
|
@@ -127,8 +129,13 @@ public class ReceiveDeviceDataService {
|
|
|
this.saveData(timeValueDto, monitorDataEntity);
|
|
|
lastTime = timeValueDto.getTime();
|
|
|
}
|
|
|
+ Long deviceId = Long.parseLong(monitorDataEntity.getDeviceId().toString());
|
|
|
// 修改设备上报时间
|
|
|
deviceMapper.updateLastTime(monitorDataEntity.getDeviceId(), lastTime);
|
|
|
+ DeviceVo deviceVo = deviceMapper.selectById(Long.parseLong(monitorDataEntity.getDeviceId().toString()));
|
|
|
+ if (deviceVo.getEnableState() == DeviceStatusEnum.NOT_ENABLED.getCode()) {
|
|
|
+ deviceMapper.updateDeviceState(deviceId, DeviceStatusEnum.NORMAL.getCode());
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
/**
|