project-tieta-convert/src/main/java/com/fdkankan/modeldemo/utils/ConvertUtil.java

package com.fdkankan.modeldemo.utils;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.io.FileUtil;
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.fdkankan.modeldemo.bean.SceneEditControlsBean;
import com.fdkankan.modeldemo.bean.SceneJsonBean;
import com.fdkankan.modeldemo.bean.TagBean;
import com.fdkankan.modeldemo.constant.Constant;
import com.fdkankan.modeldemo.constant.RedisKey;
import com.fdkankan.modeldemo.entity.*;
import com.fdkankan.modeldemo.service.*;
import com.fdkankan.redis.RedisClient;
import com.google.common.collect.Lists;
import com.google.common.collect.Sets;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.io.File;
import java.nio.charset.StandardCharsets;
import java.util.*;
import java.util.stream.Collectors;

@Slf4j
@Component
public class ConvertUtil {

    private static String RESULTS_DIR = "results";

    private static String DATA_DIR = "data";

    private static String WALLS = "walls";

    private static String SUBGROUP = "subgroup";

    private static String JSON_EXTNAME = ".json";

    private static String IMAGES_4K = "images/4k/";

    private static String IMAGES_512 = "images/512/";

    private static String IMAGES_8K = "images/8k/";

    private static String TITLE = "title";

    private final static String SHOOTTIME = "shootTime";

    private static String extinguisherJson = "extinguisher.json";



    @Autowired
    private SceneService sceneService;

    @Autowired
    private SceneFileMappingService sceneFileMappingService;
    @Resource
    private FdfsUtil fdfsUtil;
    @Resource
    private RedisClient redisClient;
    @Autowired
    private SceneEditInfoService sceneEditInfoService;
    @Autowired
    private SceneEditInfoExtService sceneEditInfoExtService;
    @Autowired
    private SceneEditControlsService sceneEditControlsService;
    @Resource
    private FYunFileService fYunFileService;

    private static String[] convertVisableHandler(JSONArray visibles, Map<Integer, String> uuidMap){
        int size = visibles.size();
        String[] visibleArr = new String[size];
        for(int j = 0; j < size; j++){
            int index = (Integer)visibles.get(j);
            String uuid = uuidMap.get(index);
            visibleArr[j] = uuid;
        }
        return visibleArr;
    }
    public static void main(String[] args) throws Exception {
        String test = "D:\\test\\111.json";
        if(FileUtil.exist(test)){
            String extinguisherStr = FileUtil.readUtf8String(test);
            JSONObject jsonObject = JSON.parseObject(extinguisherStr);
            JSONArray imgBoxsList = jsonObject.getJSONArray("imgBoxsList");
            boolean existExtinguisher = imgBoxsList.stream().anyMatch(box -> {
                JSONObject boxObj = (JSONObject) box;
                JSONArray shapes = boxObj.getJSONArray("shapes");
                return shapes.stream().anyMatch(shape -> {
                    JSONObject shapeObj = (JSONObject) shape;
                    if ("1111".equals(shapeObj.getString("category"))) {
                        return true;
                    }
                    return false;
                });
            });
            System.out.println(existExtinguisher);
        }
    }

