From 5a6af9762dfb9e3ed75422303a795b2bb8c21885 Mon Sep 17 00:00:00 2001 From: zhanghua <314079846@qq.com> Date: 星期三, 28 九月 2022 17:49:52 +0800 Subject: [PATCH] 市平台接口 --- ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/BaseCaseServiceImpl.java | 70 +++++++++++++++++++++++++++++++++++ 1 files changed, 70 insertions(+), 0 deletions(-) diff --git a/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/BaseCaseServiceImpl.java b/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/BaseCaseServiceImpl.java index f155201..353d583 100644 --- a/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/BaseCaseServiceImpl.java +++ b/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/BaseCaseServiceImpl.java @@ -1,9 +1,17 @@ package com.ycl.service.caseHandler.impl; import com.ycl.entity.caseHandler.BaseCase; +import com.ycl.entity.caseHandler.Violations; +import com.ycl.entity.video.VideoAlarmReport; import com.ycl.mapper.caseHandler.BaseCaseMapper; +import com.ycl.remote.dto.*; +import com.ycl.remote.service.CityPlatformService; import com.ycl.service.caseHandler.IBaseCaseService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ycl.service.caseHandler.IViolationsService; +import com.ycl.service.video.IVideoAlarmReportService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; /** @@ -17,4 +25,66 @@ @Service public class BaseCaseServiceImpl extends ServiceImpl<BaseCaseMapper, BaseCase> implements IBaseCaseService { + private CityPlatformService cityPlatformService; + private IViolationsService violationsService; + private IVideoAlarmReportService videoAlarmReportService; + + @Value("${fdfs.fileUrl}") + private String fileUrl; + + @Autowired + public void setCityPlatformService(CityPlatformService cityPlatformService) { + this.cityPlatformService = cityPlatformService; + } + + @Autowired + public void setViolationsService(IViolationsService violationsService) { + this.violationsService = violationsService; + } + + @Autowired + public void setVideoAlarmReportService(IVideoAlarmReportService videoAlarmReportService) { + this.videoAlarmReportService = videoAlarmReportService; + } + + @Override + public String uploadEvent(Integer caseId) { + BaseCase baseCase = this.getById(caseId); + Violations violations = violationsService.getById(caseId); + String medias = ""; + String eventDesc = ""; + if (violations != null) { + eventDesc = violations.getDescription(); + VideoAlarmReport videoAlarmReport = videoAlarmReportService.getById(violations.getVideoAlarmReportId()); + if (videoAlarmReport != null) { + StringBuilder stringBuilder = new StringBuilder().append("[{'mediaURL':'").append(fileUrl).append(videoAlarmReport.getPicData()).append("'}]"); + medias = stringBuilder.toString(); + } + } + EventAddParamDto dto = EventAddParamDto.builder().y84(baseCase.getLatitude().toString()).x84(baseCase.getLongitude().toString()) + .source(11).address(baseCase.getSite()).eventDesc(eventDesc).eventSign(baseCase.getCode()).medias(medias).build(); + ResultResponseDto<EventAddResponseDto> result = cityPlatformService.addEvent(dto); + if (result.getCode() == 0) { + EventAddResponseDto responseDto = result.getResult(); + baseCase.setTaskCode(responseDto.getTaskcode()); + this.updateById(baseCase); + return null; + } else { + return result.getMsg(); + } + } + + @Override + public String processEvent(Integer caseId) { + BaseCase baseCase = this.getById(caseId); + EventProcessParamDto paramDto = EventProcessParamDto.builder().eventSign(baseCase.getCode()).taskcode(baseCase.getTaskCode()).build(); + ResultResponseDto<EventProcessResponseDto> responseDto = cityPlatformService.getEventProcess(paramDto); + if (responseDto.getCode() == 0) { + EventProcessResponseDto eventProcessResponseDto = responseDto.getResult(); + /*********** 鏈鐞嗗競骞冲彴杩斿洖鏁版嵁 ***************/ + return null; + } else { + return responseDto.getMsg(); + } + } } -- Gitblit v1.8.0