From 3f9ebf19e687c33287b0eaec64d4564a212f57db Mon Sep 17 00:00:00 2001 From: mg <maokecheng@163.com> Date: 星期三, 12 十月 2022 16:59:57 +0800 Subject: [PATCH] Merge branch 'master' of http://42.193.1.25:9521/r/sccg_server --- ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/ViolationsServiceImpl.java | 42 ++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 40 insertions(+), 2 deletions(-) diff --git a/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/ViolationsServiceImpl.java b/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/ViolationsServiceImpl.java index 8bab837..40f34f5 100644 --- a/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/ViolationsServiceImpl.java +++ b/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/ViolationsServiceImpl.java @@ -1,13 +1,21 @@ package com.ycl.service.caseHandler.impl; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ycl.entity.caseHandler.BaseCase; +import com.ycl.entity.caseHandler.EventSource; +import com.ycl.entity.caseHandler.QuestionCategory; import com.ycl.entity.caseHandler.Violations; import com.ycl.entity.video.VideoAlarmReport; +import com.ycl.entity.video.VideoPoint; import com.ycl.mapper.caseHandler.ViolationsMapper; +import com.ycl.service.caseHandler.IBaseCaseService; import com.ycl.service.caseHandler.IViolationsService; -import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ycl.service.video.impl.IVideoPointService; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import java.time.LocalDateTime; import java.util.List; /** @@ -21,11 +29,41 @@ @Service public class ViolationsServiceImpl extends ServiceImpl<ViolationsMapper, Violations> implements IViolationsService { + private IVideoPointService videoPointService; + private IBaseCaseService baseCaseService; + + @Autowired + public void setVideoPointService(IVideoPointService videoPointService) { + this.videoPointService = videoPointService; + } + @Autowired + public void setBaseCaseService(IBaseCaseService baseCaseService) { + this.baseCaseService = baseCaseService; + } + @Override public void saveFromVideo(List<VideoAlarmReport> videoAlarmReports) { for (VideoAlarmReport videoAlarmReport : videoAlarmReports) { + VideoPoint videoPoint = null; + LambdaQueryWrapper<VideoPoint> queryWrapper = new LambdaQueryWrapper<VideoPoint>().eq(VideoPoint::getPlatResourceId, videoAlarmReport.getPlatResourceId()); + List<VideoPoint> pointList = videoPointService.list(queryWrapper); + if (pointList.size() > 0) { + videoPoint = pointList.get(0); + } + BaseCase baseCase = BaseCase.builder().eventSource(EventSource.VIDEO.getCode()).category(QuestionCategory.VIOLATION.getCode()) + .createTime(LocalDateTime.now()).createUser(0L).state(1).alarmTime(videoAlarmReport.getAlarmTime()).build(); + Violations violations = new Violations(); + if (videoPoint != null) { + baseCase.setLatitude(videoPoint.getLatitude()); + baseCase.setLongitude(videoPoint.getLongitude()); + baseCase.setStreetId(videoPoint.getStreetId()); + baseCase.setCommunityId(videoPoint.getCommunityId()); - BaseCase baseCase = BaseCase.builder().build(); + } + baseCaseService.save(baseCase); + violations.setId(baseCase.getId()); + violations.setVideoAlarmReportId(videoAlarmReport.getId()); + baseMapper.insert(violations); } } } -- Gitblit v1.8.0