|
@@ -223,7 +223,9 @@ public class UserIncrementServiceImpl extends ServiceImpl<IUserIncrementMapper,
|
|
wrapper.setSql("download_num_total = download_num_total + " + param.getCount() * incrementType.getDownloadNum());
|
|
wrapper.setSql("download_num_total = download_num_total + " + param.getCount() * incrementType.getDownloadNum());
|
|
userService.update(wrapper);
|
|
userService.update(wrapper);
|
|
|
|
|
|
- Set<Long> cameraIds = userIncrementList.stream().map(UserIncrement::getCameraId).filter(Objects::nonNull).collect(Collectors.toSet());
|
|
|
|
|
|
+ Set<Long> ids = userIncrementList.stream().map(UserIncrement::getId).collect(Collectors.toSet());
|
|
|
|
+ List<UserIncrement> userIncrements = this.listByIds(ids);
|
|
|
|
+ Set<Long> cameraIds = userIncrements.stream().map(UserIncrement::getCameraId).filter(Objects::nonNull).collect(Collectors.toSet());
|
|
for (Long cameraId : cameraIds) {
|
|
for (Long cameraId : cameraIds) {
|
|
if(cameraId != null){
|
|
if(cameraId != null){
|
|
sceneProService.lockOrUnLockBySpace(cameraId);
|
|
sceneProService.lockOrUnLockBySpace(cameraId);
|