|
@@ -3,10 +3,13 @@ package com.fdkankan.ucenter.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
|
+import com.fdkankan.common.constant.AppConstant;
|
|
import com.fdkankan.common.exception.BusinessException;
|
|
import com.fdkankan.common.exception.BusinessException;
|
|
import com.fdkankan.ucenter.common.PageInfo;
|
|
import com.fdkankan.ucenter.common.PageInfo;
|
|
import com.fdkankan.common.util.DateUtil;
|
|
import com.fdkankan.common.util.DateUtil;
|
|
import com.fdkankan.common.util.FileSizeUtil;
|
|
import com.fdkankan.common.util.FileSizeUtil;
|
|
|
|
+import com.fdkankan.ucenter.constant.CameraConstant;
|
|
|
|
+import com.fdkankan.ucenter.constant.OrderConstant;
|
|
import com.fdkankan.ucenter.entity.*;
|
|
import com.fdkankan.ucenter.entity.*;
|
|
import com.fdkankan.ucenter.httpClient.service.LaserService;
|
|
import com.fdkankan.ucenter.httpClient.service.LaserService;
|
|
import com.fdkankan.ucenter.mapper.ICameraMapper;
|
|
import com.fdkankan.ucenter.mapper.ICameraMapper;
|
|
@@ -231,7 +234,26 @@ public class CameraServiceImpl extends ServiceImpl<ICameraMapper, Camera> implem
|
|
LambdaUpdateWrapper<Camera> wrapper = new LambdaUpdateWrapper<>();
|
|
LambdaUpdateWrapper<Camera> wrapper = new LambdaUpdateWrapper<>();
|
|
wrapper.in(Camera::getSnCode,snCodeList);
|
|
wrapper.in(Camera::getSnCode,snCodeList);
|
|
List<Camera> list = this.list(wrapper);
|
|
List<Camera> list = this.list(wrapper);
|
|
- List<Long> cameraIds = list.parallelStream().map(Camera::getId).collect(Collectors.toList());
|
|
|
|
|
|
+ if(list.size() <=0){
|
|
|
|
+ throw new BusinessException(AppConstant.FAILURE_CODE_4010, snCodes +"-"+ AppConstant.FAILURE_MSG_4010);
|
|
|
|
+ }
|
|
|
|
+ List<String> dbSnCode = list.stream().map(Camera::getSnCode).collect(Collectors.toList());
|
|
|
|
+ for (String code : snCodeList) {
|
|
|
|
+ if(!dbSnCode.contains(code)){
|
|
|
|
+ throw new BusinessException(AppConstant.FAILURE_CODE_4010, code +"-"+ AppConstant.FAILURE_MSG_4010);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ HashMap<Long ,Camera> cameraHashMap = new HashMap<>();
|
|
|
|
+ list.forEach(camera -> cameraHashMap.put(camera.getId(),camera));
|
|
|
|
+ List<Long> cameraIds = list.stream().map(Camera::getId).collect(Collectors.toList());
|
|
|
|
+ HashMap<Long, CameraDetail> detailHashMap = cameraDetailService.getByCameraIds(cameraIds);
|
|
|
|
+ for (Long cameraId : detailHashMap.keySet()) {
|
|
|
|
+ CameraDetail detail = detailHashMap.get(cameraId);
|
|
|
|
+ if(detail.getUserId() != null){
|
|
|
|
+ throw new BusinessException(CameraConstant.FAILURE_CODE_6010, cameraHashMap.get(cameraId).getSnCode() +"-"+ CameraConstant.FAILURE_MSG_6010);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
cameraDetailService.bindCamera(cameraIds,user.getId());
|
|
cameraDetailService.bindCamera(cameraIds,user.getId());
|
|
sceneService.bindOrUnCamera(cameraIds,user.getId());
|
|
sceneService.bindOrUnCamera(cameraIds,user.getId());
|
|
sceneProService.bindOrUnCamera(cameraIds,user.getId());
|
|
sceneProService.bindOrUnCamera(cameraIds,user.getId());
|