    public Map<String, String> convert(String sourcePath, String num, String stationCode, Date upTime, String convertType, String upTimeKey) throws Exception {

        Map<String, String> map = new HashMap<>();
        String dataViewPath = String.format(Constant.DATA_VIEW_PATH, num);
        String imgViewPath = String.format(Constant.IMG_VIEW_PATH, num);

        String obj2TxtPath = null;

        if(!sourcePath.endsWith(File.separator)){
            sourcePath = sourcePath + File.separator;
        }
        obj2TxtPath = sourcePath.substring(0, sourcePath.length() - 1) + "_obj2txt";
        FileUtil.mkdir(obj2TxtPath);
        //调用算法生成modeldata.txt
        String extrasPath = obj2TxtPath + File.separator + "extras";
        FileUtil.mkdir(extrasPath);
        FileUtil.copyContent(new File(sourcePath + DATA_DIR + File.separator + "mesh"), new File(extrasPath), true);

        //写data.json
        writeDataJson(obj2TxtPath);

        //调用算法建模
        build3dModel(obj2TxtPath);

        //校验算法是否正常结束
        String uploadJsonPath = obj2TxtPath + File.separator + RESULTS_DIR +File.separator+"upload.json";
        boolean success = checkComputeCompleted(uploadJsonPath, 5, 300);
        if(!success){
            throw new RuntimeException("计算失败,obj2TxtPath:" + obj2TxtPath);
        }

        String uploadData = FileUtil.readUtf8String(uploadJsonPath);
        JSONObject uploadJson = null;
        JSONArray array = null;
        if(uploadData!=null) {
            uploadJson = JSONObject.parseObject(uploadData);
            array = uploadJson.getJSONArray("upload");
        }
        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(obj2TxtPath + File.separator + RESULTS_DIR + File.separator + fileName).exists()) {
                throw new Exception(obj2TxtPath + File.separator + RESULTS_DIR + File.separator + fileName + "文件不存在");
            }

            //tex文件夹
            if (fileJson.getIntValue("clazz") == 15) {
//                    FileUtil.copy(obj2TxtPath + File.separator + RESULTS_DIR + File.separator + fileName,
//                            targetImagePath + File.separator + "tieta_texture/" + fileName.replace("tex/", ""),true);
                map.put(imgViewPath +  "tieta_texture/" + fileName.replace("tex/", ""), obj2TxtPath + File.separator + RESULTS_DIR + File.separator + fileName);

            }
        }

        //压缩成dam
        String damKey = imgViewPath + "tieta.dam";
        String damPath = obj2TxtPath + File.separator + RESULTS_DIR +File.separator + "dam.txt";
        CreateObjUtil.convertTxtToDam( obj2TxtPath + File.separator + RESULTS_DIR +File.separator+"modeldata.txt", damPath);
        map.put(damKey, damPath);

        //识别灭火器
        Integer extinguisher = this.getExtinguisher(num, sourcePath, map);

        //复制文件
        JSONObject standarFloor = null;
        Integer maxWallNum = 0;
        if(FileUtil.exist(sourcePath +  DATA_DIR + "/floorplan.json")){
            String floorplanJson = FileUtil.readUtf8String(sourcePath + DATA_DIR + "/floorplan.json");
            JSONObject jsonObject = JSON.parseObject(floorplanJson);
            Integer currentId = jsonObject.getInteger("currentId");
            if(Objects.nonNull(currentId) && currentId == 0){
                FileUtil.del(sourcePath + DATA_DIR + "/floorplan.json");
            }else{
                JSONArray floors = jsonObject.getJSONArray("floors");
                for (Object floor : floors) {
                    JSONObject floorObj = (JSONObject) floor;
                    Map walls = floorObj.getObject(WALLS, Map.class);
                    if(walls.keySet().size() > maxWallNum){
                        maxWallNum = walls.keySet().size();
                        standarFloor = floorObj;
                    }
                }
                //切割，按subgroup分成多份
                for (Object floor : floors) {
                    JSONObject floorObj = (JSONObject) floor;
                    Integer subgroup = floorObj.getIntValue(SUBGROUP);
                    floorObj.put(WALLS, standarFloor.getJSONObject(WALLS));
                    floorObj.put("points", standarFloor.getJSONObject("points"));
                    floorObj.put(SUBGROUP, 0);
                    floorObj.put("id", 0);
                    jsonObject.replace("floors", Arrays.asList(floorObj));
                    String floorplanPath = sourcePath + DATA_DIR + "/floorplan" + "-" + subgroup + JSON_EXTNAME;
                    FileUtil.writeUtf8String(jsonObject.toJSONString(), floorplanPath);
                }
            }
        }

        List<File> dataFiles = FileUtil.loopFiles(sourcePath +  DATA_DIR + "/");
        for (File dataFile : dataFiles) {
            if(dataFile.getAbsolutePath().contains("floorplan")){
                continue;
            }
            map.put(dataFile.getAbsolutePath().replace(sourcePath + DATA_DIR + "/", dataViewPath) , dataFile.getAbsolutePath());
        }

        String finalSourcePath = sourcePath;
        if(FileUtil.exist(finalSourcePath + IMAGES_4K)){
            FileUtil.listFileNames(sourcePath + IMAGES_4K).stream().forEach(v->{
                map.put(imgViewPath + "pan/high/" + v.replaceAll("-", ""), finalSourcePath + IMAGES_4K + v);
//                    FileUtil.copy(finalSourcePath + IMAGES_4K + v, targetImagePath + "/pan/high/" + v.replaceAll("-", ""), true);
            });
        }

        if(FileUtil.exist(finalSourcePath + IMAGES_512)){
            FileUtil.listFileNames(finalSourcePath + IMAGES_512).stream().forEach(v->{
                map.put(imgViewPath + "pan/low/" + v.replaceAll("-", ""), finalSourcePath + IMAGES_512 + v);
//                    FileUtil.copy(finalSourcePath + IMAGES_512 + v, targetImagePath + "/pan/low/" + v.replaceAll("-", ""), true);
            });
        }

        if(FileUtil.exist(finalSourcePath + IMAGES_8K)) {
            FileUtil.listFileNames(finalSourcePath + IMAGES_8K).stream().forEach(v -> {
                map.put(imgViewPath + "pan/8k/" + v.replaceAll("-", ""), finalSourcePath + IMAGES_8K + v);
//                    FileUtil.copy(finalSourcePath + IMAGES_8K + v, targetImagePath + "/pan/8k/" + v.replaceAll("-", ""), true);
            });

        }
