| | |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.panzhihua.common.utlis.StringUtils; |
| | | import com.panzhihua.service_property.dao.ComPropertyAlarmDao; |
| | | import com.panzhihua.service_property.dto.DeviceDto; |
| | | import com.panzhihua.service_property.entity.ComPropertyAlarm; |
| | |
| | | void dealData(String message) { |
| | | comPropertyAlarmDao = SpringUtil.getBean(ComPropertyAlarmDao.class); |
| | | DeviceDto deviceInfo = JSONObject.parseObject(message, DeviceDto.class); |
| | | if (deviceInfo.getCallstatus().equals("RINGING")) { |
| | | boolean checkFlag = |
| | | "RINGING".equals(deviceInfo.getCallstatus()) && StringUtils.isNotEmpty(deviceInfo.getOri_number()); |
| | | if ("abort".equals(deviceInfo.getStatus()) || checkFlag) { |
| | | logger.info("收到设备报警信息:{}", message); |
| | | ComPropertyAlarm comPropertyAlarm = new ComPropertyAlarm(); |
| | | comPropertyAlarm.setSerialNo(deviceInfo.getUserid()); |