123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566 |
- package com.fdkankan.scene.service.impl;
- import cn.hutool.core.bean.BeanUtil;
- import cn.hutool.core.collection.CollUtil;
- import cn.hutool.core.util.StrUtil;
- import com.alibaba.fastjson.JSON;
- import com.alibaba.fastjson.JSONArray;
- import com.alibaba.fastjson.JSONObject;
- import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
- import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
- import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
- import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
- import com.fdkankan.common.constant.*;
- import com.fdkankan.common.exception.BusinessException;
- import com.fdkankan.common.response.ResultData;
- import com.fdkankan.common.util.ComputerUtil;
- import com.fdkankan.common.util.CreateObjUtil;
- import com.fdkankan.common.util.FileMd5Util;
- import com.fdkankan.common.util.FileUtil;
- import com.fdkankan.common.util.FileUtils;
- import com.fdkankan.fyun.constant.StorageType;
- import com.fdkankan.fyun.oss.UploadToOssUtil;
- import com.fdkankan.platform.api.feign.PlatformGoodsClient;
- import com.fdkankan.platform.api.feign.PlatformUserClient;
- import com.fdkankan.platform.api.dto.CameraDetail;
- import com.fdkankan.platform.api.dto.Company;
- import com.fdkankan.redis.constant.RedisKey;
- import com.fdkankan.redis.constant.RedisLockKey;
- import com.fdkankan.redis.util.RedisLockUtil;
- import com.fdkankan.redis.util.RedisUtil;
- import com.fdkankan.scene.api.dto.SceneInfoDTO;
- import com.fdkankan.scene.bean.SceneJsonBean;
- import com.fdkankan.scene.entity.SceneDataDownload;
- import com.fdkankan.scene.entity.SceneEditControls;
- import com.fdkankan.scene.entity.SceneEditInfo;
- import com.fdkankan.scene.entity.SceneEditInfoExt;
- import com.fdkankan.scene.entity.ScenePlus;
- import com.fdkankan.scene.entity.ScenePlusExt;
- import com.fdkankan.scene.entity.ScenePro;
- import com.fdkankan.scene.factory.FloorLogoHandlerFactory;
- import com.fdkankan.scene.factory.MusicHandlerFactory;
- import com.fdkankan.scene.factory.ScreenshotHandlerFactory;
- import com.fdkankan.scene.mapper.ISceneEditInfoMapper;
- import com.fdkankan.scene.service.ISceneDataDownloadService;
- import com.fdkankan.scene.service.ISceneEditControlsService;
- import com.fdkankan.scene.service.ISceneEditInfoExtService;
- import com.fdkankan.scene.service.ISceneEditInfoService;
- import com.fdkankan.scene.service.IScenePlusExtService;
- import com.fdkankan.scene.service.IScenePlusService;
- import com.fdkankan.scene.service.ISceneProExtService;
- import com.fdkankan.scene.service.ISceneProService;
- import com.fdkankan.scene.vo.*;
- import com.google.common.collect.Lists;
- import com.google.errorprone.annotations.Var;
- import java.io.File;
- import java.util.Arrays;
- import java.util.Date;
- import java.util.HashMap;
- import java.util.List;
- import java.util.Map;
- import java.util.Map.Entry;
- import java.util.UUID;
- import java.util.stream.Collectors;
- import lombok.extern.slf4j.Slf4j;
- import org.springframework.beans.factory.annotation.Autowired;
- import org.springframework.beans.factory.annotation.Value;
- import org.springframework.stereotype.Service;
- import java.io.IOException;
- import java.util.Calendar;
- import java.util.Objects;
- import org.springframework.transaction.annotation.Transactional;
- import org.springframework.web.multipart.MultipartFile;
- /**
- * <p>
- * 服务实现类
- * </p>
- *
- * @author
- * @since 2022-01-18
- */
- @Slf4j
- @Service
- public class SceneEditInfoServiceImpl extends ServiceImpl<ISceneEditInfoMapper, SceneEditInfo> implements ISceneEditInfoService {
- @Value("${oss.prefix.ali}")
- private String prefixAli;
- @Value("${oss.prefix.url}")
- private String ossUrlPrefix;
- @Value("${upload.type}")
- private String type;
- @Value("${oss.bucket:4dkankan}")
- private String bucket;
- @Value("${main.url}")
- private String mainUrl;
- @Value("${ecs.checkFile.maxTimes:5}")
- private int maxCheckTimes;
- @Value("${ecs.checkFile.waitTime:5000}")
- private int waitTime;
- @Autowired
- private ISceneEditControlsService sceneEditControlsService;
- @Autowired
- private ISceneProService sceneProService;
- @Autowired
- private UploadToOssUtil uploadToOssUtil;
- @Autowired
- RedisUtil redisUtil;
- @Autowired
- private ISceneProExtService sceneProExtService;
- @Autowired
- private RedisLockUtil redisLockUtil;
- @Autowired
- ISceneDataDownloadService sceneDataDownloadService;
- @Autowired
- PlatformGoodsClient platformGoodsClient;
- @Autowired
- PlatformUserClient platformUserClient;
- @Autowired
- private ISceneEditInfoExtService sceneEditInfoExtService;
- @Autowired
- IScenePlusService scenePlusService;
- @Autowired
- IScenePlusExtService scenePlusExtService;
- @Transactional
- @Override
- public SceneEditInfoVO saveScene(SceneEditInfoParamVO param) {
- ScenePlus scenePlus = scenePlusService.getScenePlusByNum(param.getNum());
- // ScenePro scenePro = sceneProService.findBySceneNum(param.getNum());
- if(Objects.isNull(scenePlus)){
- throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
- }
- SceneEditInfo sceneEditInfoDb = this.getByScenePlusId(scenePlus.getId());
- SceneEditControls sceneEditControlsDb = null;
- if(Objects.nonNull(sceneEditInfoDb)){
- sceneEditControlsDb = sceneEditControlsService.getBySceneEditId(sceneEditInfoDb.getId());
- }
- SceneEditInfo sceneEditInfo = BeanUtil.copyProperties(param, SceneEditInfo.class);
- sceneEditInfo.setScenePlusId(scenePlus.getId());
- if(Objects.isNull(sceneEditInfoDb)){
- this.save(sceneEditInfo);
- }else{
- sceneEditInfo.setId(sceneEditInfoDb.getId());
- this.updateById(sceneEditInfo);
- }
- if(Objects.nonNull(param.getControls())){
- SceneEditControls sceneEditControls = BeanUtil.copyProperties(param.getControls(), SceneEditControls.class);
- sceneEditControls.setEditInfoId(sceneEditInfo.getId());
- if(Objects.isNull(sceneEditControlsDb)){
- sceneEditControlsService.save(sceneEditControls);
- }else{
- sceneEditControls.setId(sceneEditControlsDb.getId());
- sceneEditControlsService.updateById(sceneEditControls);
- }
- }
- SceneEditInfoVO result = BeanUtil.copyProperties(param, SceneEditInfoVO.class);
- result.setCreateTime(sceneEditInfo.getCreateTime());
- return result;
- }
- @Override
- public SceneEditInfo getBySceneProId(long sceneProId) {
- return this.getOne(new LambdaQueryWrapper<SceneEditInfo>()
- .eq(SceneEditInfo::getSceneProId, sceneProId));
- }
- @Override
- public SceneEditInfo getByScenePlusId(long scenePlusId) {
- return this.getOne(new LambdaQueryWrapper<SceneEditInfo>()
- .eq(SceneEditInfo::getScenePlusId, scenePlusId));
- }
- @Transactional
- @Override
- public ResultData publicScene(SceneEditInfoParamVO param) throws Exception{
- String num = param.getNum();
- //根据场景码查询数据库
- ScenePro scenePro = sceneProService.findBySceneNum(num);
- ScenePlus scenePlus = scenePlusService.getScenePlusByNum(num);
- ScenePlusExt scenePlusExt = scenePlusExtService.getScenePlusExtByPlusId(scenePlus.getId());
- SceneEditInfo sceneEditInfo = this.getByScenePlusId(scenePlus.getId());
- SceneEditInfoExt sceneEditInfoExt = null;
- SceneEditControls sceneEditControls = null;
- if(sceneEditInfo == null){
- sceneEditInfo = new SceneEditInfo();
- sceneEditInfo.setSceneProId(scenePlus.getId());
- }else{
- sceneEditControls = sceneEditControlsService.getBySceneEditId(sceneEditInfo.getId());
- sceneEditInfoExt = sceneEditInfoExtService.getByEditInfoId(sceneEditInfo.getId());
- }
- if(sceneEditInfoExt == null){
- sceneEditInfoExt = new SceneEditInfoExt();
- sceneEditInfoExt.setFloorPlanAngle(0f);
- sceneEditInfoExt.setFloorPlanCompass(0f);
- }
- // if(sceneEditControls == null){
- // sceneEditControls = new SceneEditControls();
- // }
- //生成sceneJson
- SceneJsonBean sceneJson = new SceneJsonBean();
- BeanUtil.copyProperties(sceneEditInfoExt, sceneJson);
- BeanUtil.copyProperties(sceneEditInfo, sceneJson);
- SceneEditControlsVO sceneEditControlsVO = BeanUtil.copyProperties(sceneEditControls, SceneEditControlsVO.class);
- sceneJson.setControls(sceneEditControlsVO);
- sceneJson.setNum(num);
- // if(StrUtil.isNotEmpty(sceneEditInfo.getFloorPlanPath())){
- // sceneJson.setFloorPlanPaths(sceneEditInfo.getFloorPlanPath().split(","));
- // }
- sceneJson.setCreateTime(scenePlus.getCreateTime());
- sceneJson.setSceneResolution(scenePlusExt.getSceneResolution());
- sceneJson.setSceneFrom(scenePlusExt.getSceneFrom());
- if(StrUtil.isNotEmpty(scenePlusExt.getVideos())){
- sceneJson.setVideos(JSON.parseObject(scenePlusExt.getVideos()));
- }
- //处理热点数据,生成hot.json
- this.publicHotData(num, sceneEditInfo);
- // TODO: 2022/3/2 这里的逻辑放在上传球幕视频接口中做了,这里先暂时注释掉,以后要删除
- //处理球幕视频
- // this.buildVideo(sceneEditInfo, sceneProExt.getDataSource(), sceneNum);
- //本地写sceneJson文件
- String localSceneJsonPath = String.format(ConstantFilePath.SCENE_PATH_FORMAT, num);
- FileUtils.writeFile(localSceneJsonPath, JSON.toJSONString(sceneJson));
- //上传sceneJson文件
- String sceneJsonPath = String.format(UploadFilePath.DATA_VIEW_PATH+"scene.json", num);
- uploadToOssUtil.upload(JSON.toJSONBytes(sceneJson), sceneJsonPath);
- //sceneJson放入缓存
- String key = String.format(RedisKey.SCENE_JSON, num);
- redisUtil.set(key, JSON.toJSONString(sceneJson));
- //删除发布数据中的user目录
- String publicUserPath = String.format(UploadFilePath.USER_VIEW_PATH, num);
- uploadToOssUtil.deleteFile(publicUserPath);
- // String editUserPath = String.format(UploadFilePath.USER_EDIT_PATH, sceneNum);
- //复制编辑目录到发布目录
- String editPath = String.format(UploadFilePath.USER_EDIT_PATH, param.getNum());
- String viewPath = String.format(UploadFilePath.USER_VIEW_PATH, param.getNum());
- uploadToOssUtil.copyFiles(editPath,viewPath);
- //入库
- if(sceneEditInfo.getId() == null){
- this.save(sceneEditInfo);
- }else{
- this.updateById(sceneEditInfo);
- }
- sceneEditInfoExt.setSceneProId(scenePro.getId());
- sceneEditInfoExt.setScenePlusId(scenePlus.getId());
- sceneEditInfoExt.setEditInfoId(sceneEditInfo.getId());
- sceneEditInfoExtService.saveOrUpdate(sceneEditInfoExt);
- // sceneEditControls.setEditInfoId(sceneEditInfo.getId());
- // if(sceneEditControls.getId() == null){
- // sceneEditControlsService.save(sceneEditControls);
- // }else{
- // sceneEditControlsService.updateById(sceneEditControls);
- // }
- return ResultData.ok();
- }
- private void buildVideo(SceneEditInfo sceneEditInfo, String path, String num) throws Exception{
- if(CommonStatus.NO.equals(sceneEditInfo.getBuildVideoStatus())){
- return;
- }
- 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";
- log.info("球幕视频路径:{}", target + File.separator + "extras/video");
- File video = new File(target + File.separator + "extras/video");
- //如果文件夹或者文件不存在,跳出
- if(!video.exists() || video.listFiles() == null || video.listFiles().length == 0){
- return;
- }
- String userEditPath = String.format(UploadFilePath.USER_EDIT_PATH, num);
- for(String videoName : video.list()){
- log.info("球幕视频名称:{}", videoName);
- uploadToOssUtil.upload(target + File.separator + "extras/video/" + videoName,userEditPath + videoName);
- CreateObjUtil.mp4ToFlv(target + File.separator + "extras/video/" + videoName,
- target + File.separator + "extras/video/" + videoName.replace("mp4", "flv"));
- uploadToOssUtil.upload(target + File.separator + "extras/video/" + videoName.replace("mp4", "flv"),userEditPath + videoName.replace("mp4", "flv"));
- //覆盖原始视频资源
- FileUtils.copyFile(target + File.separator + "extras/video/" + videoName,
- path + File.separator + "caches/videos/" + videoName, true);
- }
- FileUtils.deleteDirectory(target + File.separator + "extras/video/");
- //重置状态
- sceneEditInfo.setBuildVideoStatus(CommonStatus.NO.code());
- }
- private void publicHotData(String sceneNum, SceneEditInfo sceneEditInfo) throws IOException {
- String hotDataKey = String.format(RedisKey.SCENE_HOT_DATA, sceneNum);
- Map<String, String> hotMap = redisUtil.hmget(hotDataKey);
- List<String> hotList = Lists.newArrayList();
- hotMap.entrySet().stream().forEach(entry->{
- if(StrUtil.isNotEmpty(entry.getValue())){
- hotList.add(entry.getValue());
- }
- });
- if(CollUtil.isNotEmpty(hotList)){
- JSONArray jsonhots = new JSONArray();
- hotList.stream().forEach(hot->{
- jsonhots.add(JSONObject.parseObject(hot));
- });
- String hotJsonPath = String.format(UploadFilePath.USER_EDIT_PATH, sceneNum) + "hot.json";
- uploadToOssUtil.upload(jsonhots.toString().getBytes(), hotJsonPath);
- //修改tags状态为是,标识有热点数据
- this.saveTagsToSceneEditInfo(sceneNum, sceneEditInfo);
- }
- }
- @Override
- public SceneInfoVO getSceneInfo(@Var SceneInfoParamVO param) throws Exception{
- SceneInfoReqType sceneInfoReqType = SceneInfoReqType.get(param.getReqType());
- switch (sceneInfoReqType){
- //如果是编辑页面请求,查数据库
- case EDIT:
- return this.getSceneInfo4Edit(param.getNum());
- //如果是查看页面请求,查redis
- case VIEW:
- return this.getSceneInfo4View(param.getNum());
- }
- return null;
- }
- @Override
- public SceneInfoDTO getSceneInfo4Download(SceneInfoParamVO param) throws Exception{
- SceneInfoVO sceneInfo4View = this.getSceneInfo4View(param.getNum());
- if(Objects.isNull(sceneInfo4View)){
- return null;
- }
- SceneInfoDTO sceneInfoDTO = BeanUtil.copyProperties(sceneInfo4View, SceneInfoDTO.class);
- ScenePlus scenePlus = scenePlusService.getScenePlusByNum(param.getNum());
- sceneInfoDTO.setSceneSource(scenePlus.getSceneSource());
- return sceneInfoDTO;
- }
- /**
- * <p>
- 编辑页面获取场景详情信息
- * </p>
- * @author dengsixing
- * @date 2022/1/21
- * @param num
- * @return com.fdkankan.scene.vo.SceneInfoVO
- **/
- private SceneInfoVO getSceneInfo4Edit(String num) throws Exception{
- // ScenePro scenePro = sceneProService.findBySceneNum(num);
- ScenePlus scenePlus = scenePlusService.getScenePlusByNum(num);
- if(Objects.isNull(scenePlus)){
- throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
- }
- // SceneProExt sceneProExt = sceneProExtService.findBySceneProId(scenePro.getId());
- ScenePlusExt scenePlusExt = scenePlusExtService.getScenePlusExtByPlusId(scenePlus.getId());
- SceneEditInfo sceneEditInfo = this.getByScenePlusId(scenePlus.getId());
- if(Objects.isNull(sceneEditInfo)){
- throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
- }
- SceneEditInfoExt sceneEditInfoExt = sceneEditInfoExtService.getByEditInfoId(sceneEditInfo.getId());
- SceneEditControls sceneEditControls = sceneEditControlsService.getBySceneEditId(sceneEditInfo.getId());
- SceneInfoVO sceneInfoVO = new SceneInfoVO();
- BeanUtil.copyProperties(sceneEditInfoExt, sceneInfoVO);
- BeanUtil.copyProperties(sceneEditInfo, sceneInfoVO);
- if(Objects.isNull(sceneInfoVO.getFloorPlanAngle())){
- sceneInfoVO.setFloorPlanAngle(0f);
- }
- if(Objects.isNull(sceneInfoVO.getFloorPlanCompass())){
- sceneInfoVO.setFloorPlanCompass(0f);
- }
- sceneInfoVO.setControls(BeanUtil.copyProperties(sceneEditControls, SceneEditControlsVO.class));
- sceneInfoVO.setNum(num);
- //生成sceneJson
- // if(StrUtil.isNotEmpty(sceneEditInfo.getFloorPlanPath())){
- // sceneInfoVO.setFloorPlanPaths(sceneEditInfo.getFloorPlanPath().split(","));
- // }
- sceneInfoVO.setCreateTime(scenePlus.getCreateTime());
- sceneInfoVO.setSceneResolution(scenePlusExt.getSceneResolution());
- sceneInfoVO.setSceneFrom(scenePlusExt.getSceneFrom());
- sceneInfoVO.setVideos(scenePlusExt.getVideos());
- this.setExtData(sceneInfoVO, scenePlus.getCameraId());
- return sceneInfoVO;
- }
- /**
- * <p>
- getInfo接口返回字段扩展
- * </p>
- * @author dengsixing
- * @date 2022/3/9
- **/
- private void setExtData(SceneInfoVO sceneInfoVO, Long cameraId) throws Exception{
- ResultData<CameraDetail> cameraResultData = platformGoodsClient.getCameraDetailByCameraId(cameraId);
- if(!cameraResultData.getSuccess()){
- throw new Exception(ServerCode.FEIGN_REQUEST_FAILD.message());
- }
- CameraDetail camera = cameraResultData.getData();
- if(Objects.isNull(camera)){
- throw new BusinessException(ErrorCode.FAILURE_CODE_7010);
- }
- if(Objects.isNull(camera.getCompanyId())){
- return;
- }
- ResultData<Company> companyResultData = platformUserClient.getCompanyById(camera.getCompanyId());
- if(!companyResultData.getSuccess()){
- throw new Exception(ServerCode.FEIGN_REQUEST_FAILD.message());
- }
- Company company = companyResultData.getData();
- if(Objects.isNull(company)){
- return;
- }
- sceneInfoVO.setDataSync(company.getDataSync());
- }
- /**
- * <p>
- 查看页面获取场景详情信息
- * </p>
- * @author dengsixing
- * @date 2022/1/21
- * @param num
- * @return com.fdkankan.scene.vo.SceneInfoVO
- **/
- private SceneInfoVO getSceneInfo4View(String num) throws Exception{
- // ScenePro scenePro = sceneProService.findBySceneNum(num);
- ScenePlus scenePlus = scenePlusService.getScenePlusByNum(num);
- String key = String.format(RedisKey.SCENE_JSON, num);
- String sceneJson = redisUtil.get(key);
- SceneInfoVO sceneInfoVO = null;
- //先查询redis
- if(StrUtil.isNotEmpty(sceneJson)) {
- sceneInfoVO = JSON.parseObject(sceneJson, SceneInfoVO.class);
- this.setExtData(sceneInfoVO, scenePlus.getCameraId());
- sceneInfoVO.setScenePassword(null);
- if(Objects.isNull(sceneInfoVO.getFloorPlanAngle())){
- sceneInfoVO.setFloorPlanAngle(0f);
- }
- if(Objects.isNull(sceneInfoVO.getFloorPlanCompass())){
- sceneInfoVO.setFloorPlanCompass(0f);
- }
- return sceneInfoVO;
- }
- //如果redis没找到,从scene.json中获取
- String objectName = String.format(ConstantFilePath.SCENE_VIEW_DATA_DATA_SCENEJSON, num);
- String objectContent = uploadToOssUtil.getObjectContent(bucket, objectName);
- if(StrUtil.isEmpty(objectContent))
- return null;
- sceneInfoVO = JSON.parseObject(objectContent, SceneInfoVO.class);
- this.setExtData(sceneInfoVO, scenePlus.getCameraId());
- sceneInfoVO.setScenePassword(null);
- if(Objects.isNull(sceneInfoVO.getFloorPlanAngle())){
- sceneInfoVO.setFloorPlanAngle(0f);
- }
- if(Objects.isNull(sceneInfoVO.getFloorPlanCompass())){
- sceneInfoVO.setFloorPlanCompass(0f);
- }
- redisUtil.set(key, JSON.toJSONString(sceneInfoVO));
- return sceneInfoVO;
- }
- @Override
- // @Transactional
- public ResultData saveUpload(SaveUploadParamVO param) throws Exception {
- FileBizType fileBizType = FileBizType.get(param.getBizType());
- String num = param.getNum();
- String fileInfo = param.getFileInfo();
- if(Objects.isNull(fileBizType)){
- throw new BusinessException(ErrorCode.FAILURE_CODE_7003);
- }
- switch (fileBizType){
- case MUSIC:
- return new MusicHandlerFactory().getHandler().save(num, fileInfo);
- case FLOOR_LOGO:
- return new FloorLogoHandlerFactory().getHandler().save(num, fileInfo);
- // case FLOOR_PLAN:
- // return new FloorPlanHandlerFactory().getHandler().save(num, fileInfo);
- case SCREENSHOT:
- return new ScreenshotHandlerFactory().getHandler().save(num, fileInfo);
- }
- return ResultData.ok();
- }
- @Override
- public ResultData saveCad(BaseDataParamVO param) throws Exception {
- String num = param.getNum();
- // ScenePro scenePro = sceneProService.findBySceneNum(num);
- ScenePlus scenePlus = scenePlusService.getScenePlusByNum(num);
- if(Objects.isNull(scenePlus))
- throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
- String editDataPath = String.format(UploadFilePath.DATA_EDIT_PATH, num);
- String editUserPath = String.format(UploadFilePath.USER_EDIT_PATH, num);
- String localDataPath = String.format(ConstantFilePath.DATABUFFER_FORMAT, num);
- String floorCadUrl = ossUrlPrefix + editDataPath + "floorplan_cad.json?t=" + System.currentTimeMillis();
- String floorUserUrl = ossUrlPrefix + editUserPath + "floorplan_user.json?t=" + System.currentTimeMillis();
- JSONObject fileInfoJson = JSON.parseObject(param.getData());
- String filePathStr = null;
- String floors = fileInfoJson.getString("floors");
- String cadInfo = null;
- Float angel = null;
- Float compass = null;
- String floorJsonData = fileInfoJson.getString("floorJsonData");
- if(StrUtil.isNotBlank(floorJsonData)){
- JSONObject jsonObject = JSON.parseObject(floorJsonData);
- cadInfo = jsonObject.getString("cadInfo");
- angel = jsonObject.getFloat("angle");
- compass = jsonObject.getFloat("compass");
- }
- // String filePaths = fileInfoJson.getString("filePaths");
- // Byte reSet = fileInfoJson.getByte("reset");
- //户型图文件路径
- // if(StrUtil.isNotEmpty(filePaths)){
- // cn.hutool.json.JSONArray filePathsArrs = JSONUtil.parseArray(filePaths);
- // List<String> filePathsList = filePathsArrs.toList(String.class);
- // StringBuilder filePathBuilder = new StringBuilder();
- // filePathsList.parallelStream().forEach(path -> {
- // filePathBuilder.append(",").append(path);
- // });
- // filePathStr = filePathBuilder.substring(1);
- // }
- //处理户型图数据
- JSONObject floorUserJson = null;
- if(StrUtil.isNotEmpty(floors)) {
- //如果入参是空,则加载服务器的
- if(StrUtil.isEmpty(floorJsonData)){
- if (!StorageType.LOCAL.code().equals(this.type)) {// TODO: 2022/2/15 这里有可能有问题,可能还需要考虑本地部署的情况
- FileUtils.downLoadFromUrl(floorUserUrl, "floorplan_user.json", localDataPath);
- }
- floorJsonData = FileUtils.readFile(localDataPath + "floorplan_user.json");
- }
- //如果floors不为空,需要根据对应楼层id修改楼层名称
- if (StrUtil.isNotEmpty(floorJsonData)) {
- floorUserJson = this.updateFloorName(floors, floorJsonData);
- floorJsonData = floorUserJson.toJSONString();
- }
- }
- //上传floorplan_user.json文件
- FileUtils.writeFile(localDataPath + "floorplan_user.json", floorJsonData);
- uploadToOssUtil.upload(localDataPath + "floorplan_user.json", editUserPath + "floorplan_user.json");
- //如果floors不为空,需要根据对应楼层id修改楼层名称
- if(StrUtil.isNotEmpty(floors)) {
- if (!StorageType.LOCAL.code().equals(this.type)) {// TODO: 2022/2/15 这里有可能有问题,可能还需要考虑本地部署的情况
- FileUtils.downLoadFromUrl(floorCadUrl, "floorplan_cad.json", localDataPath);
- }
- String floorCadStr = FileUtils.readFile(localDataPath + "floorplan_cad.json");
- if (StrUtil.isNotEmpty(floorCadStr)) {
- JSONObject floorCadJson = this.updateFloorName(floors, floorCadStr);
- FileUtils.writeFile(localDataPath + "floorplan_cad.json", floorCadJson.toString());
- uploadToOssUtil.upload(localDataPath + "floorplan_cad.json",editDataPath + "floorplan_cad.json");
- }
- }
- //写入数据库
- Byte floorPlanUser = null;
- if(StrUtil.isNotEmpty(floorJsonData)){
- floorPlanUser = CommonStatus.YES.code();
- }
- // if(CommonStatus.YES.code().equals(reSet)){
- // floorPlanUser = CommonStatus.NO.code();
- // }
- SceneEditInfo sceneEditInfoDb = this.getByScenePlusId(scenePlus.getId());
- if(Objects.nonNull(sceneEditInfoDb)){
- LambdaUpdateWrapper<SceneEditInfo> updateWrapper = new LambdaUpdateWrapper<SceneEditInfo>()
- .setSql("version=version+" + 1)
- .eq(SceneEditInfo::getId, sceneEditInfoDb.getId());
- // if(StrUtil.isNotEmpty(filePathStr)){
- // updateWrapper.set(SceneEditInfo::getFloorPlanPath, filePathStr);
- // }
- // if(StrUtil.isNotEmpty(cadInfo)){
- // updateWrapper.set(SceneEditInfo::getCadInfo, cadInfo);
- // }
- if(floorPlanUser != null){
- updateWrapper.set(SceneEditInfo::getFloorPlanUser, floorPlanUser);
- }
- this.update(updateWrapper);
- }else{
- sceneEditInfoDb = new SceneEditInfo();
- sceneEditInfoDb.setScenePlusId(scenePlus.getId());
- // sceneEditInfoDb.setFloorPlanPath(filePathStr);
- // sceneEditInfoDb.setCadInfo(cadInfo);
- sceneEditInfoDb.setFloorPlanUser(floorPlanUser);
- this.save(sceneEditInfoDb);
- }
- SceneEditInfoExt sceneEditInfoExt = sceneEditInfoExtService.getByEditInfoId(sceneEditInfoDb.getId());
- if(Objects.isNull(sceneEditInfoExt)){
- sceneEditInfoExt = new SceneEditInfoExt();
- sceneEditInfoExt.setEditInfoId(sceneEditInfoDb.getId());
- }
- if(Objects.nonNull(angel)){
- sceneEditInfoExt.setFloorPlanAngle(angel);
- }
- if(Objects.nonNull(compass)){
- sceneEditInfoExt.setFloorPlanCompass(compass);
- }
- sceneEditInfoExtService.saveOrUpdate(sceneEditInfoExt);
- return ResultData.ok();
- }
- @Override
- public ResultData resetCad(String num){
- ScenePro scenePro = sceneProService.findBySceneNum(num);
- ScenePlus scenePlus = scenePlusService.getScenePlusByNum(num);
- if(Objects.isNull(scenePlus))
- throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
- SceneEditInfo sceneEditInfoDb = this.getByScenePlusId(scenePlus.getId());
- SceneEditInfoExt sceneEditInfoExt = null;
- if(Objects.nonNull(sceneEditInfoDb)){
- LambdaUpdateWrapper<SceneEditInfo> updateWrapper = new LambdaUpdateWrapper<SceneEditInfo>()
- .setSql("version=version+" + 1)
- .set(SceneEditInfo::getFloorPlanUser, CommonStatus.NO.code())
- .eq(SceneEditInfo::getId, sceneEditInfoDb.getId());
- this.update(updateWrapper);
- sceneEditInfoExt = sceneEditInfoExtService.getByEditInfoId(sceneEditInfoDb.getId());
- }else{
- sceneEditInfoDb = new SceneEditInfo();
- sceneEditInfoDb.setSceneProId(scenePro.getId());
- sceneEditInfoDb.setScenePlusId(scenePlus.getId());
- sceneEditInfoDb.setFloorPlanUser(CommonStatus.NO.code());
- this.save(sceneEditInfoDb);
- }
- if(Objects.isNull(sceneEditInfoExt)){
- sceneEditInfoExt = new SceneEditInfoExt();
- sceneEditInfoExt.setSceneProId(scenePro.getId());
- sceneEditInfoDb.setScenePlusId(scenePlus.getId());
- sceneEditInfoExt.setEditInfoId(sceneEditInfoDb.getId());
- }
- sceneEditInfoExt.setFloorPlanAngle(0f);
- sceneEditInfoExt.setFloorPlanCompass(0f);
- sceneEditInfoExtService.saveOrUpdate(sceneEditInfoExt);
- return ResultData.ok();
- }
- private JSONObject updateFloorName(String sourceFloors, String targeFloors){
- JSONArray sourceFloorsJson = JSON.parseArray(sourceFloors);
- JSONObject targeFloorsJson = JSONObject.parseObject(targeFloors);
- JSONArray array = targeFloorsJson.getJSONArray("floors");
- for (int i = 0; i < array.size(); ++i) {
- JSONObject targetFloor = array.getJSONObject(i);
- int targetId = targetFloor.getIntValue("id");
- for (int j = 0; j < sourceFloorsJson.size(); ++j) {
- JSONObject floor = sourceFloorsJson.getJSONObject(j);
- int id = floor.getIntValue("id");
- String name = floor.getString("name");
- if (targetId != id)
- continue;
- targetFloor.put("name", name);
- }
- }
- return targeFloorsJson;
- }
- @Override
- public void upgradeVersionById(Long id) {
- this.update(new LambdaUpdateWrapper<SceneEditInfo>()
- .setSql("version=version+" + 1)
- .eq(SceneEditInfo::getId, id));
- }
- @Override
- public ResultData uploadPanorama(String num, MultipartFile file) throws Exception {
- //校验压缩包格式
- // log.info("全景图压缩包文件名:" + file.getOriginalFilename());
- // if(!file.getOriginalFilename().endsWith(".zip")){
- // throw new BusinessException(ErrorCode.FAILURE_CODE_7015);
- // }
- if(!file.getOriginalFilename().endsWith(".zip") && !file.getOriginalFilename().endsWith(".jpg")){
- throw new BusinessException(ErrorCode.FAILURE_CODE_7007, "jpg或者zip");
- }
- // ScenePro scenePro = sceneProService.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 = "F:\\test";
- String path = scenePlusExt.getDataSource();
- //全景图计算根目录
- String target = path + "_images";
- //解压缩文件存放目录
- String targetImagesPath = target + "/extras/images";
- //压缩文件保存目录
- String zipTargetFilePath = targetImagesPath + File.separator + file.getOriginalFilename();
- //压缩包保存到本地
- // String cachePath = String.format(ConstantFilePath.SCENE_CACHE_IMAGES, num);
- //先删除本地文件
- FileUtils.deleteDirectory(targetImagesPath);
- File targetFile = new File(zipTargetFilePath);
- if(!targetFile.getParentFile().exists()){
- targetFile.getParentFile().mkdirs();
- }
- file.transferTo(targetFile);
- //如果是压缩包上传,需要解压缩
- if(file.getOriginalFilename().endsWith(".zip")){
- //解压zip包
- FileUtil.unZip(zipTargetFilePath, targetImagesPath);
- // FileUtils.decompress(zipTargetFilePath, targetImagesPath);
- //删除压缩包
- FileUtil.delFile(zipTargetFilePath);
- }
- //判断文件夹目录结构,图片必须放在压缩包根目录下,不支持空文件夹或其他格式文件上传
- File[] files = new File(targetImagesPath).listFiles();
- Arrays.stream(files).forEach(item->{
- if(item.isDirectory()){
- throw new BusinessException(ErrorCode.FAILURE_CODE_7018);
- }
- });
- //获取解压后的文件列表
- List<String> uploadFileList = FileUtil.getFileList(targetImagesPath);
- if(CollUtil.isEmpty(uploadFileList)){
- throw new BusinessException(ErrorCode.FAILURE_CODE_5062);
- }
- //判断是否有可用的jpg文件
- boolean existJpg = false;
- uploadFileList = FileUtil.getFileList(targetImagesPath);
- if(CollUtil.isNotEmpty(uploadFileList)){
- existJpg = uploadFileList.stream().anyMatch(str -> {
- if(str.endsWith(".jpg")){
- return true;
- }
- return false;
- });
- }
- if(!existJpg){
- throw new BusinessException(ErrorCode.FAILURE_CODE_5062);
- }
- //列出caches/images中的文件列表
- String imgCachePath = String.format(UploadFilePath.IMG_CACHES_PATH, num);
- List<String> keyList = uploadToOssUtil.listKeys(imgCachePath);
- //比对图片列表,不存在的要返回名称集合
- List<String> notExistFileList = uploadFileList.stream().filter(filePath -> {
- filePath = filePath.substring(filePath.lastIndexOf(File.separator) + 1);
- for (String key : keyList) {
- key = key.substring(key.lastIndexOf("/") + 1);
- if (filePath.equals(key)) {
- return false;
- }
- }
- return true;
- }).collect(Collectors.toList());
- if(CollUtil.isNotEmpty(notExistFileList)){
- //删除错误文件
- notExistFileList.parallelStream().forEach(filePath->{
- FileUtils.deleteFile(filePath);
- });
- }
- //判断成功的图片,如果成功图片为0,就直接返回,不需要执行算法
- uploadFileList = FileUtil.getFileList(targetImagesPath);
- if(CollUtil.isEmpty(uploadFileList)){
- if(CollUtil.isNotEmpty(notExistFileList)){
- notExistFileList = notExistFileList.stream().map(filePath -> {
- return filePath.substring(filePath.lastIndexOf(File.separator) + 1);
- }).collect(Collectors.toList());
- }
- return ResultData.ok(new UploadPanoramaVO(0, notExistFileList));
- }
- //上传
- Map<String, String> map = new HashMap<>();
- uploadFileList.stream().forEach(filePath->{
- map.put(filePath, filePath.replace(targetImagesPath, imgCachePath));
- });
- String imgViewPath = String.format(UploadFilePath.IMG_VIEW_PATH, num);
- if(StorageType.AWS.code().equals(this.type)){
- FileUtils.downLoadFromUrl(ConstantUrl.PREFIX_AWS + imgViewPath + "vision.modeldata" + "?m="+new Date().getTime(),
- "vision.modeldata", target + File.separator + "extras" + File.separator);
- }
- if(StorageType.OSS.code().equals(this.type)){
- FileUtils.downLoadFromUrl(prefixAli + imgViewPath + "vision.modeldata" + "?m="+new Date().getTime(),
- "vision.modeldata", target + File.separator + "extras" + File.separator);
- }
- CreateObjUtil.convertVisionmodeldataToTxt(target + File.separator + "extras" + File.separator + "vision.modeldata",
- target + File.separator + "extras" + File.separator + "vision.txt");
- 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 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(scenePlusExt.getSceneScheme() == 11){
- dataJson.put("skybox_type", "SKYBOX_V7");
- }
- dataJson.put("split_type", "SPLIT_V8");
- //sceneScheme为3切成瓦片图
- if(scenePlusExt.getSceneScheme() == 3){
- dataJson.put("skybox_type", "SKYBOX_V4");
- }
- FileUtils.writeFile(target + File.separator+"data.json", new String(dataJson.toString().getBytes(), "UTF-8"));
- }
- 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");
- }
- if(StorageType.AWS.code().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");
- String uploadJsonPath= target + File.separator + "results" +File.separator+"upload.json";
- Thread.sleep(2000);
- 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");
- }
- if(array == null){
- throw new BusinessException(ErrorCode.FAILURE_CODE_7013);
- }
- JSONObject fileJson = null;
- String fileName = "";
- 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 + "文件不存在");
- }
- //high文件夹
- if (fileJson.getIntValue("clazz") == 3) {
- map.put(target + File.separator + "results" + File.separator + fileName,
- imgViewPath + "pan/high/" + fileName.replace("high/", ""));
- continue;
- }
- //low文件夹
- if (fileJson.getIntValue("clazz") == 4) {
- map.put(target + File.separator + "results" + File.separator + fileName,
- imgViewPath + "pan/low/" + fileName.replace("low/", ""));
- continue;
- }
- //tiles文件夹,亚马逊没有裁剪图片api,不需要上传4k图
- if (fileJson.getIntValue("clazz") == 5) {
- map.put(target + File.separator + "results" + File.separator + fileName,
- imgViewPath + fileName);
- continue;
- }
- //tiles文件夹,亚马逊瓦片图
- if (fileJson.getIntValue("clazz") == 7) {
- map.put(target + File.separator + "results" + File.separator + fileName,
- imgViewPath + fileName);
- continue;
- }
- }
- if(map.size()>0) {
- uploadToOssUtil.uploadMulFiles(map);
- }
- //更新版本号
- SceneEditInfo sceneEditInfo = this.getByScenePlusId(scenePlus.getId());
- this.upgradeVersionById(sceneEditInfo.getId());
- //如果部分成功,则需要返回成功数量和失败列表
- if(CollUtil.isNotEmpty(notExistFileList)){
- notExistFileList = notExistFileList.stream().map(filePath -> {
- return filePath.substring(filePath.lastIndexOf(File.separator) + 1);
- }).collect(Collectors.toList());
- return ResultData.ok(new UploadPanoramaVO(uploadFileList.size(), notExistFileList));
- }
- return ResultData.ok();
- }
- @Override
- public ResultData downloadPanorama(FileParamVO param) throws Exception {
- String num = param.getNum();
- String fileName = param.getFileName();
- String cachePath = String.format(ConstantFilePath.SCENE_CACHE, num);
- String imgCachePath = String.format(UploadFilePath.IMG_CACHES_PATH, num);
- String localImagesPath = String.format(ConstantFilePath.SCENE_CACHE_IMAGES, num);
- String cacheFormat = "downloads/scene/%s/caches/";
- String cacheImageFormat = "downloads/scene/%s/caches/images/";
- String url = null;
- String downloadName = null;
- //删除本地文件
- FileUtils.deleteDirectory(localImagesPath);
- //如果入参文件名不为空,则是单个文件下载,不需要打包
- boolean single = true;
- if(StrUtil.isNotEmpty(fileName)){
- //如果是单张图片,直接提供oss url
- if (!StorageType.LOCAL.code().equals(this.type)) {
- String filePath = imgCachePath + fileName;
- url = ossUrlPrefix + filePath;
- // FileUtils.downLoadFromUrl(imageUrl, fileName, localImagesPath);
- }
- downloadName = fileName;
- }else{
- single = false;
- //先下载到本地
- List<String> keyList = uploadToOssUtil.listKeys(imgCachePath);
- if (!StorageType.LOCAL.code().equals(this.type)) {// TODO: 2022/2/15 这里有可能有问题,可能还需要考虑本地部署的情况
- keyList.stream().forEach(key->{
- String file = key.substring(key.lastIndexOf("/") + 1);
- String imageUrl = ossUrlPrefix + imgCachePath + file + "?t=" + System.currentTimeMillis();
- FileUtils.downLoadFromUrl(imageUrl, file, localImagesPath);
- });
- }
- }
- if(!single){
- downloadName = num + "_images.zip";
- //打包
- String zipPath = cachePath + downloadName;
- FileUtils.zipFile(zipPath, localImagesPath);
- //上传压缩包
- uploadToOssUtil.upload(zipPath, String.format(cacheFormat, num) + downloadName);
- url = ossUrlPrefix + String.format(cacheFormat, num) + downloadName;
- //删除本地压缩包
- FileUtils.deleteFile(zipPath);
- //删除本地目录
- FileUtils.deleteDirectory(localImagesPath);
- }
- Map<String, Object> map = new HashMap<>();
- map.put("fileUrl", url + "?t=" + System.currentTimeMillis());
- map.put("fileName", downloadName);
- return ResultData.ok(map);
- }
- @Override
- public void saveTagsToSceneEditInfo(String num, SceneEditInfo sceneEditInfo){
- //查询缓存是否包含热点数据
- String key = String.format(RedisKey.SCENE_HOT_DATA, num);
- Map<String, String> allTagsMap = redisUtil.hmget(key);
- boolean hashTags = false;
- for (Entry<String, String> tagMap : allTagsMap.entrySet()) {
- if(StrUtil.isEmpty(tagMap.getValue())){
- continue;
- }
- hashTags = true;
- break;
- }
- //更改热点状态
- sceneEditInfo.setTags(hashTags ? CommonStatus.YES.code() : CommonStatus.NO.code());
- //version 是空的代表 sceneEditInfo记录集不存在
- if(sceneEditInfo.getVersion() != null){
- sceneEditInfo.setVersion(sceneEditInfo.getVersion() + 1);
- }
- }
- @Override
- public ResultData saveVideoBox(FileNameAndDataParamVO param) throws Exception {
- JSONObject boxVideo = JSONObject.parseObject(param.getData());
- String sid = boxVideo.getString("sid");
- if(StrUtil.isEmpty(sid)){
- throw new BusinessException(ErrorCode.PARAM_REQUIRED);
- }
- // ScenePro scenePro = sceneProService.findBySceneNum(param.getNum());
- ScenePlus scenePlus = scenePlusService.getScenePlusByNum(param.getNum());
- if(Objects.isNull(scenePlus))
- throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
- SceneEditInfo sceneEditInfo = this.getByScenePlusId(scenePlus.getId());
- //转换视频格式
- this.transferToFlv(param.getNum(), param.getFileName());
- //生成boxVideos数据
- String boxVideos = this.createBoxVideos(sid, boxVideo, sceneEditInfo, OperationType.ADDORUPDATE.code());
- //更新数据库
- this.updateBoxVideos(sceneEditInfo, scenePlus.getId(), boxVideos);
- return ResultData.ok();
- }
- @Override
- public ResultData deleteVideoBox(DeleteSidParamVO param) throws Exception {
- // ScenePro scenePro = sceneProService.findBySceneNum(param.getNum());
- ScenePlus scenePlus = scenePlusService.getScenePlusByNum(param.getNum());
- if(Objects.isNull(scenePlus))
- throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
- SceneEditInfo sceneEditInfo = this.getByScenePlusId(scenePlus.getId());
- //根据sid移除json
- String boxVideos = this.createBoxVideos(param.getSid(), null, sceneEditInfo, OperationType.DELETE.code());
- //写数据库
- this.updateBoxVideos(sceneEditInfo,scenePlus.getId(),boxVideos);
- return ResultData.ok();
- }
- @Override
- public ResultData saveBoxPhoto(BaseDataParamVO param){
- JSONObject boxPhoto = JSONObject.parseObject(param.getData());
- String sid = boxPhoto.getString("sid");
- if(StrUtil.isEmpty(sid)){
- throw new BusinessException(ServerCode.PARAM_REQUIRED, sid);
- }
- ScenePlus scenePlus = scenePlusService.getScenePlusByNum(param.getNum());
- if(Objects.isNull(scenePlus))
- throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
- SceneEditInfo sceneEditInfo = this.getByScenePlusId(scenePlus.getId());
- //生成boxVideos数据
- String boxPhotos = this.createBoxPhotos(sid, boxPhoto, sceneEditInfo, OperationType.ADDORUPDATE.code());
- //更新数据库
- this.updateBoxPhotos(sceneEditInfo, boxPhotos);
- return ResultData.ok();
- }
- @Override
- public ResultData deleteBoxPhoto(DeleteSidParamVO param){
- ScenePlus scenePlus = scenePlusService.getScenePlusByNum(param.getNum());
- if(Objects.isNull(scenePlus))
- throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
- SceneEditInfo sceneEditInfo = this.getByScenePlusId(scenePlus.getId());
- //根据sid移除json
- String boxPhotos = this.createBoxPhotos(param.getSid(), null, sceneEditInfo, OperationType.DELETE.code());
- //写数据库
- this.updateBoxPhotos(sceneEditInfo, boxPhotos);
- return ResultData.ok();
- }
- @Override
- public DownloadVO downloadBallScreenVideo(BallScreenVideoParamVO param) {
- String videoPath = String.format(UploadFilePath.VIDEOS_VIEW_PATH, param.getNum()) + param.getFileName();
- String url = ossUrlPrefix + videoPath + "?t=" + System.currentTimeMillis();
- return DownloadVO.builder()
- .fileName(param.getFileName())
- .url(url)
- .build();
- }
- @Override
- public ResultData uploadBallScreenVideo(String num, String fileName, MultipartFile file) throws Exception {
- //校验格式
- if(!fileName.endsWith(".mp4")){
- throw new BusinessException(ErrorCode.FAILURE_CODE_7016);
- }
- String videosViewPath = String.format(UploadFilePath.VIDEOS_VIEW_PATH, num);
- // ScenePro scenePro = sceneProService.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();
- //校验文件名
- String videos = scenePlusExt.getVideos();
- if(StrUtil.isEmpty(videos)){
- throw new BusinessException(ErrorCode.FAILURE_CODE_7012);
- }
- JSONObject videosJson = JSON.parseObject(videos);
- JSONArray dataArr = videosJson.getJSONArray("data");
- boolean exists = false;
- for (Object o : dataArr) {
- JSONObject jsonObject = (JSONObject)o;
- if(jsonObject.getString("id").equals(fileName.replace(".mp4", ""))){
- exists = true;
- break;
- }
- }
- if(!exists){
- throw new BusinessException(ErrorCode.FAILURE_CODE_7012);
- }
- 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 = target + File.separator + "extras/video" + File.separator + fileName;
- File targetFile = new File(filePath);
- if(!targetFile.getParentFile().exists()){
- targetFile.getParentFile().mkdirs();
- }
- //保存视频到本地
- file.transferTo(targetFile);
- File video = new File(target + File.separator + "extras/video");
- //如果文件夹或者文件不存在,跳出
- if(!video.exists() || video.listFiles() == null || video.listFiles().length == 0){
- throw new BusinessException(ErrorCode.FAILURE_CODE_7009);
- }
- for(String videoName : video.list()){
- log.info("球幕视频名称:{}", videoName);
- uploadToOssUtil.upload(target + File.separator + "extras/video/" + videoName,videosViewPath + videoName);
- CreateObjUtil.mp4ToFlv(target + File.separator + "extras/video/" + videoName,
- target + File.separator + "extras/video/" + videoName.replace("mp4", "flv"));
- uploadToOssUtil.upload(target + File.separator + "extras/video/" + videoName.replace("mp4", "flv"),videosViewPath + videoName.replace("mp4", "flv"));
- //覆盖原始视频资源
- FileUtils.copyFile(target + File.separator + "extras/video/" + videoName,
- path + File.separator + "caches/videos/" + videoName, true);
- }
- FileUtils.deleteDirectory(target + File.separator + "extras/video/");
- SceneEditInfo sceneEditInfo = this.getByScenePlusId(scenePlus.getId());
- this.upgradeVersionById(sceneEditInfo.getId());
- // SceneEditInfo sceneEditInfo = this.getBySceneProId(scenePro.getId());
- // if(sceneEditInfo == null){
- // sceneEditInfo = new SceneEditInfo();
- // sceneEditInfo.setSceneProId(scenePro.getId());
- // sceneEditInfo.setBuildVideoStatus(CommonStatus.YES.code());
- // this.save(sceneEditInfo);
- // }else{
- // sceneEditInfo.setBuildVideoStatus(CommonStatus.YES.code());
- // this.updateById(sceneEditInfo);
- // }
- return ResultData.ok();
- }
- @Override
- public ResultData sceneSync(String num, String type, String floorPlanJson, String ajkJson, String cameraJson,
- MultipartFile[] files) throws Exception {
- String lockKey = String.format(RedisLockKey.LOCK_SCENE_SYNC, num);
- Boolean lock = redisLockUtil.lock(lockKey, RedisKey.EXPIRE_TIME_2_HOUR);
- if(!lock){
- throw new BusinessException(ErrorCode.SYSTEM_BUSY);
- }
- try {
- // ScenePro scenePro = sceneProService.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());
- //更新scene.json文件
- String strsceneInfos = FileUtils.readFile(ConstantFilePath.SCENE_PATH + "data" + File.separator + "data" + num + File.separator + "scene.json");
- if(strsceneInfos == null)
- new File(ConstantFilePath.SCENE_PATH + "data" + File.separator + "data" + num + File.separator + "scene.json").createNewFile();
- String path = scenePlusExt.getDataSource();// /mnt/data/0662c5389/831989883441512448/4898cab04f8c_202104141602356060/
- if(path != null && !"".equals(path) && path.startsWith("http")){
- path = ConstantFilePath.BUILD_MODEL_PATH + File.separator + path.split("/")[path.split("/").length - 2];
- }
- String target = path + "_ajk"; // /mnt/data/0662c5389/831989883441512448/4898cab04f8c_202104141602356060_ajk
- File editPath = new File(target);
- if(!editPath.exists()){
- editPath.mkdirs();
- }
- //创建文件夹软连接并且复制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 + "caches").exists()){
- //删除link
- new File(target + File.separator + "caches" + File.separator + "images").delete();
- //删除所有文件
- FileUtils.delAllFile(target + File.separator + "caches");
- }
- if(new File(target + File.separator + "results").exists()){
- FileUtils.delAllFile(target + File.separator + "results");
- }
- //创建文件夹,并link文件夹
- new File(target + File.separator + "caches").mkdirs();
- CreateObjUtil.createSoftConnection(path + File.separator + "capture", target + File.separator + "capture");
- if(new File(path + File.separator + "caches" + File.separator + "images").exists()){
- CreateObjUtil.createSoftConnection(path + File.separator + "caches" + File.separator + "images", target + File.separator + "caches" + File.separator + "images");
- }
- 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 floorplanJson = new JSONObject();
- floorplanJson.put("has_floor_ajk_json", true);
- floorplanJson.put("has_vision_txt", true);
- floorplanJson.put("has_floorplan_json", true);
- JSONObject dataJson = JSONObject.parseObject(data);
- dataJson.put("extras", floorplanJson);
- //V5表示不需要生成high,low文件
- dataJson.put("skybox_type", "SKYBOX_V8");
- dataJson.put("split_type", "SPLIT_V10");
- FileUtils.writeFile(target + File.separator+"data.json", new String(dataJson.toString().getBytes(), "UTF-8"));
- }
- //文件上传的位置可以自定义
- log.info("画墙重建模型开始");
- File targetFile = new File(target + File.separator + "extras" + File.separator + "floor_ajk.json");
- if(!targetFile.getParentFile().exists()){
- targetFile.getParentFile().mkdirs();
- }
- if(targetFile.exists()){
- FileUtils.deleteFile(target + File.separator + "extras" + File.separator + "floor_ajk.json");
- }
- // 保存
- FileUtils.writeFile(target + File.separator + "extras" + File.separator + "floorplan.json", new String(floorPlanJson.getBytes(), "UTF-8"));
- FileUtils.writeFile(target + File.separator + "extras" + File.separator + "floor_ajk.json", new String(ajkJson.getBytes(), "UTF-8"));
- FileUtils.writeFile(ConstantFilePath.SCENE_PATH+"data"+File.separator+"data"+num + File.separator + "floor_ajk.json", new String(ajkJson.getBytes(), "UTF-8"));
- FileUtils.writeFile(target + File.separator + "extras" + File.separator + "vision.txt", new String(cameraJson.getBytes(), "UTF-8"));
- FileUtils.writeFile(ConstantFilePath.SCENE_PATH+"data"+File.separator+"data"+num + File.separator + "camera.json", new String(cameraJson.getBytes(), "UTF-8"));
- for(int i = 0; i < files.length; i ++){
- File cadImg = new File(target + File.separator + "extras" + File.separator + "Floorplans/" + files[i].getOriginalFilename());
- if(!cadImg.getParentFile().exists()){
- cadImg.getParentFile().mkdirs();
- }
- if(cadImg.exists())
- {
- cadImg.delete();
- }
- files[i].transferTo(cadImg);
- }
- //下载封面图
- FileUtils.downLoadFromUrl(scenePlusExt.getThumb() + "?t=" + System.currentTimeMillis(),
- "Cover.png", target + File.separator + "extras" + File.separator + "CoverImage");
- //转换成jpg
- FileUtils.pngToJpg(target + File.separator + "extras" + File.separator + "CoverImage/Cover.png",
- target + File.separator + "extras" + File.separator + "CoverImage/Cover.jpg");
- //安居客算法运行
- log.info("安居客算法:开始建模——"+num);
- CreateObjUtil.build3dModel(target , "1");
- String uploadJsonPath = target + File.separator + "results" + File.separator + "upload.json";
- log.info("uploadJsonPath=" + uploadJsonPath);
- //因为共享目录有延迟,这里循环检测算法是否计算完毕3次,每次隔五秒
- boolean exist = ComputerUtil.checkComputeCompleted(uploadJsonPath, maxCheckTimes, waitTime);
- if(!exist){
- throw new BusinessException(ErrorCode.FAILURE_CODE_7017);
- }
- String zipPath = target + File.separator + "results/" + num + ".zip";
- new File(zipPath).delete();
- FileUtils.zipFile(zipPath, target + File.separator + "results/ajk/");
- // String command = "bash /opt/ossutil/gzip.sh " + zipPath.replace(".zip", "") + " " + target + File.separator + "results/ajk/";
- // log.info("压缩文件:" + command);
- // CreateObjUtil.callshell(command);
- if(!new File(zipPath).exists()){
- return ResultData.error(ErrorCode.FAILURE_CODE_5043);
- }
- String fileMD5 = FileMd5Util.getFileMD5(new File(zipPath));
- uploadToOssUtil.upload(zipPath, "data_download/" + num + ".zip");
- SceneDataDownload sceneDataDownload = sceneDataDownloadService.findBySceneNum(num);
- if(sceneDataDownload == null){
- sceneDataDownload = new SceneDataDownload();
- sceneDataDownload.setNum(num);
- sceneDataDownload.setDownloadPath(prefixAli + "data_download/" + num + ".zip");
- sceneDataDownload.setFileMd5(fileMD5);
- sceneDataDownloadService.save(sceneDataDownload);
- return ResultData.ok();
- }
- sceneDataDownload.setFileMd5(fileMD5);
- sceneDataDownload.setUpdateTime(Calendar.getInstance().getTime());
- sceneDataDownloadService.updateById(sceneDataDownload);
- }catch (Exception e){
- log.error("画墙重建模型失败...", e);
- throw new BusinessException(ErrorCode.FAILURE_CODE_5039);
- }finally {
- redisLockUtil.unlockLua(lockKey);
- }
- return ResultData.ok();
- }
- @Override
- public ResultData checkKey(SceneCheckKeyParamVO param) throws Exception {
- String sceneJson = redisUtil.get(String.format(RedisKey.SCENE_JSON, param.getNum()));
- SceneJsonBean sceneJsonBean = JSON.parseObject(sceneJson, SceneJsonBean.class);
- if(!param.getPassword().equals(sceneJsonBean.getScenePassword())){
- throw new BusinessException(ErrorCode.FAILURE_CODE_5021);
- }
- return ResultData.ok();
- }
- private void updateBoxVideos(SceneEditInfo sceneEditInfo, Long scenePlusId, String boxVideos){
- if(Objects.isNull(sceneEditInfo)){
- sceneEditInfo = new SceneEditInfo();
- sceneEditInfo.setScenePlusId(scenePlusId);
- sceneEditInfo.setBoxVideos(boxVideos);
- this.save(sceneEditInfo);
- }else{
- this.update(new UpdateWrapper<SceneEditInfo>()
- .setSql("version = version + 1")
- .set("box_videos", boxVideos)
- .eq("id", sceneEditInfo.getId()));
- }
- }
- private void updateBoxPhotos(SceneEditInfo sceneEditInfo, String boxPhotos){
- this.update(new LambdaUpdateWrapper<SceneEditInfo>()
- .set(SceneEditInfo::getBoxPhotos, boxPhotos)
- .setSql("version = version + 1")
- .eq(SceneEditInfo::getId, sceneEditInfo.getId()));
- }
- private String createBoxVideos(String sid, JSONObject boxVideo, SceneEditInfo sceneEditInfo, int type){
- String boxVideos = null;
- if(sceneEditInfo != null){
- boxVideos = sceneEditInfo.getBoxVideos();
- }
- JSONArray boxVideosJson = null;
- if (StrUtil.isNotEmpty(boxVideos)) {
- boxVideosJson = JSONArray.parseArray(boxVideos);
- }else {
- boxVideosJson = new JSONArray();
- }
- String result = null;
- //删除
- if(type == OperationType.DELETE.code()){
- if(boxVideosJson.size() == 0)
- return null;
- for(int i=0;i<boxVideosJson.size();++i){
- JSONObject ele = boxVideosJson.getJSONObject(i);
- if(ele.getString("sid").equals(sid)){
- boxVideosJson.remove(i);
- }
- }
- }else{
- // TODO: 2022/3/1 目前需求只保留一个,所以这里先注释掉,sid不同时,不追加
- //更新
- // boolean exist = false;
- // for(int i=0;i<boxVideosJson.size();++i){
- // JSONObject ele = boxVideosJson.getJSONObject(i);
- // if(ele.getString("sid").equals(sid)){
- // boxVideosJson.set(i, boxVideo);
- // exist = true;
- // }
- // }
- // //新增
- // if(!exist){
- // boxVideosJson.add(boxVideo);
- // }
- boxVideosJson.clear();
- boxVideosJson.add(boxVideo);
- }
- if(boxVideosJson.size() != 0){
- result = boxVideosJson.toJSONString();
- }
- return result;
- }
- private String createBoxPhotos(String sid, JSONObject boxPhoto, SceneEditInfo sceneEditInfo, int type){
- String boxPhotos = null;
- if(sceneEditInfo != null){
- boxPhotos = sceneEditInfo.getBoxPhotos();
- }
- JSONArray boxPhotosJson = null;
- if (StrUtil.isNotEmpty(boxPhotos)) {
- boxPhotosJson = JSONArray.parseArray(boxPhotos);
- }else {
- boxPhotosJson = new JSONArray();
- }
- String result = null;
- //删除
- if(type == OperationType.DELETE.code()){
- if(boxPhotosJson.size() == 0)
- return null;
- for(int i=0;i<boxPhotosJson.size();++i){
- JSONObject ele = boxPhotosJson.getJSONObject(i);
- if(ele.getString("sid").equals(sid)){
- boxPhotosJson.remove(i);
- }
- }
- }else{
- //更新
- boolean exist = false;
- for(int i=0;i<boxPhotosJson.size();++i){
- JSONObject ele = boxPhotosJson.getJSONObject(i);
- if(ele.getString("sid").equals(sid)){
- boxPhotosJson.set(i, boxPhoto);
- exist = true;
- }
- }
- //新增
- if(!exist){
- boxPhotosJson.add(boxPhoto);
- }
- }
- if(boxPhotosJson.size() != 0){
- result = boxPhotosJson.toJSONString();
- }
- return result;
- }
- private void transferToFlv(String num, String fileName) throws Exception {
- String userEditPath = String.format(UploadFilePath.USER_EDIT_PATH, num);
- String localImagesPath = String.format(ConstantFilePath.IMAGESBUFFER_FORMAT, num);
- String localFilePath = localImagesPath + fileName;
- File targetFile = new File(localImagesPath);
- if (!targetFile.exists()){
- targetFile.mkdirs();
- }
- targetFile = new File(localFilePath);
- if (targetFile.exists()){
- FileUtils.deleteFile(localFilePath);
- }
- //从用户编辑目录中下载视频到本地
- if (!StorageType.LOCAL.code().equals(this.type)) {
- String filePath = userEditPath + fileName;
- String imageUrl = ossUrlPrefix + filePath + "?t=" + System.currentTimeMillis();
- FileUtils.downLoadFromUrl(imageUrl, fileName, localImagesPath);
- }
- //视频格式转换
- CreateObjUtil.mp4ToFlv(localFilePath, localFilePath.replace("mp4", "flv"));
- //上传
- String flvFileName = fileName.replace("mp4", "flv");
- uploadToOssUtil.upload(localFilePath, userEditPath + fileName);
- uploadToOssUtil.upload(localFilePath.replace("mp4", "flv"), userEditPath+flvFileName);
- }
- }
|