|
@@ -131,23 +131,23 @@ public class PersonDeviceLogServiceImpl implements PersonDeviceLogService {
|
|
|
throw new Exception(personDeviceLog.getDeviceNo() + "设备不存在");
|
|
|
}
|
|
|
List<WarningPusher> warningPusherList = warningPusherService.findByCompanyId(personInfo.getCompanyId());
|
|
|
- if (warningPusherList.size() <= 0) {
|
|
|
- throw new Exception("对应公司没有体温报警监管者");
|
|
|
- }
|
|
|
-
|
|
|
- for (WarningPusher warningPusher : warningPusherList) {
|
|
|
- Map<String, Object> searchParams = new HashMap<>();
|
|
|
- searchParams.put("deviceNo", personDeviceLog.getDeviceNo());
|
|
|
- searchParams.put("personId", personDeviceLog.getPersonId());
|
|
|
- searchParams.put("minTemperature", warningPusher.getTemperature());
|
|
|
- searchParams.put("beginTime", new Date(personDeviceLog.getRecordTime().getTime() - 300000));
|
|
|
- List<Sort> sortList = new ArrayList<>();
|
|
|
- sortList.add(new Sort("record_time", "desc"));
|
|
|
- List<PersonDeviceLog> personDeviceLogList = personDeviceLogDAO.search(searchParams, sortList);
|
|
|
-
|
|
|
- if (personDeviceLogList.size() >= warningPusher.getTimes()) {
|
|
|
- log.warn("开始发送模板消息");
|
|
|
- WechatMessageUtil.sendTemperatureAlarmInfo(warningPusher.getOpenId(), companyInfo.getName() + "_" + deviceInfo.getAliasName(), wxConfig.getAppId(), wxConfig.getAppSecret(),personDeviceLog.getId());
|
|
|
+ if (warningPusherList.size() > 0) {
|
|
|
+
|
|
|
+
|
|
|
+ for (WarningPusher warningPusher : warningPusherList) {
|
|
|
+ Map<String, Object> searchParams = new HashMap<>();
|
|
|
+ searchParams.put("deviceNo", personDeviceLog.getDeviceNo());
|
|
|
+ searchParams.put("personId", personDeviceLog.getPersonId());
|
|
|
+ searchParams.put("minTemperature", warningPusher.getTemperature());
|
|
|
+ searchParams.put("beginTime", new Date(personDeviceLog.getRecordTime().getTime() - 300000));
|
|
|
+ List<Sort> sortList = new ArrayList<>();
|
|
|
+ sortList.add(new Sort("record_time", "desc"));
|
|
|
+ List<PersonDeviceLog> personDeviceLogList = personDeviceLogDAO.search(searchParams, sortList);
|
|
|
+
|
|
|
+ if (personDeviceLogList.size() >= warningPusher.getTimes()) {
|
|
|
+ log.warn("开始发送模板消息");
|
|
|
+ WechatMessageUtil.sendTemperatureAlarmInfo(warningPusher.getOpenId(), companyInfo.getName() + "_" + deviceInfo.getAliasName(), wxConfig.getAppId(), wxConfig.getAppSecret(), personDeviceLog.getId());
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
|