iconList = iconBeans.stream().sorted(Comparator.comparing(IconBean::getCount).reversed())
.map(item -> {
return item.getIcon();
}).collect(Collectors.toList());
return iconList;
}
/**
*
保证热点数据安全性，当redis宕机导致热点数据丢失时，可以从文件中读取，恢复到redis
*
* @author dengsixing
* @date 2022/3/3
**/
private void syncHotFromFileToRedis(String num) throws Exception{
String key = String.format(RedisKey.SCENE_HOT_DATA, num);
boolean exist = redisUtil.hasKey(key);
if(exist){
return;
}
String lockKey = String.format(RedisLockKey.LOCK_HOT_DATA_SYNC, num);
boolean lock = redisLockUtil.lock(lockKey, RedisKey.EXPIRE_TIME_1_MINUTE);
if(!lock){
throw new BusinessException(ErrorCode.SYSTEM_BUSY);
}
try{
exist = redisUtil.hasKey(key);
if(exist){
return;
}
String tagsFilePath = String.format(ConstantFilePath.DATABUFFER_FORMAT, num);
String tagsData = FileUtils.readFile(tagsFilePath + "hot.json");
if(StrUtil.isEmpty(tagsData)){
return;
}
JSONObject jsonObject = JSON.parseObject(tagsData);
JSONArray tagsArr = jsonObject.getJSONArray("tags");
if(CollUtil.isEmpty(tagsArr)){
return;
}
Map map = new HashMap<>();
for (Object o : tagsArr) {
JSONObject jo = (JSONObject)o;
map.put(jo.getString("sid"), jo.toJSONString());
}
redisUtil.hmset(key, map);
}finally {
redisLockUtil.unlockLua(lockKey);
}
}
/**
*
保证icons数据安全性，当redis宕机导致icons数据丢失时，可以从文件中读取，恢复到redis
*
* @author dengsixing
* @date 2022/3/3
**/
private void syncIconsFromFileToRedis(String num) throws Exception{
String key = String.format(RedisKey.SCENE_HOT_ICONS, num);
boolean exist = redisUtil.hasKey(key);
if(exist){
return;
}
String lockKey = String.format(RedisLockKey.LOCK_HOT_ICONS_SYNC, num);
boolean lock = redisLockUtil.lock(lockKey, RedisKey.EXPIRE_TIME_1_MINUTE);
if(!lock){
throw new BusinessException(ErrorCode.SYSTEM_BUSY);
}
try{
exist = redisUtil.hasKey(key);
if(exist){
return;
}
String tagsFilePath = String.format(ConstantFilePath.DATABUFFER_FORMAT, num);
String tagsData = FileUtils.readFile(tagsFilePath + "hot.json");
if(StrUtil.isEmpty(tagsData)){
return;
}
JSONObject jsonObject = JSON.parseObject(tagsData);
JSONArray iconArr = jsonObject.getJSONArray("icons");
if(CollUtil.isEmpty(iconArr)){
return;
}
redisUtil.sSet(key, iconArr.toJavaList(String.class).toArray());
}finally {
redisLockUtil.unlockLua(lockKey);
}
}
/**
*
热点数据保存
*
* @author dengsixing
* @date 2022/3/3
**/
private void writeHotJson(String num) throws Exception{
String dataKey = String.format(RedisKey.SCENE_HOT_DATA, num);
Map tagMap = redisUtil.hmget(dataKey);
List tagList = Lists.newArrayList();
tagMap.entrySet().stream().forEach(entry->{
if(StrUtil.isNotEmpty(entry.getValue())){
tagList.add(entry.getValue());
}
});
JSONObject jsonObject = new JSONObject();
JSONArray tagJsonArr = new JSONArray();
if(CollUtil.isNotEmpty(tagList)){
tagList.stream().forEach(hot->{
tagJsonArr.add(JSONObject.parseObject(hot));
});
}
jsonObject.put("tags", tagJsonArr);
String iconsKey = String.format(RedisKey.SCENE_HOT_ICONS, num);
Set iconList = redisUtil.sGet(iconsKey);
jsonObject.put("icons", iconList);
String hotJsonPath = String.format(ConstantFilePath.DATABUFFER_FORMAT, num) + "hot.json";
String lockKey = String.format(RedisLockKey.LOCK_HOT_JSON, num);
boolean lock = redisLockUtil.lock(lockKey, RedisKey.EXPIRE_TIME_1_MINUTE);
if(!lock){
return;
}
try{
FileUtils.writeFile(hotJsonPath, jsonObject.toJSONString());
}finally {
redisLockUtil.unlockLua(lockKey);
}
}
private void addOrUpdateHotDataHandler(String num, Map addOrUpdateMap){
if(CollUtil.isEmpty(addOrUpdateMap))
return;
//数据验证，新增、修改状态，hotdata不能为空
for (String sid : addOrUpdateMap.keySet()) {
String hotData = addOrUpdateMap.get(sid);
if(StrUtil.isEmpty(hotData)){
throw new BusinessException(ErrorCode.FAILURE_CODE_7004);
}
}
//批量写入缓存
String key = String.format(RedisKey.SCENE_HOT_DATA, num);
redisUtil.hmset(key, addOrUpdateMap);
}
private void deleteHotData(String num, List deleteSidList) throws Exception {
this.syncHotFromFileToRedis(num);
if(CollUtil.isEmpty(deleteSidList)){
return;
}
//从redis中加载热点数据
String key = String.format(RedisKey.SCENE_HOT_DATA, num);
List deletDataList = redisUtil.hMultiGet(key, deleteSidList);
if(CollUtil.isEmpty(deletDataList))
return;
String userDataPath = String.format(UploadFilePath.USER_EDIT_PATH, num);
//删除图片音频视频等资源文件
for (String data : deletDataList) {
if(StrUtil.isBlank(data)){
continue;
}
JSONObject jsonObject = JSON.parseObject(data);
String sid = jsonObject.getString("sid");
if(jsonObject.containsKey("media")){
String fileType = jsonObject.getString("media");
if(fileType.contains("photo"))
{
uploadToOssUtil.delete(userDataPath + "hot"+sid+".jpg");
}
if(fileType.contains("audio") || fileType.contains("voice"))
{
uploadToOssUtil.delete(userDataPath + "hot"+sid+".mp3");
}
if(fileType.contains("video"))
{
uploadToOssUtil.delete(userDataPath + "hot"+sid+".mp4");
}
}
if(!StorageType.AWS.code().equals(this.type)){
JSONObject paramData = new JSONObject();
paramData.put("hotId", sid);
JSONObject hotListJson = JSONObject.parseObject(OkHttpUtils.httpGet(hotDomainList));
if(hotListJson != null){
JSONArray hotListArray = hotListJson.getJSONArray("data");
if(hotListArray != null){
for(int l = 0, len = hotListArray.size(); l < len; l++){
OkHttpUtils.httpPostJson(hotListArray.getString(l) + hotDelete + "?hotId=" + sid
, paramData.toJSONString());
}
}
}
}
}
//从redis中移除热点数据
redisUtil.hdel(key, deleteSidList.toArray());
}
@Override
// @SystemServiceLog(description = "保存场景热点")
public ResultData saveShopHot(SceneEditParamVO base) throws Exception {
if(StrUtil.isEmpty(base.getType())){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
String fileName = "shopHot.json";
String sid = base.getSid();
ScenePro scenePro = findBySceneNum(base.getNum());
if (scenePro == null ) {
return ResultData.error(ErrorCode.FAILURE_CODE_5005);
}
JSONObject jsonhot = JSONObject.parseObject(base.getHotData());
StringBuffer dataBuf = new StringBuffer()
.append("data").append(File.separator)
.append("data").append(scenePro.getNum())
.append(File.separator);
StringBuffer imagesBuf = new StringBuffer()
.append("images").append(File.separator)
.append("images").append(scenePro.getNum())
.append(File.separator);
StringBuffer imagesBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(imagesBuf.toString());
StringBuffer dataBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(dataBuf.toString());
String str = FileUtils.readFile(dataBuffer.toString() + fileName);
JSONArray jsonhots = null;
if (StrUtil.isNotEmpty(str)) {
jsonhots = JSONArray.parseArray(str);
}else {
File file = new File(dataBuffer.toString() + fileName);
if(!file.getParentFile().exists()){
file.getParentFile().mkdirs();
}
if(!file.exists()){
file.createNewFile();
}
jsonhots = new JSONArray();
}
//添加或者修改
if("1".equals(base.getType())){
sid = jsonhot.getString("sid");
if(StrUtil.isEmpty(sid)){
throw new BusinessException(ErrorCode.FAILURE_CODE_5012);
}
jsonhots.add(jsonhot);
}
else if("0".equals(base.getType())){
sid = jsonhot.getString("sid");
if(StrUtil.isEmpty(sid)){
throw new BusinessException(ErrorCode.FAILURE_CODE_5012);
}
}
else if("-1".equals(base.getType())){
if(StrUtil.isEmpty(sid)){
throw new BusinessException(ErrorCode.FAILURE_CODE_5012);
}
}
for(int i=0;i map = redisUtil.hmget(key);
List> allTags = map.entrySet().stream().filter(item -> {
if (StrUtil.isBlank(item.getValue())) {
return false;
}
return true;
}).collect(Collectors.toList());
if (CollUtil.isEmpty(allTags)) {
throw new BusinessException(ErrorCode.FAILURE_CODE_7005);
}
allTags.stream().forEach(entry->{
JSONObject hot = JSON.parseObject(entry.getValue());
visiblePanos.stream().forEach(item->{
if (hot.getString("sid").equals(((JSONObject) item).getString("sid"))) {
hot.put("visiblePanos", ((JSONObject) item).getJSONArray("value"));
hot.put("isHidden", ((JSONObject) item).getBoolean("isHidden"));
entry.setValue(hot.toJSONString());
}
});
});
//更新版本号
SceneEditInfo editInfo = sceneEditInfoService.getByScenePlusId(scenePlus.getId());
sceneEditInfoService.upgradeVersionById(editInfo.getId());
//放入缓存
Map finalMap = new HashMap<>();
allTags.stream().forEach(entry->{
finalMap.put(entry.getKey(), entry.getValue());
});
//从新放入缓存
redisUtil.hmset(key, finalMap);
return ResultData.ok();
}
@Override
// @SystemServiceLog(description = "漫游可行")
public ResultData saveRoam(BaseDataParamVO param) throws Exception {
// ScenePro scenePro = this.findBySceneNum(param.getNum());
ScenePlus scenePlus = scenePlusService.getScenePlusByNum(param.getNum());
if (scenePlus == null ) {
return ResultData.error(ErrorCode.FAILURE_CODE_5005);
}
JSONArray inputData = JSONObject.parseArray(param.getData());
String localDataPath = String.format(ConstantFilePath.DATABUFFER_FORMAT, param.getNum());
File directory = new File(localDataPath);
if (!directory.exists()) {
directory.mkdirs();
}
String viewImagesPath = String.format(UploadFilePath.IMG_VIEW_PATH, param.getNum());
String modeldataUrl = ossUrlPrefix + viewImagesPath + "vision.modeldata?t=" + System.currentTimeMillis();
//如果是云存储，将vision.modeldata下载到本地，如果是本地存储，场景计算完就已经将这个文件拷贝到编辑目录了存在这个文件了，不需要再下载
if(!StorageType.LOCAL.code().equals(this.type)){
FileUtils.downLoadFromUrl(modeldataUrl, "vision.modeldata", localDataPath);
}
//检查vision.modeldata本地是否存在，不存在抛出异常
File file = new File(localDataPath + "vision.modeldata");
if(!file.exists()) {
return ResultData.error(ErrorCode.FAILURE_CODE_5012);
}
//将vision.modeldata解压缩至vision.json
ConvertUtils.convertVisionModelDataToTxt(localDataPath + "vision.modeldata", localDataPath + "vision.json");
String str = FileUtils.readFile(localDataPath + "vision.json");
JSONObject json = JSONObject.parseObject(str);
JSONArray panos = json.getJSONArray("sweepLocations");
for (int i = 0; i < panos.size(); ++i) {
JSONObject pano = panos.getJSONObject(i);
for (int j = 0; j < inputData.size(); ++j) {
JSONObject jo = inputData.getJSONObject(j);
String currentPanoId = jo.getString("panoID");
JSONArray visibles = jo.getJSONArray("visibles");
JSONArray visibles3 = jo.getJSONArray("visibles3");
if (pano.getString("uuid").equals(currentPanoId)) {
pano.put("visibles", visibles);
pano.put("visibles3", visibles3);
}
}
}
FileUtils.deleteFile(localDataPath + "vision.json");
FileUtils.deleteFile(localDataPath + "vision.modeldata");
FileUtils.writeFile(localDataPath + "vision.json", json.toString());
ConvertUtils.convertTxtToVisionModelData(localDataPath + "vision.json", localDataPath + "vision.modeldata");
uploadToOssUtil.upload(localDataPath + "vision.modeldata", viewImagesPath + "vision.modeldata");
//更新版本号
SceneEditInfo editInfo = sceneEditInfoService.getByScenePlusId(scenePlus.getId());
if(Objects.isNull(editInfo)){
editInfo = new SceneEditInfo();
editInfo.setScenePlusId(scenePlus.getId());
sceneEditInfoService.save(editInfo);
}else{
sceneEditInfoService.upgradeVersionById(editInfo.getId());
}
return ResultData.ok();
}
@Override
public ResultData uploadShareLogo(SceneEditParamVO base, MultipartFile file) throws Exception {
if(file == null || StrUtil.isEmpty(base.getNum())){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
ScenePro scenePro = findBySceneNum(base.getNum());
if (scenePro == null ) {
return ResultData.error(ErrorCode.FAILURE_CODE_5005);
}
StringBuffer dataBuf = new StringBuffer()
.append("data").append(File.separator)
.append("data").append(scenePro.getNum())
.append(File.separator);
StringBuffer imagesBuf = new StringBuffer()
.append("images").append(File.separator)
.append("images").append(scenePro.getNum())
.append(File.separator);
StringBuffer imagesBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(imagesBuf.toString());
StringBuffer dataBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(dataBuf.toString());
String fileName = "";
if (!file.isEmpty()&&file.getSize() > 0) {
//文件上传的位置可以自定义
System.out.println("上传分享的logo");
String path = imagesBuffer.toString();
File targetFile = new File(path);
if (!targetFile.exists()) {
targetFile.mkdirs();
}
fileName = file.getOriginalFilename();
targetFile = new File(path + fileName);
int count = 1;
// 保存
synchronized(this)
{
file.transferTo(targetFile);
}
SceneProEdit sceneProEdit = sceneProEditService.findByProId(scenePro.getId());
// Map map = new HashMap<>();
// map.put("shareLogo", imagesBuf.toString() + fileName);
// map.put("version", sceneProEdit.getVersion()+1);
// FileUtils.writeJsonFile(dataBuffer.toString() + "scene.json", map);
sceneProEdit.setShareLogo(imagesBuf.toString() + fileName);
sceneProEdit.setVersion(sceneProEdit.getVersion()+1);
sceneProEdit.setUpdateTime(Calendar.getInstance().getTime());
sceneProEditService.updateById(sceneProEdit);
if("V2".equals(scenePro.getBuildType())){
MatrixToImageWriterUtil.createQRCode(mainUrl + sceneProUrl + scenePro.getNum(), ConstantFilePath.BASE_PATH + File.separator + "sceneQRcode/"+scenePro.getNum()+".png", true, path + File.separator + fileName);
MatrixToImageWriterUtil.createQRCode(mainUrl + sceneProUrl + scenePro.getNum() + "&lang=en", ConstantFilePath.BASE_PATH + File.separator + "sceneQRcode/"+scenePro.getNum()+"_en.png", true, path + File.separator + fileName);
}
if("V3".equals(scenePro.getBuildType())){
MatrixToImageWriterUtil.createQRCode(mainUrl + sceneProNewUrl + scenePro.getNum(), ConstantFilePath.BASE_PATH + File.separator + "sceneQRcode/"+scenePro.getNum()+".png", true, path + File.separator + fileName);
MatrixToImageWriterUtil.createQRCode(mainUrl + sceneProNewUrl + scenePro.getNum() + "&lang=en", ConstantFilePath.BASE_PATH + File.separator + "sceneQRcode/"+scenePro.getNum()+"_en.png", true, path + File.separator + fileName);
}
}
return ResultData.ok(imagesBuf.toString() + fileName);
}
@Override
public ResultData uploadPic(FileParamVO param, MultipartFile file) throws Exception{
String sceneNum = param.getNum();
String folderName = param.getFolderName();
String toOss = param.getToOss();
if(StrUtil.isEmpty(sceneNum)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
ScenePro scenePro = baseMapper.findByNum(sceneNum);
if(scenePro == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
if (file.isEmpty() && file.getSize() <= 0) {
throw new BusinessException(ErrorCode.FAILURE_CODE_5012);
}
//文件上传的位置可以自定义
String path = ConstantFilePath.SCENE_PATH+"images"+File.separator+"images"+sceneNum;
if(StrUtil.isNotEmpty(folderName)) {
path = path+File.separator + folderName;
}
File targetFile = new File(path);
if (!targetFile.exists()) {
targetFile.mkdirs();
}
String fileName = file.getOriginalFilename();
targetFile = new File(path + File.separator + fileName);
// 保存
synchronized(this)
{
if(targetFile.exists())
{
FileUtils.deleteFile(path + File.separator + fileName);
}
file.transferTo(targetFile);
}
if(toOss != null && "1".equals(toOss)){
uploadToOssUtil.upload(path + File.separator + fileName, "images"+File.separator+"images"+sceneNum + File.separator + fileName);
}
return ResultData.ok(targetFile.getName());
}
@Override
public ResultData uploadHotJsonToOss(SceneEditParamVO param) throws Exception {
String sceneNum = param.getNum();
if(StrUtil.isEmpty(sceneNum)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
String path = ConstantFilePath.SCENE_PATH+"data"+File.separator+"data"+sceneNum;
uploadToOssUtil.upload(path + File.separator + "hot.json", "data"+File.separator+"data"+sceneNum + File.separator + "hot.json");
return ResultData.ok();
}
@Override
public ResultData deleteOss(FileParamVO param) throws Exception {
uploadToOssUtil.deleteFile(param.getFilePath());
return ResultData.ok();
}
@Override
public ResultData uploadFloorplanPng(FileParamVO param, MultipartFile[] file) throws Exception{
String sceneNum = param.getNum();
String cadInfo = param.getCadInfo();
if(StrUtil.isEmpty(sceneNum)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
ScenePro scenePro = baseMapper.findByNum(sceneNum);
if(scenePro == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
if (file.length <= 0) {
throw new BusinessException(ErrorCode.FAILURE_CODE_5012);
}
StringBuffer dataBuf = new StringBuffer()
.append("data").append(File.separator)
.append("data").append(scenePro.getNum())
.append(File.separator);
StringBuffer imagesBuf = new StringBuffer()
.append("images").append(File.separator)
.append("images").append(scenePro.getNum())
.append(File.separator);
StringBuffer imagesBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(imagesBuf.toString());
StringBuffer dataBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(dataBuf.toString());
//文件上传的位置可以自定义
String path = ConstantFilePath.SCENE_PATH+"images"+File.separator+"images"+sceneNum;
File targetFile = new File(path);
if (!targetFile.exists()) {
targetFile.mkdirs();
}
String fileName = "";
JSONArray floorPlanPngArr = new JSONArray();
for (MultipartFile multipartFile : file) {
fileName = multipartFile.getOriginalFilename();
targetFile = new File(path + File.separator + fileName);
// 保存
synchronized(this)
{
if(targetFile.exists())
{
FileUtils.deleteFile(path + File.separator + fileName);
}
multipartFile.transferTo(targetFile);
}
floorPlanPngArr.add("images"+File.separator+"images"+sceneNum + File.separator + fileName);
}
String strsceneInfos = FileUtils.readFile(dataBuffer.toString() + "scene.json");
JSONObject scenejson = new JSONObject();
if(strsceneInfos!=null) {
scenejson = JSONObject.parseObject(strsceneInfos);
}
Map map = new HashMap<>();
map.put("floorPlanPng", floorPlanPngArr);
map.put("uploadFloorPlanPng", 1);
map.put("version", scenejson.getIntValue("version")+1);
if(StrUtil.isNotEmpty(cadInfo)){
map.put("cadInfo", cadInfo);
}
FileUtils.writeJsonFile(dataBuffer.toString() + "scene.json", map);
return ResultData.ok(floorPlanPngArr);
}
@Override
public void updateTime(String sceneNum, Long space, int payStatus, String videos, long computeTime) {
List list = this.list(new LambdaQueryWrapper().eq(ScenePro::getNum, sceneNum));
if(CollUtil.isEmpty(list))
return;
//修改场景状态 空间 支付状态 计算时间
List sceneProIds = list.stream().map(scenePro -> {
return scenePro.getId();
}).collect(Collectors.toList());
this.update(new LambdaUpdateWrapper()
.in(ScenePro::getId, sceneProIds)
.set(ScenePro::getSceneStatus, SceneStatus.NO_DISPLAY.code())
.set(ScenePro::getCreateTime, Calendar.getInstance().getTime())
.set(ScenePro::getUpdateTime, Calendar.getInstance().getTime())
.set(ScenePro::getPayStatus, payStatus)
.set(ScenePro::getVideos, videos));
sceneProExtService.update(new LambdaUpdateWrapper()
.in(SceneProExt::getSceneProId, sceneProIds)
.set(SceneProExt::getSpace, space)
.set(SceneProExt::getComputeTime, computeTime));
}
@Override
public void updateTime2(String sceneNum, String videos, long computeTime) {
List list = this.list(new LambdaQueryWrapper().eq(ScenePro::getNum, sceneNum));
if(CollUtil.isEmpty(list))
return;
//修改场景状态 空间 支付状态 计算时间
List sceneProIds = list.stream().map(scenePro -> {
return scenePro.getId();
}).collect(Collectors.toList());
this.update(new LambdaUpdateWrapper()
.in(ScenePro::getId, sceneProIds)
.set(ScenePro::getSceneStatus, SceneStatus.NO_DISPLAY.code())
.set(ScenePro::getCreateTime, Calendar.getInstance().getTime())
.set(ScenePro::getUpdateTime, Calendar.getInstance().getTime())
.set(ScenePro::getVideos, videos));
sceneProExtService.update(new LambdaUpdateWrapper()
.in(SceneProExt::getSceneProId, sceneProIds)
.set(SceneProExt::getComputeTime, computeTime));
}
@Override
public SceneVO findLatestOneByUserId(Long userId) {
return baseMapper.findLatestOneByUserId(userId);
}
@Override
public void updateUserIdByCameraId(Long userId, Long cameraId) {
this.update(new LambdaUpdateWrapper()
.eq(ScenePro::getCameraId, cameraId)
.set(ScenePro::getUserId, userId));
}
@Override
public List findByCameraIdPro(Long cameraId) {
return baseMapper.findByCameraIdPro(cameraId);
}
@Override
public void updateCameraIdByCameraIdPro(Long oldCameraId, Long cameraId) {
List list = this.list(
new LambdaQueryWrapper()
.select(ScenePro::getId)
.eq(ScenePro::getCameraId, oldCameraId));
if(CollUtil.isEmpty(list))
return;
//修改场景状态 空间 支付状态 计算时间
List sceneProIds = list.stream().map(scenePro -> {
return scenePro.getId();
}).collect(Collectors.toList());
this.update(new LambdaUpdateWrapper()
.eq(ScenePro::getCameraId, oldCameraId)
.set(ScenePro::getCameraId, cameraId)
.set(ScenePro::getPayStatus, PayStatus.NO_CAPACITY.code()));
}
@Override
public void updateRecStatus(String unicode) {
List list = sceneProExtService.list(
new LambdaQueryWrapper()
.like(SceneProExt::getDataSource, "%" + unicode + "%"));
if(CollUtil.isEmpty(list)){
return ;
}
List sceneProIds = list.stream().map(sceneProExt -> {
return sceneProExt.getSceneProId();
}).collect(Collectors.toList());
this.update(new LambdaUpdateWrapper()
.in(ScenePro::getId, sceneProIds)
.set(ScenePro::getTbStatus, TbStatus.DELETE.code()));
}
@Override
public SceneProPO findByFileId(String fileId) {
return baseMapper.findByFileId(fileId);
}
@Override
public List findTempScenes() throws Exception {
return baseMapper.findTempScenes();
}
@Override
public List findByCameraId(Long cameraId) throws Exception {
List list = this.list(new LambdaQueryWrapper()
.select(ScenePro::getWebSite)
.eq(ScenePro::getTbStatus, TbStatus.VALID.code())
.eq(ScenePro::getTbStatus, TbStatus.VALID.code())
.eq(ScenePro::getCameraId, cameraId));
if(CollUtil.isEmpty(list))
return null;
return list.stream().map(scenePro -> {
return scenePro.getWebSite();
}).collect(Collectors.toList());
}
@Override
public ResultData uploadLogoBottomStatus(FileParamVO param) throws Exception {
String sceneNum = param.getNum();
String status = param.getStatus();
if(StrUtil.isEmpty(sceneNum) || StrUtil.isEmpty(status)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
ScenePro scenePro = baseMapper.findByNum(sceneNum);
if(scenePro == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
SceneProEdit sceneProEdit = sceneProEditService.findByProId(scenePro.getId());
if(sceneProEdit == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
SceneProEditExt sceneProEditExt = sceneProEditExtService.getByProEditId(sceneProEdit.getId());
StringBuffer dataBuf = new StringBuffer()
.append("data").append(File.separator)
.append("data").append(scenePro.getNum())
.append(File.separator);
StringBuffer imagesBuf = new StringBuffer()
.append("images").append(File.separator)
.append("images").append(scenePro.getNum())
.append(File.separator);
StringBuffer imagesBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(imagesBuf.toString());
StringBuffer dataBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(dataBuf.toString());
String strsceneInfos = FileUtils.readFile(dataBuffer.toString() + "scene.json");
JSONObject scenejson = new JSONObject();
if(strsceneInfos!=null) {
scenejson = JSONObject.parseObject(strsceneInfos);
}
scenejson.put("showLogoBottom", Integer.valueOf(status));
scenejson.put("version", scenejson.getIntValue("version") + 1);
FileUtils.writeFile(dataBuffer.toString() + "scene.json", scenejson.toString());
sceneProEdit.setVersion(scenejson.getIntValue("version") + 1);
sceneProEdit.setUpdateTime(Calendar.getInstance().getTime());
sceneProEditExt.setShowLogoBottom(Integer.valueOf(status));
sceneProEditExt.setUpdateTime(Calendar.getInstance().getTime());
sceneProEditExtService.updateById(sceneProEditExt);
sceneProEditService.updateById(sceneProEdit);
return ResultData.ok();
}
@Override
public ResultData uploadObjAndImg(String num, MultipartFile file) throws Exception{
if(StrUtil.isEmpty(num)){
throw new BusinessException(ServerCode.PARAM_REQUIRED, "num");
}
if(!file.getOriginalFilename().endsWith(".zip")){
throw new BusinessException(ErrorCode.FAILURE_CODE_7015);
}
// ScenePro scenePro = this.findBySceneNum(num);
ScenePlus scenePlus = scenePlusService.getScenePlusByNum(num);
if(scenePlus == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
// SceneProExt sceneProExt = sceneProExtService.findBySceneProId(scenePro.getId());
ScenePlusExt scenePlusExt = scenePlusExtService.getScenePlusExtByPlusId(scenePlus.getId());
//文件上传的位置可以自定义
String path = scenePlusExt.getDataSource() + "_obj2txt";
String zipPath = path + "/zip/";
String filePath = path + "/extras/";
String resultPath = path + "/results/";
// String path = "F:\\uploadModel" + "_obj2txt";
// String zipPath = path + "\\zip\\";
// String filePath = path + "\\extras\\";
// String resultPath = path + "\\results\\";
//压缩文件处理：解压缩，解压缩后复制等操作
this.objAndImgFileHandler(resultPath, filePath, zipPath, file);
//创建data.json
this.writeDataJson(path);
//调用算法,不同的类型调用不同的算法
if("V2".equals(scenePlusExt.getBuildType())){
CreateObjUtil.objToTxt(path , "1");
}
if("V3".equals(scenePlusExt.getBuildType())){
CreateObjUtil.build3dModel(path , "1");
}
//算法计算完后，生成压缩文件，上传到oss
this.uploadFileofterRebuildPanoram(path, num);
//更新版本信息
SceneEditInfo sceneEditInfo = sceneEditInfoService.getByScenePlusId(scenePlus.getId());
if(Objects.isNull(sceneEditInfo)){
sceneEditInfo = new SceneEditInfo();
sceneEditInfo.setScenePlusId(scenePlus.getId());
sceneEditInfo.setFloorPublishVer(1);
sceneEditInfo.setFloorEditVer(1);
sceneEditInfo.setIsUploadObj(CommonStatus.YES.code());
sceneEditInfoService.save(sceneEditInfo);
}else{
sceneEditInfoService.update(
new LambdaUpdateWrapper()
.setSql("version = version + 1")
.setSql("floor_edit_ver = floor_edit_ver + 1")
.setSql("floor_publish_ver = floor_publish_ver + 1")
.set(SceneEditInfo::getIsUploadObj, CommonStatus.YES.code())
.eq(SceneEditInfo::getId, sceneEditInfo.getId()));
}
return ResultData.ok();
}
private void uploadFileofterRebuildPanoram(String path, String sceneNum) throws Exception {
//因为共享目录有延迟，这里循环检测算法是否计算完毕3次，每次隔五秒
String uploadJsonPath = path + File.separator + "results" +File.separator+"upload.json";
boolean exist = ComputerUtil.checkComputeCompleted(uploadJsonPath, maxCheckTimes, waitTime);
if(!exist){
throw new BusinessException(ErrorCode.FAILURE_CODE_7013);
}
String uploadData = FileUtils.readFile(uploadJsonPath);
JSONObject uploadJson = null;
JSONArray array = null;
if(uploadData!=null) {
uploadJson = JSONObject.parseObject(uploadData);
array = uploadJson.getJSONArray("upload");
}
Map map = new HashMap();
JSONObject fileJson = null;
String fileName = "";
String imgViewPath = String.format(UploadFilePath.IMG_VIEW_PATH, sceneNum);
for(int i = 0, len = array.size(); i < len; i++) {
fileJson = array.getJSONObject(i);
fileName = fileJson.getString("file");
//文件不存在抛出异常
if (!new File(path + File.separator + "results" + File.separator + fileName).exists()) {
throw new Exception(path + File.separator + "results" + File.separator + fileName + "文件不存在");
}
//tex文件夹
if (fileJson.getIntValue("clazz") == 15) {
map.put(path + File.separator + "results" + File.separator + fileName,
imgViewPath + ConstantFileName.modelUUID + "_50k_texture_jpg_high1/" + fileName.replace("tex/", ""));
// TODO: 2022/2/17 这里复制一份到本地，不知道需不需要，先注释掉
//复制一份到images本地
// FileUtils.copyFile(path + File.separator + "results" +File.separator + fileName,
// ConstantFilePath.SCENE_PATH+"images"+File.separator+"images"+sceneNum + File.separator +
// ConstantFileName.modelUUID + "_50k_texture_jpg_high1/" + fileName.replace("tex/", ""), true);
continue;
}
}
CreateObjUtil.convertTxtToDam( path + File.separator + "results" +File.separator+"modeldata.txt", path + File.separator + "results" +File.separator+ ConstantFileName.modelUUID+"_50k.dam");
CreateObjUtil.convertDamToLzma(path + File.separator + "results");
CreateObjUtil.convertTxtToDam( path + File.separator + "results" +File.separator+"modeldata.txt", path + File.separator + "results" + File.separator+ConstantFileName.modelUUID+"_50k.dam");
map.put(path + File.separator + "results" +File.separator+ConstantFileName.modelUUID+"_50k.dam.lzma", imgViewPath +ConstantFileName.modelUUID+"_50k.dam.lzma");
map.put(path + File.separator + "results" +File.separator+ConstantFileName.modelUUID+"_50k.dam", imgViewPath+ConstantFileName.modelUUID+"_50k.dam");
uploadToOssUtil.uploadMulFiles(map);
// TODO: 2022/2/17 这里复制一份到本地，不知道需不需要，先注释掉
// FileUtils.copyFile(path + File.separator + "results" +File.separator+ConstantFileName.modelUUID+"_50k.dam",
// ConstantFilePath.SCENE_PATH+"images"+File.separator+"images"+sceneNum + File.separator + ConstantFileName.modelUUID+"_50k.dam", true);
// FileUtils.copyFile(path + File.separator + "results" +File.separator+ConstantFileName.modelUUID+"_50k.dam.lzma",
// ConstantFilePath.SCENE_PATH+"images"+File.separator+"images"+sceneNum + File.separator + ConstantFileName.modelUUID+"_50k.dam.lzma", true);
}
private void writeDataJson(String path) throws IOException {
JSONObject dataJson = new JSONObject();
dataJson.put("obj2txt", true);
dataJson.put("split_type", "SPLIT_V6");
dataJson.put("data_describe", "double spherical");
dataJson.put("skybox_type", "SKYBOX_V5");
FileUtils.writeFile(path + "/data.json", dataJson.toString());
}
private void objAndImgFileHandler(String resultPath, String filePath, String zipPath, MultipartFile file)
throws Exception {
FileUtils.delAllFile(resultPath);
File targetFile = new File(filePath);
if (!targetFile.exists()) {
targetFile.mkdirs();
}else {
FileUtils.delAllFile(filePath);
}
targetFile = new File(zipPath);
if (!targetFile.exists()) {
targetFile.mkdirs();
}else {
FileUtils.delAllFile(zipPath);
}
targetFile = new File(zipPath + file.getOriginalFilename());
if(!targetFile.getParentFile().exists()){
targetFile.getParentFile().mkdirs();
}
// 保存压缩包到本地
if(targetFile.exists())
{
FileUtils.deleteFile(zipPath + file.getOriginalFilename());
}
file.transferTo(targetFile);
FileUtils.decompress(zipPath + file.getOriginalFilename(), zipPath + "data/");
//源文件数据，判断是否有多个文件夹，有多个就提示错误，有一个就将文件夹里数据迁移到extras目录，无直接迁移到extras目录
boolean flag = false;
//目录名称，如果不为空，则压缩文件第一层是目录
String targetName = "";
File dataFile = new File(zipPath + "data/");
for(File data : dataFile.listFiles()){
if(data.isDirectory() && flag){
throw new BusinessException(ErrorCode.FAILURE_CODE_5018);
}
if(data.isDirectory() && !flag){
flag = true;
targetName = data.getName();
}
}
//是否包含obj文件
boolean objFlag = false;
//是否包含mtl文件
boolean mtlFlag = false;
File[] files = null;
String dataPath = null;
if(StrUtil.isEmpty(targetName)){
files = dataFile.listFiles();
dataPath = zipPath + "data/";
}else{
files = new File(zipPath + "data/" + targetName).listFiles();
dataPath = zipPath + "data/" + targetName + File.separator;
}
for(File data : files){
if(data.isDirectory()){
throw new BusinessException(ErrorCode.FAILURE_CODE_5018);
}
if(data.getName().endsWith(".jpg") || data.getName().endsWith(".png")){
if(!FileUtils.checkFileSizeIsLimit(data.length(), 1.5, "M")){
throw new BusinessException(ErrorCode.FAILURE_CODE_5020);
}
}
if(data.getName().endsWith(".obj")){
if(objFlag){
throw new BusinessException(ErrorCode.FAILURE_CODE_5019);
}
if(!data.getName().equals("mesh.obj")){
throw new BusinessException(ErrorCode.FAILURE_CODE_5060);
}
if(!FileUtils.checkFileSizeIsLimit(data.length(), 20, "M")){
throw new BusinessException(ErrorCode.FAILURE_CODE_5020);
}
objFlag = true;
FileUtils.copyFile(dataPath + data.getName(), filePath + "mesh.obj", true);
continue;
}
if(data.getName().endsWith(".mtl")){
mtlFlag = true;
}
FileUtils.copyFile(dataPath + data.getName(), filePath + data.getName(), true);
}
//压缩文件中必须有且仅有一个obj和mtl文件，否则抛出异常
if(!mtlFlag || !objFlag){
throw new BusinessException(ErrorCode.FAILURE_CODE_5059);
}
}
@Override
public ResultData saveJsonData(FileParamVO param) throws Exception {
String sceneNum = param.getNum();
String fileName = param.getFileName();
String jsonData = param.getJsonData();
if(StrUtil.isEmpty(sceneNum) || StrUtil.isEmpty(fileName) || StrUtil.isEmpty(jsonData)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
ScenePro scenePro = baseMapper.findByNum(sceneNum);
if(scenePro == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
StringBuffer dataBuf = new StringBuffer()
.append("data").append(File.separator)
.append("data").append(scenePro.getNum())
.append(File.separator);
StringBuffer dataBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(dataBuf.toString());
FileUtils.writeFile(dataBuffer.toString() + fileName, jsonData.toString());
return ResultData.ok("scene/" + dataBuf.toString() + fileName);
}
@Override
public ResultData downloadPanoramaOrVideo(FileParamVO param) throws Exception {
String sceneNum = param.getNum();
String fileName = param.getFileName();
String planId = param.getPlanId();
String type = param.getPlanId();
if(StrUtil.isEmpty(sceneNum) || StrUtil.isEmpty(fileName) || StrUtil.isEmpty(type)|| StrUtil.isEmpty(planId)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
if(fileName.contains("..") || fileName.contains("./\\") || fileName.contains(".//")
|| fileName.contains(".\\\\") || fileName.contains(".\\/")){
throw new BusinessException(ErrorCode.FAILURE_CODE_3018);
}
ScenePro scenePro = baseMapper.findByNum(sceneNum);
if(scenePro == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
SceneProExt sceneProExt = sceneProExtService.findBySceneProId(scenePro.getId());
StringBuffer imagesBuf = new StringBuffer()
.append("images").append(File.separator)
.append("images").append(scenePro.getNum())
.append(File.separator);
StringBuffer imagesBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(imagesBuf.toString());
String path = sceneProExt.getDataSource();
String url = "";
if("image".equals(type)){
if(!new File(path + "/caches/images/" + fileName).exists()){
throw new BusinessException(ErrorCode.FAILURE_CODE_3018);
}
//备份原始数据
if(!new File(imagesBuffer.toString() + "caches/back-" + fileName).exists()){
FileUtils.copyFile(path + "/caches/images/" + fileName, imagesBuffer.toString() + "caches/back-" + fileName, false);
}
//复制打包数据，并且改名
FileUtils.copyFile(path + "/caches/images/" + fileName, imagesBuffer.toString() + "caches/" + planId + ".jpg", true);
url = mainUrl + "scene/" + imagesBuf.toString() + "caches/" + planId + ".jpg";
}
if("video".equals(type)){
url = prefixAli + "video/video" + scenePro.getNum() + "/" + planId + ".mp4";
}
Map map = new HashMap<>();
map.put("fileUrl", url + "?t=" + System.currentTimeMillis());
map.put("fileName", url.substring(url.lastIndexOf("/") + 1));
return ResultData.ok(map);
}
@Override
public ResultData uploadPanoramaOrVideo(FileParamVO param, MultipartFile file) throws Exception {
String sceneNum = param.getNum();
String fileName = param.getFileName();
String planId = param.getPlanId();
if(StrUtil.isEmpty(sceneNum) || StrUtil.isEmpty(fileName) || StrUtil.isEmpty(type) || StrUtil.isEmpty(planId)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
ScenePro scenePro = baseMapper.findByNum(sceneNum);
if(scenePro == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
SceneProExt sceneProExt = sceneProExtService.findBySceneProId(scenePro.getId());
if(!fileName.endsWith(".jpg") && !fileName.endsWith(".mp4")){
throw new BusinessException(ErrorCode.FAILURE_CODE_5023);
}
StringBuffer dataBuf = new StringBuffer()
.append("data").append(File.separator)
.append("data").append(scenePro.getNum())
.append(File.separator);
StringBuffer dataBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(dataBuf.toString());
String path = sceneProExt.getDataSource();
if(path != null && !"".equals(path) && path.startsWith("http")){
path = ConstantFilePath.BUILD_MODEL_PATH + File.separator + path.split("/")[path.split("/").length - 2];
}
String target = path + "_images";
//文件上传的位置可以自定义
String filePath = "";
if("image".equals(type)){
filePath = target + File.separator + "extras/images" + File.separator + fileName;
}
if("video".equals(type)){
filePath = target + File.separator + "extras/video" + File.separator + fileName;
}
File targetFile = new File(filePath);
if(!targetFile.getParentFile().exists()){
targetFile.getParentFile().mkdirs();
}
//上传文件
file.transferTo(targetFile);
String strsceneInfos = FileUtils.readFile(dataBuffer.toString() + "scene.json");
JSONObject scenejson = new JSONObject();
if(strsceneInfos!=null) {
scenejson = JSONObject.parseObject(strsceneInfos);
}
if(type.equals("video")){
scenejson.put("buildImages", 2);
FileUtils.writeFile(dataBuffer.toString() + "scene.json", scenejson.toString());
}else{
scenejson.put("buildImages", 1);
FileUtils.writeFile(dataBuffer.toString() + "scene.json", scenejson.toString());
}
return ResultData.ok();
}
@Override
public ResultData uploadROIVideo(FileParamVO param, MultipartFile file) throws Exception {
String sceneNum = param.getNum();
String fileName = param.getFileName();
String planId = param.getPlanId();
String rect = param.getRect();
String dir = param.getDir();
String hfov = param.getHfov();
String vfov = param.getVfov();
if(StrUtil.isEmpty(sceneNum) || StrUtil.isEmpty(fileName) ||
StrUtil.isEmpty(planId) || StrUtil.isEmpty(rect)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
ScenePro scenePro = baseMapper.findByNum(sceneNum);
if(scenePro == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
SceneProExt sceneProExt = sceneProExtService.findBySceneProId(scenePro.getId());
StringBuffer dataBuf = new StringBuffer()
.append("data").append(File.separator)
.append("data").append(scenePro.getNum())
.append(File.separator);
StringBuffer dataBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(dataBuf.toString());
String path = sceneProExt.getDataSource();
if(path != null && !"".equals(path) && path.startsWith("http")){
path = ConstantFilePath.BUILD_MODEL_PATH + File.separator + path.split("/")[path.split("/").length - 2];
}
String target = path + "_roi";
FileUtils.deleteDirectory(target);
//文件上传的位置可以自定义
String filePath = target + File.separator + "extras" + File.separator + fileName;
File targetFile = new File(filePath);
if(!targetFile.getParentFile().exists()){
targetFile.getParentFile().mkdirs();
}
if(file == null){
FileUtils.copyFile(ConstantFilePath.SCENE_PATH + "video/video"+
scenePro.getNum() + File.separator + fileName, filePath, true);
}else {
//上传文件
file.transferTo(targetFile);
FileUtils.copyFile(filePath, ConstantFilePath.SCENE_PATH + "video/video"+
scenePro.getNum() + File.separator + fileName, true);
}
String strsceneInfos = FileUtils.readFile(dataBuffer.toString() + "scene.json");
JSONObject scenejson = new JSONObject();
if(strsceneInfos!=null) {
scenejson = JSONObject.parseObject(strsceneInfos);
}
JSONArray jsonArray = new JSONArray();
JSONObject jsonObject = new JSONObject();
JSONObject rectJson = JSON.parseObject(rect);
boolean noPanoId = true;
if(scenejson.containsKey("videosUser")){
jsonArray = scenejson.getJSONArray("videosUser");
for(int i = 0, len = jsonArray.size(); i < len; i++){
jsonObject = jsonArray.getJSONObject(i);
if(planId.equals(jsonObject.getString("panoId"))){
jsonObject.put("rect", rectJson);
jsonObject.put("name", fileName.substring(0, fileName.lastIndexOf(".")));
jsonObject.put("dir", JSON.parseObject(dir));
jsonObject.put("hfov", hfov);
jsonObject.put("vfov", vfov);
noPanoId = false;
break;
}
}
}
if(noPanoId){
jsonObject = new JSONObject();
jsonObject.put("name", fileName.substring(0, fileName.lastIndexOf(".")));
jsonObject.put("panoId", planId);
jsonObject.put("rect", rectJson);
jsonObject.put("dir", JSON.parseObject(dir));
jsonObject.put("hfov", hfov);
jsonObject.put("vfov", vfov);
if(!jsonArray.contains(jsonObject)){
jsonArray.add(jsonObject);
}
}
//保存rect的json数据
FileUtils.writeFile(target + File.separator + "extras" + File.separator + "video-ROI.json", jsonObject.toJSONString());
//复制原始图片
FileUtils.copyFile(path + "/caches/images/" + planId + ".jpg",
target + File.separator + "extras" + File.separator + planId + ".jpg", true);
FileUtils.copyFile(path + File.separator + "data.json", target + File.separator+"data.json", true);
FileUtils.copyFile(path + File.separator + "project.json", target + File.separator+"project.json", true);
//data.json增加extras为执行重建算法
String project = FileUtils.readFile(target + File.separator+"project.json");
if(project != null){
JSONObject projectJson = JSONObject.parseObject(project);
projectJson.put("parent", projectJson.get("uuid"));
projectJson.put("uuid", UUID.randomUUID().toString());
projectJson.put("time", System.currentTimeMillis());
FileUtils.writeFile(path + File.separator + "project.json", projectJson.toString());
}
String data = FileUtils.readFile(target + File.separator+"data.json");
if(data != null){
JSONObject dataJson = JSONObject.parseObject(data);
//V5表示不需要生成high，low文件
dataJson.put("skybox_type", "SKYBOX_V5");
dataJson.put("split_type", "SPLIT_V11");
FileUtils.writeFile(target + File.separator+"data.json", new String(dataJson.toString().getBytes(), "UTF-8"));
}
//进行计算
log.info("绿幕抠图视频：开始建模——" + scenePro.getNum());
CreateObjUtil.build3dModel2(target , "1");
//读取upload文件，检验需要上传的文件是否存在
String uploadData = FileUtils.readFile(target + File.separator + "results" +File.separator+"upload.json");
JSONObject uploadJson = null;
JSONArray array = null;
if(uploadData!=null) {
uploadJson = JSONObject.parseObject(uploadData);
array = uploadJson.getJSONArray("upload");
}
if(array == null){
throw new Exception("upload.json数据出错");
}
Map map = new HashMap<>();
JSONObject fileJson = null;
for(int i = 0, len = array.size(); i < len; i++){
fileJson = array.getJSONObject(i);
fileName = fileJson.getString("file");
//文件不存在抛出异常
if(!new File(target + File.separator + "results" +File.separator + fileName).exists()){
throw new Exception(target + File.separator + "results" +File.separator + fileName+"文件不存在");
}
if(fileJson.getIntValue("clazz") == 19 ){
map.put(target + File.separator + "results" + File.separator+ fileName,"video/video"+
scenePro.getNum() + File.separator + fileName.replace("videos/", ""));
}
}
uploadToOssUtil.uploadMulFiles(map);
scenejson.put("videosUser", jsonArray.toJSONString());
scenejson.put("imagesVersion", scenejson.getIntValue("imagesVersion") + 1);
FileUtils.writeFile(dataBuffer.toString() + "scene.json", scenejson.toString());
SceneProEdit sceneProEdit = sceneProEditService.findByProId(scenePro.getId());
if(sceneProEdit != null){
SceneProEditExt sceneProEditExt = sceneProEditExtService.getByProEditId(sceneProEdit.getId());
sceneProEditExt.setVideosUser(jsonArray.toJSONString());
sceneProEditExt.setImagesVersion(sceneProEditExt.getImagesVersion() + 1);
sceneProEditExt.setUpdateTime(Calendar.getInstance().getTime());
sceneProEditExtService.updateById(sceneProEditExt);
}
return ResultData.ok();
}
@Override
public ResultData deleteROIVideo(FileParamVO param) throws Exception {
String sceneNum = param.getNum();
String fileName = param.getFileName();
String planId = param.getPlanId();
if(StrUtil.isEmpty(sceneNum) || StrUtil.isEmpty(fileName) || StrUtil.isEmpty(planId)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
ScenePro scenePro = baseMapper.findByNum(sceneNum);
if(scenePro == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
StringBuffer dataBuf = new StringBuffer()
.append("data").append(File.separator)
.append("data").append(scenePro.getNum())
.append(File.separator);
StringBuffer dataBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(dataBuf.toString());
String strsceneInfos = FileUtils.readFile(dataBuffer.toString() + "scene.json");
JSONObject scenejson = new JSONObject();
if(strsceneInfos!=null) {
scenejson = JSONObject.parseObject(strsceneInfos);
}
JSONArray newArray = new JSONArray();
JSONArray jsonArray = new JSONArray();
JSONObject jsonObject = new JSONObject();
if(scenejson.containsKey("videosUser")){
jsonArray = JSON.parseArray(scenejson.getString("videosUser"));
for(int i = 0, len = jsonArray.size(); i < len; i++){
jsonObject = jsonArray.getJSONObject(i);
if(planId.equals(jsonObject.getString("panoId"))){
continue;
}
if(!newArray.contains(jsonObject)){
newArray.add(jsonObject);
}
}
}
scenejson.put("videosUser", newArray.toJSONString());
scenejson.put("imagesVersion", scenejson.getIntValue("imagesVersion") + 1);
FileUtils.writeFile(dataBuffer.toString() + "scene.json", scenejson.toString());
SceneProEdit sceneProEdit = sceneProEditService.findByProId(scenePro.getId());
if(sceneProEdit != null){
SceneProEditExt sceneProEditExt = sceneProEditExtService.getByProEditId(sceneProEdit.getId());
sceneProEditExt.setVideosUser(newArray.toJSONString());
sceneProEditExt.setImagesVersion(sceneProEditExt.getImagesVersion() + 1);
sceneProEditExt.setUpdateTime(Calendar.getInstance().getTime());
sceneProEditExtService.updateById(sceneProEditExt);
}
uploadToOssUtil.delete("video/video"+ scenePro.getNum() + File.separator +
fileName.substring(0, fileName.lastIndexOf(".")) + ".mp4");
uploadToOssUtil.delete("video/video"+ scenePro.getNum() + File.separator +
fileName.substring(0, fileName.lastIndexOf(".")) + ".flv");
FileUtils.deleteFile(ConstantFilePath.SCENE_PATH + "video/video"+ scenePro.getNum() + File.separator + fileName);
return ResultData.ok();
}
@Override
public ResultData uploadBgMusic(FileParamVO param, MultipartFile file) throws Exception {
String sceneNum = param.getNum();
String fileName = param.getFileName();
if(StrUtil.isEmpty(sceneNum) || StrUtil.isEmpty(fileName)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
ScenePro scenePro = baseMapper.findByNum(sceneNum);
if(scenePro == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
StringBuffer dataBuf = new StringBuffer()
.append("data").append(File.separator)
.append("data").append(scenePro.getNum())
.append(File.separator);
StringBuffer imagesBuf = new StringBuffer()
.append("images").append(File.separator)
.append("images").append(scenePro.getNum())
.append(File.separator);
StringBuffer dataBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(dataBuf.toString());
StringBuffer imagesBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(imagesBuf.toString());
File buMusicFile = new File(imagesBuffer.toString() + fileName);
if(!buMusicFile.getParentFile().exists()){
buMusicFile.getParentFile().mkdirs();
}
//上传文件
file.transferTo(buMusicFile);
String strsceneInfos = FileUtils.readFile(dataBuffer.toString() + "scene.json");
JSONObject scenejson = new JSONObject();
if(strsceneInfos!=null) {
scenejson = JSONObject.parseObject(strsceneInfos);
}
scenejson.put("bgMusicName", fileName);
scenejson.put("uploadBgMusic", 1);
scenejson.put("version", scenejson.getIntValue("version") + 1);
FileUtils.writeFile(dataBuffer.toString() + "scene.json", scenejson.toString());
return ResultData.ok();
}
@Override
public ResultData deleteUploadBgMusic(FileParamVO param) throws Exception {
String sceneNum = param.getNum();
if(StrUtil.isEmpty(sceneNum)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
ScenePro scenePro = baseMapper.findByNum(sceneNum);
if(scenePro == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
StringBuffer dataBuf = new StringBuffer()
.append("data").append(File.separator)
.append("data").append(scenePro.getNum())
.append(File.separator);
StringBuffer dataBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(dataBuf.toString());
String strsceneInfos = FileUtils.readFile(dataBuffer.toString() + "scene.json");
JSONObject scenejson = new JSONObject();
if(strsceneInfos!=null) {
scenejson = JSONObject.parseObject(strsceneInfos);
}
scenejson.put("bgMusicName", "");
scenejson.put("uploadBgMusic", 1);
scenejson.put("version", scenejson.getIntValue("version") + 1);
FileUtils.writeFile(dataBuffer.toString() + "scene.json", scenejson.toString());
return ResultData.ok();
}
@Override
public ResultData savePanorama(FileParamVO param, MultipartFile file) throws Exception {
String sceneNum = param.getNum();
String sid = param.getSid();
String imagesName = param.getImagesName();
if(StrUtil.isEmpty(sceneNum) || StrUtil.isEmpty(sid)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
ScenePro scenePro = baseMapper.findByNum(sceneNum);
if(scenePro == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
SceneProExt sceneProExt = sceneProExtService.findBySceneProId(scenePro.getId());
StringBuffer dataBuf = new StringBuffer()
.append("data").append(File.separator)
.append("data").append(scenePro.getNum())
.append(File.separator);
StringBuffer imagesBuf = new StringBuffer()
.append("images").append(File.separator)
.append("images").append(scenePro.getNum())
.append(File.separator);
StringBuffer dataBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(dataBuf.toString());
StringBuffer imagesBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(imagesBuf.toString());
String path = sceneProExt.getDataSource();
String target = imagesBuffer.toString() + "panorama/" + sid;
FileUtils.deleteDirectory(target);
//文件上传的位置可以自定义
String filePath = target + File.separator + "extras/images" + File.separator + imagesName;
File targetFile = new File(filePath);
if(!targetFile.getParentFile().exists()){
targetFile.getParentFile().mkdirs();
}
//上传文件
file.transferTo(targetFile);
//调用算法切全景图
FileUtils.copyFile(path + File.separator + "data.json", target + File.separator+"data.json", true);
FileUtils.copyFile(path + File.separator + "project.json", target + File.separator+"project.json", true);
JSONObject visionJson = new JSONObject();
JSONArray visionArray = new JSONArray();
visionJson.put("uuid", imagesName.substring(0, imagesName.lastIndexOf(".")));
visionJson.put("group", 1);
visionJson.put("subgroup", 0);
visionArray.add(visionJson);
JSONObject vision = new JSONObject();
vision.put("sweepLocations", visionArray);
FileUtils.writeFile(target + "/extras" + File.separator + "vision.txt", new String(vision.toString().getBytes(), "UTF-8"));
//data.json增加extras为执行重建算法
String data = FileUtils.readFile(target + File.separator + "data.json");
if(data != null){
JSONObject floorplanJson = new JSONObject();
floorplanJson.put("has_source_images", true);
floorplanJson.put("has_vision_txt", true);
JSONObject dataJson = JSONObject.parseObject(data);
dataJson.put("extras", floorplanJson);
//V5表示不需要生成high，low文件
dataJson.put("skybox_type", "SKYBOX_V6");
if(scenePro.getSceneScheme() == 11){
dataJson.put("skybox_type", "SKYBOX_V7");
}
dataJson.put("split_type", "SPLIT_V8");
if(scenePro.getSceneScheme() == 3){
dataJson.put("skybox_type", "SKYBOX_V4");
}
FileUtils.writeFile(target + File.separator+"data.json", new String(dataJson.toString().getBytes(), "UTF-8"));
}
//创建文件夹软连接并且复制data.json和project.json
if(new File(target + File.separator + "capture").exists()){
new File(target + File.separator + "capture").delete();
}
if(new File(target + File.separator + "results").exists()){
FileUtils.delAllFile(target + File.separator + "results");
}
//下载data.fdage
if("aws".equals(this.type)){
//亚马逊保持旧方式，超链接capture
CreateObjUtil.createSoftConnection(path + File.separator + "capture", target + File.separator + "capture");
}
CreateObjUtil.ossUtilCp(ConstantFilePath.OSS_PREFIX + path.replace(ConstantFilePath.BUILD_MODEL_PATH, "") + "/data.fdage", target + File.separator + "capture/");
CreateObjUtil.build3dModel(target , "1");
//读取upload文件，检验需要上传的文件是否存在
String uploadData = FileUtils.readFile(target + File.separator + "results" +File.separator+"upload.json");
JSONObject uploadJson = null;
JSONArray array = null;
if(uploadData!=null) {
uploadJson = JSONObject.parseObject(uploadData);
array = uploadJson.getJSONArray("upload");
}
if(array == null){
log.info("计算全景图失败，没有upload.json");
}
Map map = new HashMap<>();
JSONObject fileJson = null;
String fileName = "";
String img = "";
for(int i = 0, len = array.size(); i < len; i++){
fileJson = array.getJSONObject(i);
fileName = fileJson.getString("file");
//文件不存在抛出异常
if(!new File(target + File.separator + "results" +File.separator + fileName).exists()){
throw new Exception(target + File.separator + "results" +File.separator + fileName+"文件不存在");
}
//low文件夹
if(fileJson.getIntValue("clazz") == 4){
img = "/results" + File.separator + fileName;
map.put(target + File.separator + "results" +File.separator+ fileName,"images/images"+
scenePro.getNum()+"/pan/low/"+ fileName.replace("low/", ""));
continue;
}
//tiles文件夹,亚马逊没有裁剪图片api，不需要上传4k图
if(fileJson.getIntValue("clazz") == 5){
map.put(target + File.separator + "results" + File.separator+ fileName,"images/images"+
scenePro.getNum()+ "/panorama_edit/" + sid + File.separator + fileName);
}
//tiles文件夹,亚马逊瓦片图
if(fileJson.getIntValue("clazz") == 7 ){
map.put(target + File.separator + "results" + File.separator+ fileName,"images/images"+
scenePro.getNum()+ File.separator + fileName);
}
}
//上传全景图
map.put(filePath, "images/images"+ scenePro.getNum()+ File.separator + "pan/high/" + imagesName);
uploadToOssUtil.uploadMulFiles(map);
String strsceneInfos = FileUtils.readFile(dataBuffer.toString() + "scene.json");
JSONObject scenejson = new JSONObject();
if(strsceneInfos!=null) {
scenejson = JSONObject.parseObject(strsceneInfos);
}
scenejson.put("uploadPanoramaImg", 1);
scenejson.put("version", scenejson.getIntValue("version") + 1);
FileUtils.writeFile(dataBuffer.toString() + "scene.json", scenejson.toString());
Map result = new HashMap<>();
result.put("type", scenePro.getSceneScheme() == 11? "2k" : "4k");
result.put("img", "scene/" + imagesBuf.toString() + "panorama/" + sid + img);
result.put("path", "images/images"+ scenePro.getNum()+ "/panorama_edit/" + sid);
return ResultData.ok(result);
}
@Override
public ResultData savePanoramaJson(FileParamVO param) throws Exception {
String sceneNum = param.getNum();
String fileName = param.getFileName();
String fileData = param.getFileData();
String sid = param.getSid();
if(StrUtil.isEmpty(sceneNum) || StrUtil.isEmpty(fileName)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
ScenePro scenePro = baseMapper.findByNum(sceneNum);
if(scenePro == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
StringBuffer dataBuf = new StringBuffer()
.append("data").append(File.separator)
.append("data").append(scenePro.getNum())
.append(File.separator);
StringBuffer imagesBuf = new StringBuffer()
.append("images").append(File.separator)
.append("images").append(scenePro.getNum())
.append(File.separator);
StringBuffer dataBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(dataBuf.toString());
StringBuffer imagesBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(imagesBuf.toString());
FileUtils.writeFile(dataBuffer.toString() + fileName, fileData);
String strsceneInfos = FileUtils.readFile(dataBuffer.toString() + "scene.json");
JSONObject scenejson = new JSONObject();
if(strsceneInfos!=null) {
scenejson = JSONObject.parseObject(strsceneInfos);
}
scenejson.put("uploadPanoramaJson", 1);
scenejson.put("version", scenejson.getIntValue("version") + 1);
if(StrUtil.isNotEmpty(fileData)){
scenejson.put("jumpScene", true);
}else {
scenejson.put("jumpScene", false);
}
FileUtils.writeFile(dataBuffer.toString() + "scene.json", scenejson.toString());
if(StrUtil.isNotEmpty(sid)){
String target = imagesBuffer.toString() + "panorama/" + sid;
FileUtils.deleteDirectory(target);
uploadToOssUtil.deleteFile(imagesBuf.toString() + "panorama_edit/" + sid);
}
return ResultData.ok();
}
@Override
public ResultData copyAndUpdateFloorJson(FileParamVO param) throws Exception{
String sceneNum = param.getNum();
String floorJsonData = param.getFloorJsonData();
if(StrUtil.isEmpty(sceneNum) ){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
StringBuffer dataBuf = new StringBuffer()
.append("data").append(File.separator)
.append("data").append(sceneNum)
.append(File.separator);
StringBuffer dataBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(dataBuf.toString());
String strsceneInfos = FileUtils.readFile(dataBuffer.toString() + "scene.json");
JSONObject scenejson = new JSONObject();
if(strsceneInfos!=null) {
scenejson = JSONObject.parseObject(strsceneInfos);
}
if(StrUtil.isEmpty(floorJsonData)){
ScenePro scenePro = baseMapper.findByNum(sceneNum);
if(scenePro == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
SceneProExt sceneProExt = sceneProExtService.findBySceneProId(scenePro.getId());
FileUtils.copyFile(sceneProExt.getDataSource() + "/results/floor.json", dataBuffer.toString() + "houst_floor.json", true);
uploadToOssUtil.upload(dataBuffer.toString() + "houst_floor.json", dataBuf.toString() + "houst_floor.json");
String result = FileUtils.readFile(dataBuffer.toString() + "houst_floor.json");
return ResultData.ok((Object) result);
}
FileUtils.writeFile(dataBuffer.toString() + "houst_floor.json", floorJsonData);
uploadToOssUtil.upload(dataBuffer.toString() + "houst_floor.json", dataBuf.toString() + "houst_floor.json");
return ResultData.ok(floorJsonData);
}
@Override
public ResultData updateFloorJson(FileParamVO param) throws Exception{
String sceneNum = param.getNum();
String floorJsonData = param.getFloorJsonData();
if(StrUtil.isEmpty(sceneNum) || StrUtil.isEmpty(floorJsonData)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
StringBuffer dataBuf = new StringBuffer()
.append("data").append(File.separator)
.append("data").append(sceneNum)
.append(File.separator);
StringBuffer dataBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(dataBuf.toString());
String strsceneInfos = FileUtils.readFile(dataBuffer.toString() + "scene.json");
JSONObject scenejson = new JSONObject();
if(strsceneInfos!=null) {
scenejson = JSONObject.parseObject(strsceneInfos);
}
scenejson.put("uploadFloorJson", 1);
scenejson.put("version", scenejson.getIntValue("version") + 1);
FileUtils.writeFile(dataBuffer.toString() + "floor.json", floorJsonData);
FileUtils.writeFile(dataBuffer.toString() + "scene.json", scenejson.toJSONString());
return ResultData.ok((Object) floorJsonData);
}
@Override
public Page getAppAllSceneByPage(Long cameraId, Long userId, int cameraType, int pageNum, Integer pageSize, String orderBy, Integer sceneType, List sceneCodeList, String sceneName) {
Page page = new Page<>(pageNum, pageSize);
List list = baseMapper.getAppAllSceneByPage(page, cameraId, userId, cameraType, sceneType, sceneCodeList, sceneName, orderBy);
page.setRecords(list);
return page;
}
@Override
public Long findSceneNumByCameraId(Long cameraId) {
return this.count(new LambdaQueryWrapper()
.eq(ScenePro::getCameraId, cameraId));
}
@Override
public SceneProPO findLastSceneByCameraId(Long cameraId) {
return baseMapper.findLastSceneByCameraId(cameraId);
}
@Override
public Long findTotalSpaceByCameraId(Long cameraId) {
List list = this.list(new LambdaQueryWrapper()
.select(ScenePro::getId)
.eq(ScenePro::getTbStatus, TbStatus.VALID.code())
.eq(ScenePro::getCameraId, cameraId)
.in(ScenePro::getSceneStatus, SceneStatus.SUCCESS.code(), SceneStatus.NO_DISPLAY.code())
.eq(ScenePro::getPayStatus, PayStatus.PAY.code()));
if(CollUtil.isEmpty(list)){
return 0l;
}
List sceneProIds = list.stream().map(scenePro -> {
return scenePro.getId();
}).collect(Collectors.toList());
List extList = sceneProExtService.list(new LambdaQueryWrapper()
.in(SceneProExt::getSceneProId, sceneProIds));
long sum = extList.parallelStream().mapToLong(ext -> ext.getSpace()).sum();
return sum;
}
@Override
public void updatePayStatusByCameraId(Integer payStatus, Long cameraId) {
this.update(new LambdaUpdateWrapper()
.eq(ScenePro::getTbStatus, TbStatus.VALID.code())
.eq(ScenePro::getCameraId, cameraId)
.set(ScenePro::getPayStatus, payStatus));
}
@Override
public ResultData downloadPanoramaData(SceneEditParamVO param) throws Exception {
String sceneNum = param.getNum();
if(StrUtil.isEmpty(sceneNum)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
ScenePro scenePro = findBySceneNum(sceneNum);
if(scenePro == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
SceneProExt sceneProExt = sceneProExtService.findBySceneProId(scenePro.getId());
StringBuffer imagesBuf = new StringBuffer()
.append("images").append(File.separator)
.append("images").append(scenePro.getNum())
.append(File.separator);
StringBuffer imagesBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(imagesBuf.toString());
String highPath = sceneProExt.getDataSource() + "/results/high";
if(!new File(highPath).exists()){
throw new BusinessException(ErrorCode.FAILURE_CODE_5012);
}
FileUtils.zipFile(imagesBuffer.toString() + sceneNum + "-high.zip", highPath);
uploadToOssUtil.upload(imagesBuffer.toString() + sceneNum + "-high.zip", imagesBuf.toString() + sceneNum + "-high.zip");
return ResultData.ok(prefixAli + imagesBuf.toString() + sceneNum + "-high.zip?t=" + System.currentTimeMillis());
}
public ResultData getSceneAndCameras(Long userId,List excludeNums) {
List scenes = findByUserId(userId,excludeNums);
Map result = new HashMap<>(2);
if(ObjectUtils.isEmpty(scenes)){
result.put("scenes",new ArrayList<>());
result.put("cameras",new ArrayList<>());
return ResultData.ok(result);
}
List ids = scenes.parallelStream().map(scene->String.valueOf(scene.getCameraId()))
.collect(Collectors.toList());
// TODO: 2021/12/29 这里需要feign接口
// List cameras = cameraService.getCamerasByIds(ids);
// result.put("scenes",scenes);
// result.put("cameras",cameras);
return ResultData.ok(result);
}
@Override
public SceneProPO findBySceneNumWithOutCheckRecStatus(String sceneNum) throws Exception {
return baseMapper.findByNumWithOutCheckRecStatus(sceneNum);
}
@Override
public Integer findFolderIdScence(Long folderId, Long userId) {
return baseMapper.findFolderIdScence(SceneProVO.builder().folderId(folderId).userId(userId).build());
}
@Override
public ResultData downloadVisionData(SceneEditParamVO param) throws Exception {
String sceneCode = param.getSceneName();
if(StrUtil.isEmpty(sceneCode)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
List sceneProList = this.list(
new QueryWrapper()
.eq("tb_status", TbStatus.VALID.code())
.eq("scene_code",sceneCode));
if(CollUtil.isEmpty(sceneProList)){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
ScenePro scenePro = sceneProList.get(0);
StringBuffer dataBuf = new StringBuffer()
.append("data").append(File.separator)
.append("data").append(scenePro.getNum())
.append(File.separator);
StringBuffer imagesBuf = new StringBuffer()
.append("images").append(File.separator)
.append("images").append(scenePro.getNum())
.append(File.separator);
StringBuffer dataBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(dataBuf.toString());
StringBuffer imagesBuffer = new StringBuffer(ConstantFilePath.SCENE_PATH).append(imagesBuf.toString());
String modeldataUrl = prefixAli + imagesBuf.toString() + "vision.modeldata?t=" + System.currentTimeMillis();
if("aws".equals(type)){
modeldataUrl = ConstantUrl.PREFIX_AWS + imagesBuf.toString() + "vision.modeldata?t=" + System.currentTimeMillis();
}
FileUtils.downLoadFromUrl(modeldataUrl, "vision.modeldata", dataBuffer.toString());
File file = new File(dataBuffer.toString() + "vision.modeldata");
if(!file.exists()) {
return ResultData.error(ErrorCode.FAILURE_CODE_5012);
}
ConvertUtils.convertVisionModelDataToTxt(dataBuffer.toString() + "vision.modeldata", dataBuffer.toString() + "vision.json");
uploadToOssUtil.upload(dataBuffer.toString() + "vision.json", dataBuf.toString() + "vision.json");
return ResultData.ok(prefixAli + dataBuf.toString() + "vision.json?t=" + System.currentTimeMillis());
}
@Override
public SceneVO getInfo(String sceneNum) {
if(StrUtil.isEmpty(sceneNum)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
List sceneProList = this.list(
new QueryWrapper()
.eq("tb_status", TbStatus.VALID.code())
.eq("scene_code",sceneNum));
if(CollUtil.isEmpty(sceneProList)){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
ScenePro scenePro = sceneProList.get(0);
if(scenePro == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
if(scenePro.getTbStatus().equals(TbStatus.DELETE.code())){
throw new BusinessException(ErrorCode.FAILURE_CODE_5009);
}
if(!SceneStatus.SUCCESS.code().equals(scenePro.getSceneStatus())
&& !SceneStatus.NO_DISPLAY.code().equals(scenePro.getSceneStatus())){
throw new BusinessException(ErrorCode.FAILURE_CODE_5033);
}
if(scenePro.getPayStatus() != 1){
throw new BusinessException(ErrorCode.FAILURE_CODE_5034);
}
SceneVO sceneVo = new SceneVO();
SceneProEdit sceneProEdit =
sceneProEditService.getOne(
new QueryWrapper()
.eq("rec_status", RecStatus.VALID.code())
.eq("tb_status", RecStatus.VALID.code())
.eq("pro_id", scenePro.getId()));// .findByProId(scenePro.getId());
SceneProEditExt sceneProEditExt
= sceneProEditExtService.getOne(
new QueryWrapper()
.eq("pro_edit_id", sceneProEdit.getId()));
BeanUtils.copyProperties(sceneProEditExt, sceneVo);
BeanUtils.copyProperties(sceneProEdit, sceneVo);
BeanUtils.copyProperties(scenePro, sceneVo);
if(StrUtil.isNotEmpty(sceneProEdit.getEntry())){
sceneVo.setEntry(JSONObject.parseObject(sceneProEdit.getEntry()).toJSONString());
}
if(StrUtil.isNotEmpty(scenePro.getGps())){
sceneVo.setGps(JSONObject.parseObject(scenePro.getGps()).toJSONString());
}
sceneVo.setCreateTime(new DateTime(scenePro.getCreateTime()).toString("yyyy-MM-dd"));
sceneVo.setCreateDate(scenePro.getCreateTime().getTime());
if(StrUtil.isEmpty(sceneProEdit.getSceneKey())){
sceneVo.setIsPublic(0);
}else {
sceneVo.setIsPublic(1);
}
//不返回场景访问密码
sceneVo.setSceneKey("");
//查询是否有随心装场景
if(sceneNum.indexOf("vr-")!=-1){
ScenePro vrScenePro= findLikeSceneNum(sceneNum);
if(Objects.nonNull(vrScenePro)){
sceneVo.setVrNum(null);
sceneVo.setVideosUser(null);
sceneVo.setBgMusicName(null);
sceneVo.setBgMusic(null);
}
}
//更新访问数量
sceneService.updateViewCount(sceneNum);
return sceneVo;
}
@Override
public ScenePro findLikeSceneNum(String sceneNum) {
return baseMapper.findLikeNum(sceneNum);
}
@Override
public ResultData rebuildReduceSpaceBySceneNum(String sceneNum) throws Exception{
ScenePro scenePro = this.findBySceneNum(sceneNum);
if(scenePro == null){
log.info("该场景不存在无法扣除容量，场景码为：" + sceneNum);
return ResultData.error(ErrorCode.FAILURE_CODE_5054);
}
if (scenePro.getSceneScheme() < 4){
log.info("该场景不属于八目相机无法扣除容量，场景码为：" + sceneNum);
return ResultData.error(ErrorCode.FAILURE_CODE_5055);
}
SceneProExt sceneProExt = sceneProExtService.findBySceneProId(scenePro.getId());
platformGoodsClient.updateCameraDetailByCameraIdAndSpace(scenePro.getCameraId(), -sceneProExt.getSpace());
sceneProExt.setSpace(Long.parseLong("0"));
sceneProExt.setUpdateTime(Calendar.getInstance().getTime());
sceneProExtService.updateById(sceneProExt);
return ResultData.ok();
}
@Override
public void tempScenes(List lockedIds) {
if (lockedIds == null || lockedIds.size() == 0){
return;
}
for (Long id : lockedIds){
ScenePro scenePro = this.getById(id);
scenePro.setPayStatus(-2);
this.updateById(scenePro);
ScenePro sceneProEntity = this.getById(id);
try{
Map map = new HashMap<>();
map.put("payStatus", -2);
FileUtils.writeJsonFile(ConstantFilePath.SCENE_PATH + "data/data" + sceneProEntity.getNum() + "/scene.json", map);
}catch (Exception e){
e.printStackTrace();
}
}
}
@Override
public ResultData getRecordAudioFromBrowser(FileParamVO param, MultipartFile file) throws IOException {
String sceneNum = param.getNum();
if(StrUtil.isEmpty(sceneNum) || file.isEmpty() || file.getSize() <= 0){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
ScenePro scenePro = this.findBySceneNum(sceneNum);
if(scenePro == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
//文件上传的位置可以自定义
log.info("开始上传文件");
String path = ConstantFilePath.SCENE_PATH+"voice"+File.separator+"voice"+sceneNum;
File targetFile = new File(path);
if (!targetFile.exists()) {
targetFile.mkdirs();
}
String fileName = file.getOriginalFilename();
targetFile = new File(path + File.separator + fileName);
// 保存
synchronized(this){
file.transferTo(targetFile);
}
return ResultData.ok();
}
@Override
public ResultData checkVideoUrl(FileParamVO param) {
String path = param.getPath();
if(StrUtil.isEmpty(path)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
if(!path.contains("qq.com") && !path.contains("youku.com") && !path.contains("iqiyi.com")){
throw new BusinessException(ErrorCode.FAILURE_CODE_5016);
}
if(path.contains("v.qq.com/txp/iframe/player.html") || path.contains("player.youku.com/embed")
|| path.contains("open.iqiyi.com/developer/player_js/coopPlayerIndex.html")){
return ResultData.ok(path);
}
String html = "";
try {
URL url = new URL(path);
HttpURLConnection httpConn = (HttpURLConnection) url.openConnection();
httpConn.setConnectTimeout(60000);
httpConn.setReadTimeout(60000);
InputStreamReader input = new InputStreamReader(httpConn
.getInputStream(), "utf-8");
BufferedReader bufReader = new BufferedReader(input);
String line = "";
String vid = "";
if(path.contains("qq.com")){
while ((line = bufReader.readLine()) != null) {
// System.out.println(line);
if(line.contains("m.v.qq.com/play.html")){
System.out.println(line.substring(line.indexOf("&vid=") + 5, line.indexOf("&ptag")));
vid = line.substring(line.indexOf("&vid=") + 5, line.indexOf("&ptag"));
break;
}
}
if(!StrUtil.isEmpty(vid)){
html = "https://v.qq.com/txp/iframe/player.html?vid=" + vid;
}
}
if(path.contains("youku.com")){
vid = path.substring(path.indexOf("/id_") + "/id_".length(), path.indexOf(".html"));
html = "https://player.youku.com/embed/" + vid;
}
if(path.contains("iqiyi.com")){
String tvid = "";
while ((line = bufReader.readLine()) != null) {
if(line.contains("param['vid']")){
vid = line.substring(line.indexOf("\"") + 1, line.lastIndexOf("\""));
}
if(line.contains("param['tvid']")){
tvid = line.substring(line.indexOf("\"") + 1, line.lastIndexOf("\""));
}
}
if(!StrUtil.isEmpty(vid) && !StrUtil.isEmpty(tvid)){
html = "https://open.iqiyi.com/developer/player_js/coopPlayerIndex.html?vid=" + vid +
"&tvId=" + tvid;
}
}
}catch (Exception e){
e.printStackTrace();
}
return ResultData.ok(html);
}
public ResultData downloadTexData(String num) throws Exception {
if(StrUtil.isEmpty(num)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
// ScenePro scenePro = this.findBySceneNum(num);
ScenePlus scenePlus = scenePlusService.getScenePlusByNum(num);
if(scenePlus == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
// SceneProExt sceneProExt = sceneProExtService.findBySceneProId(scenePro.getId());
ScenePlusExt scenePlusExt = scenePlusExtService.getScenePlusExtByPlusId(scenePlus.getId());
SceneEditInfo sceneEditInfo = sceneEditInfoService.getByScenePlusId(scenePlus.getId());
String localImagePath = String.format(ConstantFilePath.IMAGESBUFFER_FORMAT, num);
if(!new File(localImagePath).exists()){
new File(localImagePath).mkdirs();
}
String newData = scenePlusExt.getDataSource() + "_obj2txt/extras";
String newResultData = scenePlusExt.getDataSource() + "_obj2txt/results/upload.json";
String zipName = num + "_extras.zip";
String zipPath = localImagePath + zipName;
//如果用户上传过模型，就打包上传到oss，直接返回
if(CommonStatus.YES.code().equals(sceneEditInfo.getIsUploadObj())
&& new File(newData).exists()
&& new File(newResultData).exists()){
//打包
FileUtils.zipFile(zipPath, newData);
//上传压缩包
uploadToOssUtil.upload(zipPath, "downloads/extras/" + zipName);
String url = ossUrlPrefix + "downloads/extras/" + zipName + "?t=" + Calendar.getInstance().getTimeInMillis();
return ResultData.ok(url);
}
String buildType = scenePlusExt.getBuildType();
if("V3".equals(buildType)){
String dataViewPath = String.format(UploadFilePath.DATA_VIEW_PATH, num);
//V3版本去oss下载2048模型
String meshPath = String.format(ConstantFilePath.DATABUFFER_FORMAT, num) + "mesh";
FileUtils.deleteDirectory(meshPath);
CreateObjUtil.ossUtilCp(dataViewPath + "mesh", meshPath);
log.info("meshPath="+meshPath.concat("/mesh"));
if(!new File(meshPath.concat("/mesh")).exists()){
throw new BusinessException(ErrorCode.FAILURE_CODE_7006);
}
log.info(new File(meshPath.concat("/mesh")).listFiles().toString());
if(new File(meshPath.concat("/mesh")).listFiles().length > 0){
for(File file : new File(meshPath.concat("/mesh")).listFiles()){
if(file.getName().endsWith(".obj") && !"output.house.obj".equals(file.getName()) &&
!"mesh.obj".equals(file.getName())){
file.delete();
}
if(file.getName().endsWith(".mtl") && !"output.house.mtl".equals(file.getName()) &&
!"mesh.mtl".equals(file.getName())){
file.delete();
}
}
//打包
FileUtils.zipFile(zipPath, meshPath);
//上传压缩包
uploadToOssUtil.upload(zipPath, "downloads/extras/" + zipName);
String url = ossUrlPrefix + "downloads/extras/" + zipName + "?t=" + Calendar.getInstance().getTimeInMillis();
return ResultData.ok(url);
}
}
//V2版本在本地获取模型资源
//修改过的资源
String editData = scenePlusExt.getDataSource() + "_edit/caches/tex";
String results = scenePlusExt.getDataSource() + "_edit/results";
if (new File(editData).exists() && new File(results).exists()){
for(File file : new File(editData).listFiles()){
if(file.getName().endsWith(".obj") && !"output.house.obj".equals(file.getName()) &&
!"mesh.obj".equals(file.getName())){
file.delete();
}
if(file.getName().endsWith(".mtl") && !"output.house.mtl".equals(file.getName()) &&
!"mesh.mtl".equals(file.getName())){
file.delete();
}
}
FileUtils.zipFile(zipPath, editData);
//上传压缩包
uploadToOssUtil.upload(zipPath, "downloads/extras/" + zipName);
String url = ossUrlPrefix + "downloads/extras/" + zipName + "?t=" + Calendar.getInstance().getTimeInMillis();
return ResultData.ok(url);
}
//没上传过返回源资源
String dataPath = scenePlusExt.getDataSource() + "/caches/tex";
File dataFile = new File(dataPath);
if(!dataFile.exists()){
throw new BusinessException(ErrorCode.FAILURE_CODE_3018);
}
for(File file : dataFile.listFiles()){
if(file.getName().endsWith(".obj") && !"output.house.obj".equals(file.getName()) &&
!"mesh.obj".equals(file.getName())){
file.delete();
}
if(file.getName().endsWith(".mtl") && !"output.house.mtl".equals(file.getName()) &&
!"mesh.mtl".equals(file.getName())){
file.delete();
}
}
FileUtils.zipFile(zipPath, dataPath);
//上传压缩包
uploadToOssUtil.upload(zipPath, "downloads/extras/" + zipName);
String url = ossUrlPrefix + "downloads/extras/" + zipName + "?t=" + Calendar.getInstance().getTimeInMillis();
return ResultData.ok(url);
}
private void dealTour(SceneEditParamVO base, JSONObject scenejson, Map map,
StringBuffer dataBuffer, StringBuffer imagesBuffer) throws IOException {
if(!StrUtil.isEmpty(base.getTourList())){
if(scenejson.containsKey("uploadTourList") && scenejson.getIntValue("uploadTourList") == 1){
int screencapLen = 0;
File file = new File(dataBuffer.toString() + ConstantFileName.TOURLIST_FOLDER);
String[] strs = file.list();
if(strs!=null) {
for(int i=0;i-1)
{
++screencapLen;
map.put(dataBuffer.toString() + ConstantFileName.TOURLIST_FOLDER+File.separator+strs[i],
"data/data"+base.getNum()+"/tour/"+strs[i]);
}
}
}
scenejson.put("screencapLen", screencapLen);
String path = imagesBuffer.toString() + ConstantFileName.TOURLIST_FOLDER;
JSONArray tourJsons = JSONArray.parseArray(base.getTourList());
for(int i=0;i map = new HashMap<>();
if(StringUtils.isEmpty(path) || StringUtils.isEmpty(projectNum)){
return ResultData.error(ErrorCode.PARAM_REQUIRED);
}
boolean vision2 = false;
//读取upload文件，检验需要上传的文件是否存在
String uploadData = FileUtils.readFile(path + File.separator + "results" +File.separator+"upload.json");
JSONObject uploadJson = null;
JSONArray array = null;
if(uploadData!=null) {
uploadJson = JSONObject.parseObject(uploadData);
array = uploadJson.getJSONArray("upload");
}
if(array == null){
throw new Exception("upload.json数据出错");
}
JSONObject fileJson = null;
String fileName = "";
String meshfix = ""; //双模型时候会有改文件路径
for(int i = 0, len = array.size(); i < len; i++){
fileJson = array.getJSONObject(i);
fileName = fileJson.getString("file");
//文件不存在抛出异常
if(!new File(path + File.separator + "results" +File.separator + fileName).exists()){
throw new Exception(path + File.separator + "results" +File.separator + fileName+"文件不存在");
}
//判断是否有vision2.txt
if("vision2.txt".equals(fileName)){
vision2 = true;
}
//tex文件夹
if(fileJson.getIntValue("clazz") == 2 && !fileJson.containsKey("pack-file")){
if(fileName.contains("meshfix.txt")){
meshfix = fileName;
}else {
map.put(path + File.separator + "results" +File.separator+ fileName,"images/images"+
projectNum+"/"+ ConstantFileName.modelUUID+"_50k_texture_jpg_high1/"+fileName.replace("tex/", ""));
}
continue;
}
//high文件夹
if(fileJson.getIntValue("clazz") == 3){
map.put(path + File.separator + "results" +File.separator+ fileName,"images/images"+
projectNum+"/pan/high/"+ fileName.replace("high/", ""));
continue;
}
//low文件夹
if(fileJson.getIntValue("clazz") == 4){
map.put(path + File.separator + "results" +File.separator+ fileName,"images/images"+
projectNum+"/pan/low/"+ fileName.replace("low/", ""));
continue;
}
//tiles文件夹
if(fileJson.getIntValue("clazz") == 5 ){
map.put(path + File.separator + "results" + File.separator+ fileName,"images/images"+
projectNum+ File.separator + fileName);
continue;
}
//updown文件复制一份到ecs中并去掉换行符
if(fileJson.getIntValue("clazz") == 10){
String updown = FileUtils.readFile(path + File.separator + "results" +File.separator+ fileName);
JSONObject updownJson = JSONObject.parseObject(updown);
FileUtils.writeFile(ConstantFilePath.SCENE_PATH + "data" + File.separator + "data" + projectNum +
File.separator + fileName.replace("updown", "mapping"), updownJson.toString());
continue;
}
//video视频文件或封面图
if(fileJson.getIntValue("clazz") == 11 || fileJson.getIntValue("clazz") == 12){
map.put(path + File.separator + "results" + File.separator+ fileName,"video/video"+
projectNum+ File.separator + fileName.replace("videos/", ""));
}
//2048的模型和贴图
if(fileJson.getIntValue("clazz") == 16){
map.put(path + File.separator + "results" + File.separator+ fileName,"data/data"+
projectNum+ File.separator + fileName);
}
}
CreateObjUtil.convertTxtToDam( path + File.separator + "results" + File.separator+"tex"+File.separator+"modeldata.txt", path + File.separator + "results" +File.separator+ ConstantFileName.modelUUID+"_50k.dam");
CreateObjUtil.convertDamToLzma(path + File.separator + "results");
CreateObjUtil.convertTxtToDam( path + File.separator + "results" +File.separator+"tex"+File.separator+"modeldata.txt", path + File.separator + "results" + File.separator+ConstantFileName.modelUUID+"_50k.dam");
//有meshfix，表示双模型
if(!"".equals(meshfix)){
CreateObjUtil.convertTxtToDam( path + File.separator + "results" + File.separator+meshfix, path + File.separator + "results" +File.separator+ ConstantFileName.modelUUID+"_50k2.dam");
CreateObjUtil.convertDamToLzma2(path + File.separator + "results");
CreateObjUtil.convertTxtToDam( path + File.separator + "results" +File.separator+meshfix, path + File.separator + "results" + File.separator+ConstantFileName.modelUUID+"_50k2.dam");
map.put(path + File.separator + "results" +File.separator+ConstantFileName.modelUUID+"_50k2.dam.lzma", "images/images"+projectNum+"/"+ConstantFileName.modelUUID+"_50k2.dam.lzma");
map.put(path + File.separator + "results" +File.separator+ConstantFileName.modelUUID+"_50k2.dam", "images/images"+projectNum+"/"+ConstantFileName.modelUUID+"_50k2.dam");
}
CreateObjUtil.convertTxtToVisionmodeldata(path + File.separator + "results" +File.separator+"vision.txt",path + File.separator + "results" +File.separator+"vision.modeldata");
//8目相机有两个vision.txt因此第二个叫vision2.txt
if(vision2){
CreateObjUtil.convertTxtToVisionmodeldata(path + File.separator + "results" +File.separator+"vision2.txt",path + File.separator + "results" +File.separator+"vision2.modeldata");
map.put(path + File.separator + "results" +File.separator+"vision2.modeldata", "images/images"+projectNum+"/"+"vision2.modeldata");
}
log.info("数据转换完成："+projectNum);
File file = new File(path + File.separator + "results" +File.separator+ConstantFileName.modelUUID+"_50k.dam.lzma");
while(!file.exists())
{
Thread.sleep(60000);
}
map.put(path + File.separator + "results" +File.separator+"vision.modeldata", "images/images"+projectNum+"/"+"vision.modeldata");
map.put(path + File.separator + "results" +File.separator+ConstantFileName.modelUUID+"_50k.dam.lzma", "images/images"+projectNum+"/"+ConstantFileName.modelUUID+"_50k.dam.lzma");
map.put(path + File.separator + "results" +File.separator+ConstantFileName.modelUUID+"_50k.dam", "images/images"+projectNum+"/"+ConstantFileName.modelUUID+"_50k.dam");
file = new File(ConstantFilePath.SCENE_PATH+"data"+File.separator+"data"+projectNum);
if(!file.exists())
{
file.mkdir();
}
FileUtils.copyFile(path + File.separator + "results" +File.separator+"floor.json", ConstantFilePath.SCENE_PATH+"data"+File.separator+"data"+projectNum+File.separator+"floor.json", true);
log.info("floor.json路径："+ path + File.separator + "results" +File.separator+"floor.json");
map.put(path + File.separator + "results" +File.separator+"floor.json","data/data"+projectNum+"/floor.json");
log.info("准备上传文件到oss："+projectNum);
uploadToOssUtil.uploadMulFiles(map);
return ResultData.ok("上传完成");
}
@Override
public ResultData updateStatusByScene(SceneParamVO param) throws Exception{
String sceneNum = param.getNum();
Integer status = param.getStatus();
if(StrUtil.isEmpty(sceneNum)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
ScenePro scenePro = sceneProService.findBySceneNum(sceneNum);
if(scenePro != null){
scenePro.setSceneStatus(status);
sceneProService.updateById(scenePro);
SceneProEdit sceneProEdit = sceneProEditService.findByProId(scenePro.getId());
SceneProEditExt sceneProEditExt = sceneProEditExtService.getByProEditId(sceneProEdit.getId());
sceneProEdit.setVersion(sceneProEdit.getVersion() + 1);
sceneProEdit.setFloorEditVer(sceneProEdit.getFloorEditVer() + 1);
sceneProEdit.setFloorPublishVer(sceneProEdit.getFloorPublishVer() + 1);
sceneProEditService.updateById(sceneProEdit);
sceneProEditExt.setImagesVersion(sceneProEditExt.getImagesVersion() + 1);
sceneProEditExt.setVideosUser(null);
sceneProEditExtService.updateById(sceneProEditExt);
}
return ResultData.ok();
}
@Override
public ResultData getStatusByScene(SceneParamVO param) throws Exception{
String sceneNum = param.getNum();
if(StrUtil.isEmpty(sceneNum)){
throw new BusinessException(ErrorCode.PARAM_REQUIRED);
}
ScenePro scenePro = sceneProService.findBySceneNum(sceneNum);
if(scenePro != null){
return ResultData.ok(scenePro.getSceneStatus() == -2? 1 : scenePro.getSceneStatus());
}
return ResultData.ok();
}
@Override
public ResultData checkDownLoad(String sceneNum) {
if(StringUtils.isEmpty(sceneNum)){
throw new BusinessException(ErrorCode.MISSING_REQUIRED_PARAMETERS);
}
ScenePro scenePro = sceneProService.findBySceneNum(sceneNum);
if(scenePro == null ){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
SceneProEdit sceneProEdit = sceneProEditService.findByProId(scenePro.getId());
if(sceneProEdit == null){
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
}
//downloadStatus,1打包资源下载，2已下载过，3下载过，并且没有修改过，无需打包直接返回下载地址，-1没下载次数不足
SceneDownloadLog sceneDownloadLogEntity = sceneDownloadLogService.findByStatusAndNum(sceneNum, 0);
Map result = new HashMap<>();
if(sceneDownloadLogEntity != null){
result.put("downloadStatus", 1);
return ResultData.ok(result);
}
sceneDownloadLogEntity = sceneDownloadLogService.findByStatusAndNum(sceneNum, 1);
//3下载过，并且没有修改过
if(sceneDownloadLogEntity != null && sceneDownloadLogEntity.getSceneVersion().intValue() ==
sceneProEdit.getVersion()){
result.put("downloadStatus", 3);
result.put("downloadUrl", sceneDownloadLogEntity.getDownloadUrl());
return ResultData.ok(result);
}
//下载过
if(sceneDownloadLogEntity != null){
result.put("downloadStatus", 2);
// 清除旧的下载信息
redisUtil.del(RedisKey.PREFIX_DOWNLOAD_PROGRESS_V4.concat(sceneNum));
return ResultData.ok(result);
}
//未下载过
result.put("downloadStatus", 0);
return ResultData.ok(result);
}
@Override
public List findByCameraIds(String cameraIds, String startTime, String endTime) {
return this.baseMapper.findByCameraIds(cameraIds, startTime, endTime);
}
@Override
public ResultData getScenesBySnCode(String snCode, String token) {
if(StringUtils.isEmpty(token)){
throw new BusinessException(3004, "无token参数");
}
SSOUser ssoUser = ssoLoginHelper.loginCheck(token);
if(ssoUser == null){
throw new BusinessException(3004, "token参数不正确");
}
if(StringUtil.isEmpty(snCode)){
throw new BusinessException(ErrorCode.MISSING_REQUIRED_PARAMETERS);
}
Camera cameraEntity = platformGoodsClient.getCameraBySnCode(snCode).getData();
if(cameraEntity == null ){
throw new BusinessException(CameraConstant.FAILURE_6018);
}
CameraDetail cameraDetailEntity = platformGoodsClient.getCameraDetailByCameraId(cameraEntity.getId()).getData();
if(cameraDetailEntity == null ){
throw new BusinessException(CameraConstant.FAILURE_6018);
}
if(!cameraDetailEntity.getUserId().equals(ssoUser.getId())){
return ResultData.ok();
}
if(cameraDetailEntity.getCameraType() == 10 ){ //激光场景
List scenesBySnCode = fdkkLaserService.getScenesBySnCode(snCode, token);
return ResultData.ok(scenesBySnCode);
}
List sceneVo = sceneProMapper.getNumAndNameByCameraId(cameraEntity.getId(), ssoUser.getId());
return ResultData.ok(sceneVo);
}
}