//            FileUtil.copy(sourcePath + "images/vision.txt", targetImagePath + "/vision.txt", true);
        //单独上传一份全的vision.txt
        this.uploadVisionTxt(num, upTimeKey, sourcePath + "images/vision.txt");

        //生成vison.modeldata
        String visionStr = FileUtil.readUtf8String(sourcePath + "images/vision.txt");
        JSONObject visionObj = JSON.parseObject(visionStr);
        JSONArray sweepLocationsArr = visionObj.getJSONArray("sweepLocations");
        //分割中高低点位
        Map<Integer, List<String>> visibleMap = new HashMap();
        Map<Integer, List<JSONObject>> subgroupMap = new HashMap<>();
        for (Object item : sweepLocationsArr) {
            JSONObject obj = (JSONObject) item;
            int subgroup = obj.getIntValue(SUBGROUP);
            List<JSONObject> jsonObjects = subgroupMap.get(subgroup);
            if(jsonObjects == null){
                jsonObjects = new ArrayList<>();
                subgroupMap.put(subgroup, jsonObjects);
            }
            obj.put(SUBGROUP, 0);
            jsonObjects.add(obj);

            List<String> visible = visibleMap.get(subgroup);
            if(visible == null){
                visible = new ArrayList<>();
                visibleMap.put(subgroup, visible);
            }
            visible.add(obj.getString("uuid"));
        }

        for (Integer subgroup : subgroupMap.keySet()) {
            List<JSONObject> jsonObjects = subgroupMap.get(subgroup);
            List<String> uuidList = visibleMap.get(subgroup);
            for (JSONObject jsonObject : jsonObjects) {
                String uuid = jsonObject.getString("uuid");
                List<String> list = Lists.newArrayList(uuidList);
                list.remove(uuid);
                jsonObject.put("visibles",list);
                jsonObject.put("visibles2",list);
                jsonObject.put("visibles3",list);
            }
        }


        //生成场景标题
        JSONObject sceneBashInfo = this.getSceneBashInfo(num, sourcePath);

        //如果是高中低场景，需要上传三份数据
        for (Integer subgroup : subgroupMap.keySet()) {

            //拆分vision.txt
            String visionTxtPath = sourcePath + "images/vision" + "-" + subgroup + ".txt";
            String visionmodeldataPath = sourcePath + "images/visionmodeldata" + "-" + subgroup + ".txt";
            JSONObject visionTxtJson = new JSONObject();
            visionTxtJson.put("sweepLocations", subgroupMap.get(subgroup));
            FileUtil.writeUtf8String(visionTxtJson.toJSONString(), visionTxtPath);
            CreateObjUtil.convertTxtToVisionmodeldata(visionTxtPath, visionmodeldataPath);
            map.put(imgViewPath + "vision.modeldata", visionmodeldataPath);
            map.put(imgViewPath + "vision.txt", visionTxtPath);

            //拆分floorplan.json
            String floorplanPath = sourcePath + DATA_DIR + "/floorplan" + "-" + subgroup + JSON_EXTNAME;
            if(FileUtil.exist(floorplanPath)){
                map.put(dataViewPath + "floorplan.json", floorplanPath);
            }

            //生成scene.json
            String sceneJsonPath = sourcePath + DATA_DIR + "/scene" + "-" + subgroup + JSON_EXTNAME;
            SceneJsonBean sceneJsonBean = this.genSceneJson(num, sceneBashInfo.getString(TITLE), subgroup);
            FileUtil.writeUtf8String(JSON.toJSONString(sceneJsonBean), sceneJsonPath);
            map.put(dataViewPath + "scene.json", sceneJsonPath);

            String finalRoomId = num;
            map.keySet().stream().forEach(key->{
                List<SceneFileMapping> sceneFileMappingList = sceneFileMappingService.getByScene(finalRoomId, subgroup, upTimeKey, key);
                if(CollUtil.isNotEmpty(sceneFileMappingList)){
                    List<String> deleteIds = sceneFileMappingList.stream().map(v -> v.getId()).collect(Collectors.toList());
                    sceneFileMappingService.removeByIds(deleteIds);
                }
                SceneFileMapping sceneFileMapping = new SceneFileMapping();
                Map<String, String> mapping = fdfsUtil.uploadFile(map.get(key));
                sceneFileMapping.setNum(finalRoomId);
                sceneFileMapping.setFileid(mapping.get("file_id"));
                sceneFileMapping.setUrl(mapping.get("http_url"));
                sceneFileMapping.setKey(key);
                sceneFileMapping.setSubgroup(subgroup);
                sceneFileMapping.setUpTime(upTimeKey);
                sceneFileMappingService.save(sceneFileMapping);
            });


//            List<Scene> list = sceneService.list(new LambdaQueryWrapper<Scene>().eq(Scene::getNum, num).eq(Scene::getSubgroup, subgroup).eq(Scene::getUpTimeKey, upTimeKey));
//            Scene scene = null;
//            if(CollUtil.isEmpty(list)){
//                scene = new Scene();
//            }else{
//                if(list.size() > 1){
//                    sceneService.remove(new LambdaQueryWrapper<Scene>().eq(Scene::getNum, num));
//                    scene = new Scene();
//                }else{
//                    scene = list.get(0);
//                }
//            }

            Scene scene = new Scene();
            scene.setTitle(sceneBashInfo.getString(TITLE));
            scene.setNum(num);
            scene.setFloorlogosize(100);
            scene.setScenekind("pano");
            scene.setSceneresolution("4k");
            scene.setScenefrom("realsee");
            scene.setModelkind("dam");
            scene.setFloorplanangle(0);
            scene.setSubgroup(subgroup);
            scene.setStationcode(stationCode);
            scene.setShootTime(sceneBashInfo.getDate(SHOOTTIME));
            scene.setUpTime(upTime);
            scene.setAlgorithmTime(new Date());
            scene.setExtinguisher(extinguisher);
            scene.setUpTimeKey(upTimeKey);
            scene.setCacheKeyHasTime(1);
            sceneService.save(scene);

            SceneEditInfo sceneEditInfo = new SceneEditInfo();
            sceneEditInfo.setScenePlusId(scene.getId());
            sceneEditInfo.setTitle(scene.getTitle());
            sceneEditInfo.setDescription(scene.getDescription());
            sceneEditInfoService.save(sceneEditInfo);

            SceneEditInfoExt sceneEditInfoExt = new SceneEditInfoExt();
            sceneEditInfoExt.setScenePlusId(scene.getId());
            sceneEditInfoExt.setEditInfoId(sceneEditInfo.getId());
            sceneEditInfoExtService.save(sceneEditInfoExt);

            SceneEditControls sceneEditControls = new SceneEditControls();
            sceneEditControls.setEditInfoId(sceneEditInfo.getId());
            sceneEditControlsService.save(sceneEditControls);

            //同步热点
            this.keepHot(scene, sceneEditInfo);
        }

        return map;
    }

    private void keepHot(Scene scene, SceneEditInfo sceneEditInfo){

        String num = scene.getNum();
        String upTimeKey = scene.getUpTimeKey();
        Integer subgroup = scene.getSubgroup();

        //查询最新的历史场景
        Scene preScene = sceneService.getOne(new LambdaQueryWrapper<Scene>()
                .eq(Scene::getNum, num)
                .eq(Scene::getSubgroup, subgroup)
                .lt(Scene::getUpTimeKey, upTimeKey)
                .orderByDesc(Scene::getUpTimeKey).last("limit 1"));
        if(Objects.isNull(preScene)){
            return;
        }

        //查询是否有热点
        String key = String.format(RedisKey.SCENE_HOT_DATA, RedisKey.getNumStr(num, subgroup, preScene.getUpTimeKey(), preScene.getCacheKeyHasTime()));
        Map<String, String> allTagsMap = redisClient.hmget(RedisClient.scene_sys_code, key);
        if(CollUtil.isEmpty(allTagsMap)){
            return;
        }

        //如果有热点，复制redis和涉及的图片
        String newKey = String.format(RedisKey.SCENE_HOT_DATA, RedisKey.getNumStr(num, subgroup, upTimeKey, scene.getCacheKeyHasTime()));
        redisClient.hmset(RedisClient.scene_sys_code, newKey, allTagsMap);

        sceneEditInfo.setTags(1);
        sceneEditInfoService.updateById(sceneEditInfo);

        //组装热点数据
        for (String sid : allTagsMap.keySet()) {
            String hot = allTagsMap.get(sid);
            JSONObject jsonObject = JSON.parseObject(hot);
            String type = jsonObject.getString("type");
            if(!"image".equals(type) && !"video".equals(type) && !"audio".equals(type)){
                continue;
            }
            JSONObject media = jsonObject.getJSONObject("media");
            JSONArray mediaDetail = media.getJSONArray(type);
            List<String> keyList = mediaDetail.stream().map(v -> {
                JSONObject content = (JSONObject) v;
                String src = content.getString("src");
                return String.format(Constant.USER_VIEW_PATH, num) + src;
            }).collect(Collectors.toList());

            if(CollUtil.isNotEmpty(keyList)){
                List<SceneFileMapping> fileMappingList = sceneFileMappingService.getBySceneBatch(num, subgroup, preScene.getUpTimeKey(), keyList);
                if(CollUtil.isNotEmpty(fileMappingList)){
                    fileMappingList.stream().forEach(v->{
                        v.setId(null);
                        v.setUpTime(upTimeKey);
                    });
                    sceneFileMappingService.saveBatch(fileMappingList);
                }
            }
        }

        //发布热点
        this.publicHotData(scene);

        //复制icon
        //查询缓存是否包含icons
        String iconKey = String.format(RedisKey.SCENE_HOT_ICONS, RedisKey.getNumStr(num, subgroup, preScene.getUpTimeKey() ,preScene.getCacheKeyHasTime()));
        Set<String> icons = redisClient.sGet(RedisClient.scene_sys_code, iconKey);
        if(CollUtil.isNotEmpty(icons)){

            String newIconKey = String.format(RedisKey.SCENE_HOT_ICONS, RedisKey.getNumStr(num, subgroup, scene.getUpTimeKey() ,scene.getCacheKeyHasTime()));
            redisClient.sSet(RedisClient.scene_sys_code, newIconKey, icons);

            List<String> iconFileList = icons.stream().map(i -> {
                return String.format(Constant.USER_VIEW_PATH, num) + i;
            }).collect(Collectors.toList());

            if(CollUtil.isNotEmpty(iconFileList)){
                List<SceneFileMapping> fileMappingList = sceneFileMappingService.getBySceneBatch(num, subgroup, preScene.getUpTimeKey(), iconFileList);
                if(CollUtil.isNotEmpty(fileMappingList)){
                    fileMappingList.stream().forEach(v->{
                        v.setId(null);
                        v.setUpTime(scene.getUpTimeKey());
                    });
                    sceneFileMappingService.saveBatch(fileMappingList);
                }
            }
        }
    }

    private void publicHotData(Scene scene) {
        String sceneNum = scene.getNum();
        Integer subgroup = scene.getSubgroup();
        String upTime  = scene.getUpTimeKey();
        Integer cacheKeyHasTime = scene.getCacheKeyHasTime();

        String hotDataKey = String.format(RedisKey.SCENE_HOT_DATA, RedisKey.getNumStr(sceneNum, subgroup,upTime,cacheKeyHasTime));
        Map<String, String> hotMap = redisClient.hmget(RedisClient.scene_sys_code, hotDataKey);

        JSONArray tags = new JSONArray();
        if(CollUtil.isNotEmpty(hotMap)){
            List<TagBean> tagBeanList = hotMap.entrySet().stream().map(entry -> {
                JSONObject jsonObject = JSON.parseObject(entry.getValue());
                return TagBean.builder()
                        .createTime(jsonObject.getLong("createTime"))
                        .tag(jsonObject).build();
            }).collect(Collectors.toList());
            //按创建时间倒叙排序
            tagBeanList.sort(Comparator.comparingLong(TagBean::getCreateTime).reversed());

            //移除createTime字段
            tagBeanList.stream().forEach(tagBean -> {
                tags.add(tagBean.getTag());
            });
        }

        String hotJsonPath = String.format(Constant.USER_VIEW_PATH, sceneNum) + "hot.json";
        fYunFileService.uploadFile(sceneNum, subgroup, upTime, tags.toString().getBytes(StandardCharsets.UTF_8), hotJsonPath);
    }


    private Integer getExtinguisher(String num, String sourcePath, Map<String, String> map){
        int extinguisher = 0;
        try {
            String imgViewPath = String.format(Constant.IMG_VIEW_PATH, num);
            //灭火器标注识别
            String imagesPath = sourcePath + "images/";
            String annihilatorPath = imagesPath + "4k/";
            String cmd =  "bash /home/ubuntu/bin/PotreeConverter.sh tieta_det " + annihilatorPath + " /home/ubuntu/bin/model/best.onnx " + imagesPath + extinguisherJson;
            log.info("---------start extinguisher, cmd:{}", cmd);
            CmdUtils.callLineSh(cmd);
            log.info("---------end extinguisher, cmd:{}", cmd);
            if(FileUtil.exist(imagesPath + extinguisherJson)){
                map.put(imgViewPath + extinguisherJson, imagesPath + extinguisherJson);

                String extinguisherStr = FileUtil.readUtf8String(imagesPath + extinguisherJson);
                JSONObject jsonObject = JSON.parseObject(extinguisherStr);
                JSONArray imgBoxsList = jsonObject.getJSONArray("imgBoxsList");
                boolean existExtinguisher = imgBoxsList.stream().anyMatch(box -> {
                    JSONObject boxObj = (JSONObject) box;
                    JSONArray shapes = boxObj.getJSONArray("shapes");
                    if(CollUtil.isNotEmpty(shapes)){
                        return shapes.stream().anyMatch(shape -> {
                            JSONObject shapeObj = (JSONObject) shape;
                            if ("extinguisher".equals(shapeObj.getString("category"))) {
                                return true;
                            }
                            return false;
                        });
                    }
                    return false;
                });
                if(existExtinguisher){
                    extinguisher = 1;
                }
            }
        }catch (Exception e){
            log.error("getExtinguisher fail, num:{}", num, e);
        }
        return extinguisher;
    }

    private void uploadVisionTxt(String num, String upTime, String localVisionTxtPath){
        String key = String.format(Constant.IMG_VIEW_PATH, num) + "vision.txt";
        List<SceneFileMapping> sceneFileMappingList = sceneFileMappingService.getByScene(num, -1, upTime, key);
        if(CollUtil.isNotEmpty(sceneFileMappingList)){
            List<String> deleteIds = sceneFileMappingList.stream().map(v -> v.getId()).collect(Collectors.toList());
            sceneFileMappingService.removeByIds(deleteIds);
        }
        SceneFileMapping sceneFileMapping = new SceneFileMapping();
        Map<String, String> mapping = fdfsUtil.uploadFile(localVisionTxtPath);//sourcePath + "images/vision.txt"
        sceneFileMapping.setNum(num);
        sceneFileMapping.setFileid(mapping.get("file_id"));
        sceneFileMapping.setUrl(mapping.get("http_url"));
        sceneFileMapping.setKey(key);
        sceneFileMapping.setSubgroup(-1);
        sceneFileMapping.setUpTime(upTime);
        sceneFileMappingService.save(sceneFileMapping);
    }

    private SceneJsonBean genSceneJson(String roomId, String title, Integer subgroup){
        SceneEditControlsBean sceneEditControlsBean = SceneEditControlsBean.builder()
                .showDollhouse(1).showMap(1).showPanorama(1).showVR(1).showTitle(1).showFloorplan(1).build();

        SceneJsonBean sceneJsonBean = SceneJsonBean.builder()
                .title(title).description(null)
                .num(roomId).subgroup(subgroup).floorLogoSize(100).sceneKind("pano")
                .sceneResolution("4k").sceneFrom("realsee")
                .modelKind("dam").floorPlanAngle(0).controls(sceneEditControlsBean).build();

        return sceneJsonBean;

    }

    private JSONObject getSceneBashInfo(String roomId, String sourcePath){
        JSONObject info = new JSONObject();
        String sceneJsonPath =  sourcePath + DATA_DIR + "/scene.json";
        if(!FileUtil.exist(sceneJsonPath)){
            return info;
        }
        String sceneJsonStr = FileUtil.readUtf8String(sceneJsonPath);
        JSONObject jsonObject = JSON.parseObject(sceneJsonStr);
        String title = jsonObject.getString(TITLE);
        if(StrUtil.isEmpty(title)){
            title = roomId;
        }
        info.put(TITLE, title);
        String shootTimeStr = jsonObject.getString(SHOOTTIME);
        if(StrUtil.isNotEmpty(shootTimeStr)){
            info.put(SHOOTTIME, DateUtil.parse(shootTimeStr, DatePattern.NORM_DATETIME_FORMAT));
        }

        return info;
    }

    public static void writeDataJson(String path){
        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");
        FileUtil.writeUtf8String(dataJson.toString(), path + File.separator + "data.json");
    }

    public static void build3dModel(String folderName) throws Exception {
        System.out.println("开始建模");
        String command = "sudo bash /home/ubuntu/bin/Launcher.sh " + folderName;
        CmdUtils.callLineSh(command);
        System.out.println("计算完毕：" + command);
    }

    public static boolean checkComputeCompleted(String uploadJsonPath, int maxCheckTimes, long waitTime) throws Exception {
        int checkTimes = 1;
        boolean exist = false;

        do {
            if ((new File(uploadJsonPath)).exists()) {
                exist = true;
                break;
            }

            Thread.sleep(waitTime);
            ++checkTimes;
        } while(checkTimes <= maxCheckTimes);

        return exist;
    }

}