局域网版绑定相机，解绑相机

src/main/java/com/fdkankan/ucenter/service/IUserIncrementService.java

@@ -37,4 +37,8 @@ public interface IUserIncrementService extends IService<UserIncrement> {
     void incrementExpire();
 
     void incrementExpireSendSms() throws Exception;
+
+    void addByCameraAndUser(List<Long> cameraIds, Long id);
+
+    void delByCameraId(List<Long> cameraIds);
 }

src/main/java/com/fdkankan/ucenter/service/impl/CameraDetailServiceImpl.java

@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.fdkankan.common.constant.Constant;
+import com.fdkankan.ucenter.common.constants.NacosProperty;
 import com.fdkankan.ucenter.entity.*;
 import com.fdkankan.ucenter.httpClient.service.LaserService;
 import com.fdkankan.ucenter.mapper.ICameraDetailMapper;
@@ -111,7 +112,9 @@ public class CameraDetailServiceImpl extends ServiceImpl<ICameraDetailMapper, Ca
             wrapper.set(CameraDetail::getTotalSpace,Long.parseLong(Constant.EXPANSION_SPACE_VALUE_1G ) * 10L);
             this.update(wrapper);
             cameraDetail.setTotalSpace(Long.parseLong(Constant.EXPANSION_SPACE_VALUE_1G ) * 10L);
-            sceneProService.lockOrUnLockBySpace(cameraDetail,cameraDetail.getCameraId(),-2);     //封存场景
+            if(!"local".equals(NacosProperty.uploadType)){
+                sceneProService.lockOrUnLockBySpace(cameraDetail,cameraDetail.getCameraId(),-2);     //封存场景
+            }
         }
         //恢复10G基本容量
 

src/main/java/com/fdkankan/ucenter/service/impl/CameraServiceImpl.java

@@ -8,6 +8,7 @@ import com.fdkankan.common.exception.BusinessException;
 import com.fdkankan.ucenter.common.PageInfo;
 import com.fdkankan.common.util.DateUtil;
 import com.fdkankan.common.util.FileSizeUtil;
+import com.fdkankan.ucenter.common.constants.NacosProperty;
 import com.fdkankan.ucenter.constant.CameraConstant;
 import com.fdkankan.ucenter.constant.LoginConstant;
 import com.fdkankan.ucenter.constant.OrderConstant;
@@ -232,7 +233,7 @@ public class CameraServiceImpl extends ServiceImpl<ICameraMapper, Camera> implem
             cameraIds.add(Long.valueOf(id));
         }
         userIncrementService.unbindCamera(cameraIds);                   //取消关联用户权益
-        cameraDetailService.unbindCamera(cameraIds);                     //取消相机用户关联
+        cameraDetailService.unbindCamera(cameraIds);                    //取消相机用户关联
         sceneService.bindOrUnCamera(cameraIds,null);                //取消关联场景
         sceneProService.bindOrUnCamera(cameraIds,null);             //取消关联场景
         scenePlusService.bindOrUnCamera(cameraIds,null);            //取消关联场景
@@ -270,6 +271,10 @@ public class CameraServiceImpl extends ServiceImpl<ICameraMapper, Camera> implem
         sceneService.bindOrUnCamera(cameraIds,user.getId());
         sceneProService.bindOrUnCamera(cameraIds,user.getId());
         scenePlusService.bindOrUnCamera(cameraIds,user.getId());
+
+        if("local".equals(NacosProperty.uploadType)){   //局域网绑定相机，添加权益
+            userIncrementService.addByCameraAndUser(cameraIds,user.getId());
+        }
     }
 
     @Override

src/main/java/com/fdkankan/ucenter/service/impl/UserIncrementServiceImpl.java

@@ -139,10 +139,17 @@ public class UserIncrementServiceImpl extends ServiceImpl<IUserIncrementMapper,
 
     @Override
     public void unbindCamera(List<Long> cameraIds) {
-        LambdaUpdateWrapper<UserIncrement> wrapper = new LambdaUpdateWrapper<>();
-        wrapper.set(UserIncrement::getCameraId,null)
-                .in(UserIncrement::getCameraId,cameraIds);
-        this.update(wrapper);
+        if(cameraIds.size() >0){
+            LambdaUpdateWrapper<UserIncrement> wrapper = new LambdaUpdateWrapper<>();
+            wrapper.in(UserIncrement::getCameraId,cameraIds);
+            if("local".equals(NacosProperty.uploadType)){
+                this.remove(wrapper);
+            }else {
+                wrapper.set(UserIncrement::getCameraId,null);
+                this.update(wrapper);
+            }
+        }
+
     }
 
 
@@ -338,4 +345,28 @@ public class UserIncrementServiceImpl extends ServiceImpl<IUserIncrementMapper,
         }
     }
 
+    @Override
+    public void addByCameraAndUser(List<Long> cameraIds, Long userId) {
+        this.delByCameraId(cameraIds);
+        for (Long cameraId : cameraIds) {
+            UserIncrement userIncrement = new UserIncrement();
+            userIncrement.setKeyWord(UUID.randomUUID().toString().replace("-", ""));
+            userIncrement.setIsExpired(0);
+            userIncrement.setIncrementStartTime(DateUserUtil.getDate(new Date()));
+            userIncrement.setCameraId(cameraId);
+            userIncrement.setIncrementTypeId(1);
+            userIncrement.setIncrementEndTime("2199-01-01 00:00:00");
+            userIncrement.setUserId(userId);
+            this.save(userIncrement);
+        }
+    }
+
+    @Override
+    public void delByCameraId(List<Long> cameraIds) {
+        if(cameraIds.size() >0){
+            LambdaQueryWrapper<UserIncrement> wrapper = new LambdaQueryWrapper<>();
+            wrapper.in(UserIncrement::getCameraId,cameraIds);
+            this.remove(wrapper);
+        }
+    }
 }