From 1c732150ad5e8b21efff07ecd923c4ff8fda60c1 Mon Sep 17 00:00:00 2001 From: zhanghua <314079846@qq.com> Date: 星期二, 05 九月 2023 20:47:41 +0800 Subject: [PATCH] 100路视频 --- ycl-platform/src/main/java/com/ycl/controller/caseHandler/BaseCaseController.java | 183 +++++++++++++++++++++++++++++++++++---------- 1 files changed, 140 insertions(+), 43 deletions(-) diff --git a/ycl-platform/src/main/java/com/ycl/controller/caseHandler/BaseCaseController.java b/ycl-platform/src/main/java/com/ycl/controller/caseHandler/BaseCaseController.java index 569df4d..139f112 100644 --- a/ycl-platform/src/main/java/com/ycl/controller/caseHandler/BaseCaseController.java +++ b/ycl-platform/src/main/java/com/ycl/controller/caseHandler/BaseCaseController.java @@ -1,11 +1,15 @@ package com.ycl.controller.caseHandler; +import cn.hutool.core.collection.CollUtil; +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.ycl.annotation.LogSave; import com.ycl.api.CommonResult; +import com.ycl.bo.AdminUserDetails; import com.ycl.controller.BaseController; import com.ycl.common.constant.BaseCaseStatus; import com.ycl.common.util.UtilNumber; @@ -16,10 +20,14 @@ import com.ycl.entity.caseHandler.BaseCase; import com.ycl.entity.caseHandler.BaseCaseDetail; import com.ycl.entity.caseHandler.DisposeRecord; +import com.ycl.entity.resources.ImageResources; +import com.ycl.entity.resources.VideoResources; import com.ycl.service.caseHandler.IBaseCaseService; import com.ycl.service.caseHandler.IDisposeRecordService; import com.ycl.service.caseHandler.IIllegalBuildingService; import com.ycl.service.caseHandler.IViolationsService; +import com.ycl.service.resources.IImageResourcesService; +import com.ycl.service.resources.IVideoResourcesService; import com.ycl.utils.EasyExcelUtils; import com.ycl.vo.casePool.QueryForViolationVO; import io.swagger.annotations.Api; @@ -28,6 +36,7 @@ import io.swagger.annotations.ApiOperation; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.security.core.context.SecurityContextHolder; import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; @@ -64,6 +73,12 @@ @Autowired UtilNumber utilNumber; + @Autowired + IImageResourcesService iImageResourcesService; + + @Autowired + IVideoResourcesService iVideoResourcesService; + @Autowired public void setBaseCaseService(IBaseCaseService baseCaseService) { @@ -71,11 +86,11 @@ } @ApiOperation(value = "涓婁紶甯傚钩鍙�") - @PostMapping("/upload-event") - public CommonResult uploadEvent(@RequestParam Long caseId, CommonResult<Object> success) { + @PostMapping("/upload-event/{caseId}") + public CommonResult uploadEvent(@PathVariable Long caseId) { String msg = baseCaseService.uploadEvent(caseId); if (StringUtils.isEmpty(msg)) { - return success; + return CommonResult.success(msg); } else { return CommonResult.failed(msg); } @@ -113,7 +128,6 @@ } return CommonResult.failed("request parameter is null"); }*/ - @ApiOperation(value = "鏌ヨ杩濊杩濆缓") @GetMapping("/query") @ApiImplicitParams({ @@ -131,8 +145,8 @@ }) public CommonResult searchViolation(@RequestParam Integer size, @RequestParam Integer current, - @RequestParam Integer state, - @RequestParam(required = false) Integer type, + @RequestParam(required = false) Integer state, + @RequestParam Integer type, @RequestParam(required = false) Integer resource, @RequestParam(required = false) String code, @RequestParam(required = false) String categoryBig, @@ -140,21 +154,19 @@ @RequestParam(required = false) Integer street, @RequestParam(required = false) String site, @RequestParam(required = false) String startTime, - @RequestParam(required = false) String endTime ){ - if (state != null) { - Page<Object> queryList; - Integer violation = 1; - Integer illegalBuilding = 2; - if (type == violation) { - queryList = baseCaseService.listViolationsPage(new Page<>().setCurrent(current).setSize(size), state, resource, code, categoryBig, categorySmall, street, site, startTime, endTime); - } else if (type == illegalBuilding) { - queryList = baseCaseService.listIllegalBuilding(new Page<>().setCurrent(current).setSize(size), state, resource); - } else { - return CommonResult.failed("bad request url"); - } - return CommonResult.success(queryList); + @RequestParam(required = false) String endTime, + @RequestParam(required = false) Integer violationsTypeId, + @RequestParam(required = false) Integer videoId) { + + Page<Object> queryList; + if (type == 1) { + queryList = baseCaseService.listViolationsPage(current, size, state, resource, code, categoryBig, categorySmall, street, site, startTime, endTime, violationsTypeId, videoId); + } else if (type == 2) { + queryList = baseCaseService.listIllegalBuilding(current, size, state, resource); + } else { + return CommonResult.failed("bad request url"); } - return CommonResult.failed("request parameter is null"); + return CommonResult.success(queryList); } /** @@ -214,7 +226,7 @@ **/ @ApiOperation(value = "娣诲姞杩濊妗堜欢") @PostMapping("/addition_violation") - @LogSave(operationType = "浜嬮」澶勭疆绠$悊", contain = "鏂板杩濆缓妗堜欢") + @LogSave(operationType = "浜嬮」澶勭疆绠$悊", contain = "鏂板杩濊妗堜欢") public CommonResult addViolationCase(@RequestBody @Validated ViolationParam violationParam) { Integer violation = 1; Integer resource = 2; @@ -227,6 +239,34 @@ baseCase.setAlarmTime(LocalDateTime.parse(violationParam.getAlarmTime(), DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); baseCase.setCreateTime(LocalDateTime.now()); baseCaseService.save(baseCase); + // JSONArray arr = JSON.parseArray(baseCase.getPic()); + AdminUserDetails user = (AdminUserDetails) SecurityContextHolder.getContext().getAuthentication().getPrincipal(); + + if (CollUtil.isNotEmpty(violationParam.getImageUrls())) { + for (int i = 0; i < violationParam.getImageUrls().size(); i++) { + ImageResources imageResources = new ImageResources(); + imageResources.setType("01"); + imageResources.setBelongToId(baseCase.getId()); + imageResources.setUrl(violationParam.getImageUrls().get(i)); + imageResources.setCreateTime(LocalDateTime.now()); + imageResources.setCreateUser(user.getUserId()); + iImageResourcesService.save(imageResources); + } + } + + if (CollUtil.isNotEmpty(violationParam.getVideoUrls())) { + VideoResources videoResources = new VideoResources(); + videoResources.setCreateTime(LocalDateTime.now()); + videoResources.setType("1"); + videoResources.setCreateUser(user.getUserId()); + videoResources.setBelongToId(baseCase.getId().intValue()); + StringBuilder sb1 = new StringBuilder(""); + violationParam.getImageUrls().forEach(item -> { + sb1.append(",").append(item); + }); + videoResources.setUrl(sb1.substring(1, sb1.length() - 1)); + iVideoResourcesService.save(videoResources); + } return CommonResult.success(baseCaseService.saveViolationCase(violationParam, baseCase.getId())); } @@ -237,7 +277,7 @@ **/ @ApiOperation(value = "娣诲姞杩濆缓妗堜欢") @PostMapping("/addition_illegal_building") - @LogSave(operationType = "浜嬮」澶勭疆绠$悊", contain = "鏂板杩濊妗堜欢") + @LogSave(operationType = "浜嬮」澶勭疆绠$悊", contain = "鏂板杩濆缓妗堜欢") public CommonResult addIllegalBuildingCase(@RequestBody @Validated IllegalBuildingParam illegalBuildingParam) { Integer illegalBuilding = 2; Integer resource = 2; @@ -250,6 +290,49 @@ baseCase.setAlarmTime(LocalDateTime.parse(illegalBuildingParam.getAlarmTime(), DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); baseCase.setCreateTime(LocalDateTime.now()); baseCaseService.save(baseCase); + + // if (CollUtil.isNotEmpty(illegalBuildingParam.getImageUrls())) { + // ImageResources imageResources = new ImageResources(); + // imageResources.setCreateTime(LocalDateTime.now()); + // imageResources.setType("1"); + // AdminUserDetails user = (AdminUserDetails) SecurityContextHolder.getContext().getAuthentication().getPrincipal(); + // imageResources.setCreateUser(user.getUserId()); + // imageResources.setBelongToId(baseCase.getId()); + // StringBuilder sb1 = new StringBuilder(""); + // illegalBuildingParam.getImageUrls().forEach(item -> { + // sb1.append(",").append(item); + // }); + // imageResources.setUrl(sb1.substring(1, sb1.length() - 1)); + // imageResourcesService.save(imageResources); + // } + + AdminUserDetails user = (AdminUserDetails) SecurityContextHolder.getContext().getAuthentication().getPrincipal(); + if (CollUtil.isNotEmpty(illegalBuildingParam.getImageUrls())) { + for (int i = 0; i < illegalBuildingParam.getImageUrls().size(); i++) { + ImageResources imageResources = new ImageResources(); + imageResources.setType("01"); + imageResources.setBelongToId(baseCase.getId()); + imageResources.setUrl(illegalBuildingParam.getImageUrls().get(i)); + imageResources.setCreateTime(LocalDateTime.now()); + imageResources.setCreateUser(user.getUserId()); + iImageResourcesService.save(imageResources); + } + } + + if (CollUtil.isNotEmpty(illegalBuildingParam.getVideoUrls())) { + VideoResources videoResources = new VideoResources(); + videoResources.setCreateTime(LocalDateTime.now()); + videoResources.setType("01"); + user = (AdminUserDetails) SecurityContextHolder.getContext().getAuthentication().getPrincipal(); + videoResources.setCreateUser(user.getUserId()); + videoResources.setBelongToId(baseCase.getId().intValue()); + StringBuilder sb2 = new StringBuilder(""); + illegalBuildingParam.getImageUrls().forEach(item -> { + sb2.append(",").append(item); + }); + videoResources.setUrl(sb2.substring(1, sb2.length() - 1)); + iVideoResourcesService.save(videoResources); + } return CommonResult.success(baseCaseService.saveIllegalBuildingCase(illegalBuildingParam, baseCase.getId())); } @@ -316,18 +399,18 @@ @ApiOperation(value = "璋冨害绠$悊-鎵归噺鍒犻櫎") @DeleteMapping("/batch_case_delete") - public CommonResult batchCaseDelete(@RequestParam List<Long> ids){ + public CommonResult batchCaseDelete(@RequestParam List<Long> ids) { ids.forEach( - item->{ - BaseCase baseCase = baseCaseService.getOne(new LambdaQueryWrapper<BaseCase>().eq(BaseCase::getId, item)); - if (baseCase.getCategory()==1){ - violationsService.removeById(item); - baseCaseService.removeById(item); - }else { - illegalBuildingService.removeById(item); - baseCaseService.removeById(item); + item -> { + BaseCase baseCase = baseCaseService.getOne(new LambdaQueryWrapper<BaseCase>().eq(BaseCase::getId, item)); + if (baseCase.getCategory() == 1) { + violationsService.removeById(item); + baseCaseService.removeById(item); + } else { + illegalBuildingService.removeById(item); + baseCaseService.removeById(item); + } } - } ); return CommonResult.success("success"); } @@ -361,15 +444,18 @@ @ApiOperation(value = "鏌ヨ妗堝嵎") @GetMapping("/query_case") - public CommonResult queryCase(@RequestParam Integer pageSize, - @RequestParam Integer current, - @RequestParam(required = false) String number, - @RequestParam(required = false) Integer communityId, - @RequestParam(required = false) Integer categories, - @RequestParam(required = false) String startTime, - @RequestParam(required = false) String endTime, - @RequestParam(required = false) String site) { - return CommonResult.success(baseCaseService.selectPage(new Page<BaseCase>().setCurrent(current).setSize(pageSize), number, communityId, categories, startTime, endTime, site)); + public CommonResult<Page<BaseCase>> queryCase(@RequestParam Integer pageSize, + @RequestParam Integer current, + @RequestParam(required = false) String number, + @RequestParam(required = false) Integer communityId, + @RequestParam(required = false) Integer categories, + @RequestParam(required = false) String startTime, + @RequestParam(required = false) String endTime, + @RequestParam(required = false) Integer state, + @RequestParam(required = false) Integer time, + @RequestParam(required = false) Integer streetId, + @RequestParam(required = false) String site) { + return CommonResult.success(baseCaseService.selectPage(new Page<BaseCase>().setCurrent(current).setSize(pageSize), number, communityId, categories, startTime, endTime, site, state, streetId, time)); } @GetMapping("/query_for_violation") @@ -387,8 +473,19 @@ @GetMapping("/video_inspection") @ApiOperation("棰勮鐮斿垽") - public CommonResult searchVideoInspection(@RequestParam Integer current) { - return CommonResult.success(baseCaseService.selectVideoInspection(current)); + public CommonResult searchVideoInspection(@RequestParam Integer current, + @RequestParam Integer pageSize, + @RequestParam(required = false) Long gradeId, + @RequestParam(required = false) Long videoId, + @RequestParam(required = false) String beginTime, + @RequestParam(required = false) String endTime) { + return CommonResult.success(baseCaseService.selectVideoInspection(current, pageSize, gradeId, videoId, beginTime, endTime)); + } + + @GetMapping("/video_inspection/{id}") + @ApiOperation("棰勮鐮斿垽璇︽儏") + public CommonResult getVideoInspection(@PathVariable Long id) { + return CommonResult.success(baseCaseService.getById(id)); } @GetMapping("/video_inspection/Count") -- Gitblit v1.8.0