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