Merge remote-tracking branch 'origin/test' into test
| | |
| | | String attendPeople = actActivityDO.getAattendPeople(); |
| | | if (isVolunteer.intValue() == 0 && isNotBlank(attendPeople)) { |
| | | if (isBlank(currentUserTags)) { |
| | | return R.fail("您不是指定参与人群!"); |
| | | currentUserTags = "全部居民"; |
| | | } else { |
| | | currentUserTags = currentUserTags.concat(",全部居民"); |
| | | } |
| | | List<String> currentUserTagList = Arrays.asList(currentUserTags.split(",")); |
| | | boolean checkResult = currentUserTagList.stream().anyMatch(currentUserTag -> attendPeople.contains(currentUserTag)); |
| | |
| | | DeviceDto deviceInfo = JSONObject.parseObject(message, DeviceDto.class); |
| | | boolean checkFlag = |
| | | "RINGING".equals(deviceInfo.getCallstatus()) && StringUtils.isNotEmpty(deviceInfo.getOri_number()); |
| | | if ("abort".equals(deviceInfo.getStatus()) || checkFlag) { |
| | | if (checkFlag) { |
| | | logger.info("收到设备报警信息:{}", message); |
| | | ComPropertyAlarm comPropertyAlarm = new ComPropertyAlarm(); |
| | | comPropertyAlarm.setSerialNo(deviceInfo.getOri_number()); |