|
@@ -13,6 +13,7 @@ import com.care.installation.vo.*;
|
|
|
import com.care.mqtt.service.MqttConnectorPoolService;
|
|
|
import com.care.mqtt.service.MqttPublishService;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
+import org.apache.commons.lang3.StringUtils;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
@@ -38,6 +39,37 @@ public class RoomService {
|
|
|
@Resource
|
|
|
private MqttConnectorPoolService mqttConnectorPoolService;
|
|
|
|
|
|
+ public Map<String,Boolean> getConfStatusInfo(String devCode) {
|
|
|
+ Map<String,Boolean> map = new HashMap<>();
|
|
|
+ RoomVO roomVO = getRoomInfo(devCode);
|
|
|
+ if (roomVO != null){
|
|
|
+ map.put("roomVO",true);
|
|
|
+ } else {
|
|
|
+ map.put("roomVO",false);
|
|
|
+ }
|
|
|
+ RoomSensorVO roomSensorVO = getRoomSensorInfo(devCode);
|
|
|
+ if (roomSensorVO != null){
|
|
|
+ map.put("roomSensorVO",true);
|
|
|
+ } else {
|
|
|
+ map.put("roomSensorVO",false);
|
|
|
+ }
|
|
|
+ List<RoomGateVO> listRoomGateVO = listRoomGateInfo(devCode);
|
|
|
+ if(CollUtil.isNotEmpty(listRoomGateVO)){
|
|
|
+ map.put("listRoomGateVO",true);
|
|
|
+ } else {
|
|
|
+ map.put("listRoomGateVO",false);
|
|
|
+ }
|
|
|
+
|
|
|
+ List<RoomRegionVO> listRoomRegionVO = listRoomRegionInfo(devCode);
|
|
|
+ if(CollUtil.isNotEmpty(listRoomRegionVO)){
|
|
|
+ map.put("listRoomRegionVO",true);
|
|
|
+ } else {
|
|
|
+ map.put("listRoomRegionVO",false);
|
|
|
+ }
|
|
|
+
|
|
|
+ return map;
|
|
|
+ }
|
|
|
+
|
|
|
public RoomVO getRoomInfo(String devCode) {
|
|
|
QueryWrapper<CareRoom> queryWrapper = new QueryWrapper<>();
|
|
|
queryWrapper.lambda().eq(CareRoom::getRoomId,devCode);
|
|
@@ -51,8 +83,21 @@ public class RoomService {
|
|
|
}
|
|
|
|
|
|
public Boolean saveRoom(RoomVO vo) {
|
|
|
+ if (StringUtils.isEmpty(vo.getRoomId())){
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
CareRoom careRoom = new CareRoom();
|
|
|
BeanUtil.copyProperties(vo,careRoom);
|
|
|
+
|
|
|
+ QueryWrapper<CareRoom> queryWrapper = new QueryWrapper<>();
|
|
|
+ queryWrapper.lambda().eq(CareRoom::getRoomId,careRoom.getRoomId());
|
|
|
+ CareRoom careRoomDb = this.careRoomService.getOne(queryWrapper);
|
|
|
+ if(careRoomDb != null ){
|
|
|
+ careRoom.setId(careRoomDb.getId());
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
if (careRoom.getId() != null) { //修改
|
|
|
careRoom.setModifyTime(new Date());
|
|
|
return this.careRoomService.updateById(careRoom);
|
|
@@ -224,12 +269,13 @@ public class RoomService {
|
|
|
QueryWrapper<CareRoom> queryWrapper2 = new QueryWrapper<>();
|
|
|
queryWrapper2.lambda().eq(CareRoom::getRoomId,devCode);
|
|
|
CareRoom careRoom = careRoomService.getOne(queryWrapper2);
|
|
|
- boolean careRoomBool = "true".equals(careRoom.getAck());
|
|
|
+
|
|
|
+ boolean careRoomBool = careRoom != null && "true".equals(careRoom.getAck());
|
|
|
|
|
|
QueryWrapper<CareRoomSensor> queryWrapper3 = new QueryWrapper<>();
|
|
|
queryWrapper3.lambda().eq(CareRoomSensor::getRoomId,devCode);
|
|
|
CareRoomSensor careRoomSensor = careRoomSensorService.getOne(queryWrapper3);
|
|
|
- boolean careRoomSensorBool = "true".equals(careRoomSensor.getAck());
|
|
|
+ boolean careRoomSensorBool = careRoomSensor != null && "true".equals(careRoomSensor.getAck());
|
|
|
|
|
|
QueryWrapper<CareRoomGate> queryWrapper4 = new QueryWrapper<>();
|
|
|
queryWrapper4.lambda().eq(CareRoomGate::getRoomId,devCode);
|