|
@@ -14,12 +14,11 @@ import com.sooka.sponest.event.centereventtdeptevent.domain.CentereventDeptEvent
|
|
|
import com.sooka.sponest.event.centereventtdeptevent.service.ICentereventDeptEventService;
|
|
|
import com.sooka.sponest.event.centereventteventcatalogue.domain.CentereventTEventcatalogue;
|
|
|
import com.sooka.sponest.event.centereventteventcatalogue.domain.DaHuaEventBO;
|
|
|
-import com.sooka.sponest.event.centereventteventcatalogue.domain.dahua.DaHuaFireEventVO;
|
|
|
-import com.sooka.sponest.event.centereventteventcatalogue.domain.dahua.DaHuaOtherEventVO;
|
|
|
-import com.sooka.sponest.event.centereventteventcatalogue.domain.dahua.PictureVO;
|
|
|
+import com.sooka.sponest.event.centereventteventcatalogue.domain.dahua.*;
|
|
|
import com.sooka.sponest.event.centereventteventcatalogue.domain.haikang.EventsVo;
|
|
|
import com.sooka.sponest.event.centereventteventcatalogue.domain.haikang.HaiKangEventVo;
|
|
|
import com.sooka.sponest.event.centereventteventcatalogue.domain.sensor.SensorEventVo;
|
|
|
+import com.sooka.sponest.event.centereventteventcatalogue.domain.tower.TowerEventVo;
|
|
|
import com.sooka.sponest.event.centereventteventcatalogue.service.AlarmEventService;
|
|
|
import com.sooka.sponest.event.centereventteventcatalogue.service.ICentereventTEventcatalogueService;
|
|
|
import com.sooka.sponest.event.centereventteventtype.domain.CentereventTEventtype;
|
|
@@ -28,16 +27,22 @@ import com.sooka.sponest.event.centereventtfirelog.domain.CentereventTFireLog;
|
|
|
import com.sooka.sponest.event.centereventtfirelog.service.ICentereventTFireLogService;
|
|
|
import com.sooka.sponest.event.remoteapi.RemoteDataService;
|
|
|
import com.sooka.sponest.event.remoteapi.domain.CenterdataTAttach;
|
|
|
+import com.sooka.sponest.event.utils.GWHttpUtilsTest65;
|
|
|
import com.sooka.sponest.event.utils.RemoteApiUtil;
|
|
|
import com.sooka.sponest.monitor.api.RemoteMonitorService;
|
|
|
import com.sooka.sponest.monitor.api.domain.CenterdataTAidevicedept;
|
|
|
import com.sooka.sponest.monitor.api.domain.CenterdataTCamera;
|
|
|
+import org.apache.commons.collections4.MapUtils;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
+import org.springframework.http.HttpEntity;
|
|
|
+import org.springframework.http.HttpHeaders;
|
|
|
+import org.springframework.http.MediaType;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
+import org.springframework.web.client.RestTemplate;
|
|
|
|
|
|
import java.util.ArrayList;
|
|
|
import java.util.Date;
|
|
@@ -69,6 +74,9 @@ public class AlarmEventServiceImpl implements AlarmEventService {
|
|
|
@Value("${sooka.dahuaservice.detail}")
|
|
|
private String detailUrl;
|
|
|
|
|
|
+ @Value("${sooka.supermap.datasetUrl}")
|
|
|
+ private String datasetUrl;
|
|
|
+
|
|
|
static final String ERROR_MSG_CHANNEL = "无法匹配相关设备!通道编号为:{}";
|
|
|
|
|
|
static final String ERROR_MSG_DEPT = "无法匹配相关部门!摄像头编号为:{}";
|
|
@@ -186,6 +194,10 @@ public class AlarmEventServiceImpl implements AlarmEventService {
|
|
|
centereventTEventcatalogue.setIsUrged(SYS_ISURGE_2);//sys_isurge_2
|
|
|
centereventTEventcatalogue.setEventStatus("上报");
|
|
|
centereventTEventcatalogue.setEventStatusValue(FOREST_EVENT_STATUS_1);//forest_event_status_1
|
|
|
+ // 自动研判误报,218工程车、222区域入侵、237违章建筑
|
|
|
+ if ("218".equals(centereventTEventcatalogue.getEventTypeXl()) || "222".equals(centereventTEventcatalogue.getEventTypeXl()) || "237".equals(centereventTEventcatalogue.getEventTypeXl())) {
|
|
|
+ test(centereventTEventcatalogue);
|
|
|
+ }
|
|
|
centereventTEventcatalogue.setCreateBy(centerdataTCamera.getId());
|
|
|
centereventTEventcatalogue.setCreateName(centerdataTCamera.getCameraName());
|
|
|
centereventTEventcatalogue.setCreateTime(null == createTime ? DateUtils.getNowDate() : createTime);
|
|
@@ -193,6 +205,41 @@ public class AlarmEventServiceImpl implements AlarmEventService {
|
|
|
return centereventTEventcatalogue;
|
|
|
}
|
|
|
|
|
|
+ private void test(CentereventTEventcatalogue centereventTEventcatalogue) {
|
|
|
+ try {
|
|
|
+ HttpHeaders headers = new HttpHeaders();
|
|
|
+ headers.setContentType(MediaType.APPLICATION_JSON);
|
|
|
+ for (String url : datasetUrl.split(";")) {
|
|
|
+ JSONObject requestBody = JSONObject.parseObject("{" +
|
|
|
+ "\"getFeatureMode\": \"SPATIAL\"," +
|
|
|
+ "\"datasetNames\": " + url.split("&datasetNames=")[1] + "," +
|
|
|
+ "\"geometry\": {" +
|
|
|
+ "\"id\": 0," +
|
|
|
+ "\"style\": null," +
|
|
|
+ "\"parts\": [1]," +
|
|
|
+ "\"points\": [{" +
|
|
|
+ "\"y\": " + Double.parseDouble(centereventTEventcatalogue.getLatitude()) + "," +
|
|
|
+ "\"x\": " + Double.parseDouble(centereventTEventcatalogue.getLongitude()) +
|
|
|
+ "}]," +
|
|
|
+ "\"type\": \"POINT\"}," +
|
|
|
+ "\"spatialQueryMode\": \"INTERSECT\"" +
|
|
|
+ "}");
|
|
|
+ HttpEntity<JSONObject> entity = new HttpEntity<>(requestBody, headers);
|
|
|
+ RestTemplate restTemplate = new RestTemplate();
|
|
|
+ JSONObject result = restTemplate.postForEntity(url.split("&datasetNames=")[0], entity, JSONObject.class).getBody();
|
|
|
+ logger.info(result.toJSONString());
|
|
|
+ // {"features":[],"featureUriList":[],"datasetInfos":[],"totalCount":0,"featureCount":0}
|
|
|
+ if (result.getLong("totalCount") != 0 && result.getLong("featureCount") != 0) {
|
|
|
+ centereventTEventcatalogue.setEventStatus("误报");
|
|
|
+ centereventTEventcatalogue.setEventStatusValue("forest_event_status_3");
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } catch (Exception e) {
|
|
|
+ logger.error(e.getMessage());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
// 事件部门
|
|
|
private void insertEventDept(CentereventTEventcatalogue centereventTEventcatalogue, List<CenterdataTAidevicedept> listDept) {
|
|
|
listDept.forEach(item -> {
|
|
@@ -229,19 +276,23 @@ public class AlarmEventServiceImpl implements AlarmEventService {
|
|
|
@Transactional
|
|
|
@Override
|
|
|
public String insertDaHuaEvent(DaHuaFireEventVO daHuaFireEventVO) {
|
|
|
- Long type = daHuaFireEventVO.getInfo().getAlarmType();
|
|
|
+ Long type = MapUtils.getLong(daHuaFireEventVO.getInfo(), "alarmType");
|
|
|
// 313:烟雾,5122:热感
|
|
|
if (type == 313 || type == 5122) {
|
|
|
return insertFireEvent(daHuaFireEventVO);
|
|
|
+ } else if (type == 302 || type == 303 || type == 962 || type == 963 || type == 964 || type == 965) {
|
|
|
+ // 302:绊线入侵,303:区域入侵 ,962:人穿越警戒线,963:机动车穿越警戒线,964:人穿越区域,965:机动车穿越区域
|
|
|
+ return insertBayonetEvent(daHuaFireEventVO);
|
|
|
}
|
|
|
return "";
|
|
|
}
|
|
|
|
|
|
public String insertFireEvent(DaHuaFireEventVO daHuaFireEventVO) {
|
|
|
+ InfoVO infoVO = JSONObject.parseObject(JSON.toJSONString(daHuaFireEventVO.getInfo()), InfoVO.class);
|
|
|
// 验证是否配置摄像头通道
|
|
|
- CenterdataTCamera centerdataTCamera = SpringUtils.getBean(RemoteMonitorService.class).getInfoByChannelCode(daHuaFireEventVO.getInfo().getChannelSn()).getData();
|
|
|
+ CenterdataTCamera centerdataTCamera = SpringUtils.getBean(RemoteMonitorService.class).getInfoByChannelCode(infoVO.getChannelSn()).getData();
|
|
|
if (StringUtils.isNull(centerdataTCamera)) {
|
|
|
- logger.info(ERROR_MSG_CHANNEL, daHuaFireEventVO.getInfo().getChannelSn());
|
|
|
+ logger.info(ERROR_MSG_CHANNEL, infoVO.getChannelSn());
|
|
|
return "";
|
|
|
}
|
|
|
// 验证是否配置指挥中心
|
|
@@ -251,12 +302,13 @@ public class AlarmEventServiceImpl implements AlarmEventService {
|
|
|
return "";
|
|
|
}
|
|
|
// 事件目录
|
|
|
- String eventName = daHuaFireEventVO.getInfo().getChannelName() + daHuaFireEventVO.getInfo().getAlarmDateStr() + daHuaFireEventVO.getInfo().getAlarmTypeName();
|
|
|
- String eventDescription = daHuaFireEventVO.getInfo().toString(centerdataTCamera);
|
|
|
- String longitude = StringUtils.isEmpty(daHuaFireEventVO.getInfo().getFirePoint()) ? centerdataTCamera.getLongitude() : daHuaFireEventVO.getInfo().getFirePoint()[0].getGpsX();
|
|
|
- String latitude = StringUtils.isEmpty(daHuaFireEventVO.getInfo().getFirePoint()) ? centerdataTCamera.getLatitude() : daHuaFireEventVO.getInfo().getFirePoint()[0].getGpsY();
|
|
|
- String reportor = daHuaFireEventVO.getInfo().getDeviceName();
|
|
|
- Date reportTime = DateUtils.timestampToTime(daHuaFireEventVO.getInfo().getAlarmDate());
|
|
|
+ //四平市双辽市卧虎镇贺家村热感应 + 2024-01-05 10:32:54 + 火情报警
|
|
|
+ String eventName = infoVO.getChannelName() + infoVO.getAlarmDateStr() + infoVO.getAlarmTypeName();
|
|
|
+ String eventDescription = infoVO.toString(centerdataTCamera);
|
|
|
+ String longitude = StringUtils.isEmpty(infoVO.getFirePoint()) ? centerdataTCamera.getLongitude() : infoVO.getFirePoint()[0].getGpsX();
|
|
|
+ String latitude = StringUtils.isEmpty(infoVO.getFirePoint()) ? centerdataTCamera.getLatitude() : infoVO.getFirePoint()[0].getGpsY();
|
|
|
+ String reportor = infoVO.getDeviceName();
|
|
|
+ Date reportTime = DateUtils.timestampToTime(infoVO.getAlarmDate());
|
|
|
String address = centerdataTCamera.getCameraRegion();
|
|
|
CentereventTEventcatalogue centereventTEventcatalogue = new CentereventTEventcatalogue("1", null, eventName, eventDescription, longitude, latitude, reportor, reportTime, address);
|
|
|
centereventTEventcatalogue = this.insertEventCatalogue(centereventTEventcatalogue, centerdataTCamera, daHuaFireEventVO.getCreateTime());
|
|
@@ -264,8 +316,8 @@ public class AlarmEventServiceImpl implements AlarmEventService {
|
|
|
this.insertEventDept(centereventTEventcatalogue, listDept);
|
|
|
// 事件日志
|
|
|
String logId = this.insertEventLog(centereventTEventcatalogue);
|
|
|
- if (StringUtils.isNotBlank(daHuaFireEventVO.getInfo().getPicture())) {
|
|
|
- String[] pictures = daHuaFireEventVO.getInfo().getPicture().split(",");
|
|
|
+ if (StringUtils.isNotBlank(infoVO.getPicture())) {
|
|
|
+ String[] pictures = infoVO.getPicture().split(",");
|
|
|
for (String picture : pictures) {
|
|
|
CenterdataTAttach tAttach = new CenterdataTAttach();
|
|
|
tAttach.setBusId(logId);
|
|
@@ -279,6 +331,55 @@ public class AlarmEventServiceImpl implements AlarmEventService {
|
|
|
return centereventTEventcatalogue.getEventCode();
|
|
|
}
|
|
|
|
|
|
+ private String insertBayonetEvent(DaHuaFireEventVO daHuaFireEventVO) {
|
|
|
+ BayonetInfoVO infoVO = JSONObject.parseObject(JSON.toJSONString(daHuaFireEventVO.getInfo()), BayonetInfoVO.class);
|
|
|
+ // 验证是否配置摄像头
|
|
|
+ List<CenterdataTCamera> centerdataTCameras = SpringUtils.getBean(RemoteMonitorService.class).selectCameraByDepIdGong(new CenterdataTCamera(null, infoVO.getDeviceName())).getData();
|
|
|
+ if (StringUtils.isEmpty(centerdataTCameras) || 1 != centerdataTCameras.size()) {
|
|
|
+ logger.info("无法匹配相关设备!摄像头为:{}", infoVO.getDeviceName());
|
|
|
+ return "";
|
|
|
+ }
|
|
|
+ // 验证是否配置指挥中心
|
|
|
+ CenterdataTCamera centerdataTCamera = centerdataTCameras.get(0);
|
|
|
+ List<CenterdataTAidevicedept> listDept = SpringUtils.getBean(RemoteMonitorService.class).listForCommandCenter(centerdataTCamera.getId(), "1", "1").getData();
|
|
|
+ if (StringUtils.isEmpty(listDept)) {
|
|
|
+ logger.info(ERROR_MSG_DEPT, centerdataTCamera.getCameraCode());
|
|
|
+ return "";
|
|
|
+ }
|
|
|
+ // 验证事件类型是否配置对应报文码值--只能从数据库配
|
|
|
+ CentereventTEventtype centereventTEventtype = centereventTEventtypeService.selectCentereventTEventtypeByCode(infoVO.getAlarmType());
|
|
|
+ if (StringUtils.isNull(centereventTEventtype)) {
|
|
|
+ logger.info("无法匹配相关事件!报文码值为:{}", infoVO.getAlarmType());
|
|
|
+ return "";
|
|
|
+ }
|
|
|
+ // 事件目录
|
|
|
+ String eventType = centereventTEventtype.getParentId();
|
|
|
+ String eventTypeXl = centereventTEventtype.getId();
|
|
|
+ String eventName = infoVO.getChannelName() + DateUtils.parseDateToStr(YYYY_MM_DD_HH_MM_SS, new Date(infoVO.getAlarmDate() * 1000)) + centereventTEventtype.getEventTypeName();
|
|
|
+ String eventDescription = infoVO.toString(centerdataTCamera);
|
|
|
+ String longitude = centerdataTCamera.getLongitude();
|
|
|
+ String latitude = centerdataTCamera.getLatitude();
|
|
|
+ String reportor = centerdataTCamera.getCameraName();
|
|
|
+ Date reportTime = DateUtils.timestampToTime(infoVO.getAlarmDate() * 1000);
|
|
|
+ String address = centerdataTCamera.getCameraRegion();
|
|
|
+ CentereventTEventcatalogue centereventTEventcatalogue = new CentereventTEventcatalogue(eventType, eventTypeXl, eventName, eventDescription, longitude, latitude, reportor, reportTime, address);
|
|
|
+ centereventTEventcatalogue = this.insertEventCatalogue(centereventTEventcatalogue, centerdataTCamera, daHuaFireEventVO.getCreateTime());
|
|
|
+ // 事件部门
|
|
|
+ this.insertEventDept(centereventTEventcatalogue, listDept);
|
|
|
+ // 事件日志
|
|
|
+ String logId = this.insertEventLog(centereventTEventcatalogue);
|
|
|
+ if (StringUtils.isNotBlank(infoVO.getAlarmPicture())) {
|
|
|
+ CenterdataTAttach tAttach = new CenterdataTAttach();
|
|
|
+ tAttach.setBusId(logId);
|
|
|
+ tAttach.setAttachPath(infoVO.getAlarmPicture());
|
|
|
+ tAttach.setBusIndx(BUS_INDEX_2);
|
|
|
+ tAttach.setBusSource("DH_1");
|
|
|
+ tAttach.setFileType(FILE_TYPE_1);
|
|
|
+ remoteDataService.insertAttach(tAttach);
|
|
|
+ }
|
|
|
+ return centereventTEventcatalogue.getEventCode();
|
|
|
+ }
|
|
|
+
|
|
|
@Override
|
|
|
public String updateFireEventImage(DaHuaEventBO eventBO) throws ClientException {
|
|
|
// 通过eventCode查询详情
|
|
@@ -322,6 +423,7 @@ public class AlarmEventServiceImpl implements AlarmEventService {
|
|
|
return "请刷新后重试";
|
|
|
}
|
|
|
|
|
|
+ @Transactional
|
|
|
@Override
|
|
|
public String insertDaHuaOtherEvent(DaHuaOtherEventVO daHuaOtherEventVO) {
|
|
|
// 验证是否配置摄像头通道
|
|
@@ -345,7 +447,7 @@ public class AlarmEventServiceImpl implements AlarmEventService {
|
|
|
// 事件目录
|
|
|
String eventType = centereventTEventtype.getParentId();
|
|
|
String eventTypeXl = centereventTEventtype.getId();
|
|
|
- String eventName = centerdataTCamera.getCameraName() + DateUtils.parseDateToStr(YYYY_MM_DD_HH_MM_SS, DateUtils.timestampToTime(daHuaOtherEventVO.getOccurrenceTime())) + daHuaOtherEventVO.getAlarmName();
|
|
|
+ String eventName = centerdataTCamera.getCameraName() + DateUtils.parseDateToStr(YYYY_MM_DD_HH_MM_SS, DateUtils.timestampToTime(daHuaOtherEventVO.getOccurrenceTime())) + centereventTEventtype.getEventTypeName();
|
|
|
String eventDescription = daHuaOtherEventVO.toString();
|
|
|
String longitude = daHuaOtherEventVO.getLongitude();
|
|
|
String latitude = daHuaOtherEventVO.getLatitude();
|
|
@@ -375,6 +477,120 @@ public class AlarmEventServiceImpl implements AlarmEventService {
|
|
|
|
|
|
@Transactional
|
|
|
@Override
|
|
|
+ public String insertTowerEvent(TowerEventVo towerEventVo) {
|
|
|
+ // 验证是否配置摄像头
|
|
|
+ CenterdataTCamera centerdataTCamera = SpringUtils.getBean(RemoteMonitorService.class).getCameraByChinaTowerDeviceCode(towerEventVo.getDeviceCode());
|
|
|
+ if (StringUtils.isNull(centerdataTCamera)) {
|
|
|
+ logger.info("无法匹配相关设备!铁塔摄像头为:{}", towerEventVo.getDeviceCode());
|
|
|
+ return "";
|
|
|
+ }
|
|
|
+ // 验证是否配置指挥中心
|
|
|
+ List<CenterdataTAidevicedept> listDept = SpringUtils.getBean(RemoteMonitorService.class).listForCommandCenter(centerdataTCamera.getId(), "1", "1").getData();
|
|
|
+ if (StringUtils.isEmpty(listDept)) {
|
|
|
+ logger.info(ERROR_MSG_DEPT, towerEventVo.getDeviceCode());
|
|
|
+ return "";
|
|
|
+ }
|
|
|
+ // 验证事件类型是否配置对应报文码值--只能从数据库配
|
|
|
+ CentereventTEventtype centereventTEventtype = centereventTEventtypeService.selectCentereventTEventtypeByCodeTower(towerEventVo.getAlarmType());
|
|
|
+ if (StringUtils.isNull(centereventTEventtype)) {
|
|
|
+ logger.info("无法匹配相关事件!报文码值为:{}", towerEventVo.getAlarmType());
|
|
|
+ return "";
|
|
|
+ }
|
|
|
+ // 事件目录
|
|
|
+ String eventType = centereventTEventtype.getParentId();
|
|
|
+ String eventTypeXl = centereventTEventtype.getId();
|
|
|
+ String eventName = towerEventVo.getDeviceName() + DateUtils.parseDateToStr(YYYY_MM_DD_HH_MM_SS, towerEventVo.getAlarmTime()) + centereventTEventtype.getEventTypeName();
|
|
|
+ String eventDescription = towerEventVo.toString();
|
|
|
+ String longitude = towerEventVo.getEventLongitude();
|
|
|
+ String latitude = towerEventVo.getEventLatitude();
|
|
|
+ String reportor = towerEventVo.getDeviceName();
|
|
|
+ Date reportTime = towerEventVo.getAlarmTime();
|
|
|
+ String address = towerEventVo.getAddress();
|
|
|
+ CentereventTEventcatalogue centereventTEventcatalogue = new CentereventTEventcatalogue(eventType, eventTypeXl, eventName, eventDescription, longitude, latitude, reportor, reportTime, address);
|
|
|
+ centereventTEventcatalogue = this.insertEventCatalogue(centereventTEventcatalogue, centerdataTCamera, null);
|
|
|
+ // 事件部门
|
|
|
+ this.insertEventDept(centereventTEventcatalogue, listDept);
|
|
|
+ // 事件日志
|
|
|
+ String logId = this.insertEventLog(centereventTEventcatalogue);
|
|
|
+ String orderCode = SpringUtils.getBean(RemoteMonitorService.class).getOrderCodeByChinaTowerDeviceCode(towerEventVo.getDeviceCode());
|
|
|
+ if (StringUtils.isNotBlank(towerEventVo.getOriginalPictureUrl())) {
|
|
|
+ String[] pictures = towerEventVo.getOriginalPictureUrl().split(",");
|
|
|
+ for (String picture : pictures) {
|
|
|
+ CenterdataTAttach tAttach = new CenterdataTAttach();
|
|
|
+ tAttach.setBusId(logId);
|
|
|
+ tAttach.setAttachPath(GWHttpUtilsTest65.encrypt(picture, orderCode));
|
|
|
+ tAttach.setBusIndx(BUS_INDEX_2);
|
|
|
+ tAttach.setBusSource("TT_1");
|
|
|
+ tAttach.setFileType(FILE_TYPE_1);
|
|
|
+ remoteDataService.insertAttach(tAttach);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotBlank(towerEventVo.getAlarmPictureUrl())) {
|
|
|
+ String[] pictures = towerEventVo.getAlarmPictureUrl().split(",");
|
|
|
+ for (String picture : pictures) {
|
|
|
+ CenterdataTAttach tAttach = new CenterdataTAttach();
|
|
|
+ tAttach.setBusId(logId);
|
|
|
+ tAttach.setAttachPath(GWHttpUtilsTest65.encrypt(picture, orderCode));
|
|
|
+ tAttach.setBusIndx(BUS_INDEX_2);
|
|
|
+ tAttach.setBusSource("TT_1");
|
|
|
+ tAttach.setFileType(FILE_TYPE_1);
|
|
|
+ remoteDataService.insertAttach(tAttach);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotBlank(towerEventVo.getAlarmVideoUrl())) {
|
|
|
+ CenterdataTAttach tAttach = new CenterdataTAttach();
|
|
|
+ tAttach.setBusId(logId);
|
|
|
+ tAttach.setAttachPath(GWHttpUtilsTest65.encrypt(towerEventVo.getAlarmVideoUrl(), orderCode));
|
|
|
+ tAttach.setBusIndx(BUS_INDEX_2);
|
|
|
+ tAttach.setBusSource("TT_1");
|
|
|
+ tAttach.setFileType(FILE_TYPE_2);
|
|
|
+ remoteDataService.insertAttach(tAttach);
|
|
|
+ }
|
|
|
+ return centereventTEventcatalogue.getEventCode();
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public String updateFireEventImage(TowerEventVo towerEventVo, String logId) {
|
|
|
+ List<CenterdataTAttach> attachList = new ArrayList<>();
|
|
|
+ String orderCode = SpringUtils.getBean(RemoteMonitorService.class).getOrderCodeByChinaTowerDeviceCode(towerEventVo.getDeviceCode());
|
|
|
+ if (StringUtils.isNotBlank(towerEventVo.getOriginalPictureUrl())) {
|
|
|
+ String[] pictures = towerEventVo.getOriginalPictureUrl().split(",");
|
|
|
+ for (String picture : pictures) {
|
|
|
+ CenterdataTAttach tAttach = new CenterdataTAttach();
|
|
|
+ tAttach.setBusId(logId);
|
|
|
+ tAttach.setAttachPath(GWHttpUtilsTest65.encrypt(picture, orderCode));
|
|
|
+ tAttach.setBusIndx(BUS_INDEX_2);
|
|
|
+ tAttach.setBusSource("TT_1");
|
|
|
+ tAttach.setFileType(FILE_TYPE_1);
|
|
|
+ attachList.add(tAttach);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotBlank(towerEventVo.getAlarmPictureUrl())) {
|
|
|
+ String[] pictures = towerEventVo.getAlarmPictureUrl().split(",");
|
|
|
+ for (String picture : pictures) {
|
|
|
+ CenterdataTAttach tAttach = new CenterdataTAttach();
|
|
|
+ tAttach.setBusId(logId);
|
|
|
+ tAttach.setAttachPath(GWHttpUtilsTest65.encrypt(picture, orderCode));
|
|
|
+ tAttach.setBusIndx(BUS_INDEX_2);
|
|
|
+ tAttach.setBusSource("TT_1");
|
|
|
+ tAttach.setFileType(FILE_TYPE_1);
|
|
|
+ attachList.add(tAttach);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotBlank(towerEventVo.getAlarmVideoUrl())) {
|
|
|
+ CenterdataTAttach tAttach = new CenterdataTAttach();
|
|
|
+ tAttach.setBusId(logId);
|
|
|
+ tAttach.setAttachPath(GWHttpUtilsTest65.encrypt(towerEventVo.getAlarmVideoUrl(), orderCode));
|
|
|
+ tAttach.setBusIndx(BUS_INDEX_2);
|
|
|
+ tAttach.setBusSource("TT_1");
|
|
|
+ tAttach.setFileType(FILE_TYPE_2);
|
|
|
+ attachList.add(tAttach);
|
|
|
+ }
|
|
|
+ return remoteDataService.delAndInsertBatch(JSON.toJSONString(attachList)).getMsg();
|
|
|
+ }
|
|
|
+
|
|
|
+ @Transactional
|
|
|
+ @Override
|
|
|
public String insertSensorEvent(SensorEventVo sensorEventVo) {
|
|
|
// 验证是否配置指挥中心
|
|
|
List<CenterdataTAidevicedept> listDept = SpringUtils.getBean(RemoteMonitorService.class).listForCommandCenter(sensorEventVo.getSensorId(), "1", "1").getData();
|