|
@@ -7,10 +7,12 @@ import com.alibaba.nacos.shaded.org.checkerframework.checker.units.qual.A;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
+import com.fdkankan.common.constant.ErrorCode;
|
|
|
import com.fdkankan.common.util.FileUtils;
|
|
|
import com.fdkankan.fyun.face.FYunFileServiceInterface;
|
|
|
import com.fdkankan.manage_jp.common.OssPath;
|
|
|
import com.fdkankan.manage_jp.common.PageInfo;
|
|
|
+import com.fdkankan.manage_jp.common.RedisKeyUtil;
|
|
|
import com.fdkankan.manage_jp.common.ResultCode;
|
|
|
import com.fdkankan.manage_jp.entity.Company;
|
|
|
import com.fdkankan.manage_jp.entity.ScenePlus;
|
|
@@ -21,14 +23,22 @@ import com.fdkankan.manage_jp.httpClient.service.LaserService;
|
|
|
import com.fdkankan.manage_jp.mapper.ISceneProMapper;
|
|
|
import com.fdkankan.manage_jp.service.*;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
+import com.fdkankan.manage_jp.util.GenerateNumUtil;
|
|
|
+import com.fdkankan.manage_jp.util.SceneResourcePath;
|
|
|
+import com.fdkankan.manage_jp.util.SnowflakeIdGenerator;
|
|
|
import com.fdkankan.manage_jp.vo.request.SceneParam;
|
|
|
import com.fdkankan.manage_jp.vo.response.SceneVo;
|
|
|
+import com.fdkankan.redis.util.RedisUtil;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
+import java.io.File;
|
|
|
+import java.util.Date;
|
|
|
import java.util.HashMap;
|
|
|
+import java.util.HashSet;
|
|
|
import java.util.List;
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
@@ -56,7 +66,10 @@ public class SceneProServiceImpl extends ServiceImpl<ISceneProMapper, ScenePro>
|
|
|
IScenePlusExtService scenePlusExtService;
|
|
|
@Autowired
|
|
|
FYunFileServiceInterface fYunFileServiceInterface;
|
|
|
-
|
|
|
+ @Autowired
|
|
|
+ IScene3dNumService scene3dNumService;
|
|
|
+ @Autowired
|
|
|
+ SceneCommonService sceneCommonService;
|
|
|
|
|
|
@Override
|
|
|
public Long getCountByUserIds(List<Long> userIds) {
|
|
@@ -182,4 +195,98 @@ public class SceneProServiceImpl extends ServiceImpl<ISceneProMapper, ScenePro>
|
|
|
wrapper.set(ScenePro::getUserId,null);
|
|
|
this.update(wrapper);
|
|
|
}
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public void copyScene(ScenePro scenePro) {
|
|
|
+ if(scenePro.getStatus() !=-2){
|
|
|
+ throw new BusinessException(ResultCode.SCENE_ERROR);
|
|
|
+ }
|
|
|
+ String newNum = scene3dNumService.generateNum();
|
|
|
+ String oldNum = scenePro.getNum();
|
|
|
+
|
|
|
+ String oldDataSource = scenePro.getDataSource();
|
|
|
+ String newDataSource = sceneCommonService.getNewDataSource(oldDataSource);
|
|
|
+
|
|
|
+ log.info("sceneCopy--oldNum:{},oldDataSource:{},newNum:{},newDataSource:{}",
|
|
|
+ oldNum,oldDataSource,newNum,newDataSource);
|
|
|
+
|
|
|
+
|
|
|
+ Long sceneProId = scenePro.getId();
|
|
|
+ String oldSceneName = scenePro.getSceneName();
|
|
|
+ scenePro.setId(null);
|
|
|
+ scenePro.setNum(newNum);
|
|
|
+ scenePro.setSceneName(scenePro.getSceneName() +"(copy)");
|
|
|
+ scenePro.setViewCount(0);
|
|
|
+ scenePro.setWebSite(scenePro.getWebSite().replaceAll(scenePro.getNum(),scenePro.getNum()));
|
|
|
+ scenePro.setThumb(scenePro.getWebSite().replaceAll(scenePro.getNum(),scenePro.getNum()));
|
|
|
+ scenePro.setDataSource(newDataSource);
|
|
|
+ this.save(scenePro);
|
|
|
+
|
|
|
+ SceneProEdit oldEditScene = sceneProEditService.getByProId(sceneProId);
|
|
|
+ oldEditScene.setId(null);
|
|
|
+ oldEditScene.setProId(scenePro.getId());
|
|
|
+ oldEditScene.setScreencapVoiceSrc(oldEditScene.getScreencapVoiceSrc() == null ? null : oldEditScene.getScreencapVoiceSrc().replace(oldNum, scenePro.getNum()));
|
|
|
+ oldEditScene.setScreencapVoiceSound(oldEditScene.getScreencapVoiceSound() == null ? null : oldEditScene.getScreencapVoiceSound().replace(oldNum, scenePro.getNum()));
|
|
|
+ oldEditScene.setScreencapVoiceSoundsync(oldEditScene.getScreencapVoiceSoundsync() == null ? null : oldEditScene.getScreencapVoiceSoundsync().replace(oldNum, scenePro.getNum()));
|
|
|
+ oldEditScene.setPlayData(oldEditScene.getPlayData() == null ? null : oldEditScene.getPlayData().replace(oldNum, scenePro.getNum()));
|
|
|
+ oldEditScene.setScreencapThumb(oldEditScene.getScreencapThumb() == null ? null : oldEditScene.getScreencapThumb().replace(oldNum, scenePro.getNum()));
|
|
|
+ oldEditScene.setFloorPlanPng(oldEditScene.getFloorPlanPng() == null ? null : oldEditScene.getFloorPlanPng().replace(oldNum, scenePro.getNum()));
|
|
|
+ sceneProEditService.save(oldEditScene);
|
|
|
+
|
|
|
+ /*
|
|
|
+ *cp oss nas
|
|
|
+ * data/data{SceneNum}
|
|
|
+ * images/images{SceneNum}
|
|
|
+ * video/video{SceneNum}
|
|
|
+ * voice/voice{SceneNum}
|
|
|
+ */
|
|
|
+ try {
|
|
|
+ //重新生成编辑页基础设置二维码
|
|
|
+ sceneCommonService.createNewQrCode( newNum,scenePro.getWebSite());
|
|
|
+ //copyDataSource
|
|
|
+ cn.hutool.core.io.FileUtil.copyContent(new File(oldDataSource),new File(newDataSource),true);
|
|
|
+
|
|
|
+ String sourceData = String.format(SceneResourcePath.dataPath, oldNum);
|
|
|
+
|
|
|
+ String targetData = String.format(SceneResourcePath.dataPath, scenePro.getNum());
|
|
|
+ this.copyOssAndNas(oldNum,scenePro.getNum(),sourceData,targetData);
|
|
|
+ //修改 oss status.json ,nas scene.json
|
|
|
+ sceneCommonService.updateOssJson(targetData,oldNum,newNum,"v3");
|
|
|
+ sceneCommonService.updateNasSceneJson(targetData,oldNum,newNum,oldSceneName,scenePro.getSceneName(),"v3");
|
|
|
+
|
|
|
+ String sourceImages = String.format(SceneResourcePath.imagesPath, oldNum);
|
|
|
+ String targetImages = String.format(SceneResourcePath.imagesPath, scenePro.getNum());
|
|
|
+ this.copyOssAndNas(oldNum,scenePro.getNum(),sourceImages,targetImages);
|
|
|
+
|
|
|
+ String sourceVideo = String.format(SceneResourcePath.videoPath, oldNum);
|
|
|
+ String targetVideo = String.format(SceneResourcePath.videoPath, scenePro.getNum());
|
|
|
+ this.copyOssAndNas(oldNum,scenePro.getNum(),sourceVideo,targetVideo);
|
|
|
+
|
|
|
+ String sourceVoice = String.format(SceneResourcePath.voicePath, oldNum);
|
|
|
+ String targetVoice = String.format(SceneResourcePath.voicePath, scenePro.getNum());
|
|
|
+ this.copyOssAndNas(oldNum,scenePro.getNum(),sourceVoice,targetVoice);
|
|
|
+
|
|
|
+ }catch ( Exception e){
|
|
|
+ log.error("复制场景失败-sceneNum:{},error:{}",oldNum,e);
|
|
|
+ scenePro.setStatus(-1);
|
|
|
+ this.updateById(scenePro);
|
|
|
+ throw new BusinessException(-1,"复制失败");
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ private void copyOssAndNas(String oldNum ,String newNum ,String sourcePath,String targetPath){
|
|
|
+ log.info("sceneCopy-ossSource-oldNum:{},newNum:{},sourcePath:{},targetPath:{}",oldNum,newNum,sourcePath,targetPath);
|
|
|
+ fYunFileServiceInterface.copyFileInBucket(sourcePath,targetPath);
|
|
|
+ File fileData = new File(SceneResourcePath.nasBasePath + sourcePath);
|
|
|
+ if(fileData.exists()){
|
|
|
+ cn.hutool.core.io.FileUtil.copyContent(fileData,new File(SceneResourcePath.nasBasePath + targetPath),true);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
}
|