|
@@ -74,7 +74,7 @@ public class AlarmRecordServiceImpl extends ServiceImpl<AlarmRecordMapper, Alarm
|
|
|
@Resource
|
|
@Resource
|
|
|
private RfidTagService tagService;
|
|
private RfidTagService tagService;
|
|
|
|
|
|
|
|
- private static final String MSG_MATCH="==================>{},{}";
|
|
|
|
|
|
|
+ private static final String MSG_MATCH = "==================>{},{}";
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
public void getRecordInfo(List<AlarmRecordVo> recordVos) {
|
|
public void getRecordInfo(List<AlarmRecordVo> recordVos) {
|
|
@@ -97,13 +97,9 @@ public class AlarmRecordServiceImpl extends ServiceImpl<AlarmRecordMapper, Alarm
|
|
|
public List<AlarmRecord> getList(AlarmRecord alarmRecord) {
|
|
public List<AlarmRecord> getList(AlarmRecord alarmRecord) {
|
|
|
LambdaQueryWrapper<AlarmRecord> queryWrapper = Wrappers.lambdaQuery(AlarmRecord.class);
|
|
LambdaQueryWrapper<AlarmRecord> queryWrapper = Wrappers.lambdaQuery(AlarmRecord.class);
|
|
|
String startTime = alarmRecord.getStartTime();
|
|
String startTime = alarmRecord.getStartTime();
|
|
|
- if (StringUtils.hasLength(startTime)){
|
|
|
|
|
- queryWrapper.apply("DATE_FORMAT(alarm_time,'%Y-%m-%d') >="+alarmRecord.getStartTime());
|
|
|
|
|
- }
|
|
|
|
|
String endTime = alarmRecord.getEndTime();
|
|
String endTime = alarmRecord.getEndTime();
|
|
|
- if (StringUtils.hasLength(endTime)){
|
|
|
|
|
- queryWrapper.apply("DATE_FORMAT(alarm_time,'%Y-%m-%d') <="+alarmRecord.getEndTime());
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ queryWrapper.apply(StringUtils.hasLength(startTime), "DATE_FORMAT(alarm_time,'%Y-%m-%d') >=date_format('" + startTime + "','%Y-%m-%d')")
|
|
|
|
|
+ .apply(StringUtils.hasLength(startTime), "DATE_FORMAT(alarm_time,'%Y-%m-%d') <=date_format('" + endTime + "','%Y-%m-%d')");
|
|
|
return list(queryWrapper);
|
|
return list(queryWrapper);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -113,14 +109,14 @@ public class AlarmRecordServiceImpl extends ServiceImpl<AlarmRecordMapper, Alarm
|
|
|
String electronicTag = tag.getEpc();
|
|
String electronicTag = tag.getEpc();
|
|
|
RemoteLabHardware hardware = tag.getRemoteLabHardware();
|
|
RemoteLabHardware hardware = tag.getRemoteLabHardware();
|
|
|
LambdaQueryWrapper<RfidTag> queryWrapper = Wrappers.lambdaQuery(RfidTag.class);
|
|
LambdaQueryWrapper<RfidTag> queryWrapper = Wrappers.lambdaQuery(RfidTag.class);
|
|
|
- queryWrapper.eq(RfidTag::getAuthCode,electronicTag);
|
|
|
|
|
|
|
+ queryWrapper.eq(RfidTag::getAuthCode, electronicTag);
|
|
|
RfidTag rfidTag = tagService.getOne(queryWrapper);
|
|
RfidTag rfidTag = tagService.getOne(queryWrapper);
|
|
|
- if (rfidTag==null){
|
|
|
|
|
- log.info(MSG_MATCH,electronicTag,"标签未录入");
|
|
|
|
|
|
|
+ if (rfidTag == null) {
|
|
|
|
|
+ log.info(MSG_MATCH, electronicTag, "标签未录入");
|
|
|
return false;
|
|
return false;
|
|
|
}
|
|
}
|
|
|
LambdaQueryWrapper<BottleStorage> wrapper = Wrappers.lambdaQuery(BottleStorage.class);
|
|
LambdaQueryWrapper<BottleStorage> wrapper = Wrappers.lambdaQuery(BottleStorage.class);
|
|
|
- wrapper.eq(BottleStorage::getElectronicTag,rfidTag.getId());
|
|
|
|
|
|
|
+ wrapper.eq(BottleStorage::getElectronicTag, rfidTag.getId());
|
|
|
BottleStorage bottleStorage = storageService.getOne(wrapper);
|
|
BottleStorage bottleStorage = storageService.getOne(wrapper);
|
|
|
if (bottleStorage != null) {
|
|
if (bottleStorage != null) {
|
|
|
Long id = bottleStorage.getId();
|
|
Long id = bottleStorage.getId();
|
|
@@ -132,7 +128,7 @@ public class AlarmRecordServiceImpl extends ServiceImpl<AlarmRecordMapper, Alarm
|
|
|
// 发送报警消息
|
|
// 发送报警消息
|
|
|
sendAlarm(bottleStorage);
|
|
sendAlarm(bottleStorage);
|
|
|
redisService.setCacheObject(key, electronicTag, 300L, TimeUnit.SECONDS);
|
|
redisService.setCacheObject(key, electronicTag, 300L, TimeUnit.SECONDS);
|
|
|
- AlarmRecord alarmRecord=new AlarmRecord();
|
|
|
|
|
|
|
+ AlarmRecord alarmRecord = new AlarmRecord();
|
|
|
alarmRecord.setElectronicTag(electronicTag)
|
|
alarmRecord.setElectronicTag(electronicTag)
|
|
|
.setAlarmTime(Calendar.getInstance().getTime())
|
|
.setAlarmTime(Calendar.getInstance().getTime())
|
|
|
.setMasterId(id)
|
|
.setMasterId(id)
|
|
@@ -140,9 +136,9 @@ public class AlarmRecordServiceImpl extends ServiceImpl<AlarmRecordMapper, Alarm
|
|
|
.setProductType(1)
|
|
.setProductType(1)
|
|
|
.setDeptId(bottleStorage.getDeptId());
|
|
.setDeptId(bottleStorage.getDeptId());
|
|
|
return save(alarmRecord);
|
|
return save(alarmRecord);
|
|
|
- }else {
|
|
|
|
|
- if (hardware!=null){
|
|
|
|
|
- log.info(MSG_MATCH,electronicTag,"标签未绑定气瓶");
|
|
|
|
|
|
|
+ } else {
|
|
|
|
|
+ if (hardware != null) {
|
|
|
|
|
+ log.info(MSG_MATCH, electronicTag, "标签未绑定气瓶");
|
|
|
}
|
|
}
|
|
|
return false;
|
|
return false;
|
|
|
}
|
|
}
|
|
@@ -204,8 +200,8 @@ public class AlarmRecordServiceImpl extends ServiceImpl<AlarmRecordMapper, Alarm
|
|
|
alarmEntrty.setTo(phones.toArray(new String[]{}));
|
|
alarmEntrty.setTo(phones.toArray(new String[]{}));
|
|
|
alarmEntrty.setText(subjectName + airName + "气瓶被违规带离,请尽快确认");
|
|
alarmEntrty.setText(subjectName + airName + "气瓶被违规带离,请尽快确认");
|
|
|
AjaxResult result = remoteAlarmService.send(alarmEntrty);
|
|
AjaxResult result = remoteAlarmService.send(alarmEntrty);
|
|
|
- if (!result.get(AjaxResult.CODE_TAG).equals(HttpStatus.SUCCESS)){
|
|
|
|
|
- log.error("电话报警异常:发送实验室【{}】,实验室ID【{}】,接收用户手机号【{}】",subjectName,storage.getSubjectId(), phones);
|
|
|
|
|
|
|
+ if (!result.get(AjaxResult.CODE_TAG).equals(HttpStatus.SUCCESS)) {
|
|
|
|
|
+ log.error("电话报警异常:发送实验室【{}】,实验室ID【{}】,接收用户手机号【{}】", subjectName, storage.getSubjectId(), phones);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|